dbcontroller.hpp

Go to the documentation of this file.

#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_ */