#include <XrdMonDecPreProcess.hh>
Public Member Functions | |
| XrdMonDecPreProcess (fstream &theFile, kXR_int64 fSize, sequen_t lastSeq, kXR_int32 ignoreIfBefore, vector< pair< packetlen_t, kXR_int64 > > &allPackets) | |
| void | operator() () |
Private Types | |
| enum | { TBUFSIZE = 20, MAXTBUFELEM = TBUFSIZE-1 } |
Private Member Functions | |
| void | checkFile () |
| kXR_char | previousSeq () const |
| bool | outOfOrder (XrdMonDecOnePacket &packet) |
| void | keepPacket (XrdMonDecOnePacket &packet) |
| void | add2TempBuf (XrdMonDecOnePacket &packet) |
| int | processOnePacket (const char *buf, int bytesLeft, kXR_int64 fPos, kXR_int32 &xrdStartTime) |
| void | reportAndThrowIfTooBad () |
Private Attributes | |
| fstream & | _file |
| kXR_int64 | _fSize |
| XrdMonDecOnePacket | _tempBuf [TBUFSIZE] |
| short | _tempBufPos |
| bool | _markNextSlotAsSpecial |
| kXR_int32 | _ignoreIfBefore |
| vector< pair< packetlen_t, kXR_int64 > > & | _allPackets |
| vector< int > | _lostPackets |
| vector< int > | _oooPackets |
| sequen_t | _lastSeq |
Member Enumeration Documentation
Constructor & Destructor Documentation
| XrdMonDecPreProcess::XrdMonDecPreProcess | ( | fstream & | theFile, |
| kXR_int64 | fSize, | ||
| sequen_t | lastSeq, | ||
| kXR_int32 | ignoreIfBefore, | ||
| vector< pair< packetlen_t, kXR_int64 > > & | allPackets | ||
| ) |
Member Function Documentation
| void XrdMonDecPreProcess::add2TempBuf | ( | XrdMonDecOnePacket & | packet | ) | [private] |
References _tempBufPos, MAXTBUFELEM, _tempBuf, _lostPackets, and TBUFSIZE.
Referenced by keepPacket().
| void XrdMonDecPreProcess::checkFile | ( | ) | [private] |
References _fSize, _file, and processOnePacket().
Referenced by operator()().
| void XrdMonDecPreProcess::keepPacket | ( | XrdMonDecOnePacket & | packet | ) | [private] |
References _allPackets, XrdMonDecOnePacket::len(), XrdMonDecOnePacket::fPos(), and add2TempBuf().
Referenced by processOnePacket().
| void XrdMonDecPreProcess::operator() | ( | ) |
References _allPackets, _lostPackets, _file, checkFile(), and reportAndThrowIfTooBad().
| bool XrdMonDecPreProcess::outOfOrder | ( | XrdMonDecOnePacket & | packet | ) | [private] |
References _tempBufPos, _tempBuf, XrdMonDecOnePacket::LOST, XrdMonDecOnePacket::seq(), _allPackets, MAXTBUFELEM, XrdMonDecOnePacket::len(), XrdMonDecOnePacket::fPos(), and _oooPackets.
Referenced by processOnePacket().
| kXR_char XrdMonDecPreProcess::previousSeq | ( | ) | const [private] |
References _tempBufPos, _lastSeq, _tempBuf, and XrdMonDecOnePacket::seq().
Referenced by processOnePacket().
| int XrdMonDecPreProcess::processOnePacket | ( | const char * | buf, |
| int | bytesLeft, | ||
| kXR_int64 | fPos, | ||
| kXR_int32 & | xrdStartTime | ||
| ) | [private] |
References XrdMonDecOnePacket::init(), XrdMonDecOnePacket::stod(), _ignoreIfBefore, XrdMonDecOnePacket::resetNextNr(), XrdMonDecOnePacket::myNr(), timestamp2string(), ERR_INTERNALERR, _file, _fSize, _allPackets, previousSeq(), XrdMonDecOnePacket::seq(), keepPacket(), TBUFSIZE, outOfOrder(), and XrdMonDecOnePacket::LOST.
Referenced by checkFile().
| void XrdMonDecPreProcess::reportAndThrowIfTooBad | ( | ) | [private] |
References _lostPackets, _oooPackets, _allPackets, XrdMonDecOnePacket::minDictId(), XrdMonDecOnePacket::maxDictId(), and ERR_TOOMANYLOST.
Referenced by operator()().
Member Data Documentation
vector< pair<packetlen_t, kXR_int64> >& XrdMonDecPreProcess::_allPackets [private] |
Referenced by operator()(), processOnePacket(), keepPacket(), outOfOrder(), and reportAndThrowIfTooBad().
fstream& XrdMonDecPreProcess::_file [private] |
Referenced by operator()(), checkFile(), and processOnePacket().
kXR_int64 XrdMonDecPreProcess::_fSize [private] |
Referenced by checkFile(), and processOnePacket().
Referenced by processOnePacket().
sequen_t XrdMonDecPreProcess::_lastSeq [private] |
Referenced by previousSeq().
vector<int> XrdMonDecPreProcess::_lostPackets [private] |
Referenced by operator()(), add2TempBuf(), and reportAndThrowIfTooBad().
bool XrdMonDecPreProcess::_markNextSlotAsSpecial [private] |
vector<int> XrdMonDecPreProcess::_oooPackets [private] |
Referenced by outOfOrder(), and reportAndThrowIfTooBad().
XrdMonDecOnePacket XrdMonDecPreProcess::_tempBuf[TBUFSIZE] [private] |
Referenced by add2TempBuf(), previousSeq(), and outOfOrder().
short XrdMonDecPreProcess::_tempBufPos [private] |
Referenced by add2TempBuf(), previousSeq(), and outOfOrder().
The documentation for this class was generated from the following files:
