public abstract class Engine
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected PegasusBag |
mBag
The bag of initialization objects
|
protected LogManager |
mLogger
The logging object which is used to log all the messages.
|
protected java.lang.String |
mLogMsg
Contains the message which is to be logged by Pegasus.
|
protected static java.lang.String |
mOutputPool
The pool on which all the output data should be transferred.
|
protected java.lang.String |
mPoolFile
The path to the file containing the pool information.
|
protected PlannerOptions |
mPOptions
Contains the various options to the Planner as passed by the user at
runtime.
|
protected PegasusProperties |
mProps
The object holding all the properties pertaining to Pegasus.
|
protected java.lang.String |
mRLIUrl
The Replica Location Index URL got from vds.rls.url property
|
protected SiteStore |
mSiteStore
The handle to the Pool Info Provider.
|
protected java.lang.String |
mTCFile
The path to the file containing the pool information.
|
protected TransformationCatalog |
mTCHandle
The handle to the Transformation Catalog.
|
protected java.lang.String |
mTCMode
Defines the read mode for transformation catalog.
|
static java.lang.String |
REGISTRATION_UNIVERSE |
static java.lang.String |
TRANSFER_UNIVERSE |
Constructor and Description |
---|
Engine(PegasusBag bag)
A pratically nothing constructor !
|
Modifier and Type | Method and Description |
---|---|
java.util.Vector |
addVector(java.util.Vector from_vector,
java.util.Vector to_vector)
Adds elements (PegasusFile type) in a Vector to another Vector and
returns the new Vector.
|
void |
appendArrayList(java.util.ArrayList dest,
java.util.ArrayList source)
It appends the source list at the end of the destination list.
|
protected void |
complainForHeadNodeURLPrefix(java.lang.String refiner,
java.lang.String site,
FileServerType.OPERATION operation)
Complains for head node url prefix not specified
|
protected void |
complainForHeadNodeURLPrefix(java.lang.String refiner,
java.lang.String site,
FileServerType.OPERATION operation,
Job job)
Complains for head node url prefix not specified
|
void |
loadProperties()
Loads all the properties that are needed by the Engine classes.
|
void |
printVector(java.lang.String heading,
java.util.Vector vector)
It prints the contents of the Vector, with the first line being the heading.
|
boolean |
stringInList(java.lang.String stringName,
java.util.List list) |
boolean |
stringInPegVector(java.lang.String stringName,
java.util.Vector vector)
Returns true if a particular String is in the Vector of PegasusFile objects.
|
boolean |
stringInVector(java.lang.String stringName,
java.util.Vector vector)
Returns true if a particular String is in the Vector of strings.
|
java.lang.String |
vectorToString(java.lang.String heading,
java.util.Vector vector)
It prints the contents of the Vector, to a String with the first line being
the heading.
|
public static final java.lang.String REGISTRATION_UNIVERSE
public static final java.lang.String TRANSFER_UNIVERSE
protected static java.lang.String mOutputPool
protected PegasusProperties mProps
protected java.lang.String mPoolFile
protected TransformationCatalog mTCHandle
protected java.lang.String mTCFile
protected SiteStore mSiteStore
protected java.lang.String mLogMsg
protected java.lang.String mRLIUrl
protected java.lang.String mTCMode
org.griphyn.common.catalog.transformation.TCMode
protected LogManager mLogger
protected PlannerOptions mPOptions
protected PegasusBag mBag
public Engine(PegasusBag bag)
bag
- bag of initialization objectspublic void loadProperties()
public boolean stringInVector(java.lang.String stringName, java.util.Vector vector)
stringName
- the String which has to be searched for in the Vector.vector
- the Vector of Strings in which to search for a
particular String.public boolean stringInList(java.lang.String stringName, java.util.List list)
public boolean stringInPegVector(java.lang.String stringName, java.util.Vector vector)
stringName
- the String which has to be searched for in the Vector.vector
- the Vector of Strings in which to search for a particular
Stringpublic java.util.Vector addVector(java.util.Vector from_vector, java.util.Vector to_vector)
from_vector
- the sourceto_vector
- the destinationpublic void printVector(java.lang.String heading, java.util.Vector vector)
heading
- The heading you want to give to the text which is printed.vector
- The Vector
whose elements you want to print.public java.lang.String vectorToString(java.lang.String heading, java.util.Vector vector)
heading
- The heading you want to give to the text which is printed.vector
- The Vector
whose elements you want to print.public void appendArrayList(java.util.ArrayList dest, java.util.ArrayList source)
dest
- the destination listsource
- the source listprotected void complainForHeadNodeURLPrefix(java.lang.String refiner, java.lang.String site, FileServerType.OPERATION operation)
refiner
- the name of the refinersite
- the site handlejava.lang.RuntimeException
- when URL Prefix cannot be determined for various reason.protected void complainForHeadNodeURLPrefix(java.lang.String refiner, java.lang.String site, FileServerType.OPERATION operation, Job job)
refiner
- the name of the refineroperation
- the operation for which error is throwjob
- the related job if anysite
- the site handlejava.lang.RuntimeException
- when URL Prefix cannot be determined for various reason.