From: Samuel Just Date: Wed, 15 Jan 2025 22:34:31 +0000 (+0000) Subject: crimson/.../replicated_recovery_backend: only call _committed_pushed_object if complete X-Git-Tag: v20.0.0~282^2~6 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=3b07d56ef538e9a21601c2f891d94765eae9459a;p=ceph.git crimson/.../replicated_recovery_backend: only call _committed_pushed_object if complete Signed-off-by: Samuel Just --- diff --git a/src/crimson/osd/replicated_recovery_backend.cc b/src/crimson/osd/replicated_recovery_backend.cc index 01cb16bc7fa8..d0ac10b251f3 100644 --- a/src/crimson/osd/replicated_recovery_backend.cc +++ b/src/crimson/osd/replicated_recovery_backend.cc @@ -962,10 +962,10 @@ ReplicatedRecoveryBackend::handle_pull_response( DEBUGDPP("submitting transaction", pg); co_await interruptor::make_interruptible( shard_services.get_store().do_transaction(coll, std::move(t))); - pg.get_recovery_handler()->_committed_pushed_object( - epoch_frozen, pg.get_info().last_complete); if (complete) { + pg.get_recovery_handler()->_committed_pushed_object( + epoch_frozen, pg.get_info().last_complete); get_recovering(push_op.soid).set_pulled(); } else { auto reply = crimson::make_message();