Commit 18d68208 authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Minor changes. 



Signed-off-by: default avatarCristiano Urban <cristiano.urban@inaf.it>
parent ff637e6c

transfer_service/cli_handler.py

+7 −4
Original line number Diff line number Diff line
@@ -4,6 +4,7 @@ import sys 
import time



from data_rpc_server import DataRPCServer

from group_rw_rpc_server import GroupRwRPCServer

from import_rpc_server import ImportRPCServer

from job_rpc_server import JobRPCServer

from storage_rpc_server import StorageRPCServer
@@ -18,13 +19,15 @@ class CliHandler(object): 
        self.rpcServerList = []



    def addRPCServer(self, srvType, rpcQueue):

        if srvType == 'data':

        if srvType == "data":

            self.rpcServerList.append(DataRPCServer(self.host, self.port, self.db, rpcQueue))

        elif srvType == 'import':

        elif srvType == "group_rw":

            self.rpcServerList.append(GroupRwRPCServer(self.host, self.port, self.db, rpcQueue))

        elif srvType == "import":

            self.rpcServerList.append(ImportRPCServer(self.host, self.port, self.db, rpcQueue))

        elif srvType == 'storage':

        elif srvType == "storage":

            self.rpcServerList.append(StorageRPCServer(self.host, self.port, self.db, rpcQueue))

        elif srvType == 'job':

        elif srvType == "job":

            self.rpcServerList.append(JobRPCServer(self.host, self.port, self.db, rpcQueue))

        else:

            sys.exit(f"FATAL: unknown server type {srvType}.")

transfer_service/transfer_service.py

+3 −0
Original line number Diff line number Diff line
@@ -23,6 +23,9 @@ class TransferService(object): 
        # PushToVOSpace (via vos_data, the 'unofficial' command line client)

        self.cliHandler.addRPCServer("data", "data_queue")       

        

        # Group

        self.cliHandler.addRPCServer("group_rw", "group_queue")

        

        # Import

        self.cliHandler.addRPCServer("import", "import_queue")