limit multiprocessing queue to avoid memory leak on failing connections

This commit is contained in:
Jakob Ketterl 2019-11-26 20:10:56 +01:00
parent fe39c2712d
commit 11c2c8afe3

View File

@ -18,7 +18,7 @@ logger = logging.getLogger(__name__)
class Client(object): class Client(object):
def __init__(self, conn): def __init__(self, conn):
self.conn = conn self.conn = conn
self.multiprocessingPipe = Queue() self.multiprocessingPipe = Queue(100)
def mp_passthru(): def mp_passthru():
run = True run = True