update sources to 12.2.7

[ceph.git] / ceph / src / tools / rbd_mirror / image_replayer / PrepareLocalImageRequest.cc

diff --git a/ceph/src/tools/rbd_mirror/image_replayer/PrepareLocalImageRequest.cc b/ceph/src/tools/rbd_mirror/image_replayer/PrepareLocalImageRequest.cc
index 4009dc10d4af6f86ea126ec2cdbf2d00ba606419..18b548011f2ed685b9fee92d88b0c12838a0c008 100644 (file)
--- a/ceph/src/tools/rbd_mirror/image_replayer/PrepareLocalImageRequest.cc
+++ b/ceph/src/tools/rbd_mirror/image_replayer/PrepareLocalImageRequest.cc
@@ -54,6 +54,42 @@ void PrepareLocalImageRequest<I>::handle_get_local_image_id(int r) {
     return;
   }
 
+  get_local_image_name();
+}
+
+template <typename I>
+void PrepareLocalImageRequest<I>::get_local_image_name() {
+  dout(20) << dendl;
+
+  librados::ObjectReadOperation op;
+  librbd::cls_client::dir_get_name_start(&op, *m_local_image_id);
+
+  m_out_bl.clear();
+  librados::AioCompletion *aio_comp = create_rados_callback<
+    PrepareLocalImageRequest<I>,
+    &PrepareLocalImageRequest<I>::handle_get_local_image_name>(this);
+  int r = m_io_ctx.aio_operate(RBD_DIRECTORY, aio_comp, &op, &m_out_bl);
+  assert(r == 0);
+  aio_comp->release();
+}
+
+template <typename I>
+void PrepareLocalImageRequest<I>::handle_get_local_image_name(int r) {
+  dout(20) << "r=" << r << dendl;
+
+  if (r == 0) {
+    bufferlist::iterator it = m_out_bl.begin();
+    r = librbd::cls_client::dir_get_name_finish(&it, m_local_image_name);
+  }
+
+  if (r < 0) {
+    if (r != -ENOENT) {
+      derr << "failed to retrieve image name: " << cpp_strerror(r) << dendl;
+    }
+    finish(r);
+    return;
+  }
+
   get_mirror_state();
 }