cgl.narada.transport.threadpool
Class PoolTCPLinkSender

java.lang.Object
  cgl.narada.transport.threadpool.PoolTCPLinkSender

All Implemented Interfaces:

TransportDebugFlags

public class PoolTCPLinkSender
extends Object
implements TransportDebugFlags

Responsible for sending niotcp packets across the socket connection that is established during initializations. The PoolTCPSenderThread notifies any loss of connections to the PoolTCPLink which in turn proceeds to noitify the PoolTCPLinkFactory.

Field Summary

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

Constructor Summary

PoolTCPLinkSender(SocketChannel sc, PoolTCPLink niotcpLink)

Method Summary

void	populateSendBuffers(byte[] dataToSend)
void	prepareToSendData(ByteBuffer readyToSend)
void	releaseResources()
void	sendData(byte[] dataToSend)
void	sendData(byte[] dataToSend, String dataType)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PoolTCPLinkSender

public PoolTCPLinkSender(SocketChannel sc,
                         PoolTCPLink niotcpLink)
                  throws Exception

Throws:

Exception

Method Detail

releaseResources

public void releaseResources()

sendData

public void sendData(byte[] dataToSend)
              throws TransportException

Throws:

TransportException

prepareToSendData

public void prepareToSendData(ByteBuffer readyToSend)
                       throws Exception

Throws:

Exception

populateSendBuffers

public void populateSendBuffers(byte[] dataToSend)
                         throws TransportException

Throws:

TransportException

sendData

public void sendData(byte[] dataToSend,
                     String dataType)
              throws TransportException

Throws:

TransportException