#include <VectorInputSource.h>
Public Types | |
typedef std::vector < EventPrincipalVectorElement > | EventPrincipalVector |
typedef boost::shared_ptr < EventPrincipal > | EventPrincipalVectorElement |
Public Types inherited from edm::InputSource | |
enum | ItemType { IsInvalid, IsStop, IsFile, IsRun, IsLumi, IsEvent, IsRepeat } |
enum | ProcessingMode { Runs, RunsAndLumis, RunsLumisAndEvents } |
typedef ProductRegistryHelper::TypeLabelList | TypeLabelList |
Public Member Functions | |
void | dropUnwantedBranches (std::vector< std::string > const &wantedBranches) |
void | readMany (int number, EventPrincipalVector &result) |
void | readManyRandom (int number, EventPrincipalVector &result, unsigned int &fileSeqNumber) |
void | readManySequential (int number, EventPrincipalVector &result, unsigned int &fileSeqNumber) |
void | readManySpecified (std::vector< EventID > const &events, EventPrincipalVector &result) |
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 | |
boost::shared_ptr < ActivityRegistry > | actReg () const |
Accessor for Activity Registry. More... | |
void | closeFile (boost::shared_ptr< FileBlock >) |
close current file More... | |
void | doBeginJob () |
Called by framework at beginning of job. More... | |
void | doBeginLumi (LuminosityBlockPrincipal &lbp) |
Called by framework at beginning of lumi block. More... | |
void | doBeginRun (RunPrincipal &rp) |
Called by framework at beginning of run. More... | |
void | doEndJob () |
Called by framework at end of job. More... | |
void | doEndLumi (LuminosityBlockPrincipal &lbp) |
Called by framework at end of lumi block. More... | |
void | doEndRun (RunPrincipal &rp) |
Called by framework at end of run. More... | |
void | doPostForkReacquireResources (boost::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... | |
void | issueReports (EventID const &eventID) |
issue an event report More... | |
LuminosityBlockNumber_t | luminosityBlock () const |
Accessor for current luminosity block number. More... | |
boost::shared_ptr < LuminosityBlockAuxiliary > | luminosityBlockAuxiliary () const |
Called by the framework to merge or insert lumi in principal cache. More... | |
int | markLumi () |
Mark lumi as read. More... | |
int | markRun () |
Mark run as read. More... | |
int | maxEvents () const |
int | maxLuminosityBlocks () const |
ModuleDescription const & | moduleDescription () const |
Accessor for 'module' description. More... | |
ItemType | nextItemType () |
bool const | 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... | |
ProcessHistoryID const & | processHistoryID () const |
Accessor for the input process history ID of the current run. More... | |
ProcessingMode | processingMode () const |
RunsLumisAndEvents (default), RunsAndLumis, or Runs. More... | |
boost::shared_ptr < ProductRegistry const > | productRegistry () const |
Accessor for product registry. More... | |
bool | randomAccess () const |
void | readAndCacheLumi () |
Read next luminosity block. More... | |
void | readAndCacheRun () |
Read next run. More... | |
EventPrincipal * | readEvent (boost::shared_ptr< LuminosityBlockPrincipal > lbCache) |
EventPrincipal * | readEvent (EventID const &) |
Read a specific event. More... | |
boost::shared_ptr< FileBlock > | readFile () |
Read next file. More... | |
boost::shared_ptr < LuminosityBlockAuxiliary > | readLuminosityBlockAuxiliary () |
Read next luminosity block Auxilary. More... | |
boost::shared_ptr< RunAuxiliary > | readRunAuxiliary () |
Read next run Auxiliary. More... | |
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... | |
ProcessingController::ReverseState | reverseState () const |
void | rewind () |
Begin again at the first event. More... | |
RunNumber_t | run () const |
Accessor for current run number. More... | |
boost::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) |
Timestamp const & | timestamp () const |
Accessor for the current time, as seen by the input source. More... | |
void | wakeUp () |
Wake up the input source. More... | |
virtual | ~InputSource () |
Destructor. More... | |
Private Member Functions | |
virtual void | dropUnwantedBranches_ (std::vector< std::string > const &wantedBranches)=0 |
virtual void | readMany_ (int number, EventPrincipalVector &result)=0 |
virtual void | readManyRandom_ (int number, EventPrincipalVector &result, unsigned int &fileSeqNumber)=0 |
virtual void | readManySequential_ (int number, EventPrincipalVector &result, unsigned int &fileSeqNumber)=0 |
virtual void | readManySpecified_ (std::vector< EventID > const &events, EventPrincipalVector &result)=0 |
Definition at line 20 of file VectorInputSource.h.
typedef std::vector<EventPrincipalVectorElement> edm::VectorInputSource::EventPrincipalVector |
Definition at line 23 of file VectorInputSource.h.
typedef boost::shared_ptr<EventPrincipal> edm::VectorInputSource::EventPrincipalVectorElement |
Definition at line 22 of file VectorInputSource.h.
|
explicit |
Definition at line 7 of file VectorInputSource.cc.
|
virtual |
Definition at line 10 of file VectorInputSource.cc.
void edm::VectorInputSource::dropUnwantedBranches | ( | std::vector< std::string > const & | wantedBranches | ) |
Definition at line 33 of file VectorInputSource.cc.
References dropUnwantedBranches_().
Referenced by edm::PileUp::dropUnwantedBranches().
|
privatepure virtual |
Implemented in edm::PoolSource.
Referenced by dropUnwantedBranches().
void edm::VectorInputSource::readMany | ( | int | number, |
EventPrincipalVector & | result | ||
) |
Definition at line 13 of file VectorInputSource.cc.
References readMany_().
|
privatepure virtual |
Implemented in edm::PoolSource.
Referenced by readMany().
void edm::VectorInputSource::readManyRandom | ( | int | number, |
EventPrincipalVector & | result, | ||
unsigned int & | fileSeqNumber | ||
) |
Definition at line 18 of file VectorInputSource.cc.
References readManyRandom_().
Referenced by edm::PileUp::readPileUp().
|
privatepure virtual |
Implemented in edm::PoolSource.
Referenced by readManyRandom().
void edm::VectorInputSource::readManySequential | ( | int | number, |
EventPrincipalVector & | result, | ||
unsigned int & | fileSeqNumber | ||
) |
Definition at line 23 of file VectorInputSource.cc.
References readManySequential_().
Referenced by edm::PileUp::readPileUp().
|
privatepure virtual |
Implemented in edm::PoolSource.
Referenced by readManySequential().
void edm::VectorInputSource::readManySpecified | ( | std::vector< EventID > const & | events, |
EventPrincipalVector & | result | ||
) |
Definition at line 28 of file VectorInputSource.cc.
References readManySpecified_().
Referenced by edm::PileUp::readPileUp().
|
privatepure virtual |
Implemented in edm::PoolSource.
Referenced by readManySpecified().