Receiver Class Reference

Public Member Functions
	Receiver (int timeoutSecs, const Sender *)
void	run () throw (n_u::IOException)
void	report ()
float	getKbytePerSec () const

Private Member Functions
void	reallocateBuffer (int len)
int	scanBuffer ()
	Return 0 on normal scan, 1 on receipt of EOF packet. More...
	Receiver (const Receiver &)
Receiver &	operator= (const Receiver &)

Private Attributes
const int	RBUFLEN
char *	_buf
char *	_rptr
char *	_wptr
char *	_eob
int	_buflen
int	_timeoutSecs
vector< int >	_last10
vector< int >	_last100
vector< int >	_msec100
int	_msec100ago
int	_ngood10
int	_ngood100
unsigned int	_Npack
unsigned int	_Nlast
int	_dsize
int	_dsizeTrusted
int	_msec
bool	_scanHeaderNext
time_t	_sec0
int	_msec0
unsigned int	_byteSum
unsigned int	_deltaT
int	_roundTripMsecs
const Sender *	_sender

Constructor & Destructor Documentation

Receiver::Receiver	(	int	timeoutSecs,
		const Sender *	s
	)

References _last10, _last100, _msec0, _msec100, _sec0, RBUFLEN, reallocateBuffer(), and USECS_PER_MSEC.

Receiver::Receiver ( const Receiver &  )

private

Member Function Documentation

float Receiver::getKbytePerSec ( ) const

inline

Referenced by report().

Receiver& Receiver::operator= ( const Receiver &  )

private

void Receiver::reallocateBuffer ( int  len )

private

References _buf, _buflen, _eob, _rptr, _wptr, and len.

Referenced by Receiver(), and scanBuffer().

void Receiver::report

(

)

References _ngood10, _ngood100, _Nlast, _roundTripMsecs, _sender, Sender::getKbytePerSec(), getKbytePerSec(), Sender::getNout(), and shortName.

Referenced by run(), and scanBuffer().

void Receiver::run	(		)
throw	(	n_u::IOException
	)

References _eob, _wptr, nidas::util::addBackslashSequences(), device, nidas::util::SerialPort::getFd(), interrupted, len, port, nidas::util::SerialPort::read(), report(), scanBuffer(), timeoutSecs, and verbose.

Referenced by main().

int Receiver::scanBuffer ( )

private

Return 0 on normal scan, 1 on receipt of EOF packet.

References _buf, _buflen, _byteSum, _deltaT, _dsize, _dsizeTrusted, _last10, _last100, _msec, _msec0, _msec100, _msec100ago, _ngood10, _ngood100, _Nlast, _Npack, _roundTripMsecs, _rptr, _scanHeaderNext, _sec0, _sender, _wptr, cksum(), crc, EOF_NPACK, ETX, LENGTH_OF_CRC, MAX_DATA_LENGTH, MIN_PACKET_LENGTH, MSECS_PER_SEC, port, RBUFLEN, reallocateBuffer(), report(), START_OF_DATA, USECS_PER_MSEC, and nidas::util::SerialPort::write().

Referenced by run().

Member Data Documentation

char* Receiver::_buf

private

Referenced by reallocateBuffer(), and scanBuffer().

int Receiver::_buflen

private

Referenced by reallocateBuffer(), and scanBuffer().

unsigned int Receiver::_byteSum

private

Referenced by scanBuffer().

unsigned int Receiver::_deltaT

private

Referenced by scanBuffer().

int Receiver::_dsize

private

Referenced by scanBuffer().

int Receiver::_dsizeTrusted

private

Referenced by scanBuffer().

char* Receiver::_eob

private

Referenced by reallocateBuffer(), and run().

vector<int> Receiver::_last10

private

Referenced by Receiver(), and scanBuffer().

vector<int> Receiver::_last100

private

Referenced by Receiver(), and scanBuffer().

int Receiver::_msec

private

Referenced by scanBuffer().

int Receiver::_msec0

private

Referenced by Receiver(), and scanBuffer().

vector<int> Receiver::_msec100

private

Referenced by Receiver(), and scanBuffer().

int Receiver::_msec100ago

private

Referenced by scanBuffer().

int Receiver::_ngood10

private

Referenced by report(), and scanBuffer().

int Receiver::_ngood100

private

Referenced by report(), and scanBuffer().

unsigned int Receiver::_Nlast

private

Referenced by report(), and scanBuffer().

unsigned int Receiver::_Npack

private

Referenced by scanBuffer().

int Receiver::_roundTripMsecs

private

Referenced by report(), and scanBuffer().

char* Receiver::_rptr

private

Referenced by reallocateBuffer(), and scanBuffer().

bool Receiver::_scanHeaderNext

private

Referenced by scanBuffer().

time_t Receiver::_sec0

private

Referenced by Receiver(), and scanBuffer().

const Sender* Receiver::_sender

private

Referenced by report(), and scanBuffer().

int Receiver::_timeoutSecs

private

char* Receiver::_wptr

private

Referenced by reallocateBuffer(), run(), and scanBuffer().

const int Receiver::RBUFLEN

private

Referenced by Receiver(), and scanBuffer().

---

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

• nidas/apps/sing.cc