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