masscollaborationlabs/p2pfs
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Add initiative connections to connection set.

Browse source
This commit is contained in:
Yuxin Wang 2018-10-01 00:14:16 -04:00
parent 9bd517fd4f
commit 590e9cd93f
1 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
p2pfs/core/server.py
View file

@ -68,6 +68,8 @@ class MessageServer:
logger.info('Connecting to {}'.format((ip, port)))
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client.connect((ip, port))
with self._connections_lock:
self._connections.add(client)
threading.Thread(target=self._read_message, args=(client,)).start()
logger.info('Successfully connected to {} on {}'.format((ip, port), client.getsockname()))
return client