remove ceph code
[stor4nfv.git] / src / ceph / src / rgw / rgw_period_pusher.h
diff --git a/src/ceph/src/rgw/rgw_period_pusher.h b/src/ceph/src/rgw/rgw_period_pusher.h
deleted file mode 100644 (file)
index 7146bef..0000000
+++ /dev/null
@@ -1,56 +0,0 @@
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-// vim: ts=8 sw=2 smarttab
-
-#ifndef RGW_PERIOD_PUSHER_H
-#define RGW_PERIOD_PUSHER_H
-
-#include <memory>
-#include <mutex>
-#include <vector>
-
-#include "rgw_realm_reloader.h"
-
-class RGWRados;
-class RGWPeriod;
-
-// RGWRealmNotify payload for push coordination
-using RGWZonesNeedPeriod = RGWPeriod;
-
-/**
- * RGWPeriodPusher coordinates with other nodes via the realm watcher to manage
- * the responsibility for pushing period updates to other zones or zonegroups.
- */
-class RGWPeriodPusher final : public RGWRealmWatcher::Watcher,
-                              public RGWRealmReloader::Pauser {
- public:
-  RGWPeriodPusher(RGWRados* store);
-  ~RGWPeriodPusher() override;
-
-  /// respond to realm notifications by pushing new periods to other zones
-  void handle_notify(RGWRealmNotify type, bufferlist::iterator& p) override;
-
-  /// avoid accessing RGWRados while dynamic reconfiguration is in progress.
-  /// notifications will be enqueued until resume()
-  void pause() override;
-
-  /// continue processing notifications with a new RGWRados instance
-  void resume(RGWRados* store) override;
-
- private:
-  void handle_notify(RGWZonesNeedPeriod&& period);
-
-  CephContext *const cct;
-  RGWRados* store;
-
-  std::mutex mutex;
-  epoch_t realm_epoch{0}; //< the current realm epoch being sent
-  epoch_t period_epoch{0}; //< the current period epoch being sent
-
-  /// while paused for reconfiguration, we need to queue up notifications
-  std::vector<RGWZonesNeedPeriod> pending_periods;
-
-  class CRThread; //< contains thread, coroutine manager, http manager
-  std::unique_ptr<CRThread> cr_thread; //< thread to run the push coroutines
-};
-
-#endif // RGW_PERIOD_PUSHER_H