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

Re-order the code and notes.

Browse source
This commit is contained in:
Yuxin Wang 2018-09-26 19:49:17 -04:00
parent 84c66d3067
commit f56bc1c33d
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
p2pfs/core/peer.py
View file

@ -18,8 +18,8 @@ class Peer(MessageServer):
self._publish_locks = {}
self._publish_results = {}
self._list_file_lock = threading.Lock()
# locks and results for list_file method
self._list_file_lock = threading.Lock()
self._file_list = {}
# socket connected to server
@ -30,8 +30,8 @@ class Peer(MessageServer):
exit(1)
def publish(self, file):
# TODO: this method is not thread-safe, the following line only prevents sequential re-entrant but 2 threads
# can both pass the condition check and the lock-twice trick will possibly cause a deadlock
# TODO: this method is not thread-safe, the following line only prevents sequential re-entrant
# but 2 threads can both pass the condition check and the lock-twice trick will possibly cause a deadlock
if file in self._publish_locks:
return False, 'Publish file {} already in progress.'.format(file)
if not os.path.exists(file):