XrdMonDecPacketDecoder Class Reference

#include <XrdMonDecPacketDecoder.hh>

List of all members.

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

Classes

struct  CalcTime

Detailed Description

Definition at line 21 of file XrdMonDecPacketDecoder.hh.

Member Typedef Documentation

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

Definition at line 47 of file XrdMonDecPacketDecoder.hh.

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

Definition at line 59 of file XrdMonDecPacketDecoder.hh.

Constructor & Destructor Documentation

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

Definition at line 29 of file XrdMonDecPacketDecoder.cc.

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

Definition at line 37 of file XrdMonDecPacketDecoder.cc.

Member Function Documentation

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

Definition at line 47 of file XrdMonDecPacketDecoder.cc.

References _sink, and XrdMonDecSink::init().

Referenced by doDecoding().

sequen_t XrdMonDecPacketDecoder::lastSeq (  )  const [inline]

Definition at line 33 of file XrdMonDecPacketDecoder.hh.

References _sink, and XrdMonDecSink::lastSeq().

Referenced by doDecoding().

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

Definition at line 56 of file XrdMonDecPacketDecoder.cc.

References _sink, decodeDictPacket(), decodeStagePacket(), decodeTracePacket(), decodeUserPacket(), HDRLEN, len, 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().

void XrdMonDecPacketDecoder::reset ( senderid_t  senderId  ) 

Definition at line 98 of file XrdMonDecPacketDecoder.cc.

References _sink, and XrdMonDecSink::reset().

Referenced by XrdMonCtrArchiver::archivePacket().

bool XrdMonDecPacketDecoder::stopNow (  )  const [inline]

Definition at line 41 of file XrdMonDecPacketDecoder.hh.

References _stopNow.

Referenced by doDecoding().

void XrdMonDecPacketDecoder::flushHistoryData (  )  [inline]

Definition at line 43 of file XrdMonDecPacketDecoder.hh.

References _sink, and XrdMonDecSink::flushHistoryData().

Referenced by decHDFlushHeartBeat().

void XrdMonDecPacketDecoder::flushRealTimeData (  )  [inline]

Definition at line 44 of file XrdMonDecPacketDecoder.hh.

References _sink, and XrdMonDecSink::flushRealTimeData().

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

CalcTime& XrdMonDecPacketDecoder::f (  )  [private]

void XrdMonDecPacketDecoder::checkLostPackets ( const XrdMonHeader &  header  )  [private]

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

Definition at line 105 of file XrdMonDecPacketDecoder.cc.

References _stopNow, _upToTime, XrdMonDecPacketDecoder::CalcTime::begTimeNextWindow, buf, decodeClose(), decodeDisconnect(), decodeOpen(), decodeRWRequest(), decodeTime(), XrdMonDecPacketDecoder::CalcTime::endOffset, ERR_INVALIDINFOTYPE, ERR_NOTATIMEWINDOW, prepareTimestamp(), sprintf(), t, 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::decodeDictPacket ( const char *  packet,
int  packetLen,
senderid_t  senderId 
) [private]

Definition at line 154 of file XrdMonDecPacketDecoder.cc.

References _sink, and XrdMonDecSink::addDictId().

Referenced by operator()().

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

Definition at line 170 of file XrdMonDecPacketDecoder.cc.

References _sink, and XrdMonDecSink::addUserId().

Referenced by operator()().

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

Definition at line 186 of file XrdMonDecPacketDecoder.cc.

References _sink, and XrdMonDecSink::addStageInfo().

Referenced by operator()().

XrdMonDecPacketDecoder::TimePair XrdMonDecPacketDecoder::decodeTime ( const char *  packet  )  [private]

Definition at line 201 of file XrdMonDecPacketDecoder.cc.

References X, and x.

Referenced by decodeTracePacket(), and prepareTimestamp().

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

Definition at line 213 of file XrdMonDecPacketDecoder.cc.

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::decodeOpen ( const char *  packet,
kXR_int32  timestamp,
senderid_t  senderId 
) [private]

Definition at line 237 of file XrdMonDecPacketDecoder.cc.

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

Referenced by decodeTracePacket().

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

Definition at line 261 of file XrdMonDecPacketDecoder.cc.

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

Referenced by decodeTracePacket().

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

Definition at line 284 of file XrdMonDecPacketDecoder.cc.

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

Referenced by decodeTracePacket().

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

Definition at line 300 of file XrdMonDecPacketDecoder.cc.

References buf, decodeTime(), ERR_NOTATIMEWINDOW, sprintf(), t, TRACELEN, x, and XROOTD_MON_WINDOW.

Referenced by decodeTracePacket().

Member Data Documentation

XrdMonDecSink XrdMonDecPacketDecoder::_sink [private]

Definition at line 95 of file XrdMonDecPacketDecoder.hh.

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

bool XrdMonDecPacketDecoder::_stopNow [private]

Definition at line 96 of file XrdMonDecPacketDecoder.hh.

Referenced by decodeTracePacket(), and stopNow().

kXR_int32 XrdMonDecPacketDecoder::_upToTime [private]

Definition at line 98 of file XrdMonDecPacketDecoder.hh.

Referenced by decodeTracePacket().

The documentation for this class was generated from the following files:
Generated on Tue Jul 5 16:50:35 2011 for ROOT_528-00b_version by  doxygen 1.5.1