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

Wait a bit for more tasks before consider site downloaded

Browse source
This commit is contained in:
HelloZeroNet 2016-03-19 18:09:20 +01:00
parent 988f1435c5
commit 54f9b49e90
1 changed files with 10 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/Worker/WorkerManager.py
View file

@ -391,6 +391,14 @@ class WorkerManager:
if not self.tasks: if not self.tasks:
self.started_task_num = 0 self.started_task_num = 0
# Wait for other tasks
def checkComplete(self):
time.sleep(0.1)
if not self.tasks:
self.log.debug("Check compelte: No tasks")
self.started_task_num = 0
self.site.onComplete() # No more task trigger site complete
# Mark a task done # Mark a task done
def doneTask(self, task): def doneTask(self, task):
task["done"] = True task["done"] = True
@ -398,5 +406,5 @@ class WorkerManager:
self.site.onFileDone(task["inner_path"]) self.site.onFileDone(task["inner_path"])
task["evt"].set(True) task["evt"].set(True)
if not self.tasks: if not self.tasks:
self.started_task_num = 0 self.log.debug("No tasks")
self.site.onComplete() # No more task trigger site complete gevent.spawn(self.checkComplete)