oci/zeronet
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Start find optional files if no peers to try

Browse source
This commit is contained in:
shortcutme 2017-10-13 01:23:09 +02:00
parent 19c335e39a
commit 60af54a17e
No known key found for this signature in database
GPG key ID: 5B63BAE6CB9613AE
1 changed files with 5 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/Worker/WorkerManager.py
View file

@ -91,6 +91,9 @@ class WorkerManager(object):
peers_try = [peer for peer in task["peers"] if peer not in task["failed"]] peers_try = [peer for peer in task["peers"] if peer not in task["failed"]]
if peers_try: if peers_try:
self.startWorkers(peers_try, force_num=5) self.startWorkers(peers_try, force_num=5)
else:
self.startFindOptional(find_more=True)
else:
self.startFindOptional(find_more=True) self.startFindOptional(find_more=True)
else: else:
if task["peers"]: # Release the peer lock if task["peers"]: # Release the peer lock
@ -373,6 +376,8 @@ class WorkerManager(object):
if time_tasks != self.time_task_added: # New task added since start if time_tasks != self.time_task_added: # New task added since start
self.log.debug("New task since start, restarting...") self.log.debug("New task since start, restarting...")
gevent.spawn_later(0.1, self.startFindOptional) gevent.spawn_later(0.1, self.startFindOptional)
else:
self.log.debug("startFindOptional ended")
# Stop all worker # Stop all worker
def stopWorkers(self): def stopWorkers(self):