我正在尝试将D-Bus与我的boost::asio
应用程序集成。
D-Bus具有一个API,枚举一组Unix文件描述符(主要是套接字,但也可以是FIFO),以进行监视。 当这些描述符有可读内容时,我应该通知D-Bus API,以便它可以读取它们并执行操作。
目前我正在这样做:
using boost::asio::posix::stream_descriptor;
void read_handle(stream_descriptor* desc, const boost::system::error_code& ec,
std::size_t bytes_read)
{
if (!ec) {
stream_descriptor::bytes_readable command(true);
descriptor->io_control(command);
std::size_t bytes_readable = command.get();
std::cout << "It thinks I should read" << bytes_readable
<< " bytes" << std::endl;
} else {
std::cout << "There was an error" << std::endl;
}
}
void watch_descriptor(boost::asio::io_service& ios, int file_descriptor)
{
// Create the asio representation of the descriptor
stream_descriptor* desc = new stream_descriptor(ios);
desc->assign(file_descriptor);
// Try to read 0 bytes just to be informed that there is something to be read
std::vector<char> buffer(0);
desc->async_read_some(boost::asio::buffer(buffer, 0),
boost::bind(read_handle, desc, _1, _2));
}
但是处理程序立即被调用,表示没有任何字节可以读取。我希望它只在有东西可读时才被调用,但是boost::asio不能读取它。它应该像一个增强版本的select()
一样工作。有简单的方法吗?
PS:我在我的软件中广泛使用boost::asio
,这只是其中的一小部分,因此我不想依赖于glib
或其他主循环。