org.globus.cog.karajan.workflow.nodes.grid
Class GridExec

java.lang.Object
  org.globus.cog.karajan.workflow.nodes.FlowNode
      org.globus.cog.karajan.workflow.nodes.FlowContainer
          org.globus.cog.karajan.workflow.nodes.Sequential
              org.globus.cog.karajan.workflow.nodes.AbstractSequentialWithArguments
                  org.globus.cog.karajan.workflow.nodes.SequentialWithArguments
                      org.globus.cog.karajan.workflow.nodes.grid.AbstractGridNode
                          org.globus.cog.karajan.workflow.nodes.grid.GridExec

All Implemented Interfaces:

StatusListener, LoadListener, EventListener, ExtendedFlowElement, FlowElement

public class GridExec
extends AbstractGridNode
implements StatusListener

Nested Class Summary

Nested classes/interfaces inherited from class org.globus.cog.karajan.workflow.nodes.FlowNode

FlowNode.FNTP

Field Summary

static Arg	A_ARGS
static Arg	A_ARGUMENTS
static Arg	A_ATTRIBUTES
static Arg	A_BATCH
static Arg	A_COUNT
static Arg	A_DELEGATION
static Arg	A_DIRECTORY
static Arg	A_ENVIRONMENT
static Arg	A_EXECUTABLE
static Arg	A_FAIL_ON_JOB_ERROR
static Arg	A_HOST
static Arg	A_HOST_COUNT
static Arg	A_JOBTYPE
static Arg	A_MAXCPUTIME
static Arg	A_MAXMEMORY
static Arg	A_MAXTIME
static Arg	A_MAXWALLTIME
static Arg	A_MINMEMORY
static Arg	A_NATIVESPEC
static Arg	A_PROJECT
static Arg	A_PROVIDER
static Arg	A_QUEUE
static Arg	A_REDIRECT
static Arg	A_SECURITY_CONTEXT
static Arg	A_STDERR
static Arg	A_STDERRLOCATION
static Arg	A_STDIN
static Arg	A_STDOUT
static Arg	A_STDOUTLOCATION
static Arg.Channel	C_ENVIRONMENT

Fields inherited from class org.globus.cog.karajan.workflow.nodes.grid.AbstractGridNode

HANDLER, tasks

Fields inherited from class org.globus.cog.karajan.workflow.nodes.AbstractSequentialWithArguments

QUOTED

Fields inherited from class org.globus.cog.karajan.workflow.nodes.FlowNode

A_INLINE_TEXT, debug, startCount, STDERR, STDOUT, threadTracker

Fields inherited from interface org.globus.cog.karajan.workflow.nodes.FlowElement

ANNOTATION, CALLER, FILENAME, LINE, TEXT, UID

Constructor Summary

GridExec()

Method Summary

protected void	returnOutputs(Task t, VariableStack stack)
void	submitTask(VariableStack stack)
protected void	taskCompleted(StatusEvent e, VariableStack stack)
protected void	taskFailed(StatusEvent e, VariableStack stack)

Methods inherited from class org.globus.cog.karajan.workflow.nodes.grid.AbstractGridNode

abortEvent, fireNotificationEvent, getHost, getScheduler, getSecurityContext, post, removeTask, setSecurityContext, setSecurityContextIfNotLocal, statusChanged, submitScheduled, submitUnscheduled

Methods inherited from class org.globus.cog.karajan.workflow.nodes.AbstractSequentialWithArguments

addChannel, argumentsEvaluated, checkArguments, childCompleted, getArgument, getArgumentCount, getArgumentIndex, getArgumentNames, getArguments, getChannels, getMaxArgIndex, getNonpropargs, getOptionalArgs, getQuotedArgs, getSortedArgs, hasChannels, hasNestedArguments, hasVariableArguments, initializeArgs, initializeStatic, newNameBindingVariableArguments, newVariableArguments, pre, processArguments, setArguments, setHasVargs, setNestedArgs, setNonpropargs, setQuotedArgs, setVargs

Methods inherited from class org.globus.cog.karajan.workflow.nodes.Sequential

executeChildren, executeSingle, exit, getIndex, moreToExecute, notificationEvent, preDecIndex, preIncIndex, setIndex, startElement, startNext

Methods inherited from class org.globus.cog.karajan.workflow.nodes.FlowContainer

execute, getChildFailed, isOptimizable, setChildFailed, setOptimize

Methods inherited from class org.globus.cog.karajan.workflow.nodes.FlowNode

_finally, abort, acceptsInlineText, addElement, addStaticArgument, checkClass, checkCompleted, checkFailed, complete, controlEvent, copy, echo, echo, elementCount, elements, event, executeErrorHandler, executeSimple, fail, fail, failIfNotDefined, failIfNull, failIfNull, failImmediately, failImmediately, failImmediately, failImmediately, fireControlEvent, fireMonitoringEvent, fireStatusMonitoringEvent, get_locator, getBooleanProperty, getBooleanProperty, getCanonicalType, getElement, getElementType, getIntProperty, getIntProperty, getParent, getProperty, getStaticArguments, getStringProperty, getTextualName, getTreeProperty, getUID, hasFrame, hasProperty, isCheckpointable, isSimple, isSystemProperty, loadComplete, loadStarted, monitoringEvent, propertyNames, removeElement, removeElement, removeProperty, replaceElement, restart, restartElement, ret, set_locator, setAcceptsInlineText, setCheckpointable, setElements, setElementType, setFrame, setParent, setProperties, setProperty, setProperty, setProperty, setStaticArguments, start, startElement, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.globus.cog.abstraction.interfaces.StatusListener

statusChanged

Field Detail

A_EXECUTABLE

public static final Arg A_EXECUTABLE

A_ARGS

public static final Arg A_ARGS

A_ARGUMENTS

public static final Arg A_ARGUMENTS

A_HOST

public static final Arg A_HOST

A_STDOUT

public static final Arg A_STDOUT

A_STDERR

public static final Arg A_STDERR

A_STDOUTLOCATION

public static final Arg A_STDOUTLOCATION

A_STDERRLOCATION

public static final Arg A_STDERRLOCATION

A_STDIN

public static final Arg A_STDIN

A_PROVIDER

public static final Arg A_PROVIDER

A_SECURITY_CONTEXT

public static final Arg A_SECURITY_CONTEXT

A_COUNT

public static final Arg A_COUNT

A_HOST_COUNT

public static final Arg A_HOST_COUNT

A_JOBTYPE

public static final Arg A_JOBTYPE

A_MAXTIME

public static final Arg A_MAXTIME

A_MAXWALLTIME

public static final Arg A_MAXWALLTIME

A_MAXCPUTIME

public static final Arg A_MAXCPUTIME

A_ENVIRONMENT

public static final Arg A_ENVIRONMENT

A_QUEUE

public static final Arg A_QUEUE

A_PROJECT

public static final Arg A_PROJECT

A_MINMEMORY

public static final Arg A_MINMEMORY

A_MAXMEMORY

public static final Arg A_MAXMEMORY

A_REDIRECT

public static final Arg A_REDIRECT

A_DIRECTORY

public static final Arg A_DIRECTORY

A_NATIVESPEC

public static final Arg A_NATIVESPEC

A_DELEGATION

public static final Arg A_DELEGATION

C_ENVIRONMENT

public static final Arg.Channel C_ENVIRONMENT

A_ATTRIBUTES

public static final Arg A_ATTRIBUTES

A_FAIL_ON_JOB_ERROR

public static final Arg A_FAIL_ON_JOB_ERROR

A_BATCH

public static final Arg A_BATCH

Constructor Detail

GridExec

public GridExec()

Method Detail

submitTask

public void submitTask(VariableStack stack)
                throws ExecutionException

Specified by:

submitTask in class AbstractGridNode

Throws:

ExecutionException

taskFailed

protected void taskFailed(StatusEvent e,
                          VariableStack stack)
                   throws ExecutionException

Overrides:

taskFailed in class AbstractGridNode

Throws:

ExecutionException

taskCompleted

protected void taskCompleted(StatusEvent e,
                             VariableStack stack)
                      throws ExecutionException

Overrides:

taskCompleted in class AbstractGridNode

Throws:

ExecutionException

returnOutputs

protected void returnOutputs(Task t,
                             VariableStack stack)
                      throws ExecutionException

Throws:

ExecutionException