Package xal.tools.correlator

Class BinAgent<R>

java.lang.Object

xal.tools.correlator.BinAgent<R>

public class BinAgent<R>
extends Object

BinAgent is the class that gathers correlated events. It is assigned a timestamp. The agent listens for events and any event that is within the timespan of timestamp, is accepted. When the number of accepted channels equals the number of all channels monitored by the correlator, the bin agent wraps all the gathered event records into a correlation object and notifies the correlator world that it has found a correlation. The bin then resets itself.

Author:

tap

Constructor Summary

Constructors

Constructor	Description
BinAgent(MessageCenter localCenter, CorrelationTester<R> tester)	Creates new BinAgent

Method Summary

Modifier and Type	Method	Description
void	binTimespanChanged(Correlator<?,R,?> sender, double newTimespan)	Implement StateNotice interface to listen for change of state
void	correlationFilterChanged(Correlator<?,R,?> sender, CorrelationFilter<R> newFilter)	Implement StateNotice interface to listen for change of state
void	newEvent(String name, R aRecord, double timestamp)	Implement BinUpdate interface
void	registerEvents()	Register events for this bin agent
void	reset()	Forget all events
void	resetWithRecord(String name, R aRecord, double timestamp)	Forget all events and set the timestamp to the supplied one.
void	setTimespan(double timespan)	Set the maximum time span allowed among the records collected.
void	sourceAdded(Correlator<?,R,?> sender, String name, int newCount)	Implement StateNotice interface to listen for change of state
void	sourceRemoved(Correlator<?,R,?> sender, String name, int newCount)	Implement StateNotice interface to listen for change of state
void	willStartMonitoring(Correlator<?,R,?> sender)	Implement StateNotice interface to listen for change of state
void	willStopMonitoring(Correlator<?,R,?> sender)	Implement StateNotice interface to listen for change of state

Methods inherited from class java.lang.Object

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

Constructor Details

BinAgent

public BinAgent(MessageCenter localCenter,
 CorrelationTester<R> tester)

Creates new BinAgent

Method Details

registerEvents

public void registerEvents()

Register events for this bin agent

reset

public void reset()

Forget all events

resetWithRecord

public void resetWithRecord(String name,
 R aRecord,
 double timestamp)

Forget all events and set the timestamp to the supplied one. This is used when a bin is recycled.

setTimespan

public void setTimespan(double timespan)

Set the maximum time span allowed among the records collected.

newEvent

public void newEvent(String name,
 R aRecord,
 double timestamp)

Implement BinUpdate interface

sourceAdded

public void sourceAdded(Correlator<?,R,?> sender,
 String name,
 int newCount)

Implement StateNotice interface to listen for change of state

sourceRemoved

public void sourceRemoved(Correlator<?,R,?> sender,
 String name,
 int newCount)

Implement StateNotice interface to listen for change of state

binTimespanChanged

public void binTimespanChanged(Correlator<?,R,?> sender,
 double newTimespan)

Implement StateNotice interface to listen for change of state

willStopMonitoring

public void willStopMonitoring(Correlator<?,R,?> sender)

Implement StateNotice interface to listen for change of state

willStartMonitoring

public void willStartMonitoring(Correlator<?,R,?> sender)

Implement StateNotice interface to listen for change of state

correlationFilterChanged

public void correlationFilterChanged(Correlator<?,R,?> sender,
 CorrelationFilter<R> newFilter)

Implement StateNotice interface to listen for change of state