FTSManagerHandler

mod:FTSManagerHandler

Service handler for FTSDB using DISET

class DIRAC.DataManagementSystem.Service.FTSManagerHandler.FTSManagerHandler(handlerInitDict, trid)

Bases: DIRAC.Core.DISET.RequestHandler.RequestHandler

class FTSManagerHandler
exception ConnectionError(msg)

Bases: exceptions.Exception

__init__(msg)

x.__init__(…) initializes x; see help(type(x)) for signature

args
message
__init__(handlerInitDict, trid)

Constructor

Parameters:
  • handlerInitDict (dictionary) – Information vars for the service
  • trid (object) – Transport to use
auth_ping = ['all']
export_cleanUpFTSFiles(requestID, fileIDs)

Clean up FTS files, starting from RequestID

export_deleteFTSFiles(operationID, opFileIDList=None)

cleanup FTSFiles for rescheduling

classmethod export_deleteFTSJob(ftsJobID)

delete FTSJob given FTSJobID

static export_echo(data)

This method used for testing the performance of a service

classmethod export_getAllFTSFilesForRequest(requestID)

get list of FTSFiles with statuses in :statusList: given :requestID:

classmethod export_getDBSummary()

get FTSDB summary

classmethod export_getFTSFile(ftsFileID)

get FTSFile from FTSDB

classmethod export_getFTSFileIDs(statusList=None)

get FTSFilesIDs for a given status list

classmethod export_getFTSFileList(statusList=None, limit=None)

get FTSFiles with status in :statusList:

classmethod export_getFTSFilesForRequest(requestID, statusList=None)

get list of FTSFiles with statuses in :statusList: given :requestID:

classmethod export_getFTSHistory()

get last hour FTS history snapshot

classmethod export_getFTSJob(ftsJobID)

read FTSJob for processing given FTSJobID

classmethod export_getFTSJobIDs(statusList=None)

get FTSJobIDs for a given status list

classmethod export_getFTSJobList(statusList=None, limit=500)

get FTSJobs with statuses in :statusList:

classmethod export_getFTSJobsForRequest(requestID, statusList=None)

get list of FTSJobs for request given its :requestID: and statues in :statusList:

Parameters:
  • requestID (int) – ReqDB.Request.RequestID
  • statusList (list) – FTSJobs status list
export_getReplicationTree(sourceSEs, targetSEs, size)

return a replication tree with an up-to-date replication strategy

classmethod export_peekFTSFile(ftsFileID)

peek FTSFile given FTSFileID

export_ping()
export_putFTSFileList(ftsFilesJSONList)

put FTS files list

classmethod export_putFTSJob(ftsJobJSON)

put FTSJob (serialized in JSON into FTSDB

export_setFTSFilesWaiting(operationID, sourceSE, opFileIDList)

update states for waiting replications

classmethod export_setFTSJobStatus(ftsJobID, status)

set FTSJob status

ftsDB = None
ftsPlacement = None
ftsValidator = None
classmethod getCSOption(optionName, defaultValue=False)

Get an option from the CS section of the services

Returns:Value for serviceSection/optionName in the CS being defaultValue the default
classmethod getFTSPlacement()

fts placement getter

getRemoteAddress()

Get the address of the remote peer.

Returns:Address of remote peer.
getRemoteCredentials()

Get the credentials of the remote peer.

Returns:Credentials dictionary of remote peer.
initialize()

Initialize this instance of the handler (to be overwritten)

classmethod initializeHandler(serviceInfoDict)

initialize handler

classmethod refreshFTSPlacement()

Refresh the FTSPlacement

static refreshProxy()

setup DataManager shifter proxy in env

srv_disconnect(trid=None)
classmethod srv_disconnectClient(trid)
srv_getActionTuple()
classmethod srv_getCSOption(optionName, defaultValue=False)

Get an option from the CS section of the services

Returns:Value for serviceSection/optionName in the CS being defaultValue the default
srv_getClientSetup()
srv_getClientVO()
srv_getFormattedRemoteCredentials()
classmethod srv_getMonitor()
srv_getRemoteAddress()

Get the address of the remote peer.

Returns:Address of remote peer.
srv_getRemoteCredentials()

Get the credentials of the remote peer.

Returns:Credentials dictionary of remote peer.
classmethod srv_getServiceName()
srv_getTransportID()
classmethod srv_getURL()
classmethod srv_msgCreate(msgName)
srv_msgReply(msgObj)
classmethod srv_msgSend(trid, msgObj)
transfer_bulkFromClient(bulkId, token, bulkSize, fileHelper)
transfer_bulkToClient(bulkId, token, fileHelper)
transfer_fromClient(fileId, token, fileSize, fileHelper)
transfer_listBulk(bulkId, token, fileHelper)
transfer_toClient(fileId, token, fileHelper)
types_cleanUpFTSFiles = [(<type 'int'>, <type 'long'>), <type 'list'>]
types_deleteFTSFiles = [(<type 'int'>, <type 'long'>), (<type 'NoneType'>, <type 'list'>)]
types_deleteFTSJob = [[<type 'int'>, <type 'long'>]]
types_echo = [<type 'basestring'>]
types_getAllFTSFilesForRequest = [(<type 'int'>, <type 'long'>)]
types_getDBSummary = []
types_getFTSFile = [[<type 'int'>, <type 'long'>]]
types_getFTSFileIDs = [<type 'list'>]
types_getFTSFileList = [<type 'list'>, <type 'int'>]
types_getFTSFilesForRequest = [(<type 'int'>, <type 'long'>), (<type 'NoneType'>, <type 'list'>)]
types_getFTSHistory = []
types_getFTSJob = [[<type 'int'>, <type 'long'>]]
types_getFTSJobIDs = [<type 'list'>]
types_getFTSJobList = [<type 'list'>, <type 'int'>]
types_getFTSJobsForRequest = [(<type 'int'>, <type 'long'>), <type 'list'>]
types_getReplicationTree = [<type 'list'>, <type 'list'>, (<type 'int'>, <type 'long'>)]
types_peekFTSFile = [[<type 'int'>, <type 'long'>]]
types_ping = []
types_putFTSFileList = [<type 'list'>]
types_putFTSJob = [<type 'dict'>]
types_setFTSFilesWaiting = [(<type 'int'>, <type 'long'>), (<type 'str'>, <type 'unicode'>), (<type 'NoneType'>, <type 'list'>)]
types_setFTSJobStatus = [[<type 'int'>, <type 'long'>], (<type 'str'>, <type 'unicode'>)]