Commit 66ff7cb2 authored by Philip ABBET's avatar Philip ABBET
Browse files

Ensure that all sockets are correctly closed

parent 0d8bbd71
......@@ -439,6 +439,9 @@ class DockerExecutor(BaseExecutor):
retval['stdout'] += '\n' + self.host.stdout(databases_container)
retval['stderr'] += '\n' + self.host.stderr(databases_container)
self.host.rm(databases_container)
self.db_socket.setsockopt(zmq.LINGER, 0)
self.db_socket.close()
self.context.destroy()
self.message_handler.destroy()
self.message_handler = None
......
......@@ -70,6 +70,8 @@ class ProxyMessageHandler(MessageHandler):
def destroy(self):
self.socket.setsockopt(zmq.LINGER, 0)
self.socket.close()
self.context.destroy()
......
Markdown is supported
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