X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Ftools%2Frbd_mirror%2FImageDeleter.h;fp=src%2Fceph%2Fsrc%2Ftools%2Frbd_mirror%2FImageDeleter.h;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=d3df9ed6330481d8899a77aaf68be9f0247579ed;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git

diff --git a/src/ceph/src/tools/rbd_mirror/ImageDeleter.h b/src/ceph/src/tools/rbd_mirror/ImageDeleter.h
deleted file mode 100644
index d3df9ed..0000000
--- a/src/ceph/src/tools/rbd_mirror/ImageDeleter.h
+++ /dev/null
@@ -1,149 +0,0 @@
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-// vim: ts=8 sw=2 smarttab
-/*
- * Ceph - scalable distributed file system
- *
- * Copyright (C) 2016 SUSE LINUX GmbH
- *
- * This is free software; you can redistribute it and/or
- * modify it under the terms of the GNU Lesser General Public
- * License version 2.1, as published by the Free Software
- * Foundation.  See file COPYING.
- *
- */
-
-#ifndef CEPH_RBD_MIRROR_IMAGEDELETER_H
-#define CEPH_RBD_MIRROR_IMAGEDELETER_H
-
-#include "common/Mutex.h"
-#include "common/Cond.h"
-#include "common/Thread.h"
-#include "common/Timer.h"
-#include "types.h"
-
-#include <deque>
-#include <vector>
-#include <atomic>
-
-class AdminSocketHook;
-class ContextWQ;
-namespace librbd { struct ImageCtx; }
-
-namespace rbd {
-namespace mirror {
-
-template <typename> class ServiceDaemon;
-
-/**
- * Manage deletion of non-primary images.
- */
-template <typename ImageCtxT = librbd::ImageCtx>
-class ImageDeleter {
-public:
-  static const int EISPRM = 1000;
-
-  ImageDeleter(ContextWQ *work_queue, SafeTimer *timer, Mutex *timer_lock,
-               ServiceDaemon<librbd::ImageCtx>* service_daemon);
-  ~ImageDeleter();
-  ImageDeleter(const ImageDeleter&) = delete;
-  ImageDeleter& operator=(const ImageDeleter&) = delete;
-
-  void schedule_image_delete(RadosRef local_rados,
-                             int64_t local_pool_id,
-                             const std::string& global_image_id,
-                             bool ignore_orphaned);
-  void wait_for_scheduled_deletion(int64_t local_pool_id,
-                                   const std::string &global_image_id,
-                                   Context *ctx,
-                                   bool notify_on_failed_retry=true);
-  void cancel_waiter(int64_t local_pool_id,
-                     const std::string &global_image_id);
-
-  void print_status(Formatter *f, std::stringstream *ss);
-
-  // for testing purposes
-  std::vector<std::string> get_delete_queue_items();
-  std::vector<std::pair<std::string, int> > get_failed_queue_items();
-  void set_failed_timer_interval(double interval);
-
-private:
-
-  class ImageDeleterThread : public Thread {
-    ImageDeleter *m_image_deleter;
-  public:
-    ImageDeleterThread(ImageDeleter *image_deleter) :
-      m_image_deleter(image_deleter) {}
-    void *entry() override {
-      m_image_deleter->run();
-      return 0;
-    }
-  };
-
-  struct DeleteInfo {
-    RadosRef local_rados;
-    int64_t local_pool_id;
-    std::string global_image_id;
-    bool ignore_orphaned;
-    int error_code = 0;
-    int retries = 0;
-    bool notify_on_failed_retry = true;
-    Context *on_delete = nullptr;
-
-    DeleteInfo(RadosRef local_rados, int64_t local_pool_id,
-               const std::string& global_image_id,
-               bool ignore_orphaned)
-      : local_rados(local_rados), local_pool_id(local_pool_id),
-        global_image_id(global_image_id), ignore_orphaned(ignore_orphaned) {
-    }
-
-    bool match(int64_t local_pool_id, const std::string &global_image_id) {
-      return (this->local_pool_id == local_pool_id &&
-              this->global_image_id == global_image_id);
-    }
-    void notify(int r);
-    void to_string(std::stringstream& ss);
-    void print_status(Formatter *f, std::stringstream *ss,
-                      bool print_failure_info=false);
-  };
-
-  std::atomic<unsigned> m_running { 1 };
-
-  ContextWQ *m_work_queue;
-  ServiceDaemon<librbd::ImageCtx>* m_service_daemon;
-
-  std::deque<std::unique_ptr<DeleteInfo> > m_delete_queue;
-  Mutex m_delete_lock;
-  Cond m_delete_queue_cond;
-
-  unique_ptr<DeleteInfo> m_active_delete;
-
-  ImageDeleterThread m_image_deleter_thread;
-
-  std::deque<std::unique_ptr<DeleteInfo>> m_failed_queue;
-  double m_failed_interval;
-  SafeTimer *m_failed_timer;
-  Mutex *m_failed_timer_lock;
-
-  AdminSocketHook *m_asok_hook;
-
-  void run();
-  bool process_image_delete();
-  int image_has_snapshots_and_children(librados::IoCtx *ioctx,
-                                       std::string& image_id,
-                                       bool *has_snapshots);
-
-  void complete_active_delete(int r);
-  void enqueue_failed_delete(int error_code);
-  void retry_failed_deletions();
-
-  unique_ptr<DeleteInfo> const*
-  find_delete_info(int64_t local_pool_id, const std::string &global_image_id);
-
-};
-
-} // namespace mirror
-} // namespace rbd
-
-extern template class rbd::mirror::ImageDeleter<librbd::ImageCtx>;
-
-#endif // CEPH_RBD_MIRROR_IMAGEDELETER_H