Improves the stress test.

Author: mzimbres

CMakePresets.json

@@ -49,6 +49,7 @@
         "CMAKE_BUILD_TYPE": "Debug",
         "CMAKE_CXX_EXTENSIONS": "OFF",
         "CMAKE_CXX_FLAGS": "-Wall -Wextra -fsanitize=address",
+        "CMAKE_CXX_COMPILER": "g++-11",
         "CMAKE_SHARED_LINKER_FLAGS": "-fsanitize=address",
         "CMAKE_CXX_STANDARD_REQUIRED": "ON",
         "PROJECT_BINARY_DIR": "${sourceDir}/build/dev",

README.md

@@ -8,7 +8,7 @@ Aedis is a [Redis](https://redis.io/) client library built on top of
 that implements the latest version of the Redis communication
 protocol
 [RESP3](https://github.com/redis/redis-specifications/blob/master/protocol/RESP3.md).
-It makes communication with a Redis server easy by hidding most of
+It makes communication with a Redis server easy by hiding most of
 the low-level Asio-related code away from the user, which in the majority of
 the cases will be concerned with only three library entities
 
@@ -155,7 +155,7 @@ For failover with sentinels see `resolve_with_sentinel.cpp`.  At
 this point the reasons for why `async_run` was introduced in Aedis
 might have become apparent to the reader
 
-* Provide quick reaction to disconnections and hence faster failovers.
+* Provide quick reaction to disconnections and hence faster failover.
 * Support server pushes and requests in the same connection object, concurrently.
 * Separate requests, handling of server pushes and reconnection operations.
 

tests/conn_echo_stress.cpp

@@ -51,7 +51,7 @@ auto echo_session(std::shared_ptr<connection> conn, std::string id, int n) -> ne
       req.push("SUBSCRIBE", "channel");
       boost::system::error_code ec;
       co_await conn->async_exec(req, adapt(resp), redir(ec));
-      BOOST_TEST(!ec);
+      BOOST_CHECK_EQUAL(ec, boost::system::error_code{});
       BOOST_CHECK_EQUAL(msg, std::get<1>(resp));
       req.clear();
       std::get<1>(resp).clear();
@@ -63,8 +63,8 @@ auto async_echo_stress() -> net::awaitable<void>
    auto ex = co_await net::this_coro::executor;
    auto conn = std::make_shared<connection>(ex);
 
-   int const sessions = 1000;
-   int const msgs = 100;
+   int const sessions = 500;
+   int const msgs = 1000;
    int total = sessions * msgs;
 
    net::co_spawn(ex, push_consumer(conn, total), net::detached);