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 &	operator= (const PuttableSourceBase &)=delete

	PuttableSourceBase (const PuttableSourceBase &)=delete

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

void	fillProcessBlockHelper ()
	Fill the ProcessBlockHelper with info for the current file. 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...

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

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

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

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::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< 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 geometryDiff::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::shared_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_shared<edm::FileBlock>();
 }

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