#include <XrdMonCtrArchiver.hh>
Collaboration diagram for XrdMonCtrArchiver:

Public Member Functions | |
| XrdMonCtrArchiver (const char *cBaseDir, const char *dBaseDir, const char *rtLogDir, kXR_int64 maxFileSize, int ctrBufSize, int rtBufSize, bool onlineDec, bool rtDec) | |
| ~XrdMonCtrArchiver () | |
| void | operator() () |
Static Public Attributes | |
| int | _decHDFlushDelay = -1 |
| int | _decRTFlushDelay = -1 |
Private Types | |
| enum | { TIMESTAMP_FREQ = 10000, MAX_INACTIVITY = 60*60*24 } |
Private Member Functions | |
| void | check4InactiveSenders () |
| void | archivePacket (XrdMonCtrPacket *p) |
Private Attributes | |
| vector< XrdMonCtrWriter * > | _writers |
| XrdMonDecPacketDecoder * | _decoder |
| pthread_t | _decHDFlushThread |
| pthread_t | _decRTFlushThread |
| long | _currentTime |
| int | _heartbeat |
Friends | |
| void * | decHDFlushHeartBeat (void *arg) |
| void * | decRTFlushHeartBeat (void *arg) |
|
|
|
|
||||||||||||||||||||||||||||||||||||
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
1.3.9.1