C++ Boost ASIO: Wie man mit einem Timeout liest/schreibt?

Question

Beim Lesen anderer Stack Overflow-Einträge und der Dokumentation boost::asio habe ich bestätigt, dass es keine synchronen ASIO-Lese-/Schreibaufrufe gibt, die auch ein benutzerfreundliches Timeout als Parameter für den Anruf bereitstellen.

Ich bin mitten in der Umwandlung einer alten Schule Linux-Socket-Anwendung mit Select (2) Anrufe, Timeouts verwendet, und ich muss mehr oder weniger das gleiche tun.

Was ist der beste Weg, dies in boost::asio zu tun? Wenn man sich die Asio-Dokumentation anschaut, gibt es viele verwirrende Beispiele für verschiedene Dinge, die mit Timern zu tun haben, aber ich bin ziemlich verwirrt.

Ich würde gerne ein einfach zu lesendes Beispiel dafür sehen: Lesen von einem Sockel, aber warten Sie für ein Maximum von X Sekunden nach dem die Funktion entweder mit nichts zurückkehrt, oder mit allem zurückkommt, was es konnte aus dem Socket zu lesen, bevor das Timeout abgelaufen ist.

Answer 1

Dies wurde auf den Asio-Mailinglisten aufgezeigt, es gibt eine ticket Anforderung der Funktion. Zusammenfassend wird vorgeschlagen, asynchrone Methoden zu verwenden, wenn Timeouts und Löschbarkeit gewünscht sind.

---

Wenn Sie nicht auf asynchrone Methoden umwandeln kann, können Sie versuchen, die SO_RCVTIMEO und SO_SNDTIMEO Socket-Optionen. Sie können mit setsockopt eingestellt werden, der Deskriptor kann mit der boost::asio::ip::tcp::socket::native Methode erhalten werden. Die man 7 socket Manpage sagt

SO_RCVTIMEO und SO_SNDTIMEO die Empfangs Geben oder das Versenden von Timeouts, bis ein Fehler meldet. Das Argument ist eine Struktur timeval. Wenn ein Eingang oder Ausgang Funktion für diesen Zeitraum von Zeit blockiert, und Daten gesendet oder empfangen wurden, ist der Rückgabewert dieser Funktion die Menge der übertragenen Daten; Wenn keine Daten übertragen wurden und das Timeout erreicht wurde, wird -1 mit zurückgegeben, wobei errno auf EAGAIN oder EWOULDBLOCK gesetzt wird, als ob der Socket auf festgelegt wurde. Wenn das Zeitlimit auf Null gesetzt ist (Standardeinstellung), wird die Operation niemals ablaufen. Timeouts haben nur den Effekt für Systemaufrufe, die Socket-E/A durchführen (z. B. read (2), recvmsg (2), send (2), sendmsg (2)); Timeouts haben keine Auswirkungen für select (2), Umfrage (2), epoll_wait (2) usw.

Answer 2

ich einige asio docs verwendet, um dieses zu produzieren:

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

Verbrauch:

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

Ich debuggte es, und es scheint zu tun, was es soll.