Inheritance diagram for DataStats:

Public Member Functions
	DataStats ()

	~DataStats ()

int	run ()

void	readHeader (SampleInputStream &sis)

void	readSamples (SampleInputStream &sis)

int	parseRunstring (int argc, char **argv)

int	usage (const char *argv0)

void	createCounters (const list< DSMSensor * > &sensors)
	Create a SampleCounter for each of the sample tags in the given sensors, if any.

SampleCounter *	addCounter (const SampleCounter &counter)
	Copy the counter into the samples map and return a reference to it.

SampleCounter *	getCounter (dsm_sample_id_t sid)
	Return a pointer to the SampleCounter for the given sample id `sid`.

bool	reportsExhausted (int nreports=-1)

void	restartStats (const UTime &start, const UTime &end)
	Recalculate statistics as needed based on the current collection of data and time period.

void	clearSampleQueue ()

void	report ()

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

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

void	printReport (std::ostream &outs)

void	jsonReport ()

void	resetResults ()

void	setStart (const UTime &start)

Static Public Member Functions
static int	main (int argc, char **argv)

static void	handleSignal (int signum)

Private Types
typedef map< dsm_sample_id_t, SampleCounter >	sample_map_t

typedef std::list< const Sample * >	sample_queue

Private Member Functions
dsm_sample_id_t	hashId (dsm_sample_id_t sid)

void	createJsonWriters ()

Private Attributes
sample_map_t	_samples

bool	_reportall

bool	_reportdata

bool	_singlemote

bool	_fullnames

bool	_realtime

bool	_counters_created {false}

list< DSMSensor * >	allsensors {}

UTime	_period_start

UTime	_period_end

UTime	_start_time

int	_count

int	_period

int	_update

int	_nreports

sample_queue	_sampleq

NidasApp	_app

NidasAppArg	Period

NidasAppArg	Update

NidasAppArg	Count

NidasAppArg	AllSamples

NidasAppArg	ShowData

NidasAppArg	SingleMote

NidasAppArg	Fullnames

BadSampleFilterArg	FilterArg

NidasAppArg	JsonOutput

NidasAppArg	ShowProblems

n_u::auto_ptr< Json::StyledStreamWriter >	streamWriter

n_u::auto_ptr< Json::StyledStreamWriter >	headerWriter

Static Private Attributes
static const int	DEFAULT_PORT = 30000

static bool	_alarm

Member Typedef Documentation

◆ sample_map_t

typedef map<dsm_sample_id_t, SampleCounter> DataStats::sample_map_t

private

◆ sample_queue

typedef std::list<const Sample*> DataStats::sample_queue

private

Constructor & Destructor Documentation

◆ DataStats()

DataStats::DataStats ( )

◆ ~DataStats()

DataStats::~DataStats ( )

inline

References clearSampleQueue().

Member Function Documentation

◆ addCounter()

SampleCounter * DataStats::addCounter ( const SampleCounter & counter )

Copy the counter into the samples map and return a reference to it.

Also configure the counter according to whether json output or data statistics should be enabled. Mote sensor IDs for the same sensor type will be hashed to one bucket, as will sensors with different mote IDs if _singlemote is enabled. This should only be called if getCounter() does not return a counter for the sample ID.

References _reportdata, _samples, nidas::core::getSample(), hashId(), JsonOutput, and nidas::core::NidasAppArg::specified().

Referenced by createCounters().

◆ clearSampleQueue()

void DataStats::clearSampleQueue ( )

References _sampleq, and nidas::core::Sample::freeReference().

Referenced by ~DataStats().

◆ createCounters()

void DataStats::createCounters ( const list< DSMSensor * > & sensors )

Create a SampleCounter for each of the sample tags in the given sensors, if any.

Set singlemote to expect only one mote for each sensor type. When a wisard sensor returns multiple sample tags with different mote IDs, samples will only be expected from one of those tags.

References _app, addCounter(), DLOG, nidas::core::NidasApp::formatId(), getCounter(), nidas::core::DSMSensor::getDeviceName(), nidas::core::DSMSensor::getDSMConfig(), nidas::core::DSMSensor::getId(), nidas::core::SampleTag::getId(), nidas::core::getSample(), nidas::core::DSMSensor::getSampleTagIterator(), nidas::core::SampleTag::getVariables(), nidas::core::NidasApp::processData(), and nidas::core::NidasApp::sampleMatcher().

◆ createJsonWriters()

void DataStats::createJsonWriters ( )

inlineprivate

References headerWriter, and streamWriter.

Referenced by jsonReport().

◆ flush()

void DataStats::flush	(		)
throw	(	)

inlinevirtual

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

Exceptions

)

Implements nidas::core::SampleClient.

◆ getCounter()

SampleCounter * DataStats::getCounter ( dsm_sample_id_t sid )

Return a pointer to the SampleCounter for the given sample id sid.

If no such counter exists, return null. Mote sensor sample IDs are hashed into buckets by sensor type and according to the _singlemote setting, so the returned SampleCounter may not have the same ID as the one passed in.

References _samples, nidas::core::getSample(), and hashId().

Referenced by createCounters(), and restartStats().

◆ handleSignal()

void DataStats::handleSignal ( int signum )

static

References _alarm, and nidas::core::NidasApp::setInterrupted().

Referenced by run().

◆ hashId()

dsm_sample_id_t DataStats::hashId ( dsm_sample_id_t sid )

private

References _app, _singlemote, nidas::core::NidasApp::formatId(), nidas::core::getSample(), and VLOG.

Referenced by addCounter(), and getCounter().

◆ jsonReport()

void DataStats::jsonReport ( )

◆ main()

int DataStats::main	(	int	argc,
		char **	argv )

static

References nidas::core::getSample(), and nidas::core::XMLImplementation::terminate().

Referenced by main().

◆ parseRunstring()

int DataStats::parseRunstring	(	int	argc,
		char **	argv )

◆ printReport()

void DataStats::printReport ( std::ostream & outs )

References _fullnames, _reportall, _reportdata, _samples, nidas::core::NidasAppArg::asBool(), nidas::core::NidasApp::formatSampleId(), GET_DSM_ID, nidas::core::NidasApp::getApplicationInstance(), SampleCounter::getHeaderLine(), nidas::core::getSample(), SampleCounter::jsonStats(), MSECS_PER_SEC, rate, ShowProblems, USECS_PER_MSEC, and USECS_PER_SEC.

Referenced by report().

◆ readHeader()

void DataStats::readHeader ( SampleInputStream & sis )

References _alarm, _app, _nreports, _realtime, _update, DLOG, nidas::core::getSample(), nidas::core::NidasApp::interrupted(), and reportsExhausted().

Referenced by run().

◆ readSamples()

void DataStats::readSamples ( SampleInputStream & sis )

References _alarm, _app, _period_end, _realtime, _update, DLOG, nidas::core::getSample(), nidas::core::NidasApp::interrupted(), and nidas::util::UTime::toUsecs().

Referenced by run().

◆ receive()

bool DataStats::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.

Exceptions

)

Implements nidas::core::SampleClient.

References DLOG, nidas::core::NidasApp::formatId(), nidas::util::UTime::isZero(), nidas::core::SampleMatcher::match(), nidas::core::NidasApp::sampleMatcher(), nidas::util::UTime::toUsecs(), and VLOG.