CMS 3D CMS Logo

List of all members | Public Member Functions | Static Public Member Functions | Private Member Functions | Private Attributes
DQMRootOutputModule Class Reference
Inheritance diagram for DQMRootOutputModule:
edm::one::OutputModule<> edm::one::OutputModuleBase edm::EDConsumerBase

Public Member Functions

void beginJob () override
 
 DQMRootOutputModule (edm::ParameterSet const &pset)
 
 ~DQMRootOutputModule () override
 
- Public Member Functions inherited from edm::one::OutputModule<>
SerialTaskQueueglobalLuminosityBlocksQueue () final
 
SerialTaskQueueglobalRunsQueue () final
 
const OutputModuleoperator= (const OutputModule &)=delete
 
 OutputModule (const OutputModule &)=delete
 
 OutputModule (edm::ParameterSet const &iPSet)
 
bool wantsGlobalLuminosityBlocks () const final
 
bool wantsGlobalRuns () const final
 
bool wantsInputProcessBlocks () const final
 
bool wantsProcessBlocks () const final
 
- Public Member Functions inherited from edm::one::OutputModuleBase
BranchIDLists const * branchIDLists ()
 
std::array< bool, NumBranchTypes > const & hasNewlyDroppedBranch () const
 
SelectedProductsForBranchType const & keptProducts () const
 
int maxEvents () const
 
const ModuleDescriptionmoduleDescription () const
 
OutputModuleBaseoperator= (OutputModuleBase const &)=delete
 
 OutputModuleBase (OutputModuleBase const &)=delete
 
 OutputModuleBase (ParameterSet const &pset)
 
OutputProcessBlockHelper const & outputProcessBlockHelper () const
 
std::string const & processName () const
 
int remainingEvents () const
 
bool selected (BranchDescription const &desc) const
 
void selectProducts (ProductRegistry const &preg, ThinnedAssociationsHelper const &, ProcessBlockHelperBase const &)
 
SharedResourcesAcquirersharedResourcesAcquirer ()
 
SubProcessParentageHelper const * subProcessParentageHelper () const
 
ThinnedAssociationsHelper const * thinnedAssociationsHelper () const
 
bool wantAllEvents () const
 
bool wantsStreamLuminosityBlocks () const
 
bool wantsStreamRuns () const
 
 ~OutputModuleBase () 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::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
 
EDConsumerBaseoperator= (EDConsumerBase &&)=default
 
EDConsumerBase const & operator= (EDConsumerBase const &)=delete
 
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 Public Member Functions inherited from edm::one::OutputModuleBase
static const std::string & baseType ()
 
static void fillDescription (ParameterSetDescription &desc, std::vector< std::string > const &iDefaultOutputCommands=ProductSelectorRules::defaultSelectionStrings())
 
static void fillDescriptions (ConfigurationDescriptions &descriptions)
 
static void prevalidate (ConfigurationDescriptions &)
 

Private Member Functions

void finishEndFile ()
 
bool isFileOpen () const override
 
void openFile (edm::FileBlock const &) override
 
void reallyCloseFile () override
 
void startEndFile ()
 
void write (edm::EventForOutput const &e) override
 
void writeLuminosityBlock (edm::LuminosityBlockForOutput const &) override
 
void writeRun (edm::RunForOutput const &) override
 

Private Attributes

ULong64_t m_beginTime
 
std::map< unsigned int, unsigned int > m_dqmKindToTypeIndex
 
ULong64_t m_endTime
 
std::unique_ptr< TFile > m_file
 
std::string m_fileName
 
unsigned int m_filterOnRun
 
ULong64_t m_firstIndex
 
std::string m_fullNameBuffer
 
std::string * m_fullNameBufferPtr
 
TTree * m_indicesTree
 
edm::JobReport::Token m_jrToken
 
ULong64_t m_lastIndex
 
std::string m_logicalFileName
 
unsigned int m_lumi
 
unsigned int m_presentHistoryIndex
 
edm::ProcessHistoryRegistry m_processHistoryRegistry
 
unsigned int m_run
 
std::vector< edm::ProcessHistoryIDm_seenHistories
 
std::vector< std::shared_ptr< TreeHelperBase > > m_treeHelpers
 
unsigned int m_type
 

Additional Inherited Members

- Public Types inherited from edm::one::OutputModuleBase
typedef OutputModuleBase ModuleType
 
- Public Types inherited from edm::EDConsumerBase
typedef ProductLabels Labels
 
- Protected Member Functions inherited from edm::one::OutputModuleBase
void configure (OutputModuleDescription const &desc)
 
ModuleDescription const & description () const
 
void doAccessInputProcessBlock (ProcessBlockPrincipal const &, ModuleCallingContext const *)
 
void doBeginJob ()
 
bool doBeginLuminosityBlock (LumiTransitionInfo const &, ModuleCallingContext const *)
 
void doBeginProcessBlock (ProcessBlockPrincipal const &, ModuleCallingContext const *)
 
bool doBeginRun (RunTransitionInfo const &, ModuleCallingContext const *)
 
void doEndJob ()
 
bool doEndLuminosityBlock (LumiTransitionInfo const &, ModuleCallingContext const *)
 
void doEndProcessBlock (ProcessBlockPrincipal const &, ModuleCallingContext const *)
 
bool doEndRun (RunTransitionInfo const &, ModuleCallingContext const *)
 
bool doEvent (EventTransitionInfo const &, ActivityRegistry *, ModuleCallingContext const *)
 
void doPreallocate (PreallocationConfiguration const &)
 
std::map< BranchID::value_type, BranchID::value_type > const & droppedBranchIDToKeptBranchID ()
 
virtual void preallocLumis (unsigned int)
 
ParameterSetID selectorConfig () const
 
void setEventSelectionInfo (std::map< std::string, std::vector< std::pair< std::string, int >>> const &outputModulePathPositions, bool anyProductProduced)
 
- 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)
 

Detailed Description

Definition at line 197 of file DQMRootOutputModule.cc.

Constructor & Destructor Documentation

◆ DQMRootOutputModule()

DQMRootOutputModule::DQMRootOutputModule ( edm::ParameterSet const &  pset)
explicit

Definition at line 281 of file DQMRootOutputModule.cc.

284  m_fileName(pset.getUntrackedParameter<std::string>("fileName")),
285  m_logicalFileName(pset.getUntrackedParameter<std::string>("logicalFileName")),
286  m_file(nullptr),
287  m_treeHelpers(kNIndicies, std::shared_ptr<TreeHelperBase>()),
289  m_filterOnRun(pset.getUntrackedParameter<unsigned int>("filterOnRun")),
291  m_indicesTree(nullptr) {
292  // Declare dependencies for all Lumi and Run tokens here. In
293  // principle could use the keep statements, but then DQMToken would
294  // have to be made persistent (transient products are ignored),
295  // which would lead to a need to (finally) remove underscores from
296  // DQM module labels.
297  consumesMany<DQMToken, edm::InLumi>();
298  consumesMany<DQMToken, edm::InRun>();
299 }

◆ ~DQMRootOutputModule()

DQMRootOutputModule::~DQMRootOutputModule ( )
override

Definition at line 308 of file DQMRootOutputModule.cc.

308 {}

Member Function Documentation

◆ beginJob()

void DQMRootOutputModule::beginJob ( void  )
overridevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 306 of file DQMRootOutputModule.cc.

306 {}

◆ fillDescriptions()

void DQMRootOutputModule::fillDescriptions ( edm::ConfigurationDescriptions descriptions)
static

Definition at line 560 of file DQMRootOutputModule.cc.

560  {
562 
563  desc.addUntracked<std::string>("fileName");
564  desc.addUntracked<std::string>("logicalFileName", "");
565  desc.addUntracked<unsigned int>("filterOnRun", 0)
566  ->setComment("Only write the run with this run number. 0 means write all runs.");
567  desc.addOptionalUntracked<int>("splitLevel", 99)
568  ->setComment("UNUSED Only here to allow older configurations written for PoolOutputModule to work.");
569  const std::vector<std::string> keep = {"drop *", "keep DQMToken_*_*_*"};
571 
573  dataSet.setAllowAnything();
574  desc.addUntracked<edm::ParameterSetDescription>("dataset", dataSet)
575  ->setComment("PSet is only used by Data Operations and not by this module.");
576 
577  descriptions.addDefault(desc);
578 }

References edm::ConfigurationDescriptions::addDefault(), EgammaPostProcessor_cfi::dataSet, submitPVResolutionJobs::desc, edm::one::OutputModuleBase::fillDescription(), runTheMatrix::keep, and AlCaHLTBitMon_QueryRunRegistry::string.

◆ finishEndFile()

void DQMRootOutputModule::finishEndFile ( )
private

Definition at line 545 of file DQMRootOutputModule.cc.

545  {
546  //std::cout << "DQMRootOutputModule::finishEndFile"<< std::endl;
547  m_file->Write();
548  m_file->Close();
551 }

References m_file, m_jrToken, and edm::JobReport::outputFileClosed().

Referenced by reallyCloseFile().

◆ isFileOpen()

bool DQMRootOutputModule::isFileOpen ( ) const
overrideprivatevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 325 of file DQMRootOutputModule.cc.

325 { return nullptr != m_file.get(); }

References m_file.

◆ openFile()

void DQMRootOutputModule::openFile ( edm::FileBlock const &  )
overrideprivatevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 327 of file DQMRootOutputModule.cc.

327  {
328  //NOTE: I need to also set the I/O performance settings
329 
330  m_file = std::make_unique<TFile>(m_fileName.c_str(),
331  "RECREATE",
332  "1" //This is the file format version number
333  );
334 
336  cms::Digest branchHash;
337  std::string guid{m_file->GetUUID().AsString()};
338  std::transform(guid.begin(), guid.end(), guid.begin(), (int (*)(int))std::toupper);
339  m_jrToken = jr->outputFileOpened(m_fileName,
341  std::string(),
342  "DQMRootOutputModule",
344  guid,
345  std::string(),
346  branchHash.digest().toString(),
347  std::vector<std::string>());
348 
350  m_indicesTree->Branch(kRunBranch, &m_run);
351  m_indicesTree->Branch(kLumiBranch, &m_lumi);
355  m_indicesTree->Branch(kTypeBranch, &m_type);
358  m_indicesTree->SetDirectory(m_file.get());
359 
360  unsigned int i = 0;
361  for (std::vector<std::shared_ptr<TreeHelperBase> >::iterator it = m_treeHelpers.begin(), itEnd = m_treeHelpers.end();
362  it != itEnd;
363  ++it, ++i) {
364  //std::cout <<"making "<<kTypeNames[i]<<std::endl;
365  TTree* tree = new TTree(kTypeNames[i], kTypeNames[i]);
366  *it = std::shared_ptr<TreeHelperBase>(makeHelper(i, tree, m_fullNameBufferPtr));
367  tree->SetDirectory(m_file.get()); //TFile takes ownership
368  }
369 
382 }

References edm::one::OutputModuleBase::description(), cms::Digest::digest(), mps_fire::i, createfilelist::int, MonitorElementData::INT, kBeginTimeBranch, kEndTimeBranch, kFirstIndex, kFloatIndex, kIndicesTree, kIntIndex, kLastIndex, kLumiBranch, kProcessHistoryIndexBranch, kRunBranch, kStringIndex, kTH1DIndex, kTH1FIndex, kTH1SIndex, kTH2DIndex, kTH2FIndex, kTH2SIndex, kTH3FIndex, kTProfile2DIndex, kTProfileIndex, kTypeBranch, kTypeNames, m_beginTime, m_dqmKindToTypeIndex, m_endTime, m_file, m_fileName, m_firstIndex, m_fullNameBufferPtr, m_indicesTree, m_jrToken, m_lastIndex, m_logicalFileName, m_lumi, m_presentHistoryIndex, m_run, m_treeHelpers, m_type, makeHelper(), HerwigMaxPtPartonFilter_cfi::moduleLabel, MonitorElementData::REAL, MonitorElementData::STRING, AlCaHLTBitMon_QueryRunRegistry::string, MonitorElementData::TH1D, MonitorElementData::TH1F, MonitorElementData::TH1S, MonitorElementData::TH2D, MonitorElementData::TH2F, MonitorElementData::TH2S, MonitorElementData::TH3F, cms::MD5Result::toString(), MonitorElementData::TPROFILE, MonitorElementData::TPROFILE2D, HcalDetIdTransform::transform(), and trackerHitRTTI::vector.

◆ reallyCloseFile()

void DQMRootOutputModule::reallyCloseFile ( )
overrideprivatevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 487 of file DQMRootOutputModule.cc.

487  {
488  startEndFile();
489  finishEndFile();
490 }

References finishEndFile(), and startEndFile().

◆ startEndFile()

void DQMRootOutputModule::startEndFile ( )
private

Definition at line 492 of file DQMRootOutputModule.cc.

492  {
493  //std::cout << "DQMRootOutputModule::startEndFile"<< std::endl;
494  //fill in the meta data
495  m_file->cd();
496  TDirectory* metaDataDirectory = m_file->mkdir(kMetaDataDirectory);
497 
498  //Write out the Process History
499  TTree* processHistoryTree = new TTree(kProcessHistoryTree, kProcessHistoryTree);
500  processHistoryTree->SetDirectory(metaDataDirectory);
501 
502  unsigned int index = 0;
503  processHistoryTree->Branch(kPHIndexBranch, &index);
505  processHistoryTree->Branch(kProcessConfigurationProcessNameBranch, &processName);
506  std::string parameterSetID;
507  processHistoryTree->Branch(kProcessConfigurationParameterSetIDBranch, &parameterSetID);
508  std::string releaseVersion;
509  processHistoryTree->Branch(kProcessConfigurationReleaseVersion, &releaseVersion);
510  std::string passID;
511  processHistoryTree->Branch(kProcessConfigurationPassID, &passID);
512 
513  for (std::vector<edm::ProcessHistoryID>::iterator it = m_seenHistories.begin(), itEnd = m_seenHistories.end();
514  it != itEnd;
515  ++it) {
517  assert(nullptr != history);
518  index = 0;
519  for (edm::ProcessHistory::collection_type::const_iterator itPC = history->begin(), itPCEnd = history->end();
520  itPC != itPCEnd;
521  ++itPC, ++index) {
522  processName = itPC->processName();
523  releaseVersion = itPC->releaseVersion();
524  passID = itPC->passID();
525  parameterSetID = itPC->parameterSetID().compactForm();
526  tbb::this_task_arena::isolate([&] { processHistoryTree->Fill(); });
527  }
528  }
529 
530  //Store the ParameterSets
531  TTree* parameterSetsTree = new TTree(kParameterSetTree, kParameterSetTree);
532  parameterSetsTree->SetDirectory(metaDataDirectory);
533  std::string blob;
534  parameterSetsTree->Branch(kParameterSetBranch, &blob);
535 
537  assert(nullptr != psr);
538  for (edm::pset::Registry::const_iterator it = psr->begin(), itEnd = psr->end(); it != itEnd; ++it) {
539  blob.clear();
540  it->second.toString(blob);
541  tbb::this_task_arena::isolate([&] { parameterSetsTree->Fill(); });
542  }
543 }

References cms::cuda::assert(), edm::ProcessHistory::begin(), edm::pset::Registry::begin(), edm::ProcessHistory::end(), edm::pset::Registry::end(), edm::ProcessHistoryRegistry::getMapped(), edm::pset::Registry::instance(), kMetaDataDirectory, kParameterSetBranch, kParameterSetTree, kPHIndexBranch, kProcessConfigurationParameterSetIDBranch, kProcessConfigurationPassID, kProcessConfigurationProcessNameBranch, kProcessConfigurationReleaseVersion, kProcessHistoryTree, m_file, m_processHistoryRegistry, m_seenHistories, edm::one::OutputModuleBase::processName(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by reallyCloseFile().

◆ write()

void DQMRootOutputModule::write ( edm::EventForOutput const &  e)
overrideprivatevirtual

Implements edm::one::OutputModuleBase.

Definition at line 384 of file DQMRootOutputModule.cc.

384 {}

Referenced by pkg.AbstractPkg::generate().

◆ writeLuminosityBlock()

void DQMRootOutputModule::writeLuminosityBlock ( edm::LuminosityBlockForOutput const &  iLumi)
overrideprivatevirtual

Implements edm::one::OutputModuleBase.

Definition at line 386 of file DQMRootOutputModule.cc.

386  {
387  //std::cout << "DQMRootOutputModule::writeLuminosityBlock"<< std::endl;
388  edm::Service<DQMStore> dstore;
389  m_run = iLumi.id().run();
390  m_lumi = iLumi.id().value();
391  m_beginTime = iLumi.beginTime().value();
392  m_endTime = iLumi.endTime().value();
393  bool shouldWrite = (m_filterOnRun == 0 || (m_filterOnRun != 0 && m_filterOnRun == m_run));
394 
395  if (!shouldWrite)
396  return;
397  std::vector<MonitorElement*> items(dstore->getAllContents("", m_run, m_lumi));
398  for (std::vector<MonitorElement*>::iterator it = items.begin(), itEnd = items.end(); it != itEnd; ++it) {
399  assert((*it)->getScope() == MonitorElementData::Scope::LUMI);
400  std::map<unsigned int, unsigned int>::iterator itFound = m_dqmKindToTypeIndex.find((int)(*it)->kind());
401  assert(itFound != m_dqmKindToTypeIndex.end());
402  m_treeHelpers[itFound->second]->fill(*it);
403  }
404 
405  const edm::ProcessHistoryID& id = iLumi.processHistoryID();
406  std::vector<edm::ProcessHistoryID>::iterator itFind = std::find(m_seenHistories.begin(), m_seenHistories.end(), id);
407  if (itFind == m_seenHistories.end()) {
408  m_processHistoryRegistry.registerProcessHistory(iLumi.processHistory());
410  m_seenHistories.push_back(id);
411  } else {
412  m_presentHistoryIndex = itFind - m_seenHistories.begin();
413  }
414 
415  //Now store the relationship between run/lumi and indices in the other TTrees
416  bool storedLumiIndex = false;
417  unsigned int typeIndex = 0;
418  for (std::vector<std::shared_ptr<TreeHelperBase> >::iterator it = m_treeHelpers.begin(), itEnd = m_treeHelpers.end();
419  it != itEnd;
420  ++it, ++typeIndex) {
421  if ((*it)->wasFilled()) {
422  m_type = typeIndex;
423  (*it)->getRangeAndReset(m_firstIndex, m_lastIndex);
424  storedLumiIndex = true;
425  tbb::this_task_arena::isolate([&] { m_indicesTree->Fill(); });
426  }
427  }
428  if (not storedLumiIndex) {
429  //need to record lumis even if we stored no MonitorElements since some later DQM modules
430  // look to see what lumis were processed
432  m_firstIndex = 0;
433  m_lastIndex = 0;
434  tbb::this_task_arena::isolate([&] { m_indicesTree->Fill(); });
435  }
436 
439 }

References cms::cuda::assert(), edm::LuminosityBlockForOutput::beginTime(), edm::LuminosityBlockForOutput::endTime(), spr::find(), dqm::implementation::IGetter::getAllContents(), triggerObjects_cff::id, edm::LuminosityBlockForOutput::id(), mps_monitormerge::items, kNoTypesStored, m_beginTime, m_dqmKindToTypeIndex, m_endTime, m_filterOnRun, m_firstIndex, m_indicesTree, m_jrToken, m_lastIndex, m_lumi, m_presentHistoryIndex, m_processHistoryRegistry, m_run, m_seenHistories, m_treeHelpers, m_type, edm::OccurrenceForOutput::processHistory(), edm::OccurrenceForOutput::processHistoryID(), edm::ProcessHistoryRegistry::registerProcessHistory(), edm::JobReport::reportLumiSection(), edm::LuminosityBlockID::run(), edm::LuminosityBlockID::value(), edm::Timestamp::value(), and trackerHitRTTI::vector.

◆ writeRun()

void DQMRootOutputModule::writeRun ( edm::RunForOutput const &  iRun)
overrideprivatevirtual

Implements edm::one::OutputModuleBase.

Definition at line 441 of file DQMRootOutputModule.cc.

441  {
442  //std::cout << "DQMRootOutputModule::writeRun"<< std::endl;
443  edm::Service<DQMStore> dstore;
444  m_run = iRun.id().run();
445  m_lumi = 0;
446  m_beginTime = iRun.beginTime().value();
447  m_endTime = iRun.endTime().value();
448  bool shouldWrite = (m_filterOnRun == 0 || (m_filterOnRun != 0 && m_filterOnRun == m_run));
449 
450  if (!shouldWrite)
451  return;
452 
453  std::vector<MonitorElement*> items(dstore->getAllContents("", m_run, 0));
454  for (std::vector<MonitorElement*>::iterator it = items.begin(), itEnd = items.end(); it != itEnd; ++it) {
455  assert((*it)->getScope() == MonitorElementData::Scope::RUN);
456  std::map<unsigned int, unsigned int>::iterator itFound = m_dqmKindToTypeIndex.find((int)(*it)->kind());
457  assert(itFound != m_dqmKindToTypeIndex.end());
458  m_treeHelpers[itFound->second]->fill(*it);
459  }
460 
461  const edm::ProcessHistoryID& id = iRun.processHistoryID();
462  std::vector<edm::ProcessHistoryID>::iterator itFind = std::find(m_seenHistories.begin(), m_seenHistories.end(), id);
463  if (itFind == m_seenHistories.end()) {
464  m_processHistoryRegistry.registerProcessHistory(iRun.processHistory());
466  m_seenHistories.push_back(id);
467  } else {
468  m_presentHistoryIndex = itFind - m_seenHistories.begin();
469  }
470 
471  //Now store the relationship between run/lumi and indices in the other TTrees
472  unsigned int typeIndex = 0;
473  for (std::vector<std::shared_ptr<TreeHelperBase> >::iterator it = m_treeHelpers.begin(), itEnd = m_treeHelpers.end();
474  it != itEnd;
475  ++it, ++typeIndex) {
476  if ((*it)->wasFilled()) {
477  m_type = typeIndex;
478  (*it)->getRangeAndReset(m_firstIndex, m_lastIndex);
479  tbb::this_task_arena::isolate([&] { m_indicesTree->Fill(); });
480  }
481  }
482 
485 }

References cms::cuda::assert(), edm::RunForOutput::beginTime(), edm::RunForOutput::endTime(), spr::find(), dqm::implementation::IGetter::getAllContents(), triggerObjects_cff::id, edm::RunForOutput::id(), mps_monitormerge::items, m_beginTime, m_dqmKindToTypeIndex, m_endTime, m_filterOnRun, m_firstIndex, m_indicesTree, m_jrToken, m_lastIndex, m_lumi, m_presentHistoryIndex, m_processHistoryRegistry, m_run, m_seenHistories, m_treeHelpers, m_type, edm::OccurrenceForOutput::processHistory(), edm::OccurrenceForOutput::processHistoryID(), edm::ProcessHistoryRegistry::registerProcessHistory(), edm::JobReport::reportRunNumber(), edm::RunID::run(), edm::Timestamp::value(), and trackerHitRTTI::vector.

Member Data Documentation

◆ m_beginTime

ULong64_t DQMRootOutputModule::m_beginTime
private

Definition at line 223 of file DQMRootOutputModule.cc.

Referenced by openFile(), writeLuminosityBlock(), and writeRun().

◆ m_dqmKindToTypeIndex

std::map<unsigned int, unsigned int> DQMRootOutputModule::m_dqmKindToTypeIndex
private

Definition at line 231 of file DQMRootOutputModule.cc.

Referenced by openFile(), writeLuminosityBlock(), and writeRun().

◆ m_endTime

ULong64_t DQMRootOutputModule::m_endTime
private

Definition at line 224 of file DQMRootOutputModule.cc.

Referenced by openFile(), writeLuminosityBlock(), and writeRun().

◆ m_file

std::unique_ptr<TFile> DQMRootOutputModule::m_file
private

Definition at line 216 of file DQMRootOutputModule.cc.

Referenced by finishEndFile(), isFileOpen(), openFile(), and startEndFile().

◆ m_fileName

std::string DQMRootOutputModule::m_fileName
private

Definition at line 214 of file DQMRootOutputModule.cc.

Referenced by openFile().

◆ m_filterOnRun

unsigned int DQMRootOutputModule::m_filterOnRun
private

Definition at line 227 of file DQMRootOutputModule.cc.

Referenced by writeLuminosityBlock(), and writeRun().

◆ m_firstIndex

ULong64_t DQMRootOutputModule::m_firstIndex
private

Definition at line 225 of file DQMRootOutputModule.cc.

Referenced by openFile(), writeLuminosityBlock(), and writeRun().

◆ m_fullNameBuffer

std::string DQMRootOutputModule::m_fullNameBuffer
private

Definition at line 229 of file DQMRootOutputModule.cc.

◆ m_fullNameBufferPtr

std::string* DQMRootOutputModule::m_fullNameBufferPtr
private

Definition at line 230 of file DQMRootOutputModule.cc.

Referenced by openFile().

◆ m_indicesTree

TTree* DQMRootOutputModule::m_indicesTree
private

Definition at line 232 of file DQMRootOutputModule.cc.

Referenced by openFile(), writeLuminosityBlock(), and writeRun().

◆ m_jrToken

edm::JobReport::Token DQMRootOutputModule::m_jrToken
private

Definition at line 236 of file DQMRootOutputModule.cc.

Referenced by finishEndFile(), openFile(), writeLuminosityBlock(), and writeRun().

◆ m_lastIndex

ULong64_t DQMRootOutputModule::m_lastIndex
private

Definition at line 226 of file DQMRootOutputModule.cc.

Referenced by openFile(), writeLuminosityBlock(), and writeRun().

◆ m_logicalFileName

std::string DQMRootOutputModule::m_logicalFileName
private

Definition at line 215 of file DQMRootOutputModule.cc.

Referenced by openFile().

◆ m_lumi

unsigned int DQMRootOutputModule::m_lumi
private

Definition at line 220 of file DQMRootOutputModule.cc.

Referenced by openFile(), writeLuminosityBlock(), and writeRun().

◆ m_presentHistoryIndex

unsigned int DQMRootOutputModule::m_presentHistoryIndex
private

Definition at line 222 of file DQMRootOutputModule.cc.

Referenced by openFile(), writeLuminosityBlock(), and writeRun().

◆ m_processHistoryRegistry

edm::ProcessHistoryRegistry DQMRootOutputModule::m_processHistoryRegistry
private

Definition at line 235 of file DQMRootOutputModule.cc.

Referenced by startEndFile(), writeLuminosityBlock(), and writeRun().

◆ m_run

unsigned int DQMRootOutputModule::m_run
private

Definition at line 219 of file DQMRootOutputModule.cc.

Referenced by openFile(), writeLuminosityBlock(), and writeRun().

◆ m_seenHistories

std::vector<edm::ProcessHistoryID> DQMRootOutputModule::m_seenHistories
private

Definition at line 234 of file DQMRootOutputModule.cc.

Referenced by startEndFile(), writeLuminosityBlock(), and writeRun().

◆ m_treeHelpers

std::vector<std::shared_ptr<TreeHelperBase> > DQMRootOutputModule::m_treeHelpers
private

Definition at line 217 of file DQMRootOutputModule.cc.

Referenced by openFile(), writeLuminosityBlock(), and writeRun().

◆ m_type

unsigned int DQMRootOutputModule::m_type
private

Definition at line 221 of file DQMRootOutputModule.cc.

Referenced by openFile(), writeLuminosityBlock(), and writeRun().

edm::one::OutputModule<>
DQMRootOutputModule::m_presentHistoryIndex
unsigned int m_presentHistoryIndex
Definition: DQMRootOutputModule.cc:222
edm::pset::Registry::instance
static Registry * instance()
Definition: Registry.cc:12
kLastIndex
static const char *const kLastIndex
Definition: format.h:66
edm::ProcessHistoryRegistry::registerProcessHistory
bool registerProcessHistory(ProcessHistory const &processHistory)
Definition: ProcessHistoryRegistry.cc:11
DQMRootOutputModule::m_processHistoryRegistry
edm::ProcessHistoryRegistry m_processHistoryRegistry
Definition: DQMRootOutputModule.cc:235
mps_fire.i
i
Definition: mps_fire.py:428
kTProfileIndex
Definition: format.h:33
MonitorElementData::Kind::INT
DQMRootOutputModule::m_endTime
ULong64_t m_endTime
Definition: DQMRootOutputModule.cc:224
cms::Digest::digest
MD5Result digest()
Definition: Digest.cc:171
MonitorElementData::Kind::TH1S
kParameterSetBranch
static const char *const kParameterSetBranch
Definition: format.h:80
MonitorElementData::Kind::TH1F
tree
Definition: tree.py:1
MonitorElementData::Kind::STRING
EgammaPostProcessor_cfi.dataSet
dataSet
Definition: EgammaPostProcessor_cfi.py:6
edm::ParameterSetDescription
Definition: ParameterSetDescription.h:52
DQMRootOutputModule::m_fullNameBufferPtr
std::string * m_fullNameBufferPtr
Definition: DQMRootOutputModule.cc:230
cms::cuda::assert
assert(be >=bs)
DQMRootOutputModule::m_type
unsigned int m_type
Definition: DQMRootOutputModule.cc:221
kLumiBranch
static const char *const kLumiBranch
Definition: format.h:60
DQMRootOutputModule::finishEndFile
void finishEndFile()
Definition: DQMRootOutputModule.cc:545
dqm::implementation::IGetter::getAllContents
virtual std::vector< dqm::harvesting::MonitorElement * > getAllContents(std::string const &path) const
Definition: DQMStore.cc:609
spr::find
void find(edm::Handle< EcalRecHitCollection > &hits, DetId thisDet, std::vector< EcalRecHitCollection::const_iterator > &hit, bool debug=false)
Definition: FindCaloHit.cc:19
MonitorElementData::Kind::TH2D
kProcessHistoryTree
static const char *const kProcessHistoryTree
Definition: format.h:72
edm::one::OutputModuleBase::OutputModuleBase
OutputModuleBase(ParameterSet const &pset)
Definition: OutputModuleBase.cc:46
mps_monitormerge.items
list items
Definition: mps_monitormerge.py:29
MonitorElementData::Kind::TH2F
kProcessConfigurationParameterSetIDBranch
static const char *const kProcessConfigurationParameterSetIDBranch
Definition: format.h:75
kTypeNames
static const char *const kTypeNames[]
Definition: format.h:39
DQMRootOutputModule::m_lumi
unsigned int m_lumi
Definition: DQMRootOutputModule.cc:220
makeHelper
static TreeHelperBase * makeHelper(unsigned int iTypeIndex, TTree *iTree, std::string *iFullNameBufferPtr)
Definition: DQMRootOutputModule.cc:243
DQMRootOutputModule::m_fileName
std::string m_fileName
Definition: DQMRootOutputModule.cc:214
kNoTypesStored
Definition: format.h:36
cms::Digest
Definition: Digest.h:46
DQMRootOutputModule::m_dqmKindToTypeIndex
std::map< unsigned int, unsigned int > m_dqmKindToTypeIndex
Definition: DQMRootOutputModule.cc:231
edm::pset::Registry::end
const_iterator end() const
Definition: Registry.h:65
kTH3FIndex
Definition: format.h:32
kProcessConfigurationProcessNameBranch
static const char *const kProcessConfigurationProcessNameBranch
Definition: format.h:74
edm::Hash< ProcessHistoryType >
edm::JobReport::outputFileClosed
void outputFileClosed(Token fileToken)
Definition: JobReport.cc:433
HcalDetIdTransform::transform
unsigned transform(const HcalDetId &id, unsigned transformCode)
Definition: HcalDetIdTransform.cc:7
runTheMatrix.keep
keep
Definition: runTheMatrix.py:345
edm::one::OutputModuleBase::fillDescription
static void fillDescription(ParameterSetDescription &desc, std::vector< std::string > const &iDefaultOutputCommands=ProductSelectorRules::defaultSelectionStrings())
Definition: OutputModuleBase.cc:361
kParameterSetTree
static const char *const kParameterSetTree
Definition: format.h:79
DQMRootOutputModule::m_lastIndex
ULong64_t m_lastIndex
Definition: DQMRootOutputModule.cc:226
kTypeBranch
static const char *const kTypeBranch
Definition: format.h:64
DQMRootOutputModule::m_fullNameBuffer
std::string m_fullNameBuffer
Definition: DQMRootOutputModule.cc:229
edm::JobReport::reportLumiSection
void reportLumiSection(JobReport::Token token, unsigned int run, unsigned int lumiSectId, unsigned long nEvents=0)
Definition: JobReport.cc:458
kIntIndex
Definition: format.h:23
DQMRootOutputModule::m_filterOnRun
unsigned int m_filterOnRun
Definition: DQMRootOutputModule.cc:227
kTH1FIndex
Definition: format.h:26
DQMRootOutputModule::m_firstIndex
ULong64_t m_firstIndex
Definition: DQMRootOutputModule.cc:225
kMetaDataDirectory
static const char *const kMetaDataDirectory
Definition: format.h:70
kProcessConfigurationReleaseVersion
static const char *const kProcessConfigurationReleaseVersion
Definition: format.h:76
edm::Service
Definition: Service.h:30
createfilelist.int
int
Definition: createfilelist.py:10
edm::ProcessHistory::end
const_iterator end() const
Definition: ProcessHistory.h:63
trackerHitRTTI::vector
Definition: trackerHitRTTI.h:21
kStringIndex
Definition: format.h:25
kPHIndexBranch
static const char *const kPHIndexBranch
Definition: format.h:73
kTH1SIndex
Definition: format.h:27
edm::JobReport::reportRunNumber
void reportRunNumber(JobReport::Token token, unsigned int run)
Definition: JobReport.cc:469
kTH2SIndex
Definition: format.h:30
kTH2FIndex
Definition: format.h:29
kProcessConfigurationPassID
static const char *const kProcessConfigurationPassID
Definition: format.h:77
DQMRootOutputModule::m_file
std::unique_ptr< TFile > m_file
Definition: DQMRootOutputModule.cc:216
MonitorElementData::Kind::TH1D
kEndTimeBranch
static const char *const kEndTimeBranch
Definition: format.h:63
AlCaHLTBitMon_QueryRunRegistry.string
string string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:256
edm::one::OutputModuleBase::processName
std::string const & processName() const
Definition: OutputModuleBase.h:96
DQMRootOutputModule::m_seenHistories
std::vector< edm::ProcessHistoryID > m_seenHistories
Definition: DQMRootOutputModule.cc:234
DQMRootOutputModule::m_run
unsigned int m_run
Definition: DQMRootOutputModule.cc:219
kTH2DIndex
Definition: format.h:31
kNIndicies
Definition: format.h:35
MonitorElementData::Kind::TH2S
DQMRootOutputModule::m_indicesTree
TTree * m_indicesTree
Definition: DQMRootOutputModule.cc:232
submitPVResolutionJobs.desc
string desc
Definition: submitPVResolutionJobs.py:251
edm::one::OutputModuleBase::description
ModuleDescription const & description() const
Definition: OutputModuleBase.cc:351
DQMRootOutputModule::m_treeHelpers
std::vector< std::shared_ptr< TreeHelperBase > > m_treeHelpers
Definition: DQMRootOutputModule.cc:217
MonitorElementData::Kind::TPROFILE2D
MonitorElementData::Kind::TH3F
kBeginTimeBranch
static const char *const kBeginTimeBranch
Definition: format.h:62
triggerObjects_cff.id
id
Definition: triggerObjects_cff.py:29
edm::ProcessHistoryRegistry::getMapped
bool getMapped(ProcessHistoryID const &key, ProcessHistory &value) const
Definition: ProcessHistoryRegistry.cc:29
AlignmentPI::index
index
Definition: AlignmentPayloadInspectorHelper.h:46
kFirstIndex
static const char *const kFirstIndex
Definition: format.h:65
edm::ProcessHistory::begin
const_iterator begin() const
Definition: ProcessHistory.h:62
kTH1DIndex
Definition: format.h:28
DQMRootOutputModule::startEndFile
void startEndFile()
Definition: DQMRootOutputModule.cc:492
edm::ProcessHistory
Definition: ProcessHistory.h:13
kFloatIndex
Definition: format.h:24
kProcessHistoryIndexBranch
static const char *const kProcessHistoryIndexBranch
Definition: format.h:61
edm::pset::Registry::begin
const_iterator begin() const
Definition: Registry.h:63
HerwigMaxPtPartonFilter_cfi.moduleLabel
moduleLabel
Definition: HerwigMaxPtPartonFilter_cfi.py:4
DQMRootOutputModule::m_jrToken
edm::JobReport::Token m_jrToken
Definition: DQMRootOutputModule.cc:236
edm::pset::Registry::const_iterator
map_type::const_iterator const_iterator
Definition: Registry.h:61
cms::MD5Result::toString
std::string toString() const
Definition: Digest.cc:95
kIndicesTree
static const char *const kIndicesTree
Definition: format.h:58
DQMRootOutputModule::m_beginTime
ULong64_t m_beginTime
Definition: DQMRootOutputModule.cc:223
edm::ConfigurationDescriptions::addDefault
void addDefault(ParameterSetDescription const &psetDescription)
Definition: ConfigurationDescriptions.cc:99
MonitorElementData::Kind::TPROFILE
DQMRootOutputModule::m_logicalFileName
std::string m_logicalFileName
Definition: DQMRootOutputModule.cc:215
MonitorElementData::Kind::REAL
kTProfile2DIndex
Definition: format.h:34
edm::pset::Registry
Definition: Registry.h:26
muonDTDigis_cfi.pset
pset
Definition: muonDTDigis_cfi.py:27
kRunBranch
static const char *const kRunBranch
Definition: format.h:59