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::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 endJob () final
 
void endLuminosityBlock (edm::LuminosityBlock const &, edm::EventSetup const &) final
 
void endLuminosityBlockProduce (edm::LuminosityBlock &lumi, edm::EventSetup const &es) 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::one::WatchLuminosityBlocks, edm::one::WatchRuns, edm::one::SharedResources, edm::Accumulator >
 EDProducer ()=default
 
SerialTaskQueueglobalLuminosityBlocksQueue () final
 
SerialTaskQueueglobalRunsQueue () final
 
bool hasAbilityToProduceInBeginLumis () const final
 
bool hasAbilityToProduceInBeginRuns () const final
 
bool hasAbilityToProduceInEndLumis () const final
 
bool hasAbilityToProduceInEndRuns () const final
 
bool wantsGlobalLuminosityBlocks () const final
 
bool wantsGlobalRuns () 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
 
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>
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)
 
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< 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 19 of file EcalCondDBWriter.cc.

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

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 110 of file EcalCondDBWriter.cc.

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

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 121 of file EcalCondDBWriter.cc.

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

References dqm::implementation::NavigatorBase::cd(), beam_dqm_sourceclient-live_cfg::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
EcalCondDBInterface
Definition: EcalCondDBInterface.h:37
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
edm::LogInfo
Definition: MessageLogger.h:254
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
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:17
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
DQMEDHarvester::DQMStore
dqm::harvesting::DQMStore DQMStore
Definition: DQMEDHarvester.h:53
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
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:15
EcalCondDBWriter::location_
std::string location_
Definition: EcalCondDBWriter.h:39
EcalCondDBWriter::monRunGeneralTag_
std::string monRunGeneralTag_
Definition: EcalCondDBWriter.h:42
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:36
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
beam_dqm_sourceclient-live_cfg.cerr
cerr
Definition: beam_dqm_sourceclient-live_cfg.py:17
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
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
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
ecaldqm::SummaryWriter::run
bool run(EcalCondDBInterface *, MonRunIOV &) override
Definition: DBWriterWorkers.cc:1332
MillePedeFileConverter_cfg.e
e
Definition: MillePedeFileConverter_cfg.py:37