edm::ConfigurableInputSource Class Reference

#include <ConfigurableInputSource.h>

Inheritance diagram for edm::ConfigurableInputSource:

Public Member Functions
	ConfigurableInputSource (ParameterSet const &pset, InputSourceDescription const &desc, bool realData=true)
EventNumber_t	event () const
unsigned int	eventCreationDelay () 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
RunNumber_t	run () const
unsigned int	timeBetweenEvents () const
virtual	~ConfigurableInputSource ()
Public Member Functions inherited from edm::InputSource
boost::shared_ptr < ActivityRegistry >	actReg () const
	Accessor for Activity Registry. More...
void	closeFile (boost::shared_ptr< FileBlock >, bool cleaningUpAfterException)
	close current file More...
void	doBeginJob ()
	Called by framework at beginning of job. More...
void	doBeginLumi (LuminosityBlockPrincipal &lbp)
	Called by framework at beginning of lumi block. More...
void	doBeginRun (RunPrincipal &rp)
	Called by framework at beginning of run. More...
void	doEndJob ()
	Called by framework at end of job. More...
void	doEndLumi (LuminosityBlockPrincipal &lbp, bool cleaningUpAfterException)
	Called by framework at end of lumi block. More...
void	doEndRun (RunPrincipal &rp, bool cleaningUpAfterException)
	Called by framework at end of run. More...
void	doPostForkReacquireResources (boost::shared_ptr< multicore::MessageReceiverForSource >)
void	doPreForkReleaseResources ()
	Called by the framework before forking the process. More...
ProcessingController::ForwardState	forwardState () const
bool	goToEvent (EventID const &eventID)
	InputSource (ParameterSet const &, InputSourceDescription const &)
	Constructor. More...
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	markLumi ()
	Mark lumi as read. More...
int	markRun ()
	Mark run as read. More...
int	maxEvents () const
int	maxLuminosityBlocks () const
ModuleDescription const &	moduleDescription () const
	Accessor for 'module' description. More...
ItemType	nextItemType ()
bool	primary () const
	Accessor for primary input source flag. More...
ProcessConfiguration const &	processConfiguration () const
	Accessor for Process Configuration. More...
std::string const &	processGUID () const
	Accessor for global process identifier. More...
ProcessingMode	processingMode () const
	RunsLumisAndEvents (default), RunsAndLumis, or Runs. More...
boost::shared_ptr < ProductRegistry const >	productRegistry () const
	Accessor for product registry. More...
bool	randomAccess () const
void	readAndCacheLumi (bool merge, HistoryAppender &historyAppender)
	Read next luminosity block. More...
void	readAndCacheRun (bool merge, HistoryAppender &historyAppender)
	Read next run. More...
EventPrincipal *	readEvent (boost::shared_ptr< LuminosityBlockPrincipal > lbCache)
EventPrincipal *	readEvent (EventID const &)
	Read a specific event. More...
boost::shared_ptr< FileBlock >	readFile ()
	Read next file. More...
boost::shared_ptr < LuminosityBlockAuxiliary >	readLuminosityBlockAuxiliary ()
	Read next luminosity block Auxilary. 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...
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)
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 &)

Protected Member Functions
void	reallyReadEvent ()
void	setEventNumber (EventNumber_t e)
void	setTime (TimeValue_t t)
Protected Member Functions inherited from edm::InputSource
void	decreaseRemainingEventsBy (int iSkipped)
EventPrincipal *	eventPrincipalCache ()
boost::shared_ptr < LuminosityBlockPrincipal > const	luminosityBlockPrincipal () const
PrincipalCache const &	principalCache () const
PrincipalCache &	principalCache ()
ProductRegistry &	productRegistryUpdate () const
void	reset () const
void	resetLuminosityBlockAuxiliary () const
void	resetRunAuxiliary () const
boost::shared_ptr < RunPrincipal > const	runPrincipal () const
void	setLuminosityBlockAuxiliary (LuminosityBlockAuxiliary *lbp)
void	setRunAuxiliary (RunAuxiliary *rp)
void	setTimestamp (Timestamp const &theTime)
	To set the current time, as seen by the input source. More...
ItemType	state () const

Private Member Functions
void	advanceToNext ()
virtual void	beginLuminosityBlock (LuminosityBlock &)
virtual void	beginRun (Run &)
virtual void	endLuminosityBlock (LuminosityBlock &)
virtual void	endRun (Run &)
virtual size_t	fileIndex () const
virtual ItemType	getNextItemType ()
virtual void	nextEvent ()
virtual void	postForkReacquireResources (boost::shared_ptr< edm::multicore::MessageReceiverForSource >)
virtual bool	produce (Event &e)=0
virtual EventPrincipal *	readEvent_ ()
virtual boost::shared_ptr < LuminosityBlockAuxiliary >	readLuminosityBlockAuxiliary_ ()
virtual boost::shared_ptr < RunAuxiliary >	readRunAuxiliary_ ()
void	retreatToPrevious ()
virtual void	rewind_ ()
virtual void	setLumi (LuminosityBlockNumber_t lb)
virtual void	setRun (RunNumber_t r)
virtual void	setRunAndEventInfo ()
virtual void	skip (int offset)

Private Attributes
EventAuxiliary::ExperimentType	eType_
bool	eventCached_
unsigned int	eventCreationDelay_
EventID	eventID_
bool	eventSet_
bool	isRealData_
bool	lumiSet_
bool	newLumi_
bool	newRun_
unsigned int	numberEventsInLumi_
unsigned int	numberEventsInRun_
unsigned int	numberEventsInThisLumi_
unsigned int	numberEventsInThisRun_
unsigned int	numberOfEventsBeforeBigSkip_
unsigned int	numberOfSequentialEvents_
EventID	origEventID_
TimeValue_t	origTime_
TimeValue_t	presentTime_
boost::shared_ptr < edm::multicore::MessageReceiverForSource >	receiver_
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 }
enum	ProcessingMode { Runs, RunsAndLumis, RunsLumisAndEvents }
typedef ProductRegistryHelper::TypeLabelList	TypeLabelList

Detailed Description

Definition at line 19 of file ConfigurableInputSource.h.

Constructor & Destructor Documentation

edm::ConfigurableInputSource::ConfigurableInputSource ( ParameterSet const &  pset, InputSourceDescription const &  desc, bool  realData = true  )

explicit

Definition at line 20 of file ConfigurableInputSource.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_),
    newRun_(true),
    newLumi_(true),
    eventCached_(false),
    lumiSet_(false),
    eventSet_(false),
    isRealData_(realData),
    eType_(EventAuxiliary::Undefined),
    numberOfEventsBeforeBigSkip_(0),
    numberOfSequentialEvents_(0)
  { 

    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::ConfigurableInputSource::~ConfigurableInputSource ( )

virtual

Definition at line 50 of file ConfigurableInputSource.cc.

                                                    {
  }

Member Function Documentation

void edm::ConfigurableInputSource::advanceToNext ( )

private

Definition at line 233 of file ConfigurableInputSource.cc.

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

Referenced by setRunAndEventInfo(), 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;
    }
    presentTime_ += timeBetweenEvents_;
  }

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

privatevirtual

Reimplemented from edm::InputSource.

Reimplemented in ErrorStreamSource.

Definition at line 123 of file ConfigurableInputSource.cc.

                                                                {
  }

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

privatevirtual

Reimplemented from edm::InputSource.

Reimplemented in ErrorStreamSource, MCatNLOSource, AlpgenSource, and LHESource.

Definition at line 115 of file ConfigurableInputSource.cc.

                                        {
  }

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

privatevirtual

Reimplemented from edm::InputSource.

Reimplemented in ErrorStreamSource.

Definition at line 127 of file ConfigurableInputSource.cc.

                                                              {
  }

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

privatevirtual

Reimplemented from edm::InputSource.

Reimplemented in ErrorStreamSource, LHESource, and edm::CosMuoGenSource.

Definition at line 119 of file ConfigurableInputSource.cc.

                                      {
  }

EventNumber_t edm::ConfigurableInputSource::event ( ) const

inline

Definition at line 32 of file ConfigurableInputSource.h.

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

Referenced by edm::FlatRandomEThetaGunSource::produce(), edm::FlatRandomPtThetaGunSource::produce(), edm::MultiParticleInConeGunSource::produce(), edm::FlatRandomPtGunSource::produce(), edm::FlatRandomEGunSource::produce(), edm::ExpoRandomPtGunSource::produce(), LaserAlignmentSource::produce(), edm::BeamHaloSource::produce(), and ErrorStreamSource::produce().

{return eventID_.event();}

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

inline

Definition at line 28 of file ConfigurableInputSource.h.

References eventCreationDelay_.

{return eventCreationDelay_;}

virtual size_t edm::ConfigurableInputSource::fileIndex ( ) const

inlineprivatevirtual

Reimplemented in edm::ExternalInputSource.

Definition at line 62 of file ConfigurableInputSource.h.

Referenced by getNextItemType().

{return 0UL;}

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

static

Definition at line 299 of file ConfigurableInputSource.cc.

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

Referenced by edm::ExternalInputSource::fillDescription(), and edm::EmptySource::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::ConfigurableInputSource::getNextItemType ( )

privatevirtual

Implements edm::InputSource.

Definition at line 178 of file ConfigurableInputSource.cc.

References eventCached_, eventID_, eventSet_, fileIndex(), getHLTprescales::index, edm::InputSource::IsEvent, edm::InputSource::IsFile, edm::InputSource::IsLumi, edm::InputSource::IsRun, edm::InputSource::IsStop, edm::EventID::luminosityBlock(), lumiSet_, newLumi_, newRun_, nextEvent(), origEventID_, edm::InputSource::processingMode(), reallyReadEvent(), edm::EventID::run(), edm::InputSource::Runs, edm::EventID::setLuminosityBlockNumber(), and setRunAndEventInfo().

                                           {
    if (newRun_) {
      if (eventID_.run() == RunNumber_t()) {
        eventCached_ = false;
        return IsStop;
      }
      return IsRun;
    }
    if (newLumi_) {
      return IsLumi;
    }
    if(eventCached_) {
      return IsEvent;
    }
    EventID oldEventID = eventID_;
    LuminosityBlockNumber_t oldLumi = eventID_.luminosityBlock();
    size_t index = fileIndex();
    if (!eventSet_) {
      lumiSet_ = false;
      setRunAndEventInfo();
      eventSet_ = true;
      nextEvent();
    }
    if (eventID_.run() == RunNumber_t()) {
      eventCached_ = false;
      return IsStop;
    }
    bool newFile = (fileIndex() > index);
    if (oldEventID.run() != eventID_.run()) {
      //  New Run
      // If the user did not explicitly set the luminosity block number,
      // reset it back to the beginning.
      if (!lumiSet_) {
    eventID_.setLuminosityBlockNumber(origEventID_.luminosityBlock());
      }
      newRun_ = newLumi_ = true;
      return newFile ? IsFile : IsRun;
    }
      // Same Run
    if (oldLumi != eventID_.luminosityBlock()) {
      // New Lumi
      newLumi_ = true;
      if (processingMode() != Runs) {
        return newFile ? IsFile : IsLumi;
      }
    }
    reallyReadEvent();
    if(!eventCached_) {
      return IsStop;
    }
    eventSet_ = false;
    return IsEvent;
  }

LuminosityBlockNumber_t edm::ConfigurableInputSource::luminosityBlock ( ) const

inline

Definition at line 33 of file ConfigurableInputSource.h.

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

Referenced by Types.EventID::cppID(), Types.LuminosityBlockID::cppID(), and setEventNumber().

{return eventID_.luminosityBlock();}

virtual void edm::ConfigurableInputSource::nextEvent ( )

inlineprivatevirtual

Reimplemented in MCatNLOSource, and LHESource.

Definition at line 63 of file ConfigurableInputSource.h.

Referenced by getNextItemType().

{}

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

inline

Definition at line 25 of file ConfigurableInputSource.h.

References numberEventsInLumi_.

{return numberEventsInLumi_;} 

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

inline

Definition at line 24 of file ConfigurableInputSource.h.

References numberEventsInRun_.

Referenced by edm::BeamHaloSource::BeamHaloSource(), and edm::CosMuoGenSource::CosMuoGenSource().

{return numberEventsInRun_;} 

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

inline

Definition at line 30 of file ConfigurableInputSource.h.

References numberEventsInThisLumi_.

{return numberEventsInThisLumi_;}

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

inline

Definition at line 29 of file ConfigurableInputSource.h.

References numberEventsInThisRun_.

{return numberEventsInThisRun_;}

void edm::ConfigurableInputSource::postForkReacquireResources ( boost::shared_ptr< edm::multicore::MessageReceiverForSource >  iReceiver )

privatevirtual

Definition at line 146 of file ConfigurableInputSource.cc.

References numberOfEventsBeforeBigSkip_, numberOfSequentialEvents_, receiver_, edm::InputSource::repeat(), and edm::InputSource::rewind().

                                                                                                                     {
    receiver_ = iReceiver;
    receiver_->receive();
    numberOfEventsBeforeBigSkip_ = receiver_->numberOfConsecutiveIndices() + 1;
    numberOfSequentialEvents_ = receiver_->numberOfConsecutiveIndices();
    repeat();
    rewind();
  }

TimeValue_t edm::ConfigurableInputSource::presentTime ( ) const

inline

Definition at line 26 of file ConfigurableInputSource.h.

References presentTime_.

Referenced by HcalTBSource::setRunAndEventInfo().

{return presentTime_;}

virtual bool edm::ConfigurableInputSource::produce ( Event &  e )

privatepure virtual

Implemented in EcalSimpleSource, L1MuGMTHWFileReader, MCatNLOSource, ErrorStreamSource, PixelSLinkDataInputSource, AlpgenSource, edm::BeamHaloSource, LaserAlignmentSource, LHESource, HcalTBSource, LmfSource, edm::MCFileSource, edm::CosMuoGenSource, edm::H2RootNtplSource, edm::ExpoRandomPtGunSource, edm::FlatRandomEGunSource, edm::FlatRandomPtGunSource, edm::MultiParticleInConeGunSource, edm::FlatRandomEThetaGunSource, edm::FlatRandomPtThetaGunSource, edm::EmptySource, and cond::EmptyIOVSource.

Referenced by JSONExport.JsonExport::export(), HTMLExport.HTMLExport::export(), HTMLExport.HTMLExportStatic::export(), and reallyReadEvent().

EventPrincipal * edm::ConfigurableInputSource::readEvent_ ( )

privatevirtual

Implements edm::InputSource.

Definition at line 69 of file ConfigurableInputSource.cc.

References eventCached_, edm::InputSource::eventPrincipalCache(), edm::InputSource::processingMode(), and edm::InputSource::RunsLumisAndEvents.

                                      {
    assert(eventCached_ || processingMode() != RunsLumisAndEvents);
    eventCached_ = false;
    return eventPrincipalCache();
  }

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

privatevirtual

Implements edm::InputSource.

Definition at line 61 of file ConfigurableInputSource.cc.

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

                                                         {
    if (processingMode() == Runs) return boost::shared_ptr<LuminosityBlockAuxiliary>();
    Timestamp ts = Timestamp(presentTime_);
    newLumi_ = false;
    return boost::shared_ptr<LuminosityBlockAuxiliary>(new LuminosityBlockAuxiliary(eventID_.run(), eventID_.luminosityBlock(), ts, Timestamp::invalidTimestamp()));
  }

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

privatevirtual

Implements edm::InputSource.

Definition at line 54 of file ConfigurableInputSource.cc.

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

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

void edm::ConfigurableInputSource::reallyReadEvent ( )

protected

Definition at line 76 of file ConfigurableInputSource.cc.

References printConversionInfo::aux, edm::Event::commit_(), alignCSCRings::e, eType_, eventCached_, eventID_, edm::InputSource::eventPrincipalCache(), edm::EventPrincipal::fillEventPrincipal(), isRealData_, edm::InputSource::luminosityBlockPrincipal(), edm::InputSource::moduleDescription(), presentTime_, edm::InputSource::processGUID(), edm::InputSource::processingMode(), produce(), and edm::InputSource::RunsLumisAndEvents.

Referenced by getNextItemType().

                                           {
    if (processingMode() != RunsLumisAndEvents) return;
    EventSourceSentry sentry(*this);
    EventAuxiliary aux(eventID_, processGUID(), Timestamp(presentTime_), isRealData_, eType_);
    eventPrincipalCache()->fillEventPrincipal(aux, luminosityBlockPrincipal());
    Event e(*eventPrincipalCache(), moduleDescription());
    if (!produce(e)) {
      eventCached_ = false;
      return;
    }
    e.commit_();
    eventCached_ = true;
  }

void edm::ConfigurableInputSource::retreatToPrevious ( )

private

Definition at line 255 of file ConfigurableInputSource.cc.

References eventID_, edm::EventID::luminosityBlock(), numberEventsInLumi_, numberEventsInRun_, numberEventsInThisLumi_, numberEventsInThisRun_, origEventID_, presentTime_, 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_;
    }
    presentTime_ -= timeBetweenEvents_;
  }

void edm::ConfigurableInputSource::rewind_ ( )

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 156 of file ConfigurableInputSource.cc.

References edm::InputSource::decreaseRemainingEventsBy(), eventID_, newLumi_, newRun_, numberEventsInThisLumi_, numberEventsInThisRun_, numberOfEventsBeforeBigSkip_, origEventID_, origTime_, presentTime_, receiver_, and skip().

                                   {
    presentTime_ = origTime_;
    eventID_ = origEventID_;
    numberEventsInThisRun_ = 0;
    numberEventsInThisLumi_ = 0;

    if(receiver_) {
      unsigned int numberToSkip = receiver_->numberToSkip();
      numberOfEventsBeforeBigSkip_ = receiver_->numberOfConsecutiveIndices() + 1;
      //NOTE: skip() will decrease numberOfEventsBeforeBigSkip_ and therefore we need
      // to be sure it is large enough so that it never goes to 0 during the skipping
      if(numberOfEventsBeforeBigSkip_ < numberToSkip) {
        numberOfEventsBeforeBigSkip_ = numberToSkip+1;
      }
      skip(numberToSkip);
      decreaseRemainingEventsBy(numberToSkip);
      numberOfEventsBeforeBigSkip_ = receiver_->numberOfConsecutiveIndices() + 1;
    }
    newRun_ = newLumi_ = true;
  }

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

inline

Definition at line 31 of file ConfigurableInputSource.h.

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

Referenced by Types.LuminosityBlockID::cppID(), and setEventNumber().

{return eventID_.run();}

void edm::ConfigurableInputSource::setEventNumber ( EventNumber_t  e )

inlineprotected

Definition at line 38 of file ConfigurableInputSource.h.

References eventID_, eventSet_, luminosityBlock(), alignCSCRings::r, and run().

Referenced by PixelSLinkDataInputSource::produce(), cond::EmptyIOVSource::setRunAndEventInfo(), HcalTBSource::setRunAndEventInfo(), LmfSource::setRunAndEventInfo(), ErrorStreamSource::setRunAndEventInfo(), and L1MuGMTHWFileReader::setRunAndEventInfo().

                                         {
      RunNumber_t r = run();
      LuminosityBlockNumber_t lb = luminosityBlock();
      eventID_ = EventID(r, lb, e);
      eventSet_ = true;
    } 

void edm::ConfigurableInputSource::setLumi ( LuminosityBlockNumber_t  lb )

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 131 of file ConfigurableInputSource.cc.

References eventID_, edm::EventID::luminosityBlock(), lumiSet_, newLumi_, numberEventsInThisLumi_, origEventID_, and edm::EventID::setLuminosityBlockNumber().

                                                             {
    // Protect against invalid lumi.
    if (lb == LuminosityBlockNumber_t()) {
    lb = origEventID_.luminosityBlock();
    }
    // Do nothing if the lumi block is not changed.
    if (lb != eventID_.luminosityBlock()) {
      eventID_.setLuminosityBlockNumber(lb);
      numberEventsInThisLumi_ = 0;
      newLumi_ = true;
    }
    lumiSet_ = true;
  }

void edm::ConfigurableInputSource::setRun ( RunNumber_t  r )

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 102 of file ConfigurableInputSource.cc.

References eventID_, edm::EventID::luminosityBlock(), newLumi_, newRun_, numberEventsInThisLumi_, numberEventsInThisRun_, origEventID_, edm::EventID::run(), and zerothEvent_.

                                               {
    // No need to check for invalid (zero) run number,
    // as this is a legitimate way of stopping the job.
    // Do nothing if the run is not changed.
    if (r != eventID_.run()) {
      eventID_ = EventID(r, origEventID_.luminosityBlock(), zerothEvent_);
      numberEventsInThisRun_ = 0;
      numberEventsInThisLumi_ = 0;
      newRun_ = newLumi_ = true;
    }
  }

void edm::ConfigurableInputSource::setRunAndEventInfo ( )

privatevirtual

Reimplemented in L1MuGMTHWFileReader, ErrorStreamSource, LmfSource, HcalTBSource, and cond::EmptyIOVSource.

Definition at line 278 of file ConfigurableInputSource.cc.

References advanceToNext(), edm::InputSource::decreaseRemainingEventsBy(), eventCreationDelay_, eventID_, numberOfEventsBeforeBigSkip_, or, receiver_, edm::InputSource::remainingEvents(), edm::InputSource::remainingLuminosityBlocks(), and skip().

Referenced by getNextItemType().

                                              {
    if(receiver_ && 0 == --numberOfEventsBeforeBigSkip_) {
      receiver_->receive();
      unsigned long numberOfEventsToSkip = receiver_->numberToSkip();
      if (numberOfEventsToSkip !=0) {
        skip(numberOfEventsToSkip);
        decreaseRemainingEventsBy(numberOfEventsToSkip);
      }
      numberOfEventsBeforeBigSkip_ = receiver_->numberOfConsecutiveIndices();
      //Since we decrease 'remaining events' count we need to see if we reached 0 and therefore are at the end
      if(0 == numberOfEventsBeforeBigSkip_ or 0==remainingEvents() or 0 == remainingLuminosityBlocks()) {
        //this means we are to stop
        eventID_ = EventID();
        return;
      }
    }
    advanceToNext();
    if (eventCreationDelay_ > 0) {usleep(eventCreationDelay_);}
  }

void edm::ConfigurableInputSource::setTime ( TimeValue_t  t )

inlineprotected

Definition at line 44 of file ConfigurableInputSource.h.

References presentTime_, and lumiQTWidget::t.

Referenced by ErrorStreamSource::produce(), cond::EmptyIOVSource::setRunAndEventInfo(), HcalTBSource::setRunAndEventInfo(), and LmfSource::setRunAndEventInfo().

{presentTime_ = t;}

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

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 91 of file ConfigurableInputSource.cc.

References advanceToNext(), evf::evtn::offset(), and retreatToPrevious().

Referenced by rewind_(), and setRunAndEventInfo().

                                          {
    for (; offset < 0; ++offset) {
      retreatToPrevious();
    }
    for (; offset > 0; --offset) {
      advanceToNext();
    }
  }

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

inline

Definition at line 27 of file ConfigurableInputSource.h.

References timeBetweenEvents_.

Referenced by HcalTBSource::setRunAndEventInfo().

{return timeBetweenEvents_;}

Member Data Documentation

EventAuxiliary::ExperimentType edm::ConfigurableInputSource::eType_

private

Definition at line 87 of file ConfigurableInputSource.h.

Referenced by reallyReadEvent().

bool edm::ConfigurableInputSource::eventCached_

private

Definition at line 83 of file ConfigurableInputSource.h.

Referenced by getNextItemType(), readEvent_(), and reallyReadEvent().

unsigned int edm::ConfigurableInputSource::eventCreationDelay_

private

Definition at line 74 of file ConfigurableInputSource.h.

Referenced by eventCreationDelay(), and setRunAndEventInfo().

EventID edm::ConfigurableInputSource::eventID_

private

Definition at line 79 of file ConfigurableInputSource.h.

Referenced by advanceToNext(), event(), getNextItemType(), luminosityBlock(), readLuminosityBlockAuxiliary_(), readRunAuxiliary_(), reallyReadEvent(), retreatToPrevious(), rewind_(), run(), setEventNumber(), setLumi(), setRun(), and setRunAndEventInfo().

bool edm::ConfigurableInputSource::eventSet_

private

Definition at line 85 of file ConfigurableInputSource.h.

Referenced by getNextItemType(), and setEventNumber().

bool edm::ConfigurableInputSource::isRealData_

private

Definition at line 86 of file ConfigurableInputSource.h.

Referenced by reallyReadEvent().

bool edm::ConfigurableInputSource::lumiSet_

private

Definition at line 84 of file ConfigurableInputSource.h.

Referenced by getNextItemType(), and setLumi().

bool edm::ConfigurableInputSource::newLumi_

private

Definition at line 82 of file ConfigurableInputSource.h.

Referenced by getNextItemType(), readLuminosityBlockAuxiliary_(), rewind_(), setLumi(), and setRun().

bool edm::ConfigurableInputSource::newRun_

private

Definition at line 81 of file ConfigurableInputSource.h.

Referenced by getNextItemType(), readRunAuxiliary_(), rewind_(), and setRun().

unsigned int edm::ConfigurableInputSource::numberEventsInLumi_

private

Definition at line 70 of file ConfigurableInputSource.h.

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

unsigned int edm::ConfigurableInputSource::numberEventsInRun_

private

Definition at line 69 of file ConfigurableInputSource.h.

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

unsigned int edm::ConfigurableInputSource::numberEventsInThisLumi_

private

Definition at line 77 of file ConfigurableInputSource.h.

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

unsigned int edm::ConfigurableInputSource::numberEventsInThisRun_

private

Definition at line 76 of file ConfigurableInputSource.h.

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

unsigned int edm::ConfigurableInputSource::numberOfEventsBeforeBigSkip_

private

Definition at line 91 of file ConfigurableInputSource.h.

Referenced by postForkReacquireResources(), rewind_(), and setRunAndEventInfo().

unsigned int edm::ConfigurableInputSource::numberOfSequentialEvents_

private

Definition at line 92 of file ConfigurableInputSource.h.

Referenced by postForkReacquireResources().

EventID edm::ConfigurableInputSource::origEventID_

private

Definition at line 80 of file ConfigurableInputSource.h.

Referenced by advanceToNext(), getNextItemType(), retreatToPrevious(), rewind_(), setLumi(), and setRun().

TimeValue_t edm::ConfigurableInputSource::origTime_

private

Definition at line 72 of file ConfigurableInputSource.h.

Referenced by rewind_().

TimeValue_t edm::ConfigurableInputSource::presentTime_

private

Definition at line 71 of file ConfigurableInputSource.h.

Referenced by advanceToNext(), ConfigurableInputSource(), presentTime(), readLuminosityBlockAuxiliary_(), readRunAuxiliary_(), reallyReadEvent(), retreatToPrevious(), rewind_(), and setTime().

boost::shared_ptr<edm::multicore::MessageReceiverForSource> edm::ConfigurableInputSource::receiver_

private

Definition at line 90 of file ConfigurableInputSource.h.

Referenced by postForkReacquireResources(), rewind_(), and setRunAndEventInfo().

TimeValue_t edm::ConfigurableInputSource::timeBetweenEvents_

private

Definition at line 73 of file ConfigurableInputSource.h.

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

unsigned int const edm::ConfigurableInputSource::zerothEvent_

private

Definition at line 78 of file ConfigurableInputSource.h.

Referenced by setRun().