aboutsummaryrefslogtreecommitdiff
path: root/voctocore
diff options
context:
space:
mode:
authorVasil Kolev <vasil@ludost.net>2016-12-10 18:02:47 +0100
committerVasil Kolev <vasil@ludost.net>2016-12-10 18:02:47 +0100
commitb07239f8fe7a50939c52fff7fdb690861dfde916 (patch)
tree7e3fae4c7500f7fc10be3f4332b27714a34fd8d9 /voctocore
parentf4423181b773ed081446cb8cc917bb67545c76ae (diff)
fix for #117 (voctomix leaking file descriptors)
On connection close voctocore doesn't close the sockets, leading to a leak.
Diffstat (limited to 'voctocore')
-rw-r--r--voctocore/lib/tcpmulticonnection.py1
-rw-r--r--voctocore/lib/tcpsingleconnection.py1
2 files changed, 2 insertions, 0 deletions
diff --git a/voctocore/lib/tcpmulticonnection.py b/voctocore/lib/tcpmulticonnection.py
index ac228a3..e7ab700 100644
--- a/voctocore/lib/tcpmulticonnection.py
+++ b/voctocore/lib/tcpmulticonnection.py
@@ -43,6 +43,7 @@ class TCPMultiConnection(object):
def close_connection(self, conn):
if conn in self.currentConnections:
+ conn.close()
del(self.currentConnections[conn])
self.log.info('Now %u Receiver connected',
len(self.currentConnections))
diff --git a/voctocore/lib/tcpsingleconnection.py b/voctocore/lib/tcpsingleconnection.py
index 3f589a7..62a4b1f 100644
--- a/voctocore/lib/tcpsingleconnection.py
+++ b/voctocore/lib/tcpsingleconnection.py
@@ -41,5 +41,6 @@ class TCPSingleConnection(object):
return True
def close_connection(self):
+ self.currentConnection.close()
self.currentConnection = None
self.log.info('Connection closed')