From dbd776ce49d17bbd4caff854143df26b70b64504 Mon Sep 17 00:00:00 2001 From: Cristiano Urban Date: Sat, 29 May 2021 09:33:27 +0200 Subject: [PATCH] Reduced number of connections to the database. Signed-off-by: Cristiano Urban --- transfer_service/abort_job_rpc_server.py | 4 ++-- transfer_service/data_rpc_server.py | 4 ++-- transfer_service/get_job_rpc_server.py | 4 ++-- transfer_service/import_rpc_server.py | 2 +- transfer_service/job_rpc_server.py | 4 ++-- transfer_service/start_job_rpc_server.py | 4 ++-- transfer_service/storage_rpc_server.py | 4 ++-- 7 files changed, 13 insertions(+), 13 deletions(-) diff --git a/transfer_service/abort_job_rpc_server.py b/transfer_service/abort_job_rpc_server.py index ec0cb9c..df508f8 100644 --- a/transfer_service/abort_job_rpc_server.py +++ b/transfer_service/abort_job_rpc_server.py @@ -16,8 +16,8 @@ class AbortJobRPCServer(RedisRPCServer): self.params["host"], self.params.getint("port"), self.params["db"], - 4, - 8) + 1, + 2) super(AbortJobRPCServer, self).__init__(host, port, db, rpcQueue) def callback(self, requestBody): diff --git a/transfer_service/data_rpc_server.py b/transfer_service/data_rpc_server.py index 695cc86..f9c80fc 100644 --- a/transfer_service/data_rpc_server.py +++ b/transfer_service/data_rpc_server.py @@ -30,8 +30,8 @@ class DataRPCServer(RedisRPCServer): self.params["host"], self.params.getint("port"), self.params["db"], - 4, - 8) + 1, + 2) self.params = config.loadSection("transfer_node") self.storageStorePath = self.params["store_path"] self.params = config.loadSection("scheduling") diff --git a/transfer_service/get_job_rpc_server.py b/transfer_service/get_job_rpc_server.py index 8bafbec..7d06e6d 100644 --- a/transfer_service/get_job_rpc_server.py +++ b/transfer_service/get_job_rpc_server.py @@ -18,8 +18,8 @@ class GetJobRPCServer(RedisRPCServer): self.params["host"], self.params.getint("port"), self.params["db"], - 4, - 8) + 1, + 2) super(GetJobRPCServer, self).__init__(host, port, db, rpcQueue) def callback(self, requestBody): diff --git a/transfer_service/import_rpc_server.py b/transfer_service/import_rpc_server.py index 99cdef8..faadbc8 100644 --- a/transfer_service/import_rpc_server.py +++ b/transfer_service/import_rpc_server.py @@ -22,7 +22,7 @@ class ImportRPCServer(RedisRPCServer): self.params.getint("port"), self.params["db"], 1, - 1) + 2) self.params = config.loadSection("scheduling") self.maxReadyJobs = self.params.getint("max_ready_jobs") self.importReadyQueue = JobQueue("import_ready") diff --git a/transfer_service/job_rpc_server.py b/transfer_service/job_rpc_server.py index d1a1be9..d986060 100644 --- a/transfer_service/job_rpc_server.py +++ b/transfer_service/job_rpc_server.py @@ -18,8 +18,8 @@ class JobRPCServer(RedisRPCServer): self.params["host"], self.params.getint("port"), self.params["db"], - 4, - 8) + 1, + 2) super(JobRPCServer, self).__init__(host, port, db, rpcQueue) def callback(self, requestBody): diff --git a/transfer_service/start_job_rpc_server.py b/transfer_service/start_job_rpc_server.py index 2ca9895..0979335 100644 --- a/transfer_service/start_job_rpc_server.py +++ b/transfer_service/start_job_rpc_server.py @@ -20,8 +20,8 @@ class StartJobRPCServer(RedisRPCServer): self.params["host"], self.params.getint("port"), self.params["db"], - 4, - 8) + 1, + 2) self.params = config.loadSection("scheduling") self.maxPendingJobs = self.params.getint("max_pending_jobs") self.maxTerminatedJobs = self.params.getint("max_terminated_jobs") diff --git a/transfer_service/storage_rpc_server.py b/transfer_service/storage_rpc_server.py index dcf1505..b09c9c8 100644 --- a/transfer_service/storage_rpc_server.py +++ b/transfer_service/storage_rpc_server.py @@ -18,8 +18,8 @@ class StorageRPCServer(RedisRPCServer): self.params["host"], self.params.getint("port"), self.params["db"], - 4, - 8) + 1, + 2) super(StorageRPCServer, self).__init__(host, port, db, rpcQueue) def callback(self, requestBody): -- GitLab