Go to the documentation of this file. 1 #ifndef __XRDXROOTDMONITOR__
2 #define __XRDXROOTDMONITOR__
36 #include <netinet/in.h>
37 #include <sys/types.h>
47 #define XROOTD_MON_ALL 1
48 #define XROOTD_MON_FILE 2
49 #define XROOTD_MON_IO 4
50 #define XROOTD_MON_INFO 8
51 #define XROOTD_MON_USER 16
52 #define XROOTD_MON_AUTH 32
53 #define XROOTD_MON_PATH (XROOTD_MON_IO | XROOTD_MON_FILE)
54 #define XROOTD_MON_REDR 64
55 #define XROOTD_MON_IOV 128
56 #define XROOTD_MON_FSTA 256
58 #define XROOTD_MON_FSLFN 1
59 #define XROOTD_MON_FSOPS 2
60 #define XROOTD_MON_FSSSQ 4
61 #define XROOTD_MON_FSXFR 8
83 {
Add_io(dictid, rlen, offset);}
105 void appID(
char *
id);
111 static void Defaults(
char *dest1,
int m1,
char *dest2,
int m2);
112 static void Defaults(
int msz,
int rsz,
int wsz,
113 int flush,
int flash,
int iDent,
int rnm,
114 int fsint=0,
int fsopt=0,
int fsion=0);
119 const char *iHost,
const char *iProg,
120 const char *iName,
int Port);
127 const char opC,
const char *Path);
129 static time_t
Tick();
173 void Register(
const char *Uname,
const char *Hname,
214 unsigned char do_Shift(
long long xTot,
unsigned int &xVal);
217 const char id,
int size);
218 static MonRdrBuff *
Fetch();
220 static void Flush(MonRdrBuff *mP);
225 static int Send(
int mmode,
void *buff,
int size);
int Info()
Definition: XrdXrootdMonitor.hh:157
static int idLen
Definition: XrdXrootdMonitor.hh:233
int kXR_int32
Definition: XPtypes.hh:89
char Fops
Definition: XrdXrootdMonitor.hh:138
static void fillHeader(XrdXrootdMonHeader *hdr, const char id, int size)
static kXR_unt32 Map(char code, XrdXrootdMonitor::User &uInfo, const char *path)
int flushIt
Definition: XrdXrootdMonitor.hh:199
static int lastEnt
Definition: XrdXrootdMonitor.hh:243
static char monUSER
Definition: XrdXrootdMonitor.hh:265
void Close(kXR_unt32 dictid, long long rTot, long long wTot)
Definition: XrdXrootdMonData.hh:73
static XrdXrootdMonitor * altMon
Definition: XrdXrootdMonitor.hh:185
void Add_io(kXR_unt32 duid, kXR_int32 blen, kXR_int64 offs)
Definition: XrdXrootdMonitor.hh:206
union XrdXrootdMonTrace::@119 arg2
short Len
Definition: XrdXrootdMonitor.hh:139
Definition: XrdSysPthread.hh:165
static char * Dest1
Definition: XrdXrootdMonitor.hh:234
static char monCLOCK
Definition: XrdXrootdMonitor.hh:269
static int monMode2
Definition: XrdXrootdMonitor.hh:238
Definition: XrdXrootdMonitor.hh:71
const kXR_char XROOTD_MON_MAPINFO
Definition: XrdXrootdMonData.hh:99
int nextEnt
Definition: XrdXrootdMonitor.hh:198
long long kXR_int64
Definition: XPtypes.hh:98
short kXR_int16
Definition: XPtypes.hh:66
static int FlushTime
Definition: XrdXrootdMonitor.hh:247
void Add_rv(kXR_unt32 dictid, kXR_int32 rlen, kXR_int16 vcnt, kXR_char vseq, kXR_char vtype)
Definition: XrdXrootdMonitor.hh:85
static int rdrTOD
Definition: XrdXrootdMonitor.hh:251
static XrdSysError * eDest
Definition: XrdXrootdMonitor.hh:230
int Auths()
Definition: XrdXrootdMonitor.hh:142
void Disc(kXR_unt32 dictid, int csec, char Flags=0)
int Logins()
Definition: XrdXrootdMonitor.hh:161
int Ready()
Definition: XrdXrootdMonitor.hh:179
static XrdSysMutex rdrMutex
Definition: XrdXrootdMonitor.hh:204
static int Init(XrdScheduler *sp, XrdSysError *errp, const char *iHost, const char *iProg, const char *iName, int Port)
static char * idRec
Definition: XrdXrootdMonitor.hh:232
unsigned char kXR_char
Definition: XPtypes.hh:65
static int autoFlush
Definition: XrdXrootdMonitor.hh:246
static int Send(int mmode, void *buff, int size)
void Dup(XrdXrootdMonTrace *mrec)
kXR_int64 val
Definition: XrdXrootdMonData.hh:47
void Clear()
Definition: XrdXrootdMonitor.hh:144
static XrdScheduler * Sched
Definition: XrdXrootdMonitor.hh:229
static MonRdrBuff * rdrMP
Definition: XrdXrootdMonitor.hh:203
XrdXrootdMonTrace info[sizeof(XrdXrootdMonTrace)]
Definition: XrdXrootdMonData.hh:60
static XrdXrootdMonitor * Alloc(int force=0)
kXR_int32 lastWindow
Definition: XrdXrootdMonitor.hh:249
kXR_unt32 rTot[2]
Definition: XrdXrootdMonData.hh:50
char Iops
Definition: XrdXrootdMonitor.hh:137
static int lastRnt
Definition: XrdXrootdMonitor.hh:244
kXR_unt32 MapInfo(const char *Info)
Definition: XrdXrootdMonitor.hh:163
kXR_unt32 Did
Definition: XrdXrootdMonitor.hh:136
Definition: XrdNetMsg.hh:48
static kXR_int32 currWindow
Definition: XrdXrootdMonitor.hh:250
kXR_int32 lastTOD
Definition: XrdXrootdMonitor.hh:200
static int monIdent
Definition: XrdXrootdMonitor.hh:257
int Fstat()
Definition: XrdXrootdMonitor.hh:155
kXR_unt16 sVal[4]
Definition: XrdXrootdMonData.hh:49
static kXR_int32 sizeWindow
Definition: XrdXrootdMonitor.hh:254
kXR_unt32 MapPath(const char *Path)
Definition: XrdXrootdMonitor.hh:168
static XrdSysMutex windowMutex
Definition: XrdXrootdMonitor.hh:231
unsigned int kXR_unt32
Definition: XPtypes.hh:90
static int numMonitor
Definition: XrdXrootdMonitor.hh:256
Definition: XrdXrootdMonData.hh:58
void Open(kXR_unt32 dictid, off_t fsize)
static char monIO
Definition: XrdXrootdMonitor.hh:261
static char monREDR
Definition: XrdXrootdMonitor.hh:264
static kXR_int32 startTime
Definition: XrdXrootdMonitor.hh:248
void Report(const char *Info)
Definition: XrdXrootdMonitor.hh:176
static MonRdrBuff * Fetch()
XrdSysMutex Mutex
Definition: XrdXrootdMonitor.hh:201
static void unAlloc(XrdXrootdMonitor *monp)
XrdXrootdMonBuff * monBuff
Definition: XrdXrootdMonitor.hh:240
static char monFSTAT
Definition: XrdXrootdMonitor.hh:268
kXR_int32 buflen
Definition: XrdXrootdMonData.hh:51
static char sidName[16]
Definition: XrdXrootdMonitor.hh:259
Definition: XrdScheduler.hh:44
union XrdXrootdMonTrace::@118 arg1
static short sidSize
Definition: XrdXrootdMonitor.hh:260
Definition: XrdXrootdMonFile.hh:44
void Add_wr(kXR_unt32 dictid, kXR_int32 wlen, kXR_int64 offset)
Definition: XrdXrootdMonitor.hh:100
const kXR_char XROOTD_MON_MAPUSER
Definition: XrdXrootdMonData.hh:105
static int monBlen
Definition: XrdXrootdMonitor.hh:241
static int rdrNum
Definition: XrdXrootdMonitor.hh:253
static XrdNetMsg * InetDest2
Definition: XrdXrootdMonitor.hh:239
static XrdNetMsg * InetDest1
Definition: XrdXrootdMonitor.hh:236
void Register(const char *Uname, const char *Hname, const char *Pname)
static int monRlen
Definition: XrdXrootdMonitor.hh:258
static int Redirect()
Definition: XrdXrootdMonitor.hh:124
static char * Dest2
Definition: XrdXrootdMonitor.hh:237
const kXR_char XROOTD_MON_MAPPATH
Definition: XrdXrootdMonData.hh:97
static void Ident()
Definition: XrdXrootdMonitor.hh:116
unsigned char do_Shift(long long xTot, unsigned int &xVal)
int Files()
Definition: XrdXrootdMonitor.hh:153
void Add_rd(kXR_unt32 dictid, kXR_int32 rlen, kXR_int64 offset)
Definition: XrdXrootdMonitor.hh:80
XrdXrootdMonBurr * Buff
Definition: XrdXrootdMonitor.hh:197
static char monAUTH
Definition: XrdXrootdMonitor.hh:266
static kXR_unt32 GetDictID()
static char monFILE
Definition: XrdXrootdMonitor.hh:263
static void Defaults(char *dest1, int m1, char *dest2, int m2)
User()
Definition: XrdXrootdMonitor.hh:181
kXR_unt32 dictid
Definition: XrdXrootdMonData.hh:54
Definition: XrdXrootdMonData.hh:46
Definition: XrdXrootdMonitor.hh:195
static int isEnabled
Definition: XrdXrootdMonitor.hh:255
int nextEnt
Definition: XrdXrootdMonitor.hh:242
static int autoFlash
Definition: XrdXrootdMonitor.hh:245
char * Name
Definition: XrdXrootdMonitor.hh:140
Definition: XrdSysError.hh:89
static const int rdrMax
Definition: XrdXrootdMonitor.hh:189
static struct XrdXrootdMonitor::MonRdrBuff rdrMon[rdrMax]
static char monINFO
Definition: XrdXrootdMonitor.hh:262
Definition: XrdXrootdMonitor.hh:131
~User()
Definition: XrdXrootdMonitor.hh:182
static char monACTIVE
Definition: XrdXrootdMonitor.hh:267
kXR_char id[8]
Definition: XrdXrootdMonData.hh:48
MonRdrBuff * Next
Definition: XrdXrootdMonitor.hh:196
static int monMode1
Definition: XrdXrootdMonitor.hh:235
static int rdrWin
Definition: XrdXrootdMonitor.hh:252
union XrdXrootdMonTrace::@117 arg0
int InOut()
Definition: XrdXrootdMonitor.hh:159
XrdXrootdMonitor * Agent
Definition: XrdXrootdMonitor.hh:135