xrootd
|
#include <XrdMonDecOnePacket.hh>
Public Types | |
enum | { REGULAR = 257, LOST = -1, OOO = -2, INVALID = -3 } |
Public Member Functions | |
XrdMonDecOnePacket () | |
XrdMonDecOnePacket (bool) | |
XrdMonDecOnePacket (int errType, kXR_int64 pos) | |
int | init (const char *buf, int bytesLeft, kXR_int64 fPos) |
long | myNr () const |
kXR_int64 | fPos () const |
kXR_int16 | seq () const |
dictid_t | dictId () const |
packetlen_t | len () const |
kXR_int32 | stod () const |
bool | isLost () const |
void | setOOOStatus () |
Static Public Member Functions | |
static dictid_t | minDictId () |
static dictid_t | maxDictId () |
static void | resetNextNr () |
Private Attributes | |
long | _myNr |
kXR_int64 | _fPos |
kXR_int16 | _seq |
dictid_t | _dictId |
packetlen_t | _len |
kXR_int32 | _stod |
Static Private Attributes | |
static long | _nextNr = 0 |
static dictid_t | _minDictId = 0 |
static dictid_t | _maxDictId = 0 |
Friends | |
ostream & | operator<< (ostream &o, const XrdMonDecOnePacket &p) |
XrdMonDecOnePacket::XrdMonDecOnePacket | ( | ) | [inline] |
XrdMonDecOnePacket::XrdMonDecOnePacket | ( | bool | ) |
XrdMonDecOnePacket::XrdMonDecOnePacket | ( | int | errType, |
kXR_int64 | pos | ||
) |
kXR_int64 XrdMonDecOnePacket::fPos | ( | ) | const [inline] |
References _fPos.
Referenced by init(), XrdMonDecPreProcess::keepPacket(), and XrdMonDecPreProcess::outOfOrder().
int XrdMonDecOnePacket::init | ( | const char * | buf, |
int | bytesLeft, | ||
kXR_int64 | fPos | ||
) |
References _dictId, _fPos, _len, _maxDictId, _minDictId, _myNr, _nextNr, _seq, _stod, XrdMonHeader::decode(), fPos(), HDRLEN, PACKET_TYPE_DICT, XrdMonHeader::packetLen(), XrdMonHeader::packetType(), XrdMonHeader::seqNo(), and XrdMonHeader::stod().
Referenced by XrdMonDecPreProcess::processOnePacket().
packetlen_t XrdMonDecOnePacket::len | ( | ) | const [inline] |
References _len.
Referenced by XrdMonDecPreProcess::keepPacket(), and XrdMonDecPreProcess::outOfOrder().
static dictid_t XrdMonDecOnePacket::maxDictId | ( | ) | [inline, static] |
References _maxDictId.
Referenced by doDecoding(), and XrdMonDecPreProcess::reportAndThrowIfTooBad().
static dictid_t XrdMonDecOnePacket::minDictId | ( | ) | [inline, static] |
References _minDictId.
Referenced by doDecoding(), and XrdMonDecPreProcess::reportAndThrowIfTooBad().
long XrdMonDecOnePacket::myNr | ( | ) | const [inline] |
References _myNr.
Referenced by XrdMonDecPreProcess::processOnePacket().
static void XrdMonDecOnePacket::resetNextNr | ( | ) | [inline, static] |
References _nextNr.
Referenced by XrdMonDecPreProcess::processOnePacket().
kXR_int16 XrdMonDecOnePacket::seq | ( | ) | const [inline] |
References _seq.
Referenced by XrdMonDecPreProcess::outOfOrder(), XrdMonDecPreProcess::previousSeq(), and XrdMonDecPreProcess::processOnePacket().
kXR_int32 XrdMonDecOnePacket::stod | ( | ) | const [inline] |
References _stod.
Referenced by XrdMonDecPreProcess::processOnePacket().
ostream& operator<< | ( | ostream & | o, |
const XrdMonDecOnePacket & | p | ||
) | [friend] |
dictid_t XrdMonDecOnePacket::_dictId [private] |
Referenced by dictId(), init(), and operator<<().
kXR_int64 XrdMonDecOnePacket::_fPos [private] |
Referenced by fPos(), init(), and operator<<().
packetlen_t XrdMonDecOnePacket::_len [private] |
dictid_t XrdMonDecOnePacket::_maxDictId = 0 [static, private] |
Referenced by init(), and maxDictId().
dictid_t XrdMonDecOnePacket::_minDictId = 0 [static, private] |
Referenced by init(), and minDictId().
long XrdMonDecOnePacket::_myNr [private] |
Referenced by init(), myNr(), and operator<<().
long XrdMonDecOnePacket::_nextNr = 0 [static, private] |
Referenced by init(), and resetNextNr().
kXR_int16 XrdMonDecOnePacket::_seq [private] |
Referenced by init(), isLost(), operator<<(), seq(), and setOOOStatus().
kXR_int32 XrdMonDecOnePacket::_stod [private] |