Lines Matching full:boost
19 #include <boost/asio/connect.hpp>
20 #include <boost/asio/error.hpp>
21 #include <boost/asio/io_context.hpp>
22 #include <boost/asio/ip/address.hpp>
23 #include <boost/asio/ip/tcp.hpp>
24 #include <boost/asio/ssl/context.hpp>
25 #include <boost/asio/ssl/error.hpp>
26 #include <boost/asio/ssl/stream.hpp>
27 #include <boost/asio/ssl/stream_base.hpp>
28 #include <boost/asio/steady_timer.hpp>
29 #include <boost/beast/core/error.hpp>
30 #include <boost/beast/core/flat_static_buffer.hpp>
31 #include <boost/beast/http/field.hpp>
32 #include <boost/beast/http/fields.hpp>
33 #include <boost/beast/http/message.hpp>
34 #include <boost/beast/http/parser.hpp>
35 #include <boost/beast/http/read.hpp>
36 #include <boost/beast/http/status.hpp>
37 #include <boost/beast/http/verb.hpp>
38 #include <boost/beast/http/write.hpp>
39 #include <boost/container/devector.hpp>
40 #include <boost/optional/optional.hpp>
41 #include <boost/system/errc.hpp>
42 #include <boost/system/error_code.hpp>
43 #include <boost/url/host_type.hpp>
44 #include <boost/url/url.hpp>
45 #include <boost/url/url_view_base.hpp>
93 inline boost::system::error_code defaultRetryHandler(unsigned int respCode) in defaultRetryHandler()
99 return boost::system::errc::make_error_code( in defaultRetryHandler()
100 boost::system::errc::result_out_of_range); in defaultRetryHandler()
104 return boost::system::errc::make_error_code(boost::system::errc::success); in defaultRetryHandler()
114 boost::optional<uint64_t> requestByteLimit = httpReadBodyLimit;
121 std::function<boost::system::error_code(unsigned int respCode)>
127 boost::beast::http::request<bmcweb::HttpBody> req;
130 boost::beast::http::request<bmcweb::HttpBody>&& reqIn, in PendingRequest()
136 namespace http = boost::beast::http;
144 boost::urls::url host;
151 boost::beast::flat_static_buffer<httpReadBufferSize> buffer;
157 boost::asio::io_context& ioc;
161 boost::asio::ip::tcp::resolver>;
164 boost::asio::ip::tcp::socket conn;
165 std::optional<boost::asio::ssl::stream<boost::asio::ip::tcp::socket&>>
168 boost::asio::steady_timer timer;
183 const boost::system::error_code& ec, in afterResolve()
201 boost::asio::async_connect( in afterResolve()
208 const boost::beast::error_code& ec, in afterConnect()
209 const boost::asio::ip::tcp::endpoint& endpoint) in afterConnect()
213 if (ec && ec == boost::asio::error::operation_aborted) in afterConnect()
250 boost::asio::ssl::stream_base::client, in doSslHandshake()
256 const boost::beast::error_code& ec) in afterSslHandshake()
260 if (ec && ec == boost::asio::error::operation_aborted) in afterSslHandshake()
289 boost::beast::http::async_write( in sendMessage()
296 boost::beast::http::async_write( in sendMessage()
304 const boost::beast::error_code& ec, size_t bytesTransferred) in afterWrite()
308 if (ec && ec == boost::asio::error::operation_aborted) in afterWrite()
341 boost::beast::http::async_read( in recvMessage()
348 boost::beast::http::async_read( in recvMessage()
356 const boost::beast::error_code& ec, in afterRead()
361 if (ec && ec == boost::asio::error::operation_aborted) in afterRead()
367 if (ec && ec != boost::asio::ssl::error::stream_truncated) in afterRead()
426 const boost::system::error_code& ec) in onTimeout()
428 if (ec == boost::asio::error::operation_aborted) in onTimeout()
468 res.result(boost::beast::http::status::bad_gateway); in waitAndRetry()
488 const boost::system::error_code& ec) in onTimerDone()
490 if (ec == boost::asio::error::operation_aborted) in onTimerDone()
517 boost::beast::error_code ec; in shutdownConn()
518 conn.shutdown(boost::asio::ip::tcp::socket::shutdown_both, ec); in shutdownConn()
522 if (ec && ec != boost::beast::errc::not_connected) in shutdownConn()
558 bool retry, const boost::system::error_code& ec) in afterSslShutdown()
579 if (host.host_type() != boost::urls::host_type::name) in setCipherSuiteTLSext()
598 boost::beast::error_code ec{static_cast<int>(::ERR_get_error()), in setCipherSuiteTLSext()
599 boost::asio::error::get_ssl_category()}; in setCipherSuiteTLSext()
613 conn = boost::asio::ip::tcp::socket(ioc); in initializeConnection()
616 std::optional<boost::asio::ssl::context> sslCtx = in initializeConnection()
640 boost::asio::io_context& iocIn, const std::string& idIn, in ConnectionInfo()
642 const boost::urls::url_view_base& hostIn, in ConnectionInfo()
655 boost::asio::io_context& ioc;
658 boost::urls::url destIP;
660 boost::container::devector<PendingRequest> requestQueue;
735 void sendData(std::string&& data, const boost::urls::url_view_base& destUri, in sendData()
736 const boost::beast::http::fields& httpHeader, in sendData()
737 const boost::beast::http::verb verb, in sendData()
741 boost::beast::http::request<bmcweb::HttpBody> thisReq( in sendData()
743 thisReq.set(boost::beast::http::field::host, in sendData()
799 dummyRes.result(boost::beast::http::status::too_many_requests); in sendData()
841 boost::asio::io_context& iocIn, const std::string& idIn, in ConnectionPool()
843 const boost::urls::url_view_base& destIPIn, in ConnectionPool()
883 std::reference_wrapper<boost::asio::io_context> ioc;
896 explicit HttpClient(boost::asio::io_context& iocIn, in HttpClient()
909 void sendData(std::string&& data, const boost::urls::url_view_base& destUri, in sendData()
911 const boost::beast::http::fields& httpHeader, in sendData()
912 const boost::beast::http::verb verb) in sendData()
922 const boost::urls::url_view_base& destUrl, in sendDataWithCallback()
924 const boost::beast::http::fields& httpHeader, in sendDataWithCallback()
925 const boost::beast::http::verb verb, in sendDataWithCallback()