A SampleScanner which supports the set/get of message separation parameters and extracts samples from the internal buffer by recognizing separators in the message stream. More...

#include <SampleScanner.h>

Inheritance diagram for nidas::core::MessageStreamScanner:

[legend]

Public Member Functions
	MessageStreamScanner (int bufsize=4096)

void	setMessageParameters (unsigned int len, const std::string &val, bool eom)

const std::string &	getMessageSeparator () const
	Get message separator string.

const std::string	getBackslashedMessageSeparator () const
	Get message separator with backslash sequences added back.

bool	getMessageSeparatorAtEOM () const

unsigned int	getMessageLength () const
	Returns 0.

void	setNullTerminate (bool val)

bool	getNullTerminate () const
	Should the SampleScanner append a null character, '\0', to the messages.

Sample *	nextSample (DSMSensor *sensor)
	Extract the next sample from the buffer.

size_t	readBuffer (DSMSensor *sensor, bool &exhausted)

size_t	readBuffer (DSMSensor *sensor, bool &exhausted, int msecTimeout)

void	warnNonIncrTimeTag (const DSMSensor *sensor, dsm_time_t badtt, dsm_time_t cortt, unsigned int nbad)
	Issue warning log message about a non-forward time tag.

void	warnBackwardsStepTimeTag (const DSMSensor *sensor, dsm_time_t badtt, unsigned int nbad)

virtual void	init ()
	Initialize the scanner.

void	setUsecsPerByte (int val)

int	getUsecsPerByte () const

virtual void	clearBuffer ()

unsigned int	getBytesInBuffer () const

virtual void	resetStatistics ()

virtual void	calcStatistics (unsigned int periodUsec)
	Update the sensor sampling statistics: samples/sec, bytes/sec, min/max sample size, that can be accessed via getObservedSamplingRate(), getObservedDataRate() etc.

unsigned int	getMaxSampleLength () const

unsigned int	getMinSampleLength () const

unsigned int	getBadTimeTagCount () const

float	getObservedSamplingRate () const

float	getObservedDataRate () const

void	addNumBytesToStats (size_t val)

void	addSampleToStats (unsigned int val)

void	incrementBadTimeTags ()

Protected Member Functions
virtual Sample *	nextSampleSepBOM (DSMSensor *sensor)
	Method to read input and break it into samples where the message separator occurs at the beginning of the message.

virtual Sample *	nextSampleSepEOM (DSMSensor *sensor)
	Method to read input and break it into samples where the message separator occurs at the end of the message.

Sample *	nextSampleByLength (DSMSensor *sensor)
	Method to read input and break it into samples strictly by record length.

Sample *	requestBiggerSample (unsigned int nc)
	If a new sample can be allocated without exceeding MAX_MESSAGE_STREAM_SAMPLE_SIZE then get a new, larger sample, copying the timetag, id and existing data from the current sample, and return null.

Protected Attributes
Sample (MessageStreamScanner::	_nextSampleFunc )(DSMSensor *)

dsm_time_t	_tfirstchar

dsm_time_t	_lastBufferTime

dsm_time_t	_lastSampleTime

const unsigned int	MAX_MESSAGE_STREAM_SAMPLE_SIZE

int	_separatorCnt

dsm_time_t	_bomtt

int	_sampleOverflows

unsigned int	_sampleLengthAlloc
	Size of samples to allocate.

bool	_nullTerminate

int	_nsmallSamples
	Count of number of consecutive samples smaller than _sampleLengthAlloc.

unsigned int	_outSampLengthAlloc
	Number of bytes allocated in data portion of current output sample.

bool	_stepBackwards
	If the system time of a buffer read is earlier than the previous read.

unsigned int	_stepBackTimeTag
	Number of time tags that were not monotonically increasing, due to backward step changes.

unsigned int	_nonIncrTimeTag
	Number of time tags that were not monotonically increasing, not because of backward step changes, but instead due to system buffering, where the receipt times of two buffers are closer together than should be possible at the given baud rate.

const unsigned int	BUFSIZE
	Buffer size for reading from sensor.

char *	_buffer

unsigned int	_bufhead

unsigned int	_buftail

Sample *	_osamp

struct dsm_sample	_header

unsigned int	_outSampRead

unsigned int	_outSampToRead

char *	_outSampDataPtr

std::string	_messageSeparator

int	_messageLength

bool	_separatorAtEOM

char *	_separator
	messageSeparator in a C string.

int	_separatorLen
	Length of messageSeparator.

Private Attributes
std::string	_emptyString

time_t	_initialTimeSecs

unsigned int	_minSampleLength [2]

unsigned int	_maxSampleLength [2]

int	_currentIndex

int	_reportIndex

size_t	_nsamples

size_t	_nbytes

unsigned int	_badTimeTags

float	_sampleRateObs
	Observed number of samples per second.

float	_dataRateObs

int	_usecsPerByte

Detailed Description

A SampleScanner which supports the set/get of message separation parameters and extracts samples from the internal buffer by recognizing separators in the message stream.

Timetags are applied to the samples based on the time of receipt of each chunk of data, corrected backwards by the computed tranmission time of each byte in the chunk.

See also: setUsecsPerByte().

Constructor & Destructor Documentation

◆ MessageStreamScanner()

MessageStreamScanner::MessageStreamScanner ( int bufsize = 4096 )

Member Function Documentation

◆ addNumBytesToStats()

void nidas::core::SampleScanner::addNumBytesToStats ( size_t val )

inlineinherited

References nidas::core::SampleScanner::_nbytes, and nidas::core::getSample().

Referenced by nidas::core::SampleScanner::readBuffer(), and nidas::core::DatagramSampleScanner::readBuffer().

◆ addSampleToStats()

void nidas::core::SampleScanner::addSampleToStats ( unsigned int val )

inlineinherited

References nidas::core::SampleScanner::_currentIndex, nidas::core::SampleScanner::_maxSampleLength, nidas::core::SampleScanner::_minSampleLength, and nidas::core::SampleScanner::_nsamples.

Referenced by nidas::core::DriverSampleScanner::nextSample(), nidas::core::DatagramSampleScanner::nextSample(), nextSampleByLength(), nextSampleSepBOM(), nextSampleSepEOM(), and requestBiggerSample().

◆ calcStatistics()

void SampleScanner::calcStatistics ( unsigned int periodUsec )

virtualinherited

Update the sensor sampling statistics: samples/sec, bytes/sec, min/max sample size, that can be accessed via getObservedSamplingRate(), getObservedDataRate() etc.

Should be called every periodUsec by a user of this sensor.

Parameters

periodUsec Statistics period.

References nidas::core::SampleScanner::_currentIndex, nidas::core::SampleScanner::_dataRateObs, nidas::core::SampleScanner::_maxSampleLength, nidas::core::SampleScanner::_minSampleLength, nidas::core::SampleScanner::_nbytes, nidas::core::SampleScanner::_nsamples, nidas::core::SampleScanner::_reportIndex, nidas::core::SampleScanner::_sampleRateObs, nidas::core::getSample(), and USECS_PER_SEC.

Referenced by nidas::core::DSMSensor::calcStatistics().

◆ clearBuffer()

void SampleScanner::clearBuffer ( )

virtualinherited

References nidas::core::SampleScanner::_bufhead, and nidas::core::SampleScanner::_buftail.

Referenced by nidas::core::DSMSensor::clearBuffer().

◆ getBackslashedMessageSeparator()

const string MessageStreamScanner::getBackslashedMessageSeparator ( ) const

virtual

Get message separator with backslash sequences added back.

Reimplemented from nidas::core::SampleScanner.

References nidas::core::SampleScanner::_messageSeparator, and nidas::util::addBackslashSequences().

◆ getBadTimeTagCount()

unsigned int nidas::core::SampleScanner::getBadTimeTagCount ( ) const

inlineinherited

References nidas::core::SampleScanner::_badTimeTags.

Referenced by nidas::core::DSMSensor::getBadTimeTagCount().

◆ getBytesInBuffer()

unsigned int nidas::core::SampleScanner::getBytesInBuffer ( ) const

inlineinherited

References nidas::core::SampleScanner::_bufhead, and nidas::core::SampleScanner::_buftail.

◆ getMaxSampleLength()

unsigned int nidas::core::SampleScanner::getMaxSampleLength ( ) const

inlineinherited

References nidas::core::SampleScanner::_maxSampleLength, and nidas::core::SampleScanner::_reportIndex.

Referenced by nidas::core::DSMSensor::getMaxSampleLength().

◆ getMessageLength()

unsigned int nidas::core::MessageStreamScanner::getMessageLength ( ) const

inlinevirtual

Returns 0.

Reimplemented from nidas::core::SampleScanner.

References nidas::core::SampleScanner::_messageLength.

Referenced by nextSampleByLength(), nextSampleSepBOM(), nextSampleSepEOM(), and setMessageParameters().

◆ getMessageSeparator()

const std::string & nidas::core::MessageStreamScanner::getMessageSeparator ( ) const

inlinevirtual

Get message separator string.

Any backslash sequences will have been replaced by their intended value.

Reimplemented from nidas::core::SampleScanner.

References nidas::core::SampleScanner::_messageSeparator.

◆ getMessageSeparatorAtEOM()

bool nidas::core::MessageStreamScanner::getMessageSeparatorAtEOM ( ) const

inlinevirtual

Reimplemented from nidas::core::SampleScanner.

References nidas::core::SampleScanner::_separatorAtEOM.

Referenced by setMessageParameters().

◆ getMinSampleLength()

unsigned int nidas::core::SampleScanner::getMinSampleLength ( ) const

inlineinherited

References nidas::core::SampleScanner::_maxSampleLength, nidas::core::SampleScanner::_minSampleLength, and nidas::core::SampleScanner::_reportIndex.

Referenced by nidas::core::DSMSensor::getMinSampleLength().

◆ getNullTerminate()

bool nidas::core::MessageStreamScanner::getNullTerminate ( ) const

inlinevirtual

Should the SampleScanner append a null character, '\0', to the messages.

Reimplemented from nidas::core::SampleScanner.

References _nullTerminate.

Referenced by nextSampleSepBOM(), nextSampleSepEOM(), requestBiggerSample(), and setMessageParameters().

◆ getObservedDataRate()

float SampleScanner::getObservedDataRate ( ) const

inherited

References nidas::core::SampleScanner::_currentIndex, nidas::core::SampleScanner::_dataRateObs, nidas::core::SampleScanner::_initialTimeSecs, nidas::core::SampleScanner::_nbytes, and nidas::core::SampleScanner::_reportIndex.

Referenced by nidas::core::DSMSensor::getObservedDataRate().

◆ getObservedSamplingRate()

float SampleScanner::getObservedSamplingRate ( ) const

inherited

References nidas::core::SampleScanner::_currentIndex, nidas::core::SampleScanner::_initialTimeSecs, nidas::core::SampleScanner::_nsamples, nidas::core::SampleScanner::_reportIndex, and nidas::core::SampleScanner::_sampleRateObs.

Referenced by nidas::core::DSMSensor::getObservedSamplingRate().

◆ getUsecsPerByte()

int nidas::core::SampleScanner::getUsecsPerByte ( ) const

inlineinherited

References nidas::core::SampleScanner::_usecsPerByte.

Referenced by nextSampleByLength(), nextSampleSepBOM(), nextSampleSepEOM(), readBuffer(), and readBuffer().

◆ incrementBadTimeTags()

void nidas::core::SampleScanner::incrementBadTimeTags ( )

inlineinherited

References nidas::core::SampleScanner::_badTimeTags.

Referenced by nidas::core::DriverSampleScanner::nextSample().

◆ init()

void SampleScanner::init ( )

virtualinherited

Initialize the scanner.

Must be called by a user of SampleScanner prior to calling readSamples().

References nidas::core::SampleScanner::resetStatistics().

Referenced by nidas::core::DSMSensor::open().

◆ nextSample()

Sample * nidas::core::MessageStreamScanner::nextSample ( DSMSensor * sensor )

inlinevirtual

Extract the next sample from the buffer.

Returns NULL if there are no more samples in the buffer.

Implements nidas::core::SampleScanner.

References _nextSampleFunc.

◆ nextSampleByLength()

Sample * MessageStreamScanner::nextSampleByLength ( DSMSensor * sensor )

protected

Method to read input and break it into samples strictly by record length.

Referenced by setMessageParameters().

◆ nextSampleSepBOM()

Sample * MessageStreamScanner::nextSampleSepBOM ( DSMSensor * sensor )

protectedvirtual

Method to read input and break it into samples where the message separator occurs at the beginning of the message.

Reimplemented in nidas::dynld::ModbusRTU::ModbusMessageStreamScanner.

Referenced by nextSampleSepBOM(), and setMessageParameters().

◆ nextSampleSepEOM()

Sample * MessageStreamScanner::nextSampleSepEOM ( DSMSensor * sensor )

protectedvirtual

Method to read input and break it into samples where the message separator occurs at the end of the message.

Referenced by setMessageParameters().

◆ readBuffer() [1/2]

size_t MessageStreamScanner::readBuffer	(	DSMSensor *	sensor,
		bool &	exhausted )

virtual

Exceptions

nidas::util::IOException

Reimplemented from nidas::core::SampleScanner.

References _lastBufferTime, _stepBackwards, _tfirstchar, nidas::core::getSample(), nidas::util::getSystemTime(), nidas::core::SampleScanner::getUsecsPerByte(), and nidas::core::SampleScanner::readBuffer().

◆ readBuffer() [2/2]

size_t MessageStreamScanner::readBuffer	(	DSMSensor *	sensor,
		bool &	exhausted,
		int	msecTimeout )

virtual

Exceptions

nidas::util::IOException

Reimplemented from nidas::core::SampleScanner.

References _lastBufferTime, _stepBackwards, _tfirstchar, nidas::core::getSample(), nidas::util::getSystemTime(), nidas::core::SampleScanner::getUsecsPerByte(), and nidas::core::SampleScanner::readBuffer().

◆ requestBiggerSample()

Sample * MessageStreamScanner::requestBiggerSample ( unsigned int nc )

protected

If a new sample can be allocated without exceeding MAX_MESSAGE_STREAM_SAMPLE_SIZE then get a new, larger sample, copying the timetag, id and existing data from the current sample, and return null.

The data members _osamp, and _outSampDataPtr are updated to point to the new sample. Otherwise, since we've reached the MAX limit, more data will not be added to the sample, so return a pointer to the existing max'd out sample, which should then be returned as the value of the nextSample() method.

Referenced by nextSampleByLength(), nextSampleSepBOM(), and nextSampleSepEOM().

◆ resetStatistics()

void SampleScanner::resetStatistics ( )

virtualinherited

References nidas::core::SampleScanner::_badTimeTags, nidas::core::SampleScanner::_currentIndex, nidas::core::SampleScanner::_dataRateObs, nidas::core::SampleScanner::_initialTimeSecs, nidas::core::SampleScanner::_maxSampleLength, nidas::core::SampleScanner::_minSampleLength, nidas::core::SampleScanner::_nbytes, nidas::core::SampleScanner::_nsamples, nidas::core::SampleScanner::_reportIndex, nidas::core::SampleScanner::_sampleRateObs, and nidas::core::getSample().

Referenced by nidas::core::SampleScanner::init(), and nidas::core::SampleScanner::SampleScanner().

◆ setMessageParameters()

void MessageStreamScanner::setMessageParameters	(	unsigned int	len,
		const std::string &	val,
		bool	eom )

virtual

◆ setNullTerminate()

void nidas::core::MessageStreamScanner::setNullTerminate ( bool val )

inline

References _nullTerminate, and nidas::core::getSample().

Referenced by setMessageParameters().

◆ setUsecsPerByte()

void nidas::core::SampleScanner::setUsecsPerByte ( int val )

inlineinherited

References nidas::core::SampleScanner::_usecsPerByte, and nidas::core::getSample().

Referenced by nidas::dynld::ModbusRTU::open().

◆ warnBackwardsStepTimeTag()

void MessageStreamScanner::warnBackwardsStepTimeTag	(	const DSMSensor *	sensor,
		dsm_time_t	badtt,
		unsigned int	nbad )

References nidas::util::UTime::format(), nidas::core::DSMSensor::getDSMId(), nidas::core::DSMSensor::getName(), nidas::core::DSMSensor::getSensorId(), and WLOG.

Referenced by nextSampleByLength(), nextSampleSepBOM(), and nextSampleSepEOM().

◆ warnNonIncrTimeTag()

void MessageStreamScanner::warnNonIncrTimeTag	(	const DSMSensor *	sensor,
		dsm_time_t	badtt,
		dsm_time_t	cortt,
		unsigned int	nbad )

Issue warning log message about a non-forward time tag.

References nidas::util::UTime::format(), nidas::core::DSMSensor::getDSMId(), nidas::core::DSMSensor::getName(), nidas::core::DSMSensor::getSensorId(), USECS_PER_SEC, and WLOG.

Referenced by nextSampleByLength(), nextSampleSepBOM(), and nextSampleSepEOM().

Member Data Documentation

◆ _badTimeTags

unsigned int nidas::core::SampleScanner::_badTimeTags

privateinherited

Referenced by nidas::core::SampleScanner::getBadTimeTagCount(), nidas::core::SampleScanner::incrementBadTimeTags(), and nidas::core::SampleScanner::resetStatistics().

◆ _bomtt

dsm_time_t nidas::core::MessageStreamScanner::_bomtt

protected

Referenced by nextSampleSepBOM().

◆ _buffer

char* nidas::core::SampleScanner::_buffer

protectedinherited

Referenced by nidas::core::DriverSampleScanner::nextSample(), nidas::core::DatagramSampleScanner::nextSample(), nextSampleByLength(), nextSampleSepBOM(), nextSampleSepEOM(), nidas::core::SampleScanner::readBuffer(), nidas::core::DatagramSampleScanner::readBuffer(), and nidas::core::SampleScanner::~SampleScanner().

◆ _bufhead

unsigned int nidas::core::SampleScanner::_bufhead

protectedinherited

Referenced by nidas::core::SampleScanner::clearBuffer(), nidas::core::SampleScanner::getBytesInBuffer(), nidas::core::DriverSampleScanner::nextSample(), nextSampleByLength(), nextSampleSepBOM(), nextSampleSepEOM(), nidas::core::SampleScanner::readBuffer(), and nidas::core::DatagramSampleScanner::readBuffer().

◆ _buftail

unsigned int nidas::core::SampleScanner::_buftail

protectedinherited

Referenced by nidas::core::SampleScanner::clearBuffer(), nidas::core::SampleScanner::getBytesInBuffer(), nidas::core::DriverSampleScanner::nextSample(), nidas::core::DatagramSampleScanner::nextSample(), nextSampleByLength(), nextSampleSepBOM(), nextSampleSepEOM(), nidas::core::SampleScanner::readBuffer(), and nidas::core::DatagramSampleScanner::readBuffer().

◆ _currentIndex

int nidas::core::SampleScanner::_currentIndex

privateinherited

Referenced by nidas::core::SampleScanner::addSampleToStats(), nidas::core::SampleScanner::calcStatistics(), nidas::core::SampleScanner::getObservedDataRate(), nidas::core::SampleScanner::getObservedSamplingRate(), and nidas::core::SampleScanner::resetStatistics().

◆ _dataRateObs

float nidas::core::SampleScanner::_dataRateObs

privateinherited

Referenced by nidas::core::SampleScanner::calcStatistics(), nidas::core::SampleScanner::getObservedDataRate(), and nidas::core::SampleScanner::resetStatistics().

◆ _emptyString

std::string nidas::core::SampleScanner::_emptyString

privateinherited

Referenced by nidas::core::SampleScanner::getBackslashedMessageSeparator(), and nidas::core::SampleScanner::getMessageSeparator().

◆ _header

struct dsm_sample nidas::core::SampleScanner::_header

protectedinherited

Referenced by nidas::core::DriverSampleScanner::nextSample().

◆ _initialTimeSecs

time_t nidas::core::SampleScanner::_initialTimeSecs

privateinherited

Referenced by nidas::core::SampleScanner::getObservedDataRate(), nidas::core::SampleScanner::getObservedSamplingRate(), and nidas::core::SampleScanner::resetStatistics().

◆ _lastBufferTime

dsm_time_t nidas::core::MessageStreamScanner::_lastBufferTime

protected

Referenced by readBuffer(), and readBuffer().

◆ _lastSampleTime

dsm_time_t nidas::core::MessageStreamScanner::_lastSampleTime

protected

Referenced by nextSampleByLength(), nextSampleSepBOM(), and nextSampleSepEOM().

◆ _maxSampleLength

unsigned int nidas::core::SampleScanner::_maxSampleLength[2]

privateinherited

Referenced by nidas::core::SampleScanner::addSampleToStats(), nidas::core::SampleScanner::calcStatistics(), nidas::core::SampleScanner::getMaxSampleLength(), nidas::core::SampleScanner::getMinSampleLength(), and nidas::core::SampleScanner::resetStatistics().

◆ _messageLength

int nidas::core::SampleScanner::_messageLength

protectedinherited

Referenced by nidas::core::MessageSampleScanner::getMessageLength(), getMessageLength(), and setMessageParameters().

◆ _messageSeparator

std::string nidas::core::SampleScanner::_messageSeparator

protectedinherited

Referenced by nidas::core::MessageSampleScanner::getBackslashedMessageSeparator(), getBackslashedMessageSeparator(), nidas::core::MessageSampleScanner::getMessageSeparator(), getMessageSeparator(), nidas::core::MessageSampleScanner::setMessageParameters(), and setMessageParameters().

◆ _minSampleLength

unsigned int nidas::core::SampleScanner::_minSampleLength[2]

privateinherited

Referenced by nidas::core::SampleScanner::addSampleToStats(), nidas::core::SampleScanner::calcStatistics(), nidas::core::SampleScanner::getMinSampleLength(), and nidas::core::SampleScanner::resetStatistics().

◆ _nbytes

size_t nidas::core::SampleScanner::_nbytes

privateinherited

Referenced by nidas::core::SampleScanner::addNumBytesToStats(), nidas::core::SampleScanner::calcStatistics(), nidas::core::SampleScanner::getObservedDataRate(), and nidas::core::SampleScanner::resetStatistics().

◆ _nextSampleFunc

Sample *(MessageStreamScanner::* nidas::core::MessageStreamScanner::_nextSampleFunc) (DSMSensor *)

protected

Referenced by nextSample(), and setMessageParameters().

◆ _nonIncrTimeTag

unsigned int nidas::core::MessageStreamScanner::_nonIncrTimeTag

protected

Number of time tags that were not monotonically increasing, not because of backward step changes, but instead due to system buffering, where the receipt times of two buffers are closer together than should be possible at the given baud rate.

Referenced by nextSampleByLength(), nextSampleSepBOM(), and nextSampleSepEOM().

◆ _nsamples

size_t nidas::core::SampleScanner::_nsamples

privateinherited

Referenced by nidas::core::SampleScanner::addSampleToStats(), nidas::core::SampleScanner::calcStatistics(), nidas::core::SampleScanner::getObservedSamplingRate(), and nidas::core::SampleScanner::resetStatistics().

◆ _nsmallSamples

int nidas::core::MessageStreamScanner::_nsmallSamples

protected

Count of number of consecutive samples smaller than _sampleLengthAlloc.

Referenced by nextSampleSepBOM(), and nextSampleSepEOM().

◆ _nullTerminate

bool nidas::core::MessageStreamScanner::_nullTerminate

protected

Referenced by getNullTerminate(), and setNullTerminate().

◆ _osamp

Sample* nidas::core::SampleScanner::_osamp

protectedinherited

Referenced by nidas::core::DriverSampleScanner::nextSample(), nextSampleByLength(), nextSampleSepBOM(), nextSampleSepEOM(), requestBiggerSample(), and nidas::core::SampleScanner::~SampleScanner().

◆ _outSampDataPtr

char* nidas::core::SampleScanner::_outSampDataPtr

protectedinherited

Referenced by nidas::core::DriverSampleScanner::nextSample(), nextSampleByLength(), nextSampleSepBOM(), nextSampleSepEOM(), and requestBiggerSample().

◆ _outSampLengthAlloc

unsigned int nidas::core::MessageStreamScanner::_outSampLengthAlloc

protected

Number of bytes allocated in data portion of current output sample.

Referenced by nextSampleByLength(), nextSampleSepBOM(), nextSampleSepEOM(), and requestBiggerSample().

◆ _outSampRead

unsigned int nidas::core::SampleScanner::_outSampRead

protectedinherited

Referenced by nidas::core::DriverSampleScanner::nextSample(), nextSampleByLength(), nextSampleSepBOM(), nextSampleSepEOM(), and requestBiggerSample().

◆ _outSampToRead

unsigned int nidas::core::SampleScanner::_outSampToRead

protectedinherited

Referenced by nidas::core::DriverSampleScanner::nextSample().

◆ _reportIndex

int nidas::core::SampleScanner::_reportIndex

privateinherited

Referenced by nidas::core::SampleScanner::calcStatistics(), nidas::core::SampleScanner::getMaxSampleLength(), nidas::core::SampleScanner::getMinSampleLength(), nidas::core::SampleScanner::getObservedDataRate(), nidas::core::SampleScanner::getObservedSamplingRate(), and nidas::core::SampleScanner::resetStatistics().

◆ _sampleLengthAlloc

unsigned int nidas::core::MessageStreamScanner::_sampleLengthAlloc

protected

Size of samples to allocate.

Referenced by nextSampleByLength(), nextSampleSepBOM(), nextSampleSepEOM(), and setMessageParameters().

◆ _sampleOverflows

int nidas::core::MessageStreamScanner::_sampleOverflows

protected

Referenced by requestBiggerSample().

◆ _sampleRateObs

float nidas::core::SampleScanner::_sampleRateObs

privateinherited

Observed number of samples per second.

Referenced by nidas::core::SampleScanner::calcStatistics(), nidas::core::SampleScanner::getObservedSamplingRate(), and nidas::core::SampleScanner::resetStatistics().

◆ _separator

char* nidas::core::SampleScanner::_separator

protectedinherited

messageSeparator in a C string.

Referenced by nextSampleSepBOM(), nextSampleSepEOM(), setMessageParameters(), and nidas::core::SampleScanner::~SampleScanner().

◆ _separatorAtEOM

bool nidas::core::SampleScanner::_separatorAtEOM

protectedinherited

Referenced by nidas::core::MessageSampleScanner::getMessageSeparatorAtEOM(), getMessageSeparatorAtEOM(), nidas::core::MessageSampleScanner::setMessageParameters(), and setMessageParameters().

◆ _separatorCnt

int nidas::core::MessageStreamScanner::_separatorCnt

protected

Referenced by nextSampleByLength(), nextSampleSepBOM(), and nextSampleSepEOM().

◆ _separatorLen

int nidas::core::SampleScanner::_separatorLen

protectedinherited

Length of messageSeparator.

Referenced by nextSampleSepBOM(), nextSampleSepEOM(), nidas::core::MessageSampleScanner::setMessageParameters(), and setMessageParameters().

◆ _stepBackTimeTag

unsigned int nidas::core::MessageStreamScanner::_stepBackTimeTag

protected

Number of time tags that were not monotonically increasing, due to backward step changes.

Referenced by nextSampleByLength(), nextSampleSepBOM(), and nextSampleSepEOM().

◆ _stepBackwards

bool nidas::core::MessageStreamScanner::_stepBackwards

protected

If the system time of a buffer read is earlier than the previous read.

This should only happen due to a step change of the system clock.

Referenced by nextSampleByLength(), nextSampleSepBOM(), nextSampleSepEOM(), readBuffer(), and readBuffer().

◆ _tfirstchar

dsm_time_t nidas::core::MessageStreamScanner::_tfirstchar

protected

Referenced by nextSampleByLength(), nextSampleSepBOM(), nextSampleSepEOM(), readBuffer(), and readBuffer().

◆ _usecsPerByte

int nidas::core::SampleScanner::_usecsPerByte

privateinherited

Referenced by nidas::core::SampleScanner::getUsecsPerByte(), and nidas::core::SampleScanner::setUsecsPerByte().

◆ BUFSIZE

const unsigned int nidas::core::SampleScanner::BUFSIZE

protectedinherited

Buffer size for reading from sensor.

Referenced by nidas::core::SampleScanner::readBuffer(), and nidas::core::DatagramSampleScanner::readBuffer().

◆ MAX_MESSAGE_STREAM_SAMPLE_SIZE

const unsigned int nidas::core::MessageStreamScanner::MAX_MESSAGE_STREAM_SAMPLE_SIZE

protected

Referenced by nextSampleSepBOM(), nextSampleSepEOM(), requestBiggerSample(), and setMessageParameters().

The documentation for this class was generated from the following files:

nidas/core/SampleScanner.h
nidas/core/SampleScanner.cc

Public Member Functions

Protected Member Functions

Protected Attributes

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ MessageStreamScanner()

Member Function Documentation

◆ addNumBytesToStats()

◆ addSampleToStats()

◆ calcStatistics()

◆ clearBuffer()

◆ getBackslashedMessageSeparator()

◆ getBadTimeTagCount()

◆ getBytesInBuffer()

◆ getMaxSampleLength()

◆ getMessageLength()

◆ getMessageSeparator()

◆ getMessageSeparatorAtEOM()

◆ getMinSampleLength()

◆ getNullTerminate()

◆ getObservedDataRate()

◆ getObservedSamplingRate()

◆ getUsecsPerByte()

◆ incrementBadTimeTags()

◆ init()

◆ nextSample()

◆ nextSampleByLength()

◆ nextSampleSepBOM()

◆ nextSampleSepEOM()

◆ readBuffer() [1/2]

◆ readBuffer() [2/2]

◆ requestBiggerSample()

◆ resetStatistics()

◆ setMessageParameters()

◆ setNullTerminate()

◆ setUsecsPerByte()

◆ warnBackwardsStepTimeTag()

◆ warnNonIncrTimeTag()

Member Data Documentation

◆ _badTimeTags

◆ _bomtt

◆ _buffer

◆ _bufhead

◆ _buftail

◆ _currentIndex

◆ _dataRateObs

◆ _emptyString

◆ _header

◆ _initialTimeSecs

◆ _lastBufferTime

◆ _lastSampleTime

◆ _maxSampleLength

◆ _messageLength

◆ _messageSeparator

◆ _minSampleLength

◆ _nbytes

◆ _nextSampleFunc

◆ _nonIncrTimeTag

◆ _nsamples

◆ _nsmallSamples

◆ _nullTerminate

◆ _osamp

◆ _outSampDataPtr

◆ _outSampLengthAlloc

◆ _outSampRead

◆ _outSampToRead

◆ _reportIndex

◆ _sampleLengthAlloc

◆ _sampleOverflows

◆ _sampleRateObs

◆ _separator

◆ _separatorAtEOM

◆ _separatorCnt

◆ _separatorLen

◆ _stepBackTimeTag

◆ _stepBackwards

◆ _tfirstchar

◆ _usecsPerByte

◆ BUFSIZE