X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Ftools%2Frbd_mirror%2Fimage_replayer%2FGetMirrorImageIdRequest.cc;fp=src%2Fceph%2Fsrc%2Ftools%2Frbd_mirror%2Fimage_replayer%2FGetMirrorImageIdRequest.cc;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=a6a72b473f36336c2bf9a4ec6b8715f08377bdb1;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/tools/rbd_mirror/image_replayer/GetMirrorImageIdRequest.cc b/src/ceph/src/tools/rbd_mirror/image_replayer/GetMirrorImageIdRequest.cc deleted file mode 100644 index a6a72b4..0000000 --- a/src/ceph/src/tools/rbd_mirror/image_replayer/GetMirrorImageIdRequest.cc +++ /dev/null @@ -1,84 +0,0 @@ -// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- -// vim: ts=8 sw=2 smarttab - -#include "tools/rbd_mirror/image_replayer/GetMirrorImageIdRequest.h" -#include "include/rados/librados.hpp" -#include "cls/rbd/cls_rbd_client.h" -#include "common/errno.h" -#include "librbd/ImageCtx.h" -#include "librbd/Utils.h" - -#define dout_context g_ceph_context -#define dout_subsys ceph_subsys_rbd_mirror -#undef dout_prefix -#define dout_prefix *_dout << "rbd::mirror::image_replayer::" \ - << "GetMirrorImageIdRequest: " << this << " " \ - << __func__ << ": " - -namespace rbd { -namespace mirror { -namespace image_replayer { - -using librbd::util::create_rados_callback; - -template -void GetMirrorImageIdRequest::send() { - dout(20) << dendl; - get_image_id(); -} - -template -void GetMirrorImageIdRequest::get_image_id() { - dout(20) << dendl; - - // attempt to cross-reference a image id by the global image id - librados::ObjectReadOperation op; - librbd::cls_client::mirror_image_get_image_id_start(&op, m_global_image_id); - - librados::AioCompletion *aio_comp = create_rados_callback< - GetMirrorImageIdRequest, - &GetMirrorImageIdRequest::handle_get_image_id>( - this); - int r = m_io_ctx.aio_operate(RBD_MIRRORING, aio_comp, &op, &m_out_bl); - assert(r == 0); - aio_comp->release(); -} - -template -void GetMirrorImageIdRequest::handle_get_image_id(int r) { - if (r == 0) { - bufferlist::iterator iter = m_out_bl.begin(); - r = librbd::cls_client::mirror_image_get_image_id_finish( - &iter, m_image_id); - } - - dout(20) << "r=" << r << ", " - << "image_id=" << *m_image_id << dendl; - - if (r < 0) { - if (r == -ENOENT) { - dout(10) << "global image " << m_global_image_id << " not registered" - << dendl; - } else { - derr << "failed to retrieve image id: " << cpp_strerror(r) << dendl; - } - finish(r); - return; - } - - finish(0); -} - -template -void GetMirrorImageIdRequest::finish(int r) { - dout(20) << "r=" << r << dendl; - - m_on_finish->complete(r); - delete this; -} - -} // namespace image_replayer -} // namespace mirror -} // namespace rbd - -template class rbd::mirror::image_replayer::GetMirrorImageIdRequest;