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()