Loading transfer_service/storage_rpc_server.py +5 −6 Original line number Diff line number Diff line Loading @@ -135,21 +135,20 @@ class StorageRPCServer(RedisRPCServer): else: response = { "responseType": "STORAGE_LST_DONE", "storageList": result } elif requestBody["requestType"] == "TAPE_POOL_LST": elif requestBody["requestType"] == "TAPE_HSM_FS_LST": try: self.tapeClient.connect() tapePools = self.tapeClient.getPoolList() tapeHSMFilesystemList = self.tapeClient.getHSMFilesystemList() self.tapeClient.disconnect() tapePoolList = [ p.getName() for p in tapePools ] except Exception: errorMsg = "Unable to get tape pool list." errorMsg = "Unable to get tape HSM filesystem list." self.logger.exception(errorMsg) response = { "responseType": "ERROR", "errorCode": 6, "errorMsg": errorMsg } else: response = { "responseType": "TAPE_POOL_LST_DONE", "tapePoolList": tapePoolList } response = { "responseType": "TAPE_HSM_FS_LST", "tapeHSMFilesystemList": tapeHSMFilesystemList } else: errorMsg = "Unkown request type." self.logger.error(errorMsg) Loading Loading
transfer_service/storage_rpc_server.py +5 −6 Original line number Diff line number Diff line Loading @@ -135,21 +135,20 @@ class StorageRPCServer(RedisRPCServer): else: response = { "responseType": "STORAGE_LST_DONE", "storageList": result } elif requestBody["requestType"] == "TAPE_POOL_LST": elif requestBody["requestType"] == "TAPE_HSM_FS_LST": try: self.tapeClient.connect() tapePools = self.tapeClient.getPoolList() tapeHSMFilesystemList = self.tapeClient.getHSMFilesystemList() self.tapeClient.disconnect() tapePoolList = [ p.getName() for p in tapePools ] except Exception: errorMsg = "Unable to get tape pool list." errorMsg = "Unable to get tape HSM filesystem list." self.logger.exception(errorMsg) response = { "responseType": "ERROR", "errorCode": 6, "errorMsg": errorMsg } else: response = { "responseType": "TAPE_POOL_LST_DONE", "tapePoolList": tapePoolList } response = { "responseType": "TAPE_HSM_FS_LST", "tapeHSMFilesystemList": tapeHSMFilesystemList } else: errorMsg = "Unkown request type." self.logger.error(errorMsg) Loading