xrootd
Classes | Public Member Functions | Private Types | Private Member Functions | Private Attributes

XrdMonDecPacketDecoder Class Reference

#include <XrdMonDecPacketDecoder.hh>

Collaboration diagram for XrdMonDecPacketDecoder:
Collaboration graph
[legend]

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_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]

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]

References _sink, and XrdMonDecSink::addDictId().

Referenced by operator()().

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]

References _sink, and XrdMonDecSink::addStageInfo().

Referenced by operator()().

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]

References _sink, and XrdMonDecSink::addUserId().

Referenced by operator()().

CalcTime& XrdMonDecPacketDecoder::f ( ) [private]
void XrdMonDecPacketDecoder::flushHistoryData ( ) [inline]
void XrdMonDecPacketDecoder::flushRealTimeData ( ) [inline]
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 
)
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]

References _stopNow.

Referenced by doDecoding().


Member Data Documentation

Referenced by decodeTracePacket(), and stopNow().

Referenced by decodeTracePacket().


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