CMS 3D CMS Logo
List of all members | Public Member Functions | Static Public Member Functions | Private Member Functions | Private Attributes
ThroughputServiceClient Class Reference
Inheritance diagram for ThroughputServiceClient:
DQMEDHarvester edm::one::EDProducer< edm::one::WatchRuns, edm::one::WatchLuminosityBlocks, edm::one::SharedResources, edm::EndLuminosityBlockProducer > edm::one::EDProducerBase edm::ProducerBase edm::EDConsumerBase edm::ProductRegistryHelper

Public Member Functions

 ThroughputServiceClient (edm::ParameterSet const &)
 
 ~ThroughputServiceClient () override=default
 
- Public Member Functions inherited from DQMEDHarvester
virtual void beginLuminosityBlock (edm::LuminosityBlock const &, edm::EventSetup const &) final
 
virtual void beginRun (edm::Run const &, edm::EventSetup const &) override
 
 DQMEDHarvester (void)
 
virtual void endJob () final
 
virtual void endLuminosityBlock (edm::LuminosityBlock const &, edm::EventSetup const &) final
 
void endLuminosityBlockProduce (edm::LuminosityBlock &, edm::EventSetup const &) override final
 
virtual void endRun (edm::Run const &, edm::EventSetup const &) override
 
virtual void produce (edm::Event &, edm::EventSetup const &) override final
 
- Public Member Functions inherited from edm::one::EDProducer< edm::one::WatchRuns, edm::one::WatchLuminosityBlocks, edm::one::SharedResources, edm::EndLuminosityBlockProducer >
 EDProducer ()=default
 
- Public Member Functions inherited from edm::one::EDProducerBase
 EDProducerBase ()
 
ModuleDescription const & moduleDescription () const
 
virtual ~EDProducerBase ()
 
- 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 ()
 
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, std::unordered_multimap< std::string, edm::ProductResolverIndex > const &iIndicies, std::string const &moduleLabel)
 
virtual ~ProducerBase () noexcept(false)
 
- 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
 
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::vector< ModuleDescription const * > &modules, 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 updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &, bool iPrefetchMayGet)
 
virtual ~EDConsumerBase () noexcept(false)
 

Static Public Member Functions

static void fillDescriptions (edm::ConfigurationDescriptions &descriptions)
 
- 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 fillSummaryPlots (DQMStore::IBooker &booker, DQMStore::IGetter &getter)
 

Private Attributes

std::string m_dqm_path
 

Additional Inherited Members

- Public Types inherited from edm::one::EDProducerBase
typedef EDProducerBase ModuleType
 
- Public Types inherited from edm::ProducerBase
typedef ProductRegistryHelper::TypeLabelList TypeLabelList
 
- Public Types inherited from edm::EDConsumerBase
typedef ProductLabels Labels
 
- Protected Member Functions inherited from edm::EDConsumerBase
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType > consumes (edm::InputTag const &tag)
 
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 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)
 

Detailed Description

Definition at line 26 of file ThroughputServiceClient.cc.

Constructor & Destructor Documentation

ThroughputServiceClient::ThroughputServiceClient ( edm::ParameterSet const &  config)
explicit

Definition at line 44 of file ThroughputServiceClient.cc.

44  :
45  m_dqm_path( config.getUntrackedParameter<std::string>( "dqmPath" ) )
46 {
47 }
AlCaHLTBitMon_QueryRunRegistry.string
string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:255
config
Definition: config.py:1
ThroughputServiceClient::~ThroughputServiceClient ( )
overridedefault

Member Function Documentation

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

Implements DQMEDHarvester.

Definition at line 50 of file ThroughputServiceClient.cc.

References fillSummaryPlots().

51 {
52  fillSummaryPlots(booker, getter);
53 }
ThroughputServiceClient::fillSummaryPlots
void fillSummaryPlots(DQMStore::IBooker &booker, DQMStore::IGetter &getter)
Definition: ThroughputServiceClient.cc:62
void ThroughputServiceClient::dqmEndLuminosityBlock ( DQMStore::IBooker &  booker,
DQMStore::IGetter &  getter,
edm::LuminosityBlock const &  ,
edm::EventSetup const &   
)
overrideprivatevirtual

Reimplemented from DQMEDHarvester.

Definition at line 56 of file ThroughputServiceClient.cc.

References fillSummaryPlots().

57 {
58  fillSummaryPlots(booker, getter);
59 }
ThroughputServiceClient::fillSummaryPlots
void fillSummaryPlots(DQMStore::IBooker &booker, DQMStore::IGetter &getter)
Definition: ThroughputServiceClient.cc:62
void ThroughputServiceClient::fillDescriptions ( edm::ConfigurationDescriptions &  descriptions)
static

Definition at line 136 of file ThroughputServiceClient.cc.

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

136  {
137  edm::ParameterSetDescription desc;
138  desc.addUntracked<std::string>( "dqmPath", "HLT/Throughput" );
139  descriptions.add("throughputServiceClient", desc);
140 }
edm::ParameterSetDescription::addUntracked
ParameterDescriptionBase * addUntracked(U const &iLabel, T const &value)
Definition: ParameterSetDescription.h:94
AlCaHLTBitMon_QueryRunRegistry.string
string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:255
edm::ConfigurationDescriptions::add
void add(std::string const &label, ParameterSetDescription const &psetDescription)
Definition: ConfigurationDescriptions.cc:65
void ThroughputServiceClient::fillSummaryPlots ( DQMStore::IBooker &  booker,
DQMStore::IGetter &  getter 
)
private

Definition at line 62 of file ThroughputServiceClient.cc.

References DQMStore::IBooker::book1D(), plotBeamSpotDB::first, printsummarytable::folder, folders, DQMStore::IGetter::get(), DQMStore::IGetter::getSubdirs(), MonitorElement::getTH1F(), mps_fire::i, plotBeamSpotDB::last, m_dqm_path, hpstanc_transforms::max, min(), pileupCalc::nbins, DQMStore::IGetter::removeElement(), DQMStore::IBooker::setCurrentFolder(), and ApeEstimator_cff::width.

Referenced by dqmEndJob(), and dqmEndLuminosityBlock().

63 {
64  // find whether the plots are in the main folder, or in per-number-of-processess subfolders
65  std::vector<std::string> folders;
66  if (getter.get(m_dqm_path + "/throughput_sourced")) {
67  // the plots are in the main folder
68  folders.push_back(m_dqm_path);
69  } else {
70  static const boost::regex running_n_processes(".*/Running [0-9]+ processes");
71  booker.setCurrentFolder(m_dqm_path);
72  std::vector<std::string> subdirs = getter.getSubdirs();
73  for (auto const & subdir: subdirs) {
74  if (boost::regex_match(subdir, running_n_processes)) {
75  if (getter.get(subdir + "/throughput_sourced"))
76  // the plots are in a per-number-of-processes subfolder
77  folders.push_back(subdir + "/throughput_sourced");
78  }
79  }
80  }
81  for (auto const & folder: folders) {
82  TH1F * sourced = getter.get( folder + "/throughput_sourced" )->getTH1F();
83  TH1F * retired = getter.get( folder + "/throughput_retired" )->getTH1F();
84  booker.setCurrentFolder(folder);
85  unsigned int nbins = sourced->GetXaxis()->GetNbins();
86  double range = sourced->GetXaxis()->GetXmax();
87 
88  // drop .../concurrent, if it exists
89  if (getter.get(folder + "/concurrent"))
90  getter.removeElement(folder, "concurrent", true);
91  // (re)book and fill .../concurrent
92  TH1F* concurrent = booker.book1D("concurrent", "Concurrent events being processed", nbins, 0., range)->getTH1F();
93  double sum = 0;
94  // from bin=0 (underflow) to bin=nbins+1 (overflow)
95  for (unsigned int i = 0; i <= nbins+1; ++i) {
96  sum += sourced->GetBinContent(i) - retired->GetBinContent(i);
97  concurrent->Fill( concurrent->GetXaxis()->GetBinCenter(i), sum );
98  }
99 
100  TH1F* average = nullptr;
101  double avg_min = std::min(sourced->GetMinimum(0.), retired->GetMinimum(0.));
102  double avg_max = std::max(sourced->GetMaximum(), retired->GetMaximum());
103  double width = avg_max - avg_min;
104  avg_min = std::floor( avg_min - width * 0.2 );
105  if (avg_min < 0.) avg_min = 0.;
106  avg_max = std::ceil( avg_max + width * 0.2 );
107  width = avg_max - avg_min;
108 
109  // drop .../average_sourced, if it exists
110  if (getter.get(folder + "/average_sourced"))
111  getter.removeElement(folder, "average_sourced", true);
112  // define the range for .../average_sourced
113  uint64_t first = sourced->FindFirstBinAbove(0.);
114  uint64_t last = sourced->FindLastBinAbove(0.);
115  booker.setCurrentFolder(folder);
116  // (re)book and fill .../average_sourced
117  average = booker.book1D("average_sourced", "Throughput (sourced events)", (int) width, avg_min, avg_max)->getTH1F();
118  for (unsigned int i = first; i <= last; ++i)
119  average->Fill(sourced->GetBinContent(i));
120 
121  // drop .../average_retired, if it exists
122  if (getter.get(folder + "/average_retired"))
123  getter.removeElement(folder, "average_retired", true);
124  // define the range for .../average_retired
125  first = retired->FindFirstBinAbove(0.);
126  last = retired->FindLastBinAbove(0.);
127  booker.setCurrentFolder(folder);
128  // (re)book and fill .../average_retired
129  average = booker.book1D("average_retired", "Throughput (retired events)", (int) width, avg_min, avg_max)->getTH1F();
130  for (unsigned int i = first; i <= last; ++i)
131  average->Fill(retired->GetBinContent(i));
132  }
133 }
mps_fire.i
i
Definition: mps_fire.py:156
hpstanc_transforms.max
max
Definition: hpstanc_transforms.py:5
DQMStore::IGetter::get
MonitorElement * get(const std::string &path)
Definition: DQMStore.cc:305
folders
*vegas h *****************************************************used in the default bin number in original ***version of VEGAS is ***a higher bin number might help to derive a more precise ***grade subtle otherwise a larger ***bin number will have no effects or even make the ***precision lower than before *********************************************************************************************************it lies in three folders
Definition: invegas.h:5
DQMStore::IBooker::book1D
MonitorElement * book1D(Args &&...args)
Definition: DQMStore.h:115
min
T min(T a, T b)
Definition: MathUtil.h:58
DQMStore::IBooker::setCurrentFolder
void setCurrentFolder(const std::string &fullpath)
Definition: DQMStore.cc:277
cond::uint64_t
unsigned long long uint64_t
Definition: Time.h:15
ApeEstimator_cff.width
width
Definition: ApeEstimator_cff.py:24
MonitorElement::getTH1F
TH1F * getTH1F(void) const
Definition: MonitorElement.cc:1465
DQMStore::IGetter::getSubdirs
std::vector< std::string > getSubdirs(void)
Definition: DQMStore.cc:323
DQMStore::IGetter::removeElement
void removeElement(Args &&...args)
Definition: DQMStore.h:202

Member Data Documentation

std::string ThroughputServiceClient::m_dqm_path
private

Definition at line 34 of file ThroughputServiceClient.cc.

Referenced by fillSummaryPlots().

Generated for CMSSW Reference Manual by doxygen 1.8.11