Inheritance diagram for edm::TestSource:

Public Member Functions
	TestSource (ParameterSet const &, InputSourceDescription const &)

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

std::shared_ptr< BranchIDListHelper const >	branchIDListHelper () const
	Accessors for branchIDListHelper. More...

std::shared_ptr< BranchIDListHelper > &	branchIDListHelper ()

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

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

virtual void	doBeginLumi (LuminosityBlockPrincipal &lbp, ProcessContext const *)
	Called by framework at beginning of lumi block. More...

virtual void	doBeginRun (RunPrincipal &rp, ProcessContext const *)
	Called by framework at beginning of run. More...

void	doEndJob ()
	Called by framework at end of job. More...

ProcessingController::ForwardState	forwardState () const

bool	goToEvent (EventID const &eventID)

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

	InputSource (InputSource const &)=delete

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

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

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

int	maxEvents () const

int	maxLuminosityBlocks () const

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

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

InputSource &	operator= (InputSource const &)=delete

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

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

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

ProcessHistoryRegistry &	processHistoryRegistry ()

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

std::shared_ptr< ProductRegistry const >	productRegistry () const
	Accessors for product registry. More...

std::shared_ptr< ProductRegistry > &	productRegistry ()

bool	randomAccess () const

void	readAndMergeLumi (LuminosityBlockPrincipal &lbp)
	Read next luminosity block (same as a prior lumi) More...

void	readAndMergeRun (RunPrincipal &rp)
	Read next run (same as a prior run) More...

void	readEvent (EventPrincipal &ep, StreamContext &)
	Read next event. More...

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

std::unique_ptr< FileBlock >	readFile ()
	Read next file. More...

void	readLuminosityBlock (LuminosityBlockPrincipal &lumiPrincipal, HistoryAppender &historyAppender)
	Read next luminosity block (new lumi) More...

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

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

std::shared_ptr< RunAuxiliary >	readRunAuxiliary ()
	Read next run Auxiliary. More...

ProcessHistoryID const &	reducedProcessHistoryID () const

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

std::pair< SharedResourcesAcquirer , std::recursive_mutex >	resourceSharedWithDelayedReader ()
	Returns nullptr if no resource shared between the Source and a DelayedReader. More...

ProcessingController::ReverseState	reverseState () const

void	rewind ()
	Begin again at the first event. More...

RunNumber_t	run () const
	Accessor for current run number. More...

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

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

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

void	skipEvents (int offset)

std::shared_ptr< ThinnedAssociationsHelper const >	thinnedAssociationsHelper () const
	Accessors for thinnedAssociationsHelper. More...

std::shared_ptr< ThinnedAssociationsHelper > &	thinnedAssociationsHelper ()

Timestamp const &	timestamp () const
	Accessor for the current time, as seen by the input source. More...

virtual	~InputSource () noexcept(false)
	Destructor. More...

Static Public Member Functions
static void	fillDescriptions (ConfigurationDescriptions &descriptions)

Static Public Member Functions inherited from edm::InputSource
static const std::string &	baseType ()

static void	fillDescription (ParameterSetDescription &desc)

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &)

Private Member Functions
ItemType	getNextItemType () final

void	readEvent_ (EventPrincipal &eventPrincipal) final

std::shared_ptr< LuminosityBlockAuxiliary >	readLuminosityBlockAuxiliary_ () final

std::shared_ptr< RunAuxiliary >	readRunAuxiliary_ () final

Static Private Member Functions
static ItemType	stringToType (const std::string &)

Private Attributes
std::vector< std::pair< ItemType, EventID > >::const_iterator	m_nextTransition

std::vector< std::pair< ItemType, EventID > >	m_transitions

Additional Inherited Members
Public Types inherited from edm::InputSource
enum	ItemType { IsInvalid, IsStop, IsFile, IsRun, IsLumi, IsEvent, IsRepeat, IsSynchronize }

enum	ProcessingMode { Runs, RunsAndLumis, RunsLumisAndEvents }

Public Attributes inherited from edm::InputSource
signalslot::Signal< void(StreamContext const &, ModuleCallingContext const &)>	postEventReadFromSourceSignal_

signalslot::Signal< void(StreamContext const &, ModuleCallingContext const &)>	preEventReadFromSourceSignal_

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

bool	eventCached () const

bool	newLumi () const

bool	newRun () const

ProcessHistoryRegistry &	processHistoryRegistryForUpdate ()

ProductRegistry &	productRegistryUpdate ()

void	reset () const

void	resetEventCached ()

void	resetLuminosityBlockAuxiliary (bool isNewLumi=true) const

void	resetNewLumi ()

void	resetNewRun ()

void	resetRunAuxiliary (bool isNewRun=true) const

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

void	setLuminosityBlockAuxiliary (LuminosityBlockAuxiliary *lbp)

void	setNewLumi ()

void	setNewRun ()

void	setRunAuxiliary (RunAuxiliary *rp)

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

virtual void	skip (int offset)

ItemType	state () const

Detailed Description

Definition at line 12 of file TestSource.cc.

Constructor & Destructor Documentation

edm::TestSource::TestSource	(	ParameterSet const &	pset,
		InputSourceDescription const &	desc
	)

explicit

Definition at line 28 of file TestSource.cc.

References edm::ParameterSet::getUntrackedParameter(), m_nextTransition, m_transitions, AlCaHLTBitMon_ParallelJobs::p, AlCaHLTBitMon_QueryRunRegistry::string, and stringToType().

                                                            :
     InputSource(pset, desc)
   {
     for( auto const& p: pset.getUntrackedParameter<std::vector<edm::ParameterSet>>("transitions")) {
       m_transitions.emplace_back( stringToType(p.getUntrackedParameter<std::string>("type")),
                                   p.getUntrackedParameter<EventID>("id"));
     }
     m_nextTransition = m_transitions.begin();
   }

Member Function Documentation

void edm::TestSource::fillDescriptions ( ConfigurationDescriptions & descriptions )

static

Definition at line 81 of file TestSource.cc.

References edm::ConfigurationDescriptions::add(), edm::ParameterSetDescription::addUntracked(), edm::ParameterSetDescription::addVPSetUntracked(), DEFINE_FWK_INPUT_SOURCE, edm::ProducerSourceBase::fillDescription(), edm::ParameterSetDescription::setComment(), and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                       {
     ParameterSetDescription desc;
     desc.setComment("Generates the specified sequence of transitions.");
     ProducerSourceBase::fillDescription(desc);
     
     ParameterSetDescription trans;
     trans.addUntracked<std::string>("type");
     trans.addUntracked<edm::EventID>("id");
     desc.addVPSetUntracked("transitions",trans, {{}});
     descriptions.add("source", desc);
   }

TestSource::ItemType edm::TestSource::getNextItemType ( )

finalprivatevirtual

Implements edm::InputSource.

Definition at line 52 of file TestSource.cc.

References edm::InputSource::IsStop, m_nextTransition, and m_transitions.

                                                  {
     if(m_nextTransition == m_transitions.end()) {
       return IsStop;
     }
     auto trans = m_nextTransition->first;
     ++m_nextTransition;
     return trans;
   }

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

finalprivatevirtual

Implements edm::InputSource.

Definition at line 73 of file TestSource.cc.

References printConversionInfo::aux, edm::EventPrincipal::fillEventPrincipal(), m_nextTransition, edm::InputSource::processGUID(), and edm::InputSource::processHistoryRegistry().

                                                             {
     auto it =m_nextTransition;
     --it;
     EventAuxiliary aux(it->second, processGUID(), Timestamp(0), false);
     eventPrincipal.fillEventPrincipal(aux, processHistoryRegistry());
   }

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

finalprivatevirtual

Implements edm::InputSource.

Definition at line 67 of file TestSource.cc.

References m_nextTransition.

                                                                                     {
     auto it =m_nextTransition;
     --it;
     return std::make_shared<LuminosityBlockAuxiliary>(it->second.run(),it->second.luminosityBlock(), Timestamp(0),Timestamp(10));
   }

std::shared_ptr< RunAuxiliary > edm::TestSource::readRunAuxiliary_ ( )

finalprivatevirtual

Implements edm::InputSource.

Definition at line 61 of file TestSource.cc.

References m_nextTransition.

                                                             {
     auto it =m_nextTransition;
     --it;
     return std::make_shared<RunAuxiliary>(it->second.run(),Timestamp(0),Timestamp(10));
   }

TestSource::ItemType edm::TestSource::stringToType ( const std::string & iTrans )

staticprivate

Definition at line 39 of file TestSource.cc.

References edm::errors::Configuration, Exception, edm::InputSource::IsEvent, edm::InputSource::IsFile, edm::InputSource::IsInvalid, edm::InputSource::IsLumi, edm::InputSource::IsRun, edm::InputSource::IsStop, and edm::InputSource::IsSynchronize.

Referenced by TestSource().

                                                                        {
     if (iTrans == "IsStop") { return IsStop;}
     if (iTrans == "IsFile") { return IsFile;}
     if (iTrans == "IsRun") { return IsRun;}
     if (iTrans == "IsLumi") {return IsLumi;}
     if (iTrans == "IsEvent") {return IsEvent;}
     if (iTrans == "IsSynchronize") {return IsSynchronize;}
     
     throw edm::Exception(errors::Configuration)<<"Unknown transition type \'"<<iTrans<<"\'";
     
     return IsInvalid;
   }