dbcontroller.hpp

Go to the documentation of this file.

// DUNE DAQ modification notice:
// This file has been modified from the original ATLAS dbe source for the DUNE DAQ project.
// Fork baseline commit: dbe-02-12-17 (2022-05-12).
// Renamed since fork: yes (from dbe/dbcontroller.h to include/dbe/dbcontroller.hpp).
 
#ifndef DBE_DBCONTROLLER_H_
#define DBE_DBCONTROLLER_H_
 
#include "dbe/tref.hpp"
 
#include "dbe/config_reference.hpp"
#include "dbe/confobject_desc.hpp"
#include "dbe/confobject_extra.hpp"
 
#include "dbe/config_direct_access.hpp"
 
#include <iostream>
#include <memory>
#include <mutex>
#include <string>
#include <unordered_map>
#include <vector>
 
namespace dbe {
namespace inner {
//------------------------------------------------------------------------------------------
class dbcontroller
{
public:
  static configobject::tref get(dbe::cokey const& desc);

  static std::vector<configobject::tref> gets(std::string const& cname, std::string const& query = "");

  static configobject::tref create_object_request(dbe::t_config_object_preimage const& rep);

  template<typename T>
  static configobject::tref create_object_request(configobject::aref<T> const& obj);

  template<typename T>
  static configobject::tref create_object_request(configobject::gref<T> const& objref);
 
  template<typename T>
  static configobject::tref create_object_request(configobject::gref<T>& objref,
                                                  typename configobject::gref<T>::config_action_notifiable notice);

  template<typename T>
  static configobject::gref<T> delete_object_request(configobject::tref const& obj);
 
  template<typename T>
  static configobject::gref<T> delete_object_request(configobject::tref const& obj,
                                                     typename configobject::gref<T>::config_action_notifiable notice);

  static configobject::tref move_object_request(configobject::tref objref, std::string const& destfile);

  static configobject::tref rename_object_request(configobject::tref objref, std::string const& newname);

  static void flush();
 
private:
  typedef dbe::cokey t_object_key;
  typedef std::shared_ptr<configobject::oref> t_object_handle;
  typedef std::unordered_map<t_object_key, t_object_handle, configobject::refhasher> t_object_map;

  static dbcontroller& ref();

  configobject::tref insert(dunedaq::conffwk::ConfigObject const&);

  configobject::tref lookup(dbe::cokey const& desc);

  configobject::tref rename(configobject::tref objref, std::string const& aname);

  template<typename T>
  configobject::gref<T> remove(dbe::tref ref);

  std::vector<configobject::tref> referenced_by(configobject::tref objref,
                                                std::string const& name = "*",
                                                bool check_composite_only = true);
 
  t_object_map this_allobjects;
 
  typedef std::recursive_mutex t_mutex;
  typedef std::lock_guard<t_mutex> locker;
  static t_mutex this_lock;
 
  dbcontroller();
  dbcontroller(dbcontroller const&) = delete;
  dbcontroller& operator=(dbcontroller const&) = delete;
 
  friend class configobject::tref;
};
 
} // namespace inner
 
} // end namespace dbe
//------------------------------------------------------------------------------------------
 
#endif /* DBE_DBCONTROLLER_H_ */