clear the multiprocessing queue to get rid of more file descriptors,

refs #146
This commit is contained in:
Jakob Ketterl 2020-07-20 23:08:19 +02:00
parent 369a61ec59
commit d9bc03d1fc

View File

@ -37,6 +37,11 @@ class Client(ABC):
self.send(data) self.send(data)
except (EOFError, OSError): except (EOFError, OSError):
run = False 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() threading.Thread(target=mp_passthru).start()