v1.0.19: align read msg limit with native protocol

Author: NikolaiShipilov

CMakeLists.txt

@@ -1,6 +1,6 @@
 cmake_minimum_required(VERSION 3.24)
 
-project(native_streaming VERSION 1.0.18 LANGUAGES CXX)
+project(native_streaming VERSION 1.0.19 LANGUAGES CXX)
 
 if (NOT CMAKE_MESSAGE_CONTEXT)
     set(CMAKE_MESSAGE_CONTEXT ${PROJECT_NAME})

src/client.cpp

@@ -89,6 +89,9 @@ void Client::onResolve(const boost::system::error_code& ec, boost::asio::ip::tcp
 
     websocketStream = std::make_shared<WebsocketStream>(*ioContextPtr);
     websocketStream->write_buffer_bytes(65536);
+    // 256 MB - one byte bigger than max payload size within native transport protocol used above websocket connection
+    websocketStream->read_message_max(0x10000000);
+
     boost::beast::get_lowest_layer(*websocketStream).async_connect(
         results,
         [this, weak_self = weak_from_this(), wsStream = websocketStream](
@@ -170,6 +173,11 @@ void Client::onUpgradeConnection(const boost::system::error_code& ec, std::share
         return;
     }
 
+    NS_LOG_D("Websocket connection: auto-fragment {}, max read masg {}, write buffer size {}",
+             wsStream->auto_fragment(),
+             wsStream->read_message_max(),
+             wsStream->write_buffer_bytes());
+
     onNewSessionCallback(createSession(wsStream, endpointAddress, endpointPortNumber));
 }
 

src/server.cpp

@@ -136,6 +136,8 @@ void Server::onAcceptTcpConnection(boost::asio::ip::tcp::acceptor& tcpAcceptor,
 
     auto wsStream = std::make_shared<WebsocketStream>(std::move(socket));
     wsStream->write_buffer_bytes(65536);
+    // 256 MB - one byte bigger than max payload size within native transport protocol used above websocket connection
+    wsStream->read_message_max(0x10000000);
 
     boost::beast::http::async_read(wsStream->next_layer(),
                                    acceptBuffer,
@@ -235,6 +237,12 @@ void Server::onUpgradeConnection(const boost::system::error_code& ec,
     }
 
     NS_LOG_I("Client {} - websocket connection accepted", endpointAddress);
+
+    NS_LOG_D("Websocket connection: auto-fragment {}, max read masg {}, write buffer size {}",
+             wsStream->auto_fragment(),
+             wsStream->read_message_max(),
+             wsStream->write_buffer_bytes());
+
     onNewSessionCallback(createSession(wsStream, userContext, endpointAddress, endpointPortNumber));
 }