org.apache.oodt.cas.workflow.engine.runner

Class ResourceRunner

java.lang.Object

org.apache.oodt.cas.workflow.engine.runner.EngineRunner

org.apache.oodt.cas.workflow.engine.runner.AbstractEngineRunnerBase

org.apache.oodt.cas.workflow.engine.runner.ResourceRunner

All Implemented Interfaces:

CoreMetKeys, WorkflowStatus

public class ResourceRunner
extends AbstractEngineRunnerBase
implements CoreMetKeys, WorkflowStatus

Submits a WorkflowTask to the Resource Manager.

Version:

$Revision$

Author:

mattmann

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	DEFAULT_QUEUE_NAME
protected XmlRpcResourceManagerClient	rClient

Fields inherited from class org.apache.oodt.cas.workflow.engine.runner.AbstractEngineRunnerBase

instRep

Fields inherited from interface org.apache.oodt.cas.workflow.metadata.CoreMetKeys

JOB_ID, PROCESSING_NODE, QUEUE_NAME, TASK_ID, TASK_LOAD, WORKFLOW_ID, WORKFLOW_INST_ID, WORKFLOW_MANAGER_URL, WORKFLOW_NAME

Fields inherited from interface org.apache.oodt.cas.workflow.structs.WorkflowStatus

CREATED, ERROR, FINISHED, METADATA_MISSING, PAUSED, QUEUED, RESMGR_SUBMIT, STARTED

Constructor Summary

Constructors

Constructor and Description
ResourceRunner(URL resUrl, WorkflowInstanceRepository instRep)

Method Summary

Modifier and Type	Method and Description
void	execute(TaskProcessor taskProcessor) Executes a TaskProcessor on an execution substrate.
boolean	hasOpenSlots(TaskProcessor taskProcessor) Decides whether or not there are available slots within this runner to execute the provided TaskProcessor.
protected boolean	safeCheckJobComplete(String jobId)
void	setInstanceRepository(WorkflowInstanceRepository instRep)
void	shutdown() Shuts this runner down and frees its resources.
protected boolean	stopJob(String jobId)

Methods inherited from class org.apache.oodt.cas.workflow.engine.runner.AbstractEngineRunnerBase

getLifecycle, getTaskFromProcessor, persist

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_QUEUE_NAME

protected static final String DEFAULT_QUEUE_NAME

See Also:

Constant Field Values

rClient

protected XmlRpcResourceManagerClient rClient

Constructor Detail

ResourceRunner

public ResourceRunner(URL resUrl,
                      WorkflowInstanceRepository instRep)

Method Detail

execute

public void execute(TaskProcessor taskProcessor)

Description copied from class: EngineRunner

Executes a TaskProcessor on an execution substrate. Ideally there will only ever be two of these substrates, one for local execution, and another for communication with the Resource Manager.

Specified by:

execute in class EngineRunner

Parameters:

taskProcessor - The TaskProcessor to instantiate and execute.

shutdown

public void shutdown()

Description copied from class: EngineRunner

Shuts this runner down and frees its resources.

Specified by:

shutdown in class EngineRunner

hasOpenSlots

public boolean hasOpenSlots(TaskProcessor taskProcessor)

Description copied from class: EngineRunner

Decides whether or not there are available slots within this runner to execute the provided TaskProcessor.

Specified by:

hasOpenSlots in class EngineRunner

Parameters:

taskProcessor - The TaskProcessor to execute.

Returns:

True if there is an open slot, false otherwise.

setInstanceRepository

public void setInstanceRepository(WorkflowInstanceRepository instRep)

Specified by:

setInstanceRepository in class EngineRunner

safeCheckJobComplete

protected boolean safeCheckJobComplete(String jobId)

stopJob

protected boolean stopJob(String jobId)