X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Flibrbd%2Fmanaged_lock%2FAcquireRequest.h;fp=src%2Fceph%2Fsrc%2Flibrbd%2Fmanaged_lock%2FAcquireRequest.h;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=20af0693349432bbfaa0b22d3f69e3d7691bec63;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/librbd/managed_lock/AcquireRequest.h b/src/ceph/src/librbd/managed_lock/AcquireRequest.h deleted file mode 100644 index 20af069..0000000 --- a/src/ceph/src/librbd/managed_lock/AcquireRequest.h +++ /dev/null @@ -1,101 +0,0 @@ -// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- -// vim: ts=8 sw=2 smarttab - -#ifndef CEPH_LIBRBD_MANAGED_LOCK_ACQUIRE_REQUEST_H -#define CEPH_LIBRBD_MANAGED_LOCK_ACQUIRE_REQUEST_H - -#include "include/rados/librados.hpp" -#include "include/int_types.h" -#include "include/buffer.h" -#include "msg/msg_types.h" -#include "librbd/managed_lock/Types.h" -#include "librbd/watcher/Types.h" -#include - -class Context; -class ContextWQ; - -namespace librbd { - -class Watcher; - -namespace managed_lock { - -template -class AcquireRequest { -private: - typedef watcher::Traits TypeTraits; - typedef typename TypeTraits::Watcher Watcher; - -public: - static AcquireRequest* create(librados::IoCtx& ioctx, Watcher *watcher, - ContextWQ *work_queue, const std::string& oid, - const std::string& cookie, - bool exclusive, - bool blacklist_on_break_lock, - uint32_t blacklist_expire_seconds, - Context *on_finish); - - ~AcquireRequest(); - void send(); - -private: - - /** - * @verbatim - * - * - * | - * v - * GET_LOCKER - * | ^ - * | . (EBUSY && no cached locker) - * | . - * | . (EBUSY && cached locker) - * \--> LOCK_IMAGE * * * * * * * * > BREAK_LOCK . . . . . - * | ^ | . - * | | | (success) . - * | \-------------------------/ . - * v . - * < . . . . . . . . . . . . . . . . . . . - * - * @endverbatim - */ - - AcquireRequest(librados::IoCtx& ioctx, Watcher *watcher, - ContextWQ *work_queue, const std::string& oid, - const std::string& cookie, bool exclusive, - bool blacklist_on_break_lock, - uint32_t blacklist_expire_seconds, Context *on_finish); - - librados::IoCtx& m_ioctx; - Watcher *m_watcher; - CephContext *m_cct; - ContextWQ *m_work_queue; - std::string m_oid; - std::string m_cookie; - bool m_exclusive; - bool m_blacklist_on_break_lock; - uint32_t m_blacklist_expire_seconds; - Context *m_on_finish; - - bufferlist m_out_bl; - - Locker m_locker; - - void send_get_locker(); - void handle_get_locker(int r); - - void send_lock(); - void handle_lock(int r); - - void send_break_lock(); - void handle_break_lock(int r); - - void finish(int r); -}; - -} // namespace managed_lock -} // namespace librbd - -#endif // CEPH_LIBRBD_MANAGED_LOCK_ACQUIRE_REQUEST_H