CMS 3D CMS Logo

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

#include <InputSource.h>

Inheritance diagram for edm::InputSource:
edm::ProductRegistryHelper DQMRootSource dqmservices::DQMProtobufReader edm::PoolSource edm::ProducerSourceBase edm::RawInputSource cond::EmptyIOVSource edm::EmptySource edm::ProducerSourceFromFiles LmfSource edm::RawInputSourceFromFiles edm::StreamerInputSource FedRawDataInputSource AlpgenSource edm::MCFileSource FRDStreamSource HcalTBSource L1MuGMTHWFileReader LHESource MCatNLOSource PixelSLinkDataInputSource dqmservices::DQMStreamerReader edm::StreamerFileReader edm::StreamerInputModule< Producer >

Classes

class  EventSourceSentry
 
class  FileCloseSentry
 
class  FileOpenSentry
 
class  LumiSourceSentry
 
class  RunSourceSentry
 
class  SourceSentry
 

Public Types

enum  ItemType {
  IsInvalid, IsStop, IsFile, IsRun,
  IsLumi, IsEvent, IsRepeat, IsSynchronize
}
 
enum  ProcessingMode { Runs, RunsAndLumis, RunsLumisAndEvents }
 
typedef
ProductRegistryHelper::TypeLabelList 
TypeLabelList
 

Public Member Functions

std::shared_ptr< ActivityRegistryactReg () 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...
 
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...
 
InputSourceoperator= (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...
 
ProcessHistoryRegistryprocessHistoryRegistry ()
 
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< FileBlockreadFile ()
 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< 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...
 
SharedResourcesAcquirerresourceSharedWithDelayedReader ()
 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< 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 ()
 
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 ()
 Destructor. More...
 

Static Public Member Functions

static const std::string & baseType ()
 
static void fillDescription (ParameterSetDescription &desc)
 
static void fillDescriptions (ConfigurationDescriptions &descriptions)
 
static void prevalidate (ConfigurationDescriptions &)
 

Protected Member Functions

void decreaseRemainingEventsBy (int iSkipped)
 
bool eventCached () const
 
bool newLumi () const
 
bool newRun () const
 
ProcessHistoryRegistryprocessHistoryRegistryForUpdate ()
 
ProductRegistryproductRegistryUpdate ()
 
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...
 
virtual void skip (int offset)
 
ItemType state () const
 

Private Member Functions

virtual void beginJob ()
 
virtual void beginLuminosityBlock (LuminosityBlock &)
 
virtual void beginRun (Run &)
 
virtual void closeFile_ ()
 
virtual void endJob ()
 
virtual void endLuminosityBlock (LuminosityBlock &)
 
virtual void endRun (Run &)
 
bool eventLimitReached () const
 
virtual
ProcessingController::ForwardState 
forwardState_ () const
 
virtual ItemType getNextItemType ()=0
 
virtual bool goToEvent_ (EventID const &eventID)
 
bool limitReached () const
 
bool lumiLimitReached () const
 
ItemType nextItemType_ ()
 
virtual void postForkReacquireResources (std::shared_ptr< multicore::MessageReceiverForSource >)
 
virtual void preForkReleaseResources ()
 
virtual bool randomAccess_ () const
 
virtual void readEvent_ (EventPrincipal &eventPrincipal)=0
 
virtual std::unique_ptr
< FileBlock
readFile_ ()
 
virtual bool readIt (EventID const &id, EventPrincipal &eventPrincipal, StreamContext &streamContext)
 
virtual void readLuminosityBlock_ (LuminosityBlockPrincipal &lumiPrincipal)
 
virtual std::shared_ptr
< LuminosityBlockAuxiliary
readLuminosityBlockAuxiliary_ ()=0
 
virtual void readRun_ (RunPrincipal &runPrincipal)
 
virtual std::shared_ptr
< RunAuxiliary
readRunAuxiliary_ ()=0
 
virtual SharedResourcesAcquirerresourceSharedWithDelayedReader_ ()
 
virtual
ProcessingController::ReverseState 
reverseState_ () const
 
virtual void rewind_ ()
 
virtual void setLumi (LuminosityBlockNumber_t lb)
 
virtual void setRun (RunNumber_t r)
 
- Private Member Functions inherited from edm::ProductRegistryHelper
template<class ProductType >
TypeLabelItem const & produces ()
 declare what type of product will make and with which optional label More...
 
template<class ProductType >
TypeLabelItem const & produces (std::string const &instanceName)
 
template<typename ProductType , BranchType B>
TypeLabelItem const & produces ()
 
template<typename ProductType , BranchType B>
TypeLabelItem const & produces (std::string const &instanceName)
 
TypeLabelItem const & produces (const TypeID &id, std::string const &instanceName=std::string())
 
template<BranchType B>
TypeLabelItem const & produces (const TypeID &id, std::string const &instanceName=std::string())
 
 ProductRegistryHelper ()
 
TypeLabelListtypeLabelList ()
 used by the fwk to register the list of products of this module More...
 
 ~ProductRegistryHelper ()
 

Private Attributes

std::shared_ptr< ActivityRegistryactReg_
 
edm::propagate_const
< std::shared_ptr
< BranchIDListHelper > > 
branchIDListHelper_
 
bool eventCached_
 
std::shared_ptr
< LuminosityBlockAuxiliary
lumiAuxiliary_
 
int maxEvents_
 
int maxLumis_
 
int maxSecondsUntilRampdown_
 
ModuleDescription const moduleDescription_
 
bool newLumi_
 
bool newRun_
 
unsigned int numberOfEventsBeforeBigSkip_
 
std::string processGUID_
 
edm::propagate_const
< std::unique_ptr
< ProcessHistoryRegistry > > 
processHistoryRegistry_
 
ProcessingMode processingMode_
 
std::chrono::time_point
< std::chrono::steady_clock > 
processingStart_
 
edm::propagate_const
< std::shared_ptr
< ProductRegistry > > 
productRegistry_
 
int readCount_
 
edm::propagate_const
< std::shared_ptr
< edm::multicore::MessageReceiverForSource > > 
receiver_
 
int remainingEvents_
 
int remainingLumis_
 
std::shared_ptr< RunAuxiliaryrunAuxiliary_
 
ItemType state_
 
std::string statusFileName_
 
edm::propagate_const
< std::shared_ptr
< ThinnedAssociationsHelper > > 
thinnedAssociationsHelper_
 
Timestamp time_
 

Additional Inherited Members

- Private Types inherited from edm::ProductRegistryHelper
typedef std::list< TypeLabelItemTypeLabelList
 
- Static Private Member Functions inherited from edm::ProductRegistryHelper
static void addToRegistry (TypeLabelList::const_iterator const &iBegin, TypeLabelList::const_iterator const &iEnd, ModuleDescription const &iDesc, ProductRegistry &iReg, bool iIsListener=false)
 

Detailed Description

Definition at line 77 of file InputSource.h.

Member Typedef Documentation

Definition at line 96 of file InputSource.h.

Member Enumeration Documentation

Enumerator
IsInvalid 
IsStop 
IsFile 
IsRun 
IsLumi 
IsEvent 
IsRepeat 
IsSynchronize 

Definition at line 79 of file InputSource.h.

Enumerator
Runs 
RunsAndLumis 
RunsLumisAndEvents 

Definition at line 90 of file InputSource.h.

Constructor & Destructor Documentation

InputSource::InputSource ( ParameterSet const &  pset,
InputSourceDescription const &  desc 
)
explicit

Constructor.

Definition at line 47 of file InputSource.cc.

InputSource::~InputSource ( )
virtual

Destructor.

Definition at line 105 of file InputSource.cc.

edm::InputSource::InputSource ( InputSource const &  )
delete

Member Function Documentation

std::shared_ptr<ActivityRegistry> edm::InputSource::actReg ( ) const
inline

Accessor for Activity Registry.

Definition at line 259 of file InputSource.h.

std::string const & InputSource::baseType ( )
static

Definition at line 122 of file InputSource.cc.

void InputSource::beginJob ( void  )
privatevirtual

Reimplemented in edm::ProducerSourceBase.

Definition at line 552 of file InputSource.cc.

void InputSource::beginLuminosityBlock ( LuminosityBlock )
privatevirtual

Reimplemented in edm::ProducerSourceBase, FRDStreamSource, and dqmservices::DQMProtobufReader.

Definition at line 540 of file InputSource.cc.

void InputSource::beginRun ( Run )
privatevirtual

Reimplemented in MCatNLOSource, edm::ProducerSourceBase, AlpgenSource, LHESource, and FRDStreamSource.

Definition at line 546 of file InputSource.cc.

std::shared_ptr<BranchIDListHelper const> edm::InputSource::branchIDListHelper ( ) const
inline

Accessors for branchIDListHelper.

Definition at line 178 of file InputSource.h.

Referenced by edm::RootSecondaryFileSequence::makeRootFile().

std::shared_ptr<BranchIDListHelper>& edm::InputSource::branchIDListHelper ( )
inline

Definition at line 179 of file InputSource.h.

void InputSource::closeFile ( FileBlock fb,
bool  cleaningUpAfterException 
)

close current file

Definition at line 275 of file InputSource.cc.

Referenced by edm::RawInputSource::preForkReleaseResources().

virtual void edm::InputSource::closeFile_ ( )
inlineprivatevirtual

Reimplemented in DQMRootSource, edm::PoolSource, and edm::RawInputSource.

Definition at line 409 of file InputSource.h.

void InputSource::decreaseRemainingEventsBy ( int  iSkipped)
protected

Called by inheriting classes when running multicore when the receiver has told them to skip some events.

Definition at line 467 of file InputSource.cc.

void InputSource::doBeginJob ( )

Called by framework at beginning of job.

Definition at line 239 of file InputSource.cc.

void InputSource::doBeginLumi ( LuminosityBlockPrincipal lbp,
ProcessContext const *   
)

Called by framework at beginning of lumi block.

Definition at line 495 of file InputSource.cc.

void InputSource::doBeginRun ( RunPrincipal rp,
ProcessContext const *   
)

Called by framework at beginning of run.

Definition at line 479 of file InputSource.cc.

void InputSource::doEndJob ( )

Called by framework at end of job.

Definition at line 244 of file InputSource.cc.

void InputSource::doEndLumi ( LuminosityBlockPrincipal lbp,
bool  cleaningUpAfterException,
ProcessContext const *   
)

Called by framework at end of lumi block.

Definition at line 502 of file InputSource.cc.

void InputSource::doEndRun ( RunPrincipal rp,
bool  cleaningUpAfterException,
ProcessContext const *   
)

Called by framework at end of run.

Definition at line 486 of file InputSource.cc.

void InputSource::doPostForkReacquireResources ( std::shared_ptr< multicore::MessageReceiverForSource iReceiver)

Definition at line 516 of file InputSource.cc.

void InputSource::doPreForkReleaseResources ( )

Called by the framework before forking the process.

Definition at line 511 of file InputSource.cc.

void InputSource::endJob ( void  )
privatevirtual

Reimplemented in edm::PoolSource, MCatNLOSource, and LHESource.

Definition at line 555 of file InputSource.cc.

void InputSource::endLuminosityBlock ( LuminosityBlock )
privatevirtual

Reimplemented in edm::ProducerSourceBase, and FRDStreamSource.

Definition at line 543 of file InputSource.cc.

void InputSource::endRun ( Run )
privatevirtual

Reimplemented in edm::ProducerSourceBase, LHESource, and FRDStreamSource.

Definition at line 549 of file InputSource.cc.

bool edm::InputSource::eventCached ( ) const
inlineprotected
bool edm::InputSource::eventLimitReached ( ) const
inlineprivate

Definition at line 390 of file InputSource.h.

void InputSource::fillDescription ( ParameterSetDescription desc)
static

Definition at line 127 of file InputSource.cc.

Referenced by edm::RawInputSource::fillDescription().

void InputSource::fillDescriptions ( ConfigurationDescriptions descriptions)
static

Definition at line 108 of file InputSource.cc.

ProcessingController::ForwardState InputSource::forwardState ( ) const

Definition at line 528 of file InputSource.cc.

ProcessingController::ForwardState InputSource::forwardState_ ( ) const
privatevirtual

Reimplemented in edm::PoolSource.

Definition at line 574 of file InputSource.cc.

virtual ItemType edm::InputSource::getNextItemType ( )
privatepure virtual
bool InputSource::goToEvent ( EventID const &  eventID)

Definition at line 380 of file InputSource.cc.

bool InputSource::goToEvent_ ( EventID const &  eventID)
privatevirtual

Reimplemented in edm::PoolSource.

Definition at line 450 of file InputSource.cc.

void InputSource::issueReports ( EventID const &  eventID)

issue an event report

Definition at line 400 of file InputSource.cc.

bool edm::InputSource::limitReached ( ) const
inlineprivate

Definition at line 399 of file InputSource.h.

bool edm::InputSource::lumiLimitReached ( ) const
inlineprivate

Definition at line 391 of file InputSource.h.

LuminosityBlockNumber_t InputSource::luminosityBlock ( ) const

Accessor for current luminosity block number.

Definition at line 596 of file InputSource.cc.

std::shared_ptr<LuminosityBlockAuxiliary> edm::InputSource::luminosityBlockAuxiliary ( ) const
inline

Called by the framework to merge or insert lumi in principal cache.

Definition at line 265 of file InputSource.h.

Referenced by edm::RawInputSource::getNextItemType(), and edm::RawInputSource::readLuminosityBlockAuxiliary_().

int edm::InputSource::maxEvents ( ) const
inline

Accessor for maximum number of events to be read. -1 is used for unlimited.

Definition at line 196 of file InputSource.h.

int edm::InputSource::maxLuminosityBlocks ( ) const
inline

Accessor for maximum number of lumis to be read. -1 is used for unlimited.

Definition at line 204 of file InputSource.h.

ModuleDescription const& edm::InputSource::moduleDescription ( ) const
inline

Accessor for 'module' description.

Definition at line 211 of file InputSource.h.

bool edm::InputSource::newLumi ( ) const
inlineprotected
bool edm::InputSource::newRun ( ) const
inlineprotected
InputSource::ItemType InputSource::nextItemType ( )

Advances the source to the next item.

Definition at line 180 of file InputSource.cc.

InputSource::ItemType InputSource::nextItemType_ ( )
private

Definition at line 165 of file InputSource.cc.

InputSource& edm::InputSource::operator= ( InputSource const &  )
delete
void InputSource::postForkReacquireResources ( std::shared_ptr< multicore::MessageReceiverForSource iReceiver)
privatevirtual

Definition at line 561 of file InputSource.cc.

void InputSource::preForkReleaseResources ( )
privatevirtual

Reimplemented in edm::PoolSource, FedRawDataInputSource, and edm::RawInputSource.

Definition at line 558 of file InputSource.cc.

void InputSource::prevalidate ( ConfigurationDescriptions )
static

Definition at line 115 of file InputSource.cc.

ProcessConfiguration const& edm::InputSource::processConfiguration ( ) const
inline

Accessor for Process Configuration.

Definition at line 214 of file InputSource.h.

Referenced by edm::RootSecondaryFileSequence::makeRootFile().

std::string const& edm::InputSource::processGUID ( ) const
inline

Accessor for global process identifier.

Definition at line 217 of file InputSource.h.

ProcessHistoryRegistry const& edm::InputSource::processHistoryRegistry ( ) const
inline

Accessors for process history registry.

Definition at line 174 of file InputSource.h.

Referenced by edm::RawInputSource::makeEvent().

ProcessHistoryRegistry& edm::InputSource::processHistoryRegistry ( )
inline

Definition at line 175 of file InputSource.h.

ProcessHistoryRegistry& edm::InputSource::processHistoryRegistryForUpdate ( )
inlineprotected

Definition at line 351 of file InputSource.h.

Referenced by edm::RootSecondaryFileSequence::makeRootFile().

ProcessingMode edm::InputSource::processingMode ( ) const
inline

RunsLumisAndEvents (default), RunsAndLumis, or Runs.

Definition at line 256 of file InputSource.h.

Referenced by edm::RootSecondaryFileSequence::makeRootFile().

std::shared_ptr<ProductRegistry const> edm::InputSource::productRegistry ( ) const
inline

Accessors for product registry.

Definition at line 170 of file InputSource.h.

std::shared_ptr<ProductRegistry>& edm::InputSource::productRegistry ( )
inline

Definition at line 171 of file InputSource.h.

ProductRegistry& edm::InputSource::productRegistryUpdate ( )
inlineprotected
bool InputSource::randomAccess ( ) const

Definition at line 522 of file InputSource.cc.

bool InputSource::randomAccess_ ( ) const
privatevirtual

Reimplemented in edm::PoolSource.

Definition at line 569 of file InputSource.cc.

void InputSource::readAndMergeLumi ( LuminosityBlockPrincipal lbp)

Read next luminosity block (same as a prior lumi)

Definition at line 313 of file InputSource.cc.

void InputSource::readAndMergeRun ( RunPrincipal rp)

Read next run (same as a prior run)

Definition at line 298 of file InputSource.cc.

void InputSource::readEvent ( EventPrincipal ep,
StreamContext streamContext 
)

Read next event.

Definition at line 335 of file InputSource.cc.

bool InputSource::readEvent ( EventPrincipal ep,
EventID const &  eventID,
StreamContext streamContext 
)

Read a specific event.

Definition at line 355 of file InputSource.cc.

virtual void edm::InputSource::readEvent_ ( EventPrincipal eventPrincipal)
privatepure virtual
std::unique_ptr< FileBlock > InputSource::readFile ( )

Read next file.

Definition at line 267 of file InputSource.cc.

std::unique_ptr< FileBlock > InputSource::readFile_ ( )
privatevirtual

Reimplemented in DQMRootSource, edm::StreamerInputSource, and edm::PoolSource.

Definition at line 287 of file InputSource.cc.

bool InputSource::readIt ( EventID const &  id,
EventPrincipal eventPrincipal,
StreamContext streamContext 
)
privatevirtual

Reimplemented in edm::PoolSource.

Definition at line 418 of file InputSource.cc.

void InputSource::readLuminosityBlock ( LuminosityBlockPrincipal lumiPrincipal,
HistoryAppender historyAppender 
)

Read next luminosity block (new lumi)

Definition at line 304 of file InputSource.cc.

void InputSource::readLuminosityBlock_ ( LuminosityBlockPrincipal lumiPrincipal)
privatevirtual

Reimplemented in DQMRootSource, edm::PoolSource, LHESource, and dqmservices::DQMProtobufReader.

Definition at line 330 of file InputSource.cc.

std::shared_ptr< LuminosityBlockAuxiliary > InputSource::readLuminosityBlockAuxiliary ( )

Read next luminosity block Auxilary.

Definition at line 227 of file InputSource.cc.

virtual std::shared_ptr<LuminosityBlockAuxiliary> edm::InputSource::readLuminosityBlockAuxiliary_ ( )
privatepure virtual
void InputSource::readRun ( RunPrincipal runPrincipal,
HistoryAppender historyAppender 
)

Read next run (new run)

Definition at line 292 of file InputSource.cc.

void InputSource::readRun_ ( RunPrincipal runPrincipal)
privatevirtual

Reimplemented in DQMRootSource, edm::PoolSource, LHESource, and dqmservices::DQMProtobufReader.

Definition at line 322 of file InputSource.cc.

std::shared_ptr< RunAuxiliary > InputSource::readRunAuxiliary ( )

Read next run Auxiliary.

Definition at line 233 of file InputSource.cc.

virtual std::shared_ptr<RunAuxiliary> edm::InputSource::readRunAuxiliary_ ( )
privatepure virtual
ProcessHistoryID const & InputSource::reducedProcessHistoryID ( ) const

Accessor for the reduced process history ID of the current run. This is the ID of the input process history which does not include the current process.

Definition at line 584 of file InputSource.cc.

void InputSource::registerProducts ( )

Register any produced products.

Definition at line 259 of file InputSource.cc.

int edm::InputSource::remainingEvents ( ) const
inline

Accessor for remaining number of events to be read. -1 is used for unlimited.

Definition at line 200 of file InputSource.h.

int edm::InputSource::remainingLuminosityBlocks ( ) const
inline

Accessor for remaining number of lumis to be read. -1 is used for unlimited.

Definition at line 208 of file InputSource.h.

void edm::InputSource::repeat ( )
inline

Reset the remaining number of events/lumis to the maximum number.

Definition at line 186 of file InputSource.h.

void edm::InputSource::reset ( void  ) const
inlineprotected

Definition at line 369 of file InputSource.h.

void edm::InputSource::resetEventCached ( )
inlineprotected

Definition at line 383 of file InputSource.h.

Referenced by edm::RawInputSource::readEvent_().

void edm::InputSource::resetLuminosityBlockAuxiliary ( bool  isNewLumi = true) const
inlineprotected

Definition at line 365 of file InputSource.h.

Referenced by edm::RawInputSource::getNextItemType().

void edm::InputSource::resetNewLumi ( )
inlineprotected

Definition at line 379 of file InputSource.h.

Referenced by edm::RawInputSource::readLuminosityBlockAuxiliary_().

void edm::InputSource::resetNewRun ( )
inlineprotected

Definition at line 376 of file InputSource.h.

Referenced by edm::RawInputSource::readRunAuxiliary_().

void edm::InputSource::resetRunAuxiliary ( bool  isNewRun = true) const
inlineprotected

Definition at line 361 of file InputSource.h.

Referenced by edm::RawInputSource::getNextItemType().

SharedResourcesAcquirer * InputSource::resourceSharedWithDelayedReader ( )

Returns nullptr if no resource shared between the Source and a DelayedReader.

Definition at line 249 of file InputSource.cc.

SharedResourcesAcquirer * InputSource::resourceSharedWithDelayedReader_ ( )
privatevirtual

Reimplemented in edm::PoolSource.

Definition at line 254 of file InputSource.cc.

ProcessingController::ReverseState InputSource::reverseState ( ) const

Definition at line 534 of file InputSource.cc.

ProcessingController::ReverseState InputSource::reverseState_ ( ) const
privatevirtual

Reimplemented in edm::PoolSource.

Definition at line 579 of file InputSource.cc.

void InputSource::rewind ( )

Begin again at the first event.

Definition at line 385 of file InputSource.cc.

void InputSource::rewind_ ( )
privatevirtual
RunNumber_t InputSource::run ( void  ) const

Accessor for current run number.

Definition at line 590 of file InputSource.cc.

std::shared_ptr<RunAuxiliary> edm::InputSource::runAuxiliary ( ) const
inline

Called by the framework to merge or insert run in principal cache.

Definition at line 262 of file InputSource.h.

Referenced by edm::RawInputSource::getNextItemType(), and edm::RawInputSource::readRunAuxiliary_().

void edm::InputSource::setEventCached ( )
inlineprotected

Called by the framework to merge or ached() const {return eventCached_;}.

Definition at line 382 of file InputSource.h.

void InputSource::setLumi ( LuminosityBlockNumber_t  lb)
privatevirtual

Definition at line 434 of file InputSource.cc.

void edm::InputSource::setLuminosityBlockAuxiliary ( LuminosityBlockAuxiliary lbp)
inlineprotected

Definition at line 357 of file InputSource.h.

void edm::InputSource::setLuminosityBlockNumber_t ( LuminosityBlockNumber_t  lb)
inline

Set the luminosity block ID.

Definition at line 161 of file InputSource.h.

void edm::InputSource::setNewLumi ( )
inlineprotected

Definition at line 378 of file InputSource.h.

void edm::InputSource::setNewRun ( )
inlineprotected

Definition at line 375 of file InputSource.h.

void InputSource::setRun ( RunNumber_t  r)
privatevirtual

Reimplemented in edm::StreamerInputSource.

Definition at line 426 of file InputSource.cc.

void edm::InputSource::setRunAuxiliary ( RunAuxiliary rp)
inlineprotected

Definition at line 353 of file InputSource.h.

void edm::InputSource::setRunNumber ( RunNumber_t  r)
inline

Set the run number.

Definition at line 158 of file InputSource.h.

void edm::InputSource::setTimestamp ( Timestamp const &  theTime)
inlineprotected

To set the current time, as seen by the input source.

Definition at line 348 of file InputSource.h.

Referenced by edm::RawInputSource::RawInputSource().

void InputSource::skip ( int  offset)
protectedvirtual
void InputSource::skipEvents ( int  offset)

Skip the number of events specified. Offset may be negative.

Definition at line 375 of file InputSource.cc.

bool InputSource::skipForForking ( )

Skips the correct number of events if this is a forked process returns false if we are out of events

Definition at line 137 of file InputSource.cc.

ItemType edm::InputSource::state ( ) const
inlineprotected

Definition at line 352 of file InputSource.h.

Referenced by edm::RawInputSource::getNextItemType().

std::shared_ptr<ThinnedAssociationsHelper const> edm::InputSource::thinnedAssociationsHelper ( ) const
inline

Accessors for thinnedAssociationsHelper.

Definition at line 182 of file InputSource.h.

Referenced by edm::RootSecondaryFileSequence::makeRootFile().

std::shared_ptr<ThinnedAssociationsHelper>& edm::InputSource::thinnedAssociationsHelper ( )
inline

Definition at line 183 of file InputSource.h.

Timestamp const& edm::InputSource::timestamp ( ) const
inline

Accessor for the current time, as seen by the input source.

Definition at line 242 of file InputSource.h.

Member Data Documentation

std::shared_ptr<ActivityRegistry> edm::InputSource::actReg_
private

Definition at line 430 of file InputSource.h.

edm::propagate_const<std::shared_ptr<BranchIDListHelper> > edm::InputSource::branchIDListHelper_
private

Definition at line 442 of file InputSource.h.

bool edm::InputSource::eventCached_
private

Definition at line 448 of file InputSource.h.

std::shared_ptr<LuminosityBlockAuxiliary> edm::InputSource::lumiAuxiliary_
mutableprivate

Definition at line 451 of file InputSource.h.

int edm::InputSource::maxEvents_
private

Definition at line 431 of file InputSource.h.

int edm::InputSource::maxLumis_
private

Definition at line 433 of file InputSource.h.

int edm::InputSource::maxSecondsUntilRampdown_
private

Definition at line 436 of file InputSource.h.

ModuleDescription const edm::InputSource::moduleDescription_
private

Definition at line 439 of file InputSource.h.

bool edm::InputSource::newLumi_
mutableprivate

Definition at line 447 of file InputSource.h.

bool edm::InputSource::newRun_
mutableprivate

Definition at line 446 of file InputSource.h.

unsigned int edm::InputSource::numberOfEventsBeforeBigSkip_
private

Definition at line 456 of file InputSource.h.

std::string edm::InputSource::processGUID_
private

Definition at line 444 of file InputSource.h.

edm::propagate_const<std::unique_ptr<ProcessHistoryRegistry> > edm::InputSource::processHistoryRegistry_
private

Definition at line 441 of file InputSource.h.

ProcessingMode edm::InputSource::processingMode_
private

Definition at line 438 of file InputSource.h.

std::chrono::time_point<std::chrono::steady_clock> edm::InputSource::processingStart_
private

Definition at line 437 of file InputSource.h.

edm::propagate_const<std::shared_ptr<ProductRegistry> > edm::InputSource::productRegistry_
private

Definition at line 440 of file InputSource.h.

int edm::InputSource::readCount_
private

Definition at line 435 of file InputSource.h.

edm::propagate_const<std::shared_ptr<edm::multicore::MessageReceiverForSource> > edm::InputSource::receiver_
private

Definition at line 455 of file InputSource.h.

int edm::InputSource::remainingEvents_
private

Definition at line 432 of file InputSource.h.

int edm::InputSource::remainingLumis_
private

Definition at line 434 of file InputSource.h.

std::shared_ptr<RunAuxiliary> edm::InputSource::runAuxiliary_
mutableprivate

Definition at line 450 of file InputSource.h.

ItemType edm::InputSource::state_
mutableprivate

Definition at line 449 of file InputSource.h.

std::string edm::InputSource::statusFileName_
private

Definition at line 452 of file InputSource.h.

edm::propagate_const<std::shared_ptr<ThinnedAssociationsHelper> > edm::InputSource::thinnedAssociationsHelper_
private

Definition at line 443 of file InputSource.h.

Timestamp edm::InputSource::time_
private

Definition at line 445 of file InputSource.h.