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 appmodel::DataMoveCallbackConf *conf, std::function< void(DataType &&)> callback)
	Registers a callback function with a configuration object.
template<typename DataType >
std::shared_ptr< std::function< void(DataType &&)> >	get_callback (const appmodel::DataMoveCallbackConf *conf)
	Gets the callback function registered with the given configuration.

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 47 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 87 of file DataMoveCallbackRegistry.hpp.

{}

Member Function Documentation

get()

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

inlinestatic

Definition at line 50 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 appmodel::DataMoveCallbackConf * conf )

inline

Gets the callback function registered with the given configuration.

Template Parameters

DataType

The expected parameter type of the callback function

Parameters

conf	The configuration object containing 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 25 of file DataMoveCallbackRegistry.hxx.

{
  std::lock_guard<std::mutex> guard(m_mutex);
  std::string id = conf->UID();
  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 appmodel::DataMoveCallbackConf * conf, std::function< void(DataType &&)> callback )

inline

Registers a callback function with a configuration object.

Template Parameters

DataType

The parameter type of the callback function

Parameters

conf	The configuration object containing the unique identifier for the callback
callback	The callback function to register

Definition at line 11 of file DataMoveCallbackRegistry.hxx.

{
  std::lock_guard<std::mutex> guard(m_mutex);
  std::string id = conf->UID();
  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 89 of file DataMoveCallbackRegistry.hpp.

m_mutex

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

private

Definition at line 88 of file DataMoveCallbackRegistry.hpp.

s_instance

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

staticprivate

Definition at line 90 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