X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Flibrbd%2Fimage%2FSetFlagsRequest.cc;fp=src%2Fceph%2Fsrc%2Flibrbd%2Fimage%2FSetFlagsRequest.cc;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=7d292107f537af0a00911f499042facaba3353e3;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/librbd/image/SetFlagsRequest.cc b/src/ceph/src/librbd/image/SetFlagsRequest.cc deleted file mode 100644 index 7d29210..0000000 --- a/src/ceph/src/librbd/image/SetFlagsRequest.cc +++ /dev/null @@ -1,78 +0,0 @@ -// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- -// vim: ts=8 sw=2 smarttab - -#include "librbd/image/SetFlagsRequest.h" -#include "common/dout.h" -#include "common/errno.h" -#include "cls/rbd/cls_rbd_client.h" -#include "librbd/ImageCtx.h" -#include "librbd/Utils.h" -#include "include/assert.h" - -#define dout_subsys ceph_subsys_rbd -#undef dout_prefix -#define dout_prefix *_dout << "librbd::image::SetFlagsRequest: " - -namespace librbd { -namespace image { - -using util::create_context_callback; -using util::create_rados_callback; - -template -SetFlagsRequest::SetFlagsRequest(I *image_ctx, uint64_t flags, - uint64_t mask, Context *on_finish) - : m_image_ctx(image_ctx), m_flags(flags), m_mask(mask), - m_on_finish(on_finish) { -} - -template -void SetFlagsRequest::send() { - send_set_flags(); -} - -template -void SetFlagsRequest::send_set_flags() { - CephContext *cct = m_image_ctx->cct; - ldout(cct, 20) << __func__ << dendl; - - RWLock::WLocker snap_locker(m_image_ctx->snap_lock); - std::vector snap_ids; - snap_ids.push_back(CEPH_NOSNAP); - for (auto it : m_image_ctx->snap_info) { - snap_ids.push_back(it.first); - } - - Context *ctx = create_context_callback< - SetFlagsRequest, &SetFlagsRequest::handle_set_flags>(this); - C_Gather *gather_ctx = new C_Gather(cct, ctx); - - for (auto snap_id : snap_ids) { - librados::ObjectWriteOperation op; - cls_client::set_flags(&op, snap_id, m_flags, m_mask); - - librados::AioCompletion *comp = - create_rados_callback(gather_ctx->new_sub()); - int r = m_image_ctx->md_ctx.aio_operate(m_image_ctx->header_oid, comp, &op); - assert(r == 0); - comp->release(); - } - gather_ctx->activate(); -} - -template -Context *SetFlagsRequest::handle_set_flags(int *result) { - CephContext *cct = m_image_ctx->cct; - ldout(cct, 20) << __func__ << ": r=" << *result << dendl; - - if (*result < 0) { - lderr(cct) << "set_flags failed: " << cpp_strerror(*result) - << dendl; - } - return m_on_finish; -} - -} // namespace image -} // namespace librbd - -template class librbd::image::SetFlagsRequest;