daphne::zmq::ControlClient Class Reference

Thin RAII wrapper that sends Configure* protobuf requests and returns the corresponding responses. More...

#include <ControlClient.hpp>

Public Types
using	Milliseconds = std::chrono::milliseconds

Public Member Functions
	ControlClient (zmq::context_t &ctx, std::string_view ip, uint16_t port, Milliseconds timeout=Milliseconds{500})
daphnemodules::ConfigureResponse	configure (const daphnemodules::ConfigureRequest &req)
daphnemodules::ConfigureCLKsResponse	configure_clks (const daphnemodules::ConfigureCLKsRequest &req)

Private Attributes
zmq::socket_t	socket_

Detailed Description

Thin RAII wrapper that sends Configure* protobuf requests and returns the corresponding responses.

Lifetime:

• holds a ref to the external ZeroMQ context (no duplication)
• owns a DEALER/REQ socket

Definition at line 22 of file ControlClient.hpp.

Member Typedef Documentation

Milliseconds

using daphne::zmq::ControlClient::Milliseconds = std::chrono::milliseconds

Definition at line 25 of file ControlClient.hpp.

Constructor & Destructor Documentation

ControlClient()

daphne::zmq::ControlClient::ControlClient	(	zmq::context_t &	ctx,
		std::string_view	ip,
		uint16_t	port,
		Milliseconds	timeout = Milliseconds{500} )

Definition at line 42 of file ControlClient.cpp.

  : socket_(ctx, zmq::socket_type::req)
{
  socket_.set(zmq::sockopt::rcvtimeo, static_cast<int>(timeout.count()));
  socket_.set(zmq::sockopt::sndtimeo, static_cast<int>(timeout.count()));
  socket_.connect(fmt::format("tcp://{}:{}", ip, port));
}

Member Function Documentation

configure()

daphnemodules::ConfigureResponse daphne::zmq::ControlClient::configure

(

const daphnemodules::ConfigureRequest &

req

)

Send an already-filled ConfigureRequest and wait for reply.

Definition at line 56 of file ControlClient.cpp.

{
  auto bytes = make_envelope_bytes(daphnemodules::CONFIGURE_FE, req);
  socket_.send(zmq::buffer(bytes), zmq::send_flags::none);
 
  zmq::message_t reply;
  socket_.recv(reply, zmq::recv_flags::none);
 
  return parse_response<daphnemodules::ConfigureResponse>(
      reply, daphnemodules::CONFIGURE_FE);
}

configure_clks()

daphnemodules::ConfigureCLKsResponse daphne::zmq::ControlClient::configure_clks

(

const daphnemodules::ConfigureCLKsRequest &

req

)

Same for ConfigureCLKsRequest

Definition at line 69 of file ControlClient.cpp.

{
  auto bytes = make_envelope_bytes(daphnemodules::CONFIGURE_CLKS, req);
  socket_.send(zmq::buffer(bytes), zmq::send_flags::none);
 
  zmq::message_t reply;
  socket_.recv(reply, zmq::recv_flags::none);
 
  return parse_response<daphnemodules::ConfigureCLKsResponse>(
      reply, daphnemodules::CONFIGURE_CLKS);
}

Member Data Documentation

socket_

zmq::socket_t daphne::zmq::ControlClient::socket_

private

Definition at line 41 of file ControlClient.hpp.

---

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

• /github/workspace/dunedaq/sourcecode/daphnemodules/src/zmqclient/ControlClient.hpp
• /github/workspace/dunedaq/sourcecode/daphnemodules/src/zmqclient/ControlClient.cpp