Attempt to deflake DBTestXactLogIterator.TransactionLogIteratorCorruptedLog (#8627)

Summary:
The patch attempts to deflake `DBTestXactLogIterator.TransactionLogIteratorCorruptedLog`
by disabling file deletions while retrieving the list of WAL files and truncating the first WAL file.
This is to prevent the `PurgeObsoleteFiles` call triggered by `GetSortedWalFiles` from
invalidating the result of `GetSortedWalFiles`. The patch also cleans up the test case a bit
and changes it to using `test::TruncateFile` instead of calling the `truncate` syscall directly.

Pull Request resolved: https://github.com/facebook/rocksdb/pull/8627

Test Plan: `make check`

Reviewed By: akankshamahajan15

Differential Revision: D30147002

Pulled By: ltamasi

fbshipit-source-id: db11072a4ad8900a2f859cb5294e22b1888c23f6
main
Levi Tamasi 3 years ago committed by Facebook GitHub Bot
parent 82b81dc8b5
commit f63331ebaf
  1. 29
      db/db_log_iter_test.cc

@ -185,31 +185,38 @@ TEST_F(DBTestXactLogIterator, TransactionLogIteratorCorruptedLog) {
do { do {
Options options = OptionsForLogIterTest(); Options options = OptionsForLogIterTest();
DestroyAndReopen(options); DestroyAndReopen(options);
for (int i = 0; i < 1024; i++) { for (int i = 0; i < 1024; i++) {
ASSERT_OK(Put("key" + ToString(i), DummyString(10))); ASSERT_OK(Put("key" + ToString(i), DummyString(10)));
} }
ASSERT_OK(dbfull()->Flush(FlushOptions()));
ASSERT_OK(dbfull()->FlushWAL(false)); ASSERT_OK(Flush());
ASSERT_OK(db_->FlushWAL(false));
// Corrupt this log to create a gap // Corrupt this log to create a gap
ROCKSDB_NAMESPACE::VectorLogPtr wal_files; ASSERT_OK(db_->DisableFileDeletions());
ASSERT_OK(dbfull()->GetSortedWalFiles(wal_files));
VectorLogPtr wal_files;
ASSERT_OK(db_->GetSortedWalFiles(wal_files));
ASSERT_FALSE(wal_files.empty());
const auto logfile_path = dbname_ + "/" + wal_files.front()->PathName(); const auto logfile_path = dbname_ + "/" + wal_files.front()->PathName();
if (mem_env_) { ASSERT_OK(test::TruncateFile(env_, logfile_path,
mem_env_->Truncate(logfile_path, wal_files.front()->SizeFileBytes() / 2);
} else {
ASSERT_EQ(0, truncate(logfile_path.c_str(),
wal_files.front()->SizeFileBytes() / 2)); wal_files.front()->SizeFileBytes() / 2));
}
ASSERT_OK(db_->EnableFileDeletions());
// Insert a new entry to a new log file // Insert a new entry to a new log file
ASSERT_OK(Put("key1025", DummyString(10))); ASSERT_OK(Put("key1025", DummyString(10)));
ASSERT_OK(dbfull()->FlushWAL(false)); ASSERT_OK(db_->FlushWAL(false));
// Try to read from the beginning. Should stop before the gap and read less // Try to read from the beginning. Should stop before the gap and read less
// than 1025 entries // than 1025 entries
auto iter = OpenTransactionLogIter(0); auto iter = OpenTransactionLogIter(0);
int count; int count = 0;
SequenceNumber last_sequence_read = ReadRecords(iter, count, false); SequenceNumber last_sequence_read = ReadRecords(iter, count, false);
ASSERT_LT(last_sequence_read, 1025U); ASSERT_LT(last_sequence_read, 1025U);
// Try to read past the gap, should be able to seek to key1025 // Try to read past the gap, should be able to seek to key1025
auto iter2 = OpenTransactionLogIter(last_sequence_read + 1); auto iter2 = OpenTransactionLogIter(last_sequence_read + 1);
ExpectRecords(1, iter2); ExpectRecords(1, iter2);

Loading…
Cancel
Save