Inheritance diagram for DQMRootOutputModule:

Public Member Functions
	DQMRootOutputModule (edm::ParameterSet const &pset)

virtual	~DQMRootOutputModule ()

Public Member Functions inherited from edm::one::OutputModule<>
	OutputModule (edm::ParameterSet const &iPSet)

Public Member Functions inherited from edm::one::OutputModuleBase
BranchChildren const &	branchChildren () const

BranchIDLists const *	branchIDLists () const

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

SelectedProductsForBranchType const &	keptProducts () const

int	maxEvents () const

const ModuleDescription &	moduleDescription () const

OutputModuleBase &	operator= (OutputModuleBase const &)=delete

	OutputModuleBase (ParameterSet const &pset)

	OutputModuleBase (OutputModuleBase const &)=delete

std::string const &	processName () const

int	remainingEvents () const

bool	selected (BranchDescription const &desc) const

void	selectProducts (ProductRegistry const &preg)

bool	wantAllEvents () const

virtual	~OutputModuleBase ()

Public Member Functions inherited from edm::EDConsumerBase
	EDConsumerBase ()

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

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

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

std::vector < ProductHolderIndexAndSkipBit > const &	itemsToGetFromEvent () const

void	labelsForToken (EDGetToken iToken, Labels &oLabels) const

void	modulesDependentUpon (const std::string &iProcessName, std::vector< const char * > &oModuleLabels) const

bool	registeredToConsume (ProductHolderIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, BranchType) const

void	updateLookup (BranchType iBranchType, ProductHolderIndexHelper const &)

virtual	~EDConsumerBase ()

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)

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &)

Private Member Functions
void	finishEndFile ()

virtual bool	isFileOpen () const override

virtual void	openFile (edm::FileBlock const &) override

virtual void	postForkReacquireResources (unsigned int childIndex, unsigned int numberOfChildren) override

virtual void	reallyCloseFile () override

void	startEndFile ()

virtual void	write (edm::EventPrincipal const &e, edm::ModuleCallingContext const *) override

virtual void	writeLuminosityBlock (edm::LuminosityBlockPrincipal const &, edm::ModuleCallingContext const *) override

virtual void	writeRun (edm::RunPrincipal const &, edm::ModuleCallingContext const *) override

Private Attributes
ULong64_t	m_beginTime

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

bool	m_enableMultiThread

ULong64_t	m_endTime

std::auto_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::ProcessHistoryID >	m_seenHistories

std::vector< boost::shared_ptr < TreeHelperBase > >	m_treeHelpers

unsigned int	m_type

Additional Inherited Members
Public Types inherited from edm::one::OutputModuleBase
typedef OutputModuleBase	ModuleType

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

ModuleDescription const &	description () const

void	doBeginJob ()

bool	doBeginLuminosityBlock (LuminosityBlockPrincipal const &lbp, EventSetup const &c, ModuleCallingContext const *)

bool	doBeginRun (RunPrincipal const &rp, EventSetup const &c, ModuleCallingContext const *)

void	doEndJob ()

bool	doEndLuminosityBlock (LuminosityBlockPrincipal const &lbp, EventSetup const &c, ModuleCallingContext const *)

bool	doEndRun (RunPrincipal const &rp, EventSetup const &c, ModuleCallingContext const *)

bool	doEvent (EventPrincipal const &ep, EventSetup const &c, ActivityRegistry , ModuleCallingContext const )

void	doPreallocate (PreallocationConfiguration const &)

std::map< BranchID::value_type, BranchID::value_type > const &	droppedBranchIDToKeptBranchID ()

Trig	getTriggerResults (EventPrincipal const &ep, ModuleCallingContext const *) const

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)

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

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

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

template<typename ProductType , BranchType B = InEvent>
void	consumesMany ()

void	consumesMany (const TypeToGet &id)

template<BranchType B>
void	consumesMany (const TypeToGet &id)

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

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

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

Detailed Description

Definition at line 181 of file DQMRootOutputModule.cc.

Constructor & Destructor Documentation

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

explicit

Definition at line 269 of file DQMRootOutputModule.cc.

References DQMStore::enableMultiThread_, and m_enableMultiThread.

                                                                    :
 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(0),
 m_treeHelpers(kNIndicies,boost::shared_ptr<TreeHelperBase>()),
 m_presentHistoryIndex(0),
 m_filterOnRun(pset.getUntrackedParameter<unsigned int>("filterOnRun",0)),
 m_enableMultiThread(false),
 m_fullNameBufferPtr(&m_fullNameBuffer),
 m_indicesTree(0)
 {
   edm::Service<DQMStore> dstore;  
   m_enableMultiThread = dstore->enableMultiThread_;
 }

DQMRootOutputModule::~DQMRootOutputModule ( )

virtual

Definition at line 291 of file DQMRootOutputModule.cc.

292 {

293 }

Member Function Documentation

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

static

Definition at line 597 of file DQMRootOutputModule.cc.

References edm::ConfigurationDescriptions::addDefault(), and edm::ParameterSetDescription::setUnknown().

                                                                                 {
   //The following says we do not know what parameters are allowed so do no validation
   // Please change this to state exactly what you do use, even if it is no parameters
   edm::ParameterSetDescription desc;
   desc.setUnknown();
   descriptions.addDefault(desc);
 
   //NOTE: when actually filling this in, do not forget to add a untracked PSet 'dataset'
   // which is used for bookkeeping by the DMWM
 }

void DQMRootOutputModule::finishEndFile ( )

private

Definition at line 581 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);
 }

bool DQMRootOutputModule::isFileOpen ( ) const

overrideprivatevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 311 of file DQMRootOutputModule.cc.

References m_file.

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

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

overrideprivatevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 317 of file DQMRootOutputModule.cc.

Referenced by Vispa.Main.Application.Application::_readCommandLineAttributes(), Vispa.Main.Application.Application::doubleClickOnFile(), Vispa.Main.Application.Application::openFileDialog(), and Vispa.Main.Application.Application::openRecentFileSlot().

 {
   //NOTE: I need to also set the I/O performance settings
 
   m_file = std::auto_ptr<TFile>(new TFile(m_fileName.c_str(),"RECREATE",
                                 "1" //This is the file format version number
                                 ));
 
   edm::Service<edm::JobReport> jr;
   cms::Digest branchHash;
   m_jrToken = jr->outputFileOpened(m_fileName,
                                    m_logicalFileName,
                                    std::string(),
                                    "DQMRootOutputModule",
                                    description().moduleLabel(),
                                    edm::createGlobalIdentifier(),
                                    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<boost::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 = boost::shared_ptr<TreeHelperBase>(makeHelper(i,tree,m_fullNameBufferPtr));
     tree->SetDirectory(m_file.get()); //TFile takes ownership
   }
 
   m_dqmKindToTypeIndex[MonitorElement::DQM_KIND_INT]=kIntIndex;
   m_dqmKindToTypeIndex[MonitorElement::DQM_KIND_REAL]=kFloatIndex;
   m_dqmKindToTypeIndex[MonitorElement::DQM_KIND_STRING]=kStringIndex;
   m_dqmKindToTypeIndex[MonitorElement::DQM_KIND_TH1F]=kTH1FIndex;
   m_dqmKindToTypeIndex[MonitorElement::DQM_KIND_TH1S]=kTH1SIndex;
   m_dqmKindToTypeIndex[MonitorElement::DQM_KIND_TH1D]=kTH1DIndex;
   m_dqmKindToTypeIndex[MonitorElement::DQM_KIND_TH2F]=kTH2FIndex;
   m_dqmKindToTypeIndex[MonitorElement::DQM_KIND_TH2S]=kTH2SIndex;
   m_dqmKindToTypeIndex[MonitorElement::DQM_KIND_TH2D]=kTH2DIndex;
   m_dqmKindToTypeIndex[MonitorElement::DQM_KIND_TH3F]=kTH3FIndex;
   m_dqmKindToTypeIndex[MonitorElement::DQM_KIND_TPROFILE]=kTProfileIndex;
   m_dqmKindToTypeIndex[MonitorElement::DQM_KIND_TPROFILE2D]=kTProfile2DIndex;
 }

void DQMRootOutputModule::postForkReacquireResources	(	unsigned int	childIndex,
		unsigned int	numberOfChildren
	)

overrideprivatevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 376 of file DQMRootOutputModule.cc.

References lut2db_cfg::filename, m_fileName, and cmsHarvester::path.

                                                                                                       {
   // this is copied from IOPool/Output/src/PoolOutputModule.cc, for consistency
   unsigned int digits = 0;
   while (numberOfChildren != 0) {
     ++digits;
     numberOfChildren /= 10;
   }
   // protect against zero numberOfChildren
   if (digits == 0) {
     digits = 3;
   }
 
   char buffer[digits + 2];
   snprintf(buffer, digits + 2, "_%0*d", digits, childIndex);
 
   boost::filesystem::path filename(m_fileName);
   m_fileName = (filename.parent_path() / (filename.stem().string() + buffer + filename.extension().string())).string();
 }

void DQMRootOutputModule::reallyCloseFile ( )

overrideprivatevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 518 of file DQMRootOutputModule.cc.

References finishEndFile(), and startEndFile().

                                      {
    startEndFile();
    finishEndFile();
 }

void DQMRootOutputModule::startEndFile ( )

private

Definition at line 524 of file DQMRootOutputModule.cc.

References edm::ProcessHistory::begin(), edm::pset::Registry::begin(), edm::ProcessHistory::end(), edm::pset::Registry::end(), edm::ProcessHistoryRegistry::getMapped(), cmsHarvester::index, 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().

                                        {
   //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(0!=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();
       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(0!=psr);
   for(edm::pset::Registry::const_iterator it = psr->begin(), itEnd = psr->end();
   it != itEnd;
   ++it) {
     blob.clear();
     it->second.toString(blob);
     parameterSetsTree->Fill();
   }
 
 }

void DQMRootOutputModule::write	(	edm::EventPrincipal const &	e,
		edm::ModuleCallingContext const *
	)

overrideprivatevirtual

Implements edm::one::OutputModuleBase.

Definition at line 397 of file DQMRootOutputModule.cc.

Referenced by pkg.AbstractPkg::generate().

                                                                                   {
 
 }

void DQMRootOutputModule::writeLuminosityBlock	(	edm::LuminosityBlockPrincipal const &	iLumi,
		edm::ModuleCallingContext const *
	)

overrideprivatevirtual

Implements edm::one::OutputModuleBase.

Definition at line 403 of file DQMRootOutputModule.cc.

References edm::LuminosityBlockPrincipal::beginTime(), edm::LuminosityBlockPrincipal::endTime(), spr::find(), DQMStore::getAllContents(), edm::LuminosityBlockPrincipal::id(), kNoTypesStored, m_beginTime, m_dqmKindToTypeIndex, m_enableMultiThread, 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::Principal::processHistory(), edm::Principal::processHistoryID(), edm::ProcessHistoryRegistry::registerProcessHistory(), edm::JobReport::reportLumiSection(), edm::LuminosityBlockID::run(), edm::LuminosityBlockID::value(), and edm::Timestamp::value().

                                                                           {
   //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_enableMultiThread ? m_run : 0,
                                                              m_enableMultiThread ? m_lumi : 0));
   for(std::vector<MonitorElement*>::iterator it = items.begin(), itEnd=items.end();
       it!=itEnd;
       ++it) {
     if((*it)->getLumiFlag()) {
       std::map<unsigned int,unsigned int>::iterator itFound = m_dqmKindToTypeIndex.find((*it)->kind());
       assert(itFound !=m_dqmKindToTypeIndex.end());
       m_treeHelpers[itFound->second]->fill(*it);
     }
   }
 
   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<boost::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;
       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;
     m_indicesTree->Fill();
   }
 
   edm::Service<edm::JobReport> jr;
   jr->reportLumiSection(m_jrToken, m_run, m_lumi);
 }

void DQMRootOutputModule::writeRun	(	edm::RunPrincipal const &	iRun,
		edm::ModuleCallingContext const *
	)

overrideprivatevirtual

Implements edm::one::OutputModuleBase.

Definition at line 465 of file DQMRootOutputModule.cc.

References edm::RunPrincipal::beginTime(), edm::RunPrincipal::endTime(), spr::find(), DQMStore::getAllContents(), edm::RunPrincipal::id(), m_beginTime, m_dqmKindToTypeIndex, m_enableMultiThread, 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::Principal::processHistory(), edm::Principal::processHistoryID(), edm::ProcessHistoryRegistry::registerProcessHistory(), edm::JobReport::reportRunNumber(), edm::RunID::run(), and edm::Timestamp::value().

                                                                   {
   //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_enableMultiThread ? m_run : 0));
   for(std::vector<MonitorElement*>::iterator it = items.begin(), itEnd=items.end();
       it!=itEnd;
       ++it) {
     if(not (*it)->getLumiFlag()) {
       std::map<unsigned int,unsigned int>::iterator itFound = m_dqmKindToTypeIndex.find((*it)->kind());
       assert  (itFound !=m_dqmKindToTypeIndex.end());
       m_treeHelpers[itFound->second]->fill(*it);
     }
   }
 
   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<boost::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);
       m_indicesTree->Fill();
     }
   }
 
   edm::Service<edm::JobReport> jr;
   jr->reportRunNumber(m_jrToken, m_run);
 }