#include <EventSetupsController.h>

Public Member Functions
void	clearComponents ()

bool	doWeNeedToWaitForIOVsToFinish (IOVSyncValue const &) const

void	endIOVsAsync (edm::WaitingTaskHolder iEndTask)

std::multimap< ParameterSetID, ESProducerInfo > const &	esproducers () const

std::multimap< ParameterSetID, ESSourceInfo > const &	essources () const

void	eventSetupForInstanceAsync (IOVSyncValue const &, WaitingTaskHolder const &taskToStartAfterIOVInit, WaitingTaskList &endIOVWaitingTasks, std::vector< std::shared_ptr< const EventSetupImpl >> &)

	EventSetupsController ()

	EventSetupsController (EventSetupsController const &)=delete

void	finishConfiguration ()

void	forceCacheClear ()

std::shared_ptr< DataProxyProvider >	getESProducerAndRegisterProcess (ParameterSet const &pset, unsigned subProcessIndex)

ParameterSet const *	getESProducerPSet (ParameterSetID const &psetID, unsigned subProcessIndex) const

std::shared_ptr< EventSetupRecordIntervalFinder >	getESSourceAndRegisterProcess (ParameterSet const &pset, unsigned subProcessIndex)

bool	hasNonconcurrentFinder () const

unsigned	indexOfNextProcess () const

bool	isFirstMatch (ParameterSetID const &psetID, unsigned subProcessIndex, unsigned precedingProcessIndex) const

bool	isLastMatch (ParameterSetID const &psetID, unsigned subProcessIndex, unsigned precedingProcessIndex) const

bool	isMatchingESProducer (ParameterSetID const &psetID, unsigned subProcessIndex, unsigned precedingProcessIndex) const

bool	isMatchingESSource (ParameterSetID const &psetID, unsigned subProcessIndex, unsigned precedingProcessIndex) const

void	lookForMatches (ParameterSetID const &psetID, unsigned subProcessIndex, unsigned precedingProcessIndex, bool &firstProcessWithThisPSet, bool &precedingHasMatchingPSet) const

std::shared_ptr< EventSetupProvider >	makeProvider (ParameterSet &, ActivityRegistry , ParameterSet const eventSetupPset=nullptr)

bool	mustFinishConfiguration () const

EventSetupsController const &	operator= (EventSetupsController const &)=delete

std::vector< propagate_const< std::shared_ptr< EventSetupProvider > > > const &	providers () const

void	putESProducer (ParameterSet const &pset, std::shared_ptr< DataProxyProvider > const &component, unsigned subProcessIndex)

void	putESSource (ParameterSet const &pset, std::shared_ptr< EventSetupRecordIntervalFinder > const &component, unsigned subProcessIndex)

void	setMaxConcurrentIOVs (unsigned int nStreams, unsigned int nConcurrentLumis)

Private Member Functions
void	checkESProducerSharing ()

void	initializeEventSetupRecordIOVQueues ()

Private Attributes
std::multimap< ParameterSetID, ESProducerInfo >	esproducers_

std::multimap< ParameterSetID, ESSourceInfo >	essources_

std::vector< propagate_const< std::unique_ptr< EventSetupRecordIOVQueue > > >	eventSetupRecordIOVQueues_

bool	hasNonconcurrentFinder_ = false

bool	mustFinishConfiguration_ = true

NumberOfConcurrentIOVs	numberOfConcurrentIOVs_

std::vector< propagate_const< std::shared_ptr< EventSetupProvider > > >	providers_

tbb::task_arena	taskArena_

Detailed Description

Description: Manages a group of EventSetups which can share components

Usage: <usage>

Definition at line 80 of file EventSetupsController.h.

Constructor & Destructor Documentation

◆ EventSetupsController() [1/2]

edm::eventsetup::EventSetupsController::EventSetupsController ( )

Definition at line 34 of file EventSetupsController.cc.

34 : taskArena_(tbb::this_task_arena::max_concurrency()) {}

◆ EventSetupsController() [2/2]

edm::eventsetup::EventSetupsController::EventSetupsController ( EventSetupsController const & )

delete

Member Function Documentation

◆ checkESProducerSharing()

void edm::eventsetup::EventSetupsController::checkESProducerSharing ( )

private

Definition at line 357 of file EventSetupsController.cc.

                                                        {
       // Loop over SubProcesses, skip the top level process.
       auto esProvider = providers_.begin();
       auto const esProviderEnd = providers_.end();
       if (esProvider != esProviderEnd)
         ++esProvider;
       for (; esProvider != esProviderEnd; ++esProvider) {
         // An element is added to this set for each ESProducer
         // when we have determined which preceding process
         // this process can share that ESProducer with or
         // we have determined that it cannot be shared with
         // any preceding process.
         // Note the earliest possible preceding process
         // will be the one selected if there is more than one.
         std::set<ParameterSetIDHolder> sharingCheckDone;
  
         // This will hold an entry for DataProxy's that are
         // referenced by an EventSetupRecord in this SubProcess.
         // But only for DataProxy's that are associated with
         // an ESProducer (not the ones associated with ESSource's
         // or EDLooper's)
         std::map<EventSetupRecordKey, std::vector<ComponentDescription const*>> referencedESProducers;
  
         // For each EventSetupProvider from a SubProcess, loop over the
         // EventSetupProviders from the preceding processes (the first
         // preceding process will be the top level process and the others
         // SubProcess's)
         for (auto precedingESProvider = providers_.begin(); precedingESProvider != esProvider; ++precedingESProvider) {
           (*esProvider)->checkESProducerSharing(**precedingESProvider, sharingCheckDone, referencedESProducers, *this);
         }
  
         (*esProvider)->resetRecordToProxyPointers();
       }
       for (auto& eventSetupProvider : providers_) {
         eventSetupProvider->clearInitializationData();
       }
     }

References providers_.

Referenced by finishConfiguration().

◆ clearComponents()

void edm::eventsetup::EventSetupsController::clearComponents ( )

Definition at line 200 of file EventSetupsController.cc.

                                                 {
       esproducers_.clear();
       essources_.clear();
     }

References esproducers_, and essources_.

Referenced by finishConfiguration().

◆ doWeNeedToWaitForIOVsToFinish()

bool edm::eventsetup::EventSetupsController::doWeNeedToWaitForIOVsToFinish ( IOVSyncValue const & syncValue ) const

Definition at line 131 of file EventSetupsController.cc.

                                                                                                  {
       if (hasNonconcurrentFinder()) {
         for (auto& eventSetupProvider : providers_) {
           if (eventSetupProvider->doWeNeedToWaitForIOVsToFinish(syncValue)) {
             return true;
           }
         }
       }
       return false;
     }

References hasNonconcurrentFinder(), and providers_.

◆ endIOVsAsync()

void edm::eventsetup::EventSetupsController::endIOVsAsync ( edm::WaitingTaskHolder iEndTask )

Definition at line 36 of file EventSetupsController.cc.

                                                                           {
       for (auto& eventSetupRecordIOVQueue : eventSetupRecordIOVQueues_) {
         eventSetupRecordIOVQueue->endIOVAsync(iEndTask);
       }
     }

References eventSetupRecordIOVQueues_.

Referenced by edm::eventsetup::SynchronousEventSetupsController::~SynchronousEventSetupsController().

◆ esproducers()

std::multimap<ParameterSetID, ESProducerInfo> const& edm::eventsetup::EventSetupsController::esproducers ( ) const

inline

Definition at line 155 of file EventSetupsController.h.

155 { return esproducers_; }

References esproducers_.

◆ essources()

std::multimap<ParameterSetID, ESSourceInfo> const& edm::eventsetup::EventSetupsController::essources ( ) const

inline

Definition at line 157 of file EventSetupsController.h.

157 { return essources_; }

References essources_.

◆ eventSetupForInstanceAsync()

void edm::eventsetup::EventSetupsController::eventSetupForInstanceAsync	(	IOVSyncValue const &	syncValue,
		WaitingTaskHolder const &	taskToStartAfterIOVInit,
		WaitingTaskList &	endIOVWaitingTasks,
		std::vector< std::shared_ptr< const EventSetupImpl >> &	eventSetupImpls
	)

Definition at line 92 of file EventSetupsController.cc.

                                                                          {
       finishConfiguration();
  
       bool newEventSetupImpl = false;
       eventSetupImpls.clear();
       eventSetupImpls.reserve(providers_.size());
  
       // Note that unless there are one or more SubProcesses providers_ will only
       // contain one element.
  
       for (auto& eventSetupProvider : providers_) {
         eventSetupProvider->setAllValidityIntervals(syncValue);
       }
  
       for (auto& eventSetupRecordIOVQueue : eventSetupRecordIOVQueues_) {
         // For a particular record, if the top level process or any SubProcess requires
         // starting a new IOV, then we must start a new IOV for all of them. And we
         // need to know whether this is needed at this point in time. This is
         // recorded in the EventSetupRecordProviders.
         eventSetupRecordIOVQueue->setNewIntervalForAnySubProcess();
       }
  
       for (auto& eventSetupProvider : providers_) {
         // Decides whether we can reuse the existing EventSetupImpl and if we can
         // returns it. If a new one is needed it will create it, although the pointers
         // to the EventSetupRecordImpl's will not be set yet in the returned EventSetupImpl
         // object.
         eventSetupImpls.push_back(eventSetupProvider->eventSetupForInstance(syncValue, newEventSetupImpl));
       }
  
       for (auto& eventSetupRecordIOVQueue : eventSetupRecordIOVQueues_) {
         eventSetupRecordIOVQueue->checkForNewIOVs(taskToStartAfterIOVInit, endIOVWaitingTasks, newEventSetupImpl);
       }
     }

References eventSetupRecordIOVQueues_, finishConfiguration(), and providers_.

Referenced by edm::eventsetup::synchronousEventSetupForInstance().

◆ finishConfiguration()

void edm::eventsetup::EventSetupsController::finishConfiguration ( )

Definition at line 66 of file EventSetupsController.cc.

                                                     {
       if (mustFinishConfiguration_) {
         for (auto& eventSetupProvider : providers_) {
           numberOfConcurrentIOVs_.fillRecordsNotAllowingConcurrentIOVs(*eventSetupProvider);
         }
  
         for (auto& eventSetupProvider : providers_) {
           eventSetupProvider->finishConfiguration(numberOfConcurrentIOVs_, hasNonconcurrentFinder_);
         }
  
         // When the ESSources and ESProducers were constructed a first pass was
         // done which attempts to get component sharing between SubProcesses
         // correct, but in this pass only the configuration of the components
         // being shared are compared. This is not good enough for ESProducers.
         // In the following function, all the other components that contribute
         // to the same record and also the records that record depends on are
         // also checked. The component sharing is appropriately fixed as necessary.
         checkESProducerSharing();
         clearComponents();
  
         initializeEventSetupRecordIOVQueues();
         numberOfConcurrentIOVs_.clear();
         mustFinishConfiguration_ = false;
       }
     }

References checkESProducerSharing(), edm::eventsetup::NumberOfConcurrentIOVs::clear(), clearComponents(), edm::eventsetup::NumberOfConcurrentIOVs::fillRecordsNotAllowingConcurrentIOVs(), hasNonconcurrentFinder_, initializeEventSetupRecordIOVQueues(), mustFinishConfiguration_, numberOfConcurrentIOVs_, and providers_.

Referenced by eventSetupForInstanceAsync().

◆ forceCacheClear()

void edm::eventsetup::EventSetupsController::forceCacheClear ( )

Definition at line 142 of file EventSetupsController.cc.

                                                 {
       for (auto& eventSetupProvider : providers_) {
         eventSetupProvider->forceCacheClear();
       }
     }

References providers_.

◆ getESProducerAndRegisterProcess()

std::shared_ptr< DataProxyProvider > edm::eventsetup::EventSetupsController::getESProducerAndRegisterProcess	(	ParameterSet const &	pset,
		unsigned	subProcessIndex
	)

Definition at line 148 of file EventSetupsController.cc.

                                                             {
       // Try to find a DataProxyProvider with a matching ParameterSet
       auto elements = esproducers_.equal_range(pset.id());
       for (auto it = elements.first; it != elements.second; ++it) {
         // Untracked parameters must also match, do complete comparison if IDs match
         if (isTransientEqual(pset, *it->second.pset())) {
           // Register processes with an exact match
           it->second.subProcessIndexes().push_back(subProcessIndex);
           // Return the DataProxyProvider
           return it->second.provider();
         }
       }
       // Could not find it
       return std::shared_ptr<DataProxyProvider>();
     }

References bookConverter::elements, esproducers_, edm::isTransientEqual(), and muonDTDigis_cfi::pset.

Referenced by edm::eventsetup::ModuleMakerTraits::getComponentAndRegisterProcess().

◆ getESProducerPSet()

ParameterSet const * edm::eventsetup::EventSetupsController::getESProducerPSet	(	ParameterSetID const &	psetID,
		unsigned	subProcessIndex
	)		const

Definition at line 339 of file EventSetupsController.cc.

                                                                                                  {
       auto elements = esproducers_.equal_range(psetID);
       for (auto it = elements.first; it != elements.second; ++it) {
         std::vector<unsigned> const& subProcessIndexes = it->second.subProcessIndexes();
  
         auto iFound = std::find(subProcessIndexes.begin(), subProcessIndexes.end(), subProcessIndex);
         if (iFound == subProcessIndexes.end()) {
           continue;
         }
         return it->second.pset();
       }
       throw edm::Exception(edm::errors::LogicError) << "EventSetupsController::getESProducerPSet\n"
                                                     << "Subprocess index not found. This should never happen\n"
                                                     << "Please report this to a Framework Developer\n";
       return nullptr;
     }

References bookConverter::elements, esproducers_, Exception, spr::find(), and edm::errors::LogicError.

Referenced by edm::eventsetup::EventSetupProvider::checkESProducerSharing().

◆ getESSourceAndRegisterProcess()

std::shared_ptr< EventSetupRecordIntervalFinder > edm::eventsetup::EventSetupsController::getESSourceAndRegisterProcess	(	ParameterSet const &	pset,
		unsigned	subProcessIndex
	)

Definition at line 174 of file EventSetupsController.cc.

                                                             {
       // Try to find a EventSetupRecordIntervalFinder with a matching ParameterSet
       auto elements = essources_.equal_range(pset.id());
       for (auto it = elements.first; it != elements.second; ++it) {
         // Untracked parameters must also match, do complete comparison if IDs match
         if (isTransientEqual(pset, *it->second.pset())) {
           // Register processes with an exact match
           it->second.subProcessIndexes().push_back(subProcessIndex);
           // Return the EventSetupRecordIntervalFinder
           return it->second.finder();
         }
       }
       // Could not find it
       return std::shared_ptr<EventSetupRecordIntervalFinder>();
     }

References bookConverter::elements, essources_, edm::isTransientEqual(), and muonDTDigis_cfi::pset.

Referenced by edm::eventsetup::SourceMakerTraits::getComponentAndRegisterProcess().

◆ hasNonconcurrentFinder()

bool edm::eventsetup::EventSetupsController::hasNonconcurrentFinder ( ) const

inline

Definition at line 159 of file EventSetupsController.h.

159 { return hasNonconcurrentFinder_; }

References hasNonconcurrentFinder_.

Referenced by doWeNeedToWaitForIOVsToFinish().

◆ indexOfNextProcess()

unsigned edm::eventsetup::EventSetupsController::indexOfNextProcess ( ) const

inline

Definition at line 131 of file EventSetupsController.h.

131 { return providers_.size(); }

References providers_.

Referenced by edm::eventsetup::ModuleMakerTraits::getComponentAndRegisterProcess(), edm::eventsetup::SourceMakerTraits::getComponentAndRegisterProcess(), edm::eventsetup::ModuleMakerTraits::putComponent(), and edm::eventsetup::SourceMakerTraits::putComponent().

◆ initializeEventSetupRecordIOVQueues()

void edm::eventsetup::EventSetupsController::initializeEventSetupRecordIOVQueues ( )

private

Definition at line 395 of file EventSetupsController.cc.

                                                                     {
       std::set<EventSetupRecordKey> keys;
       for (auto const& provider : providers_) {
         provider->fillKeys(keys);
       }
  
       for (auto const& key : keys) {
         eventSetupRecordIOVQueues_.push_back(
             std::make_unique<EventSetupRecordIOVQueue>(numberOfConcurrentIOVs_.numberOfConcurrentIOVs(key)));
         EventSetupRecordIOVQueue& iovQueue = *eventSetupRecordIOVQueues_.back();
         for (auto& provider : providers_) {
           EventSetupRecordProvider* recProvider = provider->tryToGetRecordProvider(key);
           if (recProvider) {
             iovQueue.addRecProvider(recProvider);
           }
         }
       }
     }

References edm::eventsetup::EventSetupRecordIOVQueue::addRecProvider(), eventSetupRecordIOVQueues_, crabWrapper::key, relativeConstraints::keys, edm::eventsetup::NumberOfConcurrentIOVs::numberOfConcurrentIOVs(), numberOfConcurrentIOVs_, and providers_.

Referenced by finishConfiguration().

◆ isFirstMatch()

bool edm::eventsetup::EventSetupsController::isFirstMatch	(	ParameterSetID const &	psetID,
		unsigned	subProcessIndex,
		unsigned	precedingProcessIndex
	)		const

Definition at line 239 of file EventSetupsController.cc.

                                                                                    {
       auto elements = esproducers_.equal_range(psetID);
       for (auto it = elements.first; it != elements.second; ++it) {
         std::vector<unsigned> const& subProcessIndexes = it->second.subProcessIndexes();
  
         auto iFound = std::find(subProcessIndexes.begin(), subProcessIndexes.end(), subProcessIndex);
         if (iFound == subProcessIndexes.end()) {
           continue;
         }
  
         auto iFoundPreceding = std::find(subProcessIndexes.begin(), iFound, precedingProcessIndex);
         if (iFoundPreceding == iFound) {
           break;
         } else {
           return iFoundPreceding == subProcessIndexes.begin();
         }
       }
       throw edm::Exception(edm::errors::LogicError) << "EventSetupsController::isFirstMatch\n"
                                                     << "Subprocess index not found. This should never happen\n"
                                                     << "Please report this to a Framework Developer\n";
       return false;
     }

References bookConverter::elements, esproducers_, Exception, spr::find(), and edm::errors::LogicError.

Referenced by edm::eventsetup::EventSetupProvider::checkESProducerSharing().

◆ isLastMatch()

bool edm::eventsetup::EventSetupsController::isLastMatch	(	ParameterSetID const &	psetID,
		unsigned	subProcessIndex,
		unsigned	precedingProcessIndex
	)		const

Definition at line 264 of file EventSetupsController.cc.

                                                                                   {
       auto elements = esproducers_.equal_range(psetID);
       for (auto it = elements.first; it != elements.second; ++it) {
         std::vector<unsigned> const& subProcessIndexes = it->second.subProcessIndexes();
  
         auto iFound = std::find(subProcessIndexes.begin(), subProcessIndexes.end(), subProcessIndex);
         if (iFound == subProcessIndexes.end()) {
           continue;
         }
  
         auto iFoundPreceding = std::find(subProcessIndexes.begin(), iFound, precedingProcessIndex);
         if (iFoundPreceding == iFound) {
           break;
         } else {
           return (++iFoundPreceding) == iFound;
         }
       }
       throw edm::Exception(edm::errors::LogicError) << "EventSetupsController::isLastMatch\n"
                                                     << "Subprocess index not found. This should never happen\n"
                                                     << "Please report this to a Framework Developer\n";
       return false;
     }

References bookConverter::elements, esproducers_, Exception, spr::find(), and edm::errors::LogicError.

Referenced by edm::eventsetup::EventSetupProvider::checkESProducerSharing().

◆ isMatchingESProducer()

bool edm::eventsetup::EventSetupsController::isMatchingESProducer	(	ParameterSetID const &	psetID,
		unsigned	subProcessIndex,
		unsigned	precedingProcessIndex
	)		const

Definition at line 314 of file EventSetupsController.cc.

                                                                                            {
       auto elements = esproducers_.equal_range(psetID);
       for (auto it = elements.first; it != elements.second; ++it) {
         std::vector<unsigned> const& subProcessIndexes = it->second.subProcessIndexes();
  
         auto iFound = std::find(subProcessIndexes.begin(), subProcessIndexes.end(), subProcessIndex);
         if (iFound == subProcessIndexes.end()) {
           continue;
         }
  
         auto iFoundPreceding = std::find(subProcessIndexes.begin(), iFound, precedingProcessIndex);
         if (iFoundPreceding == iFound) {
           return false;
         } else {
           return true;
         }
       }
       throw edm::Exception(edm::errors::LogicError) << "EventSetupsController::lookForMatchingESSource\n"
                                                     << "Subprocess index not found. This should never happen\n"
                                                     << "Please report this to a Framework Developer\n";
       return false;
     }

References bookConverter::elements, esproducers_, Exception, spr::find(), and edm::errors::LogicError.

Referenced by edm::eventsetup::EventSetupProvider::doRecordsMatch().

◆ isMatchingESSource()

bool edm::eventsetup::EventSetupsController::isMatchingESSource	(	ParameterSetID const &	psetID,
		unsigned	subProcessIndex,
		unsigned	precedingProcessIndex
	)		const

Definition at line 289 of file EventSetupsController.cc.

                                                                                          {
       auto elements = essources_.equal_range(psetID);
       for (auto it = elements.first; it != elements.second; ++it) {
         std::vector<unsigned> const& subProcessIndexes = it->second.subProcessIndexes();
  
         auto iFound = std::find(subProcessIndexes.begin(), subProcessIndexes.end(), subProcessIndex);
         if (iFound == subProcessIndexes.end()) {
           continue;
         }
  
         auto iFoundPreceding = std::find(subProcessIndexes.begin(), iFound, precedingProcessIndex);
         if (iFoundPreceding == iFound) {
           return false;
         } else {
           return true;
         }
       }
       throw edm::Exception(edm::errors::LogicError) << "EventSetupsController::lookForMatchingESSource\n"
                                                     << "Subprocess index not found. This should never happen\n"
                                                     << "Please report this to a Framework Developer\n";
       return false;
     }

References bookConverter::elements, essources_, Exception, spr::find(), and edm::errors::LogicError.

Referenced by edm::eventsetup::EventSetupProvider::doRecordsMatch().

◆ lookForMatches()

void edm::eventsetup::EventSetupsController::lookForMatches	(	ParameterSetID const &	psetID,
		unsigned	subProcessIndex,
		unsigned	precedingProcessIndex,
		bool &	firstProcessWithThisPSet,
		bool &	precedingHasMatchingPSet
	)		const

Definition at line 205 of file EventSetupsController.cc.

                                                                                      {
       auto elements = esproducers_.equal_range(psetID);
       for (auto it = elements.first; it != elements.second; ++it) {
         std::vector<unsigned> const& subProcessIndexes = it->second.subProcessIndexes();
  
         auto iFound = std::find(subProcessIndexes.begin(), subProcessIndexes.end(), subProcessIndex);
         if (iFound == subProcessIndexes.end()) {
           continue;
         }
  
         if (iFound == subProcessIndexes.begin()) {
           firstProcessWithThisPSet = true;
           precedingHasMatchingPSet = false;
         } else {
           auto iFoundPreceding = std::find(subProcessIndexes.begin(), iFound, precedingProcessIndex);
           if (iFoundPreceding == iFound) {
             firstProcessWithThisPSet = false;
             precedingHasMatchingPSet = false;
           } else {
             firstProcessWithThisPSet = false;
             precedingHasMatchingPSet = true;
           }
         }
         return;
       }
       throw edm::Exception(edm::errors::LogicError) << "EventSetupsController::lookForMatches\n"
                                                     << "Subprocess index not found. This should never happen\n"
                                                     << "Please report this to a Framework Developer\n";
     }

References bookConverter::elements, esproducers_, Exception, spr::find(), and edm::errors::LogicError.

Referenced by edm::eventsetup::EventSetupProvider::checkESProducerSharing().

◆ makeProvider()

std::shared_ptr< EventSetupProvider > edm::eventsetup::EventSetupsController::makeProvider	(	ParameterSet &	iPSet,
		ActivityRegistry *	activityRegistry,
		ParameterSet const *	eventSetupPset = `nullptr`
	)

Definition at line 42 of file EventSetupsController.cc.

                                                                                                                 {
       // Makes an EventSetupProvider
       // Also parses the prefer information from ParameterSets and puts
       // it in a map that is stored in the EventSetupProvider
       std::shared_ptr<EventSetupProvider> returnValue(
           makeEventSetupProvider(iPSet, providers_.size(), activityRegistry, &taskArena_));
  
       // Construct the ESProducers and ESSources
       // shared_ptrs to them are temporarily stored in this
       // EventSetupsController and in the EventSetupProvider
       fillEventSetupProvider(*this, *returnValue, iPSet);
  
       numberOfConcurrentIOVs_.readConfigurationParameters(eventSetupPset);
  
       providers_.push_back(returnValue);
       return returnValue;
     }

References edm::eventsetup::fillEventSetupProvider(), edm::eventsetup::makeEventSetupProvider(), numberOfConcurrentIOVs_, providers_, edm::eventsetup::NumberOfConcurrentIOVs::readConfigurationParameters(), and taskArena_.

Referenced by edm::eventsetup::SynchronousEventSetupsController::makeProvider(), and edm::SubProcess::SubProcess().

◆ mustFinishConfiguration()

bool edm::eventsetup::EventSetupsController::mustFinishConfiguration ( ) const

inline

Definition at line 160 of file EventSetupsController.h.

160 { return mustFinishConfiguration_; }

References mustFinishConfiguration_.

◆ operator=()

EventSetupsController const& edm::eventsetup::EventSetupsController::operator= ( EventSetupsController const & )

delete

◆ providers()

std::vector<propagate_const<std::shared_ptr<EventSetupProvider> > > const& edm::eventsetup::EventSetupsController::providers ( ) const

inline

Definition at line 153 of file EventSetupsController.h.

153 { return providers_; }

References providers_.

◆ putESProducer()

void edm::eventsetup::EventSetupsController::putESProducer	(	ParameterSet const &	pset,
		std::shared_ptr< DataProxyProvider > const &	component,
		unsigned	subProcessIndex
	)

Definition at line 165 of file EventSetupsController.cc.

                                                                         {
       auto newElement =
           esproducers_.insert(std::pair<ParameterSetID, ESProducerInfo>(pset.id(), ESProducerInfo(&pset, component)));
       // Register processes with an exact match
       newElement->second.subProcessIndexes().push_back(subProcessIndex);
     }

References esproducers_, and muonDTDigis_cfi::pset.

Referenced by edm::eventsetup::ModuleMakerTraits::putComponent().

◆ putESSource()

void edm::eventsetup::EventSetupsController::putESSource	(	ParameterSet const &	pset,
		std::shared_ptr< EventSetupRecordIntervalFinder > const &	component,
		unsigned	subProcessIndex
	)

Definition at line 191 of file EventSetupsController.cc.

                                                                       {
       auto newElement =
           essources_.insert(std::pair<ParameterSetID, ESSourceInfo>(pset.id(), ESSourceInfo(&pset, component)));
       // Register processes with an exact match
       newElement->second.subProcessIndexes().push_back(subProcessIndex);
     }

References essources_, and muonDTDigis_cfi::pset.

Referenced by edm::eventsetup::SourceMakerTraits::putComponent().

◆ setMaxConcurrentIOVs()

void edm::eventsetup::EventSetupsController::setMaxConcurrentIOVs	(	unsigned int	nStreams,
		unsigned int	nConcurrentLumis
	)

Definition at line 62 of file EventSetupsController.cc.

                                                                                                          {
       numberOfConcurrentIOVs_.setMaxConcurrentIOVs(nStreams, nConcurrentLumis);
     }

References runTheMatrix::nStreams, numberOfConcurrentIOVs_, and edm::eventsetup::NumberOfConcurrentIOVs::setMaxConcurrentIOVs().

Member Data Documentation

◆ esproducers_

std::multimap<ParameterSetID, ESProducerInfo> edm::eventsetup::EventSetupsController::esproducers_

private

Definition at line 185 of file EventSetupsController.h.

Referenced by clearComponents(), esproducers(), getESProducerAndRegisterProcess(), getESProducerPSet(), isFirstMatch(), isLastMatch(), isMatchingESProducer(), lookForMatches(), and putESProducer().

◆ essources_

std::multimap<ParameterSetID, ESSourceInfo> edm::eventsetup::EventSetupsController::essources_

private

Definition at line 186 of file EventSetupsController.h.

Referenced by clearComponents(), essources(), getESSourceAndRegisterProcess(), isMatchingESSource(), and putESSource().

◆ eventSetupRecordIOVQueues_

std::vector<propagate_const<std::unique_ptr<EventSetupRecordIOVQueue> > > edm::eventsetup::EventSetupsController::eventSetupRecordIOVQueues_

private

Definition at line 173 of file EventSetupsController.h.

Referenced by endIOVsAsync(), eventSetupForInstanceAsync(), and initializeEventSetupRecordIOVQueues().

◆ hasNonconcurrentFinder_

bool edm::eventsetup::EventSetupsController::hasNonconcurrentFinder_ = false

private

Definition at line 188 of file EventSetupsController.h.

Referenced by finishConfiguration(), and hasNonconcurrentFinder().

◆ mustFinishConfiguration_

bool edm::eventsetup::EventSetupsController::mustFinishConfiguration_ = true

private

Definition at line 189 of file EventSetupsController.h.

Referenced by finishConfiguration(), and mustFinishConfiguration().

◆ numberOfConcurrentIOVs_

NumberOfConcurrentIOVs edm::eventsetup::EventSetupsController::numberOfConcurrentIOVs_

private

Definition at line 169 of file EventSetupsController.h.

Referenced by finishConfiguration(), initializeEventSetupRecordIOVQueues(), makeProvider(), and setMaxConcurrentIOVs().

◆ providers_

std::vector<propagate_const<std::shared_ptr<EventSetupProvider> > > edm::eventsetup::EventSetupsController::providers_

private

Definition at line 168 of file EventSetupsController.h.

Referenced by checkESProducerSharing(), doWeNeedToWaitForIOVsToFinish(), eventSetupForInstanceAsync(), finishConfiguration(), forceCacheClear(), indexOfNextProcess(), initializeEventSetupRecordIOVQueues(), makeProvider(), and providers().

◆ taskArena_

tbb::task_arena edm::eventsetup::EventSetupsController::taskArena_

private

Definition at line 167 of file EventSetupsController.h.

Referenced by makeProvider().

Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ EventSetupsController() [1/2]

◆ EventSetupsController() [2/2]

Member Function Documentation

◆ checkESProducerSharing()

◆ clearComponents()

◆ doWeNeedToWaitForIOVsToFinish()

◆ endIOVsAsync()

◆ esproducers()

◆ essources()

◆ eventSetupForInstanceAsync()

◆ finishConfiguration()

◆ forceCacheClear()

◆ getESProducerAndRegisterProcess()

◆ getESProducerPSet()

◆ getESSourceAndRegisterProcess()

◆ hasNonconcurrentFinder()

◆ indexOfNextProcess()

◆ initializeEventSetupRecordIOVQueues()

◆ isFirstMatch()

◆ isLastMatch()

◆ isMatchingESProducer()

◆ isMatchingESSource()

◆ lookForMatches()

◆ makeProvider()

◆ mustFinishConfiguration()

◆ operator=()

◆ providers()

◆ putESProducer()

◆ putESSource()

◆ setMaxConcurrentIOVs()

Member Data Documentation

◆ esproducers_

◆ essources_

◆ eventSetupRecordIOVQueues_

◆ hasNonconcurrentFinder_

◆ mustFinishConfiguration_

◆ numberOfConcurrentIOVs_

◆ providers_

◆ taskArena_