#include <InputSource.h>

Inheritance diagram for edm::InputSource:

Classes
class	EventSourceSentry

class	FileCloseSentry

class	FileOpenSentry

class	LumiSourceSentry

class	RunSourceSentry

class	SourceSentry

Public Types
enum	ItemType { IsInvalid, IsStop, IsFile, IsRun, IsLumi, IsEvent, IsRepeat }

enum	ProcessingMode { Runs, RunsAndLumis, RunsLumisAndEvents }

typedef ProductRegistryHelper::TypeLabelList	TypeLabelList

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

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

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

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

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

bool	randomAccess () const

boost::shared_ptr < LuminosityBlockPrincipal >	readAndCacheLumi (HistoryAppender &historyAppender)
	Read next luminosity block (new lumi) More...

boost::shared_ptr< RunPrincipal >	readAndCacheRun (HistoryAppender &historyAppender)
	Read next run (new run) More...

void	readAndMergeLumi (boost::shared_ptr< LuminosityBlockPrincipal > lbp)
	Read next luminosity block (same as a prior lumi) More...

void	readAndMergeRun (boost::shared_ptr< RunPrincipal > rp)
	Read next run (same as a prior run) More...

EventPrincipal *	readEvent (EventPrincipal &ep)

EventPrincipal *	readEvent (EventPrincipal &ep, EventID const &)
	Read a specific event. More...

std::unique_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)

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 const std::string &	baseType ()

static void	fillDescription (ParameterSetDescription &desc)

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &)

Protected Member Functions
void	decreaseRemainingEventsBy (int iSkipped)

bool	eventCached () const

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

bool	newLumi () const

bool	newRun () 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...

virtual void	skip (int offset)

ItemType	state () const

Private Member Functions
virtual void	beginJob ()

virtual void	beginLuminosityBlock (LuminosityBlock &)

virtual void	beginRun (Run &)

virtual void	closeFile_ ()

virtual void	endJob ()

virtual void	endLuminosityBlock (LuminosityBlock &)

virtual void	endRun (Run &)

bool	eventLimitReached () const

virtual ProcessingController::ForwardState	forwardState_ () const

virtual ItemType	getNextItemType ()=0

virtual bool	goToEvent_ (EventID const &eventID)

bool	limitReached () const

bool	lumiLimitReached () const

ItemType	nextItemType_ ()

virtual void	postForkReacquireResources (boost::shared_ptr< multicore::MessageReceiverForSource >)

void	postRead (Event &event)

virtual void	preForkReleaseResources ()

virtual bool	randomAccess_ () const

virtual EventPrincipal *	readEvent_ (EventPrincipal &eventPrincipal)=0

virtual std::unique_ptr < FileBlock >	readFile_ ()

virtual EventPrincipal *	readIt (EventID const &, EventPrincipal &eventPrincipal)

virtual boost::shared_ptr < LuminosityBlockPrincipal >	readLuminosityBlock_ (boost::shared_ptr< LuminosityBlockPrincipal > lumiPrincipal)

virtual boost::shared_ptr < LuminosityBlockAuxiliary >	readLuminosityBlockAuxiliary_ ()=0

virtual boost::shared_ptr < RunPrincipal >	readRun_ (boost::shared_ptr< RunPrincipal > runPrincipal)

virtual boost::shared_ptr < RunAuxiliary >	readRunAuxiliary_ ()=0

virtual ProcessingController::ReverseState	reverseState_ () const

virtual void	rewind_ ()

virtual void	setLumi (LuminosityBlockNumber_t lb)

virtual void	setRun (RunNumber_t r)

Private Member Functions inherited from edm::ProductRegistryHelper
template<class ProductType >
TypeLabelItem const &	produces ()
	declare what type of product will make and with which optional label More...

template<class ProductType >
TypeLabelItem const &	produces (std::string const &instanceName)

template<typename ProductType , BranchType B>
TypeLabelItem const &	produces ()

template<typename ProductType , BranchType B>
TypeLabelItem const &	produces (std::string const &instanceName)

TypeLabelItem const &	produces (const TypeID &id, std::string const &instanceName=std::string())

template<BranchType B>
TypeLabelItem const &	produces (const TypeID &id, std::string const &instanceName=std::string())

	ProductRegistryHelper ()

TypeLabelList &	typeLabelList ()
	used by the fwk to register the list of products of this module More...

	~ProductRegistryHelper ()

Private Attributes
boost::shared_ptr < ActivityRegistry >	actReg_

boost::shared_ptr < BranchIDListHelper >	branchIDListHelper_

bool	eventCached_

boost::shared_ptr < LuminosityBlockAuxiliary >	lumiAuxiliary_

int	maxEvents_

int	maxLumis_

ModuleDescription const	moduleDescription_

bool	newLumi_

bool	newRun_

unsigned int	numberOfEventsBeforeBigSkip_

bool const	primary_

std::string	processGUID_

ProcessingMode	processingMode_

boost::shared_ptr < ProductRegistry const >	productRegistry_

int	readCount_

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

int	remainingEvents_

int	remainingLumis_

boost::shared_ptr< RunAuxiliary >	runAuxiliary_

ItemType	state_

std::string	statusFileName_

Timestamp	time_

Additional Inherited Members
Private Types inherited from edm::ProductRegistryHelper
typedef std::list< TypeLabelItem >	TypeLabelList

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

Detailed Description

Definition at line 70 of file InputSource.h.

Member Typedef Documentation

typedef ProductRegistryHelper::TypeLabelList edm::InputSource::TypeLabelList

Definition at line 88 of file InputSource.h.

Member Enumeration Documentation

enum edm::InputSource::ItemType

Enumerator
IsInvalid
IsStop
IsFile
IsRun
IsLumi
IsEvent
IsRepeat

Definition at line 72 of file InputSource.h.

                   {
       IsInvalid,
       IsStop,
       IsFile,
       IsRun,
       IsLumi,
       IsEvent,
       IsRepeat
     };

enum edm::InputSource::ProcessingMode

Enumerator
Runs
RunsAndLumis
RunsLumisAndEvents

Definition at line 82 of file InputSource.h.

                         {
       Runs,
       RunsAndLumis,
       RunsLumisAndEvents
     };

Constructor & Destructor Documentation

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

explicit

Constructor.

Definition at line 55 of file InputSource.cc.

References edm::errors::Configuration, edm::hlt::Exception, edm::ParameterSet::getUntrackedParameter(), primary_, processingMode(), processingMode_, edm::InputSourceDescription::productRegistry_, Runs, RunsAndLumis, statusFileName_, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                        :
       ProductRegistryHelper(),
       actReg_(desc.actReg_),
       maxEvents_(desc.maxEvents_),
       remainingEvents_(maxEvents_),
       maxLumis_(desc.maxLumis_),
       remainingLumis_(maxLumis_),
       readCount_(0),
       processingMode_(RunsLumisAndEvents),
       moduleDescription_(desc.moduleDescription_),
       productRegistry_(createSharedPtrToStatic<ProductRegistry const>(desc.productRegistry_)),
       branchIDListHelper_(desc.branchIDListHelper_),
       primary_(pset.getParameter<std::string>("@module_label") == std::string("@main_input")),
       processGUID_(primary_ ? createGlobalIdentifier() : std::string()),
       time_(),
       newRun_(true),
       newLumi_(true),
       eventCached_(false),
       state_(IsInvalid),
       runAuxiliary_(),
       lumiAuxiliary_(),
       statusFileName_(),
       receiver_(),
       numberOfEventsBeforeBigSkip_(0) {
 
     if(pset.getUntrackedParameter<bool>("writeStatusFile", false)) {
       std::ostringstream statusfilename;
       statusfilename << "source_" << getpid();
       statusFileName_ = statusfilename.str();
     }
 
     // Secondary input sources currently do not have a product registry.
     if(primary_) {
       assert(desc.productRegistry_ != 0);
     }
     std::string const defaultMode("RunsLumisAndEvents");
     std::string const runMode("Runs");
     std::string const runLumiMode("RunsAndLumis");
 
     // The default value provided as the second argument to the getUntrackedParameter function call
     // is not used when the ParameterSet has been validated and the parameters are not optional
     // in the description.  As soon as all primary input sources and all modules with a secondary
     // input sources have defined descriptions, the defaults in the getUntrackedParameterSet function
     // calls can and should be deleted from the code.
     std::string processingMode = pset.getUntrackedParameter<std::string>("processingMode", defaultMode);
     if(processingMode == runMode) {
       processingMode_ = Runs;
     } else if(processingMode == runLumiMode) {
       processingMode_ = RunsAndLumis;
     } else if(processingMode != defaultMode) {
       throw Exception(errors::Configuration)
         << "InputSource::InputSource()\n"
         << "The 'processingMode' parameter for sources has an illegal value '" << processingMode << "'\n"
         << "Legal values are '" << defaultMode << "', '" << runLumiMode << "', or '" << runMode << "'.\n";
     }
   }

InputSource::~InputSource ( )

virtual

Destructor.

Definition at line 112 of file InputSource.cc.

112 {}

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

delete

Member Function Documentation

boost::shared_ptr<ActivityRegistry> edm::InputSource::actReg ( ) const

inline

Accessor for Activity Registry.

Definition at line 241 of file InputSource.h.

References actReg_.

Referenced by edm::InputSource::FileCloseSentry::FileCloseSentry().

241 {return actReg_;}

edm::InputSource::actReg_

boost::shared_ptr< ActivityRegistry > actReg_

Definition: InputSource.h:390

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

static

Definition at line 129 of file InputSource.cc.

References edm::kBaseType().

                         {
     return kBaseType;
   }

void InputSource::beginJob ( void )

privatevirtual

Reimplemented in edm::ProducerSourceBase.

Definition at line 567 of file InputSource.cc.

Referenced by doBeginJob().

567 {}

void InputSource::beginLuminosityBlock ( LuminosityBlock & )

privatevirtual

Reimplemented in ErrorStreamSource, and edm::ProducerSourceBase.

Definition at line 555 of file InputSource.cc.

Referenced by doBeginLumi().

555 {}

void InputSource::beginRun ( Run & )

privatevirtual

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

Definition at line 561 of file InputSource.cc.

Referenced by doBeginRun().

561 {}

boost::shared_ptr<BranchIDListHelper> edm::InputSource::branchIDListHelper ( ) const

inline

Accessor for branchIDListHelper.

Definition at line 165 of file InputSource.h.

References branchIDListHelper_.

Referenced by edm::StreamerInputSource::deserializeAndMergeWithRegistry(), edm::RootInputFileSequence::initFile(), and edm::StreamerInputSource::read().

165 {return branchIDListHelper_;}

edm::InputSource::branchIDListHelper_

boost::shared_ptr< BranchIDListHelper > branchIDListHelper_

Definition: InputSource.h:399

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

close current file

Definition at line 270 of file InputSource.cc.

References edm::FileBlock::close(), and closeFile_().

Referenced by edm::RawInputSource::preForkReleaseResources(), and Vispa.Main.Application.Application::tabCloseRequest().

                                                                      {
     if(fb != nullptr) fb->close();
     callWithTryCatchAndPrint<void>( [this](){ closeFile_(); },
                                     "Calling InputSource::closeFile_",
                                     cleaningUpAfterException );
     return;
   }

virtual void edm::InputSource::closeFile_ ( )

inlineprivatevirtual

Reimplemented in DQMRootSource, edm::PoolSource, edm::StreamerFileReader, and edm::StreamerInputModule< Producer >.

Definition at line 370 of file InputSource.h.

Referenced by closeFile().

370 {}

void InputSource::decreaseRemainingEventsBy ( int iSkipped )

protected

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

Definition at line 474 of file InputSource.cc.

References remainingEvents_.

Referenced by rewind(), and skipForForking().

                                                      {
     if(-1 == remainingEvents_) {
       return;
     }
     if(iSkipped < remainingEvents_) {
       remainingEvents_ -= iSkipped;
     } else {
       remainingEvents_ = 0;
     }
   }

void InputSource::doBeginJob ( )

Called by framework at beginning of job.

Definition at line 244 of file InputSource.cc.

References beginJob().

                           {
     this->beginJob();
   }

void InputSource::doBeginLumi ( LuminosityBlockPrincipal & lbp )

Called by framework at beginning of lumi block.

Definition at line 510 of file InputSource.cc.

References beginLuminosityBlock(), edm::LuminosityBlock::commit_(), and moduleDescription().

                                                         {
     LuminosityBlock lb(lbp, moduleDescription());
     callWithTryCatchAndPrint<void>( [this,&lb](){ beginLuminosityBlock(lb); }, "Calling InputSource::beginLuminosityBlock" );
     lb.commit_();
   }

void InputSource::doBeginRun ( RunPrincipal & rp )

Called by framework at beginning of run.

Definition at line 494 of file InputSource.cc.

References beginRun(), edm::Run::commit_(), moduleDescription(), and run().

                                           {
     Run run(rp, moduleDescription());
     callWithTryCatchAndPrint<void>( [this,&run](){ beginRun(run); }, "Calling InputSource::beginRun" );
     run.commit_();
   }

void InputSource::doEndJob ( )

Called by framework at end of job.

Definition at line 249 of file InputSource.cc.

References endJob().

Referenced by edm::EventProcessor::endJob().

                         {
     endJob();
   }

void InputSource::doEndLumi	(	LuminosityBlockPrincipal &	lbp,
		bool	cleaningUpAfterException
	)

Called by framework at end of lumi block.

Definition at line 517 of file InputSource.cc.

References edm::LuminosityBlock::commit_(), endLuminosityBlock(), moduleDescription(), edm::LuminosityBlockPrincipal::setComplete(), edm::LuminosityBlockPrincipal::setEndTime(), and time_.

                                                                                      {
     lbp.setEndTime(time_);
     lbp.setComplete();
     LuminosityBlock lb(lbp, moduleDescription());
     callWithTryCatchAndPrint<void>( [this,&lb](){ endLuminosityBlock(lb); }, "Calling InputSource::endLuminosityBlock", cleaningUpAfterException );
     lb.commit_();
   }

void InputSource::doEndRun	(	RunPrincipal &	rp,
		bool	cleaningUpAfterException
	)

Called by framework at end of run.

Definition at line 501 of file InputSource.cc.

References edm::Run::commit_(), endRun(), moduleDescription(), run(), edm::RunPrincipal::setComplete(), edm::RunPrincipal::setEndTime(), and time_.

                                                                        {
     rp.setEndTime(time_);
     rp.setComplete();
     Run run(rp, moduleDescription());
     callWithTryCatchAndPrint<void>( [this,&run](){ endRun(run); }, "Calling InputSource::endRun", cleaningUpAfterException );
     run.commit_();
   }

void InputSource::doPostForkReacquireResources ( boost::shared_ptr< multicore::MessageReceiverForSource > iReceiver )

Definition at line 531 of file InputSource.cc.

References postForkReacquireResources().

                                                                                                         {
     callWithTryCatchAndPrint<void>( [this, &iReceiver](){ postForkReacquireResources(iReceiver); },
                                     "Calling InputSource::postForkReacquireResources" );
   }

void InputSource::doPreForkReleaseResources ( )

Called by the framework before forking the process.

Definition at line 526 of file InputSource.cc.

References preForkReleaseResources().

                                          {
     callWithTryCatchAndPrint<void>( [this](){ preForkReleaseResources(); }, "Calling InputSource::preForkReleaseResources" );
   }

void InputSource::endJob ( void )

privatevirtual

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

Definition at line 570 of file InputSource.cc.

Referenced by doEndJob().

570 {}

void InputSource::endLuminosityBlock ( LuminosityBlock & )

privatevirtual

Reimplemented in ErrorStreamSource, and edm::ProducerSourceBase.

Definition at line 558 of file InputSource.cc.

Referenced by doEndLumi().

558 {}

void InputSource::endRun ( Run & )

privatevirtual

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

Definition at line 564 of file InputSource.cc.

Referenced by doEndRun().

564 {}

bool edm::InputSource::eventCached ( ) const

inlineprotected

Definition at line 347 of file InputSource.h.

References eventCached_.

Referenced by edm::RawInputSource::getNextItemType(), edm::ProducerSourceBase::getNextItemType(), edm::DaqSource::getNextItemType(), edm::RawInputSource::readEvent_(), LHESource::readEvent_(), edm::DaqSource::readEvent_(), edm::ProducerSourceBase::readEvent_(), edm::StreamerInputSource::resetAfterEndRun(), and edm::DaqSource::setRun().

347 {return eventCached_;}

edm::InputSource::eventCached_

bool eventCached_

Definition: InputSource.h:405

bool edm::InputSource::eventLimitReached ( ) const

inlineprivate

Definition at line 357 of file InputSource.h.

References remainingEvents_.

Referenced by limitReached(), nextItemType(), readEvent(), and skipForForking().

357 {return remainingEvents_ == 0;}

edm::InputSource::remainingEvents_

int remainingEvents_

Definition: InputSource.h:392

void InputSource::fillDescription ( ParameterSetDescription & desc )

static

Definition at line 134 of file InputSource.cc.

References edm::ParameterSetDescription::addUntracked(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by edm::RawInputSource::fillDescription(), edm::EDInputSource::fillDescription(), and edm::ProducerSourceBase::fillDescription().

                                                             {
     std::string defaultString("RunsLumisAndEvents");
     desc.addUntracked<std::string>("processingMode", defaultString)->setComment(
     "'RunsLumisAndEvents': process runs, lumis, and events.\n"
     "'RunsAndLumis':       process runs and lumis (not events).\n"
     "'Runs':               process runs (not lumis or events).");
     desc.addUntracked<bool>("writeStatusFile", false)->setComment("Write a status file. Intended for use by workflow management.");
   }

void InputSource::fillDescriptions ( ConfigurationDescriptions & descriptions )

static

Definition at line 115 of file InputSource.cc.

References edm::ConfigurationDescriptions::addDefault(), and edm::ParameterSetDescription::setUnknown().

                                                                        {
     ParameterSetDescription desc;
     desc.setUnknown();
     descriptions.addDefault(desc);
   }

ProcessingController::ForwardState InputSource::forwardState ( ) const

Definition at line 543 of file InputSource.cc.

References forwardState_().

                                   {
     return callWithTryCatchAndPrint<ProcessingController::ForwardState>( [this](){ return forwardState_(); },
                                                                          "Calling InputSource::forwardState_" );
   }

ProcessingController::ForwardState InputSource::forwardState_ ( ) const

privatevirtual

Reimplemented in edm::PoolSource.

Definition at line 589 of file InputSource.cc.

References edm::ProcessingController::kUnknownForward.

Referenced by forwardState().

                                    {
     return ProcessingController::kUnknownForward;
   }

virtual ItemType edm::InputSource::getNextItemType ( )

privatepure virtual

Implemented in DQMRootSource, edm::DaqSource, edm::PoolSource, edm::ProducerSourceBase, and edm::RawInputSource.

Referenced by nextItemType_().

bool InputSource::goToEvent ( EventID const & eventID )

Definition at line 387 of file InputSource.cc.

References goToEvent_().

                                                {
     return callWithTryCatchAndPrint<bool>( [this,&eventID](){ return goToEvent_(eventID); }, "Calling InputSource::goToEvent_" );
   }

bool InputSource::goToEvent_ ( EventID const & eventID )

privatevirtual

Reimplemented in edm::PoolSource.

Definition at line 457 of file InputSource.cc.

References edm::hlt::Exception, and edm::errors::LogicError.

Referenced by goToEvent().

                                         {
     throw Exception(errors::LogicError)
       << "InputSource::goToEvent_()\n"
       << "Random access is not implemented for this type of Input Source\n"
       << "Contact a Framework Developer\n";
     return true;
   }

void InputSource::issueReports ( EventID const & eventID )

issue an event report

Definition at line 407 of file InputSource.cc.

References edm::EventID::event(), edm::isInfoEnabled(), edm::EventID::luminosityBlock(), readCount_, edm::EventID::run(), statusFileName_, and createPayload::suffix.

Referenced by readEvent().

                                                   {
     if(isInfoEnabled()) {
       LogVerbatim("FwkReport") << "Begin processing the " << readCount_
                                << suffix(readCount_) << " record. Run " << eventID.run()
                                << ", Event " << eventID.event()
                                << ", LumiSection " << eventID.luminosityBlock()
                                << " at " << std::setprecision(3) << TimeOfDay();
     }
     if(!statusFileName_.empty()) {
       std::ofstream statusFile(statusFileName_.c_str());
       statusFile << eventID << " time: " << std::setprecision(3) << TimeOfDay() << '\n';
       statusFile.close();
     }
 
     // At some point we may want to initiate checkpointing here
   }

bool edm::InputSource::limitReached ( ) const

inlineprivate

Definition at line 359 of file InputSource.h.

References eventLimitReached(), and lumiLimitReached().

Referenced by readEvent(), and readFile().

359 {return eventLimitReached() || lumiLimitReached();}

edm::InputSource::lumiLimitReached

bool lumiLimitReached() const

Definition: InputSource.h:358

edm::InputSource::eventLimitReached

bool eventLimitReached() const

Definition: InputSource.h:357

bool edm::InputSource::lumiLimitReached ( ) const

inlineprivate

Definition at line 358 of file InputSource.h.

References remainingLumis_.

Referenced by limitReached(), and nextItemType().

358 {return remainingLumis_ == 0;}

edm::InputSource::remainingLumis_

int remainingLumis_

Definition: InputSource.h:394

LuminosityBlockNumber_t InputSource::luminosityBlock ( ) const

Accessor for current luminosity block number.

Definition at line 611 of file InputSource.cc.

References luminosityBlockAuxiliary().

Referenced by edm::DQMHttpSource::checkNextEvent(), Types.EventID::cppID(), Types.LuminosityBlockID::cppID(), edm::StreamerInputSource::deserializeEvent(), edm::DaqSource::getNextItemType(), and edm::PoolSource::readIt().

                                      {
     assert(luminosityBlockAuxiliary());
     return luminosityBlockAuxiliary()->luminosityBlock();
   }

boost::shared_ptr<LuminosityBlockAuxiliary> edm::InputSource::luminosityBlockAuxiliary ( ) const

inline

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

Definition at line 247 of file InputSource.h.

References lumiAuxiliary_.

Referenced by edm::DQMHttpSource::checkNextEvent(), edm::StreamerInputSource::deserializeEvent(), edm::RawInputSource::getNextItemType(), edm::DaqSource::getNextItemType(), luminosityBlock(), readAndCacheLumi(), LHESource::readLuminosityBlock_(), edm::RawInputSource::readLuminosityBlockAuxiliary_(), and edm::DaqSource::readLuminosityBlockAuxiliary_().

247 {return lumiAuxiliary_;}

edm::InputSource::lumiAuxiliary_

boost::shared_ptr< LuminosityBlockAuxiliary > lumiAuxiliary_

Definition: InputSource.h:408

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

protected

int edm::InputSource::maxEvents ( ) const

inline

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

Definition at line 175 of file InputSource.h.

References maxEvents_.

175 {return maxEvents_;}

edm::InputSource::maxEvents_

int maxEvents_

Definition: InputSource.h:391

int edm::InputSource::maxLuminosityBlocks ( ) const

inline

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

Definition at line 183 of file InputSource.h.

References maxLumis_.

183 {return maxLumis_;}

edm::InputSource::maxLumis_

int maxLumis_

Definition: InputSource.h:393

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

inline

Accessor for 'module' description.

Definition at line 190 of file InputSource.h.

References moduleDescription_.

Referenced by doBeginLumi(), doBeginRun(), doEndLumi(), doEndRun(), processConfiguration(), readEvent(), edm::ProducerSourceBase::readEvent_(), and registerProducts().

190 {return moduleDescription_;}

edm::InputSource::moduleDescription_

ModuleDescription const moduleDescription_

Definition: InputSource.h:397

bool edm::InputSource::newLumi ( ) const

inlineprotected

Definition at line 344 of file InputSource.h.

References newLumi_.

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

344 {return newLumi_;}

edm::InputSource::newLumi_

bool newLumi_

Definition: InputSource.h:404

bool edm::InputSource::newRun ( ) const

inlineprotected

Definition at line 341 of file InputSource.h.

References newRun_.

Referenced by edm::DaqSource::doMyBeginRun(), edm::RawInputSource::getNextItemType(), edm::ProducerSourceBase::getNextItemType(), edm::DaqSource::getNextItemType(), edm::RawInputSource::readEvent_(), edm::DaqSource::readEvent_(), edm::RawInputSource::readLuminosityBlockAuxiliary_(), edm::DaqSource::readLuminosityBlockAuxiliary_(), edm::RawInputSource::readRunAuxiliary_(), and edm::DaqSource::readRunAuxiliary_().

341 {return newRun_;}

edm::InputSource::newRun_

bool newRun_

Definition: InputSource.h:403

InputSource::ItemType InputSource::nextItemType ( )

Definition at line 187 of file InputSource.cc.

References eventLimitReached(), IsEvent, IsFile, IsInvalid, IsLumi, IsRun, IsStop, lumiAuxiliary_, lumiLimitReached(), nextItemType_(), processingMode(), readLuminosityBlockAuxiliary(), readRunAuxiliary(), runAuxiliary_, Runs, RunsLumisAndEvents, and state_.

                             {
     ItemType oldState = state_;
     if(eventLimitReached()) {
       // If the maximum event limit has been reached, stop.
       state_ = IsStop;
     } else if(lumiLimitReached()) {
       // If the maximum lumi limit has been reached, stop
       // when reaching a new file, run, or lumi.
       if(oldState == IsInvalid || oldState == IsFile || oldState == IsRun || processingMode() != RunsLumisAndEvents) {
         state_ = IsStop;
       } else {
         ItemType newState = nextItemType_();
         if(newState == IsEvent) {
           assert (processingMode() == RunsLumisAndEvents);
           state_ = IsEvent;
         } else {
           state_ = IsStop;
         }
       }
     } else {
       ItemType newState = nextItemType_();
       if(newState == IsStop) {
         state_ = IsStop;
       } else if(newState == IsFile || oldState == IsInvalid) {
         state_ = IsFile;
       } else if(newState == IsRun || oldState == IsFile) {
         runAuxiliary_ = readRunAuxiliary();
         state_ = IsRun;
       } else if(newState == IsLumi || oldState == IsRun) {
         assert (processingMode() != Runs);
         lumiAuxiliary_ = readLuminosityBlockAuxiliary();
         state_ = IsLumi;
       } else {
         assert (processingMode() == RunsLumisAndEvents);
         state_ = IsEvent;
       }
     }
     if(state_ == IsStop) {
       lumiAuxiliary_.reset();
       runAuxiliary_.reset();
     }
     return state_;
   }

InputSource::ItemType InputSource::nextItemType_ ( )

private

Definition at line 172 of file InputSource.cc.

References getNextItemType(), IsEvent, IsLumi, processingMode(), Runs, RunsLumisAndEvents, and skipEvents().

Referenced by nextItemType().

                              {
     ItemType itemType = callWithTryCatchAndPrint<ItemType>( [this](){ return getNextItemType(); }, "Calling InputSource::getNextItemType" );
 
     if(itemType == IsEvent && processingMode() != RunsLumisAndEvents) {
       skipEvents(1);
       return nextItemType_();
     }
     if(itemType == IsLumi && processingMode() == Runs) {
       // QQQ skipLuminosityBlock_();
       return nextItemType_();
     }
     return itemType;
   }

InputSource& edm::InputSource::operator= ( InputSource const & )

delete

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

privatevirtual

Definition at line 576 of file InputSource.cc.

References numberOfEventsBeforeBigSkip_, receiver_, and rewind().

Referenced by doPostForkReacquireResources().

                                                                                                       {
     receiver_ = iReceiver;
     receiver_->receive();
     numberOfEventsBeforeBigSkip_ = receiver_->numberOfConsecutiveIndices();
     rewind();
   }

void InputSource::postRead ( Event & event )

private

Definition at line 486 of file InputSource.cc.

References edm::Service< T >::isAvailable().

Referenced by readEvent().

                                     {
     Service<RandomNumberGenerator> rng;
     if(rng.isAvailable()) {
       rng->postEventRead(event);
     }
   }

void InputSource::preForkReleaseResources ( )

privatevirtual

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

Definition at line 573 of file InputSource.cc.

Referenced by doPreForkReleaseResources().

573 {}

void InputSource::prevalidate ( ConfigurationDescriptions & )

static

Definition at line 122 of file InputSource.cc.

122 {

123 }

bool edm::InputSource::primary ( ) const

inline

Accessor for primary input source flag.

Definition at line 196 of file InputSource.h.

References primary_.

Referenced by edm::PoolSource::PoolSource().

196 {return primary_;}

edm::InputSource::primary_

bool const primary_

Definition: InputSource.h:400

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

inline

Accessor for Process Configuration.

Definition at line 193 of file InputSource.h.

References moduleDescription(), and edm::ModuleDescription::processConfiguration().

Referenced by edm::RootInputFileSequence::processConfiguration(), readAndCacheLumi(), readAndCacheRun(), edm::PoolSource::readLuminosityBlock_(), and edm::PoolSource::readRun_().

193 {return moduleDescription().processConfiguration();}

edm::InputSource::moduleDescription

ModuleDescription const & moduleDescription() const

Accessor for 'module' description.

Definition: InputSource.h:190

edm::ModuleDescription::processConfiguration

ProcessConfiguration const & processConfiguration() const

Definition: ModuleDescription.cc:45

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

inline

Accessor for global process identifier.

Definition at line 199 of file InputSource.h.

References processGUID_.

Referenced by LHESource::readEvent_(), edm::DaqSource::readEvent_(), and edm::ProducerSourceBase::readEvent_().

199 {return processGUID_;}

edm::InputSource::processGUID_

std::string processGUID_

Definition: InputSource.h:401

ProcessingMode edm::InputSource::processingMode ( ) const

inline

RunsLumisAndEvents (default), RunsAndLumis, or Runs.

Definition at line 238 of file InputSource.h.

References processingMode_.

Referenced by edm::ProducerSourceBase::getNextItemType(), edm::RootInputFileSequence::initFile(), InputSource(), nextItemType(), nextItemType_(), LHESource::readEvent_(), edm::ProducerSourceBase::readEvent_(), and edm::ProducerSourceBase::readLuminosityBlockAuxiliary_().

238 {return processingMode_;}

edm::InputSource::processingMode_

ProcessingMode processingMode_

Definition: InputSource.h:396

boost::shared_ptr<ProductRegistry const> edm::InputSource::productRegistry ( ) const

inline

Accessor for product registry.

Definition at line 162 of file InputSource.h.

References productRegistry_.

Referenced by edm::RootInputFileSequence::productRegistry(), and edm::StreamerInputSource::read().

162 {return productRegistry_;}

edm::InputSource::productRegistry_

boost::shared_ptr< ProductRegistry const > productRegistry_

Definition: InputSource.h:398

ProductRegistry& edm::InputSource::productRegistryUpdate ( ) const

inlineprotected

Definition at line 316 of file InputSource.h.

Referenced by edm::DaqSource::DaqSource(), edm::StreamerInputSource::deserializeAndMergeWithRegistry(), LHESource::LHESource(), edm::PoolSource::PoolSource(), edm::RootInputFileSequence::productRegistryUpdate(), and registerProducts().

316 {return const_cast<ProductRegistry&>(*productRegistry_);}

bool InputSource::randomAccess ( ) const

Definition at line 537 of file InputSource.cc.

References randomAccess_().

                                   {
     return callWithTryCatchAndPrint<bool>( [this](){ return randomAccess_(); },
                                            "Calling InputSource::randomAccess_" );
   }

bool InputSource::randomAccess_ ( ) const

privatevirtual

Reimplemented in edm::PoolSource.

Definition at line 584 of file InputSource.cc.

Referenced by randomAccess().

                                    {
     return false;
   }

boost::shared_ptr< LuminosityBlockPrincipal > InputSource::readAndCacheLumi ( HistoryAppender & historyAppender )

Read next run Auxiliary.

Definition at line 238 of file InputSource.cc.

References readRunAuxiliary_().

Referenced by nextItemType().

                                 {
     return callWithTryCatchAndPrint<boost::shared_ptr<RunAuxiliary> >( [this](){ return readRunAuxiliary_(); },
                                                                        "Calling InputSource::readRunAuxiliary_" );
   }

virtual boost::shared_ptr<RunAuxiliary> edm::InputSource::readRunAuxiliary_ ( )

privatepure virtual

Implemented in DQMRootSource, edm::ProducerSourceBase, edm::DaqSource, edm::PoolSource, and edm::RawInputSource.

Referenced by readRunAuxiliary().

ProcessHistoryID const & InputSource::reducedProcessHistoryID ( ) const

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

Definition at line 599 of file InputSource.cc.

References edm::detail::ThreadSafeRegistry< KEY, T, E >::extra(), edm::detail::ThreadSafeRegistry< KEY, T, E >::instance(), and runAuxiliary().

                                              {
     assert(runAuxiliary());
     return ProcessHistoryRegistry::instance()->extra().reduceProcessHistoryID(runAuxiliary()->processHistoryID());
   }

void InputSource::registerProducts ( )

Register any produced products.

Definition at line 254 of file InputSource.cc.

References edm::ProductRegistryHelper::addToRegistry(), begin, relativeConstraints::empty, end, moduleDescription(), productRegistryUpdate(), and edm::ProductRegistryHelper::typeLabelList().

                                 {
     if(!typeLabelList().empty()) {
       addToRegistry(typeLabelList().begin(), typeLabelList().end(), moduleDescription(), productRegistryUpdate());
     }
   }

int edm::InputSource::remainingEvents ( ) const

inline

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

Definition at line 179 of file InputSource.h.

References remainingEvents_.

Referenced by edm::RootInputFileSequence::remainingEvents(), and skipForForking().

179 {return remainingEvents_;}

edm::InputSource::remainingEvents_

int remainingEvents_

Definition: InputSource.h:392

int edm::InputSource::remainingLuminosityBlocks ( ) const

inline

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

Definition at line 187 of file InputSource.h.

References remainingLumis_.

Referenced by edm::RootInputFileSequence::remainingLuminosityBlocks(), and skipForForking().

187 {return remainingLumis_;}

edm::InputSource::remainingLumis_

int remainingLumis_

Definition: InputSource.h:394

void edm::InputSource::repeat ( )

inline

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

Definition at line 168 of file InputSource.h.

References maxEvents_, maxLumis_, remainingEvents_, and remainingLumis_.

                   {
       remainingEvents_ = maxEvents_;
       remainingLumis_ = maxLumis_;
     }

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

inlineprotected

Definition at line 334 of file InputSource.h.

References IsInvalid, resetLuminosityBlockAuxiliary(), resetRunAuxiliary(), and state_.

Referenced by edm::StreamerInputSource::resetAfterEndRun(), and edm::DaqSource::setRun().

                        {
       resetLuminosityBlockAuxiliary();
       resetRunAuxiliary();
       state_ = IsInvalid;
     }

void edm::InputSource::resetEventCached ( )

inlineprotected

Definition at line 350 of file InputSource.h.

References eventCached_.

Referenced by edm::RawInputSource::readEvent_(), LHESource::readEvent_(), edm::DaqSource::readEvent_(), edm::ProducerSourceBase::readEvent_(), and rewind().

350 {eventCached_ = false;}

edm::InputSource::eventCached_

bool eventCached_

Definition: InputSource.h:405

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

inlineprotected

Definition at line 330 of file InputSource.h.

References lumiAuxiliary_, and newLumi_.

Referenced by edm::StreamerInputSource::deserializeEvent(), edm::RawInputSource::getNextItemType(), edm::DaqSource::getNextItemType(), reset(), edm::StreamerInputSource::resetAfterEndRun(), and edm::DaqSource::setRun().

                                                                     {
       lumiAuxiliary_.reset();
       newLumi_ = isNewLumi;
     }

void edm::InputSource::resetNewLumi ( )

inlineprotected

Definition at line 346 of file InputSource.h.

References newLumi_.

Referenced by edm::RawInputSource::readLuminosityBlockAuxiliary_(), edm::DaqSource::readLuminosityBlockAuxiliary_(), and edm::ProducerSourceBase::readLuminosityBlockAuxiliary_().

346 {newLumi_ = false;}

edm::InputSource::newLumi_

bool newLumi_

Definition: InputSource.h:404

void edm::InputSource::resetNewRun ( )

inlineprotected

Definition at line 343 of file InputSource.h.

References newRun_.

Referenced by edm::RawInputSource::readRunAuxiliary_(), edm::DaqSource::readRunAuxiliary_(), and edm::ProducerSourceBase::readRunAuxiliary_().

343 {newRun_ = false;}

edm::InputSource::newRun_

bool newRun_

Definition: InputSource.h:403

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

inlineprotected

Definition at line 326 of file InputSource.h.

References newLumi_, newRun_, and runAuxiliary_.

Referenced by edm::RawInputSource::getNextItemType(), reset(), and edm::StreamerInputSource::resetAfterEndRun().

                                                        {
       runAuxiliary_.reset();
       newRun_ = newLumi_ = isNewRun;
     }

ProcessingController::ReverseState InputSource::reverseState ( ) const

Definition at line 549 of file InputSource.cc.

References reverseState_().

                                   {
     return callWithTryCatchAndPrint<ProcessingController::ReverseState>( [this](){ return reverseState_(); },
                                                                          "Calling InputSource::reverseState__" );
   }

ProcessingController::ReverseState InputSource::reverseState_ ( ) const

privatevirtual

Reimplemented in edm::PoolSource.

Definition at line 594 of file InputSource.cc.

References edm::ProcessingController::kUnknownReverse.

Referenced by reverseState().

                                    {
     return ProcessingController::kUnknownReverse;
   }

void InputSource::rewind ( )

Begin again at the first event.

Definition at line 392 of file InputSource.cc.

References decreaseRemainingEventsBy(), IsInvalid, maxEvents_, receiver_, remainingEvents_, resetEventCached(), rewind_(), setNewLumi(), setNewRun(), skip(), and state_.

Referenced by postForkReacquireResources().

                       {
     state_ = IsInvalid;
     remainingEvents_ = maxEvents_;
     setNewRun();
     setNewLumi();
     resetEventCached();
     callWithTryCatchAndPrint<void>( [this](){ rewind_(); }, "Calling InputSource::rewind_" );
     if(receiver_) {
       unsigned int numberToSkip = receiver_->numberToSkip();
       skip(numberToSkip);
       decreaseRemainingEventsBy(numberToSkip);
     }
   }

void InputSource::rewind_ ( )

privatevirtual

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

Definition at line 466 of file InputSource.cc.

References edm::hlt::Exception, and edm::errors::LogicError.

Referenced by rewind().

                        {
     throw Exception(errors::LogicError)
       << "InputSource::rewind()\n"
       << "Forking and random access are not implemented for this type of Input Source\n"
       << "Contact a Framework Developer\n";
   }

RunNumber_t InputSource::run ( void ) const

Accessor for current run number.

Definition at line 605 of file InputSource.cc.

References runAuxiliary().

Referenced by edm::DQMHttpSource::checkNextEvent(), Types.LuminosityBlockID::cppID(), edm::StreamerInputSource::deserializeEvent(), doBeginRun(), doEndRun(), and edm::PoolSource::readIt().

                          {
     assert(runAuxiliary());
     return runAuxiliary()->run();
   }

boost::shared_ptr<RunAuxiliary> edm::InputSource::runAuxiliary ( ) const

inline

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

Definition at line 244 of file InputSource.h.

References runAuxiliary_.

Referenced by edm::DQMHttpSource::checkNextEvent(), edm::StreamerInputSource::deserializeEvent(), edm::RawInputSource::getNextItemType(), readAndCacheRun(), LHESource::readRun_(), edm::RawInputSource::readRunAuxiliary_(), reducedProcessHistoryID(), and run().

244 {return runAuxiliary_;}

edm::InputSource::runAuxiliary_

boost::shared_ptr< RunAuxiliary > runAuxiliary_

Definition: InputSource.h:407

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

protected

Referenced by LHESource::readRun_(), and readRun_().

void edm::InputSource::setEventCached ( )

inlineprotected

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

Definition at line 349 of file InputSource.h.

References eventCached_.

Referenced by edm::DQMHttpSource::checkNextEvent(), edm::StreamerInputSource::deserializeEvent(), edm::ProducerSourceBase::getNextItemType(), and edm::DaqSource::getNextItemType().

349 {eventCached_ = true;}

edm::InputSource::eventCached_

bool eventCached_

Definition: InputSource.h:405

void InputSource::setLumi ( LuminosityBlockNumber_t lb )

privatevirtual

Reimplemented in edm::DaqSource.

Definition at line 441 of file InputSource.cc.

References edm::hlt::Exception, and edm::errors::LogicError.

Referenced by setLuminosityBlockNumber_t().

                                               {
     throw Exception(errors::LogicError)
       << "InputSource::setLumi()\n"
       << "Luminosity Block ID cannot be modified for this type of Input Source\n"
       << "Contact a Framework Developer\n";
   }

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

inlineprotected

Definition at line 322 of file InputSource.h.

References lumiAuxiliary_, and newLumi_.

Referenced by edm::DQMHttpSource::checkNextEvent(), edm::StreamerInputSource::deserializeEvent(), and edm::DaqSource::getNextItemType().

                                                                     {
       lumiAuxiliary_.reset(lbp);
       newLumi_ = true;
     }

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

inline

Set the luminosity block ID.

Definition at line 153 of file InputSource.h.

References setLumi().

153 {setLumi(lb);}

edm::InputSource::setLumi

virtual void setLumi(LuminosityBlockNumber_t lb)

Definition: InputSource.cc:441

void edm::InputSource::setNewLumi ( )

inlineprotected

Definition at line 345 of file InputSource.h.

References newLumi_.

Referenced by edm::ProducerSourceBase::getNextItemType(), edm::DaqSource::getNextItemType(), rewind(), edm::ProducerSourceBase::rewind_(), and edm::ProducerSourceBase::skip().

345 {newLumi_ = true;}

edm::InputSource::newLumi_

bool newLumi_

Definition: InputSource.h:404

void edm::InputSource::setNewRun ( )

inlineprotected

Definition at line 342 of file InputSource.h.

References newRun_.

Referenced by edm::ProducerSourceBase::getNextItemType(), rewind(), edm::ProducerSourceBase::rewind_(), edm::DaqSource::setRun(), and edm::ProducerSourceBase::skip().

342 {newRun_ = true;}

edm::InputSource::newRun_

bool newRun_

Definition: InputSource.h:403

void InputSource::setRun ( RunNumber_t r )

privatevirtual

Reimplemented in edm::StreamerInputSource, and edm::DaqSource.

Definition at line 433 of file InputSource.cc.

References edm::hlt::Exception, and edm::errors::LogicError.

Referenced by setRunNumber().

                                  {
     throw Exception(errors::LogicError)
       << "InputSource::setRun()\n"
       << "Run number cannot be modified for this type of Input Source\n"
       << "Contact a Framework Developer\n";
   }

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

inlineprotected

Definition at line 318 of file InputSource.h.

References newLumi_, newRun_, and runAuxiliary_.

Referenced by edm::DQMHttpSource::checkNextEvent(), and edm::StreamerInputSource::deserializeEvent().

                                            {
       runAuxiliary_.reset(rp);
       newRun_ = newLumi_ = true;
     }

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

inline

Set the run number.

Definition at line 150 of file InputSource.h.

References setRun().

150 {setRun(r);}

edm::InputSource::setRun

virtual void setRun(RunNumber_t r)

Definition: InputSource.cc:433

alignCSCRings.r

list r

Definition: alignCSCRings.py:92

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

inlineprotected

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

Definition at line 314 of file InputSource.h.

References time_.

Referenced by edm::DaqSource::DaqSource(), edm::DaqSource::getNextItemType(), edm::ProducerSourceBase::ProducerSourceBase(), edm::RawInputSource::RawInputSource(), and readEvent().

314 {time_ = theTime;}

edm::InputSource::time_

Timestamp time_

Definition: InputSource.h:402

void InputSource::skip ( int offset )

protectedvirtual

Reimplemented in edm::ProducerSourceBase, edm::DaqSource, edm::PoolSource, and edm::StreamerFileReader.

Definition at line 449 of file InputSource.cc.

References edm::hlt::Exception, and edm::errors::LogicError.

Referenced by rewind(), and skipEvents().

                        {
     throw Exception(errors::LogicError)
       << "InputSource::skip()\n"
       << "Forking and random access are not implemented for this type of Input Source\n"
       << "Contact a Framework Developer\n";
   }

void InputSource::skipEvents ( int offset )

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

Definition at line 382 of file InputSource.cc.

References evf::evtn::offset(), and skip().

Referenced by nextItemType_(), and skipForForking().

                                     {
     callWithTryCatchAndPrint<void>( [this,&offset](){ skip(offset); }, "Calling InputSource::skip" );
   }

bool InputSource::skipForForking ( )

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

Definition at line 144 of file InputSource.cc.

References decreaseRemainingEventsBy(), eventLimitReached(), numberOfEventsBeforeBigSkip_, or, receiver_, remainingEvents(), remainingLuminosityBlocks(), and skipEvents().

                               {
     if(eventLimitReached()) {
       return false;
     }
     if(receiver_ && 0 == numberOfEventsBeforeBigSkip_) {
       receiver_->receive();
       unsigned long toSkip = receiver_->numberToSkip();
       if(0 != toSkip) {
         skipEvents(toSkip);
         decreaseRemainingEventsBy(toSkip);
       }
       numberOfEventsBeforeBigSkip_ = receiver_->numberOfConsecutiveIndices();
       if(0 == numberOfEventsBeforeBigSkip_ or 0 == remainingEvents() or 0 == remainingLuminosityBlocks()) {
         return false;
       }
     }
     return true;
   }