|
|
|
#include <VectorInputSource.h>
Public Member Functions | |
| void | dropUnwantedBranches (std::vector< std::string > const &wantedBranches) |
| template<typename T > | |
| size_t | loopRandom (EventPrincipal &cache, size_t &fileNameHash, size_t number, T eventOperator, CLHEP::HepRandomEngine *) |
| template<typename T > | |
| size_t | loopRandomWithID (EventPrincipal &cache, size_t &fileNameHash, LuminosityBlockID const &id, size_t number, T eventOperator, CLHEP::HepRandomEngine *) |
| template<typename T > | |
| size_t | loopSequential (EventPrincipal &cache, size_t &fileNameHash, size_t number, T eventOperator) |
| template<typename T > | |
| size_t | loopSequentialWithID (EventPrincipal &cache, size_t &fileNameHash, LuminosityBlockID const &id, size_t number, T eventOperator) |
| template<typename T , typename Iterator > | |
| size_t | loopSpecified (EventPrincipal &cache, size_t &fileNameHash, Iterator const &begin, Iterator const &end, T eventOperator) |
| VectorInputSource (ParameterSet const &pset, InputSourceDescription const &desc) | |
| virtual | ~VectorInputSource () |
 Public Member Functions inherited from edm::EDInputSource | |
| InputFileCatalog & | catalog (int n=0) |
| EDInputSource (ParameterSet const &pset, InputSourceDescription const &desc) | |
| std::vector< FileCatalogItem > const & | fileCatalogItems (int n=0) const |
| std::vector< std::string > const & | fileNames (int n=0) const |
| std::vector< std::string > const & | logicalFileNames (int n=0) const |
| virtual | ~EDInputSource () |
| Public Member Functions inherited from edm::InputSource | |
| std::shared_ptr< ActivityRegistry > | actReg () const |
| Accessor for Activity Registry. More... | |
| std::shared_ptr < BranchIDListHelper > | branchIDListHelper () const |
| Accessor for branchIDListHelper. More... | |
| void | closeFile (FileBlock *, bool cleaningUpAfterException) |
| close current file More... | |
| void | doBeginJob () |
| Called by framework at beginning of job. More... | |
| void | doBeginLumi (LuminosityBlockPrincipal &lbp, ProcessContext const *) |
| Called by framework at beginning of lumi block. More... | |
| void | doBeginRun (RunPrincipal &rp, ProcessContext const *) |
| Called by framework at beginning of run. More... | |
| void | doEndJob () |
| Called by framework at end of job. More... | |
| void | doEndLumi (LuminosityBlockPrincipal &lbp, bool cleaningUpAfterException, ProcessContext const *) |
| Called by framework at end of lumi block. More... | |
| void | doEndRun (RunPrincipal &rp, bool cleaningUpAfterException, ProcessContext const *) |
| Called by framework at end of run. More... | |
| void | doPostForkReacquireResources (std::shared_ptr< multicore::MessageReceiverForSource >) |
| void | doPreForkReleaseResources () |
| Called by the framework before forking the process. 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) |
| 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 |
| bool | primary () const |
| Accessor for primary input source flag. More... | |
| ProcessConfiguration const & | processConfiguration () const |
| Accessor for Process Configuration. More... | |
| std::string const & | processGUID () const |
| Accessor for global process identifier. More... | |
| ProcessHistoryRegistry const & | processHistoryRegistry () const |
| Const accessor for process history registry. More... | |
| ProcessHistoryRegistry & | processHistoryRegistryForUpdate () |
| Non-const accessor for process history registry. More... | |
| ProcessingMode | processingMode () const |
| RunsLumisAndEvents (default), RunsAndLumis, or Runs. More... | |
| std::shared_ptr < ProductRegistry const > | productRegistry () const |
| Accessor 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::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 |
| 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... | |
| SharedResourcesAcquirer * | resourceSharedWithDelayedReader () const |
| 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) |
| bool | skipForForking () |
| std::shared_ptr < ThinnedAssociationsHelper > | thinnedAssociationsHelper () const |
| Accessor for thinnedAssociationsHelper. More... | |
| Timestamp const & | timestamp () const |
| Accessor for the current time, as seen by the input source. More... | |
| virtual | ~InputSource () |
| Destructor. More... | |
Private Member Functions | |
| void | clearEventPrincipal (EventPrincipal &cache) |
| virtual void | dropUnwantedBranches_ (std::vector< std::string > const &wantedBranches)=0 |
| virtual void | readOneRandom (EventPrincipal &cache, size_t &fileNameHash, CLHEP::HepRandomEngine *)=0 |
| virtual bool | readOneRandomWithID (EventPrincipal &cache, size_t &fileNameHash, LuminosityBlockID const &id, CLHEP::HepRandomEngine *)=0 |
| virtual bool | readOneSequential (EventPrincipal &cache, size_t &fileNameHash)=0 |
| virtual bool | readOneSequentialWithID (EventPrincipal &cache, size_t &fileNameHash, LuminosityBlockID const &id)=0 |
| virtual void | readOneSpecified (EventPrincipal &cache, size_t &fileNameHash, SecondaryEventIDAndFileInfo const &event)=0 |
| void | readOneSpecified (EventPrincipal &cache, size_t &fileNameHash, EventID const &event) |
Additional Inherited Members | |
| Public Types inherited from edm::InputSource | |
| enum | ItemType { IsInvalid, IsStop, IsFile, IsRun, IsLumi, IsEvent, IsRepeat, IsSynchronize } |
| enum | ProcessingMode { Runs, RunsAndLumis, RunsLumisAndEvents } |
| typedef ProductRegistryHelper::TypeLabelList | TypeLabelList |
| Static Public Member Functions inherited from edm::EDInputSource | |
| static void | fillDescription (ParameterSetDescription &desc) |
| 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 inherited from edm::InputSource | |
| void | decreaseRemainingEventsBy (int iSkipped) |
| bool | eventCached () const |
| std::shared_ptr < LuminosityBlockPrincipal > const | luminosityBlockPrincipal () const |
| bool | newLumi () const |
| bool | newRun () const |
| ProcessHistoryRegistry & | processHistoryRegistryUpdate () const |
| ProductRegistry & | productRegistryUpdate () const |
| void | reset () const |
| void | resetEventCached () |
| void | resetLuminosityBlockAuxiliary (bool isNewLumi=true) const |
| void | resetNewLumi () |
| void | resetNewRun () |
| void | resetRunAuxiliary (bool isNewRun=true) const |
| std::shared_ptr< RunPrincipal > const | runPrincipal () 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 |
Definition at line 24 of file VectorInputSource.h.
|
explicit |
Definition at line 8 of file VectorInputSource.cc.
|
virtual |
Definition at line 11 of file VectorInputSource.cc.
|
private |
Definition at line 19 of file VectorInputSource.cc.
References edm::EventPrincipal::clearEventPrincipal().
Referenced by loopRandom(), loopRandomWithID(), loopSequential(), loopSequentialWithID(), and loopSpecified().
| void edm::VectorInputSource::dropUnwantedBranches | ( | std::vector< std::string > const & | wantedBranches | ) |
Definition at line 14 of file VectorInputSource.cc.
References dropUnwantedBranches_().
|
privatepure virtual |
Implemented in edm::PoolSource.
Referenced by dropUnwantedBranches().
| size_t edm::VectorInputSource::loopRandom | ( | EventPrincipal & | cache, |
| size_t & | fileNameHash, | ||
| size_t | number, | ||
| T | eventOperator, | ||
| CLHEP::HepRandomEngine * | engine | ||
| ) |
Definition at line 59 of file VectorInputSource.h.
References clearEventPrincipal(), i, contentValuesFiles::number, and readOneRandom().
| size_t edm::VectorInputSource::loopRandomWithID | ( | EventPrincipal & | cache, |
| size_t & | fileNameHash, | ||
| LuminosityBlockID const & | id, | ||
| size_t | number, | ||
| T | eventOperator, | ||
| CLHEP::HepRandomEngine * | engine | ||
| ) |
Definition at line 82 of file VectorInputSource.h.
References clearEventPrincipal(), newFWLiteAna::found, i, contentValuesFiles::number, and readOneRandomWithID().
| size_t edm::VectorInputSource::loopSequential | ( | EventPrincipal & | cache, |
| size_t & | fileNameHash, | ||
| size_t | number, | ||
| T | eventOperator | ||
| ) |
Definition at line 70 of file VectorInputSource.h.
References clearEventPrincipal(), newFWLiteAna::found, i, contentValuesFiles::number, and readOneSequential().
| size_t edm::VectorInputSource::loopSequentialWithID | ( | EventPrincipal & | cache, |
| size_t & | fileNameHash, | ||
| LuminosityBlockID const & | id, | ||
| size_t | number, | ||
| T | eventOperator | ||
| ) |
Definition at line 94 of file VectorInputSource.h.
References clearEventPrincipal(), newFWLiteAna::found, i, contentValuesFiles::number, and readOneSequentialWithID().
| size_t edm::VectorInputSource::loopSpecified | ( | EventPrincipal & | cache, |
| size_t & | fileNameHash, | ||
| Iterator const & | begin, | ||
| Iterator const & | end, | ||
| T | eventOperator | ||
| ) |
Definition at line 106 of file VectorInputSource.h.
References clearEventPrincipal(), end, i, getDQMSummary::iter, and readOneSpecified().
|
privatepure virtual |
Implemented in edm::PoolSource.
Referenced by loopRandom().
|
privatepure virtual |
Implemented in edm::PoolSource.
Referenced by loopRandomWithID().
|
privatepure virtual |
Implemented in edm::PoolSource.
Referenced by loopSequential().
|
privatepure virtual |
Implemented in edm::PoolSource.
Referenced by loopSequentialWithID().
|
privatepure virtual |
Implemented in edm::PoolSource.
Referenced by loopSpecified(), and readOneSpecified().
|
inlineprivate |
Definition at line 50 of file VectorInputSource.h.
References info(), and readOneSpecified().
1.8.5
