ConfigObjectFactory.cpp

Go to the documentation of this file.

 
#include "ConfigObjectFactory.hpp"
#include "confmodel/Service.hpp"
#include "oks/file.hpp"
 
#include <fmt/core.h> // Replace with std::format when we switch to a newer compiler?
 
namespace dunedaq {
namespace appmodel {
 
ConfigObjectFactory::ConfigObjectFactory(const SmartDaqApplication* parent)
  : m_config(&parent->configuration())
  , m_dbfile(parent->config_object().contained_in())
  , m_app_uid(parent->UID())
{
 
  // FIXME: remove this hacky hack
  oks::OksFile::set_nolock_mode(true);
}
 
ConfigObjectFactory::~ConfigObjectFactory()
{
  // FIXME: remove this hacky hack
  oks::OksFile::set_nolock_mode(false);
}
 
conffwk::ConfigObject
ConfigObjectFactory::create(const std::string& class_name, const std::string& id) const
{
  conffwk::ConfigObject cfg_obj;
  m_config->create(m_dbfile, class_name, id, cfg_obj);
  return cfg_obj;
}
 
//---
conffwk::ConfigObject
ConfigObjectFactory::create_queue_obj(const QueueDescriptor* qdesc, std::string uid) const
{
 
  std::string queue_uid(qdesc->get_uid_base() + uid);
  auto queue_obj = create("Queue", queue_uid);
  queue_obj.set_by_val<std::string>("data_type", qdesc->get_data_type());
  queue_obj.set_by_val<std::string>("queue_type", qdesc->get_queue_type());
  queue_obj.set_by_val<uint32_t>("capacity", qdesc->get_capacity());
 
  return queue_obj;
}
 
//---
conffwk::ConfigObject
ConfigObjectFactory::create_queue_sid_obj(const QueueDescriptor* qdesc, uint32_t src_id) const
{
  std::string queue_uid(fmt::format("{}{}", qdesc->get_uid_base(), src_id));
  auto queue_obj = create("QueueWithSourceId", queue_uid);
 
  queue_obj.set_by_val<std::string>("data_type", qdesc->get_data_type());
  queue_obj.set_by_val<std::string>("queue_type", qdesc->get_queue_type());
  queue_obj.set_by_val<uint32_t>("capacity", qdesc->get_capacity());
  queue_obj.set_by_val<uint32_t>("source_id", src_id);
 
  return queue_obj;
}
 
//---
conffwk::ConfigObject
ConfigObjectFactory::create_queue_sid_obj(const QueueDescriptor* qdesc, const confmodel::DetectorStream* stream) const
{
  return create_queue_sid_obj(qdesc, stream->get_source_id());
}
 
//---
conffwk::ConfigObject
ConfigObjectFactory::create_callback_sid_obj(const DataMoveCallbackDescriptor* cdesc, uint32_t src_id) const
{
  std::string rdc_uid(fmt::format("{}{}", cdesc->get_uid_base(), src_id));
  auto rdc_obj = create("DataMoveCallbackConf", rdc_uid);
 
  rdc_obj.set_by_val<std::string>("data_type", cdesc->get_data_type());
  rdc_obj.set_by_val<uint32_t>("source_id", src_id);
 
  return rdc_obj;
}
//---

conffwk::ConfigObject
ConfigObjectFactory::create_net_obj(const NetworkConnectionDescriptor* ndesc, std::string app_uid) const
{
 
  auto svc_obj = ndesc->get_associated_service()->config_object();
  std::string net_id = ndesc->get_uid_base() + app_uid;
  auto net_obj = create("NetworkConnection", net_id);
 
  net_obj.set_by_val<std::string>("data_type", ndesc->get_data_type());
  net_obj.set_by_val<std::string>("connection_type", ndesc->get_connection_type());
  net_obj.set_by_val<uint32_t>("capacity", ndesc->get_capacity());
  net_obj.set_obj("associated_service", &svc_obj);
 
  return net_obj;
}
 
conffwk::ConfigObject
ConfigObjectFactory::create_net_obj(const NetworkConnectionDescriptor* ndesc) const
{
  return create_net_obj(ndesc, this->m_app_uid);
}
 
} // namespace appmodel
} // namespace dunedaq