| Field Summary |
|
| final public static String | PEGASUS_HOME
The name of the environment variable PEGASUS_HOME. |
| final public static String | VDS_HOME
The name of the environment variable VDS_HOME. |
| protected boolean | mDeepStorageStructure
A boolean indicating whether to have a deep directory structure for
the storage directory or not. |
| protected String | mLogMsg
The String holding the log message. |
| protected LogManager | mLogger
The LogManager object which is used to log all the messages. |
| protected String | mPoolProvider
The path to the pool information provider. |
| protected PegasusProperties | mProps
The object holding all the properties pertaining to Pegasus. |
| protected String | mStorageDir
This contains the storage directory relative to the se mount point of the
pool. |
| protected UserOptions | mUserOpts
Handle to the Singleton instance containing the options passed to the
planner at run time. |
| protected String | mWorkDir
The working directory relative to the mount point of the execution pool. |
| Method Summary |
|
| public String | getEnvironmentVariable(String siteID, String envVariable)
Returns an environment variable for a particular site set in the
Site Catalog.
Parameters:
siteID - the name of the site.
Parameters:
envVariable - the environment variable whose value is required. |
| public String | getExecPoolWorkDir(String executionPool)
This determines the working directory on remote execution pool on the
basis of whether an absolute path is specified in the pegasus.dir.exec directory
or a relative path.
Parameters:
executionPool - the pool where a job has to be executed. |
| public String | getExecPoolWorkDir(SubInfo job)
This determines the working directory on remote execution pool for a
particular job. |
| public String | getExecPoolWorkDir(String siteID, String path)
This determines the working directory on remote execution pool on the
basis of whether an absolute path is specified in the pegasus.dir.exec
directory or a relative path.
Parameters:
siteID - the name of the site where a job has to be executed.
Parameters:
path - the relative path that needs to be appended to theworkdir from the execution pool. |
| public String | getExecPoolWorkDir(String siteID, String path, int jobClass)
This determines the working directory on remote execution pool on the
basis of whether an absolute path is specified in the pegasus.dir.exec directory
or a relative path. |
| abstract public List | getGridFTPServers(String siteID)
It returns all the gridftp servers corresponding to a specified pool.
Parameters:
siteID - the name of the site at which the jobmanager runs. |
| abstract public List | getJobmanagers(String siteID)
It returns all the jobmanagers corresponding to a specified site.
Parameters:
siteID - the name of the site at which the jobmanager runs. |
| abstract public List | getJobmanagers(String siteID, String universe)
It returns all the jobmanagers corresponding to a specified pool and
universe.
Parameters:
siteID - the name of the site at which the jobmanager runs.
Parameters:
universe - the gvds universe with which it is associated. |
| public String | getPegasusHome(String siteID)
Returns the value of PEGASUS_HOME for a site.
Parameters:
siteID - the name of the site. |
| abstract public SiteInfo | getPoolEntry(String siteID, String universe)
Gets the pool information from the pool.config file on the basis
of the name of the pool, and the universe. |
| abstract public String | getPoolMode()
Returns a textual description of the pool mode being used. |
| abstract public List | getPoolProfile(String siteID)
It returns the profile information associated with a particular pool. |
| public List | getPoolProfile(String siteID, String namespace)
It returns profile information associated with a particular namespace and
pool.
Parameters:
siteID - the name of the site, whose profile information you want.
Parameters:
namespace - the namespace correspoinding to which the profileinformation of a particular site is desired. |
| abstract public List | getPools()
|
| public String | getSeMountPoint(SiteInfo site)
Return the storage mount point for a particular pool.
Parameters:
site - SiteInfo object of the site for which you want thestorage-mount-point. |
| abstract public SysInfo | getSysinfo(String siteID)
Returns the System information for a single site. |
| abstract public Map | getSysinfos(List siteids)
Returns the System information for a bunch of sites. |
| public SiteInfo | getTXPoolEntry(String poolName)
Gets the pool object to be used for the transfer universe. |
| public String | getURLPrefix(String poolName)
Returns the url prefix of a gridftp server on the pool.
gsiftp://dataserver.phys.uwm.edu/~/griphyn_test/ligodemo_output/
gives a URL prefix of gsiftp://dataserver.phys.uwm.edu
Parameters:
poolName - the name of the pool. |
| public String | getVDS_HOME(String siteID)
Returns the value of VDS_HOME for a site.
Parameters:
siteID - the name of the site. |
| public void | loadNonSingletonObjects(String propFileName)
It loads the objects using their non singleton implementations. |
| protected void | loadSingletonObjects()
It loads the objects that the pool providers need in a singleton manner,
wherever possible. |
| protected void | logMessage(String msg)
Logs the message to a logging stream. |
| public static PoolInfoProvider | nonSingletonInstance(String poolProvider, String propFileName)
The method that returns a Non Singleton instance of the dervived
InfoProvider class. |
| abstract public boolean | removeGridFtp(String siteID, String urlPrefix)
This is a soft state remove, that removes a gridftp server from a particular
pool entry. |
| abstract public boolean | removeJobManager(String siteID, String universe, String jobManagerContact)
This is a soft state remove, that removes a jobmanager from a particular
pool entry. |
| public GridFTPServer | selectGridFtp(ArrayList ftp)
Return a random gridftp url from the list of gridftp url's.
Parameters:
ftp - Takes an ArrayList of GridFTPServer Objects. |
| public String | selectLRC(ArrayList lrcs)
Return a random lrc url from the list of lrc url's.
Parameters:
lrcs - Arraylist of LRC objects. |
| public String | selectWorkdir(WorkDir workdir)
Returns the path to the execution mount point (The Workdir).
Parameters:
workdir - the WorkDir object containing the workdirinformation. |
| public static PoolInfoProvider | singletonInstance(String poolProvider)
The method which returns a Singleton instance of the derived InfoProvider
class. |
