public class Starter
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected static java.util.Map<IComponentIdentifier,Tuple2<BlockingQueue,java.lang.Thread>> |
rescuethreads
The rescue threads - per platform.
|
Constructor and Description |
---|
Starter() |
Modifier and Type | Method and Description |
---|---|
static IFuture<IExternalAccess> |
createPlatform()
Create the platform.
|
static IFuture<IExternalAccess> |
createPlatform(java.util.Map<java.lang.String,java.lang.String> args)
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.
|
protected static java.util.Map<IComponentIdentifier,Tuple2<BlockingQueue,java.lang.Thread>> rescuethreads
protected static java.lang.String unescape(java.lang.String str)
public static void main(java.lang.String[] args)
args
- The arguments.java.lang.Exception
public static IFuture<IExternalAccess> createPlatform(java.util.Map<java.lang.String,java.lang.String> args)
args
- The command line arguments.public static IFuture<IExternalAccess> createPlatform(java.lang.String... args)
args
- The command line arguments.public static IFuture<IExternalAccess> createPlatform()
public static IFuture<IExternalAccess> createPlatform(PlatformConfiguration config)
config
- The PlatformConfiguration object.public static IFuture<IExternalAccess> createPlatform(PlatformConfiguration config, boolean printExceptions)
config
- The PlatformConfiguration object.protected static IComponentIdentifier createPlatformIdentifier(java.lang.String pfname)
protected static IFuture<java.lang.Void> startComponents(int i, java.util.List<java.lang.String> components, IInternalAccess instance)
i
- Number to start.components
- The list of components.instance
- The instance.public static void initRescueThread(IComponentIdentifier cid, RootComponentConfiguration rootConfig)
public static void scheduleRescueStep(IComponentIdentifier cid, java.lang.Runnable run)
cid
- The id of a component of the platform.run
- The runnable to execute.public static boolean isRescueThread(IComponentIdentifier cid)
cid
- The id of a component of the platform.public static void shutdownRescueThread(IComponentIdentifier cid)
public static IFuture<IComponentIdentifier> createProxy(IExternalAccess local, IExternalAccess remote)
public static long getRemoteDefaultTimeout(IComponentIdentifier platform)
public static long getScaledRemoteDefaultTimeout(IComponentIdentifier platform, double scale)
public static long getLocalDefaultTimeout(IComponentIdentifier platform)
public static long getScaledLocalDefaultTimeout(IComponentIdentifier platform, double scale)
public static void setRemoteDefaultTimeout(IComponentIdentifier platform, long timeout)
public static void setLocalDefaultTimeout(IComponentIdentifier platform, long timeout)
public static boolean isRealtimeTimeout(IComponentIdentifier platform)
public static boolean isParameterCopy(IComponentIdentifier platform)