From 57a61f0c40ccbcee36759b7088bb898e8da0cd8e Mon Sep 17 00:00:00 2001 From: Jakob Ketterl Date: Sun, 8 Dec 2019 21:11:36 +0100 Subject: [PATCH] close connection when queue overflows --- owrx/connection.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/owrx/connection.py b/owrx/connection.py index 523763d..ce05f07 100644 --- a/owrx/connection.py +++ b/owrx/connection.py @@ -7,6 +7,7 @@ from owrx.bookmarks import Bookmarks from owrx.map import Map from owrx.locator import Locator from multiprocessing import Queue +from queue import Full import json import threading @@ -39,7 +40,10 @@ class Client(object): self.multiprocessingPipe.close() def mp_send(self, data): - self.multiprocessingPipe.put(data, block=False) + try: + self.multiprocessingPipe.put(data, block=False) + except Full: + self.close() def handleTextMessage(self, conn, message): pass