12 #include "websocket.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>
30 #include <boost/beast/websocket/ssl.hpp>
41 namespace websocket  namespace
56         std::function<void(crow::websocket::Connection&, std::string_view,  in ConnectionImpl()
57                            crow::websocket::MessageType type,  in ConnectionImpl()
69         /* Turn on the timeouts on websocket stream to server role */  in ConnectionImpl()
70         ws.set_option(boost::beast::websocket::stream_base::timeout::suggested(  in ConnectionImpl()
83         ws.set_option(boost::beast::websocket::stream_base::decorator(  in start()
85              protocolHeader](boost::beast::websocket::response_type& m) {  in start()
95                             BMCWEB_LOG_ERROR("Websocket CSRF error");  in start()
122         // Perform the websocket upgrade  in start()
182             {boost::beast::websocket::close_code::normal, msg},  in close()
190                     BMCWEB_LOG_ERROR("Error closing websocket {}", ec);  in close()
211         BMCWEB_LOG_DEBUG("Websocket accepted connection");  in acceptDone()
252             else if (ec != boost::beast::websocket::error::closed &&  in afterRead()
287             if (ec == boost::beast::websocket::error::closed)  in afterWrite()
359     boost::beast::websocket::stream<Adaptor, false> ws;
373     std::function<void(crow::websocket::Connection&, std::string_view,
374                        crow::websocket::MessageType type,
383 } // namespace websocket