| java.lang.Object
 org.griphyn.cPlanner.transfer.implementation.Abstract
org.griphyn.cPlanner.transfer.implementation.AbstractSingleFTPerXFERJob
All known Subclasses: org.griphyn.cPlanner.transfer.implementation.Stork, org.griphyn.cPlanner.transfer.implementation.OldGUC,
| AbstractSingleFTPerXFERJob | | abstract public class AbstractSingleFTPerXFERJob extends Abstract implements SingleFTPerXFERJob(Code) | | An abstract implementation for implementations that can handle only a single
file transfer in a single file transfer job.
author:
Karan Vahi
version:
$Revision: 50 $ |
| AbstractSingleFTPerXFERJob | | public AbstractSingleFTPerXFERJob(PegasusProperties properties, PlannerOptions options)(Code) | | The overloaded constructor, that is called by the Factory to load the
class.
Parameters:
properties - the properties object.
Parameters:
options - the options passed to the Planner. |
| createTransferJob | | public TransferJob createTransferJob(SubInfo job, Collection files, Collection execFiles, String txJobName, int jobClass)(Code) | | Constructs a general transfer job that handles single transfers per
transfer job. There are appropriate callouts to generate the implementation
specific details. It throws an error if asked to create a transfer job
for more than one transfer.
Parameters:
job - the SubInfo object for the job, in relation to whichthe transfer node is being added. Either the transfernode can be transferring this jobs input files tothe execution pool, or transferring this job's outputfiles to the output pool.
Parameters:
files - collection of FileTransfer objectsrepresenting the data files and staged executables to betransferred.
Parameters:
execFiles - subset collection of the files parameter, that identifiesthe executable files that are being transferred.
Parameters:
txJobName - the name of transfer node.
Parameters:
jobClass - the job Class for the newly added job. Can be one of thefollowing:stage-instage-outinter-pool transfer the created TransferJob. |
| createTransferJob | | public TransferJob createTransferJob(SubInfo job, FileTransfer file, Collection execFiles, String txJobName, int jobClass)(Code) | | Constructs a general transfer job that handles single transfers per
transfer job. There are appropriate callouts to generate the implementation
specific details.
Parameters:
job - the SubInfo object for the job, in relation to whichthe transfer node is being added. Either the transfernode can be transferring this jobs input files tothe execution pool, or transferring this job's outputfiles to the output pool.
Parameters:
file - collection of FileTransfer objectsrepresenting the data files and staged executables to betransferred.
Parameters:
execFiles - subset collection of the files parameter, that identifiesthe executable files that are being transferred.
Parameters:
txJobName - the name of transfer node.
Parameters:
jobClass - the job Class for the newly added job. Can be one of thefollowing:stage-instage-outinter-pool transfer the created TransferJob. |
| generateArgumentString | | abstract protected String generateArgumentString(TransferJob job, FileTransfer file)(Code) | | It constructs the arguments to the transfer executable that need to be passed
to the executable referred to in this transfer mode.
Parameters:
job - the job containing the transfer node.
Parameters:
file - the FileTransfer that needs to be done. the argument string |
| getCompleteTCName | | abstract protected String getCompleteTCName()(Code) | | Returns the complete name for the transformation that the implementation
is using.
the complete name. |
| getDerivationName | | abstract protected String getDerivationName()(Code) | | Returns the logical name of the derivation that this implementation
refers to.
the name of the derivation. |
| getDerivationNamespace | | abstract protected String getDerivationNamespace()(Code) | | Returns the namespace of the derivation that this implementation
refers to.
the namespace of the derivation. |
| getDerivationVersion | | abstract protected String getDerivationVersion()(Code) | | Returns the version of the derivation that this implementation
refers to.
the version of the derivation. |
| Methods inherited from org.griphyn.cPlanner.transfer.implementation.Abstract | protected boolean addSetXBitJobs(SubInfo computeJob, SubInfo txJob, Collection execFiles)(Code)(Java Doc)
public boolean addSetXBitJobs(SubInfo computeJob, String txJobName, Collection execFiles, int transferClass)(Code)(Java Doc)
public boolean addSetXBitJobs(SubInfo computeJob, String txJobName, Collection execFiles, int transferClass, int xbitIndex)(Code)(Java Doc)
public void applyPriority(TransferJob job)(Code)(Java Doc)
public boolean checkAndTransferProxy(TransferJob job)(Code)(Java Doc)
protected void construct(SubInfo job, String key, String value)(Code)(Java Doc)
public SubInfo createNoOPJob(String name)(Code)(Java Doc)
protected SubInfo createSetXBitJob(FileTransfer file, String name)(Code)(Java Doc)
protected Set determineDisabledChmodSites(String sites)(Code)(Java Doc)
protected boolean disableChmodJobCreation(String site)(Code)(Java Doc)
public String getNOOPJobName(String name, int counter)(Code)(Java Doc)
protected String getPathToUserProxy()(Code)(Java Doc)
protected String getPriority(TransferJob job)(Code)(Java Doc)
public String getSetXBitJobName(String name, int counter)(Code)(Java Doc)
public void setRefiner(Refiner refiner)(Code)(Java Doc)
|
|
|