From: Chunmei Liu <chunmei.liu@ibm.com>
Date: Wed, 1 Oct 2025 22:58:23 +0000 (+0000)
Subject: crimson/tools: fixing tools according to osd shards number change modification
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=2d866776b2b9499a5251fcfb146174cfad7f660c;p=ceph.git

crimson/tools: fixing tools according to osd shards number change modification

Signed-off-by: Chunmei Liu <chunmei.liu@ibm.com>
---

diff --git a/src/crimson/tools/objectstore/crimson_objectstore_tool.cc b/src/crimson/tools/objectstore/crimson_objectstore_tool.cc
index 1c6fe8995a1..39e14022005 100644
--- a/src/crimson/tools/objectstore/crimson_objectstore_tool.cc
+++ b/src/crimson/tools/objectstore/crimson_objectstore_tool.cc
@@ -291,7 +291,8 @@ static seastar::future<int> action_on_all_objects(
 {
   auto pgs = co_await st.list_pgs();
 
-  for (const auto& [coll, shard_id] : pgs) {
+  for (const auto& [coll, shard_info] : pgs) {
+    auto [shard_id, store_index] = shard_info;
     if (pgid_filter.has_value()) {
       spg_t cand_pgid;
       if (!coll.is_pg(&cand_pgid)) {
@@ -327,7 +328,7 @@ static seastar::future<bool> find_shard_for_object(
     fmt::println(std::cerr, "PG '{}' not found for {} object", config.coll, object_type);
     co_return false;
   }
-  st.set_shard_id(it->second);
+  st.set_shard_id(it->second.first);
   co_return true;
 }
 
diff --git a/src/crimson/tools/store_nbd/fs_driver.cc b/src/crimson/tools/store_nbd/fs_driver.cc
index 6b58909021b..e6c433dc319 100644
--- a/src/crimson/tools/store_nbd/fs_driver.cc
+++ b/src/crimson/tools/store_nbd/fs_driver.cc
@@ -289,7 +289,7 @@ seastar::future<> FSDriver::init()
     *config.path,
     crimson::common::local_conf().get_config_values()
   );
-  return fs->start().then([this] {
+  return fs->start().then([this](uint32_t store_shard_nums) {
     sharded_fs = &(fs->get_sharded_store());
   });
 }
diff --git a/src/crimson/tools/store_nbd/tm_driver.cc b/src/crimson/tools/store_nbd/tm_driver.cc
index 6a2f8059c6a..b74d8d6444f 100644
--- a/src/crimson/tools/store_nbd/tm_driver.cc
+++ b/src/crimson/tools/store_nbd/tm_driver.cc
@@ -145,9 +145,9 @@ void TMDriver::init()
 
   std::vector<Device*> sec_devices;
 #ifndef NDEBUG
-  tm = make_transaction_manager(device.get(), sec_devices, shard_stats, true);
+  tm = make_transaction_manager(device.get(), sec_devices, shard_stats, 0, true);
 #else
-  tm = make_transaction_manager(device.get(), sec_devices, shard_stats, false);
+  tm = make_transaction_manager(device.get(), sec_devices, shard_stats, 0, false);
 #endif
 }