Lines Matching full:boost
24 #include <boost/asio/connect.hpp>
25 #include <boost/asio/io_context.hpp>
26 #include <boost/asio/ip/address.hpp>
27 #include <boost/asio/ip/basic_endpoint.hpp>
28 #include <boost/asio/ip/tcp.hpp>
29 #include <boost/asio/ssl/context.hpp>
30 #include <boost/asio/ssl/error.hpp>
31 #include <boost/asio/ssl/stream.hpp>
32 #include <boost/asio/steady_timer.hpp>
33 #include <boost/beast/core/flat_static_buffer.hpp>
34 #include <boost/beast/http/message.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/write.hpp>
39 #include <boost/container/devector.hpp>
40 #include <boost/system/error_code.hpp>
41 #include <boost/url/format.hpp>
42 #include <boost/url/url.hpp>
43 #include <boost/url/url_view_base.hpp>
83 inline boost::system::error_code defaultRetryHandler(unsigned int respCode) in defaultRetryHandler()
89 return boost::system::errc::make_error_code( in defaultRetryHandler()
90 boost::system::errc::result_out_of_range); in defaultRetryHandler()
94 return boost::system::errc::make_error_code(boost::system::errc::success); in defaultRetryHandler()
104 boost::optional<uint64_t> requestByteLimit = httpReadBodyLimit;
111 std::function<boost::system::error_code(unsigned int respCode)>
117 boost::beast::http::request<bmcweb::HttpBody> req;
120 boost::beast::http::request<bmcweb::HttpBody>&& reqIn, in PendingRequest()
126 namespace http = boost::beast::http;
134 boost::urls::url host;
141 boost::beast::flat_static_buffer<httpReadBufferSize> buffer;
147 boost::asio::io_context& ioc;
151 boost::asio::ip::tcp::resolver>;
154 boost::asio::ip::tcp::socket conn;
155 std::optional<boost::asio::ssl::stream<boost::asio::ip::tcp::socket&>>
158 boost::asio::steady_timer timer;
173 const boost::system::error_code& ec, in afterResolve()
191 boost::asio::async_connect( in afterResolve()
198 const boost::beast::error_code& ec, in afterConnect()
199 const boost::asio::ip::tcp::endpoint& endpoint) in afterConnect()
203 if (ec && ec == boost::asio::error::operation_aborted) in afterConnect()
240 boost::asio::ssl::stream_base::client, in doSslHandshake()
246 const boost::beast::error_code& ec) in afterSslHandshake()
250 if (ec && ec == boost::asio::error::operation_aborted) in afterSslHandshake()
279 boost::beast::http::async_write( in sendMessage()
286 boost::beast::http::async_write( in sendMessage()
294 const boost::beast::error_code& ec, size_t bytesTransferred) in afterWrite()
298 if (ec && ec == boost::asio::error::operation_aborted) in afterWrite()
331 boost::beast::http::async_read( in recvMessage()
338 boost::beast::http::async_read( in recvMessage()
346 const boost::beast::error_code& ec, in afterRead()
351 if (ec && ec == boost::asio::error::operation_aborted) in afterRead()
357 if (ec && ec != boost::asio::ssl::error::stream_truncated) in afterRead()
416 const boost::system::error_code& ec) in onTimeout()
418 if (ec == boost::asio::error::operation_aborted) in onTimeout()
458 res.result(boost::beast::http::status::bad_gateway); in waitAndRetry()
478 const boost::system::error_code& ec) in onTimerDone()
480 if (ec == boost::asio::error::operation_aborted) in onTimerDone()
507 boost::beast::error_code ec; in shutdownConn()
508 conn.shutdown(boost::asio::ip::tcp::socket::shutdown_both, ec); in shutdownConn()
512 if (ec && ec != boost::beast::errc::not_connected) in shutdownConn()
548 bool retry, const boost::system::error_code& ec) in afterSslShutdown()
569 if (host.host_type() != boost::urls::host_type::name) in setCipherSuiteTLSext()
588 boost::beast::error_code ec{static_cast<int>(::ERR_get_error()), in setCipherSuiteTLSext()
589 boost::asio::error::get_ssl_category()}; in setCipherSuiteTLSext()
603 conn = boost::asio::ip::tcp::socket(ioc); in initializeConnection()
606 std::optional<boost::asio::ssl::context> sslCtx = in initializeConnection()
630 boost::asio::io_context& iocIn, const std::string& idIn, in ConnectionInfo()
632 const boost::urls::url_view_base& hostIn, in ConnectionInfo()
645 boost::asio::io_context& ioc;
648 boost::urls::url destIP;
650 boost::container::devector<PendingRequest> requestQueue;
725 void sendData(std::string&& data, const boost::urls::url_view_base& destUri, in sendData()
726 const boost::beast::http::fields& httpHeader, in sendData()
727 const boost::beast::http::verb verb, in sendData()
731 boost::beast::http::request<bmcweb::HttpBody> thisReq( in sendData()
733 thisReq.set(boost::beast::http::field::host, in sendData()
789 dummyRes.result(boost::beast::http::status::too_many_requests); in sendData()
831 boost::asio::io_context& iocIn, const std::string& idIn, in ConnectionPool()
833 const boost::urls::url_view_base& destIPIn, in ConnectionPool()
873 std::reference_wrapper<boost::asio::io_context> ioc;
886 explicit HttpClient(boost::asio::io_context& iocIn, in HttpClient()
899 void sendData(std::string&& data, const boost::urls::url_view_base& destUri, in sendData()
901 const boost::beast::http::fields& httpHeader, in sendData()
902 const boost::beast::http::verb verb) in sendData()
912 const boost::urls::url_view_base& destUrl, in sendDataWithCallback()
914 const boost::beast::http::fields& httpHeader, in sendDataWithCallback()
915 const boost::beast::http::verb verb, in sendDataWithCallback()