org.globus.cog.karajan.scheduler
Class DefaultScheduler

java.lang.Object
  java.lang.Thread
      org.globus.cog.karajan.scheduler.AbstractScheduler
          org.globus.cog.karajan.scheduler.LateBindingScheduler
              org.globus.cog.karajan.scheduler.DefaultScheduler

All Implemented Interfaces:

Runnable, Scheduler, StatusListener

public class DefaultScheduler

extends LateBindingScheduler

implements Scheduler, Runnable

Field Summary

Fields inherited from class org.globus.cog.karajan.scheduler.LateBindingScheduler

executionHandlers

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

DefaultScheduler()

Method Summary

void	activateTaskList()
void	deactivateTaskList()
protected BoundContact	getNextContact()
String[]	getPropertyNames()
void	setProperty(String name, String value)
void	setTaskList(boolean value)
void	statusChanged(StatusEvent e)
void	submitBoundToServices(Task t, Contact[] contacts, Service[] services)

Methods inherited from class org.globus.cog.karajan.scheduler.LateBindingScheduler

allocateContact, cancelTask, checkFreeMemory, checkGlobalLoadConditions, checkLoad, decRunning, enqueue, findTaskHandler, getContacts, getHandler, getHandlerType, getJobsPerCPU, getRunning, getVirtualContacts, incRunning, isDone, releaseContact, removeHandler, resolveContact, resolveService, resolveVirtualContact, run, setHandler, setProperty, setVirtualContacts, terminate

Methods inherited from class org.globus.cog.karajan.scheduler.AbstractScheduler

addJobStatusListener, addTaskHandler, combineNames, fireJobStatusChangeEvent, fireJobStatusChangeEvent, getConstraints, getJobQueue, getMaxSimultaneousJobs, getProperty, getResources, getTaskHadlerWrapper, getTaskHandlers, getTaskHandlerWrapper, getTaskHandlerWrappers, removeJobStatusListener, setConstraints, setMaxSimultaneousJobs, setResources, setTaskHandlers

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.globus.cog.karajan.scheduler.Scheduler

addJobStatusListener, addTaskHandler, allocateContact, cancelTask, enqueue, getResources, getTaskHandlers, releaseContact, removeJobStatusListener, setProperty, setResources

Methods inherited from interface java.lang.Runnable

run

Constructor Detail

DefaultScheduler

public DefaultScheduler()

Method Detail

setTaskList

public void setTaskList(boolean value)

activateTaskList

public void activateTaskList()

deactivateTaskList

public void deactivateTaskList()

getNextContact

protected BoundContact getNextContact()
                               throws NoFreeResourceException

Specified by:

getNextContact in class LateBindingScheduler

Throws:

NoFreeResourceException

setProperty

public void setProperty(String name,
                        String value)

getPropertyNames

public String[] getPropertyNames()

Specified by:

getPropertyNames in interface Scheduler

Overrides:

getPropertyNames in class LateBindingScheduler

submitBoundToServices

public void submitBoundToServices(Task t,
                                  Contact[] contacts,
                                  Service[] services)
                           throws TaskSubmissionException

Overrides:

submitBoundToServices in class LateBindingScheduler

Throws:

TaskSubmissionException

statusChanged

public void statusChanged(StatusEvent e)

Specified by:

statusChanged in interface StatusListener

Overrides:

statusChanged in class LateBindingScheduler