Main Page | Namespace List | Class Hierarchy | Class List | Directories | File List | Namespace Members | Class Members | File Members

XrdMonDecSink Class Reference

#include <XrdMonDecSink.hh>

Collaboration diagram for XrdMonDecSink:

Collaboration graph
[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< XrdMonDecTraceInfoTraceVector

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:
Generated on Sun Nov 6 13:37:06 2011 for xrootd by  doxygen 1.3.9.1