The WIBCommon class defines convenience methods for using the ZeroMQ and protobuf communication protocol to the WIB. More...

#include <WIBCommon.hpp>

Public Member Functions
	WIBCommon (const std::string &wib_addr)

	~WIBCommon ()

template<class R , class C >
void	send_command (const C &msg, R &repl)

Private Attributes
zmq::context_t	context

zmq::socket_t	socket

Detailed Description

The WIBCommon class defines convenience methods for using the ZeroMQ and protobuf communication protocol to the WIB.

Definition at line 28 of file WIBCommon.hpp.

Constructor & Destructor Documentation

◆ WIBCommon()

dunedaq::wibmod::WIBCommon::WIBCommon ( const std::string & wib_addr )

Definition at line 20 of file WIBCommon.cpp.

                                              :
    context(1),
    socket(context, ZMQ_REQ)
{
  socket.connect(wib_addr); // tcp://192.168.121.*:1234
  TLOG_DEBUG(0) << wib_addr << " Connected!";
}

◆ ~WIBCommon()

dunedaq::wibmod::WIBCommon::~WIBCommon ( )

Definition at line 28 of file WIBCommon.cpp.

{
  socket.close();
}

Member Function Documentation

◆ send_command()

template<class R , class C >

void dunedaq::wibmod::WIBCommon::send_command	(	const C &	msg,
		R &	repl )

Definition at line 49 of file WIBCommon.hpp.

{
  wib::Command command;
  command.mutable_cmd()->PackFrom(msg);
  
  std::string cmd_str;
  command.SerializeToString(&cmd_str);
  
  zmq::message_t request(cmd_str.size());
  memcpy(static_cast<void*>(request.data()), cmd_str.c_str(), cmd_str.size());
  socket.send(request);
  
  zmq::message_t reply;
  socket.recv(&reply);
  
  std::string reply_str(static_cast<char*>(reply.data()), reply.size());
  repl.ParseFromString(reply_str);
}

Member Data Documentation

◆ context

zmq::context_t dunedaq::wibmod::WIBCommon::context

private

Definition at line 41 of file WIBCommon.hpp.

◆ socket

zmq::socket_t dunedaq::wibmod::WIBCommon::socket