jas.job
Class AbstractJob

java.lang.Object
  |
  +--java.util.Observable
        |
        +--jas.job.AbstractJob

All Implemented Interfaces:

BasicJob

Direct Known Subclasses:

JDSJob

public abstract class AbstractJob

extends java.util.Observable

implements BasicJob

Note: AbstractJob is extended by LocalJob (for the local case) and JDSJob (for the remote case). It is really only JDSJob that needs to extends Observable, but multiple inheritance is not supported (and Observable is not an interface, which it should be).

Inner Class Summary

static class	AbstractJob.EventSourceStopped
static interface	AbstractJob.SlowEventSource

Fields inherited from interface jas.job.BasicJob

CURRENTEVENTSOURCE, DATASET, EVENTSOURCE, RESET, SHOWNOW

Constructor Summary

AbstractJob()

AbstractJob(java.lang.String name)

Method Summary

void	addEventAnalyzer(EventAnalyzer ana)
void	close()
void	closeDataset(TreeItem item)
protected java.lang.Thread	createEventLoopThread(java.lang.Runnable loop)
int	eventsAnalyzed()
int	eventsTotal()
protected java.lang.Thread	getActiveThread()
protected abstract java.io.OutputStream	getErrorStream()
EventData	getEvent()
java.lang.Class	getEventDataClass(TreeItem item)
Job	getHepAnalysisJob()
java.lang.Object	getItem(TreeItem search)
protected abstract java.io.OutputStream	getLogStream()
java.lang.String	getName()
java.lang.String	getState()
SimpleNode	getTreeRoot()
void	go(int n)
boolean	isAtEndOfData()
boolean	isAtStartOfData()
boolean	isPersistent()
boolean	isRunnable()
boolean	isRunning()
void	kill()
void	loadObject(java.lang.String name)
protected abstract void	notifyInfo()
protected abstract void	notifyInfo(int n)
void	receiveMessage(java.lang.Object message) Called when a message is received from the client
void	removeAllEventAnalyzers()
void	removeEventAnalyzer(EventAnalyzer ana)
protected abstract void	reportError(AnalysisException e)
void	rewind()
protected abstract void	sendMessage(java.lang.String message)
void	setActiveThread()
protected void	setClassLoader(java.lang.ClassLoader cl)
void	setEventSource(EventGenerator gen)
void	setEventSource(EventSource source)
void	setEventSource(TreeItem item)
void	setHepAnalysisJob(Job job)
void	setPersistent(boolean persist)
protected void	setRoot(JobFolder root)
protected void	setState(java.lang.String state)
void	stop()
void	unloadAll()
void	update(java.util.Observable obs, java.lang.Object arg)

Methods inherited from class java.util.Observable

addObserver, clearChanged, countObservers, deleteObserver, deleteObservers, hasChanged, notifyObservers, notifyObservers, setChanged

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface jas.job.BasicJob

isChanged

Constructor Detail

AbstractJob

public AbstractJob(java.lang.String name)

AbstractJob

public AbstractJob()

Method Detail

setRoot

protected void setRoot(JobFolder root)

setHepAnalysisJob

public void setHepAnalysisJob(Job job)

getHepAnalysisJob

public Job getHepAnalysisJob()

getTreeRoot

public SimpleNode getTreeRoot()

setEventSource

public final void setEventSource(EventGenerator gen)

setEventSource

public final void setEventSource(EventSource source)

closeDataset

public void closeDataset(TreeItem item)

Specified by:

closeDataset in interface BasicJob

setEventSource

public void setEventSource(TreeItem item)

Specified by:

setEventSource in interface BasicJob

getEventDataClass

public final java.lang.Class getEventDataClass(TreeItem item)

Specified by:

getEventDataClass in interface BasicJob

addEventAnalyzer

public final void addEventAnalyzer(EventAnalyzer ana)

removeAllEventAnalyzers

public final void removeAllEventAnalyzers()

removeEventAnalyzer

public final void removeEventAnalyzer(EventAnalyzer ana)

close

public void close()

Specified by:

close in interface BasicJob

loadObject

public void loadObject(java.lang.String name)
                throws LoaderException

Specified by:

loadObject in interface BasicJob

unloadAll

public void unloadAll()

Specified by:

unloadAll in interface BasicJob

setClassLoader

protected final void setClassLoader(java.lang.ClassLoader cl)

getItem

public java.lang.Object getItem(TreeItem search)

Specified by:

getItem in interface BasicJob

setState

protected void setState(java.lang.String state)

isRunnable

public final boolean isRunnable()

Specified by:

isRunnable in interface BasicJob

isAtEndOfData

public final boolean isAtEndOfData()

Specified by:

isAtEndOfData in interface BasicJob

isAtStartOfData

public final boolean isAtStartOfData()

Specified by:

isAtStartOfData in interface BasicJob

isRunning

public final boolean isRunning()

Specified by:

isRunning in interface BasicJob

isPersistent

public final boolean isPersistent()

Specified by:

isPersistent in interface BasicJob

rewind

public final void rewind()

Specified by:

rewind in interface BasicJob

createEventLoopThread

protected java.lang.Thread createEventLoopThread(java.lang.Runnable loop)

go

public final void go(int n)

Specified by:

go in interface BasicJob

stop

public final void stop()

Specified by:

stop in interface BasicJob

kill

public final void kill()

Specified by:

kill in interface BasicJob

setActiveThread

public final void setActiveThread()

getActiveThread

protected final java.lang.Thread getActiveThread()

getName

public final java.lang.String getName()

Specified by:

getName in interface BasicJob

getEvent

public final EventData getEvent()

Specified by:

getEvent in interface BasicJob

getState

public final java.lang.String getState()

eventsTotal

public final int eventsTotal()

Specified by:

eventsTotal in interface BasicJob

eventsAnalyzed

public final int eventsAnalyzed()

Specified by:

eventsAnalyzed in interface BasicJob

receiveMessage

public void receiveMessage(java.lang.Object message)

Called when a message is received from the client

Specified by:

receiveMessage in interface BasicJob

setPersistent

public final void setPersistent(boolean persist)

Specified by:

setPersistent in interface BasicJob

update

public void update(java.util.Observable obs,
                   java.lang.Object arg)

notifyInfo

protected abstract void notifyInfo()

notifyInfo

protected abstract void notifyInfo(int n)

getErrorStream

protected abstract java.io.OutputStream getErrorStream()

getLogStream

protected abstract java.io.OutputStream getLogStream()

sendMessage

protected abstract void sendMessage(java.lang.String message)

reportError

protected abstract void reportError(AnalysisException e)