QueueRegistry.cpp

Go to the documentation of this file.

 
#include "iomanager/queue/QueueRegistry.hpp"
 
#include <map>
#include <memory>
#include <set>
#include <string>
#include <vector>
 
namespace dunedaq::iomanager {
 
std::unique_ptr<QueueRegistry> QueueRegistry::s_instance = nullptr;
 
QueueRegistry&
QueueRegistry::get()
{
  if (!s_instance) {
    s_instance.reset(new QueueRegistry());
  }
  return *s_instance;
}
 
void
QueueRegistry::configure(const std::vector<const confmodel::Queue*>& configs, opmonlib::OpMonManager& mgr)
{
  if (m_configured) {
    throw QueueRegistryConfigured(ERS_HERE);
  }
 
  m_queue_configs = configs;
 
  mgr.register_node("queues", m_opmon_link);
 
  m_configured = true;
}
 
bool
QueueRegistry::has_queue(const std::string& uid, const std::string& data_type) const
{
  for (auto& config : m_queue_configs) {
    if (config->UID() == uid && config->get_data_type() == data_type) {
      return true;
    }
  }
 
  return false;
}
 
std::set<std::string>
QueueRegistry::get_datatypes(const std::string& uid) const
{
  std::set<std::string> output;
 
  for (auto& config : m_queue_configs) {
    if (config->UID() == uid) {
      output.insert(config->get_data_type());
    }
  }
 
  return output;
}
 
} // namespace dunedaq::iomanager