xrootd
|
#include <XrdMonCtrArchiver.hh>
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 | |
static int | _decHDFlushDelay = -1 |
static 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) |
XrdMonCtrArchiver::XrdMonCtrArchiver | ( | const char * | cBaseDir, |
const char * | dBaseDir, | ||
const char * | rtLogDir, | ||
kXR_int64 | maxFileSize, | ||
int | ctrBufSize, | ||
int | rtBufSize, | ||
bool | onlineDec, | ||
bool | rtDec | ||
) |
XrdMonCtrArchiver::~XrdMonCtrArchiver | ( | ) |
References _decoder, _writers, XrdMonDecPacketDecoder::flushRealTimeData(), and XrdMonSenderInfo::shutdown().
void XrdMonCtrArchiver::archivePacket | ( | XrdMonCtrPacket * | p | ) | [private] |
References _currentTime, _decoder, _writers, XrdMonCtrPacket::buf, XrdMonSenderInfo::convert2Id(), XrdMonHeader::decode(), XrdMonCtrAdmin::decodeAdminPacket(), XrdMonCtrAdmin::doIt(), XrdMonSenderInfo::id2HostPortStr(), XrdMonCtrAdmin::isAdminPacket(), XrdMonCtrWriter::prevStod(), XrdMonDecPacketDecoder::reset(), XrdMonCtrPacket::sender, and XrdMonHeader::stod().
Referenced by operator()().
void XrdMonCtrArchiver::check4InactiveSenders | ( | ) | [private] |
References _currentTime, _heartbeat, _writers, gettimeofday(), XrdMonSenderInfo::id2HostPortStr(), MAX_INACTIVITY, and TIMESTAMP_FREQ.
Referenced by operator()().
void XrdMonCtrArchiver::operator() | ( | ) |
void* decHDFlushHeartBeat | ( | void * | arg | ) | [friend] |
Referenced by XrdMonCtrArchiver().
void* decRTFlushHeartBeat | ( | void * | arg | ) | [friend] |
Referenced by XrdMonCtrArchiver().
long XrdMonCtrArchiver::_currentTime [private] |
Referenced by archivePacket(), and check4InactiveSenders().
int XrdMonCtrArchiver::_decHDFlushDelay = -1 [static] |
Referenced by decHDFlushHeartBeat(), and main().
pthread_t XrdMonCtrArchiver::_decHDFlushThread [private] |
Referenced by XrdMonCtrArchiver().
Referenced by archivePacket(), XrdMonCtrArchiver(), and ~XrdMonCtrArchiver().
int XrdMonCtrArchiver::_decRTFlushDelay = -1 [static] |
Referenced by decRTFlushHeartBeat(), and main().
pthread_t XrdMonCtrArchiver::_decRTFlushThread [private] |
Referenced by XrdMonCtrArchiver().
int XrdMonCtrArchiver::_heartbeat [private] |
Referenced by check4InactiveSenders(), and operator()().
vector<XrdMonCtrWriter*> XrdMonCtrArchiver::_writers [private] |
Referenced by archivePacket(), check4InactiveSenders(), and ~XrdMonCtrArchiver().