jadex.base

Class Starter

java.lang.Object

jadex.base.Starter

public class Starter
extends java.lang.Object

Starter class for

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.util.Map<IComponentIdentifier,Tuple2<BlockingQueue,java.lang.Thread>>	rescuethreads The rescue threads - per platform.

Constructor Summary

Constructors

Constructor and Description
Starter()

Method Summary

Modifier and Type	Method and Description
static IFuture<IExternalAccess>	createPlatform() Create the platform.
static IFuture<IExternalAccess>	createPlatform(PlatformConfiguration config) Create the platform.
static IFuture<IExternalAccess>	createPlatform(PlatformConfiguration config, boolean printExceptions) Create the platform.
static IFuture<IExternalAccess>	createPlatform(java.lang.String[] args) Create the platform.
protected static IComponentIdentifier	createPlatformIdentifier(java.lang.String pfname)
static IFuture<IComponentIdentifier>	createProxy(IExternalAccess local, IExternalAccess remote) Create a proxy for the remote platform.
static long	getLocalDefaultTimeout(IComponentIdentifier platform) Get the local default timeout.
static long	getRemoteDefaultTimeout(IComponentIdentifier platform) Get the remote default timeout.
static long	getScaledLocalDefaultTimeout(IComponentIdentifier platform, double scale) Get the scaled local default timeout.
static long	getScaledRemoteDefaultTimeout(IComponentIdentifier platform, double scale) Get the scaled remote default timeout.
static void	initRescueThread(IComponentIdentifier cid, RootComponentConfiguration rootConfig) Init the rescue thread for a platform..
static boolean	isParameterCopy(IComponentIdentifier platform) Check if the parameter copy flag is set for a platform.
static boolean	isRealtimeTimeout(IComponentIdentifier platform) Check if the real time timeout flag is set for a platform.
static boolean	isRescueThread(IComponentIdentifier cid) Test if the current thread is the rescue thread of the platform.
static void	main(java.lang.String[] args) Main for starting the platform (with meaningful fallbacks)
static void	scheduleRescueStep(IComponentIdentifier cid, java.lang.Runnable run) Schedule a rescue step.
static void	setLocalDefaultTimeout(IComponentIdentifier platform, long timeout) Set the local default timeout.
static void	setRemoteDefaultTimeout(IComponentIdentifier platform, long timeout) Set the remote default timeout.
static void	shutdownRescueThread(IComponentIdentifier cid) Shutdown the rescue thread of a platform.
protected static IFuture<java.lang.Void>	startComponents(int i, java.util.List<java.lang.String> components, IInternalAccess instance) Loop for starting components.
protected static java.lang.String	unescape(java.lang.String str) Unescape a string.

Methods inherited from class java.lang.Object

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

Field Detail

rescuethreads

protected static java.util.Map<IComponentIdentifier,Tuple2<BlockingQueue,java.lang.Thread>> rescuethreads

The rescue threads - per platform.

Constructor Detail

Starter

public Starter()

Method Detail

unescape

protected static java.lang.String unescape(java.lang.String str)

Unescape a string.

main

public static void main(java.lang.String[] args)

Main for starting the platform (with meaningful fallbacks)

Parameters:

args - The arguments.

Throws:

java.lang.Exception

createPlatform

public static IFuture<IExternalAccess> createPlatform(java.lang.String[] args)

Create the platform.

Parameters:

args - The command line arguments.

Returns:

The external access of the root component.

createPlatform

public static IFuture<IExternalAccess> createPlatform()

Create the platform.

Returns:

The external access of the root component.

createPlatform

public static IFuture<IExternalAccess> createPlatform(PlatformConfiguration config)

Create the platform.

Parameters:

config - The PlatformConfiguration object.

Returns:

The external access of the root component.

createPlatform

public static IFuture<IExternalAccess> createPlatform(PlatformConfiguration config,
                                                      boolean printExceptions)

Create the platform.

Parameters:

config - The PlatformConfiguration object.

Returns:

The external access of the root component.

createPlatformIdentifier

protected static IComponentIdentifier createPlatformIdentifier(java.lang.String pfname)

startComponents

protected static IFuture<java.lang.Void> startComponents(int i,
                                                         java.util.List<java.lang.String> components,
                                                         IInternalAccess instance)

Loop for starting components.

Parameters:

i - Number to start.

components - The list of components.

instance - The instance.

Returns:

True, when done.

initRescueThread

public static void initRescueThread(IComponentIdentifier cid,
                                    RootComponentConfiguration rootConfig)

Init the rescue thread for a platform..

scheduleRescueStep

public static void scheduleRescueStep(IComponentIdentifier cid,
                                      java.lang.Runnable run)

Schedule a rescue step.

Parameters:

cid - The id of a component of the platform.

run - The runnable to execute.

isRescueThread

public static boolean isRescueThread(IComponentIdentifier cid)

Test if the current thread is the rescue thread of the platform.

Parameters:

cid - The id of a component of the platform.

Returns:

True, if is the rescue thread.

shutdownRescueThread

public static void shutdownRescueThread(IComponentIdentifier cid)

Shutdown the rescue thread of a platform.

createProxy

public static IFuture<IComponentIdentifier> createProxy(IExternalAccess local,
                                                        IExternalAccess remote)

Create a proxy for the remote platform.

getRemoteDefaultTimeout

public static long getRemoteDefaultTimeout(IComponentIdentifier platform)

Get the remote default timeout.

getScaledRemoteDefaultTimeout

public static long getScaledRemoteDefaultTimeout(IComponentIdentifier platform,
                                                 double scale)

Get the scaled remote default timeout.

getLocalDefaultTimeout

public static long getLocalDefaultTimeout(IComponentIdentifier platform)

Get the local default timeout.

getScaledLocalDefaultTimeout

public static long getScaledLocalDefaultTimeout(IComponentIdentifier platform,
                                                double scale)

Get the scaled local default timeout.

setRemoteDefaultTimeout

public static void setRemoteDefaultTimeout(IComponentIdentifier platform,
                                           long timeout)

Set the remote default timeout.

setLocalDefaultTimeout

public static void setLocalDefaultTimeout(IComponentIdentifier platform,
                                          long timeout)

Set the local default timeout.

isRealtimeTimeout

public static boolean isRealtimeTimeout(IComponentIdentifier platform)

Check if the real time timeout flag is set for a platform.

isParameterCopy

public static boolean isParameterCopy(IComponentIdentifier platform)

Check if the parameter copy flag is set for a platform.