From: Matan Breizman Date: Sun, 31 Dec 2023 14:38:30 +0000 (+0000) Subject: rename prep_push to prep_push_to_replica X-Git-Tag: v19.3.0~288^2~4 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=09b638c8dbd4745b1753b8ed26f27b0ca7237e68;p=ceph.git rename prep_push to prep_push_to_replica dismiss head_ctx Signed-off-by: Matan Breizman --- diff --git a/src/crimson/osd/replicated_recovery_backend.cc b/src/crimson/osd/replicated_recovery_backend.cc index 266e3ebcf34a..92435a9c925c 100644 --- a/src/crimson/osd/replicated_recovery_backend.cc +++ b/src/crimson/osd/replicated_recovery_backend.cc @@ -61,7 +61,7 @@ ReplicatedRecoveryBackend::maybe_push_shards( return interruptor::parallel_for_each( shards, [this, need, soid, head_obc](auto shard) { - return prep_push(head_obc, soid, need, shard + return prep_push_to_replica(soid, need, shard ).then_interruptible([this, soid, shard](auto push) { auto msg = crimson::make_message(); msg->from = pg.get_pg_whoami(); @@ -310,8 +310,7 @@ ReplicatedRecoveryBackend::recover_delete( } RecoveryBackend::interruptible_future -ReplicatedRecoveryBackend::prep_push( - const crimson::osd::ObjectContextRef &head_obc, +ReplicatedRecoveryBackend::prep_push_to_replica( const hobject_t& soid, eversion_t need, pg_shard_t pg_shard) @@ -342,8 +341,6 @@ ReplicatedRecoveryBackend::prep_push( push_info.recovery_info.copy_subset = data_subset; push_info.recovery_info.soid = soid; push_info.recovery_info.oi = obc->obs.oi; - assert(head_obc->ssc); - push_info.recovery_info.ss = head_obc->ssc->snapset; push_info.recovery_info.version = obc->obs.oi.version; push_info.recovery_info.object_exist = missing_iter->second.clean_regions.object_is_exist(); diff --git a/src/crimson/osd/replicated_recovery_backend.h b/src/crimson/osd/replicated_recovery_backend.h index cfce12c691a3..8d0e5ecabb78 100644 --- a/src/crimson/osd/replicated_recovery_backend.h +++ b/src/crimson/osd/replicated_recovery_backend.h @@ -49,8 +49,7 @@ protected: Ref m); interruptible_future<> handle_recovery_delete_reply( Ref m); - interruptible_future prep_push( - const crimson::osd::ObjectContextRef &head_obc, + interruptible_future prep_push_to_replica( const hobject_t& soid, eversion_t need, pg_shard_t pg_shard);