Package jmri.jmrix.loconet.loconetovertcp

Class ClientRxHandler

java.lang.Object

java.lang.Thread

jmri.jmrix.loconet.loconetovertcp.ClientRxHandler

All Implemented Interfaces:

Runnable, EventListener, LocoNetListener

public final class ClientRxHandler
extends Thread
implements LocoNetListener

Implementation of the LocoNetOverTcp 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) LocoNetMessage	lastSentMessage
(package private) final LinkedList<LocoNetMessage>	msgQueue
(package private) OutputStream	outStream
(package private) String	remoteAddress
(package private) LnTrafficController	tc
(package private) Thread	txThread

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
ClientRxHandler(String newRemoteAddress, Socket newSocket, LnTrafficController _tc)

Method Summary

Modifier and Type	Method	Description
void	close()
(package private) void	dispose()	Kill this thread, usually for testing purposes
void	message(LocoNetMessage msg)	Member function that will be invoked by a LocoNetInterface implementation to forward a LocoNet message from the layout.
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

msgQueue

final LinkedList<LocoNetMessage> msgQueue

txThread

volatile Thread txThread

inString

String inString

remoteAddress

String remoteAddress

lastSentMessage

LocoNetMessage lastSentMessage

tc

LnTrafficController tc

Constructor Details

ClientRxHandler

public ClientRxHandler(String newRemoteAddress,
 Socket newSocket,
 LnTrafficController _tc)

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(LocoNetMessage msg)

Description copied from interface: LocoNetListener

Member function that will be invoked by a LocoNetInterface implementation to forward a LocoNet message from the layout.

Specified by:

message in interface LocoNetListener

Parameters:

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

dispose

void dispose()

Kill this thread, usually for testing purposes