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