From acf6781148108493e9391c7d4a6e6bc36af54abb Mon Sep 17 00:00:00 2001 From: Yuxin Wang Date: Sat, 13 Oct 2018 23:10:02 -0400 Subject: [PATCH] Update chunkinfo by update_frequency. --- p2pfs/core/peer.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/p2pfs/core/peer.py b/p2pfs/core/peer.py index df51dd4..dc4286b 100644 --- a/p2pfs/core/peer.py +++ b/p2pfs/core/peer.py @@ -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()