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

Set socket blocking for send operations.

Browse source
This commit is contained in:
Yuxin Wang 2018-10-04 00:04:50 -04:00
parent 13ba10c595
commit fe18541299
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

@ -134,7 +134,9 @@ class MessageServer:
compressed = self._compressor.compress(raw_msg)
logger.debug('Compressed rate: {}'.format(len(compressed) / len(raw_msg)))
compressed = struct.pack('>I', len(compressed)) + compressed
client.setblocking(True)
client.sendall(compressed)
client.settimeout(MessageServer._SOCKET_TIMEOUT)
def _client_connected(self, client):
pass