#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 ()

Public Member Functions inherited from edm::InputSource
boost::shared_ptr < ActivityRegistry >	actReg () const
	Accessor for Activity Registry. More...

boost::shared_ptr < BranchIDListHelper >	branchIDListHelper () const
	Accessor for branchIDListHelper. More...

void	closeFile (FileBlock *, bool cleaningUpAfterException)
	close current file More...

void	doBeginJob ()
	Called by framework at beginning of job. More...

void	doBeginLumi (LuminosityBlockPrincipal &lbp, 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 (boost::shared_ptr< multicore::MessageReceiverForSource >)

void	doPreForkReleaseResources ()
	Called by the framework before forking the process. More...

ProcessingController::ForwardState	forwardState () const

bool	goToEvent (EventID const &eventID)

	InputSource (ParameterSet const &, InputSourceDescription const &)
	Constructor. More...

	InputSource (InputSource const &)=delete

void	issueReports (EventID const &eventID)
	issue an event report More...

LuminosityBlockNumber_t	luminosityBlock () const
	Accessor for current luminosity block number. More...

boost::shared_ptr < LuminosityBlockAuxiliary >	luminosityBlockAuxiliary () const
	Called by the framework to merge or insert lumi in principal cache. More...

int	maxEvents () const

int	maxLuminosityBlocks () const

ModuleDescription const &	moduleDescription () const
	Accessor for 'module' description. More...

ItemType	nextItemType ()
	Advances the source to the next item. More...

InputSource &	operator= (InputSource const &)=delete

bool	primary () const
	Accessor for primary input source flag. More...

ProcessConfiguration const &	processConfiguration () const
	Accessor for Process Configuration. More...

std::string const &	processGUID () const
	Accessor for global process identifier. More...

ProcessHistoryRegistry const &	processHistoryRegistry () const
	Const accessor for process history registry. More...

ProcessHistoryRegistry &	processHistoryRegistryForUpdate ()
	Non-const accessor for process history registry. More...

ProcessingMode	processingMode () const
	RunsLumisAndEvents (default), RunsAndLumis, or Runs. More...

boost::shared_ptr < ProductRegistry const >	productRegistry () const
	Accessor for product registry. More...

bool	randomAccess () const

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

boost::shared_ptr < LuminosityBlockAuxiliary >	readLuminosityBlockAuxiliary ()
	Read next luminosity block Auxilary. More...

void	readRun (RunPrincipal &runPrincipal, HistoryAppender &historyAppender)
	Read next run (new run) More...

boost::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...

SharedResourcesAcquirer *	resourceSharedWithDelayedReader () const
	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...

boost::shared_ptr< RunAuxiliary >	runAuxiliary () const
	Called by the framework to merge or insert run in principal cache. More...

void	setLuminosityBlockNumber_t (LuminosityBlockNumber_t lb)
	Set the luminosity block ID. More...

void	setRunNumber (RunNumber_t r)
	Set the run number. More...

void	skipEvents (int offset)

bool	skipForForking ()

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 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 () override

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 boost::shared_ptr < LuminosityBlockAuxiliary >	readLuminosityBlockAuxiliary_ () override

virtual boost::shared_ptr < RunAuxiliary >	readRunAuxiliary_ () override

void	retreatToPrevious (EventID &eventID, TimeValue_t &time)

virtual void	rewind_ () override

virtual bool	setRunAndEventInfo (EventID &id, TimeValue_t &time)=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_

unsigned int 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

Protected Member Functions inherited from edm::InputSource
void	decreaseRemainingEventsBy (int iSkipped)

bool	eventCached () const

boost::shared_ptr < LuminosityBlockPrincipal > const	luminosityBlockPrincipal () const

bool	newLumi () const

bool	newRun () const

ProcessHistoryRegistry &	processHistoryRegistryUpdate () const

ProductRegistry &	productRegistryUpdate () const

void	reset () const

void	resetEventCached ()

void	resetLuminosityBlockAuxiliary (bool isNewLumi=true) const

void	resetNewLumi ()

void	resetNewRun ()

void	resetRunAuxiliary (bool isNewRun=true) const

boost::shared_ptr < RunPrincipal > const	runPrincipal () const

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

void	setLuminosityBlockAuxiliary (LuminosityBlockAuxiliary *lbp)

void	setNewLumi ()

void	setNewRun ()

void	setRunAuxiliary (RunAuxiliary *rp)

void	setTimestamp (Timestamp const &theTime)
	To set the current time, as seen by the input source. More...

ItemType	state () const

Detailed Description

Definition at line 19 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.getUntrackedParameter<unsigned int>("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 ( )

virtual

Definition at line 41 of file ProducerSourceBase.cc.

41 {

42 }

Member Function Documentation

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

private

Definition at line 173 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 91 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 106 of file ProducerSourceBase.cc.

106 {

107 }

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

overrideprivatevirtual

Reimplemented from edm::InputSource.

Reimplemented in MCatNLOSource, AlpgenSource, LHESource, and FRDStreamSource.

Definition at line 98 of file ProducerSourceBase.cc.

98 {

99 }

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

overrideprivatevirtual

Reimplemented from edm::InputSource.

Reimplemented in FRDStreamSource.

Definition at line 110 of file ProducerSourceBase.cc.

110 {

111 }

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

overrideprivatevirtual

Reimplemented from edm::InputSource.

Reimplemented in LHESource, and FRDStreamSource.

Definition at line 102 of file ProducerSourceBase.cc.

102 {

103 }

EventNumber_t edm::ProducerSourceBase::event ( ) const

inline

Definition at line 33 of file ProducerSourceBase.h.

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

Referenced by FRDStreamSource::setRunAndEventInfo().

33 {return eventID_.event();}

edm::EventID::event

EventNumber_t event() const

Definition: EventID.h:44

edm::ProducerSourceBase::eventID_

EventID eventID_

Definition: ProducerSourceBase.h:71

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

inline

Definition at line 28 of file ProducerSourceBase.h.

References eventCreationDelay_.

28 {return eventCreationDelay_;}

edm::ProducerSourceBase::eventCreationDelay_

unsigned int eventCreationDelay_

Definition: ProducerSourceBase.h:66

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

inline

Definition at line 31 of file ProducerSourceBase.h.

References eventID_.

Referenced by LHESource::readEvent_().

31 {return eventID_;}

edm::ProducerSourceBase::eventID_

EventID eventID_

Definition: ProducerSourceBase.h:71

size_t edm::ProducerSourceBase::fileIndex ( ) const

privatevirtual

Definition at line 223 of file ProducerSourceBase.cc.

Referenced by getNextItemType().

                                       {
     return 0UL;
   }

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

static

Definition at line 228 of file ProducerSourceBase.cc.

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

Referenced by edm::ProducerSourceFromFiles::fillDescription(), edm::EmptySource::fillDescriptions(), and edm::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.addUntracked<unsigned int>("firstEvent", 1)->setComment("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 ( )

overrideprivatevirtual

Implements edm::InputSource.

Definition at line 128 of file ProducerSourceBase.cc.

References advanceToNext(), 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_);
     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 114 of file ProducerSourceBase.cc.

Referenced by beginJob().

114 {

115 }

LuminosityBlockNumber_t edm::ProducerSourceBase::luminosityBlock ( ) const

inline

Definition at line 34 of file ProducerSourceBase.h.

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

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

34 {return eventID_.luminosityBlock();}

edm::ProducerSourceBase::eventID_

EventID eventID_

Definition: ProducerSourceBase.h:71

edm::EventID::luminosityBlock

LuminosityBlockNumber_t luminosityBlock() const

Definition: EventID.h:43

bool edm::ProducerSourceBase::noFiles ( ) const

privatevirtual

Reimplemented in edm::ProducerSourceFromFiles.

Definition at line 218 of file ProducerSourceBase.cc.

Referenced by getNextItemType().

                                     {
     return false;
   }

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

inline

Definition at line 25 of file ProducerSourceBase.h.

References numberEventsInLumi_.

25 {return numberEventsInLumi_;}

edm::ProducerSourceBase::numberEventsInLumi_

unsigned int numberEventsInLumi_

Definition: ProducerSourceBase.h:62

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

inline

Definition at line 24 of file ProducerSourceBase.h.

References numberEventsInRun_.

24 {return numberEventsInRun_;}

edm::ProducerSourceBase::numberEventsInRun_

unsigned int numberEventsInRun_

Definition: ProducerSourceBase.h:61

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

inline

Definition at line 30 of file ProducerSourceBase.h.

References numberEventsInThisLumi_.

30 {return numberEventsInThisLumi_;}

edm::ProducerSourceBase::numberEventsInThisLumi_

unsigned int numberEventsInThisLumi_

Definition: ProducerSourceBase.h:69

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

inline

Definition at line 29 of file ProducerSourceBase.h.

References numberEventsInThisRun_.

29 {return numberEventsInThisRun_;}

edm::ProducerSourceBase::numberEventsInThisRun_

unsigned int numberEventsInThisRun_

Definition: ProducerSourceBase.h:68

TimeValue_t edm::ProducerSourceBase::presentTime ( ) const

inline

Definition at line 26 of file ProducerSourceBase.h.

References presentTime_.

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

26 {return presentTime_;}

edm::ProducerSourceBase::presentTime_

TimeValue_t presentTime_

Definition: ProducerSourceBase.h:63

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

privatepure virtual

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

Referenced by readEvent_().

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

overrideprivatevirtual

Implements edm::InputSource.

Reimplemented in LHESource.

Definition at line 60 of file ProducerSourceBase.cc.

References 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_();
     resetEventCached();
   }

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

overrideprivatevirtual

Implements edm::InputSource.

Definition at line 52 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 boost::shared_ptr<LuminosityBlockAuxiliary>();
     Timestamp ts = Timestamp(presentTime_);
     resetNewLumi();
     return boost::shared_ptr<LuminosityBlockAuxiliary>(new LuminosityBlockAuxiliary(eventID_.run(), eventID_.luminosityBlock(), ts, Timestamp::invalidTimestamp()));
   }

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

overrideprivatevirtual

Implements edm::InputSource.

Definition at line 45 of file ProducerSourceBase.cc.

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

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

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

private

Definition at line 195 of file ProducerSourceBase.cc.

References 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
       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 118 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 32 of file ProducerSourceBase.h.

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

Referenced by PixelSLinkDataInputSource::setRunAndEventInfo().

32 {return eventID_.run();}

edm::EventID::run

RunNumber_t run() const

Definition: EventID.h:42

edm::ProducerSourceBase::eventID_

EventID eventID_

Definition: ProducerSourceBase.h:71

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

privatepure virtual

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

Referenced by getNextItemType().

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

overrideprivatevirtual

Reimplemented from edm::InputSource.

Definition at line 71 of file ProducerSourceBase.cc.

References advanceToNext(), eventID_, edm::EventID::luminosityBlock(), evf::evtn::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();
     }
   }