Inheritance diagram for FastTimerServiceClient:

Public Member Functions
	FastTimerServiceClient (edm::ParameterSet const &)

	~FastTimerServiceClient () override

Public Member Functions inherited from DQMEDHarvester
void	accumulate (edm::Event const &ev, edm::EventSetup const &es) final

void	beginJob () override

void	beginLuminosityBlock (edm::LuminosityBlock const &lumi, edm::EventSetup const &) final

void	beginRun (edm::Run const &run, edm::EventSetup const &) override

virtual void	dqmAnalyze (DQMStore::IBooker &, DQMStore::IGetter &, edm::Event const &, edm::EventSetup const &)

	DQMEDHarvester (edm::ParameterSet const &iConfig)

	DQMEDHarvester ()

virtual void	dqmEndRun (DQMStore::IBooker &, DQMStore::IGetter &, edm::Run const &, edm::EventSetup const &)

void	endLuminosityBlock (edm::LuminosityBlock const &, edm::EventSetup const &) final

void	endLuminosityBlockProduce (edm::LuminosityBlock &lumi, edm::EventSetup const &es) final

void	endProcessBlockProduce (edm::ProcessBlock &) final

void	endRun (edm::Run const &, edm::EventSetup const &) override

void	endRunProduce (edm::Run &run, edm::EventSetup const &es) final

	~DQMEDHarvester () override=default

Public Member Functions inherited from edm::one::EDProducer< T >
	EDProducer ()=default

	EDProducer (const EDProducer &)=delete

SerialTaskQueue *	globalLuminosityBlocksQueue () final

SerialTaskQueue *	globalRunsQueue () final

bool	hasAbilityToProduceInBeginLumis () const final

bool	hasAbilityToProduceInBeginProcessBlocks () const final

bool	hasAbilityToProduceInBeginRuns () const final

bool	hasAbilityToProduceInEndLumis () const final

bool	hasAbilityToProduceInEndProcessBlocks () const final

bool	hasAbilityToProduceInEndRuns () const final

const EDProducer &	operator= (const EDProducer &)=delete

bool	wantsGlobalLuminosityBlocks () const final

bool	wantsGlobalRuns () const final

bool	wantsInputProcessBlocks () const final

bool	wantsProcessBlocks () const final

Public Member Functions inherited from edm::one::EDProducerBase
	EDProducerBase ()

ModuleDescription const &	moduleDescription () const

bool	wantsStreamLuminosityBlocks () const

bool	wantsStreamRuns () const

	~EDProducerBase () override

Public Member Functions inherited from edm::ProducerBase
void	callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)

std::vector < edm::ProductResolverIndex > const &	indiciesForPutProducts (BranchType iBranchType) const

	ProducerBase ()

std::vector < edm::ProductResolverIndex > const &	putTokenIndexToProductResolverIndex () const

void	registerProducts (ProducerBase , ProductRegistry , ModuleDescription const &)

std::function< void(BranchDescription const &)>	registrationCallback () const
	used by the fwk to register list of products More...

void	resolvePutIndicies (BranchType iBranchType, ModuleToResolverIndicies const &iIndicies, std::string const &moduleLabel)

	~ProducerBase () noexcept(false) override

Public Member Functions inherited from edm::EDConsumerBase
std::vector< ConsumesInfo >	consumesInfo () const

void	convertCurrentProcessAlias (std::string const &processName)
	Convert "@currentProcess" in InputTag process names to the actual current process name. More...

	EDConsumerBase ()

	EDConsumerBase (EDConsumerBase const &)=delete

	EDConsumerBase (EDConsumerBase &&)=default

ESProxyIndex const *	esGetTokenIndices (edm::Transition iTrans) const

std::vector< ESProxyIndex > const &	esGetTokenIndicesVector (edm::Transition iTrans) const

std::vector< ESRecordIndex > const &	esGetTokenRecordIndicesVector (edm::Transition iTrans) const

ProductResolverIndexAndSkipBit	indexFrom (EDGetToken, BranchType, TypeID const &) const

void	itemsMayGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const

void	itemsToGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const

std::vector < ProductResolverIndexAndSkipBit > const &	itemsToGetFrom (BranchType iType) const

void	labelsForToken (EDGetToken iToken, Labels &oLabels) const

void	modulesWhoseProductsAreConsumed (std::array< std::vector< ModuleDescription const * > , NumBranchTypes > &modulesAll, std::vector< ModuleProcessName > &modulesInPreviousProcesses, ProductRegistry const &preg, std::map< std::string, ModuleDescription const > const &labelsToDesc, std::string const &processName) const

EDConsumerBase const &	operator= (EDConsumerBase const &)=delete

EDConsumerBase &	operator= (EDConsumerBase &&)=default

bool	registeredToConsume (ProductResolverIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, BranchType) const

void	selectInputProcessBlocks (ProductRegistry const &productRegistry, ProcessBlockHelperBase const &processBlockHelperBase)

ProductResolverIndexAndSkipBit	uncheckedIndexFrom (EDGetToken) const

void	updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &, bool iPrefetchMayGet)

void	updateLookup (eventsetup::ESRecordsToProxyIndices const &)

virtual	~EDConsumerBase () noexcept(false)

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

static void	fillLumiMePSetDescription (edm::ParameterSetDescription &pset)

static void	fillPUMePSetDescription (edm::ParameterSetDescription &pset)

Static Public Member Functions inherited from edm::one::EDProducerBase
static const std::string &	baseType ()

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &descriptions)

Private Member Functions
void	dqmEndJob (DQMStore::IBooker &booker, DQMStore::IGetter &getter) override

void	dqmEndLuminosityBlock (DQMStore::IBooker &booker, DQMStore::IGetter &getter, edm::LuminosityBlock const &, edm::EventSetup const &) override

void	fillPathSummaryPlots (DQMStore::IBooker &booker, DQMStore::IGetter &getter, double events, std::string const &path)

void	fillPlotsVsLumi (DQMStore::IBooker &booker, DQMStore::IGetter &getter, std::string const &current_path, std::string const &suffix, MEPSet pset)

void	fillProcessSummaryPlots (DQMStore::IBooker &booker, DQMStore::IGetter &getter, std::string const &path)

void	fillSummaryPlots (DQMStore::IBooker &booker, DQMStore::IGetter &getter)

Static Private Member Functions
static MEPSet	getHistoPSet (const edm::ParameterSet &pset)

Private Attributes
bool	doPlotsVsPixelLumi_

bool	doPlotsVsPU_

bool	doPlotsVsScalLumi_

bool	fillEveryLumiSection_

std::string	m_dqm_path

MEPSet	pixelLumiMEPSet_

MEPSet	puMEPSet_

MEPSet	scalLumiMEPSet_

Additional Inherited Members
Public Types inherited from DQMEDHarvester
typedef dqm::harvesting::DQMStore	DQMStore

typedef dqm::harvesting::MonitorElement	MonitorElement

Public Types inherited from edm::one::EDProducerBase
typedef EDProducerBase	ModuleType

Public Types inherited from edm::ProducerBase
using	ModuleToResolverIndicies = std::unordered_multimap< std::string, std::tuple< edm::TypeID const , const char , edm::ProductResolverIndex >>

typedef ProductRegistryHelper::TypeLabelList	TypeLabelList

Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels

Protected Member Functions inherited from edm::ProducerBase
ProducesCollector	producesCollector ()

Protected Member Functions inherited from edm::EDConsumerBase
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	consumes (edm::InputTag const &tag)

template<BranchType B = InEvent>
EDConsumerBaseAdaptor< B >	consumes (edm::InputTag tag) noexcept

EDGetToken	consumes (const TypeToGet &id, edm::InputTag const &tag)

template<BranchType B>
EDGetToken	consumes (TypeToGet const &id, edm::InputTag const &tag)

ConsumesCollector	consumesCollector ()
	Use a ConsumesCollector to gather consumes information from helper functions. More...

template<typename ProductType , BranchType B = InEvent>
void	consumesMany ()

void	consumesMany (const TypeToGet &id)

template<BranchType B>
void	consumesMany (const TypeToGet &id)

template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes ()

template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag const &tag)

template<Transition Tr = Transition::Event>
constexpr auto	esConsumes ()

template<Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag tag)

template<Transition Tr = Transition::Event>
ESGetTokenGeneric	esConsumes (eventsetup::EventSetupRecordKey const &iRecord, eventsetup::DataKey const &iKey)
	Used with EventSetupRecord::doGet. More...

template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	mayConsume (edm::InputTag const &tag)

EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

template<BranchType B>
EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

void	resetItemsToGetFrom (BranchType iType)

Protected Attributes inherited from DQMEDHarvester
DQMStore *	dqmstore_

edm::GetterOfProducts< DQMToken >	jobmegetter_

edm::EDPutTokenT< DQMToken >	jobToken_

edm::GetterOfProducts< DQMToken >	lumimegetter_

edm::EDPutTokenT< DQMToken >	lumiToken_

edm::GetterOfProducts< DQMToken >	runmegetter_

edm::EDPutTokenT< DQMToken >	runToken_

Detailed Description

Definition at line 33 of file FastTimerServiceClient.cc.

Constructor & Destructor Documentation

FastTimerServiceClient::FastTimerServiceClient ( edm::ParameterSet const & config )

explicit

Definition at line 76 of file FastTimerServiceClient.cc.

     : m_dqm_path(config.getUntrackedParameter<std::string>("dqmPath")),
       doPlotsVsScalLumi_(config.getParameter<bool>("doPlotsVsScalLumi")),
       doPlotsVsPixelLumi_(config.getParameter<bool>("doPlotsVsPixelLumi")),
       doPlotsVsPU_(config.getParameter<bool>("doPlotsVsPU")),
       scalLumiMEPSet_(doPlotsVsScalLumi_ ? getHistoPSet(config.getParameter<edm::ParameterSet>("scalLumiME"))
                                          : MEPSet{}),
       pixelLumiMEPSet_(doPlotsVsPixelLumi_ ? getHistoPSet(config.getParameter<edm::ParameterSet>("pixelLumiME"))
                                            : MEPSet{}),
       puMEPSet_(doPlotsVsPU_ ? getHistoPSet(config.getParameter<edm::ParameterSet>("puME")) : MEPSet{}),
       fillEveryLumiSection_(config.getParameter<bool>("fillEveryLumiSection")) {}

FastTimerServiceClient::~FastTimerServiceClient ( )

overridedefault

Member Function Documentation

void FastTimerServiceClient::dqmEndJob	(	DQMStore::IBooker &	booker,
		DQMStore::IGetter &	getter
	)

overrideprivatevirtual

Implements DQMEDHarvester.

Definition at line 90 of file FastTimerServiceClient.cc.

References fillSummaryPlots().

                                                                                        {
   fillSummaryPlots(booker, getter);
 }

void FastTimerServiceClient::dqmEndLuminosityBlock	(	DQMStore::IBooker &	booker,
		DQMStore::IGetter &	getter,
		edm::LuminosityBlock const &	lumi,
		edm::EventSetup const &	setup
	)

overrideprivatevirtual

Reimplemented from DQMEDHarvester.

Definition at line 94 of file FastTimerServiceClient.cc.

References fillEveryLumiSection_, and fillSummaryPlots().

                                                                                {
   if (fillEveryLumiSection_)
     fillSummaryPlots(booker, getter);
 }

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

static

Definition at line 475 of file FastTimerServiceClient.cc.

References edm::ConfigurationDescriptions::add(), edm::ParameterSetDescription::add(), edm::ParameterSetDescription::addUntracked(), submitPVResolutionJobs::desc, fillLumiMePSetDescription(), fillPUMePSetDescription(), and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                         {
   // The following says we do not know what parameters are allowed so do no validation
   // Please change this to state exactly what you do use, even if it is no parameters
   edm::ParameterSetDescription desc;
   desc.addUntracked<std::string>("dqmPath", "HLT/TimerService");
   desc.add<bool>("doPlotsVsScalLumi", true);
   desc.add<bool>("doPlotsVsPixelLumi", false);
   desc.add<bool>("doPlotsVsPU", true);
 
   edm::ParameterSetDescription scalLumiMEPSet;
   fillLumiMePSetDescription(scalLumiMEPSet);
   desc.add<edm::ParameterSetDescription>("scalLumiME", scalLumiMEPSet);
 
   edm::ParameterSetDescription pixelLumiMEPSet;
   fillLumiMePSetDescription(pixelLumiMEPSet);
   desc.add<edm::ParameterSetDescription>("pixelLumiME", pixelLumiMEPSet);
 
   edm::ParameterSetDescription puMEPSet;
   fillPUMePSetDescription(puMEPSet);
   desc.add<edm::ParameterSetDescription>("puME", puMEPSet);
   desc.add<bool>("fillEveryLumiSection", true);
   descriptions.add("fastTimerServiceClient", desc);
 }

void FastTimerServiceClient::fillLumiMePSetDescription ( edm::ParameterSetDescription & pset )

static

Definition at line 449 of file FastTimerServiceClient.cc.

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

Referenced by fillDescriptions().

                                                                                        {
   pset.add<std::string>("folder", "HLT/LumiMonitoring");
   pset.add<std::string>("name", "lumiVsLS");
   pset.add<int>("nbins", 440);
   pset.add<double>("xmin", 0.);
   pset.add<double>("xmax", 22000.);
 }

void FastTimerServiceClient::fillPathSummaryPlots	(	DQMStore::IBooker &	booker,
		DQMStore::IGetter &	getter,
		double	events,
		std::string const &	path
	)

private

Definition at line 167 of file FastTimerServiceClient.cc.

References cms::cuda::assert(), dqm::implementation::IBooker::book1D(), counter, doPlotsVsPixelLumi_, doPlotsVsPU_, doPlotsVsScalLumi_, compareTotals::efficiency, fillPlotsVsLumi(), dqm::implementation::IGetter::get(), dqm::impl::MonitorElement::getMean(), dqm::implementation::IGetter::getMEs(), dqm::implementation::IGetter::getSubdirs(), dqm::legacy::MonitorElement::getTH1D(), dqm::legacy::MonitorElement::getTH1F(), mps_fire::i, SiStripPI::max, hlt_dqm_clientPB-live_cfg::me, SiStripPI::mean, SiStripPI::min, callgraph::module, dqmiodumpmetadata::n, or, AlCaHLTBitMon_ParallelJobs::p, fed_dqm_sourceclient-live_cfg::path, pixelLumiMEPSet_, PostProcessorHGCAL_cfi::prefix, puMEPSet_, scalLumiMEPSet_, dqm::impl::MonitorElement::setBinContent(), dqm::impl::MonitorElement::setBinLabel(), dqm::implementation::NavigatorBase::setCurrentFolder(), AlCaHLTBitMon_QueryRunRegistry::string, submitPVValidationJobs::t, and ctpps_dqm_sourceclient-live_cfg::test.

Referenced by fillProcessSummaryPlots().

                                                                                  {
   // note: the following checks need to be kept separate, as any of these histograms might be missing
 
   booker.setCurrentFolder(current_path);
   std::vector<std::string> subsubdirs = getter.getSubdirs();
   size_t npaths = subsubdirs.size();
 
   MonitorElement* paths_time =
       booker.book1D("paths_time_real", "Total (real) time spent in each path", npaths, -0.5, double(npaths) - 0.5);
   MonitorElement* paths_thread =
       booker.book1D("paths_time_thread", "Total (thread) time spent in each path", npaths, -0.5, double(npaths) - 0.5);
   MonitorElement* paths_allocated =
       booker.book1D("paths_allocated", "Total allocated memory in each path", npaths, -0.5, double(npaths) - 0.5);
   MonitorElement* paths_deallocated =
       booker.book1D("paths_deallocated", "Total deallocated in each path", npaths, -0.5, double(npaths) - 0.5);
 
   MonitorElement* me;
   double mean = -1.;
 
   // extract the list of Paths and EndPaths from the summary plots
   int ibin = 1;
   for (auto const& subsubdir : subsubdirs) {
     std::string test = "/path ";
     if (subsubdir.find(test) == std::string::npos)
       continue;
 
     static const boost::regex prefix(current_path + "/path ");
     std::string path = boost::regex_replace(subsubdir, prefix, "");
 
     paths_time->setBinLabel(ibin, path);
     paths_thread->setBinLabel(ibin, path);
     paths_allocated->setBinLabel(ibin, path);
     paths_deallocated->setBinLabel(ibin, path);
 
     if ((me = getter.get(subsubdir + "/path time_real"))) {
       mean = me->getMean();
       paths_time->setBinContent(ibin, mean);
     }
     if ((me = getter.get(subsubdir + "/path time_thread"))) {
       mean = me->getMean();
       paths_thread->setBinContent(ibin, mean);
     }
     if ((me = getter.get(subsubdir + "/path allocated"))) {
       mean = me->getMean();
       paths_allocated->setBinContent(ibin, mean);
     }
 
     if ((me = getter.get(subsubdir + "/path deallocated"))) {
       mean = me->getMean();
       paths_deallocated->setBinContent(ibin, mean);
     }
 
     ibin++;
   }
 
   for (auto const& subsubdir : subsubdirs) {
     // for each path, fill histograms with
     //  - the average time spent in each module (total time spent in that module, averaged over all events)
     //  - the running time spent in each module (total time spent in that module, averaged over the events where that module actually ran)
     //  - the "efficiency" of each module (number of time a module succeded divided by the number of times the has run)
 
     getter.setCurrentFolder(subsubdir);
     std::vector<std::string> allmenames = getter.getMEs();
     if (allmenames.empty())
       continue;
 
     MonitorElement* me_counter = getter.get(subsubdir + "/module_counter");
     MonitorElement* me_real_total = getter.get(subsubdir + "/module_time_real_total");
     MonitorElement* me_thread_total = getter.get(subsubdir + "/module_time_thread_total");
 
     if (me_counter == nullptr or me_real_total == nullptr)
       continue;
 
     TH1D* counter = me_counter->getTH1D();
     TH1D* real_total = me_real_total->getTH1D();
     TH1D* thread_total = me_thread_total->getTH1D();
     uint32_t bins = counter->GetXaxis()->GetNbins() - 1;
     double min = counter->GetXaxis()->GetXmin();
     double max = counter->GetXaxis()->GetXmax() - 1;
 
     TH1F* real_average;
     TH1F* real_running;
     TH1F* thread_average;
     TH1F* thread_running;
     TH1F* efficiency;
     MonitorElement* me;
 
     booker.setCurrentFolder(subsubdir);
     me = getter.get(subsubdir + "/module_time_real_average");
     if (me) {
       real_average = me->getTH1F();
       assert(me->getTH1F()->GetXaxis()->GetXmin() == min);
       assert(me->getTH1F()->GetXaxis()->GetXmax() == max);
       real_average->Reset();
     } else {
       real_average = booker.book1D("module_time_real_average", "module real average timing", bins, min, max)->getTH1F();
       real_average->SetYTitle("average processing (real) time [ms]");
       for (uint32_t i = 1; i <= bins; ++i) {
         const char* module = counter->GetXaxis()->GetBinLabel(i);
         real_average->GetXaxis()->SetBinLabel(i, module);
       }
     }
 
     me = getter.get(subsubdir + "/module_time_thread_average");
     if (me) {
       thread_average = me->getTH1F();
       assert(me->getTH1F()->GetXaxis()->GetXmin() == min);
       assert(me->getTH1F()->GetXaxis()->GetXmax() == max);
       thread_average->Reset();
     } else {
       thread_average =
           booker.book1D("module_time_thread_average", "module thread average timing", bins, min, max)->getTH1F();
       thread_average->SetYTitle("average processing (thread) time [ms]");
       for (uint32_t i = 1; i <= bins; ++i) {
         const char* module = counter->GetXaxis()->GetBinLabel(i);
         thread_average->GetXaxis()->SetBinLabel(i, module);
       }
     }
 
     me = getter.get(subsubdir + "/module_time_real_running");
     if (me) {
       real_running = me->getTH1F();
       assert(me->getTH1F()->GetXaxis()->GetXmin() == min);
       assert(me->getTH1F()->GetXaxis()->GetXmax() == max);
       real_running->Reset();
     } else {
       real_running = booker.book1D("module_time_real_running", "module real running timing", bins, min, max)->getTH1F();
       real_running->SetYTitle("running processing (real) time [ms]");
       for (uint32_t i = 1; i <= bins; ++i) {
         const char* module = counter->GetXaxis()->GetBinLabel(i);
         real_running->GetXaxis()->SetBinLabel(i, module);
       }
     }
 
     me = getter.get(subsubdir + "/module_time_thread_running");
     if (me) {
       thread_running = me->getTH1F();
       assert(me->getTH1F()->GetXaxis()->GetXmin() == min);
       assert(me->getTH1F()->GetXaxis()->GetXmax() == max);
       thread_running->Reset();
     } else {
       thread_running =
           booker.book1D("module_time_thread_running", "module thread running timing", bins, min, max)->getTH1F();
       thread_running->SetYTitle("running processing (thread) time [ms]");
       for (uint32_t i = 1; i <= bins; ++i) {
         const char* module = counter->GetXaxis()->GetBinLabel(i);
         thread_running->GetXaxis()->SetBinLabel(i, module);
       }
     }
 
     me = getter.get(subsubdir + "/module_efficiency");
     if (me) {
       efficiency = me->getTH1F();
       assert(me->getTH1F()->GetXaxis()->GetXmin() == min);
       assert(me->getTH1F()->GetXaxis()->GetXmax() == max);
       efficiency->Reset();
     } else {
       efficiency = booker.book1D("module_efficiency", "module efficiency", bins, min, max)->getTH1F();
       efficiency->SetYTitle("filter efficiency");
       efficiency->SetMaximum(1.05);
       for (uint32_t i = 1; i <= bins; ++i) {
         const char* module = counter->GetXaxis()->GetBinLabel(i);
         efficiency->GetXaxis()->SetBinLabel(i, module);
       }
     }
 
     for (uint32_t i = 1; i <= bins; ++i) {
       double n = counter->GetBinContent(i);
       double p = counter->GetBinContent(i + 1);
       if (n)
         efficiency->SetBinContent(i, p / n);
 
       // real timing
       double t = real_total->GetBinContent(i);
       real_average->SetBinContent(i, t / events);
       if (n)
         real_running->SetBinContent(i, t / n);
 
       // thread timing
       t = thread_total->GetBinContent(i);
       thread_average->SetBinContent(i, t / events);
       if (n)
         thread_running->SetBinContent(i, t / n);
     }
 
     // vs lumi
     if (doPlotsVsScalLumi_)
       fillPlotsVsLumi(booker, getter, subsubdir, "VsScalLumi", scalLumiMEPSet_);
     if (doPlotsVsPixelLumi_)
       fillPlotsVsLumi(booker, getter, subsubdir, "VsPixelLumi", pixelLumiMEPSet_);
     if (doPlotsVsPU_)
       fillPlotsVsLumi(booker, getter, subsubdir, "VsPU", puMEPSet_);
   }
 }

void FastTimerServiceClient::fillPlotsVsLumi	(	DQMStore::IBooker &	booker,
		DQMStore::IGetter &	getter,
		std::string const &	current_path,
		std::string const &	suffix,
		MEPSet	pset
	)

private

Definition at line 366 of file FastTimerServiceClient.cc.

References cms::cuda::assert(), dqm::implementation::IBooker::bookProfile(), dqm::impl::MonitorElement::Fill(), printsummarytable::folder, MEPSet::folder, dqm::implementation::IGetter::get(), dqm::implementation::IGetter::getMEs(), dqm::legacy::MonitorElement::getTProfile(), label, dqmdumpme::lumi, visualization-live-secondInstance_cfg::m, SiStripPI::max, hlt_dqm_clientPB-live_cfg::me, MEPSet::name, mergeVDriftHistosByStation::name, MEPSet::nbins, hlt_dqm_clientPB-live_cfg::nbins, dqm::impl::MonitorElement::Reset(), dqm::implementation::NavigatorBase::setCurrentFolder(), findQualityFiles::size, AlCaHLTBitMon_QueryRunRegistry::string, ctpps_dqm_sourceclient-live_cfg::test, MEPSet::xmax, hlt_dqm_clientPB-live_cfg::xmax, MEPSet::xmin, hlt_dqm_clientPB-live_cfg::xmin, compareTotals::xtitle, y, SiStrip_OfflineMonitoring_cff::ymax, SiStrip_OfflineMonitoring_cff::ymin, and compareTotals::ytitle.

Referenced by fillPathSummaryPlots(), and fillProcessSummaryPlots().

                                                           {
   std::vector<std::string> menames;
 
   static const boost::regex byls(".*byls");
   static const boost::regex test(suffix);
   // get all MEs in the current_path
   getter.setCurrentFolder(current_path);
   std::vector<std::string> allmenames = getter.getMEs();
   for (auto const& m : allmenames) {
     // get only MEs vs LS
     if (boost::regex_match(m, byls))
       menames.push_back(m);
   }
   // if no MEs available, return
   if (menames.empty())
     return;
 
   // get info for getting the lumi VS LS histogram
   std::string folder = pset.folder;
   std::string name = pset.name;
   int nbins = pset.nbins;
   double xmin = pset.xmin;
   double xmax = pset.xmax;
 
   // get lumi/PU VS LS ME
   getter.setCurrentFolder(folder);
   MonitorElement* lumiVsLS = getter.get(folder + "/" + name);
   // if no ME available, return
   if (!lumiVsLS) {
     edm::LogWarning("FastTimerServiceClient") << "no " << name << " ME is available in " << folder << std::endl;
     return;
   }
 
   // get range and binning for new MEs x-axis
   size_t size = lumiVsLS->getTProfile()->GetXaxis()->GetNbins();
   std::string xtitle = lumiVsLS->getTProfile()->GetYaxis()->GetTitle();
 
   std::vector<double> lumi;
   std::vector<int> LS;
   for (size_t ibin = 1; ibin <= size; ++ibin) {
     // avoid to store points w/ no info
     if (lumiVsLS->getTProfile()->GetBinContent(ibin) == 0.)
       continue;
 
     lumi.push_back(lumiVsLS->getTProfile()->GetBinContent(ibin));
     LS.push_back(lumiVsLS->getTProfile()->GetXaxis()->GetBinCenter(ibin));
   }
 
   booker.setCurrentFolder(current_path);
   getter.setCurrentFolder(current_path);
   for (auto const& m : menames) {
     std::string label = m;
     label.erase(label.find("_byls"));
 
     MonitorElement* me = getter.get(current_path + "/" + m);
     float ymin = 0.;
     float ymax = std::numeric_limits<float>::max();
     std::string ytitle = me->getTProfile()->GetYaxis()->GetTitle();
 
     MonitorElement* meVsLumi = getter.get(current_path + "/" + label + "_" + suffix);
     if (meVsLumi) {
       assert(meVsLumi->getTProfile()->GetXaxis()->GetXmin() == xmin);
       assert(meVsLumi->getTProfile()->GetXaxis()->GetXmax() == xmax);
       meVsLumi->Reset();  // do I have to do it ?!?!?
     } else {
       meVsLumi = booker.bookProfile(label + "_" + suffix, label + "_" + suffix, nbins, xmin, xmax, ymin, ymax);
       //    TProfile* meVsLumi_p = meVsLumi->getTProfile();
       meVsLumi->getTProfile()->GetXaxis()->SetTitle(xtitle.c_str());
       meVsLumi->getTProfile()->GetYaxis()->SetTitle(ytitle.c_str());
     }
     for (size_t ils = 0; ils < LS.size(); ++ils) {
       int ibin = me->getTProfile()->GetXaxis()->FindBin(LS[ils]);
       double y = me->getTProfile()->GetBinContent(ibin);
 
       meVsLumi->Fill(lumi[ils], y);
     }
   }
 }

void FastTimerServiceClient::fillProcessSummaryPlots	(	DQMStore::IBooker &	booker,
		DQMStore::IGetter &	getter,
		std::string const &	path
	)

private

Definition at line 128 of file FastTimerServiceClient.cc.

References doPlotsVsPixelLumi_, doPlotsVsPU_, doPlotsVsScalLumi_, patZpeak::events, fillPathSummaryPlots(), fillPlotsVsLumi(), dqm::implementation::IGetter::get(), dqm::implementation::IGetter::getSubdirs(), dqm::legacy::MonitorElement::getTH1F(), hlt_dqm_clientPB-live_cfg::me, pixelLumiMEPSet_, relval_parameters_module::process_name, puMEPSet_, scalLumiMEPSet_, dqm::implementation::NavigatorBase::setCurrentFolder(), and compareTotals::subdirs.

Referenced by fillSummaryPlots().

                                                                                     {
   MonitorElement* me = getter.get(current_path + "/event time_real");
   if (me == nullptr)
     // no FastTimerService DQM information
     return;
 
   if (doPlotsVsScalLumi_)
     fillPlotsVsLumi(booker, getter, current_path, "VsScalLumi", scalLumiMEPSet_);
   if (doPlotsVsPixelLumi_)
     fillPlotsVsLumi(booker, getter, current_path, "VsPixelLumi", pixelLumiMEPSet_);
   if (doPlotsVsPU_)
     fillPlotsVsLumi(booker, getter, current_path, "VsPU", puMEPSet_);
 
   //  getter.setCurrentFolder(current_path);
 
   double events = me->getTH1F()->GetEntries();
 
   // look for per-process directories
   static const boost::regex process_name(".*/process .*");
 
   booker.setCurrentFolder(current_path);  // ?!?!?
   std::vector<std::string> subdirs = getter.getSubdirs();
   for (auto const& subdir : subdirs) {
     if (boost::regex_match(subdir, process_name)) {
       getter.setCurrentFolder(subdir);
       // look for per-path plots inside each per-process directory
       std::vector<std::string> subsubdirs = getter.getSubdirs();
       for (auto const& subsubdir : subsubdirs) {
         if (getter.get(subsubdir + "/path time_real")) {
           fillPathSummaryPlots(booker, getter, events, subdir);
           break;
         }
       }
     }
   }  // loop on subdir
 }

void FastTimerServiceClient::fillPUMePSetDescription ( edm::ParameterSetDescription & pset )

static

Definition at line 457 of file FastTimerServiceClient.cc.

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

Referenced by fillDescriptions().

                                                                                      {
   pset.add<std::string>("folder", "HLT/LumiMonitoring");
   pset.add<std::string>("name", "puVsLS");
   pset.add<int>("nbins", 260);
   pset.add<double>("xmin", 0.);
   pset.add<double>("xmax", 130.);
 }

void FastTimerServiceClient::fillSummaryPlots	(	DQMStore::IBooker &	booker,
		DQMStore::IGetter &	getter
	)

private

Definition at line 102 of file FastTimerServiceClient.cc.

References fillProcessSummaryPlots(), dqm::implementation::IGetter::get(), dqm::implementation::IGetter::getSubdirs(), m_dqm_path, dqm::implementation::NavigatorBase::setCurrentFolder(), and compareTotals::subdirs.

Referenced by dqmEndJob(), and dqmEndLuminosityBlock().

                                                                                               {
   if (getter.get(m_dqm_path + "/event time_real")) {
     // the plots are directly in the configured folder
     fillProcessSummaryPlots(booker, getter, m_dqm_path);
   } else {
     static const boost::regex running_n_processes(".*/Running .*");
 
     booker.setCurrentFolder(m_dqm_path);
     std::vector<std::string> subdirs = getter.getSubdirs();
     for (auto const& subdir : subdirs) {
       // the plots are in a per-number-of-processes folder
       if (boost::regex_match(subdir, running_n_processes)) {
         booker.setCurrentFolder(subdir);
         if (getter.get(subdir + "/event time_real"))
           fillProcessSummaryPlots(booker, getter, subdir);
 
         std::vector<std::string> subsubdirs = getter.getSubdirs();
         for (auto const& subsubdir : subsubdirs) {
           if (getter.get(subsubdir + "/event time_real"))
             fillProcessSummaryPlots(booker, getter, subsubdir);
         }
       }
     }  // loop on subdirs
   }
 }

MEPSet FastTimerServiceClient::getHistoPSet ( const edm::ParameterSet & pset )

staticprivate

Definition at line 465 of file FastTimerServiceClient.cc.

References edm::ParameterSet::getParameter(), and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                        {
   return MEPSet{
       pset.getParameter<std::string>("folder"),
       pset.getParameter<std::string>("name"),
       pset.getParameter<int>("nbins"),
       pset.getParameter<double>("xmin"),
       pset.getParameter<double>("xmax"),
   };
 }