A subclass of MessageStreamScanner, with a modified nextSampleSepBOM() method that adjusts the sample time tag by the tranmission time of the number of bytes that were discarded between the libmodbus read and the data sent over the pipe. More...

#include <ModbusRTU.h>

Inheritance diagram for nidas::dynld::ModbusRTU::ModbusMessageStreamScanner:

[legend]

Public Member Functions
	ModbusMessageStreamScanner ()

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

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 *	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
int	_nbytesDiscarded

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 subclass of MessageStreamScanner, with a modified nextSampleSepBOM() method that adjusts the sample time tag by the tranmission time of the number of bytes that were discarded between the libmodbus read and the data sent over the pipe.

From an email from Josh Carnes: A ModbusRTU response includes 1-byte address 1- byte function 1-byte Byte Count (X) X-byte data 2-byte CRC So, the response transmission length is 5-bytes longer than the data. In this application, that's 7 Bytes total.

The samples on the pipe after the modbus read consist of a 2-byte length and then the 2 byte sample word. So we need to adjust the sample time earlier by the transmission time of 3 bytes.

Constructor & Destructor Documentation

◆ ModbusMessageStreamScanner()

nidas::dynld::ModbusRTU::ModbusMessageStreamScanner::ModbusMessageStreamScanner ( )

inline

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(), nidas::core::MessageStreamScanner::nextSampleByLength(), nidas::core::MessageStreamScanner::nextSampleSepBOM(), nidas::core::MessageStreamScanner::nextSampleSepEOM(), and nidas::core::MessageStreamScanner::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

virtualinherited

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

inlinevirtualinherited

Returns 0.

Reimplemented from nidas::core::SampleScanner.

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

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

◆ getMessageSeparator()

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

inlinevirtualinherited

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

inlinevirtualinherited

Reimplemented from nidas::core::SampleScanner.

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

Referenced by nidas::core::MessageStreamScanner::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

inlinevirtualinherited

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

Reimplemented from nidas::core::SampleScanner.

References nidas::core::MessageStreamScanner::_nullTerminate.

Referenced by nidas::core::MessageStreamScanner::nextSampleSepBOM(), nidas::core::MessageStreamScanner::nextSampleSepEOM(), nidas::core::MessageStreamScanner::requestBiggerSample(), and nidas::core::MessageStreamScanner::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 nidas::core::MessageStreamScanner::nextSampleByLength(), nidas::core::MessageStreamScanner::nextSampleSepBOM(), nidas::core::MessageStreamScanner::nextSampleSepEOM(), nidas::core::MessageStreamScanner::readBuffer(), and nidas::core::MessageStreamScanner::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 )

inlinevirtualinherited

Extract the next sample from the buffer.

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

Implements nidas::core::SampleScanner.

References nidas::core::MessageStreamScanner::_nextSampleFunc.

◆ nextSampleByLength()

Sample * MessageStreamScanner::nextSampleByLength ( DSMSensor * sensor )

protectedinherited

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

Referenced by nidas::core::MessageStreamScanner::setMessageParameters().

◆ nextSampleSepBOM()

Sample * nidas::dynld::ModbusRTU::ModbusMessageStreamScanner::nextSampleSepBOM ( DSMSensor * sensor )

virtual

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

Reimplemented from nidas::core::MessageStreamScanner.

◆ nextSampleSepEOM()

Sample * MessageStreamScanner::nextSampleSepEOM ( DSMSensor * sensor )

protectedvirtualinherited

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

Referenced by nidas::core::MessageStreamScanner::setMessageParameters().

◆ readBuffer() [1/2]

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

virtualinherited

Exceptions

nidas::util::IOException

Reimplemented from nidas::core::SampleScanner.

References nidas::core::MessageStreamScanner::_lastBufferTime, nidas::core::MessageStreamScanner::_stepBackwards, nidas::core::MessageStreamScanner::_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 )

virtualinherited

Exceptions

nidas::util::IOException

Reimplemented from nidas::core::SampleScanner.

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

◆ requestBiggerSample()

Sample * MessageStreamScanner::requestBiggerSample ( unsigned int nc )

protectedinherited

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.

References nidas::core::SampleScanner::_osamp, nidas::core::SampleScanner::_outSampDataPtr, nidas::core::MessageStreamScanner::_outSampLengthAlloc, nidas::core::SampleScanner::_outSampRead, nidas::core::MessageStreamScanner::_sampleOverflows, nidas::core::SampleScanner::addSampleToStats(), nidas::core::Sample::freeReference(), nidas::core::Sample::getAllocByteLength(), nidas::core::Sample::getId(), nidas::core::MessageStreamScanner::getNullTerminate(), nidas::core::getSample(), nidas::core::Sample::getTimeTag(), nidas::core::Sample::getVoidDataPtr(), nidas::core::MessageStreamScanner::MAX_MESSAGE_STREAM_SAMPLE_SIZE, and nidas::core::Sample::setDataLength().

Referenced by nidas::core::MessageStreamScanner::nextSampleByLength(), nidas::core::MessageStreamScanner::nextSampleSepBOM(), and nidas::core::MessageStreamScanner::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 )

virtualinherited

Exceptions

nidas::util::InvalidParameterException

Implements nidas::core::SampleScanner.

◆ setNullTerminate()

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

inlineinherited

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

Referenced by nidas::core::MessageStreamScanner::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 )

inherited

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

Referenced by nidas::core::MessageStreamScanner::nextSampleByLength(), nidas::core::MessageStreamScanner::nextSampleSepBOM(), and nidas::core::MessageStreamScanner::nextSampleSepEOM().

◆ warnNonIncrTimeTag()

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

inherited

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 nidas::core::MessageStreamScanner::nextSampleByLength(), nidas::core::MessageStreamScanner::nextSampleSepBOM(), and nidas::core::MessageStreamScanner::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

protectedinherited

Referenced by nidas::core::MessageStreamScanner::nextSampleSepBOM().

◆ _buffer

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

protectedinherited

Referenced by nidas::core::DriverSampleScanner::nextSample(), nidas::core::DatagramSampleScanner::nextSample(), nidas::core::MessageStreamScanner::nextSampleByLength(), nidas::core::MessageStreamScanner::nextSampleSepBOM(), nidas::core::MessageStreamScanner::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(), nidas::core::MessageStreamScanner::nextSampleByLength(), nidas::core::MessageStreamScanner::nextSampleSepBOM(), nidas::core::MessageStreamScanner::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(), nidas::core::MessageStreamScanner::nextSampleByLength(), nidas::core::MessageStreamScanner::nextSampleSepBOM(), nidas::core::MessageStreamScanner::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

protectedinherited

Referenced by nidas::core::MessageStreamScanner::readBuffer(), and nidas::core::MessageStreamScanner::readBuffer().

◆ _lastSampleTime

dsm_time_t nidas::core::MessageStreamScanner::_lastSampleTime

protectedinherited

Referenced by nidas::core::MessageStreamScanner::nextSampleByLength(), nidas::core::MessageStreamScanner::nextSampleSepBOM(), and nidas::core::MessageStreamScanner::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(), nidas::core::MessageStreamScanner::getMessageLength(), and nidas::core::MessageStreamScanner::setMessageParameters().

◆ _messageSeparator

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

protectedinherited

Referenced by nidas::core::MessageSampleScanner::getBackslashedMessageSeparator(), nidas::core::MessageStreamScanner::getBackslashedMessageSeparator(), nidas::core::MessageSampleScanner::getMessageSeparator(), nidas::core::MessageStreamScanner::getMessageSeparator(), nidas::core::MessageSampleScanner::setMessageParameters(), and nidas::core::MessageStreamScanner::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().

◆ _nbytesDiscarded

int nidas::dynld::ModbusRTU::ModbusMessageStreamScanner::_nbytesDiscarded

private

◆ _nextSampleFunc

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

protectedinherited

Referenced by nidas::core::MessageStreamScanner::nextSample(), and nidas::core::MessageStreamScanner::setMessageParameters().

◆ _nonIncrTimeTag

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

protectedinherited

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 nidas::core::MessageStreamScanner::nextSampleByLength(), nidas::core::MessageStreamScanner::nextSampleSepBOM(), and nidas::core::MessageStreamScanner::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

protectedinherited

Count of number of consecutive samples smaller than _sampleLengthAlloc.

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

◆ _nullTerminate

bool nidas::core::MessageStreamScanner::_nullTerminate

protectedinherited

Referenced by nidas::core::MessageStreamScanner::getNullTerminate(), and nidas::core::MessageStreamScanner::setNullTerminate().

◆ _osamp

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

protectedinherited

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

◆ _outSampDataPtr

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

protectedinherited

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

◆ _outSampLengthAlloc

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

protectedinherited

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

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

◆ _outSampRead

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

protectedinherited

Referenced by nidas::core::DriverSampleScanner::nextSample(), nidas::core::MessageStreamScanner::nextSampleByLength(), nidas::core::MessageStreamScanner::nextSampleSepBOM(), nidas::core::MessageStreamScanner::nextSampleSepEOM(), and nidas::core::MessageStreamScanner::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

protectedinherited

Size of samples to allocate.

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

◆ _sampleOverflows

int nidas::core::MessageStreamScanner::_sampleOverflows

protectedinherited

Referenced by nidas::core::MessageStreamScanner::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 nidas::core::MessageStreamScanner::nextSampleSepBOM(), nidas::core::MessageStreamScanner::nextSampleSepEOM(), nidas::core::MessageStreamScanner::setMessageParameters(), and nidas::core::SampleScanner::~SampleScanner().

◆ _separatorAtEOM

bool nidas::core::SampleScanner::_separatorAtEOM

protectedinherited

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

◆ _separatorCnt

int nidas::core::MessageStreamScanner::_separatorCnt

protectedinherited

Referenced by nidas::core::MessageStreamScanner::nextSampleByLength(), nidas::core::MessageStreamScanner::nextSampleSepBOM(), and nidas::core::MessageStreamScanner::nextSampleSepEOM().

◆ _separatorLen

int nidas::core::SampleScanner::_separatorLen

protectedinherited

Length of messageSeparator.

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

◆ _stepBackTimeTag

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

protectedinherited

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

Referenced by nidas::core::MessageStreamScanner::nextSampleByLength(), nidas::core::MessageStreamScanner::nextSampleSepBOM(), and nidas::core::MessageStreamScanner::nextSampleSepEOM().

◆ _stepBackwards

bool nidas::core::MessageStreamScanner::_stepBackwards

protectedinherited

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 nidas::core::MessageStreamScanner::nextSampleByLength(), nidas::core::MessageStreamScanner::nextSampleSepBOM(), nidas::core::MessageStreamScanner::nextSampleSepEOM(), nidas::core::MessageStreamScanner::readBuffer(), and nidas::core::MessageStreamScanner::readBuffer().

◆ _tfirstchar

dsm_time_t nidas::core::MessageStreamScanner::_tfirstchar

protectedinherited

Referenced by nidas::core::MessageStreamScanner::nextSampleByLength(), nidas::core::MessageStreamScanner::nextSampleSepBOM(), nidas::core::MessageStreamScanner::nextSampleSepEOM(), nidas::core::MessageStreamScanner::readBuffer(), and nidas::core::MessageStreamScanner::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

protectedinherited

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

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

nidas/dynld/ModbusRTU.h

Public Member Functions

Protected Member Functions

Protected Attributes

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ ModbusMessageStreamScanner()

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

◆ _nbytesDiscarded

◆ _nextSampleFunc

◆ _nonIncrTimeTag

◆ _nsamples

◆ _nsmallSamples

◆ _nullTerminate

◆ _osamp

◆ _outSampDataPtr

◆ _outSampLengthAlloc

◆ _outSampRead

◆ _outSampToRead

◆ _reportIndex

◆ _sampleLengthAlloc

◆ _sampleOverflows

◆ _sampleRateObs

◆ _separator

◆ _separatorAtEOM

◆ _separatorCnt

◆ _separatorLen

◆ _stepBackTimeTag

◆ _stepBackwards

◆ _tfirstchar

◆ _usecsPerByte