From: Yingxin Cheng <yingxin.cheng@intel.com>
Date: Mon, 3 Apr 2023 01:51:02 +0000 (+0800)
Subject: test/crimson/test_messenger_thrash: free msgr after its connections
X-Git-Tag: v18.1.0~37^2~3
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=154f19975ed68a641cfe2e2cc3be976befa3e3fd;p=ceph.git

test/crimson/test_messenger_thrash: free msgr after its connections

Signed-off-by: Yingxin Cheng <yingxin.cheng@intel.com>
(cherry picked from commit 3fde061a49ba31c3d64b4a0c2798fc4972100a19)
---

diff --git a/src/test/crimson/test_messenger_thrash.cc b/src/test/crimson/test_messenger_thrash.cc
index d56da0a86e83..1dd910be9a60 100644
--- a/src/test/crimson/test_messenger_thrash.cc
+++ b/src/test/crimson/test_messenger_thrash.cc
@@ -200,8 +200,10 @@ class SyntheticDispatcher final
 };
 
 class SyntheticWorkload {
+  // messengers must be freed after its connections
   std::set<crimson::net::MessengerRef> available_servers;
   std::set<crimson::net::MessengerRef> available_clients;
+
   crimson::net::SocketPolicy server_policy;
   crimson::net::SocketPolicy client_policy;
   std::map<crimson::net::ConnectionRef,
@@ -452,8 +454,6 @@ class SyntheticWorkload {
          server->stop();
          return server->shutdown();
        });
-     }).then([this] {
-       available_servers.clear();
      }).then([this] {
        return seastar::do_for_each(available_clients, [] (auto client) {
 	 if (verbose) {
@@ -462,8 +462,6 @@ class SyntheticWorkload {
          client->stop();
          return client->shutdown();
        });
-     }).then([this] {
-       available_clients.clear();
      });
    }