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