From 43e6f374faabaa2f3083ee5507d29f7328cdba4e Mon Sep 17 00:00:00 2001 From: shortcutme Date: Tue, 3 Oct 2017 15:49:52 +0200 Subject: [PATCH] Don't increase priority when addTask called again --- src/Worker/WorkerManager.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/src/Worker/WorkerManager.py b/src/Worker/WorkerManager.py index 53a85070..81392197 100644 --- a/src/Worker/WorkerManager.py +++ b/src/Worker/WorkerManager.py @@ -413,6 +413,7 @@ class WorkerManager(object): self.site.onFileStart(inner_path) # First task, trigger site download started task = self.findTask(inner_path) if task: # Already has task for that file + task["priority"] = max(priority, task["priority"]) if peer and task["peers"]: # This peer also has new version, add it to task possible peers task["peers"].append(peer) self.log.debug("Added peer %s to %s" % (peer.key, task["inner_path"])) @@ -421,9 +422,6 @@ class WorkerManager(object): task["failed"].remove(peer) # New update arrived, remove the peer from failed peers self.log.debug("Removed peer %s from failed %s" % (peer.key, task["inner_path"])) self.startWorkers([peer]) - - if priority: - task["priority"] += priority # Boost on priority return task else: # No task for that file yet evt = gevent.event.AsyncResult()