123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763 |
- //
- // 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_WRITE_HPP
- #define BOOST_BEAST_HTTP_WRITE_HPP
- #include <boost/beast/core/detail/config.hpp>
- #include <boost/beast/http/message.hpp>
- #include <boost/beast/http/serializer.hpp>
- #include <boost/beast/http/type_traits.hpp>
- #include <boost/beast/http/detail/chunk_encode.hpp>
- #include <boost/beast/core/error.hpp>
- #include <boost/beast/core/stream_traits.hpp>
- #include <boost/asio/async_result.hpp>
- #include <iosfwd>
- #include <limits>
- #include <memory>
- #include <type_traits>
- #include <utility>
- namespace boost {
- namespace beast {
- namespace http {
- /** Write part of a message to a stream using a serializer.
- This function is used to write part of a message to a stream using
- a caller-provided HTTP/1 serializer. The call will block until one
- of the following conditions is true:
-
- @li One or more bytes have been transferred.
- @li The function @ref serializer::is_done returns `true`
- @li An error occurs on the stream.
- This operation is implemented in terms of one or more calls
- to the stream's `write_some` function.
- The amount of data actually transferred is controlled by the behavior
- of the underlying stream, subject to the buffer size limit of the
- serializer obtained or set through a call to @ref serializer::limit.
- Setting a limit and performing bounded work helps applications set
- reasonable timeouts. It also allows application-level flow control
- to function correctly. For example when using a TCP/IP based
- stream.
- @param stream The stream to which the data is to be written.
- The type must support the <em>SyncWriteStream</em> concept.
- @param sr The serializer to use.
- @return The number of bytes written to the stream.
- @throws system_error Thrown on failure.
- @see serializer
- */
- template<
- class SyncWriteStream,
- bool isRequest, class Body, class Fields>
- std::size_t
- write_some(
- SyncWriteStream& stream,
- serializer<isRequest, Body, Fields>& sr);
- /** Write part of a message to a stream using a serializer.
- This function is used to write part of a message to a stream using
- a caller-provided HTTP/1 serializer. The call will block until one
- of the following conditions is true:
-
- @li One or more bytes have been transferred.
- @li The function @ref serializer::is_done returns `true`
- @li An error occurs on the stream.
- This operation is implemented in terms of one or more calls
- to the stream's `write_some` function.
- The amount of data actually transferred is controlled by the behavior
- of the underlying stream, subject to the buffer size limit of the
- serializer obtained or set through a call to @ref serializer::limit.
- Setting a limit and performing bounded work helps applications set
- reasonable timeouts. It also allows application-level flow control
- to function correctly. For example when using a TCP/IP based
- stream.
-
- @param stream The stream to which the data is to be written.
- The type must support the <em>SyncWriteStream</em> concept.
- @param sr The serializer to use.
- @param ec Set to indicate what error occurred, if any.
- @return The number of bytes written to the stream.
- @see async_write_some, serializer
- */
- template<
- class SyncWriteStream,
- bool isRequest, class Body, class Fields>
- std::size_t
- write_some(
- SyncWriteStream& stream,
- serializer<isRequest, Body, Fields>& sr,
- error_code& ec);
- /** Write part of a message to a stream asynchronously using a serializer.
- This function is used to write part of a message to a stream
- asynchronously using a caller-provided HTTP/1 serializer. The function
- call always returns immediately. The asynchronous operation will continue
- until one of the following conditions is true:
- @li One or more bytes have been transferred.
- @li The function @ref serializer::is_done returns `true`
- @li An error occurs on the stream.
- This operation is implemented in terms of zero or more calls to the stream's
- `async_write_some` function, and is known as a <em>composed operation</em>.
- The program must ensure that the stream performs no other writes
- until this operation completes.
- The amount of data actually transferred is controlled by the behavior
- of the underlying stream, subject to the buffer size limit of the
- serializer obtained or set through a call to @ref serializer::limit.
- Setting a limit and performing bounded work helps applications set
- reasonable timeouts. It also allows application-level flow control
- to function correctly. For example when using a TCP/IP based
- stream.
-
- @param stream The stream to which the data is to be written.
- The type must support the <em>AsyncWriteStream</em> concept.
- @param sr The serializer 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 written to the stream
- );
- @endcode
- Regardless of whether the asynchronous operation completes
- immediately or not, 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`.
- @see serializer
- */
- template<
- class AsyncWriteStream,
- bool isRequest, class Body, class Fields,
- BOOST_BEAST_ASYNC_TPARAM2 WriteHandler =
- net::default_completion_token_t<
- executor_type<AsyncWriteStream>>>
- BOOST_BEAST_ASYNC_RESULT2(WriteHandler)
- async_write_some(
- AsyncWriteStream& stream,
- serializer<isRequest, Body, Fields>& sr,
- WriteHandler&& handler =
- net::default_completion_token_t<
- executor_type<AsyncWriteStream>>{});
- //------------------------------------------------------------------------------
- /** Write a header to a stream using a serializer.
- This function is used to write a header to a stream using a
- caller-provided HTTP/1 serializer. The call will block until one
- of the following conditions is true:
- @li The function @ref serializer::is_header_done returns `true`
- @li An error occurs.
- This operation is implemented in terms of one or more calls
- to the stream's `write_some` function.
- @param stream The stream to which the data is to be written.
- The type must support the <em>SyncWriteStream</em> concept.
- @param sr The serializer to use.
- @return The number of bytes written to the stream.
- @throws system_error Thrown on failure.
- @note The implementation will call @ref serializer::split with
- the value `true` on the serializer passed in.
- @see serializer
- */
- template<
- class SyncWriteStream,
- bool isRequest, class Body, class Fields>
- std::size_t
- write_header(
- SyncWriteStream& stream,
- serializer<isRequest, Body, Fields>& sr);
- /** Write a header to a stream using a serializer.
- This function is used to write a header to a stream using a
- caller-provided HTTP/1 serializer. The call will block until one
- of the following conditions is true:
- @li The function @ref serializer::is_header_done returns `true`
- @li An error occurs.
- This operation is implemented in terms of one or more calls
- to the stream's `write_some` function.
- @param stream The stream to which the data is to be written.
- The type must support the <em>SyncWriteStream</em> concept.
- @param sr The serializer to use.
- @param ec Set to indicate what error occurred, if any.
- @return The number of bytes written to the stream.
- @note The implementation will call @ref serializer::split with
- the value `true` on the serializer passed in.
- @see serializer
- */
- template<
- class SyncWriteStream,
- bool isRequest, class Body, class Fields>
- std::size_t
- write_header(
- SyncWriteStream& stream,
- serializer<isRequest, Body, Fields>& sr,
- error_code& ec);
- /** Write a header to a stream asynchronously using a serializer.
- This function is used to write a header to a stream asynchronously
- using a caller-provided HTTP/1 serializer. The function call always
- returns immediately. The asynchronous operation will continue until
- one of the following conditions is true:
- @li The function @ref serializer::is_header_done returns `true`
- @li An error occurs.
- This operation is implemented in terms of zero or more calls to the stream's
- `async_write_some` function, and is known as a <em>composed operation</em>.
- The program must ensure that the stream performs no other writes
- until this operation completes.
- @param stream The stream to which the data is to be written.
- The type must support the <em>AsyncWriteStream</em> concept.
- @param sr The serializer 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 written to the stream
- );
- @endcode
- Regardless of whether the asynchronous operation completes
- immediately or not, 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 serializer::split with
- the value `true` on the serializer passed in.
- @see serializer
- */
- template<
- class AsyncWriteStream,
- bool isRequest, class Body, class Fields,
- BOOST_BEAST_ASYNC_TPARAM2 WriteHandler =
- net::default_completion_token_t<
- executor_type<AsyncWriteStream>>>
- BOOST_BEAST_ASYNC_RESULT2(WriteHandler)
- async_write_header(
- AsyncWriteStream& stream,
- serializer<isRequest, Body, Fields>& sr,
- WriteHandler&& handler =
- net::default_completion_token_t<
- executor_type<AsyncWriteStream>>{});
- //------------------------------------------------------------------------------
- /** Write a complete message to a stream using a serializer.
- This function is used to write a complete message to a stream using
- a caller-provided HTTP/1 serializer. The call will block until one
- of the following conditions is true:
- @li The function @ref serializer::is_done returns `true`
- @li An error occurs.
- This operation is implemented in terms of one or more calls
- to the stream's `write_some` function.
- @param stream The stream to which the data is to be written.
- The type must support the <em>SyncWriteStream</em> concept.
- @param sr The serializer to use.
- @return The number of bytes written to the stream.
- @throws system_error Thrown on failure.
- @see serializer
- */
- template<
- class SyncWriteStream,
- bool isRequest, class Body, class Fields>
- std::size_t
- write(
- SyncWriteStream& stream,
- serializer<isRequest, Body, Fields>& sr);
- /** Write a complete message to a stream using a serializer.
- This function is used to write a complete message to a stream using
- a caller-provided HTTP/1 serializer. The call will block until one
- of the following conditions is true:
- @li The function @ref serializer::is_done returns `true`
- @li An error occurs.
- This operation is implemented in terms of one or more calls
- to the stream's `write_some` function.
- @param stream The stream to which the data is to be written.
- The type must support the <em>SyncWriteStream</em> concept.
- @param sr The serializer to use.
- @param ec Set to the error, if any occurred.
- @return The number of bytes written to the stream.
- @see serializer
- */
- template<
- class SyncWriteStream,
- bool isRequest, class Body, class Fields>
- std::size_t
- write(
- SyncWriteStream& stream,
- serializer<isRequest, Body, Fields>& sr,
- error_code& ec);
- /** Write a complete message to a stream asynchronously using a serializer.
- This function is used to write a complete message to a stream
- asynchronously using a caller-provided HTTP/1 serializer. The
- function call always returns immediately. The asynchronous
- operation will continue until one of the following conditions is true:
- @li The function @ref serializer::is_done returns `true`
- @li An error occurs.
- This operation is implemented in terms of zero or more calls to the stream's
- `async_write_some` function, and is known as a <em>composed operation</em>.
- The program must ensure that the stream performs no other writes
- until this operation completes.
- @param stream The stream to which the data is to be written.
- The type must support the <em>AsyncWriteStream</em> concept.
- @param sr The serializer 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 written to the stream
- );
- @endcode
- Regardless of whether the asynchronous operation completes
- immediately or not, 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`.
- @see serializer
- */
- template<
- class AsyncWriteStream,
- bool isRequest, class Body, class Fields,
- BOOST_BEAST_ASYNC_TPARAM2 WriteHandler =
- net::default_completion_token_t<
- executor_type<AsyncWriteStream>>>
- BOOST_BEAST_ASYNC_RESULT2(WriteHandler)
- async_write(
- AsyncWriteStream& stream,
- serializer<isRequest, Body, Fields>& sr,
- WriteHandler&& handler =
- net::default_completion_token_t<
- executor_type<AsyncWriteStream>>{});
- //------------------------------------------------------------------------------
- /** Write a complete message to a stream.
- This function is used to write a complete message to a stream using
- HTTP/1. The call will block until one of the following conditions is true:
- @li The entire message is written.
- @li An error occurs.
- This operation is implemented in terms of one or more calls to the stream's
- `write_some` function. The algorithm will use a temporary @ref serializer
- with an empty chunk decorator to produce buffers.
- @note This function only participates in overload resolution
- if @ref is_mutable_body_writer for <em>Body</em> returns `true`.
- @param stream The stream to which the data is to be written.
- The type must support the <em>SyncWriteStream</em> concept.
- @param msg The message to write.
- @return The number of bytes written to the stream.
- @throws system_error Thrown on failure.
- @see message
- */
- template<
- class SyncWriteStream,
- bool isRequest, class Body, class Fields>
- #if BOOST_BEAST_DOXYGEN
- std::size_t
- #else
- typename std::enable_if<
- is_mutable_body_writer<Body>::value,
- std::size_t>::type
- #endif
- write(
- SyncWriteStream& stream,
- message<isRequest, Body, Fields>& msg);
- /** Write a complete message to a stream.
- This function is used to write a complete message to a stream using
- HTTP/1. The call will block until one of the following conditions is true:
- @li The entire message is written.
- @li An error occurs.
- This operation is implemented in terms of one or more calls to the stream's
- `write_some` function. The algorithm will use a temporary @ref serializer
- with an empty chunk decorator to produce buffers.
- @note This function only participates in overload resolution
- if @ref is_mutable_body_writer for <em>Body</em> returns `false`.
- @param stream The stream to which the data is to be written.
- The type must support the <em>SyncWriteStream</em> concept.
- @param msg The message to write.
- @return The number of bytes written to the stream.
- @throws system_error Thrown on failure.
- @see message
- */
- template<
- class SyncWriteStream,
- bool isRequest, class Body, class Fields>
- #if BOOST_BEAST_DOXYGEN
- std::size_t
- #else
- typename std::enable_if<
- ! is_mutable_body_writer<Body>::value,
- std::size_t>::type
- #endif
- write(
- SyncWriteStream& stream,
- message<isRequest, Body, Fields> const& msg);
- /** Write a complete message to a stream.
- This function is used to write a complete message to a stream using
- HTTP/1. The call will block until one of the following conditions is true:
- @li The entire message is written.
- @li An error occurs.
- This operation is implemented in terms of one or more calls to the stream's
- `write_some` function. The algorithm will use a temporary @ref serializer
- with an empty chunk decorator to produce buffers.
- @note This function only participates in overload resolution
- if @ref is_mutable_body_writer for <em>Body</em> returns `true`.
- @param stream The stream to which the data is to be written.
- The type must support the <em>SyncWriteStream</em> concept.
- @param msg The message to write.
- @param ec Set to the error, if any occurred.
- @return The number of bytes written to the stream.
- @see message
- */
- template<
- class SyncWriteStream,
- bool isRequest, class Body, class Fields>
- #if BOOST_BEAST_DOXYGEN
- std::size_t
- #else
- typename std::enable_if<
- is_mutable_body_writer<Body>::value,
- std::size_t>::type
- #endif
- write(
- SyncWriteStream& stream,
- message<isRequest, Body, Fields>& msg,
- error_code& ec);
- /** Write a complete message to a stream.
- This function is used to write a complete message to a stream using
- HTTP/1. The call will block until one of the following conditions is true:
- @li The entire message is written.
- @li An error occurs.
- This operation is implemented in terms of one or more calls to the stream's
- `write_some` function. The algorithm will use a temporary @ref serializer
- with an empty chunk decorator to produce buffers.
- @note This function only participates in overload resolution
- if @ref is_mutable_body_writer for <em>Body</em> returns `false`.
- @param stream The stream to which the data is to be written.
- The type must support the <em>SyncWriteStream</em> concept.
- @param msg The message to write.
- @param ec Set to the error, if any occurred.
- @return The number of bytes written to the stream.
- @see message
- */
- template<
- class SyncWriteStream,
- bool isRequest, class Body, class Fields>
- #if BOOST_BEAST_DOXYGEN
- std::size_t
- #else
- typename std::enable_if<
- ! is_mutable_body_writer<Body>::value,
- std::size_t>::type
- #endif
- write(
- SyncWriteStream& stream,
- message<isRequest, Body, Fields> const& msg,
- error_code& ec);
- /** Write a complete message to a stream asynchronously.
- This function is used to write a complete message to a stream asynchronously
- using HTTP/1. The function call always returns immediately. The asynchronous
- operation will continue until one of the following conditions is true:
- @li The entire message is written.
- @li An error occurs.
- This operation is implemented in terms of zero or more calls to the stream's
- `async_write_some` function, and is known as a <em>composed operation</em>.
- The program must ensure that the stream performs no other writes
- until this operation completes. The algorithm will use a temporary
- @ref serializer with an empty chunk decorator to produce buffers.
- @note This function only participates in overload resolution
- if @ref is_mutable_body_writer for <em>Body</em> returns `true`.
- @param stream The stream to which the data is to be written.
- The type must support the <em>AsyncWriteStream</em> concept.
- @param msg The message to write.
- 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 written to the stream
- );
- @endcode
- Regardless of whether the asynchronous operation completes
- immediately or not, 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`.
- @see message
- */
- template<
- class AsyncWriteStream,
- bool isRequest, class Body, class Fields,
- BOOST_BEAST_ASYNC_TPARAM2 WriteHandler =
- net::default_completion_token_t<
- executor_type<AsyncWriteStream>>>
- BOOST_BEAST_ASYNC_RESULT2(WriteHandler)
- async_write(
- AsyncWriteStream& stream,
- message<isRequest, Body, Fields>& msg,
- WriteHandler&& handler =
- net::default_completion_token_t<
- executor_type<AsyncWriteStream>>{}
- #ifndef BOOST_BEAST_DOXYGEN
- , typename std::enable_if<
- is_mutable_body_writer<Body>::value>::type* = 0
- #endif
- );
- /** Write a complete message to a stream asynchronously.
- This function is used to write a complete message to a stream asynchronously
- using HTTP/1. The function call always returns immediately. The asynchronous
- operation will continue until one of the following conditions is true:
- @li The entire message is written.
- @li An error occurs.
- This operation is implemented in terms of zero or more calls to the stream's
- `async_write_some` function, and is known as a <em>composed operation</em>.
- The program must ensure that the stream performs no other writes
- until this operation completes. The algorithm will use a temporary
- @ref serializer with an empty chunk decorator to produce buffers.
- @note This function only participates in overload resolution
- if @ref is_mutable_body_writer for <em>Body</em> returns `false`.
- @param stream The stream to which the data is to be written.
- The type must support the <em>AsyncWriteStream</em> concept.
- @param msg The message to write.
- 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 written to the stream
- );
- @endcode
- Regardless of whether the asynchronous operation completes
- immediately or not, 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`.
- @see message
- */
- template<
- class AsyncWriteStream,
- bool isRequest, class Body, class Fields,
- BOOST_BEAST_ASYNC_TPARAM2 WriteHandler =
- net::default_completion_token_t<
- executor_type<AsyncWriteStream>>>
- BOOST_BEAST_ASYNC_RESULT2(WriteHandler)
- async_write(
- AsyncWriteStream& stream,
- message<isRequest, Body, Fields> const& msg,
- WriteHandler&& handler =
- net::default_completion_token_t<
- executor_type<AsyncWriteStream>>{}
- #ifndef BOOST_BEAST_DOXYGEN
- , typename std::enable_if<
- ! is_mutable_body_writer<Body>::value>::type* = 0
- #endif
- );
- //------------------------------------------------------------------------------
- /** Serialize an HTTP/1 header to a `std::ostream`.
- The function converts the header to its HTTP/1 serialized
- representation and stores the result in the output stream.
- @param os The output stream to write to.
- @param msg The message fields to write.
- */
- template<bool isRequest, class Fields>
- std::ostream&
- operator<<(std::ostream& os,
- header<isRequest, Fields> const& msg);
- /** Serialize an HTTP/1 message to a `std::ostream`.
- The function converts the message to its HTTP/1 serialized
- representation and stores the result in the output stream.
- The implementation will automatically perform chunk encoding if
- the contents of the message indicate that chunk encoding is required.
- @param os The output stream to write to.
- @param msg The message to write.
- */
- template<bool isRequest, class Body, class Fields>
- std::ostream&
- operator<<(std::ostream& os,
- message<isRequest, Body, Fields> const& msg);
- } // http
- } // beast
- } // boost
- #include <boost/beast/http/impl/write.hpp>
- #endif
|