org.globus.cog.karajan.workflow.nodes
Class AbstractUParallelIterator

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.PartialArgumentsContainer
                      org.globus.cog.karajan.workflow.nodes.AbstractIterator
                          org.globus.cog.karajan.workflow.nodes.AbstractParallelIterator
                              org.globus.cog.karajan.workflow.nodes.AbstractUParallelIterator

All Implemented Interfaces:

LoadListener, EventListener, ExtendedFlowElement, FlowElement

Direct Known Subclasses:

UParallelFor

public abstract class AbstractUParallelIterator
extends AbstractParallelIterator

Nested Class Summary

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

FlowNode.FNTP

Field Summary

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

logger

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

A_IN, A_NAME, ITERATE, ITERATOR, VAR

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

AbstractUParallelIterator()

Method Summary

protected void	addChannelBuffers(VariableStack stack)
protected void	closeBuffers(VariableStack stack) This must be called before a leave
protected void	initializeChannelBuffers(VariableStack stack)

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

citerate, iterate, iterationCompleted, nonArgChildCompleted, notificationEvent, testAndSetChildFailed

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

iterate, partialArgumentsEvaluated, preDecRunning, preIncRunning, setRunning

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

childCompleted, executeChildren, executeSingle, getArgCount, getArgsDone, initializeStatic, setArgsDone, startRest

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

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

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

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, 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, fireNotificationEvent, 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

Constructor Detail

AbstractUParallelIterator

public AbstractUParallelIterator()

Method Detail

addChannelBuffers

protected void addChannelBuffers(VariableStack stack)
                          throws ExecutionException

Overrides:

addChannelBuffers in class AbstractParallelIterator

Throws:

ExecutionException

closeBuffers

protected void closeBuffers(VariableStack stack)
                     throws ExecutionException

Description copied from class: AbstractParallelIterator

This must be called before a leave

Overrides:

closeBuffers in class AbstractParallelIterator

Throws:

ExecutionException

initializeChannelBuffers

protected void initializeChannelBuffers(VariableStack stack)
                                 throws ExecutionException

Overrides:

initializeChannelBuffers in class AbstractParallelIterator

Throws:

ExecutionException