dunedaq::datahandlinglibs::DataMoveCallbackRegistry Class Reference

#include <DataMoveCallbackRegistry.hpp>

Public Member Functions
	DataMoveCallbackRegistry (const DataMoveCallbackRegistry &)=delete
	DataMoveCallbackRegistry is not copy-constructible.
DataMoveCallbackRegistry &	operator= (const DataMoveCallbackRegistry &)=delete
	DataMoveCallbackRegistry is not copy-assignable.
	DataMoveCallbackRegistry (DataMoveCallbackRegistry &&)=delete
	DataMoveCallbackRegistry is not move-constructible.
DataMoveCallbackRegistry &	operator= (DataMoveCallbackRegistry &&)=delete
	DataMoveCallbackRegistry is not move-assignable.
template<typename DataType >
void	register_callback (const std::string &id, std::function< void(DataType &&)> callback)
template<typename DataType >
std::shared_ptr< std::function< void(DataType &&)> >	get_callback (const std::string &id)
	Gets the callback function registered with the given ID.

Static Public Member Functions
static std::shared_ptr< DataMoveCallbackRegistry >	get ()

Private Member Functions
	DataMoveCallbackRegistry ()

Private Attributes
std::mutex	m_mutex
std::map< std::string, std::shared_ptr< CallbackConcept > >	m_callback_map

Static Private Attributes
static std::shared_ptr< DataMoveCallbackRegistry >	s_instance = nullptr

Detailed Description

Definition at line 45 of file DataMoveCallbackRegistry.hpp.

Constructor & Destructor Documentation

DataMoveCallbackRegistry() [1/3]

dunedaq::datahandlinglibs::DataMoveCallbackRegistry::DataMoveCallbackRegistry ( const DataMoveCallbackRegistry & )

delete

DataMoveCallbackRegistry is not copy-constructible.

DataMoveCallbackRegistry() [2/3]

dunedaq::datahandlinglibs::DataMoveCallbackRegistry::DataMoveCallbackRegistry ( DataMoveCallbackRegistry && )

delete

DataMoveCallbackRegistry is not move-constructible.

DataMoveCallbackRegistry() [3/3]

dunedaq::datahandlinglibs::DataMoveCallbackRegistry::DataMoveCallbackRegistry ( )

inlineprivate

Definition at line 77 of file DataMoveCallbackRegistry.hpp.

{}

Member Function Documentation

get()

static std::shared_ptr< DataMoveCallbackRegistry > dunedaq::datahandlinglibs::DataMoveCallbackRegistry::get ( )

inlinestatic

Definition at line 48 of file DataMoveCallbackRegistry.hpp.

  {
    if (!s_instance)
      s_instance = std::shared_ptr<DataMoveCallbackRegistry>(new DataMoveCallbackRegistry());
 
    return s_instance;
  }

get_callback()

template<typename DataType >

std::shared_ptr< std::function< void(DataType &&)> > dunedaq::datahandlinglibs::DataMoveCallbackRegistry::get_callback ( const std::string & id )

inline

Gets the callback function registered with the given ID.

Template Parameters

DataType

The expected parameter type of the callback function

Parameters

id	The unique identifier for the callback

Returns

A shared pointer to the callback function

Exceptions

GenericConfigurationError

if the registered callback function's parameter type does not match DataType

Definition at line 23 of file DataMoveCallbackRegistry.hxx.

{
  std::lock_guard<std::mutex> guard(m_mutex);
  if (m_callback_map.contains(id)) {
    TLOG() << "Providing DataMoveCallback with ID: " << id;
    if (auto callback = dynamic_cast<DataMoveCallback<DataType>*>(m_callback_map[id].get()); callback != nullptr) {
      return callback->m_callback;
    } else {
      // As this can happen due to a very bad config error and wherever the acquire is called will lead to undefined behavior
      throw GenericConfigurationError(
        ERS_HERE,
        std::format("Callback cast failed for function signature with datatypes (expected vs. registered) : {} vs. {}",
                    typeid(DataMoveCallback<DataType>).name(),
                    typeid(*m_callback_map[id]).name()));
    }
  } else {
    TLOG() << "No callback registered with ID: " << id << " Returning nullptr.";
    return nullptr;
  }
}

operator=() [1/2]

DataMoveCallbackRegistry & dunedaq::datahandlinglibs::DataMoveCallbackRegistry::operator= ( const DataMoveCallbackRegistry & )

delete

DataMoveCallbackRegistry is not copy-assignable.

operator=() [2/2]

DataMoveCallbackRegistry & dunedaq::datahandlinglibs::DataMoveCallbackRegistry::operator= ( DataMoveCallbackRegistry && )

delete

DataMoveCallbackRegistry is not move-assignable.

register_callback()

template<typename DataType >

void dunedaq::datahandlinglibs::DataMoveCallbackRegistry::register_callback ( const std::string & id, std::function< void(DataType &&)> callback )

inline

Definition at line 11 of file DataMoveCallbackRegistry.hxx.

                                                                                                       {
  std::lock_guard<std::mutex> guard(m_mutex);
  if (m_callback_map.count(id) == 0) {
    TLOG() << "Registering DataMoveCallback with ID: " << id;
    m_callback_map[id] = std::make_shared<DataMoveCallback<DataType>>(DataMoveCallback(id, callback));
  } else {
    TLOG() << "Callback is already registered with ID: " << id << " Ignoring this registration.";
  }
}

Member Data Documentation

m_callback_map

std::map<std::string, std::shared_ptr<CallbackConcept> > dunedaq::datahandlinglibs::DataMoveCallbackRegistry::m_callback_map

private

Definition at line 79 of file DataMoveCallbackRegistry.hpp.

m_mutex

std::mutex dunedaq::datahandlinglibs::DataMoveCallbackRegistry::m_mutex

private

Definition at line 78 of file DataMoveCallbackRegistry.hpp.

s_instance

std::shared_ptr< dunedaq::datahandlinglibs::DataMoveCallbackRegistry > dunedaq::datahandlinglibs::DataMoveCallbackRegistry::s_instance = nullptr

staticprivate

Definition at line 80 of file DataMoveCallbackRegistry.hpp.

---

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

• /github/workspace/dunedaq/sourcecode/datahandlinglibs/include/datahandlinglibs/DataMoveCallbackRegistry.hpp
• /github/workspace/dunedaq/sourcecode/datahandlinglibs/include/datahandlinglibs/detail/DataMoveCallbackRegistry.hxx
• /github/workspace/dunedaq/sourcecode/datahandlinglibs/src/DataMoveCallbackRegistry.cpp