Main Page | Namespace List | Class Hierarchy | Class List | Directories | File List | Namespace Members | Class Members | File Members

XrdMonCtrArchiver Class Reference

#include <XrdMonCtrArchiver.hh>

Collaboration diagram for XrdMonCtrArchiver:

Collaboration graph
[legend]
List of all members.

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)

Member Enumeration Documentation

anonymous enum [private]
 

Enumeration values:
TIMESTAMP_FREQ 
MAX_INACTIVITY 


Constructor & Destructor Documentation

XrdMonCtrArchiver::XrdMonCtrArchiver const char *  cBaseDir,
const char *  dBaseDir,
const char *  rtLogDir,
kXR_int64  maxFileSize,
int  ctrBufSize,
int  rtBufSize,
bool  onlineDec,
bool  rtDec
 

XrdMonCtrArchiver::~XrdMonCtrArchiver  ) 
 


Member Function Documentation

void XrdMonCtrArchiver::archivePacket XrdMonCtrPacket p  )  [private]
 

void XrdMonCtrArchiver::check4InactiveSenders  )  [private]
 

void XrdMonCtrArchiver::operator()  ) 
 


Friends And Related Function Documentation

void* decHDFlushHeartBeat void *  arg  )  [friend]
 

void* decRTFlushHeartBeat void *  arg  )  [friend]
 


Member Data Documentation

long XrdMonCtrArchiver::_currentTime [private]
 

int XrdMonCtrArchiver::_decHDFlushDelay = -1 [static]
 

pthread_t XrdMonCtrArchiver::_decHDFlushThread [private]
 

XrdMonDecPacketDecoder* XrdMonCtrArchiver::_decoder [private]
 

int XrdMonCtrArchiver::_decRTFlushDelay = -1 [static]
 

pthread_t XrdMonCtrArchiver::_decRTFlushThread [private]
 

int XrdMonCtrArchiver::_heartbeat [private]
 

vector<XrdMonCtrWriter*> XrdMonCtrArchiver::_writers [private]
 


The documentation for this class was generated from the following files:
Generated on Sun Nov 6 13:42:14 2011 for xrootd by  doxygen 1.3.9.1