@@ -3300,7 +3300,6 @@ TEST_F(DBCompactionTest, WaitForCompactWaitsOnCompactionToFinish) {
33003300
33013301 Options options = CurrentOptions ();
33023302 options.level0_file_num_compaction_trigger = kNumFiles + 1 ;
3303- options.max_background_compactions = 1 ;
33043303
33053304 DestroyAndReopen (options);
33063305
@@ -3326,21 +3325,12 @@ TEST_F(DBCompactionTest, WaitForCompactWaitsOnCompactionToFinish) {
33263325 }
33273326 ASSERT_OK (dbfull ()->WaitForCompact (WaitForCompactOptions ()));
33283327 ASSERT_EQ (" 2" , FilesPerLevel ());
3329- // There has been no compaction. Only flushes from memtable.
33303328 ASSERT_EQ (0 , compaction_finished);
33313329
3332- ROCKSDB_NAMESPACE::SyncPoint::GetInstance ()->LoadDependency (
3333- {{" CompactionJob::Run():Start" ,
3334- " DBCompactionTest::WaitForCompactWaitsOnCompactionToFinish" }});
3335-
3336- // Now trigger L0 compaction by adding a file
3330+ // create compaction debt by adding one more L0 file then closing
33373331 GenerateNewRandomFile (&rnd, /* nowait */ true );
3338- ASSERT_OK (Flush ());
3339-
3340- // Before compaction job finishes, close the db.
33413332 Close ();
33423333 ASSERT_EQ (0 , compaction_finished);
3343- TEST_SYNC_POINT (" DBCompactionTest::WaitForCompactWaitsOnCompactionToFinish" );
33443334
33453335 // Reopen the db and we expect the compaction to be triggered.
33463336 Reopen (options);
@@ -3378,27 +3368,18 @@ TEST_F(DBCompactionTest, WaitForCompactAbortOnPauseAborted) {
33783368 }
33793369 ASSERT_OK (dbfull ()->WaitForCompact (WaitForCompactOptions ()));
33803370
3381- ROCKSDB_NAMESPACE::SyncPoint::GetInstance ()->LoadDependency (
3382- {{" CompactionJob::Run():Start" ,
3383- " DBCompactionTest::WaitForCompactAbortOnPauseAborted" }});
3384- ROCKSDB_NAMESPACE::SyncPoint::GetInstance ()->EnableProcessing ();
3385-
33863371 // Now trigger L0 compaction by adding a file
33873372 GenerateNewRandomFile (&rnd, /* nowait */ true );
33883373 ASSERT_OK (Flush ());
33893374
33903375 // Pause the background jobs.
33913376 ASSERT_OK (dbfull ()->PauseBackgroundWork ());
33923377
3393- TEST_SYNC_POINT (" DBCompactionTest::WaitForCompactAbortOnPauseAborted" );
3394-
33953378 WaitForCompactOptions waitForCompactOptions = WaitForCompactOptions ();
33963379 waitForCompactOptions.abort_on_pause = true ;
33973380 Status s = dbfull ()->WaitForCompact (waitForCompactOptions);
33983381 ASSERT_NOK (s);
33993382 ASSERT_TRUE (s.IsAborted ());
3400-
3401- ROCKSDB_NAMESPACE::SyncPoint::GetInstance ()->DisableProcessing ();
34023383}
34033384
34043385TEST_F (DBCompactionTest, WaitForCompactContinueAfterPauseNotAborted) {
@@ -3426,29 +3407,19 @@ TEST_F(DBCompactionTest, WaitForCompactContinueAfterPauseNotAborted) {
34263407 }
34273408 ASSERT_OK (dbfull ()->WaitForCompact (WaitForCompactOptions ()));
34283409
3429- ROCKSDB_NAMESPACE::SyncPoint::GetInstance ()->LoadDependency (
3430- {{" CompactionJob::Run():Start" ,
3431- " DBCompactionTest::WaitForCompactContinueAfterPauseNotAborted" }});
3432- ROCKSDB_NAMESPACE::SyncPoint::GetInstance ()->EnableProcessing ();
3433-
34343410 // Now trigger L0 compaction by adding a file
34353411 GenerateNewRandomFile (&rnd, /* nowait */ true );
34363412 ASSERT_OK (Flush ());
34373413
34383414 // Pause the background jobs.
34393415 ASSERT_OK (dbfull ()->PauseBackgroundWork ());
34403416
3441- TEST_SYNC_POINT (
3442- " DBCompactionTest::WaitForCompactContinueAfterPauseNotAborted" );
3443-
34443417 // Continue the background jobs.
34453418 ASSERT_OK (dbfull ()->ContinueBackgroundWork ());
34463419
34473420 WaitForCompactOptions waitForCompactOptions = WaitForCompactOptions ();
34483421 waitForCompactOptions.abort_on_pause = false ;
34493422 ASSERT_OK (dbfull ()->WaitForCompact (waitForCompactOptions));
3450-
3451- ROCKSDB_NAMESPACE::SyncPoint::GetInstance ()->DisableProcessing ();
34523423}
34533424
34543425TEST_F (DBCompactionTest, WaitForCompactShutdownWhileWaiting) {
@@ -3477,8 +3448,8 @@ TEST_F(DBCompactionTest, WaitForCompactShutdownWhileWaiting) {
34773448 ASSERT_OK (dbfull ()->WaitForCompact (WaitForCompactOptions ()));
34783449
34793450 ROCKSDB_NAMESPACE::SyncPoint::GetInstance ()->LoadDependency (
3480- {{" CompactionJob::Run():Start " ,
3481- " DBCompactionTest::WaitForCompactShutdownWhileWaiting " }});
3451+ {{" DBCompactionTest::WaitForCompactShutdownWhileWaiting " ,
3452+ " CompactionJob::Run():Start " }});
34823453 ROCKSDB_NAMESPACE::SyncPoint::GetInstance ()->EnableProcessing ();
34833454
34843455 // Now trigger L0 compaction by adding a file
0 commit comments