public class DistributedApplication extends CoreApplication
CoreApplication
.
Specifically, support for transferring NetworkNode
s to other machines
when algorithms are restored
and a distributed network controller registration support are added.log
Constructor and Description |
---|
DistributedApplication() |
Modifier and Type | Method and Description |
---|---|
boolean |
algorithmRestore(java.io.PrintStream out,
java.lang.String... args)
Restores a previously serialized algorithm from file.
|
static void |
main(java.lang.String[] args)
Start a MESSIF application.
|
protected boolean |
parseArguments(java.lang.String[] args,
int argIndex)
Internal method called from
main method
to read parameters and initialize the application. |
protected java.lang.String |
usage()
Returns the command line arguments description.
|
addNamedInstance, algorithmInfo, algorithmInfoAll, algorithmSelect, algorithmSelectByName, algorithmStart, algorithmStop, algorithmStopAll, algorithmStore, algorithmSupportedOperations, algorithmToNamedInstance, collectGarbage, controlFile, controlFileExecuteAction, controlFileExecuteMethod, createCFActionRepeatEveryThread, currentTime, decode, echo, getCFActionArguments, getCFActionException, getCFActionForeach, getCFActionOutput, getCFActionRepeat, getCmdSocket, getExtendedNamedInstances, getNamedInstance, getRootCauseInvocationTargetException, help, logException, loggingConsoleChangeLevel, loggingFileAdd, loggingFileChangeLevel, loggingFileRemove, loggingLevel, memoryUsage, methodExecute, methodExecuteOnAlgorithm, namedInstanceAdd, namedInstanceConstructor, namedInstanceEcho, namedInstanceList, namedInstanceRemove, namedInstanceReplace, namedInstanceRestore, namedInstanceStore, namedInstanceThread, objectStreamClose, objectStreamConvert, objectStreamOpen, objectStreamReset, objectStreamSetParameter, objectStreamSkip, operationAnswer, operationAnswerRawObjects, operationArgument, operationBgExecute, operationErrorCode, operationExecute, operationExecuteAgain, operationChangeAnswerCollection, operationChangeAnswerNamedInstance, operationInfo, operationObjectCount, operationParam, operationParamProcessByMethod, operationPrepare, operationProcessByMethod, operationQueryObjectLocator, operationSubAnswer, postponeCFAction, processException, processInteractiveSocket, propertiesOpen, quit, retrieveIntArgument, startApplication, statisticsDisable, statisticsGlobal, statisticsGlobalGet, statisticsLastOperation, statisticsResetGlobal, statisticsSetAutoBinding, stopRepeatEveryThread, substituteVariables, sum, waitForRepeatEveryThread
public boolean algorithmRestore(java.io.PrintStream out, java.lang.String... args)
MESSIF >>> algorithmRestore /some/where/file/algorithm.serializedOptionally, additional parameter can specify a file with network identification translation. It is a simple text file with format "original_address:original_port=new_address:new_port". If the ports are unspecified, only addresses are translated.
algorithmRestore
in class CoreApplication
out
- a stream where the application writes information for the userargs
- file name with the serialized algorithm and, optionally, port remaping fileCoreApplication.algorithmStore(java.io.PrintStream, java.lang.String...)
protected java.lang.String usage()
CoreApplication
usage
in class CoreApplication
protected boolean parseArguments(java.lang.String[] args, int argIndex)
CoreApplication
main
method
to read parameters and initialize the application.parseArguments
in class CoreApplication
args
- the command line argumentsargIndex
- the index of the argument where to startpublic static void main(java.lang.String[] args)
args
- the command line arguments