Commit b78ac0a0 authored by froehlich martin - mfroehli's avatar froehlich martin - mfroehli
Browse files

Update with explicit socket close method.

parent d5ab4303
......@@ -69,6 +69,9 @@ class One2ManyMoProxy(multiprocessing.Process):
self.sink.sendto(data, client)
self.logger.exception('Oops, something went wrong!', extra={'stack': True})
def stop(self):
self.kill_signal.value = True
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment