From 1fe8b846641486cc294fe7e1d2450132c38d2dba Mon Sep 17 00:00:00 2001 From: Samuel Just Date: Thu, 20 Nov 2014 15:15:08 -0800 Subject: [PATCH] PGLog: include rollback_info_trimmed_to in (read|write)_log Fixes: #10157 Backport: firefly, giant Signed-off-by: Samuel Just --- src/osd/PGLog.cc | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/src/osd/PGLog.cc b/src/osd/PGLog.cc index 586b675338052..b0d86e11c0259 100644 --- 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); -- 2.39.5