From c83c06e8ba53174ae9d0a7f4f3ccc443a2e586b6 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Piotr=20Ma=C5=9Blanka?= <piotr.maslanka@henrietta.com.pl>
Date: Fri, 3 Jan 2020 18:55:02 +0100
Subject: [PATCH] careful adjustment for the race condition I just had on PyPy
---
coolamqp/uplink/connection/connection.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/coolamqp/uplink/connection/connection.py b/coolamqp/uplink/connection/connection.py
index cf99595..78f5e07 100644
--- a/coolamqp/uplink/connection/connection.py
+++ b/coolamqp/uplink/connection/connection.py
@@ -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):
"""
--
GitLab