PGLog: include rollback_info_trimmed_to in (read|write)_log

Fixes: #10157
Backport: firefly, giant
Signed-off-by: Samuel Just <sjust@redhat.com>

diff --git a/src/osd/PGLog.cc b/src/osd/PGLog.cc
index 586b6753380526efb0277721ae70ba5bbd3652a7..b0d86e11c0259f86520c33160a47f4c8e7feb6c5 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"]);
 
   if (!to_remove.empty())
     t.omap_rmkeys(META_COLL, log_oid, to_remove);
@@ -823,8 +824,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
@@ -836,6 +840,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);