ObjectStore::Transaction t;
pg_info_t info;
list<hobject_t> remove_snap;
- bool dirty_log = false;
bool dirty_info = false;
bool dirty_big_info = false;
log.tail = eversion_t(2, 1);
EXPECT_THROW(rewind_divergent_log(t, eversion_t(1, 1), info, remove_snap,
- dirty_log, dirty_info, dirty_big_info),
+ dirty_info, dirty_big_info),
FailedAssertion);
}
ObjectStore::Transaction t;
pg_info_t info;
list<hobject_t> remove_snap;
- bool dirty_log = false;
bool dirty_info = false;
bool dirty_big_info = false;
EXPECT_FALSE(missing.have_missing());
EXPECT_EQ(3U, log.log.size());
- EXPECT_EQ(0U, ondisklog.length());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_EQ(log.head, info.last_update);
EXPECT_EQ(log.head, info.last_complete);
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_FALSE(dirty_info);
EXPECT_FALSE(dirty_big_info);
rewind_divergent_log(t, newhead, info, remove_snap,
- dirty_log, dirty_info, dirty_big_info);
+ dirty_info, dirty_big_info);
EXPECT_TRUE(missing.is_missing(divergent_object));
EXPECT_EQ(1U, log.objects.count(divergent_object));
EXPECT_EQ(2U, log.log.size());
- EXPECT_EQ(0U, ondisklog.length());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_EQ(newhead, info.last_update);
EXPECT_EQ(newhead, info.last_complete);
- EXPECT_TRUE(dirty_log);
+ EXPECT_TRUE(dirty());
EXPECT_TRUE(dirty_info);
EXPECT_TRUE(dirty_big_info);
}
ObjectStore::Transaction t;
pg_info_t info;
list<hobject_t> remove_snap;
- bool dirty_log = false;
bool dirty_info = false;
bool dirty_big_info = false;
EXPECT_FALSE(missing.have_missing());
EXPECT_EQ(1U, log.log.size());
- EXPECT_EQ(0U, ondisklog.length());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_FALSE(dirty_info);
EXPECT_FALSE(dirty_big_info);
rewind_divergent_log(t, newhead, info, remove_snap,
- dirty_log, dirty_info, dirty_big_info);
+ dirty_info, dirty_big_info);
EXPECT_TRUE(missing.is_missing(divergent_object));
EXPECT_EQ(0U, log.objects.count(divergent_object));
EXPECT_TRUE(log.empty());
- EXPECT_EQ(0U, ondisklog.length());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
- EXPECT_TRUE(dirty_log);
+ EXPECT_TRUE(dirty());
EXPECT_TRUE(dirty_info);
EXPECT_TRUE(dirty_big_info);
}
pg_log_entry_t oe;
pg_info_t info;
list<hobject_t> remove_snap;
- bool dirty_log = false;
info.last_backfill = hobject_t();
info.last_backfill.hash = 1;
oe.soid.hash = 2;
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_FALSE(missing.have_missing());
EXPECT_TRUE(log.empty());
- EXPECT_EQ(0U, ondisklog.length());
- EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap, dirty_log));
+ EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap));
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_FALSE(missing.have_missing());
EXPECT_TRUE(log.empty());
- EXPECT_EQ(0U, ondisklog.length());
}
// a clone with no non-divergent log entry is deleted
pg_log_entry_t oe;
pg_info_t info;
list<hobject_t> remove_snap;
- bool dirty_log = false;
oe.op = pg_log_entry_t::CLONE;
oe.soid.snap = CEPH_NOSNAP;
- EXPECT_THROW(merge_old_entry(t, oe, info, remove_snap, dirty_log), FailedAssertion);
+ EXPECT_THROW(merge_old_entry(t, oe, info, remove_snap), FailedAssertion);
oe.soid.snap = 1U;
missing.add(oe.soid, eversion_t(), eversion_t());
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_TRUE(missing.have_missing());
EXPECT_TRUE(missing.is_missing(oe.soid));
EXPECT_TRUE(log.empty());
- EXPECT_EQ(0U, ondisklog.length());
- EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap, dirty_log));
+ EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap));
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_EQ(oe.soid, remove_snap.front());
EXPECT_TRUE(t.empty());
EXPECT_FALSE(missing.have_missing());
EXPECT_TRUE(log.empty());
- EXPECT_EQ(0U, ondisklog.length());
}
// the new entry (from the logs) old entry (from the log entry
pg_log_entry_t oe;
pg_info_t info;
list<hobject_t> remove_snap;
- bool dirty_log = false;
oe.version = eversion_t(1,1);
log.add(oe);
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_FALSE(missing.have_missing());
EXPECT_EQ(1U, log.log.size());
- EXPECT_EQ(0U, ondisklog.length());
- EXPECT_TRUE(merge_old_entry(t, oe, info, remove_snap, dirty_log));
+ EXPECT_TRUE(merge_old_entry(t, oe, info, remove_snap));
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_FALSE(missing.have_missing());
EXPECT_EQ(1U, log.log.size());
- EXPECT_EQ(0U, ondisklog.length());
}
// the new entry (from the logs) has a version that is higher than
ObjectStore::Transaction t;
pg_info_t info;
list<hobject_t> remove_snap;
- bool dirty_log = false;
pg_log_entry_t ne;
ne.version = eversion_t(2,1);
log.add(ne);
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_FALSE(missing.have_missing());
EXPECT_EQ(1U, log.log.size());
EXPECT_EQ(ne.version, log.log.front().version);
- EXPECT_EQ(0U, ondisklog.length());
// the newer entry ( from the logs ) can be DELETE
{
pg_log_entry_t oe;
oe.version = eversion_t(1,1);
- EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap, dirty_log));
+ EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap));
}
// if the newer entry is not DELETE, the object must be in missing
pg_log_entry_t oe;
oe.version = eversion_t(1,1);
- EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap, dirty_log));
+ EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap));
missing.rm(ne.soid, ne.version);
}
pg_log_entry_t oe;
oe.version = eversion_t(1,1);
- EXPECT_THROW(merge_old_entry(t, oe, info, remove_snap, dirty_log), FailedAssertion);
+ EXPECT_THROW(merge_old_entry(t, oe, info, remove_snap), FailedAssertion);
}
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_FALSE(missing.have_missing());
EXPECT_EQ(1U, log.log.size());
EXPECT_EQ(ne.version, log.log.front().version);
- EXPECT_EQ(0U, ondisklog.length());
}
pg_log_entry_t oe;
pg_info_t info;
list<hobject_t> remove_snap;
- bool dirty_log = false;
pg_log_entry_t ne;
ne.version = eversion_t(1,1);
oe.version = eversion_t(2,1);
oe.op = pg_log_entry_t::DELETE;
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_FALSE(missing.have_missing());
EXPECT_EQ(1U, log.log.size());
- EXPECT_EQ(0U, ondisklog.length());
- EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap, dirty_log));
+ EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap));
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_FALSE(missing.have_missing());
EXPECT_EQ(1U, log.log.size());
- EXPECT_EQ(0U, ondisklog.length());
}
// the new entry (from the logs) has a version that is lower than
pg_log_entry_t oe;
pg_info_t info;
list<hobject_t> remove_snap;
- bool dirty_log = false;
pg_log_entry_t ne;
ne.version = eversion_t(1,1);
oe.version = eversion_t(2,1);
oe.op = oe_op;
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_FALSE(missing.have_missing());
EXPECT_EQ(1U, log.log.size());
- EXPECT_EQ(0U, ondisklog.length());
eversion_t old_version(0, 0);
// if the object is not already in missing, add it
{
- EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap, dirty_log));
+ EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap));
EXPECT_TRUE(missing.is_missing(ne.soid, ne.version));
EXPECT_FALSE(missing.is_missing(ne.soid, old_version));
missing.revise_need(ne.soid, old_version);
EXPECT_TRUE(missing.is_missing(ne.soid, old_version));
- EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap, dirty_log));
+ EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap));
EXPECT_TRUE(missing.is_missing(ne.soid, ne.version));
EXPECT_FALSE(missing.is_missing(ne.soid, old_version));
}
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_TRUE(missing.is_missing(ne.soid));
EXPECT_EQ(1U, log.log.size());
- EXPECT_EQ(0U, ondisklog.length());
}
}
pg_log_entry_t oe;
pg_info_t info;
list<hobject_t> remove_snap;
- bool dirty_log = false;
pg_log_entry_t ne;
ne.version = eversion_t(1,1);
oe.op = pg_log_entry_t::MODIFY;
missing.add_next_event(oe);
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_TRUE(missing.is_missing(oe.soid));
EXPECT_EQ(1U, log.log.size());
- EXPECT_EQ(0U, ondisklog.length());
- EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap, dirty_log));
+ EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap));
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_FALSE(missing.have_missing());
EXPECT_EQ(1U, log.log.size());
- EXPECT_EQ(0U, ondisklog.length());
}
// there is no new entry (from the logs) and
pg_log_entry_t oe;
pg_info_t info;
list<hobject_t> remove_snap;
- bool dirty_log = false;
info.log_tail = eversion_t(1,1);
oe.op = pg_log_entry_t::MODIFY;
oe.prior_version = eversion_t(2,1);
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_FALSE(missing.have_missing());
EXPECT_TRUE(log.empty());
- EXPECT_EQ(0U, ondisklog.length());
- EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap, dirty_log));
+ EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap));
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_FALSE(missing.have_missing());
EXPECT_TRUE(log.empty());
- EXPECT_EQ(0U, ondisklog.length());
}
// there is no new entry (from the logs) and
// the old entry (from the log entry given in argument) is not a CLONE and
// the old entry (from the log entry given in argument) is not a DELETE and
// the old entry prior_version is lower than the tail of the log :
- // add the old object to the remove_snap list and
- // add the old object to ondisklog divergent priors and
- // set dirty_log to true and
+ // add the old object to the remove_snap list and
+ // add the old object to divergent priors and
// add or update the prior_version of the object to missing and
// return false
{
pg_log_entry_t oe;
pg_info_t info;
list<hobject_t> remove_snap;
- bool dirty_log = false;
info.log_tail = eversion_t(2,1);
oe.soid.hash = 1;
oe.op = pg_log_entry_t::MODIFY;
oe.prior_version = eversion_t(1,1);
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_FALSE(missing.have_missing());
EXPECT_TRUE(log.empty());
- EXPECT_EQ(0U, ondisklog.length());
- EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap, dirty_log));
+ EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap));
- EXPECT_TRUE(dirty_log);
+ EXPECT_TRUE(dirty());
EXPECT_EQ(oe.soid, remove_snap.front());
EXPECT_TRUE(t.empty());
EXPECT_TRUE(missing.is_missing(oe.soid));
EXPECT_TRUE(log.empty());
- EXPECT_EQ(oe.soid, ondisklog.divergent_priors[oe.prior_version]);
+ EXPECT_EQ(oe.soid, divergent_priors[oe.prior_version]);
}
// there is no new entry (from the logs) and
// the old entry (from the log entry given in argument) is not a CLONE and
// the old entry (from the log entry given in argument) is a DELETE and
// the old entry prior_version is lower than the tail of the log :
- // add the old object to ondisklog divergent priors and
- // set dirty_log to true and
+ // add the old object to divergent priors and
// add or update the prior_version of the object to missing and
// return false
{
pg_log_entry_t oe;
pg_info_t info;
list<hobject_t> remove_snap;
- bool dirty_log = false;
info.log_tail = eversion_t(2,1);
oe.soid.hash = 1;
oe.op = pg_log_entry_t::DELETE;
oe.prior_version = eversion_t(1,1);
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_FALSE(missing.have_missing());
EXPECT_TRUE(log.empty());
- EXPECT_EQ(0U, ondisklog.length());
- EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap, dirty_log));
+ EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap));
- EXPECT_TRUE(dirty_log);
+ EXPECT_TRUE(dirty());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_TRUE(missing.is_missing(oe.soid));
EXPECT_TRUE(log.empty());
- EXPECT_EQ(oe.soid, ondisklog.divergent_priors[oe.prior_version]);
+ EXPECT_EQ(oe.soid, divergent_priors[oe.prior_version]);
}
// there is no new entry (from the logs) and
pg_log_entry_t oe;
pg_info_t info;
list<hobject_t> remove_snap;
- bool dirty_log = false;
info.log_tail = eversion_t(10,1);
oe.soid.hash = 1;
missing.add(oe.soid, eversion_t(1,1), eversion_t());
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_TRUE(missing.is_missing(oe.soid));
EXPECT_TRUE(log.empty());
- EXPECT_EQ(0U, ondisklog.length());
- EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap, dirty_log));
+ EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap));
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_FALSE(missing.have_missing());
EXPECT_TRUE(log.empty());
- EXPECT_EQ(0U, ondisklog.length());
}
// there is no new entry (from the logs) and
pg_log_entry_t oe;
pg_info_t info;
list<hobject_t> remove_snap;
- bool dirty_log = false;
info.log_tail = eversion_t(10,1);
oe.soid.hash = 1;
missing.add(oe.soid, eversion_t(1,1), eversion_t());
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_TRUE(missing.is_missing(oe.soid));
EXPECT_TRUE(log.empty());
- EXPECT_EQ(0U, ondisklog.length());
- EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap, dirty_log));
+ EXPECT_FALSE(merge_old_entry(t, oe, info, remove_snap));
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_EQ(oe.soid, remove_snap.front());
EXPECT_TRUE(t.empty());
EXPECT_FALSE(missing.have_missing());
EXPECT_TRUE(log.empty());
- EXPECT_EQ(0U, ondisklog.length());
}
}
int fromosd = -1;
pg_info_t info;
list<hobject_t> remove_snap;
- bool dirty_log = false;
bool dirty_info = false;
bool dirty_big_info = false;
EXPECT_FALSE(missing.have_missing());
EXPECT_EQ(0U, log.log.size());
- EXPECT_EQ(0U, ondisklog.length());
EXPECT_EQ(stat_version, info.stats.version);
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_EQ(last_backfill, info.last_backfill);
EXPECT_TRUE(info.purged_snaps.empty());
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_FALSE(dirty_info);
EXPECT_FALSE(dirty_big_info);
merge_log(t, oinfo, olog, fromosd, info, remove_snap,
- dirty_log, dirty_info, dirty_big_info);
+ dirty_info, dirty_big_info);
EXPECT_FALSE(missing.have_missing());
EXPECT_EQ(0U, log.log.size());
- EXPECT_EQ(0U, ondisklog.length());
EXPECT_EQ(stat_version, info.stats.version);
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_TRUE(info.purged_snaps.empty());
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_FALSE(dirty_info);
EXPECT_FALSE(dirty_big_info);
}
int fromosd = -1;
pg_info_t info;
list<hobject_t> remove_snap;
- bool dirty_log = false;
bool dirty_info = false;
bool dirty_big_info = false;
EXPECT_FALSE(missing.have_missing());
EXPECT_EQ(0U, log.log.size());
- EXPECT_EQ(0U, ondisklog.length());
EXPECT_EQ(eversion_t(), info.stats.version);
EXPECT_EQ(stat_reported, info.stats.reported);
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_TRUE(info.last_backfill.is_max());
EXPECT_TRUE(info.purged_snaps.empty());
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_FALSE(dirty_info);
EXPECT_FALSE(dirty_big_info);
merge_log(t, oinfo, olog, fromosd, info, remove_snap,
- dirty_log, dirty_info, dirty_big_info);
+ dirty_info, dirty_big_info);
EXPECT_FALSE(missing.have_missing());
EXPECT_EQ(0U, log.log.size());
- EXPECT_EQ(0U, ondisklog.length());
EXPECT_EQ(stat_version, info.stats.version);
EXPECT_EQ(stat_reported, info.stats.reported);
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_TRUE(info.purged_snaps.empty());
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_FALSE(dirty_info);
EXPECT_FALSE(dirty_big_info);
}
int fromosd = -1;
pg_info_t info;
list<hobject_t> remove_snap;
- bool dirty_log = false;
bool dirty_info = false;
bool dirty_big_info = false;
EXPECT_FALSE(missing.have_missing());
EXPECT_EQ(2U, log.log.size());
- EXPECT_EQ(0U, ondisklog.length());
EXPECT_EQ(stat_version, info.stats.version);
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_EQ(last_backfill, info.last_backfill);
EXPECT_TRUE(info.purged_snaps.empty());
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_FALSE(dirty_info);
EXPECT_FALSE(dirty_big_info);
merge_log(t, oinfo, olog, fromosd, info, remove_snap,
- dirty_log, dirty_info, dirty_big_info);
+ dirty_info, dirty_big_info);
EXPECT_FALSE(missing.have_missing());
EXPECT_EQ(3U, log.log.size());
- EXPECT_EQ(0U, ondisklog.length());
EXPECT_EQ(stat_version, info.stats.version);
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_TRUE(info.purged_snaps.empty());
- EXPECT_TRUE(dirty_log);
+ EXPECT_TRUE(dirty());
EXPECT_TRUE(dirty_info);
EXPECT_TRUE(dirty_big_info);
}
int fromosd = -1;
pg_info_t info;
list<hobject_t> remove_snap;
- bool dirty_log = false;
bool dirty_info = false;
bool dirty_big_info = false;
EXPECT_FALSE(missing.have_missing());
EXPECT_EQ(1U, log.objects.count(divergent_object));
EXPECT_EQ(3U, log.log.size());
- EXPECT_EQ(0U, ondisklog.length());
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_EQ(log.head, info.last_update);
EXPECT_TRUE(info.purged_snaps.empty());
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_FALSE(dirty_info);
EXPECT_FALSE(dirty_big_info);
merge_log(t, oinfo, olog, fromosd, info, remove_snap,
- dirty_log, dirty_info, dirty_big_info);
+ dirty_info, dirty_big_info);
/* When the divergent entry is a DELETE and the authoritative
entry is a MODIFY, the object will be added to missing : it is
EXPECT_TRUE(missing.is_missing(divergent_object));
EXPECT_EQ(1U, log.objects.count(divergent_object));
EXPECT_EQ(4U, log.log.size());
- EXPECT_EQ(0U, ondisklog.length());
/* DELETE entries from olog that are appended to the hed of the
log are also added to remove_snap.
*/
EXPECT_TRUE(t.empty());
EXPECT_EQ(log.head, info.last_update);
EXPECT_TRUE(info.purged_snaps.contains(purged_snap));
- EXPECT_TRUE(dirty_log);
+ EXPECT_TRUE(dirty());
EXPECT_TRUE(dirty_info);
EXPECT_TRUE(dirty_big_info);
}
int fromosd = -1;
pg_info_t info;
list<hobject_t> remove_snap;
- bool dirty_log = false;
bool dirty_info = false;
bool dirty_big_info = false;
EXPECT_FALSE(missing.have_missing());
EXPECT_EQ(3U, log.log.size());
- EXPECT_EQ(0U, ondisklog.length());
EXPECT_EQ(stat_version, info.stats.version);
EXPECT_TRUE(remove_snap.empty());
EXPECT_TRUE(t.empty());
EXPECT_EQ(last_backfill, info.last_backfill);
EXPECT_TRUE(info.purged_snaps.empty());
- EXPECT_FALSE(dirty_log);
+ EXPECT_FALSE(dirty());
EXPECT_FALSE(dirty_info);
EXPECT_FALSE(dirty_big_info);
merge_log(t, oinfo, olog, fromosd, info, remove_snap,
- dirty_log, dirty_info, dirty_big_info);
+ dirty_info, dirty_big_info);
EXPECT_FALSE(missing.have_missing());
EXPECT_EQ(2U, log.log.size());
- EXPECT_EQ(0U, ondisklog.length());
EXPECT_EQ(stat_version, info.stats.version);
EXPECT_EQ(0x9U, remove_snap.front().hash);
EXPECT_TRUE(t.empty());
EXPECT_TRUE(info.purged_snaps.empty());
- EXPECT_TRUE(dirty_log);
+ EXPECT_TRUE(dirty());
EXPECT_TRUE(dirty_info);
EXPECT_TRUE(dirty_big_info);
}
int fromosd = -1;
pg_info_t info;
list<hobject_t> remove_snap;
- bool dirty_log = false;
bool dirty_info = false;
bool dirty_big_info = false;
olog.tail = eversion_t(1, 1);
ASSERT_THROW(merge_log(t, oinfo, olog, fromosd, info, remove_snap,
- dirty_log, dirty_info, dirty_big_info), FailedAssertion);
+ dirty_info, dirty_big_info), FailedAssertion);
}
/* +--------------------------+
int fromosd = -1;
pg_info_t info;
list<hobject_t> remove_snap;
- bool dirty_log = false;
bool dirty_info = false;
bool dirty_big_info = false;
}
EXPECT_THROW(merge_log(t, oinfo, olog, fromosd, info, remove_snap,
- dirty_log, dirty_info, dirty_big_info), FailedAssertion);
+ dirty_info, dirty_big_info), FailedAssertion);
}
}