Inheritance diagram for DQMRootOutputModule:

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

virtual	~DQMRootOutputModule ()

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

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

SelectionsArray const &	keptProducts () const

int	maxEvents () const

	OutputModule (ParameterSet const &pset)

std::string const &	processName () const

int	remainingEvents () const

bool	selected (BranchDescription const &desc) const

void	selectProducts ()

bool	wantAllEvents () const

virtual	~OutputModule ()

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

Static Public Member Functions inherited from edm::OutputModule
static const std::string &	baseType ()

static void	fillDescription (ParameterSetDescription &desc)

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

Private Member Functions
virtual void	beginRun (edm::RunPrincipal const &r)

virtual void	finishEndFile ()

virtual void	startEndFile ()

virtual void	write (edm::EventPrincipal const &e)

virtual void	writeLuminosityBlock (edm::LuminosityBlockPrincipal const &)

virtual void	writeRun (edm::RunPrincipal const &)

Private Attributes
ULong64_t	m_beginTime

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

ULong64_t	m_endTime

std::auto_ptr< TFile >	m_file

std::string	m_fileName

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

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::OutputModule
typedef OutputModule	ModuleType

typedef OutputWorker	WorkerType

Protected Member Functions inherited from edm::OutputModule
CurrentProcessingContext const *	currentContext () const

ModuleDescription const &	description () const

void	doBeginJob ()

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

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

void	doEndJob ()

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

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

bool	doEvent (EventPrincipal const &ep, EventSetup const &c, CurrentProcessingContext const *cpc)

Trig	getTriggerResults (Event const &ep) const

Trig	getTriggerResults (EventPrincipal const &ep) const

ParameterSetID	selectorConfig () const

Detailed Description

Definition at line 174 of file DQMRootOutputModule.cc.

Constructor & Destructor Documentation

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

explicit

Definition at line 255 of file DQMRootOutputModule.cc.

                                                                    :
 edm::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_fullNameBufferPtr(&m_fullNameBuffer),
 m_indicesTree(0)
 {
   //NOTE: I need to also set the I/O performance settings
   
   m_file = std::auto_ptr<TFile>(new TFile(m_fileName.c_str(),"CREATE",
                                 "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",
                                    pset.getParameter<std::string>("@module_label"),
                                    m_file->GetUUID().AsString(),
                                    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;
 }

DQMRootOutputModule::~DQMRootOutputModule ( )

virtual

Definition at line 325 of file DQMRootOutputModule.cc.

326 {

327 }

Member Function Documentation

void DQMRootOutputModule::beginRun ( edm::RunPrincipal const & r )

privatevirtual

Reimplemented from edm::OutputModule.

Definition at line 426 of file DQMRootOutputModule.cc.

References spr::find(), m_presentHistoryIndex, m_seenHistories, and edm::Principal::processHistoryID().

                                                                     {
   //The ProcessHistory for a lumi must be the same as its Run so we only need to 
   // record it at Run time
   edm::ProcessHistoryID id = iPrincipal.processHistoryID();
   std::vector<edm::ProcessHistoryID>::iterator itFind = std::find(m_seenHistories.begin(),m_seenHistories.end(),id);
   if(itFind == m_seenHistories.end()) {
     m_presentHistoryIndex = m_seenHistories.size();
     m_seenHistories.push_back(id);
   } else {
     m_presentHistoryIndex = itFind - m_seenHistories.begin();
   }
 }

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

static

Definition at line 512 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 ( )

privatevirtual

Reimplemented from edm::OutputModule.

Definition at line 497 of file DQMRootOutputModule.cc.

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

                                         {
   m_file->Write();
   m_file->Close();
   edm::Service<edm::JobReport> jr;
   jr->outputFileClosed(m_jrToken);
 }

void DQMRootOutputModule::startEndFile ( )

privatevirtual

Reimplemented from edm::OutputModule.

Definition at line 439 of file DQMRootOutputModule.cc.

References edm::ProcessHistory::begin(), edm::detail::ThreadSafeRegistry< KEY, T, E >::begin(), edm::ProcessHistory::end(), edm::detail::ThreadSafeRegistry< KEY, T, E >::end(), edm::detail::ThreadSafeRegistry< KEY, T, E >::getMapped(), getHLTprescales::index, edm::detail::ThreadSafeRegistry< KEY, T, E >::instance(), kMetaDataDirectory, kParameterSetBranch, kParameterSetTree, kPHIndexBranch, kProcessConfigurationParameterSetIDBranch, kProcessConfigurationPassID, kProcessConfigurationProcessNameBranch, kProcessConfigurationReleaseVersion, kProcessHistoryTree, m_file, m_seenHistories, and edm::OutputModule::processName().

                                        {
   //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);
 
   edm::ProcessHistoryRegistry* phr = edm::ProcessHistoryRegistry::instance();
   assert(0!=phr);
   for(std::vector<edm::ProcessHistoryID>::iterator it = m_seenHistories.begin(), itEnd = m_seenHistories.end();
       it !=itEnd;
       ++it) {
     const edm::ProcessHistory* history = phr->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 )

privatevirtual

Implements edm::OutputModule.

Definition at line 345 of file DQMRootOutputModule.cc.

                                                    {
   
 }

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

privatevirtual

Implements edm::OutputModule.

Definition at line 349 of file DQMRootOutputModule.cc.

References edm::LuminosityBlockPrincipal::beginTime(), edm::LuminosityBlockPrincipal::endTime(), DQMStore::getAllContents(), edm::LuminosityBlockPrincipal::id(), kNoTypesStored, m_beginTime, m_dqmKindToTypeIndex, m_endTime, m_firstIndex, m_indicesTree, m_lastIndex, m_lumi, m_run, m_treeHelpers, m_type, edm::JobReport::reportLumiSection(), edm::LuminosityBlockID::run(), edm::LuminosityBlockID::value(), and edm::Timestamp::value().

                                                                                   {
   edm::Service<DQMStore> dstore;
   m_run=iLumi.id().run();
   m_lumi = iLumi.id().value();
   m_beginTime = iLumi.beginTime().value();
   m_endTime = iLumi.endTime().value();
   
   std::vector<MonitorElement *> items(dstore->getAllContents(""));
   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);
     }
   }
   //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_run,m_lumi);
 }

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

privatevirtual

Implements edm::OutputModule.

Definition at line 392 of file DQMRootOutputModule.cc.

References edm::RunPrincipal::beginTime(), edm::RunPrincipal::endTime(), DQMStore::getAllContents(), edm::RunPrincipal::id(), m_beginTime, m_dqmKindToTypeIndex, m_endTime, m_firstIndex, m_indicesTree, m_lastIndex, m_lumi, m_run, m_treeHelpers, m_type, edm::JobReport::reportRunNumber(), edm::RunID::run(), and edm::Timestamp::value().

                                                              {
   edm::Service<DQMStore> dstore;
   m_run=iRun.id().run();
   m_lumi = 0;
   m_beginTime = iRun.beginTime().value();
   m_endTime = iRun.endTime().value();
   
   std::vector<MonitorElement *> items(dstore->getAllContents(""));
   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);
     }
   }
   
   //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_run);
 }