From 11c2c8afe3dd7da79f69aa7f41f19056e337d2b1 Mon Sep 17 00:00:00 2001 From: Jakob Ketterl Date: Tue, 26 Nov 2019 20:10:56 +0100 Subject: [PATCH] limit multiprocessing queue to avoid memory leak on failing connections --- owrx/connection.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/owrx/connection.py b/owrx/connection.py index a6e1624..523763d 100644 --- a/owrx/connection.py +++ b/owrx/connection.py @@ -18,7 +18,7 @@ logger = logging.getLogger(__name__) class Client(object): def __init__(self, conn): self.conn = conn - self.multiprocessingPipe = Queue() + self.multiprocessingPipe = Queue(100) def mp_passthru(): run = True