Skip to content
Snippets Groups Projects
Commit a425f22d authored by phil's avatar phil Committed by Guillaume Valadon
Browse files

TCPListenPipe sends address tuple instead of its repr() ; trigger before emptying the queue

parent 07dc5b67
No related branches found
No related tags found
No related merge requests found
......@@ -200,16 +200,16 @@ class TCPListenPipe(TCPConnectPipe):
self._send(self.fd.recv(65536))
else:
fd,frm = self.fd.accept()
self._high_send(repr(frm))
self._high_send(frm)
self.fd.close()
self.fd = fd
self.connected = True
self._trigger(frm)
while True:
try:
self.fd.send(self.q.get(block=False))
except Queue.Empty:
break
self._trigger(repr(frm))
class TriggeredMessage(Drain):
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment