nidas  v1.2-1520
Public Member Functions | Private Attributes | Static Private Attributes | List of all members
PacketReader Class Reference

Public Member Functions

 PacketReader ()
 
 ~PacketReader ()
 
int parseRunstring (int argc, char **argv)
 
int usage (const char *argv0)
 
const deque
< n_u::DatagramPacket * > & 
getPackets () const
 
nidas::util::ConddataReady ()
 
void loop () throw ()
 
const string & getHeader () const
 
int getTCPPort () const
 
int getMaxPacketSize () const
 
void checkPacket (n_u::DatagramPacket &)
 
void logBadPacket (const n_u::DatagramPacket &pkt, const string &msg)
 

Private Attributes

int _udpport
 
int _tcpport
 
int _packetsize
 
string _header
 
deque< n_u::DatagramPacket * > _packets
 
nidas::util::Cond _dataReady
 
size_t _rejectedPackets
 
long long _minSampleTime
 
long long _maxSampleTime
 
int _maxDsmId
 
unsigned int _maxSampleLength
 
int _rejectPacketInterval
 
int _packetReadInterval
 
NidasApp _app
 

Static Private Attributes

static const int DEFAULT_PACKET_SIZE = 16384
 

Constructor & Destructor Documentation

PacketReader::PacketReader ( )
PacketReader::~PacketReader ( )

Member Function Documentation

void PacketReader::checkPacket ( n_u::DatagramPacket pkt)
nidas::util::Cond& PacketReader::dataReady ( )
inline

Referenced by WriterThread::run().

const string& PacketReader::getHeader ( ) const
inline
int PacketReader::getMaxPacketSize ( ) const
inline

Referenced by WriterThread::run().

const deque<n_u::DatagramPacket*>& PacketReader::getPackets ( ) const
inline

Referenced by WriterThread::run().

int PacketReader::getTCPPort ( ) const
inline
void PacketReader::logBadPacket ( const n_u::DatagramPacket pkt,
const string &  msg 
)
void PacketReader::loop ( )
throw (
)
int PacketReader::parseRunstring ( int  argc,
char **  argv 
)
int PacketReader::usage ( const char *  argv0)

Member Data Documentation

NidasApp PacketReader::_app
private

Referenced by PacketReader(), parseRunstring(), and usage().

nidas::util::Cond PacketReader::_dataReady
private

Referenced by loop(), and ~PacketReader().

string PacketReader::_header
private

Referenced by parseRunstring().

int PacketReader::_maxDsmId
private

Referenced by checkPacket().

unsigned int PacketReader::_maxSampleLength
private

Referenced by checkPacket().

long long PacketReader::_maxSampleTime
private

Referenced by checkPacket().

long long PacketReader::_minSampleTime
private

Referenced by checkPacket().

int PacketReader::_packetReadInterval
private

Referenced by loop(), and parseRunstring().

deque<n_u::DatagramPacket*> PacketReader::_packets
private

Referenced by loop(), and ~PacketReader().

int PacketReader::_packetsize
private

Referenced by loop(), and parseRunstring().

size_t PacketReader::_rejectedPackets
private

Referenced by checkPacket(), and logBadPacket().

int PacketReader::_rejectPacketInterval
private

Referenced by checkPacket(), and parseRunstring().

int PacketReader::_tcpport
private

Referenced by parseRunstring().

int PacketReader::_udpport
private

Referenced by loop(), and parseRunstring().

const int PacketReader::DEFAULT_PACKET_SIZE = 16384
staticprivate

Referenced by usage().


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