17 #include <boost/asio/io_context.hpp>
18 #include <boost/asio/ip/tcp.hpp>
19 #include <boost/asio/ssl/stream.hpp>
20 #include <boost/asio/steady_timer.hpp>
21 #include <boost/beast/_experimental/test/stream.hpp>
22 #include <boost/beast/core/buffers_generator.hpp>
23 #include <boost/beast/core/flat_static_buffer.hpp>
24 #include <boost/beast/http/error.hpp>
25 #include <boost/beast/http/message_generator.hpp>
26 #include <boost/beast/http/parser.hpp>
27 #include <boost/beast/http/read.hpp>
28 #include <boost/beast/http/write.hpp>
29 #include <boost/beast/websocket.hpp>
54 struct IsTls<boost::asio::ssl::stream<T>> : std::true_type
64     Connection(Handler* handlerIn, boost::asio::steady_timer&& timerIn,  in Connection()
94                            boost::asio::ssl::verify_context& ctx)  in tlsVerifyCallback()
143             boost::system::error_code ec;  in prepareMutualTls()
184             adaptor.async_handshake(boost::asio::ssl::stream_base::server,  in start()
186                                         const boost::system::error_code& ec) {  in start()
230         boost::beast::http::request_parser<bmcweb::HttpBody>& instance =  in initParser()
238         instance.body_limit(boost::none);  in initParser()
252             res.result(boost::beast::http::status::bad_request);  in handle()
264             if (req->getHeaderValue(boost::beast::http::field::host).empty())  in handle()
266                 res.result(boost::beast::http::status::bad_request);  in handle()
286         if constexpr (!std::is_same_v<Adaptor, boost::beast::test::stream>)  in handle()
314             req->getHeaderValue(boost::beast::http::field::upgrade));  in handle()
321                     if (thisRes.result() != boost::beast::http::status::ok)  in handle()
337             req->getHeaderValue(boost::beast::http::field::if_none_match);  in handle()
355         boost::beast::get_lowest_layer(adaptor).close();  in hardClose()
359                              const boost::system::error_code& ec)  in tlsShutdownComplete()
390         res.addHeader(boost::beast::http::field::date, getCachedDateStr());  in completeRequest()
401         boost::system::error_code ec;  in readClientIp()
403         if constexpr (!std::is_same_v<Adaptor, boost::beast::test::stream>)  in readClientIp()
405             boost::asio::ip::tcp::endpoint endpoint =  in readClientIp()
406                 boost::beast::get_lowest_layer(adaptor).remote_endpoint(ec);  in readClientIp()
443         const boost::optional<uint64_t> contentLength =  in handleContentLengthError()
465                 res.result(boost::beast::http::status::unauthorized);  in handleContentLengthError()
475                 res.result(boost::beast::http::status::payload_too_large);  in handleContentLengthError()
487                           const boost::system::error_code& ec,  in afterReadHeaders()
497             if (ec == boost::beast::http::error::header_limit)  in afterReadHeaders()
502                 res.result(boost::beast::http::status::  in afterReadHeaders()
508             if (ec == boost::beast::http::error::end_of_stream)  in afterReadHeaders()
530             std::is_same_v<Adaptor, boost::beast::test::stream>;  in afterReadHeaders()
534             boost::beast::http::verb method = parser->get().method();  in afterReadHeaders()
540             parser->get()[boost::beast::http::field::expect];  in afterReadHeaders()
543             res.result(boost::beast::http::status::continue_);  in afterReadHeaders()
573         boost::beast::http::async_read_header(  in doReadHeaders()
580                    const boost::system::error_code& ec,  in afterRead()
590             if (ec == boost::beast::http::error::body_limit)  in afterRead()
598                         boost::beast::http::status::internal_server_error);  in afterRead()
641         boost::beast::http::async_read_some(  in doRead()
647                       const boost::system::error_code& ec,  in afterDoWrite()
655         if (ec == boost::system::errc::operation_would_block ||  in afterDoWrite()
656             ec == boost::system::errc::resource_unavailable_try_again)  in afterDoWrite()
667         if (res.result() == boost::beast::http::status::continue_)  in afterDoWrite()
670             res.result(boost::beast::http::status::ok);  in afterDoWrite()
700         boost::beast::async_write(  in doWrite()
702             boost::beast::http::message_generator(std::move(res.response)),  in doWrite()
713                         const boost::system::error_code& ec)  in afterTimerWait()
720             if (ec == boost::asio::error::operation_aborted)  in afterTimerWait()
738             if (ec == boost::asio::error::operation_aborted)  in afterTimerWait()
774     boost::asio::ip::address ip;
778     std::optional<boost::beast::http::request_parser<bmcweb::HttpBody>> parser;
780     boost::beast::flat_static_buffer<8192> buffer;
790     boost::asio::steady_timer timer;