cgl.narada.transport
Class TransmissionManager
java.lang.Object
cgl.narada.transport.TransmissionManager
- All Implemented Interfaces:
- TransportDebugFlags
public class TransmissionManager
- extends Object
- implements TransportDebugFlags
This class checks/keeps track of pending transfers within the registered
TransmissionReporters associated with the links.
| Fields inherited from interface cgl.narada.transport.TransportDebugFlags |
IPSecLink_Debug, IPSecLinkFactory_Debug, IPSecReceiverThread_Debug, IPSecSenderThread_Debug, IPSecServerThread_Debug, MulticastLink_Debug, MulticastLinkFactory_Debug, MulticastReceiverThread_Debug, MulticastSenderThread_Debug, NIOTCPLink_Debug, NIOTCPLinkFactory_Debug, NIOTCPReceiverThread_Debug, NIOTCPSenderThread_Debug, NIOTCPServerThread_Debug, PoolTCPLink_Debug, PoolTCPLinkFactory_Debug, PoolTCPLinkReceiver_Debug, PoolTCPLinkSender_Debug, PoolTCPServerThread_Debug, PTCPLink_Debug, PTCPLinkFactory_Debug, PTCPReceiverThread_Debug, PTCPSenderThread_Debug, PTCPServerThread_Debug, ReceiveTask_Debug, RTPLink_Debug, RTPLinkFactory_Debug, RTPReceiverThread_Debug, RTPSenderThread_Debug, SendTask_Debug, TCPLink_Debug, TCPLinkFactory_Debug, TCPReceiverThread_Debug, TCPSenderThread_Debug, TCPServerThread_Debug, TransmissionManager_Debug, TransportHandlerImpl_Debug, UDPLink_Debug, UDPLinkFactory_Debug, UDPReceiverThread_Debug, UDPSenderThread_Debug |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TransmissionManager
public TransmissionManager()
registerTransmissionReporter
public void registerTransmissionReporter(String linkId,
TransmissionReporter reporter)
- Register a transmission reporter for a specific link ID
- Parameters:
linkId - The linkId of the link being trackedreporter - The reporter associated with the link
removeTransmissionReporter
public void removeTransmissionReporter(String linkId)
- Remove the transmission reporter associated with the link.
- Parameters:
linkId -
hasPendingTransfers
public boolean hasPendingTransfers()
reset
public void reset()
main
public static void main(String[] args)
- Parameters:
args -
For comments and suggestions please send
e-mail to
The NaradaBrokering Project