SharedResourcesRegistry.h

Go to the documentation of this file.

#ifndef FWCore_Framework_SharedResourcesRegistry_h
#define FWCore_Framework_SharedResourcesRegistry_h
// -*- C++ -*-
//
// Package:     FWCore/Framework
// Class  :     SharedResourcesRegistry
// 
//
// Original Author:  Chris Jones
//         Created:  Sun, 06 Oct 2013 15:48:44 GMT
//

// system include files
#include <vector>
#include <string>
#include <map>
#include <mutex>
#include <memory>

#include "FWCore/Concurrency/interface/SerialTaskQueue.h"
#include "FWCore/Utilities/interface/propagate_const.h"

// user include files

// forward declarations
class testSharedResourcesRegistry;

namespace edm {
  class SharedResourcesAcquirer;
  
  class SharedResourcesRegistry
  {
    
  public:
    //needed for testing
    friend class ::testSharedResourcesRegistry;
    
    // ---------- const member functions ---------------------
    SharedResourcesAcquirer createAcquirer(std::vector<std::string> const&) const;
    
    std::pair<SharedResourcesAcquirer, std::shared_ptr<std::recursive_mutex>> createAcquirerForSourceDelayedReader();
    
    // ---------- static member functions --------------------
    static SharedResourcesRegistry* instance();
    
    static const std::string kLegacyModuleResourceName;
    
    // ---------- member functions ---------------------------
    void registerSharedResource(const std::string&);

#ifdef SHAREDRESOURCETESTACCESSORS
    // The next function is intended to be used only in a unit test
    std::map<std::string, std::pair<std::shared_ptr<SerialTaskQueue>,unsigned int>> const& resourceMap() const { return resourceMap_; }
#endif

  private:
    SharedResourcesRegistry();
    ~SharedResourcesRegistry()=default;

    SharedResourcesRegistry(const SharedResourcesRegistry&) = delete; // stop default
    
    const SharedResourcesRegistry& operator=(const SharedResourcesRegistry&) = delete; // stop default
    
    // ---------- member data --------------------------------
    std::map<std::string, std::pair<std::shared_ptr<SerialTaskQueue>,unsigned int>> resourceMap_;
    
    edm::propagate_const<std::shared_ptr<std::recursive_mutex>> resourceForDelayedReader_;
    
    edm::propagate_const<std::shared_ptr<SerialTaskQueue>> queueForDelayedReader_;

    unsigned int nLegacy_;
  };
}

#endif