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 8a6bb5c6d43c201a34c700ca3f4bea26245a7ccf..2a53d767ab87712785b365dc18b1600c628e2804 100644 (file)
--- 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 5c56f75d4db28f43ffff22598296b7a3400ecfcc..7eea4ca45f5550bf50da3c4529b6b3ddb9bdf44d 100644 (file)
--- 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