Inheritance diagram for DQMRootOutputModule:

Public Member Functions
void	beginJob () override

	DQMRootOutputModule (edm::ParameterSet const &pset)

	~DQMRootOutputModule () override

Public Member Functions inherited from edm::one::OutputModule<>
SerialTaskQueue *	globalLuminosityBlocksQueue () final

SerialTaskQueue *	globalRunsQueue () final

const OutputModule &	operator= (const OutputModule &)=delete

	OutputModule (edm::ParameterSet const &iPSet)

	OutputModule (const OutputModule &)=delete

bool	wantsGlobalLuminosityBlocks () const final

bool	wantsGlobalRuns () const final

bool	wantsInputProcessBlocks () const final

bool	wantsProcessBlocks () const final

Public Member Functions inherited from edm::one::OutputModuleBase
OutputModuleBase &	operator= (OutputModuleBase const &)=delete

	OutputModuleBase (ParameterSet const &pset)

	OutputModuleBase (OutputModuleBase const &)=delete

SharedResourcesAcquirer &	sharedResourcesAcquirer ()

SubProcessParentageHelper const *	subProcessParentageHelper () const

bool	wantsStreamLuminosityBlocks () const

bool	wantsStreamRuns () const

Public Member Functions inherited from edm::core::OutputModuleCore
BranchIDLists const *	branchIDLists () const

void	callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)

std::array< bool, NumBranchTypes > const &	hasNewlyDroppedBranch () const

SelectedProductsForBranchType const &	keptProducts () const

int	maxEvents () const

const ModuleDescription &	moduleDescription () const

OutputModuleCore &	operator= (OutputModuleCore const &)=delete

	OutputModuleCore (ParameterSet const &pset)

	OutputModuleCore (OutputModuleCore const &)=delete

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 &)

ThinnedAssociationsHelper const *	thinnedAssociationsHelper () const

bool	wantAllEvents () const

	~OutputModuleCore () override

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

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

	EDConsumerBase ()

	EDConsumerBase (EDConsumerBase const &)=delete

	EDConsumerBase (EDConsumerBase &&)=default

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

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

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

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

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

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

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

void	labelsForToken (EDGetToken iToken, Labels &oLabels) const

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

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

EDConsumerBase &	operator= (EDConsumerBase &&)=default

bool	registeredToConsume (ProductResolverIndex, bool, BranchType) const

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

ProductResolverIndexAndSkipBit	uncheckedIndexFrom (EDGetToken) const

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

void	updateLookup (eventsetup::ESRecordsToProductResolverIndices const &)

virtual	~EDConsumerBase () noexcept(false)

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

Static Public Member Functions inherited from edm::core::OutputModuleCore
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

edm::GetterOfProducts< DQMToken >	m_getterOfProductsLumi

edm::GetterOfProducts< DQMToken >	m_getterOfProductsRun

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::ProcessHistoryID >	m_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::core::OutputModuleCore
typedef OutputModuleCore	ModuleType

Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels

Protected Member Functions inherited from edm::one::OutputModuleBase
void	configure (OutputModuleDescription const &desc)

void	doBeginJob ()

bool	doEvent (EventTransitionInfo const &, ActivityRegistry , ModuleCallingContext const )

void	doPreallocate (PreallocationConfiguration const &)

Protected Member Functions inherited from edm::core::OutputModuleCore
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
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	consumes (edm::InputTag const &tag)

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

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

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

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

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

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

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

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

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

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

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

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

void	resetItemsToGetFrom (BranchType iType)

Protected Attributes inherited from edm::core::OutputModuleCore
std::atomic< int >	remainingEvents_

Detailed Description

Definition at line 201 of file DQMRootOutputModule.cc.

Constructor & Destructor Documentation

◆ DQMRootOutputModule()

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

explicit

Definition at line 292 of file DQMRootOutputModule.cc.

References edm::core::OutputModuleCore::callWhenNewProductsRegistered(), m_getterOfProductsLumi, and m_getterOfProductsRun.

     : edm::one::OutputModuleBase::OutputModuleBase(pset),
       edm::one::OutputModule<>(pset),
       m_fileName(pset.getUntrackedParameter<std::string>("fileName")),
       m_logicalFileName(pset.getUntrackedParameter<std::string>("logicalFileName")),
       m_file(nullptr),
       m_treeHelpers(kNIndicies, std::shared_ptr<TreeHelperBase>()),
       m_presentHistoryIndex(0),
       m_filterOnRun(pset.getUntrackedParameter<unsigned int>("filterOnRun")),
       m_fullNameBufferPtr(&m_fullNameBuffer),
       m_indicesTree(nullptr),
       m_getterOfProductsLumi(edm::TypeMatch(), this, edm::InLumi),
       m_getterOfProductsRun(edm::TypeMatch(), this, edm::InRun) {
   // Declare dependencies for all Lumi and Run tokens here. In
   // principle could use the keep statements, but then DQMToken would
   // have to be made persistent (transient products are ignored),
   // which would lead to a need to (finally) remove underscores from
   // DQM module labels.
   // This is needed to support unscheduled DQM modules now that
   // non-consumed EDProducers are deleted from the job at beginJob.
   callWhenNewProductsRegistered([this](edm::BranchDescription const& bd) {
     m_getterOfProductsLumi(bd);
     m_getterOfProductsRun(bd);
   });
 }

◆ ~DQMRootOutputModule()

DQMRootOutputModule::~DQMRootOutputModule ( )

override

Definition at line 325 of file DQMRootOutputModule.cc.

325 {}

Member Function Documentation

◆ beginJob()

void DQMRootOutputModule::beginJob ( void )

overridevirtual

Reimplemented from edm::core::OutputModuleCore.

Definition at line 323 of file DQMRootOutputModule.cc.

323 {}

◆ fillDescriptions()

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

static

Definition at line 581 of file DQMRootOutputModule.cc.

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

                                                                                      {
   edm::ParameterSetDescription desc;
 
   desc.addUntracked<std::string>("fileName");
   desc.addUntracked<std::string>("logicalFileName", "");
   desc.addUntracked<unsigned int>("filterOnRun", 0)
       ->setComment("Only write the run with this run number. 0 means write all runs.");
   desc.addOptionalUntracked<int>("splitLevel", 99)
       ->setComment("UNUSED Only here to allow older configurations written for PoolOutputModule to work.");
   const std::vector<std::string> keep = {"drop *", "keep DQMToken_*_*_*"};
   edm::one::OutputModule<>::fillDescription(desc, keep);
 
   edm::ParameterSetDescription dataSet;
   dataSet.setAllowAnything();
   desc.addUntracked<edm::ParameterSetDescription>("dataset", dataSet)
       ->setComment("PSet is only used by Data Operations and not by this module.");
 
   descriptions.addDefault(desc);
 }

◆ finishEndFile()

void DQMRootOutputModule::finishEndFile ( )

private

Definition at line 566 of file DQMRootOutputModule.cc.

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

Referenced by reallyCloseFile().

                                         {
   //std::cout << "DQMRootOutputModule::finishEndFile"<< std::endl;
   m_file->Write();
   m_file->Close();
   edm::Service<edm::JobReport> jr;
   jr->outputFileClosed(m_jrToken);
 }

◆ isFileOpen()

bool DQMRootOutputModule::isFileOpen ( ) const

overrideprivatevirtual

Reimplemented from edm::core::OutputModuleCore.

Definition at line 342 of file DQMRootOutputModule.cc.

References m_file.

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

DQMRootOutputModule::m_file

std::unique_ptr< TFile > m_file

Definition: DQMRootOutputModule.cc:220

◆ openFile()

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

overrideprivatevirtual

Reimplemented from edm::core::OutputModuleCore.

Definition at line 344 of file DQMRootOutputModule.cc.

                                                       {
   //NOTE: I need to also set the I/O performance settings
 
   m_file = std::make_unique<TFile>(m_fileName.c_str(),
                                    "RECREATE",
                                    "1"  //This is the file format version number
   );
 
   edm::Service<edm::JobReport> jr;
   cms::Digest branchHash;
   std::string guid{edm::createGlobalIdentifier()};
   std::transform(guid.begin(), guid.end(), guid.begin(), (int (*)(int))std::toupper);
 
   m_file->WriteObject(&guid, kCmsGuid);
   m_jrToken = jr->outputFileOpened(m_fileName,
                                    m_logicalFileName,
                                    std::string(),
                                    "DQMRootOutputModule",
                                    description().moduleLabel(),
                                    guid,
                                    std::string(),
                                    branchHash.digest().toString(),
                                    std::vector<std::string>());
 
   m_indicesTree = new TTree(kIndicesTree, kIndicesTree);
   m_indicesTree->Branch(kRunBranch, &m_run);
   m_indicesTree->Branch(kLumiBranch, &m_lumi);
   m_indicesTree->Branch(kProcessHistoryIndexBranch, &m_presentHistoryIndex);
   m_indicesTree->Branch(kBeginTimeBranch, &m_beginTime);
   m_indicesTree->Branch(kEndTimeBranch, &m_endTime);
   m_indicesTree->Branch(kTypeBranch, &m_type);
   m_indicesTree->Branch(kFirstIndex, &m_firstIndex);
   m_indicesTree->Branch(kLastIndex, &m_lastIndex);
   m_indicesTree->SetDirectory(m_file.get());
 
   unsigned int i = 0;
   for (std::vector<std::shared_ptr<TreeHelperBase> >::iterator it = m_treeHelpers.begin(), itEnd = m_treeHelpers.end();
        it != itEnd;
        ++it, ++i) {
     //std::cout <<"making "<<kTypeNames[i]<<std::endl;
     TTree* tree = new TTree(kTypeNames[i], kTypeNames[i]);
     *it = std::shared_ptr<TreeHelperBase>(makeHelper(i, tree, m_fullNameBufferPtr));
     tree->SetDirectory(m_file.get());  //TFile takes ownership
   }
 
   m_dqmKindToTypeIndex[(int)MonitorElement::Kind::INT] = kIntIndex;
   m_dqmKindToTypeIndex[(int)MonitorElement::Kind::REAL] = kFloatIndex;
   m_dqmKindToTypeIndex[(int)MonitorElement::Kind::STRING] = kStringIndex;
   m_dqmKindToTypeIndex[(int)MonitorElement::Kind::TH1F] = kTH1FIndex;
   m_dqmKindToTypeIndex[(int)MonitorElement::Kind::TH1S] = kTH1SIndex;
   m_dqmKindToTypeIndex[(int)MonitorElement::Kind::TH1D] = kTH1DIndex;
   m_dqmKindToTypeIndex[(int)MonitorElement::Kind::TH1I] = kTH1IIndex;
   m_dqmKindToTypeIndex[(int)MonitorElement::Kind::TH2F] = kTH2FIndex;
   m_dqmKindToTypeIndex[(int)MonitorElement::Kind::TH2S] = kTH2SIndex;
   m_dqmKindToTypeIndex[(int)MonitorElement::Kind::TH2D] = kTH2DIndex;
   m_dqmKindToTypeIndex[(int)MonitorElement::Kind::TH2I] = kTH2IIndex;
   m_dqmKindToTypeIndex[(int)MonitorElement::Kind::TH3F] = kTH3FIndex;
   m_dqmKindToTypeIndex[(int)MonitorElement::Kind::TPROFILE] = kTProfileIndex;
   m_dqmKindToTypeIndex[(int)MonitorElement::Kind::TPROFILE2D] = kTProfile2DIndex;
 }

◆ reallyCloseFile()

void DQMRootOutputModule::reallyCloseFile ( )

overrideprivatevirtual

Reimplemented from edm::core::OutputModuleCore.

Definition at line 508 of file DQMRootOutputModule.cc.

References finishEndFile(), and startEndFile().

                                           {
   startEndFile();
   finishEndFile();
 }

◆ startEndFile()

void DQMRootOutputModule::startEndFile ( )

private

Definition at line 513 of file DQMRootOutputModule.cc.

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::core::OutputModuleCore::processName(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by reallyCloseFile().

                                        {
   //std::cout << "DQMRootOutputModule::startEndFile"<< std::endl;
   //fill in the meta data
   m_file->cd();
   TDirectory* metaDataDirectory = m_file->mkdir(kMetaDataDirectory);
 
   //Write out the Process History
   TTree* processHistoryTree = new TTree(kProcessHistoryTree, kProcessHistoryTree);
   processHistoryTree->SetDirectory(metaDataDirectory);
 
   unsigned int index = 0;
   processHistoryTree->Branch(kPHIndexBranch, &index);
   std::string processName;
   processHistoryTree->Branch(kProcessConfigurationProcessNameBranch, &processName);
   std::string parameterSetID;
   processHistoryTree->Branch(kProcessConfigurationParameterSetIDBranch, &parameterSetID);
   std::string releaseVersion;
   processHistoryTree->Branch(kProcessConfigurationReleaseVersion, &releaseVersion);
   std::string passID;
   processHistoryTree->Branch(kProcessConfigurationPassID, &passID);
 
   for (std::vector<edm::ProcessHistoryID>::iterator it = m_seenHistories.begin(), itEnd = m_seenHistories.end();
        it != itEnd;
        ++it) {
     const edm::ProcessHistory* history = m_processHistoryRegistry.getMapped(*it);
     assert(nullptr != history);
     index = 0;
     for (edm::ProcessHistory::collection_type::const_iterator itPC = history->begin(), itPCEnd = history->end();
          itPC != itPCEnd;
          ++itPC, ++index) {
       processName = itPC->processName();
       releaseVersion = itPC->releaseVersion();
       passID = itPC->passID();
       parameterSetID = itPC->parameterSetID().compactForm();
       tbb::this_task_arena::isolate([&] { processHistoryTree->Fill(); });
     }
   }
 
   //Store the ParameterSets
   TTree* parameterSetsTree = new TTree(kParameterSetTree, kParameterSetTree);
   parameterSetsTree->SetDirectory(metaDataDirectory);
   std::string blob;
   parameterSetsTree->Branch(kParameterSetBranch, &blob);
 
   edm::pset::Registry* psr = edm::pset::Registry::instance();
   assert(nullptr != psr);
   for (edm::pset::Registry::const_iterator it = psr->begin(), itEnd = psr->end(); it != itEnd; ++it) {
     blob.clear();
     it->second.toString(blob);
     tbb::this_task_arena::isolate([&] { parameterSetsTree->Fill(); });
   }
 }

◆ write()

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

overrideprivatevirtual

Implements edm::core::OutputModuleCore.

Definition at line 405 of file DQMRootOutputModule.cc.

Referenced by pkg.AbstractPkg::generate().

405 {}

◆ writeLuminosityBlock()

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

overrideprivatevirtual

Implements edm::core::OutputModuleCore.

Definition at line 407 of file DQMRootOutputModule.cc.

References cms::cuda::assert(), edm::LuminosityBlockForOutput::beginTime(), edm::LuminosityBlockForOutput::endTime(), spr::find(), dqm::implementation::IGetter::getAllContents(), edm::LuminosityBlockForOutput::id(), l1ctLayer2EG_cff::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.

                                                                                        {
   //std::cout << "DQMRootOutputModule::writeLuminosityBlock"<< std::endl;
   edm::Service<DQMStore> dstore;
   m_run = iLumi.id().run();
   m_lumi = iLumi.id().value();
   m_beginTime = iLumi.beginTime().value();
   m_endTime = iLumi.endTime().value();
   bool shouldWrite = (m_filterOnRun == 0 || (m_filterOnRun != 0 && m_filterOnRun == m_run));
 
   if (!shouldWrite)
     return;
   std::vector<MonitorElement*> items(dstore->getAllContents("", m_run, m_lumi));
   for (std::vector<MonitorElement*>::iterator it = items.begin(), itEnd = items.end(); it != itEnd; ++it) {
     assert((*it)->getScope() == MonitorElementData::Scope::LUMI);
     std::map<unsigned int, unsigned int>::iterator itFound = m_dqmKindToTypeIndex.find((int)(*it)->kind());
     assert(itFound != m_dqmKindToTypeIndex.end());
     m_treeHelpers[itFound->second]->fill(*it);
   }
 
   const edm::ProcessHistoryID& id = iLumi.processHistoryID();
   std::vector<edm::ProcessHistoryID>::iterator itFind = std::find(m_seenHistories.begin(), m_seenHistories.end(), id);
   if (itFind == m_seenHistories.end()) {
     m_processHistoryRegistry.registerProcessHistory(iLumi.processHistory());
     m_presentHistoryIndex = m_seenHistories.size();
     m_seenHistories.push_back(id);
   } else {
     m_presentHistoryIndex = itFind - m_seenHistories.begin();
   }
 
   //Now store the relationship between run/lumi and indices in the other TTrees
   bool storedLumiIndex = false;
   unsigned int typeIndex = 0;
   for (std::vector<std::shared_ptr<TreeHelperBase> >::iterator it = m_treeHelpers.begin(), itEnd = m_treeHelpers.end();
        it != itEnd;
        ++it, ++typeIndex) {
     if ((*it)->wasFilled()) {
       m_type = typeIndex;
       (*it)->getRangeAndReset(m_firstIndex, m_lastIndex);
       storedLumiIndex = true;
       tbb::this_task_arena::isolate([&] { m_indicesTree->Fill(); });
     }
   }
   if (not storedLumiIndex) {
     //need to record lumis even if we stored no MonitorElements since some later DQM modules
     // look to see what lumis were processed
     m_type = kNoTypesStored;
     m_firstIndex = 0;
     m_lastIndex = 0;
     tbb::this_task_arena::isolate([&] { m_indicesTree->Fill(); });
   }
 
   edm::Service<edm::JobReport> jr;
   jr->reportLumiSection(m_jrToken, m_run, m_lumi);
 }

◆ writeRun()

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

overrideprivatevirtual

Implements edm::core::OutputModuleCore.

Definition at line 462 of file DQMRootOutputModule.cc.

References cms::cuda::assert(), edm::RunForOutput::beginTime(), edm::RunForOutput::endTime(), spr::find(), dqm::implementation::IGetter::getAllContents(), edm::RunForOutput::id(), l1ctLayer2EG_cff::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.

                                                               {
   //std::cout << "DQMRootOutputModule::writeRun"<< std::endl;
   edm::Service<DQMStore> dstore;
   m_run = iRun.id().run();
   m_lumi = 0;
   m_beginTime = iRun.beginTime().value();
   m_endTime = iRun.endTime().value();
   bool shouldWrite = (m_filterOnRun == 0 || (m_filterOnRun != 0 && m_filterOnRun == m_run));
 
   if (!shouldWrite)
     return;
 
   std::vector<MonitorElement*> items(dstore->getAllContents("", m_run, 0));
   for (std::vector<MonitorElement*>::iterator it = items.begin(), itEnd = items.end(); it != itEnd; ++it) {
     assert((*it)->getScope() == MonitorElementData::Scope::RUN);
     std::map<unsigned int, unsigned int>::iterator itFound = m_dqmKindToTypeIndex.find((int)(*it)->kind());
     assert(itFound != m_dqmKindToTypeIndex.end());
     m_treeHelpers[itFound->second]->fill(*it);
   }
 
   const edm::ProcessHistoryID& id = iRun.processHistoryID();
   std::vector<edm::ProcessHistoryID>::iterator itFind = std::find(m_seenHistories.begin(), m_seenHistories.end(), id);
   if (itFind == m_seenHistories.end()) {
     m_processHistoryRegistry.registerProcessHistory(iRun.processHistory());
     m_presentHistoryIndex = m_seenHistories.size();
     m_seenHistories.push_back(id);
   } else {
     m_presentHistoryIndex = itFind - m_seenHistories.begin();
   }
 
   //Now store the relationship between run/lumi and indices in the other TTrees
   unsigned int typeIndex = 0;
   for (std::vector<std::shared_ptr<TreeHelperBase> >::iterator it = m_treeHelpers.begin(), itEnd = m_treeHelpers.end();
        it != itEnd;
        ++it, ++typeIndex) {
     if ((*it)->wasFilled()) {
       m_type = typeIndex;
       (*it)->getRangeAndReset(m_firstIndex, m_lastIndex);
       tbb::this_task_arena::isolate([&] { m_indicesTree->Fill(); });
     }
   }
 
   edm::Service<edm::JobReport> jr;
   jr->reportRunNumber(m_jrToken, m_run);
 }

Member Data Documentation

◆ m_beginTime

ULong64_t DQMRootOutputModule::m_beginTime

private

Definition at line 227 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 235 of file DQMRootOutputModule.cc.

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

◆ m_endTime

ULong64_t DQMRootOutputModule::m_endTime

private

Definition at line 228 of file DQMRootOutputModule.cc.

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

◆ m_file

std::unique_ptr<TFile> DQMRootOutputModule::m_file

private

Definition at line 220 of file DQMRootOutputModule.cc.

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

◆ m_fileName

std::string DQMRootOutputModule::m_fileName

private

Definition at line 218 of file DQMRootOutputModule.cc.

Referenced by openFile().

◆ m_filterOnRun

unsigned int DQMRootOutputModule::m_filterOnRun

private

Definition at line 231 of file DQMRootOutputModule.cc.

Referenced by writeLuminosityBlock(), and writeRun().

◆ m_firstIndex

ULong64_t DQMRootOutputModule::m_firstIndex

private

Definition at line 229 of file DQMRootOutputModule.cc.

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

◆ m_fullNameBuffer

std::string DQMRootOutputModule::m_fullNameBuffer

private

Definition at line 233 of file DQMRootOutputModule.cc.

◆ m_fullNameBufferPtr

std::string* DQMRootOutputModule::m_fullNameBufferPtr

private

Definition at line 234 of file DQMRootOutputModule.cc.

Referenced by openFile().

◆ m_getterOfProductsLumi

edm::GetterOfProducts<DQMToken> DQMRootOutputModule::m_getterOfProductsLumi

private

Definition at line 242 of file DQMRootOutputModule.cc.

Referenced by DQMRootOutputModule().

◆ m_getterOfProductsRun

edm::GetterOfProducts<DQMToken> DQMRootOutputModule::m_getterOfProductsRun

private

Definition at line 243 of file DQMRootOutputModule.cc.

Referenced by DQMRootOutputModule().

◆ m_indicesTree

TTree* DQMRootOutputModule::m_indicesTree

private

Definition at line 236 of file DQMRootOutputModule.cc.

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

◆ m_jrToken

edm::JobReport::Token DQMRootOutputModule::m_jrToken

private

Definition at line 240 of file DQMRootOutputModule.cc.

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

◆ m_lastIndex

ULong64_t DQMRootOutputModule::m_lastIndex

private

Definition at line 230 of file DQMRootOutputModule.cc.

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

◆ m_logicalFileName

std::string DQMRootOutputModule::m_logicalFileName

private

Definition at line 219 of file DQMRootOutputModule.cc.

Referenced by openFile().

◆ m_lumi

unsigned int DQMRootOutputModule::m_lumi

private

Definition at line 224 of file DQMRootOutputModule.cc.

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

◆ m_presentHistoryIndex

unsigned int DQMRootOutputModule::m_presentHistoryIndex

private

Definition at line 226 of file DQMRootOutputModule.cc.

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

◆ m_processHistoryRegistry

edm::ProcessHistoryRegistry DQMRootOutputModule::m_processHistoryRegistry

private

Definition at line 239 of file DQMRootOutputModule.cc.

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

◆ m_run

unsigned int DQMRootOutputModule::m_run

private

Definition at line 223 of file DQMRootOutputModule.cc.

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

◆ m_seenHistories

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

private

Definition at line 238 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 221 of file DQMRootOutputModule.cc.

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

◆ m_type

unsigned int DQMRootOutputModule::m_type

private

Definition at line 225 of file DQMRootOutputModule.cc.

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

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ DQMRootOutputModule()

◆ ~DQMRootOutputModule()

Member Function Documentation

◆ beginJob()

◆ fillDescriptions()

◆ finishEndFile()

◆ isFileOpen()

◆ openFile()

◆ reallyCloseFile()

◆ startEndFile()

◆ write()

◆ writeLuminosityBlock()

◆ writeRun()

Member Data Documentation

◆ m_beginTime

◆ m_dqmKindToTypeIndex

◆ m_endTime

◆ m_file

◆ m_fileName

◆ m_filterOnRun

◆ m_firstIndex

◆ m_fullNameBuffer

◆ m_fullNameBufferPtr

◆ m_getterOfProductsLumi

◆ m_getterOfProductsRun

◆ m_indicesTree

◆ m_jrToken

◆ m_lastIndex

◆ m_logicalFileName

◆ m_lumi

◆ m_presentHistoryIndex

◆ m_processHistoryRegistry

◆ m_run

◆ m_seenHistories

◆ m_treeHelpers

◆ m_type