Methods in org.globus.cog.karajan.workflow.nodes with parameters of type VariableStack |
protected void |
Exclusive._finally(VariableStack stack)
|
protected void |
FileWrite._finally(VariableStack stack)
|
protected void |
FlowNode._finally(VariableStack stack)
|
protected void |
EventWait.abort(VariableStack stack)
|
protected void |
FlowNode.abort(VariableStack stack)
|
void |
WaitNode.abort(VariableStack stack)
|
protected void |
AbstractParallelIterator.addChannelBuffers(VariableStack stack)
|
protected void |
AbstractUParallelIterator.addChannelBuffers(VariableStack stack)
|
protected void |
Parallel.addChannelBuffers(VariableStack stack)
|
protected void |
UParallel.addChannelBuffers(VariableStack stack)
|
protected void |
AbstractSequentialWithArguments.argumentsEvaluated(VariableStack stack)
|
protected void |
ChannelClose.argumentsEvaluated(VariableStack stack)
|
protected void |
ChannelFork.argumentsEvaluated(VariableStack stack)
|
protected void |
Info.argumentsEvaluated(VariableStack stack)
|
protected void |
Break.break_(VariableStack stack)
|
protected void |
Include.checkArgs(VariableStack stack)
|
protected void |
FlowNode.checkCompleted(VariableStack stack)
|
protected void |
FlowNode.checkFailed(VariableStack stack)
|
protected void |
AbstractSequentialWithArguments.childCompleted(VariableStack stack)
|
protected void |
If.childCompleted(VariableStack stack)
|
protected void |
Maybe.childCompleted(VariableStack stack)
|
protected void |
PartialArgumentsContainer.childCompleted(VariableStack stack)
|
protected void |
Sequential.childCompleted(VariableStack stack)
|
protected void |
SequentialChoice.childCompleted(VariableStack stack)
|
protected void |
AbstractParallelIterator.citerate(VariableStack stack,
Identifier var,
KarajanIterator i)
|
protected void |
AbstractParallelIterator.closeBuffers(VariableStack stack)
This must be called before a leave |
protected void |
AbstractUParallelIterator.closeBuffers(VariableStack stack)
|
protected void |
Parallel.closeBuffers(VariableStack stack)
|
protected void |
UParallel.closeBuffers(VariableStack stack)
|
protected void |
SequentialChoice.commitBuffers(VariableStack stack)
|
void |
FlowNode.complete(VariableStack stack)
|
protected void |
Continue.continue_(VariableStack stack)
|
protected void |
CacheNode.cpre(Object key,
VariableStack stack)
|
protected void |
Define.Definer.define(VariableStack stack,
String name,
String nsprefix,
Object def)
|
protected void |
Export.Definer.define(VariableStack stack,
String name,
String nsprefix,
Object def)
|
protected void |
Include.defineElements(VariableStack stack)
|
void |
WaitNode.delayElapsed(VariableStack stack,
org.globus.cog.karajan.workflow.nodes.WaitNode.Task task)
|
void |
Break.execute(VariableStack stack)
|
void |
Continue.execute(VariableStack stack)
|
void |
Disallowed.execute(VariableStack stack)
|
void |
ElementList.execute(VariableStack stack)
|
void |
FlowContainer.execute(VariableStack stack)
|
void |
FlowNode.execute(VariableStack stack)
|
protected abstract void |
FlowContainer.executeChildren(VariableStack stack)
|
void |
FutureNode.executeChildren(VariableStack stack)
|
void |
Parallel.executeChildren(VariableStack stack)
|
void |
ParallelChoice.executeChildren(VariableStack stack)
|
protected void |
PartialArgumentsContainer.executeChildren(VariableStack stack)
|
protected void |
Sequential.executeChildren(VariableStack stack)
|
protected void |
UnsynchronizedNode.executeChildren(VariableStack stack)
|
protected boolean |
GenerateErrorNode.executeErrorHandler(VariableStack stack,
FlowEvent error)
|
protected boolean |
FlowNode.executeErrorHandler(VariableStack stack,
NotificationEvent error)
|
void |
ExtendedFlowElement.executeSimple(VariableStack stack)
|
void |
FlowNode.executeSimple(VariableStack stack)
|
protected void |
PartialArgumentsContainer.executeSingle(VariableStack stack)
|
protected void |
Sequential.executeSingle(VariableStack stack)
|
protected void |
Sequential.exit(VariableStack stack)
Aborts the execution of any further sub-elements |
void |
FlowNode.fail(VariableStack stack,
String message)
|
void |
FlowNode.fail(VariableStack stack,
String message,
Throwable cause)
|
void |
FlowNode.failIfNotDefined(VariableStack stack,
String var,
String message)
|
void |
FlowNode.failIfNull(VariableStack stack,
String name)
|
void |
FlowNode.failIfNull(VariableStack stack,
String name,
String message)
|
void |
FlowNode.failImmediately(VariableStack stack,
FailureNotificationEvent fne)
|
void |
FlowElement.failImmediately(VariableStack stack,
String string)
Provides means to cause the execution of this element under the
given context (stack ) to fail |
void |
FlowNode.failImmediately(VariableStack stack,
String message)
|
void |
FlowNode.failImmediately(VariableStack stack,
String message,
Exception exception)
|
void |
FlowNode.failImmediately(VariableStack stack,
Throwable exception)
|
protected void |
Info.find(String prefix,
VariableStack stack,
VariableArguments stdout)
|
void |
FlowNode.fireNotificationEvent(FlowEvent event,
VariableStack stack)
Notification events notify callers of the status of the execution
(completed, failed, aborted, ...) |
void |
FlowNode.fireStatusMonitoringEvent(MonitoringEventType type,
VariableStack stack,
Object detail)
|
Object |
JavaMethodInvocationNode.function(VariableStack stack)
|
Object |
NewJavaObjectNode.function(VariableStack stack)
|
protected boolean |
PartialArgumentsContainer.getArgsDone(VariableStack stack)
|
protected Object |
AbstractSequentialWithArguments.getArgument(Arg arg,
VariableStack stack)
|
protected Object[] |
AbstractSequentialWithArguments.getArguments(Arg[] args,
VariableStack stack)
|
protected Arguments |
ExecuteElement.getArguments(VariableStack stack,
UserDefinedElement def)
|
protected Cache |
CacheNode.getCache(VariableStack stack)
|
protected Cache |
Once.getCache(VariableStack stack)
|
protected boolean |
FlowContainer.getChildFailed(VariableStack stack)
|
protected StackFrame |
Define.getFrame(VariableStack stack)
|
protected StackFrame |
Global.getFrame(VariableStack stack)
|
protected StackFrame |
GlobalK.getFrame(VariableStack stack)
|
protected StackFrame |
SetVar.getFrame(VariableStack stack)
|
protected StackFrame |
SetVarK.getFrame(VariableStack stack)
|
protected int |
Sequential.getIndex(VariableStack stack)
|
void |
Include.includeFile(String iname,
VariableStack stack)
|
protected void |
SequentialChoice.initializeArgBuffers(VariableStack stack)
|
protected void |
AbstractSequentialWithArguments.initializeArgs(VariableStack stack)
|
protected void |
AbstractParallelIterator.initializeChannelBuffers(VariableStack stack)
|
protected void |
AbstractUParallelIterator.initializeChannelBuffers(VariableStack stack)
|
protected void |
Parallel.initializeChannelBuffers(VariableStack stack)
|
protected void |
UParallel.initializeChannelBuffers(VariableStack stack)
|
abstract void |
AbstractIterator.iterate(VariableStack stack,
Identifier var,
KarajanIterator i)
|
void |
AbstractParallelIterator.iterate(VariableStack stack,
Identifier var,
KarajanIterator i)
|
void |
AbstractSequentialIterator.iterate(VariableStack stack,
Identifier var,
KarajanIterator l)
|
void |
AbstractIterator.iterate(VariableStack stack,
KarajanIterator i)
|
protected void |
AbstractParallelIterator.iterationCompleted(VariableStack stack)
|
protected void |
AbstractSequentialIterator.iterationCompleted(VariableStack stack,
KarajanIterator l)
|
protected boolean |
RestartOnErrorNode.matches(VariableStack stack,
FailureNotificationEvent e)
|
protected boolean |
Sequential.moreToExecute(VariableStack stack)
|
protected void |
AbstractParallelIterator.nonArgChildCompleted(VariableStack stack)
|
protected void |
AbstractSequentialIterator.nonArgChildCompleted(VariableStack stack)
|
protected void |
PartialArgumentsContainer.nonArgChildCompleted(VariableStack stack)
|
protected void |
AbstractIterator.partialArgumentsEvaluated(VariableStack stack)
|
protected void |
CacheNode.partialArgumentsEvaluated(VariableStack stack)
|
protected void |
CacheOn.partialArgumentsEvaluated(VariableStack stack)
|
protected void |
Catch.partialArgumentsEvaluated(VariableStack stack)
|
void |
ChannelFrom.partialArgumentsEvaluated(VariableStack stack)
|
void |
ChannelTo.partialArgumentsEvaluated(VariableStack stack)
|
protected void |
ErrorHandlerNode.partialArgumentsEvaluated(VariableStack stack)
|
protected void |
Exclusive.partialArgumentsEvaluated(VariableStack stack)
|
protected void |
FileWrite.partialArgumentsEvaluated(VariableStack stack)
|
protected void |
FutureIteratorNode.partialArgumentsEvaluated(VariableStack stack)
|
protected void |
IgnoreErrorsNode.partialArgumentsEvaluated(VariableStack stack)
|
protected void |
Namespace.partialArgumentsEvaluated(VariableStack stack)
|
protected void |
Once.partialArgumentsEvaluated(VariableStack stack)
|
protected void |
PartialArgumentsContainer.partialArgumentsEvaluated(VariableStack stack)
|
protected void |
RestartOnErrorNode.partialArgumentsEvaluated(VariableStack stack)
|
void |
CacheNode.post(VariableStack stack)
|
void |
Channel.post(VariableStack stack)
|
void |
CheckpointNode.post(VariableStack stack)
|
void |
ConditionNode.post(VariableStack stack)
|
void |
DefaultParameterNode.post(VariableStack stack)
|
void |
Define.post(VariableStack stack)
|
protected void |
Each.post(VariableStack stack)
|
void |
ElementDefNode.post(VariableStack stack)
|
void |
EventWait.post(VariableStack stack)
|
void |
ExecuteElement.post(VariableStack stack)
|
void |
ExecuteFile.post(VariableStack stack)
|
void |
ExecuteJavaNode.post(VariableStack stack)
|
void |
Export.post(VariableStack stack)
|
protected void |
FlowContainer.post(VariableStack stack)
|
void |
FutureIteratorNode.post(VariableStack stack)
|
void |
FutureNode.post(VariableStack stack)
|
void |
GenerateErrorNode.post(VariableStack stack)
|
void |
Include.post(VariableStack stack)
|
void |
Maybe.post(VariableStack stack)
|
void |
Namespace.post(VariableStack stack)
|
void |
OptionalArgs.post(VariableStack stack)
|
void |
Print.post(VariableStack stack)
|
void |
SequentialChoice.post(VariableStack stack)
|
void |
SetVar.post(VariableStack stack)
|
void |
SetVarK.post(VariableStack stack)
|
void |
UnsynchronizedNode.post(VariableStack stack)
|
void |
WaitNode.post(VariableStack stack)
|
void |
AbstractSequentialWithArguments.pre(VariableStack stack)
|
void |
Define.pre(VariableStack stack)
|
void |
ElementDefNode.pre(VariableStack stack)
|
protected void |
FlowContainer.pre(VariableStack stack)
|
void |
Guard.pre(VariableStack stack)
|
protected void |
If.pre(VariableStack stack)
|
void |
Include.pre(VariableStack stack)
|
void |
Parallel.pre(VariableStack stack)
|
void |
ParallelChoice.pre(VariableStack stack)
|
void |
SequentialChoice.pre(VariableStack stack)
|
void |
SetVarK.pre(VariableStack stack)
|
void |
UndefinedNode.pre(VariableStack vs)
|
void |
UnsynchronizedNode.pre(VariableStack stack)
|
void |
While.pre(VariableStack stack)
|
protected int |
Sequential.preDecIndex(VariableStack stack)
|
protected int |
AbstractIterator.preDecRunning(VariableStack stack)
|
protected int |
Parallel.preDecRunning(VariableStack stack)
|
protected int |
Sequential.preIncIndex(VariableStack stack)
|
protected int |
AbstractIterator.preIncRunning(VariableStack stack)
|
protected int |
Parallel.preIncRunning(VariableStack stack)
|
void |
Echo.print(VariableStack stack,
String message)
|
protected void |
Print.print(VariableStack stack,
String message)
|
protected void |
AbstractSequentialWithArguments.processArguments(VariableStack stack)
|
void |
FlowNode.restart(VariableStack stack)
|
void |
FlowNode.restartElement(FlowElement c,
VariableStack stack)
|
protected void |
FlowNode.ret(VariableStack stack,
Object value)
|
protected void |
PartialArgumentsContainer.setArgsDone(VariableStack stack)
|
protected void |
FlowContainer.setChildFailed(VariableStack stack,
boolean value)
|
protected void |
Sequential.setIndex(VariableStack stack,
int value)
|
protected void |
SetVarK.setMultiple(List idents,
VariableArguments vargs,
VariableStack stack)
|
protected void |
AbstractIterator.setRunning(VariableStack stack,
int running)
|
protected void |
Parallel.setRunning(VariableStack stack,
int running)
|
protected void |
SetVarK.setSingle(Identifier ident,
VariableArguments vargs,
VariableStack stack)
|
void |
FlowNode.start(VariableStack stack)
|
protected void |
ExecuteElement.startDef(VariableStack stack,
UDEDefinition def)
|
protected void |
FlowNode.startElement(FlowElement c,
VariableStack stack)
|
protected void |
Sequential.startElement(FlowElement fn,
VariableStack stack)
|
void |
FlowNode.startElement(int index,
VariableStack stack)
|
protected void |
Sequential.startNext(VariableStack stack)
|
protected void |
While.startNext(VariableStack stack)
|
protected void |
PartialArgumentsContainer.startRest(VariableStack stack)
|
protected boolean |
Exclusive.testAndAdd(Map locks,
Object on,
VariableStack stack)
|
protected boolean |
AbstractParallelIterator.testAndSetChildFailed(VariableStack stack)
|
Methods in org.globus.cog.karajan.workflow.nodes.grid with parameters of type VariableStack |
protected void |
AllocateHost._finally(VariableStack stack)
|
void |
AbstractGridNode.fireNotificationEvent(FlowEvent event,
VariableStack stack)
Overriden to release the notification threads as soon as possible. |
Object |
AvailableTaskHandlers.function(VariableStack stack)
|
Object |
GridNode.function(VariableStack stack)
|
Object |
HostNode.function(VariableStack stack)
|
Object |
SecurityContextNode.function(VariableStack stack)
|
Object |
ServiceNode.function(VariableStack stack)
|
Object |
TaskHandlerNode.function(VariableStack stack)
|
protected abstract String[] |
AbstractFileOperation.getArguments(VariableStack stack)
|
protected String[] |
Chmod.getArguments(VariableStack stack)
|
protected String[] |
FileExists.getArguments(VariableStack stack)
|
protected String[] |
FileList.getArguments(VariableStack stack)
|
protected String[] |
FileRemove.getArguments(VariableStack stack)
|
protected String[] |
FileSize.getArguments(VariableStack stack)
|
protected String[] |
IsDirectory.getArguments(VariableStack stack)
|
protected String[] |
MakeDir.getArguments(VariableStack stack)
|
protected String[] |
Rename.getArguments(VariableStack stack)
|
protected String[] |
Rmdir.getArguments(VariableStack stack)
|
protected void |
AvailableTaskHandlers.getHandlers(VariableStack stack,
String type)
|
protected Contact |
AbstractGridNode.getHost(VariableStack stack,
Arg hostarg,
Scheduler scheduler,
String provider)
|
protected abstract String |
AbstractFileOperation.getOperation(VariableStack stack)
|
protected String |
Chmod.getOperation(VariableStack stack)
|
protected String |
FileExists.getOperation(VariableStack stack)
|
protected String |
FileList.getOperation(VariableStack stack)
|
protected String |
FileRemove.getOperation(VariableStack stack)
|
protected String |
FileSize.getOperation(VariableStack stack)
|
protected String |
IsDirectory.getOperation(VariableStack stack)
|
protected String |
MakeDir.getOperation(VariableStack stack)
|
protected String |
Rename.getOperation(VariableStack stack)
|
protected String |
Rmdir.getOperation(VariableStack stack)
|
Scheduler |
AbstractGridNode.getScheduler(VariableStack stack)
|
protected SecurityContext |
AbstractGridNode.getSecurityContext(VariableStack stack,
String provider)
|
protected Scheduler |
SchedulerNode.newScheduler(VariableStack stack)
|
protected void |
AllocateHost.partialArgumentsEvaluated(VariableStack stack)
|
void |
AbstractGridNode.post(VariableStack stack)
|
void |
BDP.post(VariableStack stack)
|
void |
SchedulerNode.post(VariableStack stack)
|
protected void |
GridExec.returnOutputs(Task t,
VariableStack stack)
|
void |
AbstractGridNode.setSecurityContext(VariableStack stack,
Service service)
|
void |
AbstractGridNode.submitScheduled(Scheduler scheduler,
Task task,
VariableStack stack,
Object constraints)
|
void |
AbstractFileOperation.submitTask(VariableStack stack)
|
protected abstract void |
AbstractGridNode.submitTask(VariableStack stack)
|
void |
GridExec.submitTask(VariableStack stack)
|
void |
GridTransfer.submitTask(VariableStack stack)
|
void |
AbstractGridNode.submitUnscheduled(TaskHandler handler,
Task task,
VariableStack stack)
|
boolean |
Functions.task_host_hasservice(VariableStack stack)
|
String |
Functions.task_serviceuri(VariableStack stack)
|
protected void |
AbstractGridNode.taskCompleted(StatusEvent e,
VariableStack stack)
|
protected void |
FileExists.taskCompleted(StatusEvent e,
VariableStack stack)
|
protected void |
FileList.taskCompleted(StatusEvent e,
VariableStack stack)
|
protected void |
FileSize.taskCompleted(StatusEvent e,
VariableStack stack)
|
protected void |
GridExec.taskCompleted(StatusEvent e,
VariableStack stack)
|
protected void |
IsDirectory.taskCompleted(StatusEvent e,
VariableStack stack)
|
protected void |
AbstractGridNode.taskFailed(StatusEvent e,
VariableStack stack)
|
protected void |
GridExec.taskFailed(StatusEvent e,
VariableStack stack)
|
Methods in org.globus.cog.karajan.workflow.nodes.user with parameters of type VariableStack |
protected void |
UserDefinedElement.checkBothArgs(VariableStack stack)
|
protected boolean |
ExplicitExecutionUDE.checkFirstArg(VariableStack stack)
|
protected boolean |
UserDefinedElement.checkFirstArg(VariableStack stack)
|
protected void |
SequentialImplicitExecutionUDE.childCompleted(VariableStack stack)
|
protected void |
UserDefinedElement.childCompleted(VariableStack stack)
|
protected void |
ParallelImplicitExecutionUDE.closeArgs(VariableStack stack)
|
void |
UDEWrapper.executeChildren(VariableStack stack)
|
protected void |
UserDefinedElement.executeChildren(VariableStack stack)
|
void |
UDEWrapper.executeWrapper(VariableStack stack)
|
UDEDefinition |
UDEWrapper.getDef(VariableStack stack)
|
protected UDEDefinition |
Self.getDefInternal(VariableStack stack)
|
protected UDEDefinition |
UDEWrapper.getDefInternal(VariableStack stack)
|
protected DefinitionEnvironment |
UserDefinedElement.getEnv(VariableStack stack)
|
protected Arguments |
ExplicitExecutionUDE.getUDEArguments(VariableStack stack)
|
protected Arguments |
ParallelImplicitExecutionUDE.getUDEArguments(VariableStack stack)
|
protected Arguments |
SequentialImplicitExecutionUDE.getUDEArguments(VariableStack stack)
|
protected void |
UDEWrapper.initializeArgs(VariableStack stack)
|
protected boolean |
UserDefinedElement.isArgumentsThread(VariableStack stack)
|
void |
UDEWrapper.pre(VariableStack stack)
|
void |
UserDefinedElement.pre(VariableStack stack)
|
protected void |
ParallelImplicitExecutionUDE.prepareArguments(VariableStack stack,
UDEWrapper wrapper)
|
protected void |
ParallelImplicitExecutionUDE.prepareInstanceArguments(VariableStack stack,
Arguments fnargs)
|
protected void |
UserDefinedElement.prepareInstanceArguments(VariableStack stack,
Arguments fnargs)
|
protected void |
ExplicitExecutionUDE.setArguments(VariableStack stack)
|
protected void |
ParallelImplicitExecutionUDE.setArguments(VariableStack stack)
|
protected void |
SequentialImplicitExecutionUDE.setArguments(VariableStack stack)
|
protected void |
ParallelImplicitExecutionUDE.startArguments(VariableStack stack,
UDEWrapper wrapper)
|
protected void |
SequentialImplicitExecutionUDE.startArguments(VariableStack stack,
UDEWrapper wrapper)
|
protected void |
UserDefinedElement.startArguments(VariableStack stack,
UDEWrapper wrapper)
|
protected void |
ExplicitExecutionUDE.startBody(VariableStack stack)
|
void |
UserDefinedElement.startBody(VariableStack stack,
Arguments fnargs)
|
protected void |
SequentialImplicitExecutionUDE.startBody(VariableStack stack,
DefinitionEnvironment env)
|
void |
ExplicitExecutionUDE.startInstance(VariableStack stack,
UDEWrapper wrapper,
DefinitionEnvironment env)
|
void |
ParallelImplicitExecutionUDE.startInstance(VariableStack stack,
UDEWrapper wrapper,
DefinitionEnvironment env)
|
void |
SequentialImplicitExecutionUDE.startInstance(VariableStack stack,
UDEWrapper wrapper,
DefinitionEnvironment env)
|
abstract void |
UserDefinedElement.startInstance(VariableStack stack,
UDEWrapper wrapper,
DefinitionEnvironment env)
|