xrootd: XrdMonCtrArchiver Class Reference

xrootd

#include <XrdMonCtrArchiver.hh>

Collaboration diagram for XrdMonCtrArchiver:

Collaboration graph

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
static int	_decHDFlushDelay = -1
static int	_decRTFlushDelay = -1
Private Types
enum	{ TIMESTAMP_FREQ = 10000, MAX_INACTIVITY = 606024 }
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, gettimeofday(), 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: