XrdMonDecPreProcess Class Reference

#include <XrdMonDecPreProcess.hh>

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

---

Detailed Description

Definition at line 31 of file XrdMonDecPreProcess.hh.

---

Member Enumeration Documentation

anonymous enum [private]

Definition at line 56 of file XrdMonDecPreProcess.hh.

---

Constructor & Destructor Documentation

XrdMonDecPreProcess::XrdMonDecPreProcess	(	fstream &	theFile,
		kXR_int64	fSize,
		sequen_t	lastSeq,
		kXR_int32	ignoreIfBefore,
		vector< pair< packetlen_t, kXR_int64 > > &	allPackets
	)

Definition at line 31 of file XrdMonDecPreProcess.cc.

---

Member Function Documentation

void XrdMonDecPreProcess::operator()

(

)

Definition at line 46 of file XrdMonDecPreProcess.cc.

References _allPackets, _file, _lostPackets, checkFile(), and reportAndThrowIfTooBad().

void XrdMonDecPreProcess::checkFile

(

)

[private]

Definition at line 61 of file XrdMonDecPreProcess.cc.

References _file, _fSize, and processOnePacket().

Referenced by operator()().

kXR_char XrdMonDecPreProcess::previousSeq

(

)

const [private]

Definition at line 190 of file XrdMonDecPreProcess.cc.

References _lastSeq, _tempBuf, _tempBufPos, i, and s.

Referenced by processOnePacket().

bool XrdMonDecPreProcess::outOfOrder

(

XrdMonDecOnePacket &

packet

)

[private]

Definition at line 206 of file XrdMonDecPreProcess.cc.

References _allPackets, _oooPackets, _tempBuf, _tempBufPos, XrdMonDecOnePacket::fPos(), XrdMonDecOnePacket::len(), XrdMonDecOnePacket::LOST, MAXTBUFELEM, and XrdMonDecOnePacket::seq().

Referenced by processOnePacket().

void XrdMonDecPreProcess::keepPacket

(

XrdMonDecOnePacket &

packet

)

[private]

Definition at line 163 of file XrdMonDecPreProcess.cc.

References _allPackets, add2TempBuf(), XrdMonDecOnePacket::fPos(), and XrdMonDecOnePacket::len().

Referenced by processOnePacket().

void XrdMonDecPreProcess::add2TempBuf

(

XrdMonDecOnePacket &

packet

)

[private]

Definition at line 172 of file XrdMonDecPreProcess.cc.

References _lostPackets, _tempBuf, _tempBufPos, i, MAXTBUFELEM, and TBUFSIZE.

Referenced by keepPacket().

int XrdMonDecPreProcess::processOnePacket	(	const char *	buf,
		int	bytesLeft,
		kXR_int64	fPos,
		kXR_int32 &	xrdStartTime
	)			[private]

Definition at line 95 of file XrdMonDecPreProcess.cc.

References _allPackets, _file, _fSize, _ignoreIfBefore, ERR_INTERNALERR, XrdMonDecOnePacket::init(), int, keepPacket(), XrdMonDecOnePacket::LOST, XrdMonDecOnePacket::myNr(), out, outOfOrder(), previousSeq(), XrdMonDecOnePacket::resetNextNr(), XrdMonDecOnePacket::seq(), XrdMonDecOnePacket::stod(), TBUFSIZE, and timestamp2string().

Referenced by checkFile().

void XrdMonDecPreProcess::reportAndThrowIfTooBad

(

)

[private]

Definition at line 235 of file XrdMonDecPreProcess.cc.

References _allPackets, _lostPackets, _oooPackets, double, ERR_TOOMANYLOST, i, XrdMonDecOnePacket::maxDictId(), XrdMonDecOnePacket::minDictId(), and out.

Referenced by operator()().

---

Member Data Documentation

fstream& XrdMonDecPreProcess::_file [private]

Definition at line 53 of file XrdMonDecPreProcess.hh.

Referenced by checkFile(), operator()(), and processOnePacket().

kXR_int64 XrdMonDecPreProcess::_fSize [private]

Definition at line 54 of file XrdMonDecPreProcess.hh.

Referenced by checkFile(), and processOnePacket().

XrdMonDecOnePacket XrdMonDecPreProcess::_tempBuf[TBUFSIZE] [private]

Definition at line 58 of file XrdMonDecPreProcess.hh.

Referenced by add2TempBuf(), outOfOrder(), and previousSeq().

short XrdMonDecPreProcess::_tempBufPos [private]

Definition at line 59 of file XrdMonDecPreProcess.hh.

Referenced by add2TempBuf(), outOfOrder(), and previousSeq().

bool XrdMonDecPreProcess::_markNextSlotAsSpecial [private]

Definition at line 60 of file XrdMonDecPreProcess.hh.

kXR_int32 XrdMonDecPreProcess::_ignoreIfBefore [private]

Definition at line 62 of file XrdMonDecPreProcess.hh.

Referenced by processOnePacket().

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

Definition at line 64 of file XrdMonDecPreProcess.hh.

Referenced by keepPacket(), operator()(), outOfOrder(), processOnePacket(), and reportAndThrowIfTooBad().

vector<int> XrdMonDecPreProcess::_lostPackets [private]

Definition at line 67 of file XrdMonDecPreProcess.hh.

Referenced by add2TempBuf(), operator()(), and reportAndThrowIfTooBad().

vector<int> XrdMonDecPreProcess::_oooPackets [private]

Definition at line 68 of file XrdMonDecPreProcess.hh.

Referenced by outOfOrder(), and reportAndThrowIfTooBad().

sequen_t XrdMonDecPreProcess::_lastSeq [private]

Definition at line 70 of file XrdMonDecPreProcess.hh.

Referenced by previousSeq().

---

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

• net/xrootd/src/xrootd/src/XrdMon/XrdMonDecPreProcess.hh
• net/xrootd/src/xrootd/src/XrdMon/XrdMonDecPreProcess.cc

---