Explorar o código

handle disconnected messages with lowest priority

When we can't keep up with the messages in the queue, we don't want to
talk to any additional peers.
Malte Kraus %!s(int64=8) %!d(string=hai) anos
pai
achega
80ecd7595b
Modificáronse 1 ficheiros con 1 adicións e 1 borrados
  1. 1 1
      src/protocol.py

+ 1 - 1
src/protocol.py

@@ -114,7 +114,7 @@ class PeerConnection:
                 self.outgoing_msgs.get_nowait()
             self.outgoing_msgs.put(None)
             self.is_connected = False
-            self.proto.received("disconnected", None, self)
+            self.proto.received("disconnected", None, self, 3)
 
             self.socket.close()