sfi.director.schedule.SimpleScheduler Class Reference

Inheritance diagram for sfi.director.schedule.SimpleScheduler:

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

Implements sfi.director.schedule.Scheduler.

References sfi.director.jobs.Job.Abort(), sfi.director.util.Tools.debug(), sfi.director.jobs.JobStatus.equals(), sfi.director.jobs.Job.getId(), sfi.director.jobs.Job.getScheduleOption(), sfi.director.jobs.Job.getStatus(), sfi.director.jobs.Job.invoke(), sfi.director.util.DirectorException.isRetryable(), sfi.director.util.Tools.log(), sfi.director.jobs.JobStatus.runnable, sfi.director.jobs.Job.setScheduleOption(), and sfi.director.util.Logger.WARNING.

---

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

• director/src/sfi/director/schedule/SimpleScheduler.java