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 35 of file XrdStatistics.h.

Constructor & Destructor Documentation

XrdStatisticsService()

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

Definition at line 18 of file XrdStatistics.cc.

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

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

Member Function Documentation

condorUpdate()

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

(

)

Definition at line 44 of file XrdStatistics.cc.

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

References fwrapper::cs, edm::get_underlying_safe(), XrdAdaptor::XrdSiteStatisticsInformation::getInstance(), instance, CommonMethods::lock(), mps_fire::result, contentValuesCheck::ss, and dqmMemoryStats::stats.

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

fillDescriptions()

void XrdStatisticsService::fillDescriptions

(

edm::ConfigurationDescriptions &

descriptions

)

Definition at line 90 of file XrdStatistics.cc.

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

References edm::ConfigurationDescriptions::add(), and submitPVResolutionJobs::desc.

postEndJob()

void XrdStatisticsService::postEndJob

(

)

Definition at line 26 of file XrdStatistics.cc.

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

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

Referenced by XrdStatisticsService().