org.apache.oodt.cas.resource.system

Class XmlRpcResourceManager

java.lang.Object

org.apache.oodt.cas.resource.system.XmlRpcResourceManager

public class XmlRpcResourceManager
extends Object

Version:

$Revision$

An XML RPC-based Resource manager.

Author:

woollard

Constructor Summary

Constructors

Constructor and Description
XmlRpcResourceManager(int port)

Method Summary

Modifier and Type	Method and Description
boolean	addNode(Hashtable hashNode)
boolean	addNodeCore(Map hashNode)
boolean	addNodeToQueue(String nodeId, String queueName)
boolean	addQueue(String queueName)
String	getExecutionNode(String jobId)
String	getExecutionReport()
Map	getJobInfo(String jobId)
int	getJobQueueCapacity() Gets the max number of Jobs allowed in JobQueue
int	getJobQueueSize() Gets the number of Jobs in JobQueue
Map	getNodeById(String nodeId)
String	getNodeLoad(String nodeId)
String	getNodeReport()
List	getNodes()
List<String>	getNodesInQueue(String queueName)
List	getQueuedJobs()
List<String>	getQueues()
List<String>	getQueuesWithNode(String nodeId)
String	handleJob(Hashtable jobHash, boolean jobIn)
boolean	handleJob(Hashtable jobHash, boolean jobIn, String urlStr)
String	handleJob(Hashtable jobHash, byte[] jobIn)
boolean	handleJob(Hashtable jobHash, byte[] jobIn, String urlStr)
String	handleJob(Hashtable jobHash, Date jobIn)
boolean	handleJob(Hashtable jobHash, Date jobIn, String urlStr)
String	handleJob(Hashtable jobHash, double jobIn)
boolean	handleJob(Hashtable jobHash, double jobIn, String urlStr)
boolean	handleJob(Hashtable jobHash, Hashtable jobIn, String urlStr)
String	handleJob(Hashtable jobHash, int jobIn)
boolean	handleJob(Hashtable jobHash, int jobIn, String urlStr)
String	handleJob(Hashtable jobHash, Map jobIn)
String	handleJob(Hashtable jobHash, String jobIn)
boolean	handleJob(Hashtable jobHash, String jobIn, String urlStr)
String	handleJob(Hashtable jobHash, Vector jobIn)
boolean	handleJob(Hashtable jobHash, Vector jobIn, String urlStr)
boolean	isAlive()
boolean	isJobComplete(String jobId)
boolean	killJob(String jobId)
static void	main(String[] args)
boolean	removeNode(String nodeId)
boolean	removeNodeFromQueue(String nodeId, String queueName)
boolean	removeQueue(String queueName)
boolean	setNodeCapacity(String nodeId, int capacity)
boolean	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

XmlRpcResourceManager

public XmlRpcResourceManager(int port)
                      throws IOException

Throws:

IOException

Method Detail

isAlive

public boolean isAlive()

getJobQueueSize

public int getJobQueueSize()
                    throws JobRepositoryException

Gets the number of Jobs in JobQueue

Returns:

Number of Jobs in JobQueue

Throws:

JobRepositoryException - On Any Exception

getJobQueueCapacity

public int getJobQueueCapacity()
                        throws JobRepositoryException

Gets the max number of Jobs allowed in JobQueue

Returns:

Max number of Jobs

Throws:

JobRepositoryException - On Any Exception

isJobComplete

public boolean isJobComplete(String jobId)
                      throws JobRepositoryException

Throws:

JobRepositoryException

getJobInfo

public Map getJobInfo(String jobId)
               throws JobRepositoryException

Throws:

JobRepositoryException

handleJob

public String handleJob(Hashtable jobHash,
                        Map jobIn)
                 throws SchedulerException

Throws:

SchedulerException

handleJob

public String handleJob(Hashtable jobHash,
                        int jobIn)
                 throws SchedulerException

Throws:

SchedulerException

handleJob

public String handleJob(Hashtable jobHash,
                        boolean jobIn)
                 throws SchedulerException

Throws:

SchedulerException

handleJob

public String handleJob(Hashtable jobHash,
                        String jobIn)
                 throws SchedulerException

Throws:

SchedulerException

handleJob

public String handleJob(Hashtable jobHash,
                        double jobIn)
                 throws SchedulerException

Throws:

SchedulerException

handleJob

public String handleJob(Hashtable jobHash,
                        Date jobIn)
                 throws SchedulerException

Throws:

SchedulerException

handleJob

public String handleJob(Hashtable jobHash,
                        Vector jobIn)
                 throws SchedulerException

Throws:

SchedulerException

handleJob

public String handleJob(Hashtable jobHash,
                        byte[] jobIn)
                 throws SchedulerException

Throws:

SchedulerException

handleJob

public boolean handleJob(Hashtable jobHash,
                         Hashtable jobIn,
                         String urlStr)
                  throws JobExecutionException

Throws:

JobExecutionException

handleJob

public boolean handleJob(Hashtable jobHash,
                         int jobIn,
                         String urlStr)
                  throws JobExecutionException

Throws:

JobExecutionException

handleJob

public boolean handleJob(Hashtable jobHash,
                         boolean jobIn,
                         String urlStr)
                  throws JobExecutionException

Throws:

JobExecutionException

handleJob

public boolean handleJob(Hashtable jobHash,
                         String jobIn,
                         String urlStr)
                  throws JobExecutionException

Throws:

JobExecutionException

handleJob

public boolean handleJob(Hashtable jobHash,
                         double jobIn,
                         String urlStr)
                  throws JobExecutionException

Throws:

JobExecutionException

handleJob

public boolean handleJob(Hashtable jobHash,
                         Date jobIn,
                         String urlStr)
                  throws JobExecutionException

Throws:

JobExecutionException

handleJob

public boolean handleJob(Hashtable jobHash,
                         Vector jobIn,
                         String urlStr)
                  throws JobExecutionException

Throws:

JobExecutionException

handleJob

public boolean handleJob(Hashtable jobHash,
                         byte[] jobIn,
                         String urlStr)
                  throws JobExecutionException

Throws:

JobExecutionException

getNodes

public List getNodes()
              throws MonitorException

Throws:

MonitorException

getNodeById

public Map getNodeById(String nodeId)
                throws MonitorException

Throws:

MonitorException

killJob

public boolean killJob(String jobId)
                throws MonitorException

Throws:

MonitorException

getExecutionNode

public String getExecutionNode(String jobId)

getQueues

public List<String> getQueues()

addQueue

public boolean addQueue(String queueName)

removeQueue

public boolean removeQueue(String queueName)

addNode

public boolean addNode(Hashtable hashNode)
                throws MonitorException

Throws:

MonitorException

addNodeCore

public boolean addNodeCore(Map hashNode)
                    throws MonitorException

Throws:

MonitorException

removeNode

public boolean removeNode(String nodeId)
                   throws MonitorException

Throws:

MonitorException

addNodeToQueue

public boolean addNodeToQueue(String nodeId,
                              String queueName)
                       throws QueueManagerException

Throws:

QueueManagerException

removeNodeFromQueue

public boolean removeNodeFromQueue(String nodeId,
                                   String queueName)
                            throws QueueManagerException

Throws:

QueueManagerException

getNodesInQueue

public List<String> getNodesInQueue(String queueName)
                             throws QueueManagerException

Throws:

QueueManagerException

getQueuesWithNode

public List<String> getQueuesWithNode(String nodeId)

shutdown

public boolean shutdown()

getNodeLoad

public String getNodeLoad(String nodeId)
                   throws MonitorException

Throws:

MonitorException

getQueuedJobs

public List getQueuedJobs()

getNodeReport

public String getNodeReport()
                     throws MonitorException

Throws:

MonitorException

getExecutionReport

public String getExecutionReport()
                          throws JobRepositoryException

Throws:

JobRepositoryException

main

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

Throws:

IOException

setNodeCapacity

public boolean setNodeCapacity(String nodeId,
                               int capacity)