Inheritance diagram for DQMRootSource:

Classes
struct	OpenFileInfo

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

	DQMRootSource (const DQMRootSource &)=delete

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

	~DQMRootSource () override

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

bool	hasAbilityToProduceInBeginRuns () const final

PuttableSourceBase &	operator= (const PuttableSourceBase &)=delete

	PuttableSourceBase (ParameterSet const &, InputSourceDescription const &)

	PuttableSourceBase (const PuttableSourceBase &)=delete

void	registerProducts (ProducerBase , ProductRegistry , ModuleDescription const &)

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

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 const >	branchIDListHelper () const
	Accessors for branchIDListHelper. More...

std::shared_ptr< BranchIDListHelper > &	branchIDListHelper ()

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...

void	fillProcessBlockHelper ()
	Fill the ProcessBlockHelper with info for the current file. More...

ProcessingController::ForwardState	forwardState () const

bool	goToEvent (EventID const &eventID)

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

	InputSource (InputSource const &)=delete

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...

bool	nextProcessBlock (ProcessBlockPrincipal &)
	Next process block, return false if there is none, sets the processName in the principal. More...

InputSource &	operator= (InputSource const &)=delete

std::shared_ptr< ProcessBlockHelper const >	processBlockHelper () const
	Accessors for processBlockHelper. More...

std::shared_ptr< ProcessBlockHelper > &	processBlockHelper ()

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

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

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

ProcessHistoryRegistry &	processHistoryRegistry ()

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

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...

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

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

std::shared_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...

void	readProcessBlock (ProcessBlockPrincipal &)
	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)

void	switchTo (std::shared_ptr< ProductRegistry > iOther)
	switch to a different ProductRegistry. More...

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

std::shared_ptr< ThinnedAssociationsHelper > &	thinnedAssociationsHelper ()

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

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

void	readElements ()

void	readEvent_ (edm::EventPrincipal &) override

std::shared_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< OpenFileInfo >	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
template<typename T >
using	BranchAliasSetterT = ProductRegistryHelper::BranchAliasSetterT< T >

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<Transition Tr = Transition::Event>
auto	produces (std::string instanceName) noexcept
	declare what type of product will make and with which optional label More...

template<Transition B>
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)

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

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

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

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

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

template<Transition Tr = Transition::Event>
auto	produces () noexcept

ProducesCollector	producesCollector ()

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

typedef dqm::harvesting::MonitorElement	MonitorElement

Detailed Description

Definition at line 317 of file DQMRootSource.cc.

Constructor & Destructor Documentation

◆ DQMRootSource() [1/2]

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

Definition at line 430 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<OpenFileInfo>()),
       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[kTH1IIndex].reset(new TreeObjectReader<TH1I>(MonitorElementData::Kind::TH1I, 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[kTH2IIndex].reset(new TreeObjectReader<TH2I>(MonitorElementData::Kind::TH2I, 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() [2/2]

DQMRootSource::DQMRootSource ( const DQMRootSource & )

delete

◆ ~DQMRootSource()

DQMRootSource::~DQMRootSource ( )

override

Definition at line 474 of file DQMRootSource.cc.

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

                               {
   for (auto& file : m_openFiles) {
     if (file.m_file && file.m_file->IsOpen()) {
       logFileAction("Closed file", "");
     }
   }
 }

Member Function Documentation

◆ beginLuminosityBlock()

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

overrideprivatevirtual

Reimplemented from edm::PuttableSourceBase.

Definition at line 752 of file DQMRootSource.cc.

References eostools::move().

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

◆ beginRun()

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

overrideprivatevirtual

Reimplemented from edm::PuttableSourceBase.

Definition at line 747 of file DQMRootSource.cc.

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

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

◆ fillDescriptions()

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

static

Definition at line 407 of file DQMRootSource.cc.

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

                                                                                {
   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);
 }

◆ getNextItemType()

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

overrideprivatevirtual

Implements edm::InputSource.

Definition at line 486 of file DQMRootSource.cc.

References m_nextItemType.

486 { return m_nextItemType; }

DQMRootSource::m_nextItemType

edm::InputSource::ItemType m_nextItemType

Definition: DQMRootSource.cc:372

◆ isRunOrLumiTransition()

bool DQMRootSource::isRunOrLumiTransition ( ) const

private

Definition at line 713 of file DQMRootSource.cc.

References m_currentIndex, m_fileMetadatas, DQMTTreeIO::FileMetadata::m_lumi, DQMTTreeIO::FileMetadata::m_run, and OccupancyTask_cfi::metadata.

Referenced by readLuminosityBlock_(), and readRun_().

                                                 {
   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;
 }

◆ keepIt()

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

private

Definition at line 757 of file DQMRootSource.cc.

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

Referenced by readFile_().

                                                                                     {
   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;
 }

◆ logFileAction()

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

private

Definition at line 778 of file DQMRootSource.cc.

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

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

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

◆ operator=()

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

delete

◆ readElements()

void DQMRootSource::readElements ( )

private

Definition at line 689 of file DQMRootSource.cc.

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

Referenced by readLuminosityBlock_(), and readRun_().

                                  {
   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();
   }
 }

◆ readEvent_()

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

overrideprivatevirtual

Implements edm::InputSource.

Definition at line 687 of file DQMRootSource.cc.

687 {}

◆ readFile_()

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

overrideprivatevirtual

Reimplemented from edm::InputSource.

Definition at line 489 of file DQMRootSource.cc.

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

                                                      {
   const int numFiles = m_catalog.fileNames(0).size();
   m_openFiles.reserve(numFiles);
 
   for (auto& fileitem : m_catalog.fileCatalogItems()) {
     TFile* file = nullptr;
     std::string pfn;
     std::string lfn;
     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 << " 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());
         pfn = *it;
         lfn = fileitem.logicalFileName();
         break;
       } else {
         if (std::next(it) == fNames.end()) {
           if (!m_skipBadFiles) {
             edm::Exception ex(edm::errors::FileOpenError);
             ex << "Input file " << *it << " 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 (!file || (!isGoodFile && m_skipBadFiles))
       continue;
 
     std::unique_ptr<std::string> guid{file->Get<std::string>(kCmsGuid)};
     if (not guid) {
       guid = std::make_unique<std::string>(file->GetUUID().AsString());
       std::transform(guid->begin(), guid->end(), guid->begin(), (int (*)(int))std::toupper);
     }
 
     edm::Service<edm::JobReport> jr;
     auto jrToken = jr->inputFileOpened(
         pfn, lfn, std::string(), std::string(), "DQMRootSource", "source", *guid, std::vector<std::string>());
     m_openFiles.emplace_back(file, jrToken);
 
     // 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] << " 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_shared<edm::FileBlock>();
 }

◆ readLuminosityBlock_()

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

overrideprivatevirtual

Reimplemented from edm::InputSource.

Definition at line 673 of file DQMRootSource.cc.

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().

                                                                              {
   // 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()));
 }

◆ readLuminosityBlockAuxiliary_()

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

overrideprivatevirtual

Implements edm::InputSource.

Definition at line 648 of file DQMRootSource.cc.

References m_currentIndex, m_fileMetadatas, and OccupancyTask_cfi::metadata.

                                                                                         {
   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);
 }

◆ readNextItemType()

void DQMRootSource::readNextItemType ( )

private

Definition at line 729 of file DQMRootSource.cc.

References edm::InputSource::IsLumi, edm::InputSource::IsRun, edm::InputSource::IsStop, m_currentIndex, m_fileMetadatas, DQMTTreeIO::FileMetadata::m_lumi, m_nextItemType, DQMTTreeIO::FileMetadata::m_run, and OccupancyTask_cfi::metadata.

Referenced by readLuminosityBlock_(), and readRun_().

                                      {
   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;
     }
   }
 }

◆ readRun_()

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

overrideprivatevirtual

Reimplemented from edm::InputSource.

Definition at line 656 of file DQMRootSource.cc.

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

                                                      {
   // 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());
 }

◆ readRunAuxiliary_()

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

overrideprivatevirtual

Implements edm::InputSource.

Definition at line 641 of file DQMRootSource.cc.

References m_currentIndex, m_fileMetadatas, and OccupancyTask_cfi::metadata.

                                                                 {
   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);
 }

Member Data Documentation

◆ m_catalog

edm::InputFileCatalog DQMRootSource::m_catalog

private

Definition at line 368 of file DQMRootSource.cc.

Referenced by readFile_().

◆ m_currentIndex

unsigned int DQMRootSource::m_currentIndex

private

Definition at line 377 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 396 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 367 of file DQMRootSource.cc.

Referenced by keepIt().

◆ m_lumisToProcess

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

private

Definition at line 369 of file DQMRootSource.cc.

Referenced by keepIt().

◆ m_nextItemType

edm::InputSource::ItemType DQMRootSource::m_nextItemType

private

Definition at line 372 of file DQMRootSource.cc.

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

◆ m_openFiles

std::vector<OpenFileInfo> DQMRootSource::m_openFiles

private

Definition at line 393 of file DQMRootSource.cc.

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

◆ m_rescope

MonitorElementData::Scope DQMRootSource::m_rescope

private

Definition at line 370 of file DQMRootSource.cc.

◆ m_skipBadFiles

bool DQMRootSource::m_skipBadFiles

private

Definition at line 366 of file DQMRootSource.cc.

Referenced by readFile_().

◆ m_treeReaders

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

private

Definition at line 374 of file DQMRootSource.cc.

Referenced by readElements().

Classes

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ DQMRootSource() [1/2]

◆ DQMRootSource() [2/2]

◆ ~DQMRootSource()

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