Package jmri.jmrix.dccpp.dccppovertcp

Class ClientRxHandler

java.lang.Object

java.lang.Thread

jmri.jmrix.dccpp.dccppovertcp.ClientRxHandler

All Implemented Interfaces:

Runnable, EventListener, AbstractMRListener, DCCppListener

public final class ClientRxHandler
extends Thread
implements DCCppListener

Implementation of the DCCppOverTcp LbServer Server Protocol.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	ClientRxHandler.ClientTxHandler

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
(package private) Socket	clientSocket
(package private) BufferedReader	inStream
(package private) String	inString
(package private) DCCppMessage	lastSentMessage
(package private) OutputStream	outStream
(package private) String	remoteAddress
(package private) final LinkedList<DCCppReply>	replyQueue
(package private) Thread	txThread
(package private) boolean	useOldPrefix

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
ClientRxHandler(String newRemoteAddress, Socket newSocket)

Method Summary

Modifier and Type	Method	Description
void	close()
void	message(DCCppMessage msg)	Member function that will be invoked by a DCCppInterface implementation to forward a DCC++ message sent to the layout.
void	message(DCCppReply msg)	Member function that will be invoked by a DCCppInterface implementation to forward a DCC++ message from the layout.
void	notifyTimeout(DCCppMessage m)	Member function invoked by an DCCppInterface implementation to notify a sender that an outgoing message timed out and was dropped from the queue.
void	run()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Details

clientSocket

Socket clientSocket

inStream

BufferedReader inStream

outStream

OutputStream outStream

replyQueue

final LinkedList<DCCppReply> replyQueue

txThread

Thread txThread

inString

String inString

remoteAddress

String remoteAddress

lastSentMessage

DCCppMessage lastSentMessage

useOldPrefix

boolean useOldPrefix

Constructor Details

ClientRxHandler

public ClientRxHandler(String newRemoteAddress,
 Socket newSocket)

Method Details

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

close

public void close()

message

public void message(DCCppMessage msg)

Description copied from interface: DCCppListener

Member function that will be invoked by a DCCppInterface implementation to forward a DCC++ message sent to the layout. Normally, this function will do nothing.

Specified by:

message in interface DCCppListener

Parameters:

msg - The received DCC++ message. Note that this same object may be presented to multiple users. It should not be modified here.

message

public void message(DCCppReply msg)

Description copied from interface: DCCppListener

Member function that will be invoked by a DCCppInterface implementation to forward a DCC++ message from the layout.

Specified by:

message in interface DCCppListener

Parameters:

msg - The received DCC++ message. Note that this same object may be presented to multiple users. It should not be modified here.

notifyTimeout

public void notifyTimeout(DCCppMessage m)

Description copied from interface: DCCppListener

Member function invoked by an DCCppInterface implementation to notify a sender that an outgoing message timed out and was dropped from the queue.

Specified by:

notifyTimeout in interface DCCppListener

Parameters:

m - the message that timed out.