XrdMonDecPacketDecoder Class Reference

#include <XrdMonDecPacketDecoder.hh>

Collaboration diagram for XrdMonDecPacketDecoder:

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