crimson: finish_decode() of MOSDRepOp on target core

athanatos · Matan-B · commit c4dd06366bfc · 2025-04-30T08:22:09.000Z
Signed-off-by: Samuel Just <sjust@redhat.com> (cherry picked from commit bd95adc)
diff --git 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
@@ -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

Original file line number	Diff line number	Diff line change
`@@ -1428,7 +1428,6 @@ seastar::future<> OSD::handle_rep_op(`
`1428`	`1428`	`crimson::net::ConnectionRef conn,`
`1429`	`1429`	`Ref<MOSDRepOp> m)`
`1430`	`1430`	`{`
`1431`		`- m->finish_decode();`
`1432`	`1431`	`return pg_shard_manager.start_pg_operation<RepRequest>(`
`1433`	`1432`	`std::move(conn),`
`1434`	`1433`	`std::move(m)).second;`
Original file line number	Diff line number	Diff line change
`@@ -69,6 +69,7 @@ RepRequest::interruptible_future<> RepRequest::with_pg_interruptible(`
`69`	`69`	`{`
`70`	`70`	`LOG_PREFIX(RepRequest::with_pg_interruptible);`
`71`	`71`	`DEBUGI("{}", *this);`
	`72`	`+ req->finish_decode();`
`72`	`73`	`co_await this->template enter_stage<interruptor>(repop_pipeline(*pg).process);`
`73`	`74`	`co_await interruptor::make_interruptible(this->template with_blocking_event<`
`74`	`75`	`PG_OSDMapGate::OSDMapBlocker::BlockingEvent`