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 "zmq.hpp"
#include "wib.pb.h"
 
#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_