#include <XrdFrmMonitor.hh>
|
static void | Defaults (char *dest1, int m1, char *dest2, int m2, int iTime) |
|
static void | Ident () |
|
static int | Init (const char *iHost, const char *iProg, const char *iName) |
|
static kXR_unt32 | Map (char code, const char *uname, const char *path) |
|
Definition at line 47 of file XrdFrmMonitor.hh.
◆ XrdFrmMonitor()
XrdFrmMonitor::XrdFrmMonitor |
( |
| ) |
|
◆ ~XrdFrmMonitor()
XrdFrmMonitor::~XrdFrmMonitor |
( |
| ) |
|
◆ Defaults()
void XrdFrmMonitor::Defaults |
( |
char * |
dest1, |
|
|
int |
m1, |
|
|
char * |
dest2, |
|
|
int |
m2, |
|
|
int |
iTime |
|
) |
| |
|
static |
Definition at line 84 of file XrdFrmMonitor.cc.
90 if (dest1 && !mode1) {free(dest1); dest1 = 0; mode1 = 0;}
91 if (dest2 && !mode2) {free(dest2); dest2 = 0; mode2 = 0;}
96 {mode1 = (dest1 = dest2) ? mode2 : 0;
102 if (Dest1) free(Dest1);
103 Dest1 = dest1; monMode1 = mode1;
104 if (Dest2) free(Dest2);
105 Dest2 = dest2; monMode2 = mode2;
115 isEnabled = (Dest1 == 0 && Dest2 == 0 ? 0 : 1);
References XROOTD_MON_MIGR, XROOTD_MON_PURGE, and XROOTD_MON_STAGE.
◆ Ident()
void XrdFrmMonitor::Ident |
( |
| ) |
|
|
static |
◆ Init()
int XrdFrmMonitor::Init |
( |
const char * |
iHost, |
|
|
const char * |
iProg, |
|
|
const char * |
iName |
|
) |
| |
|
static |
Definition at line 134 of file XrdFrmMonitor.cc.
138 const char *etext = 0;
145 (iName ? iName :
"anon"), 0);
146 sidSize = strlen(sidName);
147 startTime = htonl(time(0));
151 if (!isEnabled)
return 1;
155 #if defined(__GNUC__) && __GNUC__ >= 12
156 #pragma GCC diagnostic push
157 #pragma GCC diagnostic ignored "-Warray-bounds"
162 idRec = (
char *)malloc(idLen+1);
167 strcpy(mP->
info, iBuff);
168 #if defined(__GNUC__) && __GNUC__ >= 12
169 #pragma GCC diagnostic pop
176 {
Say.
Emsg(
"Monitor",
"setup monitor collector;", etext);
185 {
Say.
Emsg(
"Monitor",
"setup monitor collector;", etext);
196 {
Say.
Emsg(
"Init", retc,
"create monitor ident thread");
return 0;}
void * XrdFrmMonitorID(void *parg)
const kXR_char XROOTD_MON_MAPIDNT
static char * Ident(long long &mySID, char *iBuff, int iBlen, const char *iHost, const char *iProg, const char *iName, int Port)
int Emsg(const char *esfx, int ecode, const char *text1, const char *text2=0)
static int Run(pthread_t *, void *(*proc)(void *), void *arg, int opts=0, const char *desc=0)
References XrdXrootdMonMap::dictid, XrdSysError::Emsg(), XrdXrootdMonMap::hdr, XrdOucUtils::Ident(), XrdXrootdMonMap::info, XrdXrootdMonHeader::pseq, XrdSysThread::Run(), XrdFrc::Say, XrdXrootdMonInfo::startTime, XrdFrmMonitorID(), and XROOTD_MON_MAPIDNT.
◆ Map()
kXR_unt32 XrdFrmMonitor::Map |
( |
char |
code, |
|
|
const char * |
uname, |
|
|
const char * |
path |
|
) |
| |
|
static |
Definition at line 208 of file XrdFrmMonitor.cc.
211 const char *colonP, *atP;
217 if ((colonP = index(uname,
':')) && (atP = index(colonP+1,
'@')))
218 {
int n = colonP - uname + 1;
219 strncpy(uBuff, uname, n);
220 strcpy(uBuff+n, sidName);
221 strcpy(uBuff+n+sidSize, atP);
222 }
else strcpy(uBuff, uname);
227 strcpy(map.
info, uBuff);
228 size = strlen(uBuff);
230 {*(map.
info+size) =
'\n';
232 size = size + strlen(path) + 1;
249 fillHeader(&map.
hdr, code, size);
251 Send(montype, (
void *)&map, size);
const kXR_char XROOTD_MON_MAPXFER
const kXR_char XROOTD_MON_MAPMIGR
const kXR_char XROOTD_MON_MAPSTAG
const kXR_char XROOTD_MON_MAPPURG
References XrdXrootdMonMap::dictid, XrdXrootdMonMap::hdr, XrdXrootdMonMap::info, XrdSys::Send(), strlcpy(), XROOTD_MON_INFO, XROOTD_MON_MAPMIGR, XROOTD_MON_MAPPURG, XROOTD_MON_MAPSTAG, XROOTD_MON_MAPXFER, XROOTD_MON_MIGR, XROOTD_MON_PURGE, and XROOTD_MON_STAGE.
◆ monMIGR
char XrdFrmMonitor::monMIGR = 0 |
|
static |
◆ monPURGE
char XrdFrmMonitor::monPURGE = 0 |
|
static |
◆ monSTAGE
char XrdFrmMonitor::monSTAGE = 0 |
|
static |
The documentation for this class was generated from the following files: