Method loop_rx

OpenHD/ohd_common/src/openhd_tcp.cpp:137–155

}

void openhd::TCPServer::ConnectedClient::loop_rx() {
  auto console = openhd::log::create_or_get(fmt::format("TCPClient{}", ip));
  const auto buff = std::make_unique<std::array<uint8_t, READ_BUFF_SIZE>>();
  while (keep_rx_looping) {
    const ssize_t message_length = read(sock_fd, buff->data(), buff->size());
    if (message_length < 0) {
      console->debug("Read error {} {}", message_length, strerror(errno));
      marked_to_be_removed = true;
      break;
    }
    if (message_length == 0) {
      console->debug("Client disconnected");
      marked_to_be_removed = true;
      break;
    }
    parent->on_packet_any_tcp_client(buff->data(), message_length);
  }
  parent->on_external_device(ip, port, false);
}