Comment implémenter le timeout avec l'utilisation de boost :: asio :: read_some?

Question

Nous pouvons le faire lire avec le temps sur la prise avec somethiong comme ceci:

#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); 
} 

comme le montre here. Je me demande est-il possible et comment mettre en œuvre timeouted read_some dans une telle fashon (où nous gardons la trace du temps unteel premier symbole)? Ou est-il possible d'utiliser reead_some_unteel avec minuteries?

Answer 1

Je pense que vous pourriez utiliser principalement le même code, il suffit de remplacer async_read avec socket. async_read_some et ajustez les paramètres que vous passez comme ReadHandler pour async_read_some

#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; 

}