Home
last modified time | relevance | path

Searched refs:vstorage_ (Results 1 – 5 of 5) sorted by relevance

/rocksdb-6.9/db/compaction/
Dcompaction_picker_test.cc42 std::unique_ptr<VersionStorageInfo> vstorage_; member in ROCKSDB_NAMESPACE::CompactionPickerTest
59 vstorage_(nullptr) { in CompactionPickerTest()
82 vstorage_.reset(); in DeleteVersionStorage()
92 assert(level < vstorage_->num_levels()); in Add()
102 vstorage_->AddFile(level, f); in Add()
119 assert(level < vstorage_->num_levels()); in AddToCompactionFiles()
127 vstorage_->UpdateNumNonEmptyLevels(); in UpdateVersionStorageInfo()
128 vstorage_->GenerateFileIndexer(); in UpdateVersionStorageInfo()
129 vstorage_->GenerateLevelFilesBrief(); in UpdateVersionStorageInfo()
131 vstorage_->GenerateLevel0NonOverlapping(); in UpdateVersionStorageInfo()
[all …]
Dcompaction_picker_level.cc54 vstorage_(vstorage), in LevelCompactionBuilder()
101 VersionStorageInfo* vstorage_; member in ROCKSDB_NAMESPACE::__anon867945220111::LevelCompactionBuilder
128 if (vstorage_->ExpiredTtlFiles().empty()) { in PickExpiredTtlFiles()
153 for (auto& level_file : vstorage_->ExpiredTtlFiles()) { in PickExpiredTtlFiles()
200 start_level_score_ = vstorage_->CompactionScore(i); in SetupInitialFiles()
201 start_level_ = vstorage_->CompactionScoreLevel(i); in SetupInitialFiles()
250 cf_name_, vstorage_, &start_level_, &output_level_, in SetupInitialFiles()
475 vstorage_->FilesByCompactionPri(start_level_); in PickFileToCompact()
477 vstorage_->LevelFiles(start_level_); in PickFileToCompact()
526 vstorage_->SetNextCompactionIndex(start_level_, cmp_idx); in PickFileToCompact()
[all …]
Dcompaction_picker_universal.cc45 vstorage_(vstorage), in UniversalCompactionBuilder()
118 VersionStorageInfo* vstorage_; member in ROCKSDB_NAMESPACE::__anon109b84230111::UniversalCompactionBuilder
374 score_ = vstorage_->CompactionScore(kLevel0); in PickCompaction()
380 vstorage_->FilesMarkedForCompaction().empty() && in PickCompaction()
705 output_level = vstorage_->num_levels() - 1; in PickCompactionToReduceSortedRuns()
714 (output_level == vstorage_->num_levels() - 1)) { in PickCompactionToReduceSortedRuns()
857 if (vstorage_->num_levels() == 1) { in PickDeleteTriggeredCompaction()
867 for (FileMetaData* f : vstorage_->LevelFiles(0)) { in PickDeleteTriggeredCompaction()
901 if (output_level == vstorage_->num_levels()) { in PickDeleteTriggeredCompaction()
903 output_level = vstorage_->num_levels() - 1; in PickDeleteTriggeredCompaction()
[all …]
/rocksdb-6.9/db/
Dversion_builder_test.cc25 VersionStorageInfo vstorage_; member in ROCKSDB_NAMESPACE::VersionBuilderTest
44 for (auto* f : vstorage_.LevelFiles(i)) { in ~VersionBuilderTest()
64 assert(level < vstorage_.num_levels()); in Add()
74 vstorage_.AddFile(level, f); in Add()
77 vstorage_.UpdateAccumulatedStats(f); in Add()
91 vstorage_.AddBlobFile(std::move(meta)); in AddBlob()
111 vstorage_.UpdateNumNonEmptyLevels(); in UpdateVersionStorageInfo()
112 vstorage_.GenerateFileIndexer(); in UpdateVersionStorageInfo()
113 vstorage_.GenerateLevelFilesBrief(); in UpdateVersionStorageInfo()
115 vstorage_.GenerateLevel0NonOverlapping(); in UpdateVersionStorageInfo()
[all …]
Dversion_set_test.cc107 VersionStorageInfo vstorage_; member in ROCKSDB_NAMESPACE::VersionStorageInfoTest
143 vstorage_.AddFile(level, f); in Add()
156 vstorage_.AddFile(level, f); in Add()
199 ASSERT_EQ(vstorage_.base_level(), 5); in TEST_F()
205 ASSERT_EQ(vstorage_.base_level(), 4); in TEST_F()
211 ASSERT_EQ(vstorage_.base_level(), 4); in TEST_F()
219 ASSERT_EQ(vstorage_.base_level(), 3); in TEST_F()
230 ASSERT_EQ(vstorage_.base_level(), 1); in TEST_F()
249 ASSERT_EQ(vstorage_.base_level(), 1); in TEST_F()
392 vstorage_.UpdateNumNonEmptyLevels(); in TEST_F()
[all …]