cgl.narada.transport.niotcp
Class NIOTCPReceiverThread

java.lang.Object
  extended by java.lang.Thread
      extended by cgl.narada.transport.niotcp.NIOTCPReceiverThread
All Implemented Interfaces:
TransportDebugFlags, Runnable

public class NIOTCPReceiverThread
extends Thread
implements TransportDebugFlags

Listens for NIOTCP packets arriving at a socket and performs various operations based on situations arising during communication. These received packets are then encapsulated into a specialized data structure and forwarded to the transport handler implenetation residing in the transport layer.


Nested Class Summary
 
Nested classes/interfaces inherited from class java.lang.Thread
Thread.State, Thread.UncaughtExceptionHandler
 
Field Summary
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
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
NIOTCPReceiverThread(SocketChannel sc, NIOTCPLink niotcpLink)
           
 
Method Summary
 void readDataFromSocket()
           
 void releaseResources()
           
 void run()
           
 void setLinkId(String linkId)
           
 
Methods inherited from class java.lang.Thread
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

NIOTCPReceiverThread

public NIOTCPReceiverThread(SocketChannel sc,
                            NIOTCPLink niotcpLink)
                     throws Exception
Throws:
Exception
Method Detail

setLinkId

public void setLinkId(String linkId)

releaseResources

public void releaseResources()

run

public void run()
Specified by:
run in interface Runnable
Overrides:
run in class Thread

readDataFromSocket

public void readDataFromSocket()
                        throws Exception
Throws:
Exception


For comments and suggestions please send e-mail to The NaradaBrokering Project