From: Samuel Just <sjust@redhat.com>
Date: Fri, 4 Apr 2025 02:12:33 +0000 (-0700)
Subject: crimson: finish_decode() of MOSDRepOp on target core
X-Git-Tag: v20.1.0~325^2~9
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=c4dd06366bfcd3ab20e447455f6d7e63ac33d0e5;p=ceph.git

crimson: finish_decode() of MOSDRepOp on target core

Signed-off-by: Samuel Just <sjust@redhat.com>
(cherry picked from commit bd95adc594908047afd8bb40328ff8dda4488908)
---

diff --git a/src/crimson/osd/osd.cc b/src/crimson/osd/osd.cc
index 8a6bb5c6d43c..2a53d767ab87 100644
--- a/src/crimson/osd/osd.cc
+++ b/src/crimson/osd/osd.cc
@@ -1428,7 +1428,6 @@ seastar::future<> OSD::handle_rep_op(
   crimson::net::ConnectionRef conn,
   Ref<MOSDRepOp> m)
 {
-  m->finish_decode();
   return pg_shard_manager.start_pg_operation<RepRequest>(
     std::move(conn),
     std::move(m)).second;
diff --git a/src/crimson/osd/osd_operations/replicated_request.cc b/src/crimson/osd/osd_operations/replicated_request.cc
index 5c56f75d4db2..7eea4ca45f55 100644
--- a/src/crimson/osd/osd_operations/replicated_request.cc
+++ b/src/crimson/osd/osd_operations/replicated_request.cc
@@ -69,6 +69,7 @@ RepRequest::interruptible_future<> RepRequest::with_pg_interruptible(
 {
   LOG_PREFIX(RepRequest::with_pg_interruptible);
   DEBUGI("{}", *this);
+  req->finish_decode();
   co_await this->template enter_stage<interruptor>(repop_pipeline(*pg).process);
   co_await interruptor::make_interruptible(this->template with_blocking_event<
     PG_OSDMapGate::OSDMapBlocker::BlockingEvent