]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
crimson/.../replicated_recovery_backend: only call _committed_pushed_object if complete
authorSamuel Just <sjust@redhat.com>
Wed, 15 Jan 2025 22:34:31 +0000 (22:34 +0000)
committerSamuel Just <sjust@redhat.com>
Wed, 29 Jan 2025 05:00:36 +0000 (05:00 +0000)
Signed-off-by: Samuel Just <sjust@redhat.com>
src/crimson/osd/replicated_recovery_backend.cc

index 01cb16bc7fa8f08b7ad50fab57905fcad12afb25..d0ac10b251f31b591fdba1a4610aca0db77fbddd 100644 (file)
@@ -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<MOSDPGPull>();