fix case

Author: poor-circle

include/ylt/easylog.hpp

@@ -14,6 +14,7 @@
  * limitations under the License.
  */
 #pragma once
+#include <atomic>
 #include <functional>
 #include <string_view>
 #include <utility>
@@ -75,7 +76,9 @@ class logger {
     enable_console_ = enable_console;
   }
 
-  bool check_severity(Severity severity) { return severity >= min_severity_; }
+  bool check_severity(Severity severity) {
+    return severity >= min_severity_.load(std::memory_order::relaxed);
+  }
 
   void add_appender(std::function<void(std::string_view)> fn) {
     appenders_.emplace_back(std::move(fn));
@@ -85,7 +88,9 @@ class logger {
 
   // set and get
   void set_min_severity(Severity severity) { min_severity_ = severity; }
-  Severity get_min_severity() { return min_severity_; }
+  Severity get_min_severity() {
+    return min_severity_.load(std::memory_order::relaxed);
+  }
 
   void set_console(bool enable) {
     enable_console_ = enable;
@@ -122,7 +127,7 @@ class logger {
     }
   }
 
-  Severity min_severity_ =
+  std::atomic<Severity> min_severity_ =
 #if NDEBUG
       Severity::WARN;
 #else

src/coro_rpc/tests/test_parallel.cpp

@@ -24,8 +24,8 @@ TEST_CASE("test parall coro_rpc call") {
 
   server.register_handler<echo>();
   server.async_start();
-  int client_cnt = 500;
-  int64_t work_cnt_tot = thread_cnt * client_cnt * 10;
+  int client_cnt = 200;
+  int64_t work_cnt_tot = thread_cnt * client_cnt * 5;
   std::vector<std::unique_ptr<coro_rpc::coro_rpc_client>> clients;
   clients.resize(client_cnt);
   std::atomic<int> connected_cnt = 0;
@@ -77,7 +77,7 @@ TEST_CASE("test parall coro_rpc call2") {
   }};
   server.register_handler<echo>();
   server.async_start();
-  int client_cnt = 500;
+  int client_cnt = 200;
   std::vector<std::unique_ptr<coro_rpc::coro_rpc_client>> clients;
   clients.resize(client_cnt);
   std::atomic<int> work_cnt = 0;
@@ -88,7 +88,7 @@ TEST_CASE("test parall coro_rpc call2") {
         .via(pool.get_executor())
         .start([&](auto&&) {
           [](coro_rpc::coro_rpc_client& cli) -> Lazy<void> {
-            for (int i = 0; i < 1000; ++i)
+            for (int i = 0; i < 500; ++i)
               if (!cli.has_closed()) {
                 auto result = co_await cli.call<echo>("hello");
                 if (result.has_value()) {