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

java.lang.Object
  org.globus.cog.karajan.workflow.nodes.FlowNode
      org.globus.cog.karajan.workflow.nodes.FlowContainer
          org.globus.cog.karajan.workflow.nodes.Parallel

All Implemented Interfaces:

LoadListener, EventListener, ExtendedFlowElement, FlowElement

Direct Known Subclasses:

ParallelChoice, UParallel

public class Parallel
extends FlowContainer

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.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

Parallel()

Method Summary

protected void	addChannelBuffers(VariableStack stack)
protected void	closeBuffers(VariableStack stack)
void	executeChildren(VariableStack stack)
protected void	initializeChannelBuffers(VariableStack stack)
protected void	notificationEvent(NotificationEvent e)
void	pre(VariableStack stack)
protected int	preDecRunning(VariableStack stack)
protected int	preIncRunning(VariableStack stack)
protected void	setRunning(VariableStack stack, int running)

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

execute, getChildFailed, initializeStatic, 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, startElement, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

Parallel

public Parallel()

Method Detail

pre

public void pre(VariableStack stack)
         throws ExecutionException

Overrides:

pre in class FlowContainer

Throws:

ExecutionException

executeChildren

public void executeChildren(VariableStack stack)
                     throws ExecutionException

Specified by:

executeChildren in class FlowContainer

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

Throws:

ExecutionException

setRunning

protected final void setRunning(VariableStack stack,
                                int running)

preDecRunning

protected final int preDecRunning(VariableStack stack)

preIncRunning

protected final int preIncRunning(VariableStack stack)

notificationEvent

protected void notificationEvent(NotificationEvent e)
                          throws ExecutionException

Overrides:

notificationEvent in class FlowNode

Throws:

ExecutionException