123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845 |
- //
- // Copyright (c) 2016-2019 Vinnie Falco (vinnie dot falco at gmail dot com)
- //
- // Distributed under the Boost Software License, Version 1.0. (See accompanying
- // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
- //
- // Official repository: https://github.com/boostorg/beast
- //
- #ifndef BOOST_BEAST_HTTP_READ_HPP
- #define BOOST_BEAST_HTTP_READ_HPP
- #include <boost/beast/core/detail/config.hpp>
- #include <boost/beast/core/error.hpp>
- #include <boost/beast/core/stream_traits.hpp>
- #include <boost/beast/http/basic_parser.hpp>
- #include <boost/beast/http/message.hpp>
- #include <boost/asio/async_result.hpp>
- namespace boost {
- namespace beast {
- namespace http {
- //------------------------------------------------------------------------------
- /** Read part of a message from a stream using a parser.
- This function is used to read part of a message from a stream into an
- instance of @ref basic_parser. The call will block until one of the
- following conditions is true:
- @li A call to @ref basic_parser::put with a non-empty buffer sequence
- is successful.
- @li An error occurs.
- This operation is implemented in terms of one or more calls to the stream's
- `read_some` function. The implementation may read additional bytes from
- the stream that lie past the end of the message being read. These additional
- bytes are stored in the dynamic buffer, which must be preserved for
- subsequent reads.
- If the end of file error is received while reading from the stream, then
- the error returned from this function will be:
- @li @ref error::end_of_stream if no bytes were parsed, or
- @li @ref error::partial_message if any bytes were parsed but the
- message was incomplete, otherwise:
- @li A successful result. The next attempt to read will return
- @ref error::end_of_stream
- @param stream The stream from which the data is to be read. The type must
- meet the <em>SyncReadStream</em> requirements.
- @param buffer Storage for additional bytes read by the implementation from
- the stream. This is both an input and an output parameter; on entry, the
- parser will be presented with any remaining data in the dynamic buffer's
- readable bytes sequence first. The type must meet the <em>DynamicBuffer</em>
- requirements.
- @param parser The parser to use.
- @return The number of bytes consumed by the parser.
- @throws system_error Thrown on failure.
- */
- template<
- class SyncReadStream,
- class DynamicBuffer,
- bool isRequest>
- std::size_t
- read_some(
- SyncReadStream& stream,
- DynamicBuffer& buffer,
- basic_parser<isRequest>& parser);
- /** Read part of a message from a stream using a parser.
- This function is used to read part of a message from a stream into an
- instance of @ref basic_parser. The call will block until one of the
- following conditions is true:
- @li A call to @ref basic_parser::put with a non-empty buffer sequence
- is successful.
- @li An error occurs.
- This operation is implemented in terms of one or more calls to the stream's
- `read_some` function. The implementation may read additional bytes from
- the stream that lie past the end of the message being read. These additional
- bytes are stored in the dynamic buffer, which must be preserved for
- subsequent reads.
- If the end of file error is received while reading from the stream, then
- the error returned from this function will be:
- @li @ref error::end_of_stream if no bytes were parsed, or
- @li @ref error::partial_message if any bytes were parsed but the
- message was incomplete, otherwise:
- @li A successful result. The next attempt to read will return
- @ref error::end_of_stream
- @param stream The stream from which the data is to be read. The type must
- support the <em>SyncReadStream</em> requirements.
- @param buffer Storage for additional bytes read by the implementation from
- the stream. This is both an input and an output parameter; on entry, the
- parser will be presented with any remaining data in the dynamic buffer's
- readable bytes sequence first. The type must meet the <em>DynamicBuffer</em>
- requirements.
- @param parser The parser to use.
- @param ec Set to the error, if any occurred.
- @return The number of bytes consumed by the parser.
- */
- template<
- class SyncReadStream,
- class DynamicBuffer,
- bool isRequest>
- std::size_t
- read_some(
- SyncReadStream& stream,
- DynamicBuffer& buffer,
- basic_parser<isRequest>& parser,
- error_code& ec);
- /** Read part of a message asynchronously from a stream using a parser.
- This function is used to asynchronously read part of a message from
- a stream into an instance of @ref basic_parser. The function call
- always returns immediately. The asynchronous operation will continue
- until one of the following conditions is true:
- @li A call to @ref basic_parser::put with a non-empty buffer sequence
- is successful.
- @li An error occurs.
- This operation is implemented in terms of zero or more calls to the
- next layer's `async_read_some` function, and is known as a <em>composed
- operation</em>. The program must ensure that the stream performs no other
- reads until this operation completes. The implementation may read additional
- bytes from the stream that lie past the end of the message being read.
- These additional bytes are stored in the dynamic buffer, which must be
- preserved for subsequent reads.
- If the end of file error is received while reading from the stream, then
- the error returned from this function will be:
- @li @ref error::end_of_stream if no bytes were parsed, or
- @li @ref error::partial_message if any bytes were parsed but the
- message was incomplete, otherwise:
- @li A successful result. The next attempt to read will return
- @ref error::end_of_stream
- @param stream The stream from which the data is to be read. The type
- must meet the <em>AsyncReadStream</em> requirements.
- @param buffer Storage for additional bytes read by the implementation from
- the stream. This is both an input and an output parameter; on entry, the
- parser will be presented with any remaining data in the dynamic buffer's
- readable bytes sequence first. The type must meet the <em>DynamicBuffer</em>
- requirements. The object must remain valid at least until the handler
- is called; ownership is not transferred.
- @param parser The parser to use. The object must remain valid at least until
- the handler is called; ownership is not transferred.
- @param handler The completion handler to invoke when the operation
- completes. The implementation takes ownership of the handler by
- performing a decay-copy. The equivalent function signature of
- the handler must be:
- @code
- void handler(
- error_code const& error, // result of operation
- std::size_t bytes_transferred // the number of bytes consumed by the parser
- );
- @endcode
- If the handler has an associated immediate executor,
- an immediate completion will be dispatched to it.
- Otherwise, the handler will not be invoked from within
- this function. Invocation of the handler will be performed in a
- manner equivalent to using `net::post`.
- @par Per-Operation Cancellation
- This asynchronous operation supports cancellation for the following
- net::cancellation_type values:
- @li @c net::cancellation_type::terminal
- if the `stream` also supports terminal cancellation, `terminal`
- cancellation leaves the stream in an undefined state, so that only
- closing it is guaranteed to succeed.
- */
- template<
- class AsyncReadStream,
- class DynamicBuffer,
- bool isRequest,
- BOOST_BEAST_ASYNC_TPARAM2 ReadHandler =
- net::default_completion_token_t<
- executor_type<AsyncReadStream>>>
- BOOST_BEAST_ASYNC_RESULT2(ReadHandler)
- async_read_some(
- AsyncReadStream& stream,
- DynamicBuffer& buffer,
- basic_parser<isRequest>& parser,
- ReadHandler&& handler =
- net::default_completion_token_t<
- executor_type<AsyncReadStream>>{});
- //------------------------------------------------------------------------------
- /** Read a complete message header from a stream using a parser.
- This function is used to read a complete message header from a stream
- into an instance of @ref basic_parser. The call will block until one of the
- following conditions is true:
- @li @ref basic_parser::is_header_done returns `true`
- @li An error occurs.
- This operation is implemented in terms of one or more calls to the stream's
- `read_some` function. The implementation may read additional bytes from
- the stream that lie past the end of the message being read. These additional
- bytes are stored in the dynamic buffer, which must be preserved for
- subsequent reads.
- If the end of file error is received while reading from the stream, then
- the error returned from this function will be:
- @li @ref error::end_of_stream if no bytes were parsed, or
- @li @ref error::partial_message if any bytes were parsed but the
- message was incomplete, otherwise:
- @li A successful result. The next attempt to read will return
- @ref error::end_of_stream
- @param stream The stream from which the data is to be read. The type must
- meet the <em>SyncReadStream</em> requirements.
- @param buffer Storage for additional bytes read by the implementation from
- the stream. This is both an input and an output parameter; on entry, the
- parser will be presented with any remaining data in the dynamic buffer's
- readable bytes sequence first. The type must meet the <em>DynamicBuffer</em>
- requirements.
- @param parser The parser to use.
- @return The number of bytes consumed by the parser.
- @throws system_error Thrown on failure.
- @note The implementation will call @ref basic_parser::eager with the value
- `false` on the parser passed in.
- */
- template<
- class SyncReadStream,
- class DynamicBuffer,
- bool isRequest>
- std::size_t
- read_header(
- SyncReadStream& stream,
- DynamicBuffer& buffer,
- basic_parser<isRequest>& parser);
- /** Read a complete message header from a stream using a parser.
- This function is used to read a complete message header from a stream
- into an instance of @ref basic_parser. The call will block until one of the
- following conditions is true:
- @li @ref basic_parser::is_header_done returns `true`
- @li An error occurs.
- This operation is implemented in terms of one or more calls to the stream's
- `read_some` function. The implementation may read additional bytes from
- the stream that lie past the end of the message being read. These additional
- bytes are stored in the dynamic buffer, which must be preserved for
- subsequent reads.
- If the end of file error is received while reading from the stream, then
- the error returned from this function will be:
- @li @ref error::end_of_stream if no bytes were parsed, or
- @li @ref error::partial_message if any bytes were parsed but the
- message was incomplete, otherwise:
- @li A successful result. The next attempt to read will return
- @ref error::end_of_stream
- @param stream The stream from which the data is to be read. The type must
- meet the <em>SyncReadStream</em> requirements.
- @param buffer Storage for additional bytes read by the implementation from
- the stream. This is both an input and an output parameter; on entry, the
- parser will be presented with any remaining data in the dynamic buffer's
- readable bytes sequence first. The type must meet the <em>DynamicBuffer</em>
- requirements.
- @param parser The parser to use.
- @param ec Set to the error, if any occurred.
- @return The number of bytes consumed by the parser.
- @note The implementation will call @ref basic_parser::eager with the value
- `false` on the parser passed in.
- */
- template<
- class SyncReadStream,
- class DynamicBuffer,
- bool isRequest>
- std::size_t
- read_header(
- SyncReadStream& stream,
- DynamicBuffer& buffer,
- basic_parser<isRequest>& parser,
- error_code& ec);
- /** Read a complete message header asynchronously from a stream using a parser.
- This function is used to asynchronously read a complete message header from
- a stream into an instance of @ref basic_parser. The function call always
- returns immediately. The asynchronous operation will continue until one of
- the following conditions is true:
- @li @ref basic_parser::is_header_done returns `true`
- @li An error occurs.
- This operation is implemented in terms of zero or more calls to the
- next layer's `async_read_some` function, and is known as a <em>composed
- operation</em>. The program must ensure that the stream performs no other
- reads until this operation completes. The implementation may read additional
- bytes from the stream that lie past the end of the message being read.
- These additional bytes are stored in the dynamic buffer, which must be
- preserved for subsequent reads.
- If the end of file error is received while reading from the stream, then
- the error returned from this function will be:
- @li @ref error::end_of_stream if no bytes were parsed, or
- @li @ref error::partial_message if any bytes were parsed but the
- message was incomplete, otherwise:
- @li A successful result. The next attempt to read will return
- @ref error::end_of_stream
- @param stream The stream from which the data is to be read. The type
- must meet the <em>AsyncReadStream</em> requirements.
- @param buffer Storage for additional bytes read by the implementation from
- the stream. This is both an input and an output parameter; on entry, the
- parser will be presented with any remaining data in the dynamic buffer's
- readable bytes sequence first. The type must meet the <em>DynamicBuffer</em>
- requirements. The object must remain valid at least until the handler
- is called; ownership is not transferred.
- @param parser The parser to use. The object must remain valid at least until
- the handler is called; ownership is not transferred.
- @param handler The completion handler to invoke when the operation
- completes. The implementation takes ownership of the handler by
- performing a decay-copy. The equivalent function signature of
- the handler must be:
- @code
- void handler(
- error_code const& error, // result of operation
- std::size_t bytes_transferred // the number of bytes consumed by the parser
- );
- @endcode
- If the handler has an associated immediate executor,
- an immediate completion will be dispatched to it.
- Otherwise, the handler will not be invoked from within
- this function. Invocation of the handler will be performed in a
- manner equivalent to using `net::post`.
- @note The implementation will call @ref basic_parser::eager with the value
- `false` on the parser passed in.
- @par Per-Operation Cancellation
- This asynchronous operation supports cancellation for the following
- net::cancellation_type values:
- @li @c net::cancellation_type::terminal
- if the `stream` also supports terminal cancellation, `terminal`
- cancellation leaves the stream in an undefined state, so that only
- closing it is guaranteed to succeed.
- */
- template<
- class AsyncReadStream,
- class DynamicBuffer,
- bool isRequest,
- BOOST_BEAST_ASYNC_TPARAM2 ReadHandler =
- net::default_completion_token_t<
- executor_type<AsyncReadStream>>>
- BOOST_BEAST_ASYNC_RESULT2(ReadHandler)
- async_read_header(
- AsyncReadStream& stream,
- DynamicBuffer& buffer,
- basic_parser<isRequest>& parser,
- ReadHandler&& handler =
- net::default_completion_token_t<
- executor_type<AsyncReadStream>>{});
- //------------------------------------------------------------------------------
- /** Read a complete message from a stream using a parser.
- This function is used to read a complete message from a stream into an
- instance of @ref basic_parser. The call will block until one of the
- following conditions is true:
- @li @ref basic_parser::is_done returns `true`
- @li An error occurs.
- This operation is implemented in terms of one or more calls to the stream's
- `read_some` function. The implementation may read additional bytes from
- the stream that lie past the end of the message being read. These additional
- bytes are stored in the dynamic buffer, which must be preserved for
- subsequent reads.
- If the end of file error is received while reading from the stream, then
- the error returned from this function will be:
- @li @ref error::end_of_stream if no bytes were parsed, or
- @li @ref error::partial_message if any bytes were parsed but the
- message was incomplete, otherwise:
- @li A successful result. The next attempt to read will return
- @ref error::end_of_stream
- @param stream The stream from which the data is to be read. The type must
- meet the <em>SyncReadStream</em> requirements.
- @param buffer Storage for additional bytes read by the implementation from
- the stream. This is both an input and an output parameter; on entry, the
- parser will be presented with any remaining data in the dynamic buffer's
- readable bytes sequence first. The type must meet the <em>DynamicBuffer</em>
- requirements.
- @param parser The parser to use.
- @return The number of bytes consumed by the parser.
- @throws system_error Thrown on failure.
- @note The implementation will call @ref basic_parser::eager with the value
- `true` on the parser passed in.
- */
- template<
- class SyncReadStream,
- class DynamicBuffer,
- bool isRequest>
- std::size_t
- read(
- SyncReadStream& stream,
- DynamicBuffer& buffer,
- basic_parser<isRequest>& parser);
- /** Read a complete message from a stream using a parser.
- This function is used to read a complete message from a stream into an
- instance of @ref basic_parser. The call will block until one of the
- following conditions is true:
- @li @ref basic_parser::is_done returns `true`
- @li An error occurs.
- This operation is implemented in terms of one or more calls to the stream's
- `read_some` function. The implementation may read additional bytes from
- the stream that lie past the end of the message being read. These additional
- bytes are stored in the dynamic buffer, which must be preserved for
- subsequent reads.
- If the end of file error is received while reading from the stream, then
- the error returned from this function will be:
- @li @ref error::end_of_stream if no bytes were parsed, or
- @li @ref error::partial_message if any bytes were parsed but the
- message was incomplete, otherwise:
- @li A successful result. The next attempt to read will return
- @ref error::end_of_stream
- @param stream The stream from which the data is to be read. The type must
- meet the <em>SyncReadStream</em> requirements.
- @param buffer Storage for additional bytes read by the implementation from
- the stream. This is both an input and an output parameter; on entry, the
- parser will be presented with any remaining data in the dynamic buffer's
- readable bytes sequence first. The type must meet the <em>DynamicBuffer</em>
- requirements.
- @param parser The parser to use.
- @param ec Set to the error, if any occurred.
- @return The number of bytes consumed by the parser.
- @note The implementation will call @ref basic_parser::eager with the value
- `true` on the parser passed in.
- */
- template<
- class SyncReadStream,
- class DynamicBuffer,
- bool isRequest>
- std::size_t
- read(
- SyncReadStream& stream,
- DynamicBuffer& buffer,
- basic_parser<isRequest>& parser,
- error_code& ec);
- /** Read a complete message asynchronously from a stream using a parser.
- This function is used to asynchronously read a complete message from a
- stream into an instance of @ref basic_parser. The function call always
- returns immediately. The asynchronous operation will continue until one
- of the following conditions is true:
- @li @ref basic_parser::is_done returns `true`
- @li An error occurs.
- This operation is implemented in terms of zero or more calls to the
- next layer's `async_read_some` function, and is known as a <em>composed
- operation</em>. The program must ensure that the stream performs no other
- reads until this operation completes. The implementation may read additional
- bytes from the stream that lie past the end of the message being read.
- These additional bytes are stored in the dynamic buffer, which must be
- preserved for subsequent reads.
- If the end of file error is received while reading from the stream, then
- the error returned from this function will be:
- @li @ref error::end_of_stream if no bytes were parsed, or
- @li @ref error::partial_message if any bytes were parsed but the
- message was incomplete, otherwise:
- @li A successful result. The next attempt to read will return
- @ref error::end_of_stream
- @param stream The stream from which the data is to be read. The type
- must meet the <em>AsyncReadStream</em> requirements.
- @param buffer Storage for additional bytes read by the implementation from
- the stream. This is both an input and an output parameter; on entry, the
- parser will be presented with any remaining data in the dynamic buffer's
- readable bytes sequence first. The type must meet the <em>DynamicBuffer</em>
- requirements. The object must remain valid at least until the handler
- is called; ownership is not transferred.
- @param parser The parser to use. The object must remain valid at least until
- the handler is called; ownership is not transferred.
- @param handler The completion handler to invoke when the operation
- completes. The implementation takes ownership of the handler by
- performing a decay-copy. The equivalent function signature of
- the handler must be:
- @code
- void handler(
- error_code const& error, // result of operation
- std::size_t bytes_transferred // the number of bytes consumed by the parser
- );
- @endcode
- If the handler has an associated immediate executor,
- an immediate completion will be dispatched to it.
- Otherwise, the handler will not be invoked from within
- this function. Invocation of the handler will be performed in a
- manner equivalent to using `net::post`.
- @note The implementation will call @ref basic_parser::eager with the value
- `true` on the parser passed in.
- @par Per-Operation Cancellation
- This asynchronous operation supports cancellation for the following
- net::cancellation_type values:
- @li @c net::cancellation_type::terminal
- if the `stream` also supports terminal cancellation, `terminal`
- cancellation leaves the stream in an undefined state, so that only
- closing it is guaranteed to succeed.
- */
- template<
- class AsyncReadStream,
- class DynamicBuffer,
- bool isRequest,
- BOOST_BEAST_ASYNC_TPARAM2 ReadHandler =
- net::default_completion_token_t<
- executor_type<AsyncReadStream>>>
- BOOST_BEAST_ASYNC_RESULT2(ReadHandler)
- async_read(
- AsyncReadStream& stream,
- DynamicBuffer& buffer,
- basic_parser<isRequest>& parser,
- ReadHandler&& handler =
- net::default_completion_token_t<
- executor_type<AsyncReadStream>>{});
- //------------------------------------------------------------------------------
- /** Read a complete message from a stream.
- This function is used to read a complete message from a stream into an
- instance of @ref message. The call will block until one of the following
- conditions is true:
- @li The entire message is read in.
- @li An error occurs.
- This operation is implemented in terms of one or more calls to the stream's
- `read_some` function. The implementation may read additional bytes from
- the stream that lie past the end of the message being read. These additional
- bytes are stored in the dynamic buffer, which must be preserved for
- subsequent reads.
- If the end of file error is received while reading from the stream, then
- the error returned from this function will be:
- @li @ref error::end_of_stream if no bytes were parsed, or
- @li @ref error::partial_message if any bytes were parsed but the
- message was incomplete, otherwise:
- @li A successful result. The next attempt to read will return
- @ref error::end_of_stream
- @param stream The stream from which the data is to be read. The type must
- meet the <em>SyncReadStream</em> requirements.
- @param buffer Storage for additional bytes read by the implementation from
- the stream. This is both an input and an output parameter; on entry, the
- parser will be presented with any remaining data in the dynamic buffer's
- readable bytes sequence first. The type must meet the <em>DynamicBuffer</em>
- requirements.
- @param msg The container in which to store the message contents. This
- message container should not have previous contents, otherwise the behavior
- is undefined. The type must be meet the <em>MoveAssignable</em> and
- <em>MoveConstructible</em> requirements.
- @return The number of bytes consumed by the parser.
- @throws system_error Thrown on failure.
- @note The implementation will call @ref basic_parser::eager with the value
- `true` on the parser passed in.
- */
- template<
- class SyncReadStream,
- class DynamicBuffer,
- bool isRequest, class Body, class Allocator>
- std::size_t
- read(
- SyncReadStream& stream,
- DynamicBuffer& buffer,
- message<isRequest, Body, basic_fields<Allocator>>& msg);
- /** Read a complete message from a stream.
- This function is used to read a complete message from a stream into an
- instance of @ref message. The call will block until one of the following
- conditions is true:
- @li The entire message is read in.
- @li An error occurs.
- This operation is implemented in terms of one or more calls to the stream's
- `read_some` function. The implementation may read additional bytes from
- the stream that lie past the end of the message being read. These additional
- bytes are stored in the dynamic buffer, which must be preserved for
- subsequent reads.
- If the end of file error is received while reading from the stream, then
- the error returned from this function will be:
- @li @ref error::end_of_stream if no bytes were parsed, or
- @li @ref error::partial_message if any bytes were parsed but the
- message was incomplete, otherwise:
- @li A successful result. The next attempt to read will return
- @ref error::end_of_stream
- @param stream The stream from which the data is to be read. The type must
- meet the <em>SyncReadStream</em> requirements.
- @param buffer Storage for additional bytes read by the implementation from
- the stream. This is both an input and an output parameter; on entry, the
- parser will be presented with any remaining data in the dynamic buffer's
- readable bytes sequence first. The type must meet the <em>DynamicBuffer</em>
- requirements.
- @param msg The container in which to store the message contents. This
- message container should not have previous contents, otherwise the behavior
- is undefined. The type must be meet the <em>MoveAssignable</em> and
- <em>MoveConstructible</em> requirements.
- @param ec Set to the error, if any occurred.
- @return The number of bytes consumed by the parser.
- @note The implementation will call @ref basic_parser::eager with the value
- `true` on the parser passed in.
- */
- template<
- class SyncReadStream,
- class DynamicBuffer,
- bool isRequest, class Body, class Allocator>
- std::size_t
- read(
- SyncReadStream& stream,
- DynamicBuffer& buffer,
- message<isRequest, Body, basic_fields<Allocator>>& msg,
- error_code& ec);
- /** Read a complete message asynchronously from a stream.
- This function is used to asynchronously read a complete message from a
- stream into an instance of @ref message. The function call always returns
- immediately. The asynchronous operation will continue until one of the
- following conditions is true:
- @li The entire message is read in.
- @li An error occurs.
- This operation is implemented in terms of zero or more calls to the
- next layer's `async_read_some` function, and is known as a <em>composed
- operation</em>. The program must ensure that the stream performs no other
- reads until this operation completes. The implementation may read additional
- bytes from the stream that lie past the end of the message being read.
- These additional bytes are stored in the dynamic buffer, which must be
- preserved for subsequent reads.
- If the end of file error is received while reading from the stream, then
- the error returned from this function will be:
- @li @ref error::end_of_stream if no bytes were parsed, or
- @li @ref error::partial_message if any bytes were parsed but the
- message was incomplete, otherwise:
- @li A successful result. The next attempt to read will return
- @ref error::end_of_stream
- @param stream The stream from which the data is to be read. The type
- must meet the <em>AsyncReadStream</em> requirements.
- @param buffer Storage for additional bytes read by the implementation from
- the stream. This is both an input and an output parameter; on entry, the
- parser will be presented with any remaining data in the dynamic buffer's
- readable bytes sequence first. The type must meet the <em>DynamicBuffer</em>
- requirements. The object must remain valid at least until the handler
- is called; ownership is not transferred.
- @param msg The container in which to store the message contents. This
- message container should not have previous contents, otherwise the behavior
- is undefined. The type must be meet the <em>MoveAssignable</em> and
- <em>MoveConstructible</em> requirements. The object must remain valid
- at least until the handler is called; ownership is not transferred.
- @param handler The completion handler to invoke when the operation
- completes. The implementation takes ownership of the handler by
- performing a decay-copy. The equivalent function signature of
- the handler must be:
- @code
- void handler(
- error_code const& error, // result of operation
- std::size_t bytes_transferred // the number of bytes consumed by the parser
- );
- @endcode
- If the handler has an associated immediate executor,
- an immediate completion will be dispatched to it.
- Otherwise, the handler will not be invoked from within
- this function. Invocation of the handler will be performed in a
- manner equivalent to using `net::post`.
- @note The implementation will call @ref basic_parser::eager with the value
- `true` on the parser passed in.
- @par Per-Operation Cancellation
- This asynchronous operation supports cancellation for the following
- net::cancellation_type values:
- @li @c net::cancellation_type::terminal
- if the `stream` also supports terminal cancellation, `terminal`
- cancellation leaves the stream in an undefined state, so that only
- closing it is guaranteed to succeed.
- */
- template<
- class AsyncReadStream,
- class DynamicBuffer,
- bool isRequest, class Body, class Allocator,
- BOOST_BEAST_ASYNC_TPARAM2 ReadHandler =
- net::default_completion_token_t<
- executor_type<AsyncReadStream>>>
- BOOST_BEAST_ASYNC_RESULT2(ReadHandler)
- async_read(
- AsyncReadStream& stream,
- DynamicBuffer& buffer,
- message<isRequest, Body, basic_fields<Allocator>>& msg,
- ReadHandler&& handler =
- net::default_completion_token_t<
- executor_type<AsyncReadStream>>{});
- } // http
- } // beast
- } // boost
- #include <boost/beast/http/impl/read.hpp>
- #endif
|