Node Director
Public Member Functions | List of all members
sfi.director.schedule.SimpleScheduler Class Reference
Inheritance diagram for sfi.director.schedule.SimpleScheduler:
sfi.director.schedule.Scheduler sfi.director.schedule.ParallelScheduler

Public Member Functions

void SimpleScheduler ()
void goThroughVector (Vector jobqueue) throws DirectorException
- Public Member Functions inherited from sfi.director.schedule.Scheduler
void claimQueue (int timeout) throws DirectorException
void claimQueue () throws DirectorException
boolean isQueueMine ()
void releaseQueue () throws DirectorException
void notifyServer () throws DirectorException
void scheduleDSUpdate (Enumeration classes) throws DirectorException
void scheduleDSUpdate (DBObject dbo) throws DirectorException
void scheduleShutdown () throws DirectorException
void scheduleRemoteHostPw (String login, String pw) throws DirectorException
void scheduleJob (Job job) throws DirectorException
void scheduleJob (Enumeration jobs) throws DirectorException
synchronized void executePendingDSUpdate ()
void goThroughCmds () throws DirectorException
void purgeOldJobs () throws DirectorException
void removeOldJobs () throws DirectorException
synchronized void goThroughQueue () throws DirectorException
void attach () throws DirectorException
 Start scheduler and attach it to the job queue.
synchronized void detach () throws DirectorException
 Stop scheduler and detach from the job queue.
Job getJob (String jobId)
 Get a pending job from the in-memory job queue.
Options getOptions ()
 get schedule options.
boolean isShutdown ()
 ask if we are requested to shut down.
boolean isSchedulerRunning () throws DirectorException
 ask if there is a scheduler running on our cmd/job queue.
Options getRunningSchedulerOpts () throws DirectorException
 retrieve the options of a scheduler running on our cmd/job queue.
String getRunningSchedulerId () throws DirectorException
 retrieve the ID of a scheduler running on our cmd/job queue.
String getRunningSchedulerHost () throws DirectorException
 retrieve the host of a scheduler running on our cmd/job queue.
void rescan () throws DirectorException
 do a rescan of the job/cmd queues
String getStatus ()
 return human readable status information
String dumpStatus ()
void setPriviledged (boolean priviledged)
 choose queue for the next addCmd() (schedule*()) invocation.

Additional Inherited Members

- Static Public Member Functions inherited from sfi.director.schedule.Scheduler
static Vector loadQueue (DBConnection queue) throws DirectorException
static Vector identifyHeads (Vector queue)
- Static Public Attributes inherited from sfi.director.schedule.Scheduler
final static String scheduleOptAttr = "sfijobschedule-option"
- Protected Member Functions inherited from sfi.director.schedule.Scheduler
void executeDSUpdate (DBObject cmd) throws DirectorException
void executeCmd (DBObject cmd, boolean priviledged) throws DirectorException
void runThroughCmdQueue (DBConnection db, boolean priviledged) throws DirectorException
void runThroughLockedQueue () throws DirectorException

Constructor & Destructor Documentation

void sfi.director.schedule.SimpleScheduler.SimpleScheduler ( )

Member Function Documentation

void sfi.director.schedule.SimpleScheduler.goThroughVector ( Vector  jobqueue) throws DirectorException
virtual

The documentation for this class was generated from the following file: