xrootd: XrdMonDecPreProcess Class Reference

xrootd

#include <XrdMonDecPreProcess.hh>

Collaboration diagram for XrdMonDecPreProcess:

Collaboration graph

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

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

Referenced by processOnePacket().

void XrdMonDecPreProcess::operator() ( )

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

bool XrdMonDecPreProcess::outOfOrder ( XrdMonDecOnePacket & packet )

private

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

Referenced by processOnePacket().

kXR_char XrdMonDecPreProcess::previousSeq ( ) const

private

References _lastSeq, _tempBuf, _tempBufPos, and XrdMonDecOnePacket::seq().

Referenced by processOnePacket().

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

private

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

Referenced by checkFile().

void XrdMonDecPreProcess::reportAndThrowIfTooBad ( )

private

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

Referenced by operator()().

Member Data Documentation

vector< pair<packetlen_t, kXR_int64> >& XrdMonDecPreProcess::_allPackets

private

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

fstream& XrdMonDecPreProcess::_file

private

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

kXR_int64 XrdMonDecPreProcess::_fSize

private

Referenced by checkFile(), and processOnePacket().

kXR_int32 XrdMonDecPreProcess::_ignoreIfBefore

private

Referenced by processOnePacket().

sequen_t XrdMonDecPreProcess::_lastSeq

private

Referenced by previousSeq().

vector<int> XrdMonDecPreProcess::_lostPackets

private

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

bool XrdMonDecPreProcess::_markNextSlotAsSpecial

private

vector<int> XrdMonDecPreProcess::_oooPackets

private

Referenced by outOfOrder(), and reportAndThrowIfTooBad().

XrdMonDecOnePacket XrdMonDecPreProcess::_tempBuf[TBUFSIZE]

private

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

short XrdMonDecPreProcess::_tempBufPos

private

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

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