From 70c1d79d1d0f52cd65541f59cedb00e39cba3f76 Mon Sep 17 00:00:00 2001 From: Matan Breizman Date: Sun, 3 Mar 2024 13:43:10 +0000 Subject: [PATCH] mon/OSDMonitor: unify remove_pool_snap callers No changes in behavior. Signed-off-by: Matan Breizman --- src/mon/OSDMonitor.cc | 21 +++++++++++++-------- src/mon/OSDMonitor.h | 4 ++++ 2 files changed, 17 insertions(+), 8 deletions(-) diff --git a/src/mon/OSDMonitor.cc b/src/mon/OSDMonitor.cc index 3f1254cd71887..fe106a71d8e90 100644 --- a/src/mon/OSDMonitor.cc +++ b/src/mon/OSDMonitor.cc @@ -4570,6 +4570,17 @@ void OSDMonitor::send_incremental(epoch_t first, } } +bool OSDMonitor::remove_pool_snap(std::string_view snapname, + pg_pool_t &pp, int64_t pool) { + snapid_t snapid = pp.snap_exists(snapname); + if (snapid) { + pp.remove_snap(snapid); + pending_inc.new_removed_snaps[pool].insert(snapid); + return true; + } + return false; +}; + int OSDMonitor::get_version(version_t ver, bufferlist& bl) { return get_version(ver, mon.get_quorum_con_features(), bl); @@ -13083,11 +13094,8 @@ bool OSDMonitor::prepare_command_impl(MonOpRequestRef op, pp = &pending_inc.new_pools[pool]; *pp = *p; } - snapid_t sn = pp->snap_exists(snapname.c_str()); - if (sn) { - pp->remove_snap(sn); + if (remove_pool_snap(snapname, *pp, pool)) { pp->set_snap_epoch(pending_inc.epoch); - pending_inc.new_removed_snaps[pool].insert(sn); ss << "removed pool " << poolstr << " snap " << snapname; } else { ss << "already removed pool " << poolstr << " snap " << snapname; @@ -14307,10 +14315,7 @@ bool OSDMonitor::prepare_pool_op(MonOpRequestRef op) case POOL_OP_DELETE_SNAP: { - snapid_t s = pp.snap_exists(m->name.c_str()); - if (s) { - pp.remove_snap(s); - pending_inc.new_removed_snaps[m->pool].insert(s); + if (remove_pool_snap(m->name, pp, m->pool)) { changed = true; } } diff --git a/src/mon/OSDMonitor.h b/src/mon/OSDMonitor.h index 08aa4f61783b2..398daf9243e10 100644 --- a/src/mon/OSDMonitor.h +++ b/src/mon/OSDMonitor.h @@ -404,6 +404,10 @@ private: MOSDMap *build_incremental(epoch_t first, epoch_t last, uint64_t features); void send_full(MonOpRequestRef op); void send_incremental(MonOpRequestRef op, epoch_t first); + + bool remove_pool_snap(std::string_view snapname, + pg_pool_t &pp, int64_t pool); + public: /** * Make sure the existing (up) OSDs support the given features -- 2.39.5