XrdStatsConfig.cc File Reference

#include "XrdVersion.hh"
#include "XrdStatsConfig.hh"
#include "XrdStatsFileSystem.hh"
#include "XrdSys/XrdSysError.hh"
#include <sstream>

Include dependency graph for XrdStatsConfig.cc:

Go to the source code of this file.

Functions
std::string	LogMaskToString (int mask)
bool	ParseDuration (const std::string &duration, std::chrono::steady_clock::duration &result, std::string &errmsg)
XrdOss *	XrdOssAddStorageSystem2 (XrdOss *curr_oss, XrdSysLogger *logger, const char *config_fn, const char *parms, XrdOucEnv *envP)
	XrdVERSIONINFO (XrdOssAddStorageSystem2, fsstats)
	XrdVERSIONINFO (XrdOssGetFileSystem, Stats)

Function Documentation

LogMaskToString()

std::string LogMaskToString

(

int

mask

)

Definition at line 13 of file XrdStatsConfig.cc.

                                    {
    if (mask == LogMask::All) {return "all";}
 
    bool has_entry = false;
    std::stringstream ss;
    if (mask & LogMask::Debug) {
        ss << "debug";
        has_entry = true;
    }
    if (mask & LogMask::Info) {
        ss << (has_entry ? ", " : "") << "info";
        has_entry = true;
    }
    if (mask & LogMask::Warning) {
        ss << (has_entry ? ", " : "") << "warning";
        has_entry = true;
    }
    if (mask & LogMask::Error) {
        ss << (has_entry ? ", " : "") << "error";
        has_entry = true;
    }
    return ss.str();
}

References All, Macaroons::Debug, Macaroons::Error, Info, and Warning.

Referenced by StatsFileSystem::Config().

Here is the caller graph for this function:

ParseDuration()

bool ParseDuration	(	const std::string &	duration,
		std::chrono::steady_clock::duration &	result,
		std::string &	errmsg
	)

Definition at line 41 of file XrdStatsConfig.cc.

                                                                                                        {
 
    if (duration.empty()) {
        errmsg = "cannot parse empty string as a time duration";
        return false;
    }
    if (duration == "0") {
        result = std::chrono::steady_clock::duration(0);
        return true;
    }
    std::chrono::steady_clock::duration dur(0);
    auto strValue = duration;
    while (!strValue.empty()) {
        std::size_t pos;
        double value;
        try {
            value = std::stod(strValue, &pos);
        } catch (std::invalid_argument const &exc) {
            errmsg = "Invalid number provided as timeout: " + strValue;
            return false;
        } catch (std::out_of_range const &exc) {
            errmsg = "Provided timeout out of representable range: " + std::string(exc.what());
            return false;
        }
        if (value < 0) {
            errmsg = "Provided timeout was negative";
            return false;
        }
        strValue = strValue.substr(pos);
        char unit[3] = {'\0', '\0', '\0'};
        if (!strValue.empty()) {
            unit[0] = strValue[0];
            if (unit[0] >= '0' && unit[0] <= '9') {unit[0] = '\0';}
        }
        if (strValue.size() > 1) {
            unit[1] = strValue[1];
            if (unit[1] >= '0' && unit[1] <= '9') {unit[1] = '\0';}
        }
        if (!strncmp(unit, "ns", 2)) {
            dur += std::chrono::duration_cast<typeof(dur)>(std::chrono::duration<double, std::nano>(value));
        } else if (!strncmp(unit, "us", 2)) {
            dur += std::chrono::duration_cast<typeof(dur)>(std::chrono::duration<double, std::micro>(value));
        } else if (!strncmp(unit, "ms", 2)) {
            dur += std::chrono::duration_cast<typeof(dur)>(std::chrono::duration<double, std::milli>(value));
        } else if (!strncmp(unit, "s", 1)) {
            dur += std::chrono::duration_cast<typeof(dur)>(std::chrono::duration<double>(value));
        } else if (!strncmp(unit, "m", 1)) {
            dur += std::chrono::duration_cast<typeof(dur)>(std::chrono::duration<double, std::ratio<60>>(value));
        } else if (!strncmp(unit, "h", 1)) {
            dur += std::chrono::duration_cast<typeof(dur)>(std::chrono::duration<double, std::ratio<3600>>(value));
        } else if (strlen(unit) > 0) {
            errmsg = "Unknown unit in duration: " + std::string(unit);
            return false;
        } else {
            errmsg = "Unit missing from duration: " + duration;
            return false;
        }
        strValue = strValue.substr(strlen(unit));
    }
    result = dur;
    return true;
}

Referenced by StatsFileSystem::Config().

Here is the caller graph for this function:

XrdOssAddStorageSystem2()

XrdOss* XrdOssAddStorageSystem2	(	XrdOss *	curr_oss,
		XrdSysLogger *	logger,
		const char *	config_fn,
		const char *	parms,
		XrdOucEnv *	envP
	)

Definition at line 110 of file XrdStatsConfig.cc.

{
                   
    XrdSysError log(logger, "fsstats_");
    try {
        return new StatsFileSystem(curr_oss, logger, config_fn, envP);
    } catch (std::runtime_error &re) {
        log.Emsg("Initialize", "Encountered a runtime failure:", re.what());
        return nullptr;
    }
}

References XrdSysError::Emsg(), and XrdProxy::envP.

Here is the call graph for this function:

XrdVERSIONINFO() [1/2]

XrdVERSIONINFO	(	XrdOssAddStorageSystem2	,
		fsstats
	)

XrdVERSIONINFO() [2/2]

XrdVERSIONINFO	(	XrdOssGetFileSystem	,
		Stats
	)