lejos.remote.nxt

Class LCPResponder

java.lang.Object

java.lang.Thread

lejos.remote.nxt.LCPResponder

All Implemented Interfaces:

java.lang.Runnable

public class LCPResponder
extends java.lang.Thread

Support for LCP commands

Author:

Lawrie Griffiths/Andy Shaw

Nested Class Summary

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

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected NXTConnection	conn
protected NXTCommConnector	connector
protected boolean	running

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
LCPResponder(NXTCommConnector connector) Create a Responder using the provided connector The connector is used to create the listening connection used to accept remote commands.

Method Summary

Modifier and Type	Method and Description
protected int	command(byte[] inMsg, int len, byte[] reply) Process the actual command Default action is to call the LCP object to emulate the command
protected void	disconnect() Method called to disconnect the responder connect.
boolean	isConnected() Checks whether there is an active connection
protected void	postCommand(byte[] inMsg, int inLen, byte[] replyMsg, int replyLen)
protected int	preCommand(byte[] inMsg, int len) Method called with a newly read command, before it is processed.
void	run()
void	shutdown() Terminate the responder.
protected void	waitConnect() Method called when the responder is waiting for a new connection.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, 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

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

Field Detail

connector

protected NXTCommConnector connector

conn

protected NXTConnection conn

running

protected boolean running

Constructor Detail

LCPResponder

public LCPResponder(NXTCommConnector connector)

Create a Responder using the provided connector The connector is used to create the listening connection used to accept remote commands.

Parameters:

connector -

Method Detail

waitConnect

protected void waitConnect()

Method called when the responder is waiting for a new connection. Default action is to wait for the new connection and return.

disconnect

protected void disconnect()

Method called to disconnect the responder connect. Default action is to close the underlying connection object.

preCommand

protected int preCommand(byte[] inMsg,
                         int len)

Method called with a newly read command, before it is processed. Default action is to detect invalid commands and if detected to drop the connection.

Parameters:

inMsg - Newly read command

len - length of the command

Returns:

the length of the command

command

protected int command(byte[] inMsg,
                      int len,
                      byte[] reply)

Process the actual command Default action is to call the LCP object to emulate the command

Parameters:

inMsg - The command bytes

len - length of the command

reply - bytes to send back in response to the command

Returns:

length of the reply

postCommand

protected void postCommand(byte[] inMsg,
                           int inLen,
                           byte[] replyMsg,
                           int replyLen)

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

shutdown

public void shutdown()

Terminate the responder. Abort any listening operation and close any open connections (this will also abort any current read requests).

isConnected

public boolean isConnected()

Checks whether there is an active connection

Returns:

true iff the responder is connected