X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Flibrbd%2Fimage%2FCloneRequest.h;fp=src%2Fceph%2Fsrc%2Flibrbd%2Fimage%2FCloneRequest.h;h=e1622eb1d863497e3338d18e3892a24ae300fd7b;hb=812ff6ca9fcd3e629e49d4328905f33eee8ca3f5;hp=0000000000000000000000000000000000000000;hpb=15280273faafb77777eab341909a3f495cf248d9;p=stor4nfv.git

diff --git a/src/ceph/src/librbd/image/CloneRequest.h b/src/ceph/src/librbd/image/CloneRequest.h
new file mode 100644
index 0000000..e1622eb
--- /dev/null
+++ b/src/ceph/src/librbd/image/CloneRequest.h
@@ -0,0 +1,164 @@
+// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
+// vim: ts=8 sw=2 smarttab
+
+#ifndef CEPH_LIBRBD_IMAGE_CLONE_REQUEST_H
+#define CEPH_LIBRBD_IMAGE_CLONE_REQUEST_H
+
+#include "cls/rbd/cls_rbd_types.h"
+#include "include/rbd/librbd.hpp"
+#include "librbd/internal.h"
+
+class Context;
+
+using librados::IoCtx;
+
+namespace librbd {
+namespace image {
+
+template <typename ImageCtxT = ImageCtx>
+class CloneRequest {
+public:
+  static CloneRequest *create(ImageCtxT *p_imctx, IoCtx &c_ioctx, const std::string &c_name,
+			      const std::string &c_id, ImageOptions c_options,
+			      const std::string &non_primary_global_image_id,
+			      const std::string &primary_mirror_uuid,
+			      ContextWQ *op_work_queue, Context *on_finish) {
+    return new CloneRequest(p_imctx, c_ioctx, c_name, c_id, c_options,
+                             non_primary_global_image_id, primary_mirror_uuid,
+                             op_work_queue, on_finish);
+  }
+
+  void send();
+private:
+  /**
+   * @verbatim
+   *
+   *                                  <start>
+   *                                     |
+   *                                     v
+   *                             VALIDATE PARENT
+   *                                     |
+   *                                     v
+   * (error: bottom up)           VALIDATE CHILD
+   *  _______<_______                    |
+   * |               |                   v
+   * |               |             CREATE IMAGE
+   * |               |                   |
+   * |               |                   v          (parent_md exists)
+   * |               |              OPEN IMAGE. . . . . > . . . .
+   * v               |               /   |                      .
+   * |         REMOVE IMAGE<--------/    v                      .
+   * |               |           SET PARENT IN HEADER           .
+   * |          CLOSE IMAGE          /   |                      .
+   * |               ^-------<------/    v                      .
+   * |               |\           UPDATE DIR_CHILDREN. . < . . . 
+   * |               | \              /  |
+   * |               |  *<-----------/   v
+   * |               |                REFRESH
+   * |               |                /  |                     
+   * |   CLEAN DIR_CHILDREN <--------/   v            (meta is empty)
+   * |               |\         GET META IN PARENT  . . . . . . .
+   * |               | \              /  |                      .
+   * v               |  *<-----------/   v     (journaling disabled)           .
+   * |               |          SET META IN CHILD . . . . . . . v
+   * |               |               /   |                      .
+   * |               -------<-------/    v       (no need to enable mirror)             .
+   * |               |            GET MIRROR MODE . . . . . . . v
+   * |               |               /   |                      .
+   * |               -------<-------/    v                      .
+   * |               |          ENABLE MIRROR MODE              v
+   * |               |               /   |                      .
+   * |               -------<-------/    v                      .
+   * |                               CLOSE IMAGE . . . . .< . . .
+   * |                                   |
+   * |                                   v
+   * |_____________>__________________<finish>
+   *
+   * @endverbatim
+   */
+
+  CloneRequest(ImageCtxT *p_imctx, IoCtx &c_ioctx, const std::string &c_name,
+			      const std::string &c_id,
+			      ImageOptions c_options,
+			      const std::string &non_primary_global_image_id,
+			      const std::string &primary_mirror_uuid,
+			      ContextWQ *op_work_queue, Context *on_finish);
+
+  ImageCtxT *m_p_imctx;
+  IoCtx &m_ioctx;
+  std::string m_name;
+  std::string m_id;
+  ImageOptions m_opts;
+  ParentSpec m_pspec;
+  ImageCtxT *m_imctx;
+  cls::rbd::MirrorMode m_mirror_mode = cls::rbd::MIRROR_MODE_DISABLED;
+  const std::string m_non_primary_global_image_id;
+  const std::string m_primary_mirror_uuid;
+  NoOpProgressContext m_no_op;
+  ContextWQ *m_op_work_queue;
+  Context *m_on_finish;
+
+  CephContext *m_cct;
+  bool m_use_p_features;
+  uint64_t m_p_features;
+  uint64_t m_features;
+  map<string, bufferlist> m_pairs;
+  bufferlist m_out_bl;
+  uint64_t m_size;
+  int m_r_saved = 0;
+  bool m_is_primary;
+  bool m_force_non_primary;
+
+  void validate_options();
+
+  void send_validate_parent();
+  void handle_validate_parent(int r);
+
+  void send_validate_child();
+  void handle_validate_child(int r);
+
+  void send_create();
+  void handle_create(int r);
+
+  void send_open();
+  void handle_open(int r);
+
+  void send_set_parent();
+  void handle_set_parent(int r);
+
+  void send_add_child();
+  void handle_add_child(int r);
+
+  void send_refresh();
+  void handle_refresh(int r);
+
+  void send_metadata_list();
+  void handle_metadata_list(int r);
+
+  void send_metadata_set();
+  void handle_metadata_set(int r);
+
+  void get_mirror_mode();
+  void handle_get_mirror_mode(int r);
+
+  void send_enable_mirror();
+  void handle_enable_mirror(int r);
+
+  void send_close();
+  void handle_close(int r);
+
+  void send_remove();
+  void handle_remove(int r);
+
+  void send_remove_child();
+  void handle_remove_child(int r);
+
+  void complete(int r);
+};
+
+} //namespace image
+} //namespace librbd
+
+extern template class librbd::image::CloneRequest<librbd::ImageCtx>;
+
+#endif // CEPH_LIBRBD_IMAGE_CLONE_REQUEST_H