XrdAdaptor::XrdStatisticsService Class Reference

#include <XrdStatistics.h>

Classes
struct	CondorIOStats

Public Member Functions
std::vector< std::pair< std::string, CondorIOStats > >	condorUpdate ()
void	fillDescriptions (edm::ConfigurationDescriptions &descriptions)
void	postEndJob ()
	XrdStatisticsService (const edm::ParameterSet &iPS, edm::ActivityRegistry &iRegistry)

Detailed Description

Definition at line 39 of file XrdStatistics.h.

Constructor & Destructor Documentation

XrdStatisticsService::XrdStatisticsService	(	const edm::ParameterSet &	iPS,
		edm::ActivityRegistry &	iRegistry
	)

Definition at line 20 of file XrdStatistics.cc.

References XrdAdaptor::XrdSiteStatisticsInformation::createInstance(), edm::ParameterSet::getUntrackedParameter(), postEndJob(), and edm::ActivityRegistry::watchPostEndJob().

{
    XrdSiteStatisticsInformation::createInstance();

    if (iPS.getUntrackedParameter<bool>("reportToFJR", false))
    {
        iRegistry.watchPostEndJob(this, &XrdStatisticsService::postEndJob);
    }
}

Member Function Documentation

std::vector< std::pair< std::string, XrdStatisticsService::CondorIOStats > > XrdStatisticsService::condorUpdate

(

)

Definition at line 48 of file XrdStatistics.cc.

References XrdAdaptor::XrdStatisticsService::CondorIOStats::bytesRead, fwrapper::cs, edm::get_underlying_safe(), XrdAdaptor::XrdSiteStatisticsInformation::getInstance(), instance, CommonMethods::lock(), XrdAdaptor::XrdSiteStatisticsInformation::m_mutex, XrdAdaptor::XrdSiteStatisticsInformation::m_sites, mps_fire::result, and XrdAdaptor::XrdStatisticsService::CondorIOStats::transferTime.

Referenced by edm::service::CondorStatusService::updateImpl().

{
    std::vector<std::pair<std::string, XrdStatisticsService::CondorIOStats>> result;
    XrdSiteStatisticsInformation *instance = XrdSiteStatisticsInformation::getInstance();
    if (!instance) {return result;}

    std::lock_guard<std::mutex> lock(instance->m_mutex);
    result.reserve(instance->m_sites.size());
    for (auto& stats : instance->m_sites)
    {
        CondorIOStats cs;
        std::shared_ptr<XrdSiteStatistics> ss = get_underlying_safe(stats);
        if (!ss) continue;
        cs.bytesRead = ss->getTotalBytes();
        cs.transferTime = ss->getTotalReadTime();
        result.emplace_back(ss->site(), cs);
    }
    return result;
}

void XrdStatisticsService::fillDescriptions

(

edm::ConfigurationDescriptions &

descriptions

)

Definition at line 102 of file XrdStatistics.cc.

References edm::ConfigurationDescriptions::add(), edm::ParameterSetDescription::addUntracked(), and edm::ParameterSetDescription::setComment().

{
    edm::ParameterSetDescription desc;
    desc.setComment("Report Xrootd-related statistics centrally.");
    desc.addUntracked<bool>("reportToFJR", true)
        ->setComment("True: Add per-site Xrootd statistics to the framework job report.\n"
                     "False: Collect no site-specific statistics.\n");
    descriptions.add("XrdAdaptor::XrdStatisticsService", desc);
}

void XrdStatisticsService::postEndJob

(

)

Definition at line 31 of file XrdStatistics.cc.

References XrdAdaptor::XrdSiteStatisticsInformation::getInstance(), instance, edm::Service< T >::isAvailable(), XrdAdaptor::XrdSiteStatisticsInformation::m_sites, and edm::JobReport::reportPerformanceForModule().

Referenced by XrdStatisticsService().

{
    edm::Service<edm::JobReport> reportSvc;
    if (!reportSvc.isAvailable()) {return;}

    XrdSiteStatisticsInformation *instance = XrdSiteStatisticsInformation::getInstance();
    if (!instance) {return;}

    std::map<std::string, std::string> props;
    for (auto& stats : instance->m_sites)
    {
        stats->recomputeProperties(props);
        reportSvc->reportPerformanceForModule(stats->site(), "XrdSiteStatistics", props);
    }
}