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

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

All Implemented Interfaces:

LoadListener, EventListener, ExtendedFlowElement, FlowElement

Direct Known Subclasses:

AbstractUParallelIterator, ParallelFor

public abstract class AbstractParallelIterator
extends AbstractIterator

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

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

AbstractParallelIterator()

Method Summary

protected void	addChannelBuffers(VariableStack stack)
protected void	citerate(VariableStack stack, Identifier var, KarajanIterator i)
protected void	closeBuffers(VariableStack stack) This must be called before a leave
protected void	initializeChannelBuffers(VariableStack stack)
void	iterate(VariableStack stack, Identifier var, KarajanIterator i)
protected void	iterationCompleted(VariableStack stack)
protected void	nonArgChildCompleted(VariableStack stack)
void	notificationEvent(NotificationEvent e)
protected boolean	testAndSetChildFailed(VariableStack stack)

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

Field Detail

logger

public static final org.apache.log4j.Logger logger

Constructor Detail

AbstractParallelIterator

public AbstractParallelIterator()

Method Detail

iterate

public void iterate(VariableStack stack,
                    Identifier var,
                    KarajanIterator i)
             throws ExecutionException

Specified by:

iterate in class AbstractIterator

Throws:

ExecutionException

citerate

protected void citerate(VariableStack stack,
                        Identifier var,
                        KarajanIterator i)
                 throws ExecutionException

Throws:

ExecutionException

initializeChannelBuffers

protected void initializeChannelBuffers(VariableStack stack)
                                 throws ExecutionException

Throws:

ExecutionException

addChannelBuffers

protected void addChannelBuffers(VariableStack stack)
                          throws ExecutionException

Throws:

ExecutionException

closeBuffers

protected void closeBuffers(VariableStack stack)
                     throws ExecutionException

This must be called before a leave

Throws:

ExecutionException

iterationCompleted

protected void iterationCompleted(VariableStack stack)
                           throws ExecutionException

Throws:

ExecutionException

nonArgChildCompleted

protected void nonArgChildCompleted(VariableStack stack)
                             throws ExecutionException

Overrides:

nonArgChildCompleted in class PartialArgumentsContainer

Throws:

ExecutionException

testAndSetChildFailed

protected boolean testAndSetChildFailed(VariableStack stack)

notificationEvent

public void notificationEvent(NotificationEvent e)
                       throws ExecutionException

Overrides:

notificationEvent in class Sequential

Throws:

ExecutionException