Node Director
|
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. |
Static Public Attributes | |
static CatchAllLogsJob | catchAllJob = new CatchAllLogsJob() |
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 () |
sfi.director.jobs.JobMonitor.JobMonitor | ( | ) |
Referenced by sfi.director.jobs.JobMonitor.main().
sfi.director.jobs.JobMonitor.JobMonitor | ( | OutputStream | out | ) |
References sfi.director.jobs.JobMonitor.setOutput().
sfi.director.jobs.JobMonitor.JobMonitor | ( | OutputStream | out, |
String | jobId | ||
) |
|
protected |
References sfi.director.jobs.JobMonitor.removeAll().
boolean sfi.director.jobs.JobMonitor.isAlive | ( | ) |
Referenced by sfi.director.jobs.JobMonitor.monitor().
|
protected |
References sfi.director.jobs.Job.getDescr(), sfi.director.jobs.Job.getId(), and sfi.director.jobs.Job.getName().
Referenced by sfi.director.jobs.JobMonitor.statusChange().
void sfi.director.jobs.JobMonitor.log | ( | LogEntry | le | ) |
void sfi.director.jobs.JobMonitor.log | ( | LogEntry | le, |
int | indent | ||
) |
Reimplemented in sfi.director.jobs.RawJobMonitor.
References sfi.director.util.LogEntry.getLevel(), sfi.director.util.LogEntry.getLevelStr(), sfi.director.util.LogEntry.getMessage(), sfi.director.util.Options.getOption(), sfi.director.util.LogEntry.getTime(), sfi.director.util.Logger.NOTICE, sfi.director.util.DiscardingBuffer.put(), and sfi.director.util.Tools.timeStamp().
|
static |
void sfi.director.jobs.JobMonitor.monitor | ( | ) |
References sfi.director.jobs.Job.addMonitor(), sfi.director.jobs.JobMonitor.catchAllJob, sfi.director.util.DiscardingBuffer.get(), sfi.director.util.Options.getOption(), sfi.director.jobs.Job.getStatus(), sfi.director.util.Logger.INFO, sfi.director.jobs.JobMonitor.isAlive(), sfi.director.jobs.JobStatus.isFinal(), sfi.director.jobs.JobMonitor.log(), sfi.director.util.Logger.NOTICE, sfi.director.jobs.JobMonitor.removeAll(), sfi.director.jobs.JobMonitor.retrieveJob(), and sfi.director.jobs.JobMonitor.traverse().
Referenced by sfi.director.jobs.JobMonitor.main(), and sfi.director.application.AdminServer.oneConnection().
|
protected |
References sfi.director.jobs.Job.removeMonitor(), and sfi.director.jobs.JobMonitor.retrieveJob().
Referenced by sfi.director.jobs.JobMonitor.finalize(), and sfi.director.jobs.JobMonitor.monitor().
|
protected |
Referenced by sfi.director.jobs.JobMonitor.statusChange(), and sfi.director.jobs.JobMonitor.unmonitor().
|
protected |
Job sfi.director.jobs.JobMonitor.retrieveJob | ( | String | id | ) |
References sfi.director.util.Setup.cmdqueuedb, sfi.director.schedule.Scheduler.getJob(), sfi.director.util.Setup.jobarchivedb, sfi.director.util.Setup.jobqueuedb, sfi.director.jobs.JobMonitor.retrieveFrom(), and sfi.director.util.Setup.scheduler.
Referenced by sfi.director.jobs.JobMonitor.monitor(), sfi.director.jobs.JobMonitor.removeAll(), sfi.director.jobs.JobMonitor.traverse(), and sfi.director.application.objevents.Workflow.watch().
synchronized void sfi.director.jobs.JobMonitor.setJob | ( | String | jobId | ) |
Referenced by sfi.director.jobs.JobMonitor.JobMonitor().
void sfi.director.jobs.JobMonitor.setOption | ( | String | name | ) |
References sfi.director.util.Options.setOption().
Referenced by sfi.director.jobs.JobMonitor.main(), and sfi.director.application.AdminServer.oneConnection().
void sfi.director.jobs.JobMonitor.setOption | ( | String | name, |
String | contents | ||
) |
References sfi.director.util.Options.setOption().
void sfi.director.jobs.JobMonitor.setOption | ( | Options | opts | ) |
References sfi.director.util.Options.setOption().
void sfi.director.jobs.JobMonitor.setOutput | ( | OutputStream | out | ) |
Referenced by sfi.director.jobs.JobMonitor.JobMonitor().
void sfi.director.jobs.JobMonitor.statusChange | ( | Job | job | ) |
References sfi.director.jobs.Job.getId(), sfi.director.jobs.Job.getStatus(), sfi.director.util.Logger.INFO, sfi.director.jobs.JobStatus.isFinal(), sfi.director.jobs.JobMonitor.jobName(), sfi.director.jobs.JobMonitor.log(), sfi.director.jobs.JobMonitor.removeMonitor(), and sfi.director.jobs.Job.removeMonitor().
|
protected |
Referenced by sfi.director.jobs.JobMonitor.monitor().
|
protected |
void sfi.director.jobs.JobMonitor.unmonitor | ( | Job | job | ) |
|
static |
Referenced by sfi.director.jobs.Job.log(), and sfi.director.jobs.JobMonitor.monitor().