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