PacketReader::PacketReader |
( |
| ) |
|
PacketReader::~PacketReader |
( |
| ) |
|
References _maxDsmId, _maxSampleLength, _maxSampleTime, _minSampleTime, _rejectedPackets, _rejectPacketInterval, nidas::core::CHAR_ST, GET_DSM_ID, GET_SPS_ID, nidas::util::DatagramPacketT< DataT >::getConstDataVoidPtr(), nidas::core::SampleHeader::getDataByteLength(), nidas::core::SampleHeader::getId(), nidas::util::DatagramPacketBase::getLength(), nidas::core::SampleHeader::getSizeOf(), nidas::core::SampleHeader::getTimeTag(), nidas::core::SampleHeader::getType(), logBadPacket(), and nidas::util::DatagramPacketBase::setLength().
Referenced by loop().
const string& PacketReader::getHeader |
( |
| ) |
const |
|
inline |
int PacketReader::getMaxPacketSize |
( |
| ) |
const |
|
inline |
int PacketReader::getTCPPort |
( |
| ) |
const |
|
inline |
void PacketReader::loop |
( |
| ) |
|
throw | ( | |
| ) | | |
References _dataReady, _packetReadInterval, _packets, _packetsize, _udpport, nidas::util::Cond::broadcast(), checkPacket(), nidas::util::DatagramSocket::close(), nidas::util::DatagramPacketBase::getLength(), nidas::util::DatagramPacketBase::getMaxLength(), nidas::util::DatagramPacketBase::getSocketAddress(), interrupted, nidas::util::Cond::lock(), PLOG, nidas::util::DatagramSocket::receive(), nidas::util::SocketAddress::toString(), nidas::util::Cond::unlock(), VLOG, and nidas::util::Exception::what().
Referenced by main().
int PacketReader::parseRunstring |
( |
int |
argc, |
|
|
char ** |
argv |
|
) |
| |
References _app, _header, _packetReadInterval, _packetsize, _rejectPacketInterval, _tcpport, _udpport, nidas::core::NidasAppArg::acceptShortFlag(), nidas::core::NidasApp::allowUnrecognized(), nidas::core::NidasAppArgv::argc, nidas::core::NidasAppArgv::argv, nidas::core::NidasApp::DebugDaemon, nidas::core::NidasApp::enableArguments(), fclose(), fp, nidas::core::NidasApp::Help, nidas::core::NidasApp::helpRequested(), nidas::core::NidasApp::loggingArgs(), nidas::core::NidasApp::parseArgs(), usage(), nidas::core::NidasApp::Version, and nidas::util::Exception::what().
Referenced by main().
int PacketReader::usage |
( |
const char * |
argv0 | ) |
|
string PacketReader::_header |
|
private |
int PacketReader::_maxDsmId |
|
private |
unsigned int PacketReader::_maxSampleLength |
|
private |
long long PacketReader::_maxSampleTime |
|
private |
long long PacketReader::_minSampleTime |
|
private |
int PacketReader::_packetReadInterval |
|
private |
int PacketReader::_packetsize |
|
private |
size_t PacketReader::_rejectedPackets |
|
private |
int PacketReader::_rejectPacketInterval |
|
private |
int PacketReader::_tcpport |
|
private |
int PacketReader::_udpport |
|
private |
const int PacketReader::DEFAULT_PACKET_SIZE = 16384 |
|
staticprivate |
The documentation for this class was generated from the following file: