org.ow2.proactive.scheduler.task

Class TaskLauncher

java.lang.Object

org.ow2.proactive.scheduler.task.TaskLauncher

All Implemented Interfaces:

org.objectweb.proactive.Active, org.objectweb.proactive.InitActive

public class TaskLauncher
extends Object
implements org.objectweb.proactive.InitActive

The node side of task execution: - communicates with the Scheduler via ProActive - deals with data transfers - deals with task killing and walltime - sends result back to the Scheduler

Constructor Summary

Constructors

Constructor and Description
TaskLauncher() Needed for ProActive but should never be used manually to create an instance of the object.
TaskLauncher(TaskLauncherInitializer initializer)
TaskLauncher(TaskLauncherInitializer initializer, TaskLauncherFactory factory)

Method Summary

Modifier and Type	Method and Description
void	activateLogs(AppenderProvider logSink)
void	doTask(ExecutableContainer executableContainer, TaskResult[] previousTasksResults, TaskTerminateNotification terminateNotification, String terminateNotificationNodeURL, boolean taskRecoverable)
PublicKey	generatePublicKey()
KeyPair	getKeyPair()
int	getProgress()
void	getStoredLogs(AppenderProvider logSink)
void	initActivity(org.objectweb.proactive.Body body)
boolean	isActivated() Method used to wait until the TaskLauncher is activated (i.e.
boolean	isTaskStarted()
void	kill()

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskLauncher

public TaskLauncher()

Needed for ProActive but should never be used manually to create an instance of the object.

TaskLauncher

public TaskLauncher(TaskLauncherInitializer initializer,
                    TaskLauncherFactory factory)

TaskLauncher

public TaskLauncher(TaskLauncherInitializer initializer)

Method Detail

initActivity

public void initActivity(org.objectweb.proactive.Body body)

Specified by:

initActivity in interface org.objectweb.proactive.InitActive

isActivated

public boolean isActivated()

Method used to wait until the TaskLauncher is activated (i.e. the initActivity method has been run).

Returns:

dummy boolean value

isTaskStarted

public boolean isTaskStarted()

doTask

public void doTask(ExecutableContainer executableContainer,
                   TaskResult[] previousTasksResults,
                   TaskTerminateNotification terminateNotification,
                   String terminateNotificationNodeURL,
                   boolean taskRecoverable)

activateLogs

public void activateLogs(AppenderProvider logSink)

getStoredLogs

public void getStoredLogs(AppenderProvider logSink)

getKeyPair

public KeyPair getKeyPair()
                   throws NoSuchAlgorithmException

Throws:

NoSuchAlgorithmException

generatePublicKey

public PublicKey generatePublicKey()
                            throws NoSuchAlgorithmException

Throws:

NoSuchAlgorithmException

kill

public void kill()

getProgress

public int getProgress()