stella.net

Class ParameterServer

java.lang.Object

util.PropertyContainer

util.PropertyResources

util.rmi.RmiPropertyContainer

util.rmi.AbstractRmiCaster

stella.CastingContainer

stella.net.ReceiverServer

stella.net.ErrorServer

stella.net.ParameterServer

All Implemented Interfaces:

GlobalDepending, Cloneable, Runnable, Remote, Caster, ErrorCaster, ErrorProcessing, RmiErrorCaster, CancelRunnable, ExitCleaning, Initializable, PropertySupplying, ResourceSupplying, RmiCaster, RmiPropertyBearing

public class ParameterServer
extends ErrorServer
implements ErrorCaster, GlobalDepending

A parameter server class. This class allows clients to connect to its listening port to query instances of SocketParameter. The functionality is as follows.

• After starting the server with the startServer() method it aquires a listening state on the port defined by #KEY_PORT.
• Incomming request spawn a new ParameterServer.ParameterHandler thread. This thread reads in the name of the parameter to be querried from the client.
• The parameter name is than matched to a SocketParameter instance. Its SocketParameter.getAscii() method is used to serialize the parameter value into a string.
• The string is written to the socket-stream. The stream is terminated with a newline and flushed.
• This ends the protocol. The streams and the sockets are closed.

As the parameter server runs within the master mind, local error casting is enabled.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	ParameterServer.ParameterHandler The helper class to run the protocol for ascii-based parameter exchanges.

Nested classes/interfaces inherited from class util.PropertyResources

PropertyResources.Load, PropertyResources.URLResource

Field Summary

Fields

Modifier and Type	Field and Description
private static long	DEFTIMEOUT The default sleep interval between available queries.
static String	KEY_TIMEOUT The key for join-time on cancel.
private static ThreadGroup	parameterGroup The thread group commands run in.
private ParameterServer.ParameterHandler	request The handler for dealing with parameter queries.
private GlobalGrouping	set The reference to the parameters served.

Fields inherited from class stella.net.ErrorServer

KEY_BIND, KEY_BINDNAME

Fields inherited from class stella.net.ReceiverServer

DEFSERVERPORT, handlerGroup, KEY_BUFFERSIZE, KEY_HANDLERPRIORITY, KEY_HOSTADDRESS, KEY_LOGOUT, KEY_RECEIVERNAME, KEY_SERVERPORT, KEY_SERVERPRIORITY

Fields inherited from class util.rmi.AbstractRmiCaster

ALTERNATEHOST, ALTERNATEPORT, KEY_EXPORTPORT, KEY_REGISTRYHOST, KEY_REGISTRYPORT

Fields inherited from class util.PropertyResources

KEY_NOINITONCREATE, POSTFIX_ALPHABET, POSTFIX_BYTES, POSTFIX_DIR, POSTFIX_EXT, POSTFIX_FILE, POSTFIX_LIST, POSTFIX_MODTIME, POSTFIX_URL

Fields inherited from class util.PropertyContainer

KEY_LISTSEPARATOR, KEY_MAPKEYVALUECHAR, KEY_MAPSEPARATOR

Fields inherited from interface util.ResourceSupplying

KEY_URLRESOURCES, KEY_URLUSECONFIG, KEY_URLUSECURRENT, KEY_URLUSEHOME

Fields inherited from interface util.PropertySupplying

CONFIG, KEY_CLASS

Constructor Summary

Constructors

Constructor and Description
ParameterServer(Map prop) Constructs a new parameter server.

Method Summary

Modifier and Type	Method and Description
void	cancel() Cancels the parameter server.
protected void	protocol(Socket client) The method called as soon as a connection is established.
void	registerGlobals(GlobalGrouping toserve) Registers the set of parameters served by this parameter server.
void	startServer() Starts the server.

Methods inherited from class stella.net.ErrorServer

exit, init, processError

Methods inherited from class stella.net.ReceiverServer

getAsociatedThread, getBufferSize, getHandlerPriority, getReceiverName, getServerPort, getServerPriority, initReceiverServer, maxTimeToCancel, run

Methods inherited from class stella.CastingContainer

addErrorListener, addRmiErrorListener, isValid, notifyErrorListener, removeErrorListener, removeRmiErrorListener, sendError, sendError, sendError, sendStatus, sendStatus, sendStatus

Methods inherited from class util.rmi.AbstractRmiCaster

bindToRegistry, bindToRegistry, bindToRegistry, bindToRegistry, bindToRegistry, bindToRegistry, casterExit, casterExit, getBindName, getBindName, unbindFromRegistry, unbindFromRegistry

Methods inherited from class util.rmi.RmiPropertyContainer

containsRemoteProperty, getRemoteProperties, getRemoteProperty, setRemoteProperty

Methods inherited from class util.PropertyResources

clone, createFrom, createFrom, createFrom, createInstance, getApplet, getAsResources, getLocate, getPropertiesToKey, getPropertiesToKey, getResource, getResourceAsStream, getResourceFromKey, getResources, hasLocalURLs, initProperties, keyCreate, keyCreate, reload, setApplet

Methods inherited from class util.PropertyContainer

augment, augment, augment, augment, augment, defaultBoolean, defaultChar, defaultDouble, defaultFloat, defaultInt, defaultLong, defaultObject, defaultObject, defaultProperties, defaultProperty, getAsBoolean, getAsChar, getAsDouble, getAsEnums, getAsFloat, getAsInt, getAsList, getAsLong, getAsMap, getAsMap, getAsObject, getAsObject, getProperties, getProperty, has, isNew, parseObject, parseObject, reload, removeProperty, requires, rescanned, setObject, setProperties, setProperty, stringProperties, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface stella.ErrorCaster

addErrorListener, removeErrorListener

Methods inherited from interface stella.rmi.RmiErrorCaster

addRmiErrorListener, removeRmiErrorListener

Methods inherited from interface util.rmi.RmiCaster

bindToRegistry, isValid, unbindFromRegistry

Methods inherited from interface util.PropertySupplying

defaultBoolean, defaultChar, defaultDouble, defaultFloat, defaultInt, defaultLong, defaultObject, defaultObject, defaultProperties, defaultProperty, getAsBoolean, getAsChar, getAsDouble, getAsFloat, getAsInt, getAsList, getAsLong, getAsMap, getAsObject, getAsObject, getProperties, getProperty, has, parseObject, removeProperty, setObject, setProperty, stringProperties

Field Detail

KEY_TIMEOUT

public static final String KEY_TIMEOUT

The key for join-time on cancel.

See Also:

Constant Field Values

DEFTIMEOUT

private static final long DEFTIMEOUT

The default sleep interval between available queries.

See Also:

Constant Field Values

set

private GlobalGrouping set

The reference to the parameters served.

parameterGroup

private static final transient ThreadGroup parameterGroup

The thread group commands run in.

request

private ParameterServer.ParameterHandler request

The handler for dealing with parameter queries.

Constructor Detail

ParameterServer

public ParameterServer(Map prop)
                throws RemoteException

Constructs a new parameter server. The server thread must be started explicetly with a call to startServer(). SocketParameters should be added prior to starting the parameter server, otherwise synchronization on the look-up table may cause time delays.

Throws:

RemoteException

Method Detail

registerGlobals

public void registerGlobals(GlobalGrouping toserve)

Registers the set of parameters served by this parameter server.

Specified by:

registerGlobals in interface GlobalDepending

startServer

public void startServer()

Starts the server. The linked thread is already constructed in ReceiverServer.ReceiverServer(Map), which also sets the server priority.

cancel

public void cancel()

Cancels the parameter server. If a connection is currently active, it is first closed.

Specified by:

cancel in interface CancelRunnable

Overrides:

cancel in class ReceiverServer

protocol

protected void protocol(Socket client)

The method called as soon as a connection is established. It spwans a ParameterServer.ParameterHandler thread witch performs the actual communication.

Specified by:

protocol in class ReceiverServer

Parameters:

client - The client socket.

See Also:

CommandReceiver, ErrorReceiver