From: Yingxin Cheng <yingxin.cheng@intel.com>
Date: Thu, 25 May 2023 03:52:05 +0000 (+0800)
Subject: crimson/tools/perf_async_msgr: support configure ms_async_op_threads
X-Git-Tag: v18.2.1~129^2~17
X-Git-Url: http://git.apps.os.sepia.ceph.com/?a=commitdiff_plain;h=5b5385b162cfb3d955a17e6579c017afd6201c79;p=ceph-ci.git

crimson/tools/perf_async_msgr: support configure ms_async_op_threads

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

diff --git a/src/crimson/tools/perf_async_msgr.cc b/src/crimson/tools/perf_async_msgr.cc
index de3367a6e91..007de1e8a21 100644
--- a/src/crimson/tools/perf_async_msgr.cc
+++ b/src/crimson/tools/perf_async_msgr.cc
@@ -94,7 +94,9 @@ int main(int argc, char** argv)
     ("bs", po::value<unsigned>()->default_value(0),
      "server block size")
     ("crc-enabled", po::value<bool>()->default_value(false),
-     "enable CRC checks");
+     "enable CRC checks")
+    ("threads", po::value<unsigned>()->default_value(3),
+     "async messenger worker threads");
   po::variables_map vm;
   std::vector<std::string> unrecognized_options;
   try {
@@ -120,6 +122,7 @@ int main(int argc, char** argv)
   ceph_assert_always(target_addr.is_msgr2());
   auto bs = vm["bs"].as<unsigned>();
   auto crc_enabled = vm["crc-enabled"].as<bool>();
+  auto worker_threads = vm["threads"].as<unsigned>();
 
   std::vector<const char*> args(argv, argv + argc);
   auto cct = global_init(nullptr, args,
@@ -136,5 +139,7 @@ int main(int argc, char** argv)
     cct->_conf.set_val("ms_crc_data", "false");
   }
 
+  cct->_conf.set_val("ms_async_op_threads", fmt::format("{}", worker_threads));
+
   run(cct.get(), target_addr, bs);
 }