Improving the network communication #4

Merged
PeterSurda merged 12 commits from lee.miller/MiNode:network into v0.3 2024-07-15 07:58:57 +02:00
Showing only changes of commit 1b9648f3de - Show all commits

View File

@ -28,6 +28,9 @@ class Listener(threading.Thread):
break
try:
conn, addr = self.s.accept()
except socket.timeout:
continue
logging.info('Incoming connection from: %s:%i', *addr[:2])
with shared.connections_lock:
if len(shared.connections) > shared.connection_limit:
@ -36,5 +39,3 @@ class Listener(threading.Thread):
c = Connection(*addr[:2], conn, server=True)
c.start()
shared.connections.add(c)
except socket.timeout:
pass