bmcweb/http/http_connection.hpp

22 #include <boost/asio/error.hpp>
23 #include <boost/asio/ip/tcp.hpp>
24 #include <boost/asio/ssl/stream.hpp>
25 #include <boost/asio/ssl/stream_base.hpp>
26 #include <boost/asio/ssl/verify_context.hpp>
27 #include <boost/asio/steady_timer.hpp>
28 #include <boost/beast/_experimental/test/stream.hpp>
29 #include <boost/beast/core/buffers_generator.hpp>
30 #include <boost/beast/core/detect_ssl.hpp>
31 #include <boost/beast/core/error.hpp>
32 #include <boost/beast/core/flat_static_buffer.hpp>
33 #include <boost/beast/http/error.hpp>
34 #include <boost/beast/http/field.hpp>
35 #include <boost/beast/http/message_generator.hpp>
36 #include <boost/beast/http/parser.hpp>
37 #include <boost/beast/http/read.hpp>
38 #include <boost/beast/http/rfc7230.hpp>
39 #include <boost/beast/http/status.hpp>
40 #include <boost/beast/http/verb.hpp>
41 #include <boost/none.hpp>
42 #include <boost/optional/optional.hpp>
78                boost::asio::steady_timer&& timerIn,
80                boost::asio::ssl::stream<Adaptor>&& adaptorIn) :
108                            boost::asio::ssl::verify_context& ctx)
155         boost::system::error_code ec;
168                         boost::beast::error_code ec, bool isTls)
187                 boost::asio::ssl::stream_base::server, buffer.data(),
230         boost::beast::async_detect_ssl(
237                            const boost::system::error_code& ec,
272         boost::beast::http::request_parser<bmcweb::HttpBody>& instance =
280         instance.body_limit(boost::none);
300         using boost::beast::http::field;
301         using boost::beast::http::token_list;
327                 res.result(boost::beast::http::status::switching_protocols);
328                 res.addHeader(boost::beast::http::field::connection, "Upgrade");
329                 res.addHeader(boost::beast::http::field::upgrade, "h2c");
334         if (req->req.method() == boost::beast::http::verb::get)
340                         if (thisRes.result() != boost::beast::http::status::ok)
380             res.result(boost::beast::http::status::bad_request);
392             if (req->getHeaderValue(boost::beast::http::field::host).empty())
394                 res.result(boost::beast::http::status::bad_request);
439             req->getHeaderValue(boost::beast::http::field::if_none_match);
454                              const boost::system::error_code& ec)
493         res.addHeader(boost::beast::http::field::date, getCachedDateStr());
504         boost::system::error_code ec;
506         boost::asio::ip::tcp::endpoint endpoint =
507             boost::beast::get_lowest_layer(adaptor).remote_endpoint(ec);
548         const boost::optional<uint64_t> contentLength =
570                 res.result(boost::beast::http::status::unauthorized);
580                 res.result(boost::beast::http::status::payload_too_large);
592                           const boost::system::error_code& ec,
602             if (ec == boost::beast::http::error::header_limit)
607                 res.result(boost::beast::http::status::
613             if (ec == boost::beast::http::error::end_of_stream)
636             boost::beast::http::verb method = parser->get().method();
642             parser->get()[boost::beast::http::field::expect];
645             res.result(boost::beast::http::status::continue_);
677             boost::beast::http::async_read_header(
684             boost::beast::http::async_read_header(
692                    const boost::system::error_code& ec,
702             if (ec == boost::beast::http::error::body_limit)
710                         boost::beast::http::status::internal_server_error);
755             boost::beast::http::async_read_some(
762             boost::beast::http::async_read_some(
770                       const boost::system::error_code& ec,
778         if (ec == boost::system::errc::operation_would_block ||
779             ec == boost::system::errc::resource_unavailable_try_again)
790         if (res.result() == boost::beast::http::status::switching_protocols)
796         if (res.result() == boost::beast::http::status::continue_)
799             res.result(boost::beast::http::status::ok);
831             boost::beast::async_write(
833                 boost::beast::http::message_generator(std::move(res.response)),
839             boost::beast::async_write(
841                 boost::beast::http::message_generator(std::move(res.response)),
853                         const boost::system::error_code& ec)
860             if (ec == boost::asio::error::operation_aborted)
878             if (ec == boost::asio::error::operation_aborted)
914     boost::asio::ssl::stream<Adaptor> adaptor;
917     boost::asio::ip::address ip;
921     std::optional<boost::beast::http::request_parser<bmcweb::HttpBody>> parser;
923     boost::beast::flat_static_buffer<8192> buffer;
933     boost::asio::steady_timer timer;