Inheritance diagram for DQMRootSource:

Public Member Functions
	DQMRootSource (edm::ParameterSet const &, const edm::InputSourceDescription &)

	~DQMRootSource () override

Public Member Functions inherited from edm::PuttableSourceBase
bool	hasAbilityToProduceInBeginLumis () const final

bool	hasAbilityToProduceInBeginRuns () const final

	PuttableSourceBase (ParameterSet const &, InputSourceDescription const &)

void	registerProducts () final
	Register any produced products. More...

void	registerProducts (ProducerBase , ProductRegistry , ModuleDescription const &)

void	resolvePutIndicies (BranchType iBranchType, ModuleToResolverIndicies const &iIndicies, std::string const &moduleLabel)

Public Member Functions inherited from edm::InputSource
std::shared_ptr< ActivityRegistry >	actReg () const
	Accessor for Activity Registry. More...

std::shared_ptr< BranchIDListHelper > &	branchIDListHelper ()

std::shared_ptr< BranchIDListHelper const >	branchIDListHelper () const
	Accessors for branchIDListHelper. More...

void	closeFile (FileBlock *, bool cleaningUpAfterException)
	close current file More...

void	doBeginJob ()
	Called by framework at beginning of job. More...

void	doEndJob ()
	Called by framework at end of job. More...

ProcessingController::ForwardState	forwardState () const

bool	goToEvent (EventID const &eventID)

	InputSource (InputSource const &)=delete

	InputSource (ParameterSet const &, InputSourceDescription const &)
	Constructor. More...

void	issueReports (EventID const &eventID, StreamID streamID)
	issue an event report More...

LuminosityBlockNumber_t	luminosityBlock () const
	Accessor for current luminosity block number. More...

std::shared_ptr< LuminosityBlockAuxiliary >	luminosityBlockAuxiliary () const
	Called by the framework to merge or insert lumi in principal cache. More...

int	maxEvents () const

int	maxLuminosityBlocks () const

ModuleDescription const &	moduleDescription () const
	Accessor for 'module' description. More...

ItemType	nextItemType ()
	Advances the source to the next item. More...

InputSource &	operator= (InputSource const &)=delete

ProcessConfiguration const &	processConfiguration () const
	Accessor for Process Configuration. More...

std::string const &	processGUID () const
	Accessor for global process identifier. More...

ProcessHistoryRegistry &	processHistoryRegistry ()

ProcessHistoryRegistry const &	processHistoryRegistry () const
	Accessors for process history registry. More...

ProcessingMode	processingMode () const
	RunsLumisAndEvents (default), RunsAndLumis, or Runs. More...

std::shared_ptr< ProductRegistry > &	productRegistry ()

std::shared_ptr< ProductRegistry const >	productRegistry () const
	Accessors for product registry. More...

bool	randomAccess () const

void	readAndMergeLumi (LuminosityBlockPrincipal &lbp)
	Read next luminosity block (same as a prior lumi) More...

void	readAndMergeRun (RunPrincipal &rp)
	Read next run (same as a prior run) More...

bool	readEvent (EventPrincipal &ep, EventID const &, StreamContext &)
	Read a specific event. More...

void	readEvent (EventPrincipal &ep, StreamContext &)
	Read next event. More...

std::unique_ptr< FileBlock >	readFile ()
	Read next file. More...

void	readLuminosityBlock (LuminosityBlockPrincipal &lumiPrincipal, HistoryAppender &historyAppender)
	Read next luminosity block (new lumi) More...

std::shared_ptr< LuminosityBlockAuxiliary >	readLuminosityBlockAuxiliary ()
	Read next luminosity block Auxilary. More...

bool	readProcessBlock ()
	Read next process block. More...

void	readRun (RunPrincipal &runPrincipal, HistoryAppender &historyAppender)
	Read next run (new run) More...

std::shared_ptr< RunAuxiliary >	readRunAuxiliary ()
	Read next run Auxiliary. More...

ProcessHistoryID const &	reducedProcessHistoryID () const

int	remainingEvents () const

int	remainingLuminosityBlocks () const

void	repeat ()
	Reset the remaining number of events/lumis to the maximum number. More...

std::pair< SharedResourcesAcquirer , std::recursive_mutex >	resourceSharedWithDelayedReader ()
	Returns nullptr if no resource shared between the Source and a DelayedReader. More...

ProcessingController::ReverseState	reverseState () const

void	rewind ()
	Begin again at the first event. More...

RunNumber_t	run () const
	Accessor for current run number. More...

std::shared_ptr< RunAuxiliary >	runAuxiliary () const
	Called by the framework to merge or insert run in principal cache. More...

void	setLuminosityBlockNumber_t (LuminosityBlockNumber_t lb)
	Set the luminosity block ID. More...

void	setRunNumber (RunNumber_t r)
	Set the run number. More...

void	skipEvents (int offset)

std::shared_ptr< ThinnedAssociationsHelper > &	thinnedAssociationsHelper ()

std::shared_ptr< ThinnedAssociationsHelper const >	thinnedAssociationsHelper () const
	Accessors for thinnedAssociationsHelper. More...

Timestamp const &	timestamp () const
	Accessor for the current time, as seen by the input source. More...

virtual	~InputSource () noexcept(false)
	Destructor. More...

Public Member Functions inherited from edm::ProducerBase
void	callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)

std::vector< edm::ProductResolverIndex > const &	indiciesForPutProducts (BranchType iBranchType) const

	ProducerBase ()

std::vector< edm::ProductResolverIndex > const &	putTokenIndexToProductResolverIndex () const

std::vector< bool > const &	recordProvenanceList () const

void	registerProducts (ProducerBase , ProductRegistry , ModuleDescription const &)

std::function< void(BranchDescription const &)>	registrationCallback () const
	used by the fwk to register list of products More...

void	resolvePutIndicies (BranchType iBranchType, ModuleToResolverIndicies const &iIndicies, std::string const &moduleLabel)

TypeLabelList const &	typeLabelList () const
	used by the fwk to register the list of products of this module More...

	~ProducerBase () noexcept(false) override

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

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

static void	fillDescription (ParameterSetDescription &desc)

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &)

Private Member Functions
void	beginLuminosityBlock (edm::LuminosityBlock &lumi) override

void	beginRun (edm::Run &run) override

	DQMRootSource (const DQMRootSource &)=delete

edm::InputSource::ItemType	getNextItemType () override

bool	isRunOrLumiTransition () const

bool	keepIt (edm::RunNumber_t, edm::LuminosityBlockNumber_t) const

void	logFileAction (char const msg, char const fileName) const

const DQMRootSource &	operator= (const DQMRootSource &)=delete

void	readElements ()

void	readEvent_ (edm::EventPrincipal &) override

std::unique_ptr< edm::FileBlock >	readFile_ () override

void	readLuminosityBlock_ (edm::LuminosityBlockPrincipal &lbCache) override

std::shared_ptr< edm::LuminosityBlockAuxiliary >	readLuminosityBlockAuxiliary_ () override

void	readNextItemType ()

void	readRun_ (edm::RunPrincipal &rpCache) override

std::shared_ptr< edm::RunAuxiliary >	readRunAuxiliary_ () override

Private Attributes
edm::InputFileCatalog	m_catalog

unsigned int	m_currentIndex

std::vector< FileMetadata >	m_fileMetadatas

unsigned int	m_filterOnRun

std::vector< edm::LuminosityBlockRange >	m_lumisToProcess

edm::InputSource::ItemType	m_nextItemType

std::vector< TFile * >	m_openFiles

MonitorElementData::Scope	m_rescope

bool	m_skipBadFiles

std::vector< std::shared_ptr< TreeReaderBase > >	m_treeReaders

Additional Inherited Members
Public Types inherited from edm::InputSource
enum	ItemType { IsInvalid, IsStop, IsFile, IsRun, IsLumi, IsEvent, IsRepeat, IsSynchronize }

enum	ProcessingMode { Runs, RunsAndLumis, RunsLumisAndEvents }

Public Types inherited from edm::ProducerBase
using	ModuleToResolverIndicies = std::unordered_multimap< std::string, std::tuple< edm::TypeID const , const char , edm::ProductResolverIndex > >

typedef ProductRegistryHelper::TypeLabelList	TypeLabelList

Public Attributes inherited from edm::InputSource
signalslot::Signal< void(StreamContext const &, ModuleCallingContext const &)>	postEventReadFromSourceSignal_

signalslot::Signal< void(StreamContext const &, ModuleCallingContext const &)>	preEventReadFromSourceSignal_

Protected Member Functions inherited from edm::PuttableSourceBase
void	beginJob () override
	Begin protected makes it easier to do template programming. More...

Protected Member Functions inherited from edm::InputSource
void	decreaseRemainingEventsBy (int iSkipped)

bool	eventCached () const

bool	newLumi () const

bool	newRun () const

ProcessHistoryRegistry &	processHistoryRegistryForUpdate ()

ProductRegistry &	productRegistryUpdate ()

void	reset () const

void	resetEventCached ()

void	resetLuminosityBlockAuxiliary (bool isNewLumi=true) const

void	resetNewLumi ()

void	resetNewRun ()

void	resetRunAuxiliary (bool isNewRun=true) const

void	setEventCached ()
	Called by the framework to merge or ached() const {return eventCached_;}. More...

void	setLuminosityBlockAuxiliary (LuminosityBlockAuxiliary *lbp)

void	setNewLumi ()

void	setNewRun ()

void	setRunAuxiliary (RunAuxiliary *rp)

void	setTimestamp (Timestamp const &theTime)
	To set the current time, as seen by the input source. More...

virtual void	skip (int offset)

ItemType	state () const

Protected Member Functions inherited from edm::ProducerBase
template<class ProductType >
BranchAliasSetterT< ProductType >	produces ()
	declare what type of product will make and with which optional label More...

template<typename ProductType , BranchType B>
BranchAliasSetterT< ProductType >	produces ()

template<typename ProductType , Transition B>
BranchAliasSetterT< ProductType >	produces ()

BranchAliasSetter	produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)

template<BranchType B>
BranchAliasSetter	produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)

template<Transition B>
BranchAliasSetter	produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)

template<typename ProductType , Transition B>
BranchAliasSetterT< ProductType >	produces (std::string instanceName)

template<class ProductType >
BranchAliasSetterT< ProductType >	produces (std::string instanceName)

template<typename ProductType , BranchType B>
BranchAliasSetterT< ProductType >	produces (std::string instanceName)

ProducesCollector	producesCollector ()

Private Types inherited from DQMTTreeIO
typedef dqm::harvesting::DQMStore	DQMStore

typedef dqm::harvesting::MonitorElement	MonitorElement

Detailed Description

Definition at line 311 of file DQMRootSource.cc.

Constructor & Destructor Documentation

◆ DQMRootSource() [1/2]

DQMRootSource::DQMRootSource	(	edm::ParameterSet const &	iPSet,
		const edm::InputSourceDescription &	iDesc
	)

Definition at line 410 of file DQMRootSource.cc.

     : edm::PuttableSourceBase(iPSet, iDesc),
       m_skipBadFiles(iPSet.getUntrackedParameter<bool>("skipBadFiles", false)),
       m_filterOnRun(iPSet.getUntrackedParameter<unsigned int>("filterOnRun", 0)),
       m_catalog(iPSet.getUntrackedParameter<std::vector<std::string>>("fileNames"),
                 iPSet.getUntrackedParameter<std::string>("overrideCatalog")),
       m_lumisToProcess(iPSet.getUntrackedParameter<std::vector<edm::LuminosityBlockRange>>(
           "lumisToProcess", std::vector<edm::LuminosityBlockRange>())),
       m_rescope(std::map<std::string, MonitorElementData::Scope>{
           {"", MonitorElementData::Scope::LUMI},
           {"LUMI", MonitorElementData::Scope::LUMI},
           {"RUN", MonitorElementData::Scope::RUN},
           {"JOB", MonitorElementData::Scope::JOB}}[iPSet.getUntrackedParameter<std::string>("reScope", "JOB")]),
       m_nextItemType(edm::InputSource::IsFile),
       m_treeReaders(kNIndicies, std::shared_ptr<TreeReaderBase>()),
       m_currentIndex(0),
       m_openFiles(std::vector<TFile*>()),
       m_fileMetadatas(std::vector<FileMetadata>()) {
   edm::sortAndRemoveOverlaps(m_lumisToProcess);
  
   if (m_catalog.fileNames(0).empty()) {
     m_nextItemType = edm::InputSource::IsStop;
   } else {
     m_treeReaders[kIntIndex].reset(new TreeSimpleReader<Long64_t>(MonitorElementData::Kind::INT, m_rescope));
     m_treeReaders[kFloatIndex].reset(new TreeSimpleReader<double>(MonitorElementData::Kind::REAL, m_rescope));
     m_treeReaders[kStringIndex].reset(new TreeStringReader(MonitorElementData::Kind::STRING, m_rescope));
     m_treeReaders[kTH1FIndex].reset(new TreeObjectReader<TH1F>(MonitorElementData::Kind::TH1F, m_rescope));
     m_treeReaders[kTH1SIndex].reset(new TreeObjectReader<TH1S>(MonitorElementData::Kind::TH1S, m_rescope));
     m_treeReaders[kTH1DIndex].reset(new TreeObjectReader<TH1D>(MonitorElementData::Kind::TH1D, m_rescope));
     m_treeReaders[kTH2FIndex].reset(new TreeObjectReader<TH2F>(MonitorElementData::Kind::TH2F, m_rescope));
     m_treeReaders[kTH2SIndex].reset(new TreeObjectReader<TH2S>(MonitorElementData::Kind::TH2S, m_rescope));
     m_treeReaders[kTH2DIndex].reset(new TreeObjectReader<TH2D>(MonitorElementData::Kind::TH2D, m_rescope));
     m_treeReaders[kTH3FIndex].reset(new TreeObjectReader<TH3F>(MonitorElementData::Kind::TH3F, m_rescope));
     m_treeReaders[kTProfileIndex].reset(new TreeObjectReader<TProfile>(MonitorElementData::Kind::TPROFILE, m_rescope));
     m_treeReaders[kTProfile2DIndex].reset(
         new TreeObjectReader<TProfile2D>(MonitorElementData::Kind::TPROFILE2D, m_rescope));
   }
  
   produces<DQMToken, edm::Transition::BeginRun>("DQMGenerationRecoRun");
   produces<DQMToken, edm::Transition::BeginLuminosityBlock>("DQMGenerationRecoLumi");
 }

◆ ~DQMRootSource()

DQMRootSource::~DQMRootSource ( )

override

Definition at line 452 of file DQMRootSource.cc.

                               {
   for (auto& file : m_openFiles) {
     if (file != nullptr && file->IsOpen()) {
       file->Close();
       logFileAction("Closed file", "");
     }
   }
 }

References FrontierConditions_GlobalTag_cff::file, logFileAction(), and m_openFiles.

◆ DQMRootSource() [2/2]

DQMRootSource::DQMRootSource ( const DQMRootSource & )

privatedelete

Member Function Documentation

◆ beginLuminosityBlock()

void DQMRootSource::beginLuminosityBlock ( edm::LuminosityBlock & lumi )

overrideprivatevirtual

Reimplemented from edm::PuttableSourceBase.

Definition at line 718 of file DQMRootSource.cc.

                                                                  {
   std::unique_ptr<DQMToken> product = std::make_unique<DQMToken>();
   lumi.put(std::move(product), "DQMGenerationRecoLumi");
 }

References eostools::move().

◆ beginRun()

void DQMRootSource::beginRun ( edm::Run & run )

overrideprivatevirtual

Reimplemented from edm::PuttableSourceBase.

Definition at line 713 of file DQMRootSource.cc.

                                         {
   std::unique_ptr<DQMToken> product = std::make_unique<DQMToken>();
   run.put(std::move(product), "DQMGenerationRecoRun");
 }

References eostools::move(), and edm::InputSource::run().

◆ fillDescriptions()

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

static

Definition at line 387 of file DQMRootSource.cc.

                                                                                {
   edm::ParameterSetDescription desc;
   desc.addUntracked<std::vector<std::string>>("fileNames")->setComment("Names of files to be processed.");
   desc.addUntracked<unsigned int>("filterOnRun", 0)->setComment("Just limit the process to the selected run.");
   desc.addUntracked<std::string>("reScope", "JOB")
       ->setComment(
           "Accumulate histograms more coarsely."
           " Options: \"\": keep unchanged, \"RUN\": turn LUMI histograms into RUN histograms, \"JOB\": turn everything "
           "into JOB histograms.");
   desc.addUntracked<bool>("skipBadFiles", false)->setComment("Skip the file if it is not valid");
   desc.addUntracked<std::string>("overrideCatalog", std::string())
       ->setComment("An alternate file catalog to use instead of the standard site one.");
   std::vector<edm::LuminosityBlockRange> defaultLumis;
   desc.addUntracked<std::vector<edm::LuminosityBlockRange>>("lumisToProcess", defaultLumis)
       ->setComment("Skip any lumi inside the specified run:lumi range.");
  
   descriptions.addDefault(desc);
 }

References edm::ConfigurationDescriptions::addDefault(), submitPVResolutionJobs::desc, and AlCaHLTBitMon_QueryRunRegistry::string.

◆ getNextItemType()

edm::InputSource::ItemType DQMRootSource::getNextItemType ( )

overrideprivatevirtual

Implements edm::InputSource.

Definition at line 465 of file DQMRootSource.cc.

465 { return m_nextItemType; }

References m_nextItemType.

◆ isRunOrLumiTransition()

bool DQMRootSource::isRunOrLumiTransition ( ) const

private

Definition at line 679 of file DQMRootSource.cc.

                                                 {
   if (m_currentIndex == 0) {
     return false;
   }
  
   if (m_currentIndex > m_fileMetadatas.size() - 1) {
     // We reached the end
     return true;
   }
  
   FileMetadata previousMetadata = m_fileMetadatas[m_currentIndex - 1];
   FileMetadata metadata = m_fileMetadatas[m_currentIndex];
  
   return previousMetadata.m_run != metadata.m_run || previousMetadata.m_lumi != metadata.m_lumi;
 }

References m_currentIndex, m_fileMetadatas, and TrackingMonitor_cfi::metadata.

Referenced by readLuminosityBlock_(), and readRun_().

◆ keepIt()

bool DQMRootSource::keepIt	(	edm::RunNumber_t	run,
		edm::LuminosityBlockNumber_t	lumi
	)		const

private

Definition at line 723 of file DQMRootSource.cc.

                                                                                     {
   if (m_filterOnRun != 0 && run != m_filterOnRun) {
     return false;
   }
  
   if (m_lumisToProcess.empty()) {
     return true;
   }
  
   for (edm::LuminosityBlockRange const& lumiToProcess : m_lumisToProcess) {
     if (run >= lumiToProcess.startRun() && run <= lumiToProcess.endRun()) {
       if (lumi >= lumiToProcess.startLumi() && lumi <= lumiToProcess.endLumi()) {
         return true;
       } else if (lumi == 0) {
         return true;
       }
     }
   }
   return false;
 }

References m_filterOnRun, m_lumisToProcess, and edm::InputSource::run().

Referenced by readFile_().

◆ logFileAction()

void DQMRootSource::logFileAction	(	char const *	msg,
		char const *	fileName
	)		const

private

Definition at line 744 of file DQMRootSource.cc.

                                                                              {
   edm::LogAbsolute("fileAction") << std::setprecision(0) << edm::TimeOfDay() << msg << fileName;
   edm::FlushMessageLog();
 }

References MillePedeFileConverter_cfg::fileName, edm::FlushMessageLog(), and mps_check::msg.

Referenced by readFile_(), and ~DQMRootSource().

◆ operator=()

const DQMRootSource& DQMRootSource::operator= ( const DQMRootSource & )

privatedelete

◆ readElements()

void DQMRootSource::readElements ( )

private

Definition at line 655 of file DQMRootSource.cc.

                                  {
   FileMetadata metadata = m_fileMetadatas[m_currentIndex];
  
   if (metadata.m_type != kNoTypesStored) {
     std::shared_ptr<TreeReaderBase> reader = m_treeReaders[metadata.m_type];
     TTree* tree = dynamic_cast<TTree*>(metadata.m_file->Get(kTypeNames[metadata.m_type]));
     // The Reset() below screws up the tree, so we need to re-read it from file
     // before use here.
     tree->Refresh();
  
     reader->setTree(tree);
  
     ULong64_t index = metadata.m_firstIndex;
     ULong64_t endIndex = metadata.m_lastIndex + 1;
  
     for (; index != endIndex; ++index) {
       reader->read(index, edm::Service<DQMStore>().operator->(), metadata.m_run, metadata.m_lumi);
     }
     // Drop buffers in the TTree. This reduces memory consuption while the tree
     // just sits there and waits for the next block to be read.
     tree->Reset();
   }
 }

References kNoTypesStored, kTypeNames, m_currentIndex, m_fileMetadatas, m_treeReaders, TrackingMonitor_cfi::metadata, Utilities::operator, and DQM::reader.

Referenced by readLuminosityBlock_(), and readRun_().

◆ readEvent_()

void DQMRootSource::readEvent_ ( edm::EventPrincipal & )

overrideprivatevirtual

Implements edm::InputSource.

Definition at line 653 of file DQMRootSource.cc.

653 {}

◆ readFile_()

std::unique_ptr< edm::FileBlock > DQMRootSource::readFile_ ( )

overrideprivatevirtual

Reimplemented from edm::InputSource.

Definition at line 468 of file DQMRootSource.cc.

                                                      {
   const int numFiles = m_catalog.fileNames(0).size();
   m_openFiles.reserve(numFiles);
  
   for (auto& fileitem : m_catalog.fileCatalogItems()) {
     TFile* file;
     std::list<std::string> exInfo;
     //loop over names of a file, each of them corresponds to a data catalog
     bool isGoodFile(true);
     //get all names of a file, each of them corresponds to a data catalog
     const std::vector<std::string>& fNames = fileitem.fileNames();
     for (std::vector<std::string>::const_iterator it = fNames.begin(); it != fNames.end(); ++it) {
       // Try to open a file
       try {
         file = TFile::Open(it->c_str());
  
         // Exception will be trapped so we pull it out ourselves
         std::exception_ptr e = edm::threadLocalException::getException();
         if (e != std::exception_ptr()) {
           edm::threadLocalException::setException(std::exception_ptr());
           std::rethrow_exception(e);
         }
  
       } catch (cms::Exception const& e) {
         file = nullptr;                       // is there anything we need to free?
         if (std::next(it) == fNames.end()) {  //last name corresponding to the last data catalog to try
           if (!m_skipBadFiles) {
             edm::Exception ex(edm::errors::FileOpenError, "", e);
             ex.addContext("Opening DQM Root file");
             ex << "\nInput file " << it->c_str() << " was not found, could not be opened, or is corrupted.\n";
             //report previous exceptions when use other names to open file
             for (auto const& s : exInfo)
               ex.addAdditionalInfo(s);
             throw ex;
           }
           isGoodFile = false;
         }
         // save in case of error when trying next name
         for (auto const& s : e.additionalInfo())
           exInfo.push_back(s);
       }
  
       // Check if a file is usable
       if (file && !file->IsZombie()) {
         logFileAction("Successfully opened file ", it->c_str());
         break;
       } else {
         if (std::next(it) == fNames.end()) {
           if (!m_skipBadFiles) {
             edm::Exception ex(edm::errors::FileOpenError);
             ex << "Input file " << it->c_str() << " could not be opened.\n";
             ex.addContext("Opening DQM Root file");
             //report previous exceptions when use other names to open file
             for (auto const& s : exInfo)
               ex.addAdditionalInfo(s);
             throw ex;
           }
           isGoodFile = false;
         }
         if (file) {
           delete file;
           file = nullptr;
         }
       }
     }  //end loop over names of the file
  
     if (!isGoodFile && m_skipBadFiles)
       continue;
  
     m_openFiles.insert(m_openFiles.begin(), file);
  
     // Check file format version, which is encoded in the Title of the TFile
     if (strcmp(file->GetTitle(), "1") != 0) {
       edm::Exception ex(edm::errors::FileReadError);
       ex << "Input file " << fNames[0].c_str() << " does not appear to be a DQM Root file.\n";
     }
  
     // Read metadata from the file
     TTree* indicesTree = dynamic_cast<TTree*>(file->Get(kIndicesTree));
     assert(indicesTree != nullptr);
  
     FileMetadata temp;
     // Each line of metadata will be read into the coresponding fields of temp.
     indicesTree->SetBranchAddress(kRunBranch, &temp.m_run);
     indicesTree->SetBranchAddress(kLumiBranch, &temp.m_lumi);
     indicesTree->SetBranchAddress(kBeginTimeBranch, &temp.m_beginTime);
     indicesTree->SetBranchAddress(kEndTimeBranch, &temp.m_endTime);
     indicesTree->SetBranchAddress(kTypeBranch, &temp.m_type);
     indicesTree->SetBranchAddress(kFirstIndex, &temp.m_firstIndex);
     indicesTree->SetBranchAddress(kLastIndex, &temp.m_lastIndex);
  
     for (Long64_t index = 0; index != indicesTree->GetEntries(); ++index) {
       indicesTree->GetEntry(index);
       temp.m_file = file;
  
       if (keepIt(temp.m_run, temp.m_lumi)) {
         m_fileMetadatas.push_back(temp);
       }
     }
  
   }  //end loop over files
  
   // Sort to make sure runs and lumis appear in sequential order
   std::stable_sort(m_fileMetadatas.begin(), m_fileMetadatas.end());
  
   // If we have lumisections without matching runs, insert dummy runs here.
   unsigned int run = 0;
   auto toadd = std::vector<FileMetadata>();
   for (auto& metadata : m_fileMetadatas) {
     if (run < metadata.m_run && metadata.m_lumi != 0) {
       // run transition and lumi transition at the same time!
       FileMetadata dummy{};  // zero initialize
       dummy.m_run = metadata.m_run;
       dummy.m_lumi = 0;
       dummy.m_type = kNoTypesStored;
       toadd.push_back(dummy);
     }
     run = metadata.m_run;
   }
  
   if (!toadd.empty()) {
     // rather than trying to insert at the right places, just append and sort again.
     m_fileMetadatas.insert(m_fileMetadatas.end(), toadd.begin(), toadd.end());
     std::stable_sort(m_fileMetadatas.begin(), m_fileMetadatas.end());
   }
  
   //for (auto& metadata : m_fileMetadatas)
   //  metadata.describe();
  
   // Stop if there's nothing to process. Otherwise start the run.
   if (m_fileMetadatas.empty())
     m_nextItemType = edm::InputSource::IsStop;
   else
     m_nextItemType = edm::InputSource::IsRun;
  
   // We have to return something but not sure why
   return std::make_unique<edm::FileBlock>();
 }

References cms::Exception::addAdditionalInfo(), cms::Exception::addContext(), cms::cuda::assert(), MillePedeFileConverter_cfg::e, FrontierConditions_GlobalTag_cff::file, edm::InputFileCatalog::fileCatalogItems(), edm::InputFileCatalog::fileNames(), edm::errors::FileOpenError, edm::errors::FileReadError, edm::threadLocalException::getException(), edm::InputSource::IsRun, edm::InputSource::IsStop, kBeginTimeBranch, keepIt(), kEndTimeBranch, kFirstIndex, kIndicesTree, kLastIndex, kLumiBranch, kNoTypesStored, kRunBranch, kTypeBranch, logFileAction(), m_catalog, m_fileMetadatas, m_nextItemType, m_openFiles, m_skipBadFiles, TrackingMonitor_cfi::metadata, GetRecoTauVFromDQM_MC_cff::next, edm::InputSource::run(), alignCSCRings::s, edm::threadLocalException::setException(), and groupFilesInBlocks::temp.

◆ readLuminosityBlock_()

void DQMRootSource::readLuminosityBlock_ ( edm::LuminosityBlockPrincipal & lbCache )

overrideprivatevirtual

Reimplemented from edm::InputSource.

Definition at line 639 of file DQMRootSource.cc.

                                                                              {
   // Read elements of a current lumi.
   do {
     readElements();
     m_currentIndex++;
   } while (!isRunOrLumiTransition());
  
   readNextItemType();
  
   edm::Service<edm::JobReport> jr;
   jr->reportInputLumiSection(lbCache.id().run(), lbCache.id().luminosityBlock());
   lbCache.fillLuminosityBlockPrincipal(processHistoryRegistry().getMapped(lbCache.aux().processHistoryID()));
 }

References edm::LuminosityBlockPrincipal::aux(), edm::LuminosityBlockPrincipal::fillLuminosityBlockPrincipal(), edm::LuminosityBlockPrincipal::id(), isRunOrLumiTransition(), edm::LuminosityBlockID::luminosityBlock(), m_currentIndex, edm::LuminosityBlockAuxiliary::processHistoryID(), edm::InputSource::processHistoryRegistry(), readElements(), readNextItemType(), edm::JobReport::reportInputLumiSection(), and edm::LuminosityBlockID::run().

◆ readLuminosityBlockAuxiliary_()

std::shared_ptr< edm::LuminosityBlockAuxiliary > DQMRootSource::readLuminosityBlockAuxiliary_ ( )

overrideprivatevirtual

Implements edm::InputSource.

Definition at line 614 of file DQMRootSource.cc.

                                                                                         {
   FileMetadata metadata = m_fileMetadatas[m_currentIndex];
   auto lumiAux = edm::LuminosityBlockAuxiliary(edm::LuminosityBlockID(metadata.m_run, metadata.m_lumi),
                                                edm::Timestamp(metadata.m_beginTime),
                                                edm::Timestamp(metadata.m_endTime));
   return std::make_shared<edm::LuminosityBlockAuxiliary>(lumiAux);
 }

References m_currentIndex, m_fileMetadatas, and TrackingMonitor_cfi::metadata.

◆ readNextItemType()

void DQMRootSource::readNextItemType ( )

private

Definition at line 695 of file DQMRootSource.cc.

                                      {
   if (m_currentIndex == 0) {
     m_nextItemType = edm::InputSource::IsRun;
   } else if (m_currentIndex > m_fileMetadatas.size() - 1) {
     // We reached the end
     m_nextItemType = edm::InputSource::IsStop;
   } else {
     FileMetadata previousMetadata = m_fileMetadatas[m_currentIndex - 1];
     FileMetadata metadata = m_fileMetadatas[m_currentIndex];
  
     if (previousMetadata.m_run != metadata.m_run) {
       m_nextItemType = edm::InputSource::IsRun;
     } else if (previousMetadata.m_lumi != metadata.m_lumi) {
       m_nextItemType = edm::InputSource::IsLumi;
     }
   }
 }

References edm::InputSource::IsLumi, edm::InputSource::IsRun, edm::InputSource::IsStop, m_currentIndex, m_fileMetadatas, m_nextItemType, and TrackingMonitor_cfi::metadata.

Referenced by readLuminosityBlock_(), and readRun_().

◆ readRun_()

void DQMRootSource::readRun_ ( edm::RunPrincipal & rpCache )

overrideprivatevirtual

Reimplemented from edm::InputSource.

Definition at line 622 of file DQMRootSource.cc.

                                                      {
   // Read elements of a current run.
   do {
     FileMetadata metadata = m_fileMetadatas[m_currentIndex];
     if (metadata.m_lumi == 0) {
       readElements();
     }
     m_currentIndex++;
   } while (!isRunOrLumiTransition());
  
   readNextItemType();
  
   edm::Service<edm::JobReport> jr;
   jr->reportInputRunNumber(rpCache.id().run());
   rpCache.fillRunPrincipal(processHistoryRegistryForUpdate());
 }

References edm::RunPrincipal::fillRunPrincipal(), edm::RunPrincipal::id(), isRunOrLumiTransition(), m_currentIndex, m_fileMetadatas, TrackingMonitor_cfi::metadata, edm::InputSource::processHistoryRegistryForUpdate(), readElements(), readNextItemType(), edm::JobReport::reportInputRunNumber(), and edm::RunID::run().

◆ readRunAuxiliary_()

std::shared_ptr< edm::RunAuxiliary > DQMRootSource::readRunAuxiliary_ ( )

overrideprivatevirtual

Implements edm::InputSource.

Definition at line 607 of file DQMRootSource.cc.

                                                                 {
   FileMetadata metadata = m_fileMetadatas[m_currentIndex];
   auto runAux =
       edm::RunAuxiliary(metadata.m_run, edm::Timestamp(metadata.m_beginTime), edm::Timestamp(metadata.m_endTime));
   return std::make_shared<edm::RunAuxiliary>(runAux);
 }

References m_currentIndex, m_fileMetadatas, and TrackingMonitor_cfi::metadata.

Member Data Documentation

◆ m_catalog

edm::InputFileCatalog DQMRootSource::m_catalog

private

Definition at line 363 of file DQMRootSource.cc.

Referenced by readFile_().

◆ m_currentIndex

unsigned int DQMRootSource::m_currentIndex

private

Definition at line 372 of file DQMRootSource.cc.

Referenced by isRunOrLumiTransition(), readElements(), readLuminosityBlock_(), readLuminosityBlockAuxiliary_(), readNextItemType(), readRun_(), and readRunAuxiliary_().

◆ m_fileMetadatas

std::vector<FileMetadata> DQMRootSource::m_fileMetadatas

private

Definition at line 376 of file DQMRootSource.cc.

Referenced by isRunOrLumiTransition(), readElements(), readFile_(), readLuminosityBlockAuxiliary_(), readNextItemType(), readRun_(), and readRunAuxiliary_().

◆ m_filterOnRun

unsigned int DQMRootSource::m_filterOnRun

private

Definition at line 362 of file DQMRootSource.cc.

Referenced by keepIt().

◆ m_lumisToProcess

std::vector<edm::LuminosityBlockRange> DQMRootSource::m_lumisToProcess

private

Definition at line 364 of file DQMRootSource.cc.

Referenced by keepIt().

◆ m_nextItemType

edm::InputSource::ItemType DQMRootSource::m_nextItemType

private

Definition at line 367 of file DQMRootSource.cc.

Referenced by getNextItemType(), readFile_(), and readNextItemType().

◆ m_openFiles

std::vector<TFile*> DQMRootSource::m_openFiles

private

Definition at line 374 of file DQMRootSource.cc.

Referenced by readFile_(), and ~DQMRootSource().

◆ m_rescope

MonitorElementData::Scope DQMRootSource::m_rescope

private

Definition at line 365 of file DQMRootSource.cc.

◆ m_skipBadFiles

bool DQMRootSource::m_skipBadFiles

private

Definition at line 361 of file DQMRootSource.cc.

Referenced by readFile_().

◆ m_treeReaders

std::vector<std::shared_ptr<TreeReaderBase> > DQMRootSource::m_treeReaders

private

Definition at line 369 of file DQMRootSource.cc.

Referenced by readElements().

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ DQMRootSource() [1/2]

◆ ~DQMRootSource()

◆ DQMRootSource() [2/2]

Member Function Documentation

◆ beginLuminosityBlock()

◆ beginRun()

◆ fillDescriptions()

◆ getNextItemType()

◆ isRunOrLumiTransition()

◆ keepIt()

◆ logFileAction()

◆ operator=()

◆ readElements()

◆ readEvent_()

◆ readFile_()

◆ readLuminosityBlock_()

◆ readLuminosityBlockAuxiliary_()

◆ readNextItemType()

◆ readRun_()

◆ readRunAuxiliary_()

Member Data Documentation

◆ m_catalog

◆ m_currentIndex

◆ m_fileMetadatas

◆ m_filterOnRun

◆ m_lumisToProcess

◆ m_nextItemType

◆ m_openFiles

◆ m_rescope

◆ m_skipBadFiles

◆ m_treeReaders