| java.lang.Object
 org.griphyn.cPlanner.transfer.implementation.Abstract
All known Subclasses: org.griphyn.cPlanner.transfer.implementation.Windward, org.griphyn.cPlanner.transfer.implementation.AbstractMultipleFTPerXFERJob, org.griphyn.cPlanner.transfer.implementation.AbstractSingleFTPerXFERJob,
| Abstract | | abstract public class Abstract implements Implementation(Code) | | An abstract implementation that implements some of the common functions in
the Implementation Interface that are required by all the implementations.
author:
Karan Vahi
version:
$Revision: 192 $ |
| Method Summary | |
| protected boolean | addSetXBitJobs(SubInfo computeJob, SubInfo txJob, Collection execFiles)
Adds the dirmanager to the workflow, that do a chmod on the files
being staged.
Parameters:
computeJob - the computeJob for which the files are being staged.
Parameters:
txJob - the transfer job that is staging the files.
Parameters:
execFiles - the executable files that are being staged. | | public boolean | addSetXBitJobs(SubInfo computeJob, String txJobName, Collection execFiles, int transferClass)
Adds the dirmanager job to the workflow, that do a chmod on the files
being staged. | | public boolean | addSetXBitJobs(SubInfo computeJob, String txJobName, Collection execFiles, int transferClass, int xbitIndex)
Adds the dirmanager job to the workflow, that do a chmod on the files
being staged.
Parameters:
computeJob - the computeJob for which the files arebeing staged.
Parameters:
txJobName - the name of the transfer job that is staging the files.
Parameters:
execFiles - the executable files that are being staged.
Parameters:
transferClass - the class of transfer job
Parameters:
xbitIndex - index to be used for creating the name of XBitJob. | | public void | applyPriority(TransferJob job)
Applies priorities to the transfer jobs if a priority is specified
in the properties file. | | public boolean | checkAndTransferProxy(TransferJob job)
Determines if there is a need to transfer proxy for the transfer
job or not. | | protected void | construct(SubInfo job, String key, String value)
Constructs a condor variable in the condor profile namespace
associated with the job. | | public SubInfo | createNoOPJob(String name)
It creates a NoOP job that runs on the submit host. | | protected SubInfo | createSetXBitJob(FileTransfer file, String name)
Creates a dirmanager job, that does a chmod on the file being staged.
The file being staged should be of type executable. | | protected Set | determineDisabledChmodSites(String sites)
Builds up a set of disabled chmod sites
Parameters:
sites - comma separated list of sites. | | protected boolean | disableChmodJobCreation(String site)
Returns a boolean indicating whether to disable chmod job creation for
a site or not. | | public String | getNOOPJobName(String name, int counter)
Generates the name of the noop job , that is unique for the given
workflow.
Parameters:
name - the name of the compute job
Parameters:
counter - the index for the noop job. | | protected String | getPathToUserProxy()
Returns the path to the user proxy from the pool configuration file and
the properties file. | | protected String | getPriority(TransferJob job)
Returns the priority for the transfer job as specified in the properties
file.
Parameters:
job - the Transfer job. | | public String | getSetXBitJobName(String name, int counter)
Generates the name of the setXBitJob , that is unique for the given
workflow.
Parameters:
name - the name of the compute job
Parameters:
counter - the index for the setXBit job. | | public void | setRefiner(Refiner refiner)
Sets the callback to the refiner, that has loaded this implementation. |
| CHANGE_XBIT_TRANSFORMATION | | final public static String CHANGE_XBIT_TRANSFORMATION(Code) | | The logical name of the transformation that creates directories on the
remote execution pools.
|
| NOOP_PREFIX | | final public static String NOOP_PREFIX(Code) | | The prefix for the NoOP jobs that are created.
|
| SET_XBIT_PREFIX | | final public static String SET_XBIT_PREFIX(Code) | | The prefix for the jobs which are added to set X bit for the staged
executables.
|
| XBIT_DERIVATION_NS | | final public static String XBIT_DERIVATION_NS(Code) | | The derivation namespace for the setXBit jobs.
|
| XBIT_DERIVATION_VERSION | | final public static String XBIT_DERIVATION_VERSION(Code) | | The version number for the derivations for setXBit jobs.
|
| XBIT_TRANSFORMATION_NS | | final public static String XBIT_TRANSFORMATION_NS(Code) | | The transformation namespace for the setXBit jobs.
|
| XBIT_TRANSFORMATION_VERSION | | final public static String XBIT_TRANSFORMATION_VERSION(Code) | | The version number for the derivations for setXBit jobs.
|
| mDisabledChmodSites | | protected Set mDisabledChmodSites(Code) | | The set of sites for which chmod job creation has to be disabled while
doing executable staging.
|
| mLocalUserProxy | | protected String mLocalUserProxy(Code) | | The path to the user proxy on the submit host (local pool), that is picked
up for use in transfer of proxies.
|
| mLocalUserProxyBasename | | protected String mLocalUserProxyBasename(Code) | | The basename of the user proxy , that is picked up for use in transfer of
proxies.
|
| mPOptions | | protected PlannerOptions mPOptions(Code) | | Contains the various options to the Planner as passed by the user at
runtime.
|
| mProps | | protected PegasusProperties mProps(Code) | | The handle to the properties object holding the properties relevant to
Pegasus.
|
| mRefiner | | protected Refiner mRefiner(Code) | | The handle to the refiner that loaded this implementation.
|
| mSCHandle | | protected PoolInfoProvider mSCHandle(Code) | | The handle to the Site Catalog. It is instantiated in this class.
|
| mTCHandle | | protected TransformationCatalog mTCHandle(Code) | | The handle to the Transformation Catalog. It must be instantiated in the
implementing class
|
| Abstract | | public Abstract(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. |
| addSetXBitJobs | | protected boolean addSetXBitJobs(SubInfo computeJob, SubInfo txJob, Collection execFiles)(Code) | | Adds the dirmanager to the workflow, that do a chmod on the files
being staged.
Parameters:
computeJob - the computeJob for which the files are being staged.
Parameters:
txJob - the transfer job that is staging the files.
Parameters:
execFiles - the executable files that are being staged. boolean indicating whether any XBitJobs were succesfully added ornot. |
| addSetXBitJobs | | public boolean addSetXBitJobs(SubInfo computeJob, String txJobName, Collection execFiles, int transferClass)(Code) | | Adds the dirmanager job to the workflow, that do a chmod on the files
being staged.
Parameters:
computeJob - the computeJob for which the files arebeing staged.
Parameters:
txJobName - the name of the transfer job that is staging the files.
Parameters:
execFiles - the executable files that are being staged.
Parameters:
transferClass - the class of transfer job boolean indicating whether any XBitJobs were succesfully added ornot. |
| addSetXBitJobs | | public boolean addSetXBitJobs(SubInfo computeJob, String txJobName, Collection execFiles, int transferClass, int xbitIndex)(Code) | | Adds the dirmanager job to the workflow, that do a chmod on the files
being staged.
Parameters:
computeJob - the computeJob for which the files arebeing staged.
Parameters:
txJobName - the name of the transfer job that is staging the files.
Parameters:
execFiles - the executable files that are being staged.
Parameters:
transferClass - the class of transfer job
Parameters:
xbitIndex - index to be used for creating the name of XBitJob. boolean indicating whether any XBitJobs were succesfully added ornot. |
| applyPriority | | public void applyPriority(TransferJob job)(Code) | | Applies priorities to the transfer jobs if a priority is specified
in the properties file.
Parameters:
job - the transfer job . |
| checkAndTransferProxy | | public boolean checkAndTransferProxy(TransferJob job)(Code) | | Determines if there is a need to transfer proxy for the transfer
job or not. If there is a need to transfer proxy, then the job is
modified to create the correct condor commands to transfer the proxy.
Proxy is usually transferred if the VDS profile TRANSFER_PROXY is set,
or the job is being run in the condor vanilla universe. The proxy is
transferred from the submit host (i.e site local). The location is
determined from the value of the X509_USER_PROXY profile key associated
in the env namespace.
Parameters:
job - the transfer job . boolean true job was modified to transfer the proxy, elsefalse when job is not modified. |
| construct | | protected void construct(SubInfo job, String key, String value)(Code) | | Constructs a condor variable in the condor profile namespace
associated with the job. Overrides any preexisting key values.
Parameters:
job - contains the job description.
Parameters:
key - the key of the profile.
Parameters:
value - the associated value. |
| createNoOPJob | | public SubInfo createNoOPJob(String name)(Code) | | It creates a NoOP job that runs on the submit host.
Parameters:
name - the name to be assigned to the noop job the noop job. |
| createSetXBitJob | | protected SubInfo createSetXBitJob(FileTransfer file, String name)(Code) | | Creates a dirmanager job, that does a chmod on the file being staged.
The file being staged should be of type executable. Though no explicit
check is made for that. The staged file is the one whose X bit would be
set on execution of this job. The site at which job is executed, is
determined from the site associated with the destination URL.
Parameters:
file - the FileTransfer containing the file that hasto be X Bit Set.
Parameters:
name - the name that has to be assigned to the job. the chmod job, else null if it is not able to be createdfor some reason. |
| determineDisabledChmodSites | | protected Set determineDisabledChmodSites(String sites)(Code) | | Builds up a set of disabled chmod sites
Parameters:
sites - comma separated list of sites. a Set containing the site names. |
| disableChmodJobCreation | | protected boolean disableChmodJobCreation(String site)(Code) | | Returns a boolean indicating whether to disable chmod job creation for
a site or not.
Parameters:
site - the name of the site boolean |
| getNOOPJobName | | public String getNOOPJobName(String name, int counter)(Code) | | Generates the name of the noop job , that is unique for the given
workflow.
Parameters:
name - the name of the compute job
Parameters:
counter - the index for the noop job. the name of the setXBitJob . |
| getPathToUserProxy | | protected String getPathToUserProxy()(Code) | | Returns the path to the user proxy from the pool configuration file and
the properties file. The value in the properties file overrides the
value from the pool configuration file.
path to user proxy on local pool.null if no path is found. |
| getPriority | | protected String getPriority(TransferJob job)(Code) | | Returns the priority for the transfer job as specified in the properties
file.
Parameters:
job - the Transfer job. the priority of the job as determined from properties, can be nullif invalid value passed or property not set. |
| getSetXBitJobName | | public String getSetXBitJobName(String name, int counter)(Code) | | Generates the name of the setXBitJob , that is unique for the given
workflow.
Parameters:
name - the name of the compute job
Parameters:
counter - the index for the setXBit job. the name of the setXBitJob . |
| setRefiner | | public void setRefiner(Refiner refiner)(Code) | | Sets the callback to the refiner, that has loaded this implementation.
Parameters:
refiner - the transfer refiner that loaded the implementation. |
|
|