Methods in org.globus.cog.karajan.workflow.nodes that throw ExecutionException |
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 |
FlowNode.abortEvent(AbortEvent e)
|
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 |
EventWait.addListener(Object source,
String methodName,
Class argType)
|
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)
|
Object |
FlowNode.checkClass(Object value,
Class cls,
String name)
|
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 |
FlowNode.controlEvent(ControlEvent e)
|
protected static Object |
JavaMethodInvocationNode.convert(Class type,
Object src)
|
protected static Object |
JavaMethodInvocationNode.convert(Class type,
Object src,
boolean array)
|
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 |
FlowNode.event(Event e)
|
void |
While.event(Event e)
|
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)
|
protected void |
CacheNode.failAll(List l,
FailureNotificationEvent e)
|
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 |
FlowElement.failImmediately(VariableStack stack,
String string)
Provides means to cause the execution of this element under the
given context (stack ) to fail |
protected void |
Info.find(String prefix,
VariableStack stack,
VariableArguments stdout)
|
Object |
JavaMethodInvocationNode.function(VariableStack stack)
|
Object |
NewJavaObjectNode.function(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)
|
static Class |
JavaMethodInvocationNode.getClass(String type)
|
void |
ErrorHandlerNode.handleError(FlowElement source,
FailureNotificationEvent error)
|
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 void |
While.loopNotificationEvent(LoopNotificationEvent e)
|
protected void |
FlowNode.monitoringEvent(MonitoringEvent 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)
|
void |
AbstractParallelIterator.notificationEvent(NotificationEvent e)
|
void |
AbstractSequentialIterator.notificationEvent(NotificationEvent e)
|
protected void |
CacheNode.notificationEvent(NotificationEvent e)
|
protected void |
ErrorHandlerNode.notificationEvent(NotificationEvent e)
|
protected void |
ExecuteFile.notificationEvent(NotificationEvent e)
|
protected void |
FlowNode.notificationEvent(NotificationEvent e)
|
protected void |
FutureIteratorNode.notificationEvent(NotificationEvent e)
|
protected void |
FutureNode.notificationEvent(NotificationEvent e)
|
protected void |
Guard.notificationEvent(NotificationEvent e)
|
protected void |
IgnoreErrorsNode.notificationEvent(NotificationEvent e)
|
protected void |
Maybe.notificationEvent(NotificationEvent e)
|
protected void |
Parallel.notificationEvent(NotificationEvent e)
|
protected void |
ParallelChoice.notificationEvent(NotificationEvent e)
|
protected void |
RestartOnErrorNode.notificationEvent(NotificationEvent e)
|
protected void |
Sequential.notificationEvent(NotificationEvent e)
|
protected void |
SequentialChoice.notificationEvent(NotificationEvent e)
|
protected void |
SetVarK.notificationEvent(NotificationEvent e)
|
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)
|
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)
|
protected void |
FlowNode.ret(VariableStack stack,
Object value)
|
protected void |
SetVarK.setMultiple(List idents,
VariableArguments vargs,
VariableStack stack)
|
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)
|
Methods in org.globus.cog.karajan.workflow.nodes.grid that throw ExecutionException |
protected void |
AllocateHost._finally(VariableStack stack)
|
void |
AbstractGridNode.abortEvent(AbortEvent e)
|
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 Service |
AbstractFileOperation.getService(BoundContact contact,
String provider)
|
protected Service |
GridTransfer.getService(BoundContact contact,
String provider)
|
protected String |
BDP.getSize(String sz)
|
protected Scheduler |
SchedulerNode.newScheduler(VariableStack stack)
|
protected Map |
BDP.parseBDP()
|
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 |
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)
|