Zwiększanie asio: Czy możliwe jest przekierowanie zaakceptowanego gniazda tcp do basic_socket_iostream (lub jakoś je z niego pobrać)?

Question

Więc oto mój problem: już mamy accepted doładowanie gniazda asio tcp. I wszystkie nasze interfejsy API go używają. Musimy po prostu wykonać taki "odczyt z przekroczeniem limitu czasu" w jednej funkcji.

Możliwe jest wykonanie takiego "odczytu z przekroczeniem limitu czasu", jak pokazano here. Ale dostaję doładowanie asio tcp gniazda z moich API, więc zastanawiam się, czy to było jak to możliwe, aby włączyć Boost :: Asio gniazdo do basic_socket_iostream. Jak to zrobić?

Answer 1

Zastanawiam się, czy to możliwe, aby jakikolwiek sposób włączyć boost :: asio gniazdo do basic_socket_iostream. Jak to zrobić?

można użyć tcp::iostream::rdbuf() aby uzyskać wskaźnik do socket::basic_socket_streambuf następnie assign() deskryptora.

#include <boost/asio.hpp> 

int 
main() 
{ 
    boost::asio::io_service io_service; 
    boost::asio::ip::tcp::socket socket(io_service); 
    boost::asio::ip::tcp::iostream stream; 
    stream.rdbuf()->assign(boost::asio::ip::tcp::v4(), socket.native_handle()); 
} 

Choć jest bardzo zawiłe i zdecydowanie nie proponuję jechać tą trasą. Jak wskazano Ralf's answer i my answer dla sugerowanego przez ciebie linku, naprawdę powinieneś używać do tego celu deadline_timer.

Answer 2

Nie stwierdzić, czy istnieje wymóg, aby nie używać asynchronicznego API więc może to pomaga, a może nie:

Chyba jestem nieporozumienie was, myślę, że SO odpowiedzieć odwołać patrzy inny przypadek użycia, np. limit czasu przy użyciu tcp :: iostream. Jeśli chcesz po prostu dodać limit czasu do czytania, czy spojrzałeś na timeout examples in the asio documentation? Jest to standardowe podejście do przekroczenia limitu czasu operacji gniazda.

Answer 3

Dla każdego, kto będzie natknąć się ten problem, po próbuje dostać tej pracy na wiele godzin postanowiłem napisać prosty klasy otoki użyciu Boost „Devices”: przykład http://www.boost.org/doc/libs/1_64_0/libs/iostreams/doc/tutorial/container_source.html

#include <iostream> 
#include <boost/smart_ptr.hpp> 
#include <boost/asio.hpp> 
#include <boost/iostreams/stream.hpp> 
#include <boost/iostreams/concepts.hpp> 

using boost::asio::ip::tcp; 

typedef boost::shared_ptr<tcp::socket> socket_ptr; 

class my_source : public boost::iostreams::source 
{ 
public: 
    my_source(socket_ptr sock) : _sock(sock) 
    { 

    } 

    std::streamsize read(char* s, std::streamsize n) 
    { 
     return _sock->read_some(boost::asio::buffer(s, n)); 
    } 

private: 
    socket_ptr _sock; 

}; 

Zastosowanie:

boost::iostreams::stream<my_source> in(sock); 

for (;;) { 
    std::getline(in, line); 
    if (line.length() > 0) 
     std::cout << line << std::endl; 
    else 
     break; 
}