edu.isi.pegasus.planner.refiner
public abstract class Engine extends 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 String |
mLogMsg
Contains the message which is to be logged by Pegasus.
|
protected static String |
mOutputPool
The pool on which all the output data should be transferred.
|
protected 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 String |
mRLIUrl
The Replica Location Index URL got from vds.rls.url property
|
protected SiteStore |
mSiteStore
The handle to the Pool Info Provider.
|
protected String |
mTCFile
The path to the file containing the pool information.
|
protected TransformationCatalog |
mTCHandle
The handle to the Transformation Catalog.
|
protected String |
mTCMode
Defines the read mode for transformation catalog.
|
static String |
REGISTRATION_UNIVERSE |
static String |
TRANSFER_UNIVERSE |
Constructor and Description |
---|
Engine(PegasusBag bag)
A pratically nothing constructor !
|
Modifier and Type | Method and Description |
---|---|
Vector |
addVector(Vector from_vector,
Vector to_vector)
Adds elements (PegasusFile type) in a Vector to another Vector and
returns the new Vector.
|
void |
appendArrayList(ArrayList dest,
ArrayList source)
It appends the source list at the end of the destination list.
|
protected void |
complainForHeadNodeURLPrefix(String refiner,
String site,
FileServerType.OPERATION operation)
Complains for head node url prefix not specified
|
protected void |
complainForHeadNodeURLPrefix(String refiner,
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(String heading,
Vector vector)
It prints the contents of the Vector, with the first line being the heading.
|
boolean |
stringInList(String stringName,
List list) |
boolean |
stringInPegVector(String stringName,
Vector vector)
Returns true if a particular String is in the Vector of PegasusFile objects.
|
boolean |
stringInVector(String stringName,
Vector vector)
Returns true if a particular String is in the Vector of strings.
|
String |
vectorToString(String heading,
Vector vector)
It prints the contents of the Vector, to a String with the first line being
the heading.
|
public static final String REGISTRATION_UNIVERSE
public static final String TRANSFER_UNIVERSE
protected static String mOutputPool
protected PegasusProperties mProps
protected String mPoolFile
protected TransformationCatalog mTCHandle
protected String mTCFile
protected SiteStore mSiteStore
protected String mLogMsg
protected String mRLIUrl
protected 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(String stringName, 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 stringInPegVector(String stringName, 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 Vector addVector(Vector from_vector, Vector to_vector)
from_vector
- the sourceto_vector
- the destinationpublic void printVector(String heading, 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 String vectorToString(String heading, 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(ArrayList dest, ArrayList source)
dest
- the destination listsource
- the source listprotected void complainForHeadNodeURLPrefix(String refiner, String site, FileServerType.OPERATION operation)
refiner
- the name of the refinersite
- the site handleRuntimeException
- when URL Prefix cannot be determined for various reason.protected void complainForHeadNodeURLPrefix(String refiner, 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 handleRuntimeException
- when URL Prefix cannot be determined for various reason.