sfi.director.jobs.Job Class Reference

Inheritance diagram for sfi.director.jobs.Job:

Public Member Functions
	Job ()
	Job (String name)
	Job (String name, String descr)
	Job (DBObject db)
	Job (DBObject db, boolean doregister)
void	Notify (Job j)
void	addNotify (Notifiable n)
void	addNotify (String id)
void	delegateNotify (Job next)
JobStatus	getStatus ()
void	die ()
void	setDescr (String descr)
String	getDescr ()
void	setName (String name)
String	getName ()
String	getId ()
long	getCreationTime ()
void	Abort ()
void	Sleep ()
void	WakeUp ()
void	reanimate () throws DirectorException
void	commit () throws ArgumentException
void	invoke () throws DirectorException
void	setOption (String name, String content)
void	setOption (String name)
void	setServer (ServerConnection server)
ServerConnection	getServer ()
void	setScheduleOption (String name)
void	setScheduleOption (String name, String val)
String	getScheduleOption (String name)
DBObject	todb ()
DN	getDN ()
void	todb (DBObject dbo)
void	log (LogEntry le)
Vector	getLog ()
Vector	getMonitors ()
void	addMonitor (JobMonitor monitor)
void	removeMonitor (JobMonitor monitor)
void	finalize ()
void	setHead (JobNode head)
JobNode	getHead ()
String	getHeadId ()

Static Public Member Functions
static Job	Job (DBObject dbo) throws DirectorException
static Job	Job (DBObject dbo, boolean doregister) throws DirectorException

Protected Member Functions
void	NotifyAll ()
void	setStatus (JobStatus status)
void	setHeadId (String id)

Constructor & Destructor Documentation

static Job sfi.director.jobs.Job.Job ( DBObject  dbo ) throws DirectorException

static

References sfi.director.jobs.Job.Job().

Referenced by sfi.director.schedule.ParallelScheduler.executeCmd(), sfi.director.schedule.Scheduler.loadQueue(), sfi.director.schedule.Scheduler.purgeOldJobs(), and sfi.director.jobs.JobMonitor.retrieveFrom().

static Job sfi.director.jobs.Job.Job ( DBObject  dbo, boolean  doregister  ) throws DirectorException

static

References sfi.director.jobs.Job.Job().

sfi.director.jobs.Job.Job

(

)

Referenced by sfi.director.jobs.Job.Job().

sfi.director.jobs.Job.Job

(

String

name

)

sfi.director.jobs.Job.Job	(	String	name,
		String	descr
	)

References sfi.director.jobs.Job.setDescr(), and sfi.director.jobs.Job.setName().

sfi.director.jobs.Job.Job

(

DBObject

db

)

sfi.director.jobs.Job.Job	(	DBObject	db,
		boolean	doregister
	)

References sfi.director.jobs.Job.addNotify(), sfi.director.repository.DBObject.getAttribute(), sfi.director.repository.DBObject.getEValue(), sfi.director.repository.DBObject.getValue(), sfi.director.jobs.Job.setDescr(), sfi.director.jobs.Job.setHeadId(), sfi.director.jobs.Job.setName(), sfi.director.jobs.Job.setOption(), and sfi.director.jobs.Job.setScheduleOption().

Member Function Documentation

void sfi.director.jobs.Job.Abort

(

)

Reimplemented in sfi.director.jobs.JobNode.

References sfi.director.jobs.JobStatus.aborted, and sfi.director.jobs.Job.setStatus().

Referenced by sfi.director.jobs.JobNode.Abort(), and sfi.director.schedule.SimpleScheduler.goThroughVector().

void sfi.director.jobs.Job.addMonitor

(

JobMonitor

monitor

)

Referenced by sfi.director.jobs.JobMonitor.monitor().

void sfi.director.jobs.Job.addNotify

(

Notifiable

n

)

References sfi.director.util.Tools.debug(), sfi.director.jobs.Notifiable.getId(), and sfi.director.jobs.Job.getId().

Referenced by sfi.director.jobs.Job.delegateNotify(), sfi.director.jobs.Job.Job(), sfi.director.jobs.JobNode.setJob(), and sfi.director.jobs.JobNode.setSub().

void sfi.director.jobs.Job.addNotify

(

String

id

)

void sfi.director.jobs.Job.commit

(

)

throws ArgumentException

Reimplemented in sfi.director.jobs.RemoteJob.

References sfi.director.jobs.JobStatus.equals(), sfi.director.jobs.Job.setStatus(), sfi.director.jobs.JobStatus.setup, and sfi.director.jobs.JobStatus.wait.

Referenced by sfi.director.application.scripttask.Report.create(), sfi.director.application.scripttask.EmulateRoot.create(), sfi.director.application.scripttask.WakeOnLan.create(), sfi.director.application.scripttask.ResolveDependencies.create(), sfi.director.application.scripttask.ReloadService.create(), sfi.director.application.scripttask.ChainEvent.create(), sfi.director.application.scripttask.SetHostIP.create(), sfi.director.application.scripttask.StoreAsDBChoice.create(), sfi.director.application.scripttask.ConfigureNetwork.create(), sfi.director.application.scripttask.RepositoryScan.create(), sfi.director.application.scripttask.ZoneUpdated.create(), sfi.director.application.scripttask.Shell.create(), sfi.director.application.scripttask.CreateHome.create(), sfi.director.application.scripttask.CreateReleaseDir.create(), sfi.director.application.scripttask.ApplyDomainTemplate.create(), sfi.director.application.scripttask.D3HostDefine.create(), sfi.director.application.scripttask.SubscribeApps.create(), sfi.director.application.scripttask.BootStrapDirector.create(), sfi.director.application.scripttask.BuildDependingDomains.create(), sfi.director.application.scripttask.CreateHomeDB.create(), sfi.director.application.scripttask.FreezeApplication.create(), sfi.director.application.scripttask.SetServerPassword.create(), sfi.director.application.scripttask.INFAppModules.create(), sfi.director.application.scripttask.InjectUserSettings.create(), sfi.director.application.scripttask.DoAppImport.create(), sfi.director.application.scripttask.CupsDrivers.create(), sfi.director.application.scripttask.ConfigHost.create(), sfi.director.application.scripttask.PublishApplication.create(), sfi.director.application.objevents.EventEnvironment.createWorkflow(), sfi.director.application.objevents.Workflow.flush(), sfi.director.application.HostPackages.forPkg(), sfi.director.application.FilePackageHandler.makeJob(), sfi.director.application.scripttask.AppInstallHost.remoteMethod(), and sfi.director.repository.DirectoryServiceMerger.targetJob().

void sfi.director.jobs.Job.delegateNotify

(

Job

next

)

References sfi.director.jobs.Job.addNotify().

void sfi.director.jobs.Job.die

(

)

Reimplemented in sfi.director.jobs.JobNode.

References sfi.director.util.Tools.debug(), and sfi.director.jobs.Job.getId().

Referenced by sfi.director.jobs.Job.finalize(), and sfi.director.jobs.Job.setStatus().

void sfi.director.jobs.Job.finalize

(

)

References sfi.director.jobs.Job.die().

long sfi.director.jobs.Job.getCreationTime

(

)

Referenced by sfi.director.schedule.Scheduler.purgeOldJobs(), sfi.director.schedule.ParallelScheduler.removeOldJobs(), and sfi.director.schedule.Scheduler.removeOldJobs().

String sfi.director.jobs.Job.getDescr

(

)

Referenced by sfi.director.application.scripttask.Shell.create(), sfi.director.application.scripttask.BuildDependingDomains.create(), sfi.director.util.Tools.executeLocalqueue(), sfi.director.application.objevents.Workflow.flush(), sfi.director.schedule.ParallelScheduler.getStatus(), sfi.director.jobs.JobMonitor.jobName(), sfi.director.jobs.JobNode.JobNode(), sfi.director.schedule.ParallelScheduler.markHeads(), and sfi.director.cli.queuestat.print_tree().

DN sfi.director.jobs.Job.getDN

(

)

Referenced by sfi.director.jobs.Job.todb().

JobNode sfi.director.jobs.Job.getHead

(

)

References sfi.director.util.Stub.getObject().

Referenced by sfi.director.jobs.Job.log(), sfi.director.jobs.JobNode.setHead(), and sfi.director.jobs.JobNode.setStatus().

String sfi.director.jobs.Job.getHeadId

(

)

References sfi.director.util.Stub.getId().

Referenced by sfi.director.jobs.Job.todb().

String sfi.director.jobs.Job.getId

(

)

Implements sfi.director.jobs.Notifiable.

Referenced by sfi.director.executor.AppExecutor.accept(), sfi.director.jobs.Job.addNotify(), sfi.director.invoker.StreamConnection.agentlistener(), sfi.director.schedule.ParallelScheduler.attach(), sfi.director.jobs.Job.die(), sfi.director.schedule.ParallelScheduler.executeCmd(), sfi.director.application.FrontendInterface.executeCommand(), sfi.director.util.Tools.executeLocalqueue(), sfi.director.application.objevents.Workflow.flush(), sfi.director.schedule.ParallelScheduler.getStatus(), sfi.director.schedule.SimpleScheduler.goThroughVector(), sfi.director.jobs.JobMonitor.jobName(), sfi.director.jobs.CatchAllLogsJob.log(), sfi.director.jobs.JobNode.nextTmpFile(), sfi.director.jobs.JobNode.Notify(), sfi.director.cli.queuestat.print_tree(), sfi.director.schedule.Scheduler.purgeOldJobs(), sfi.director.schedule.ParallelScheduler.removeOldJobs(), sfi.director.schedule.Scheduler.removeOldJobs(), sfi.director.schedule.Scheduler.runThroughLockedQueue(), sfi.director.schedule.ParallelScheduler.saveQueue(), sfi.director.application.objevents.Workflow.setBackChain(), sfi.director.jobs.Job.setStatus(), sfi.director.jobs.JobMonitor.statusChange(), and sfi.director.jobs.JobMonitor.unmonitor().

Vector sfi.director.jobs.Job.getLog

(

)

Vector sfi.director.jobs.Job.getMonitors

(

)

Referenced by sfi.director.jobs.CatchAllLogsJob.log().

String sfi.director.jobs.Job.getName

(

)

Referenced by sfi.director.executor.Executor.accept(), sfi.director.application.scripttask.Shell.create(), sfi.director.application.scripttask.BuildDependingDomains.create(), sfi.director.application.objevents.Workflow.flush(), sfi.director.schedule.ParallelScheduler.getStatus(), sfi.director.jobs.JobMonitor.jobName(), sfi.director.jobs.JobNode.JobNode(), and sfi.director.cli.queuestat.print_tree().

String sfi.director.jobs.Job.getScheduleOption

(

String

name

)

References sfi.director.util.Options.getOption().

Referenced by sfi.director.schedule.SimpleScheduler.goThroughVector(), sfi.director.schedule.ParallelScheduler.parallelizedExec(), sfi.director.schedule.ParallelScheduler.removeOldJobs(), and sfi.director.schedule.Scheduler.removeOldJobs().

ServerConnection sfi.director.jobs.Job.getServer

(

)

Referenced by sfi.director.retriever.ServerRetriever.accept().

JobStatus sfi.director.jobs.Job.getStatus

(

)

Referenced by sfi.director.invoker.StreamConnection.agentlistener(), sfi.director.util.Tools.executeLocalqueue(), sfi.director.schedule.SimpleScheduler.goThroughVector(), sfi.director.jobs.RemoteJob.invoke(), sfi.director.jobs.JobNode.invoke(), sfi.director.jobs.JobMonitor.monitor(), sfi.director.jobs.JobNode.Notify(), sfi.director.schedule.ParallelScheduler.parallelizedExec(), sfi.director.cli.queuestat.print_tree(), sfi.director.schedule.ParallelScheduler.removeOldJobs(), sfi.director.schedule.Scheduler.removeOldJobs(), sfi.director.cli.queuestat.run(), sfi.director.jobs.JobNode.setStatus(), sfi.director.jobs.JobMonitor.statusChange(), sfi.director.jobs.Job.todb(), and sfi.director.application.objevents.Workflow.watch().

void sfi.director.jobs.Job.invoke

(

)

throws DirectorException

Reimplemented in sfi.director.jobs.JobNode, sfi.director.jobs.RemoteJob, and sfi.director.jobs.NullJob.

Referenced by sfi.director.schedule.SimpleScheduler.goThroughVector().

void sfi.director.jobs.Job.log

(

LogEntry

le

)

Reimplemented in sfi.director.jobs.JobNode.

References sfi.director.jobs.JobMonitor.catchAllJob, sfi.director.jobs.Job.getHead(), sfi.director.jobs.CatchAllLogsJob.log(), and sfi.director.jobs.JobNode.log().

void sfi.director.jobs.Job.Notify

(

Job

j

)

Implements sfi.director.jobs.Notifiable.

Reimplemented in sfi.director.jobs.JobNode.

void sfi.director.jobs.Job.NotifyAll ( )

protected

References sfi.director.jobs.Notifiable.Notify().

Referenced by sfi.director.jobs.Job.setStatus().

void sfi.director.jobs.Job.reanimate

(

)

throws DirectorException

Reimplemented in sfi.director.jobs.JobNode.

References sfi.director.jobs.JobStatus.runnable, and sfi.director.jobs.Job.setStatus().

Referenced by sfi.director.invoker.StreamConnection.agentlistener(), and sfi.director.jobs.JobNode.reanimate().

void sfi.director.jobs.Job.removeMonitor

(

JobMonitor

monitor

)

Referenced by sfi.director.jobs.JobMonitor.removeAll(), sfi.director.jobs.JobMonitor.statusChange(), and sfi.director.jobs.JobMonitor.unmonitor().

void sfi.director.jobs.Job.setDescr

(

String

descr

)

Referenced by sfi.director.application.objevents.Workflow.flush(), and sfi.director.jobs.Job.Job().

void sfi.director.jobs.Job.setHead

(

JobNode

head

)

Reimplemented in sfi.director.jobs.JobNode.

Referenced by sfi.director.jobs.JobNode.setHead().

void sfi.director.jobs.Job.setHeadId ( String  id )

protected

Referenced by sfi.director.jobs.Job.Job().

void sfi.director.jobs.Job.setName

(

String

name

)

Referenced by sfi.director.application.objevents.Workflow.flush(), and sfi.director.jobs.Job.Job().

void sfi.director.jobs.Job.setOption	(	String	name,
		String	content
	)

References sfi.director.util.Options.setOption().

Referenced by sfi.director.jobs.Job.Job().

void sfi.director.jobs.Job.setOption

(

String

name

)

References sfi.director.util.Options.setOption().

void sfi.director.jobs.Job.setScheduleOption

(

String

name

)

References sfi.director.util.Options.setOption().

Referenced by sfi.director.application.scripttask.Shell.create(), sfi.director.schedule.SimpleScheduler.goThroughVector(), and sfi.director.jobs.Job.Job().

void sfi.director.jobs.Job.setScheduleOption	(	String	name,
		String	val
	)

References sfi.director.util.Options.setOption().

void sfi.director.jobs.Job.setServer

(

ServerConnection

server

)

Referenced by sfi.director.invoker.StreamConnection.agentlistener().

void sfi.director.jobs.Job.setStatus ( JobStatus  status )

protected

Reimplemented in sfi.director.jobs.JobNode.

References sfi.director.util.Tools.debug(), sfi.director.jobs.Job.die(), sfi.director.jobs.JobStatus.equals(), sfi.director.util.Logger.ERR, sfi.director.jobs.Job.getId(), sfi.director.jobs.JobStatus.isFinal(), sfi.director.util.Tools.log(), sfi.director.jobs.Job.NotifyAll(), and sfi.director.jobs.JobStatus.toString().

Referenced by sfi.director.jobs.Job.Abort(), sfi.director.jobs.RemoteJob.commit(), sfi.director.jobs.Job.commit(), sfi.director.jobs.NullJob.invoke(), sfi.director.jobs.RemoteJob.invoke(), sfi.director.jobs.JobNode.Notify(), sfi.director.jobs.Job.reanimate(), sfi.director.jobs.Job.Sleep(), and sfi.director.jobs.Job.WakeUp().

void sfi.director.jobs.Job.Sleep

(

)

Reimplemented in sfi.director.jobs.JobNode.

References sfi.director.jobs.Job.setStatus(), and sfi.director.jobs.JobStatus.wait.

Referenced by sfi.director.application.scripttask.ChainEvent.exec(), sfi.director.invoker.StreamConnection.masterlistener(), and sfi.director.jobs.JobNode.Sleep().

DBObject sfi.director.jobs.Job.todb

(

)

Implements sfi.director.repository.DBFiable.

Referenced by sfi.director.schedule.ParallelScheduler.attach(), sfi.director.schedule.Scheduler.runThroughLockedQueue(), and sfi.director.schedule.ParallelScheduler.saveQueue().

void sfi.director.jobs.Job.todb

(

DBObject

dbo

)

Implements sfi.director.repository.DBFiable.

Reimplemented in sfi.director.jobs.JobNode, sfi.director.jobs.RemoteJob, and sfi.director.jobs.NullJob.

References sfi.director.jobs.Job.getDN(), sfi.director.jobs.Job.getHeadId(), sfi.director.util.Options.getOption(), sfi.director.jobs.Job.getStatus(), sfi.director.repository.DBObject.setDN(), sfi.director.jobs.JobStatus.todb(), and sfi.director.util.LogEntry.toVector().

void sfi.director.jobs.Job.WakeUp

(

)

Reimplemented in sfi.director.jobs.JobNode.

References sfi.director.jobs.JobStatus.runnable, and sfi.director.jobs.Job.setStatus().

Referenced by sfi.director.invoker.Recorder.executeJob(), and sfi.director.jobs.JobNode.WakeUp().

---

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

• director/src/sfi/director/jobs/Job.java