com.netflix.genie.agent.execution.process.impl

Class JobProcessManagerImpl

java.lang.Object

com.netflix.genie.agent.execution.process.impl.JobProcessManagerImpl

All Implemented Interfaces:

JobProcessManager, java.util.EventListener, org.springframework.context.ApplicationListener<KillService.KillEvent>

public class JobProcessManagerImpl
extends java.lang.Object
implements JobProcessManager

Configures and launches a job sub-process using metadata passed through ExecutionContext.

Since:

4.0.0

Constructor Summary

Constructors

Constructor and Description
JobProcessManagerImpl(org.springframework.scheduling.TaskScheduler taskScheduler) Constructor.

Method Summary

Modifier and Type	Method and Description
void	kill(KillService.KillSource source) Terminate job process execution (if still running) or prevent it from launching (if not launched yet).
void	launchProcess(java.io.File jobDirectory, java.util.Map<java.lang.String,java.lang.String> environmentVariablesMap, java.util.List<java.lang.String> commandArguments, java.util.List<java.lang.String> jobArguments, boolean interactive, java.lang.Integer timeout) Launch the job process (unless launch was aborted by previous a kill call).
void	onApplicationEvent(KillService.KillEvent event)
JobProcessResult	waitFor() Wait indefinitely for the job process to terminate.

Methods inherited from class java.lang.Object

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

Constructor Detail

JobProcessManagerImpl

public JobProcessManagerImpl(org.springframework.scheduling.TaskScheduler taskScheduler)

Constructor.

Parameters:

taskScheduler - The TaskScheduler instance to use to run scheduled asynchronous tasks

Method Detail

launchProcess

public void launchProcess(java.io.File jobDirectory,
                          java.util.Map<java.lang.String,java.lang.String> environmentVariablesMap,
                          java.util.List<java.lang.String> commandArguments,
                          java.util.List<java.lang.String> jobArguments,
                          boolean interactive,
                          @Nullable
                          java.lang.Integer timeout)
                   throws JobLaunchException

Launch the job process (unless launch was aborted by previous a kill call).

Specified by:

launchProcess in interface JobProcessManager

Parameters:

jobDirectory - Job directory

environmentVariablesMap - additional environment variables (to merge on top of inherited environment)

commandArguments - command-line executable and its fixed arguments arguments

jobArguments - job-specific arguments

interactive - launch in interactive mode (inherit I/O) or batch (no input, write outputs to files)

timeout - The optional number of seconds this job is allowed to run before the system will kill it

Throws:

JobLaunchException - if the job process failed to launch

kill

public void kill(KillService.KillSource source)

Terminate job process execution (if still running) or prevent it from launching (if not launched yet). Optionally sends SIGINT to the process (unnecessary under certain circumstances. For example, CTRL-C in a terminal session, is already received by the job process, issuing a second one is unneeded).

Specified by:

kill in interface JobProcessManager

Parameters:

source - The KillService.KillSource value representing where this kill request is coming from

waitFor

public JobProcessResult waitFor()
                         throws java.lang.InterruptedException

Wait indefinitely for the job process to terminate.

Specified by:

waitFor in interface JobProcessManager

Returns:

KILLED, SUCCESSFUL, or FAILED

Throws:

java.lang.InterruptedException - if the calling thread is interrupted while waiting

onApplicationEvent

public void onApplicationEvent(KillService.KillEvent event)

Specified by:

onApplicationEvent in interface org.springframework.context.ApplicationListener<KillService.KillEvent>