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

Don't increase priority when addTask called again

Browse source
This commit is contained in:
shortcutme 2017-10-03 15:49:52 +02:00
parent c91011e6ea
commit 43e6f374fa
No known key found for this signature in database
GPG key ID: 5B63BAE6CB9613AE
1 changed files with 1 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/Worker/WorkerManager.py
View file

@ -413,6 +413,7 @@ class WorkerManager(object):
self.site.onFileStart(inner_path) # First task, trigger site download started self.site.onFileStart(inner_path) # First task, trigger site download started
task = self.findTask(inner_path) task = self.findTask(inner_path)
if task: # Already has task for that file 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 if peer and task["peers"]: # This peer also has new version, add it to task possible peers
task["peers"].append(peer) task["peers"].append(peer)
self.log.debug("Added peer %s to %s" % (peer.key, task["inner_path"])) 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 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.log.debug("Removed peer %s from failed %s" % (peer.key, task["inner_path"]))
self.startWorkers([peer]) self.startWorkers([peer])
if priority:
task["priority"] += priority # Boost on priority
return task return task
else: # No task for that file yet else: # No task for that file yet
evt = gevent.event.AsyncResult() evt = gevent.event.AsyncResult()