CMS 3D CMS Logo

List of all members | Public Member Functions | Private Types | Private Member Functions | Private Attributes
EcalCondDBWriter Class Reference

#include <EcalCondDBWriter.h>

Inheritance diagram for EcalCondDBWriter:
DQMEDHarvester edm::one::EDProducer< edm::EndLuminosityBlockProducer, edm::EndRunProducer, edm::EndProcessBlockProducer, edm::one::WatchLuminosityBlocks, edm::one::WatchRuns, edm::one::SharedResources, edm::Accumulator > edm::one::EDProducerBase edm::ProducerBase edm::EDConsumerBase edm::ProductRegistryHelper

Public Member Functions

 EcalCondDBWriter (edm::ParameterSet const &)
 
 ~EcalCondDBWriter () 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 ()
 
 DQMEDHarvester (edm::ParameterSet const &iConfig)
 
virtual void dqmEndLuminosityBlock (DQMStore::IBooker &, DQMStore::IGetter &, edm::LuminosityBlock const &, edm::EventSetup const &)
 
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< edm::EndLuminosityBlockProducer, edm::EndRunProducer, edm::EndProcessBlockProducer, edm::one::WatchLuminosityBlocks, edm::one::WatchRuns, edm::one::SharedResources, edm::Accumulator >
 EDProducer ()=default
 
SerialTaskQueueglobalLuminosityBlocksQueue () final
 
SerialTaskQueueglobalRunsQueue () 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
 
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
 
std::vector< bool > const & recordProvenanceList () 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)
 
TypeLabelList const & typeLabelList () const
 used by the fwk to register the list of products of this module More...
 
 ~ProducerBase () noexcept(false) override
 
- Public Member Functions inherited from edm::EDConsumerBase
std::vector< ConsumesInfoconsumesInfo () const
 
void convertCurrentProcessAlias (std::string const &processName)
 Convert "@currentProcess" in InputTag process names to the actual current process name. More...
 
 EDConsumerBase ()
 
 EDConsumerBase (EDConsumerBase &&)=default
 
 EDConsumerBase (EDConsumerBase const &)=delete
 
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::vector< ModuleDescription const * > &modules, ProductRegistry const &preg, std::map< std::string, ModuleDescription const * > const &labelsToDesc, std::string const &processName) const
 
EDConsumerBaseoperator= (EDConsumerBase &&)=default
 
EDConsumerBase const & operator= (EDConsumerBase const &)=delete
 
bool registeredToConsume (ProductResolverIndex, bool, BranchType) const
 
bool registeredToConsumeMany (TypeID const &, BranchType) const
 
ProductResolverIndexAndSkipBit uncheckedIndexFrom (EDGetToken) const
 
void updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &, bool iPrefetchMayGet)
 
void updateLookup (eventsetup::ESRecordsToProxyIndices const &)
 
virtual ~EDConsumerBase () noexcept(false)
 

Private Types

enum  Tasks {
  Integrity = 0, Cosmic = 1, Laser = 2, Pedestal = 3,
  Presample = 4, TestPulse = 5, BeamCalo = 6, BeamHodo = 7,
  TriggerPrimitives = 8, Cluster = 9, Timing = 10, Led = 11,
  RawData = 12, Occupancy = 13, nTasks = 14
}
 

Private Member Functions

void dqmEndJob (DQMStore::IBooker &, DQMStore::IGetter &) override
 

Private Attributes

EcalCondDBInterfacedb_
 
bool executed_
 
std::vector< std::string > inputRootFiles_
 
std::string location_
 
std::string monRunGeneralTag_
 
std::string runGeneralTag_
 
int runNumber_
 
std::string runType_
 
ecaldqm::SummaryWriter summaryWriter_
 
int verbosity_
 
ecaldqm::DBWriterWorkerworkers_ [nTasks]
 

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
 
- Static Public Member Functions inherited from edm::one::EDProducerBase
static const std::string & baseType ()
 
static void fillDescriptions (ConfigurationDescriptions &descriptions)
 
static void prevalidate (ConfigurationDescriptions &descriptions)
 
- Protected Member Functions inherited from edm::ProducerBase
template<class ProductType >
BranchAliasSetterT< ProductType > produces ()
 declare what type of product will make and with which optional label More...
 
template<typename ProductType , BranchType B>
BranchAliasSetterT< ProductType > produces ()
 
template<typename ProductType , Transition B>
BranchAliasSetterT< ProductType > produces ()
 
BranchAliasSetter produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)
 
template<BranchType B>
BranchAliasSetter produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)
 
template<Transition B>
BranchAliasSetter produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)
 
template<typename ProductType , Transition B>
BranchAliasSetterT< ProductType > produces (std::string instanceName)
 
template<class ProductType >
BranchAliasSetterT< ProductType > produces (std::string instanceName)
 
template<typename ProductType , BranchType B>
BranchAliasSetterT< ProductType > produces (std::string instanceName)
 
ProducesCollector producesCollector ()
 
- Protected Member Functions inherited from edm::EDConsumerBase
EDGetToken consumes (const TypeToGet &id, edm::InputTag const &tag)
 
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType > consumes (edm::InputTag const &tag)
 
template<BranchType B = InEvent>
EDConsumerBaseAdaptor< B > consumes (edm::InputTag tag) noexcept
 
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<Transition Tr = Transition::Event>
constexpr auto esConsumes () noexcept
 
template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto esConsumes (ESInputTag const &tag)
 
template<Transition Tr = Transition::Event>
auto esConsumes (ESInputTag tag) noexcept
 
template<Transition Tr = Transition::Event>
ESGetTokenGeneric esConsumes (eventsetup::EventSetupRecordKey const &iRecord, eventsetup::DataKey const &iKey)
 Used with EventSetupRecord::doGet. More...
 
EDGetToken mayConsume (const TypeToGet &id, edm::InputTag const &tag)
 
template<BranchType B>
EDGetToken mayConsume (const TypeToGet &id, edm::InputTag const &tag)
 
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType > mayConsume (edm::InputTag const &tag)
 
- Protected Attributes inherited from DQMEDHarvester
DQMStoredqmstore_
 
edm::GetterOfProducts< DQMTokenjobmegetter_
 
edm::EDPutTokenT< DQMTokenjobToken_
 
edm::GetterOfProducts< DQMTokenlumimegetter_
 
edm::EDPutTokenT< DQMTokenlumiToken_
 
edm::GetterOfProducts< DQMTokenrunmegetter_
 
edm::EDPutTokenT< DQMTokenrunToken_
 

Detailed Description

Definition at line 10 of file EcalCondDBWriter.h.

Member Enumeration Documentation

◆ Tasks

Enumerator
Integrity 
Cosmic 
Laser 
Pedestal 
Presample 
TestPulse 
BeamCalo 
BeamHodo 
TriggerPrimitives 
Cluster 
Timing 
Led 
RawData 
Occupancy 
nTasks 

Definition at line 19 of file EcalCondDBWriter.h.

19  {
20  Integrity = 0,
21  Cosmic = 1,
22  Laser = 2,
23  Pedestal = 3,
24  Presample = 4,
25  TestPulse = 5,
26  BeamCalo = 6,
27  BeamHodo = 7,
29  Cluster = 9,
30  Timing = 10,
31  Led = 11,
32  RawData = 12,
33  Occupancy = 13,
34  nTasks = 14
35  };

Constructor & Destructor Documentation

◆ EcalCondDBWriter()

EcalCondDBWriter::EcalCondDBWriter ( edm::ParameterSet const &  _ps)

Definition at line 21 of file EcalCondDBWriter.cc.

22  : runNumber_(0),
23  db_(nullptr),
24  location_(_ps.getUntrackedParameter<std::string>("location")),
25  runType_(_ps.getUntrackedParameter<std::string>("runType")),
26  runGeneralTag_(_ps.getUntrackedParameter<std::string>("runGeneralTag")),
27  monRunGeneralTag_(_ps.getUntrackedParameter<std::string>("monRunGeneralTag")),
28  summaryWriter_(_ps.getUntrackedParameterSet("workerParams")),
29  verbosity_(_ps.getUntrackedParameter<int>("verbosity")),
30  executed_(false) {
31  std::vector<std::string> inputRootFiles(_ps.getUntrackedParameter<std::vector<std::string>>("inputRootFiles"));
32 
33  if (inputRootFiles.empty())
34  throw cms::Exception("Configuration") << "No input ROOT file given";
35 
36  if (verbosity_ > 0)
37  edm::LogInfo("EcalDQM") << "Initializing DQMStore from input ROOT files";
38 
40 
41  for (unsigned iF(0); iF < inputRootFiles.size(); ++iF) {
43 
44  if (verbosity_ > 1)
45  edm::LogInfo("EcalDQM") << " " << fileName;
46 
47  TPRegexp pat("DQM_V[0-9]+(?:|_[0-9a-zA-Z]+)_R([0-9]+)");
48  std::unique_ptr<TObjArray> matches(pat.MatchS(fileName.c_str()));
49  if (matches->GetEntries() == 0)
50  throw cms::Exception("Configuration") << "Input file " << fileName << " is not an DQM output";
51 
52  if (iF == 0)
53  runNumber_ = TString(matches->At(1)->GetName()).Atoi();
54  else if (TString(matches->At(1)->GetName()).Atoi() != runNumber_)
55  throw cms::Exception("Configuration") << "Input files disagree in run number";
56 
57  dqmStore.open(fileName, false, "", "", DQMStore::StripRunDirs);
58  }
59 
60  std::string DBName(_ps.getUntrackedParameter<std::string>("DBName"));
61  std::string hostName(_ps.getUntrackedParameter<std::string>("hostName"));
62  int hostPort(_ps.getUntrackedParameter<int>("hostPort"));
63  std::string userName(_ps.getUntrackedParameter<std::string>("userName"));
64  std::string password(_ps.getUntrackedParameter<std::string>("password"));
65 
66  std::unique_ptr<EcalCondDBInterface> db(nullptr);
67 
68  if (verbosity_ > 0)
69  edm::LogInfo("EcalDQM") << "Establishing DB connection";
70 
71  try {
72  db = std::make_unique<EcalCondDBInterface>(DBName, userName, password);
73  } catch (std::runtime_error &re) {
74  if (!hostName.empty()) {
75  try {
76  db = std::make_unique<EcalCondDBInterface>(hostName, DBName, userName, password, hostPort);
77  } catch (std::runtime_error &re2) {
78  throw cms::Exception("DBError") << re2.what();
79  }
80  } else
81  throw cms::Exception("DBError") << re.what();
82  }
83 
84  db_ = db.release();
85 
86  if (verbosity_ > 0)
87  edm::LogInfo("EcalDQM") << " Done.";
88 
89  edm::ParameterSet const &workerParams(_ps.getUntrackedParameterSet("workerParams"));
90 
92  workers_[Cosmic] = nullptr;
97  workers_[BeamCalo] = nullptr;
98  workers_[BeamHodo] = nullptr;
99  workers_[TriggerPrimitives] = nullptr;
100  workers_[Cluster] = nullptr;
103  workers_[RawData] = nullptr;
105 
106  for (unsigned iC(0); iC < nTasks; ++iC)
107  if (workers_[iC])
109 }

References BeamCalo, BeamHodo, Cluster, Cosmic, dqmiodatasetharvest::db, db_, EcalCondDBWriter_cfi::DBName, L1TBPTX_cfi::dqmStore, Exception, MillePedeFileConverter_cfg::fileName, edm::ParameterSet::getUntrackedParameter(), edm::ParameterSet::getUntrackedParameterSet(), EcalCondDBWriter_cfi::hostName, EcalCondDBWriter_cfi::hostPort, EcalCondDBWriter_cfi::inputRootFiles, Integrity, Laser, Led, patCandidatesForDimuonsSequences_cff::matches, nTasks, Occupancy, EcalCondDBWriter_cfi::password, Pedestal, Presample, RawData, runNumber_, ecaldqm::DBWriterWorker::setVerbosity(), AlCaHLTBitMon_QueryRunRegistry::string, dqm::implementation::DQMStore::StripRunDirs, TestPulse, Timing, TriggerPrimitives, EcalCondDBWriter_cfi::userName, verbosity_, EcalCondDBWriter_cfi::workerParams, and workers_.

◆ ~EcalCondDBWriter()

EcalCondDBWriter::~EcalCondDBWriter ( )
override

Definition at line 111 of file EcalCondDBWriter.cc.

111  {
112  try {
113  delete db_;
114  } catch (std::runtime_error &e) {
115  throw cms::Exception("DBError") << e.what();
116  }
117 
118  for (unsigned iC(0); iC < nTasks; ++iC)
119  delete workers_[iC];
120 }

References db_, MillePedeFileConverter_cfg::e, Exception, nTasks, and workers_.

Member Function Documentation

◆ dqmEndJob()

void EcalCondDBWriter::dqmEndJob ( DQMStore::IBooker ,
DQMStore::IGetter _igetter 
)
overrideprivatevirtual

Implements DQMEDHarvester.

Definition at line 122 of file EcalCondDBWriter.cc.

122  {
123  if (executed_)
124  return;
125 
127 
128  if (verbosity_ > 1)
129  edm::LogInfo("EcalDQM") << " Searching event info";
130 
131  uint64_t timeStampInFile(0);
132  unsigned processedEvents(0);
133 
134  _igetter.cd();
135  std::vector<std::string> dirs(_igetter.getSubdirs());
136  for (unsigned iD(0); iD < dirs.size(); ++iD) {
137  if (!_igetter.dirExists(dirs[iD] + "/EventInfo"))
138  continue;
139 
140  MonitorElement *timeStampME(_igetter.get(dirs[iD] + "/EventInfo/runStartTimeStamp"));
141  if (timeStampME) {
142  double timeStampValue(timeStampME->getFloatValue());
143  uint64_t seconds(timeStampValue);
144  uint64_t microseconds((timeStampValue - seconds) * 1.e6);
145  timeStampInFile = (seconds << 32) | microseconds;
146  }
147 
148  MonitorElement *eventsME(_igetter.get(dirs[iD] + "/EventInfo/processedEvents"));
149  if (eventsME)
150  processedEvents = eventsME->getIntValue();
151 
152  if (timeStampInFile != 0 && processedEvents != 0) {
153  if (verbosity_ > 1)
154  edm::LogInfo("EcalDQM") << " Event info found; timestamp=" << timeStampInFile
155  << " processedEvents=" << processedEvents;
156  break;
157  }
158  }
159 
160  if (verbosity_ > 0)
161  edm::LogInfo("EcalDQM") << " Done.";
162 
164 
165  if (verbosity_ > 0)
166  edm::LogInfo("EcalDQM") << "Setting up source MonitorElements for given run type " << runType_;
167 
168  int taskList(0);
169  for (unsigned iC(0); iC < nTasks; ++iC) {
170  if (!workers_[iC] || !workers_[iC]->runsOn(runType_))
171  continue;
172 
173  workers_[iC]->retrieveSource(_igetter);
174 
175  setBit(taskList, iC);
176  }
177 
178  if (verbosity_ > 0)
179  edm::LogInfo("EcalDQM") << " Done.";
180 
182 
183  if (verbosity_ > 0)
184  edm::LogInfo("EcalDQM") << "Initializing DB entry";
185 
186  RunIOV runIOV;
187  RunTag runTag;
188  try {
189  runIOV = db_->fetchRunIOV(location_, runNumber_);
190  runTag = runIOV.getRunTag();
191  } catch (std::runtime_error &e) {
192  std::cerr << e.what();
193 
194  if (timeStampInFile == 0)
195  throw cms::Exception("Initialization") << "Time stamp for the run could not be found";
196 
197  LocationDef locationDef;
198  locationDef.setLocation(location_);
199  RunTypeDef runTypeDef;
200  runTypeDef.setRunType(runType_);
201  runTag.setLocationDef(locationDef);
202  runTag.setRunTypeDef(runTypeDef);
204 
205  runIOV.setRunStart(Tm(timeStampInFile));
206  runIOV.setRunNumber(runNumber_);
207  runIOV.setRunTag(runTag);
208 
209  try {
210  db_->insertRunIOV(&runIOV);
211  runIOV = db_->fetchRunIOV(&runTag, runNumber_);
212  } catch (std::runtime_error &e) {
213  throw cms::Exception("DBError") << e.what();
214  }
215  }
216 
217  // No filtering - DAQ definitions change time to time..
218  // if(runType_ != runIOV.getRunTag().getRunTypeDef().getRunType())
219  // throw cms::Exception("Configuration") << "Given run type " << runType_
220  // << " does not match the run type in DB " <<
221  // runIOV.getRunTag().getRunTypeDef().getRunType();
222 
223  MonVersionDef versionDef;
224  versionDef.setMonitoringVersion("test01"); // the only mon_ver in mon_version_def table as of September
225  // 2012
226  MonRunTag monTag;
227  monTag.setMonVersionDef(versionDef);
229 
230  MonRunIOV monIOV;
231 
232  try {
233  monIOV = db_->fetchMonRunIOV(&runTag, &monTag, runNumber_, 1);
234  } catch (std::runtime_error &e) {
235  std::cerr << e.what();
236 
237  monIOV.setRunIOV(runIOV);
238  monIOV.setSubRunNumber(1);
239  monIOV.setSubRunStart(runIOV.getRunStart());
240  monIOV.setSubRunEnd(runIOV.getRunEnd());
241  monIOV.setMonRunTag(monTag);
242 
243  try {
244  db_->insertMonRunIOV(&monIOV);
245  monIOV = db_->fetchMonRunIOV(&runTag, &monTag, runNumber_, 1);
246  } catch (std::runtime_error &e) {
247  throw cms::Exception("DBError") << e.what();
248  }
249  }
250 
251  if (verbosity_ > 0)
252  edm::LogInfo("EcalDQM") << " Done.";
253 
255 
256  if (verbosity_ > 0)
257  edm::LogInfo("EcalDQM") << "Writing to DB";
258 
259  int outcome(0);
260  for (unsigned iC(0); iC < nTasks; ++iC) {
261  if (!getBit(taskList, iC))
262  continue;
263 
264  if (verbosity_ > 1)
265  edm::LogInfo("EcalDQM") << " " << workers_[iC]->getName();
266 
267  if (workers_[iC]->isActive() && workers_[iC]->run(db_, monIOV))
268  setBit(outcome, iC);
269  }
270 
271  if (verbosity_ > 0)
272  edm::LogInfo("EcalDQM") << " Done.";
273 
274  if (verbosity_ > 0)
275  edm::LogInfo("EcalDQM") << "Registering the outcome of DB writing";
276 
277  summaryWriter_.setTaskList(taskList);
278  summaryWriter_.setOutcome(outcome);
279  summaryWriter_.setProcessedEvents(processedEvents);
280  summaryWriter_.run(db_, monIOV);
281 
282  if (verbosity_ > 0)
283  edm::LogInfo("EcalDQM") << " Done.";
284 
285  executed_ = true;
286 }

References dqm::implementation::NavigatorBase::cd(), EcnaPython_AdcPeg12_S1_10_R170298_1_0_150_Dee0::cerr, db_, dqm::implementation::IGetter::dirExists(), heppy_check::dirs, MillePedeFileConverter_cfg::e, Exception, executed_, EcalCondDBInterface::fetchMonRunIOV(), EcalCondDBInterface::fetchRunIOV(), dqm::implementation::IGetter::get(), getBit(), dqm::impl::MonitorElement::getIntValue(), ecaldqm::DBWriterWorker::getName(), RunIOV::getRunEnd(), RunIOV::getRunStart(), RunIOV::getRunTag(), dqm::implementation::IGetter::getSubdirs(), EcalCondDBInterface::insertMonRunIOV(), EcalCondDBInterface::insertRunIOV(), location_, monRunGeneralTag_, nTasks, ecaldqm::DBWriterWorker::retrieveSource(), writedatasetfile::run, ecaldqm::SummaryWriter::run(), runGeneralTag_, runNumber_, runType_, seconds(), setBit(), MonRunTag::setGeneralTag(), RunTag::setGeneralTag(), LocationDef::setLocation(), RunTag::setLocationDef(), MonVersionDef::setMonitoringVersion(), MonRunIOV::setMonRunTag(), MonRunTag::setMonVersionDef(), ecaldqm::SummaryWriter::setOutcome(), ecaldqm::SummaryWriter::setProcessedEvents(), MonRunIOV::setRunIOV(), RunIOV::setRunNumber(), RunIOV::setRunStart(), RunIOV::setRunTag(), RunTypeDef::setRunType(), RunTag::setRunTypeDef(), MonRunIOV::setSubRunEnd(), MonRunIOV::setSubRunNumber(), MonRunIOV::setSubRunStart(), ecaldqm::SummaryWriter::setTaskList(), summaryWriter_, verbosity_, and workers_.

Member Data Documentation

◆ db_

EcalCondDBInterface* EcalCondDBWriter::db_
private

Definition at line 38 of file EcalCondDBWriter.h.

Referenced by dqmEndJob(), EcalCondDBWriter(), and ~EcalCondDBWriter().

◆ executed_

bool EcalCondDBWriter::executed_
private

Definition at line 48 of file EcalCondDBWriter.h.

Referenced by dqmEndJob().

◆ inputRootFiles_

std::vector<std::string> EcalCondDBWriter::inputRootFiles_
private

Definition at line 43 of file EcalCondDBWriter.h.

◆ location_

std::string EcalCondDBWriter::location_
private

Definition at line 39 of file EcalCondDBWriter.h.

Referenced by dqmEndJob().

◆ monRunGeneralTag_

std::string EcalCondDBWriter::monRunGeneralTag_
private

Definition at line 42 of file EcalCondDBWriter.h.

Referenced by dqmEndJob().

◆ runGeneralTag_

std::string EcalCondDBWriter::runGeneralTag_
private

Definition at line 41 of file EcalCondDBWriter.h.

Referenced by dqmEndJob().

◆ runNumber_

int EcalCondDBWriter::runNumber_
private

Definition at line 37 of file EcalCondDBWriter.h.

Referenced by dqmEndJob(), and EcalCondDBWriter().

◆ runType_

std::string EcalCondDBWriter::runType_
private

Definition at line 40 of file EcalCondDBWriter.h.

Referenced by dqmEndJob().

◆ summaryWriter_

ecaldqm::SummaryWriter EcalCondDBWriter::summaryWriter_
private

Definition at line 45 of file EcalCondDBWriter.h.

Referenced by dqmEndJob().

◆ verbosity_

int EcalCondDBWriter::verbosity_
private

Definition at line 47 of file EcalCondDBWriter.h.

Referenced by dqmEndJob(), and EcalCondDBWriter().

◆ workers_

ecaldqm::DBWriterWorker* EcalCondDBWriter::workers_[nTasks]
private

Definition at line 44 of file EcalCondDBWriter.h.

Referenced by dqmEndJob(), EcalCondDBWriter(), and ~EcalCondDBWriter().

LocationDef::setLocation
void setLocation(std::string loc)
Definition: LocationDef.cc:20
ecaldqm::PedestalWriter
Definition: DBWriterWorkers.h:60
EcalCondDBWriter::TestPulse
Definition: EcalCondDBWriter.h:25
RunIOV
Definition: RunIOV.h:13
dqm::implementation::DQMStore::StripRunDirs
Definition: DQMStore.h:542
MonVersionDef::setMonitoringVersion
void setMonitoringVersion(std::string ver)
Definition: MonVersionDef.cc:21
EcalCondDBWriter::Occupancy
Definition: EcalCondDBWriter.h:33
EcalCondDBWriter::TriggerPrimitives
Definition: EcalCondDBWriter.h:28
EcalCondDBWriter_cfi.hostPort
hostPort
Definition: EcalCondDBWriter_cfi.py:60
EcalCondDBWriter::BeamHodo
Definition: EcalCondDBWriter.h:27
EcalCondDBWriter::Led
Definition: EcalCondDBWriter.h:31
heppy_check.dirs
dirs
Definition: heppy_check.py:26
RunTag
Definition: RunTag.h:13
ecaldqm::LaserWriter
Definition: DBWriterWorkers.h:49
EcalCondDBWriter::Cluster
Definition: EcalCondDBWriter.h:29
ecaldqm::OccupancyWriter
Definition: DBWriterWorkers.h:111
LocationDef
Definition: LocationDef.h:12
EcalCondDBInterface::fetchMonRunIOV
MonRunIOV fetchMonRunIOV(RunTag *runtag, MonRunTag *montag, run_t run, subrun_t monrun) noexcept(false)
Definition: EcalCondDBInterface.cc:674
EcalCondDBWriter_cfi.DBName
DBName
Definition: EcalCondDBWriter_cfi.py:58
dqm::implementation::IGetter::getSubdirs
virtual DQM_DEPRECATED std::vector< std::string > getSubdirs() const
Definition: DQMStore.cc:678
EcalCondDBInterface::insertRunIOV
void insertRunIOV(RunIOV *iov) noexcept(false)
Definition: EcalCondDBInterface.cc:505
dqm::legacy::MonitorElement
Definition: MonitorElement.h:461
getBit
bool getBit(int &_bitArray, unsigned _iBit)
Definition: EcalCondDBWriter.cc:19
edm::LogInfo
Log< level::Info, false > LogInfo
Definition: MessageLogger.h:125
MillePedeFileConverter_cfg.fileName
fileName
Definition: MillePedeFileConverter_cfg.py:32
ecaldqm::IntegrityWriter
Definition: DBWriterWorkers.h:41
RunIOV::setRunStart
void setRunStart(const Tm &start)
Definition: RunIOV.cc:33
MonRunIOV::setRunIOV
void setRunIOV(const RunIOV &iov)
Definition: MonRunIOV.cc:36
MonRunIOV::setSubRunEnd
void setSubRunEnd(const Tm &end)
Definition: MonRunIOV.cc:63
MonRunTag::setGeneralTag
void setGeneralTag(std::string tag)
Definition: MonRunTag.cc:21
EcalCondDBWriter::db_
EcalCondDBInterface * db_
Definition: EcalCondDBWriter.h:38
EcalCondDBWriter_cfi.userName
userName
Definition: EcalCondDBWriter_cfi.py:61
ecaldqm::DBWriterWorker::getName
const std::string & getName() const
Definition: DBWriterWorkers.h:30
EcalCondDBWriter::runType_
std::string runType_
Definition: EcalCondDBWriter.h:40
dqmiodatasetharvest.db
db
Definition: dqmiodatasetharvest.py:119
RunTypeDef::setRunType
void setRunType(std::string runtype)
Definition: RunTypeDef.cc:21
EcalCondDBWriter_cfi.password
password
Definition: EcalCondDBWriter_cfi.py:62
RunIOV::getRunEnd
Tm getRunEnd() const
Definition: RunIOV.cc:49
dqm::legacy::DQMStore
Definition: DQMStore.h:727
RunTag::setGeneralTag
void setGeneralTag(std::string tag)
Definition: RunTag.cc:24
seconds
double seconds()
RunIOV::getRunTag
RunTag getRunTag() const
Definition: RunIOV.cc:58
setBit
void setBit(int &_bitArray, unsigned _iBit)
Definition: EcalCondDBWriter.cc:17
EcalCondDBWriter::location_
std::string location_
Definition: EcalCondDBWriter.h:39
EcalCondDBWriter::monRunGeneralTag_
std::string monRunGeneralTag_
Definition: EcalCondDBWriter.h:42
dqm::implementation::NavigatorBase::cd
virtual void cd()
Definition: DQMStore.cc:29
ecaldqm::SummaryWriter::setProcessedEvents
void setProcessedEvents(unsigned _n)
Definition: DBWriterWorkers.h:127
MonVersionDef
Definition: MonVersionDef.h:12
RunIOV::setRunTag
void setRunTag(const RunTag &tag)
Definition: RunIOV.cc:51
Tm
Definition: Tm.h:13
L1TBPTX_cfi.dqmStore
dqmStore
Definition: L1TBPTX_cfi.py:6
AlCaHLTBitMon_QueryRunRegistry.string
string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:256
RunTypeDef
Definition: RunTypeDef.h:12
ecaldqm::TestPulseWriter
Definition: DBWriterWorkers.h:80
EcalCondDBWriter::RawData
Definition: EcalCondDBWriter.h:32
EcalCondDBWriter::Timing
Definition: EcalCondDBWriter.h:30
ecaldqm::PresampleWriter
Definition: DBWriterWorkers.h:72
ecaldqm::SummaryWriter::setTaskList
void setTaskList(int _list)
Definition: DBWriterWorkers.h:125
EcalCondDBWriter_cfi.workerParams
workerParams
Definition: EcalCondDBWriter_cfi.py:68
edm::ParameterSet
Definition: ParameterSet.h:47
EcalCondDBWriter::verbosity_
int verbosity_
Definition: EcalCondDBWriter.h:47
EcalCondDBWriter_cfi.hostName
hostName
Definition: EcalCondDBWriter_cfi.py:59
RunIOV::setRunNumber
void setRunNumber(run_t run)
Definition: RunIOV.cc:22
ecaldqm::LedWriter
Definition: DBWriterWorkers.h:100
ecaldqm::DBWriterWorker::setVerbosity
void setVerbosity(int _v)
Definition: DBWriterWorkers.h:28
EcalCondDBWriter::nTasks
Definition: EcalCondDBWriter.h:34
EcalCondDBWriter::Pedestal
Definition: EcalCondDBWriter.h:23
EcalCondDBWriter::runNumber_
int runNumber_
Definition: EcalCondDBWriter.h:37
edm::Service
Definition: Service.h:30
EcalCondDBWriter::workers_
ecaldqm::DBWriterWorker * workers_[nTasks]
Definition: EcalCondDBWriter.h:44
EcalCondDBWriter::BeamCalo
Definition: EcalCondDBWriter.h:26
EcalCondDBInterface::insertMonRunIOV
void insertMonRunIOV(MonRunIOV *iov) noexcept(false)
Definition: EcalCondDBInterface.cc:652
MonRunIOV
Definition: MonRunIOV.h:14
pat
Definition: HeavyIon.h:7
MonRunIOV::setSubRunNumber
void setSubRunNumber(subrun_t subrun)
Definition: MonRunIOV.cc:45
MonRunTag
Definition: MonRunTag.h:13
MonRunIOV::setMonRunTag
void setMonRunTag(const MonRunTag &tag)
Definition: MonRunIOV.cc:27
ecaldqm::DBWriterWorker::retrieveSource
void retrieveSource(DQMStore::IGetter &)
Definition: DBWriterWorkers.cc:79
EcalCondDBWriter::summaryWriter_
ecaldqm::SummaryWriter summaryWriter_
Definition: EcalCondDBWriter.h:45
EcalCondDBWriter::Presample
Definition: EcalCondDBWriter.h:24
ecaldqm::SummaryWriter::setOutcome
void setOutcome(int _outcome)
Definition: DBWriterWorkers.h:126
writedatasetfile.run
run
Definition: writedatasetfile.py:27
RunTag::setLocationDef
void setLocationDef(const LocationDef &locDef)
Definition: RunTag.cc:33
EcalCondDBWriter::executed_
bool executed_
Definition: EcalCondDBWriter.h:48
EcalCondDBWriter::Cosmic
Definition: EcalCondDBWriter.h:21
Exception
Definition: hltDiff.cc:246
dqm::implementation::IGetter::get
virtual MonitorElement * get(std::string const &fullpath) const
Definition: DQMStore.cc:651
EcalCondDBWriter::Integrity
Definition: EcalCondDBWriter.h:20
patCandidatesForDimuonsSequences_cff.matches
matches
Definition: patCandidatesForDimuonsSequences_cff.py:131
cond::uint64_t
unsigned long long uint64_t
Definition: Time.h:13
RunTag::setRunTypeDef
void setRunTypeDef(const RunTypeDef &runTypeDef)
Definition: RunTag.cc:42
MonRunIOV::setSubRunStart
void setSubRunStart(const Tm &start)
Definition: MonRunIOV.cc:54
ecaldqm::TimingWriter
Definition: DBWriterWorkers.h:92
cms::Exception
Definition: Exception.h:70
EcalCondDBWriter_cfi.inputRootFiles
inputRootFiles
Definition: EcalCondDBWriter_cfi.py:67
MonRunTag::setMonVersionDef
void setMonVersionDef(const MonVersionDef &ver)
Definition: MonRunTag.cc:30
RunIOV::getRunStart
Tm getRunStart() const
Definition: RunIOV.cc:40
EcalCondDBWriter::runGeneralTag_
std::string runGeneralTag_
Definition: EcalCondDBWriter.h:41
EcnaPython_AdcPeg12_S1_10_R170298_1_0_150_Dee0.cerr
cerr
Definition: EcnaPython_AdcPeg12_S1_10_R170298_1_0_150_Dee0.py:8
EcalCondDBInterface::fetchRunIOV
RunIOV fetchRunIOV(RunTag *tag, run_t run) noexcept(false)
Definition: EcalCondDBInterface.cc:631
EcalCondDBWriter::Laser
Definition: EcalCondDBWriter.h:22
dqm::impl::MonitorElement::getIntValue
virtual int64_t getIntValue() const
Definition: MonitorElement.cc:912
dqm::implementation::IGetter::dirExists
virtual bool dirExists(std::string const &path) const
Definition: DQMStore.cc:708
ecaldqm::SummaryWriter::run
bool run(EcalCondDBInterface *, MonRunIOV &) override
Definition: DBWriterWorkers.cc:1332
MillePedeFileConverter_cfg.e
e
Definition: MillePedeFileConverter_cfg.py:37