org.eclipse.hyades.internal.execution.local.common
Class MultiplexedDataServer

java.lang.Object
  org.eclipse.hyades.internal.execution.local.common.MultiplexedDataServer

All Implemented Interfaces:

Constants, AgentListener

public class MultiplexedDataServer
extends java.lang.Object
implements AgentListener, Constants

Please see TCPDataServer for implmentation details.

Field Summary

static byte	BINARY_DATA
static byte	UNICODE_STRING_DATA
static byte	UTF8_STRING_DATA

Fields inherited from interface org.eclipse.hyades.internal.execution.local.common.Constants

CTL_PORT_NUM_CLIENT, CTL_PORT_NUM_SERVER, DATA_PORT_NUM_CLIENT, DEFAULT_TIMEOUT, MAX_COMMAND_LINE_LENGTH, MAX_DATA_LENGTH, MAX_MESSAGE_LENGTH, MESSAGE_HEADER_LENGTH, RA_ACKNOWLEDGEMENT_MESSAGE, RA_AGENT_ACTIVE, RA_AGENT_ATTACHED, RA_AGENT_CONFIGURATION, RA_AGENT_CONTROLLER_AVAILABLE, RA_AGENT_CONTROLLER_UNAVAILABLE, RA_AGENT_DETACHED, RA_AGENT_DETAILS, RA_AGENT_INACTIVE, RA_AGENT_LIST, RA_AGENT_QUERY_STATE, RA_AGENT_REQUEST_MONITOR, RA_AGENT_REQUEST_MONITOR_PORT, RA_AGENT_SCOPING_INFORMATION, RA_ATTACH_FAILED, RA_ATTACH_SUCCESSFUL, RA_ATTACH_TO_AGENT, RA_AUTHENTICATE, RA_AUTHENTICATION_FAILED, RA_AUTHENTICATION_SUCCESSFUL, RA_BINARY_CUSTOM_COMMAND, RA_CONSOLE_INFO, RA_CONTROL_MESSAGE, RA_CONTROLLER_MONITOR_PEER, RA_CONTROLLER_REQUEST_MONITOR, RA_CONTROLLER_REQUEST_MONITOR_PORT, RA_CUSTOM_COMMAND, RA_DELETE_FILE, RA_DETACH_FROM_AGENT, RA_ERROR_STRING, RA_GET_FILE, RA_GET_PROPERTY_LIST, RA_KILL_PROCESS, RA_LAUNCH_PROCESS, RA_LOCAL_AGENT_ACTIVE, RA_MAGIC, RA_MAGIC_0, RA_MAGIC_1, RA_MAGIC_2, RA_MAGIC_3, RA_MANAGE_FILE, RA_MASTER_ADDRESS, RA_PEER_UNREACHABLE, RA_PIPE_NAMESPACE, RA_PIPE_NAMESPACE_WIN32, RA_PROCESS_EXITED, RA_PROCESS_LAUNCHED, RA_PROCESS_LIST, RA_PROPERTY_LIST, RA_PUT_FILE, RA_QUERY_AGENT_DETAILS, RA_QUERY_AGENT_LIST, RA_QUERY_PROCESS_LIST, RA_REGISTER_AGENT_NOTIFICATION, RA_RESOURCE_LOCATION, RA_SERVER_SECURITY_REQUIREMENTS, RA_SET_NAME_VALUE_PAIR, RA_SHUTDOWN, RA_START_MONITORING_AGENT_LOCAL, RA_START_MONITORING_AGENT_REMOTE, RA_STOP_MONITORING_AGENT, RA_VERSION, sizeofByte, sizeofChar, sizeofLong, sizeofShort

Constructor Summary

MultiplexedDataServer()

Method Summary

void	agentActive(Agent agent) Invoked when an agent first becomes active
void	agentInactive(Agent agent) Invoked when an agent becomes inactive.
void	error(Agent agent, java.lang.String errorId, java.lang.String errorMessage) Invoked when an error is recieved from the agent.
void	handleCommand(Agent agent, CommandElement command) Invoked when there is no established handler for the context of a message.
void	incommingData(byte[] b, java.net.InetAddress peer)
void	incommingData(char[] c, java.net.InetAddress peer)
boolean	isProcessing()
void	resumeServer()
void	resumeServer(DataProcessor processor)
void	shutdownServer()
void	startServer(DataProcessor processor)
void	stopServer()

Methods inherited from class java.lang.Object

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

Field Detail

BINARY_DATA

public static final byte BINARY_DATA

See Also:

Constant Field Values

UTF8_STRING_DATA

public static final byte UTF8_STRING_DATA

See Also:

Constant Field Values

UNICODE_STRING_DATA

public static final byte UNICODE_STRING_DATA

See Also:

Constant Field Values

Constructor Detail

MultiplexedDataServer

public MultiplexedDataServer()

Method Detail

startServer

public void startServer(DataProcessor processor)
                 throws java.lang.Exception

Throws:

java.lang.Exception

isProcessing

public boolean isProcessing()

stopServer

public void stopServer()

resumeServer

public void resumeServer()

resumeServer

public void resumeServer(DataProcessor processor)

shutdownServer

public void shutdownServer()

incommingData

public void incommingData(byte[] b,
                          java.net.InetAddress peer)

incommingData

public void incommingData(char[] c,
                          java.net.InetAddress peer)

agentActive

public void agentActive(Agent agent)

Description copied from interface: AgentListener

Invoked when an agent first becomes active

Specified by:

agentActive in interface AgentListener

agentInactive

public void agentInactive(Agent agent)

Description copied from interface: AgentListener

Invoked when an agent becomes inactive.

Specified by:

agentInactive in interface AgentListener

error

public void error(Agent agent,
                  java.lang.String errorId,
                  java.lang.String errorMessage)

Description copied from interface: AgentListener

Invoked when an error is recieved from the agent.

Specified by:

error in interface AgentListener

handleCommand

public void handleCommand(Agent agent,
                          CommandElement command)

Description copied from interface: AgentListener

Invoked when there is no established handler for the context of a message.

Specified by:

handleCommand in interface AgentListener