XrdAdaptor::XrdStatisticsService Class Reference

#include <XrdStatistics.h>

Inheritance diagram for XrdAdaptor::XrdStatisticsService:

Public Member Functions
std::vector< std::pair < std::string, CondorIOStats > >	condorUpdate () final
void	postEndJob ()
	XrdStatisticsService (const edm::ParameterSet &iPS, edm::ActivityRegistry &iRegistry)
Public Member Functions inherited from xrd_adaptor::XrdStatistics
	XrdStatistics ()
virtual	~XrdStatistics ()

Static Public Member Functions
static void	fillDescriptions (edm::ConfigurationDescriptions &descriptions)

Detailed Description

Definition at line 36 of file XrdStatistics.h.

Constructor & Destructor Documentation

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

Definition at line 24 of file XrdStatistics.cc.

References edm::ParameterSet::getUntrackedParameter(), 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 ( )

finalvirtual

Implements xrd_adaptor::XrdStatistics.

Definition at line 50 of file XrdStatistics.cc.

References xrd_adaptor::XrdStatistics::CondorIOStats::bytesRead, fwrapper::cs, edm::get_underlying_safe(), instance, CommonMethods::lock(), XrdAdaptor::XrdSiteStatisticsInformation::m_mutex, XrdAdaptor::XrdSiteStatisticsInformation::m_sites, mps_fire::result, contentValuesCheck::ss, dqmMemoryStats::stats, and xrd_adaptor::XrdStatistics::CondorIOStats::transferTime.

                                                                                                    {
  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 )

static

Definition at line 96 of file XrdStatistics.cc.

References edm::ConfigurationDescriptions::add(), edm::ParameterSetDescription::addUntracked(), submitPVResolutionJobs::desc, 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("XrdStatisticsService", desc);
}

void XrdStatisticsService::postEndJob

(

)

Definition at line 32 of file XrdStatistics.cc.

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

                                      {
  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);
  }
}