ceph/src/tools/rbd_mirror/MirrorStatusWatcher.cc

   1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
   2 // vim: ts=8 sw=2 smarttab
   3
   4 #include "MirrorStatusWatcher.h"
   5 #include "common/debug.h"
   6 #include "common/errno.h"
   7 #include "cls/rbd/cls_rbd_client.h"
   8 #include "librbd/Utils.h"
   9
  10 #define dout_context g_ceph_context
  11 #define dout_subsys ceph_subsys_rbd_mirror
  12 #undef dout_prefix
  13 #define dout_prefix *_dout << "rbd::mirror::MirrorStatusWatcher: " \
  14                            << this << " " << __func__ << ": "
  15
  16 namespace rbd {
  17 namespace mirror {
  18
  19 using librbd::util::create_rados_callback;
  20
  21 template <typename I>
  22 MirrorStatusWatcher<I>::MirrorStatusWatcher(librados::IoCtx &io_ctx,
  23                                             librbd::asio::ContextWQ *work_queue)
  24   : Watcher(io_ctx, work_queue, RBD_MIRRORING) {
  25 }
  26
  27 template <typename I>
  28 MirrorStatusWatcher<I>::~MirrorStatusWatcher() {
  29 }
  30
  31 template <typename I>
  32 void MirrorStatusWatcher<I>::init(Context *on_finish) {
  33   dout(20) << dendl;
  34
  35   on_finish = new LambdaContext(
  36     [this, on_finish] (int r) {
  37       if (r < 0) {
  38         derr << "error removing down statuses: " << cpp_strerror(r) << dendl;
  39         on_finish->complete(r);
  40         return;
  41       }
  42       register_watch(on_finish);
  43     });
  44
  45   librados::ObjectWriteOperation op;
  46   librbd::cls_client::mirror_image_status_remove_down(&op);
  47   librados::AioCompletion *aio_comp = create_rados_callback(on_finish);
  48
  49   int r = m_ioctx.aio_operate(RBD_MIRRORING, aio_comp, &op);
  50   ceph_assert(r == 0);
  51   aio_comp->release();
  52 }
  53
  54 template <typename I>
  55 void MirrorStatusWatcher<I>::shut_down(Context *on_finish) {
  56   dout(20) << dendl;
  57
  58   unregister_watch(on_finish);
  59 }
  60
  61 template <typename I>
  62 void MirrorStatusWatcher<I>::handle_notify(uint64_t notify_id, uint64_t handle,
  63                                            uint64_t notifier_id,
  64                                            bufferlist &bl) {
  65   dout(20) << dendl;
  66
  67   bufferlist out;
  68   acknowledge_notify(notify_id, handle, out);
  69 }
  70
  71 } // namespace mirror
  72 } // namespace rbd
  73
  74 template class rbd::mirror::MirrorStatusWatcher<librbd::ImageCtx>;