diff --git a/db/db_impl.cc b/db/db_impl.cc index 5526b7261686c7b1ebe78acaa502645be0338a76..75cc1b060c6d553ffbee3898301953450ae7e93e 100644 --- a/db/db_impl.cc +++ b/db/db_impl.cc @@ -807,7 +807,8 @@ void DBImpl::ScheduleGCTTL() { ROCKS_LOG_INFO(immutable_db_options_.info_log, "marked for compact SST: %d,%d", marked_count,mark_count); if (mark_count > 0) { -// MaybeScheduleFlushOrCompaction(); + InstrumentedMutexLock l(&mutex_); + MaybeScheduleFlushOrCompaction(); } } void DBImpl::DumpStats() { diff --git a/db/db_impl_gc_ttl_test.cc b/db/db_impl_gc_ttl_test.cc index 2ff60738ee2631eb1b917dd8890478eeb3b82b6e..e3cfc1002910e4fa803023317f424b206e28f488 100644 --- a/db/db_impl_gc_ttl_test.cc +++ b/db/db_impl_gc_ttl_test.cc @@ -72,6 +72,7 @@ TEST_F(DBImplGCTTL_Test, L0FileExpiredTest) { dbfull()->TEST_WaitForTimedTaskRun([&] { mock_env->set_current_time(ttl); }); ASSERT_TRUE(flag); ASSERT_EQ(L0FilesNums,mark); + dbfull()->TEST_WaitForCompact(); }