Commit dbd776ce authored May 29, 2021 by Cristiano Urban

Reduced number of connections to the database.



Signed-off-by: Cristiano Urban <cristiano.urban@inaf.it>

parent b983489f

transfer_service/abort_job_rpc_server.py

+2 −2

Original line number	Diff line number	Diff line
		@@ -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):

transfer_service/data_rpc_server.py

+2 −2

Original line number	Diff line number	Diff line
		@@ -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")

transfer_service/get_job_rpc_server.py

+2 −2

Original line number	Diff line number	Diff line
		@@ -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):

transfer_service/import_rpc_server.py

+1 −1

Original line number	Diff line number	Diff line
		@@ -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")

transfer_service/job_rpc_server.py

+2 −2

Original line number	Diff line number	Diff line
		@@ -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):