X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Flibrbd%2Fmirror%2FEnableRequest.cc;fp=src%2Fceph%2Fsrc%2Flibrbd%2Fmirror%2FEnableRequest.cc;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=3a94096eb79f8eacb828fbe3d947fb4cc94a8abf;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/librbd/mirror/EnableRequest.cc b/src/ceph/src/librbd/mirror/EnableRequest.cc deleted file mode 100644 index 3a94096..0000000 --- a/src/ceph/src/librbd/mirror/EnableRequest.cc +++ /dev/null @@ -1,190 +0,0 @@ -// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- -// vim: ts=8 sw=2 smarttab - -#include "librbd/mirror/EnableRequest.h" -#include "common/dout.h" -#include "common/errno.h" -#include "cls/rbd/cls_rbd_client.h" -#include "librbd/ImageState.h" -#include "librbd/Journal.h" -#include "librbd/MirroringWatcher.h" -#include "librbd/Utils.h" - -#define dout_subsys ceph_subsys_rbd -#undef dout_prefix -#define dout_prefix *_dout << "librbd::mirror::EnableRequest: " - -namespace librbd { -namespace mirror { - -using util::create_context_callback; -using util::create_rados_callback; - -template -EnableRequest::EnableRequest(librados::IoCtx &io_ctx, - const std::string &image_id, - const std::string &non_primary_global_image_id, - ContextWQ *op_work_queue, Context *on_finish) - : m_io_ctx(io_ctx), m_image_id(image_id), - m_non_primary_global_image_id(non_primary_global_image_id), - m_op_work_queue(op_work_queue), m_on_finish(on_finish), - m_cct(reinterpret_cast(io_ctx.cct())) { -} - -template -void EnableRequest::send() { - send_get_tag_owner(); -} - -template -void EnableRequest::send_get_tag_owner() { - if (!m_non_primary_global_image_id.empty()) { - return - send_get_mirror_image(); - } - ldout(m_cct, 10) << this << " " << __func__ << dendl; - - using klass = EnableRequest; - Context *ctx = create_context_callback< - klass, &klass::handle_get_tag_owner>(this); - librbd::Journal<>::is_tag_owner(m_io_ctx, m_image_id, &m_is_primary, - m_op_work_queue, ctx); -} - -template -Context *EnableRequest::handle_get_tag_owner(int *result) { - ldout(m_cct, 10) << this << " " << __func__ << ": r=" << *result << dendl; - - if (*result < 0) { - lderr(m_cct) << "failed to check tag ownership: " << cpp_strerror(*result) - << dendl; - return m_on_finish; - } - - if (!m_is_primary) { - lderr(m_cct) << "last journal tag not owned by local cluster" << dendl; - *result = -EINVAL; - return m_on_finish; - } - - send_get_mirror_image(); - return nullptr; -} - -template -void EnableRequest::send_get_mirror_image() { - ldout(m_cct, 10) << this << " " << __func__ << dendl; - - librados::ObjectReadOperation op; - cls_client::mirror_image_get_start(&op, m_image_id); - - using klass = EnableRequest; - librados::AioCompletion *comp = - create_rados_callback(this); - m_out_bl.clear(); - int r = m_io_ctx.aio_operate(RBD_MIRRORING, comp, &op, &m_out_bl); - assert(r == 0); - comp->release(); -} - -template -Context *EnableRequest::handle_get_mirror_image(int *result) { - ldout(m_cct, 10) << this << " " << __func__ << ": r=" << *result << dendl; - - if (*result == 0) { - bufferlist::iterator iter = m_out_bl.begin(); - *result = cls_client::mirror_image_get_finish(&iter, &m_mirror_image); - } - - if (*result == 0) { - if (m_mirror_image.state == cls::rbd::MIRROR_IMAGE_STATE_ENABLED) { - ldout(m_cct, 10) << this << " " << __func__ - << ": mirroring is already enabled" << dendl; - } else { - lderr(m_cct) << "currently disabling" << dendl; - *result = -EINVAL; - } - return m_on_finish; - } - - if (*result != -ENOENT) { - lderr(m_cct) << "failed to retreive mirror image: " << cpp_strerror(*result) - << dendl; - return m_on_finish; - } - - *result = 0; - m_mirror_image.state = cls::rbd::MIRROR_IMAGE_STATE_ENABLED; - if (m_non_primary_global_image_id.empty()) { - uuid_d uuid_gen; - uuid_gen.generate_random(); - m_mirror_image.global_image_id = uuid_gen.to_string(); - } else { - m_mirror_image.global_image_id = m_non_primary_global_image_id; - } - - send_set_mirror_image(); - return nullptr; -} - -template -void EnableRequest::send_set_mirror_image() { - ldout(m_cct, 10) << this << " " << __func__ << dendl; - - librados::ObjectWriteOperation op; - cls_client::mirror_image_set(&op, m_image_id, m_mirror_image); - - using klass = EnableRequest; - librados::AioCompletion *comp = - create_rados_callback(this); - m_out_bl.clear(); - int r = m_io_ctx.aio_operate(RBD_MIRRORING, comp, &op); - assert(r == 0); - comp->release(); -} - -template -Context *EnableRequest::handle_set_mirror_image(int *result) { - ldout(m_cct, 10) << this << " " << __func__ << ": r=" << *result << dendl; - - if (*result < 0) { - lderr(m_cct) << "failed to enable mirroring: " << cpp_strerror(*result) - << dendl; - return m_on_finish; - } - - send_notify_mirroring_watcher(); - return nullptr; -} - -template -void EnableRequest::send_notify_mirroring_watcher() { - ldout(m_cct, 10) << this << " " << __func__ << dendl; - - using klass = EnableRequest; - Context *ctx = create_context_callback< - klass, &klass::handle_notify_mirroring_watcher>(this); - - MirroringWatcher<>::notify_image_updated(m_io_ctx, - cls::rbd::MIRROR_IMAGE_STATE_ENABLED, - m_image_id, - m_mirror_image.global_image_id, ctx); -} - -template -Context *EnableRequest::handle_notify_mirroring_watcher(int *result) { - ldout(m_cct, 10) << this << " " << __func__ << ": r=" << *result << dendl; - - if (*result < 0) { - lderr(m_cct) << "failed to send update notification: " - << cpp_strerror(*result) << dendl; - *result = 0; - } - - return m_on_finish; -} - -} // namespace mirror -} // namespace librbd - -template class librbd::mirror::EnableRequest;