dunedaq::ipm::ZmqContext Class Reference

#include <ZmqContext.hpp>

Public Member Functions
zmq::context_t &	GetContext ()
void	set_context_threads (int nthreads)
void	set_context_maxsockets (int max_sockets)

Static Public Member Functions
static ZmqContext &	instance ()

Private Member Functions
	ZmqContext ()
	~ZmqContext ()
	ZmqContext (ZmqContext const &)=delete
	ZmqContext (ZmqContext &&)=delete
ZmqContext &	operator= (ZmqContext const &)=delete
ZmqContext &	operator= (ZmqContext &&)=delete

Private Attributes
zmq::context_t	m_context

Static Private Attributes
static constexpr int	s_minimum_sockets = 16636

Detailed Description

Definition at line 107 of file ZmqContext.hpp.

Constructor & Destructor Documentation

ZmqContext() [1/3]

dunedaq::ipm::ZmqContext::ZmqContext ( )

inlineprivate

Definition at line 130 of file ZmqContext.hpp.

  {
    auto threads_c = getenv("IPM_ZMQ_IO_THREADS");
    if (threads_c != nullptr) {
      auto threads = std::atoi(threads_c); // NOLINT If a conversion error occurs, we discard the result
      if (threads > 1) {
        set_context_threads(threads);
      }
    }
 
    bool sockets_set = false;
    auto sockets_c = getenv("IPM_ZMQ_MAX_SOCKETS");
    if (sockets_c != nullptr) {
      auto sockets = std::atoi(sockets_c); // NOLINT If a conversion error occurs, we discard the result
      if (sockets > s_minimum_sockets) {
        set_context_maxsockets(sockets);
        sockets_set = true;
      }
    }
    if (!sockets_set) {
      set_context_maxsockets(s_minimum_sockets);
    }
  }

~ZmqContext()

dunedaq::ipm::ZmqContext::~ZmqContext ( )

inlineprivate

Definition at line 153 of file ZmqContext.hpp.

{ m_context.close(); }

ZmqContext() [2/3]

dunedaq::ipm::ZmqContext::ZmqContext ( ZmqContext const & )

privatedelete

ZmqContext() [3/3]

dunedaq::ipm::ZmqContext::ZmqContext ( ZmqContext && )

privatedelete

Member Function Documentation

GetContext()

zmq::context_t & dunedaq::ipm::ZmqContext::GetContext ( )

inline

Definition at line 116 of file ZmqContext.hpp.

{ return m_context; }

instance()

static ZmqContext & dunedaq::ipm::ZmqContext::instance ( )

inlinestatic

Definition at line 110 of file ZmqContext.hpp.

  {
    static ZmqContext s_ctx;
    return s_ctx;
  }

operator=() [1/2]

ZmqContext & dunedaq::ipm::ZmqContext::operator= ( ZmqContext && )

privatedelete

operator=() [2/2]

ZmqContext & dunedaq::ipm::ZmqContext::operator= ( ZmqContext const & )

privatedelete

set_context_maxsockets()

void dunedaq::ipm::ZmqContext::set_context_maxsockets ( int max_sockets )

inline

Definition at line 123 of file ZmqContext.hpp.

  {
    TLOG_DEBUG(TLVL_ZMQCONTEXT) << "Setting ZMQ Context max sockets to " << max_sockets;
    m_context.set(zmq::ctxopt::max_sockets, max_sockets);
  }

set_context_threads()

void dunedaq::ipm::ZmqContext::set_context_threads ( int nthreads )

inline

Definition at line 118 of file ZmqContext.hpp.

  {
    TLOG_DEBUG(TLVL_ZMQCONTEXT) << "Setting ZMQ Context IO thread count to " << nthreads;
    m_context.set(zmq::ctxopt::io_threads, nthreads);
  }

Member Data Documentation

m_context

zmq::context_t dunedaq::ipm::ZmqContext::m_context

private

Definition at line 154 of file ZmqContext.hpp.

s_minimum_sockets

int dunedaq::ipm::ZmqContext::s_minimum_sockets = 16636

staticconstexprprivate

Definition at line 155 of file ZmqContext.hpp.

---

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

• /github/workspace/dunedaq/sourcecode/ipm/include/ipm/ZmqContext.hpp