]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
osd/PGLog: drop old compat coll/oid args to read_log_and_missing 17708/head
authorSage Weil <sage@redhat.com>
Fri, 6 Oct 2017 19:34:41 +0000 (14:34 -0500)
committerSage Weil <sage@redhat.com>
Fri, 6 Oct 2017 20:37:51 +0000 (15:37 -0500)
The oldest version we care about is 10, and these were for <8.

Signed-off-by: Sage Weil <sage@redhat.com>
src/osd/PG.cc
src/osd/PGLog.h
src/test/osd/TestPGLog.cc
src/tools/ceph_objectstore_tool.cc

index 47817f0bb919ab739d67eb63fe912add4eacf610..d08b46e898e3d9d05779ee11e101cdc7c0d5249a 100644 (file)
@@ -3290,8 +3290,7 @@ void PG::read_state(ObjectStore *store)
   pg_log.read_log_and_missing(
     store,
     coll,
-    info_struct_v < 8 ? coll_t::meta() : coll,
-    ghobject_t(info_struct_v < 8 ? OSD::make_pg_log_oid(pg_id) : pgmeta_oid),
+    pgmeta_oid,
     info,
     oss,
     cct->_conf->osd_ignore_stale_divergent_priors,
index db3aa10541066d6435d1ede40fa4bc1ef10854be..4e8e084a2ad312d2d4985632c4b3a604ba7be8ce 100644 (file)
@@ -1257,15 +1257,14 @@ public:
   void read_log_and_missing(
     ObjectStore *store,
     coll_t pg_coll,
-    coll_t log_coll,
-    ghobject_t log_oid,
+    ghobject_t pgmeta_oid,
     const pg_info_t &info,
     ostringstream &oss,
     bool tolerate_divergent_missing_log,
     bool debug_verify_stored_missing = false
     ) {
     return read_log_and_missing(
-      store, pg_coll, log_coll, log_oid, info,
+      store, pg_coll, pgmeta_oid, info,
       log, missing, oss,
       tolerate_divergent_missing_log,
       &clear_divergent_priors,
@@ -1278,8 +1277,7 @@ public:
   static void read_log_and_missing(
     ObjectStore *store,
     coll_t pg_coll,
-    coll_t log_coll,
-    ghobject_t log_oid,
+    ghobject_t pgmeta_oid,
     const pg_info_t &info,
     IndexedLog &log,
     missing_type &missing,
@@ -1291,18 +1289,19 @@ public:
     bool debug_verify_stored_missing = false
     ) {
     ldpp_dout(dpp, 20) << "read_log_and_missing coll " << pg_coll
-                      << " log_oid " << log_oid << dendl;
+                      << " " << pgmeta_oid << dendl;
 
     // legacy?
     struct stat st;
-    int r = store->stat(log_coll, log_oid, &st);
+    int r = store->stat(pg_coll, pgmeta_oid, &st);
     assert(r == 0);
     assert(st.st_size == 0);
 
     // will get overridden below if it had been recorded
     eversion_t on_disk_can_rollback_to = info.last_update;
     eversion_t on_disk_rollback_info_trimmed_to = eversion_t();
-    ObjectMap::ObjectMapIterator p = store->get_omap_iterator(log_coll, log_oid);
+    ObjectMap::ObjectMapIterator p = store->get_omap_iterator(pg_coll,
+                                                             pgmeta_oid);
     map<eversion_t, hobject_t> divergent_priors;
     bool must_rebuild = false;
     missing.may_include_deletes = false;
index 14ab46601bbd155a8e4aa7ae45028ce487c766fd..4d7a858a520f9cf303febc6bc18ba560eb809d33 100644 (file)
@@ -2495,7 +2495,7 @@ public:
     auto orig_dups = log.dups;
     clear();
     ostringstream err;
-    read_log_and_missing(store.get(), test_coll, test_coll, log_oid,
+    read_log_and_missing(store.get(), test_coll, log_oid,
                         pg_info_t(), err, false);
     ASSERT_EQ(orig_dups.size(), log.dups.size());
     ASSERT_EQ(orig_dups, log.dups);
index 2e4884910c7317b062e1d5a00dbf4cf4e726c716..253882f47bb400215faf1f9d3303f95580155fe3 100644 (file)
@@ -289,9 +289,6 @@ struct lookup_ghobject : public action_on_object_t {
   }
 };
 
-ghobject_t infos_oid = OSD::make_infos_oid();
-ghobject_t log_oid;
-
 int file_fd = fd_none;
 bool debug;
 bool force = false;
@@ -325,12 +322,12 @@ int get_log(ObjectStore *fs, __u8 struct_ver,
   try {
     ostringstream oss;
     assert(struct_ver > 0);
-    PGLog::read_log_and_missing(fs, coll,
-                   struct_ver >= 8 ? coll : coll_t::meta(),
-                   struct_ver >= 8 ? pgid.make_pgmeta_oid() : log_oid,
-                   info, log, missing,
-                   oss,
-                   g_ceph_context->_conf->osd_ignore_stale_divergent_priors);
+    PGLog::read_log_and_missing(
+      fs, coll,
+      pgid.make_pgmeta_oid(),
+      info, log, missing,
+      oss,
+      g_ceph_context->_conf->osd_ignore_stale_divergent_priors);
     if (debug && oss.str().size())
       cerr << oss.str() << std::endl;
   }
@@ -1362,7 +1359,6 @@ int ObjectStoreTool::do_import(ObjectStore *store, OSDSuperblock& sb,
   }
 
   ghobject_t pgmeta_oid = pgid.make_pgmeta_oid();
-  log_oid = OSD::make_pg_log_oid(pgid);
 
   //Check for PG already present.
   coll_t coll(pgid);
@@ -3201,8 +3197,6 @@ int main(int argc, char **argv)
     goto out;
   }
 
-  log_oid = OSD::make_pg_log_oid(pgid);
-
   if (op == "remove") {
     if (!force && !dry_run) {
       cerr << "Please use export-remove or you must use --force option" << std::endl;