org.globus.cog.karajan.scheduler
Class ThrottlingScheduler

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

All Implemented Interfaces:

Runnable, StatusListener, Scheduler

public class ThrottlingScheduler
extends LateBindingScheduler

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, propertyNames, 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

ThrottlingScheduler()

Method Summary

protected BoundContact	getNextContact(TaskConstraints constraints)
Service	resolveService(BoundContact contact, int taskType)

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, getPropertyNames, getRunning, getSubmitQueue, getTaskConstraints, getVirtualContacts, incRunning, isDone, releaseContact, removeHandler, resolveContact, resolveVirtualContact, run, setHandler, setProperty, setVirtualContacts, statusChanged, submitBoundToServices, 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

Constructor Detail

ThrottlingScheduler

public ThrottlingScheduler()

Method Detail

getNextContact

protected BoundContact getNextContact(TaskConstraints constraints)
                               throws NoFreeResourceException

Specified by:

getNextContact in class LateBindingScheduler

Throws:

NoFreeResourceException

resolveService

public Service resolveService(BoundContact contact,
                              int taskType)

Overrides:

resolveService in class LateBindingScheduler