| java.lang.Object
 org.griphyn.cPlanner.transfer.implementation.Abstract
org.griphyn.cPlanner.transfer.implementation.AbstractMultipleFTPerXFERJob
All known Subclasses: org.griphyn.cPlanner.transfer.implementation.SRM, org.griphyn.cPlanner.transfer.implementation.Transfer, org.griphyn.cPlanner.transfer.implementation.Condor, org.griphyn.cPlanner.transfer.implementation.CRFT, org.griphyn.cPlanner.transfer.implementation.T2, org.griphyn.cPlanner.transfer.implementation.RFT,
| AbstractMultipleFTPerXFERJob | | abstract public class AbstractMultipleFTPerXFERJob extends Abstract implements MultipleFTPerXFERJob(Code) | | An abstract implementation for implementations that can handle multiple
file transfers in a single file transfer job.
author:
Karan Vahi
version:
$Revision: 145 $ |
| Method Summary | |
| public TransferJob | createTransferJob(SubInfo job, Collection files, Collection execFiles, String txJobName, int jobClass)
Constructs a general transfer job that handles multiple transfers per
transfer job. | | protected TransformationCatalogEntry | defaultTCEntry(String namespace, String name, String version, String site)
Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
Parameters:
namespace - the namespace of the transfer transformation
Parameters:
name - the logical name of the transfer transformation
Parameters:
version - the version of the transfer transformation
Parameters:
site - the site for which the default entry is required. | | abstract protected String | generateArgumentString(TransferJob job)
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 object containing the transfer node. | | abstract protected String | getCompleteTCName()
Returns the complete name for the transformation that the implementation
is using.. | | abstract protected String | getDerivationName()
Returns the logical name of the derivation that this implementation
refers to. | | abstract protected String | getDerivationNamespace()
Returns the namespace of the derivation that this implementation
refers to. | | abstract protected String | getDerivationVersion()
Returns the version of the derivation that this implementation
refers to. | | abstract protected List | getEnvironmentVariables(String site)
Returns the environment profiles that are required for the default
entry to sensibly work.
Parameters:
site - the site where the job is going to run. | | public void | postProcess(TransferJob job)
An optional method that allows the derived classes to do their own
post processing on the the transfer job before it is returned to
the calling module. | | protected String | prepareSTDIN(String name, Collection files)
Prepares the stdin for the transfer job. | | abstract protected void | writeJumboStdIn(FileWriter stdIn, Collection files)
|
| AbstractMultipleFTPerXFERJob | | public AbstractMultipleFTPerXFERJob(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 multiple 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:
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. |
| defaultTCEntry | | protected TransformationCatalogEntry defaultTCEntry(String namespace, String name, String version, String site)(Code) | | Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
Parameters:
namespace - the namespace of the transfer transformation
Parameters:
name - the logical name of the transfer transformation
Parameters:
version - the version of the transfer transformation
Parameters:
site - the site for which the default entry is required. the default entry. |
| generateArgumentString | | abstract protected String generateArgumentString(TransferJob job)(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 object containing the transfer node. 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. |
| getEnvironmentVariables | | abstract protected List getEnvironmentVariables(String site)(Code) | | Returns the environment profiles that are required for the default
entry to sensibly work.
Parameters:
site - the site where the job is going to run. List of environment variables, else null in case where therequired environment variables could not be found. |
| postProcess | | public void postProcess(TransferJob job)(Code) | | An optional method that allows the derived classes to do their own
post processing on the the transfer job before it is returned to
the calling module.
Parameters:
job - the TransferJob that has been created. |
| prepareSTDIN | | protected String prepareSTDIN(String name, Collection files) throws Exception(Code) | | Prepares the stdin for the transfer job. Usually involves writing out a
text file that Condor transfers to the remote end.
Parameters:
name - the name of the transfer job.
Parameters:
files - Collection of FileTransfer objects containingthe information about sourceam fin and destURL's. the path to the prepared stdin file.
throws:
Exception - in case of error. |
| writeJumboStdIn | | abstract protected void writeJumboStdIn(FileWriter stdIn, Collection files) throws Exception(Code) | | Writes to a FileWriter stream the stdin which goes into the magic script
via standard input
Parameters:
stdIn - the writer to the stdin file.
Parameters:
files - Collection of FileTransfer objects containingthe information about sourceam fin and destURL's.
throws:
Exception - |
| 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)
|
|
|