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

diff --git a/src/ceph/src/osd/ScrubStore.cc b/src/ceph/src/osd/ScrubStore.cc
deleted file mode 100644
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