From c4dd06366bfcd3ab20e447455f6d7e63ac33d0e5 Mon Sep 17 00:00:00 2001 From: Samuel Just Date: Thu, 3 Apr 2025 19:12:33 -0700 Subject: [PATCH] crimson: finish_decode() of MOSDRepOp on target core Signed-off-by: Samuel Just (cherry picked from commit bd95adc594908047afd8bb40328ff8dda4488908) --- src/crimson/osd/osd.cc | 1 - src/crimson/osd/osd_operations/replicated_request.cc | 1 + 2 files changed, 1 insertion(+), 1 deletion(-) 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 m) { - m->finish_decode(); return pg_shard_manager.start_pg_operation( 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(repop_pipeline(*pg).process); co_await interruptor::make_interruptible(this->template with_blocking_event< PG_OSDMapGate::OSDMapBlocker::BlockingEvent -- 2.47.3