|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--org.edg.data.reptor.info.InfoServiceBase | +--org.edg.data.reptor.info.InfoServiceRGMA
Interface to get information about the Storage Elements and Computing Elements and other Services (like RLS, RMC, ROS) from R-GMA.
Field Summary | |
protected static int |
FILE
|
protected static java.lang.String |
LRC_SERVICE
|
protected java.util.List |
m_CE
|
protected Configuration |
m_config
|
protected java.net.URI |
m_lrcURI
|
protected int |
m_printinfo
|
protected java.net.URI |
m_rliURI
|
protected java.net.URI |
m_rmcURI
|
protected java.net.URI |
m_rosURI
|
protected java.util.List |
m_SE
the list of storage elements and computing elements known to the VO |
protected java.util.HashMap |
m_storageResource
|
protected static java.lang.String |
RLI_SERVICE
|
protected static java.lang.String |
RMC_SERVICE
|
protected static java.lang.String |
ROS_SERVICE
|
protected static int |
SCREEN
|
Constructor Summary | |
InfoServiceRGMA(Configuration config)
|
Method Summary | |
protected void |
addSE(java.lang.String name,
java.lang.String seHost,
int port,
java.lang.String seID,
java.net.URL endpoint)
|
protected java.net.URI |
chooseLocalService(java.util.List urilist)
|
protected java.lang.String |
getAccessPoint(java.lang.String seID)
|
protected void |
getAllCEs(java.io.PrintStream out)
|
protected void |
getAllSEs(java.io.PrintStream out)
|
java.lang.String |
getCloseCE(java.lang.String SEHost)
Return the close CE information based on an SE host |
java.lang.String |
getCloseSE(java.lang.String ceID)
Return the close SE information based on an CE |
ComputingElementInfo |
getComputingElementInfoById(java.lang.String ceID)
Return the CE-Info object based on a host name. |
java.net.URI |
getLocalReplicaCatalogLocation()
return the single LRC instance for the system |
java.net.URI |
getLocalReplicaCatalogLocationVO(java.lang.String vo)
return the single LRC instance for the system |
java.net.URI |
getMetadataCatalogLocation()
return the single RMC instance for the system |
java.net.URI |
getMetadataCatalogLocationVO(java.lang.String vo)
return the single RMC instance for the system |
java.lang.String[] |
getProtocols(java.lang.String name,
java.lang.String seID)
Get the list of protocols for a given SE. |
java.net.URI |
getRemoteReplicaCatalogLocation(java.lang.String seHost)
return the (remote) LRC endpoint for this host. |
java.net.URI |
getReplicaLocationIndexLocation()
return the single RLI instance for the system |
java.net.URI |
getReplicaLocationIndexLocationVO(java.lang.String vo)
return the single RLI instance for the system |
java.net.URI |
getReplicaOptimizationLocation()
return the single ROS instance for the system |
java.net.URI |
getReplicaOptimizationLocationVO(java.lang.String vo)
return the single ROS instance for the system |
java.util.ArrayList |
getSEList()
return all SE names |
protected java.net.URI |
getServiceURI(java.lang.String service,
java.lang.String vo)
|
protected java.util.List |
getServiceVOs()
|
StorageElementInfo |
getStorageElementInfoByHost(java.lang.String host)
Return the SE-Info object based on a host name. |
StorageResource |
getStorageResourceByHost(java.lang.String seHost)
Return the storage resource associated with a given host. |
protected java.util.List |
getVOS(java.lang.String seID)
|
boolean |
haveCE(java.lang.String ceID)
Check whether a given CE is in our list |
boolean |
haveSE(java.lang.String seHost)
Check whether a given host is in our list of SEs |
protected boolean |
lookupCE(java.lang.String id)
|
protected boolean |
lookupSE(java.lang.String seHost)
|
void |
printInfo(java.io.PrintStream out)
Print the information used by the replica manager, as obtained from the info service specified by the configuration file, to the given stream. |
void |
printInfoForStub(java.io.PrintStream out)
Just like printInfo, but print it in a format that can be reused by the InfoServiceStub object as input file. |
protected java.lang.String |
replaceColon(java.lang.String ceHost)
|
protected java.lang.String |
retrieveCloseCE(java.lang.String SEHost)
|
protected java.lang.String[] |
toStringArray(java.util.List l)
convert List to String[] |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.edg.data.reptor.info.InfoService |
getCloseCE, getCloseSE, getComputingElementInfoById, getLocalReplicaCatalogLocation, getMetadataCatalogLocation, getRemoteReplicaCatalogLocation, getReplicaLocationIndexLocation, getReplicaOptimizationLocation, getStorageElementInfoByHost, getStorageResourceByHost, haveCE, haveSE, printInfo, printInfoForStub |
Field Detail |
protected Configuration m_config
protected java.net.URI m_lrcURI
protected java.net.URI m_rosURI
protected java.net.URI m_rmcURI
protected java.net.URI m_rliURI
protected java.util.HashMap m_storageResource
protected java.util.List m_SE
protected java.util.List m_CE
protected static java.lang.String LRC_SERVICE
protected static java.lang.String RMC_SERVICE
protected static java.lang.String ROS_SERVICE
protected static java.lang.String RLI_SERVICE
protected int m_printinfo
protected static int SCREEN
protected static int FILE
Constructor Detail |
public InfoServiceRGMA(Configuration config)
Method Detail |
protected java.lang.String retrieveCloseCE(java.lang.String SEHost) throws InfoServiceException
retrieveCloseCE
in class org.edg.data.reptor.info.InfoServiceBase
InfoServiceException
protected java.lang.String getAccessPoint(java.lang.String seID) throws InfoServiceException
getAccessPoint
in class org.edg.data.reptor.info.InfoServiceBase
InfoServiceException
protected void getAllSEs(java.io.PrintStream out) throws InfoServiceException
getAllSEs
in class org.edg.data.reptor.info.InfoServiceBase
InfoServiceException
public java.util.ArrayList getSEList() throws InfoServiceException
InfoService
getSEList
in interface InfoService
InfoServiceException
protected void getAllCEs(java.io.PrintStream out) throws InfoServiceException
getAllCEs
in class org.edg.data.reptor.info.InfoServiceBase
InfoServiceException
protected java.net.URI getServiceURI(java.lang.String service, java.lang.String vo) throws InfoServiceException
getServiceURI
in class org.edg.data.reptor.info.InfoServiceBase
InfoServiceException
public java.lang.String[] getProtocols(java.lang.String name, java.lang.String seID) throws InfoServiceException
getProtocols
in interface InfoService
getProtocols
in class org.edg.data.reptor.info.InfoServiceBase
seID
- usually the SE hostname
InfoServiceException
protected java.util.List getVOS(java.lang.String seID) throws InfoServiceException
getVOS
in class org.edg.data.reptor.info.InfoServiceBase
InfoServiceException
protected boolean lookupSE(java.lang.String seHost) throws InfoServiceException
lookupSE
in class org.edg.data.reptor.info.InfoServiceBase
InfoServiceException
protected boolean lookupCE(java.lang.String id) throws InfoServiceException
lookupCE
in class org.edg.data.reptor.info.InfoServiceBase
InfoServiceException
protected java.util.List getServiceVOs() throws InfoServiceException
getServiceVOs
in class org.edg.data.reptor.info.InfoServiceBase
InfoServiceException
public boolean haveSE(java.lang.String seHost) throws InfoServiceException
InfoServiceException
public boolean haveCE(java.lang.String ceID) throws InfoServiceException
InfoServiceException
public java.lang.String getCloseCE(java.lang.String SEHost) throws ConfigurationException, InfoServiceException
SEHost
-
ConfigurationException
InfoServiceException
public java.lang.String getCloseSE(java.lang.String ceID) throws ConfigurationException, InfoServiceException
ceID
-
ConfigurationException
InfoServiceException
public java.net.URI getLocalReplicaCatalogLocation() throws InfoServiceException
InfoServiceException
public java.net.URI getMetadataCatalogLocation() throws InfoServiceException
InfoServiceException
public java.net.URI getReplicaOptimizationLocation() throws InfoServiceException
InfoServiceException
public java.net.URI getReplicaLocationIndexLocation() throws InfoServiceException
InfoServiceException
public java.net.URI getLocalReplicaCatalogLocationVO(java.lang.String vo) throws InfoServiceException
InfoServiceException
public java.net.URI getMetadataCatalogLocationVO(java.lang.String vo) throws InfoServiceException
InfoServiceException
public java.net.URI getReplicaOptimizationLocationVO(java.lang.String vo) throws InfoServiceException
InfoServiceException
public java.net.URI getReplicaLocationIndexLocationVO(java.lang.String vo) throws InfoServiceException
InfoServiceException
public StorageElementInfo getStorageElementInfoByHost(java.lang.String host) throws InfoServiceException
host
- the host
InfoServiceException
StorageElementInfo
public ComputingElementInfo getComputingElementInfoById(java.lang.String ceID) throws InfoServiceException
ceID
- the ce id
InfoServiceException
ComputingElementInfo
public StorageResource getStorageResourceByHost(java.lang.String seHost) throws InfoServiceException, StorageResourceException
InfoServiceException
StorageResourceException
public java.net.URI getRemoteReplicaCatalogLocation(java.lang.String seHost) throws InfoServiceException
InfoServiceException
public void printInfo(java.io.PrintStream out) throws InfoServiceException, ConfigurationException
out
- The PrintStream object to print to.
InfoServiceException
ConfigurationException
public void printInfoForStub(java.io.PrintStream out) throws InfoServiceException, ConfigurationException
out
- the PrintStream to print to
InfoServiceException
ConfigurationException
protected void addSE(java.lang.String name, java.lang.String seHost, int port, java.lang.String seID, java.net.URL endpoint) throws java.net.MalformedURLException, InfoServiceException
java.net.MalformedURLException
InfoServiceException
protected java.lang.String[] toStringArray(java.util.List l)
l
-
protected java.net.URI chooseLocalService(java.util.List urilist) throws InfoServiceException, ConfigurationException
InfoServiceException
ConfigurationException
protected java.lang.String replaceColon(java.lang.String ceHost)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |