sfi.director.schedule.ParallelScheduler Class Reference

Inheritance diagram for sfi.director.schedule.ParallelScheduler:


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 ()
Protected Member Functions
void	saveQueue ()
void	finalize ()
synchronized void	executeCmd (DBObject cmd, boolean priviledged) throws DirectorException
void	parallelizedExec ()
Package Attributes
Vector	jobqueue = null
Hashtable	jobids = null
DBSet	savedQueue = null
boolean	locked = false
StoppableThread	queueRunner = null
Hashtable	currentHosts = null
Hashtable	inProgress = null
int	queueSize = 0
Classes
class	encapsulatedInt
class	ExecutorThread

Constructor & Destructor Documentation

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

Member Function Documentation

synchronized void sfi.director.schedule.ParallelScheduler.attach ( ) throws DirectorException

Start scheduler and attach it to the job queue.

Reimplemented from sfi.director.schedule.Scheduler.

synchronized void sfi.director.schedule.ParallelScheduler.detach ( ) throws DirectorException

Stop scheduler and detach from the job queue.

Reimplemented from sfi.director.schedule.Scheduler.

String sfi.director.schedule.ParallelScheduler.dumpStatus ( )

Reimplemented from sfi.director.schedule.Scheduler.

synchronized void sfi.director.schedule.ParallelScheduler.executeCmd ( DBObject cmd,

boolean priviledged

) throws DirectorException [protected]

Reimplemented from sfi.director.schedule.Scheduler.

void sfi.director.schedule.ParallelScheduler.finalize ( ) [protected]

Job sfi.director.schedule.ParallelScheduler.getJob ( String id )

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 ( )

return human readable status information

Reimplemented from sfi.director.schedule.Scheduler.

synchronized void sfi.director.schedule.ParallelScheduler.goThroughCmds ( ) throws DirectorException

Reimplemented from sfi.director.schedule.Scheduler.

synchronized void sfi.director.schedule.ParallelScheduler.goThroughQueue ( ) throws DirectorException

Reimplemented from sfi.director.schedule.Scheduler.

void sfi.director.schedule.ParallelScheduler.parallelizedExec ( ) [protected]

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

Reimplemented from sfi.director.schedule.Scheduler.