c++ - async_receive_from 在 Linux 下接收几个数据包后停止

Question

我有一个设置，多个对等方每 200 毫秒 (5fps) 广播一次 udp 数据包(包含图像)。

虽然接收本地流作为外部流在 Windows 下工作正常，但相同的代码(除了 Windows XP 中的 socket->cancel();，请参见代码中的注释)产生相当奇怪的结果Linux 下的行为:

• 另一台机器发送的前几个(5~7)个数据包(当这台机器开始流式传输时)按预期接收；
• 在此之后，在不规则的长间隔(12 秒、5 秒、17 秒，...)或超时(定义为 20 秒后)后接收来自另一台机器的数据包。在某些时刻，再次如预期收到突发的 (3~4) 个数据包。
• 机器本身发送的数据包仍按预期接收。

使用 Wireshark，我看到本地和外部数据包都按预期到达，连续数据包之间的时间间隔正确。当本地机器仅监听单个其他流而禁用本地流时，也会出现此行为。

这是来自接收器的一些代码(有一些更新如下建议，谢谢!):

Receiver::Receiver(port p)
{
  this->port = p;
  this->stop = false;
}

int Receiver::run()
{
  io_service io_service;
  boost::asio::ip::udp::socket socket(
    io_service,
    boost::asio::ip::udp::endpoint(boost::asio::ip::udp::v4(),
    this->port));
  while(!stop)
  {
    const int bufflength = 65000;
    int timeout = 20000;
    char sockdata[bufflength];
    boost::asio::ip::udp::endpoint remote_endpoint;
    int rcvd;

    bool read_success = this->receive_with_timeout(
           sockdata, bufflength, &rcvd, &socket, remote_endpoint, timeout);

    if(read_success)
    {
      std::cout << "read succes " << remote_endpoint.address().to_string() << std::endl;
    }
    else
    {
      std::cout << "read fail" << std::endl;
    }
  }
  return 0;
}

void handle_receive_from(
  bool* toset, boost::system::error_code error, size_t length, int* outsize)
{
  if(!error || error == boost::asio::error::message_size)
  {
    *toset = length>0?true:false;
    *outsize = length;
  }
  else
  {
    std::cout << error.message() << std::endl;
  }
}

// Update: error check
void handle_timeout( bool* toset, boost::system::error_code error)
{
  if(!error)
  {
    *toset = true;
  }
  else
  {
    std::cout << error.message() << std::endl;
  }
}

bool Receiver::receive_with_timeout(
  char* data, int buffl, int* outsize,
  boost::asio::ip::udp::socket *socket,
  boost::asio::ip::udp::endpoint &sender_endpoint, int msec_tout)
{
  bool timer_overflow = false;
  bool read_result = false;

  deadline_timer timer( socket->get_io_service() );

  timer.expires_from_now( boost::posix_time::milliseconds(msec_tout) );
  timer.async_wait( boost::bind(&handle_timeout, &timer_overflow,
    boost::asio::placeholders::error) );

  socket->async_receive_from(
    boost::asio::buffer(data, buffl), sender_endpoint,
    boost::bind(&handle_receive_from, &read_result,
    boost::asio::placeholders::error,
    boost::asio::placeholders::bytes_transferred, outsize));

  socket->get_io_service().reset();

  while ( socket->get_io_service().run_one())
  {
    if ( read_result )
    {
      timer.cancel();
    }
    else if ( timer_overflow )
    {
      //not to be used on Windows XP, Windows Server 2003, or earlier
      socket->cancel();
      // Update: added run_one()
      socket->get_io_service().run_one();
    }
  }
  // Update: added run_one()
  socket->get_io_service().run_one();
  return read_result;
}

当计时器超过 20 秒时，将返回“操作已取消”的错误消息，但很难获得有关正在发生的事情的任何其他信息。

任何人都可以找出问题或给我一些提示以获取有关问题所在的更多信息吗？感谢您的帮助。

Answer 1

好的，您正在做的是，当您调用 receive_with_timeout 时，您正在设置两个异步请求(一个用于 recv，一个用于超时)。当第一个完成时，您取消另一个。

但是，您永远不会再次调用 ioservice::run_one() 以允许其回调完成。当您在 boost::asio 中取消一个操作时，它会调用处理程序，通常带有一个错误代码，指示该操作已被中止或取消。在这种情况下，我相信一旦您销毁截止日期服务，您就会有一个悬空的处理程序，因为它有一个指向堆栈的指针，用于存储结果。

解决方法是在函数退出前再次调用run_one()处理取消的回调结果。您还应该检查传递给超时处理程序的错误代码，只有在没有错误的情况下才将其视为超时。

此外，如果确实有超时，您需要执行 run_one 以便 async_recv_from 处理程序可以执行，并报告它已被取消。