#include <EDLooperBase.h>

Inheritance diagram for edm::EDLooperBase:

Public Types
enum	Status { kContinue, kStop }

Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels

Public Member Functions
virtual void	attachTo (ActivityRegistry &)
	Override this method if you need to monitor the state of the processing. More...

void	beginOfJob (EventSetupImpl const &)

virtual void	beginOfJob (EventSetup const &)

virtual void	beginOfJob ()

void	copyInfo (ScheduleInfo const &)

void	doBeginLuminosityBlock (LuminosityBlockPrincipal &, EventSetupImpl const &, ProcessContext *)

void	doBeginRun (RunPrincipal &, EventSetupImpl const &, ProcessContext *)

Status	doDuringLoop (EventPrincipal &eventPrincipal, EventSetupImpl const &es, ProcessingController &, StreamContext *)

void	doEndLuminosityBlock (LuminosityBlockPrincipal &, EventSetupImpl const &, ProcessContext *)

Status	doEndOfLoop (EventSetupImpl const &es)

void	doEndRun (RunPrincipal &, EventSetupImpl const &, ProcessContext *)

void	doStartingNewLoop ()

	EDLooperBase ()

	EDLooperBase (EDLooperBase const &)=delete

virtual void	endOfJob ()

void	esPrefetchAsync (WaitingTaskHolder iTask, EventSetupImpl const &iImpl, Transition iTrans, ServiceToken const &iToken) const

virtual std::set < eventsetup::EventSetupRecordKey >	modifyingRecords () const

EDLooperBase &	operator= (EDLooperBase const &)=delete

void	prefetchAsync (WaitingTaskHolder iTask, ServiceToken const &token, Transition iTrans, Principal const &iPrincipal, EventSetupImpl const &iImpl) const

void	prepareForNextLoop (eventsetup::EventSetupProvider *esp)

void	setActionTable (ExceptionToActionTable const *actionTable)

void	setModuleChanger (ModuleChanger *)

	~EDLooperBase () noexcept(false) override

Public Member Functions inherited from edm::EDConsumerBase
std::vector< ConsumesInfo >	consumesInfo () const

void	convertCurrentProcessAlias (std::string const &processName)
	Convert "@currentProcess" in InputTag process names to the actual current process name. More...

	EDConsumerBase ()

	EDConsumerBase (EDConsumerBase const &)=delete

	EDConsumerBase (EDConsumerBase &&)=default

ESProxyIndex const *	esGetTokenIndices (edm::Transition iTrans) const

std::vector< ESProxyIndex > const &	esGetTokenIndicesVector (edm::Transition iTrans) const

std::vector< ESRecordIndex > const &	esGetTokenRecordIndicesVector (edm::Transition iTrans) const

ProductResolverIndexAndSkipBit	indexFrom (EDGetToken, BranchType, TypeID const &) const

void	itemsMayGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const

void	itemsToGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const

std::vector < ProductResolverIndexAndSkipBit > const &	itemsToGetFrom (BranchType iType) const

void	labelsForToken (EDGetToken iToken, Labels &oLabels) const

void	modulesWhoseProductsAreConsumed (std::array< std::vector< ModuleDescription const * > , NumBranchTypes > &modulesAll, std::vector< ModuleProcessName > &modulesInPreviousProcesses, ProductRegistry const &preg, std::map< std::string, ModuleDescription const > const &labelsToDesc, std::string const &processName) const

EDConsumerBase const &	operator= (EDConsumerBase const &)=delete

EDConsumerBase &	operator= (EDConsumerBase &&)=default

bool	registeredToConsume (ProductResolverIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, BranchType) const

void	selectInputProcessBlocks (ProductRegistry const &productRegistry, ProcessBlockHelperBase const &processBlockHelperBase)

ProductResolverIndexAndSkipBit	uncheckedIndexFrom (EDGetToken) const

void	updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &, bool iPrefetchMayGet)

void	updateLookup (eventsetup::ESRecordsToProxyIndices const &)

virtual	~EDConsumerBase () noexcept(false)

Protected Member Functions
ModuleChanger *	moduleChanger ()
	This only returns a non-zero value during the call to endOfLoop. More...

ScheduleInfo const *	scheduleInfo () const
	This returns a non-zero value after the constructor has been called. More...

Protected Member Functions inherited from edm::EDConsumerBase
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	consumes (edm::InputTag const &tag)

template<BranchType B = InEvent>
EDConsumerBaseAdaptor< B >	consumes (edm::InputTag tag) noexcept

EDGetToken	consumes (const TypeToGet &id, edm::InputTag const &tag)

template<BranchType B>
EDGetToken	consumes (TypeToGet const &id, edm::InputTag const &tag)

ConsumesCollector	consumesCollector ()
	Use a ConsumesCollector to gather consumes information from helper functions. More...

template<typename ProductType , BranchType B = InEvent>
void	consumesMany ()

void	consumesMany (const TypeToGet &id)

template<BranchType B>
void	consumesMany (const TypeToGet &id)

template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes ()

template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag const &tag)

template<Transition Tr = Transition::Event>
constexpr auto	esConsumes () noexcept

template<Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag tag) noexcept

template<Transition Tr = Transition::Event>
ESGetTokenGeneric	esConsumes (eventsetup::EventSetupRecordKey const &iRecord, eventsetup::DataKey const &iKey)
	Used with EventSetupRecord::doGet. More...

template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	mayConsume (edm::InputTag const &tag)

EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

template<BranchType B>
EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

void	resetItemsToGetFrom (BranchType iType)

Private Member Functions
virtual void	beginLuminosityBlock (LuminosityBlock const &, EventSetup const &)
	Called after all event modules have processed the begin of a LuminosityBlock. More...

virtual void	beginRun (Run const &, EventSetup const &)
	Called after all event modules have processed the begin of a Run. More...

virtual Status	duringLoop (Event const &, EventSetup const &, ProcessingController &)=0

void	edPrefetchAsync (WaitingTaskHolder iTask, ServiceToken const &token, Principal const &iPrincipal) const

virtual void	endLuminosityBlock (LuminosityBlock const &, EventSetup const &)
	Called after all event modules have processed the end of a LuminosityBlock. More...

virtual Status	endOfLoop (EventSetup const &, unsigned int iCounter)=0

virtual void	endRun (Run const &, EventSetup const &)
	Called after all event modules have processed the end of a Run. More...

virtual void	startingNewLoop (unsigned int)=0

Private Attributes
ExceptionToActionTable const *	act_table_

unsigned int	iCounter_

ModuleCallingContext	moduleCallingContext_

edm::propagate_const < ModuleChanger * >	moduleChanger_

ModuleDescription	moduleDescription_

edm::propagate_const < std::unique_ptr < ScheduleInfo > >	scheduleInfo_

Detailed Description

Definition at line 80 of file EDLooperBase.h.

Member Enumeration Documentation

enum edm::EDLooperBase::Status

Enumerator
kContinue
kStop

Definition at line 82 of file EDLooperBase.h.

82 { kContinue, kStop };

edm::EDLooperBase::kContinue

Definition: EDLooperBase.h:82

edm::EDLooperBase::kStop

Definition: EDLooperBase.h:82

Constructor & Destructor Documentation

EDLooperBase::EDLooperBase ( )

Definition at line 39 of file EDLooperBase.cc.

       : iCounter_(0),
         act_table_(nullptr),
         moduleChanger_(nullptr),
         moduleDescription_("Looper", "looper"),
         moduleCallingContext_(&moduleDescription_) {}

EDLooperBase::~EDLooperBase ( )

overridenoexcept

Definition at line 45 of file EDLooperBase.cc.

45 {}

edm::EDLooperBase::EDLooperBase ( EDLooperBase const & )

delete

Member Function Documentation

void EDLooperBase::attachTo ( ActivityRegistry & )

virtual

Override this method if you need to monitor the state of the processing.

Reimplemented in FWFFLooper.

Definition at line 190 of file EDLooperBase.cc.

190 {}

void EDLooperBase::beginLuminosityBlock	(	LuminosityBlock const &	,
		EventSetup const &
	)

privatevirtual

Called after all event modules have processed the begin of a LuminosityBlock.

Reimplemented in AlignmentProducer.

Definition at line 187 of file EDLooperBase.cc.

Referenced by doBeginLuminosityBlock().

187 {}

void EDLooperBase::beginOfJob ( EventSetupImpl const & iImpl )

Definition at line 96 of file EDLooperBase.cc.

References beginOfJob(), edm::BeginRun, edm::EDConsumerBase::esGetTokenIndices(), and moduleCallingContext_.

                                                               {
     ESParentContext parentC(&moduleCallingContext_);
     beginOfJob(EventSetup{iImpl,
                           static_cast<unsigned int>(Transition::BeginRun),
                           esGetTokenIndices(Transition::BeginRun),
                           parentC,
                           false});
   }

void EDLooperBase::beginOfJob ( EventSetup const & )

virtual

Reimplemented in AlignmentProducer.

Definition at line 104 of file EDLooperBase.cc.

References beginOfJob().

104 { beginOfJob(); }

edm::EDLooperBase::beginOfJob

virtual void beginOfJob()

Definition: EDLooperBase.cc:105

void EDLooperBase::beginOfJob ( )

virtual

Reimplemented in ZeeCalibration, Pi0FixedMassWindowCalibration, __class__< T >, EcalEleCalibLooper, and InvRingCalib.

Definition at line 105 of file EDLooperBase.cc.

Referenced by beginOfJob().

105 {}

void EDLooperBase::beginRun	(	Run const &	,
		EventSetup const &
	)

privatevirtual

Called after all event modules have processed the begin of a Run.

Reimplemented in FWFFLooper, and AlignmentProducer.

Definition at line 185 of file EDLooperBase.cc.

Referenced by doBeginRun().

185 {}

void EDLooperBase::copyInfo ( ScheduleInfo const & iInfo )

Definition at line 294 of file EDLooperBase.cc.

References scheduleInfo_.

294 { scheduleInfo_ = std::make_unique<ScheduleInfo>(iInfo); }

edm::EDLooperBase::scheduleInfo_

edm::propagate_const< std::unique_ptr< ScheduleInfo > > scheduleInfo_

Definition: EDLooperBase.h:167

void EDLooperBase::doBeginLuminosityBlock	(	LuminosityBlockPrincipal &	iLB,
		EventSetupImpl const &	iES,
		ProcessContext *	processContext
	)

Definition at line 142 of file EDLooperBase.cc.

References edm::BeginLuminosityBlock, beginLuminosityBlock(), edm::LuminosityBlockPrincipal::beginTime(), edm::EDConsumerBase::esGetTokenIndices(), edm::LuminosityBlockPrincipal::id(), edm::LuminosityBlockPrincipal::index(), edm::RunPrincipal::index(), edm::GlobalContext::kBeginLuminosityBlock, moduleCallingContext_, moduleDescription_, edm::LuminosityBlockPrincipal::runPrincipal(), and edm::LuminosityBlock::setConsumer().

                                                                             {
     GlobalContext globalContext(GlobalContext::Transition::kBeginLuminosityBlock,
                                 iLB.id(),
                                 iLB.runPrincipal().index(),
                                 iLB.index(),
                                 iLB.beginTime(),
                                 processContext);
     ParentContext parentContext(&globalContext);
     ModuleContextSentry moduleContextSentry(&moduleCallingContext_, parentContext);
     LuminosityBlock luminosityBlock(iLB, moduleDescription_, &moduleCallingContext_, false);
     luminosityBlock.setConsumer(this);
     ESParentContext parentC(&moduleCallingContext_);
     const EventSetup es{iES,
                         static_cast<unsigned int>(Transition::BeginLuminosityBlock),
                         esGetTokenIndices(Transition::BeginLuminosityBlock),
                         parentC,
                         false};
     beginLuminosityBlock(luminosityBlock, es);
   }

void EDLooperBase::doBeginRun	(	RunPrincipal &	iRP,
		EventSetupImpl const &	iES,
		ProcessContext *	processContext
	)

Definition at line 109 of file EDLooperBase.cc.

References edm::BeginRun, beginRun(), edm::RunPrincipal::beginTime(), edm::EDConsumerBase::esGetTokenIndices(), edm::RunPrincipal::index(), edm::LuminosityBlockIndex::invalidLuminosityBlockIndex(), edm::GlobalContext::kBeginRun, moduleCallingContext_, moduleDescription_, edm::RunPrincipal::run(), submitPVValidationJobs::run, and edm::Run::setConsumer().

                                                                                                             {
     GlobalContext globalContext(GlobalContext::Transition::kBeginRun,
                                 LuminosityBlockID(iRP.run(), 0),
                                 iRP.index(),
                                 LuminosityBlockIndex::invalidLuminosityBlockIndex(),
                                 iRP.beginTime(),
                                 processContext);
     ParentContext parentContext(&globalContext);
     ModuleContextSentry moduleContextSentry(&moduleCallingContext_, parentContext);
     Run run(iRP, moduleDescription_, &moduleCallingContext_, false);
     run.setConsumer(this);
     ESParentContext parentC(&moduleCallingContext_);
     const EventSetup es{
         iES, static_cast<unsigned int>(Transition::BeginRun), esGetTokenIndices(Transition::BeginRun), parentC, false};
     beginRun(run, es);
   }

EDLooperBase::Status EDLooperBase::doDuringLoop	(	edm::EventPrincipal &	eventPrincipal,
		EventSetupImpl const &	es,
		edm::ProcessingController &	ioController,
		StreamContext *	streamContext
	)

Definition at line 49 of file EDLooperBase.cc.

References act_table_, mps_fire::action, cms::Exception::addContext(), cms::Exception::category(), duringLoop(), alignCSCRings::e, edm::EDConsumerBase::esGetTokenIndices(), edm::Event, edmPickEvents::event, edm::ExceptionToActionTable::find(), edm::EventPrincipal::id(), edm::LuminosityBlockPrincipal::index(), edm::RunPrincipal::index(), kContinue, edm::StreamContext::kEvent, edm::EventPrincipal::luminosityBlockPrincipal(), moduleCallingContext_, moduleDescription_, edm::printCmsExceptionWarning(), edm::exception_actions::Rethrow, edm::LuminosityBlockPrincipal::runPrincipal(), edm::StreamContext::setEventID(), edm::StreamContext::setLuminosityBlockIndex(), edm::StreamContext::setRunIndex(), edm::StreamContext::setTimestamp(), edm::StreamContext::setTransition(), mps_update::status, and edm::EventPrincipal::time().

                                                                                 {
     streamContext->setTransition(StreamContext::Transition::kEvent);
     streamContext->setEventID(eventPrincipal.id());
     streamContext->setRunIndex(eventPrincipal.luminosityBlockPrincipal().runPrincipal().index());
     streamContext->setLuminosityBlockIndex(eventPrincipal.luminosityBlockPrincipal().index());
     streamContext->setTimestamp(eventPrincipal.time());
     ParentContext parentContext(streamContext);
     ModuleContextSentry moduleContextSentry(&moduleCallingContext_, parentContext);
     Event event(eventPrincipal, moduleDescription_, &moduleCallingContext_);
     event.setConsumer(this);
 
     Status status = kContinue;
     try {
       ESParentContext parentC(&moduleCallingContext_);
       const EventSetup es{
           esi, static_cast<unsigned int>(Transition::Event), esGetTokenIndices(Transition::Event), parentC, false};
       status = duringLoop(event, es, ioController);
     } catch (cms::Exception& e) {
       e.addContext("Calling the 'duringLoop' method of a looper");
       exception_actions::ActionCodes action = (act_table_->find(e.category()));
       if (action != exception_actions::Rethrow) {
         edm::printCmsExceptionWarning("SkipEvent", e);
       } else {
         throw;
       }
     }
     return status;
   }

void EDLooperBase::doEndLuminosityBlock	(	LuminosityBlockPrincipal &	iLB,
		EventSetupImpl const &	iES,
		ProcessContext *	processContext
	)

Definition at line 163 of file EDLooperBase.cc.

References edm::LuminosityBlockPrincipal::beginTime(), edm::EndLuminosityBlock, endLuminosityBlock(), edm::EDConsumerBase::esGetTokenIndices(), edm::LuminosityBlockPrincipal::id(), edm::LuminosityBlockPrincipal::index(), edm::RunPrincipal::index(), edm::GlobalContext::kEndLuminosityBlock, moduleCallingContext_, moduleDescription_, edm::LuminosityBlockPrincipal::runPrincipal(), and edm::LuminosityBlock::setConsumer().

                                                                           {
     GlobalContext globalContext(GlobalContext::Transition::kEndLuminosityBlock,
                                 iLB.id(),
                                 iLB.runPrincipal().index(),
                                 iLB.index(),
                                 iLB.beginTime(),
                                 processContext);
     ParentContext parentContext(&globalContext);
     ModuleContextSentry moduleContextSentry(&moduleCallingContext_, parentContext);
     LuminosityBlock luminosityBlock(iLB, moduleDescription_, &moduleCallingContext_, true);
     luminosityBlock.setConsumer(this);
     ESParentContext parentC(&moduleCallingContext_);
     const EventSetup es{iES,
                         static_cast<unsigned int>(Transition::EndLuminosityBlock),
                         esGetTokenIndices(Transition::EndLuminosityBlock),
                         parentC,
                         false};
     endLuminosityBlock(luminosityBlock, es);
   }

EDLooperBase::Status EDLooperBase::doEndOfLoop ( EventSetupImpl const & es )

Definition at line 81 of file EDLooperBase.cc.

References endOfLoop(), edm::EndRun, edm::EDConsumerBase::esGetTokenIndices(), iCounter_, and moduleCallingContext_.

                                                                            {
     ESParentContext parentC(&moduleCallingContext_);
     const EventSetup es{
         esi, static_cast<unsigned int>(Transition::EndRun), esGetTokenIndices(Transition::EndRun), parentC, false};
     return endOfLoop(es, iCounter_);
   }

void EDLooperBase::doEndRun	(	RunPrincipal &	iRP,
		EventSetupImpl const &	iES,
		ProcessContext *	processContext
	)

Definition at line 126 of file EDLooperBase.cc.

References edm::EndRun, endRun(), edm::RunPrincipal::endTime(), edm::EDConsumerBase::esGetTokenIndices(), edm::RunPrincipal::index(), edm::LuminosityBlockIndex::invalidLuminosityBlockIndex(), edm::GlobalContext::kEndRun, moduleCallingContext_, moduleDescription_, edm::RunPrincipal::run(), submitPVValidationJobs::run, and edm::Run::setConsumer().

                                                                                                           {
     GlobalContext globalContext(GlobalContext::Transition::kEndRun,
                                 LuminosityBlockID(iRP.run(), 0),
                                 iRP.index(),
                                 LuminosityBlockIndex::invalidLuminosityBlockIndex(),
                                 iRP.endTime(),
                                 processContext);
     ParentContext parentContext(&globalContext);
     ModuleContextSentry moduleContextSentry(&moduleCallingContext_, parentContext);
     Run run(iRP, moduleDescription_, &moduleCallingContext_, true);
     run.setConsumer(this);
     ESParentContext parentC(&moduleCallingContext_);
     const EventSetup es{
         iES, static_cast<unsigned int>(Transition::EndRun), esGetTokenIndices(Transition::EndRun), parentC, false};
     endRun(run, es);
   }

void EDLooperBase::doStartingNewLoop ( )

Definition at line 47 of file EDLooperBase.cc.

References iCounter_, and startingNewLoop().

47 { startingNewLoop(iCounter_); }

edm::EDLooperBase::iCounter_

unsigned int iCounter_

Definition: EDLooperBase.h:164

edm::EDLooperBase::startingNewLoop

virtual void startingNewLoop(unsigned int)=0

virtual Status edm::EDLooperBase::duringLoop	(	Event const &	,
		EventSetup const &	,
		ProcessingController &
	)

privatepure virtual

Called after all event modules have had a chance to process the Event.

Implemented in FWFFLooper, edm::EDLooper, and edm::NavigateEventsLooper.

Referenced by doDuringLoop().

void EDLooperBase::edPrefetchAsync	(	WaitingTaskHolder	iTask,
		ServiceToken const &	token,
		Principal const &	iPrincipal
	)		const

private

Definition at line 201 of file EDLooperBase.cc.

References edm::Principal::branchType(), B2GTnPMonitor_cfi::item, mps_monitormerge::items, edm::EDConsumerBase::itemsToGetFrom(), moduleCallingContext_, edm::Principal::prefetchAsync(), and edm::ProductResolverIndexAmbiguous.

Referenced by prefetchAsync().

                                                                         {
     //Based on Worker edPrefetchAsync
 
     // Prefetch products the module declares it consumes
     std::vector<ProductResolverIndexAndSkipBit> const& items = itemsToGetFrom(iPrincipal.branchType());
 
     for (auto const& item : items) {
       ProductResolverIndex productResolverIndex = item.productResolverIndex();
       bool skipCurrentProcess = item.skipCurrentProcess();
       if (productResolverIndex != ProductResolverIndexAmbiguous) {
         iPrincipal.prefetchAsync(iTask, productResolverIndex, skipCurrentProcess, token, &moduleCallingContext_);
       }
     }
   }

void EDLooperBase::endLuminosityBlock	(	LuminosityBlock const &	,
		EventSetup const &
	)

privatevirtual

Called after all event modules have processed the end of a LuminosityBlock.

Reimplemented in AlignmentProducer.

Definition at line 188 of file EDLooperBase.cc.

Referenced by doEndLuminosityBlock().

188 {}

void EDLooperBase::endOfJob ( )

virtual

Reimplemented in MuScleFit, ZeeCalibration, Pi0FixedMassWindowCalibration, __class__< T >, EcalEleCalibLooper, InvRingCalib, and AlignmentProducer.

Definition at line 107 of file EDLooperBase.cc.

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

107 {}

virtual Status edm::EDLooperBase::endOfLoop	(	EventSetup const &	,
		unsigned int	iCounter
	)

privatepure virtual

Called after the system has finished one loop over the events. Thar argument is a count of how many loops have been processed before this loo. For the first time through the events the argument will be 0.

Implemented in MuScleFit, ZeeCalibration, FWFFLooper, Pi0FixedMassWindowCalibration, EcalEleCalibLooper, InvRingCalib, edm::NavigateEventsLooper, AlignmentProducer, and edm::IterateNTimesLooper.

Referenced by doEndOfLoop().

void EDLooperBase::endRun	(	Run const &	,
		EventSetup const &
	)

privatevirtual

Called after all event modules have processed the end of a Run.

Reimplemented in AlignmentProducer.

Definition at line 186 of file EDLooperBase.cc.

Referenced by doEndRun().

186 {}

void EDLooperBase::esPrefetchAsync	(	WaitingTaskHolder	iTask,
		EventSetupImpl const &	iImpl,
		Transition	iTrans,
		ServiceToken const &	iToken
	)		const

Definition at line 218 of file EDLooperBase.cc.

References cms::cuda::assert(), edm::EDConsumerBase::esGetTokenIndicesVector(), edm::EDConsumerBase::esGetTokenRecordIndicesVector(), edm::EventSetupImpl::findImpl(), edm::WaitingTaskHolder::group(), watchdog::group, mps_fire::i, mps_monitormerge::items, edm::ServiceWeakToken::lock(), edm::make_waiting_task(), moduleCallingContext_, eostools::move(), edm::NumberOfEventSetupTransitions, edm::eventsetup::EventSetupRecordImpl::prefetchAsync(), edm::syncWait(), edm::EventSetupImpl::taskArena(), unpackBuffers-CaloStage2::token, and UNLIKELY.

Referenced by prefetchAsync().

                                                                        {
     //Based on Worker::esPrefetchAsync
     if (iTrans >= edm::Transition::NumberOfEventSetupTransitions) {
       return;
     }
     auto const& recs = esGetTokenRecordIndicesVector(iTrans);
     auto const& items = esGetTokenIndicesVector(iTrans);
 
     assert(items.size() == recs.size());
     if (items.empty()) {
       return;
     }
 
     //Thread case of 1 thread special. The master thread is doing a wait_for_all on the
     // default tbb arena. It will not process any tasks on the es arena. We need to add a
     // task that will synchronously do a wait_for_all in the es arena to be sure prefetching
     // will work.
 
     if UNLIKELY (tbb::global_control::active_value(tbb::global_control::max_allowed_parallelism) == 1) {
       auto taskGroup = iTask.group();
       ServiceWeakToken weakToken = iToken;
       taskGroup->run([this, task = std::move(iTask), iTrans, &iImpl, weakToken]() {
         std::exception_ptr exceptPtr{};
         iImpl.taskArena()->execute([this, iTrans, &iImpl, weakToken, &exceptPtr]() {
           exceptPtr = syncWait([&](WaitingTaskHolder&& iHolder) {
             auto const& recs = esGetTokenRecordIndicesVector(iTrans);
             auto const& items = esGetTokenIndicesVector(iTrans);
             auto hWaitTask = std::move(iHolder);
             auto token = weakToken.lock();
             for (size_t i = 0; i != items.size(); ++i) {
               if (recs[i] != ESRecordIndex{}) {
                 auto rec = iImpl.findImpl(recs[i]);
                 if (rec) {
                   rec->prefetchAsync(hWaitTask, items[i], &iImpl, token, ESParentContext(&moduleCallingContext_));
                 }
               }
             }
           });  //syncWait
         });    //esTaskArena().execute
         //note use of a copy gets around declaring the lambda as mutable
         auto tempTask = task;
         tempTask.doneWaiting(exceptPtr);
       });  //group.run
     } else {
       auto group = iTask.group();
       //We need iTask to run in the default arena since it is not an ES task
       auto task = make_waiting_task(
           [holder = WaitingTaskWithArenaHolder(std::move(iTask))](std::exception_ptr const* iExcept) mutable {
             if (iExcept) {
               holder.doneWaiting(*iExcept);
             } else {
               holder.doneWaiting(std::exception_ptr{});
             }
           });
 
       WaitingTaskHolder tempH(*group, task);
       iImpl.taskArena()->execute([&]() {
         for (size_t i = 0; i != items.size(); ++i) {
           if (recs[i] != ESRecordIndex{}) {
             auto rec = iImpl.findImpl(recs[i]);
             if (rec) {
               rec->prefetchAsync(tempH, items[i], &iImpl, iToken, ESParentContext(&moduleCallingContext_));
             }
           }
         }
       });
     }
   }

std::set< eventsetup::EventSetupRecordKey > EDLooperBase::modifyingRecords ( ) const

virtual

Reimplemented in edm::ESProducerLooper.

Definition at line 290 of file EDLooperBase.cc.

Referenced by prepareForNextLoop().

                                                                              {
     return std::set<eventsetup::EventSetupRecordKey>();
   }

ModuleChanger * EDLooperBase::moduleChanger ( )

protected

This only returns a non-zero value during the call to endOfLoop.

Definition at line 297 of file EDLooperBase.cc.

References moduleChanger_.

Referenced by FWFFLooper::endOfLoop().

297 { return moduleChanger_; }

edm::EDLooperBase::moduleChanger_

edm::propagate_const< ModuleChanger * > moduleChanger_

Definition: EDLooperBase.h:168

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

delete

void EDLooperBase::prefetchAsync	(	WaitingTaskHolder	iTask,
		ServiceToken const &	token,
		Transition	iTrans,
		Principal const &	iPrincipal,
		EventSetupImpl const &	iImpl
	)		const

Definition at line 192 of file EDLooperBase.cc.

References edPrefetchAsync(), esPrefetchAsync(), and eostools::move().

                                                                       {
     esPrefetchAsync(iTask, iImpl, iTrans, token);
     edPrefetchAsync(std::move(iTask), token, iPrincipal);
   }

void EDLooperBase::prepareForNextLoop ( eventsetup::EventSetupProvider * esp )

Definition at line 88 of file EDLooperBase.cc.

References edm::for_all(), iCounter_, relativeConstraints::keys, modifyingRecords(), and edm::eventsetup::EventSetupProvider::resetRecordPlusDependentRecords().

                                                                          {
     ++iCounter_;
 
     std::set<edm::eventsetup::EventSetupRecordKey> const& keys = modifyingRecords();
     for_all(keys,
             std::bind(&eventsetup::EventSetupProvider::resetRecordPlusDependentRecords, esp, std::placeholders::_1));
   }

const ScheduleInfo * EDLooperBase::scheduleInfo ( ) const

protected

This returns a non-zero value after the constructor has been called.

Definition at line 298 of file EDLooperBase.cc.

References scheduleInfo_.

Referenced by FWFFLooper::startingNewLoop().

298 { return scheduleInfo_.get(); }

edm::EDLooperBase::scheduleInfo_

edm::propagate_const< std::unique_ptr< ScheduleInfo > > scheduleInfo_

Definition: EDLooperBase.h:167

void edm::EDLooperBase::setActionTable ( ExceptionToActionTable const * actionTable )

inline

Definition at line 120 of file EDLooperBase.h.

References act_table_.

120 { act_table_ = actionTable; }

edm::EDLooperBase::act_table_

ExceptionToActionTable const * act_table_

Definition: EDLooperBase.h:165

void EDLooperBase::setModuleChanger ( ModuleChanger * iChanger )

Definition at line 295 of file EDLooperBase.cc.

References moduleChanger_.

295 { moduleChanger_ = iChanger; }

edm::EDLooperBase::moduleChanger_

edm::propagate_const< ModuleChanger * > moduleChanger_

Definition: EDLooperBase.h:168

virtual void edm::EDLooperBase::startingNewLoop ( unsigned int )

privatepure virtual

Called before system starts to loop over the events. The argument is a count of how many loops have been processed. For the first time through the events the argument will be 0.

Implemented in MuScleFit, ZeeCalibration, FWFFLooper, Pi0FixedMassWindowCalibration, __class__< T >, EcalEleCalibLooper, InvRingCalib, edm::NavigateEventsLooper, edm::IterateNTimesLooper, and AlignmentProducer.

Referenced by doStartingNewLoop().