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

Delay the deletion.

Browse source
This commit is contained in:
Yuxin Wang 2018-09-26 17:21:09 -04:00
parent 2a26d67430
commit 61ba4fb321
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

@ -52,15 +52,17 @@ class Peer(MessageServer):
lock.acquire()
# second lock blocks the method until reply is ready
lock.acquire()
del self._publish_locks[filename]
# when we wake up it means the result is ready
is_success, message = self._publish_results[filename]
del self._publish_results[filename]
if is_success:
self._file_map[filename] = file
logger.info('File {} published on server with name {}'.format(file, filename))
else:
logger.info('File {} failed to publish, {}'.format(file, message))
# remove the locks and results
del self._publish_locks[filename]
del self._publish_results[filename]
return is_success, message
def list_file(self):