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