repicea.net.server

Class JavaLocalGatewayServer

java.lang.Object

repicea.app.AbstractGenericEngine

repicea.net.server.AbstractServer

repicea.net.server.JavaLocalGatewayServer

All Implemented Interfaces:

java.beans.PropertyChangeListener, java.util.EventListener

public class JavaLocalGatewayServer
extends AbstractServer

The JavaLocalGatewayServer class is a one-to-one local server that makes it possible to create objects and to execute methods in Java from a non-Java application.

Nested Class Summary

Nested classes/interfaces inherited from class repicea.net.server.AbstractServer

AbstractServer.ServerReply

Field Summary

Fields

Modifier and Type	Field and Description
protected repicea.net.server.JavaLocalGatewayServer.REpiceaBackDoorCancellationThread	backdoorThread
protected boolean	bypassShutdownForTesting
protected boolean	shutdownOnClosedConnection
protected REpiceaCodeTranslator	translator

Fields inherited from class repicea.net.server.AbstractServer

clientQueue, isCallerAJavaApplication

Fields inherited from class repicea.app.AbstractGenericEngine

finalTask, logger, queue, tasksDone

Constructor Summary

Constructors

Modifier	Constructor and Description
	JavaLocalGatewayServer(ServerConfiguration servConf, REpiceaCodeTranslator translator) Constructor.
protected	JavaLocalGatewayServer(ServerConfiguration servConf, REpiceaCodeTranslator translator, boolean shutdownOnClosedConnection) Hidden constructor for test purpose

Method Summary

Modifier and Type	Method and Description
protected ClientThread	createClientThread(AbstractServer server, int id)
protected SocketWrapper	getWaitingClients() This method waits until the head of the queue is non null and returns the socket.
protected void	shutdown(int shutdownCode)

Methods inherited from class repicea.net.server.AbstractServer

addPropertyChangeListener, closeAndRestartTheseThreads, firePropertyChange, firstTasksToDo, getClientThreads, getConfiguration, listenToClients, propertyChange, removePropertyChangeListener, requestShutdown, startReceiverThread

Methods inherited from class repicea.app.AbstractGenericEngine

addTask, addTasks, cancelRunningTask, decideWhatToDoInCaseOfFailure, getSettingMemory, lockEngine, lockEngine, setSettingMemory, startApplication, unlockEngine

Methods inherited from class java.lang.Object

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

Field Detail

translator

protected final REpiceaCodeTranslator translator

shutdownOnClosedConnection

protected final boolean shutdownOnClosedConnection

backdoorThread

protected final repicea.net.server.JavaLocalGatewayServer.REpiceaBackDoorCancellationThread backdoorThread

bypassShutdownForTesting

protected boolean bypassShutdownForTesting

Constructor Detail

JavaLocalGatewayServer

public JavaLocalGatewayServer(ServerConfiguration servConf,
                              REpiceaCodeTranslator translator)
                       throws java.lang.Exception

Constructor.

Parameters:

servConf - a ServerConfiguration instance

translator - an instance that implements the REpiceaCodeTranslator interface

Throws:

java.lang.Exception

JavaLocalGatewayServer

protected JavaLocalGatewayServer(ServerConfiguration servConf,
                                 REpiceaCodeTranslator translator,
                                 boolean shutdownOnClosedConnection)
                          throws java.lang.Exception

Hidden constructor for test purpose

Parameters:

servConf - a ServerConfiguration instance

translator - an instance that implements the REpiceaCodeTranslator interface

shutdownOnClosedConnection - by default this parameter is set to true so that if the connection is lost, the server is shutdown.

Throws:

java.lang.Exception

Method Detail

getWaitingClients

protected SocketWrapper getWaitingClients()
                                   throws java.lang.InterruptedException

This method waits until the head of the queue is non null and returns the socket.

Overrides:

getWaitingClients in class AbstractServer

Returns:

a Socket instance

Throws:

java.lang.InterruptedException

createClientThread

protected ClientThread createClientThread(AbstractServer server,
                                          int id)

Specified by:

createClientThread in class AbstractServer

shutdown

protected void shutdown(int shutdownCode)

Overrides:

shutdown in class AbstractGenericEngine