xrootd
|
#include <XrdMonDecPacketDecoder.hh>
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 |
typedef pair<float, kXR_int32> XrdMonDecPacketDecoder::FloatTime [private] |
typedef pair<kXR_int32, kXR_int32> XrdMonDecPacketDecoder::TimePair [private] |
XrdMonDecPacketDecoder::XrdMonDecPacketDecoder | ( | const char * | baseDir, |
const char * | rtLogDir, | ||
int | rtBufSize | ||
) |
XrdMonDecPacketDecoder::XrdMonDecPacketDecoder | ( | const char * | baseDir, |
bool | saveTraces, | ||
int | maxTraceLogSize, | ||
kXR_int32 | upToTime | ||
) |
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] |
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] |
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().
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().
XrdMonDecSink XrdMonDecPacketDecoder::_sink [private] |
bool XrdMonDecPacketDecoder::_stopNow [private] |
Referenced by decodeTracePacket(), and stopNow().
kXR_int32 XrdMonDecPacketDecoder::_upToTime [private] |
Referenced by decodeTracePacket().