Skip to content
Snippets Groups Projects
Commit c83c06e8 authored by Piotr Maślanka's avatar Piotr Maślanka
Browse files

careful adjustment for the race condition I just had on PyPy

parent beef1b1e
No related branches found
No related tags found
No related merge requests found
......@@ -176,11 +176,11 @@ class Connection(object):
self.watch_for_method(0, (ConnectionClose, ConnectionCloseOk),
self.on_connection_close)
self.sendf = SendingFramer(self.listener_socket.send)
Handshaker(self, self.node_definition, self.on_connected, self.extra_properties)
self.listener_socket = self.listener_thread.register(sock,
on_read=self.recvf.put,
on_fail=self.on_fail)
self.sendf = SendingFramer(self.listener_socket.send)
def on_fail(self):
"""
......
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