From 0926bf7b73e910f8700761367ea9ab5431b53864 Mon Sep 17 00:00:00 2001
From: Jeffrey Wigger <jeffrey.wigger@epfl.ch>
Date: Sat, 21 May 2022 22:47:24 +0200
Subject: [PATCH] working reliably 2
---
src/decentralizepy/communication/TCPRandomWalk.py | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/src/decentralizepy/communication/TCPRandomWalk.py b/src/decentralizepy/communication/TCPRandomWalk.py
index 98fd8e3..b66b645 100644
--- a/src/decentralizepy/communication/TCPRandomWalk.py
+++ b/src/decentralizepy/communication/TCPRandomWalk.py
@@ -305,9 +305,11 @@ class TCPRandomWalk(TCPRandomWalkBase):
"""
print("disconnect_neighbors")
+ self.flag_running.value = 0
+ time.sleep(4)
self.send_queue.close() # this crashes
self.recv_queue.close()
- self.flag_running.value = 0
+
#del self.lock
self.send_queue.join_thread()
self.recv_queue.join_thread()
--
GitLab