WIBCommon.hpp

Go to the documentation of this file.

 
#ifndef WIBMOD_INCLUDE_WIBMOD_WIBCOMMON_HPP_
#define WIBMOD_INCLUDE_WIBMOD_WIBCOMMON_HPP_
 
#include "logging/Logging.hpp"
 
#include "wib.pb.h"
#include "zmq.hpp"
 
#include <string>
 
namespace dunedaq {
namespace wibmod {

class WIBCommon
{
public:
  WIBCommon(const std::string& wib_addr);
 
  ~WIBCommon();
 
  template<class R, class C>
  void send_command(const C& msg, R& repl);
 
private:
  zmq::context_t context;
 
  zmq::socket_t socket;
};
 
template<class R, class C>
void
WIBCommon::send_command(const C& msg, R& repl)
{
  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::send_flags::none);
 
  zmq::message_t reply;
  auto res = socket.recv(reply);
  TLOG_DEBUG(12) << "Recv res=" << res.value_or(0);
 
  std::string reply_str(static_cast<char*>(reply.data()), reply.size());
  repl.ParseFromString(reply_str);
}
 
} // namespace wibmod
} // namespace dunedaq
 
#endif // WIBMOD_INCLUDE_WIBMOD_WIBCOMMON_HPP_