public class NoGridStart extends java.lang.Object implements GridStart
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CLASSNAME
The basename of the class that is implmenting this.
|
private PegasusBag |
mBag |
private ADag |
mDAG |
protected boolean |
mEnablingPartOfAggregatedJob
An instance variable to track if enabling is happening as part of a clustered job.
|
protected java.lang.String |
mExitParserArguments
The argument string containing the arguments with which the exitcode
is invoked on kickstart output.
|
protected boolean |
mGenerateLOF
A boolean indicating whether to generate lof files or not.
|
protected LogManager |
mLogger
The LogManager object which is used to log all the messages.
|
protected PlannerOptions |
mPOptions
The options passed to the planner.
|
protected PegasusProperties |
mProps
The object holding all the properties pertaining to Pegasus.
|
protected SiteStore |
mSiteStore
Handle to the site catalog store.
|
protected SLS |
mSLS
The handle to the SLS implementor
|
protected java.lang.String |
mSubmitDir
The submit directory where the submit files are being generated for
the workflow.
|
protected boolean |
mWorkerPackageStagingEnabled
Boolean indicating whether worker package staging is enabled or not.
|
static java.lang.String |
SHORT_NAME
The SHORTNAME for this implementation.
|
mSeparator, VERSION
Constructor and Description |
---|
NoGridStart() |
Modifier and Type | Method and Description |
---|---|
private void |
addToFile(java.io.File src,
java.io.OutputStream out)
Adds contents to an output stream.
|
boolean |
canSetXBit()
Indicates whether the enabling mechanism can set the X bit
on the executable on the remote grid site, in addition to launching
it on the remote grid stie
|
private void |
construct(Job job,
java.lang.String key,
java.lang.String value)
Constructs a condor variable in the condor profile namespace
associated with the job.
|
java.lang.String |
defaultPOSTScript()
Returns the SHORT_NAME for the POSTScript implementation that is used
to be as default with this GridStart implementation.
|
boolean |
enable(AggregatedJob job,
boolean isGlobusJob)
Enables a job to run on the grid.
|
AggregatedJob |
enable(AggregatedJob aggJob,
java.util.Collection jobs)
Enables a collection of jobs and puts them into an AggregatedJob.
|
boolean |
enable(Job job,
boolean isGlobusJob)
Enables a job to run on the grid by launching it directly.
|
java.lang.String |
generateListofFilenamesFile(java.util.Set files,
java.lang.String basename)
Writes out the list of filenames file for the job.
|
protected java.lang.String |
getDirectory(Job job)
Returns the directory in which the job should run.
|
private java.lang.String |
getDirectoryKey(Job job)
Returns the directory that is associated with the job to specify
the directory in which the job needs to run
|
java.lang.String |
getVDSKeyValue()
Returns the value of the vds profile with key as Pegasus.GRIDSTART_KEY,
that would result in the loading of this particular implementation.
|
java.lang.String |
getWorkerNodeDirectory(Job job)
Returns the directory in which the job executes on the worker node.
|
protected java.lang.String |
handleTransferOfExecutable(Job job)
It changes the paths to the executable depending on whether we want to
transfer the executable or not.
|
void |
initialize(PegasusBag bag,
ADag dag)
Initializes the GridStart implementation.
|
private boolean |
removeDirectoryKey(Job job)
Returns a boolean indicating whether to remove remote directory
information or not from the job.
|
protected boolean |
requiresToSetDirectory(Job job)
Returns a boolean indicating whether we need to set the directory for
the job or not.
|
java.lang.String |
shortDescribe()
Returns a short textual description in the form of the name of the class.
|
void |
useFullPathToGridStarts(boolean fullPath)
Setter method to control whether a full path to Gridstart should be
returned while wrapping a job or not.
|
private PegasusBag mBag
private ADag mDAG
public static final java.lang.String CLASSNAME
public static final java.lang.String SHORT_NAME
protected LogManager mLogger
protected PegasusProperties mProps
protected java.lang.String mSubmitDir
protected java.lang.String mExitParserArguments
protected boolean mGenerateLOF
protected SLS mSLS
protected PlannerOptions mPOptions
protected SiteStore mSiteStore
protected boolean mEnablingPartOfAggregatedJob
protected boolean mWorkerPackageStagingEnabled
public void initialize(PegasusBag bag, ADag dag)
initialize
in interface GridStart
bag
- the bag of objects that is used for initialization.dag
- the concrete dag so far.public AggregatedJob enable(AggregatedJob aggJob, java.util.Collection jobs)
aggJob
- the AggregatedJob into which the collection has to be
integrated.jobs
- the collection of jobs (Job) that need to be enabled.enable(Job,boolean)
public boolean enable(AggregatedJob job, boolean isGlobusJob)
enable
in interface GridStart
job
- the Job
object containing the job description
of the job that has to be enabled on the grid.isGlobusJob
- is true
, if the job generated a
line universe = globus
, and thus runs remotely.
Set to false
, if the job runs on the submit
host in any way.public boolean enable(Job job, boolean isGlobusJob)
enable
in interface GridStart
job
- the Job
object containing the job description
of the job that has to be enabled on the grid.isGlobusJob
- is true
, if the job generated a
line universe = globus
, and thus runs remotely.
Set to false
, if the job runs on the submit
host in any way.protected java.lang.String handleTransferOfExecutable(Job job)
job
- the Job
containing the job description.public boolean canSetXBit()
canSetXBit
in interface GridStart
public java.lang.String getVDSKeyValue()
getVDSKeyValue
in interface GridStart
org.griphyn.cPlanner.namespace.Pegasus#GRIDSTART_KEY
public java.lang.String shortDescribe()
shortDescribe
in interface GridStart
public java.lang.String defaultPOSTScript()
defaultPOSTScript
in interface GridStart
POSTScript.shortDescribe()
protected boolean requiresToSetDirectory(Job job)
job
- the job for which to set directory.protected java.lang.String getDirectory(Job job)
job
- the job in which the directory has to run.private java.lang.String getDirectoryKey(Job job)
job
- the jobprivate boolean removeDirectoryKey(Job job)
job
- the job in question.private void construct(Job job, java.lang.String key, java.lang.String value)
job
- contains the job description.key
- the key of the profile.value
- the associated value.public java.lang.String generateListofFilenamesFile(java.util.Set files, java.lang.String basename)
files
- the list of PegasusFile
objects contains the files
whose stat information is required.basename
- the basename of the file that is to be createdprivate void addToFile(java.io.File src, java.io.OutputStream out) throws java.io.IOException
src
- out
- java.io.IOException
public java.lang.String getWorkerNodeDirectory(Job job)
getWorkerNodeDirectory
in interface GridStart
job
- public void useFullPathToGridStarts(boolean fullPath)
GridStart
useFullPathToGridStarts
in interface GridStart
fullPath
- if set to true, indicates that full path would be used.