Commit ef0ddde8 authored by Luke Macken's avatar Luke Macken

Clean up the server socket in our IPC

parent 8b3ae4c3
...@@ -63,6 +63,7 @@ class PyrasiteIPC(object): ...@@ -63,6 +63,7 @@ class PyrasiteIPC(object):
super(PyrasiteIPC, self).__init__() super(PyrasiteIPC, self).__init__()
self.pid = pid self.pid = pid
self.sock = None self.sock = None
self.server_sock = None
def connect(self): def connect(self):
""" """
...@@ -168,6 +169,8 @@ class PyrasiteIPC(object): ...@@ -168,6 +169,8 @@ class PyrasiteIPC(object):
def close(self): def close(self):
if self.sock: if self.sock:
self.sock.close() self.sock.close()
if self.server_sock:
self.server_sock.close()
def __repr__(self): def __repr__(self):
return "<%s %s>" % (self.__class__.__name__, self.pid) return "<%s %s>" % (self.__class__.__name__, self.pid)
......
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