DalRegistry.hxx

Go to the documentation of this file.

#ifndef __DUNEDAQ_CONFFWK_DALREGISTRY_HXX__
#define __DUNEDAQ_CONFFWK_DALREGISTRY_HXX__
 
#include "conffwk/Errors.hpp"
 
namespace dunedaq {
namespace conffwk {
 
//-----------------------------------------------------------------------------
template<class T> 
T *
DalRegistry::get(ConfigObject& obj, bool init_children, bool init_object) {
 
  TLOG_DEBUG(50) << "Building object " << obj.UID() << " of class " << obj.class_name() << " and returning class " << T::s_class_name;
 
  // Ensure that T is a superclass of (or the same class as) obj.class_name()
  if ( not (
    m_confdb.is_superclass_of(obj.class_name(), T::s_class_name) ||
    m_confdb.is_superclass_of(T::s_class_name, obj.class_name())
   )) {
    // do nothing if this is the case
    return nullptr;
  }
 
  // Find the class domain of T
  auto it_dom = m_class_domain_map.find(&DalFactory::instance().get_known_class_name_ref(T::s_class_name));
  
  // Class not known, this should not happen
  if ( it_dom == m_class_domain_map.end() ) {
    const std::string id(obj.UID() + '@' + obj.class_name());
    throw dunedaq::conffwk::NotFound(ERS_HERE, "object", id.c_str());
  }
 
  auto& domain = m_cache_domains[it_dom->second];
 
  DalObject*& dal_ptr(domain.cache[obj.m_impl->m_id]);
  T* result = dynamic_cast<T*>(dal_ptr);
 
  if (result == nullptr) {
    // result = new T(*this, obj);
    dal_ptr = DalFactory::instance().make(*this, obj, T::s_class_name);
 
    TLOG_DEBUG(50) << "Casting " << obj.UID() << " of class " << obj.class_name() << " to " << T::s_class_name;
    result = dynamic_cast<T*>(dal_ptr);
    TLOG_DEBUG(50) << "From " << (void*)dal_ptr << " to " << (void*)result;
 
    if (init_object) {
      std::lock_guard<std::mutex> scoped_lock(result->m_mutex);
      result->init(init_children);
    }
 
  } else if (obj.m_impl != result->p_obj.m_impl) {
 
    std::lock_guard<std::mutex> scoped_lock(result->m_mutex);
    result->set(obj); // update implementation object; to be used in case if the object is re-created
  
  }
 
  TLOG_DEBUG(50) << "Returning " << (void*)result;
 
  return result;
}
 
 
//-----------------------------------------------------------------------------
template<class T> T *
DalRegistry::get(const std::string& name, bool init_children, bool init_object, unsigned long rlevel, const std::vector<std::string> * rclasses) {
 
  TLOG_DEBUG(50) << "Building object " << name;
 
  const std::string& ref_name = DalFactory::instance().get_known_class_name_ref(T::s_class_name);
 
  TLOG_DEBUG(50) << "Ref name is " << ref_name;
 
 
  // Find the class domain of T
  auto it_dom = m_class_domain_map.find(&ref_name);
 
  // Class not known, this should not happen
  if ( it_dom == m_class_domain_map.end() ) {
    const std::string id(name + '@' + T::s_class_name);
    throw dunedaq::conffwk::NotFound(ERS_HERE, "object", id.c_str());
  }
 
  auto& domain = m_cache_domains[it_dom->second];
 
  TLOG_DEBUG(50) << "Class domain for " << ref_name << " is " << it_dom->second;
 
  auto it_ptr = domain.cache.find(ref_name);
 
  TLOG_DEBUG(50) << "Cache found";
 
  if ( it_ptr == domain.cache.end()) {
    try {
      // Search for an ConfigObject of id 'name' of class 'T'
      conffwk::ConfigObject obj;
      m_confdb._get(T::s_class_name, name, obj, rlevel, rclasses);
 
      DalObject*& dal_ptr(domain.cache[obj.m_impl->m_id]);
 
      T* result = dynamic_cast<T*>(dal_ptr);
 
 
      if (result == nullptr) {
        // result = new T(*this, obj);
        dal_ptr = DalFactory::instance().make(*this, obj, T::s_class_name);
 
        TLOG_DEBUG(50) << "Casting " << obj.UID() << " of class " << obj.class_name() << " to " << T::s_class_name;
        result = dynamic_cast<T*>(dal_ptr);
        TLOG_DEBUG(50) << "From " << (void*)dal_ptr << " to " << (void*)result;
 
        if (init_object) {
          std::lock_guard<std::mutex> scoped_lock(result->m_mutex);
          result->init(init_children);
        }
      } else if (obj.m_impl != result->p_obj.m_impl) {
        std::lock_guard<std::mutex> scoped_lock(result->m_mutex);
        result->set(obj); // update implementation object; to be used in case if the object is re-created
      }
      
      return result;
 
    } catch (dunedaq::conffwk::NotFound& ex) {
 
      if (!strcmp(ex.get_type(), "class")) {
 
        std::ostringstream text;
        text << "wrong database schema, cannot find class \"" << ex.get_data() << '\"';
 
        throw dunedaq::conffwk::Generic(ERS_HERE, text.str().c_str());
      }
 
      return nullptr;
    }
  }
 
  std::cout << "Found " << (void*)it_ptr->second << std::endl;
  return dynamic_cast<T*>(it_ptr->second);
 
}
 
 
//-----------------------------------------------------------------------------
template<class T>
T *
DalRegistry::find(const std::string & id) {
  std::lock_guard<std::mutex> scoped_lock(m_mutex);
 
  auto it_dom = m_class_domain_map.find(&T::s_class_name);
 
  if ( it_dom == m_class_domain_map.end()) {
    return nullptr;
  }
 
  auto& domain = m_cache_domains[it_dom.second];
  auto it_obj = domain.cache.find(id);
  return (it_obj != domain.cache.end() ? dynamic_cast<T*>(it_obj->second) : nullptr);
}
 
 
//-----------------------------------------------------------------------------
template<class T>
const T*
DalRegistry::_ref(ConfigObject& obj, const std::string& name, bool read_children)
{
  ConfigObject res;
 
  try {
    obj.get(name, res);
  } catch (dunedaq::conffwk::Generic& ex) {
    throw(dunedaq::conffwk::Generic(ERS_HERE, Configuration::mk_ref_ex_text("an object", T::s_class_name, name, obj).c_str(), ex));
  }
 
  return ((!res.is_null()) ? this->get<T>(res, read_children, read_children) : nullptr);
}
 
 
 
// Get multiple relations from object and instantiate result with it.
template<class T>
void
DalRegistry::_ref(ConfigObject& obj, const std::string& name, std::vector<const T*>& results, bool read_children)
{
 
  std::vector<ConfigObject> objs;
 
  results.clear();
 
  try {
    obj.get(name, objs);
    results.reserve(objs.size());
 
    for (auto& i : objs) {
      auto ptr = this->get<T>(i, read_children, read_children);
      results.push_back(ptr);
    }
  } catch (dunedaq::conffwk::Generic& ex) {
    throw(dunedaq::conffwk::Generic(ERS_HERE, Configuration::mk_ref_ex_text("objects", T::s_class_name, name, obj).c_str(), ex));
  }
}
 
//-----------------------------------------------------------------------------
template<class T>
bool 
DalRegistry::is_valid(const T * object) noexcept {
 
  std::lock_guard<std::mutex> scoped_lock(m_mutex);
 
  auto it_dom = m_class_domain_map.find(&T::s_class_name);
  if ( it_dom == m_class_domain_map.end()) {
    return false;
  }
 
  for( const auto& [uid, ptr] : m_cache_domains[it_dom->second].cache ) {
    if ( ptr == object ) {
      return true;
    }
  }
}
 
 
//-----------------------------------------------------------------------------
template<class T>
void
DalRegistry::update(const std::vector<std::string>& modified,
            const std::vector<std::string>& removed,
            const std::vector<std::string>& created) {
  
  this->update(T::s_class_name, modified, removed, created);
}
 
 
//-----------------------------------------------------------------------------
template<class T> 
void
DalRegistry::_reset_objects() {
 
  // Find the class domain of T
  auto it_dom = m_class_domain_map.find(&DalFactory::instance().get_known_class_name_ref(T::s_class_name));
 
  // Class not known, this should not happen
  if ( it_dom == m_class_domain_map.end() ) {
    throw dunedaq::conffwk::NotFound(ERS_HERE, "class", T::s_class_name.c_str());
  }
 
  auto& domain = m_cache_domains[it_dom->second];
 
  // Loop over the objects in the domain and reset those inheriting from T
  for( const auto& [uid, ptr] : domain.cache ) {
    
 
    T* obj_ptr = dynamic_cast<T*>(ptr);
    
    if (!obj_ptr)
      continue;
 
    std::lock_guard<std::mutex> scoped_lock(domain.mutex);
    obj_ptr->p_was_read = false;
  }
}
 
} // namespace conffwk
} // namespace dunedaq
 
#endif /*__DUNEDAQ_CONFFWK_DALREGISTRY_HXX__ */