sfi.director.jobs.JobMonitor Class Reference

Inheritance diagram for sfi.director.jobs.JobMonitor:

List of all members.

Public Member Functions
	JobMonitor ()
	JobMonitor (OutputStream out)
	JobMonitor (OutputStream out, String jobId)
void	setOutput (OutputStream out)
synchronized void	setJob (String jobId)
void	monitor ()
void	setOption (String name)
void	setOption (String name, String contents)
void	setOption (Options opts)
boolean	isAlive ()
void	log (LogEntry le)
void	log (LogEntry le, int indent)
Job	retrieveJob (String id)
void	unmonitor (Job job)
void	statusChange (Job job)
void	jobLog (Job job, LogEntry le)
Static Public Member Functions
static void	main (String args[])
	Test procedure.
Protected Member Functions
void	traverse (String id, int indent)
void	traverse (String id, int indent, Hashtable traversed)
String	jobName (Job job)
Job	retrieveFrom (DBConnection db, String id)
synchronized void	removeMonitor (String id)
synchronized void	removeAll ()
void	finalize ()
Package Attributes
OutputStream	out = null
	The stream we send our progress/status reports to.
Hashtable	whereFrom = new Hashtable()
	A table that stores for every jobID the location of the respective job ("archive", "cmdqueue", "jobqueue", "scheduler").
Vector	monitoredJobs = new Vector()
	A list of IDs currently monitored jobs.
Options	options = new Options()
Thread	monitorThread = null
String	headId = null
boolean	alive = false
Static Package Attributes
static final String	SRC_ARCHIVE = "job archive"
static final String	SRC_CMDQUEUE = "command queue"
static final String	SRC_JOBQUEUE = "job queue"
static final String	SRC_SCHEDULER = "scheduler"

---

Constructor & Destructor Documentation

sfi.director.jobs.JobMonitor.JobMonitor (   )

sfi.director.jobs.JobMonitor.JobMonitor (  OutputStream  out  )

sfi.director.jobs.JobMonitor.JobMonitor (  OutputStream  out, String  jobId )

---

Member Function Documentation

void sfi.director.jobs.JobMonitor.finalize (   )  [protected]

boolean sfi.director.jobs.JobMonitor.isAlive (   )

void sfi.director.jobs.JobMonitor.jobLog (  Job  job, LogEntry  le )

String sfi.director.jobs.JobMonitor.jobName (  Job  job  )  [protected]

void sfi.director.jobs.JobMonitor.log (  LogEntry  le, int  indent )

Reimplemented in sfi.director.jobs.RawJobMonitor.

void sfi.director.jobs.JobMonitor.log (  LogEntry  le  )

static void sfi.director.jobs.JobMonitor.main (  String  args[]  )  [static]

Test procedure.

void sfi.director.jobs.JobMonitor.monitor (   )

synchronized void sfi.director.jobs.JobMonitor.removeAll (   )  [protected]

synchronized void sfi.director.jobs.JobMonitor.removeMonitor (  String  id  )  [protected]

Job sfi.director.jobs.JobMonitor.retrieveFrom (  DBConnection  db, String  id )  [protected]

Job sfi.director.jobs.JobMonitor.retrieveJob (  String  id  )

synchronized void sfi.director.jobs.JobMonitor.setJob (  String  jobId  )

void sfi.director.jobs.JobMonitor.setOption (  Options  opts  )

void sfi.director.jobs.JobMonitor.setOption (  String  name, String  contents )

void sfi.director.jobs.JobMonitor.setOption (  String  name  )

void sfi.director.jobs.JobMonitor.setOutput (  OutputStream  out  )

void sfi.director.jobs.JobMonitor.statusChange (  Job  job  )

void sfi.director.jobs.JobMonitor.traverse (  String  id, int  indent, Hashtable  traversed )  [protected]

void sfi.director.jobs.JobMonitor.traverse (  String  id, int  indent )  [protected]

void sfi.director.jobs.JobMonitor.unmonitor (  Job  job  )

---

Member Data Documentation

boolean sfi.director.jobs.JobMonitor.alive = false [package]

String sfi.director.jobs.JobMonitor.headId = null [package]

Vector sfi.director.jobs.JobMonitor.monitoredJobs = new Vector() [package]

A list of IDs currently monitored jobs. These are intentionally not references to the Job objects but rather job IDs - we do not want to prevent the GC from disposing of listed jobs.

Thread sfi.director.jobs.JobMonitor.monitorThread = null [package]

Options sfi.director.jobs.JobMonitor.options = new Options() [package]

OutputStream sfi.director.jobs.JobMonitor.out = null [package]

The stream we send our progress/status reports to.

final String sfi.director.jobs.JobMonitor.SRC_ARCHIVE = "job archive" [static, package]

final String sfi.director.jobs.JobMonitor.SRC_CMDQUEUE = "command queue" [static, package]

final String sfi.director.jobs.JobMonitor.SRC_JOBQUEUE = "job queue" [static, package]

final String sfi.director.jobs.JobMonitor.SRC_SCHEDULER = "scheduler" [static, package]

Hashtable sfi.director.jobs.JobMonitor.whereFrom = new Hashtable() [package]

A table that stores for every jobID the location of the respective job ("archive", "cmdqueue", "jobqueue", "scheduler").

---

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

• director/jobs/JobMonitor.java

---