XrdXrootdMonitor Class Reference

#include <XrdXrootdMonitor.hh>

Collaboration diagram for XrdXrootdMonitor:

List of all members.

Public Member Functions
void	Add_rd (kXR_unt32 dictid, kXR_int32 rlen, kXR_int64 offset)
void	Add_rv (kXR_unt32 dictid, kXR_int32 rlen, kXR_int16 vcnt, kXR_char vseq)
void	Add_wr (kXR_unt32 dictid, kXR_int32 wlen, kXR_int64 offset)
void	appID (char *id)
void	Close (kXR_unt32 dictid, long long rTot, long long wTot)
void	Disc (kXR_unt32 dictid, int csec)
void	Dup (XrdXrootdMonTrace *mrec)
void	Open (kXR_unt32 dictid, off_t fsize)
	XrdXrootdMonitor ()
Static Public Member Functions
static XrdXrootdMonitor *	Alloc (int force=0)
static void	Defaults (char *dest1, int m1, char *dest2, int m2)
static void	Defaults (int msz, int rsz, int wsz, int flush, int flash)
static int	Init (XrdScheduler *sp, XrdSysError *errp)
static kXR_unt32	Map (const char code, const char *uname, const char *path)
static time_t	Tick ()
static void	unAlloc (XrdXrootdMonitor *monp)
Static Public Attributes
static XrdXrootdMonitor *	altMon = 0
static char	monIO = 0
static char	monINFO = 0
static char	monFILE = 0
static char	monREDR = 0
static char	monSTAGE = 0
static char	monUSER = 0
static char	monAUTH = 0
Private Member Functions
	~XrdXrootdMonitor ()
void	Add_io (kXR_unt32 dictid, kXR_int32 buflen, kXR_int64 offset)
unsigned char	do_Shift (long long xTot, unsigned int &xVal)
void	Flush ()
void	Mark ()
Static Private Member Functions
static void	fillHeader (XrdXrootdMonHeader *hdr, const char id, int size)
static int	Send (int mmode, void *buff, int size)
static void	startClock ()
Private Attributes
XrdXrootdMonBuff *	monBuff
int	nextEnt
kXR_int32	lastWindow
Static Private Attributes
static XrdScheduler *	Sched = 0
static XrdSysError *	eDest = 0
static XrdSysMutex	windowMutex
static int	monFD
static char *	Dest1 = 0
static int	monMode1 = 0
static struct sockaddr	InetAddr1
static char *	Dest2 = 0
static int	monMode2 = 0
static struct sockaddr	InetAddr2
static int	monBlen = 0
static int	lastEnt = 0
static int	autoFlash = 0
static int	autoFlush = 600
static int	FlushTime = 0
static kXR_int32	startTime = 0
static kXR_int32	currWindow = 0
static kXR_int32	sizeWindow = 60
static int	isEnabled = 0
static int	numMonitor = 0
static int	monRlen = 0
Friends
class	XrdXrootdMonitorDummy

---

Constructor & Destructor Documentation

XrdXrootdMonitor::XrdXrootdMonitor

(

)

References windowMutex, XrdSysMutex::Lock(), currWindow, XrdSysMutex::UnLock(), monBuff, memalign, monBlen, eDest, XrdSysError::Emsg(), nextEnt, XrdXrootdMonBuff::info, XrdXrootdMonTrace::arg0, XrdXrootdMonTrace::rTot, XrdXrootdMonTrace::id, XROOTD_MON_WINDOW, XrdXrootdMonTrace::arg1, XrdXrootdMonTrace::Window, and XrdXrootdMonTrace::arg2.

Referenced by Alloc(), and Init().

XrdXrootdMonitor::~XrdXrootdMonitor

(

)

[private]

References monBuff, and Flush().

---

Member Function Documentation

void XrdXrootdMonitor::Add_io	(	kXR_unt32	dictid,
		kXR_int32	buflen,
		kXR_int64	offset
	)		[inline, private]

References lastWindow, currWindow, Mark(), nextEnt, lastEnt, Flush(), monBuff, XrdXrootdMonBuff::info, XrdXrootdMonTrace::arg0, XrdXrootdMonTrace::val, XrdXrootdMonTrace::arg1, XrdXrootdMonTrace::buflen, XrdXrootdMonTrace::arg2, and XrdXrootdMonTrace::dictid.

Referenced by Add_rd(), and Add_wr().

void XrdXrootdMonitor::Add_rd	(	kXR_unt32	dictid,
		kXR_int32	rlen,
		kXR_int64	offset
	)		[inline]

References Add_io().

Referenced by XrdXrootdProtocol::do_Read(), and XrdXrootdProtocol::do_ReadV().

void XrdXrootdMonitor::Add_rv	(	kXR_unt32	dictid,
		kXR_int32	rlen,
		kXR_int16	vcnt,
		kXR_char	vseq
	)		[inline]

References lastWindow, currWindow, Mark(), nextEnt, lastEnt, Flush(), monBuff, XrdXrootdMonBuff::info, XrdXrootdMonTrace::arg0, XrdXrootdMonTrace::id, XROOTD_MON_READV, XrdXrootdMonTrace::sVal, XrdXrootdMonTrace::rTot, XrdXrootdMonTrace::arg1, XrdXrootdMonTrace::buflen, XrdXrootdMonTrace::arg2, and XrdXrootdMonTrace::dictid.

Referenced by XrdXrootdProtocol::do_ReadV().

void XrdXrootdMonitor::Add_wr	(	kXR_unt32	dictid,
		kXR_int32	wlen,
		kXR_int64	offset
	)		[inline]

References Add_io().

Referenced by XrdXrootdProtocol::do_Write().

XrdXrootdMonitor * XrdXrootdMonitor::Alloc

(

int

force = 0

)

[static]

References isEnabled, monIO, altMon, XrdXrootdMonitor(), monBuff, windowMutex, XrdSysMutex::Lock(), numMonitor, startClock(), and XrdSysMutex::UnLock().

Referenced by XrdXrootdProtocol::do_Login(), and XrdXrootdProtocol::do_Set_Mon().

void XrdXrootdMonitor::appID

(

char *

id

)

References altMon, lastWindow, currWindow, Mark(), nextEnt, lastEnt, Flush(), monBuff, XrdXrootdMonBuff::info, XrdXrootdMonTrace::arg0, XrdXrootdMonTrace::id, and XROOTD_MON_APPID.

Referenced by XrdXrootdProtocol::do_Set_Mon().

void XrdXrootdMonitor::Close	(	kXR_unt32	dictid,
		long long	rTot,
		long long	wTot
	)

References lastWindow, currWindow, Mark(), nextEnt, lastEnt, Flush(), monBuff, XrdXrootdMonBuff::info, XrdXrootdMonTrace::arg0, XrdXrootdMonTrace::id, XROOTD_MON_CLOSE, do_Shift(), XrdXrootdMonTrace::rTot, XrdXrootdMonTrace::arg1, XrdXrootdMonTrace::wTot, XrdXrootdMonTrace::arg2, XrdXrootdMonTrace::dictid, altMon, and Dup().

Referenced by XrdXrootdProtocol::do_Close().

void XrdXrootdMonitor::Defaults	(	char *	dest1,
		int	m1,
		char *	dest2,
		int	m2
	)		[static]

References Dest1, monMode1, Dest2, monMode2, isEnabled, XROOTD_MON_ALL, monIO, XROOTD_MON_IO, XROOTD_MON_IOV, monINFO, XROOTD_MON_INFO, monFILE, XROOTD_MON_FILE, monREDR, XROOTD_MON_REDR, monSTAGE, XROOTD_MON_STAGE, monUSER, XROOTD_MON_USER, monAUTH, and XROOTD_MON_AUTH.

Referenced by XrdXrootdProtocol::xmon().

void XrdXrootdMonitor::Defaults	(	int	msz,
		int	rsz,
		int	wsz,
		int	flush,
		int	flash
	)		[static]

References sizeWindow, autoFlush, autoFlash, lastEnt, monBlen, monRlen, and startTime.

void XrdXrootdMonitor::Disc	(	kXR_unt32	dictid,
		int	csec
	)

References altMon, monUSER, Disc(), lastWindow, currWindow, Mark(), nextEnt, lastEnt, Flush(), monBuff, XrdXrootdMonBuff::info, XrdXrootdMonTrace::arg0, XrdXrootdMonTrace::rTot, XrdXrootdMonTrace::id, XROOTD_MON_DISC, XrdXrootdMonTrace::arg1, XrdXrootdMonTrace::wTot, XrdXrootdMonTrace::arg2, XrdXrootdMonTrace::dictid, and Dup().

Referenced by Disc(), and XrdXrootdProtocol::Recycle().

unsigned char XrdXrootdMonitor::do_Shift	(	long long	xTot,
		unsigned int &	xVal
	)		[private]

Referenced by Close().

void XrdXrootdMonitor::Dup

(

XrdXrootdMonTrace *

mrec

)

References lastWindow, currWindow, Mark(), nextEnt, lastEnt, Flush(), monBuff, and XrdXrootdMonBuff::info.

Referenced by Close(), Disc(), and Open().

void XrdXrootdMonitor::fillHeader	(	XrdXrootdMonHeader *	hdr,
		const char	id,
		int	size
	)		[static, private]

References XrdSysMutex::Lock(), XrdSysMutex::UnLock(), XrdXrootdMonHeader::code, XrdXrootdMonHeader::pseq, XrdXrootdMonHeader::plen, XrdXrootdMonHeader::stod, and startTime.

Referenced by Map(), and Flush().

void XrdXrootdMonitor::Flush

(

)

[private]

References nextEnt, windowMutex, XrdSysMutex::Lock(), currWindow, XrdSysMutex::UnLock(), fillHeader(), monBuff, XrdXrootdMonBuff::hdr, XROOTD_MON_MAPTRCE, lastWindow, sizeWindow, XrdXrootdMonBuff::info, XrdXrootdMonTrace::arg0, XrdXrootdMonTrace::rTot, XrdXrootdMonTrace::id, XROOTD_MON_WINDOW, XrdXrootdMonTrace::arg1, XrdXrootdMonTrace::Window, XrdXrootdMonTrace::arg2, altMon, Send(), XROOTD_MON_IO, XROOTD_MON_FILE, FlushTime, and autoFlush.

Referenced by ~XrdXrootdMonitor(), appID(), Close(), Disc(), Dup(), Open(), Tick(), Mark(), Add_rv(), and Add_io().

int XrdXrootdMonitor::Init	(	XrdScheduler *	sp,
		XrdSysError *	errp
	)		[static]

References Sched, eDest, isEnabled, XrdNet::Relay(), Dest1, XRDNET_SENDONLY, monFD, XrdNetPeer::fd, XrdSysDNS::Host2Dest(), InetAddr1, XrdSysError::Emsg(), Dest2, InetAddr2, monMode1, XROOTD_MON_IO, monMode2, altMon, XrdXrootdMonitor(), monBuff, and startClock().

Referenced by XrdXrootdProtocol::Configure().

kXR_unt32 XrdXrootdMonitor::Map	(	const char	code,
		const char *	uname,
		const char *	path
	)		[static]

References XrdSysMutex::Lock(), XrdSysMutex::UnLock(), XrdXrootdMonMap::dictid, XrdXrootdMonMap::info, strlcpy(), fillHeader(), XrdXrootdMonMap::hdr, XROOTD_MON_MAPUSER, XROOTD_MON_USER, XROOTD_MON_MAPPATH, XROOTD_MON_PATH, XROOTD_MON_MAPSTAG, XROOTD_MON_STAGE, XROOTD_MON_INFO, and Send().

Referenced by XrdXrootdProtocol::do_Login(), XrdXrootdProtocol::do_Open(), XrdXrootdProtocol::do_Set_Mon(), and XrdXrootdProtocol::MonAuth().

void XrdXrootdMonitor::Mark

(

)

[private]

References windowMutex, XrdSysMutex::Lock(), currWindow, XrdSysMutex::UnLock(), altMon, autoFlash, nextEnt, monBuff, XrdXrootdMonBuff::info, XrdXrootdMonTrace::arg2, XrdXrootdMonTrace::Window, Flush(), lastWindow, XrdXrootdMonTrace::arg0, XrdXrootdMonTrace::id, XROOTD_MON_WINDOW, lastEnt, XrdXrootdMonTrace::rTot, XrdXrootdMonTrace::arg1, and sizeWindow.

Referenced by appID(), Close(), Disc(), Dup(), Open(), Add_rv(), and Add_io().

void XrdXrootdMonitor::Open	(	kXR_unt32	dictid,
		off_t	fsize
	)

References lastWindow, currWindow, Mark(), nextEnt, lastEnt, Flush(), monBuff, XrdXrootdMonBuff::info, XrdXrootdMonTrace::arg0, XrdXrootdMonTrace::val, XrdXrootdMonTrace::id, XROOTD_MON_OPEN, XrdXrootdMonTrace::arg1, XrdXrootdMonTrace::buflen, XrdXrootdMonTrace::arg2, XrdXrootdMonTrace::dictid, altMon, and Dup().

Referenced by XrdXrootdProtocol::do_Open().

int XrdXrootdMonitor::Send	(	int	mmode,
		void *	buff,
		int	size
	)		[static, private]

References XrdSysMutex::Lock(), monMode1, monFD, InetAddr1, TRACE, DEBUG, Dest1, monMode2, InetAddr2, Dest2, and XrdSysMutex::UnLock().

Referenced by Map(), and Flush().

void XrdXrootdMonitor::startClock

(

)

[static, private]

References currWindow, XrdXrootdMonitor_Tick::Set(), Sched, sizeWindow, FlushTime, autoFlush, and XrdScheduler::Schedule().

Referenced by Alloc(), and Init().

time_t XrdXrootdMonitor::Tick

(

)

[static]

References windowMutex, XrdSysMutex::Lock(), currWindow, isEnabled, numMonitor, XrdSysMutex::UnLock(), altMon, FlushTime, XrdXrootdMonitorLock::Lock(), nextEnt, Flush(), autoFlush, and XrdXrootdMonitorLock::UnLock().

Referenced by XrdXrootdMonitor_Tick::DoIt().

void XrdXrootdMonitor::unAlloc

(

XrdXrootdMonitor *

monp

)

[static]

References altMon, isEnabled, windowMutex, XrdSysMutex::Lock(), numMonitor, and XrdSysMutex::UnLock().

Referenced by XrdXrootdProtocol::Cleanup(), and XrdXrootdProtocol::do_Set_Mon().

---

Friends And Related Function Documentation

friend class XrdXrootdMonitorDummy [friend]

---

Member Data Documentation

XrdXrootdMonitor * XrdXrootdMonitor::altMon = 0 [static, read]

Referenced by XrdXrootdMonitorLock::XrdXrootdMonitorLock(), appID(), Alloc(), Close(), Disc(), Init(), Open(), Tick(), unAlloc(), Flush(), and Mark().

int XrdXrootdMonitor::autoFlash = 0 [static, private]

Referenced by Defaults(), and Mark().

int XrdXrootdMonitor::autoFlush = 600 [static, private]

Referenced by Defaults(), Tick(), Flush(), and startClock().

kXR_int32 XrdXrootdMonitor::currWindow = 0 [static, private]

Referenced by XrdXrootdMonitor(), appID(), Close(), Disc(), Dup(), Open(), Tick(), Flush(), Mark(), startClock(), Add_rv(), and Add_io().

char * XrdXrootdMonitor::Dest1 = 0 [static, private]

Referenced by Defaults(), Init(), and Send().

char * XrdXrootdMonitor::Dest2 = 0 [static, read, private]

Referenced by Defaults(), Init(), and Send().

XrdSysError * XrdXrootdMonitor::eDest = 0 [static, private]

Referenced by XrdXrootdMonitor(), and Init().

int XrdXrootdMonitor::FlushTime = 0 [static, private]

Referenced by Tick(), Flush(), and startClock().

struct sockaddr XrdXrootdMonitor::InetAddr1 [static, private]

Referenced by Init(), and Send().

struct sockaddr XrdXrootdMonitor::InetAddr2 [static, private]

Referenced by Init(), and Send().

int XrdXrootdMonitor::isEnabled = 0 [static, private]

Referenced by Alloc(), Defaults(), Init(), Tick(), and unAlloc().

int XrdXrootdMonitor::lastEnt = 0 [static, private]

Referenced by appID(), Close(), Disc(), Defaults(), Dup(), Open(), Mark(), Add_rv(), and Add_io().

kXR_int32 XrdXrootdMonitor::lastWindow [private]

Referenced by appID(), Close(), Disc(), Dup(), Open(), Flush(), Mark(), Add_rv(), and Add_io().

char XrdXrootdMonitor::monAUTH = 0 [static]

Referenced by Defaults(), and XrdXrootdProtocol::do_Login().

int XrdXrootdMonitor::monBlen = 0 [static, private]

Referenced by XrdXrootdMonitor(), and Defaults().

XrdXrootdMonBuff* XrdXrootdMonitor::monBuff [private]

Referenced by XrdXrootdMonitor(), ~XrdXrootdMonitor(), appID(), Alloc(), Close(), Disc(), Dup(), Init(), Open(), Flush(), Mark(), Add_rv(), and Add_io().

int XrdXrootdMonitor::monFD [static, private]

Referenced by Init(), and Send().

char XrdXrootdMonitor::monFILE = 0 [static]

Referenced by Defaults().

char XrdXrootdMonitor::monINFO = 0 [static]

Referenced by Defaults(), and XrdXrootdProtocol::do_Set_Mon().

char XrdXrootdMonitor::monIO = 0 [static]

Referenced by Alloc(), Defaults(), and XrdXrootdProtocol::do_Set_Mon().

int XrdXrootdMonitor::monMode1 = 0 [static, private]

Referenced by Defaults(), Init(), and Send().

int XrdXrootdMonitor::monMode2 = 0 [static, private]

Referenced by Defaults(), Init(), and Send().

char XrdXrootdMonitor::monREDR = 0 [static]

Referenced by Defaults().

int XrdXrootdMonitor::monRlen = 0 [static, private]

Referenced by Defaults().

char XrdXrootdMonitor::monSTAGE = 0 [static]

Referenced by Defaults().

char XrdXrootdMonitor::monUSER = 0 [static]

Referenced by Disc(), Defaults(), XrdXrootdProtocol::Recycle(), XrdXrootdProtocol::do_Auth(), XrdXrootdProtocol::do_Login(), and XrdXrootdProtocol::do_Set_Mon().

int XrdXrootdMonitor::nextEnt [private]

Referenced by XrdXrootdMonitor(), appID(), Close(), Disc(), Dup(), Open(), Tick(), Flush(), Mark(), Add_rv(), and Add_io().

int XrdXrootdMonitor::numMonitor = 0 [static, private]

Referenced by Alloc(), Tick(), and unAlloc().

XrdScheduler * XrdXrootdMonitor::Sched = 0 [static, private]

Referenced by Init(), and startClock().

kXR_int32 XrdXrootdMonitor::sizeWindow = 60 [static, private]

Referenced by Defaults(), Flush(), Mark(), and startClock().

kXR_int32 XrdXrootdMonitor::startTime = 0 [static, private]

Referenced by Defaults(), and fillHeader().

XrdSysMutex XrdXrootdMonitor::windowMutex [static, private]

Referenced by XrdXrootdMonitor(), Alloc(), Tick(), unAlloc(), Flush(), and Mark().

---

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

• XrdXrootdMonitor.hh
• XrdXrootdMonitor.cc