remove ceph code

[stor4nfv.git] / src / ceph / src / tools / rbd_mirror / ClusterWatcher.cc

diff --git a/src/ceph/src/tools/rbd_mirror/ClusterWatcher.cc b/src/ceph/src/tools/rbd_mirror/ClusterWatcher.cc
deleted file mode 100644 (file)
index c4f3544..0000000
--- a/src/ceph/src/tools/rbd_mirror/ClusterWatcher.cc
+++ /dev/null
@@ -1,153 +0,0 @@
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-// vim: ts=8 sw=2 smarttab
-
-#include "ClusterWatcher.h"
-#include "common/debug.h"
-#include "common/errno.h"
-#include "cls/rbd/cls_rbd_client.h"
-#include "librbd/internal.h"
-#include "librbd/api/Mirror.h"
-#include "tools/rbd_mirror/ServiceDaemon.h"
-
-#define dout_context g_ceph_context
-#define dout_subsys ceph_subsys_rbd_mirror
-#undef dout_prefix
-#define dout_prefix *_dout << "rbd::mirror::ClusterWatcher:" << this << " " \
-                           << __func__ << ": "
-
-using std::list;
-using std::map;
-using std::set;
-using std::string;
-using std::unique_ptr;
-using std::vector;
-
-using librados::Rados;
-using librados::IoCtx;
-
-namespace rbd {
-namespace mirror {
-
-ClusterWatcher::ClusterWatcher(RadosRef cluster, Mutex &lock,
-                               ServiceDaemon<librbd::ImageCtx>* service_daemon)
-  : m_cluster(cluster), m_lock(lock), m_service_daemon(service_daemon)
-{
-}
-
-const ClusterWatcher::PoolPeers& ClusterWatcher::get_pool_peers() const
-{
-  assert(m_lock.is_locked());
-  return m_pool_peers;
-}
-
-void ClusterWatcher::refresh_pools()
-{
-  dout(20) << "enter" << dendl;
-
-  PoolPeers pool_peers;
-  PoolNames pool_names;
-  read_pool_peers(&pool_peers, &pool_names);
-
-  Mutex::Locker l(m_lock);
-  m_pool_peers = pool_peers;
-  // TODO: perhaps use a workqueue instead, once we get notifications
-  // about config changes for existing pools
-}
-
-void ClusterWatcher::read_pool_peers(PoolPeers *pool_peers,
-                                    PoolNames *pool_names)
-{
-  list<pair<int64_t, string> > pools;
-  int r = m_cluster->pool_list2(pools);
-  if (r < 0) {
-    derr << "error listing pools: " << cpp_strerror(r) << dendl;
-    return;
-  }
-
-  std::set<int64_t> service_pool_ids;
-  for (auto& kv : pools) {
-    int64_t pool_id = kv.first;
-    auto& pool_name = kv.second;
-    int64_t base_tier;
-    r = m_cluster->pool_get_base_tier(pool_id, &base_tier);
-    if (r == -ENOENT) {
-      dout(10) << "pool " << pool_name << " no longer exists" << dendl;
-      continue;
-    } else if (r < 0) {
-      derr << "Error retrieving base tier for pool " << pool_name << dendl;
-      continue;
-    }
-    if (pool_id != base_tier) {
-      // pool is a cache; skip it
-      continue;
-    }
-
-    IoCtx ioctx;
-    r = m_cluster->ioctx_create2(pool_id, ioctx);
-    if (r == -ENOENT) {
-      dout(10) << "pool " << pool_id << " no longer exists" << dendl;
-      continue;
-    } else if (r < 0) {
-      derr << "Error accessing pool " << pool_name << cpp_strerror(r) << dendl;
-      continue;
-    }
-
-    cls::rbd::MirrorMode mirror_mode_internal;
-    r = librbd::cls_client::mirror_mode_get(&ioctx, &mirror_mode_internal);
-    if (r == 0 && mirror_mode_internal == cls::rbd::MIRROR_MODE_DISABLED) {
-      dout(10) << "mirroring is disabled for pool " << pool_name << dendl;
-      continue;
-    }
-
-    service_pool_ids.insert(pool_id);
-    if (m_service_pools.find(pool_id) == m_service_pools.end()) {
-      m_service_pools[pool_id] = {};
-      m_service_daemon->add_pool(pool_id, pool_name);
-    }
-
-    if (r == -EPERM) {
-      dout(10) << "access denied querying pool " << pool_name << dendl;
-      m_service_pools[pool_id] = m_service_daemon->add_or_update_callout(
-        pool_id, m_service_pools[pool_id],
-        service_daemon::CALLOUT_LEVEL_WARNING, "access denied");
-      continue;
-    } else if (r < 0) {
-      derr << "could not tell whether mirroring was enabled for " << pool_name
-          << " : " << cpp_strerror(r) << dendl;
-      m_service_pools[pool_id] = m_service_daemon->add_or_update_callout(
-        pool_id, m_service_pools[pool_id],
-        service_daemon::CALLOUT_LEVEL_WARNING, "mirroring mode query failed");
-      continue;
-    }
-
-    vector<librbd::mirror_peer_t> configs;
-    r = librbd::api::Mirror<>::peer_list(ioctx, &configs);
-    if (r < 0) {
-      derr << "error reading mirroring config for pool " << pool_name
-          << cpp_strerror(r) << dendl;
-      m_service_pools[pool_id] = m_service_daemon->add_or_update_callout(
-        pool_id, m_service_pools[pool_id],
-        service_daemon::CALLOUT_LEVEL_ERROR, "mirroring peer list failed");
-      continue;
-    }
-
-    if (m_service_pools[pool_id] != service_daemon::CALLOUT_ID_NONE) {
-      m_service_daemon->remove_callout(pool_id, m_service_pools[pool_id]);
-      m_service_pools[pool_id] = service_daemon::CALLOUT_ID_NONE;
-    }
-
-    pool_peers->insert({pool_id, Peers{configs.begin(), configs.end()}});
-    pool_names->insert(pool_name);
-  }
-
-  for (auto it = m_service_pools.begin(); it != m_service_pools.end(); ) {
-    auto current_it(it++);
-    if (service_pool_ids.find(current_it->first) == service_pool_ids.end()) {
-      m_service_daemon->remove_pool(current_it->first);
-      m_service_pools.erase(current_it->first);
-    }
-  }
-}
-
-} // namespace mirror
-} // namespace rbd