使用 boost::asio::async_read 失败，但 boost::asio::read 有效（正在使用 io_stream.run_one()）

Question

我有一个本机 posix 套接字，我尝试使用 boost::asio::async_read 异步读取它。但是，当我这样做时：

// io_stream and fd are passed by reference to this function
asio::posix::stream_descriptor stream(io_stream);
stream.assign(fd);

boost::system::error_code ec;

asio::async_read(stream, buffer,
                 asio::transfer_at_least(1),
                 boost::bind(doRead,
                             asio::placeholders::error,
                             asio::placeholders::bytes_transferred));
size_t count = io_service.run_one(ec);

count 变量设置为 0，并且 doRead 处理程序永远不会被调用，并且 ec 不包含错误。但是，如果我将异步读取替换为同步读取：

size_t count = asio::read(stream, buffer,
                          asio::transfer_at_least(1));

这会起作用，并且我会在计数变量中得到预期的数据量。

我的测试用例使用由“int pipeline(int pipelinefd[2]);”创建的 fd并通过 asio::async_read 很好地传递数据，所以我认为这可能是几个选项：

• 我传递的本机描述符在某种程度上与 async_read 不兼容，因此它会默默地失败。我尝试过通过阻塞打开和关闭来创建它，但没有成功。
• io_service 和 posix::stream_descriptor 没有连接，因此 io_service 永远不会尝试运行读取。这可能是由于我通过引用传递 io_service 造成的吗？ （就此而言，也在几个线程内？）

Answer 1

我发现了这个问题。

我在拥有对象的初始化函数中调用 io_service.stop() ，因为它可以重新初始化。然而，在调用停止后我没有调用 io_service.reset() ，并且 io_service 在停止后不会运行，直到调用重置为止。

RTFM 中的一课作为停止和重置都记录了这一点。

然而 boost::system::error_code 变量并没有反映这种状态，这有点令人沮丧，因为它可以让我省去一些麻烦。