edm::InputSource Class Reference

#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, IsSynchronize }
enum	ProcessingMode { Runs, RunsAndLumis, RunsLumisAndEvents }
typedef ProductRegistryHelper::TypeLabelList	TypeLabelList

Public Member Functions
std::shared_ptr< ActivityRegistry >	actReg () const
	Accessor for Activity Registry. More...
std::shared_ptr < BranchIDListHelper const >	branchIDListHelper () const
	Accessors for branchIDListHelper. More...
std::shared_ptr < BranchIDListHelper > &	branchIDListHelper ()
void	closeFile (FileBlock *, bool cleaningUpAfterException)
	close current file More...
void	doBeginJob ()
	Called by framework at beginning of job. More...
void	doBeginLumi (LuminosityBlockPrincipal &lbp, ProcessContext const *)
	Called by framework at beginning of lumi block. More...
void	doBeginRun (RunPrincipal &rp, ProcessContext const *)
	Called by framework at beginning of run. More...
void	doEndJob ()
	Called by framework at end of job. More...
void	doEndLumi (LuminosityBlockPrincipal &lbp, bool cleaningUpAfterException, ProcessContext const *)
	Called by framework at end of lumi block. More...
void	doEndRun (RunPrincipal &rp, bool cleaningUpAfterException, ProcessContext const *)
	Called by framework at end of run. More...
void	doPostForkReacquireResources (std::shared_ptr< multicore::MessageReceiverForSource >)
void	doPreForkReleaseResources ()
	Called by the framework before forking the process. More...
ProcessingController::ForwardState	forwardState () const
bool	goToEvent (EventID const &eventID)
	InputSource (ParameterSet const &, InputSourceDescription const &)
	Constructor. More...
	InputSource (InputSource const &)=delete
void	issueReports (EventID const &eventID)
	issue an event report More...
LuminosityBlockNumber_t	luminosityBlock () const
	Accessor for current luminosity block number. More...
std::shared_ptr < LuminosityBlockAuxiliary >	luminosityBlockAuxiliary () const
	Called by the framework to merge or insert lumi in principal cache. More...
int	maxEvents () const
int	maxLuminosityBlocks () const
ModuleDescription const &	moduleDescription () const
	Accessor for 'module' description. More...
ItemType	nextItemType ()
	Advances the source to the next item. More...
InputSource &	operator= (InputSource const &)=delete
ProcessConfiguration const &	processConfiguration () const
	Accessor for Process Configuration. More...
std::string const &	processGUID () const
	Accessor for global process identifier. More...
ProcessHistoryRegistry const &	processHistoryRegistry () const
	Accessors for process history registry. More...
ProcessHistoryRegistry &	processHistoryRegistry ()
ProcessingMode	processingMode () const
	RunsLumisAndEvents (default), RunsAndLumis, or Runs. More...
std::shared_ptr < ProductRegistry const >	productRegistry () const
	Accessors for product registry. More...
std::shared_ptr < ProductRegistry > &	productRegistry ()
bool	randomAccess () const
void	readAndMergeLumi (LuminosityBlockPrincipal &lbp)
	Read next luminosity block (same as a prior lumi) More...
void	readAndMergeRun (RunPrincipal &rp)
	Read next run (same as a prior run) More...
void	readEvent (EventPrincipal &ep, StreamContext &)
	Read next event. More...
bool	readEvent (EventPrincipal &ep, EventID const &, StreamContext &)
	Read a specific event. More...
std::unique_ptr< FileBlock >	readFile ()
	Read next file. More...
void	readLuminosityBlock (LuminosityBlockPrincipal &lumiPrincipal, HistoryAppender &historyAppender)
	Read next luminosity block (new lumi) More...
std::shared_ptr < LuminosityBlockAuxiliary >	readLuminosityBlockAuxiliary ()
	Read next luminosity block Auxilary. More...
void	readRun (RunPrincipal &runPrincipal, HistoryAppender &historyAppender)
	Read next run (new run) More...
std::shared_ptr< RunAuxiliary >	readRunAuxiliary ()
	Read next run Auxiliary. More...
ProcessHistoryID const &	reducedProcessHistoryID () const
void	registerProducts ()
	Register any produced products. More...
int	remainingEvents () const
int	remainingLuminosityBlocks () const
void	repeat ()
	Reset the remaining number of events/lumis to the maximum number. More...
SharedResourcesAcquirer *	resourceSharedWithDelayedReader ()
	Returns nullptr if no resource shared between the Source and a DelayedReader. More...
ProcessingController::ReverseState	reverseState () const
void	rewind ()
	Begin again at the first event. More...
RunNumber_t	run () const
	Accessor for current run number. More...
std::shared_ptr< RunAuxiliary >	runAuxiliary () const
	Called by the framework to merge or insert run in principal cache. More...
void	setLuminosityBlockNumber_t (LuminosityBlockNumber_t lb)
	Set the luminosity block ID. More...
void	setRunNumber (RunNumber_t r)
	Set the run number. More...
void	skipEvents (int offset)
bool	skipForForking ()
std::shared_ptr < ThinnedAssociationsHelper const >	thinnedAssociationsHelper () const
	Accessors for thinnedAssociationsHelper. More...
std::shared_ptr < ThinnedAssociationsHelper > &	thinnedAssociationsHelper ()
Timestamp const &	timestamp () const
	Accessor for the current time, as seen by the input source. More...
virtual	~InputSource ()
	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
bool	newLumi () const
bool	newRun () const
ProcessHistoryRegistry &	processHistoryRegistryForUpdate ()
ProductRegistry &	productRegistryUpdate ()
void	reset () const
void	resetEventCached ()
void	resetLuminosityBlockAuxiliary (bool isNewLumi=true) const
void	resetNewLumi ()
void	resetNewRun ()
void	resetRunAuxiliary (bool isNewRun=true) const
void	setEventCached ()
	Called by the framework to merge or ached() const {return eventCached_;}. More...
void	setLuminosityBlockAuxiliary (LuminosityBlockAuxiliary *lbp)
void	setNewLumi ()
void	setNewRun ()
void	setRunAuxiliary (RunAuxiliary *rp)
void	setTimestamp (Timestamp const &theTime)
	To set the current time, as seen by the input source. More...
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 (std::shared_ptr< multicore::MessageReceiverForSource >)
virtual void	preForkReleaseResources ()
virtual bool	randomAccess_ () const
virtual void	readEvent_ (EventPrincipal &eventPrincipal)=0
virtual std::unique_ptr < FileBlock >	readFile_ ()
virtual bool	readIt (EventID const &id, EventPrincipal &eventPrincipal, StreamContext &streamContext)
virtual void	readLuminosityBlock_ (LuminosityBlockPrincipal &lumiPrincipal)
virtual std::shared_ptr < LuminosityBlockAuxiliary >	readLuminosityBlockAuxiliary_ ()=0
virtual void	readRun_ (RunPrincipal &runPrincipal)
virtual std::shared_ptr < RunAuxiliary >	readRunAuxiliary_ ()=0
virtual SharedResourcesAcquirer *	resourceSharedWithDelayedReader_ ()
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
std::shared_ptr< ActivityRegistry >	actReg_
edm::propagate_const < std::shared_ptr < BranchIDListHelper > >	branchIDListHelper_
bool	eventCached_
std::shared_ptr < LuminosityBlockAuxiliary >	lumiAuxiliary_
int	maxEvents_
int	maxLumis_
int	maxSecondsUntilRampdown_
ModuleDescription const	moduleDescription_
bool	newLumi_
bool	newRun_
unsigned int	numberOfEventsBeforeBigSkip_
std::string	processGUID_
edm::propagate_const < std::unique_ptr < ProcessHistoryRegistry > >	processHistoryRegistry_
ProcessingMode	processingMode_
std::chrono::time_point < std::chrono::steady_clock >	processingStart_
edm::propagate_const < std::shared_ptr < ProductRegistry > >	productRegistry_
int	readCount_
edm::propagate_const < std::shared_ptr < edm::multicore::MessageReceiverForSource > >	receiver_
int	remainingEvents_
int	remainingLumis_
std::shared_ptr< RunAuxiliary >	runAuxiliary_
ItemType	state_
std::string	statusFileName_
edm::propagate_const < std::shared_ptr < ThinnedAssociationsHelper > >	thinnedAssociationsHelper_
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 77 of file InputSource.h.

Member Typedef Documentation

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

Definition at line 96 of file InputSource.h.

Member Enumeration Documentation

enum edm::InputSource::ItemType

Enumerator
IsInvalid
IsStop
IsFile
IsRun
IsLumi
IsEvent
IsRepeat
IsSynchronize

Definition at line 79 of file InputSource.h.

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

enum edm::InputSource::ProcessingMode

Enumerator
Runs
RunsAndLumis
RunsLumisAndEvents

Definition at line 90 of file InputSource.h.

                        {
      Runs,
      RunsAndLumis,
      RunsLumisAndEvents
    };

Constructor & Destructor Documentation

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

explicit

Constructor.

Definition at line 47 of file InputSource.cc.

References edm::errors::Configuration, Exception, edm::ParameterSet::getUntrackedParameter(), maxSecondsUntilRampdown_, fileCollector::now, processingMode(), processingMode_, processingStart_, Runs, RunsAndLumis, statusFileName_, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                       :
      ProductRegistryHelper(),
      actReg_(desc.actReg_),
      maxEvents_(desc.maxEvents_),
      remainingEvents_(maxEvents_),
      maxLumis_(desc.maxLumis_),
      remainingLumis_(maxLumis_),
      readCount_(0),
      maxSecondsUntilRampdown_(desc.maxSecondsUntilRampdown_),
      processingMode_(RunsLumisAndEvents),
      moduleDescription_(desc.moduleDescription_),
      productRegistry_(desc.productRegistry_),
      processHistoryRegistry_(new ProcessHistoryRegistry),
      branchIDListHelper_(desc.branchIDListHelper_),
      thinnedAssociationsHelper_(desc.thinnedAssociationsHelper_),
      processGUID_(createGlobalIdentifier()),
      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();
    }
    if (maxSecondsUntilRampdown_ > 0) {
      processingStart_ = std::chrono::steady_clock::now();
    }

    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 105 of file InputSource.cc.

{}

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

delete

Member Function Documentation

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

inline

Accessor for Activity Registry.

Definition at line 259 of file InputSource.h.

References actReg_.

Referenced by edm::InputSource::EventSourceSentry::EventSourceSentry(), edm::InputSource::FileCloseSentry::FileCloseSentry(), and edm::InputSource::FileOpenSentry::FileOpenSentry().

{return actReg_;}

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

static

Definition at line 122 of file InputSource.cc.

References edm::kBaseType().

                        {
    return kBaseType;
  }

void InputSource::beginJob ( void  )

privatevirtual

Reimplemented in edm::ProducerSourceBase.

Definition at line 552 of file InputSource.cc.

Referenced by doBeginJob().

{}

void InputSource::beginLuminosityBlock ( LuminosityBlock &  )

privatevirtual

Reimplemented in edm::ProducerSourceBase, FRDStreamSource, and dqmservices::DQMProtobufReader.

Definition at line 540 of file InputSource.cc.

Referenced by doBeginLumi().

{}

void InputSource::beginRun ( Run &  )

privatevirtual

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

Definition at line 546 of file InputSource.cc.

Referenced by doBeginRun().

{}

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

inline

Accessors for branchIDListHelper.

Definition at line 178 of file InputSource.h.

References branchIDListHelper_, and edm::get_underlying_safe().

Referenced by edm::StreamerInputSource::deserializeAndMergeWithRegistry(), edm::RootSecondaryFileSequence::makeRootFile(), edm::RootPrimaryFileSequence::makeRootFile(), and edm::StreamerInputSource::read().

{return get_underlying_safe(branchIDListHelper_);}

std::shared_ptr<BranchIDListHelper>& edm::InputSource::branchIDListHelper ( )

inline

Definition at line 179 of file InputSource.h.

References branchIDListHelper_, and edm::get_underlying_safe().

{return get_underlying_safe(branchIDListHelper_);}

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

close current file

Definition at line 275 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, and edm::RawInputSource.

Definition at line 409 of file InputSource.h.

Referenced by closeFile().

{}

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 467 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 239 of file InputSource.cc.

References beginJob().

                          {
    this->beginJob();
  }

void InputSource::doBeginLumi	(	LuminosityBlockPrincipal &	lbp,
		ProcessContext const *
	)

Called by framework at beginning of lumi block.

Definition at line 495 of file InputSource.cc.

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

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

void InputSource::doBeginRun	(	RunPrincipal &	rp,
		ProcessContext const *
	)

Called by framework at beginning of run.

Definition at line 479 of file InputSource.cc.

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

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

void InputSource::doEndJob

(

)

Called by framework at end of job.

Definition at line 244 of file InputSource.cc.

References endJob().

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

                        {
    endJob();
  }

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

Called by framework at end of lumi block.

Definition at line 502 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(), nullptr);
    callWithTryCatchAndPrint<void>( [this,&lb](){ endLuminosityBlock(lb); }, "Calling InputSource::endLuminosityBlock", cleaningUpAfterException );
    lb.commit_();
  }

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

Called by framework at end of run.

Definition at line 486 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(), nullptr);
    callWithTryCatchAndPrint<void>( [this,&run](){ endRun(run); }, "Calling InputSource::endRun", cleaningUpAfterException );
    run.commit_();
  }

void InputSource::doPostForkReacquireResources

(

std::shared_ptr< multicore::MessageReceiverForSource >

iReceiver

)

Definition at line 516 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 511 of file InputSource.cc.

References preForkReleaseResources().

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

void InputSource::endJob ( void  )

privatevirtual

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

Definition at line 555 of file InputSource.cc.

Referenced by doEndJob().

{}

void InputSource::endLuminosityBlock ( LuminosityBlock &  )

privatevirtual

Reimplemented in edm::ProducerSourceBase, and FRDStreamSource.

Definition at line 543 of file InputSource.cc.

Referenced by doEndLumi().

{}

void InputSource::endRun ( Run &  )

privatevirtual

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

Definition at line 549 of file InputSource.cc.

Referenced by doEndRun().

{}

bool edm::InputSource::eventCached ( ) const

inlineprotected

Definition at line 380 of file InputSource.h.

References eventCached_.

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

{return eventCached_;}

bool edm::InputSource::eventLimitReached ( ) const

inlineprivate

Definition at line 390 of file InputSource.h.

References remainingEvents_.

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

{return remainingEvents_ == 0;}

void InputSource::fillDescription ( ParameterSetDescription &  desc )

static

Definition at line 127 of file InputSource.cc.

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

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

                                                            {
    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 108 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 528 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 574 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::PoolSource, edm::ProducerSourceBase, edm::RawInputSource, and dqmservices::DQMProtobufReader.

Referenced by nextItemType_().

bool InputSource::goToEvent

(

EventID const &

eventID

)

Definition at line 380 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 450 of file InputSource.cc.

References 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 400 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 399 of file InputSource.h.

References eventLimitReached(), and lumiLimitReached().

Referenced by readEvent(), and readFile().

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

bool edm::InputSource::lumiLimitReached ( ) const

inlineprivate

Definition at line 391 of file InputSource.h.

References KineDebug3::count(), end, maxSecondsUntilRampdown_, fileCollector::now, processingStart_, and remainingLumis_.

Referenced by limitReached(), and nextItemType().

                                  {
      if (remainingLumis_ == 0) {return true;}
      if (maxSecondsUntilRampdown_ <= 0) {return false;}
      auto end = std::chrono::steady_clock::now();
      auto elapsed = end - processingStart_;
      if (std::chrono::duration_cast<std::chrono::seconds>(elapsed).count() > maxSecondsUntilRampdown_) {return true;}
      return false;
    }

LuminosityBlockNumber_t InputSource::luminosityBlock

(

)

const

Accessor for current luminosity block number.

Definition at line 596 of file InputSource.cc.

References assert(), and luminosityBlockAuxiliary().

Referenced by Types.EventID::cppID(), Types.LuminosityBlockID::cppID(), edm::StreamerInputSource::deserializeEvent(), FedRawDataInputSource::maybeOpenNewLumiSection(), and edm::PoolSource::readIt().

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

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

inline

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

Definition at line 265 of file InputSource.h.

References lumiAuxiliary_.

Referenced by edm::StreamerInputSource::deserializeEvent(), edm::RawInputSource::getNextItemType(), luminosityBlock(), FedRawDataInputSource::maybeOpenNewLumiSection(), LHESource::readLuminosityBlock_(), and edm::RawInputSource::readLuminosityBlockAuxiliary_().

{return lumiAuxiliary_;}

int edm::InputSource::maxEvents ( ) const

inline

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

Definition at line 196 of file InputSource.h.

References maxEvents_.

{return maxEvents_;}

int edm::InputSource::maxLuminosityBlocks ( ) const

inline

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

Definition at line 204 of file InputSource.h.

References maxLumis_.

{return maxLumis_;}

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

inline

Accessor for 'module' description.

Definition at line 211 of file InputSource.h.

References moduleDescription_.

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

{return moduleDescription_;}

bool edm::InputSource::newLumi ( ) const

inlineprotected

Definition at line 377 of file InputSource.h.

References newLumi_.

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

{return newLumi_;}

bool edm::InputSource::newRun ( ) const

inlineprotected

Definition at line 374 of file InputSource.h.

References newRun_.

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

{return newRun_;}

InputSource::ItemType InputSource::nextItemType

(

)

Advances the source to the next item.

Definition at line 180 of file InputSource.cc.

References assert(), eventLimitReached(), IsEvent, IsFile, IsInvalid, IsLumi, IsRun, IsStop, IsSynchronize, 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 == IsSynchronize) {
        state_ = IsSynchronize;
      } 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 165 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 ( std::shared_ptr< multicore::MessageReceiverForSource >  iReceiver )

privatevirtual

Definition at line 561 of file InputSource.cc.

References numberOfEventsBeforeBigSkip_, receiver_, and rewind().

Referenced by doPostForkReacquireResources().

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

void InputSource::preForkReleaseResources ( )

privatevirtual

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

Definition at line 558 of file InputSource.cc.

Referenced by doPreForkReleaseResources().

{}

void InputSource::prevalidate ( ConfigurationDescriptions &  )

static

Definition at line 115 of file InputSource.cc.

                                                      {
  }

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

inline

Accessor for Process Configuration.

Definition at line 214 of file InputSource.h.

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

Referenced by edm::RootSecondaryFileSequence::makeRootFile(), edm::RootPrimaryFileSequence::makeRootFile(), edm::PoolSource::readLuminosityBlock_(), and edm::PoolSource::readRun_().

{return moduleDescription().processConfiguration();}

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

inline

Accessor for global process identifier.

Definition at line 217 of file InputSource.h.

References processGUID_.

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

{return processGUID_;}

ProcessHistoryRegistry const& edm::InputSource::processHistoryRegistry ( ) const

inline

Accessors for process history registry.

Definition at line 174 of file InputSource.h.

References processHistoryRegistry_.

Referenced by edm::RawInputSource::makeEvent(), edm::StreamerInputSource::read(), edm::ProducerSourceBase::readEvent_(), readLuminosityBlock_(), and readRun_().

{return *processHistoryRegistry_;}

ProcessHistoryRegistry& edm::InputSource::processHistoryRegistry ( )

inline

Definition at line 175 of file InputSource.h.

References processHistoryRegistry_.

{return *processHistoryRegistry_;}

ProcessHistoryRegistry& edm::InputSource::processHistoryRegistryForUpdate ( )

inlineprotected

Definition at line 351 of file InputSource.h.

References processHistoryRegistry_.

Referenced by edm::StreamerInputSource::deserializeEvent(), FedRawDataInputSource::FedRawDataInputSource(), LHESource::LHESource(), edm::RootSecondaryFileSequence::makeRootFile(), edm::RootPrimaryFileSequence::makeRootFile(), LHESource::nextEvent(), LHESource::readEvent_(), dqmservices::DQMProtobufReader::readLuminosityBlock_(), LHESource::readLuminosityBlock_(), DQMRootSource::readLuminosityBlock_(), dqmservices::DQMProtobufReader::readRun_(), LHESource::readRun_(), DQMRootSource::readRun_(), and DQMRootSource::setupFile().

{return *processHistoryRegistry_;}

ProcessingMode edm::InputSource::processingMode ( ) const

inline

RunsLumisAndEvents (default), RunsAndLumis, or Runs.

Definition at line 256 of file InputSource.h.

References processingMode_.

Referenced by edm::ProducerSourceBase::getNextItemType(), InputSource(), edm::RootSecondaryFileSequence::makeRootFile(), edm::RootPrimaryFileSequence::makeRootFile(), nextItemType(), nextItemType_(), LHESource::readEvent_(), edm::ProducerSourceBase::readEvent_(), and edm::ProducerSourceBase::readLuminosityBlockAuxiliary_().

{return processingMode_;}

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

inline

Accessors for product registry.

Definition at line 170 of file InputSource.h.

References edm::get_underlying_safe(), and productRegistry_.

Referenced by edm::StreamerInputSource::read().

{return get_underlying_safe(productRegistry_);}

std::shared_ptr<ProductRegistry>& edm::InputSource::productRegistry ( )

inline

Definition at line 171 of file InputSource.h.

References edm::get_underlying_safe(), and productRegistry_.

{return get_underlying_safe(productRegistry_);}

ProductRegistry& edm::InputSource::productRegistryUpdate ( )

inlineprotected

Definition at line 350 of file InputSource.h.

References productRegistry_.

Referenced by edm::StreamerInputSource::deserializeAndMergeWithRegistry(), FedRawDataInputSource::FedRawDataInputSource(), edm::RootPrimaryFileSequence::nextFile(), edm::RootPrimaryFileSequence::previousFile(), registerProducts(), edm::RootPrimaryFileSequence::RootPrimaryFileSequence(), and edm::RootSecondaryFileSequence::RootSecondaryFileSequence().

{return *productRegistry_;}

bool InputSource::randomAccess

(

)

const

Definition at line 522 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 569 of file InputSource.cc.

Referenced by randomAccess().

                                   {
    return false;
  }

void InputSource::readAndMergeLumi

(

LuminosityBlockPrincipal &

lbp

)

Read next luminosity block (same as a prior lumi)

Definition at line 313 of file InputSource.cc.

References readLuminosityBlock_(), and remainingLumis_.

                                                             {
    LumiSourceSentry sentry(*this);
    callWithTryCatchAndPrint<void>( [this,&lbp](){ readLuminosityBlock_(lbp); }, "Calling InputSource::readLuminosityBlock_" );
    if(remainingLumis_ > 0) {
      --remainingLumis_;
    }
  }

void InputSource::readAndMergeRun

(

RunPrincipal &

rp

)

Read next run (same as a prior run)

Definition at line 298 of file InputSource.cc.

References readRun_().

                                               {
    RunSourceSentry sentry(*this);
    callWithTryCatchAndPrint<void>( [this,&rp](){ readRun_(rp); }, "Calling InputSource::readRun_" );
  }

void InputSource::readEvent	(	EventPrincipal &	ep,
		StreamContext &	streamContext
	)

Read next event.

Definition at line 335 of file InputSource.cc.

References assert(), eventLimitReached(), edm::EventPrincipal::id(), IsEvent, issueReports(), numberOfEventsBeforeBigSkip_, readCount_, readEvent_(), receiver_, remainingEvents_, setTimestamp(), state_, and edm::EventPrincipal::time().

                                                                         {
    assert(state_ == IsEvent);
    assert(!eventLimitReached());
    {
      // block scope, in order to issue the PostSourceEvent signal before calling postRead and issueReports
      EventSourceSentry sentry(*this, streamContext);

      callWithTryCatchAndPrint<void>( [this,&ep](){ readEvent_(ep); }, "Calling InputSource::readEvent_" );
      if(receiver_) {
        --numberOfEventsBeforeBigSkip_;
      }
    }

    if(remainingEvents_ > 0) --remainingEvents_;
    ++readCount_;
    setTimestamp(ep.time());
    issueReports(ep.id());
  }

bool InputSource::readEvent	(	EventPrincipal &	ep,
		EventID const &	eventID,
		StreamContext &	streamContext
	)

Read a specific event.

Definition at line 355 of file InputSource.cc.

References edm::EventPrincipal::id(), issueReports(), limitReached(), readCount_, readIt(), remainingEvents_, and mps_fire::result.

                                                                                                 {
    bool result = false;

    if (not limitReached()) {
      // the Pre/PostSourceEvent signals should be generated only if the event is actually found.
      // this should be taken care of by an EventSourceSentry in the implementaion of readIt()

      //result = callWithTryCatchAndPrint<bool>( [this,&eventID,&ep](){ return readIt(eventID, ep); }, "Calling InputSource::readIt" );
      result = readIt(eventID, ep, streamContext);

      if (result) {
        if(remainingEvents_ > 0) --remainingEvents_;
        ++readCount_;
        issueReports(ep.id());
      }
    }
    return result;
  }

virtual void edm::InputSource::readEvent_ ( EventPrincipal &  eventPrincipal )

privatepure virtual

Implemented in DQMRootSource, edm::ProducerSourceBase, edm::PoolSource, LHESource, dqmservices::DQMProtobufReader, and edm::RawInputSource.

Referenced by readEvent().

std::unique_ptr< FileBlock > InputSource::readFile

(

)

Read next file.

Definition at line 267 of file InputSource.cc.

References assert(), IsFile, limitReached(), readFile_(), and state_.

Referenced by Vispa.Plugins.EventBrowser.EventBrowserTabController.EventBrowserTabController::navigate(), Vispa.Main.TabController.TabController::open(), and Vispa.Main.TabController.TabController::refresh().

                        {
    assert(state_ == IsFile);
    assert(!limitReached());
    return callWithTryCatchAndPrint<std::unique_ptr<FileBlock> >( [this](){ return readFile_(); },
                                                                  "Calling InputSource::readFile_" );
  }

std::unique_ptr< FileBlock > InputSource::readFile_ ( )

privatevirtual

Reimplemented in DQMRootSource, edm::StreamerInputSource, and edm::PoolSource.

Definition at line 287 of file InputSource.cc.

Referenced by readFile().

                         {
    return std::unique_ptr<FileBlock>(new FileBlock);
  }

bool InputSource::readIt ( EventID const &  id, EventPrincipal &  eventPrincipal, StreamContext &  streamContext  )

privatevirtual

Reimplemented in edm::PoolSource.

Definition at line 418 of file InputSource.cc.

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

Referenced by readEvent().

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

void InputSource::readLuminosityBlock	(	LuminosityBlockPrincipal &	lumiPrincipal,
		HistoryAppender &	historyAppender
	)

Read next luminosity block (new lumi)

Definition at line 304 of file InputSource.cc.

References readLuminosityBlock_(), and remainingLumis_.

                                                                                             {
    LumiSourceSentry sentry(*this);
    callWithTryCatchAndPrint<void>( [this,&lumiPrincipal](){ readLuminosityBlock_(lumiPrincipal); }, "Calling InputSource::readLuminosityBlock_" );
    if(remainingLumis_ > 0) {
      --remainingLumis_;
    }
  }

void InputSource::readLuminosityBlock_ ( LuminosityBlockPrincipal &  lumiPrincipal )

privatevirtual

Reimplemented in DQMRootSource, edm::PoolSource, LHESource, and dqmservices::DQMProtobufReader.

Definition at line 330 of file InputSource.cc.

References edm::LuminosityBlockPrincipal::fillLuminosityBlockPrincipal(), and processHistoryRegistry().

Referenced by readAndMergeLumi(), and readLuminosityBlock().

                                                                           {
    lumiPrincipal.fillLuminosityBlockPrincipal(processHistoryRegistry());
  }

std::shared_ptr< LuminosityBlockAuxiliary > InputSource::readLuminosityBlockAuxiliary

(

)

Read next luminosity block Auxilary.

Definition at line 227 of file InputSource.cc.

References readLuminosityBlockAuxiliary_().

Referenced by nextItemType().

                                            {
    return callWithTryCatchAndPrint<std::shared_ptr<LuminosityBlockAuxiliary> >( [this](){ return readLuminosityBlockAuxiliary_(); },
                                                                                   "Calling InputSource::readLuminosityBlockAuxiliary_" );
  }

virtual std::shared_ptr<LuminosityBlockAuxiliary> edm::InputSource::readLuminosityBlockAuxiliary_ ( )

privatepure virtual

Implemented in DQMRootSource, edm::ProducerSourceBase, edm::PoolSource, edm::RawInputSource, and dqmservices::DQMProtobufReader.

Referenced by readLuminosityBlockAuxiliary().

void InputSource::readRun	(	RunPrincipal &	runPrincipal,
		HistoryAppender &	historyAppender
	)

Read next run (new run)

Definition at line 292 of file InputSource.cc.

References readRun_().

                                                                    {
    RunSourceSentry sentry(*this);
    callWithTryCatchAndPrint<void>( [this,&runPrincipal](){ readRun_(runPrincipal); }, "Calling InputSource::readRun_" );
  }

void InputSource::readRun_ ( RunPrincipal &  runPrincipal )

privatevirtual

Reimplemented in DQMRootSource, edm::PoolSource, LHESource, and dqmservices::DQMProtobufReader.

Definition at line 322 of file InputSource.cc.

References edm::RunPrincipal::fillRunPrincipal(), and processHistoryRegistry().

Referenced by readAndMergeRun(), and readRun().

                                                  {
    // Note: For the moment, we do not support saving and restoring the state of the
    // random number generator if random numbers are generated during processing of runs
    // (e.g. beginRun(), endRun())
    runPrincipal.fillRunPrincipal(processHistoryRegistry());
  }

std::shared_ptr< RunAuxiliary > InputSource::readRunAuxiliary

(

)

Read next run Auxiliary.

Definition at line 233 of file InputSource.cc.

References readRunAuxiliary_().

Referenced by nextItemType().

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

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

privatepure virtual

Implemented in DQMRootSource, edm::ProducerSourceBase, edm::PoolSource, edm::RawInputSource, and dqmservices::DQMProtobufReader.

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 584 of file InputSource.cc.

References assert(), processHistoryRegistry_, and runAuxiliary().

                                             {
    assert(runAuxiliary());
    return processHistoryRegistry_->reducedProcessHistoryID(runAuxiliary()->processHistoryID());
  }

void InputSource::registerProducts

(

)

Register any produced products.

Definition at line 259 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 200 of file InputSource.h.

References remainingEvents_.

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

{return remainingEvents_;}

int edm::InputSource::remainingLuminosityBlocks ( ) const

inline

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

Definition at line 208 of file InputSource.h.

References remainingLumis_.

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

{return remainingLumis_;}

void edm::InputSource::repeat ( )

inline

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

Definition at line 186 of file InputSource.h.

References maxEvents_, maxLumis_, remainingEvents_, and remainingLumis_.

                  {
      remainingEvents_ = maxEvents_;
      remainingLumis_ = maxLumis_;
    }

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

inlineprotected

Definition at line 369 of file InputSource.h.

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

Referenced by edm::StreamerInputSource::resetAfterEndRun().

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

void edm::InputSource::resetEventCached ( )

inlineprotected

Definition at line 383 of file InputSource.h.

References eventCached_.

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

{eventCached_ = false;}

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

inlineprotected

Definition at line 365 of file InputSource.h.

References lumiAuxiliary_, and newLumi_.

Referenced by FedRawDataInputSource::checkNextEvent(), edm::StreamerInputSource::deserializeEvent(), edm::RawInputSource::getNextItemType(), FedRawDataInputSource::maybeOpenNewLumiSection(), reset(), and edm::StreamerInputSource::resetAfterEndRun().

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

void edm::InputSource::resetNewLumi ( )

inlineprotected

Definition at line 379 of file InputSource.h.

References newLumi_.

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

{newLumi_ = false;}

void edm::InputSource::resetNewRun ( )

inlineprotected

Definition at line 376 of file InputSource.h.

References newRun_.

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

{newRun_ = false;}

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

inlineprotected

Definition at line 361 of file InputSource.h.

References newLumi_, newRun_, and runAuxiliary_.

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

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

SharedResourcesAcquirer * InputSource::resourceSharedWithDelayedReader

(

)

Returns nullptr if no resource shared between the Source and a DelayedReader.

Definition at line 249 of file InputSource.cc.

References resourceSharedWithDelayedReader_().

                                               {
    return resourceSharedWithDelayedReader_();
  }

SharedResourcesAcquirer * InputSource::resourceSharedWithDelayedReader_ ( )

privatevirtual

Reimplemented in edm::PoolSource.

Definition at line 254 of file InputSource.cc.

Referenced by resourceSharedWithDelayedReader().

                                                {
    return nullptr;
  }

ProcessingController::ReverseState InputSource::reverseState

(

)

const

Definition at line 534 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 579 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 385 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::PoolSource, FedRawDataInputSource, edm::ProducerSourceBase, and edm::RawInputSource.

Definition at line 459 of file InputSource.cc.

References 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 590 of file InputSource.cc.

References assert(), and runAuxiliary().

Referenced by Types.EventID::cppID(), Types.LuminosityBlockID::cppID(), edm::StreamerInputSource::deserializeEvent(), doBeginRun(), doEndRun(), edm::PoolSource::getNextItemType(), FedRawDataInputSource::maybeOpenNewLumiSection(), and edm::PoolSource::readIt().

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

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

inline

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

Definition at line 262 of file InputSource.h.

References runAuxiliary_.

Referenced by edm::StreamerInputSource::deserializeEvent(), FedRawDataInputSource::FedRawDataInputSource(), edm::RawInputSource::getNextItemType(), FedRawDataInputSource::maybeOpenNewLumiSection(), LHESource::readRun_(), edm::RawInputSource::readRunAuxiliary_(), reducedProcessHistoryID(), and run().

{return runAuxiliary_;}

void edm::InputSource::setEventCached ( )

inlineprotected

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

Definition at line 382 of file InputSource.h.

References eventCached_.

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

{eventCached_ = true;}

void InputSource::setLumi ( LuminosityBlockNumber_t  lb )

privatevirtual

Definition at line 434 of file InputSource.cc.

References 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 357 of file InputSource.h.

References lumiAuxiliary_, and newLumi_.

Referenced by edm::StreamerInputSource::deserializeEvent(), and FedRawDataInputSource::maybeOpenNewLumiSection().

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

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

inline

Set the luminosity block ID.

Definition at line 161 of file InputSource.h.

References setLumi().

{setLumi(lb);}

void edm::InputSource::setNewLumi ( )

inlineprotected

Definition at line 378 of file InputSource.h.

References newLumi_.

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

{newLumi_ = true;}

void edm::InputSource::setNewRun ( )

inlineprotected

Definition at line 375 of file InputSource.h.

References newRun_.

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

{newRun_ = true;}

void InputSource::setRun ( RunNumber_t  r )

privatevirtual

Reimplemented in edm::StreamerInputSource.

Definition at line 426 of file InputSource.cc.

References 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 353 of file InputSource.h.

References newLumi_, newRun_, and runAuxiliary_.

Referenced by edm::StreamerInputSource::deserializeEvent(), FedRawDataInputSource::FedRawDataInputSource(), and FedRawDataInputSource::postForkReacquireResources().

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

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

inline

Set the run number.

Definition at line 158 of file InputSource.h.

References setRun().

{setRun(r);}

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

inlineprotected

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

Definition at line 348 of file InputSource.h.

References time_.

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

{time_ = theTime;}

void InputSource::skip ( int  offset )

protectedvirtual

Reimplemented in edm::PoolSource, edm::ProducerSourceBase, dqmservices::DQMStreamerReader, and edm::StreamerFileReader.

Definition at line 442 of file InputSource.cc.

References 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 375 of file InputSource.cc.

References hltrates_dqm_sourceclient-live_cfg::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 137 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;
  }

ItemType edm::InputSource::state ( ) const

inlineprotected

Definition at line 352 of file InputSource.h.

References state_.

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

{return state_;}

std::shared_ptr<ThinnedAssociationsHelper const> edm::InputSource::thinnedAssociationsHelper ( ) const

inline

Accessors for thinnedAssociationsHelper.

Definition at line 182 of file InputSource.h.

References edm::get_underlying_safe(), and thinnedAssociationsHelper_.

Referenced by edm::StreamerInputSource::deserializeAndMergeWithRegistry(), edm::RootSecondaryFileSequence::makeRootFile(), and edm::RootPrimaryFileSequence::makeRootFile().

{return get_underlying_safe(thinnedAssociationsHelper_);}

std::shared_ptr<ThinnedAssociationsHelper>& edm::InputSource::thinnedAssociationsHelper ( )

inline

Definition at line 183 of file InputSource.h.

References edm::get_underlying_safe(), and thinnedAssociationsHelper_.

{return get_underlying_safe(thinnedAssociationsHelper_);}

Timestamp const& edm::InputSource::timestamp ( ) const

inline

Accessor for the current time, as seen by the input source.

Definition at line 242 of file InputSource.h.

References time_.

{return time_;}

Member Data Documentation

std::shared_ptr<ActivityRegistry> edm::InputSource::actReg_

private

Definition at line 430 of file InputSource.h.

Referenced by actReg().

edm::propagate_const<std::shared_ptr<BranchIDListHelper> > edm::InputSource::branchIDListHelper_

private

Definition at line 442 of file InputSource.h.

Referenced by branchIDListHelper().

bool edm::InputSource::eventCached_

private

Definition at line 448 of file InputSource.h.

Referenced by eventCached(), resetEventCached(), and setEventCached().

std::shared_ptr<LuminosityBlockAuxiliary> edm::InputSource::lumiAuxiliary_

mutableprivate

Definition at line 451 of file InputSource.h.

Referenced by luminosityBlockAuxiliary(), nextItemType(), resetLuminosityBlockAuxiliary(), and setLuminosityBlockAuxiliary().

int edm::InputSource::maxEvents_

private

Definition at line 431 of file InputSource.h.

Referenced by maxEvents(), repeat(), and rewind().

int edm::InputSource::maxLumis_

private

Definition at line 433 of file InputSource.h.

Referenced by maxLuminosityBlocks(), and repeat().

int edm::InputSource::maxSecondsUntilRampdown_

private

Definition at line 436 of file InputSource.h.

Referenced by InputSource(), and lumiLimitReached().

ModuleDescription const edm::InputSource::moduleDescription_

private

Definition at line 439 of file InputSource.h.

Referenced by moduleDescription().

bool edm::InputSource::newLumi_

mutableprivate

Definition at line 447 of file InputSource.h.

Referenced by newLumi(), resetLuminosityBlockAuxiliary(), resetNewLumi(), resetRunAuxiliary(), setLuminosityBlockAuxiliary(), setNewLumi(), and setRunAuxiliary().

bool edm::InputSource::newRun_

mutableprivate

Definition at line 446 of file InputSource.h.

Referenced by newRun(), resetNewRun(), resetRunAuxiliary(), setNewRun(), and setRunAuxiliary().

unsigned int edm::InputSource::numberOfEventsBeforeBigSkip_

private

Definition at line 456 of file InputSource.h.

Referenced by postForkReacquireResources(), readEvent(), and skipForForking().

std::string edm::InputSource::processGUID_

private

Definition at line 444 of file InputSource.h.

Referenced by processGUID().

edm::propagate_const<std::unique_ptr<ProcessHistoryRegistry> > edm::InputSource::processHistoryRegistry_

private

Definition at line 441 of file InputSource.h.

Referenced by processHistoryRegistry(), processHistoryRegistryForUpdate(), and reducedProcessHistoryID().

ProcessingMode edm::InputSource::processingMode_

private

Definition at line 438 of file InputSource.h.

Referenced by InputSource(), and processingMode().

std::chrono::time_point<std::chrono::steady_clock> edm::InputSource::processingStart_

private

Definition at line 437 of file InputSource.h.

Referenced by InputSource(), and lumiLimitReached().

edm::propagate_const<std::shared_ptr<ProductRegistry> > edm::InputSource::productRegistry_

private

Definition at line 440 of file InputSource.h.

Referenced by productRegistry(), and productRegistryUpdate().

int edm::InputSource::readCount_

private

Definition at line 435 of file InputSource.h.

Referenced by issueReports(), and readEvent().

edm::propagate_const<std::shared_ptr<edm::multicore::MessageReceiverForSource> > edm::InputSource::receiver_

private

Definition at line 455 of file InputSource.h.

Referenced by postForkReacquireResources(), readEvent(), rewind(), and skipForForking().

int edm::InputSource::remainingEvents_

private

Definition at line 432 of file InputSource.h.

Referenced by decreaseRemainingEventsBy(), eventLimitReached(), readEvent(), remainingEvents(), repeat(), and rewind().

int edm::InputSource::remainingLumis_

private

Definition at line 434 of file InputSource.h.

Referenced by lumiLimitReached(), readAndMergeLumi(), readLuminosityBlock(), remainingLuminosityBlocks(), and repeat().

std::shared_ptr<RunAuxiliary> edm::InputSource::runAuxiliary_

mutableprivate

Definition at line 450 of file InputSource.h.

Referenced by nextItemType(), resetRunAuxiliary(), runAuxiliary(), and setRunAuxiliary().

ItemType edm::InputSource::state_

mutableprivate

Definition at line 449 of file InputSource.h.

Referenced by nextItemType(), readEvent(), readFile(), reset(), rewind(), and state().

std::string edm::InputSource::statusFileName_

private

Definition at line 452 of file InputSource.h.

Referenced by InputSource(), and issueReports().

edm::propagate_const<std::shared_ptr<ThinnedAssociationsHelper> > edm::InputSource::thinnedAssociationsHelper_

private

Definition at line 443 of file InputSource.h.

Referenced by thinnedAssociationsHelper().

Timestamp edm::InputSource::time_

private

Definition at line 445 of file InputSource.h.

Referenced by doEndLumi(), doEndRun(), setTimestamp(), and timestamp().