From fe7a53fb8affce6142c9c241e8d97c14684b6fe2 Mon Sep 17 00:00:00 2001 From: shortcutme Date: Mon, 27 Feb 2017 00:02:56 +0100 Subject: [PATCH] Separate config argument for workers --- src/Config.py | 1 + src/Worker/WorkerManager.py | 4 ++-- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/src/Config.py b/src/Config.py index e4930730..aaa9440b 100644 --- a/src/Config.py +++ b/src/Config.py @@ -183,6 +183,7 @@ class Config(object): metavar='address') self.parser.add_argument('--size_limit', help='Default site size limit in MB', default=10, type=int, metavar='size') self.parser.add_argument('--connected_limit', help='Max connected peer per site', default=6, type=int, metavar='connected_limit') + self.parser.add_argument('--workers', help='Download workers per site', default=5, type=int, metavar='workers') self.parser.add_argument('--fileserver_ip', help='FileServer bind address', default="*", metavar='ip') self.parser.add_argument('--fileserver_port', help='FileServer bind port', default=15441, type=int, metavar='port') diff --git a/src/Worker/WorkerManager.py b/src/Worker/WorkerManager.py index 13c5664c..0e6e2d41 100644 --- a/src/Worker/WorkerManager.py +++ b/src/Worker/WorkerManager.py @@ -126,9 +126,9 @@ class WorkerManager(object): def getMaxWorkers(self): if len(self.tasks) > 100: - return config.connected_limit * 3 + return config.workers * 3 else: - return config.connected_limit + return config.workers # Add new worker def addWorker(self, peer):