nidas v1.2.3
Public Member Functions | Public Attributes | Private Member Functions | Private Attributes | List of all members
Receiver Class Reference

Public Member Functions

 Receiver (int timeoutSecs, const Sender *)
 
int run ()
 
void report ()
 
float getKbytePerSec () const
 

Public Attributes

unsigned int nBad
 

Private Member Functions

void reallocateBuffer (int len)
 
int scanBuffer ()
 Return 0 on normal scan, 1 on receipt of EOF packet.
 
 Receiver (const Receiver &)
 
Receiveroperator= (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() [1/2]

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

◆ Receiver() [2/2]

Receiver::Receiver ( const Receiver & )
private

Member Function Documentation

◆ getKbytePerSec()

float Receiver::getKbytePerSec ( ) const
inline

References _byteSum, and _deltaT.

Referenced by report().

◆ operator=()

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

◆ reallocateBuffer()

void Receiver::reallocateBuffer ( int len)
private

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

Referenced by Receiver(), and scanBuffer().

◆ report()

void Receiver::report ( )

◆ run()

int Receiver::run ( )

◆ scanBuffer()

int Receiver::scanBuffer ( )
private

Member Data Documentation

◆ _buf

char* Receiver::_buf
private

Referenced by reallocateBuffer(), and scanBuffer().

◆ _buflen

int Receiver::_buflen
private

Referenced by reallocateBuffer(), and scanBuffer().

◆ _byteSum

unsigned int Receiver::_byteSum
private

Referenced by getKbytePerSec(), and scanBuffer().

◆ _deltaT

unsigned int Receiver::_deltaT
private

Referenced by getKbytePerSec(), and scanBuffer().

◆ _dsize

int Receiver::_dsize
private

Referenced by scanBuffer().

◆ _dsizeTrusted

int Receiver::_dsizeTrusted
private

Referenced by scanBuffer().

◆ _eob

char* Receiver::_eob
private

Referenced by reallocateBuffer(), and run().

◆ _last10

vector<int> Receiver::_last10
private

Referenced by Receiver(), and scanBuffer().

◆ _last100

vector<int> Receiver::_last100
private

Referenced by Receiver(), and scanBuffer().

◆ _msec

int Receiver::_msec
private

Referenced by scanBuffer().

◆ _msec0

int Receiver::_msec0
private

Referenced by Receiver(), and scanBuffer().

◆ _msec100

vector<int> Receiver::_msec100
private

Referenced by Receiver(), and scanBuffer().

◆ _msec100ago

int Receiver::_msec100ago
private

Referenced by scanBuffer().

◆ _ngood10

int Receiver::_ngood10
private

Referenced by report(), and scanBuffer().

◆ _ngood100

int Receiver::_ngood100
private

Referenced by report(), and scanBuffer().

◆ _Nlast

unsigned int Receiver::_Nlast
private

Referenced by report(), and scanBuffer().

◆ _Npack

unsigned int Receiver::_Npack
private

Referenced by scanBuffer().

◆ _roundTripMsecs

int Receiver::_roundTripMsecs
private

Referenced by report(), and scanBuffer().

◆ _rptr

char* Receiver::_rptr
private

Referenced by reallocateBuffer(), and scanBuffer().

◆ _scanHeaderNext

bool Receiver::_scanHeaderNext
private

Referenced by scanBuffer().

◆ _sec0

time_t Receiver::_sec0
private

Referenced by Receiver(), and scanBuffer().

◆ _sender

const Sender* Receiver::_sender
private

Referenced by report(), and scanBuffer().

◆ _timeoutSecs

int Receiver::_timeoutSecs
private

◆ _wptr

char* Receiver::_wptr
private

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

◆ nBad

unsigned int Receiver::nBad

Referenced by scanBuffer().

◆ RBUFLEN

const int Receiver::RBUFLEN
private

Referenced by Receiver(), and scanBuffer().


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