diff --git a/owrx/connection.py b/owrx/connection.py index f3e951e..ac9c35c 100644 --- a/owrx/connection.py +++ b/owrx/connection.py @@ -37,6 +37,11 @@ class Client(ABC): self.send(data) except (EOFError, OSError): run = False + except Exception: + logger.exception("Exception on client multiprocessing queue") + + # unset the queue object to free shared memory file descriptors + self.multiprocessingPipe = None threading.Thread(target=mp_passthru).start()