xrootd
Public Member Functions | Private Types | Private Member Functions | Private Attributes

XrdMonDecPreProcess Class Reference

#include <XrdMonDecPreProcess.hh>

Collaboration diagram for XrdMonDecPreProcess:
Collaboration graph
[legend]

List of all members.

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

anonymous enum [private]
Enumerator:
TBUFSIZE 
MAXTBUFELEM 

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 _lostPackets, _tempBuf, _tempBufPos, MAXTBUFELEM, and TBUFSIZE.

Referenced by keepPacket().

void XrdMonDecPreProcess::checkFile ( ) [private]

References _file, _fSize, and processOnePacket().

Referenced by operator()().

void XrdMonDecPreProcess::keepPacket ( XrdMonDecOnePacket packet) [private]
void XrdMonDecPreProcess::operator() ( )
bool XrdMonDecPreProcess::outOfOrder ( XrdMonDecOnePacket packet) [private]
kXR_char XrdMonDecPreProcess::previousSeq ( ) const [private]
int XrdMonDecPreProcess::processOnePacket ( const char *  buf,
int  bytesLeft,
kXR_int64  fPos,
kXR_int32 xrdStartTime 
) [private]
void XrdMonDecPreProcess::reportAndThrowIfTooBad ( ) [private]

Member Data Documentation

fstream& XrdMonDecPreProcess::_file [private]

Referenced by checkFile(), and processOnePacket().

Referenced by processOnePacket().

Referenced by previousSeq().

vector<int> XrdMonDecPreProcess::_lostPackets [private]
vector<int> XrdMonDecPreProcess::_oooPackets [private]

The documentation for this class was generated from the following files: