dunedaq::ipm::CallbackAdapter Class Reference

#include <CallbackAdapter.hpp>

Collaboration diagram for dunedaq::ipm::CallbackAdapter:

Public Member Functions
	CallbackAdapter ()=default
virtual	~CallbackAdapter () noexcept
void	set_receiver (Receiver *receiver_ptr)
void	set_callback (std::function< void(Receiver::Response &)> callback)
void	clear_callback ()

Private Member Functions
void	startup ()
void	shutdown ()
void	thread_loop ()

Private Attributes
Receiver *	m_receiver_ptr { nullptr }
std::function< void(Receiver::Response &)>	m_callback { nullptr }
std::mutex	m_callback_mutex
std::unique_ptr< std::thread >	m_thread { nullptr }
std::atomic< bool >	m_is_listening { false }

Detailed Description

Definition at line 24 of file CallbackAdapter.hpp.

Constructor & Destructor Documentation

CallbackAdapter()

dunedaq::ipm::CallbackAdapter::CallbackAdapter ( )

default

~CallbackAdapter()

dunedaq::ipm::CallbackAdapter::~CallbackAdapter ( )

virtualnoexcept

Definition at line 19 of file CallbackAdapter.cpp.

{
  {
    std::lock_guard<std::mutex> lk(m_callback_mutex);
    m_callback = nullptr;
  }
  shutdown();
  m_receiver_ptr = nullptr;
}

Member Function Documentation

clear_callback()

void dunedaq::ipm::CallbackAdapter::clear_callback

(

)

Definition at line 56 of file CallbackAdapter.cpp.

{
  {
    std::lock_guard<std::mutex> lk(m_callback_mutex);
    m_callback = nullptr;
  }
  shutdown();
}

set_callback()

void dunedaq::ipm::CallbackAdapter::set_callback

(

std::function< void(Receiver::Response &)>

callback

)

Definition at line 43 of file CallbackAdapter.cpp.

{
  {
    std::lock_guard<std::mutex> lk(m_callback_mutex);
    m_callback = callback;
  }
 
  if (m_receiver_ptr != nullptr && m_callback != nullptr) {
    startup();
  }
}

set_receiver()

void dunedaq::ipm::CallbackAdapter::set_receiver

(

Receiver *

receiver_ptr

)

Definition at line 30 of file CallbackAdapter.cpp.

{
  {
    std::lock_guard<std::mutex> lk(m_callback_mutex);
    m_receiver_ptr = receiver_ptr;
  }
 
  if (m_receiver_ptr != nullptr && m_callback != nullptr) {
    startup();
  }
}

shutdown()

void dunedaq::ipm::CallbackAdapter::shutdown ( )

private

Definition at line 66 of file CallbackAdapter.cpp.

{
  if (m_thread && m_thread->joinable())
    m_thread->join();
 
  m_is_listening = false;
  m_thread.reset(nullptr);
}

startup()

void dunedaq::ipm::CallbackAdapter::startup ( )

private

Definition at line 76 of file CallbackAdapter.cpp.

{
  shutdown();
  m_is_listening = false;
  m_thread.reset(new std::thread([&] { thread_loop(); }));
 
  while (!m_is_listening.load()) {
    usleep(1000);
  }
}

thread_loop()

void dunedaq::ipm::CallbackAdapter::thread_loop ( )

private

Definition at line 88 of file CallbackAdapter.cpp.

{
  do {
    try {
      auto response = m_receiver_ptr->receive(Receiver::s_no_block);
 
      TLOG_DEBUG(25) << "Received " << response.data.size() << " bytes. Dispatching to callback.";
      {
        std::lock_guard<std::mutex> lk(m_callback_mutex);
        if (m_callback != nullptr) {
          m_callback(response);
        }
      }
    } catch (ipm::ReceiveTimeoutExpired const& tmo) {
      usleep(10000);
    }
    m_is_listening = true;
  } while (m_callback != nullptr && m_receiver_ptr != nullptr);
}

Member Data Documentation

m_callback

std::function<void(Receiver::Response&)> dunedaq::ipm::CallbackAdapter::m_callback { nullptr }

private

Definition at line 41 of file CallbackAdapter.hpp.

{ nullptr };

m_callback_mutex

std::mutex dunedaq::ipm::CallbackAdapter::m_callback_mutex

mutableprivate

Definition at line 42 of file CallbackAdapter.hpp.

m_is_listening

std::atomic<bool> dunedaq::ipm::CallbackAdapter::m_is_listening { false }

private

Definition at line 44 of file CallbackAdapter.hpp.

{ false };

m_receiver_ptr

Receiver* dunedaq::ipm::CallbackAdapter::m_receiver_ptr { nullptr }

private

Definition at line 40 of file CallbackAdapter.hpp.

{ nullptr };

m_thread

std::unique_ptr<std::thread> dunedaq::ipm::CallbackAdapter::m_thread { nullptr }

private

Definition at line 43 of file CallbackAdapter.hpp.

{ nullptr };

---

The documentation for this class was generated from the following files:

• /github/workspace/dunedaq/sourcecode/ipm/src/CallbackAdapter.hpp
• /github/workspace/dunedaq/sourcecode/ipm/src/CallbackAdapter.cpp