|
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 |