org.globus.cog.karajan.workflow.nodes.user
Class ParallelImplicitExecutionUDE

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.user.UserDefinedElement
                      org.globus.cog.karajan.workflow.nodes.user.ParallelImplicitExecutionUDE

All Implemented Interfaces:

LoadListener, NonCacheable, EventListener, ExtendedFlowElement, FlowElement

public class ParallelImplicitExecutionUDE
extends UserDefinedElement

Nested Class Summary

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

FlowNode.FNTP

Field Summary

static org.apache.log4j.Logger	logger
static String	WRAPPER

Fields inherited from class org.globus.cog.karajan.workflow.nodes.user.UserDefinedElement

A_ARGUMENTS, A_CHANNELS, A_NAME, A_NAMED, A_OPTARGS, A_VARGS, ARGUMENTS_THREAD, BODY_THREAD, FNARGS, KMODE, NO_ARGUMENTS, NO_CHANNELS, PREFIX, SKIP, START_BODY

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

ParallelImplicitExecutionUDE()

Method Summary

protected void	closeArgs(VariableStack stack)
protected Arguments	getUDEArguments(VariableStack stack)
protected void	notificationEvent(NotificationEvent e)
protected void	prepareArguments(VariableStack stack, UDEWrapper wrapper)
protected void	prepareInstanceArguments(VariableStack stack, Arguments fnargs)
protected void	setArguments(VariableStack stack)
protected void	startArguments(VariableStack stack, UDEWrapper wrapper)
void	startInstance(VariableStack stack, UDEWrapper wrapper, DefinitionEnvironment env)

Methods inherited from class org.globus.cog.karajan.workflow.nodes.user.UserDefinedElement

addStaticArgument, checkBothArgs, checkFirstArg, childCompleted, controlEvent, executeChildren, getArguments, getChannels, getEnv, getKmode, getOptargs, getSkip, getTextualName, hasChannels, hasNamed, hasNestedArgs, hasVargs, initializeStatic, isArgumentsThread, pre, setProperties, setProperty, setUDEArguments, startBody

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

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

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

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

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

execute, getChildFailed, isOptimizable, post, setChildFailed, setOptimize

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

_finally, abort, abortEvent, acceptsInlineText, addElement, checkClass, checkCompleted, checkFailed, complete, copy, echo, echo, elementCount, elements, event, executeErrorHandler, executeSimple, fail, fail, failIfNotDefined, failIfNull, failIfNull, failImmediately, failImmediately, failImmediately, failImmediately, fireControlEvent, fireMonitoringEvent, fireNotificationEvent, fireStatusMonitoringEvent, get_locator, getBooleanProperty, getBooleanProperty, getCanonicalType, getElement, getElementType, getIntProperty, getIntProperty, getParent, getProperty, getStaticArguments, getStringProperty, 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, setProperty, setProperty, setStaticArguments, start, startElement, toString

Methods inherited from class java.lang.Object

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

Field Detail

logger

public static final org.apache.log4j.Logger logger

WRAPPER

public static final String WRAPPER

See Also:

Constant Field Values

Constructor Detail

ParallelImplicitExecutionUDE

public ParallelImplicitExecutionUDE()

Method Detail

startInstance

public void startInstance(VariableStack stack,
                          UDEWrapper wrapper,
                          DefinitionEnvironment env)
                   throws ExecutionException

Specified by:

startInstance in class UserDefinedElement

Throws:

ExecutionException

prepareArguments

protected void prepareArguments(VariableStack stack,
                                UDEWrapper wrapper)
                         throws ExecutionException

Throws:

ExecutionException

startArguments

protected void startArguments(VariableStack stack,
                              UDEWrapper wrapper)
                       throws ExecutionException

Overrides:

startArguments in class UserDefinedElement

Throws:

ExecutionException

closeArgs

protected void closeArgs(VariableStack stack)
                  throws ExecutionException

Throws:

ExecutionException

setArguments

protected void setArguments(VariableStack stack)

getUDEArguments

protected Arguments getUDEArguments(VariableStack stack)
                             throws ExecutionException

Throws:

ExecutionException

notificationEvent

protected void notificationEvent(NotificationEvent e)
                          throws ExecutionException

Overrides:

notificationEvent in class Sequential

Throws:

ExecutionException

prepareInstanceArguments

protected void prepareInstanceArguments(VariableStack stack,
                                        Arguments fnargs)
                                 throws ExecutionException

Overrides:

prepareInstanceArguments in class UserDefinedElement

Throws:

ExecutionException