X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Ftools%2Frbd_mirror%2Fimage_sync%2FSyncPointPruneRequest.cc;fp=src%2Fceph%2Fsrc%2Ftools%2Frbd_mirror%2Fimage_sync%2FSyncPointPruneRequest.cc;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=a9d9445a0f4e242015d4b90eb35e5876ee05a139;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git

diff --git a/src/ceph/src/tools/rbd_mirror/image_sync/SyncPointPruneRequest.cc b/src/ceph/src/tools/rbd_mirror/image_sync/SyncPointPruneRequest.cc
deleted file mode 100644
index a9d9445..0000000
--- a/src/ceph/src/tools/rbd_mirror/image_sync/SyncPointPruneRequest.cc
+++ /dev/null
@@ -1,219 +0,0 @@
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-// vim: ts=8 sw=2 smarttab
-
-#include "SyncPointPruneRequest.h"
-#include "common/errno.h"
-#include "journal/Journaler.h"
-#include "librbd/ImageCtx.h"
-#include "librbd/ImageState.h"
-#include "librbd/Operations.h"
-#include "librbd/Utils.h"
-#include <set>
-
-#define dout_context g_ceph_context
-#define dout_subsys ceph_subsys_rbd_mirror
-#undef dout_prefix
-#define dout_prefix *_dout << "rbd::mirror::image_sync::SyncPointPruneRequest: " \
-                           << this << " " << __func__
-namespace rbd {
-namespace mirror {
-namespace image_sync {
-
-using librbd::util::create_context_callback;
-
-template <typename I>
-SyncPointPruneRequest<I>::SyncPointPruneRequest(I *remote_image_ctx,
-                                                bool sync_complete,
-                                                Journaler *journaler,
-                                                MirrorPeerClientMeta *client_meta,
-                                                Context *on_finish)
-  : m_remote_image_ctx(remote_image_ctx), m_sync_complete(sync_complete),
-    m_journaler(journaler), m_client_meta(client_meta), m_on_finish(on_finish),
-    m_client_meta_copy(*client_meta) {
-}
-
-template <typename I>
-void SyncPointPruneRequest<I>::send() {
-  if (m_client_meta->sync_points.empty()) {
-    send_remove_snap();
-    return;
-  }
-
-  if (m_sync_complete) {
-    // if sync is complete, we can remove the master sync point
-    auto it = m_client_meta_copy.sync_points.begin();
-    MirrorPeerSyncPoint &sync_point = *it;
-
-    ++it;
-    if (it == m_client_meta_copy.sync_points.end() ||
-        it->from_snap_name != sync_point.snap_name) {
-      m_snap_names.push_back(sync_point.snap_name);
-    }
-
-    if (!sync_point.from_snap_name.empty()) {
-      m_snap_names.push_back(sync_point.from_snap_name);
-    }
-  } else {
-    // if we have more than one sync point or invalid sync points,
-    // trim them off
-    RWLock::RLocker snap_locker(m_remote_image_ctx->snap_lock);
-    std::set<std::string> snap_names;
-    for (auto it = m_client_meta_copy.sync_points.rbegin();
-         it != m_client_meta_copy.sync_points.rend(); ++it) {
-      MirrorPeerSyncPoint &sync_point = *it;
-      if (&sync_point == &m_client_meta_copy.sync_points.front()) {
-        if (m_remote_image_ctx->get_snap_id(
-	      cls::rbd::UserSnapshotNamespace(), sync_point.snap_name) ==
-              CEPH_NOSNAP) {
-          derr << ": failed to locate sync point snapshot: "
-               << sync_point.snap_name << dendl;
-        } else if (!sync_point.from_snap_name.empty()) {
-          derr << ": unexpected from_snap_name in primary sync point: "
-               << sync_point.from_snap_name << dendl;
-        } else {
-          // first sync point is OK -- keep it
-          break;
-        }
-        m_invalid_master_sync_point = true;
-      }
-
-      if (snap_names.count(sync_point.snap_name) == 0) {
-        snap_names.insert(sync_point.snap_name);
-        m_snap_names.push_back(sync_point.snap_name);
-      }
-
-      MirrorPeerSyncPoint &front_sync_point =
-        m_client_meta_copy.sync_points.front();
-      if (!sync_point.from_snap_name.empty() &&
-          snap_names.count(sync_point.from_snap_name) == 0 &&
-          sync_point.from_snap_name != front_sync_point.snap_name) {
-        snap_names.insert(sync_point.from_snap_name);
-        m_snap_names.push_back(sync_point.from_snap_name);
-      }
-    }
-  }
-
-  send_remove_snap();
-}
-
-template <typename I>
-void SyncPointPruneRequest<I>::send_remove_snap() {
-  if (m_snap_names.empty()) {
-    send_refresh_image();
-    return;
-  }
-
-  const std::string &snap_name = m_snap_names.front();
-
-  dout(20) << ": snap_name=" << snap_name << dendl;
-
-  Context *ctx = create_context_callback<
-    SyncPointPruneRequest<I>, &SyncPointPruneRequest<I>::handle_remove_snap>(
-      this);
-  m_remote_image_ctx->operations->snap_remove(cls::rbd::UserSnapshotNamespace(),
-					      snap_name.c_str(),
-					      ctx);
-}
-
-template <typename I>
-void SyncPointPruneRequest<I>::handle_remove_snap(int r) {
-  dout(20) << ": r=" << r << dendl;
-
-  assert(!m_snap_names.empty());
-  std::string snap_name = m_snap_names.front();
-  m_snap_names.pop_front();
-
-  if (r == -ENOENT) {
-    r = 0;
-  }
-  if (r < 0) {
-    derr << ": failed to remove snapshot '" << snap_name << "': "
-         << cpp_strerror(r) << dendl;
-    finish(r);
-    return;
-  }
-
-  send_remove_snap();
-}
-
-template <typename I>
-void SyncPointPruneRequest<I>::send_refresh_image() {
-  dout(20) << dendl;
-
-  Context *ctx = create_context_callback<
-    SyncPointPruneRequest<I>, &SyncPointPruneRequest<I>::handle_refresh_image>(
-      this);
-  m_remote_image_ctx->state->refresh(ctx);
-}
-
-template <typename I>
-void SyncPointPruneRequest<I>::handle_refresh_image(int r) {
-  dout(20) << ": r=" << r << dendl;
-
-  if (r < 0) {
-    derr << ": remote image refresh failed: " << cpp_strerror(r) << dendl;
-    finish(r);
-    return;
-  }
-
-  send_update_client();
-}
-
-template <typename I>
-void SyncPointPruneRequest<I>::send_update_client() {
-  dout(20) << dendl;
-
-  if (m_sync_complete) {
-    m_client_meta_copy.sync_points.pop_front();
-    if (m_client_meta_copy.sync_points.empty()) {
-      m_client_meta_copy.state = librbd::journal::MIRROR_PEER_STATE_REPLAYING;
-    }
-  } else {
-    while (m_client_meta_copy.sync_points.size() > 1) {
-      m_client_meta_copy.sync_points.pop_back();
-    }
-    if (m_invalid_master_sync_point) {
-      // all subsequent sync points would have been pruned
-      m_client_meta_copy.sync_points.clear();
-    }
-  }
-
-  bufferlist client_data_bl;
-  librbd::journal::ClientData client_data(m_client_meta_copy);
-  ::encode(client_data, client_data_bl);
-
-  Context *ctx = create_context_callback<
-    SyncPointPruneRequest<I>, &SyncPointPruneRequest<I>::handle_update_client>(
-      this);
-  m_journaler->update_client(client_data_bl, ctx);
-}
-
-template <typename I>
-void SyncPointPruneRequest<I>::handle_update_client(int r) {
-  dout(20) << ": r=" << r << dendl;
-
-  if (r < 0) {
-    derr << ": failed to update client data: " << cpp_strerror(r)
-         << dendl;
-    finish(r);
-    return;
-  }
-
-  // update provided meta structure to reflect reality
-  *m_client_meta = m_client_meta_copy;
-  finish(0);
-}
-
-template <typename I>
-void SyncPointPruneRequest<I>::finish(int r) {
-  dout(20) << ": r=" << r << dendl;
-
-  m_on_finish->complete(r);
-  delete this;
-}
-
-} // namespace image_sync
-} // namespace mirror
-} // namespace rbd
-
-template class rbd::mirror::image_sync::SyncPointPruneRequest<librbd::ImageCtx>;