From 9b2e474e04c519ebd7625814df45239c549da3d9 Mon Sep 17 00:00:00 2001 From: Yingxin Cheng Date: Tue, 10 Dec 2024 17:20:43 +0800 Subject: [PATCH] crimson/os/seastore: drop unnecessary _omap_set_kvs() Signed-off-by: Yingxin Cheng --- src/crimson/os/seastore/seastore.cc | 38 +++++++++-------------------- src/crimson/os/seastore/seastore.h | 6 ----- 2 files changed, 12 insertions(+), 32 deletions(-) diff --git a/src/crimson/os/seastore/seastore.cc b/src/crimson/os/seastore/seastore.cc index 4cbf67513516d..0e9137af1326d 100644 --- a/src/crimson/os/seastore/seastore.cc +++ b/src/crimson/os/seastore/seastore.cc @@ -2271,17 +2271,18 @@ SeaStore::Shard::_zero( }); } -SeaStore::Shard::omap_set_kvs_ret -SeaStore::Shard::_omap_set_kvs( - const OnodeRef &onode, - const omap_root_le_t& omap_root, - Transaction& t, - std::map&& kvs) +SeaStore::Shard::tm_ret +SeaStore::Shard::_omap_set_values( + internal_context_t &ctx, + OnodeRef &onode, + std::map &&kvs, + const omap_root_le_t &omap_root) { + Transaction& t = *ctx.transaction; return seastar::do_with( BtreeOMapManager(*transaction_manager), omap_root.get(onode->get_metadata_hint(device->get_block_size())), - [&t, &onode, kvs=std::move(kvs)] + [this, &t, &onode, kvs=std::move(kvs)] (auto &omap_manager, auto &root) mutable { assert(root.get_type() < omap_type_t::NONE); @@ -2301,30 +2302,15 @@ SeaStore::Shard::_omap_set_kvs( }).si_then([&root] { return tm_iertr::make_ready_future(std::move(root)); }); - }); -} - -SeaStore::Shard::tm_ret -SeaStore::Shard::_omap_set_values( - internal_context_t &ctx, - OnodeRef &onode, - std::map &&aset, - const omap_root_le_t &omap_root) -{ - return _omap_set_kvs( - onode, - omap_root, - *ctx.transaction, - std::move(aset) - ).si_then([onode, &ctx](auto root) { + }).si_then([&onode, &t](auto root) { if (root.must_update()) { if (root.get_type() == omap_type_t::OMAP) { - onode->update_omap_root(*ctx.transaction, root); + onode->update_omap_root(t, root); } else if (root.get_type() == omap_type_t::XATTR) { - onode->update_xattr_root(*ctx.transaction, root); + onode->update_xattr_root(t, root); } else { ceph_assert(root.get_type() == omap_type_t::LOG); - onode->update_log_root(*ctx.transaction, root); + onode->update_log_root(t, root); } } }); diff --git a/src/crimson/os/seastore/seastore.h b/src/crimson/os/seastore/seastore.h index 1f5c964d6a27f..dbefc1f53f68d 100644 --- a/src/crimson/os/seastore/seastore.h +++ b/src/crimson/os/seastore/seastore.h @@ -497,12 +497,6 @@ public: tm_ret _remove_collection( internal_context_t &ctx, const coll_t& cid); - using omap_set_kvs_ret = tm_iertr::future; - omap_set_kvs_ret _omap_set_kvs( - const OnodeRef &onode, - const omap_root_le_t& omap_root, - Transaction& t, - std::map&& kvs); boost::intrusive_ptr _get_collection(const coll_t& cid); -- 2.39.5