src/ceph/src/librbd/journal/RemoveRequest.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 "common/dout.h"
   5 #include "common/errno.h"
   6 #include "common/Timer.h"
   7 #include "common/WorkQueue.h"
   8 #include "journal/Settings.h"
   9 #include "include/assert.h"
  10 #include "librbd/Utils.h"
  11 #include "librbd/journal/RemoveRequest.h"
  12
  13 #define dout_subsys ceph_subsys_rbd
  14 #undef dout_prefix
  15 #define dout_prefix *_dout << "librbd::Journal::RemoveRequest: "
  16
  17 namespace librbd {
  18
  19 using util::create_context_callback;
  20
  21 namespace journal {
  22
  23 template<typename I>
  24 RemoveRequest<I>::RemoveRequest(IoCtx &ioctx, const std::string &image_id,
  25                                 const std::string &client_id,
  26                                 ContextWQ *op_work_queue,
  27                                 Context *on_finish)
  28   : m_ioctx(ioctx), m_image_id(image_id), m_image_client_id(client_id),
  29     m_op_work_queue(op_work_queue), m_on_finish(on_finish) {
  30   m_cct = reinterpret_cast<CephContext *>(m_ioctx.cct());
  31 }
  32
  33 template<typename I>
  34 void RemoveRequest<I>::send() {
  35   ldout(m_cct, 20) << this << " " << __func__ << dendl;
  36
  37   stat_journal();
  38 }
  39
  40 template<typename I>
  41 void RemoveRequest<I>::stat_journal() {
  42   ldout(m_cct, 20) << this << " " << __func__ << dendl;
  43
  44   ImageCtx::get_timer_instance(m_cct, &m_timer, &m_timer_lock);
  45   m_journaler = new Journaler(m_op_work_queue, m_timer, m_timer_lock,
  46                               m_ioctx, m_image_id, m_image_client_id, {});
  47
  48   using klass = RemoveRequest<I>;
  49   Context *ctx = create_context_callback<klass, &klass::handle_stat_journal>(this);
  50
  51   m_journaler->exists(ctx);
  52 }
  53
  54 template<typename I>
  55 Context *RemoveRequest<I>::handle_stat_journal(int *result) {
  56   ldout(m_cct, 20) << __func__ << ": r=" << *result << dendl;
  57
  58   if ((*result < 0) && (*result != -ENOENT)) {
  59     lderr(m_cct) << "failed to stat journal header: " << cpp_strerror(*result) << dendl;
  60     shut_down_journaler(*result);
  61     return nullptr;
  62   }
  63
  64   if (*result == -ENOENT) {
  65     shut_down_journaler(0);
  66     return nullptr;
  67   }
  68
  69   init_journaler();
  70   return nullptr;
  71 }
  72
  73 template<typename I>
  74 void RemoveRequest<I>::init_journaler() {
  75   ldout(m_cct, 20) << this << " " << __func__ << dendl;
  76
  77   using klass = RemoveRequest<I>;
  78   Context *ctx = create_context_callback<klass, &klass::handle_init_journaler>(this);
  79
  80   m_journaler->init(ctx);
  81 }
  82
  83 template<typename I>
  84 Context *RemoveRequest<I>::handle_init_journaler(int *result) {
  85   ldout(m_cct, 20) << __func__ << ": r=" << *result << dendl;
  86
  87   if ((*result < 0) && (*result != -ENOENT)) {
  88     lderr(m_cct) << "failed to init journaler: " << cpp_strerror(*result) << dendl;
  89     shut_down_journaler(*result);
  90     return nullptr;
  91   }
  92
  93   remove_journal();
  94   return nullptr;
  95 }
  96
  97 template<typename I>
  98 void RemoveRequest<I>::remove_journal() {
  99   ldout(m_cct, 20) << this << " " << __func__ << dendl;
 100
 101   using klass = RemoveRequest<I>;
 102   Context *ctx = create_context_callback<klass, &klass::handle_remove_journal>(this);
 103
 104   m_journaler->remove(true, ctx);
 105 }
 106
 107 template<typename I>
 108 Context *RemoveRequest<I>::handle_remove_journal(int *result) {
 109   ldout(m_cct, 20) << __func__ << ": r=" << *result << dendl;
 110
 111   if (*result < 0) {
 112     lderr(m_cct) << "failed to remove journal: " << cpp_strerror(*result) << dendl;
 113   }
 114
 115   shut_down_journaler(*result);
 116   return nullptr;
 117 }
 118
 119 template<typename I>
 120 void RemoveRequest<I>::shut_down_journaler(int r) {
 121   ldout(m_cct, 20) << this << " " << __func__ << dendl;
 122
 123   m_r_saved = r;
 124
 125   using klass = RemoveRequest<I>;
 126   Context *ctx = create_context_callback<klass, &klass::handle_journaler_shutdown>(this);
 127
 128   m_journaler->shut_down(ctx);
 129 }
 130
 131 template<typename I>
 132 Context *RemoveRequest<I>::handle_journaler_shutdown(int *result) {
 133   ldout(m_cct, 20) << __func__ << ": r=" << *result << dendl;
 134
 135   if (*result < 0) {
 136     lderr(m_cct) << "failed to shut down journaler: " << cpp_strerror(*result) << dendl;
 137   }
 138
 139   delete m_journaler;
 140
 141   if (m_r_saved == 0) {
 142     ldout(m_cct, 20) << "done." << dendl;
 143   }
 144
 145   m_on_finish->complete(m_r_saved);
 146   delete this;
 147
 148   return nullptr;
 149 }
 150
 151 } // namespace journal
 152 } // namespace librbd
 153
 154 template class librbd::journal::RemoveRequest<librbd::ImageCtx>;