src/ceph/src/librbd/operation/SnapshotRenameRequest.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 "librbd/operation/SnapshotRenameRequest.h"
   5 #include "common/dout.h"
   6 #include "common/errno.h"
   7 #include "librbd/ExclusiveLock.h"
   8 #include "librbd/ImageCtx.h"
   9
  10 #define dout_subsys ceph_subsys_rbd
  11 #undef dout_prefix
  12 #define dout_prefix *_dout << "librbd::SnapshotRenameRequest: "
  13
  14 namespace librbd {
  15 namespace operation {
  16
  17 namespace {
  18
  19 template <typename I>
  20 std::ostream& operator<<(std::ostream& os,
  21                          const typename SnapshotRenameRequest<I>::State& state) {
  22   switch(state) {
  23   case SnapshotRenameRequest<I>::STATE_RENAME_SNAP:
  24     os << "RENAME_SNAP";
  25     break;
  26   }
  27   return os;
  28 }
  29
  30 } // anonymous namespace
  31
  32 template <typename I>
  33 SnapshotRenameRequest<I>::SnapshotRenameRequest(I &image_ctx,
  34                                                 Context *on_finish,
  35                                                 uint64_t snap_id,
  36                                                 const std::string &snap_name)
  37   : Request<I>(image_ctx, on_finish), m_snap_id(snap_id), m_snap_name(snap_name) {
  38 }
  39
  40 template <typename I>
  41 journal::Event SnapshotRenameRequest<I>::create_event(uint64_t op_tid) const {
  42   I &image_ctx = this->m_image_ctx;
  43   assert(image_ctx.snap_lock.is_locked());
  44
  45   std::string src_snap_name;
  46   auto snap_info_it = image_ctx.snap_info.find(m_snap_id);
  47   if (snap_info_it != image_ctx.snap_info.end()) {
  48     src_snap_name = snap_info_it->second.name;
  49   }
  50
  51   return journal::SnapRenameEvent(op_tid, m_snap_id, src_snap_name,
  52                                   m_snap_name);
  53 }
  54
  55 template <typename I>
  56 void SnapshotRenameRequest<I>::send_op() {
  57   send_rename_snap();
  58 }
  59
  60 template <typename I>
  61 bool SnapshotRenameRequest<I>::should_complete(int r) {
  62   I &image_ctx = this->m_image_ctx;
  63   CephContext *cct = image_ctx.cct;
  64   ldout(cct, 5) << this << " " << __func__ << ": state=" << m_state << ", "
  65                 << "r=" << r << dendl;
  66   if (r < 0) {
  67     if (r == -EEXIST) {
  68       ldout(cct, 1) << "snapshot already exists" << dendl;
  69     } else {
  70       lderr(cct) << "encountered error: " << cpp_strerror(r) << dendl;
  71     }
  72   }
  73   return true;
  74 }
  75
  76 template <typename I>
  77 void SnapshotRenameRequest<I>::send_rename_snap() {
  78   I &image_ctx = this->m_image_ctx;
  79   assert(image_ctx.owner_lock.is_locked());
  80   RWLock::RLocker md_locker(image_ctx.md_lock);
  81   RWLock::RLocker snap_locker(image_ctx.snap_lock);
  82
  83   CephContext *cct = image_ctx.cct;
  84   ldout(cct, 5) << this << " " << __func__ << dendl;
  85
  86   m_state = STATE_RENAME_SNAP;
  87
  88   librados::ObjectWriteOperation op;
  89   if (image_ctx.old_format) {
  90     cls_client::old_snapshot_rename(&op, m_snap_id, m_snap_name);
  91   } else {
  92     cls_client::snapshot_rename(&op, m_snap_id, m_snap_name);
  93   }
  94
  95   librados::AioCompletion *rados_completion = this->create_callback_completion();
  96   int r = image_ctx.md_ctx.aio_operate(image_ctx.header_oid,
  97                                        rados_completion, &op);
  98   assert(r == 0);
  99   rados_completion->release();
 100 }
 101
 102 } // namespace operation
 103 } // namespace librbd
 104
 105 template class librbd::operation::SnapshotRenameRequest<librbd::ImageCtx>;