org.apache.oodt.cas.resource.mux

Class QueueMuxScheduler

java.lang.Object

org.apache.oodt.cas.resource.mux.QueueMuxScheduler

All Implemented Interfaces:

Runnable, Scheduler

public class QueueMuxScheduler
extends Object
implements Scheduler

This scheduler multiplexes between multiple schedulers based on the "queue" .

Version:

$Revision$

Author:

starchmd

Constructor Summary

Constructors

Constructor and Description
QueueMuxScheduler(BackendManager backend, QueueManager qm, JobQueue jq) ctor

Method Summary

Modifier and Type	Method and Description
Batchmgr	getBatchmgr()
JobQueue	getJobQueue()
Monitor	getMonitor()
QueueManager	getQueueManager()
ResourceNode	nodeAvailable(JobSpec spec) Returns the ResourceNode that is considered to be most available within our underlying set of resources for the given JobSpec.
void	run()
boolean	schedule(JobSpec spec) Schedules a job to be executed by a particular batch manager.

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueMuxScheduler

public QueueMuxScheduler(BackendManager backend,
                         QueueManager qm,
                         JobQueue jq)

ctor

Parameters:

backend - - Backend manager to handle the many different backends.

Method Detail

run

public void run()

Specified by:

run in interface Runnable

schedule

public boolean schedule(JobSpec spec)
                 throws SchedulerException

Description copied from interface: Scheduler

Schedules a job to be executed by a particular batch manager.

Specified by:

schedule in interface Scheduler

Parameters:

spec - The JobSpec to schedule for execution.

Returns:

Whether the job was successfully scheduled or not.

Throws:

SchedulerException - If there was any error scheduling the given JobSpec.

getBatchmgr

public Batchmgr getBatchmgr()

Specified by:

getBatchmgr in interface Scheduler

Returns:

The underlying Batchmgr used by this Scheduler.

getMonitor

public Monitor getMonitor()

Specified by:

getMonitor in interface Scheduler

Returns:

The underlying Monitor used by this Scheduler.

getJobQueue

public JobQueue getJobQueue()

Specified by:

getJobQueue in interface Scheduler

Returns:

The underlying JobQueue used by this Scheduler.

getQueueManager

public QueueManager getQueueManager()

Specified by:

getQueueManager in interface Scheduler

Returns:

The underlying QueueManager used by this Scheduler.

nodeAvailable

public ResourceNode nodeAvailable(JobSpec spec)
                           throws SchedulerException

Description copied from interface: Scheduler

Returns the ResourceNode that is considered to be most available within our underlying set of resources for the given JobSpec.

Specified by:

nodeAvailable in interface Scheduler

Parameters:

spec - The JobSpec to find an available node for.

Returns:

The ResourceNode best suited to handle this JobSpec

Throws:

SchedulerException - If any error occurs.