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/confobject_desc.hpp"
#include "dbe/confobject_extra.hpp"
#include "dbe/config_reference.hpp"
 
#include "dbe/config_direct_access.hpp"
 
#include <string>
#include <vector>
#include <memory>
#include <iostream>
#include <mutex>
#include <unordered_map>
 
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_ */