CallbackAdapter.hpp

Go to the documentation of this file.

 
#ifndef IPM_SRC_CALLBACKADAPTER_HPP_
#define IPM_SRC_CALLBACKADAPTER_HPP_
 
#include "ipm/Receiver.hpp"
 
#include <atomic>
#include <functional>
#include <memory>
#include <mutex>
#include <thread>
 
namespace dunedaq::ipm {
 
class CallbackAdapter
{
public:
  CallbackAdapter() = default; // Explicitly defaulted
 
  virtual ~CallbackAdapter() noexcept;
 
  void set_receiver(Receiver* receiver_ptr);
  void set_callback(std::function<void(Receiver::Response&)> callback);
  void clear_callback();
 
private:
  void startup();
  void shutdown();
  void thread_loop();
 
  Receiver* m_receiver_ptr{ nullptr }; // Bare pointer used here as CallbackAdapter does not own the Receiver instance,
                                       // and until set_receiver is called, this will be null.
  std::function<void(Receiver::Response&)> m_callback{ nullptr };
  mutable std::mutex m_callback_mutex;
  std::unique_ptr<std::thread> m_thread{ nullptr };
  std::atomic<bool> m_is_listening{ false };
};
} // namespace dunedaq::ipm
 
#endif // IPM_SRC_CALLBACKADAPTER_HPP_