remove ceph code

[stor4nfv.git] / src / ceph / src / osd / ScrubStore.cc

diff --git a/src/ceph/src/osd/ScrubStore.cc b/src/ceph/src/osd/ScrubStore.cc
deleted file mode 100644 (file)
index 08dcae8..0000000
--- a/src/ceph/src/osd/ScrubStore.cc
+++ /dev/null
@@ -1,195 +0,0 @@
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- 
-// vim: ts=8 sw=2 smarttab
-
-#include "ScrubStore.h"
-#include "osd_types.h"
-#include "common/scrub_types.h"
-#include "include/rados/rados_types.hpp"
-
-namespace {
-ghobject_t make_scrub_object(const spg_t& pgid)
-{
-  ostringstream ss;
-  ss << "scrub_" << pgid;
-  return pgid.make_temp_ghobject(ss.str());
-}
-
-string first_object_key(int64_t pool)
-{
-  auto hoid = hobject_t(object_t(),
-                       "",
-                       0,
-                       0x00000000,
-                       pool,
-                       "");
-  hoid.build_hash_cache();
-  return "SCRUB_OBJ_" + hoid.to_str();
-}
-
-// the object_key should be unique across pools
-string to_object_key(int64_t pool, const librados::object_id_t& oid)
-{
-  auto hoid = hobject_t(object_t(oid.name),
-                       oid.locator, // key
-                       oid.snap,
-                       0,              // hash
-                       pool,
-                       oid.nspace);
-  hoid.build_hash_cache();
-  return "SCRUB_OBJ_" + hoid.to_str();
-}
-
-string last_object_key(int64_t pool)
-{
-  auto hoid = hobject_t(object_t(),
-                       "",
-                       0,
-                       0xffffffff,
-                       pool,
-                       "");
-  hoid.build_hash_cache();
-  return "SCRUB_OBJ_" + hoid.to_str();
-}
-
-string first_snap_key(int64_t pool)
-{
-  // scrub object is per spg_t object, so we can misuse the hash (pg.seed) for
-  // the representing the minimal and maximum keys. and this relies on how
-  // hobject_t::to_str() works: hex(pool).hex(revhash).
-  auto hoid = hobject_t(object_t(),
-                       "",
-                       0,
-                       0x00000000,
-                       pool,
-                       "");
-  hoid.build_hash_cache();
-  return "SCRUB_SS_" + hoid.to_str();
-}
-
-string to_snap_key(int64_t pool, const librados::object_id_t& oid)
-{
-  auto hoid = hobject_t(object_t(oid.name),
-                       oid.locator, // key
-                       oid.snap,
-                       0x77777777, // hash
-                       pool,
-                       oid.nspace);
-  hoid.build_hash_cache();
-  return "SCRUB_SS_" + hoid.to_str();
-}
-
-string last_snap_key(int64_t pool)
-{
-  auto hoid = hobject_t(object_t(),
-                       "",
-                       0,
-                       0xffffffff,
-                       pool,
-                       "");
-  hoid.build_hash_cache();
-  return "SCRUB_SS_" + hoid.to_str();
-}
-}
-
-namespace Scrub {
-
-Store*
-Store::create(ObjectStore* store,
-             ObjectStore::Transaction* t,
-             const spg_t& pgid,
-             const coll_t& coll)
-{
-  assert(store);
-  assert(t);
-  ghobject_t oid = make_scrub_object(pgid);
-  t->touch(coll, oid);
-  return new Store{coll, oid, store};
-}
-
-Store::Store(const coll_t& coll, const ghobject_t& oid, ObjectStore* store)
-  : coll(coll),
-    hoid(oid),
-    driver(store, coll, hoid),
-    backend(&driver)
-{}
-
-Store::~Store()
-{
-  assert(results.empty());
-}
-
-void Store::add_object_error(int64_t pool, const inconsistent_obj_wrapper& e)
-{
-  bufferlist bl;
-  e.encode(bl);
-  results[to_object_key(pool, e.object)] = bl;
-}
-
-void Store::add_snap_error(int64_t pool, const inconsistent_snapset_wrapper& e)
-{
-  bufferlist bl;
-  e.encode(bl);
-  results[to_snap_key(pool, e.object)] = bl;
-}
-
-bool Store::empty() const
-{
-  return results.empty();
-}
-
-void Store::flush(ObjectStore::Transaction* t)
-{
-  if (t) {
-    OSDriver::OSTransaction txn = driver.get_transaction(t);
-    backend.set_keys(results, &txn);
-  }
-  results.clear();
-}
-
-void Store::cleanup(ObjectStore::Transaction* t)
-{
-  t->remove(coll, hoid);
-}
-
-std::vector<bufferlist>
-Store::get_snap_errors(ObjectStore* store,
-                      int64_t pool,
-                      const librados::object_id_t& start,
-                      uint64_t max_return)
-{
-  const string begin = (start.name.empty() ?
-                       first_snap_key(pool) : to_snap_key(pool, start));
-  const string end = last_snap_key(pool);
-  return get_errors(store, begin, end, max_return);     
-}
-
-std::vector<bufferlist>
-Store::get_object_errors(ObjectStore* store,
-                        int64_t pool,
-                        const librados::object_id_t& start,
-                        uint64_t max_return)
-{
-  const string begin = (start.name.empty() ?
-                       first_object_key(pool) : to_object_key(pool, start));
-  const string end = last_object_key(pool);
-  return get_errors(store, begin, end, max_return);
-}
-
-std::vector<bufferlist>
-Store::get_errors(ObjectStore* store,
-                 const string& begin,
-                 const string& end,
-                 uint64_t max_return)
-{
-  vector<bufferlist> errors;
-  auto next = std::make_pair(begin, bufferlist{});
-  while (max_return && !backend.get_next(next.first, &next)) {
-    if (next.first >= end)
-      break;
-    errors.push_back(next.second);
-    max_return--;
-  }
-  return errors;
-}
-
-} // namespace Scrub