X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Flibrbd%2Foperation%2FSnapshotCreateRequest.h;fp=src%2Fceph%2Fsrc%2Flibrbd%2Foperation%2FSnapshotCreateRequest.h;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=571916000f2a24a452404e0b836172254ed2834c;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/librbd/operation/SnapshotCreateRequest.h b/src/ceph/src/librbd/operation/SnapshotCreateRequest.h deleted file mode 100644 index 5719160..0000000 --- a/src/ceph/src/librbd/operation/SnapshotCreateRequest.h +++ /dev/null @@ -1,126 +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_SNAPSHOT_CREATE_REQUEST_H -#define CEPH_LIBRBD_OPERATION_SNAPSHOT_CREATE_REQUEST_H - -#include "cls/rbd/cls_rbd_types.h" -#include "librbd/Types.h" -#include "librbd/operation/Request.h" -#include - -class Context; - -namespace librbd { - -class ImageCtx; - -namespace operation { - -template -class SnapshotCreateRequest : public Request { -public: - /** - * Snap Create goes through the following state machine: - * - * @verbatim - * - * - * | - * v - * STATE_SUSPEND_REQUESTS - * | - * v - * STATE_SUSPEND_AIO * * * * * * * * * * * * * - * | * - * v * - * STATE_APPEND_OP_EVENT (skip if journal * - * | disabled) * - * (retry) v * - * . . . > STATE_ALLOCATE_SNAP_ID * - * . | * - * . v * - * . . . . STATE_CREATE_SNAP * * * * * * * * * * * - * | * * - * v * * - * STATE_CREATE_OBJECT_MAP (skip if * * - * | disabled) * * - * | * * - * | v * - * | STATE_RELEASE_SNAP_ID * - * | | * - * | v * - * \----------------> < * * * * * - * - * @endverbatim - * - * The _CREATE_STATE state may repeat back to the _ALLOCATE_SNAP_ID state - * if a stale snapshot context is allocated. If the create operation needs - * to abort, the error path is followed to record the result in the journal - * (if enabled) and bubble the originating error code back to the client. - */ - SnapshotCreateRequest(ImageCtxT &image_ctx, Context *on_finish, - const cls::rbd::SnapshotNamespace &snap_namespace, - const std::string &snap_name, - uint64_t journal_op_tid, - bool skip_object_map); - -protected: - void send_op() override; - bool should_complete(int r) override { - return true; - } - bool can_affect_io() const override { - return true; - } - journal::Event create_event(uint64_t op_tid) const override { - return journal::SnapCreateEvent(op_tid, m_snap_namespace, m_snap_name); - } - -private: - cls::rbd::SnapshotNamespace m_snap_namespace; - std::string m_snap_name; - bool m_skip_object_map; - - int m_ret_val; - - uint64_t m_snap_id; - uint64_t m_size; - ParentInfo m_parent_info; - - void send_suspend_requests(); - Context *handle_suspend_requests(int *result); - - void send_suspend_aio(); - Context *handle_suspend_aio(int *result); - - void send_append_op_event(); - Context *handle_append_op_event(int *result); - - void send_allocate_snap_id(); - Context *handle_allocate_snap_id(int *result); - - void send_create_snap(); - Context *handle_create_snap(int *result); - - Context *send_create_object_map(); - Context *handle_create_object_map(int *result); - - void send_release_snap_id(); - Context *handle_release_snap_id(int *result); - - void update_snap_context(); - - void save_result(int *result) { - if (m_ret_val == 0 && *result < 0) { - m_ret_val = *result; - } - } -}; - -} // namespace operation -} // namespace librbd - -extern template class librbd::operation::SnapshotCreateRequest; - -#endif // CEPH_LIBRBD_OPERATION_SNAPSHOT_CREATE_REQUEST_H