QueueRegistry.hpp

Go to the documentation of this file.

 
#ifndef IOMANAGER_INCLUDE_IOMANAGER_QUEUE_QUEUEREGISTRY_HPP_
#define IOMANAGER_INCLUDE_IOMANAGER_QUEUE_QUEUEREGISTRY_HPP_
 
#include "iomanager/SchemaUtils.hpp"
#include "iomanager/queue/Queue.hpp"
#include "iomanager/queue/QueueIssues.hpp"
 
#include "confmodel/Queue.hpp"
#include "opmonlib/OpMonManager.hpp"
 
#include "ers/Issue.hpp"
 
#include <map>
#include <memory>
#include <set>
#include <string>
#include <vector>
 
namespace dunedaq::iomanager {

class QueueRegistry
{
public:
  ~QueueRegistry() = default;

  static QueueRegistry& get();

  template<typename T>
  std::shared_ptr<Queue<T>> get_queue(const std::string& name);

  void configure(const std::vector<const confmodel::Queue*>& configs, opmonlib::OpMonManager& mgr);
 
  // ONLY TO BE USED FOR TESTING!
  static void reset() { s_instance.reset(nullptr); }
  void shutdown() { m_queue_registry.clear(); }
 
  bool has_queue(std::string const& uid, std::string const& data_type) const;
 
  std::set<std::string> get_datatypes(std::string const& uid) const;
 
private:
  struct QueueEntry
  {
    const confmodel::Queue* m_config;
    const std::type_info* m_type;
    std::shared_ptr<QueueBase> m_instance;
  };
 
  QueueRegistry() = default;
 
  template<typename T>
  std::shared_ptr<QueueBase> create_queue(const confmodel::Queue* config);
 
  std::map<std::string, QueueEntry> m_queue_registry;
  std::vector<const confmodel::Queue*> m_queue_configs;
  std::shared_ptr<opmonlib::OpMonLink> m_opmon_link{ std::make_shared<opmonlib::OpMonLink>() };
 
  bool m_configured{ false };
 
  static std::unique_ptr<QueueRegistry> s_instance;
 
  QueueRegistry(const QueueRegistry&) = delete;
  QueueRegistry& operator=(const QueueRegistry&) = delete;
  QueueRegistry(QueueRegistry&&) = delete;
  QueueRegistry& operator=(QueueRegistry&&) = delete;
};
 
} // namespace dunedaq::iomanager
 
#include "detail/QueueRegistry.hxx"
 
#endif // IOMANAGER_INCLUDE_IOMANAGER_QUEUE_QUEUEREGISTRY_HPP_