X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Flibrbd%2Fmanaged_lock%2FReacquireRequest.cc;fp=src%2Fceph%2Fsrc%2Flibrbd%2Fmanaged_lock%2FReacquireRequest.cc;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=65e63656f5150259ad765de5b696658549b48dc1;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/librbd/managed_lock/ReacquireRequest.cc b/src/ceph/src/librbd/managed_lock/ReacquireRequest.cc deleted file mode 100644 index 65e6365..0000000 --- a/src/ceph/src/librbd/managed_lock/ReacquireRequest.cc +++ /dev/null @@ -1,79 +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/ReacquireRequest.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/ImageCtx.h" -#include "librbd/Utils.h" -#include "librbd/managed_lock/Utils.h" - -#define dout_subsys ceph_subsys_rbd -#undef dout_prefix -#define dout_prefix *_dout << "librbd::managed_lock::ReacquireRequest: " \ - << this << ": " << __func__ - -using std::string; - -namespace librbd { -namespace managed_lock { - -using librbd::util::create_rados_callback; - -template -ReacquireRequest::ReacquireRequest(librados::IoCtx& ioctx, - const string& oid, - const string& old_cookie, - const string &new_cookie, - bool exclusive, - Context *on_finish) - : m_ioctx(ioctx), m_oid(oid), m_old_cookie(old_cookie), - m_new_cookie(new_cookie), m_exclusive(exclusive), m_on_finish(on_finish) { -} - - -template -void ReacquireRequest::send() { - set_cookie(); -} - -template -void ReacquireRequest::set_cookie() { - CephContext *cct = reinterpret_cast(m_ioctx.cct()); - ldout(cct, 10) << dendl; - - librados::ObjectWriteOperation op; - rados::cls::lock::set_cookie(&op, RBD_LOCK_NAME, - m_exclusive ? LOCK_EXCLUSIVE : LOCK_SHARED, - m_old_cookie, util::get_watcher_lock_tag(), - m_new_cookie); - - librados::AioCompletion *rados_completion = create_rados_callback< - ReacquireRequest, &ReacquireRequest::handle_set_cookie>(this); - int r = m_ioctx.aio_operate(m_oid, rados_completion, &op); - assert(r == 0); - rados_completion->release(); -} - -template -void ReacquireRequest::handle_set_cookie(int r) { - CephContext *cct = reinterpret_cast(m_ioctx.cct()); - ldout(cct, 10) << ": r=" << r << dendl; - - if (r == -EOPNOTSUPP) { - ldout(cct, 10) << ": OSD doesn't support updating lock" << dendl; - } else if (r < 0) { - lderr(cct) << ": failed to update lock: " << cpp_strerror(r) << dendl; - } - - m_on_finish->complete(r); - delete this; -} - -} // namespace managed_lock -} // namespace librbd - -template class librbd::managed_lock::ReacquireRequest;