CMS 3D CMS Logo

 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Pages
List of all members | Public Member Functions | Private Member Functions
edm::VectorInputSource Class Referenceabstract

#include <VectorInputSource.h>

Inheritance diagram for edm::VectorInputSource:
edm::EDInputSource edm::InputSource edm::ProductRegistryHelper edm::PoolSource

Public Member Functions

void dropUnwantedBranches (std::vector< std::string > const &wantedBranches)
 
template<typename T >
size_t loopRandom (EventPrincipal &cache, size_t number, T eventOperator)
 
template<typename T >
size_t loopRandomWithID (EventPrincipal &cache, LuminosityBlockID const &id, size_t number, T eventOperator)
 
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
InputFileCatalogcatalog (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...
 
boost::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)
 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, bool cleaningUpAfterException)
 Called by framework at end of lumi block. More...
 
void doEndRun (RunPrincipal &rp, bool cleaningUpAfterException)
 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...
 
 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...
 
boost::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 ()
 
InputSourceoperator= (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...
 
ProcessingMode processingMode () const
 RunsLumisAndEvents (default), RunsAndLumis, or Runs. More...
 
boost::shared_ptr
< ProductRegistry const > 
productRegistry () const
 Accessor for product registry. More...
 
bool randomAccess () const
 
boost::shared_ptr
< LuminosityBlockPrincipal
readAndCacheLumi (HistoryAppender &historyAppender)
 Read next luminosity block (new lumi) More...
 
boost::shared_ptr< RunPrincipalreadAndCacheRun (HistoryAppender &historyAppender)
 Read next run (new run) More...
 
void readAndMergeLumi (boost::shared_ptr< LuminosityBlockPrincipal > lbp)
 Read next luminosity block (same as a prior lumi) More...
 
void readAndMergeRun (boost::shared_ptr< RunPrincipal > rp)
 Read next run (same as a prior run) More...
 
EventPrincipalreadEvent (EventPrincipal &ep)
 
EventPrincipalreadEvent (EventPrincipal &ep, EventID const &)
 Read a specific event. More...
 
std::unique_ptr< FileBlockreadFile ()
 Read next file. More...
 
boost::shared_ptr
< LuminosityBlockAuxiliary
readLuminosityBlockAuxiliary ()
 Read next luminosity block Auxilary. More...
 
boost::shared_ptr< RunAuxiliaryreadRunAuxiliary ()
 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...
 
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< RunAuxiliaryrunAuxiliary () 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 ()
 
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 EventPrincipalreadOneRandom (EventPrincipal &cache)=0
 
virtual EventPrincipalreadOneRandomWithID (EventPrincipal &cache, LuminosityBlockID const &id)=0
 
virtual EventPrincipalreadOneSequential (EventPrincipal &cache)=0
 
virtual EventPrincipalreadOneSequentialWithID (EventPrincipal &cache, LuminosityBlockID const &id)=0
 
virtual EventPrincipalreadOneSpecified (EventPrincipal &cache, EventID const &event)=0
 

Additional Inherited Members

- Public Types inherited from edm::InputSource
enum  ItemType {
  IsInvalid, IsStop, IsFile, IsRun,
  IsLumi, IsEvent, IsRepeat
}
 
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
 
boost::shared_ptr
< LuminosityBlockPrincipal >
const 
luminosityBlockPrincipal () const
 
bool newLumi () const
 
bool newRun () const
 
ProductRegistryproductRegistryUpdate () const
 
void reset () const
 
void resetEventCached ()
 
void resetLuminosityBlockAuxiliary (bool isNewLumi=true) const
 
void resetNewLumi ()
 
void resetNewRun ()
 
void resetRunAuxiliary (bool isNewRun=true) const
 
boost::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
 

Detailed Description

Definition at line 19 of file VectorInputSource.h.

Constructor & Destructor Documentation

edm::VectorInputSource::VectorInputSource ( ParameterSet const &  pset,
InputSourceDescription const &  desc 
)
explicit

Definition at line 8 of file VectorInputSource.cc.

8  :
9  EDInputSource(pset, desc) {}
EDInputSource(ParameterSet const &pset, InputSourceDescription const &desc)
edm::VectorInputSource::~VectorInputSource ( )
virtual

Definition at line 11 of file VectorInputSource.cc.

11 {}

Member Function Documentation

void edm::VectorInputSource::clearEventPrincipal ( EventPrincipal cache)
private

Definition at line 19 of file VectorInputSource.cc.

References edm::EventPrincipal::clearEventPrincipal().

Referenced by loopRandom(), loopRandomWithID(), loopSequential(), loopSequentialWithID(), and loopSpecified().

19  {
20  cache.clearEventPrincipal();
21  }
void edm::VectorInputSource::dropUnwantedBranches ( std::vector< std::string > const &  wantedBranches)

Definition at line 14 of file VectorInputSource.cc.

References dropUnwantedBranches_().

14  {
15  this->dropUnwantedBranches_(wantedBranches);
16  }
virtual void dropUnwantedBranches_(std::vector< std::string > const &wantedBranches)=0
virtual void edm::VectorInputSource::dropUnwantedBranches_ ( std::vector< std::string > const &  wantedBranches)
privatepure virtual

Implemented in edm::PoolSource.

Referenced by dropUnwantedBranches().

template<typename T >
size_t edm::VectorInputSource::loopRandom ( EventPrincipal cache,
size_t  number,
T  eventOperator 
)

Definition at line 50 of file VectorInputSource.h.

References clearEventPrincipal(), i, and readOneRandom().

50  {
51  size_t i = 0U;
52  for(; i < number; ++i) {
53  clearEventPrincipal(cache);
54  EventPrincipal* ep = readOneRandom(cache);
55  if(!ep) break;
56  eventOperator(*ep);
57  }
58  return i;
59  }
int i
Definition: DBlmapReader.cc:9
void clearEventPrincipal(EventPrincipal &cache)
virtual EventPrincipal * readOneRandom(EventPrincipal &cache)=0
template<typename T >
size_t edm::VectorInputSource::loopRandomWithID ( EventPrincipal cache,
LuminosityBlockID const &  id,
size_t  number,
T  eventOperator 
)

Definition at line 74 of file VectorInputSource.h.

References clearEventPrincipal(), i, and readOneRandomWithID().

74  {
75  size_t i = 0U;
76  for(; i < number; ++i) {
77  clearEventPrincipal(cache);
78  EventPrincipal* ep = readOneRandomWithID(cache, id);
79  if(!ep) break;
80  eventOperator(*ep);
81  }
82  return i;
83  }
int i
Definition: DBlmapReader.cc:9
virtual EventPrincipal * readOneRandomWithID(EventPrincipal &cache, LuminosityBlockID const &id)=0
void clearEventPrincipal(EventPrincipal &cache)
template<typename T >
size_t edm::VectorInputSource::loopSequential ( EventPrincipal cache,
size_t  number,
T  eventOperator 
)

Definition at line 62 of file VectorInputSource.h.

References clearEventPrincipal(), i, and readOneSequential().

62  {
63  size_t i = 0U;
64  for(; i < number; ++i) {
65  clearEventPrincipal(cache);
66  EventPrincipal* ep = readOneSequential(cache);
67  if(!ep) break;
68  eventOperator(*ep);
69  }
70  return i;
71  }
int i
Definition: DBlmapReader.cc:9
void clearEventPrincipal(EventPrincipal &cache)
virtual EventPrincipal * readOneSequential(EventPrincipal &cache)=0
template<typename T >
size_t edm::VectorInputSource::loopSequentialWithID ( EventPrincipal cache,
LuminosityBlockID const &  id,
size_t  number,
T  eventOperator 
)

Definition at line 86 of file VectorInputSource.h.

References clearEventPrincipal(), i, and readOneSequentialWithID().

86  {
87  size_t i = 0U;
88  for(; i < number; ++i) {
89  clearEventPrincipal(cache);
90  EventPrincipal* ep = readOneSequentialWithID(cache, id);
91  if(!ep) break;
92  eventOperator(*ep);
93  }
94  return i;
95  }
int i
Definition: DBlmapReader.cc:9
void clearEventPrincipal(EventPrincipal &cache)
virtual EventPrincipal * readOneSequentialWithID(EventPrincipal &cache, LuminosityBlockID const &id)=0
template<typename T , typename Collection >
size_t edm::VectorInputSource::loopSpecified ( EventPrincipal cache,
Collection const &  events,
T  eventOperator 
)

Definition at line 98 of file VectorInputSource.h.

References clearEventPrincipal(), i, and readOneSpecified().

98  {
99  size_t i = 0U;
100  for(typename Collection::const_iterator it = events.begin(), itEnd = events.end(); it != itEnd; ++it) {
101  clearEventPrincipal(cache);
102  EventPrincipal* ep = readOneSpecified(cache, *it);
103  if(!ep) break;
104  eventOperator(*ep);
105  ++i;
106  }
107  return i;
108  }
int i
Definition: DBlmapReader.cc:9
void clearEventPrincipal(EventPrincipal &cache)
tuple events
Definition: patZpeak.py:19
virtual EventPrincipal * readOneSpecified(EventPrincipal &cache, EventID const &event)=0
virtual EventPrincipal* edm::VectorInputSource::readOneRandom ( EventPrincipal cache)
privatepure virtual

Implemented in edm::PoolSource.

Referenced by loopRandom().

virtual EventPrincipal* edm::VectorInputSource::readOneRandomWithID ( EventPrincipal cache,
LuminosityBlockID const &  id 
)
privatepure virtual

Implemented in edm::PoolSource.

Referenced by loopRandomWithID().

virtual EventPrincipal* edm::VectorInputSource::readOneSequential ( EventPrincipal cache)
privatepure virtual

Implemented in edm::PoolSource.

Referenced by loopSequential().

virtual EventPrincipal* edm::VectorInputSource::readOneSequentialWithID ( EventPrincipal cache,
LuminosityBlockID const &  id 
)
privatepure virtual

Implemented in edm::PoolSource.

Referenced by loopSequentialWithID().

virtual EventPrincipal* edm::VectorInputSource::readOneSpecified ( EventPrincipal cache,
EventID const &  event 
)
privatepure virtual

Implemented in edm::PoolSource.

Referenced by loopSpecified().