XrdMonCtrArchiver Class Reference

#include <XrdMonCtrArchiver.hh>

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
static int	_decRTFlushDelay
Private Types
enum
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)

---

Detailed Description

Definition at line 32 of file XrdMonCtrArchiver.hh.

---

Member Enumeration Documentation

anonymous enum [private]

Definition at line 57 of file XrdMonCtrArchiver.hh.

---

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
	)

Definition at line 34 of file XrdMonCtrArchiver.cc.

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

XrdMonCtrArchiver::~XrdMonCtrArchiver

(

)

Definition at line 72 of file XrdMonCtrArchiver.cc.

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

---

Member Function Documentation

void XrdMonCtrArchiver::operator()

(

)

Definition at line 89 of file XrdMonCtrArchiver.cc.

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

void XrdMonCtrArchiver::check4InactiveSenders

(

)

[private]

Definition at line 154 of file XrdMonCtrArchiver.cc.

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

Referenced by operator()().

void XrdMonCtrArchiver::archivePacket

(

XrdMonCtrPacket *

p

)

[private]

Definition at line 174 of file XrdMonCtrArchiver.cc.

References _currentTime, _decoder, _writers, command, XrdMonSenderInfo::convert2Id(), XrdMonHeader::decode(), XrdMonCtrAdmin::decodeAdminPacket(), XrdMonCtrAdmin::doIt(), XrdMonSenderInfo::id2HostPortStr(), XrdMonCtrAdmin::isAdminPacket(), p, XrdMonDecPacketDecoder::reset(), and w.

Referenced by operator()().

---

Friends And Related Function Documentation

void* decHDFlushHeartBeat

(

void *

arg

)

[friend]

Definition at line 112 of file XrdMonCtrArchiver.cc.

Referenced by XrdMonCtrArchiver().

void* decRTFlushHeartBeat

(

void *

arg

)

[friend]

Definition at line 133 of file XrdMonCtrArchiver.cc.

Referenced by XrdMonCtrArchiver().

---

Member Data Documentation

int XrdMonCtrArchiver::_decHDFlushDelay [static]

Definition at line 45 of file XrdMonCtrArchiver.hh.

Referenced by decHDFlushHeartBeat(), and main().

int XrdMonCtrArchiver::_decRTFlushDelay [static]

Definition at line 47 of file XrdMonCtrArchiver.hh.

Referenced by decRTFlushHeartBeat(), and main().

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

Definition at line 61 of file XrdMonCtrArchiver.hh.

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

XrdMonDecPacketDecoder* XrdMonCtrArchiver::_decoder [private]

Definition at line 63 of file XrdMonCtrArchiver.hh.

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

pthread_t XrdMonCtrArchiver::_decHDFlushThread [private]

Definition at line 64 of file XrdMonCtrArchiver.hh.

Referenced by XrdMonCtrArchiver().

pthread_t XrdMonCtrArchiver::_decRTFlushThread [private]

Definition at line 65 of file XrdMonCtrArchiver.hh.

Referenced by XrdMonCtrArchiver().

long XrdMonCtrArchiver::_currentTime [private]

Definition at line 67 of file XrdMonCtrArchiver.hh.

Referenced by archivePacket(), and check4InactiveSenders().

int XrdMonCtrArchiver::_heartbeat [private]

Definition at line 68 of file XrdMonCtrArchiver.hh.

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

---

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

• net/xrootd/src/xrootd/src/XrdMon/XrdMonCtrArchiver.hh
• net/xrootd/src/xrootd/src/XrdMon/XrdMonCtrArchiver.cc

---