diff --git a/minode/listener.py b/minode/listener.py index 88b26db..bec5365 100644 --- a/minode/listener.py +++ b/minode/listener.py @@ -28,13 +28,14 @@ class Listener(threading.Thread): break try: conn, addr = self.s.accept() - logging.info('Incoming connection from: %s:%i', *addr[:2]) - with shared.connections_lock: - if len(shared.connections) > shared.connection_limit: - conn.close() - else: - c = Connection(*addr[:2], conn, server=True) - c.start() - shared.connections.add(c) except socket.timeout: - pass + continue + + logging.info('Incoming connection from: %s:%i', *addr[:2]) + with shared.connections_lock: + if len(shared.connections) > shared.connection_limit: + conn.close() + else: + c = Connection(*addr[:2], conn, server=True) + c.start() + shared.connections.add(c)