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

Update chunkinfo by update_frequency.

Browse source
This commit is contained in:
Yuxin Wang 2018-10-13 23:10:02 -04:00
parent 310c82f9ed
commit acf6781148
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
p2pfs/core/peer.py
View file

@ -397,7 +397,7 @@ class Peer(MessageServer):
server_address=self._server_address, window_size=30)
# update chunkinfo every UPDATE_FREQUENCY chunks
update_frequency = 30
update_frequency = 100
try:
with open(destination + '.temp', 'wb') as dest_file:
@ -406,8 +406,10 @@ class Peer(MessageServer):
dest_file.seek(chunknum * Peer._CHUNK_SIZE, 0)
dest_file.write(data)
dest_file.flush()
finished_chunknum, file_size = download_manager.get_progress()
if finished_chunknum % update_frequency == 0:
await download_manager.update_chunkinfo()
if reporthook:
finished_chunknum, file_size = download_manager.get_progress()
reporthook(finished_chunknum, Peer._CHUNK_SIZE, file_size)
finally:
await download_manager.clean()