1#ifndef __XRDXROOTDMONITOR__
2#define __XRDXROOTDMONITOR__
36#include <netinet/in.h>
48#define XROOTD_MON_ALL 0x00000001
49#define XROOTD_MON_FILE 0x00000002
50#define XROOTD_MON_IO 0x00000004
51#define XROOTD_MON_INFO 0x00000008
52#define XROOTD_MON_USER 0x00000010
53#define XROOTD_MON_AUTH 0x00000020
54#define XROOTD_MON_PATH (XROOTD_MON_IO | XROOTD_MON_FILE)
55#define XROOTD_MON_REDR 0x00000040
56#define XROOTD_MON_IOV 0x00000080
57#define XROOTD_MON_FSTA 0x00000100
58#define XROOTD_MON_CCM 0x00000200
59#define XROOTD_MON_PFC 0x00000400
60#define XROOTD_MON_TCPMO 0x00000800
61#define XROOTD_MON_TPC 0x00001000
62#define XROOTD_MON_GSTRM (XROOTD_MON_CCM | XROOTD_MON_PFC | XROOTD_MON_TCPMO)
64#define XROOTD_MON_FSLFN 1
65#define XROOTD_MON_FSOPS 2
66#define XROOTD_MON_FSSSQ 4
67#define XROOTD_MON_FSXFR 8
89 {
Add_io(dictid, rlen, offset);}
117static void Defaults(
char *dest1,
int m1,
char *dest2,
int m2);
119 int flush,
int flash,
int iDent,
int rnm,
120 int fbsz,
int fsint=0,
int fsopt=0,
int fsion=0);
129 const char *iHost,
const char *iProg,
130 const char *iName,
int Port);
142 const char opC,
const char *Path);
144static int Send(
int mmode,
void *buff,
int size,
bool setseq=
true);
213 void Register(
const char *Uname,
const char *Hname,
260 unsigned char do_Shift(
long long xTot,
unsigned int &xVal);
263 const char id,
int size);
long long kXR_int64
Definition XPtypes.hh:98
int kXR_int32
Definition XPtypes.hh:89
unsigned int kXR_unt32
Definition XPtypes.hh:90
short kXR_int16
Definition XPtypes.hh:66
unsigned char kXR_char
Definition XPtypes.hh:65
const kXR_char XROOTD_MON_MAPUSER
Definition XrdXrootdMonData.hh:114
const kXR_char XROOTD_MON_MAPINFO
Definition XrdXrootdMonData.hh:107
const kXR_char XROOTD_MON_MAPPATH
Definition XrdXrootdMonData.hh:104
Definition XrdNetMsg.hh:50
Definition XrdScheduler.hh:46
Definition XrdSecMonitor.hh:34
WhatInfo
Definition XrdSecMonitor.hh:37
Definition XrdSysError.hh:90
Definition XrdSysPthread.hh:165
Definition XrdXrootdMonFile.hh:43
Definition XrdXrootdMonitor.hh:151
static Hello * First
Definition XrdXrootdMonitor.hh:163
Hello * Next
Definition XrdXrootdMonitor.hh:164
virtual ~Hello()
Definition XrdXrootdMonitor.hh:160
char theMode
Definition XrdXrootdMonitor.hh:166
char * theDest
Definition XrdXrootdMonitor.hh:165
virtual void Ident()
Definition XrdXrootdMonitor.hh:156
Hello(const char *dest, char mode)
Definition XrdXrootdMonitor.hh:172
kXR_unt32 Did
Definition XrdXrootdMonitor.hh:176
short Len
Definition XrdXrootdMonitor.hh:179
~User()
Definition XrdXrootdMonitor.hh:226
kXR_unt32 MapInfo(const char *Info)
Definition XrdXrootdMonitor.hh:203
bool Report(WhatInfo infoT, const char *info) override
void Clear()
Definition XrdXrootdMonitor.hh:184
kXR_unt32 MapPath(const char *Path)
Definition XrdXrootdMonitor.hh:208
User()
Definition XrdXrootdMonitor.hh:225
void Register(const char *Uname, const char *Hname, const char *Pname)
int Auths()
Definition XrdXrootdMonitor.hh:182
int Logins()
Definition XrdXrootdMonitor.hh:201
char * Name
Definition XrdXrootdMonitor.hh:180
char Fops
Definition XrdXrootdMonitor.hh:178
char Iops
Definition XrdXrootdMonitor.hh:177
void Report(const char *Info)
Definition XrdXrootdMonitor.hh:216
int Info()
Definition XrdXrootdMonitor.hh:197
int Fstat()
Definition XrdXrootdMonitor.hh:195
int InOut()
Definition XrdXrootdMonitor.hh:199
void Report(int eCode, int aCode)
int Ready()
Definition XrdXrootdMonitor.hh:223
XrdXrootdMonitor * Agent
Definition XrdXrootdMonitor.hh:175
int Files()
Definition XrdXrootdMonitor.hh:193
Definition XrdXrootdMonitor.hh:78
static kXR_unt32 GetDictID(bool hbo=false)
static int lastRnt
Definition XrdXrootdMonitor.hh:286
static void Defaults(char *dest1, int m1, char *dest2, int m2)
static char monINFO
Definition XrdXrootdMonitor.hh:301
static char monFILE
Definition XrdXrootdMonitor.hh:302
static char monIO
Definition XrdXrootdMonitor.hh:300
static int monMode1
Definition XrdXrootdMonitor.hh:277
static int monRlen
Definition XrdXrootdMonitor.hh:299
static MonRdrBuff * rdrMP
Definition XrdXrootdMonitor.hh:249
static const int rdrMax
Definition XrdXrootdMonitor.hh:235
static char monAUTH
Definition XrdXrootdMonitor.hh:305
static int idLen
Definition XrdXrootdMonitor.hh:275
static int FlushTime
Definition XrdXrootdMonitor.hh:289
static char monFSTAT
Definition XrdXrootdMonitor.hh:307
static XrdXrootdMonitor * Alloc(int force=0)
static int numMonitor
Definition XrdXrootdMonitor.hh:297
static void Ident()
Definition XrdXrootdMonitor.hh:126
kXR_int32 lastWindow
Definition XrdXrootdMonitor.hh:290
static int lastEnt
Definition XrdXrootdMonitor.hh:285
static void unAlloc(XrdXrootdMonitor *monp)
static char * Dest2
Definition XrdXrootdMonitor.hh:279
static int Flushing()
Definition XrdXrootdMonitor.hh:122
static kXR_int32 sizeWindow
Definition XrdXrootdMonitor.hh:295
static void Init(XrdScheduler *sp, XrdSysError *errp, const char *iHost, const char *iProg, const char *iName, int Port)
void Add_rv(kXR_unt32 dictid, kXR_int32 rlen, kXR_int16 vcnt, kXR_char vseq, kXR_char vtype)
Definition XrdXrootdMonitor.hh:91
void Disc(kXR_unt32 dictid, int csec, char Flags=0)
static int rdrNum
Definition XrdXrootdMonitor.hh:294
static char monREDR
Definition XrdXrootdMonitor.hh:303
static char monACTIVE
Definition XrdXrootdMonitor.hh:306
static int rdrWin
Definition XrdXrootdMonitor.hh:293
static XrdXrootdMonitor * altMon
Definition XrdXrootdMonitor.hh:231
void Close(kXR_unt32 dictid, long long rTot, long long wTot)
void Add_io(kXR_unt32 duid, kXR_int32 blen, kXR_int64 offs)
Definition XrdXrootdMonitor.hh:252
static int Send(int mmode, void *buff, int size, bool setseq=true)
unsigned char do_Shift(long long xTot, unsigned int &xVal)
static XrdSysMutex rdrMutex
Definition XrdXrootdMonitor.hh:250
static XrdSysMutex windowMutex
Definition XrdXrootdMonitor.hh:273
static int monBlen
Definition XrdXrootdMonitor.hh:283
static int monMode2
Definition XrdXrootdMonitor.hh:280
static XrdNetMsg * InetDest2
Definition XrdXrootdMonitor.hh:281
static int Redirect(kXR_unt32 mID, const char *hName, int Port, const char opC, const char *Path)
static int monIdent
Definition XrdXrootdMonitor.hh:298
XrdXrootdMonBuff * monBuff
Definition XrdXrootdMonitor.hh:282
static MonRdrBuff * Fetch()
int nextEnt
Definition XrdXrootdMonitor.hh:284
static int autoFlush
Definition XrdXrootdMonitor.hh:288
static int isEnabled
Definition XrdXrootdMonitor.hh:296
static struct XrdXrootdMonitor::MonRdrBuff rdrMon[rdrMax]
static int autoFlash
Definition XrdXrootdMonitor.hh:287
static char monCLOCK
Definition XrdXrootdMonitor.hh:308
void Dup(XrdXrootdMonTrace *mrec)
static char * idRec
Definition XrdXrootdMonitor.hh:274
void Add_rd(kXR_unt32 dictid, kXR_int32 rlen, kXR_int64 offset)
Definition XrdXrootdMonitor.hh:86
static void Flush(MonRdrBuff *mP)
static char monUSER
Definition XrdXrootdMonitor.hh:304
static kXR_unt32 Map(char code, XrdXrootdMonitor::User &uInfo, const char *path)
static void Defaults(int msz, int rsz, int wsz, int flush, int flash, int iDent, int rnm, int fbsz, int fsint=0, int fsopt=0, int fsion=0)
static int Redirect()
Definition XrdXrootdMonitor.hh:139
static bool ModeEnabled(int mode)
Definition XrdXrootdMonitor.hh:134
void Add_wr(kXR_unt32 dictid, kXR_int32 wlen, kXR_int64 offset)
Definition XrdXrootdMonitor.hh:106
void Open(kXR_unt32 dictid, off_t fsize)
static char * Dest1
Definition XrdXrootdMonitor.hh:276
static int rdrTOD
Definition XrdXrootdMonitor.hh:292
static void fillHeader(XrdXrootdMonHeader *hdr, const char id, int size)
static XrdNetMsg * InetDest1
Definition XrdXrootdMonitor.hh:278
static kXR_int32 currWindow
Definition XrdXrootdMonitor.hh:291
Definition XrdXrootdMonData.hh:59
XrdXrootdMonTrace info[sizeof(XrdXrootdMonTrace)]
Definition XrdXrootdMonData.hh:60
Definition XrdXrootdMonData.hh:74
Definition XrdXrootdMonData.hh:47
kXR_int64 val
Definition XrdXrootdMonData.hh:47
kXR_char id[8]
Definition XrdXrootdMonData.hh:48
kXR_unt32 rTot[2]
Definition XrdXrootdMonData.hh:50
union XrdXrootdMonTrace::@162 arg1
kXR_int32 buflen
Definition XrdXrootdMonData.hh:51
union XrdXrootdMonTrace::@163 arg2
kXR_unt16 sVal[4]
Definition XrdXrootdMonData.hh:49
kXR_unt32 dictid
Definition XrdXrootdMonData.hh:54
union XrdXrootdMonTrace::@161 arg0
Definition XrdXrootdMonitor.hh:242
MonRdrBuff * Next
Definition XrdXrootdMonitor.hh:242
int flushIt
Definition XrdXrootdMonitor.hh:245
int nextEnt
Definition XrdXrootdMonitor.hh:244
XrdXrootdMonBurr * Buff
Definition XrdXrootdMonitor.hh:243
kXR_int32 lastTOD
Definition XrdXrootdMonitor.hh:246
XrdSysMutex Mutex
Definition XrdXrootdMonitor.hh:247