Class CollectorAnalyzer

java.lang.Object
   |
   +----java.lang.Thread
           |
           +----CollectorAnalyzer

Coordinates the processing of all CollectorUpdate data.

CollectorAnalyzer(ConfigMgr, CollectorStorage, DataCollector): Class constructor.

delete(CollectorUpdate): Delete the given update from the queue.
dequeueUpdate(): Dequeues a CollectorUpdate from our internal processing queue.
enqueueUpdate(CollectorUpdate): Queues the specified CollectorUpdate to our internal processing queue.
finalize(): Ensures that input FIFO are drained.
getQueueIteration(): Return an enumeration of the FIFO queue.
queueSize(): Gets the number of components currently on the processing queue.
run(): Processes the entries on our internal processing queue.

qpause

 private static final int qpause

Number of milliseconds to pause between update queue runs

 private CollectorStorage cs

Pointer to the CollectorStorage manager for this run

 private ModelStorage ms

Pointer to the ModelStorage manager for this run

 private DataCollector dc

Pointer to the DataCollector manager for this run

cuQ

 private FIFO cuQ

FIFO queue for CollectorUpdates waiting to be processed

net

 private CollectorNetwork net

Pointer to the CollectorNetwork reprenting this run

CollectorAnalyzer

 public CollectorAnalyzer(ConfigMgr cm,
                          CollectorStorage cs,
                          DataCollector dc)

Class constructor.

Parameters:: cm - the configuration manager containing all configuration information for this run; cs - the storage object for performing CollectorUpdate I/O
Throws: IOException: if any files couldn't be opened

run

 public void run()

Processes the entries on our internal processing queue.

 public void enqueueUpdate(CollectorUpdate update)

Queues the specified CollectorUpdate to our internal processing queue.

 public CollectorUpdate dequeueUpdate()

Dequeues a CollectorUpdate from our internal processing queue.

 public int queueSize()

Gets the number of components currently on the processing queue.

 public void delete(CollectorUpdate up)

Delete the given update from the queue.

 public Enumeration getQueueIteration()

Return an enumeration of the FIFO queue.

 protected void finalize() throws IOException

Ensures that input FIFO are drained.