org.ow2.proactive.scheduler.task

Class TaskStateImpl

java.lang.Object

org.ow2.proactive.scheduler.common.task.CommonAttribute

org.ow2.proactive.scheduler.common.task.Task

org.ow2.proactive.scheduler.common.task.TaskState

org.ow2.proactive.scheduler.task.TaskStateImpl

All Implemented Interfaces:

Serializable, Comparable<TaskState>

public class TaskStateImpl
extends TaskState

See Also:

Serialized Form

Field Summary

Fields inherited from class org.ow2.proactive.scheduler.common.task.TaskState

ASC_ORDER, COMPARE_BY_FINISHED_TIME_ASC, currentOrder, currentSort, DESC_ORDER, SORT_BY_DESCRIPTION, SORT_BY_EXEC_DURATION, SORT_BY_EXECUTIONLEFT, SORT_BY_EXECUTIONONFAILURELEFT, SORT_BY_FINISHED_TIME, SORT_BY_HOST_NAME, SORT_BY_ID, SORT_BY_NAME, SORT_BY_STARTED_TIME, SORT_BY_STATUS

Fields inherited from class org.ow2.proactive.scheduler.common.task.Task

cScript, description, flowBlock, flowScript, forkEnvironment, inputFiles, name, outputFiles, parallelEnvironment, postScript, preciousLogs, preciousResult, preScript, runAsMe, sScripts, tag, variables, wallTime

Fields inherited from class org.ow2.proactive.scheduler.common.task.CommonAttribute

GENERIC_INFO_START_AT_KEY, genericInformation, maxNumberOfExecution, onTaskError, restartTaskOnError, unresolvedGenericInformation

Constructor Summary

Constructors

Constructor and Description
TaskStateImpl()

Method Summary

Modifier and Type	Method and Description
List<TaskState>	getDependences() To get the dependences of this task.
int	getIterationIndex() When Control Flow actions are performed (see Task.getFlowScript()), some tasks are replicated.
int	getMaxNumberOfExecutionOnFailure() Get the number of execution on failure allowed by the task.
int	getReplicationIndex() When Control Flow actions are performed (see Task.getFlowScript()), some tasks are replicated.
TaskInfo	getTaskInfo() To get the taskInfo
TaskState	replicate() Replicates a task
void	setIterationIndex(int iterationIndex)
void	setMaxNumberOfExecutionOnFailure(int maxNumberOfExecutionOnFailure)
void	setReplicationIndex(int replicationIndex)
void	update(TaskInfo taskInfo) To update this taskState using a taskInfo

Methods inherited from class org.ow2.proactive.scheduler.common.task.TaskState

addDependence, addDependences, compareTo, equals, getDependencesList, getExecutionDuration, getExecutionHostName, getExecutionHostNameList, getFinishedTime, getId, getJobId, getName, getNumberOfExecutionLeft, getNumberOfExecutionOnFailureLeft, getProgress, getRuntimeGenericInformation, getRuntimeVariables, getScheduledTime, getScopeVariables, getStartTime, getStatus, getSystemVariables, hashCode, isTaskAlive, setSortingBy, setSortingOrder, toString

Methods inherited from class org.ow2.proactive.scheduler.common.task.Task

addInputFiles, addInputFiles, addOutputFiles, addOutputFiles, addSelectionScript, display, getCleaningScript, getDescription, getFlowBlock, getFlowScript, getForkEnvironment, getInputFilesList, getNumberOfNodesNeeded, getOutputFilesList, getParallelEnvironment, getPostScript, getPreScript, getSelectionScripts, getTag, getVariables, getVariablesOverriden, getWallTime, getWorkingDir, isParallel, isPreciousLogs, isPreciousResult, isRunAsMe, isWallTimeSet, setCleaningScript, setDescription, setFlowBlock, setFlowScript, setForkEnvironment, setName, setNumberOfNeededNodes, setParallelEnvironment, setPostScript, setPreciousLogs, setPreciousResult, setPreScript, setRunAsMe, setSelectionScript, setSelectionScripts, setTag, setVariables, setWallTime

Methods inherited from class org.ow2.proactive.scheduler.common.task.CommonAttribute

addGenericInformation, addGenericInformations, applyReplacementsOnGenericInformation, getGenericInformation, getMaxNumberOfExecution, getMaxNumberOfExecutionProperty, getOnTaskErrorProperty, getRestartTaskOnError, getRestartTaskOnErrorProperty, getUnresolvedGenericInformation, setGenericInformation, setMaxNumberOfExecution, setOnTaskError, setRestartTaskOnError, setUnresolvedGenericInformation

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

TaskStateImpl

public TaskStateImpl()

Method Detail

update

public void update(TaskInfo taskInfo)

Description copied from class: TaskState

To update this taskState using a taskInfo

Specified by:

update in class TaskState

Parameters:

taskInfo - the taskInfo to set

getDependences

public List<TaskState> getDependences()

Description copied from class: TaskState

To get the dependences of this task. Return null if this task has no dependence.

Specified by:

getDependences in class TaskState

Returns:

the dependences of this task

getTaskInfo

public TaskInfo getTaskInfo()

Description copied from class: TaskState

To get the taskInfo

Specified by:

getTaskInfo in class TaskState

Returns:

the taskInfo

setMaxNumberOfExecutionOnFailure

public void setMaxNumberOfExecutionOnFailure(int maxNumberOfExecutionOnFailure)

getMaxNumberOfExecutionOnFailure

public int getMaxNumberOfExecutionOnFailure()

Description copied from class: TaskState

Get the number of execution on failure allowed by the task.

Specified by:

getMaxNumberOfExecutionOnFailure in class TaskState

Returns:

the number of execution on failure allowed by the task

replicate

public TaskState replicate()
                    throws Exception

Description copied from class: TaskState

Replicates a task

Deep copies all fields, does not share any reference

Specified by:

replicate in class TaskState

Returns:

the newly created task, cast as a TaskState

Throws:

Exception

setIterationIndex

public void setIterationIndex(int iterationIndex)

getIterationIndex

public int getIterationIndex()

Description copied from class: TaskState

When Control Flow actions are performed (see Task.getFlowScript()), some tasks are replicated. A task replicated by a FlowActionType.LOOP action is differentiated from the original by an incremented Iteration Index.

Specified by:

getIterationIndex in class TaskState

Returns:

the iteration number of this task if it was replicated by a LOOP flow operation (>= 0)

setReplicationIndex

public void setReplicationIndex(int replicationIndex)

getReplicationIndex

public int getReplicationIndex()

Description copied from class: TaskState

When Control Flow actions are performed (see Task.getFlowScript()), some tasks are replicated. A task replicated by a FlowActionType.REPLICATE action is differentiated from the original by an incremented Replication Index.

Specified by:

getReplicationIndex in class TaskState

Returns:

the replication number of this task if it was replicated by a REPLICATE flow operations (>= 0)