A C D E F G J L M N O P R S T U

A

AlreadyRegisteredException - exception org.globus.exec.monitoring.AlreadyRegisteredException.

Job ID Already Registered.

AlreadyRegisteredException(String) - Constructor for class org.globus.exec.monitoring.AlreadyRegisteredException

addEvent(SchedulerEvent) - Method in class org.globus.exec.monitoring.JobStateMonitor

C

CACHE_FLUSH_PERIOD - Static variable in class org.globus.exec.monitoring.JobStateMonitor

Period of time between running the cache flush task.

cacheEvent(SchedulerEvent) - Method in class org.globus.exec.monitoring.JobStateMonitor

Store an event in the JobStateMonitor's cache

cacheFlushTask - Variable in class org.globus.exec.monitoring.JobStateMonitor

Cache flushing task.

cachedEvents - Variable in class org.globus.exec.monitoring.JobStateMonitor

Time-sorted soft-state cache of events

cleanProcess() - Method in class org.globus.exec.monitoring.SchedulerEventGenerator

comparator - Static variable in class org.globus.exec.monitoring.SchedulerEvent

compare(Object, Object) - Method in class org.globus.exec.monitoring.SchedulerEvent.Comparator

Compare two SchedulerEvents.

D

dispatchEvent(ResourceKey, SchedulerEvent) - Method in class org.globus.exec.monitoring.JobStateMonitor

Call the jobStateChange callback for a SEG event.

E

events - Variable in class org.globus.exec.monitoring.JobStateMonitor.DispatcherThread

exitCode - Variable in class org.globus.exec.monitoring.SchedulerEvent

F

flushCache() - Method in class org.globus.exec.monitoring.JobStateMonitor

G

getCachedEvents(String) - Method in class org.globus.exec.monitoring.JobStateMonitor

Get all cached events associated with a Job ID.

getComparator() - Static method in class org.globus.exec.monitoring.SchedulerEvent

Return a reference to the comparator used to order events.

getExitCode() - Method in class org.globus.exec.monitoring.SchedulerEvent

Return the value of the event's exit code

getLocalId() - Method in class org.globus.exec.monitoring.SchedulerEvent

Retrieve the value of the event's local ID

getMapping(String) - Method in class org.globus.exec.monitoring.JobStateMonitor

Look up the localId to ResourceKey mapping for a specified id.

getState() - Method in class org.globus.exec.monitoring.SchedulerEvent

Return the value of the event's state

getTimeStamp() - Method in class org.globus.exec.monitoring.SchedulerEvent

Retreive the value of the event's time stamp

globusLocation - Variable in class org.globus.exec.monitoring.SchedulerEventGenerator

Path to the SEG executable

J

JobStateChangeListener - interface org.globus.exec.monitoring.JobStateChangeListener.

Job State Change notification listener.

JobStateMonitor - class org.globus.exec.monitoring.JobStateMonitor.

JobStateMonitor(File, String, String, JobStateChangeListener, JobStateRecoveryListener) - Constructor for class org.globus.exec.monitoring.JobStateMonitor

Construct a new JobStateMonitor with a non-daemon SEG.

JobStateMonitor(File, String, String, JobStateChangeListener, JobStateRecoveryListener, boolean) - Constructor for class org.globus.exec.monitoring.JobStateMonitor

Construct a new JobStateMonitor.

JobStateMonitor.DispatcherThread - class org.globus.exec.monitoring.JobStateMonitor.DispatcherThread.

JobStateMonitor.DispatcherThread(ResourceKey, List) - Constructor for class org.globus.exec.monitoring.JobStateMonitor.DispatcherThread

JobStateRecoveryListener - interface org.globus.exec.monitoring.JobStateRecoveryListener.

Interface for recovery information updates.

jobStateChanged(ResourceKey, String, Date, StateEnumeration, int) - Method in interface org.globus.exec.monitoring.JobStateChangeListener

Method called by the JobStateMonitor when a job changes state.

L

lastEventTimestamp - Variable in class org.globus.exec.monitoring.JobStateMonitor

Timestamp of the last dispatched event.

lastRestart - Variable in class org.globus.exec.monitoring.SchedulerEventGenerator

Used to keep track of the last restart time for the SEG process---if it was too recent (less than our THROTTLE_RESTART_THRESHOLD) wait THROTTLE_RESTART_TIME before trying again.

listener - Variable in class org.globus.exec.monitoring.JobStateMonitor

JobStateChangeListener which will be notified of job state changes for registered job IDs.

localId - Variable in class org.globus.exec.monitoring.AlreadyRegisteredException

localId - Variable in class org.globus.exec.monitoring.NotRegisteredException

localId - Variable in class org.globus.exec.monitoring.SchedulerEvent

logger - Static variable in class org.globus.exec.monitoring.JobStateMonitor

logger - Static variable in class org.globus.exec.monitoring.SchedulerEventGenerator

M

MAX_CACHE_AGE - Static variable in class org.globus.exec.monitoring.JobStateMonitor

Maximum age of the oldest event in the soft-state cache.

mapping - Variable in class org.globus.exec.monitoring.JobStateMonitor

Mapping of Job IDs to Object keys

monitor - Variable in class org.globus.exec.monitoring.SchedulerEventGenerator

Monitor which created this SchedulerEventGenerator.

N

NotRegisteredException - exception org.globus.exec.monitoring.NotRegisteredException.

Job ID Not registered.

NotRegisteredException(String) - Constructor for class org.globus.exec.monitoring.NotRegisteredException

O

org.globus.exec.monitoring - package org.globus.exec.monitoring

P

proc - Variable in class org.globus.exec.monitoring.SchedulerEventGenerator

SEG Process handle

R

RECOVERY_PERIOD - Static variable in class org.globus.exec.monitoring.JobStateMonitor

Period of time between running the recovery update task.

recoveryListener - Variable in class org.globus.exec.monitoring.JobStateMonitor

JobStateRecoveryListener which will be notified when the JSM decides that its recovery information should be updated.

recoveryTask - Variable in class org.globus.exec.monitoring.JobStateMonitor

Recovery data update task.

registerJobID(String, ResourceKey) - Method in class org.globus.exec.monitoring.JobStateMonitor

Register a mapping from local scheduler job ID to a resource key.

resourceKey - Variable in class org.globus.exec.monitoring.JobStateMonitor.DispatcherThread

run() - Method in class org.globus.exec.monitoring.JobStateMonitor.DispatcherThread

run() - Method in class org.globus.exec.monitoring.SchedulerEventGenerator

Start and monitor a SEG process.

runtime - Static variable in class org.globus.exec.monitoring.SchedulerEventGenerator

Reference to the runtime used to start the SEG process

S

SEG_EXECUTABLE_NAME - Static variable in class org.globus.exec.monitoring.SchedulerEventGenerator

SchedulerEvent - class org.globus.exec.monitoring.SchedulerEvent.

Class used internally by the JobStateMonitor to store events emmited by the Scheduler Event Generator.

SchedulerEvent(Date, String, StateEnumeration, int) - Constructor for class org.globus.exec.monitoring.SchedulerEvent

Create a new SchedulerEvent.

SchedulerEvent.Comparator - class org.globus.exec.monitoring.SchedulerEvent.Comparator.

SchedulerEvent.Comparator() - Constructor for class org.globus.exec.monitoring.SchedulerEvent.Comparator

SchedulerEventGenerator - class org.globus.exec.monitoring.SchedulerEventGenerator.

Scheduler Event Generator monitor thread.

SchedulerEventGenerator(File, String, String, JobStateMonitor) - Constructor for class org.globus.exec.monitoring.SchedulerEventGenerator

SEG constructor.

schedulerName - Variable in class org.globus.exec.monitoring.SchedulerEventGenerator

Path to the SEG executable

seg - Variable in class org.globus.exec.monitoring.JobStateMonitor

Reference to the SEG-monitoring thread.

shutdown() - Method in class org.globus.exec.monitoring.SchedulerEventGenerator

Tell a SEG process to terminate.

shutdownCalled - Variable in class org.globus.exec.monitoring.SchedulerEventGenerator

Flag indicating that the SEG process should no longer be restarted and the thread should terminate.

start(Date) - Method in class org.globus.exec.monitoring.JobStateMonitor

Start processing SEG events.

start(Date) - Method in class org.globus.exec.monitoring.SchedulerEventGenerator

startSegProcess(Date) - Method in class org.globus.exec.monitoring.SchedulerEventGenerator

Start a scheduler event generator process.

state - Variable in class org.globus.exec.monitoring.SchedulerEvent

stop() - Method in class org.globus.exec.monitoring.JobStateMonitor

Stop processing SEG events.

T

THROTTLE_RESTART_THRESHOLD - Variable in class org.globus.exec.monitoring.SchedulerEventGenerator

When SEG terminates within this amount of time of being started, assume something might be wrong and delay again.

THROTTLE_RESTART_TIME - Variable in class org.globus.exec.monitoring.SchedulerEventGenerator

When throttling process restarts, wait this many milliseconds before next restart attempt.

throttleRestart() - Method in class org.globus.exec.monitoring.SchedulerEventGenerator

Delay THROTTLE_RESTART_TIME before returning unless either The SEG process wasn't restarted within THROTTLE_RESTART_THRESHOLD The shutdown method has been called

timeStamp - Variable in class org.globus.exec.monitoring.SchedulerEventGenerator

Timestamp of last event we've received from a SEG.

timer - Static variable in class org.globus.exec.monitoring.JobStateMonitor

Timer to handle all cache flushing and recovery timestamp update tasks.

timestamp - Variable in class org.globus.exec.monitoring.SchedulerEvent

toString() - Method in class org.globus.exec.monitoring.SchedulerEvent

U

unregisterJobID(String) - Method in class org.globus.exec.monitoring.JobStateMonitor

Unregister a local scheduler job ID for event propagation.

updateJobMonitorRecoveryTimeStamp(JobStateMonitor, Date) - Method in interface org.globus.exec.monitoring.JobStateRecoveryListener

Update the value of the timestamp used for recovering this JobStatemonitor instance.

updateRecoveryInfo() - Method in class org.globus.exec.monitoring.JobStateMonitor

userName - Variable in class org.globus.exec.monitoring.SchedulerEventGenerator

Username of the account to run the SEG as.

A C D E F G J L M N O P R S T U