xrootd: XrdMonCtrWriter Class Reference

xrootd

#include <XrdMonCtrWriter.hh>

Collaboration diagram for XrdMonCtrWriter:

Collaboration graph

Public Member Functions
	XrdMonCtrWriter (senderid_t senderId, kXR_int32 stod)

	~XrdMonCtrWriter ()

void	operator() (const char *packet, const XrdMonHeader &header, long currentTime)

kXR_int32	prevStod () const

void	forceClose ()

long	lastActivity () const

Static Public Member Functions
static void	setBaseDir (const char *dir)

static void	setMaxLogSize (kXR_int64 size)

static void	setBufferSize (int size)

Private Types
enum	LogType { ACTIVE, PERMANENT }

Private Member Functions
bool	logIsOpen ()

bool	logIsFull ()

bool	bufferIsFull (packetlen_t x)

string	logName (LogType t) const

void	mkActiveLogNameDirs () const

void	flushBuffer ()

void	openLog ()

void	closeLog ()

void	publish ()

Private Attributes
kXR_int32	_prevStod

string	_timestamp

hp_t	_sender

char *	_buffer

kXR_int32	_bPos

fstream	_file

long	_lastActivity

Static Private Attributes
static string	_baseDir

static kXR_int64	_maxLogSize

static int	_bufferSize

static long	_totalArchived

Friends
ostream &	operator<< (ostream &o, const XrdMonCtrWriter &w)

Member Enumeration Documentation

enum XrdMonCtrWriter::LogType

private

Enumerator
ACTIVE
PERMANENT

Constructor & Destructor Documentation

XrdMonCtrWriter::XrdMonCtrWriter	(	senderid_t	senderId,
		kXR_int32	stod
	)

References _bufferSize, _sender, _timestamp, generateTimestamp(), and XrdMonSenderInfo::id2HostPort().

XrdMonCtrWriter::~XrdMonCtrWriter ( )

References _buffer, closeLog(), flushBuffer(), and publish().

Member Function Documentation

bool XrdMonCtrWriter::bufferIsFull ( packetlen_t x )

inlineprivate

References _bPos, and _bufferSize.

Referenced by operator()().

void XrdMonCtrWriter::closeLog ( )

private

References _file.

Referenced by flushBuffer(), and ~XrdMonCtrWriter().

void XrdMonCtrWriter::flushBuffer ( )

private

References _bPos, _buffer, _bufferSize, _file, closeLog(), logIsFull(), logIsOpen(), openLog(), and publish().

Referenced by operator()(), and ~XrdMonCtrWriter().

void XrdMonCtrWriter::forceClose ( )

long XrdMonCtrWriter::lastActivity ( ) const

inline

References _lastActivity.

bool XrdMonCtrWriter::logIsFull ( )

inlineprivate

References _file, and _maxLogSize.

Referenced by flushBuffer().

bool XrdMonCtrWriter::logIsOpen ( )

inlineprivate

References _file.

Referenced by flushBuffer().

string XrdMonCtrWriter::logName ( LogType t ) const

private

References _baseDir, _sender, _timestamp, ACTIVE, ERR_INVALIDARG, and PERMANENT.

Referenced by openLog(), and publish().

void XrdMonCtrWriter::mkActiveLogNameDirs ( ) const

private

References _baseDir, _sender, and mkdirIfNecessary().

Referenced by openLog().

void XrdMonCtrWriter::openLog ( )

private

References _file, ACTIVE, logName(), and mkActiveLogNameDirs().

Referenced by flushBuffer().

void XrdMonCtrWriter::operator()	(	const char *	packet,
		const XrdMonHeader &	header,
		long	currentTime
	)

References _bPos, _buffer, _bufferSize, _lastActivity, XrdMonCtrDebug::_mutex, bufferIsFull(), ERR_NOMEM, flushBuffer(), XrdSysMutexHelper::Lock(), XrdMonHeader::packetLen(), XrdMonCtrDebug::Receiving, and XrdMonCtrDebug::verbose().

kXR_int32 XrdMonCtrWriter::prevStod ( ) const

inline

References _prevStod.

Referenced by XrdMonCtrArchiver::archivePacket().

void XrdMonCtrWriter::publish ( )

private

References _bPos, _timestamp, access(), ACTIVE, ERR_RENAME, generateTimestamp(), logName(), PERMANENT, and rename().

Referenced by flushBuffer(), and ~XrdMonCtrWriter().

static void XrdMonCtrWriter::setBaseDir ( const char * dir )

inlinestatic

References _baseDir.

Referenced by XrdMonCtrArchiver::XrdMonCtrArchiver().

static void XrdMonCtrWriter::setBufferSize ( int size )

inlinestatic

References _bufferSize.

Referenced by XrdMonCtrArchiver::XrdMonCtrArchiver().

static void XrdMonCtrWriter::setMaxLogSize ( kXR_int64 size )

inlinestatic

References _maxLogSize.

Referenced by XrdMonCtrArchiver::XrdMonCtrArchiver().

Friends And Related Function Documentation

ostream& operator<<	(	ostream &	o,
		const XrdMonCtrWriter &	w
	)

friend

Member Data Documentation

string XrdMonCtrWriter::_baseDir

staticprivate

Referenced by logName(), mkActiveLogNameDirs(), and setBaseDir().

kXR_int32 XrdMonCtrWriter::_bPos

private

Referenced by bufferIsFull(), flushBuffer(), operator()(), and publish().

char* XrdMonCtrWriter::_buffer

private

Referenced by flushBuffer(), operator()(), and ~XrdMonCtrWriter().

kXR_int32 XrdMonCtrWriter::_bufferSize

staticprivate

Referenced by bufferIsFull(), flushBuffer(), operator()(), setBufferSize(), and XrdMonCtrWriter().

fstream XrdMonCtrWriter::_file

private

Referenced by closeLog(), flushBuffer(), logIsFull(), logIsOpen(), and openLog().

long XrdMonCtrWriter::_lastActivity

private

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

kXR_int64 XrdMonCtrWriter::_maxLogSize

staticprivate

Referenced by logIsFull(), and setMaxLogSize().

kXR_int32 XrdMonCtrWriter::_prevStod

private

Referenced by prevStod().

hp_t XrdMonCtrWriter::_sender

private

Referenced by logName(), mkActiveLogNameDirs(), operator<<(), and XrdMonCtrWriter().

string XrdMonCtrWriter::_timestamp

private

Referenced by logName(), publish(), and XrdMonCtrWriter().

long XrdMonCtrWriter::_totalArchived

staticprivate

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