cs.packetstream: PacketConnection shutdown: only warn about uncollected packeted if they are not ERQ or EOF
1 files changed, 8 insertions(+), 4 deletions(-)

M lib/python/cs/packetstream.py
M lib/python/cs/packetstream.py +8 -4
@@ 461,11 461,11 @@ class PacketConnection(MultiOpenMixin):
               self._sendQ.close(enforce_final_close=True)
               self._send_thread.join()
             if not self._sendQ.empty():
-              warning(
-                  "%s: EXTRA unsent items in _sentQ %s:", self, self._sendQ
-              )
               n_extra = 0
               for item in self._sendQ:
+                if item in (PacketConnection.EOF_Packet,
+                            PacketConnection.ERQ_Packet):
+                  continue
                 n_extra += 1
                 warning(
                     "  EXTRA %s:%s %s",

          
@@ 477,7 477,11 @@ class PacketConnection(MultiOpenMixin):
                         if item == PacketConnection.ERQ_Packet else ""
                     ),
                 )
-              assert n_extra > 0
+              if n_extra > 0:
+                warning(
+                    "%s: %d EXTRA unsent items in _sentQ %s", self, n_extra,
+                    self._sendQ
+                )
             with run_task(
                 "%s: wait for _recv_thread %s" % (
                     self,