org.globus.cog.karajan.workflow.nodes.grid
Class GridTransfer

java.lang.Object
  extended by org.globus.cog.karajan.workflow.nodes.FlowNode
      extended by org.globus.cog.karajan.workflow.nodes.FlowContainer
          extended by org.globus.cog.karajan.workflow.nodes.Sequential
              extended by org.globus.cog.karajan.workflow.nodes.AbstractSequentialWithArguments
                  extended by org.globus.cog.karajan.workflow.nodes.SequentialWithArguments
                      extended by org.globus.cog.karajan.workflow.nodes.grid.AbstractGridNode
                          extended by org.globus.cog.karajan.workflow.nodes.grid.GridTransfer
All Implemented Interfaces:
StatusListener, LoadListener, EventListener, ExtendedFlowElement, FlowElement

public class GridTransfer
extends AbstractGridNode
implements StatusListener


Nested Class Summary
 
Nested classes/interfaces inherited from class org.globus.cog.karajan.workflow.nodes.FlowNode
FlowNode.FNTP
 
Field Summary
static Arg A_DESTDIR
           
static Arg A_DESTFILE
           
static Arg A_DESTHOST
           
static Arg A_DESTOFFSET
           
static Arg A_DESTPROVIDER
           
static Arg A_LENGTH
           
static Arg A_PROVIDER
           
static Arg A_SRCDIR
           
static Arg A_SRCFILE
           
static Arg A_SRCHOST
           
static Arg A_SRCOFFSET
           
static Arg A_SRCPROVIDER
           
static Arg A_TCP_BUFSZ
           
static Arg A_THIRDPARTY
           
static org.apache.log4j.Logger logger
           
 
Fields inherited from class org.globus.cog.karajan.workflow.nodes.grid.AbstractGridNode
A_SECURITY_CONTEXT, HANDLER, tasks
 
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
GridTransfer()
           
 
Method Summary
protected  Service getService(BoundContact contact, String provider)
           
protected  void removeTask(Task task)
           
 void submitTask(VariableStack stack)
           
 
Methods inherited from class org.globus.cog.karajan.workflow.nodes.grid.AbstractGridNode
abortEvent, fireNotificationEvent, getHost, getScheduler, getSecurityContext, post, setSecurityContext, setSecurityContextIfNotLocal, statusChanged, submitScheduled, submitUnscheduled, taskCompleted, taskFailed
 
Methods inherited from class org.globus.cog.karajan.workflow.nodes.AbstractSequentialWithArguments
addChannel, argumentsEvaluated, checkArguments, childCompleted, getArgument, getArgumentCount, getArgumentIndex, getArgumentNames, getArguments, getChannels, getMaxArgIndex, getNonpropargs, getOptionalArgs, getQuotedArgs, getSortedArgs, hasChannels, hasNestedArguments, hasVariableArguments, initializeArgs, initializeStatic, newNameBindingVariableArguments, newVariableArguments, pre, processArguments, setArguments, setHasVargs, setNestedArgs, setNonpropargs, setQuotedArgs, setVargs
 
Methods inherited from class org.globus.cog.karajan.workflow.nodes.Sequential
executeChildren, executeSingle, exit, getIndex, moreToExecute, notificationEvent, preDecIndex, preIncIndex, setIndex, startElement, startNext
 
Methods inherited from class org.globus.cog.karajan.workflow.nodes.FlowContainer
execute, getChildFailed, isOptimizable, setChildFailed, setOptimize
 
Methods inherited from class org.globus.cog.karajan.workflow.nodes.FlowNode
_finally, abort, 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, 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
 
Methods inherited from interface org.globus.cog.abstraction.interfaces.StatusListener
statusChanged
 

Field Detail

logger

public static final org.apache.log4j.Logger logger

A_SRCFILE

public static final Arg A_SRCFILE

A_SRCDIR

public static final Arg A_SRCDIR

A_SRCHOST

public static final Arg A_SRCHOST

A_SRCPROVIDER

public static final Arg A_SRCPROVIDER

A_SRCOFFSET

public static final Arg A_SRCOFFSET

A_DESTFILE

public static final Arg A_DESTFILE

A_DESTDIR

public static final Arg A_DESTDIR

A_DESTHOST

public static final Arg A_DESTHOST

A_DESTPROVIDER

public static final Arg A_DESTPROVIDER

A_DESTOFFSET

public static final Arg A_DESTOFFSET

A_PROVIDER

public static final Arg A_PROVIDER

A_THIRDPARTY

public static final Arg A_THIRDPARTY

A_LENGTH

public static final Arg A_LENGTH

A_TCP_BUFSZ

public static final Arg A_TCP_BUFSZ
Constructor Detail

GridTransfer

public GridTransfer()
Method Detail

submitTask

public void submitTask(VariableStack stack)
                throws ExecutionException
Specified by:
submitTask in class AbstractGridNode
Throws:
ExecutionException

removeTask

protected void removeTask(Task task)
Overrides:
removeTask in class AbstractGridNode

getService

protected Service getService(BoundContact contact,
                             String provider)
                      throws ExecutionException
Throws:
ExecutionException