C++ Boost ASIO: jak czytać/pisać z limitem czasu?

Question

Odczytywanie innych wpisów przepełnienia stosu i dokumentacji boost::asio potwierdziło, że nie ma synchronicznych wywołań odczytu/zapisu ASIO, które również zapewniają łatwy w użyciu limit czasu jako parametr połączenia.

Jestem w trakcie konwersji old-schoolowego gniazda Linux-a z wybranymi (2) połączeniami, które wykorzystują limity czasu i muszę zrobić mniej więcej to samo.

Jaki jest najlepszy sposób na zrobienie tego w boost::asio? Patrząc na dokumentację Asio, jest wiele mylących przykładów różnych rzeczy związanych z timerem, ale jestem bardzo zdezorientowany.

Chciałbym zobaczyć prosty do odczytania przykład: Odczytać z gniazda, ale odczekać maksymalnie X sekund, po którym funkcja albo wraca z niczym, albo wraca z czymkolwiek, co było w stanie. do odczytu z gniazda przed upływem limitu czasu.

Answer 1

Zostało to poruszone na listach mailingowych Asio, jest też ticket z żądaniem funkcji. Podsumowując, zaleca się stosowanie metod asynchronicznych, jeśli zależy Ci na limitach czasu i możliwości anulowania.

---

Jeśli nie można konwertować do metod asynchronicznych, można spróbować opcji gniazda SO_RCVTIMEO i SO_SNDTIMEO. Można je ustawić za pomocą setsockopt, deskryptor można uzyskać za pomocą metody boost::asio::ip::tcp::socket::native. Strona man 7 socket człowiek mówi

SO_RCVTIMEO i SO_SNDTIMEO Określ odbiera lub wysyła limity czasu aż zgłoszenie błędu . Argumentem jest czas struktury struct. Jeśli blok funkcyjny na wejściu lub wyjściu dla tego okresu czasu i dane zostały wysłane lub odebrane, wartość zwracana tej funkcji będzie wynosiła ilość przesłanych danych; Jeśli dane nie zostały przesłane i upłynął limit czasu wynoszący , wartość -1 wynosi wrócona z ustawieniem errno na EAGAIN lub EWOULDBLOCK, tak jak gdyby gniazdo zostało określone na , bez blokowania. Jeśli limit czasu to ustawiony na zero (domyślnie), to operacja nigdy nie przekroczy limitu czasu. Limity czasu mają tylko wpływ dla wywołań systemowych wykonujących gniazda I/O (np. Odczyt (2), recvmsg (2), send (2), sendmsg (2)); limity czasu nie mają wpływu na select (2), ankiecie (2), epoll_wait (2), itp

Answer 2

użyłem trochę asio docs produkować to:

class TimeoutAdjust 
{ 
public: 
    TimeoutAdjust(unsigned int dwTimeout) : m_dwTimeout(dwTimeout) {}; 

    template<class Protocol> 
    int level(const Protocol& p) const {return SOL_SOCKET;} 

    template<class Protocol> 
    int name(const Protocol& p) const {return SO_SNDTIMEO;} 

    template<class Protocol> 
    const void* data(const Protocol& p) const {return &m_dwTimeout;} 

    template<class Protocol> 
    size_t size(const Protocol& p) const {return sizeof(m_dwTimeout);} 
private: 
    unsigned int m_dwTimeout; 
}; 

Zastosowanie:

TimeoutAdjust adjust(5000); 
sSocket.set_option(adjust); 

I debugowałem go i wydaje się, że robi to, co powinien.