Как читать в буфер asio, скажем, `1` байт из одного сокета и чем` read_some` больше из другого? - PullRequest
Новая
       58

Как читать в буфер asio, скажем, `1` байт из одного сокета и чем` read_some` больше из другого?

0 голосов
/ 04 ноября 2011

Итак, я пытаюсь реализовать синхронизированное http-соединение Keep-Alive. И мне нужно быть способным убить его по истечении определенного времени. Так что в настоящее время у меня есть (или, по крайней мере, я хотел бы иметь): 

void http_request::timed_receive_base(boost::asio::ip::tcp::socket& socket, int buffer_size, int seconds_to_wait, int seconds_to_parse)
{
    this->clear();

    http_request_parser_state parser_state = METHOD;

    char* buffer = new char[buffer_size];
    std::string key = "";
    std::string value = "";
    boost::asio::ip::tcp::iostream stream;
    stream.rdbuf()->assign( boost::asio::ip::tcp::v4(), socket.native() );
    try
    {
        do
        {
            stream.expires_from_now(boost::posix_time::seconds(seconds_to_wait));
            int bytes_read = stream.read_some(boost::asio::buffer(buffer, buffer_size));
            stream.expires_from_now(boost::posix_time::seconds(seconds_to_parse));
            if (stream) // false if read timed out or other error
            {
                parse_buffer(buffer, parser_state, key, value, bytes_read);
            }
            else
            {
                throw std::runtime_error("Waiting for 2 long...");
            }


        } while (parser_state != OK);
    }
    catch (...)
    {
        delete buffer;
        throw;
    }
    delete buffer;
}

Но в tcp :: iostream нет read_some, поэтому компилятор выдает мне ошибку: 

Error   1   error C2039: 'read_some' : is not a member of 'boost::asio::basic_socket_iostream<Protocol>'

Вот почему я задаюсь вопросом - как прочитать 1 байт через stream.read (например, stream.read(buffer, 1);) и чем read_some в этот самый буфер через API сокетов (это будет выглядеть как int bytes_read = socket.read_some(boost::asio::buffer(buffer, buffer_size));, а затем вызвать мой parse_buffer функция с действительным bytes_read значением)

Кстати, похоже, будет действительно печальная проблема с 1 последним байтом .. (

1 Ответ

0 голосов
/ 04 ноября 2011

Извините, что немного грубоват, но вы читали документацию?Предполагается, что сокет iostream работает как обычный iostream, например cin и cout.Просто сделай stream >> var.Может быть, вы хотите basic_stream_socket::read_some вместо?

...