edm::ProducerSourceBase Class Reference

#include <ProducerSourceBase.h>

Inheritance diagram for edm::ProducerSourceBase:

Public Member Functions
EventNumber_t	event () const
unsigned int	eventCreationDelay () const
EventID const &	eventID () const
LuminosityBlockNumber_t	luminosityBlock () const
unsigned int	numberEventsInLumi () const
unsigned int	numberEventsInRun () const
unsigned int	numberEventsInThisLumi () const
unsigned int	numberEventsInThisRun () const
TimeValue_t	presentTime () const
	ProducerSourceBase (ParameterSet const &pset, InputSourceDescription const &desc, bool realData)
RunNumber_t	run () const
unsigned int	timeBetweenEvents () const
virtual	~ProducerSourceBase () noexcept(false)
Public Member Functions inherited from edm::InputSource
std::shared_ptr< ActivityRegistry >	actReg () 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...
InputSource &	operator= (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...
ProcessHistoryRegistry &	processHistoryRegistry ()
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< 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...
std::pair < SharedResourcesAcquirer *, std::recursive_mutex * >	resourceSharedWithDelayedReader ()
	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 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 () noexcept(false)
	Destructor. More...

Static Public Member Functions
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 &)

Private Member Functions
void	advanceToNext (EventID &eventID, TimeValue_t &time)
virtual void	beginJob () override
virtual void	beginLuminosityBlock (LuminosityBlock &) override
virtual void	beginRun (Run &) override
virtual void	endLuminosityBlock (LuminosityBlock &) override
virtual void	endRun (Run &) override
virtual size_t	fileIndex () const
virtual ItemType	getNextItemType () overridefinal
virtual void	initialize (EventID &id, TimeValue_t &time, TimeValue_t &interval)
virtual bool	noFiles () const
virtual void	produce (Event &e)=0
virtual void	readEvent_ (EventPrincipal &eventPrincipal) override
virtual std::shared_ptr < LuminosityBlockAuxiliary >	readLuminosityBlockAuxiliary_ () override
virtual std::shared_ptr < RunAuxiliary >	readRunAuxiliary_ () override
void	retreatToPrevious (EventID &eventID, TimeValue_t &time)
virtual void	rewind_ () override
virtual bool	setRunAndEventInfo (EventID &id, TimeValue_t &time, EventAuxiliary::ExperimentType &etype)=0
virtual void	skip (int offset) override

Private Attributes
EventAuxiliary::ExperimentType	eType_
unsigned int	eventCreationDelay_
EventID	eventID_
bool	isRealData_
unsigned int	numberEventsInLumi_
unsigned int	numberEventsInRun_
unsigned int	numberEventsInThisLumi_
unsigned int	numberEventsInThisRun_
EventID	origEventID_
TimeValue_t	origTime_
TimeValue_t	presentTime_
TimeValue_t	timeBetweenEvents_
EventNumber_t const	zerothEvent_

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
Public Attributes inherited from edm::InputSource
signalslot::Signal< void(StreamContext const &, ModuleCallingContext const &)>	postEventReadFromSourceSignal_
signalslot::Signal< void(StreamContext const &, ModuleCallingContext const &)>	preEventReadFromSourceSignal_
Protected Member Functions inherited from edm::InputSource
void	decreaseRemainingEventsBy (int iSkipped)
bool	eventCached () const
bool	newLumi () const
bool	newRun () const
ProcessHistoryRegistry &	processHistoryRegistryForUpdate ()
ProductRegistry &	productRegistryUpdate ()
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...
ItemType	state () const

Detailed Description

Definition at line 20 of file ProducerSourceBase.h.

Constructor & Destructor Documentation

edm::ProducerSourceBase::ProducerSourceBase ( ParameterSet const &  pset, InputSourceDescription const &  desc, bool  realData  )

explicit

Definition at line 19 of file ProducerSourceBase.cc.

References presentTime_, and edm::InputSource::setTimestamp().

                                                                          :
      InputSource(pset, desc),
      numberEventsInRun_(pset.getUntrackedParameter<unsigned int>("numberEventsInRun", remainingEvents())),
      numberEventsInLumi_(pset.getUntrackedParameter<unsigned int>("numberEventsInLuminosityBlock", remainingEvents())),
      presentTime_(pset.getUntrackedParameter<unsigned long long>("firstTime", 1ULL)),  //time in ns
      origTime_(presentTime_),
      timeBetweenEvents_(pset.getUntrackedParameter<unsigned long long>("timeBetweenEvents", kNanoSecPerSec/kAveEventPerSec)),
      eventCreationDelay_(pset.getUntrackedParameter<unsigned int>("eventCreationDelay", 0)),
      numberEventsInThisRun_(0),
      numberEventsInThisLumi_(0),
      zerothEvent_(pset.existsAs<unsigned int>("firstEvent", false) ? pset.getUntrackedParameter<unsigned int>("firstEvent", 1) - 1 :
                                                                      pset.getUntrackedParameter<unsigned long long>("firstEvent", 1) - 1),
      eventID_(pset.getUntrackedParameter<unsigned int>("firstRun", 1), pset.getUntrackedParameter<unsigned int>("firstLuminosityBlock", 1), zerothEvent_),
      origEventID_(eventID_),
      isRealData_(realData),
      eType_(EventAuxiliary::Undefined) {

    setTimestamp(Timestamp(presentTime_));
    // We need to map this string to the EventAuxiliary::ExperimentType enumeration
    // std::string eType = pset.getUntrackedParameter<std::string>("experimentType", std::string("Any"))),
  }

edm::ProducerSourceBase::~ProducerSourceBase ( )

virtualnoexcept

Definition at line 42 of file ProducerSourceBase.cc.

                                                          {
  }

Member Function Documentation

void edm::ProducerSourceBase::advanceToNext ( EventID &  eventID, TimeValue_t &  time  )

private

Definition at line 174 of file ProducerSourceBase.cc.

References edm::EventID::luminosityBlock(), edm::EventID::next(), edm::EventID::nextRunFirstEvent(), numberEventsInLumi_, numberEventsInRun_, numberEventsInThisLumi_, numberEventsInThisRun_, origEventID_, and timeBetweenEvents_.

Referenced by getNextItemType(), and skip().

                                                                        {
    if (numberEventsInRun_ < 1 || numberEventsInThisRun_ < numberEventsInRun_) {
      // same run
      ++numberEventsInThisRun_;
      if (!(numberEventsInLumi_ < 1 || numberEventsInThisLumi_ < numberEventsInLumi_)) {
        // new lumi
        eventID = eventID.next(eventID.luminosityBlock() + 1);
        numberEventsInThisLumi_ = 1;
      } else {
        eventID = eventID.next(eventID.luminosityBlock());
        ++numberEventsInThisLumi_;
      }
    } else {
      // new run
      eventID = eventID.nextRunFirstEvent(origEventID_.luminosityBlock());
      numberEventsInThisLumi_ = 1;
      numberEventsInThisRun_ = 1;
    }
    time += timeBetweenEvents_;
  }

void edm::ProducerSourceBase::beginJob ( void  )

overrideprivatevirtual

Reimplemented from edm::InputSource.

Definition at line 92 of file ProducerSourceBase.cc.

References eventID_, initialize(), presentTime_, and timeBetweenEvents_.

                               {
    // initialize cannot be called from the constructor, because it is a virtual function
    // that needs to be invoked from a derived class if the derived class overrides it.
    initialize(eventID_, presentTime_, timeBetweenEvents_);
  }

void edm::ProducerSourceBase::beginLuminosityBlock ( LuminosityBlock &  )

overrideprivatevirtual

Reimplemented from edm::InputSource.

Reimplemented in FRDStreamSource.

Definition at line 107 of file ProducerSourceBase.cc.

                                                           {
  }

void edm::ProducerSourceBase::beginRun ( Run &  )

overrideprivatevirtual

Reimplemented from edm::InputSource.

Reimplemented in MCatNLOSource, AlpgenSource, LHESource, and FRDStreamSource.

Definition at line 99 of file ProducerSourceBase.cc.

                                   {
  }

void edm::ProducerSourceBase::endLuminosityBlock ( LuminosityBlock &  )

overrideprivatevirtual

Reimplemented from edm::InputSource.

Reimplemented in FRDStreamSource.

Definition at line 111 of file ProducerSourceBase.cc.

                                                         {
  }

void edm::ProducerSourceBase::endRun ( Run &  )

overrideprivatevirtual

Reimplemented from edm::InputSource.

Reimplemented in LHESource, and FRDStreamSource.

Definition at line 103 of file ProducerSourceBase.cc.

                                 {
  }

EventNumber_t edm::ProducerSourceBase::event ( ) const

inline

Definition at line 34 of file ProducerSourceBase.h.

References edm::EventID::event(), and eventID_.

Referenced by FRDStreamSource::setRunAndEventInfo().

{return eventID_.event();}

unsigned int edm::ProducerSourceBase::eventCreationDelay ( ) const

inline

Definition at line 29 of file ProducerSourceBase.h.

References eventCreationDelay_.

{return eventCreationDelay_;}

EventID const& edm::ProducerSourceBase::eventID ( ) const

inline

Definition at line 32 of file ProducerSourceBase.h.

References eventID_.

Referenced by LHESource::readEvent_().

{return eventID_;}

size_t edm::ProducerSourceBase::fileIndex ( ) const

privatevirtual

Definition at line 225 of file ProducerSourceBase.cc.

Referenced by getNextItemType().

                                      {
    return 0UL;
  }

void edm::ProducerSourceBase::fillDescription ( ParameterSetDescription &  desc )

static

Definition at line 230 of file ProducerSourceBase.cc.

References edm::ParameterSetDescription::addNode(), edm::ParameterSetDescription::addOptionalUntracked(), edm::ParameterSetDescription::addUntracked(), edm::InputSource::fillDescription(), edm::kAveEventPerSec, edm::kNanoSecPerSec, and edm::ParameterDescriptionNode::setComment().

Referenced by edm::ProducerSourceFromFiles::fillDescription(), edm::EmptySource::fillDescriptions(), and dqmservices::DQMProtobufReader::fillDescriptions().

                                                                   {
    desc.addOptionalUntracked<unsigned int>("numberEventsInRun")->setComment("Number of events to generate in each run.");
    desc.addOptionalUntracked<unsigned int>("numberEventsInLuminosityBlock")->setComment("Number of events to generate in each lumi.");
    desc.addUntracked<unsigned long long>("firstTime", 1)->setComment("Time before first event (ns) (for timestamp).");
    desc.addUntracked<unsigned long long>("timeBetweenEvents", kNanoSecPerSec/kAveEventPerSec)->setComment("Time between consecutive events (ns) (for timestamp).");
    desc.addUntracked<unsigned int>("eventCreationDelay", 0)->setComment("Real time delay between generation of consecutive events (ms).");

    desc.addNode( edm::ParameterDescription<unsigned int>("firstEvent", 1U, false) xor
                  edm::ParameterDescription<unsigned long long>("firstEvent", 1ULL, false))
        ->setComment("'firstEvent' is an XOR group because it can have type uint32 or uint64, default:1\n"
                     "Event number of first event to generate.");

    desc.addUntracked<unsigned int>("firstLuminosityBlock", 1)->setComment("Luminosity block number of first lumi to generate.");
    desc.addUntracked<unsigned int>("firstRun", 1)->setComment("Run number of first run to generate.");
    InputSource::fillDescription(desc);
  }

InputSource::ItemType edm::ProducerSourceBase::getNextItemType ( )

finaloverrideprivatevirtual

Implements edm::InputSource.

Definition at line 129 of file ProducerSourceBase.cc.

References advanceToNext(), eType_, edm::InputSource::eventCached(), eventCreationDelay_, eventID_, fileIndex(), cmsHarvester::index, edm::InputSource::IsEvent, edm::InputSource::IsFile, edm::InputSource::IsInvalid, edm::InputSource::IsLumi, edm::InputSource::IsRun, edm::InputSource::IsStop, edm::EventID::luminosityBlock(), edm::InputSource::newLumi(), edm::InputSource::newRun(), noFiles(), presentTime_, edm::InputSource::processingMode(), edm::EventID::run(), edm::InputSource::Runs, edm::InputSource::RunsAndLumis, edm::InputSource::setEventCached(), edm::InputSource::setNewLumi(), edm::InputSource::setNewRun(), setRunAndEventInfo(), and edm::InputSource::state().

                                      {
    if(state() == IsInvalid) {
      return noFiles() ? IsStop : IsFile;
    }
    if (newRun()) {
      return IsRun;
    }
    if (newLumi()) {
      return IsLumi;
    }
    if(eventCached()) {
      return IsEvent;
    }
    EventID oldEventID = eventID_;
    advanceToNext(eventID_, presentTime_);
    if (eventCreationDelay_ > 0) {usleep(eventCreationDelay_);}
    size_t index = fileIndex();
    bool another = setRunAndEventInfo(eventID_, presentTime_, eType_);
    if(!another) {
      return IsStop;
    }
    bool newFile = (fileIndex() > index);
    setEventCached();
    if(newRun() || eventID_.run() != oldEventID.run()) {
      // New Run
      setNewRun();
      setNewLumi();
      return newFile ? IsFile : IsRun;
    }
    if (processingMode() == Runs) {
      return newFile ? IsFile : IsRun;
    }
    if (processingMode() == RunsAndLumis) {
      return newFile ? IsFile : IsLumi;
    }
    // Same Run
    if (newLumi() || eventID_.luminosityBlock() != oldEventID.luminosityBlock()) {
      // New Lumi
      setNewLumi();
      return newFile ? IsFile : IsLumi;
    }
    return newFile ? IsFile : IsEvent;
  }

void edm::ProducerSourceBase::initialize ( EventID &  id, TimeValue_t &  time, TimeValue_t &  interval  )

privatevirtual

Reimplemented in cond::EmptyIOVSource.

Definition at line 115 of file ProducerSourceBase.cc.

Referenced by beginJob().

                                                                     {
  }

LuminosityBlockNumber_t edm::ProducerSourceBase::luminosityBlock ( ) const

inline

Definition at line 35 of file ProducerSourceBase.h.

References eventID_, and edm::EventID::luminosityBlock().

Referenced by cond::EmptyIOVSource::initialize(), cond::EmptyIOVSource::setRunAndEventInfo(), HcalTBSource::setRunAndEventInfo(), and PixelSLinkDataInputSource::setRunAndEventInfo().

{return eventID_.luminosityBlock();}

bool edm::ProducerSourceBase::noFiles ( ) const

privatevirtual

Reimplemented in edm::ProducerSourceFromFiles.

Definition at line 220 of file ProducerSourceBase.cc.

Referenced by getNextItemType().

                                    {
    return false;
  }

unsigned int edm::ProducerSourceBase::numberEventsInLumi ( ) const

inline

Definition at line 26 of file ProducerSourceBase.h.

References numberEventsInLumi_.

{return numberEventsInLumi_;} 

unsigned int edm::ProducerSourceBase::numberEventsInRun ( ) const

inline

Definition at line 25 of file ProducerSourceBase.h.

References numberEventsInRun_.

{return numberEventsInRun_;} 

unsigned int edm::ProducerSourceBase::numberEventsInThisLumi ( ) const

inline

Definition at line 31 of file ProducerSourceBase.h.

References numberEventsInThisLumi_.

{return numberEventsInThisLumi_;}

unsigned int edm::ProducerSourceBase::numberEventsInThisRun ( ) const

inline

Definition at line 30 of file ProducerSourceBase.h.

References numberEventsInThisRun_.

{return numberEventsInThisRun_;}

TimeValue_t edm::ProducerSourceBase::presentTime ( ) const

inline

Definition at line 27 of file ProducerSourceBase.h.

References presentTime_.

Referenced by LHESource::readEvent_(), and HcalTBSource::setRunAndEventInfo().

{return presentTime_;}

virtual void edm::ProducerSourceBase::produce ( Event &  e )

privatepure virtual

Implemented in MCatNLOSource, L1MuGMTHWFileReader, PixelSLinkDataInputSource, LHESource, AlpgenSource, edm::MCFileSource, FRDStreamSource, LmfSource, HcalTBSource, edm::EmptySource, and cond::EmptyIOVSource.

Referenced by readEvent_().

void edm::ProducerSourceBase::readEvent_ ( EventPrincipal &  eventPrincipal )

overrideprivatevirtual

Implements edm::InputSource.

Reimplemented in LHESource.

Definition at line 61 of file ProducerSourceBase.cc.

References assert(), printConversionInfo::aux, edm::Event::commit_(), alignCSCRings::e, eType_, edm::InputSource::eventCached(), eventID_, edm::EventPrincipal::fillEventPrincipal(), isRealData_, edm::InputSource::moduleDescription(), presentTime_, edm::InputSource::processGUID(), edm::InputSource::processHistoryRegistry(), edm::InputSource::processingMode(), produce(), edm::InputSource::resetEventCached(), and edm::InputSource::RunsLumisAndEvents.

                                                               {
    assert(eventCached() || processingMode() != RunsLumisAndEvents);
    EventAuxiliary aux(eventID_, processGUID(), Timestamp(presentTime_), isRealData_, eType_);
    eventPrincipal.fillEventPrincipal(aux, processHistoryRegistry());
    Event e(eventPrincipal, moduleDescription(), nullptr);
    produce(e);
    e.commit_(std::vector<ProductResolverIndex>());
    resetEventCached();
  }

std::shared_ptr< LuminosityBlockAuxiliary > edm::ProducerSourceBase::readLuminosityBlockAuxiliary_ ( )

overrideprivatevirtual

Implements edm::InputSource.

Definition at line 53 of file ProducerSourceBase.cc.

References eventID_, edm::Timestamp::invalidTimestamp(), edm::EventID::luminosityBlock(), presentTime_, edm::InputSource::processingMode(), edm::InputSource::resetNewLumi(), edm::EventID::run(), and edm::InputSource::Runs.

                                                    {
    if (processingMode() == Runs) return std::shared_ptr<LuminosityBlockAuxiliary>();
    Timestamp ts = Timestamp(presentTime_);
    resetNewLumi();
    return std::make_shared<LuminosityBlockAuxiliary>(eventID_.run(), eventID_.luminosityBlock(), ts, Timestamp::invalidTimestamp());
  }

std::shared_ptr< RunAuxiliary > edm::ProducerSourceBase::readRunAuxiliary_ ( )

overrideprivatevirtual

Implements edm::InputSource.

Definition at line 46 of file ProducerSourceBase.cc.

References eventID_, edm::Timestamp::invalidTimestamp(), presentTime_, edm::InputSource::resetNewRun(), and edm::EventID::run().

                                        {
    Timestamp ts = Timestamp(presentTime_);
    resetNewRun();
    return std::make_shared<RunAuxiliary>(eventID_.run(), ts, Timestamp::invalidTimestamp());
  }

void edm::ProducerSourceBase::retreatToPrevious ( EventID &  eventID, TimeValue_t &  time  )

private

Definition at line 196 of file ProducerSourceBase.cc.

References assert(), edm::EventID::luminosityBlock(), numberEventsInLumi_, numberEventsInRun_, numberEventsInThisLumi_, numberEventsInThisRun_, origEventID_, edm::EventID::previous(), edm::EventID::previousRunLastEvent(), edm::EventID::run(), and timeBetweenEvents_.

Referenced by skip().

                                                                            {
    if (numberEventsInRun_ < 1 || numberEventsInThisRun_ > 0) {
      // same run
      --numberEventsInThisRun_;
      eventID = eventID.previous(eventID.luminosityBlock());
      if (!(numberEventsInLumi_ < 1 || numberEventsInThisLumi_ > 0)) {
        // new lumi
        eventID = eventID.previous(eventID.luminosityBlock() - 1);
        numberEventsInThisLumi_ = numberEventsInLumi_;
      } else {
        --numberEventsInThisLumi_;
      }
    } else {
      // new run
      assert(numberEventsInLumi_ != 0);
      eventID = eventID.previousRunLastEvent(origEventID_.luminosityBlock() + numberEventsInRun_/numberEventsInLumi_);
      eventID = EventID(numberEventsInRun_, eventID.luminosityBlock(), eventID.run());
      numberEventsInThisLumi_ = numberEventsInLumi_;
      numberEventsInThisRun_ = numberEventsInRun_;
    }
    time -= timeBetweenEvents_;
  }

void edm::ProducerSourceBase::rewind_ ( )

overrideprivatevirtual

Reimplemented from edm::InputSource.

Definition at line 119 of file ProducerSourceBase.cc.

References eventID_, numberEventsInThisLumi_, numberEventsInThisRun_, origEventID_, origTime_, presentTime_, edm::InputSource::setNewLumi(), and edm::InputSource::setNewRun().

                              {
    presentTime_ = origTime_;
    eventID_ = origEventID_;
    numberEventsInThisRun_ = 0;
    numberEventsInThisLumi_ = 0;
    setNewRun();
    setNewLumi();
  }

RunNumber_t edm::ProducerSourceBase::run ( void  ) const

inline

Definition at line 33 of file ProducerSourceBase.h.

References eventID_, and edm::EventID::run().

Referenced by PixelSLinkDataInputSource::setRunAndEventInfo().

{return eventID_.run();}

virtual bool edm::ProducerSourceBase::setRunAndEventInfo ( EventID &  id, TimeValue_t &  time, EventAuxiliary::ExperimentType &  etype  )

privatepure virtual

Implemented in MCatNLOSource, L1MuGMTHWFileReader, PixelSLinkDataInputSource, LHESource, AlpgenSource, LmfSource, edm::MCFileSource, FRDStreamSource, HcalTBSource, edm::EmptySource, and cond::EmptyIOVSource.

Referenced by getNextItemType().

void edm::ProducerSourceBase::skip ( int  offset )

overrideprivatevirtual

Reimplemented from edm::InputSource.

Definition at line 72 of file ProducerSourceBase.cc.

References advanceToNext(), eventID_, edm::EventID::luminosityBlock(), hltrates_dqm_sourceclient-live_cfg::offset, presentTime_, retreatToPrevious(), edm::EventID::run(), edm::InputSource::setNewLumi(), and edm::InputSource::setNewRun().

                                     {
    EventID oldEventID = eventID_;
    for(; offset < 0; ++offset) {
      retreatToPrevious(eventID_, presentTime_);
    }
    for(; offset > 0; --offset) {
      advanceToNext(eventID_, presentTime_);
    }
    if(eventID_.run() != oldEventID.run()) {
      // New Run
      setNewRun();
      setNewLumi();
    }
    if (eventID_.luminosityBlock() != oldEventID.luminosityBlock()) {
      // New Lumi
      setNewLumi();
    }
  }

unsigned int edm::ProducerSourceBase::timeBetweenEvents ( ) const

inline

Definition at line 28 of file ProducerSourceBase.h.

References timeBetweenEvents_.

Referenced by HcalTBSource::setRunAndEventInfo().

{return timeBetweenEvents_;}

Member Data Documentation

EventAuxiliary::ExperimentType edm::ProducerSourceBase::eType_

private

Definition at line 75 of file ProducerSourceBase.h.

Referenced by getNextItemType(), and readEvent_().

unsigned int edm::ProducerSourceBase::eventCreationDelay_

private

Definition at line 67 of file ProducerSourceBase.h.

Referenced by eventCreationDelay(), and getNextItemType().

EventID edm::ProducerSourceBase::eventID_

private

Definition at line 72 of file ProducerSourceBase.h.

Referenced by beginJob(), event(), eventID(), getNextItemType(), luminosityBlock(), readEvent_(), readLuminosityBlockAuxiliary_(), readRunAuxiliary_(), rewind_(), run(), and skip().

bool edm::ProducerSourceBase::isRealData_

private

Definition at line 74 of file ProducerSourceBase.h.

Referenced by readEvent_().

unsigned int edm::ProducerSourceBase::numberEventsInLumi_

private

Definition at line 63 of file ProducerSourceBase.h.

Referenced by advanceToNext(), numberEventsInLumi(), and retreatToPrevious().

unsigned int edm::ProducerSourceBase::numberEventsInRun_

private

Definition at line 62 of file ProducerSourceBase.h.

Referenced by advanceToNext(), numberEventsInRun(), and retreatToPrevious().

unsigned int edm::ProducerSourceBase::numberEventsInThisLumi_

private

Definition at line 70 of file ProducerSourceBase.h.

Referenced by advanceToNext(), numberEventsInThisLumi(), retreatToPrevious(), and rewind_().

unsigned int edm::ProducerSourceBase::numberEventsInThisRun_

private

Definition at line 69 of file ProducerSourceBase.h.

Referenced by advanceToNext(), numberEventsInThisRun(), retreatToPrevious(), and rewind_().

EventID edm::ProducerSourceBase::origEventID_

private

Definition at line 73 of file ProducerSourceBase.h.

Referenced by advanceToNext(), retreatToPrevious(), and rewind_().

TimeValue_t edm::ProducerSourceBase::origTime_

private

Definition at line 65 of file ProducerSourceBase.h.

Referenced by rewind_().

TimeValue_t edm::ProducerSourceBase::presentTime_

private

Definition at line 64 of file ProducerSourceBase.h.

Referenced by beginJob(), getNextItemType(), presentTime(), ProducerSourceBase(), readEvent_(), readLuminosityBlockAuxiliary_(), readRunAuxiliary_(), rewind_(), and skip().

TimeValue_t edm::ProducerSourceBase::timeBetweenEvents_

private

Definition at line 66 of file ProducerSourceBase.h.

Referenced by advanceToNext(), beginJob(), retreatToPrevious(), and timeBetweenEvents().

EventNumber_t const edm::ProducerSourceBase::zerothEvent_

private

Definition at line 71 of file ProducerSourceBase.h.