如何使用boost::asio::read_some实现超时

How to implement timeout with using boost::asio::read_some?

本文关键字：some 实现 超时 asio 何使用 boost read      更新时间：2023-10-16

我们可以这样做:

#include <boost/asio.hpp>
#include <boost/optional.hpp>
//...
void http_request::set_result(boost::optional<boost::system::error_code>* a, boost::system::error_code b) 
{ 
    a->reset(b); 
} 
template <typename MutableBufferSequence> 
void read_with_timeout(boost::asio::ip::tcp::socket& sock, 
    const MutableBufferSequence& buffers) 
{ 
    boost::optional<boost::system::error_code> timer_result; 
    boost::asio::deadline_timer timer(sock.io_service()); 
    timer.expires_from_now(seconds(1)); 
    timer.async_wait(boost::bind(set_result, &timer_result, _1)); 
    boost::optional<boost::system::error_code> read_result; 
    async_read(sock, buffers, 
        boost::bind(set_result, &read_result, _1)); 
    sock.io_service().reset(); 
    while (sock.io_service().run_one()) 
    { 
        if (read_result) 
            timer.cancel(); 
        else if (timer_result) 
            sock.cancel(); 
    } 
    if (*read_result) 
        throw std::system_error(*read_result); 
}

如下所示。我想知道这是可能的，以及如何实现timeoutoutread_some在这种方式(我们保持时间跟踪第一个符号)?或者可以使用reead_some_unteel与计时器?

我认为你可以使用大部分相同的代码，只是用socket代替async_read。async_read_some并调整你作为async_read_some的ReadHandler传递的参数

#include <boost/asio.hpp>
#include <boost/optional.hpp>
//...
void http_request::set_result(boost::optional<boost::system::error_code>* a,
                              boost::system::error_code b) 
{ 
    a->reset(b); 
}
void http_request::set_readsome_result(boost::optional<boost::system::error_code>* oa,
        boost::optional<std::size_t>* os, 
        boost::system::error_code a, std::size_t b)
{
    oa->reset(a);
    ob->reset(b);  
}
// Returns true if successful - false if a timeout occurs
template <typename MutableBufferSequence> 
bool read_with_timeout(boost::asio::ip::tcp::socket& sock, 
    const MutableBufferSequence& buffers, std::size_t& amount_read) 
{ 
    boost::optional<boost::system::error_code> timer_result; 
    boost::asio::deadline_timer timer(sock.io_service()); 
    timer.expires_from_now(seconds(1)); 
    timer.async_wait(boost::bind(set_result, &timer_result, _1)); 
    boost::optional<boost::system::error_code> read_error_result;
    boost::optional<std::size_t> read_size_result;
    sock.async_read_some(buffers, 
      boost::bind(set_result, &read_result, &read_size_result, _1, _2));
    sock.io_service().reset(); 
    while (sock.io_service().run_one()) 
    { 
        if (read_result) 
            timer.cancel(); 
        else if (timer_result) 
            sock.cancel(); 
    } 
    if (timer_result)
        return false;
    amount_read = *read_size_result;
    if (*read_error_result) 
        throw std::system_error(*read_result);
    return true;
}
相关文章：