#include <VectorInputSource.h>
Public Member Functions | |
void | dropUnwantedBranches (std::vector< std::string > const &wantedBranches) |
template<typename T > | |
size_t | loopRandom (EventPrincipal &cache, size_t number, T eventOperator, CLHEP::HepRandomEngine *) |
template<typename T > | |
size_t | loopRandomWithID (EventPrincipal &cache, LuminosityBlockID const &id, size_t number, T eventOperator, CLHEP::HepRandomEngine *) |
template<typename T > | |
size_t | loopSequential (EventPrincipal &cache, size_t number, T eventOperator) |
template<typename T > | |
size_t | loopSequentialWithID (EventPrincipal &cache, LuminosityBlockID const &id, size_t number, T eventOperator) |
template<typename T , typename Collection > | |
size_t | loopSpecified (EventPrincipal &cache, Collection const &events, 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, CLHEP::HepRandomEngine *)=0 |
virtual bool | readOneRandomWithID (EventPrincipal &cache, LuminosityBlockID const &id, CLHEP::HepRandomEngine *)=0 |
virtual bool | readOneSequential (EventPrincipal &cache)=0 |
virtual bool | readOneSequentialWithID (EventPrincipal &cache, LuminosityBlockID const &id)=0 |
virtual void | readOneSpecified (EventPrincipal &cache, EventID const &event)=0 |
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 23 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 | number, | ||
T | eventOperator, | ||
CLHEP::HepRandomEngine * | engine | ||
) |
Definition at line 54 of file VectorInputSource.h.
References clearEventPrincipal(), i, contentValuesFiles::number, and readOneRandom().
size_t edm::VectorInputSource::loopRandomWithID | ( | EventPrincipal & | cache, |
LuminosityBlockID const & | id, | ||
size_t | number, | ||
T | eventOperator, | ||
CLHEP::HepRandomEngine * | engine | ||
) |
Definition at line 77 of file VectorInputSource.h.
References clearEventPrincipal(), newFWLiteAna::found, i, contentValuesFiles::number, and readOneRandomWithID().
size_t edm::VectorInputSource::loopSequential | ( | EventPrincipal & | cache, |
size_t | number, | ||
T | eventOperator | ||
) |
Definition at line 65 of file VectorInputSource.h.
References clearEventPrincipal(), newFWLiteAna::found, i, contentValuesFiles::number, and readOneSequential().
size_t edm::VectorInputSource::loopSequentialWithID | ( | EventPrincipal & | cache, |
LuminosityBlockID const & | id, | ||
size_t | number, | ||
T | eventOperator | ||
) |
Definition at line 89 of file VectorInputSource.h.
References clearEventPrincipal(), newFWLiteAna::found, i, contentValuesFiles::number, and readOneSequentialWithID().
size_t edm::VectorInputSource::loopSpecified | ( | EventPrincipal & | cache, |
Collection const & | events, | ||
T | eventOperator | ||
) |
Definition at line 101 of file VectorInputSource.h.
References clearEventPrincipal(), i, 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().