X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Flibrbd%2Fmanaged_lock%2FReleaseRequest.cc;fp=src%2Fceph%2Fsrc%2Flibrbd%2Fmanaged_lock%2FReleaseRequest.cc;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=0ccf674f00c5f29390584fe40c9f32d08c799ee6;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/librbd/managed_lock/ReleaseRequest.cc b/src/ceph/src/librbd/managed_lock/ReleaseRequest.cc deleted file mode 100644 index 0ccf674..0000000 --- a/src/ceph/src/librbd/managed_lock/ReleaseRequest.cc +++ /dev/null @@ -1,94 +0,0 @@ -// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- -// vim: ts=8 sw=2 smarttab - -#include "librbd/managed_lock/ReleaseRequest.h" -#include "librbd/Watcher.h" -#include "cls/lock/cls_lock_client.h" -#include "cls/lock/cls_lock_types.h" -#include "common/dout.h" -#include "common/errno.h" -#include "librbd/Utils.h" - -#include "librbd/ImageCtx.h" - -#define dout_subsys ceph_subsys_rbd -#undef dout_prefix -#define dout_prefix *_dout << "librbd::managed_lock::ReleaseRequest: " \ - << this << " " << __func__ << ": " - -namespace librbd { -namespace managed_lock { - -using util::detail::C_AsyncCallback; -using util::create_context_callback; -using util::create_rados_callback; - -template -ReleaseRequest* ReleaseRequest::create(librados::IoCtx& ioctx, - Watcher *watcher, - ContextWQ *work_queue, - const string& oid, - const string& cookie, - Context *on_finish) { - return new ReleaseRequest(ioctx, watcher, work_queue, oid, cookie, - on_finish); -} - -template -ReleaseRequest::ReleaseRequest(librados::IoCtx& ioctx, Watcher *watcher, - ContextWQ *work_queue, const string& oid, - const string& cookie, Context *on_finish) - : m_ioctx(ioctx), m_watcher(watcher), m_oid(oid), m_cookie(cookie), - m_on_finish(new C_AsyncCallback(work_queue, on_finish)) { -} - -template -ReleaseRequest::~ReleaseRequest() { -} - - -template -void ReleaseRequest::send() { - send_unlock(); -} - -template -void ReleaseRequest::send_unlock() { - CephContext *cct = reinterpret_cast(m_ioctx.cct()); - ldout(cct, 10) << "entity=client." << m_ioctx.get_instance_id() << ", " - << "cookie=" << m_cookie << dendl; - - librados::ObjectWriteOperation op; - rados::cls::lock::unlock(&op, RBD_LOCK_NAME, m_cookie); - - using klass = ReleaseRequest; - librados::AioCompletion *rados_completion = - create_rados_callback(this); - int r = m_ioctx.aio_operate(m_oid, rados_completion, &op); - assert(r == 0); - rados_completion->release(); -} - -template -void ReleaseRequest::handle_unlock(int r) { - CephContext *cct = reinterpret_cast(m_ioctx.cct()); - ldout(cct, 10) << "r=" << r << dendl; - - if (r < 0 && r != -ENOENT) { - lderr(cct) << "failed to unlock: " << cpp_strerror(r) << dendl; - } - - finish(); -} - -template -void ReleaseRequest::finish() { - m_on_finish->complete(0); - delete this; -} - -} // namespace managed_lock -} // namespace librbd - -template class librbd::managed_lock::ReleaseRequest; -