Main Page | Namespace List | Class Hierarchy | Class List | Directories | File List | Namespace Members | Class Members | File Members

XrdMonDecPacketDecoder Class Reference

#include <XrdMonDecPacketDecoder.hh>

Collaboration diagram for XrdMonDecPacketDecoder:

Collaboration graph
[legend]
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_int32TimePair
typedef pair< float, kXR_int32FloatTime

Private Member Functions

CalcTimef ()
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]
 

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

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

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

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

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

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

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

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

CalcTime& XrdMonDecPacketDecoder::f  )  [private]
 

void XrdMonDecPacketDecoder::flushHistoryData  )  [inline]
 

void XrdMonDecPacketDecoder::flushRealTimeData  )  [inline]
 

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

sequen_t XrdMonDecPacketDecoder::lastSeq  )  const [inline]
 

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

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

void XrdMonDecPacketDecoder::reset senderid_t  senderId  ) 
 

bool XrdMonDecPacketDecoder::stopNow  )  const [inline]
 


Member Data Documentation

XrdMonDecSink XrdMonDecPacketDecoder::_sink [private]
 

bool XrdMonDecPacketDecoder::_stopNow [private]
 

kXR_int32 XrdMonDecPacketDecoder::_upToTime [private]
 


The documentation for this class was generated from the following files:
Generated on Sun Nov 6 13:37:06 2011 for xrootd by  doxygen 1.3.9.1