import 15.2.0 Octopus source

[ceph.git] / ceph / src / rgw / rgw_period_pusher.h

diff --git a/ceph/src/rgw/rgw_period_pusher.h b/ceph/src/rgw/rgw_period_pusher.h
index fdadd226621665f0a958f8f353370be277729ddd..22ed6380a2aeb1c628a56fb66d36af2c90df48cc 100644 (file)
--- a/ceph/src/rgw/rgw_period_pusher.h
+++ b/ceph/src/rgw/rgw_period_pusher.h
@@ -1,5 +1,5 @@
 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-// vim: ts=8 sw=2 smarttab
+// vim: ts=8 sw=2 smarttab ft=cpp
 
 #ifndef RGW_PERIOD_PUSHER_H
 #define RGW_PERIOD_PUSHER_H
@@ -10,7 +10,12 @@
 
 #include "rgw_realm_reloader.h"
 
-class RGWRados;
+namespace rgw {
+namespace sal {
+class RGWRadosStore;
+}
+}
+
 class RGWPeriod;
 
 // RGWRealmNotify payload for push coordination
@@ -23,7 +28,7 @@ using RGWZonesNeedPeriod = RGWPeriod;
 class RGWPeriodPusher final : public RGWRealmWatcher::Watcher,
                               public RGWRealmReloader::Pauser {
  public:
-  explicit RGWPeriodPusher(RGWRados* store);
+  explicit RGWPeriodPusher(rgw::sal::RGWRadosStore* store);
   ~RGWPeriodPusher() override;
 
   /// respond to realm notifications by pushing new periods to other zones
@@ -34,13 +39,13 @@ class RGWPeriodPusher final : public RGWRealmWatcher::Watcher,
   void pause() override;
 
   /// continue processing notifications with a new RGWRados instance
-  void resume(RGWRados* store) override;
+  void resume(rgw::sal::RGWRadosStore* store) override;
 
  private:
   void handle_notify(RGWZonesNeedPeriod&& period);
 
   CephContext *const cct;
-  RGWRados* store;
+  rgw::sal::RGWRadosStore* store;
 
   std::mutex mutex;
   epoch_t realm_epoch{0}; //< the current realm epoch being sent