remove ceph code
[stor4nfv.git] / src / ceph / src / librbd / operation / Request.h
diff --git a/src/ceph/src/librbd/operation/Request.h b/src/ceph/src/librbd/operation/Request.h
deleted file mode 100644 (file)
index 8eaca29..0000000
+++ /dev/null
@@ -1,108 +0,0 @@
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-// vim: ts=8 sw=2 smarttab
-
-#ifndef CEPH_LIBRBD_OPERATION_REQUEST_H
-#define CEPH_LIBRBD_OPERATION_REQUEST_H
-
-#include "librbd/AsyncRequest.h"
-#include "include/Context.h"
-#include "common/RWLock.h"
-#include "librbd/Utils.h"
-#include "librbd/Journal.h"
-
-namespace librbd {
-
-class ImageCtx;
-
-namespace operation {
-
-template <typename ImageCtxT = ImageCtx>
-class Request : public AsyncRequest<ImageCtxT> {
-public:
-  Request(ImageCtxT &image_ctx, Context *on_finish,
-          uint64_t journal_op_tid = 0);
-
-  void send();
-
-protected:
-  void finish(int r) override;
-  virtual void send_op() = 0;
-
-  virtual bool can_affect_io() const {
-    return false;
-  }
-  virtual journal::Event create_event(uint64_t op_tid) const = 0;
-
-  template <typename T, Context*(T::*MF)(int*)>
-  bool append_op_event(T *request) {
-    ImageCtxT &image_ctx = this->m_image_ctx;
-
-    assert(can_affect_io());
-    RWLock::RLocker owner_locker(image_ctx.owner_lock);
-    RWLock::RLocker snap_locker(image_ctx.snap_lock);
-    if (image_ctx.journal != nullptr) {
-      if (image_ctx.journal->is_journal_replaying()) {
-        Context *ctx = util::create_context_callback<T, MF>(request);
-        replay_op_ready(ctx);
-        return true;
-      } else if (image_ctx.journal->is_journal_appending()) {
-        Context *ctx = util::create_context_callback<T, MF>(request);
-        append_op_event(ctx);
-        return true;
-      }
-    }
-    return false;
-  }
-
-  bool append_op_event();
-
-  // NOTE: temporary until converted to new state machine format
-  Context *create_context_finisher(int r);
-  void finish_and_destroy(int r) override;
-
-private:
-  struct C_AppendOpEvent : public Context {
-    Request *request;
-    Context *on_safe;
-    C_AppendOpEvent(Request *request, Context *on_safe)
-      : request(request), on_safe(on_safe) {
-    }
-    void finish(int r) override {
-      if (r >= 0) {
-        request->m_appended_op_event = true;
-      }
-      on_safe->complete(r);
-    }
-  };
-
-  struct C_CommitOpEvent : public Context {
-    Request *request;
-    int ret_val;
-    C_CommitOpEvent(Request *request, int ret_val)
-      : request(request), ret_val(ret_val) {
-    }
-    void finish(int r) override {
-      request->handle_commit_op_event(r, ret_val);
-      delete request;
-    }
-  };
-
-  uint64_t m_op_tid = 0;
-  bool m_appended_op_event = false;
-  bool m_committed_op_event = false;
-
-  void replay_op_ready(Context *on_safe);
-  void append_op_event(Context *on_safe);
-  void handle_op_event_safe(int r);
-
-  bool commit_op_event(int r);
-  void handle_commit_op_event(int r, int original_ret_val);
-
-};
-
-} // namespace operation
-} // namespace librbd
-
-extern template class librbd::operation::Request<librbd::ImageCtx>;
-
-#endif // CEPH_LIBRBD_OPERATION_REQUEST_H