From bd95adc594908047afd8bb40328ff8dda4488908 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 --- 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 8dd910f2719..773a6be5da9 100644 --- a/src/crimson/osd/osd.cc +++ b/src/crimson/osd/osd.cc @@ -1431,7 +1431,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 5c56f75d4db..7eea4ca45f5 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.39.5