PGLog: include rollback_info_trimmed_to in (read|write)_log

Fixes: #10157
Backport: firefly, giant
Signed-off-by: Samuel Just <sjust@redhat.com>
(cherry picked from commit 1fe8b846641486cc294fe7e1d2450132c38d2dba)

diff --git a/src/osd/PGLog.cc b/src/osd/PGLog.cc
index 60390a2a5962f4172161ebf1ee8be49850161434..1bb0523283e2928ac93032f646796acd70961521 100644 (file)
--- a/src/osd/PGLog.cc
+++ b/src/osd/PGLog.cc
@@ -798,6 +798,7 @@ void PGLog::_write_log(
     ::encode(divergent_priors, keys["divergent_priors"]);
   }
   ::encode(log.can_rollback_to, keys["can_rollback_to"]);
+  ::encode(log.rollback_info_trimmed_to, keys["rollback_info_trimmed_to"]);
 
   t.omap_rmkeys(META_COLL, log_oid, to_remove);
   t.omap_setkeys(META_COLL, log_oid, keys);
@@ -822,8 +823,11 @@ bool PGLog::read_log(ObjectStore *store, coll_t coll, hobject_t log_oid,
     rewrite_log = true;
   } else {
     log.tail = info.log_tail;
+
     // will get overridden below if it had been recorded
     log.can_rollback_to = info.last_update;
+    log.rollback_info_trimmed_to = eversion_t();
+
     ObjectMap::ObjectMapIterator p = store->get_omap_iterator(META_COLL, log_oid);
     if (p) for (p->seek_to_first(); p->valid() ; p->next()) {
       bufferlist bl = p->value();//Copy bufferlist before creating iterator
@@ -835,6 +839,10 @@ bool PGLog::read_log(ObjectStore *store, coll_t coll, hobject_t log_oid,
        bufferlist bl = p->value();
        bufferlist::iterator bp = bl.begin();
        ::decode(log.can_rollback_to, bp);
+      } else if (p->key() == "rollback_info_trimmed_to") {
+       bufferlist bl = p->value();
+       bufferlist::iterator bp = bl.begin();
+       ::decode(log.rollback_info_trimmed_to, bp);
       } else {
        pg_log_entry_t e;
        e.decode_with_checksum(bp);