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

Worker stats on stop

Browse source
This commit is contained in:
shortcutme 2019-04-04 13:27:46 +02:00
parent bfc7e7c33f
commit 380c32dee2
No known key found for this signature in database
GPG key ID: 5B63BAE6CB9613AE
1 changed files with 7 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/Worker/Worker.py
View file

@ -15,6 +15,8 @@ class Worker(object):
self.key = None
self.running = False
self.thread = None
self.num_downloaded = 0
self.num_failed = 0
def __str__(self):
return "Worker %s %s" % (self.manager.site.address_short, self.key)
@ -32,7 +34,8 @@ class Worker(object):
time.sleep(0.1) # Wait a bit for new tasks
task = self.manager.getTask(self.peer)
if not task: # Still no task, stop it
self.manager.log.debug("%s: No task found, stopping" % self.key)
stats = "downloaded files: %s, failed: %s" % (self.num_downloaded, self.num_failed)
self.manager.log.debug("%s: No task found, stopping (%s)" % (self.key, stats))
break
if not task["time_started"]:
task["time_started"] = time.time() # Task started now
@ -114,10 +117,13 @@ class Worker(object):
if task["done"] is False:
if write_error:
self.manager.failTask(task)
self.num_failed += 1
else:
self.manager.doneTask(task)
self.num_downloaded += 1
task["workers_num"] -= 1
else: # Verify failed
self.num_failed += 1
task["workers_num"] -= 1
if self.manager.started_task_num < 50 or config.verbose:
self.manager.log.debug(