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
	~ProducerSourceBase () noexcept(false) override
Public Member Functions inherited from edm::PuttableSourceBase
bool	hasAbilityToProduceInLumis () const final
bool	hasAbilityToProduceInRuns () const final
	PuttableSourceBase (ParameterSet const &, InputSourceDescription const &)
void	registerProducts () final
	Register any produced products. More...
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	doEndJob ()
	Called by framework at end of job. 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, StreamID streamID)
	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
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)
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...
Public Member Functions inherited from edm::ProducerBase
void	callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)
std::vector< edm::ProductResolverIndex > const &	indiciesForPutProducts (BranchType iBranchType) const
	ProducerBase ()
std::vector< edm::ProductResolverIndex > const &	putTokenIndexToProductResolverIndex () const
void	registerProducts (ProducerBase *, ProductRegistry *, ModuleDescription const &)
std::function< void(BranchDescription const &)>	registrationCallback () const
	used by the fwk to register list of products More...
void	resolvePutIndicies (BranchType iBranchType, ModuleToResolverIndicies const &iIndicies, std::string const &moduleLabel)
	~ProducerBase () noexcept(false) override

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)
void	beginJob () override
virtual size_t	fileIndex () const
ItemType	getNextItemType () final
virtual void	initialize (EventID &id, TimeValue_t &time, TimeValue_t &interval)
virtual bool	noFiles () const
virtual void	produce (Event &e)=0
void	readEvent_ (EventPrincipal &eventPrincipal) override
std::shared_ptr< LuminosityBlockAuxiliary >	readLuminosityBlockAuxiliary_ () override
std::shared_ptr< RunAuxiliary >	readRunAuxiliary_ () override
void	retreatToPrevious (EventID &eventID, TimeValue_t &time)
void	rewind_ () override
RunNumber_t	runForLumi (LuminosityBlockNumber_t) const
virtual bool	setRunAndEventInfo (EventID &id, TimeValue_t &time, EventAuxiliary::ExperimentType &etype)=0
void	skip (int offset) override

Private Attributes
EventAuxiliary::ExperimentType	eType_
unsigned int	eventCreationDelay_
EventID	eventID_
std::vector< edm::LuminosityBlockID >	firstLumiForRuns_
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 }
Public Types inherited from edm::ProducerBase
using	ModuleToResolverIndicies = std::unordered_multimap< std::string, std::tuple< edm::TypeID const *, const char *, edm::ProductResolverIndex >>
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::PuttableSourceBase
void	beginJob () override
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 22 of file ProducerSourceBase.h.

Constructor & Destructor Documentation

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

explicit

Definition at line 38 of file ProducerSourceBase.cc.

References eventID_, firstLumiForRuns_, edm::EventID::luminosityBlock(), numberEventsInRun_, presentTime_, runForLumi(), edm::InputSource::setTimestamp(), and zerothEvent_.

      : PuttableSourceBase(pset, desc),
        firstLumiForRuns_(
            pset.getUntrackedParameter<std::vector<edm::LuminosityBlockID>>("firstLuminosityBlockForEachRun")),
        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_));
    checkFirstLumiForRuns(firstLumiForRuns_);
    if (not firstLumiForRuns_.empty()) {
      numberEventsInRun_ = -1;
      eventID_ = EventID(runForLumi(eventID_.luminosityBlock()), eventID_.luminosityBlock(), zerothEvent_);
    }
  }

edm::ProducerSourceBase::~ProducerSourceBase ( )

overridenoexcept

Definition at line 69 of file ProducerSourceBase.cc.

{}

Member Function Documentation

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

private

Definition at line 180 of file ProducerSourceBase.cc.

References edm::EventID::event(), eventID_, firstLumiForRuns_, edm::EventID::luminosityBlock(), edm::EventID::next(), edm::EventID::nextRunFirstEvent(), numberEventsInLumi_, numberEventsInRun_, numberEventsInThisLumi_, numberEventsInThisRun_, origEventID_, run(), edm::EventID::run(), runForLumi(), and timeBetweenEvents_.

Referenced by getNextItemType(), luminosityBlock(), 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;
        if (not firstLumiForRuns_.empty()) {
          auto run = runForLumi(eventID.luminosityBlock());
          if (run != eventID.run()) {
            numberEventsInThisRun_ = 1;
            eventID = eventID.nextRunFirstEvent(eventID_.luminosityBlock());

            eventID = EventID(run, eventID.luminosityBlock(), eventID.event());
          }
        }
      } 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 116 of file ProducerSourceBase.cc.

References edm::PuttableSourceBase::beginJob(), eventID_, initialize(), presentTime_, and timeBetweenEvents_.

Referenced by luminosityBlock().

                                    {
    PuttableSourceBase::beginJob();
    // 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_);
  }

EventNumber_t edm::ProducerSourceBase::event ( ) const

inline

Definition at line 36 of file ProducerSourceBase.h.

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

{ return eventID_.event(); }

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

inline

Definition at line 31 of file ProducerSourceBase.h.

References eventCreationDelay_.

{ return eventCreationDelay_; }

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

inline

Definition at line 34 of file ProducerSourceBase.h.

References eventID_.

Referenced by luminosityBlock(), LHESource::readEvent_(), LHESource::readLuminosityBlockAuxiliary_(), and LHESource::readRunAuxiliary_().

{ return eventID_; }

size_t edm::ProducerSourceBase::fileIndex ( ) const

privatevirtual

Reimplemented in edm::ProducerSourceFromFiles.

Definition at line 255 of file ProducerSourceBase.cc.

Referenced by getNextItemType(), and luminosityBlock().

{ return 0UL; }

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

static

Definition at line 257 of file ProducerSourceBase.cc.

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

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

                                                                        {
    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.");
    desc.addUntracked<std::vector<edm::LuminosityBlockID>>("firstLuminosityBlockForEachRun", {})
        ->setComment(
            "When the source makes a new LuminosityBlock, this list is checked to see what Run number should be used. "
            "The LuminosityBlock numbers are required to be in ascending order.");
    InputSource::fillDescription(desc);
  }

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

finalprivatevirtual

Implements edm::InputSource.

Definition at line 134 of file ProducerSourceBase.cc.

References advanceToNext(), eType_, edm::InputSource::eventCached(), eventCreationDelay_, eventID_, fileIndex(), 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().

Referenced by luminosityBlock().

                                                          {
    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 123 of file ProducerSourceBase.cc.

Referenced by beginJob(), and luminosityBlock().

{}

LuminosityBlockNumber_t edm::ProducerSourceBase::luminosityBlock ( ) const

inline

Definition at line 37 of file ProducerSourceBase.h.

References advanceToNext(), beginJob(), MillePedeFileConverter_cfg::e, eventID(), eventID_, fileIndex(), fillDescription(), getNextItemType(), initialize(), edm::EventID::luminosityBlock(), noFiles(), PFRecoTauDiscriminationByIsolation_cfi::offset, produce(), readEvent_(), readLuminosityBlockAuxiliary_(), readRunAuxiliary_(), retreatToPrevious(), rewind_(), runForLumi(), setRunAndEventInfo(), skip(), and ntuplemaker::time.

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 253 of file ProducerSourceBase.cc.

Referenced by getNextItemType(), and luminosityBlock().

{ return false; }

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

inline

Definition at line 28 of file ProducerSourceBase.h.

References numberEventsInLumi_.

{ return numberEventsInLumi_; }

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

inline

Definition at line 27 of file ProducerSourceBase.h.

References numberEventsInRun_.

{ return numberEventsInRun_; }

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

inline

Definition at line 33 of file ProducerSourceBase.h.

References numberEventsInThisLumi_.

{ return numberEventsInThisLumi_; }

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

inline

Definition at line 32 of file ProducerSourceBase.h.

References numberEventsInThisRun_.

{ return numberEventsInThisRun_; }

TimeValue_t edm::ProducerSourceBase::presentTime ( ) const

inline

Definition at line 29 of file ProducerSourceBase.h.

References presentTime_.

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

{ return presentTime_; }

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

privatepure virtual

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

Referenced by luminosityBlock(), and readEvent_().

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

overrideprivatevirtual

Implements edm::InputSource.

Reimplemented in LHESource.

Definition at line 86 of file ProducerSourceBase.cc.

References printConversionInfo::aux, edm::Event::commit_(), MillePedeFileConverter_cfg::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(), edm::InputSource::RunsLumisAndEvents, and edm::Event::setProducer().

Referenced by luminosityBlock().

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

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

overrideprivatevirtual

Implements edm::InputSource.

Reimplemented in LHESource.

Definition at line 77 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.

Referenced by luminosityBlock().

                                                                                            {
    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.

Reimplemented in LHESource.

Definition at line 71 of file ProducerSourceBase.cc.

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

Referenced by luminosityBlock().

                                                                    {
    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 210 of file ProducerSourceBase.cc.

References edm::EventID::event(), eventID_, firstLumiForRuns_, edm::EventID::luminosityBlock(), numberEventsInLumi_, numberEventsInRun_, numberEventsInThisLumi_, numberEventsInThisRun_, origEventID_, edm::EventID::previous(), edm::EventID::previousRunLastEvent(), run(), edm::EventID::run(), runForLumi(), and timeBetweenEvents_.

Referenced by luminosityBlock(), and 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_;

        if (not firstLumiForRuns_.empty()) {
          auto run = runForLumi(eventID.luminosityBlock());
          if (run != eventID.run()) {
            eventID = eventID.previousRunLastEvent(eventID_.luminosityBlock());

            eventID = EventID(run, eventID.luminosityBlock(), eventID.event());
          }
        }
      } 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 125 of file ProducerSourceBase.cc.

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

Referenced by luminosityBlock().

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

RunNumber_t edm::ProducerSourceBase::run ( ) const

inline

Definition at line 35 of file ProducerSourceBase.h.

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

Referenced by advanceToNext(), retreatToPrevious(), and PixelSLinkDataInputSource::setRunAndEventInfo().

{ return eventID_.run(); }

RunNumber_t edm::ProducerSourceBase::runForLumi ( LuminosityBlockNumber_t  iLumi ) const

private

Definition at line 242 of file ProducerSourceBase.cc.

References firstLumiForRuns_.

Referenced by advanceToNext(), luminosityBlock(), ProducerSourceBase(), and retreatToPrevious().

                                                                                {
    auto it = std::find_if(firstLumiForRuns_.rbegin(), firstLumiForRuns_.rend(), [iLumi](auto const& iV) {
      return iV.luminosityBlock() <= iLumi;
    });
    if (it == firstLumiForRuns_.rend()) {
      //use first since we are off the end
      return firstLumiForRuns_[0].run();
    }
    return it->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(), and luminosityBlock().

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

overrideprivatevirtual

Reimplemented from edm::InputSource.

Definition at line 97 of file ProducerSourceBase.cc.

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

Referenced by luminosityBlock().

                                          {
    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 30 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 advanceToNext(), beginJob(), event(), eventID(), getNextItemType(), luminosityBlock(), ProducerSourceBase(), readEvent_(), readLuminosityBlockAuxiliary_(), readRunAuxiliary_(), retreatToPrevious(), rewind_(), run(), and skip().

std::vector<edm::LuminosityBlockID> edm::ProducerSourceBase::firstLumiForRuns_

private

Definition at line 61 of file ProducerSourceBase.h.

Referenced by advanceToNext(), ProducerSourceBase(), retreatToPrevious(), and runForLumi().

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(), ProducerSourceBase(), 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.

Referenced by ProducerSourceBase().