Main Page | Namespace List | Class Hierarchy | Class List | Directories | File List | Namespace Members | Class Members | File Members

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]
 

Enumeration values:
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]
 

void XrdMonDecPreProcess::checkFile  )  [private]
 

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

vector< pair<packetlen_t, kXR_int64> >& XrdMonDecPreProcess::_allPackets [private]
 

fstream& XrdMonDecPreProcess::_file [private]
 

kXR_int64 XrdMonDecPreProcess::_fSize [private]
 

kXR_int32 XrdMonDecPreProcess::_ignoreIfBefore [private]
 

sequen_t XrdMonDecPreProcess::_lastSeq [private]
 

vector<int> XrdMonDecPreProcess::_lostPackets [private]
 

bool XrdMonDecPreProcess::_markNextSlotAsSpecial [private]
 

vector<int> XrdMonDecPreProcess::_oooPackets [private]
 

XrdMonDecOnePacket XrdMonDecPreProcess::_tempBuf[TBUFSIZE] [private]
 

short XrdMonDecPreProcess::_tempBufPos [private]
 


The documentation for this class was generated from the following files:
Generated on Sun Nov 6 13:37:06 2011 for xrootd by  doxygen 1.3.9.1