edm::eventsetup::EventSetupsController Class Reference

#include <EventSetupsController.h>

Public Member Functions
void	clearComponents ()
bool	doWeNeedToWaitForIOVsToFinish (IOVSyncValue const &) const
std::multimap< ParameterSetID, ESProducerInfo > const &	esproducers () const
std::multimap< ParameterSetID, ESSourceInfo > const &	essources () const
void	eventSetupForInstance (IOVSyncValue const &, WaitingTaskHolder const &taskToStartAfterIOVInit, WaitingTaskList &endIOVWaitingTasks, std::vector< std::shared_ptr< const EventSetupImpl >> &)
void	eventSetupForInstance (IOVSyncValue const &)
	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_

Detailed Description

Description: Manages a group of EventSetups which can share components

Usage: <usage>

Definition at line 79 of file EventSetupsController.h.

Constructor & Destructor Documentation

edm::eventsetup::EventSetupsController::EventSetupsController

(

)

Definition at line 33 of file EventSetupsController.cc.

{}

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

delete

Member Function Documentation

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

private

Definition at line 389 of file EventSetupsController.cc.

References providers_.

Referenced by finishConfiguration().

                                                       {
      // 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();
      }
    }

void edm::eventsetup::EventSetupsController::clearComponents

(

)

Definition at line 232 of file EventSetupsController.cc.

References esproducers_, and essources_.

Referenced by finishConfiguration().

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

bool edm::eventsetup::EventSetupsController::doWeNeedToWaitForIOVsToFinish

(

IOVSyncValue const &

syncValue

)

const

Definition at line 163 of file EventSetupsController.cc.

References hasNonconcurrentFinder(), and providers_.

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

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

inline

Definition at line 155 of file EventSetupsController.h.

{ return esproducers_; }

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

inline

Definition at line 157 of file EventSetupsController.h.

{ return essources_; }

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

Definition at line 85 of file EventSetupsController.cc.

References eventSetupRecordIOVQueues_, finishConfiguration(), and providers_.

Referenced by eventSetupForInstance().

                                                                         {
      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);
      }
    }

void edm::eventsetup::EventSetupsController::eventSetupForInstance

(

IOVSyncValue const &

syncValue

)

Definition at line 124 of file EventSetupsController.cc.

References edm::WaitingTaskList::doneWaiting(), eventSetupForInstance(), and edm::make_empty_waiting_task().

                                                                                   {
      // This function only supports use cases where the event setup
      // system is used without multiple concurrent IOVs.
      // At the time this comment is being written, this is used for
      // run transitions and in unit test code. In the future,
      // it may only be needed for unit tests. This function uses
      // the other version of eventSetupForInstance that
      // supports concurrent IOVs. To get this to work, a couple
      // arguments to that function need dummy objects that do
      // not serve any purpose in this context. We also need to
      // add in a task to wait for the asynchronous initialization
      // of IOVs to complete.

      auto waitUntilIOVInitializationCompletes = make_empty_waiting_task();
      waitUntilIOVInitializationCompletes->increment_ref_count();

      // These do nothing ...
      WaitingTaskList dummyWaitingTaskList;
      std::vector<std::shared_ptr<const EventSetupImpl>> dummyEventSetupImpls;

      {
        WaitingTaskHolder waitingTaskHolder(waitUntilIOVInitializationCompletes.get());

        try {
          // All the real work is done here.
          eventSetupForInstance(syncValue, waitingTaskHolder, dummyWaitingTaskList, dummyEventSetupImpls);
          dummyWaitingTaskList.doneWaiting(std::exception_ptr{});
        } catch (...) {
          dummyWaitingTaskList.doneWaiting(std::exception_ptr{});
          waitingTaskHolder.doneWaiting(std::current_exception());
        }
      }
      waitUntilIOVInitializationCompletes->wait_for_all();

      if (waitUntilIOVInitializationCompletes->exceptionPtr() != nullptr) {
        std::rethrow_exception(*(waitUntilIOVInitializationCompletes->exceptionPtr()));
      }
    }

void edm::eventsetup::EventSetupsController::finishConfiguration

(

)

Definition at line 59 of file EventSetupsController.cc.

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

Referenced by eventSetupForInstance().

                                                    {
      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;
      }
    }

void edm::eventsetup::EventSetupsController::forceCacheClear

(

)

Definition at line 174 of file EventSetupsController.cc.

References providers_.

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

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

Definition at line 180 of file EventSetupsController.cc.

References bookConverter::elements, esproducers_, edm::ParameterSet::id(), and edm::isTransientEqual().

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

                                                            {
      // 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>();
    }

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

Definition at line 371 of file EventSetupsController.cc.

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

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

                                                                                                 {
      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;
    }

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

Definition at line 206 of file EventSetupsController.cc.

References bookConverter::elements, essources_, edm::ParameterSet::id(), and edm::isTransientEqual().

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

                                                            {
      // 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>();
    }

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

inline

Definition at line 159 of file EventSetupsController.h.

Referenced by doWeNeedToWaitForIOVsToFinish().

{ return hasNonconcurrentFinder_; }

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

inline

Definition at line 131 of file EventSetupsController.h.

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

{ return providers_.size(); }

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

private

Definition at line 427 of file EventSetupsController.cc.

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

Referenced by finishConfiguration().

                                                                    {
      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);
          }
        }
      }
    }

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

Definition at line 271 of file EventSetupsController.cc.

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

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

                                                                                   {
      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;
    }

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

Definition at line 296 of file EventSetupsController.cc.

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

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

                                                                                  {
      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;
    }

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

Definition at line 346 of file EventSetupsController.cc.

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

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

                                                                                           {
      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;
    }

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

Definition at line 321 of file EventSetupsController.cc.

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

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

                                                                                         {
      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;
    }

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

Definition at line 237 of file EventSetupsController.cc.

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

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

                                                                                     {
      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";
    }

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

Definition at line 35 of file EventSetupsController.cc.

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

Referenced by edm::SubProcess::SubProcess().

                                                                                                                {
      // 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));

      // 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;
    }

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

inline

Definition at line 160 of file EventSetupsController.h.

{ return mustFinishConfiguration_; }

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

delete

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

inline

Definition at line 153 of file EventSetupsController.h.

{ return providers_; }

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

Definition at line 197 of file EventSetupsController.cc.

References esproducers_, and edm::ParameterSet::id().

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

                                                                        {
      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);
    }

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

Definition at line 223 of file EventSetupsController.cc.

References essources_, and edm::ParameterSet::id().

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

                                                                      {
      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);
    }

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

Definition at line 55 of file EventSetupsController.cc.

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

                                                                                                         {
      numberOfConcurrentIOVs_.setMaxConcurrentIOVs(nStreams, nConcurrentLumis);
    }

Member Data Documentation

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

private

Definition at line 184 of file EventSetupsController.h.

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

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

private

Definition at line 185 of file EventSetupsController.h.

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

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

private

Definition at line 172 of file EventSetupsController.h.

Referenced by eventSetupForInstance(), and initializeEventSetupRecordIOVQueues().

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

private

Definition at line 187 of file EventSetupsController.h.

Referenced by finishConfiguration().

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

private

Definition at line 188 of file EventSetupsController.h.

Referenced by finishConfiguration().

NumberOfConcurrentIOVs edm::eventsetup::EventSetupsController::numberOfConcurrentIOVs_

private

Definition at line 168 of file EventSetupsController.h.

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

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

private

Definition at line 167 of file EventSetupsController.h.

Referenced by checkESProducerSharing(), doWeNeedToWaitForIOVsToFinish(), eventSetupForInstance(), finishConfiguration(), forceCacheClear(), initializeEventSetupRecordIOVQueues(), and makeProvider().