edm::SharedResourcesRegistry Class Reference

#include <SharedResourcesRegistry.h>

Public Member Functions
SharedResourcesAcquirer	createAcquirer (std::vector< std::string > const &) const
std::pair< SharedResourcesAcquirer, std::shared_ptr< std::recursive_mutex > >	createAcquirerForSourceDelayedReader ()
const SharedResourcesRegistry &	operator= (const SharedResourcesRegistry &)=delete
void	registerSharedResource (const std::string &)
	A resource name must be registered before it can be used in the createAcquirer call. More...
	SharedResourcesRegistry (const SharedResourcesRegistry &)=delete

Static Public Member Functions
static SharedResourcesRegistry *	instance ()

Private Member Functions
	SharedResourcesRegistry ()
	~SharedResourcesRegistry ()=default

Private Attributes
edm::propagate_const< std::shared_ptr< SerialTaskQueue > >	queueForDelayedReader_
edm::propagate_const< std::shared_ptr< std::recursive_mutex > >	resourceForDelayedReader_
std::map< std::string, std::pair< std::shared_ptr< SerialTaskQueue >, unsigned int > >	resourceMap_

Friends
class	::testSharedResourcesRegistry

Detailed Description

Definition at line 35 of file SharedResourcesRegistry.h.

Constructor & Destructor Documentation

SharedResourcesRegistry() [1/2]

edm::SharedResourcesRegistry::SharedResourcesRegistry ( const SharedResourcesRegistry &  )

delete

SharedResourcesRegistry() [2/2]

SharedResourcesRegistry::SharedResourcesRegistry ( )

private

Definition at line 26 of file SharedResourcesRegistry.cc.

{}

~SharedResourcesRegistry()

edm::SharedResourcesRegistry::~SharedResourcesRegistry ( )

privatedefault

Member Function Documentation

createAcquirer()

SharedResourcesAcquirer SharedResourcesRegistry::createAcquirer

(

std::vector< std::string > const &

resourceNames

)

const

Definition at line 53 of file SharedResourcesRegistry.cc.

References cms::cuda::assert(), eostools::move(), Skims_PA_cff::name, nnet::resource, and resourceMap_.

Referenced by edm::one::impl::SharedResourcesUser< T >::createAcquirer().

                                                                                                                 {
    // The acquirer will acquire the shared resources declared by a module
    // so that only it can use those resources while it runs. The other
    // modules using the same resource will not be run until the module
    // that acquired the resources completes its task.

    // Sort by how often used and then by name
    // Consistent sorting avoids deadlocks and this particular order optimizes performance
    std::map<std::pair<unsigned int, std::string>, std::shared_ptr<SerialTaskQueue>> sortedResources;

    for (auto const& name : resourceNames) {
      auto resource = resourceMap_.find(name);
      assert(resource != resourceMap_.end());
      // If only one module wants it, it really isn't shared
      if (resource->second.second > 1) {
        sortedResources.insert(
            std::make_pair(std::make_pair(resource->second.second, resource->first), resource->second.first));
      }
    }

    std::vector<std::shared_ptr<SerialTaskQueue>> queues;
    queues.reserve(sortedResources.size());
    for (auto const& resource : sortedResources) {
      queues.push_back(resource.second);
    }
    if (queues.empty()) {
      //Calling code is depending on there being at least one shared queue
      queues.reserve(1);
      queues.push_back(std::make_shared<SerialTaskQueue>());
    }

    return SharedResourcesAcquirer(std::move(queues));
  }

createAcquirerForSourceDelayedReader()

std::pair< SharedResourcesAcquirer, std::shared_ptr< std::recursive_mutex > > SharedResourcesRegistry::createAcquirerForSourceDelayedReader

(

)

Definition at line 42 of file SharedResourcesRegistry.cc.

References edm::get_underlying(), eostools::move(), queueForDelayedReader_, and resourceForDelayedReader_.

Referenced by edm::DelayedReaderThrowingSource::DelayedReaderThrowingSource(), edm::PoolSource::PoolSource(), and edm::RootDelayedReader::RootDelayedReader().

                                                                {
    if (not resourceForDelayedReader_) {
      resourceForDelayedReader_ =
          std::make_shared<std::recursive_mutex>();  // propagate_const<T> has no reset() function
      queueForDelayedReader_ = std::make_shared<SerialTaskQueue>();
    }

    std::vector<std::shared_ptr<SerialTaskQueue>> queues = {get_underlying(queueForDelayedReader_)};
    return std::make_pair(SharedResourcesAcquirer(std::move(queues)), get_underlying(resourceForDelayedReader_));
  }

instance()

SharedResourcesRegistry * SharedResourcesRegistry::instance ( )

static

Definition at line 21 of file SharedResourcesRegistry.cc.

Referenced by edm::one::impl::SharedResourcesUser< T >::createAcquirer(), edm::DelayedReaderThrowingSource::DelayedReaderThrowingSource(), edm::PoolSource::PoolSource(), edm::RootDelayedReader::RootDelayedReader(), edm::ESProducer::updateLookup(), edm::one::impl::SharedResourcesUser< T >::usesResource(), and edm::ESProducer::usesResources().

                                                             {
    static SharedResourcesRegistry s_instance;
    return &s_instance;
  }

operator=()

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

delete

registerSharedResource()

void SharedResourcesRegistry::registerSharedResource

(

const std::string &

resourceName

)

A resource name must be registered before it can be used in the createAcquirer call.

Definition at line 28 of file SharedResourcesRegistry.cc.

References resourceMap_.

Referenced by edm::one::impl::SharedResourcesUser< T >::usesResource().

                                                                                    {
    auto& queueAndCounter = resourceMap_[resourceName];

    // count the number of times the resource was registered
    ++queueAndCounter.second;

    // If registering a resource the second time
    // we know we will need the queue so go ahead and create it.
    if (queueAndCounter.second == 2) {
      queueAndCounter.first = std::make_shared<SerialTaskQueue>();
    }
  }

Friends And Related Function Documentation

::testSharedResourcesRegistry

friend class ::testSharedResourcesRegistry

friend

Definition at line 38 of file SharedResourcesRegistry.h.

Member Data Documentation

queueForDelayedReader_

edm::propagate_const<std::shared_ptr<SerialTaskQueue> > edm::SharedResourcesRegistry::queueForDelayedReader_

private

Definition at line 68 of file SharedResourcesRegistry.h.

Referenced by createAcquirerForSourceDelayedReader().

resourceForDelayedReader_

edm::propagate_const<std::shared_ptr<std::recursive_mutex> > edm::SharedResourcesRegistry::resourceForDelayedReader_

private

Definition at line 66 of file SharedResourcesRegistry.h.

Referenced by createAcquirerForSourceDelayedReader().

resourceMap_

std::map<std::string, std::pair<std::shared_ptr<SerialTaskQueue>, unsigned int> > edm::SharedResourcesRegistry::resourceMap_

private

Definition at line 64 of file SharedResourcesRegistry.h.

Referenced by createAcquirer(), and registerSharedResource().