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=d3df9ed6330481d8899a77aaf68be9f0247579ed;hb=812ff6ca9fcd3e629e49d4328905f33eee8ca3f5;hp=0000000000000000000000000000000000000000;hpb=15280273faafb77777eab341909a3f495cf248d9;p=stor4nfv.git

diff --git a/src/ceph/src/tools/rbd_mirror/ImageDeleter.h b/src/ceph/src/tools/rbd_mirror/ImageDeleter.h
new file mode 100644
index 0000000..d3df9ed
--- /dev/null
+++ b/src/ceph/src/tools/rbd_mirror/ImageDeleter.h
@@ -0,0 +1,149 @@
+// -*- 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