XrdHttpMon Class Reference

#include <XrdHttpMon.hh>

Collaboration diagram for XrdHttpMon:

Classes
struct	HttpInfo

Public Types
enum	StatusCodes {   sc_100 ,   sc_200 ,   sc_201 ,   sc_202 ,   sc_206 ,   sc_207 ,   sc_302 ,   sc_307 ,   sc_400 ,   sc_401 ,   sc_403 ,   sc_404 ,   sc_405 ,   sc_409 ,   sc_416 ,   sc_423 ,   sc_500 ,   sc_502 ,   sc_504 ,   sc_507 ,   sc_UNKNOWN ,   sc_Count }

Static Public Member Functions
static void	Initialize (XrdSysLogger *logP, XrdXrootdGStream *gStream, XrdMonRoll *mrollP)
static bool	IsInitialized ()
static void	Record (XrdHttpReq &req, int code)
static void *	Start (void *)

Detailed Description

Definition at line 13 of file XrdHttpMon.hh.

---

Class Documentation

XrdHttpMon::HttpInfo

struct XrdHttpMon::HttpInfo

Definition at line 44 of file XrdHttpMon.hh.

Collaboration diagram for XrdHttpMon::HttpInfo:

Class Members
RAtomic_uint64_t	count {0}
RAtomic_uint64_t	duration_us {0}
RAtomic_uint64_t	error_network {0}
RAtomic_uint64_t	error_xrootd {0}
RAtomic_uint64_t	success {0}

Member Enumeration Documentation

StatusCodes

enum XrdHttpMon::StatusCodes

Enumerator
sc_100
sc_200
sc_201
sc_202
sc_206
sc_207
sc_302
sc_307
sc_400
sc_401
sc_403
sc_404
sc_405
sc_409
sc_416
sc_423
sc_500
sc_502
sc_504
sc_507
sc_UNKNOWN
sc_Count

Definition at line 18 of file XrdHttpMon.hh.

                     {
        sc_100,
        sc_200,
        sc_201,
        sc_202,
        sc_206,
        sc_207,
        sc_302,
        sc_307,
        sc_400,
        sc_401,
        sc_403,
        sc_404,
        sc_405,
        sc_409,
        sc_416,
        sc_423,
        sc_500,
        sc_502,
        sc_504,
        sc_507,
        sc_UNKNOWN,
        sc_Count
    };

Member Function Documentation

Initialize()

void XrdHttpMon::Initialize ( XrdSysLogger * logP, XrdXrootdGStream * gStream, XrdMonRoll * mrollP )

static

Definition at line 74 of file XrdHttpMon.cc.

                                                                                             {
    eDest.logger(logP);
    XrdHttpMon::gStream = gStream;
    XrdHttpMon::mrollP = mrollP;
 
    if (gStream != nullptr){
        hasGStream = true;
        flushPeriod = std::chrono::seconds(gStream->GetAutoFlush());
    }
 
    if (mrollP != nullptr) {
        hasMonRoll = true;
        mrollP->Register(XrdMonRoll::AddOn, "http_plugin", statsSchema);
    }
 
    isInitialized = true;
}

References XrdMonRoll::AddOn, and eDest.

IsInitialized()

bool XrdHttpMon::IsInitialized ( )

inlinestatic

Definition at line 56 of file XrdHttpMon.hh.

{ return isInitialized; }

Record()

void XrdHttpMon::Record ( XrdHttpReq & req, int code )

static

Definition at line 106 of file XrdHttpMon.cc.

{
    // Early return if monitoring is not enabled.
    if (!isInitialized) return;
 
    // Only record once we have a "final" (>= 200) response code. 100-Continue is interim.
    if (code < 200) return;
 
    std::chrono::steady_clock::duration duration{};
    if (hasGStream) {
        const auto now = std::chrono::steady_clock::now();
        duration = now - req.startTime;
    }
 
    StatusCodes statusCode = ToStatusCode(code);
    XrdHttpMonState st = req.monState;
 
    if (req.request >= XrdHttpReq::ReqType::rtCount || req.request < 0) {
        eDest.Emsg("Record", "ERROR: Record called with invalid request type");
        return;
    }
 
    switch (st) {
        case XrdHttpMonState::NEW:
            RecordGStreamCount(req.request, statusCode);
            RecordMonRollVerb(req.request);
            req.monState = XrdHttpMonState::ACTIVE;
            return;
 
        case XrdHttpMonState::ACTIVE:
            RecordGStreamSuccess(req.request, statusCode, duration);
            RecordMonRollStatus(statusCode);
            req.monState = XrdHttpMonState::DONE;
            return;
 
        case XrdHttpMonState::ERR_NET:
            RecordGStreamErrNet(req.request, statusCode, duration);
            RecordMonRollStatus(statusCode);
            req.monState = XrdHttpMonState::DONE;
            return;
 
        case XrdHttpMonState::ERR_PROT:
            RecordGStreamErrProt(req.request, statusCode, duration);
            RecordMonRollStatus(statusCode);
            req.monState = XrdHttpMonState::DONE;
            return;
 
        case XrdHttpMonState::DONE:
            eDest.Emsg("Record", "ERROR: Record called after state was set to DONE");
            return;
    }
}

References ACTIVE, DONE, eDest, ERR_NET, ERR_PROT, XrdHttpReq::monState, NEW, XrdHttpReq::request, XrdHttpReq::rtCount, and XrdHttpReq::startTime.

Start()

void * XrdHttpMon::Start ( void * )

static

Definition at line 99 of file XrdHttpMon.cc.

                             {
    while (true) {
        std::this_thread::sleep_for(flushPeriod);
        Report();
    }
}

---

The documentation for this class was generated from the following files:

• XrdHttpMon.hh
• XrdHttpMon.cc