Unverified Commit 028ef32c authored by Xinye Tao's avatar Xinye Tao Committed by GitHub

Fix db cleanup in blob_gc_job_test (#107)

Signed-off-by: 's avatartabokie <xy.tao@outlook.com>
parent 96922d49
...@@ -41,7 +41,7 @@ class BlobGCJobTest : public testing::Test { ...@@ -41,7 +41,7 @@ class BlobGCJobTest : public testing::Test {
options_.env->CreateDirIfMissing(dbname_); options_.env->CreateDirIfMissing(dbname_);
options_.env->CreateDirIfMissing(options_.dirname); options_.env->CreateDirIfMissing(options_.dirname);
} }
~BlobGCJobTest() {} ~BlobGCJobTest() { Close(); }
void DisableMergeSmall() { options_.merge_small_file_threshold = 0; } void DisableMergeSmall() { options_.merge_small_file_threshold = 0; }
...@@ -87,7 +87,7 @@ class BlobGCJobTest : public testing::Test { ...@@ -87,7 +87,7 @@ class BlobGCJobTest : public testing::Test {
} }
void Reopen() { void Reopen() {
DestroyDB(); Close();
Open(); Open();
} }
...@@ -119,9 +119,9 @@ class BlobGCJobTest : public testing::Test { ...@@ -119,9 +119,9 @@ class BlobGCJobTest : public testing::Test {
b->ComputeGCScore(); b->ComputeGCScore();
} }
void DestroyDB() { void Close() {
Status s __attribute__((__unused__)) = db_->Close(); if (!db_) return;
assert(s.ok()); ASSERT_OK(db_->Close());
delete db_; delete db_;
db_ = nullptr; db_ = nullptr;
} }
...@@ -220,7 +220,6 @@ class BlobGCJobTest : public testing::Test { ...@@ -220,7 +220,6 @@ class BlobGCJobTest : public testing::Test {
bool discardable = false; bool discardable = false;
ASSERT_OK(blob_gc_job.DiscardEntry(key, blob_index, &discardable)); ASSERT_OK(blob_gc_job.DiscardEntry(key, blob_index, &discardable));
ASSERT_FALSE(discardable); ASSERT_FALSE(discardable);
DestroyDB();
} }
void TestRunGC() { void TestRunGC() {
...@@ -277,7 +276,6 @@ class BlobGCJobTest : public testing::Test { ...@@ -277,7 +276,6 @@ class BlobGCJobTest : public testing::Test {
} }
delete db_iter; delete db_iter;
ASSERT_FALSE(iter->Valid() || !iter->status().ok()); ASSERT_FALSE(iter->Valid() || !iter->status().ok());
DestroyDB();
} }
}; };
...@@ -354,7 +352,7 @@ TEST_F(BlobGCJobTest, GCLimiter) { ...@@ -354,7 +352,7 @@ TEST_F(BlobGCJobTest, GCLimiter) {
RunGC(true); RunGC(true);
ASSERT_TRUE(test_limiter->WriteRequested()); ASSERT_TRUE(test_limiter->WriteRequested());
ASSERT_FALSE(test_limiter->ReadRequested()); ASSERT_FALSE(test_limiter->ReadRequested());
DestroyDB(); Close();
test_limiter = new TestLimiter(RateLimiter::Mode::kReadsOnly); test_limiter = new TestLimiter(RateLimiter::Mode::kReadsOnly);
options_.rate_limiter.reset(test_limiter); options_.rate_limiter.reset(test_limiter);
...@@ -364,7 +362,7 @@ TEST_F(BlobGCJobTest, GCLimiter) { ...@@ -364,7 +362,7 @@ TEST_F(BlobGCJobTest, GCLimiter) {
RunGC(true); RunGC(true);
ASSERT_FALSE(test_limiter->WriteRequested()); ASSERT_FALSE(test_limiter->WriteRequested());
ASSERT_TRUE(test_limiter->ReadRequested()); ASSERT_TRUE(test_limiter->ReadRequested());
DestroyDB(); Close();
test_limiter = new TestLimiter(RateLimiter::Mode::kAllIo); test_limiter = new TestLimiter(RateLimiter::Mode::kAllIo);
options_.rate_limiter.reset(test_limiter); options_.rate_limiter.reset(test_limiter);
...@@ -374,7 +372,7 @@ TEST_F(BlobGCJobTest, GCLimiter) { ...@@ -374,7 +372,7 @@ TEST_F(BlobGCJobTest, GCLimiter) {
RunGC(true); RunGC(true);
ASSERT_TRUE(test_limiter->WriteRequested()); ASSERT_TRUE(test_limiter->WriteRequested());
ASSERT_TRUE(test_limiter->ReadRequested()); ASSERT_TRUE(test_limiter->ReadRequested());
DestroyDB(); Close();
} }
TEST_F(BlobGCJobTest, Reopen) { TEST_F(BlobGCJobTest, Reopen) {
...@@ -397,8 +395,6 @@ TEST_F(BlobGCJobTest, Reopen) { ...@@ -397,8 +395,6 @@ TEST_F(BlobGCJobTest, Reopen) {
RunGC(false, true); RunGC(false, true);
CheckBlobNumber(1); CheckBlobNumber(1);
DestroyDB();
} }
// Tests blob file will be kept after GC, if it is still visible by active // Tests blob file will be kept after GC, if it is still visible by active
...@@ -456,8 +452,6 @@ TEST_F(BlobGCJobTest, PurgeBlobs) { ...@@ -456,8 +452,6 @@ TEST_F(BlobGCJobTest, PurgeBlobs) {
RunGC(false); RunGC(false);
CheckBlobNumber(1); CheckBlobNumber(1);
DestroyDB();
} }
TEST_F(BlobGCJobTest, DeleteFilesInRange) { TEST_F(BlobGCJobTest, DeleteFilesInRange) {
...@@ -549,8 +543,6 @@ TEST_F(BlobGCJobTest, DeleteFilesInRange) { ...@@ -549,8 +543,6 @@ TEST_F(BlobGCJobTest, DeleteFilesInRange) {
} }
ASSERT_OK(iter->status()); ASSERT_OK(iter->status());
delete iter; delete iter;
DestroyDB();
} }
TEST_F(BlobGCJobTest, LevelMergeGC) { TEST_F(BlobGCJobTest, LevelMergeGC) {
...@@ -602,8 +594,6 @@ TEST_F(BlobGCJobTest, LevelMergeGC) { ...@@ -602,8 +594,6 @@ TEST_F(BlobGCJobTest, LevelMergeGC) {
BlobFileMeta::FileState::kObsolete); BlobFileMeta::FileState::kObsolete);
ASSERT_EQ(b->FindFile(5).lock()->file_state(), ASSERT_EQ(b->FindFile(5).lock()->file_state(),
BlobFileMeta::FileState::kNormal); BlobFileMeta::FileState::kNormal);
DestroyDB();
} }
TEST_F(BlobGCJobTest, RangeMergeScheduler) { TEST_F(BlobGCJobTest, RangeMergeScheduler) {
...@@ -775,8 +765,6 @@ TEST_F(BlobGCJobTest, RangeMergeScheduler) { ...@@ -775,8 +765,6 @@ TEST_F(BlobGCJobTest, RangeMergeScheduler) {
files[i]->FileStateTransit(BlobFileMeta::FileEvent::kReset); files[i]->FileStateTransit(BlobFileMeta::FileEvent::kReset);
} }
} }
DestroyDB();
} }
TEST_F(BlobGCJobTest, RangeMerge) { TEST_F(BlobGCJobTest, RangeMerge) {
...@@ -827,8 +815,6 @@ TEST_F(BlobGCJobTest, RangeMerge) { ...@@ -827,8 +815,6 @@ TEST_F(BlobGCJobTest, RangeMerge) {
auto blob = b->FindFile(i).lock(); auto blob = b->FindFile(i).lock();
ASSERT_EQ(blob->file_state(), BlobFileMeta::FileState::kObsolete); ASSERT_EQ(blob->file_state(), BlobFileMeta::FileState::kObsolete);
} }
DestroyDB();
} }
} // namespace titandb } // namespace titandb
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment