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, StatusListener, Scheduler

public class DefaultScheduler
extends LateBindingScheduler
implements Scheduler, Runnable

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

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

DEFAULT_JOBS_PER_CPU, DEFAULT_MAX_FILE_OPERATIONS, DEFAULT_MAX_TRANSFERS, DEFAULT_SSH_INITIAL_RATE, executionHandlers, HOST_SUBMIT_THROTTLE, JOBS_PER_CPU, K, MAX_FILE_OPERATIONS, MAX_TRANSFERS, SSH_INITIAL_RATE, SUBMIT_THROTTLE, THREAD_STACK_SIZE

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

THROTTLE_OFF

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(TaskConstraints t)
String[]	getPropertyNames()
void	setProperty(String name, Object value) Sets a scheduler property.
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, allocateContact, cancelTask, checkFreeMemory, checkGlobalLoadConditions, checkLoad, checkTaskLoadConditions, decRunning, enqueue, failTask, findTaskHandler, getContacts, getHandler, getHandlerType, getJobsPerCPU, getNextContact, getRunning, getSubmitQueue, getTaskConstraints, getVirtualContacts, incRunning, isDone, releaseContact, removeHandler, resolveContact, resolveService, resolveVirtualContact, run, setHandler, setVirtualContacts, terminate

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

addFailureHandler, addJobStatusListener, addTaskHandler, addTaskTransformer, applyTaskTransformers, checkConstraints, checkConstraints, combineNames, fireJobStatusChangeEvent, fireJobStatusChangeEvent, getConstraintChecker, getConstraints, getJobQueue, getMaxSimultaneousJobs, getProperty, getResources, getTaskHadlerWrapper, getTaskHandlers, getTaskHandlerWrapper, getTaskHandlerWrappers, getTaskTransformers, removeConstraints, removeJobStatusListener, runFailureHandlers, setConstraintChecker, setConstraints, setMaxSimultaneousJobs, setResources, setTaskHandlers, throttleValue

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, 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

addFailureHandler, addJobStatusListener, addTaskHandler, addTaskTransformer, allocateContact, allocateContact, cancelTask, enqueue, getResources, getTaskHandlers, releaseContact, removeJobStatusListener, 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(TaskConstraints t)
                               throws NoFreeResourceException

Specified by:

getNextContact in class LateBindingScheduler

Throws:

NoFreeResourceException

setProperty

public void setProperty(String name,
                        Object value)

Description copied from interface: Scheduler

Sets a scheduler property. The supported property names can be queried using the getPropertyNames method

Specified by:

setProperty in interface Scheduler

Overrides:

setProperty in class LateBindingScheduler

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