]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph-ci.git/commitdiff
crimson/os/seastore/omap_manager: remove config from wip-liucm-omap-coawait-crimson-only
authorchunmei liu <chunmei.liu@ibm.com>
Wed, 17 Dec 2025 06:25:51 +0000 (22:25 -0800)
committerchunmei liu <chunmei.liu@ibm.com>
Wed, 31 Dec 2025 19:17:32 +0000 (11:17 -0800)
 omap_rm_key_range.

Signed-off-by: chunmei liu <chunmei.liu@ibm.com>
src/crimson/os/seastore/omap_manager.h
src/crimson/os/seastore/omap_manager/btree/btree_omap_manager.cc
src/crimson/os/seastore/omap_manager/btree/btree_omap_manager.h
src/crimson/os/seastore/seastore.cc
src/test/crimson/seastore/test_omap_manager.cc

index e5664ae25d8edd1c2bdf3edbeb44371b0f508a91..1e952f390c0c8cdeba7b38f6ba2d499f2eb86ed6 100644 (file)
@@ -239,8 +239,7 @@ public:
     omap_root_t &omap_root,
     Transaction &t,
     const std::string &first,
-    const std::string &last,
-    omap_list_config_t config) = 0;
+    const std::string &last) = 0;
 
   /**
    * clear all omap tree key->value mapping
index a413ee84d43384209d0f70d8d89ab9d2c9a77423..dc40f39bb6f838336cffbd55f46d6ae8c3dd8a83 100644 (file)
@@ -230,8 +230,7 @@ BtreeOMapManager::omap_rm_key_range(
   omap_root_t &omap_root,
   Transaction &t,
   const std::string &first,
-  const std::string &last,
-  omap_list_config_t config)
+  const std::string &last)
 {
   LOG_PREFIX(BtreeOMapManager::omap_rm_key_range);
   DEBUGT("{} ~ {}", t, first, last);
index 804df917c1cc987eedc40eaa134abbb610d70b0d..e39f2675cb6868c2b95dd5a824a3f9bf71a1d895 100644 (file)
@@ -93,8 +93,7 @@ public:
     omap_root_t &omap_root,
     Transaction &t,
     const std::string &first,
-    const std::string &last,
-    omap_list_config_t config) final;
+    const std::string &last) final;
 
   omap_iterate_ret omap_iterate(
     const omap_root_t &omap_root,
index f7f5d185e7f40402e303a9a811cbcfb3e4f6b2d5..4f3ed7bafd71ba2d2a056706ec98a18ea53d1623 100644 (file)
@@ -2941,11 +2941,8 @@ SeaStore::Shard::omaptree_rm_keyrange(
     [&t, &onode, FNAME]
     (auto &omap_manager, auto &root, auto &first, auto &last)
   {
-    auto config = OMapManager::omap_list_config_t()
-      .with_inclusive(true, false)
-      .without_max();
     return omap_manager.omap_rm_key_range(
-      root, t, first, last, config
+      root, t, first, last
     ).si_then([&t, &root, &onode, FNAME] {
       if (root.must_update()) {
         omaptree_update_root(t, root, onode);
index 1df414135530eb32652e8bf0148c5a7141bb0974..65293b5f8afcdac08239e389a06289769d72ec84 100644 (file)
@@ -171,30 +171,25 @@ struct omap_manager_test_t :
     const std::string &first,
     const std::string &last) {
     logger().debug("rm keys in range {} ~ {}", first, last);
-    auto config = OMapManager::omap_list_config_t()
-      .with_max(3000)
-      .with_inclusive(true, false);
 
     with_trans_intr(
       t,
       [&, this](auto &t) {
       return omap_manager->omap_rm_key_range(
-       omap_root, t, first, last, config);
+        omap_root, t, first, last);
     }).unsafe_get();
 
     std::vector<std::string> keys;
-    size_t count = 0;
     for (auto iter = test_omap_mappings.begin();
-       iter != test_omap_mappings.end(); ) {
+      iter != test_omap_mappings.end(); ) {
       if (iter->first >= first && iter->first < last) {
-       keys.push_back(iter->first);
-       iter = test_omap_mappings.erase(iter);
-       count++;
+        keys.push_back(iter->first);
+        iter = test_omap_mappings.erase(iter);
       } else {
-       iter++;
+        iter++;
       }
-      if (count == config.max_result_size) {
-       break;
+      if (iter->first >= last) {
+        break;
       }
     }
     return keys;