XrdMonCtrArchiver Class Reference

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

Member Enumeration Documentation

anonymous enum

private

Enumerator:

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
	)

References _decHDFlushThread, _decoder, _decRTFlushThread, decHDFlushHeartBeat, decRTFlushHeartBeat, ERR_PTHREADCREATE, XrdMonCtrWriter::setBaseDir(), XrdMonCtrWriter::setBufferSize(), and XrdMonCtrWriter::setMaxLogSize().

XrdMonCtrArchiver::~XrdMonCtrArchiver

(

)

References _decoder, _writers, XrdMonDecPacketDecoder::flushRealTimeData(), and XrdMonSenderInfo::shutdown().

Member Function Documentation

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, XrdMonSenderInfo::id2HostPortStr(), MAX_INACTIVITY, and TIMESTAMP_FREQ.

Referenced by operator()().

void XrdMonCtrArchiver::operator()

(

)

References _heartbeat, archivePacket(), check4InactiveSenders(), XrdMonException::err(), XrdMonCtrBuffer::instance(), XrdMonCtrBuffer::pop_front(), XrdMonException::printItOnce(), and SIG_SHUTDOWNNOW.

Friends And Related Function Documentation

void* decHDFlushHeartBeat ( void *  arg )

friend

Referenced by XrdMonCtrArchiver().

void* decRTFlushHeartBeat ( void *  arg )

friend

Referenced by XrdMonCtrArchiver().

Member Data Documentation

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().

XrdMonDecPacketDecoder* XrdMonCtrArchiver::_decoder

private

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().

---

The documentation for this class was generated from the following files:

• XrdMonCtrArchiver.hh
• XrdMonCtrArchiver.cc