CMS 3D CMS Logo

 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Pages
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

virtual void beginJob () override
 
 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
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 (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, ThinnedAssociationsHelper const &)
 
ThinnedAssociationsHelper const * thinnedAssociationsHelper () const
 
bool wantAllEvents () const
 
virtual ~OutputModuleBase ()
 
- Public Member Functions inherited from edm::EDConsumerBase
std::vector< ConsumesInfoconsumesInfo () const
 
 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 (std::string const &iProcessName, std::string const &iModuleLabel, bool iPrint, std::vector< char const * > &oModuleLabels) const
 
void modulesWhoseProductsAreConsumed (std::vector< ModuleDescription const * > &modules, ProductRegistry const &preg, std::map< std::string, ModuleDescription const * > const &labelsToDesc, std::string const &processName) 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
 
- 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 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 ()
 
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 270 of file DQMRootOutputModule.cc.

270  :
273 m_fileName(pset.getUntrackedParameter<std::string>("fileName")),
274 m_logicalFileName(pset.getUntrackedParameter<std::string>("logicalFileName","")),
275 m_file(0),
276 m_treeHelpers(kNIndicies,boost::shared_ptr<TreeHelperBase>()),
278 m_filterOnRun(pset.getUntrackedParameter<unsigned int>("filterOnRun",0)),
279 m_enableMultiThread(false),
281 m_indicesTree(0)
282 {
283 }
unsigned int m_presentHistoryIndex
std::auto_ptr< TFile > m_file
OutputModuleBase(ParameterSet const &pset)
std::vector< boost::shared_ptr< TreeHelperBase > > m_treeHelpers
std::string * m_fullNameBufferPtr
DQMRootOutputModule::~DQMRootOutputModule ( )
virtual

Definition at line 298 of file DQMRootOutputModule.cc.

299 {
300 }

Member Function Documentation

void DQMRootOutputModule::beginJob ( void  )
overridevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 291 of file DQMRootOutputModule.cc.

References DQMStore::enableMultiThread_, and m_enableMultiThread.

292 {
293  // Determine if we are running multithreading asking to the DQMStore. Not to be moved in the ctor
294  edm::Service<DQMStore> dstore;
296 }
bool enableMultiThread_
Definition: DQMStore.h:704
void DQMRootOutputModule::fillDescriptions ( edm::ConfigurationDescriptions descriptions)
static

Definition at line 604 of file DQMRootOutputModule.cc.

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

604  {
605  //The following says we do not know what parameters are allowed so do no validation
606  // Please change this to state exactly what you do use, even if it is no parameters
608  desc.setUnknown();
609  descriptions.addDefault(desc);
610 
611  //NOTE: when actually filling this in, do not forget to add a untracked PSet 'dataset'
612  // which is used for bookkeeping by the DMWM
613 }
void addDefault(ParameterSetDescription const &psetDescription)
void DQMRootOutputModule::finishEndFile ( )
private

Definition at line 588 of file DQMRootOutputModule.cc.

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

Referenced by reallyCloseFile().

588  {
589  //std::cout << "DQMRootOutputModule::finishEndFile"<< std::endl;
590  m_file->Write();
591  m_file->Close();
594 }
std::auto_ptr< TFile > m_file
void outputFileClosed(Token fileToken)
Definition: JobReport.cc:518
edm::JobReport::Token m_jrToken
bool DQMRootOutputModule::isFileOpen ( ) const
overrideprivatevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 318 of file DQMRootOutputModule.cc.

References m_file.

319 {
320  return nullptr!=m_file.get();
321 }
std::auto_ptr< TFile > m_file
void DQMRootOutputModule::openFile ( edm::FileBlock const &  )
overrideprivatevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 324 of file DQMRootOutputModule.cc.

References edm::createGlobalIdentifier(), edm::one::OutputModuleBase::description(), cms::Digest::digest(), MonitorElement::DQM_KIND_INT, MonitorElement::DQM_KIND_REAL, MonitorElement::DQM_KIND_STRING, MonitorElement::DQM_KIND_TH1D, MonitorElement::DQM_KIND_TH1F, MonitorElement::DQM_KIND_TH1S, MonitorElement::DQM_KIND_TH2D, MonitorElement::DQM_KIND_TH2F, MonitorElement::DQM_KIND_TH2S, MonitorElement::DQM_KIND_TH3F, MonitorElement::DQM_KIND_TPROFILE, MonitorElement::DQM_KIND_TPROFILE2D, i, 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(), edm::JobReport::outputFileOpened(), AlCaHLTBitMon_QueryRunRegistry::string, cms::MD5Result::toString(), and MainPageGenerator::tree.

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

325 {
326  //NOTE: I need to also set the I/O performance settings
327 
328  m_file = std::auto_ptr<TFile>(new TFile(m_fileName.c_str(),"RECREATE",
329  "1" //This is the file format version number
330  ));
331 
333  cms::Digest branchHash;
336  std::string(),
337  "DQMRootOutputModule",
338  description().moduleLabel(),
340  std::string(),
341  branchHash.digest().toString(),
342  std::vector<std::string>()
343  );
344 
345 
347  m_indicesTree->Branch(kRunBranch,&m_run);
348  m_indicesTree->Branch(kLumiBranch,&m_lumi);
352  m_indicesTree->Branch(kTypeBranch,&m_type);
355  m_indicesTree->SetDirectory(m_file.get());
356 
357  unsigned int i = 0;
358  for(std::vector<boost::shared_ptr<TreeHelperBase> >::iterator it = m_treeHelpers.begin(), itEnd = m_treeHelpers.end();
359  it != itEnd;
360  ++it,++i) {
361  //std::cout <<"making "<<kTypeNames[i]<<std::endl;
362  TTree* tree = new TTree(kTypeNames[i],kTypeNames[i]);
363  *it = boost::shared_ptr<TreeHelperBase>(makeHelper(i,tree,m_fullNameBufferPtr));
364  tree->SetDirectory(m_file.get()); //TFile takes ownership
365  }
366 
379 }
int i
Definition: DBlmapReader.cc:9
static const char *const kRunBranch
Definition: format.h:41
ModuleDescription const & description() const
static const char *const kTypeNames[]
Definition: format.h:28
static const char *const kIndicesTree
Definition: format.h:40
unsigned int m_presentHistoryIndex
static TreeHelperBase * makeHelper(unsigned int iTypeIndex, TTree *iTree, std::string *iFullNameBufferPtr)
static const char *const kFirstIndex
Definition: format.h:47
static const char *const kLumiBranch
Definition: format.h:42
MD5Result digest() const
Definition: Digest.cc:194
std::map< unsigned int, unsigned int > m_dqmKindToTypeIndex
std::auto_ptr< TFile > m_file
static const char *const kTypeBranch
Definition: format.h:46
static const char *const kProcessHistoryIndexBranch
Definition: format.h:43
Token outputFileOpened(std::string const &physicalFileName, std::string const &logicalFileName, std::string const &catalog, std::string const &outputModuleClassName, std::string const &moduleLabel, std::string const &guid, std::string const &dataType, std::string const &branchHash, std::vector< std::string > const &branchNames)
Definition: JobReport.cc:472
static const char *const kEndTimeBranch
Definition: format.h:45
std::vector< boost::shared_ptr< TreeHelperBase > > m_treeHelpers
std::string * m_fullNameBufferPtr
static const char *const kLastIndex
Definition: format.h:48
std::string toString() const
Definition: Digest.cc:87
static const char *const kBeginTimeBranch
Definition: format.h:44
edm::JobReport::Token m_jrToken
std::string createGlobalIdentifier()
void DQMRootOutputModule::postForkReacquireResources ( unsigned int  childIndex,
unsigned int  numberOfChildren 
)
overrideprivatevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 383 of file DQMRootOutputModule.cc.

References lut2db_cfg::filename, m_fileName, and fed_dqm_sourceclient-live_cfg::path.

383  {
384  // this is copied from IOPool/Output/src/PoolOutputModule.cc, for consistency
385  unsigned int digits = 0;
386  while (numberOfChildren != 0) {
387  ++digits;
388  numberOfChildren /= 10;
389  }
390  // protect against zero numberOfChildren
391  if (digits == 0) {
392  digits = 3;
393  }
394 
395  char buffer[digits + 2];
396  snprintf(buffer, digits + 2, "_%0*d", digits, childIndex);
397 
399  m_fileName = (filename.parent_path() / (filename.stem().string() + buffer + filename.extension().string())).string();
400 }
tuple filename
Definition: lut2db_cfg.py:20
void DQMRootOutputModule::reallyCloseFile ( )
overrideprivatevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 525 of file DQMRootOutputModule.cc.

References finishEndFile(), and startEndFile().

525  {
526  startEndFile();
527  finishEndFile();
528 }
void DQMRootOutputModule::startEndFile ( )
private

Definition at line 531 of file DQMRootOutputModule.cc.

References assert(), 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().

531  {
532  //std::cout << "DQMRootOutputModule::startEndFile"<< std::endl;
533  //fill in the meta data
534  m_file->cd();
535  TDirectory* metaDataDirectory = m_file->mkdir(kMetaDataDirectory);
536 
537 
538  //Write out the Process History
539  TTree* processHistoryTree = new TTree(kProcessHistoryTree,kProcessHistoryTree);
540  processHistoryTree->SetDirectory(metaDataDirectory);
541 
542  unsigned int index = 0;
543  processHistoryTree->Branch(kPHIndexBranch,&index);
545  processHistoryTree->Branch(kProcessConfigurationProcessNameBranch,&processName);
546  std::string parameterSetID;
547  processHistoryTree->Branch(kProcessConfigurationParameterSetIDBranch,&parameterSetID);
548  std::string releaseVersion;
549  processHistoryTree->Branch(kProcessConfigurationReleaseVersion,&releaseVersion);
550  std::string passID;
551  processHistoryTree->Branch(kProcessConfigurationPassID,&passID);
552 
553  for(std::vector<edm::ProcessHistoryID>::iterator it = m_seenHistories.begin(), itEnd = m_seenHistories.end();
554  it !=itEnd;
555  ++it) {
557  assert(0!=history);
558  index = 0;
559  for(edm::ProcessHistory::collection_type::const_iterator itPC = history->begin(), itPCEnd = history->end();
560  itPC != itPCEnd;
561  ++itPC,++index) {
562  processName = itPC->processName();
563  releaseVersion = itPC->releaseVersion();
564  passID = itPC->passID();
565  parameterSetID = itPC->parameterSetID().compactForm();
566  processHistoryTree->Fill();
567  }
568  }
569 
570  //Store the ParameterSets
571  TTree* parameterSetsTree = new TTree(kParameterSetTree,kParameterSetTree);
572  parameterSetsTree->SetDirectory(metaDataDirectory);
573  std::string blob;
574  parameterSetsTree->Branch(kParameterSetBranch,&blob);
575 
577  assert(0!=psr);
578  for(edm::pset::Registry::const_iterator it = psr->begin(), itEnd = psr->end();
579  it != itEnd;
580  ++it) {
581  blob.clear();
582  it->second.toString(blob);
583  parameterSetsTree->Fill();
584  }
585 
586 }
const_iterator begin() const
static const char *const kProcessHistoryTree
Definition: format.h:54
map_type::const_iterator const_iterator
Definition: Registry.h:63
bool getMapped(ProcessHistoryID const &key, ProcessHistory &value) const
const_iterator end() const
Definition: Registry.h:69
assert(m_qm.get())
edm::ProcessHistoryRegistry m_processHistoryRegistry
static const char *const kPHIndexBranch
Definition: format.h:55
static const char *const kParameterSetBranch
Definition: format.h:62
static const char *const kMetaDataDirectory
Definition: format.h:52
std::auto_ptr< TFile > m_file
static const char *const kParameterSetTree
Definition: format.h:61
const_iterator begin() const
Definition: Registry.h:65
static const char *const kProcessConfigurationPassID
Definition: format.h:59
static const char *const kProcessConfigurationReleaseVersion
Definition: format.h:58
std::string const & processName() const
static const char *const kProcessConfigurationProcessNameBranch
Definition: format.h:56
const_iterator end() const
static Registry * instance()
Definition: Registry.cc:12
static const char *const kProcessConfigurationParameterSetIDBranch
Definition: format.h:57
std::vector< edm::ProcessHistoryID > m_seenHistories
void DQMRootOutputModule::write ( edm::EventPrincipal const &  e,
edm::ModuleCallingContext const *   
)
overrideprivatevirtual

Implements edm::one::OutputModuleBase.

Definition at line 404 of file DQMRootOutputModule.cc.

Referenced by pkg.AbstractPkg::generate().

404  {
405 
406 }
void DQMRootOutputModule::writeLuminosityBlock ( edm::LuminosityBlockPrincipal const &  iLumi,
edm::ModuleCallingContext const *   
)
overrideprivatevirtual

Implements edm::one::OutputModuleBase.

Definition at line 410 of file DQMRootOutputModule.cc.

References assert(), edm::LuminosityBlockPrincipal::beginTime(), edm::LuminosityBlockPrincipal::endTime(), spr::find(), DQMStore::getAllContents(), edm::LuminosityBlockPrincipal::id(), mps_monitormerge::items, 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().

411  {
412  //std::cout << "DQMRootOutputModule::writeLuminosityBlock"<< std::endl;
413  edm::Service<DQMStore> dstore;
414  m_run = iLumi.id().run();
415  m_lumi = iLumi.id().value();
416  m_beginTime = iLumi.beginTime().value();
417  m_endTime = iLumi.endTime().value();
418  bool shouldWrite = (m_filterOnRun == 0 ||
419  (m_filterOnRun != 0 && m_filterOnRun == m_run));
420 
421  if (! shouldWrite)
422  return;
423  std::vector<MonitorElement *> items(dstore->getAllContents("",
425  m_enableMultiThread ? m_lumi : 0));
426  for(std::vector<MonitorElement*>::iterator it = items.begin(), itEnd=items.end();
427  it!=itEnd;
428  ++it) {
429  if((*it)->getLumiFlag()) {
430  std::map<unsigned int,unsigned int>::iterator itFound = m_dqmKindToTypeIndex.find((*it)->kind());
431  assert(itFound !=m_dqmKindToTypeIndex.end());
432  m_treeHelpers[itFound->second]->fill(*it);
433  }
434  }
435 
436  edm::ProcessHistoryID id = iLumi.processHistoryID();
437  std::vector<edm::ProcessHistoryID>::iterator itFind = std::find(m_seenHistories.begin(),m_seenHistories.end(),id);
438  if(itFind == m_seenHistories.end()) {
439  m_processHistoryRegistry.registerProcessHistory(iLumi.processHistory());
441  m_seenHistories.push_back(id);
442  } else {
443  m_presentHistoryIndex = itFind - m_seenHistories.begin();
444  }
445 
446  //Now store the relationship between run/lumi and indices in the other TTrees
447  bool storedLumiIndex = false;
448  unsigned int typeIndex = 0;
449  for(std::vector<boost::shared_ptr<TreeHelperBase> >::iterator it = m_treeHelpers.begin(), itEnd = m_treeHelpers.end();
450  it != itEnd;
451  ++it,++typeIndex) {
452  if((*it)->wasFilled()) {
453  m_type = typeIndex;
454  (*it)->getRangeAndReset(m_firstIndex,m_lastIndex);
455  storedLumiIndex = true;
456  m_indicesTree->Fill();
457  }
458  }
459  if(not storedLumiIndex) {
460  //need to record lumis even if we stored no MonitorElements since some later DQM modules
461  // look to see what lumis were processed
463  m_firstIndex=0;
464  m_lastIndex=0;
465  m_indicesTree->Fill();
466  }
467 
469  jr->reportLumiSection(m_jrToken, m_run, m_lumi);
470 }
assert(m_qm.get())
unsigned int m_presentHistoryIndex
bool registerProcessHistory(ProcessHistory const &processHistory)
edm::ProcessHistoryRegistry m_processHistoryRegistry
void find(edm::Handle< EcalRecHitCollection > &hits, DetId thisDet, std::vector< EcalRecHitCollection::const_iterator > &hit, bool debug=false)
Definition: FindCaloHit.cc:7
std::vector< MonitorElement * > getAllContents(const std::string &path, uint32_t runNumber=0, uint32_t lumi=0) const
Definition: DQMStore.cc:1988
std::map< unsigned int, unsigned int > m_dqmKindToTypeIndex
std::vector< boost::shared_ptr< TreeHelperBase > > m_treeHelpers
edm::JobReport::Token m_jrToken
void reportLumiSection(JobReport::Token token, unsigned int run, unsigned int lumiSectId, unsigned long nEvents=0)
Definition: JobReport.cc:544
std::vector< edm::ProcessHistoryID > m_seenHistories
void DQMRootOutputModule::writeRun ( edm::RunPrincipal const &  iRun,
edm::ModuleCallingContext const *   
)
overrideprivatevirtual

Implements edm::one::OutputModuleBase.

Definition at line 472 of file DQMRootOutputModule.cc.

References assert(), edm::RunPrincipal::beginTime(), edm::RunPrincipal::endTime(), spr::find(), DQMStore::getAllContents(), edm::RunPrincipal::id(), mps_monitormerge::items, 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().

473  {
474  //std::cout << "DQMRootOutputModule::writeRun"<< std::endl;
475  edm::Service<DQMStore> dstore;
476  m_run = iRun.id().run();
477  m_lumi = 0;
478  m_beginTime = iRun.beginTime().value();
479  m_endTime = iRun.endTime().value();
480  bool shouldWrite = (m_filterOnRun == 0 ||
481  (m_filterOnRun != 0 && m_filterOnRun == m_run));
482 
483  if (! shouldWrite)
484  return;
485 
486  std::vector<MonitorElement*> items(dstore->getAllContents("",
487  m_enableMultiThread ? m_run : 0));
488  for(std::vector<MonitorElement*>::iterator it = items.begin(), itEnd=items.end();
489  it!=itEnd;
490  ++it) {
491  if(not (*it)->getLumiFlag()) {
492  std::map<unsigned int,unsigned int>::iterator itFound = m_dqmKindToTypeIndex.find((*it)->kind());
493  assert (itFound !=m_dqmKindToTypeIndex.end());
494  m_treeHelpers[itFound->second]->fill(*it);
495  }
496  }
497 
498  edm::ProcessHistoryID id = iRun.processHistoryID();
499  std::vector<edm::ProcessHistoryID>::iterator itFind = std::find(m_seenHistories.begin(),m_seenHistories.end(),id);
500  if(itFind == m_seenHistories.end()) {
501  m_processHistoryRegistry.registerProcessHistory(iRun.processHistory());
503  m_seenHistories.push_back(id);
504  } else {
505  m_presentHistoryIndex = itFind - m_seenHistories.begin();
506  }
507 
508  //Now store the relationship between run/lumi and indices in the other TTrees
509  unsigned int typeIndex = 0;
510  for(std::vector<boost::shared_ptr<TreeHelperBase> >::iterator it = m_treeHelpers.begin(), itEnd = m_treeHelpers.end();
511  it != itEnd;
512  ++it,++typeIndex) {
513  if((*it)->wasFilled()) {
514  m_type = typeIndex;
515  (*it)->getRangeAndReset(m_firstIndex,m_lastIndex);
516  m_indicesTree->Fill();
517  }
518  }
519 
521  jr->reportRunNumber(m_jrToken, m_run);
522 }
assert(m_qm.get())
unsigned int m_presentHistoryIndex
bool registerProcessHistory(ProcessHistory const &processHistory)
edm::ProcessHistoryRegistry m_processHistoryRegistry
void reportRunNumber(JobReport::Token token, unsigned int run)
Definition: JobReport.cc:554
void find(edm::Handle< EcalRecHitCollection > &hits, DetId thisDet, std::vector< EcalRecHitCollection::const_iterator > &hit, bool debug=false)
Definition: FindCaloHit.cc:7
std::vector< MonitorElement * > getAllContents(const std::string &path, uint32_t runNumber=0, uint32_t lumi=0) const
Definition: DQMStore.cc:1988
std::map< unsigned int, unsigned int > m_dqmKindToTypeIndex
std::vector< boost::shared_ptr< TreeHelperBase > > m_treeHelpers
edm::JobReport::Token m_jrToken
std::vector< edm::ProcessHistoryID > m_seenHistories

Member Data Documentation

ULong64_t DQMRootOutputModule::m_beginTime
private

Definition at line 208 of file DQMRootOutputModule.cc.

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

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

Definition at line 217 of file DQMRootOutputModule.cc.

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

bool DQMRootOutputModule::m_enableMultiThread
private

Definition at line 213 of file DQMRootOutputModule.cc.

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

ULong64_t DQMRootOutputModule::m_endTime
private

Definition at line 209 of file DQMRootOutputModule.cc.

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

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

Definition at line 201 of file DQMRootOutputModule.cc.

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

std::string DQMRootOutputModule::m_fileName
private

Definition at line 199 of file DQMRootOutputModule.cc.

Referenced by openFile(), and postForkReacquireResources().

unsigned int DQMRootOutputModule::m_filterOnRun
private

Definition at line 212 of file DQMRootOutputModule.cc.

Referenced by writeLuminosityBlock(), and writeRun().

ULong64_t DQMRootOutputModule::m_firstIndex
private

Definition at line 210 of file DQMRootOutputModule.cc.

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

std::string DQMRootOutputModule::m_fullNameBuffer
private

Definition at line 215 of file DQMRootOutputModule.cc.

std::string* DQMRootOutputModule::m_fullNameBufferPtr
private

Definition at line 216 of file DQMRootOutputModule.cc.

Referenced by openFile().

TTree* DQMRootOutputModule::m_indicesTree
private

Definition at line 218 of file DQMRootOutputModule.cc.

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

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

Definition at line 222 of file DQMRootOutputModule.cc.

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

ULong64_t DQMRootOutputModule::m_lastIndex
private

Definition at line 211 of file DQMRootOutputModule.cc.

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

std::string DQMRootOutputModule::m_logicalFileName
private

Definition at line 200 of file DQMRootOutputModule.cc.

Referenced by openFile().

unsigned int DQMRootOutputModule::m_lumi
private

Definition at line 205 of file DQMRootOutputModule.cc.

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

unsigned int DQMRootOutputModule::m_presentHistoryIndex
private

Definition at line 207 of file DQMRootOutputModule.cc.

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

edm::ProcessHistoryRegistry DQMRootOutputModule::m_processHistoryRegistry
private

Definition at line 221 of file DQMRootOutputModule.cc.

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

unsigned int DQMRootOutputModule::m_run
private

Definition at line 204 of file DQMRootOutputModule.cc.

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

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

Definition at line 220 of file DQMRootOutputModule.cc.

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

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

Definition at line 202 of file DQMRootOutputModule.cc.

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

unsigned int DQMRootOutputModule::m_type
private

Definition at line 206 of file DQMRootOutputModule.cc.

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