#include <PoolSource.h>
Public Member Functions | |
bool | bypassVersionCheck () const |
bool | dropDescendants () const |
bool | labelRawDataLikeMC () const |
unsigned int | nStreams () const |
PoolSource (ParameterSet const &pset, InputSourceDescription const &desc) | |
ProductSelectorRules const & | productSelectorRules () const |
RunHelperBase * | runHelper () |
bool | skipBadFiles () const |
int | treeMaxVirtualSize () const |
~PoolSource () override | |
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... | |
virtual void | doBeginLumi (LuminosityBlockPrincipal &lbp, ProcessContext const *) |
Called by framework at beginning of lumi block. More... | |
virtual void | doBeginRun (RunPrincipal &rp, ProcessContext const *) |
Called by framework at beginning of run. More... | |
void | doEndJob () |
Called by framework at end of job. 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... | |
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 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... | |
std::shared_ptr< ProductRegistry > & | productRegistry () |
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::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... | |
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 |
virtual void | registerProducts () |
Register any produced products. More... | |
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 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... | |
Static Public Member Functions | |
static void | fillDescriptions (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 &) |
Protected Member Functions | |
ItemType | getNextItemType () override |
void | readEvent_ (EventPrincipal &eventPrincipal) override |
void | readLuminosityBlock_ (LuminosityBlockPrincipal &lumiPrincipal) override |
std::shared_ptr< LuminosityBlockAuxiliary > | readLuminosityBlockAuxiliary_ () override |
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... | |
ItemType | state () const |
Private Member Functions | |
void | closeFile_ () override |
void | endJob () override |
ProcessingController::ForwardState | forwardState_ () const override |
bool | goToEvent_ (EventID const &eventID) override |
bool | randomAccess_ () const override |
std::unique_ptr< FileBlock > | readFile_ () override |
bool | readIt (EventID const &id, EventPrincipal &eventPrincipal, StreamContext &streamContext) override |
void | readRun_ (RunPrincipal &runPrincipal) override |
std::shared_ptr< RunAuxiliary > | readRunAuxiliary_ () override |
std::pair< SharedResourcesAcquirer *, std::recursive_mutex * > | resourceSharedWithDelayedReader_ () override |
ProcessingController::ReverseState | reverseState_ () const override |
void | rewind_ () override |
void | skip (int offset) override |
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 Attributes inherited from edm::InputSource | |
signalslot::Signal< void(StreamContext const &, ModuleCallingContext const &)> | postEventReadFromSourceSignal_ |
signalslot::Signal< void(StreamContext const &, ModuleCallingContext const &)> | preEventReadFromSourceSignal_ |
Definition at line 32 of file PoolSource.h.
|
explicit |
Definition at line 65 of file PoolSource.cc.
References branchIDsToReplace_, edm::errors::Configuration, edm::SharedResourcesRegistry::createAcquirerForSourceDelayedReader(), edm::InputFileCatalog::empty(), relativeConstraints::empty, Exception, edm::ParameterSet::getUntrackedParameter(), mps_fire::i, edm::InEvent, edm::InLumi, edm::InRun, edm::SharedResourcesRegistry::instance(), eostools::move(), mutexSharedWithDelayedReader_, nStreams_, edm::NumBranchTypes, primaryFileSequence_, edm::InputSource::processConfiguration(), edm::ProductRegistry::productListUpdator(), edm::InputSource::productRegistryUpdate(), mps_fire::resources, resourceSharedWithDelayedReaderPtr_, secondaryCatalog_, secondaryEventPrincipals_, secondaryFileSequence_, and findQualityFiles::size.
|
override |
Definition at line 148 of file PoolSource.cc.
|
inline |
Definition at line 42 of file PoolSource.h.
References bypassVersionCheck_.
Referenced by edm::RootSecondaryFileSequence::makeRootFile(), and edm::RootPrimaryFileSequence::makeRootFile().
|
overrideprivatevirtual |
Reimplemented from edm::InputSource.
Definition at line 165 of file PoolSource.cc.
References primaryFileSequence_.
Referenced by runHelper().
|
inline |
Definition at line 41 of file PoolSource.h.
References dropDescendants_.
Referenced by edm::RootSecondaryFileSequence::makeRootFile(), and edm::RootPrimaryFileSequence::makeRootFile().
|
overrideprivatevirtual |
Reimplemented from edm::InputSource.
Definition at line 150 of file PoolSource.cc.
References primaryFileSequence_, edm::InputFile::reportReadBranches(), and secondaryFileSequence_.
Referenced by runHelper().
|
static |
Definition at line 276 of file PoolSource.cc.
References edm::ConfigurationDescriptions::add(), edm::ParameterSetDescription::addUntracked(), edm::RunHelperBase::fillDescription(), edm::ProductSelectorRules::fillDescription(), edm::RootPrimaryFileSequence::fillDescription(), edm::InputSource::fillDescription(), edm::ParameterSetDescription::setComment(), and AlCaHLTBitMon_QueryRunRegistry::string.
Referenced by runHelper().
|
overrideprivatevirtual |
Reimplemented from edm::InputSource.
Definition at line 315 of file PoolSource.cc.
References primaryFileSequence_.
Referenced by runHelper().
|
overrideprotectedvirtual |
Implements edm::InputSource.
Definition at line 249 of file PoolSource.cc.
References edm::IndexIntoFile::invalidEvent, edm::IndexIntoFile::invalidLumi, edm::IndexIntoFile::invalidRun, edm::InputSource::IsEvent, edm::InputSource::IsLumi, edm::InputSource::IsRun, edm::InputSource::IsSynchronize, primaryFileSequence_, edm::InputSource::run(), runHelper_, secondaryFileSequence_, and edm::InputSource::state().
Referenced by edm::OneLumiPoolSource::getNextItemType(), and runHelper().
|
overrideprivatevirtual |
Reimplemented from edm::InputSource.
Definition at line 274 of file PoolSource.cc.
References primaryFileSequence_.
Referenced by runHelper().
|
inline |
Definition at line 43 of file PoolSource.h.
References labelRawDataLikeMC_.
Referenced by edm::RootSecondaryFileSequence::makeRootFile(), and edm::RootPrimaryFileSequence::makeRootFile().
|
inline |
Definition at line 44 of file PoolSource.h.
References nStreams_.
Referenced by edm::RootSecondaryFileSequence::makeRootFile(), and edm::RootPrimaryFileSequence::makeRootFile().
|
inline |
Definition at line 46 of file PoolSource.h.
References productSelectorRules_.
Referenced by edm::RootSecondaryFileSequence::makeRootFile(), and edm::RootPrimaryFileSequence::makeRootFile().
|
overrideprivatevirtual |
Reimplemented from edm::InputSource.
Definition at line 313 of file PoolSource.cc.
Referenced by runHelper().
|
overrideprotectedvirtual |
Implements edm::InputSource.
Definition at line 217 of file PoolSource.cc.
References branchIDsToReplace_, edm::EventPrincipal::clearEventPrincipal(), delayReadingEventProducts_, relativeConstraints::empty, edm::EventID::event(), Exception, runEdmFileComparison::found, edm::EventPrincipal::id(), edm::InEvent, edm::EventPrincipal::luminosityBlock(), edm::EventPrincipal::mergeProvenanceRetrievers(), edm::errors::MismatchedInputFiles, primaryFileSequence_, edm::Principal::readAllFromSourceAndMergeImmediately(), edm::Principal::recombine(), edm::EventPrincipal::run(), secondaryEventPrincipals_, secondaryFileSequence_, edm::EventPrincipal::streamID(), and edm::StreamID::value().
Referenced by edm::OneLumiPoolSource::readEvent_(), readIt(), and runHelper().
|
overrideprivatevirtual |
Reimplemented from edm::InputSource.
Definition at line 157 of file PoolSource.cc.
References benchmark_cfg::fb, edm::FileBlock::HasSecondaryFileSequence, primaryFileSequence_, and secondaryFileSequence_.
Referenced by runHelper().
|
overrideprivatevirtual |
Reimplemented from edm::InputSource.
Definition at line 240 of file PoolSource.cc.
References event(), runEdmFileComparison::found, edm::InputSource::luminosityBlock(), primaryFileSequence_, readEvent_(), and edm::InputSource::run().
Referenced by runHelper().
|
overrideprotectedvirtual |
Reimplemented from edm::InputSource.
Definition at line 195 of file PoolSource.cc.
References edm::LuminosityBlockPrincipal::aux(), branchIDsToReplace_, relativeConstraints::empty, Exception, runEdmFileComparison::found, edm::LuminosityBlockPrincipal::index(), edm::InLumi, edm::LuminosityBlockPrincipal::luminosityBlock(), edm::errors::MismatchedInputFiles, primaryFileSequence_, edm::InputSource::processConfiguration(), edm::Principal::recombine(), edm::LuminosityBlockPrincipal::run(), secondaryFileSequence_, secondaryLumiPrincipal_, and mitigatedMETSequence_cff::U.
Referenced by edm::OneLumiPoolSource::getNextItemType(), and runHelper().
|
overrideprotectedvirtual |
Implements edm::InputSource.
Definition at line 169 of file PoolSource.cc.
References primaryFileSequence_.
Referenced by edm::OneLumiPoolSource::readLuminosityBlockAuxiliary_(), and runHelper().
|
overrideprivatevirtual |
Reimplemented from edm::InputSource.
Definition at line 173 of file PoolSource.cc.
References edm::RunPrincipal::aux(), branchIDsToReplace_, relativeConstraints::empty, Exception, runEdmFileComparison::found, edm::RunPrincipal::index(), edm::InRun, edm::errors::MismatchedInputFiles, primaryFileSequence_, edm::InputSource::processConfiguration(), edm::Principal::recombine(), edm::RunPrincipal::run(), secondaryFileSequence_, secondaryRunPrincipal_, and mitigatedMETSequence_cff::U.
Referenced by runHelper().
|
overrideprivatevirtual |
Implements edm::InputSource.
Definition at line 167 of file PoolSource.cc.
References primaryFileSequence_.
Referenced by runHelper().
|
overrideprivatevirtual |
Reimplemented from edm::InputSource.
Definition at line 264 of file PoolSource.cc.
References mutexSharedWithDelayedReader_, and resourceSharedWithDelayedReaderPtr_.
Referenced by runHelper().
|
overrideprivatevirtual |
Reimplemented from edm::InputSource.
Definition at line 317 of file PoolSource.cc.
References primaryFileSequence_.
Referenced by runHelper().
|
overrideprivatevirtual |
Reimplemented from edm::InputSource.
Definition at line 269 of file PoolSource.cc.
References primaryFileSequence_.
Referenced by runHelper().
|
inline |
Definition at line 47 of file PoolSource.h.
References closeFile_(), endJob(), fillDescriptions(), forwardState_(), getNextItemType(), goToEvent_(), PFRecoTauDiscriminationByIsolation_cfi::offset, randomAccess_(), readEvent_(), readFile_(), readIt(), readLuminosityBlock_(), readLuminosityBlockAuxiliary_(), readRun_(), readRunAuxiliary_(), resourceSharedWithDelayedReader_(), reverseState_(), rewind_(), runHelper_, and skip().
Referenced by edm::RootSecondaryFileSequence::makeRootFile(), and edm::RootPrimaryFileSequence::makeRootFile().
|
overrideprivatevirtual |
Reimplemented from edm::InputSource.
Definition at line 272 of file PoolSource.cc.
References primaryFileSequence_.
Referenced by runHelper().
|
inline |
Definition at line 40 of file PoolSource.h.
References skipBadFiles_.
Referenced by edm::RootPrimaryFileSequence::nextFile(), edm::RootPrimaryFileSequence::readFile_(), edm::RootPrimaryFileSequence::RootPrimaryFileSequence(), and edm::RootSecondaryFileSequence::RootSecondaryFileSequence().
|
inline |
Definition at line 45 of file PoolSource.h.
References treeMaxVirtualSize_.
Referenced by edm::RootSecondaryFileSequence::makeRootFile(), and edm::RootPrimaryFileSequence::makeRootFile().
|
private |
Definition at line 79 of file PoolSource.h.
Referenced by PoolSource(), readEvent_(), readLuminosityBlock_(), and readRun_().
|
private |
Definition at line 83 of file PoolSource.h.
Referenced by bypassVersionCheck().
|
private |
Definition at line 74 of file PoolSource.h.
|
private |
Definition at line 88 of file PoolSource.h.
Referenced by readEvent_().
|
private |
Definition at line 86 of file PoolSource.h.
Referenced by dropDescendants().
|
private |
Definition at line 87 of file PoolSource.h.
Referenced by labelRawDataLikeMC().
|
private |
Definition at line 93 of file PoolSource.h.
Referenced by PoolSource(), and resourceSharedWithDelayedReader_().
|
private |
Definition at line 81 of file PoolSource.h.
Referenced by nStreams(), and PoolSource().
|
private |
Definition at line 94 of file PoolSource.h.
Referenced by closeFile_(), endJob(), forwardState_(), getNextItemType(), goToEvent_(), PoolSource(), readEvent_(), readFile_(), readIt(), readLuminosityBlock_(), readLuminosityBlockAuxiliary_(), readRun_(), readRunAuxiliary_(), reverseState_(), rewind_(), and skip().
|
private |
Definition at line 85 of file PoolSource.h.
Referenced by productSelectorRules().
|
private |
Definition at line 92 of file PoolSource.h.
Referenced by PoolSource(), and resourceSharedWithDelayedReader_().
|
private |
Definition at line 73 of file PoolSource.h.
|
private |
Definition at line 90 of file PoolSource.h.
Referenced by getNextItemType(), and runHelper().
|
private |
Definition at line 75 of file PoolSource.h.
Referenced by PoolSource().
|
private |
Definition at line 78 of file PoolSource.h.
Referenced by PoolSource(), and readEvent_().
|
private |
Definition at line 95 of file PoolSource.h.
Referenced by endJob(), getNextItemType(), PoolSource(), readEvent_(), readFile_(), readLuminosityBlock_(), and readRun_().
|
private |
Definition at line 77 of file PoolSource.h.
Referenced by readLuminosityBlock_().
|
private |
Definition at line 76 of file PoolSource.h.
Referenced by readRun_().
|
private |
Definition at line 82 of file PoolSource.h.
Referenced by skipBadFiles().
|
private |
Definition at line 84 of file PoolSource.h.
Referenced by treeMaxVirtualSize().