From 86cd29d6440f7825c28e91dc8a68611ccb2d3de4 Mon Sep 17 00:00:00 2001 From: "Zezheng.Li" Date: Sun, 26 Jan 2025 17:54:24 +0800 Subject: [PATCH] [coro_rpc] fix data race in coro_rpc --- include/ylt/coro_rpc/impl/coro_rpc_server.hpp | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/include/ylt/coro_rpc/impl/coro_rpc_server.hpp b/include/ylt/coro_rpc/impl/coro_rpc_server.hpp index ac8064baf..e1f9a1be0 100644 --- a/include/ylt/coro_rpc/impl/coro_rpc_server.hpp +++ b/include/ylt/coro_rpc/impl/coro_rpc_server.hpp @@ -205,12 +205,13 @@ class coro_rpc_server_base { return; } - ELOG_INFO << "begin to stop coro_rpc_server, conn size " << conns_.size(); + ELOG_INFO << "begin to stop coro_rpc_server"; if (flag_ == stat::started) { close_acceptor(); { std::unique_lock lock(conns_mtx_); + ELOG_INFO << "total connection count: " << conns_.size(); for (auto &conn : conns_) { if (!conn.second->has_closed()) { conn.second->async_close();