Only announce once per checkTask loop
This commit is contained in:
parent
bc9bddf918
commit
e2b6dd37b7
1 changed files with 4 additions and 1 deletions
|
@ -38,6 +38,7 @@ class WorkerManager(object):
|
|||
def checkTasks(self):
|
||||
while self.running:
|
||||
tasks = task = worker = workers = None # Cleanup local variables
|
||||
announced = False
|
||||
time.sleep(15) # Check every 15 sec
|
||||
|
||||
# Clean up workers
|
||||
|
@ -74,7 +75,9 @@ class WorkerManager(object):
|
|||
len(task["peers"] or []), len(task["failed"]), len(self.asked_peers)
|
||||
)
|
||||
)
|
||||
task["site"].announce(mode="more") # Find more peers
|
||||
if not announced:
|
||||
task["site"].announce(mode="more") # Find more peers
|
||||
announced = True
|
||||
if task["optional_hash_id"]:
|
||||
if self.workers:
|
||||
if not task["time_started"]:
|
||||
|
|
Loading…
Reference in a new issue