A B C D E F G H I J K L M N O P Q R S T U V W X

R

raiseException() - Static method in exception org.gridbus.broker.exceptions.BadCommandException

Raise an Exception of type BadCommandException

RandomGUID - Class in org.gridbus.broker.util

RandomGUID generates truly random GUIDs by using the system's IP address (name/IP), system time in milliseconds (as an integer), and a very large random number joined together in a single String that is passed through an MD5 hash.

RandomGUID() - Constructor for class org.gridbus.broker.util.RandomGUID

Default constructor.

RandomGUID(boolean) - Constructor for class org.gridbus.broker.util.RandomGUID

Constructor with security option.

read(Object) - Method in class org.gridbus.broker.persistence.db.DBReader

read(Object) - Method in interface org.gridbus.broker.persistence.Reader

Reads all the data related to the invocation of the broker with the given brokerID from storage and returns the FarmingEngine as a State object.

read() - Method in class org.gridbus.broker.util.Base64.InputStream

Reads enough of the input stream to convert to/from Base64 and returns the next byte.

read(byte[], int, int) - Method in class org.gridbus.broker.util.Base64.InputStream

Calls read repeatedly until the end of stream is reached or len bytes are read.

readBrokerInstance(Object) - Method in class org.gridbus.broker.persistence.db.DBReader

readBrokerInstance(Object) - Method in interface org.gridbus.broker.persistence.Reader

Same as the read method without an argument, but reads the instance with the given ID

readDataFile(Object, Object) - Method in class org.gridbus.broker.persistence.db.DBReader

Reads the datafile from the store and returns a DataFile object with given ID and brokerID.

readDataFile(Object, Object) - Method in interface org.gridbus.broker.persistence.Reader

Reads the datafile with the specified ID, and brokerID and returns a DataFile object

readDataFileHosts(Collection, Collection, Object) - Method in class org.gridbus.broker.persistence.db.DBReader

Reads the DataHosts and DataFiles and sets the links between them

readDataFiles(Object) - Method in class org.gridbus.broker.persistence.db.DBReader

Reads all the datafiles associated with the given brokerID and returns a collection of datafiles.

readDataFiles(Object) - Method in interface org.gridbus.broker.persistence.Reader

Reads datafiles from the storage and returns a vector of datafile objects with the given brokerID

readDataHost(Object, Object) - Method in class org.gridbus.broker.persistence.db.DBReader

Reads the datahost from the store and returns a DataHost object with given ID and brokerID.

readDataHost(Object, Object) - Method in interface org.gridbus.broker.persistence.Reader

Reads the datahost with specified ID and brokerID and returns a DataHost object

readDataHosts(Object) - Method in class org.gridbus.broker.persistence.db.DBReader

Reads all the datahosts associated with the given brokerID and returns a collection of datahosts.

readDataHosts(Object) - Method in interface org.gridbus.broker.persistence.Reader

Reads the datahosts from storage and returns a hashtable containing those hosts, with the given brokerID

Reader - Interface in org.gridbus.broker.persistence

readEvent(Object, Object) - Method in class org.gridbus.broker.persistence.db.DBReader

Reads the event with the given eventID from the "history" table and returns a BrokerEvent object

readEvent(Object, Object) - Method in interface org.gridbus.broker.persistence.Reader

Reads an event and returns an object containing the event information

readEvents(Object) - Method in class org.gridbus.broker.persistence.db.DBReader

Reads the history of events and returns a collection of BrokerEvent objects

readJob(Object, Object) - Method in class org.gridbus.broker.persistence.db.DBReader

Reads the job with the given jobID and brokerID from the store, and returns a Job object

readJob(Object, Object) - Method in interface org.gridbus.broker.persistence.Reader

readJobCount(Object) - Method in class org.gridbus.broker.persistence.db.DBReader

readJobCount(Object, int) - Method in class org.gridbus.broker.persistence.db.DBReader

readJobCount(String, int, String) - Method in class org.gridbus.broker.persistence.db.DBReader

readJobCount(Object) - Method in interface org.gridbus.broker.persistence.Reader

readJobCount(Object, int) - Method in interface org.gridbus.broker.persistence.Reader

readJobCount(String, int, String) - Method in interface org.gridbus.broker.persistence.Reader

readJobs(Object) - Method in class org.gridbus.broker.persistence.db.DBReader

Returns the jobs collection read from the DB.

readJobs(Object, int) - Method in class org.gridbus.broker.persistence.db.DBReader

readJobs(Object, int, int, int) - Method in class org.gridbus.broker.persistence.db.DBReader

readJobs(Object) - Method in interface org.gridbus.broker.persistence.Reader

Reads jobs from the persistent storage, and returns a vector (collection) of jobs with the given brokerID

readJobs(Object, int) - Method in interface org.gridbus.broker.persistence.Reader

Reads jobs from the persistent storage with the given status, and returns a vector (collection) of jobs with the given brokerID

readJobs(Object, int, int, int) - Method in interface org.gridbus.broker.persistence.Reader

Reads a page of jobs with the given status.

readNextNJobs(Object, int) - Method in class org.gridbus.broker.persistence.db.DBReader

Reads and returns 'n' jobs from the persistent store.

readNextNJobs(Object, int, int) - Method in class org.gridbus.broker.persistence.db.DBReader

If a jobStatus of Job.ALL is passed in, jobs with all statuses are retrieved.

readNextNJobs(Object, int) - Method in interface org.gridbus.broker.persistence.Reader

Returns the first 'N' jobs from the persistent store, if available.

readNextNJobs(Object, int, int) - Method in interface org.gridbus.broker.persistence.Reader

Returns the first 'N' jobs with the given status from the persistent store, if available.

readPlan() - Method in class org.gridbus.broker.xpml.Plan2XML

This method reads the input plan file and parses it to produce an XML file representing the app-description.

readServer(Object, Object) - Method in class org.gridbus.broker.persistence.db.DBReader

Returns the ComputeServer record read from the DB corresponding to the given serverID and brokerID

readServer(Object, Object) - Method in interface org.gridbus.broker.persistence.Reader

readServerCount(Object) - Method in class org.gridbus.broker.persistence.db.DBReader

readServerCount(Object, int) - Method in class org.gridbus.broker.persistence.db.DBReader

readServerCount(Object) - Method in interface org.gridbus.broker.persistence.Reader

readServerCount(Object, int) - Method in interface org.gridbus.broker.persistence.Reader

readServers(Object) - Method in class org.gridbus.broker.persistence.db.DBReader

Reads all the ComputeServers associated with the given brokerID and returns a collection of servers.

readServers(Object, int) - Method in class org.gridbus.broker.persistence.db.DBReader

readServers(Object) - Method in interface org.gridbus.broker.persistence.Reader

Reads servers from the persistent storage, and returns a vector (collection) of computeservers with the given brokerID

readServers(Object, int) - Method in interface org.gridbus.broker.persistence.Reader

Reads servers from the persistent storage, and returns a vector (collection) of computeservers with the given brokerID

READY - Static variable in class org.gridbus.broker.farming.common.ComputeServer

Server is ready

READY - Static variable in class org.gridbus.broker.farming.common.GridbusFarmingEngine

recover(Object, BrokerProperties) - Static method in class org.gridbus.broker.persistence.Recovery

recover(Object) - Static method in class org.gridbus.broker.persistence.Recovery

Recovers the stored state of the Broker

recoverJob(Job) - Method in class org.gridbus.broker.farming.common.ComputeServer

This method queries the remote-node for the latest job-status and tries to recover the job output from the remote-node.

recoverStats() - Method in class org.gridbus.broker.scheduler.Scheduler

This method re-initialises the scheduler stats, when the broker is recovering from a crash.

Recovery - Class in org.gridbus.broker.persistence

Recovery() - Constructor for class org.gridbus.broker.persistence.Recovery

registerComputeServer(String, String) - Static method in class org.gridbus.broker.farming.globus.GassServerContainer

registerGassErrorStream(JobOutputStream) - Method in class org.gridbus.broker.farming.globus.GassServerContainer

Registers a GASS server error stream

registerGassOutputStream(JobOutputStream) - Method in class org.gridbus.broker.farming.globus.GassServerContainer

Registers a GASS server output stream

registerPostProcessJob(String, Job) - Method in class org.gridbus.broker.farming.common.postprocess.PostProcessManager

REMOTE_BROKER_OUTPUT_DIR - Static variable in class org.gridbus.broker.util.BrokerUtil

REMOTE_EXECUTE_CMD - Static variable in class org.gridbus.broker.runfile.TaskCommand

removeAllJobListeners() - Method in class org.gridbus.broker.farming.common.ComputeServer

Unregisters all the joblisteners

removeAllListeners() - Method in class org.gridbus.broker.farming.common.JobMonitor

removeJobListener(JobListener) - Method in class org.gridbus.broker.farming.common.ComputeServer

Unregisters a joblistener.

removeListener(JobListener) - Method in class org.gridbus.broker.farming.common.JobMonitor

removesFarmingEngine(FarmingEngineKey) - Method in class org.gridbus.broker.server.GridbusBrokerServer

removeVariable(SingleVariable) - Method in class org.gridbus.broker.farming.common.Job

Remove the variable name passed and its corresponding values from the list of variables

replaceParaminFile(String, String, String, String) - Static method in class org.gridbus.broker.util.FileOpsUtil

Replaces the complete line 'oldline' in the 'oldfile' with the 'newline' in the 'newfile' or null if the param is not found in the file

replaceString(String, String, String) - Static method in class org.gridbus.broker.util.FileOpsUtil

Replaces the string pattern in an input string with another string

REPLICA_CATALOG - Static variable in class org.gridbus.broker.farming.common.services.Service

ReplicaAccess - Interface in org.gridbus.broker.util

This is the interface for the classes which implement Replica Catalog access.

ReplicaCatalog - Class in org.gridbus.broker.farming.common.services

ReplicaCatalog() - Constructor for class org.gridbus.broker.farming.common.services.ReplicaCatalog

Default constructor

Requirement - Class in org.gridbus.broker.runfile

Requirement() - Constructor for class org.gridbus.broker.runfile.Requirement

Requirement(String) - Constructor for class org.gridbus.broker.runfile.Requirement

RequirementProcessor - Class in org.gridbus.broker.xpml

RequirementProcessor(Element) - Constructor for class org.gridbus.broker.xpml.RequirementProcessor

reset() - Method in class org.gridbus.broker.farming.common.Job

Resets the job status to UNSUBMITTED and sets the server to null.

resetSearchControls() - Static method in class org.gridbus.broker.farming.globus.MDSUtil

Resets the current search controls.

RESOURCE_DESCRIPTION - Static variable in class org.gridbus.broker.farming.common.BrokerProperties

The resource description used for the current grid application

resume() - Method in class org.gridbus.broker.farming.common.ComputeServerManager

resumeEncoding() - Method in class org.gridbus.broker.util.Base64.OutputStream

Resumes encoding of the stream.

returnWallClockTimeTaken() - Method in class org.gridbus.broker.farming.common.Job

This function returns the difference between the job completed timestamp and the job submitted timestamp

RoundRobinScheduler - Class in org.gridbus.broker.scheduler

This class is a Round Robin Event-based scheduler which implements a simple round-robin scheduling algorithm and expects that the jobs are always persistent.

RoundRobinScheduler(GridbusFarmingEngine) - Constructor for class org.gridbus.broker.scheduler.RoundRobinScheduler

Constructor for the scheduler

run() - Method in class org.gridbus.broker.farming.common.ComputeServerManager

run() - Method in class org.gridbus.broker.farming.common.dispatchers.OutputStager

run() - Method in class org.gridbus.broker.farming.common.JobMonitor

run() - Method in class org.gridbus.broker.farming.common.postprocess.PostProcessManager

run() - Method in class org.gridbus.broker.scheduler.Scheduler

The run method enables the scheduler to run as a seperate thread, and calls the 'schedule()' method.

RunFile - Class in org.gridbus.broker.runfile

This class parses a run file and loads the information into appropriate data structures.

RunFile() - Constructor for class org.gridbus.broker.runfile.RunFile