org.globus.cog.karajan.workflow.service
Class RemoteNode

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

All Implemented Interfaces:

LoadListener, EventListener, ExtendedFlowElement, FlowElement, Command.Callback

public class RemoteNode
extends PartialArgumentsContainer
implements Command.Callback

Nested Class Summary

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

FlowNode.FNTP

Field Summary

static Arg	A_HOST
static String	CHANNEL
static String	COMMANDS
static String	HOST
static org.apache.log4j.Logger	logger
static String	REMOTE_FLAG
static String	SOURCE_HOST
static String	SOURCE_ID

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

RemoteNode()

Method Summary

void	errorReceived(Command cmd, String msg, Exception t)
protected GSSCredential	getCredential(VariableStack stack)
protected void	nonArgChildCompleted(VariableStack stack)
protected void	notificationEvent(NotificationEvent e)
protected void	partialArgumentsEvaluated(VariableStack stack)
protected void	register(Command cmd, VariableStack stack)
protected void	register(Object obj, VariableStack stack)
void	replyReceived(Command cmd)
protected VariableStack	unregister(Object obj)

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

A_HOST

public static final Arg A_HOST

HOST

public static final String HOST

See Also:

Constant Field Values

SOURCE_HOST

public static final String SOURCE_HOST

See Also:

Constant Field Values

SOURCE_ID

public static final String SOURCE_ID

See Also:

Constant Field Values

REMOTE_FLAG

public static final String REMOTE_FLAG

See Also:

Constant Field Values

CHANNEL

public static final String CHANNEL

See Also:

Constant Field Values

COMMANDS

public static final String COMMANDS

See Also:

Constant Field Values

Constructor Detail

RemoteNode

public RemoteNode()

Method Detail

partialArgumentsEvaluated

protected void partialArgumentsEvaluated(VariableStack stack)
                                  throws ExecutionException

Overrides:

partialArgumentsEvaluated in class PartialArgumentsContainer

Throws:

ExecutionException

register

protected void register(Command cmd,
                        VariableStack stack)

register

protected void register(Object obj,
                        VariableStack stack)

unregister

protected VariableStack unregister(Object obj)

getCredential

protected GSSCredential getCredential(VariableStack stack)
                               throws ExecutionException

Throws:

ExecutionException

replyReceived

public void replyReceived(Command cmd)

Specified by:

replyReceived in interface Command.Callback

errorReceived

public void errorReceived(Command cmd,
                          String msg,
                          Exception t)

Specified by:

errorReceived in interface Command.Callback

nonArgChildCompleted

protected void nonArgChildCompleted(VariableStack stack)
                             throws ExecutionException

Overrides:

nonArgChildCompleted in class PartialArgumentsContainer

Throws:

ExecutionException

notificationEvent

protected void notificationEvent(NotificationEvent e)
                          throws ExecutionException

Overrides:

notificationEvent in class Sequential

Throws:

ExecutionException