ARCHIVE/clio
1
0
Fork 0
mirror of https://github.com/XRPLF/clio.git synced 2026-10-04 02:48:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: WebServer NG send queue (#3181)

Browse Source
This commit is contained in:
Alex Kremer
2026-08-24 18:03:55 +01:00
committed by GitHub
parent 292d55aa1c
commit 2e7f303b7a
17 changed files with 272 additions and 98 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
tests/unit/web/ng/impl/HttpConnectionTests.cpp
View File

@@ -29,6 +29,10 @@
#include <string>
#include <utility>
namespace {
constexpr size_t kMaxSendingQueueSize = 1500;
} // namespace
using namespace web::ng::impl;
using namespace web::ng;
using namespace util::config;
@@ -45,7 +49,8 @@ struct HttpConnectionTests : SyncAsioContextTest {
std::move(expectedSocket).value(),
std::move(ip),
boost::beast::flat_buffer{},
tagDecoratorFactory_
tagDecoratorFactory_,
kMaxSendingQueueSize
);
connection->setTimeout(std::chrono::milliseconds{100});
return connection;
@@ -388,7 +393,8 @@ TEST_F(HttpConnectionTests, Upgrade)
[&]() { ASSERT_TRUE(expectedResult.has_value()) << expectedResult.error().message(); }();
[&]() { ASSERT_TRUE(expectedResult.value()); }();
auto expectedWsConnection = connection->upgrade(tagDecoratorFactory_, yield);
auto expectedWsConnection =
connection->upgrade(tagDecoratorFactory_, kMaxSendingQueueSize, yield);
[&]() {
ASSERT_TRUE(expectedWsConnection.has_value()) << expectedWsConnection.error().message();
}();