dunedaq::iomanager::IOManager Class Reference

#include <IOManager.hpp>

Public Member Functions
	IOManager (const IOManager &)=delete
	IOManager is not copy-constructible.
IOManager &	operator= (const IOManager &)=delete
	IOManager is not copy-assignable.
	IOManager (IOManager &&)=delete
	IOManager is not move-constructible.
IOManager &	operator= (IOManager &&)=delete
	IOManager is not move-assignable.
void	configure (std::string session, std::vector< const confmodel::Queue * > queues, std::vector< const confmodel::NetworkConnection * > connections, const confmodel::ConnectivityService *connection_service, opmonlib::OpMonManager &)
void	reset ()
void	shutdown ()
template<typename Datatype >
std::shared_ptr< SenderConcept< Datatype > >	get_sender (ConnectionId id)
template<typename Datatype >
std::shared_ptr< SenderConcept< Datatype > >	get_sender (std::string const &uid)
template<typename Datatype >
std::shared_ptr< ReceiverConcept< Datatype > >	get_receiver (ConnectionId id)
template<typename Datatype >
std::shared_ptr< ReceiverConcept< Datatype > >	get_receiver (std::string const &uid)
template<typename Datatype >
std::shared_ptr< ReceiverConcept< Datatype > >	get_receiver (std::string const &uid, std::string const &tag)
template<typename Datatype >
void	add_callback (ConnectionId const &id, std::function< void(Datatype &)> callback)
template<typename Datatype >
void	add_callback (std::string const &uid, std::function< void(Datatype &)> callback)
template<typename Datatype >
void	add_callback (std::string const &uid, std::string const &tag, std::function< void(Datatype &)> callback)
template<typename Datatype >
void	remove_callback (ConnectionId const &id)
template<typename Datatype >
void	remove_callback (std::string const &uid)
template<typename Datatype >
void	remove_callback (std::string const &uid, std::string const &tag)
std::set< std::string >	get_datatypes (std::string const &uid)

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

Private Types
using	SenderMap = std::map<ConnectionId, std::shared_ptr<Sender>>
using	ReceiverMap = std::map<ConnectionId, std::shared_ptr<Receiver>>

Private Member Functions
	IOManager ()

Private Attributes
SenderMap	m_senders
ReceiverMap	m_receivers
std::string	m_session

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

Detailed Description

Wrapper class for sockets and SPSC circular buffers. Makes the communication between DAQ processes easier and scalable.

Definition at line 36 of file IOManager.hpp.

Member Typedef Documentation

ReceiverMap

using dunedaq::iomanager::IOManager::ReceiverMap = std::map<ConnectionId, std::shared_ptr<Receiver>>

private

Definition at line 99 of file IOManager.hpp.

SenderMap

using dunedaq::iomanager::IOManager::SenderMap = std::map<ConnectionId, std::shared_ptr<Sender>>

private

Definition at line 98 of file IOManager.hpp.

Constructor & Destructor Documentation

IOManager() [1/3]

dunedaq::iomanager::IOManager::IOManager ( const IOManager & )

delete

IOManager is not copy-constructible.

IOManager() [2/3]

dunedaq::iomanager::IOManager::IOManager ( IOManager && )

delete

IOManager is not move-constructible.

IOManager() [3/3]

dunedaq::iomanager::IOManager::IOManager ( )

inlineprivate

Definition at line 96 of file IOManager.hpp.

{}

Member Function Documentation

add_callback() [1/3]

template<typename Datatype >

void dunedaq::iomanager::IOManager::add_callback ( ConnectionId const & id, std::function< void(Datatype &)> callback )

inline

Definition at line 24 of file IOManager.hxx.

{
  auto receiver = get_receiver<Datatype>(id);
  receiver->add_callback(callback);
}

add_callback() [2/3]

template<typename Datatype >

void dunedaq::iomanager::IOManager::add_callback ( std::string const & uid, std::function< void(Datatype &)> callback )

inline

Definition at line 124 of file IOManager.hxx.

{
  auto receiver = get_receiver<Datatype>(uid);
  receiver->add_callback(callback);
}

add_callback() [3/3]

template<typename Datatype >

void dunedaq::iomanager::IOManager::add_callback ( std::string const & uid, std::string const & tag, std::function< void(Datatype &)> callback )

inline

Definition at line 132 of file IOManager.hxx.

{
  auto receiver = get_receiver<Datatype>(uid, tag);
  receiver->add_callback(callback);
}

configure()

void dunedaq::iomanager::IOManager::configure	(	std::string	session,
		std::vector< const confmodel::Queue * >	queues,
		std::vector< const confmodel::NetworkConnection * >	connections,
		const confmodel::ConnectivityService *	connection_service,
		opmonlib::OpMonManager &	opmgr )

Definition at line 16 of file IOManager.cpp.

{
  m_session = session;
 
  QueueRegistry::get().configure(queues, opmgr);
  NetworkManager::get().configure(session, connections, connection_service, opmgr);
}

get()

static std::shared_ptr< IOManager > dunedaq::iomanager::IOManager::get ( )

inlinestatic

Definition at line 40 of file IOManager.hpp.

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

get_datatypes()

std::set< std::string > dunedaq::iomanager::IOManager::get_datatypes

(

std::string const &

uid

)

Definition at line 48 of file IOManager.cpp.

{
  auto output = QueueRegistry::get().get_datatypes(uid);
  auto networks = NetworkManager::get().get_datatypes(uid);
  for (auto& dt : networks) {
    output.insert(dt);
  }
  return output;
}

get_receiver() [1/3]

template<typename Datatype >

std::shared_ptr< ReceiverConcept< Datatype > > dunedaq::iomanager::IOManager::get_receiver ( ConnectionId id )

inline

Definition at line 56 of file IOManager.hxx.

{
  if (id.data_type != datatype_to_string<Datatype>()) {
    throw DatatypeMismatch(ERS_HERE, id.uid, id.data_type, datatype_to_string<Datatype>());
  }
 
  if (id.session == "") {
    id.session = m_session;
  }
 
  static std::mutex dt_receiver_mutex;
  std::lock_guard<std::mutex> lk(dt_receiver_mutex);
 
  if (!m_receivers.count(id)) {
    if (QueueRegistry::get().has_queue(id.uid, id.data_type)) { // if queue
      TLOG("IOManager") << "Creating QueueReceiverModel for uid " << id.uid << ", datatype " << id.data_type;
      m_receivers[id] = std::make_shared<QueueReceiverModel<Datatype>>(id);
    } else {
      TLOG("IOManager") << "Creating NetworkReceiverModel for uid " << id.uid << ", datatype " << id.data_type
                        << " in session " << id.session;
      m_receivers[id] = std::make_shared<NetworkReceiverModel<Datatype>>(id);
    }
  }
  return std::dynamic_pointer_cast<ReceiverConcept<Datatype>>(m_receivers[id]); // NOLINT
}

get_receiver() [2/3]

template<typename Datatype >

std::shared_ptr< ReceiverConcept< Datatype > > dunedaq::iomanager::IOManager::get_receiver ( std::string const & uid )

inline

Definition at line 32 of file IOManager.hxx.

{
  auto data_type = datatype_to_string<Datatype>();
  ConnectionId id;
  id.uid = uid;
  id.data_type = data_type;
  id.session = m_session;
  return get_receiver<Datatype>(id);
}

get_receiver() [3/3]

template<typename Datatype >

std::shared_ptr< ReceiverConcept< Datatype > > dunedaq::iomanager::IOManager::get_receiver ( std::string const & uid, std::string const & tag )

inline

Definition at line 43 of file IOManager.hxx.

{
  auto data_type = datatype_to_string<Datatype>();
  ConnectionId id;
  id.uid = uid;
  id.data_type = data_type;
  id.session = m_session;
  id.tag = tag;
  return get_receiver<Datatype>(id);
}

get_sender() [1/2]

template<typename Datatype >

std::shared_ptr< SenderConcept< Datatype > > dunedaq::iomanager::IOManager::get_sender ( ConnectionId id )

inline

Definition at line 96 of file IOManager.hxx.

{
  if (id.data_type != datatype_to_string<Datatype>()) {
    throw DatatypeMismatch(ERS_HERE, id.uid, id.data_type, datatype_to_string<Datatype>());
  }
 
  if (id.session == "") {
    id.session = m_session;
  }
 
  static std::mutex dt_sender_mutex;
  std::lock_guard<std::mutex> lk(dt_sender_mutex);
 
  if (!m_senders.count(id)) {
    if (QueueRegistry::get().has_queue(id.uid, id.data_type)) { // if queue
      TLOG("IOManager") << "Creating QueueSenderModel for uid " << id.uid << ", datatype " << id.data_type;
      m_senders[id] = std::make_shared<QueueSenderModel<Datatype>>(id);
    } else {
      TLOG("IOManager") << "Creating NetworkSenderModel for uid " << id.uid << ", datatype " << id.data_type
                        << " in session " << id.session;
      m_senders[id] = std::make_shared<NetworkSenderModel<Datatype>>(id);
    }
  }
  return std::dynamic_pointer_cast<SenderConcept<Datatype>>(m_senders[id]);
}

get_sender() [2/2]

template<typename Datatype >

std::shared_ptr< SenderConcept< Datatype > > dunedaq::iomanager::IOManager::get_sender ( std::string const & uid )

inline

Definition at line 84 of file IOManager.hxx.

{
  auto data_type = datatype_to_string<Datatype>();
  ConnectionId id;
  id.uid = uid;
  id.data_type = data_type;
  id.session = m_session;
  return get_sender<Datatype>(id);
}

operator=() [1/2]

IOManager & dunedaq::iomanager::IOManager::operator= ( const IOManager & )

delete

IOManager is not copy-assignable.

operator=() [2/2]

IOManager & dunedaq::iomanager::IOManager::operator= ( IOManager && )

delete

IOManager is not move-assignable.

remove_callback() [1/3]

template<typename Datatype >

void dunedaq::iomanager::IOManager::remove_callback ( ConnectionId const & id )

inline

Definition at line 140 of file IOManager.hxx.

{
  auto receiver = get_receiver<Datatype>(id);
  receiver->remove_callback();
}

remove_callback() [2/3]

template<typename Datatype >

void dunedaq::iomanager::IOManager::remove_callback ( std::string const & uid )

inline

Definition at line 148 of file IOManager.hxx.

{
  auto receiver = get_receiver<Datatype>(uid);
  receiver->remove_callback();
}

remove_callback() [3/3]

template<typename Datatype >

void dunedaq::iomanager::IOManager::remove_callback ( std::string const & uid, std::string const & tag )

inline

Definition at line 155 of file IOManager.hxx.

{
  auto receiver = get_receiver<Datatype>(uid, tag);
  receiver->remove_callback();
}

reset()

void dunedaq::iomanager::IOManager::reset

(

)

Definition at line 38 of file IOManager.cpp.

{
  QueueRegistry::get().reset();
  NetworkManager::get().reset();
  m_senders.clear();
  m_receivers.clear();
  s_instance = nullptr;
}

shutdown()

void dunedaq::iomanager::IOManager::shutdown

(

)

Definition at line 29 of file IOManager.cpp.

{
  QueueRegistry::get().shutdown();
  NetworkManager::get().shutdown();
  m_senders.clear();
  m_receivers.clear();
}

Member Data Documentation

m_receivers

ReceiverMap dunedaq::iomanager::IOManager::m_receivers

private

Definition at line 101 of file IOManager.hpp.

m_senders

SenderMap dunedaq::iomanager::IOManager::m_senders

private

Definition at line 100 of file IOManager.hpp.

m_session

std::string dunedaq::iomanager::IOManager::m_session

private

Definition at line 102 of file IOManager.hpp.

s_instance

std::shared_ptr< dunedaq::iomanager::IOManager > dunedaq::iomanager::IOManager::s_instance = nullptr

staticprivate

Definition at line 104 of file IOManager.hpp.

---

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

• /github/workspace/dunedaq/sourcecode/iomanager/include/iomanager/IOManager.hpp
• /github/workspace/dunedaq/sourcecode/iomanager/include/iomanager/detail/IOManager.hxx
• /github/workspace/dunedaq/sourcecode/iomanager/src/IOManager.cpp