XrdMonDecSink Class Reference

#include <XrdMonDecSink.hh>

Collaboration diagram for XrdMonDecSink:

[legend]List of all members.

Public Member Functions
	XrdMonDecSink (const char *baseDir, const char *rtLogDir, int rtBufSize, bool saveTraces, int maxTraceLogSize)
	~XrdMonDecSink ()
void	init (dictid_t min, dictid_t max, const string &senderHP)
sequen_t	lastSeq () const
void	registerXrdRestart (kXR_int32 stod, senderid_t senderId)
void	setLastSeq (sequen_t seq)
void	addDictId (dictid_t xrdId, const char *theString, int len, senderid_t senderId)
void	addStageInfo (dictid_t xrdId, const char *theString, int len, senderid_t senderId)
void	addUserId (dictid_t xrdId, const char *theString, int len, senderid_t senderId)
void	add (dictid_t xrdId, XrdMonDecTraceInfo &trace, senderid_t senderId)
void	addUserDisconnect (dictid_t xrdId, kXR_int32 sec, kXR_int32 timestamp, senderid_t senderId)
void	openFile (dictid_t dictId, kXR_int32 timestamp, senderid_t senderId, kXR_int64 fSize)
void	closeFile (dictid_t dictId, kXR_int64 bytesR, kXR_int64 bytesW, kXR_int32 timestamp, senderid_t senderId)
void	flushHistoryData ()
void	flushRealTimeData ()
void	reset (senderid_t senderId)
Private Types
typedef map< dictid_t, XrdMonDecDictInfo * >	dmap_t
typedef map< dictid_t, XrdMonDecUserInfo * >	umap_t
typedef map< dictid_t, XrdMonDecDictInfo * >::iterator	dmapitr_t
typedef map< dictid_t, XrdMonDecUserInfo * >::iterator	umapitr_t
typedef vector< XrdMonDecTraceInfo >	TraceVector
Private Member Functions
void	initRT (const char *rtLogDir, int rtBufSize)
void	addVersion ()
void	loadUniqueIdsAndSeq ()
vector< XrdMonDecDictInfo * >	loadActiveDictInfo ()
void	flushClosedDicts ()
void	flushUserCache ()
void	flushTCache ()
void	checkpoint ()
void	openTraceFile (fstream &f)
void	write2TraceFile (fstream &f, const char *buf, int len)
void	registerLostPacket (dictid_t id, const char *descr)
void	reportLostPackets ()
void	flushOneDMap (dmap_t *m, int &curLen, const int BUFSIZE, string &buf, fstream &fD)
void	flushOneUMap (umap_t *m, int &curLen, const int BUFSIZE, string &buf, fstream &fD)
void	resetDMap (senderid_t senderId)
void	resetUMap (senderid_t senderId)
Private Attributes
kXR_unt16	_verFreqCount
vector< dmap_t * >	_dCache
vector< umap_t * >	_uCache
XrdSysMutex	_dMutex
XrdSysMutex	_uMutex
XrdMonBufferedOutput *	_rtLogger
bool	_saveTraces
TraceVector	_tCache
kXR_unt32	_tCacheSize
kXR_unt16	_traceLogNumber
kXR_int64	_maxTraceLogSize
map< dictid_t, long >	_lost
sequen_t	_lastSeq
dictid_t	_uniqueDictId
dictid_t	_uniqueUserId
string	_path
string	_jnlPath
string	_dictPath
string	_userPath
string	_rtFlagPath
string	_rtMaxIdsPath
string	_xrdRestartLog
Static Private Attributes
const kXR_unt16	VER_FREQ = 1000

---

Member Typedef Documentation

typedef map<dictid_t, XrdMonDecDictInfo*> XrdMonDecSink::dmap_t [private]

typedef map<dictid_t, XrdMonDecDictInfo*>::iterator XrdMonDecSink::dmapitr_t [private]

typedef vector<XrdMonDecTraceInfo> XrdMonDecSink::TraceVector [private]

typedef map<dictid_t, XrdMonDecUserInfo*> XrdMonDecSink::umap_t [private]

typedef map<dictid_t, XrdMonDecUserInfo*>::iterator XrdMonDecSink::umapitr_t [private]

---

Constructor & Destructor Documentation

XrdMonDecSink::XrdMonDecSink (  const char *  baseDir, const char *  rtLogDir, int  rtBufSize, bool  saveTraces, int  maxTraceLogSize )

XrdMonDecSink::~XrdMonDecSink (   )

---

Member Function Documentation

void XrdMonDecSink::add (  dictid_t  xrdId, XrdMonDecTraceInfo &  trace, senderid_t  senderId )

void XrdMonDecSink::addDictId (  dictid_t  xrdId, const char *  theString, int  len, senderid_t  senderId )

void XrdMonDecSink::addStageInfo (  dictid_t  xrdId, const char *  theString, int  len, senderid_t  senderId )

void XrdMonDecSink::addUserDisconnect (  dictid_t  xrdId, kXR_int32  sec, kXR_int32  timestamp, senderid_t  senderId )

void XrdMonDecSink::addUserId (  dictid_t  xrdId, const char *  theString, int  len, senderid_t  senderId )

void XrdMonDecSink::addVersion (   )  [private]

void XrdMonDecSink::checkpoint (   )  [private]

void XrdMonDecSink::closeFile (  dictid_t  dictId, kXR_int64  bytesR, kXR_int64  bytesW, kXR_int32  timestamp, senderid_t  senderId )

void XrdMonDecSink::flushClosedDicts (   )  [private]

void XrdMonDecSink::flushHistoryData (   )

void XrdMonDecSink::flushOneDMap (  dmap_t *  m, int &  curLen, const int  BUFSIZE, string &  buf, fstream &  fD )  [private]

void XrdMonDecSink::flushOneUMap (  umap_t *  m, int &  curLen, const int  BUFSIZE, string &  buf, fstream &  fD )  [private]

void XrdMonDecSink::flushRealTimeData (   )  [inline]

void XrdMonDecSink::flushTCache (   )  [private]

void XrdMonDecSink::flushUserCache (   )  [private]

void XrdMonDecSink::init (  dictid_t  min, dictid_t  max, const string &  senderHP )

void XrdMonDecSink::initRT (  const char *  rtLogDir, int  rtBufSize )  [private]

sequen_t XrdMonDecSink::lastSeq (   )  const [inline]

vector< XrdMonDecDictInfo * > XrdMonDecSink::loadActiveDictInfo (   )  [private]

void XrdMonDecSink::loadUniqueIdsAndSeq (   )  [private]

void XrdMonDecSink::openFile (  dictid_t  dictId, kXR_int32  timestamp, senderid_t  senderId, kXR_int64  fSize )

void XrdMonDecSink::openTraceFile (  fstream &  f  )  [private]

void XrdMonDecSink::registerLostPacket (  dictid_t  id, const char *  descr )  [private]

void XrdMonDecSink::registerXrdRestart (  kXR_int32  stod, senderid_t  senderId )

void XrdMonDecSink::reportLostPackets (   )  [private]

void XrdMonDecSink::reset (  senderid_t  senderId  )

void XrdMonDecSink::resetDMap (  senderid_t  senderId  )  [private]

void XrdMonDecSink::resetUMap (  senderid_t  senderId  )  [private]

void XrdMonDecSink::setLastSeq (  sequen_t  seq  )  [inline]

void XrdMonDecSink::write2TraceFile (  fstream &  f, const char *  buf, int  len )  [private]

---

Member Data Documentation

vector< dmap_t* > XrdMonDecSink::_dCache [private]

string XrdMonDecSink::_dictPath [private]

XrdSysMutex XrdMonDecSink::_dMutex [private]

string XrdMonDecSink::_jnlPath [private]

sequen_t XrdMonDecSink::_lastSeq [private]

map<dictid_t, long> XrdMonDecSink::_lost [private]

kXR_int64 XrdMonDecSink::_maxTraceLogSize [private]

string XrdMonDecSink::_path [private]

string XrdMonDecSink::_rtFlagPath [private]

XrdMonBufferedOutput* XrdMonDecSink::_rtLogger [private]

string XrdMonDecSink::_rtMaxIdsPath [private]

bool XrdMonDecSink::_saveTraces [private]

TraceVector XrdMonDecSink::_tCache [private]

kXR_unt32 XrdMonDecSink::_tCacheSize [private]

kXR_unt16 XrdMonDecSink::_traceLogNumber [private]

vector< umap_t* > XrdMonDecSink::_uCache [private]

XrdSysMutex XrdMonDecSink::_uMutex [private]

dictid_t XrdMonDecSink::_uniqueDictId [private]

dictid_t XrdMonDecSink::_uniqueUserId [private]

string XrdMonDecSink::_userPath [private]

kXR_unt16 XrdMonDecSink::_verFreqCount [private]

string XrdMonDecSink::_xrdRestartLog [private]

const kXR_unt16 XrdMonDecSink::VER_FREQ = 1000 [static, private]

---

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

• XrdMonDecSink.hh
• XrdMonDecSink.cc

---