From 7322c740121e0858d5fb64a3b4641f401d1c5941 Mon Sep 17 00:00:00 2001 From: Yueh-Hsuan Chiang Date: Fri, 5 Jun 2015 11:23:09 -0700 Subject: [PATCH] Revert incorrect commit Summary: Revert incorrect commit Test Plan: db_test Reviewers: sdong, IslamAbdelRahman Reviewed By: IslamAbdelRahman Subscribers: dhruba, leveldb Differential Revision: https://reviews.facebook.net/D39651 --- db/db_impl.cc | 3 --- db/db_test.cc | 51 --------------------------------------------------- 2 files changed, 54 deletions(-) diff --git a/db/db_impl.cc b/db/db_impl.cc index 2fd97d6ba..39e6fb4d2 100644 --- a/db/db_impl.cc +++ b/db/db_impl.cc @@ -1735,9 +1735,6 @@ Status DBImpl::ReFitLevel(ColumnFamilyData* cfd, int level, int target_level) { to_level = FindMinimumEmptyLevelFitting(cfd, mutable_cf_options, level); } - printf("level %d, to_level %d\n", level, to_level); - assert(to_level <= level); - Status status; auto* vstorage = cfd->current()->storage_info(); if (to_level > level) { diff --git a/db/db_test.cc b/db/db_test.cc index d5613b397..f5b55fe97 100644 --- a/db/db_test.cc +++ b/db/db_test.cc @@ -13238,57 +13238,6 @@ TEST_F(DBTest, FlushesInParallelWithCompactRange) { rocksdb::SyncPoint::GetInstance()->DisableProcessing(); } } -TEST_F(DBTest, TrivialMoveTargetLevel) { - int32_t trivial_move = 0; - int32_t non_trivial_move = 0; -/* - rocksdb::SyncPoint::GetInstance()->SetCallBack( - "DBImpl::BackgroundCompaction:TrivialMove", - [&](void* arg) { trivial_move++;printf("trivial\n"); }); - rocksdb::SyncPoint::GetInstance()->SetCallBack( - "DBImpl::BackgroundCompaction:NonTrivial", - [&](void* arg) { non_trivial_move++;printf("non-trivial\n"); }); - rocksdb::SyncPoint::GetInstance()->EnableProcessing(); -*/ - Options options = CurrentOptions(); - options.disable_auto_compactions = true; - options.write_buffer_size = 10 * 1024 * 1024; - options.num_levels = 5; - - DestroyAndReopen(options); - int32_t value_size = 10 * 1024; // 10 KB - - // Add 2 non-overlapping files - Random rnd(301); - std::map values; - for (int32_t i = 0; i <= 100; i++) { - values[i] = RandomString(&rnd, value_size); - ASSERT_OK(Put(Key(i), values[i])); - } - ASSERT_OK(Flush()); - - for (int32_t i = 300; i <= 700; i++) { - values[i] = RandomString(&rnd, value_size); - ASSERT_OK(Put(Key(i), values[i])); - } - ASSERT_OK(Flush()); - - ASSERT_EQ("2", FilesPerLevel(0)); - printf("Compact\n"); - db_->CompactRange(db_->DefaultColumnFamily(), nullptr, nullptr, true, 1, 0); - printf("Done\n"); - ASSERT_EQ("0,0,0,2", FilesPerLevel(0)); - - ASSERT_EQ(trivial_move, 3); - ASSERT_EQ(non_trivial_move, 0); - - for (int32_t i = 0; i <= 100; i++) { - ASSERT_EQ(Get(Key(i)), values[i]); - } - for (int32_t i = 300; i <= 700; i++) { - ASSERT_EQ(Get(Key(i)), values[i]); - } -} } // namespace rocksdb -- GitLab