14 #include <boost/asio/buffer.hpp>
15 #include <boost/asio/error.hpp>
16 #include <boost/asio/ssl/error.hpp>
17 #include <boost/beast/core/error.hpp>
18 #include <boost/beast/core/multi_buffer.hpp>
19 #include <boost/beast/core/role.hpp>
20 #include <boost/beast/http/field.hpp>
21 #include <boost/beast/http/message.hpp>
22 #include <boost/beast/http/status.hpp>
23 #include <boost/beast/websocket/error.hpp>
24 #include <boost/beast/websocket/rfc6455.hpp>
25 #include <boost/beast/websocket/stream.hpp>
26 #include <boost/beast/websocket/stream_base.hpp>
27 #include <boost/url/url_view.hpp>
30 #include <boost/beast/websocket/ssl.hpp>
51         const boost::urls::url_view& urlViewIn,  in ConnectionImpl()
70         ws.set_option(boost::beast::websocket::stream_base::timeout::suggested(  in ConnectionImpl()
71             boost::beast::role_type::server));  in ConnectionImpl()
79         using bf = boost::beast::http::field;  in start()
83         ws.set_option(boost::beast::websocket::stream_base::decorator(  in start()
85              protocolHeader](boost::beast::websocket::response_type& m) {  in start()
96                             m.result(boost::beast::http::status::unauthorized);  in start()
119         using Body = boost::beast::http::request<bmcweb::HttpBody>;  in start()
131         outBuffer.commit(boost::asio::buffer_copy(outBuffer.prepare(msg.size()),  in sendBinary()
132                                                   boost::asio::buffer(msg)));  in sendBinary()
148         ws.async_write(boost::asio::buffer(msg),  in sendEx()
150                            const boost::beast::error_code& ec, size_t) {  in sendEx()
174         outBuffer.commit(boost::asio::buffer_copy(outBuffer.prepare(msg.size()),  in sendText()
175                                                   boost::asio::buffer(msg)));  in sendText()
182             {boost::beast::websocket::close_code::normal, msg},  in close()
183             [self(shared_from_this())](const boost::system::error_code& ec) {  in close()
184                 if (ec == boost::asio::error::operation_aborted)  in close()
196     boost::urls::url_view url() override  in url()
203                         boost::beast::http::request<bmcweb::HttpBody>>& /*req*/,  in acceptDone()
204                     const boost::system::error_code& ec)  in acceptDone()
240                    const boost::beast::error_code& ec, size_t bytesRead)  in afterRead()
244             if (ec == boost::beast::error::timeout)  in afterRead()
248             else if (ec == boost::asio::error::operation_aborted)  in afterRead()
252             else if (ec != boost::beast::websocket::error::closed &&  in afterRead()
253                      ec != boost::asio::error::eof &&  in afterRead()
254                      ec != boost::asio::ssl::error::stream_truncated)  in afterRead()
281                     const boost::beast::error_code& ec, size_t bytesSent)  in afterWrite()
287             if (ec == boost::beast::websocket::error::closed)  in afterWrite()
293             else if (ec == boost::asio::error::operation_aborted)  in afterWrite()
357     boost::urls::url uri;
359     boost::beast::websocket::stream<Adaptor, false> ws;
363     boost::asio::dynamic_string_buffer<std::string::value_type,
368     boost::beast::multi_buffer outBuffer;