XrdMonDecPacketDecoder Class Reference

#include <XrdMonDecPacketDecoder.hh>

Collaboration diagram for XrdMonDecPacketDecoder:

List of all members.

Classes
struct	CalcTime
Public Member Functions
	XrdMonDecPacketDecoder (const char *baseDir, const char *rtLogDir, int rtBufSize)
	XrdMonDecPacketDecoder (const char *baseDir, bool saveTraces, int maxTraceLogSize, kXR_int32 upToTime)
void	init (dictid_t min, dictid_t max, const string &senderHP)
sequen_t	lastSeq () const
void	operator() (const XrdMonHeader &header, const char *packet, senderid_t senderId=INVALID_SENDER_ID)
void	reset (senderid_t senderId)
bool	stopNow () const
void	flushHistoryData ()
void	flushRealTimeData ()
Private Types
typedef pair< kXR_int32, kXR_int32 >	TimePair
typedef pair< float, kXR_int32 >	FloatTime
Private Member Functions
CalcTime &	f ()
void	checkLostPackets (const XrdMonHeader &header)
void	decodeTracePacket (const char *packet, int packetLen, senderid_t senderId)
void	decodeDictPacket (const char *packet, int packetLen, senderid_t senderId)
void	decodeUserPacket (const char *packet, int packetLen, senderid_t senderId)
void	decodeStagePacket (const char *packet, int packetLen, senderid_t senderId)
TimePair	decodeTime (const char *packet)
void	decodeRWRequest (const char *packet, kXR_int32 timestamp, senderid_t senderId)
void	decodeOpen (const char *packet, kXR_int32 timestamp, senderid_t senderId)
void	decodeClose (const char *packet, kXR_int32 timestamp, senderid_t senderId)
void	decodeDisconnect (const char *packet, kXR_int32 timestamp, senderid_t senderId)
CalcTime	prepareTimestamp (const char *packet, int &offset, int len, kXR_int32 &begTime)
Private Attributes
XrdMonDecSink	_sink
bool	_stopNow
kXR_int32	_upToTime

---

Member Typedef Documentation

typedef pair<float, kXR_int32> XrdMonDecPacketDecoder::FloatTime [private]

typedef pair<kXR_int32, kXR_int32> XrdMonDecPacketDecoder::TimePair [private]

---

Constructor & Destructor Documentation

XrdMonDecPacketDecoder::XrdMonDecPacketDecoder	(	const char *	baseDir,
		const char *	rtLogDir,
		int	rtBufSize
	)

XrdMonDecPacketDecoder::XrdMonDecPacketDecoder	(	const char *	baseDir,
		bool	saveTraces,
		int	maxTraceLogSize,
		kXR_int32	upToTime
	)

---

Member Function Documentation

void XrdMonDecPacketDecoder::checkLostPackets

(

const XrdMonHeader &

header

)

[private]

void XrdMonDecPacketDecoder::decodeClose	(	const char *	packet,
		kXR_int32	timestamp,
		senderid_t	senderId
	)		[private]

References _sink, XrdXrootdMonTrace::arg0, XrdXrootdMonTrace::arg1, XrdXrootdMonTrace::arg2, XrdMonDecSink::closeFile(), XrdXrootdMonTrace::dictid, XrdXrootdMonTrace::id, XrdXrootdMonTrace::rTot, and XrdXrootdMonTrace::wTot.

Referenced by decodeTracePacket().

void XrdMonDecPacketDecoder::decodeDictPacket	(	const char *	packet,
		int	packetLen,
		senderid_t	senderId
	)		[private]

References _sink, and XrdMonDecSink::addDictId().

Referenced by operator()().

void XrdMonDecPacketDecoder::decodeDisconnect	(	const char *	packet,
		kXR_int32	timestamp,
		senderid_t	senderId
	)		[private]

References _sink, XrdMonDecSink::addUserDisconnect(), XrdXrootdMonTrace::arg1, XrdXrootdMonTrace::arg2, XrdXrootdMonTrace::buflen, and XrdXrootdMonTrace::dictid.

Referenced by decodeTracePacket().

void XrdMonDecPacketDecoder::decodeOpen	(	const char *	packet,
		kXR_int32	timestamp,
		senderid_t	senderId
	)		[private]

References _sink, XrdXrootdMonTrace::arg0, XrdXrootdMonTrace::arg2, XrdXrootdMonTrace::dictid, XrdMonDecSink::openFile(), and XrdXrootdMonTrace::val.

Referenced by decodeTracePacket().

void XrdMonDecPacketDecoder::decodeRWRequest	(	const char *	packet,
		kXR_int32	timestamp,
		senderid_t	senderId
	)		[private]

References _sink, XrdMonDecSink::add(), XrdXrootdMonTrace::arg0, XrdXrootdMonTrace::arg1, XrdXrootdMonTrace::arg2, XrdXrootdMonTrace::buflen, XrdXrootdMonTrace::dictid, ERR_NEGATIVEOFFSET, ntohll, and XrdXrootdMonTrace::val.

Referenced by decodeTracePacket().

void XrdMonDecPacketDecoder::decodeStagePacket	(	const char *	packet,
		int	packetLen,
		senderid_t	senderId
	)		[private]

References _sink, and XrdMonDecSink::addStageInfo().

Referenced by operator()().

XrdMonDecPacketDecoder::TimePair XrdMonDecPacketDecoder::decodeTime

(

const char *

packet

)

[private]

Referenced by decodeTracePacket(), and prepareTimestamp().

void XrdMonDecPacketDecoder::decodeTracePacket	(	const char *	packet,
		int	packetLen,
		senderid_t	senderId
	)		[private]

References _stopNow, _upToTime, XrdMonDecPacketDecoder::CalcTime::begTimeNextWindow, decodeClose(), decodeDisconnect(), decodeOpen(), decodeRWRequest(), decodeTime(), XrdMonDecPacketDecoder::CalcTime::endOffset, ERR_INVALIDINFOTYPE, ERR_NOTATIMEWINDOW, prepareTimestamp(), XrdMonDecPacketDecoder::CalcTime::timePerTrace, TRACELEN, XROOTD_MON_CLOSE, XROOTD_MON_DISC, XROOTD_MON_OPEN, XROOTD_MON_RWREQUESTMASK, and XROOTD_MON_WINDOW.

Referenced by operator()().

void XrdMonDecPacketDecoder::decodeUserPacket	(	const char *	packet,
		int	packetLen,
		senderid_t	senderId
	)		[private]

References _sink, and XrdMonDecSink::addUserId().

Referenced by operator()().

CalcTime& XrdMonDecPacketDecoder::f

(

)

[private]

void XrdMonDecPacketDecoder::flushHistoryData

(

)

[inline]

References _sink, and XrdMonDecSink::flushHistoryData().

Referenced by decHDFlushHeartBeat().

void XrdMonDecPacketDecoder::flushRealTimeData

(

)

[inline]

References _sink, and XrdMonDecSink::flushRealTimeData().

Referenced by decRTFlushHeartBeat(), and XrdMonCtrArchiver::~XrdMonCtrArchiver().

void XrdMonDecPacketDecoder::init	(	dictid_t	min,
		dictid_t	max,
		const string &	senderHP
	)

References _sink, and XrdMonDecSink::init().

Referenced by doDecoding().

sequen_t XrdMonDecPacketDecoder::lastSeq

(

)

const [inline]

References _sink, and XrdMonDecSink::lastSeq().

Referenced by doDecoding().

void XrdMonDecPacketDecoder::operator()	(	const XrdMonHeader &	header,
		const char *	packet,
		senderid_t	senderId = INVALID_SENDER_ID
	)

References _sink, decodeDictPacket(), decodeStagePacket(), decodeTracePacket(), decodeUserPacket(), HDRLEN, PACKET_TYPE_DICT, PACKET_TYPE_STAGE, PACKET_TYPE_TRACE, PACKET_TYPE_USER, XrdMonHeader::packetLen(), XrdMonHeader::packetType(), XrdMonDecSink::registerXrdRestart(), XrdMonHeader::seqNo(), XrdMonDecSink::setLastSeq(), XrdMonHeader::stod(), and XrdMonHeader::stodChanged().

XrdMonDecPacketDecoder::CalcTime XrdMonDecPacketDecoder::prepareTimestamp	(	const char *	packet,
		int &	offset,
		int	len,
		kXR_int32 &	begTime
	)		[private]

References decodeTime(), ERR_NOTATIMEWINDOW, TRACELEN, and XROOTD_MON_WINDOW.

Referenced by decodeTracePacket().

void XrdMonDecPacketDecoder::reset

(

senderid_t

senderId

)

References _sink, and XrdMonDecSink::reset().

Referenced by XrdMonCtrArchiver::archivePacket().

bool XrdMonDecPacketDecoder::stopNow

(

)

const [inline]

References _stopNow.

Referenced by doDecoding().

---

Member Data Documentation

XrdMonDecSink XrdMonDecPacketDecoder::_sink [private]

Referenced by decodeClose(), decodeDictPacket(), decodeDisconnect(), decodeOpen(), decodeRWRequest(), decodeStagePacket(), decodeUserPacket(), flushHistoryData(), flushRealTimeData(), init(), lastSeq(), operator()(), and reset().

bool XrdMonDecPacketDecoder::_stopNow [private]

Referenced by decodeTracePacket(), and stopNow().

kXR_int32 XrdMonDecPacketDecoder::_upToTime [private]

Referenced by decodeTracePacket().

---

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

• XrdMonDecPacketDecoder.hh
• XrdMonDecPacketDecoder.cc