From 380c32dee2baa092b121b4c06209527c6fa205af Mon Sep 17 00:00:00 2001 From: shortcutme Date: Thu, 4 Apr 2019 13:27:46 +0200 Subject: [PATCH] Worker stats on stop --- src/Worker/Worker.py | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/src/Worker/Worker.py b/src/Worker/Worker.py index ab1ccb03..89c4ccf6 100644 --- a/src/Worker/Worker.py +++ b/src/Worker/Worker.py @@ -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(