From b4ce41caa10ac85b38f9a5da8170fe8a26e8bade 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 19:08:01 +0100
Subject: [PATCH] trying to solve that race condition
---
coolamqp/uplink/listener/thread.py | 3 +++
1 file changed, 3 insertions(+)
diff --git a/coolamqp/uplink/listener/thread.py b/coolamqp/uplink/listener/thread.py
index 7fda4fe..c7cad12 100644
--- a/coolamqp/uplink/listener/thread.py
+++ b/coolamqp/uplink/listener/thread.py
@@ -38,6 +38,9 @@ class ListenerThread(threading.Thread):
"""Called before start. It is not safe to fork after this"""
self.listener = EpollListener()
+ def activate(self, sock):
+ self.listener.activate(sock)
+
def run(self):
while not self.terminating:
self.listener.wait(timeout=1)
--
GitLab