#include <ThroughputService.h>

Classes
struct	stream_histograms

Public Member Functions
	ThroughputService (const edm::ParameterSet &, edm::ActivityRegistry &)

	~ThroughputService ()

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

Private Member Functions
void	postEvent (edm::StreamContext const &sc)

void	postStreamEndLumi (edm::StreamContext const &sc)

void	postStreamEndRun (edm::StreamContext const &sc)

void	preallocate (edm::service::SystemBounds const &bounds)

void	preSourceEvent (edm::StreamID sid)

void	preStreamBeginRun (edm::StreamContext const &sc)

Private Attributes
std::string	m_dqm_path

unsigned int	m_module_id

std::chrono::steady_clock::time_point	m_startup

std::vector< stream_histograms >	m_stream_histograms

double	m_time_range

double	m_time_resolution

Detailed Description

Definition at line 29 of file ThroughputService.h.

Constructor & Destructor Documentation

ThroughputService::ThroughputService	(	const edm::ParameterSet &	config,
		edm::ActivityRegistry &	registry
	)

Definition at line 22 of file ThroughputService.cc.

References postEvent(), postStreamEndLumi(), postStreamEndRun(), preallocate(), preSourceEvent(), preStreamBeginRun(), edm::ActivityRegistry::watchPostEvent(), edm::ActivityRegistry::watchPostStreamEndLumi(), edm::ActivityRegistry::watchPostStreamEndRun(), edm::ActivityRegistry::watchPreallocate(), edm::ActivityRegistry::watchPreSourceEvent(), and edm::ActivityRegistry::watchPreStreamBeginRun().

                                                                                                    :
   m_stream_histograms(),
   // configuration
   m_time_range(      config.getUntrackedParameter<double>("timeRange") ),
   m_time_resolution( config.getUntrackedParameter<double>("timeResolution") ),
   m_dqm_path(        config.getUntrackedParameter<std::string>("dqmPath" ) )
 {
   registry.watchPreallocate(        this, & ThroughputService::preallocate );
   registry.watchPreStreamBeginRun(  this, & ThroughputService::preStreamBeginRun );
   registry.watchPostStreamEndLumi(  this, & ThroughputService::postStreamEndLumi );
   registry.watchPostStreamEndRun(   this, & ThroughputService::postStreamEndRun );
   registry.watchPreSourceEvent(     this, & ThroughputService::preSourceEvent );
   registry.watchPostEvent(          this, & ThroughputService::postEvent );
 }

ThroughputService::~ThroughputService ( )

Definition at line 37 of file ThroughputService.cc.

38 {

39 }

Member Function Documentation

void ThroughputService::fillDescriptions ( edm::ConfigurationDescriptions & descriptions )

static

Definition at line 14 of file ThroughputService.cc.

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

                                                                                     {
   edm::ParameterSetDescription desc;
   desc.addUntracked<double>(        "timeRange",       60000.0 );
   desc.addUntracked<double>(        "timeResolution",     10.0 );
   desc.addUntracked<std::string>(   "dqmPath",           "HLT/Throughput" );
   descriptions.add("ThroughputService", desc);
 }

void ThroughputService::postEvent ( edm::StreamContext const & sc )

private

Definition at line 102 of file ThroughputService.cc.

References KineDebug3::count(), m_startup, m_stream_histograms, fileCollector::now, edm::StreamContext::streamID(), cond::timestamp, and edm::StreamID::value().

Referenced by ThroughputService().

 {
   unsigned int sid = sc.streamID().value();
   auto timestamp = std::chrono::steady_clock::now();
   m_stream_histograms[sid].retired_events->Fill( std::chrono::duration_cast<std::chrono::duration<double>>(timestamp - m_startup).count() );
 }

void ThroughputService::postStreamEndLumi ( edm::StreamContext const & sc )

private

Definition at line 81 of file ThroughputService.cc.

References edm::StreamContext::eventID(), edm::EventID::luminosityBlock(), m_module_id, edm::EventID::run(), edm::StreamContext::streamID(), and edm::StreamID::value().

Referenced by ThroughputService().

 {
   if (edm::Service<DQMStore>().isAvailable())
     edm::Service<DQMStore>()->mergeAndResetMEsLuminositySummaryCache(sc.eventID().run(), sc.eventID().luminosityBlock(), sc.streamID().value(), m_module_id);
 }

void ThroughputService::postStreamEndRun ( edm::StreamContext const & sc )

private

Definition at line 88 of file ThroughputService.cc.

References edm::StreamContext::eventID(), m_module_id, edm::EventID::run(), edm::StreamContext::streamID(), and edm::StreamID::value().

Referenced by ThroughputService().

 {
   if (edm::Service<DQMStore>().isAvailable())
     edm::Service<DQMStore>()->mergeAndResetMEsRunSummaryCache(sc.eventID().run(), sc.streamID().value(), m_module_id);
 }

void ThroughputService::preallocate ( edm::service::SystemBounds const & bounds )

private

Definition at line 42 of file ThroughputService.cc.

References edm::ModuleDescription::getUniqueID(), m_module_id, m_startup, m_stream_histograms, edm::service::SystemBounds::maxNumberOfStreams(), and fileCollector::now.

Referenced by ThroughputService().

 {
   m_startup = std::chrono::steady_clock::now();
 
   m_stream_histograms.resize( bounds.maxNumberOfStreams() );
 
   // assign a pseudo module id to the FastTimerService
   m_module_id = edm::ModuleDescription::getUniqueID();
 }

void ThroughputService::preSourceEvent ( edm::StreamID sid )

private

Definition at line 95 of file ThroughputService.cc.

References KineDebug3::count(), m_startup, m_stream_histograms, fileCollector::now, and cond::timestamp.

Referenced by ThroughputService().

 {
   auto timestamp = std::chrono::steady_clock::now();
   m_stream_histograms[sid].sourced_events->Fill( std::chrono::duration_cast<std::chrono::duration<double>>(timestamp - m_startup).count() );
 }

void ThroughputService::preStreamBeginRun ( edm::StreamContext const & sc )

private

Definition at line 53 of file ThroughputService.cc.

References edm::StreamContext::eventID(), cmsPerfStripChart::format, m_dqm_path, m_module_id, m_stream_histograms, m_time_range, m_time_resolution, edm::EventID::run(), edm::StreamContext::streamID(), AlCaHLTBitMon_QueryRunRegistry::string, and edm::StreamID::value().

Referenced by ThroughputService().

 {
   // if the DQMStore is available, book the DQM histograms
   if (edm::Service<DQMStore>().isAvailable()) {
     unsigned int sid = sc.streamID().value();
     auto & stream = m_stream_histograms[sid];
 
     std::string   y_axis_title = (boost::format("events / %g s") % m_time_resolution).str();
     unsigned int  bins         = std::round( m_time_range / m_time_resolution );
     double        range        = bins * m_time_resolution; 
 
     // define a callback that can book the histograms
     auto bookTransactionCallback = [&, this] (DQMStore::IBooker & booker) {
       booker.setCurrentFolder(m_dqm_path);
       stream.sourced_events = booker.book1D("throughput_sourced",  "Throughput (sourced events)",   bins, 0., range)->getTH1F();
       stream.sourced_events ->SetXTitle("time [s]");
       stream.sourced_events ->SetYTitle(y_axis_title.c_str());
       stream.retired_events = booker.book1D("throughput_retired",  "Throughput (retired events)",   bins, 0., range)->getTH1F();
       stream.retired_events ->SetXTitle("time [s]");
       stream.retired_events ->SetYTitle(y_axis_title.c_str());
     };
 
     // book MonitorElement's for this stream
     edm::Service<DQMStore>()->bookTransaction(bookTransactionCallback, sc.eventID().run(), sid, m_module_id);
   }
 }