提交 0b3b3955 编写于 作者: W wangyi.ywq 提交者: 奏之章

[feature] fix maybeScheduleCompaction and fix unit test #5

上级 a626723c
...@@ -807,7 +807,8 @@ void DBImpl::ScheduleGCTTL() { ...@@ -807,7 +807,8 @@ void DBImpl::ScheduleGCTTL() {
ROCKS_LOG_INFO(immutable_db_options_.info_log, "marked for compact SST: %d,%d", ROCKS_LOG_INFO(immutable_db_options_.info_log, "marked for compact SST: %d,%d",
marked_count,mark_count); marked_count,mark_count);
if (mark_count > 0) { if (mark_count > 0) {
// MaybeScheduleFlushOrCompaction(); InstrumentedMutexLock l(&mutex_);
MaybeScheduleFlushOrCompaction();
} }
} }
void DBImpl::DumpStats() { void DBImpl::DumpStats() {
......
...@@ -72,6 +72,7 @@ TEST_F(DBImplGCTTL_Test, L0FileExpiredTest) { ...@@ -72,6 +72,7 @@ TEST_F(DBImplGCTTL_Test, L0FileExpiredTest) {
dbfull()->TEST_WaitForTimedTaskRun([&] { mock_env->set_current_time(ttl); }); dbfull()->TEST_WaitForTimedTaskRun([&] { mock_env->set_current_time(ttl); });
ASSERT_TRUE(flag); ASSERT_TRUE(flag);
ASSERT_EQ(L0FilesNums,mark); ASSERT_EQ(L0FilesNums,mark);
dbfull()->TEST_WaitForCompact();
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册