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

Only log worker download status if small ammount of task present

Browse source
This commit is contained in:
shortcutme 2019-03-15 23:30:34 +01:00
parent 7ffb7db888
commit 13d1df3cef
No known key found for this signature in database
GPG key ID: 5B63BAE6CB9613AE
1 changed files with 7 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/Worker/Worker.py
View file

@ -100,7 +100,8 @@ class Worker(object):
error_message = "Download failed" error_message = "Download failed"
correct = False correct = False
if correct is True or correct is None: # Verify ok or same file if correct is True or correct is None: # Verify ok or same file
self.manager.log.debug("%s: Verify correct: %s" % (self.key, task["inner_path"])) if self.manager.started_task_num < 50 or config.verbose:
self.manager.log.debug("%s: Verify correct: %s" % (self.key, task["inner_path"]))
write_error = None write_error = None
if correct is True and task["done"] is False: # Save if changed and task not done yet if correct is True and task["done"] is False: # Save if changed and task not done yet
buff.seek(0) buff.seek(0)
@ -118,10 +119,11 @@ class Worker(object):
task["workers_num"] -= 1 task["workers_num"] -= 1
else: # Verify failed else: # Verify failed
task["workers_num"] -= 1 task["workers_num"] -= 1
self.manager.log.debug( if self.manager.started_task_num < 50 or config.verbose:
"%s: Verify failed: %s, error: %s, failed peers: %s, workers: %s" % self.manager.log.debug(
(self.key, task["inner_path"], err, len(task["failed"]), task["workers_num"]) "%s: Verify failed: %s, error: %s, failed peers: %s, workers: %s" %
) (self.key, task["inner_path"], error_message, len(task["failed"]), task["workers_num"])
)
task["failed"].append(self.peer) task["failed"].append(self.peer)
self.peer.hash_failed += 1 self.peer.hash_failed += 1
if self.peer.hash_failed >= max(len(self.manager.tasks), 3) or self.peer.connection_error > 10: if self.peer.hash_failed >= max(len(self.manager.tasks), 3) or self.peer.connection_error > 10: