Package jmri.jmrix.xpa

Class XpaTrafficController

java.lang.Object

jmri.jmrix.xpa.XpaTrafficController

All Implemented Interfaces:

Runnable, XpaInterface

public class XpaTrafficController
extends Object
implements XpaInterface, Runnable

Converts Stream-based I/O to/from Xpa messages. The "XpaInterface" side sends/receives message objects. The connection to an XpaPortController is via a pair of *Streams, which then carry sequences of characters for transmission. Note that this processing is handled in an independent thread.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	XpaTrafficController.XmtHandler	Captive class to handle transmission.

Field Summary

Fields

Modifier and Type	Field	Description
protected final ArrayList<XpaListener>	cmdListeners
(package private) DataInputStream	istream
(package private) XpaListener	lastSender
(package private) OutputStream	ostream
(package private) final XpaTrafficController.XmtHandler	xmtHandler	(local class) object to implement the transmit thread
(package private) final LinkedList<byte[]>	xmtList
(package private) Thread	xmtThread

Constructor Summary

Constructors

Constructor	Description
XpaTrafficController()	Create a new XpaTrafficController instance.

Method Summary

Modifier and Type	Method	Description
void	addXpaListener(XpaListener l)
void	connectPort(XpaPortController p)	Make connection to existing PortController object.
void	disconnectPort(XpaPortController p)	Break connection to existing XpaPortController object.
(package private) void	handleOneIncomingReply()
protected void	notifyMessage(XpaMessage m, XpaListener notMe)	Forward a XpaMessage to all registered XpaInterface listeners.
protected void	notifyReply(XpaMessage r)
void	removeXpaListener(XpaListener l)
void	run()	Handle incoming characters.
void	sendXpaMessage(XpaMessage m, XpaListener reply)	Forward a pre-formatted message to the actual interface.
void	startTransmitThread()	Start the Transmit thread.
boolean	status()	Test operational status of interface.

Methods inherited from class java.lang.Object

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

Field Details

xmtList

final LinkedList<byte[]> xmtList

xmtHandler

final XpaTrafficController.XmtHandler xmtHandler

(local class) object to implement the transmit thread

xmtThread

Thread xmtThread

cmdListeners

protected final ArrayList<XpaListener> cmdListeners

lastSender

XpaListener lastSender

istream

DataInputStream istream

ostream

OutputStream ostream

Constructor Details

XpaTrafficController

public XpaTrafficController()

Create a new XpaTrafficController instance.

Method Details

startTransmitThread

public void startTransmitThread()

Start the Transmit thread.

status

public boolean status()

Description copied from interface: XpaInterface

Test operational status of interface.

Specified by:

status in interface XpaInterface

Returns:

true if the interface implementation is operational.

addXpaListener

public void addXpaListener(XpaListener l)

Specified by:

addXpaListener in interface XpaInterface

removeXpaListener

public void removeXpaListener(XpaListener l)

Specified by:

removeXpaListener in interface XpaInterface

notifyMessage

protected void notifyMessage(XpaMessage m,
 XpaListener notMe)

Forward a XpaMessage to all registered XpaInterface listeners.

Parameters:

m - the message to forward

notMe - registered listener not to forward the message to

notifyReply

protected void notifyReply(XpaMessage r)

sendXpaMessage

public void sendXpaMessage(XpaMessage m,
 XpaListener reply)

Forward a pre-formatted message to the actual interface.

Specified by:

sendXpaMessage in interface XpaInterface

Parameters:

m - the message to forward

reply - the listener to receive the reply

connectPort

public void connectPort(XpaPortController p)

Make connection to existing PortController object.

Parameters:

p - controller for the port associated with this controller

disconnectPort

public void disconnectPort(XpaPortController p)

Break connection to existing XpaPortController object. Once broken, attempts to send via "message" member will fail.

Parameters:

p - controller for the port associated with this controller

run

public void run()

Handle incoming characters. This is a permanent loop, looking for input messages in character form on the stream connected to the PortController via connectPort. Terminates with the input stream breaking out of the try block.

Specified by:

run in interface Runnable

handleOneIncomingReply

void handleOneIncomingReply()
                     throws IOException

Throws:

IOException