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

Check file existence before doing the actual work.

Browse source
This commit is contained in:
Yuxin Wang 2018-10-03 23:23:56 -04:00
parent 0c8db5cf68
commit 9308d01638
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
p2pfs/core/peer.py
View file

@ -55,14 +55,15 @@ class Peer(MessageServer):
return True
def publish(self, file):
if not os.path.exists(file):
return False, 'File {} doesn\'t exist'.format(file)
path, filename = os.path.split(file)
# guard the check to prevent 2 threads passing the check simultaneously
with self._publish_lock:
if filename in self._publish_results:
return False, 'Publish file {} already in progress.'.format(file)
self._publish_results[filename] = Queue(maxsize=1)
if not os.path.exists(file):
return False, 'File {} doesn\'t exist'.format(file)
# send out the request packet
self._write_message(self._server_sock, {