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 XrdMonCtrWriter::setBaseDir(), XrdMonCtrWriter::setMaxLogSize(), XrdMonCtrWriter::setBufferSize(), _decoder, _decHDFlushThread, decHDFlushHeartBeat, ERR_PTHREADCREATE, _decRTFlushThread, and decRTFlushHeartBeat.

XrdMonCtrArchiver::~XrdMonCtrArchiver ( )

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

Member Function Documentation

void XrdMonCtrArchiver::archivePacket ( XrdMonCtrPacket * p ) [private]

References XrdMonHeader::decode(), XrdMonCtrPacket::buf, XrdMonCtrAdmin::isAdminPacket(), XrdMonCtrAdmin::decodeAdminPacket(), XrdMonCtrAdmin::doIt(), XrdMonSenderInfo::convert2Id(), XrdMonCtrPacket::sender, _writers, XrdMonHeader::stod(), XrdMonCtrWriter::prevStod(), XrdMonSenderInfo::id2HostPortStr(), _decoder, XrdMonDecPacketDecoder::reset(), and _currentTime.

Referenced by operator()().

void XrdMonCtrArchiver::check4InactiveSenders ( ) [private]

References _heartbeat, TIMESTAMP_FREQ, gettimeofday(), _currentTime, MAX_INACTIVITY, _writers, and XrdMonSenderInfo::id2HostPortStr().

Referenced by operator()().

void XrdMonCtrArchiver::operator() ( )

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

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 check4InactiveSenders(), and archivePacket().

int XrdMonCtrArchiver::_decHDFlushDelay = -1 [static]

Referenced by decHDFlushHeartBeat().

pthread_t XrdMonCtrArchiver::_decHDFlushThread [private]

Referenced by XrdMonCtrArchiver().

XrdMonDecPacketDecoder* XrdMonCtrArchiver::_decoder [private]

Referenced by XrdMonCtrArchiver(), ~XrdMonCtrArchiver(), and archivePacket().

int XrdMonCtrArchiver::_decRTFlushDelay = -1 [static]

Referenced by decRTFlushHeartBeat().

pthread_t XrdMonCtrArchiver::_decRTFlushThread [private]

Referenced by XrdMonCtrArchiver().

int XrdMonCtrArchiver::_heartbeat [private]

Referenced by operator()(), and check4InactiveSenders().

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

Referenced by ~XrdMonCtrArchiver(), check4InactiveSenders(), and archivePacket().

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