alma.acs.commandcenter.engine

Class Executor

java.lang.Object

alma.acs.commandcenter.engine.Executor

public class Executor
extends java.lang.Object

Author:

mschilli

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Executor.LocalInProcFlow
protected static class	Executor.LocalInProcStream
static class	Executor.LocalOutProcFlow
static class	Executor.RemoteContainerDaemonFlow
static class	Executor.RemoteFlow
static class	Executor.RemoteServicesDaemonFlow
static interface	Executor.RunMain
static class	Executor.SingleStepFlow

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.util.Vector<Connection>	connections
static boolean	disableRemote
static Executor.LocalInProcFlow	localInProcFlow
static Executor.LocalOutProcFlow	localOutProcFlow
static Executor.RemoteContainerDaemonFlow	remoteContainerDaemonFlow
static int	remoteDaemonForContainersCompletionDelay
static Executor.RemoteFlow	remoteFlow
static Executor.RemoteServicesDaemonFlow	remoteServicesDaemonFlow
protected static java.util.Vector<Session>	sessions
static Executor.SingleStepFlow	singleStepFlow
static java.lang.String	SYSPROP_COMMAND_NATIVE_SSH

Constructor Summary

Constructors

Constructor and Description
Executor()

Method Summary

Modifier and Type	Method and Description
static void	local(Executor.RunMain runMain) The only sense of this is to have a flow for normal java instructions that may take a while.
static void	localInProc(java.util.Properties properties, java.lang.String pexpect, NativeCommand.Listener listener, Executor.RunMain runMain)
static void	localOutProc(java.lang.String command, boolean foreground, long maxExecutionTime, java.lang.String endMark, NativeCommand.Listener listener)
static boolean	remote(boolean nativeSSH, java.lang.String username, java.lang.String password, java.lang.String command, java.lang.String endMark, NativeCommand.Listener listener, java.lang.String host)
static void	remoteDaemonEnable(Firestarter fs)
static java.lang.Exception	remoteDaemonForContainers(java.lang.String host, int instance, boolean startStop, java.lang.String contName, java.lang.String contType, java.lang.String[] contTypeMods, java.lang.String cmdFlags, NativeCommand.Listener listener)
static java.lang.Exception	remoteDaemonForServices(java.lang.String host, int instance, boolean startStop, java.lang.String cmdFlags, NativeCommand.Listener listener) Starts or stops ACS via the ACS services daemon.
static void	remoteDownAll()

Methods inherited from class java.lang.Object

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

Field Detail

disableRemote

public static boolean disableRemote

SYSPROP_COMMAND_NATIVE_SSH

public static final java.lang.String SYSPROP_COMMAND_NATIVE_SSH

See Also:

Constant Field Values

remoteFlow

public static Executor.RemoteFlow remoteFlow

localInProcFlow

public static Executor.LocalInProcFlow localInProcFlow

localOutProcFlow

public static Executor.LocalOutProcFlow localOutProcFlow

singleStepFlow

public static Executor.SingleStepFlow singleStepFlow

remoteServicesDaemonFlow

public static Executor.RemoteServicesDaemonFlow remoteServicesDaemonFlow

remoteContainerDaemonFlow

public static Executor.RemoteContainerDaemonFlow remoteContainerDaemonFlow

connections

protected static java.util.Vector<Connection> connections

sessions

protected static java.util.Vector<Session> sessions

remoteDaemonForContainersCompletionDelay

public static int remoteDaemonForContainersCompletionDelay

Constructor Detail

Executor

public Executor()

Method Detail

remote

public static boolean remote(boolean nativeSSH,
                             java.lang.String username,
                             java.lang.String password,
                             java.lang.String command,
                             java.lang.String endMark,
                             NativeCommand.Listener listener,
                             java.lang.String host)
                      throws java.lang.Throwable

Returns:

false - if this failed gracefully

Throws:

java.io.IOException - - if this failed severely

java.lang.Throwable

remoteDownAll

public static void remoteDownAll()

localInProc

public static void localInProc(java.util.Properties properties,
                               java.lang.String pexpect,
                               NativeCommand.Listener listener,
                               Executor.RunMain runMain)

Parameters:

properties - the properties to insert (and override) into the system properties

pexpect - as soon as the process writes this to stdout, this method returns

listener - a proprietary listener if the caller wants to hear about the process' output

runMain - a callback that will be invoked by the newly spawned thread

local

public static void local(Executor.RunMain runMain)

The only sense of this is to have a flow for normal java instructions that may take a while.

Parameters:

runMain - the java instructions to perform

localOutProc

public static void localOutProc(java.lang.String command,
                                boolean foreground,
                                long maxExecutionTime,
                                java.lang.String endMark,
                                NativeCommand.Listener listener)
                         throws java.lang.Throwable

Throws:

java.lang.Throwable

remoteDaemonEnable

public static void remoteDaemonEnable(Firestarter fs)

remoteDaemonForServices

public static java.lang.Exception remoteDaemonForServices(java.lang.String host,
                                                          int instance,
                                                          boolean startStop,
                                                          java.lang.String cmdFlags,
                                                          NativeCommand.Listener listener)

Starts or stops ACS via the ACS services daemon. This call returns only when the action has completed. Exceptions will be returned instead of thrown.

Returns:

any exception that occurs underways

remoteDaemonForContainers

public static java.lang.Exception remoteDaemonForContainers(java.lang.String host,
                                                            int instance,
                                                            boolean startStop,
                                                            java.lang.String contName,
                                                            java.lang.String contType,
                                                            java.lang.String[] contTypeMods,
                                                            java.lang.String cmdFlags,
                                                            NativeCommand.Listener listener)

Parameters:

startStop - - if true, the daemon starts the container, otherwise stops it. @todo rethink how useful this overloading is.

contType - - only needed for starting (i.e. startStop==true)

contTypeMods - - only needed for starting (i.e. startStop==true)

See Also:

http://www.eso.org/projects/alma/develop/acs/OnlineDocs/ACS_docs/schemas/urn_schemas-cosylab-com_Container_1.0/complexType/DeployInfo.html