|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Uses of SubInfo in org.griphyn.cPlanner.classes |
|---|
| Subclasses of SubInfo in org.griphyn.cPlanner.classes | |
|---|---|
class |
AggregatedJob
This class holds all the specifics of an aggregated job. |
class |
GRMSJob
This extends the job description used in Pegasus to incorporate the input and the output url's that are required to pull in the input and push out the output files. |
class |
TransferJob
This is a data class that stores the contents of the transfer job that transfers the data. |
| Methods in org.griphyn.cPlanner.classes that return SubInfo | |
|---|---|
SubInfo |
ADag.getSubInfo(String job)
This returns a SubInfo object corresponding to the job by looking through all the subInfos. |
| Methods in org.griphyn.cPlanner.classes with parameters of type SubInfo | |
|---|---|
void |
AggregatedJob.add(SubInfo job)
Adds a job to the aggregated job. |
void |
ADag.add(SubInfo job)
This adds a new job to the ADAG object. |
void |
DagInfo.addNewJob(SubInfo job)
Adds a new job to the dag. |
void |
WorkflowMetrics.decrement(SubInfo job)
Decrement the metrics when on the basis of type of job. |
void |
WorkflowMetrics.increment(SubInfo job)
Increment the metrics when on the basis of type of job. |
void |
SubInfo.mergeProfiles(SubInfo job)
Merges profiles from another job to this job in a controlled fashion. |
boolean |
ADag.remove(SubInfo job)
Removes a particular job from the workflow. |
boolean |
DagInfo.remove(SubInfo job)
Removes a job from the dag/graph structure. |
| Constructors in org.griphyn.cPlanner.classes with parameters of type SubInfo | |
|---|---|
AggregatedJob(SubInfo job,
int num)
The overloaded constructor. |
|
GRMSJob(SubInfo job)
The overloaded construct that constructs a GRMS job by wrapping around the SubInfo job. |
|
SubInfo(SubInfo job)
Overloaded constructor. |
|
TransferJob(SubInfo job)
The overloaded construct that constructs a GRMS job by wrapping around the SubInfo job. |
|
| Uses of SubInfo in org.griphyn.cPlanner.cluster |
|---|
| Methods in org.griphyn.cPlanner.cluster that return SubInfo | |
|---|---|
protected SubInfo |
Abstract.clusteredJob(Partition p)
Returns the job corresponding to a partition. |
protected SubInfo |
Abstract.clusteredJob(String id)
Returns the job corresponding to a partition. |
protected SubInfo |
Abstract.getJob(String id)
Returns the job object corresponding to the id of the job. |
| Methods in org.griphyn.cPlanner.cluster with parameters of type SubInfo | |
|---|---|
protected void |
Abstract.addJob(SubInfo job)
Adds jobs to the internal map of jobs that is maintained by the clusterer. |
protected void |
Abstract.associate(Partition p,
SubInfo job)
Maps the partition to the corresponding clustered job. |
int[] |
Horizontal.getCollapseFactor(String pool,
SubInfo job,
int size)
Returns the collapse factor, that is used to chunk up the jobs of a particular type on a pool. |
private void |
Horizontal.updateReplacementTable(List jobs,
SubInfo mergedJob)
Updates the replacement table. |
| Uses of SubInfo in org.griphyn.cPlanner.cluster.aggregator |
|---|
| Methods in org.griphyn.cPlanner.cluster.aggregator with parameters of type SubInfo | |
|---|---|
protected TransformationCatalogEntry |
Abstract.getTCEntry(SubInfo job)
Helper method to get an entry from the transformation catalog for an installed executable. |
JobAggregator |
JobAggregatorInstanceFactory.loadInstance(SubInfo job)
Returns the appropriate handle to the JobAggregator that is to be used for a particular type of job. |
| Uses of SubInfo in org.griphyn.cPlanner.code |
|---|
| Methods in org.griphyn.cPlanner.code with parameters of type SubInfo | |
|---|---|
boolean |
POSTScript.construct(SubInfo job,
String key)
Constructs the postscript that has to be invoked on the submit host after the job has executed on the remote end. |
boolean |
GridStart.enable(SubInfo job,
boolean isGlobusJob)
Enables a job to run on the grid. |
void |
CodeGenerator.generateCode(ADag dag,
SubInfo job)
Generates the code for a single job in the input format of the workflow executor being used. |
| Uses of SubInfo in org.griphyn.cPlanner.code.generator |
|---|
| Methods in org.griphyn.cPlanner.code.generator with parameters of type SubInfo | |
|---|---|
protected String |
GRMS.argumentsToXML(SubInfo job)
This method returns the xml description of the arguments that are passed to the transformation that is being invoked. |
protected String |
GRMS.executableToXML(SubInfo job)
This method returns the xml description for the executable that is to be executed, that includes the arguments with which it is to be invoked, the path to the executable and location of it's stdout , stdin and stderr. |
void |
Stork.generateCode(ADag dag,
SubInfo job)
Generates the code for a single job in the Stork format. |
void |
GRMS.generateCode(ADag dag,
SubInfo job)
Generates the code for a single job in the input format of the workflow executor being used. |
String |
Stork.getFileBaseName(SubInfo job)
Returns the basename of the file to which the job is written to. |
String |
Abstract.getFileBaseName(SubInfo job)
Returns the basename of the file to which the job is written to. |
PrintWriter |
Abstract.getWriter(SubInfo job)
Returns an open stream to the file that is used for writing out the job information for the job. |
PrintWriter |
HashedFile.getWriter(SubInfo job)
Returns an open stream to the file that is used for writing out the job information for the job. |
private String |
GRMS.gridstart(SubInfo job)
This launches a particular job through gridstart, and accordingly changes the stdio , stdin and stderr handling for the launched job. |
protected String |
GRMS.jobToXML(ADag dag,
SubInfo job)
It returns the corresponding xml description for a particular job. |
protected String |
GRMS.relationsToXML(ADag dag,
SubInfo job)
This method returns the xml description of the relations between the jobs. |
| Uses of SubInfo in org.griphyn.cPlanner.code.generator.condor |
|---|
| Methods in org.griphyn.cPlanner.code.generator.condor with parameters of type SubInfo | |
|---|---|
void |
CondorStyle.apply(SubInfo job)
Apply a style to a job. |
protected void |
CondorGenerator.applyStyle(SubInfo job,
PrintWriter writer)
Applies a submit file style to the job, according to the fact whether the job has to be submitted directly to condor or to a remote jobmanager via CondorG and GRAM. |
static void |
ClassADSGenerator.generate(PrintWriter writer,
ADag dag,
SubInfo job)
Writes out the classads for a job to corresponding writer stream. |
void |
CondorGenerator.generateCode(ADag dag,
SubInfo job)
Generates the code (condor submit file) for a single job. |
private String |
CondorGenerator.gridstart(PrintWriter writer,
SubInfo job,
boolean isGlobusJob)
This function creates the stdio handling with and without gridstart. |
protected void |
CondorGenerator.handleCondorVarForJob(SubInfo sinfo)
It updates/adds the condor variables that are got through the Dax with the values specified in the properties file, pool config file or adds some variables internally. |
protected void |
CondorGenerator.handleEnvVarForJob(SubInfo sinfo)
It updates/adds the environment variables that are got through the Dax with the values specified in the properties file, pool config file or adds some variables internally. |
protected void |
CondorGenerator.handleGlobusRSLForJob(SubInfo sinfo)
It updates/adds the the Globus RSL parameters got through the dax that are in SubInfo object. |
protected void |
CondorGenerator.handleTransferOfExecutable(SubInfo sinfo)
It changes the paths to the executable depending on whether we want to transfer the executable or not. |
| Uses of SubInfo in org.griphyn.cPlanner.code.generator.condor.style |
|---|
| Methods in org.griphyn.cPlanner.code.generator.condor.style with parameters of type SubInfo | |
|---|---|
void |
Condor.apply(SubInfo job)
Applies the condor style to the job. |
void |
CondorGlideIN.apply(SubInfo job)
Applies the style to the job to be run in a condor glide in environment. |
void |
CondorG.apply(SubInfo job)
Applies the globus style to the job. |
protected String |
Abstract.errorMessage(SubInfo job,
String style,
String universe)
Constructs an error message in case of style mismatch. |
CondorStyle |
CondorStyleFactory.loadInstance(SubInfo job)
This method loads the appropriate implementing CondorStyle as specified by the user at runtime. |
| Uses of SubInfo in org.griphyn.cPlanner.code.gridstart |
|---|
| Methods in org.griphyn.cPlanner.code.gridstart with parameters of type SubInfo | |
|---|---|
private void |
Kickstart.addCleanupPostScript(SubInfo job,
List files)
Adds a /bin/rm post job to kickstart that removes the files passed. |
boolean |
NoPOSTScript.construct(SubInfo job,
String key)
Constructs the postscript that has to be invoked on the submit host after the job has executed on the remote end. |
boolean |
UserPOSTScript.construct(SubInfo job,
String key)
Constructs the postscript that has to be invoked on the submit host after the job has executed on the remote end. |
boolean |
VDSPOSTScript.construct(SubInfo job,
String key)
Constructs the postscript that has to be invoked on the submit host after the job has executed on the remote end. |
private void |
NoGridStart.construct(SubInfo job,
String key,
String value)
Constructs a condor variable in the condor profile namespace associated with the job. |
private void |
Kickstart.construct(SubInfo job,
String key,
String value)
Constructs a condor variable in the condor profile namespace associated with the job. |
protected String |
Kickstart.constructCleanupJob(SubInfo job,
String workerNodeTmp)
Constructs a kickstart setup job |
protected String |
Kickstart.constructPOSTJob(SubInfo job,
String headNodeURLPrefix,
String headNodeDirectory,
String workerNodeDirectory,
String slsFile)
Constructs the post job that fetches sls file, and then invokes transfer again. |
protected String |
Kickstart.constructPREJob(SubInfo job,
String headNodeURLPrefix,
String headNodeDirectory,
String workerNodeDirectory,
String slsFile)
Constructs the prejob that fetches sls file, and then invokes transfer again. |
protected String |
Kickstart.constructSetupJob(SubInfo job,
String workerNodeTmp)
Constructs a kickstart setup job |
boolean |
NoGridStart.enable(SubInfo job,
boolean isGlobusJob)
Enables a job to run on the grid by launching it directly. |
boolean |
Kickstart.enable(SubInfo job,
boolean isGlobusJob)
Enables a job to run on the grid by launching it through kickstart. |
protected boolean |
Kickstart.enable(SubInfo job,
boolean isGlobusJob,
boolean stat,
boolean addPostScript)
Enables a job to run on the grid by launching it through kickstart. |
protected void |
Kickstart.enableForWorkerNodeExecution(SubInfo job,
StringBuffer args)
Enables a job for worker node execution, by calling out to the SLS interface to do the second level staging. |
protected String |
VDSPOSTScript.getPostScriptLogFile(SubInfo job)
Returns the path to the postscript log file for a job. |
protected String |
Kickstart.handleTransferOfExecutable(SubInfo job,
String path)
It changes the paths to the executable depending on whether we want to transfer the executable or not. |
GridStart |
GridStartFactory.loadGridStart(SubInfo job,
String gridStartPath)
Loads the appropriate gridstart implementation for a job on the basis of the value of the GRIDSTART_KEY in the VDS namepsace. |
POSTScript |
GridStartFactory.loadPOSTScript(SubInfo job,
GridStart gridStart)
Loads the appropriate POST Script implementation for a job on the basis of the value of the VDS profile GRIDSTART_KEY, and the DAGMan profile POST_SCRIPT_KEY in the VDS namepsace. |
private boolean |
NoGridStart.removeDirectoryKey(SubInfo job)
Returns a boolean indicating whether to remove remote directory information or not from the job. |
private boolean |
Kickstart.useInvoke(SubInfo job,
StringBuffer args)
Triggers the creation of the kickstart input file, that contains the the remote executable and the arguments with which it has to be invoked. |
| Uses of SubInfo in org.griphyn.cPlanner.engine |
|---|
| Methods in org.griphyn.cPlanner.engine that return SubInfo | |
|---|---|
private SubInfo |
TransferEngine.getSubInfo(String jobName)
Returns the SubInfo object for the job specified. |
protected SubInfo |
CreateDirectory.makeCreateDirJob(String execPool,
String jobName)
It creates a make directory job that creates a directory on the remote pool using the perl executable that Gaurang wrote. |
SubInfo |
HourGlass.makeDummyConcatJob()
It creates a dummy concat job that is run at the local submit host. |
SubInfo |
ReplicaCatalogBridge.makeRCRegNode(String regJobName,
SubInfo job,
Collection files)
It constructs the SubInfo object for the registration node, which registers the materialized files on the output pool in the RLS. |
private SubInfo |
RemoveDirectory.makeRemoveDirJob(String execPool,
String jobName)
It creates a remove directory job that creates a directory on the remote pool using the perl executable that Gaurang wrote. |
| Methods in org.griphyn.cPlanner.engine with parameters of type SubInfo | |
|---|---|
private void |
HourGlass.construct(SubInfo job,
String key,
String value)
Constructs a condor variable in the condor profile namespace associated with the job. |
private Vector |
TransferEngine.getDeletedFileTX(String pool,
SubInfo job)
This gets the file transfer objects corresponding to the location of files found in the replica mechanism, and transfers it to the output pool asked by the user. |
private void |
TransferEngine.getFilesFromRC(SubInfo job,
Vector searchFiles)
It looks up the RCEngine Hashtable to lookup the locations for the files and add nodes to transfer them. |
private Vector |
TransferEngine.getFileTX(String destPool,
SubInfo job)
This gets the Vector of FileTransfer objects for the files which have to be transferred to an one destination pool. |
private Vector |
TransferEngine.getInterpoolFileTX(SubInfo job,
Vector nodes)
This gets the Vector of FileTransfer objects for all the files which have to be transferred to the destination pool in case of Interpool transfers. |
private void |
InterPoolEngine.handleDependantExecutables(SubInfo job)
Handles the dependant executables that need to be staged. |
private boolean |
InterPoolEngine.incorporateHint(SubInfo job,
String key)
It incorporates a hint in the namespace to the job. |
private boolean |
InterPoolEngine.incorporateProfiles(SubInfo job)
Incorporates the profiles from the various sources into the job. |
protected void |
InterPoolEngine.logRefinerAction(SubInfo job)
Logs the action taken by the refiner on a job as a XML fragment in the XML Producer. |
SubInfo |
ReplicaCatalogBridge.makeRCRegNode(String regJobName,
SubInfo job,
Collection files)
It constructs the SubInfo object for the registration node, which registers the materialized files on the output pool in the RLS. |
private void |
TransferEngine.processParents(SubInfo job,
Vector vParents)
It processes a nodes parents and determines if nodes are to be added or not. |
private TransformationCatalogEntry |
InterPoolEngine.selectTCEntry(List entries,
SubInfo job,
String selectors)
Recursively ends up calling the transformation selector accordxing to a chain of selections that need to be performed on the list of valid transformation catalog |
| Uses of SubInfo in org.griphyn.cPlanner.engine.cleanup |
|---|
| Methods in org.griphyn.cPlanner.engine.cleanup that return SubInfo | |
|---|---|
SubInfo |
Implementation.createCleanupJob(String id,
List files,
SubInfo job)
Creates a cleanup job that removes the files from remote working directory. |
SubInfo |
Cleanup.createCleanupJob(String id,
List files,
SubInfo job)
Creates a cleanup job that removes the files from remote working directory. |
SubInfo |
RM.createCleanupJob(String id,
List files,
SubInfo job)
Creates a cleanup job that removes the files from remote working directory. |
| Methods in org.griphyn.cPlanner.engine.cleanup with parameters of type SubInfo | |
|---|---|
SubInfo |
Implementation.createCleanupJob(String id,
List files,
SubInfo job)
Creates a cleanup job that removes the files from remote working directory. |
SubInfo |
Cleanup.createCleanupJob(String id,
List files,
SubInfo job)
Creates a cleanup job that removes the files from remote working directory. |
SubInfo |
RM.createCleanupJob(String id,
List files,
SubInfo job)
Creates a cleanup job that removes the files from remote working directory. |
protected String |
InPlace.generateCleanupID(SubInfo job)
Returns the identifier that is to be assigned to cleanup job. |
| Uses of SubInfo in org.griphyn.cPlanner.parser |
|---|
| Fields in org.griphyn.cPlanner.parser declared as SubInfo | |
|---|---|
private SubInfo |
DaxParser.mCurrentJobSubInfo
Holds information regarding the current job being parsed. |
| Uses of SubInfo in org.griphyn.cPlanner.parser.dax |
|---|
| Methods in org.griphyn.cPlanner.parser.dax with parameters of type SubInfo | |
|---|---|
void |
Callback.cbJob(SubInfo job)
Callback for the job from section 2 jobs. |
void |
DAX2NewGraph.cbJob(SubInfo job)
This constructs a graph node for the job and ends up storing it in the internal map. |
void |
DAX2Metadata.cbJob(SubInfo job)
Callback for the job from section 2 jobs. |
void |
DAX2LabelGraph.cbJob(SubInfo job)
This constructs a graph node for the job and ends up storing it in the internal map. |
void |
DAX2Graph.cbJob(SubInfo job)
This constructs a graph node for the job and ends up storing it in the internal map. |
void |
DAX2CDAG.cbJob(SubInfo job)
Callback for the job from section 2 jobs. |
| Uses of SubInfo in org.griphyn.cPlanner.parser.pdax |
|---|
| Methods in org.griphyn.cPlanner.parser.pdax that return SubInfo | |
|---|---|
protected SubInfo |
PDAX2MDAG.constructDAGJob(Partition partition,
File directory,
String dax)
Constructs a job that plans and submits the partitioned workflow, referred to by a Partition. |
protected SubInfo |
PDAX2MDAG.getJob(String id)
Returns the job that has been constructed for a particular partition. |
| Methods in org.griphyn.cPlanner.parser.pdax with parameters of type SubInfo | |
|---|---|
protected String |
PDAX2MDAG.getBasenamePrefix(SubInfo job)
Returns the basename prefix of a dagman (usually) related file for a a job that submits nested dagman. |
protected String |
PDAX2MDAG.getCacheFilePath(SubInfo job)
Returns the full path to a cache file that corresponds for one partition. |
protected void |
PDAX2MDAG.setPrescript(SubInfo job,
String daxURL,
String log)
Sets the prescript that ends up calling to the default wrapper that introduces retry into Pegasus for a particular job. |
protected void |
PDAX2MDAG.setPrescript(SubInfo job,
String daxURL,
String log,
String namespace,
String name,
String version)
Sets the prescript that ends up calling to the default wrapper that introduces retry into Pegasus for a particular job. |
| Uses of SubInfo in org.griphyn.cPlanner.poolinfo |
|---|
| Methods in org.griphyn.cPlanner.poolinfo with parameters of type SubInfo | |
|---|---|
String |
PoolInfoProvider.getExecPoolWorkDir(SubInfo job)
This determines the working directory on remote execution pool for a particular job. |
| Uses of SubInfo in org.griphyn.cPlanner.selector.site |
|---|
| Methods in org.griphyn.cPlanner.selector.site with parameters of type SubInfo | |
|---|---|
private void |
Group.insert(SubInfo job)
Inserts the job into the group map. |
void |
RoundRobin.mapJob(SubInfo job,
List sites)
Maps a job in the workflow to an execution site. |
void |
Random.mapJob(SubInfo job,
List sites)
Maps a job in the workflow to an execution site. |
void |
NonJavaCallout.mapJob(SubInfo job,
List sites)
Calls out to the external site selector. |
abstract void |
AbstractPerJob.mapJob(SubInfo job,
List sites)
Maps a job in the workflow to the various grid sites. |
private boolean |
NonJavaCallout.parseStdOut(SubInfo job,
String s)
Extracts the chosen site from the site selector's answer. |
private File |
NonJavaCallout.prepareInputFile(SubInfo job,
List pools)
Writes job knowledge into the temporary file passed to the external site selector. |
| Uses of SubInfo in org.griphyn.cPlanner.selector.site.heft |
|---|
| Methods in org.griphyn.cPlanner.selector.site.heft with parameters of type SubInfo | |
|---|---|
protected float |
Algorithm.calculateAverageComputeTime(SubInfo job)
Returns the average compute time in seconds for a job. |
protected int |
Algorithm.getExpectedRuntime(SubInfo job,
TransformationCatalogEntry entry)
Return expected runtime. |
protected int |
Algorithm.getExpectedRuntimeFromAC(SubInfo job,
TransformationCatalogEntry entry)
Return expected runtime from the AC only if the process catalog is initialized. |
String |
Algorithm.mapJob2ExecPool(SubInfo job,
List pools)
The call out to the site selector to determine on what pool the job should be scheduled. |
| Uses of SubInfo in org.griphyn.cPlanner.transfer |
|---|
| Methods in org.griphyn.cPlanner.transfer with parameters of type SubInfo | |
|---|---|
void |
Refiner.addInterSiteTXNodes(SubInfo job,
Collection files)
Adds the inter pool transfer nodes that are required for transferring the output files of the parents to the jobs execution site. |
void |
Refiner.addJob(SubInfo job)
Add a new job to the workflow being refined. |
boolean |
Implementation.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. |
boolean |
Implementation.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. |
void |
Refiner.addStageInXFERNodes(SubInfo job,
Collection files)
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 |
Refiner.addStageOutXFERNodes(SubInfo job,
Collection files,
ReplicaCatalogBridge rcb)
Adds the stageout transfer nodes, that stage data to an output site specified by the user. |
void |
Refiner.addStageOutXFERNodes(SubInfo job,
Collection files,
ReplicaCatalogBridge rcb,
boolean deletedLeaf)
Adds the stageout transfer nodes, that stage data to an output site specified by the user. |
TransferJob |
Implementation.createTransferJob(SubInfo job,
Collection files,
Collection execFiles,
String txJobName,
int jobClass)
This constructs the SubInfo object for the transfer node. |
File |
SLS.generateSLSInputFile(SubInfo job,
String fileName,
String submitDir,
String headNodeDirectory,
String workerNodeDirectory)
Generates a second level staging file of the input files to the worker node directory. |
File |
SLS.generateSLSOutputFile(SubInfo job,
String fileName,
String submitDir,
String headNodeDirectory,
String workerNodeDirectory)
Generates a second level staging file of the input files to the worker node directory. |
String |
SLS.getSLSInputLFN(SubInfo job)
Returns the LFN of sls input file. |
String |
SLS.getSLSOutputLFN(SubInfo job)
Returns the LFN of sls output file. |
String |
SLS.invocationString(SubInfo job,
File slsFile)
Constructs a command line invocation for a job, with a given sls file. |
boolean |
SLS.modifyJobForFirstLevelStaging(SubInfo job,
String submitDir,
String slsInputLFN,
String slsOutputLFN)
Modifies a job for the first level staging to headnode.This is to add any files that needs to be staged to the head node for a job specific to the SLS implementation. |
boolean |
SLS.modifyJobForWorkerNodeExecution(SubInfo job,
String headNodeURLPrefix,
String headNodeDirectory,
String workerNodeDirectory)
Modifies a compute job for second level staging. |
boolean |
SLS.needsSLSInput(SubInfo job)
Returns a boolean indicating whether it will an input file for a job to do the transfers. |
boolean |
SLS.needsSLSOutput(SubInfo job)
Returns a boolean indicating whether it will an output file for a job to do the transfers. |
| Uses of SubInfo in org.griphyn.cPlanner.transfer.implementation |
|---|
| Methods in org.griphyn.cPlanner.transfer.implementation that return SubInfo | |
|---|---|
SubInfo |
Abstract.createNoOPJob(String name)
It creates a NoOP job that runs on the submit host. |
protected SubInfo |
Abstract.createSetXBitJob(FileTransfer file,
String name)
Creates a dirmanager job, that does a chmod on the file being staged. |
| Methods in org.griphyn.cPlanner.transfer.implementation with parameters of type SubInfo | |
|---|---|
boolean |
Abstract.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. |
boolean |
Abstract.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. |
protected boolean |
Abstract.addSetXBitJobs(SubInfo computeJob,
SubInfo txJob,
Collection execFiles)
Adds the dirmanager to the workflow, that do a chmod on the files being staged. |
protected void |
Abstract.construct(SubInfo job,
String key,
String value)
Constructs a condor variable in the condor profile namespace associated with the job. |
TransferJob |
Condor.createTransferJob(SubInfo job,
Collection files,
Collection execFiles,
String txJobName,
int jobClass)
Constructs a condor file transfer job that handles multiple transfers. |
TransferJob |
Windward.createTransferJob(SubInfo job,
Collection files,
Collection execFiles,
String txJobName,
int jobClass)
|
TransferJob |
AbstractMultipleFTPerXFERJob.createTransferJob(SubInfo job,
Collection files,
Collection execFiles,
String txJobName,
int jobClass)
Constructs a general transfer job that handles multiple transfers per transfer job. |
TransferJob |
CRFT.createTransferJob(SubInfo job,
Collection files,
Collection execFiles,
String txJobName,
int jobClass)
Calls out to the super class method to create the main structure of the job. |
TransferJob |
AbstractSingleFTPerXFERJob.createTransferJob(SubInfo job,
Collection files,
Collection execFiles,
String txJobName,
int jobClass)
Constructs a general transfer job that handles single transfers per transfer job. |
TransferJob |
Stork.createTransferJob(SubInfo job,
FileTransfer file,
Collection execFiles,
String txJobName,
int jobClass)
Constructs a general transfer job that handles single transfers per transfer job. |
TransferJob |
AbstractSingleFTPerXFERJob.createTransferJob(SubInfo job,
FileTransfer file,
Collection execFiles,
String txJobName,
int jobClass)
Constructs a general transfer job that handles single transfers per transfer job. |
| Uses of SubInfo in org.griphyn.cPlanner.transfer.refiner |
|---|
| Methods in org.griphyn.cPlanner.transfer.refiner that return SubInfo | |
|---|---|
protected SubInfo |
SDefault.createRegistrationJob(String regJobName,
SubInfo job,
Collection files,
ReplicaCatalogBridge rcb)
Creates the registration jobs, which registers the materialized files on the output site in the Replica Catalog. |
protected SubInfo |
Default.createRegistrationJob(String regJobName,
SubInfo job,
Collection files,
ReplicaCatalogBridge rcb)
Creates the registration jobs, which registers the materialized files on the output site in the Replica Catalog. |
| Methods in org.griphyn.cPlanner.transfer.refiner with parameters of type SubInfo | |
|---|---|
void |
Condor.addInterSiteTXNodes(SubInfo job,
Collection files)
Adds the inter pool transfer nodes that are required for transferring the output files of the parents to the jobs execution site. |
void |
SDefault.addInterSiteTXNodes(SubInfo job,
Collection files)
Adds the inter pool transfer nodes that are required for transferring the output files of the parents to the jobs execution site. |
void |
GRMS.addInterSiteTXNodes(SubInfo job,
Collection files)
Adds the inter pool transfer nodes that are required for transferring the output files of the parents to the jobs execution site. |
void |
Default.addInterSiteTXNodes(SubInfo job,
Collection files)
Adds the inter pool transfer nodes that are required for transferring the output files of the parents to the jobs execution site. |
void |
Condor.addJob(SubInfo job)
Add a new job to the workflow being refined. |
void |
SDefault.addJob(SubInfo job)
Add a new job to the workflow being refined. |
void |
GRMS.addJob(SubInfo job)
Add a new job to the workflow being refined. |
void |
Default.addJob(SubInfo job)
Add a new job to the workflow being refined. |
void |
Condor.addStageInXFERNodes(SubInfo job,
Collection files)
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 |
SDefault.addStageInXFERNodes(SubInfo job,
Collection files)
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 |
GRMS.addStageInXFERNodes(SubInfo job,
Collection files)
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 |
Bundle.addStageInXFERNodes(SubInfo job,
Collection files)
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 |
Default.addStageInXFERNodes(SubInfo job,
Collection files)
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 |
Condor.addStageOutXFERNodes(SubInfo job,
Collection files,
ReplicaCatalogBridge rcb)
Adds the stageout transfer nodes, that stage data to an output site specified by the user. |
void |
SDefault.addStageOutXFERNodes(SubInfo job,
Collection files,
ReplicaCatalogBridge rcb)
Adds the stageout transfer nodes, that stage data to an output site specified by the user. |
void |
GRMS.addStageOutXFERNodes(SubInfo job,
Collection files,
ReplicaCatalogBridge rcb)
Adds the stageout transfer nodes, that stage data to an output site specified by the user. |
void |
Default.addStageOutXFERNodes(SubInfo job,
Collection files,
ReplicaCatalogBridge rcb)
Adds the stageout transfer nodes, that stage data to an output site specified by the user. |
void |
Condor.addStageOutXFERNodes(SubInfo job,
Collection files,
ReplicaCatalogBridge rcb,
boolean deletedLeaf)
|
void |
SDefault.addStageOutXFERNodes(SubInfo job,
Collection files,
ReplicaCatalogBridge rcb,
boolean deletedLeaf)
Adds the stageout transfer nodes, that stage data to an output site specified by the user. |
void |
GRMS.addStageOutXFERNodes(SubInfo job,
Collection files,
ReplicaCatalogBridge rcb,
boolean deletedLeaf)
For GRMS we do not need to add any push transfer nodes. |
void |
Bundle.addStageOutXFERNodes(SubInfo job,
Collection files,
ReplicaCatalogBridge rcb,
boolean deletedLeaf)
Adds the stageout transfer nodes, that stage data to an output site specified by the user. |
void |
Default.addStageOutXFERNodes(SubInfo job,
Collection files,
ReplicaCatalogBridge rcb,
boolean deletedLeaf)
Adds the stageout transfer nodes, that stage data to an output site specified by the user. |
protected SubInfo |
SDefault.createRegistrationJob(String regJobName,
SubInfo job,
Collection files,
ReplicaCatalogBridge rcb)
Creates the registration jobs, which registers the materialized files on the output site in the Replica Catalog. |
protected SubInfo |
Default.createRegistrationJob(String regJobName,
SubInfo job,
Collection files,
ReplicaCatalogBridge rcb)
Creates the registration jobs, which registers the materialized files on the output site in the Replica Catalog. |
private TransferJob |
Condor.createStageOutTransferJob(SubInfo job,
Collection files,
String directory,
String txJobName)
Constructs a condor file transfer job that handles multiple transfers. |
protected void |
Default.logRefinerAction(SubInfo computeJob,
SubInfo txJob,
Collection files,
String type)
Records the refiner action into the Provenace Store as a XML fragment. |
| Uses of SubInfo in org.griphyn.cPlanner.transfer.sls |
|---|
| Methods in org.griphyn.cPlanner.transfer.sls with parameters of type SubInfo | |
|---|---|
File |
Condor.generateSLSInputFile(SubInfo job,
String fileName,
String submitDir,
String headNodeDirectory,
String workerNodeDirectory)
Generates a second level staging file of the input files to the worker node directory. |
File |
Transfer.generateSLSInputFile(SubInfo job,
String fileName,
String submitDir,
String headNodeDirectory,
String workerNodeDirectory)
Generates a second level staging file of the input files to the worker node directory. |
File |
Condor.generateSLSOutputFile(SubInfo job,
String fileName,
String submitDir,
String headNodeDirectory,
String workerNodeDirectory)
Generates a second level staging file of the input files to the worker node directory. |
File |
Transfer.generateSLSOutputFile(SubInfo job,
String fileName,
String submitDir,
String headNodeDirectory,
String workerNodeDirectory)
Generates a second level staging file of the input files to the worker node directory. |
String |
Condor.getSLSInputLFN(SubInfo job)
Returns the LFN of sls input file. |
String |
Transfer.getSLSInputLFN(SubInfo job)
Returns the LFN of sls input file. |
String |
Condor.getSLSOutputLFN(SubInfo job)
Returns the LFN of sls output file. |
String |
Transfer.getSLSOutputLFN(SubInfo job)
Returns the LFN of sls output file. |
String |
Condor.invocationString(SubInfo job,
File slsFile)
Constructs a command line invocation for a job, with a given sls file. |
String |
Transfer.invocationString(SubInfo job,
File slsFile)
Constructs a command line invocation for a job, with a given sls file. |
boolean |
Condor.modifyJobForFirstLevelStaging(SubInfo job,
String submitDir,
String slsInputLFN,
String slsOutputLFN)
Modifies a job for the first level staging to headnode.This is to add any files that needs to be staged to the head node for a job specific to the SLS implementation. |
boolean |
Transfer.modifyJobForFirstLevelStaging(SubInfo job,
String submitDir,
String slsInputLFN,
String slsOutputLFN)
Modifies a job for the first level staging to headnode.This is to add any files that needs to be staged to the head node for a job specific to the SLS implementation. |
boolean |
Condor.modifyJobForWorkerNodeExecution(SubInfo job,
String headNodeURLPrefix,
String headNodeDirectory,
String workerNodeDirectory)
Modifies a compute job for second level staging. |
boolean |
Transfer.modifyJobForWorkerNodeExecution(SubInfo job,
String headNodeURLPrefix,
String headNodeDirectory,
String workerNodeDirectory)
Modifies a compute job for second level staging. |
boolean |
Condor.needsSLSInput(SubInfo job)
Returns a boolean indicating whether it will an input file for a job to do the transfers. |
boolean |
Transfer.needsSLSInput(SubInfo job)
Returns a boolean indicating whether it will an input file for a job to do the transfers. |
boolean |
Condor.needsSLSOutput(SubInfo job)
Returns a boolean indicating whether it will an output file for a job to do the transfers. |
boolean |
Transfer.needsSLSOutput(SubInfo job)
Returns a boolean indicating whether it will an output file for a job to do the transfers. |
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||