|
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 |