org.apache.oodt.cas.filemgr.system

Class XmlRpcFileManager

java.lang.Object

org.apache.oodt.cas.filemgr.system.XmlRpcFileManager

public class XmlRpcFileManager
extends Object

Version:

$Revision$

An XML RPC-based File manager.

Author:

mattmann, bfoster

Constructor Summary

Constructors

Constructor and Description
XmlRpcFileManager(int port) Creates a new XmlRpcFileManager with the given metadata store factory, and the given data store factory, on the given port.

Method Summary

Modifier and Type	Method and Description
boolean	addMetadata(Hashtable<String,Object> productHash, Hashtable<String,String> metadata)
boolean	addMetadataCore(Map<String,Object> productHash, Map<String,String> metadata)
boolean	addProductReferences(Hashtable<String,Object> productHash)
boolean	addProductReferencesCore(Map<String,Object> productHash)
String	addProductType(Hashtable<String,Object> productTypeHash)
String	addProductTypeCore(Map<String,Object> productTypeHash)
String	catalogProduct(Hashtable<String,Object> productHash)
String	catalogProductCore(Map<String,Object> productHash)
List<Map<String,Object>>	complexQuery(Hashtable<String,Object> complexQueryHash)
List<Map<String,Object>>	complexQueryCore(Map<String,Object> complexQueryHash)
Map<String,Object>	getCatalogQuery(Hashtable<String,Object> queryHash, Hashtable<String,Object> productTypeHash)
Map<String,Object>	getCatalogQueryCore(Map<String,Object> queryHash, Map<String,Object> productTypeHash)
Map<String,Object>	getCatalogValues(Hashtable<String,Object> metadataHash, Hashtable<String,Object> productTypeHash)
Map<String,Object>	getCatalogValuesCore(Map<String,Object> metadataHash, Map<String,Object> productTypeHash)
Map<String,Object>	getCurrentFileTransferCore()
List<Map<String,Object>>	getCurrentFileTransfers()
Map<String,Object>	getElementById(String elementId)
Map<String,Object>	getElementByName(String elementName)
List<Map<String,Object>>	getElementsByProductType(Map<String,Object> productTypeHash)
Map<String,Object>	getFirstPage(Hashtable<String,Object> productTypeHash)
Map<String,Object>	getFirstPageCore(Map<String,Object> productTypeHash)
Map<String,Object>	getLastPage(Hashtable<String,Object> productTypeHash)
Map<String,Object>	getLastPageCore(Map<String,Object> productTypeHash)
Map<String,Object>	getMetadata(Hashtable<String,Object> productHash)
Map<String,Object>	getMetadataCore(Map<String,Object> productHash)
Map<String,Object>	getNextPage(Hashtable<String,Object> productTypeHash, Hashtable<String,Object> currentPageHash)
Map<String,Object>	getNextPageCore(Map<String,Object> productTypeHash, Map<String,Object> currentPageHash)
int	getNumProducts(Hashtable<String,Object> productTypeHash)
int	getNumProductsCore(Map<String,Object> productTypeHash)
Map<String,Object>	getOrigValues(Hashtable<String,Object> metadataHash, Hashtable<String,Object> productTypeHash)
Map<String,Object>	getOrigValuesCore(Map<String,Object> metadataHash, Map<String,Object> productTypeHash)
Map<String,Object>	getPrevPage(Hashtable<String,Object> productTypeHash, Hashtable<String,Object> currentPageHash)
Map<String,Object>	getPrevPageCore(Map<String,Object> productTypeHash, Map<String,Object> currentPageHash)
Map<String,Object>	getProductById(String productId)
Map<String,Object>	getProductByName(String productName)
double	getProductPctTransferred(Hashtable<String,Object> productHash)
double	getProductPctTransferredCore(Map<String,Object> productHash)
List<Map<String,Object>>	getProductReferences(Hashtable<String,Object> productHash)
List<Map<String,Object>>	getProductReferencesCore(Map<String,Object> productHash)
List<Map<String,Object>>	getProductsByProductType(Hashtable<String,Object> productTypeHash)
List<Map<String,Object>>	getProductsByProductTypeCore(Map<String,Object> productTypeHash)
Map<String,Object>	getProductTypeById(String productTypeId)
Map<String,Object>	getProductTypeByName(String productTypeName)
List<Map<String,Object>>	getProductTypes()
Map<String,Object>	getReducedMetadata(Hashtable<String,Object> productHash, Vector<String> elements)
Map<String,Object>	getReducedMetadataCore(Map<String,Object> productHash, Vector<String> elements)
double	getRefPctTransferred(Hashtable<String,Object> refHash)
double	getRefPctTransferredCore(Map<String,Object> refHash)
List<Map<String,Object>>	getTopNProducts(int n)
List<Map<String,Object>>	getTopNProducts(int n, Hashtable<String,Object> productTypeHash)
List<Map<String,Object>>	getTopNProductsCore(int n, Map<String,Object> productTypeHash)
boolean	hasProduct(String productName)
String	ingestProduct(Hashtable<String,Object> ph, Hashtable<String,String> m, boolean ct)
String	ingestProductCore(Map<String,Object> productHash, Map<String,String> metadata, boolean clientTransfer)
boolean	isAlive()
boolean	isTransferComplete(Hashtable<String,Object> productHash)
boolean	isTransferCompleteCore(Map<String,Object> productHash)
static void	main(String[] args)
boolean	modifyProduct(Hashtable<?,?> productHash)
boolean	modifyProductCore(Map<?,?> productHash)
boolean	moveProduct(Hashtable<String,Object> productHash, String newPath)
boolean	moveProductCore(Map<String,Object> productHash, String newPath)
Map<String,Object>	pagedQuery(Hashtable<String,Object> queryHash, Hashtable<String,Object> productTypeHash, int pageNum)
Map<String,Object>	pagedQueryCore(Map<String,Object> queryHash, Map<String,Object> productTypeHash, int pageNum)
List<Map<String,Object>>	query(Hashtable<String,Object> queryHash, Hashtable<String,Object> productTypeHash)
List<Map<String,Object>>	queryCore(Map<String,Object> queryHash, Map<String,Object> productTypeHash)
boolean	refreshConfigAndPolicy()
boolean	removeFile(String filePath)
boolean	removeProduct(Hashtable table)
boolean	removeProduct(Map<String,Object> productHash)
boolean	removeProductTransferStatus(Hashtable<String,Object> productHash)
boolean	removeProductTransferStatusCore(Map<String,Object> productHash)
byte[]	retrieveFile(String filePath, int offset, int numBytes)
void	setCatalog(Catalog catalog)
boolean	setProductTransferStatus(Hashtable<String,Object> productHash)
boolean	setProductTransferStatusCore(Map<String,Object> productHash)
boolean	shutdown()
boolean	transferFile(String filePath, byte[] fileData, int offset, int numBytes)
boolean	transferringProduct(Hashtable<String,Object> productHash)
boolean	transferringProductCore(Map<String,Object> productHash)
boolean	updateMetadata(Hashtable<String,Object> productHash, Hashtable<String,Object> metadataHash)
boolean	updateMetadataCore(Map<String,Object> productHash, Map<String,Object> metadataHash)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

XmlRpcFileManager

public XmlRpcFileManager(int port)
                  throws IOException

Creates a new XmlRpcFileManager with the given metadata store factory, and the given data store factory, on the given port.

Parameters:

port - The web server port to run the XML Rpc server on, defaults to 1999.

Throws:

IOException

Method Detail

setCatalog

public void setCatalog(Catalog catalog)

isAlive

public boolean isAlive()

refreshConfigAndPolicy

public boolean refreshConfigAndPolicy()

transferringProduct

public boolean transferringProduct(Hashtable<String,Object> productHash)

transferringProductCore

public boolean transferringProductCore(Map<String,Object> productHash)

getCurrentFileTransferCore

public Map<String,Object> getCurrentFileTransferCore()

getCurrentFileTransfers

public List<Map<String,Object>> getCurrentFileTransfers()

getProductPctTransferred

public double getProductPctTransferred(Hashtable<String,Object> productHash)

getProductPctTransferredCore

public double getProductPctTransferredCore(Map<String,Object> productHash)

getRefPctTransferred

public double getRefPctTransferred(Hashtable<String,Object> refHash)

getRefPctTransferredCore

public double getRefPctTransferredCore(Map<String,Object> refHash)

removeProductTransferStatus

public boolean removeProductTransferStatus(Hashtable<String,Object> productHash)

removeProductTransferStatusCore

public boolean removeProductTransferStatusCore(Map<String,Object> productHash)

isTransferComplete

public boolean isTransferComplete(Hashtable<String,Object> productHash)

isTransferCompleteCore

public boolean isTransferCompleteCore(Map<String,Object> productHash)

pagedQuery

public Map<String,Object> pagedQuery(Hashtable<String,Object> queryHash,
                                     Hashtable<String,Object> productTypeHash,
                                     int pageNum)
                              throws CatalogException

Throws:

CatalogException

pagedQueryCore

public Map<String,Object> pagedQueryCore(Map<String,Object> queryHash,
                                         Map<String,Object> productTypeHash,
                                         int pageNum)
                                  throws CatalogException

Throws:

CatalogException

getFirstPage

public Map<String,Object> getFirstPage(Hashtable<String,Object> productTypeHash)

getFirstPageCore

public Map<String,Object> getFirstPageCore(Map<String,Object> productTypeHash)

getLastPage

public Map<String,Object> getLastPage(Hashtable<String,Object> productTypeHash)

getLastPageCore

public Map<String,Object> getLastPageCore(Map<String,Object> productTypeHash)

getNextPage

public Map<String,Object> getNextPage(Hashtable<String,Object> productTypeHash,
                                      Hashtable<String,Object> currentPageHash)

getNextPageCore

public Map<String,Object> getNextPageCore(Map<String,Object> productTypeHash,
                                          Map<String,Object> currentPageHash)

getPrevPage

public Map<String,Object> getPrevPage(Hashtable<String,Object> productTypeHash,
                                      Hashtable<String,Object> currentPageHash)

getPrevPageCore

public Map<String,Object> getPrevPageCore(Map<String,Object> productTypeHash,
                                          Map<String,Object> currentPageHash)

addProductType

public String addProductType(Hashtable<String,Object> productTypeHash)
                      throws RepositoryManagerException

Throws:

RepositoryManagerException

addProductTypeCore

public String addProductTypeCore(Map<String,Object> productTypeHash)
                          throws RepositoryManagerException

Throws:

RepositoryManagerException

setProductTransferStatus

public boolean setProductTransferStatus(Hashtable<String,Object> productHash)
                                 throws CatalogException

Throws:

CatalogException

setProductTransferStatusCore

public boolean setProductTransferStatusCore(Map<String,Object> productHash)
                                     throws CatalogException

Throws:

CatalogException

getNumProducts

public int getNumProducts(Hashtable<String,Object> productTypeHash)
                   throws CatalogException

Throws:

CatalogException

getNumProductsCore

public int getNumProductsCore(Map<String,Object> productTypeHash)
                       throws CatalogException

Throws:

CatalogException

getTopNProducts

public List<Map<String,Object>> getTopNProducts(int n)
                                         throws CatalogException

Throws:

CatalogException

getTopNProducts

public List<Map<String,Object>> getTopNProducts(int n,
                                                Hashtable<String,Object> productTypeHash)
                                         throws CatalogException

Throws:

CatalogException

getTopNProductsCore

public List<Map<String,Object>> getTopNProductsCore(int n,
                                                    Map<String,Object> productTypeHash)
                                             throws CatalogException

Throws:

CatalogException

hasProduct

public boolean hasProduct(String productName)
                   throws CatalogException

Throws:

CatalogException

getMetadata

public Map<String,Object> getMetadata(Hashtable<String,Object> productHash)
                               throws CatalogException

Throws:

CatalogException

getMetadataCore

public Map<String,Object> getMetadataCore(Map<String,Object> productHash)
                                   throws CatalogException

Throws:

CatalogException

getReducedMetadata

public Map<String,Object> getReducedMetadata(Hashtable<String,Object> productHash,
                                             Vector<String> elements)
                                      throws CatalogException

Throws:

CatalogException

getReducedMetadataCore

public Map<String,Object> getReducedMetadataCore(Map<String,Object> productHash,
                                                 Vector<String> elements)
                                          throws CatalogException

Throws:

CatalogException

getProductTypes

public List<Map<String,Object>> getProductTypes()
                                         throws RepositoryManagerException

Throws:

RepositoryManagerException

getProductReferences

public List<Map<String,Object>> getProductReferences(Hashtable<String,Object> productHash)
                                              throws CatalogException

Throws:

CatalogException

getProductReferencesCore

public List<Map<String,Object>> getProductReferencesCore(Map<String,Object> productHash)
                                                  throws CatalogException

Throws:

CatalogException

getProductById

public Map<String,Object> getProductById(String productId)
                                  throws CatalogException

Throws:

CatalogException

getProductByName

public Map<String,Object> getProductByName(String productName)
                                    throws CatalogException

Throws:

CatalogException

getProductsByProductType

public List<Map<String,Object>> getProductsByProductType(Hashtable<String,Object> productTypeHash)
                                                  throws CatalogException

Throws:

CatalogException

getProductsByProductTypeCore

public List<Map<String,Object>> getProductsByProductTypeCore(Map<String,Object> productTypeHash)
                                                      throws CatalogException

Throws:

CatalogException

getElementsByProductType

public List<Map<String,Object>> getElementsByProductType(Map<String,Object> productTypeHash)
                                                  throws ValidationLayerException

Throws:

ValidationLayerException

getElementById

public Map<String,Object> getElementById(String elementId)
                                  throws ValidationLayerException

Throws:

ValidationLayerException

getElementByName

public Map<String,Object> getElementByName(String elementName)
                                    throws ValidationLayerException

Throws:

ValidationLayerException

complexQuery

public List<Map<String,Object>> complexQuery(Hashtable<String,Object> complexQueryHash)
                                      throws CatalogException

Throws:

CatalogException

complexQueryCore

public List<Map<String,Object>> complexQueryCore(Map<String,Object> complexQueryHash)
                                          throws CatalogException

Throws:

CatalogException

query

public List<Map<String,Object>> query(Hashtable<String,Object> queryHash,
                                      Hashtable<String,Object> productTypeHash)
                               throws CatalogException

Throws:

CatalogException

queryCore

public List<Map<String,Object>> queryCore(Map<String,Object> queryHash,
                                          Map<String,Object> productTypeHash)
                                   throws CatalogException

Throws:

CatalogException

getProductTypeByName

public Map<String,Object> getProductTypeByName(String productTypeName)
                                        throws RepositoryManagerException

Throws:

RepositoryManagerException

getProductTypeById

public Map<String,Object> getProductTypeById(String productTypeId)
                                      throws RepositoryManagerException

Throws:

RepositoryManagerException

updateMetadata

public boolean updateMetadata(Hashtable<String,Object> productHash,
                              Hashtable<String,Object> metadataHash)
                       throws CatalogException

Throws:

CatalogException

updateMetadataCore

public boolean updateMetadataCore(Map<String,Object> productHash,
                                  Map<String,Object> metadataHash)
                           throws CatalogException

Throws:

CatalogException

catalogProduct

public String catalogProduct(Hashtable<String,Object> productHash)
                      throws CatalogException

Throws:

CatalogException

catalogProductCore

public String catalogProductCore(Map<String,Object> productHash)
                          throws CatalogException

Throws:

CatalogException

addMetadata

public boolean addMetadata(Hashtable<String,Object> productHash,
                           Hashtable<String,String> metadata)
                    throws CatalogException

Throws:

CatalogException

addMetadataCore

public boolean addMetadataCore(Map<String,Object> productHash,
                               Map<String,String> metadata)
                        throws CatalogException

Throws:

CatalogException

addProductReferencesCore

public boolean addProductReferencesCore(Map<String,Object> productHash)
                                 throws CatalogException

Throws:

CatalogException

addProductReferences

public boolean addProductReferences(Hashtable<String,Object> productHash)
                             throws CatalogException

Throws:

CatalogException

ingestProduct

public String ingestProduct(Hashtable<String,Object> ph,
                            Hashtable<String,String> m,
                            boolean ct)
                     throws CatalogException

Throws:

CatalogException

ingestProductCore

public String ingestProductCore(Map<String,Object> productHash,
                                Map<String,String> metadata,
                                boolean clientTransfer)
                         throws CatalogException

Throws:

CatalogException

retrieveFile

public byte[] retrieveFile(String filePath,
                           int offset,
                           int numBytes)
                    throws DataTransferException

Throws:

DataTransferException

transferFile

public boolean transferFile(String filePath,
                            byte[] fileData,
                            int offset,
                            int numBytes)

moveProduct

public boolean moveProduct(Hashtable<String,Object> productHash,
                           String newPath)
                    throws DataTransferException

Throws:

DataTransferException

moveProductCore

public boolean moveProductCore(Map<String,Object> productHash,
                               String newPath)
                        throws DataTransferException

Throws:

DataTransferException

removeFile

public boolean removeFile(String filePath)
                   throws DataTransferException,
                          IOException

Throws:

DataTransferException

IOException

modifyProduct

public boolean modifyProduct(Hashtable<?,?> productHash)
                      throws CatalogException

Throws:

CatalogException

modifyProductCore

public boolean modifyProductCore(Map<?,?> productHash)
                          throws CatalogException

Throws:

CatalogException

removeProduct

public boolean removeProduct(Hashtable table)
                      throws CatalogException

Throws:

CatalogException

removeProduct

public boolean removeProduct(Map<String,Object> productHash)
                      throws CatalogException

Throws:

CatalogException

getCatalogValues

public Map<String,Object> getCatalogValues(Hashtable<String,Object> metadataHash,
                                           Hashtable<String,Object> productTypeHash)
                                    throws RepositoryManagerException

Throws:

RepositoryManagerException

getCatalogValuesCore

public Map<String,Object> getCatalogValuesCore(Map<String,Object> metadataHash,
                                               Map<String,Object> productTypeHash)
                                        throws RepositoryManagerException

Throws:

RepositoryManagerException

getOrigValues

public Map<String,Object> getOrigValues(Hashtable<String,Object> metadataHash,
                                        Hashtable<String,Object> productTypeHash)
                                 throws RepositoryManagerException

Throws:

RepositoryManagerException

getOrigValuesCore

public Map<String,Object> getOrigValuesCore(Map<String,Object> metadataHash,
                                            Map<String,Object> productTypeHash)
                                     throws RepositoryManagerException

Throws:

RepositoryManagerException

getCatalogQuery

public Map<String,Object> getCatalogQuery(Hashtable<String,Object> queryHash,
                                          Hashtable<String,Object> productTypeHash)
                                   throws RepositoryManagerException,
                                          QueryFormulationException

Throws:

RepositoryManagerException

QueryFormulationException

getCatalogQueryCore

public Map<String,Object> getCatalogQueryCore(Map<String,Object> queryHash,
                                              Map<String,Object> productTypeHash)
                                       throws RepositoryManagerException,
                                              QueryFormulationException

Throws:

RepositoryManagerException

QueryFormulationException

main

public static void main(String[] args)
                 throws IOException

Throws:

IOException

shutdown

public boolean shutdown()