From: Matan Breizman <mbreizma@redhat.com>
Date: Sun, 2 Feb 2025 13:14:14 +0000 (+0000)
Subject: crimson/.../replicate_recovery_backend: remove unnecessary check
X-Git-Tag: v20.3.0~387^2~4
X-Git-Url: http://git.apps.os.sepia.ceph.com/?a=commitdiff_plain;h=a0df2e5133ccf1eb4087da51d7099ce01885fa10;p=ceph.git

crimson/.../replicate_recovery_backend: remove unnecessary check

Already checked in handle_recovery_op.

Signed-off-by: Matan Breizman <mbreizma@redhat.com>
---

diff --git a/src/crimson/osd/replicated_recovery_backend.cc b/src/crimson/osd/replicated_recovery_backend.cc
index d9a4481200a28..3eeff2314ee73 100644
--- a/src/crimson/osd/replicated_recovery_backend.cc
+++ b/src/crimson/osd/replicated_recovery_backend.cc
@@ -773,10 +773,6 @@ ReplicatedRecoveryBackend::handle_pull(Ref<MOSDPGPull> m)
 {
   LOG_PREFIX(ReplicatedRecoveryBackend::handle_pull);
   DEBUGDPP("{}", pg, *m);
-  if (pg.can_discard_replica_op(*m)) {
-    DEBUGDPP("discarding {}", pg, *m);
-    return seastar::now();
-  }
   return seastar::do_with(m->take_pulls(), [FNAME, this, from=m->from](auto& pulls) {
     return interruptor::parallel_for_each(
       pulls,
@@ -943,10 +939,6 @@ ReplicatedRecoveryBackend::handle_pull_response(
   Ref<MOSDPGPush> m)
 {
   LOG_PREFIX(ReplicatedRecoveryBackend::handle_pull_response);
-  if (pg.can_discard_replica_op(*m)) {
-    DEBUGDPP("discarding {}", pg, *m);
-    co_return;
-  }
   PushOp& push_op = m->pushes[0]; //TODO: only one push per message for now.
   if (push_op.version == eversion_t()) {
     // replica doesn't have it!