Skip to content

Commit a0df2e5

Browse files
committed
crimson/.../replicate_recovery_backend: remove unnecessary check
Already checked in handle_recovery_op. Signed-off-by: Matan Breizman <[email protected]>
1 parent b609599 commit a0df2e5

File tree

1 file changed

+0
-8
lines changed

1 file changed

+0
-8
lines changed

src/crimson/osd/replicated_recovery_backend.cc

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -773,10 +773,6 @@ ReplicatedRecoveryBackend::handle_pull(Ref<MOSDPGPull> m)
773773
{
774774
LOG_PREFIX(ReplicatedRecoveryBackend::handle_pull);
775775
DEBUGDPP("{}", pg, *m);
776-
if (pg.can_discard_replica_op(*m)) {
777-
DEBUGDPP("discarding {}", pg, *m);
778-
return seastar::now();
779-
}
780776
return seastar::do_with(m->take_pulls(), [FNAME, this, from=m->from](auto& pulls) {
781777
return interruptor::parallel_for_each(
782778
pulls,
@@ -943,10 +939,6 @@ ReplicatedRecoveryBackend::handle_pull_response(
943939
Ref<MOSDPGPush> m)
944940
{
945941
LOG_PREFIX(ReplicatedRecoveryBackend::handle_pull_response);
946-
if (pg.can_discard_replica_op(*m)) {
947-
DEBUGDPP("discarding {}", pg, *m);
948-
co_return;
949-
}
950942
PushOp& push_op = m->pushes[0]; //TODO: only one push per message for now.
951943
if (push_op.version == eversion_t()) {
952944
// replica doesn't have it!

0 commit comments

Comments
 (0)