TransportPool

class DIRAC.Core.DISET.private.TransportPool.TransportPool(logger=False)

Bases: object

__init__(logger=False)
add(transport)
associateData(trid, kw, value)
close(trid)
exists(trid)
get(trid)
getAssociatedData(trid, kw)
receive(trid, maxBufferSize=0, blockAfterKeepAlive=True, idleReceive=False)
remove(trid)
send(trid, msg)
sendAndClose(trid, msg)
sendErrorAndClose(trid, msg)
sendKeepAlive(trid, responseId=None)
DIRAC.Core.DISET.private.TransportPool.getGlobalTransportPool()