1

我在boost.1.50源代码中阅读了asio,方法是什么?

void operator()(const boost::system::error_code& ec,
    std::size_t bytes_transferred, int start = 0)
{
  switch (start)
  {
    case 1:
    buffers_.prepare(this->check_for_completion(ec, total_transferred_));
    for (;;)
    {
      stream_.async_read_some(buffers_,
          BOOST_ASIO_MOVE_CAST(read_op)(*this));
      return; default:
      total_transferred_ += bytes_transferred;
      buffers_.consume(bytes_transferred);
      buffers_.prepare(this->check_for_completion(ec, total_transferred_));
      if ((!ec && bytes_transferred == 0)
          || buffers_.begin() == buffers_.end())
        break;
    }

    handler_(ec, static_cast<const std::size_t&>(total_transferred_));
  }
}

代码是从 boost_1_50_0\boost\asio\impl\read.hpp 中获取的。switch case 样式看起来很奇怪,“return;default:”???

4

1 回答 1

1

这是一个管理组合读取操作的函子。

当第一次调用 ( start == 1) 时,它准备缓冲区,发出第一次读取,将自己作为完成处理程序传递,然后返回。

现在,每次作为完成处理程序调用时,它都会直接跳转到default标签并更新缓冲区和内部计数器,并在需要时发出另一个读取。

实际上,可以将此运算符拆分为 2 个单独的运算符:一个用于初始读取,另一个用于后续调用。但也许这种方法会生成更多代码,因此被库作者拒绝。

于 2012-09-03T10:56:10.800 回答