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

Only start worker if there is valid task for it

Browse source
This commit is contained in:
shortcutme 2019-04-04 13:27:21 +02:00
parent 8594e4ce4a
commit bfc7e7c33f
No known key found for this signature in database
GPG key ID: 5B63BAE6CB9613AE
1 changed files with 10 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
src/Worker/WorkerManager.py
View file

@ -157,12 +157,16 @@ class WorkerManager(object):
key = "%s/%s" % (key, len(self.workers)) key = "%s/%s" % (key, len(self.workers))
if key not in self.workers: if key not in self.workers:
# We dont have worker for that peer and workers num less than max # We dont have worker for that peer and workers num less than max
worker = Worker(self, peer) task = self.getTask(peer)
self.workers[key] = worker if task:
worker.key = key worker = Worker(self, peer)
worker.start() self.workers[key] = worker
return worker worker.key = key
else: # We have woker for this peer or its over the limit worker.start()
return worker
else:
return False
else: # We have worker for this peer or its over the limit
return False return False
def taskAddPeer(self, task, peer): def taskAddPeer(self, task, peer):