X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Flibrbd%2Foperation%2FSnapshotRenameRequest.cc;fp=src%2Fceph%2Fsrc%2Flibrbd%2Foperation%2FSnapshotRenameRequest.cc;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=236d82815b3ea7220b429373c32d7f25bd395fe1;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/librbd/operation/SnapshotRenameRequest.cc b/src/ceph/src/librbd/operation/SnapshotRenameRequest.cc deleted file mode 100644 index 236d828..0000000 --- a/src/ceph/src/librbd/operation/SnapshotRenameRequest.cc +++ /dev/null @@ -1,105 +0,0 @@ -// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- -// vim: ts=8 sw=2 smarttab - -#include "librbd/operation/SnapshotRenameRequest.h" -#include "common/dout.h" -#include "common/errno.h" -#include "librbd/ExclusiveLock.h" -#include "librbd/ImageCtx.h" - -#define dout_subsys ceph_subsys_rbd -#undef dout_prefix -#define dout_prefix *_dout << "librbd::SnapshotRenameRequest: " - -namespace librbd { -namespace operation { - -namespace { - -template -std::ostream& operator<<(std::ostream& os, - const typename SnapshotRenameRequest::State& state) { - switch(state) { - case SnapshotRenameRequest::STATE_RENAME_SNAP: - os << "RENAME_SNAP"; - break; - } - return os; -} - -} // anonymous namespace - -template -SnapshotRenameRequest::SnapshotRenameRequest(I &image_ctx, - Context *on_finish, - uint64_t snap_id, - const std::string &snap_name) - : Request(image_ctx, on_finish), m_snap_id(snap_id), m_snap_name(snap_name) { -} - -template -journal::Event SnapshotRenameRequest::create_event(uint64_t op_tid) const { - I &image_ctx = this->m_image_ctx; - assert(image_ctx.snap_lock.is_locked()); - - std::string src_snap_name; - auto snap_info_it = image_ctx.snap_info.find(m_snap_id); - if (snap_info_it != image_ctx.snap_info.end()) { - src_snap_name = snap_info_it->second.name; - } - - return journal::SnapRenameEvent(op_tid, m_snap_id, src_snap_name, - m_snap_name); -} - -template -void SnapshotRenameRequest::send_op() { - send_rename_snap(); -} - -template -bool SnapshotRenameRequest::should_complete(int r) { - I &image_ctx = this->m_image_ctx; - CephContext *cct = image_ctx.cct; - ldout(cct, 5) << this << " " << __func__ << ": state=" << m_state << ", " - << "r=" << r << dendl; - if (r < 0) { - if (r == -EEXIST) { - ldout(cct, 1) << "snapshot already exists" << dendl; - } else { - lderr(cct) << "encountered error: " << cpp_strerror(r) << dendl; - } - } - return true; -} - -template -void SnapshotRenameRequest::send_rename_snap() { - I &image_ctx = this->m_image_ctx; - assert(image_ctx.owner_lock.is_locked()); - RWLock::RLocker md_locker(image_ctx.md_lock); - RWLock::RLocker snap_locker(image_ctx.snap_lock); - - CephContext *cct = image_ctx.cct; - ldout(cct, 5) << this << " " << __func__ << dendl; - - m_state = STATE_RENAME_SNAP; - - librados::ObjectWriteOperation op; - if (image_ctx.old_format) { - cls_client::old_snapshot_rename(&op, m_snap_id, m_snap_name); - } else { - cls_client::snapshot_rename(&op, m_snap_id, m_snap_name); - } - - librados::AioCompletion *rados_completion = this->create_callback_completion(); - int r = image_ctx.md_ctx.aio_operate(image_ctx.header_oid, - rados_completion, &op); - assert(r == 0); - rados_completion->release(); -} - -} // namespace operation -} // namespace librbd - -template class librbd::operation::SnapshotRenameRequest;