osd: pass sdata into dequeue_peering_evt (and dequeue_delete)

Signed-off-by: Sage Weil <sage@redhat.com>

diff --git a/src/osd/OSD.cc b/src/osd/OSD.cc
index e2128ae319a69053a7f157aa4d5c39a5b65d6534..8d37b5e1c5ab9d08d949aa5cfe82d22755cac511 100644 (file)
--- a/src/osd/OSD.cc
+++ b/src/osd/OSD.cc
@@ -8982,6 +8982,7 @@ void OSD::dequeue_op(
 
 
 void OSD::dequeue_peering_evt(
+  OSDShard *sdata,
   PG *pg,
   PGPeeringEventRef evt,
   ThreadPool::TPHandle& handle)
@@ -9021,11 +9022,13 @@ void OSD::dequeue_peering_evt(
 }
 
 void OSD::dequeue_delete(
+  OSDShard *sdata,
   PG *pg,
   epoch_t e,
   ThreadPool::TPHandle& handle)
 {
   dequeue_peering_evt(
+    sdata,
     pg,
     PGPeeringEventRef(
       std::make_shared<PGPeeringEvent>(

diff --git a/src/osd/OSD.h b/src/osd/OSD.h
index 7d9c7223c8b64c38a96564e63d39fa5d504383b5..b1742dae1f7269eff036edbe0a05242e2a24ce36 100644 (file)
--- a/src/osd/OSD.h
+++ b/src/osd/OSD.h
@@ -1769,11 +1769,13 @@ private:
     spg_t pgid,
     PGPeeringEventRef ref);
   void dequeue_peering_evt(
+    OSDShard *sdata,
     PG *pg,
     PGPeeringEventRef ref,
     ThreadPool::TPHandle& handle);
 
   void dequeue_delete(
+    OSDShard *sdata,
     PG *pg,
     epoch_t epoch,
     ThreadPool::TPHandle& handle);

diff --git a/src/osd/OpQueueItem.cc b/src/osd/OpQueueItem.cc
index deb73ee522d8d3773bf5a77b7cad6499e7d79674..1deb1e7a03e0288ba1dfbe60b092d64e440e1d23 100644 (file)
--- a/src/osd/OpQueueItem.cc
+++ b/src/osd/OpQueueItem.cc
@@ -31,7 +31,7 @@ void PGPeeringItem::run(
   PGRef& pg,
   ThreadPool::TPHandle &handle)
 {
-  osd->dequeue_peering_evt(pg.get(), evt, handle);
+  osd->dequeue_peering_evt(sdata, pg.get(), evt, handle);
 }
 
 void PGSnapTrim::run(
@@ -80,5 +80,5 @@ void PGDelete::run(
   PGRef& pg,
   ThreadPool::TPHandle &handle)
 {
-  osd->dequeue_delete(pg.get(), epoch_queued, handle);
+  osd->dequeue_delete(sdata, pg.get(), epoch_queued, handle);
 }