org.thales.punch.apps.shiva.worker.impl

Class PlanWorkerApplication

java.lang.Object

org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication

org.thales.punch.apps.shiva.worker.impl.PlanWorkerApplication

public class PlanWorkerApplication
extends AbstractWorkerApplication

Plans are executed differently than other shiva apps. A plan is a lightweight thread only in charge of fork-exec-ing a punchline every now and then.

Having one new process per plan is overkill in terms of RAM usage. Hence shiva uses one dedicated thread per plan.

Author:

jonathan

Field Summary

Fields inherited from class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication

application, applicationFolder, clusterName, confDirFolder, ephemeral, executionTime, hasStarted, lastExecutionStart, numExecution, platformReporter, workerId

Constructor Summary

Constructors

Constructor and Description
PlanWorkerApplication(String workerId, String clusterName, Path dataFolder, Path folder, org.thales.punch.libraries.shiva.api.Application application)

Method Summary

Modifier and Type	Method and Description
int	exitValue() exit value here refers to a thread that dies or not; thus the plan thread itself and not the subprocess executed by plan thread
boolean	isAlive()
boolean	start() Start a worker task, i.e.
void	stop() Stop a worker task, i.e.

Methods inherited from class org.thales.punch.apps.shiva.worker.impl.AbstractWorkerApplication

getApplication, getClusterName, getFolder, getName, getWorkerId, isEphemeral, isEverRunningTask, isStarted, launchChildApplication, started, taskShouldRunNow, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

PlanWorkerApplication

public PlanWorkerApplication(String workerId,
                             String clusterName,
                             Path dataFolder,
                             Path folder,
                             org.thales.punch.libraries.shiva.api.Application application)

Method Detail

isAlive

public boolean isAlive()

Specified by:

isAlive in class AbstractWorkerApplication

Returns:

true if the underlying process is started

start

public boolean start()

Description copied from class: AbstractWorkerApplication

Start a worker task, i.e. a child process. This method takes care of reporting errors to logs and reporters.

Specified by:

start in class AbstractWorkerApplication

Returns:

true if it has been started, false in case of failure

stop

public void stop()

Description copied from class: AbstractWorkerApplication

Stop a worker task, i.e. a child process

Specified by:

stop in class AbstractWorkerApplication

exitValue

public int exitValue()

exit value here refers to a thread that dies or not; thus the plan thread itself and not the subprocess executed by plan thread

Specified by:

exitValue in class AbstractWorkerApplication

Returns:

the process exit value