#include <XrdXrootdMonitor.hh>
|
| void | Add_rd (kXR_unt32 dictid, kXR_int32 rlen, kXR_int64 offset) |
| |
| void | Add_rv (kXR_unt32 dictid, kXR_int32 rlen, kXR_int16 vcnt, kXR_char vseq, kXR_char vtype) |
| |
| void | Add_wr (kXR_unt32 dictid, kXR_int32 wlen, kXR_int64 offset) |
| |
| void | appID (char *id) |
| |
| void | Close (kXR_unt32 dictid, long long rTot, long long wTot) |
| |
| void | Disc (kXR_unt32 dictid, int csec, char Flags=0) |
| |
| void | Open (kXR_unt32 dictid, off_t fsize) |
| |
| | XrdXrootdMonitor () |
| |
|
| static void | Defaults (char *dest1, int m1, char *dest2, int m2) |
| |
| static void | Defaults (int msz, int rsz, int wsz, int flush, int flash, int iDent, int rnm, int fsint=0, int fsopt=0, int fsion=0) |
| |
| static void | Ident () |
| |
| static int | Init (XrdScheduler *sp, XrdSysError *errp, const char *iHost, const char *iProg, const char *iName, int Port) |
| |
| static int | Redirect () |
| |
| static int | Redirect (kXR_unt32 mID, const char *hName, int Port, const char opC, const char *Path) |
| |
| static time_t | Tick () |
| |
| XrdXrootdMonitor::XrdXrootdMonitor |
( |
| ) |
|
| XrdXrootdMonitor::~XrdXrootdMonitor |
( |
| ) |
|
|
private |
References XrdXrootdMonTrace::arg0, XrdXrootdMonTrace::arg1, XrdXrootdMonTrace::arg2, XrdXrootdMonTrace::buflen, currWindow, XrdXrootdMonTrace::dictid, Flush(), XrdXrootdMonBuff::info, lastEnt, lastWindow, Mark(), monBuff, nextEnt, and XrdXrootdMonTrace::val.
Referenced by Add_rd(), and Add_wr().
References XrdXrootdMonTrace::arg0, XrdXrootdMonTrace::arg1, XrdXrootdMonTrace::arg2, XrdXrootdMonTrace::buflen, currWindow, XrdXrootdMonTrace::dictid, Flush(), XrdXrootdMonTrace::id, XrdXrootdMonBuff::info, lastEnt, lastWindow, Mark(), monBuff, nextEnt, XrdXrootdMonTrace::rTot, and XrdXrootdMonTrace::sVal.
Referenced by XrdXrootdProtocol::do_ReadV().
References altMon, isEnabled, XrdSysMutex::Lock(), monBuff, monIO, monREDR, numMonitor, startClock(), XrdSysMutex::UnLock(), windowMutex, and XrdXrootdMonitor().
Referenced by XrdXrootdMonitor::User::Enable(), and XrdXrootdMonitor::User::Register().
| void XrdXrootdMonitor::appID |
( |
char * |
id | ) |
|
References altMon, XrdXrootdMonTrace::arg0, currWindow, Flush(), XrdXrootdMonTrace::id, XrdXrootdMonBuff::info, lastEnt, lastWindow, Mark(), monBuff, nextEnt, and XROOTD_MON_APPID.
Referenced by XrdXrootdProtocol::do_Set_Mon().
| void XrdXrootdMonitor::Close |
( |
kXR_unt32 |
dictid, |
|
|
long long |
rTot, |
|
|
long long |
wTot |
|
) |
| |
References altMon, XrdXrootdMonTrace::arg0, XrdXrootdMonTrace::arg1, XrdXrootdMonTrace::arg2, currWindow, XrdXrootdMonTrace::dictid, do_Shift(), Dup(), Flush(), XrdXrootdMonTrace::id, XrdXrootdMonBuff::info, lastEnt, lastWindow, Mark(), monBuff, nextEnt, XrdXrootdMonTrace::rTot, XrdXrootdMonTrace::wTot, and XROOTD_MON_CLOSE.
Referenced by XrdXrootdProtocol::do_Close(), and XrdXrootdFileTable::Recycle().
| void XrdXrootdMonitor::Defaults |
( |
char * |
dest1, |
|
|
int |
m1, |
|
|
char * |
dest2, |
|
|
int |
m2 |
|
) |
| |
|
static |
References Dest1, Dest2, XrdOucEnv::Export(), isEnabled, monACTIVE, monAUTH, monCLOCK, monFILE, monFSTAT, monIdent, monINFO, monIO, monMode1, monMode2, monREDR, monUSER, XROOTD_MON_ALL, XROOTD_MON_AUTH, XROOTD_MON_FILE, XROOTD_MON_FSTA, XROOTD_MON_INFO, XROOTD_MON_IO, XROOTD_MON_IOV, XROOTD_MON_REDR, and XROOTD_MON_USER.
Referenced by XrdXrootdProtocol::xmon().
| void XrdXrootdMonitor::Defaults |
( |
int |
msz, |
|
|
int |
rsz, |
|
|
int |
wsz, |
|
|
int |
flush, |
|
|
int |
flash, |
|
|
int |
iDent, |
|
|
int |
rnm, |
|
|
int |
fsint = 0, |
|
|
int |
fsopt = 0, |
|
|
int |
fsion = 0 |
|
) |
| |
|
static |
References autoFlash, autoFlush, XrdXrootdMonFile::Defaults(), lastEnt, lastRnt, monBlen, monFSTAT, monIdent, monRlen, rdrMax, rdrNum, rdrWin, and sizeWindow.
| void XrdXrootdMonitor::Disc |
( |
kXR_unt32 |
dictid, |
|
|
int |
csec, |
|
|
char |
Flags = 0 |
|
) |
| |
References altMon, XrdXrootdMonTrace::arg0, XrdXrootdMonTrace::arg1, XrdXrootdMonTrace::arg2, currWindow, XrdXrootdMonTrace::dictid, Disc(), Dup(), Flush(), XrdXrootdMonTrace::id, XrdXrootdMonBuff::info, lastEnt, lastWindow, Mark(), monBuff, monUSER, nextEnt, XrdXrootdMonTrace::rTot, XrdXrootdMonTrace::wTot, and XROOTD_MON_DISC.
Referenced by Disc(), and XrdXrootdProtocol::Recycle().
| unsigned char XrdXrootdMonitor::do_Shift |
( |
long long |
xTot, |
|
|
unsigned int & |
xVal |
|
) |
| |
|
private |
| void XrdXrootdMonitor::Flush |
( |
| ) |
|
|
private |
References altMon, autoFlush, currWindow, fillHeader(), FlushTime, XrdXrootdMonBuff::hdr, lastWindow, monBuff, nextEnt, Send(), setTMark, sizeWindow, XROOTD_MON_FILE, XROOTD_MON_IO, and XROOTD_MON_MAPTRCE.
Referenced by Add_io(), Add_rv(), appID(), Close(), Disc(), Dup(), Mark(), Open(), Redirect(), Tick(), and ~XrdXrootdMonitor().
References autoFlush, XrdXrootdMonitor::MonRdrBuff::Buff, fillHeader(), XrdXrootdMonitor::MonRdrBuff::flushIt, XrdXrootdMonBurr::hdr, XrdXrootdMonitor::MonRdrBuff::lastTOD, XrdXrootdMonitor::MonRdrBuff::nextEnt, rdrTOD, Send(), setTMurk, XROOTD_MON_MAPREDR, and XROOTD_MON_REDR.
| static void XrdXrootdMonitor::Ident |
( |
| ) |
|
|
inlinestatic |
| int XrdXrootdMonitor::Init |
( |
XrdScheduler * |
sp, |
|
|
XrdSysError * |
errp, |
|
|
const char * |
iHost, |
|
|
const char * |
iProg, |
|
|
const char * |
iName, |
|
|
int |
Port |
|
) |
| |
|
static |
References altMon, autoFlush, XrdXrootdMonitor::MonRdrBuff::Buff, Dest1, Dest2, XrdXrootdMonMap::dictid, eDest, XrdSysError::Emsg(), XrdNetPeer::fd, fillHeader(), XrdXrootdMonitor::MonRdrBuff::flushIt, XrdXrootdMonMap::hdr, XrdSysDNS::Host2Dest(), XrdOucUtils::Ident(), idLen, idRec, InetAddr1, InetAddr2, XrdXrootdMonMap::info, XrdXrootdMonFile::Init(), isEnabled, XrdXrootdMonitor::MonRdrBuff::lastTOD, monBuff, monCLOCK, monFD, monFSTAT, monIdent, monMode1, monMode2, monREDR, monRlen, mySID, XrdXrootdMonitor::MonRdrBuff::Next, XrdXrootdMonitor::MonRdrBuff::nextEnt, XrdXrootdMonHeader::pseq, rdrMon, rdrMP, rdrNum, XrdNet::Relay(), Sched, XrdScheduler::Schedule(), XrdXrootdMonBurr::sID, sidName, sidSize, startClock(), startTime, XrdXrootdMonBurr::sXX, XRDNET_SENDONLY, XrdVERSION, XrdXrootdMonitor(), XROOTD_MON_IO, XROOTD_MON_MAPIDNT, and XROOTD_MON_REDSID.
Referenced by XrdXrootdProtocol::Configure().
References XrdXrootdMonMap::dictid, fillHeader(), GetDictID(), XrdXrootdMonMap::hdr, XrdXrootdMonMap::info, XrdXrootdMonitor::User::Len, XrdXrootdMonitor::User::Name, Send(), strlcpy(), XROOTD_MON_INFO, XROOTD_MON_MAPPATH, XROOTD_MON_MAPUSER, XROOTD_MON_PATH, and XROOTD_MON_USER.
Referenced by XrdXrootdMonitor::User::MapInfo(), XrdXrootdMonitor::User::MapPath(), and XrdXrootdMonitor::User::Report().
| void XrdXrootdMonitor::Mark |
( |
| ) |
|
|
private |
References altMon, XrdXrootdMonTrace::arg0, XrdXrootdMonTrace::arg1, XrdXrootdMonTrace::arg2, autoFlash, currWindow, Flush(), XrdXrootdMonTrace::id, XrdXrootdMonBuff::info, lastEnt, lastWindow, monBuff, mySID, nextEnt, sizeWindow, XrdXrootdMonTrace::val, XrdXrootdMonTrace::Window, and XROOTD_MON_WINDOW.
Referenced by Add_io(), Add_rv(), appID(), Close(), Disc(), Dup(), and Open().
| void XrdXrootdMonitor::Open |
( |
kXR_unt32 |
dictid, |
|
|
off_t |
fsize |
|
) |
| |
References altMon, XrdXrootdMonTrace::arg0, XrdXrootdMonTrace::arg1, XrdXrootdMonTrace::arg2, XrdXrootdMonTrace::buflen, currWindow, XrdXrootdMonTrace::dictid, Dup(), Flush(), XrdXrootdMonTrace::id, XrdXrootdMonBuff::info, lastEnt, lastWindow, Mark(), monBuff, nextEnt, XrdXrootdMonTrace::val, and XROOTD_MON_OPEN.
Referenced by XrdXrootdProtocol::do_Open().
| static int XrdXrootdMonitor::Redirect |
( |
| ) |
|
|
inlinestatic |
| int XrdXrootdMonitor::Redirect |
( |
kXR_unt32 |
mID, |
|
|
const char * |
hName, |
|
|
int |
Port, |
|
|
const char |
opC, |
|
|
const char * |
Path |
|
) |
| |
|
static |
References XrdXrootdMonRedir::arg0, XrdXrootdMonRedir::arg1, XrdXrootdMonitor::MonRdrBuff::Buff, XrdXrootdMonRedir::dictid, Fetch(), Flush(), XrdXrootdMonBurr::info, lastRnt, XrdXrootdMonitor::MonRdrBuff::lastTOD, XrdSysMutex::Lock(), XrdXrootdMonitor::MonRdrBuff::Mutex, XrdXrootdMonitor::MonRdrBuff::nextEnt, XrdXrootdMonRedir::rdr, rdrTOD, setTMurk, XrdSysMutex::UnLock(), and XROOTD_MON_REDIRECT.
| int XrdXrootdMonitor::Send |
( |
int |
mmode, |
|
|
void * |
buff, |
|
|
int |
size |
|
) |
| |
|
staticprivate |
References DEBUG, Dest1, Dest2, InetAddr1, InetAddr2, XrdSysMutex::Lock(), monFD, monMode1, monMode2, TRACE, and XrdSysMutex::UnLock().
Referenced by XrdXrootdMonFile::Flush(), Flush(), Ident(), and Map().
| void XrdXrootdMonitor::startClock |
( |
| ) |
|
|
staticprivate |
| time_t XrdXrootdMonitor::Tick |
( |
| ) |
|
|
static |
References altMon, autoFlush, currWindow, Flush(), XrdXrootdMonitor::MonRdrBuff::flushIt, FlushTime, isEnabled, XrdSysMutex::Lock(), XrdXrootdMonitorLock::Lock(), monREDR, XrdXrootdMonitor::MonRdrBuff::Mutex, nextEnt, numMonitor, rdrMon, rdrNum, rdrTOD, XrdSysMutex::UnLock(), XrdXrootdMonitorLock::UnLock(), and windowMutex.
Referenced by XrdXrootdMonitor_Tick::DoIt().
Referenced by Alloc(), appID(), Close(), Disc(), Flush(), Init(), Mark(), Open(), Tick(), unAlloc(), and XrdXrootdMonitorLock::XrdXrootdMonitorLock().
| int XrdXrootdMonitor::autoFlash = 0 |
|
staticprivate |
| int XrdXrootdMonitor::autoFlush = 600 |
|
staticprivate |
Referenced by Add_io(), Add_rv(), appID(), Close(), Disc(), Dup(), Flush(), Mark(), Open(), startClock(), Tick(), and XrdXrootdMonitor().
| char * XrdXrootdMonitor::Dest1 = 0 |
|
staticprivate |
| char * XrdXrootdMonitor::Dest2 = 0 |
|
staticreadprivate |
| int XrdXrootdMonitor::FlushTime = 0 |
|
staticprivate |
| int XrdXrootdMonitor::idLen = 0 |
|
staticprivate |
| char * XrdXrootdMonitor::idRec = 0 |
|
staticprivate |
| struct sockaddr XrdXrootdMonitor::InetAddr1 |
|
staticprivate |
| struct sockaddr XrdXrootdMonitor::InetAddr2 |
|
staticprivate |
| int XrdXrootdMonitor::isEnabled = 0 |
|
staticprivate |
| int XrdXrootdMonitor::lastEnt = 0 |
|
staticprivate |
| int XrdXrootdMonitor::lastRnt = 0 |
|
staticprivate |
| char XrdXrootdMonitor::monACTIVE = 0 |
|
staticprivate |
| char XrdXrootdMonitor::monAUTH = 0 |
|
staticprivate |
| int XrdXrootdMonitor::monBlen = 0 |
|
staticprivate |
Referenced by Add_io(), Add_rv(), Alloc(), appID(), Close(), Disc(), Dup(), Flush(), Init(), Mark(), Open(), XrdXrootdMonitor(), and ~XrdXrootdMonitor().
| char XrdXrootdMonitor::monCLOCK = 0 |
|
staticprivate |
| int XrdXrootdMonitor::monFD |
|
staticprivate |
| char XrdXrootdMonitor::monFILE = 0 |
|
staticprivate |
| char XrdXrootdMonitor::monFSTAT = 0 |
|
staticprivate |
| int XrdXrootdMonitor::monIdent = 3600 |
|
staticprivate |
| char XrdXrootdMonitor::monINFO = 0 |
|
staticprivate |
| char XrdXrootdMonitor::monIO = 0 |
|
staticprivate |
| int XrdXrootdMonitor::monMode1 = 0 |
|
staticprivate |
| int XrdXrootdMonitor::monMode2 = 0 |
|
staticprivate |
| char XrdXrootdMonitor::monREDR = 0 |
|
staticprivate |
| int XrdXrootdMonitor::monRlen = 0 |
|
staticprivate |
| char XrdXrootdMonitor::monUSER = 0 |
|
staticprivate |
| long long XrdXrootdMonitor::mySID = 0 |
|
staticprivate |
| int XrdXrootdMonitor::nextEnt |
|
private |
Referenced by Add_io(), Add_rv(), appID(), Close(), Disc(), Dup(), Flush(), Mark(), Open(), Tick(), and XrdXrootdMonitor().
| int XrdXrootdMonitor::numMonitor = 0 |
|
staticprivate |
| const int XrdXrootdMonitor::rdrMax = 8 |
|
static |
| int XrdXrootdMonitor::rdrNum = 3 |
|
staticprivate |
| int XrdXrootdMonitor::rdrTOD = 0 |
|
staticprivate |
| int XrdXrootdMonitor::rdrWin = 0 |
|
staticprivate |
| char XrdXrootdMonitor::sidName = {0} |
|
staticprivate |
| short XrdXrootdMonitor::sidSize = 0 |
|
staticprivate |
The documentation for this class was generated from the following files: