From f2c1e39f46e6d20f9e304728ef0a7a4ab85e2646 Mon Sep 17 00:00:00 2001 From: Matan Breizman Date: Tue, 27 Jun 2023 07:05:28 +0000 Subject: [PATCH] crimson/osd/osd_operations/pg_advance_map: peering_request_pg_pipeline getter Signed-off-by: Matan Breizman (cherry picked from commit 9f8159d9e017f5e36db0eb440284bc742a1fd5a5) --- src/crimson/osd/osd_operations/pg_advance_map.cc | 7 ++++++- src/crimson/osd/osd_operations/pg_advance_map.h | 3 +++ 2 files changed, 9 insertions(+), 1 deletion(-) diff --git a/src/crimson/osd/osd_operations/pg_advance_map.cc b/src/crimson/osd/osd_operations/pg_advance_map.cc index 7a9b0ffb45fcd..3706af810557e 100644 --- a/src/crimson/osd/osd_operations/pg_advance_map.cc +++ b/src/crimson/osd/osd_operations/pg_advance_map.cc @@ -55,6 +55,11 @@ void PGAdvanceMap::dump_detail(Formatter *f) const f->close_section(); } +PGPeeringPipeline &PGAdvanceMap::peering_pp(PG &pg) +{ + return pg.peering_request_pg_pipeline; +} + seastar::future<> PGAdvanceMap::start() { using cached_map_t = OSDMapService::cached_map_t; @@ -63,7 +68,7 @@ seastar::future<> PGAdvanceMap::start() IRef ref = this; return enter_stage<>( - pg->peering_request_pg_pipeline.process + peering_pp(*pg).process ).then([this] { /* * PGAdvanceMap is scheduled at pg creation and when diff --git a/src/crimson/osd/osd_operations/pg_advance_map.h b/src/crimson/osd/osd_operations/pg_advance_map.h index c7277f790b3d2..b712cc12e4778 100644 --- a/src/crimson/osd/osd_operations/pg_advance_map.h +++ b/src/crimson/osd/osd_operations/pg_advance_map.h @@ -49,6 +49,9 @@ public: std::tuple< PGPeeringPipeline::Process::BlockingEvent > tracking_events; + +private: + PGPeeringPipeline &peering_pp(PG &pg); }; } -- 2.39.5