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

Don't retry failed peer on optional file search

Browse source
This commit is contained in:
shortcutme 2016-11-16 11:22:38 +01:00
parent b220f5de5c
commit 0e83eba6df
1 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/Worker/WorkerManager.py
View file

@ -177,13 +177,15 @@ class WorkerManager(object):
for task in optional_tasks: for task in optional_tasks:
optional_hash_id = task["optional_hash_id"] optional_hash_id = task["optional_hash_id"]
if optional_hash_id in hashfield_set: if optional_hash_id in hashfield_set:
if reset_task and len(task["failed"]) > 0:
task["failed"] = []
if peer in task["failed"]:
continue
found[optional_hash_id].append(peer) found[optional_hash_id].append(peer)
if task["peers"] and peer not in task["peers"]: if task["peers"] and peer not in task["peers"]:
task["peers"].append(peer) task["peers"].append(peer)
else: else:
task["peers"] = [peer] task["peers"] = [peer]
if reset_task and len(task["failed"]) > 0:
task["failed"] = []
return found return found
@ -221,9 +223,9 @@ class WorkerManager(object):
task["peers"] = [] task["peers"] = []
if peer not in task["peers"]: if peer not in task["peers"]:
task["peers"].append(peer) task["peers"].append(peer)
found[hash_id].append(peer)
if peer.hashfield.appendHashId(hash_id): # Peer has this file if peer.hashfield.appendHashId(hash_id): # Peer has this file
peer.time_hashfield = None # Peer hashfield probably outdated peer.time_hashfield = None # Peer hashfield probably outdated
found[hash_id].append(peer)
return found return found