From: Matan Breizman <mbreizma@redhat.com>
Date: Tue, 27 Jun 2023 07:05:28 +0000 (+0000)
Subject: crimson/osd/osd_operations/pg_advance_map: peering_request_pg_pipeline getter
X-Git-Tag: v18.2.1~128^2
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=f2c1e39f46e6d20f9e304728ef0a7a4ab85e2646;p=ceph.git

crimson/osd/osd_operations/pg_advance_map: peering_request_pg_pipeline getter

Signed-off-by: Matan Breizman <mbreizma@redhat.com>
(cherry picked from commit 9f8159d9e017f5e36db0eb440284bc742a1fd5a5)
---

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);
 };
 
 }