From 0ca816c15a5259776fb4d98f48f934ee07a3494e Mon Sep 17 00:00:00 2001 From: Konrad Feldmeier Date: Thu, 7 Jan 2021 13:26:18 +0100 Subject: [PATCH] Join broadcast queue when stopping raiden_service --- raiden/network/transport/matrix/transport.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/raiden/network/transport/matrix/transport.py b/raiden/network/transport/matrix/transport.py index 4a3c27e6b1..b5484aa38a 100644 --- a/raiden/network/transport/matrix/transport.py +++ b/raiden/network/transport/matrix/transport.py @@ -567,6 +567,8 @@ def stop(self) -> None: if self._stop_event.ready(): return self.log.debug("Matrix stopping") + # Ensure, we send all broadcast messages before shutting down + self._broadcast_queue.join() self._stop_event.set() self._broadcast_event.set()