Method serverLoop

src/loggers/groot2_publisher.cpp:233–503

}

void Groot2Publisher::serverLoop()
{
  auto const serialized_uuid = CreateRandomUUID();

  auto& socket = _p->server;

  auto sendErrorReply = [&socket](const std::string& msg) {
    zmq::multipart_t error_msg;
    error_msg.addstr("error");
    error_msg.addstr(msg);
    error_msg.send(socket);
  };

  // initialize _p->last_heartbeat
  {
    const std::unique_lock lk(_p->last_heartbeat_mutex);
    _p->last_heartbeat = std::chrono::steady_clock::now();
  }

  while(_p->active_server)
  {
    zmq::multipart_t requestMsg;
    try
    {
      if(!requestMsg.recv(socket) || requestMsg.size() == 0)
      {
        continue;
      }
    }
    catch(const zmq::error_t&)
    {
      // Context was terminated or socket error - exit the loop
      break;
    }

    // this heartbeat will help establishing if Groot is connected or not
    {
      const std::unique_lock lk(_p->last_heartbeat_mutex);
      _p->last_heartbeat = std::chrono::steady_clock::now();
    }

    std::string const request_str = requestMsg[0].to_string();
    if(request_str.size() != Monitor::RequestHeader::size())
    {
      sendErrorReply("wrong request header");
      continue;
    }

    auto request_header = Monitor::DeserializeRequestHeader(request_str);

    Monitor::ReplyHeader reply_header;
    reply_header.request = request_header;
    reply_header.request.protocol = Monitor::kProtocolID;
    reply_header.tree_id = serialized_uuid;

    zmq::multipart_t reply_msg;
    reply_msg.addstr(Monitor::SerializeHeader(reply_header));