Modifier and Type | Field and Description |
---|---|
static String |
INTER_POOL_PREFIX
The prefix for the jobs which are added to transfer the files generated by
the parents of a job to the jobs execution pool.
|
static String |
LOCAL_PREFIX
The prefix for all local transfer jobs.
|
static String |
REGISTER_PREFIX
The prefix for the jobs which register the newly materialized files in the
Replica Catalog.
|
static String |
REMOTE_PREFIX
The prefix for all remote transfer jobs
|
static String |
STAGE_IN_PREFIX
The prefix for the jobs which are added to transfer the files to a job's
execution pool from the location returned from the replica mechanism.
|
static String |
STAGE_OUT_PREFIX
The prefix for the jobs which are added to transfer the files generated by
a job on an execution pool to the output pool.
|
Modifier and Type | Method and Description |
---|---|
void |
addInterSiteTXNodes(Job job,
Collection files,
boolean localTransfer)
Adds the inter pool transfer nodes that are required for transferring
the output files of the parents to the jobs execution site.
|
void |
addJob(Job job)
Add a new job to the workflow being refined.
|
void |
addRelation(String parent,
String child)
Adds a new relation to the workflow being refiner.
|
void |
addRelation(String parent,
String child,
String pool,
boolean parentNew)
Adds a new relation to the workflow.
|
void |
addStageInXFERNodes(Job job,
Collection<FileTransfer> files,
Collection<FileTransfer> symLinkFiles)
Adds the stage in transfer nodes which transfer the input files for a job,
from the location returned from the replica catalog to the job's execution
pool.
|
void |
addStageOutXFERNodes(Job job,
Collection files,
ReplicaCatalogBridge rcb,
boolean localTransfer)
Adds the stageout transfer nodes, that stage data to an output site
specified by the user.
|
void |
addStageOutXFERNodes(Job job,
Collection files,
ReplicaCatalogBridge rcb,
boolean localTransfer,
boolean deletedLeaf)
Adds the stageout transfer nodes, that stage data to an output site
specified by the user.
|
void |
done()
Signals that the traversal of the workflow is done.
|
String |
getDescription()
Returns a textual description of the transfer mode.
|
boolean |
isSiteThirdParty(String site,
int type)
Returns whether a Site is third party enabled or not.
|
void |
loadImplementations(PegasusBag bag)
Loads the appropriate implementations that is required by this refinement
strategy for different types of transfer jobs.
|
boolean |
refinerPreferenceForLocalTransferJobs(int type)
Boolean indicating Refiner preference for transfer jobs to run locally.
|
boolean |
refinerPreferenceForTransferJobLocation()
Boolean indicating whether the Transfer Refiner has a preference for
where a transfer job is run.
|
boolean |
runTPTOnRemoteSite(String site,
int type)
Returns whether the third party transfers for a particular site are to
be run on the remote site or the submit host.
|
boolean |
runTransferRemotely(String site,
int type)
Returns whether a Site prefers transfers to be run on it i.e remote transfers
enabled.
|
getWorkflow, getXMLProducer
static final String LOCAL_PREFIX
static final String REMOTE_PREFIX
static final String STAGE_IN_PREFIX
static final String STAGE_OUT_PREFIX
static final String INTER_POOL_PREFIX
static final String REGISTER_PREFIX
void loadImplementations(PegasusBag bag) throws TransferImplementationFactoryException
bag
- the bag of initialization objects.org.griphyn.cPlanner.transfer.implementation.TransferImplementationFactoryException
TransferImplementationFactoryException
void addInterSiteTXNodes(Job job, Collection files, boolean localTransfer)
job
- Job
object corresponding to the node to
which the files are to be transferred to.files
- Collection of FileTransfer
objects containing the
information about source and destURL's.localTransfer
- boolean indicating that associated transfer job will run
on local site.void addStageOutXFERNodes(Job job, Collection files, ReplicaCatalogBridge rcb, boolean localTransfer)
job
- Job
object corresponding to the node to
which the files are to be transferred to.files
- Collection of FileTransfer
objects containing the
information about source and destURL's.rcb
- bridge to the Replica Catalog. Used for creating registration
nodes in the workflow.localTransfer
- boolean indicating that associated transfer job will run
on local site.void addStageOutXFERNodes(Job job, Collection files, ReplicaCatalogBridge rcb, boolean localTransfer, boolean deletedLeaf)
job
- Job
object corresponding to the node to
which the files are to be transferred to.files
- Collection of FileTransfer
objects containing the
information about source and destURL's.rcb
- bridge to the Replica Catalog. Used for creating registration
nodes in the workflow.localTransfer
- boolean indicating that associated transfer job will run
on local site.deletedLeaf
- to specify whether the node is being added for
a deleted node by the reduction engine or not.
default: falsevoid addStageInXFERNodes(Job job, Collection<FileTransfer> files, Collection<FileTransfer> symLinkFiles)
job
- Job
object corresponding to the node to
which the files are to be transferred to.files
- Collection of FileTransfer
objects containing the
information about source and destURL's.symLinkFiles
- Collection of FileTransfer
objects containing
source and destination file url's for symbolic linking
on compute site.void done()
boolean refinerPreferenceForTransferJobLocation()
boolean refinerPreferenceForLocalTransferJobs(int type)
type
- the type of transfer job for which the URL is being constructed.
Should be one of the following:
stage-in
stage-out
inter-pool transferboolean runTransferRemotely(String site, int type)
site
- the name of the site.type
- the type of transfer job for which the URL is being constructed.
Should be one of the following:
stage-in
stage-out
inter-pool transferJob.STAGE_IN_JOB
,
Job.INTER_POOL_JOB
,
Job.STAGE_OUT_JOB
boolean isSiteThirdParty(String site, int type)
site
- the name of the site.type
- the type of transfer job for which the URL is being constructed.
Should be one of the following:
stage-in
stage-out
inter-pool transferJob.STAGE_IN_JOB
,
Job.INTER_POOL_JOB
,
Job.STAGE_OUT_JOB
boolean runTPTOnRemoteSite(String site, int type)
site
- the name of the site.type
- the type of transfer job for which the URL is being constructed.
Should be one of the following:
stage-in
stage-out
inter-pool transferJob.STAGE_IN_JOB
,
Job.INTER_POOL_JOB
,
Job.STAGE_OUT_JOB
void addJob(Job job)
job
- the job to be added.void addRelation(String parent, String child)
parent
- the jobname of the parent node of the edge.child
- the jobname of the child node of the edge.void addRelation(String parent, String child, String pool, boolean parentNew)
parent
- the jobname of the parent node of the edge.child
- the jobname of the child node of the edge.pool
- the execution pool where the transfer node is to be run.parentNew
- the parent node being added, is the new transfer job
and is being called for the first time.String getDescription()
Copyright © 2011 The University of Southern California. All Rights Reserved.