DataMoveCallbackRegistry.hpp

Go to the documentation of this file.

#ifndef DATAHANDLINGLIBS_INCLUDE_DATAHANDLINGLIBS_DATAMOVECALLBACKREGISTRY_HPP_
#define DATAHANDLINGLIBS_INCLUDE_DATAHANDLINGLIBS_DATAMOVECALLBACKREGISTRY_HPP_
 
#include "logging/Logging.hpp"
 
#include "appmodel/DataMoveCallbackConf.hpp"
 
#include <functional>
#include <map>
#include <memory>
#include <string>
 
namespace dunedaq {
namespace datahandlinglibs {
 
class CallbackConcept
{
public:
  explicit CallbackConcept(std::string id)
    : m_id(id)
  {
  }
  virtual ~CallbackConcept() = default;
  std::string id() const { return m_id; }
 
protected:
  std::string m_id;
};
 
template<typename DataType>
class DataMoveCallback : public CallbackConcept
{
public:
  DataMoveCallback(std::string id, std::function<void(DataType&&)> callback)
    : CallbackConcept(id)
  {
    m_callback = std::make_shared<std::function<void(DataType&&)>>(callback);
  }
  std::shared_ptr<std::function<void(DataType&&)>> m_callback;
};
 
class DataMoveCallbackRegistry
{
public:
  static std::shared_ptr<DataMoveCallbackRegistry> get()
  {
    if (!s_instance)
      s_instance = std::shared_ptr<DataMoveCallbackRegistry>(new DataMoveCallbackRegistry());
 
    return s_instance;
  }
 
  DataMoveCallbackRegistry(const DataMoveCallbackRegistry&) =
    delete; 
  DataMoveCallbackRegistry& operator=(const DataMoveCallbackRegistry&) =
    delete;                                                      
  DataMoveCallbackRegistry(DataMoveCallbackRegistry&&) = delete; 
  DataMoveCallbackRegistry& operator=(DataMoveCallbackRegistry&&) =
    delete; 

  template<typename DataType>
  void register_callback(const appmodel::DataMoveCallbackConf* conf, std::function<void(DataType&&)> callback);

  template<typename DataType>
  std::shared_ptr<std::function<void(DataType&&)>> get_callback(const appmodel::DataMoveCallbackConf* conf);
 
private:
  DataMoveCallbackRegistry() {}
  std::mutex m_mutex;
  std::map<std::string, std::shared_ptr<CallbackConcept>> m_callback_map;
  static std::shared_ptr<DataMoveCallbackRegistry> s_instance;
};
 
} // namespace datahandlinglibs
} // namespace dunedaq
 
#include "detail/DataMoveCallbackRegistry.hxx"
 
#endif // DATAHANDLINGLIBS_INCLUDE_DATAHANDLINGLIBS_DATAMOVECALLBACKREGISTRY_HPP_