Chunkinfo is managed by another command.

This commit is contained in:
Yuxin Wang 2018-09-26 11:11:25 -04:00
parent d7f6bbdb0a
commit e88464469a

View file

@ -34,8 +34,7 @@ class Peer(MessageServer):
self._write_message(self._server_sock, {
'type': MessageType.REQUEST_PUBLISH,
'filename': filename,
'size': os.stat(file).st_size,
'chunkinfo': []
'size': os.stat(file).st_size
})
lock = threading.Lock()
self._publish_locks[filename] = lock