Inheritance diagram for SampleDispatcher:

Public Member Functions
	SampleDispatcher (InfluxDB db, const list< DSMSensor > &sensors, NidasApp &app)

virtual	~SampleDispatcher ()

void	flush () throw ()
	Ask that this SampleClient send out any buffered Samples that it may be holding. More...

bool	receive (const Sample *samp) throw ()
	Method called to pass a sample to this client. More...

Private Types
typedef map< dsm_sample_id_t, SampleToDatabase >	sample_map_t

Private Member Functions
sample_map_t::iterator	findStats (dsm_sample_id_t sampid)
	Find the SampleToDatabase for the given sample ID. More...

Private Attributes
sample_map_t	_samples

NidasApp &	_app

Member Typedef Documentation

typedef map<dsm_sample_id_t, SampleToDatabase> SampleDispatcher::sample_map_t

private

Constructor & Destructor Documentation

SampleDispatcher::SampleDispatcher	(	InfluxDB *	db,
		const list< DSMSensor * > &	sensors,
		NidasApp &	app
	)

References _app, _samples, DLOG, findStats(), nidas::core::NidasApp::formatId(), nidas::core::SampleTag::getId(), nidas::core::DSMSensor::getSampleTagIterator(), nidas::core::SampleTag::getVariables(), nidas::core::SampleTagIterator::hasNext(), nidas::core::SampleMatcher::match(), nidas::core::SampleTagIterator::next(), and nidas::core::NidasApp::sampleMatcher().

virtual SampleDispatcher::~SampleDispatcher ( )

inlinevirtual

Member Function Documentation

sample_map_t::iterator SampleDispatcher::findStats ( dsm_sample_id_t sampid )

inlineprivate

Find the SampleToDatabase for the given sample ID.

Wisard samples get mapped to one sensor type, so we look for all of them.

References VLOG.

Referenced by SampleDispatcher().

void SampleDispatcher::flush	(	)
throw	(
	)

inlinevirtual

Ask that this SampleClient send out any buffered Samples that it may be holding.

Implements nidas::core::SampleClient.

bool SampleDispatcher::receive	(	const Sample *	s	)
throw	(
	)

virtual

Method called to pass a sample to this client.

This method is typically called by a SampleSource for each of its SampleClients when it has a sample ready. Returns true: success false: sample rejected. This is meant to signal a warning-type situation - like a socket not being available temporarily. True errors will be thrown as an IOException.

Implements nidas::core::SampleClient.

References DLOG, VLOG, and WLOG.