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


class  encapsulatedInt
class  ExecutorThread

Public Member Functions

void ParallelScheduler ()
synchronized 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.
synchronized void goThroughCmds () throws DirectorException
synchronized void removeOldJobs () throws DirectorException
synchronized void goThroughQueue () throws DirectorException
Job getJob (String id)
 Get a pending job from the in-memory job queue.
String getStatus ()
 return human readable status information
String dumpStatus ()
- Public Member Functions inherited from sfi.director.schedule.SimpleScheduler
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 purgeOldJobs () throws DirectorException
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
void setPriviledged (boolean priviledged)
 choose queue for the next addCmd() (schedule*()) invocation.

Protected Member Functions

void saveQueue ()
void finalize ()
synchronized void executeCmd (DBObject cmd, boolean priviledged) throws DirectorException
void markHeads (int from)
 go through structure of newly loaded jobs and mark head jobs
void parallelizedExec ()

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"

Constructor & Destructor Documentation

void sfi.director.schedule.ParallelScheduler.ParallelScheduler ( )

Member Function Documentation

synchronized void sfi.director.schedule.ParallelScheduler.attach ( ) throws DirectorException
synchronized void sfi.director.schedule.ParallelScheduler.detach ( ) throws DirectorException
String sfi.director.schedule.ParallelScheduler.dumpStatus ( )
synchronized void sfi.director.schedule.ParallelScheduler.executeCmd ( DBObject  cmd,
boolean  priviledged 
) throws DirectorException
void sfi.director.schedule.ParallelScheduler.finalize ( )
Job sfi.director.schedule.ParallelScheduler.getJob ( String  jobId)

Get a pending job from the in-memory job queue.

If the job is not held in memory return null. This explicitly will not try to retrieve a job from the jobqueue database!

Reimplemented from sfi.director.schedule.Scheduler.

String sfi.director.schedule.ParallelScheduler.getStatus ( )
synchronized void sfi.director.schedule.ParallelScheduler.goThroughCmds ( ) throws DirectorException
synchronized void sfi.director.schedule.ParallelScheduler.goThroughQueue ( ) throws DirectorException
void sfi.director.schedule.ParallelScheduler.markHeads ( int  from)

go through structure of newly loaded jobs and mark head jobs

: Requires jobqueue to be locked by the caller

References, sfi.director.schedule.Scheduler.identifyHeads(),, sfi.director.util.Logger.NOTICE, and

Referenced by sfi.director.schedule.ParallelScheduler.goThroughCmds().

void sfi.director.schedule.ParallelScheduler.parallelizedExec ( )
synchronized void sfi.director.schedule.ParallelScheduler.removeOldJobs ( ) throws DirectorException
void sfi.director.schedule.ParallelScheduler.saveQueue ( )

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