From f997a69ebc35786382879a5d105cc920eda02c75 Mon Sep 17 00:00:00 2001 From: shortcutme Date: Wed, 4 Oct 2017 17:26:21 +0200 Subject: [PATCH] Run checkTask for every task --- src/Worker/WorkerManager.py | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/Worker/WorkerManager.py b/src/Worker/WorkerManager.py index 14ca2649..c97eda16 100644 --- a/src/Worker/WorkerManager.py +++ b/src/Worker/WorkerManager.py @@ -87,7 +87,7 @@ class WorkerManager(object): if len(self.asked_peers) < ask_limit and len(task["peers"] or []) <= len(task["failed"]) * 2: # Re-search for high priority self.startFindOptional(find_more=True) - elif task["peers"]: + if task["peers"]: peers_try = [peer for peer in task["peers"] if peer not in task["failed"]] if peers_try: self.startWorkers(peers_try) @@ -96,8 +96,7 @@ class WorkerManager(object): if task["peers"]: # Release the peer lock self.log.debug("Task peer lock release: %s" % task["inner_path"]) task["peers"] = [] - self.startWorkers() - break # One reannounce per loop + self.startWorkers() if len(self.tasks) > len(self.workers) * 2 and len(self.workers) < self.getMaxWorkers(): self.startWorkers()