Home
last modified time | relevance | path

Searched refs:start_level (Results 1 – 11 of 11) sorted by relevance

/rocksdb-6.9/db/compaction/
Dcompaction_picker_universal.cc176 if (l == 0 && c->start_level() == 0) { in create_level_heap()
482 if (c->start_level() == 0) { in PickCompaction()
702 int start_level = sorted_runs_[start_index].level; in PickCompactionToReduceSortedRuns() local
721 inputs[i].level = start_level + static_cast<int>(i); in PickCompactionToReduceSortedRuns()
881 int start_level; in PickDeleteTriggeredCompaction() local
902 if (start_level == 0) { in PickDeleteTriggeredCompaction()
919 if (start_level == 0) { in PickDeleteTriggeredCompaction()
979 int start_level = sorted_runs_[start_index].level; in PickCompactionToOldest() local
1068 int start_level = sorted_runs_[start_index].level; in PickPeriodicCompaction() local
1072 if (start_level != 0) { in PickPeriodicCompaction()
[all …]
Dcompaction_picker.cc590 int start_level = 0; in CompactRange() local
591 for (; start_level < vstorage->num_levels() && in CompactRange()
592 vstorage->NumLevelFiles(start_level) == 0; in CompactRange()
593 start_level++) { in CompactRange()
595 if (start_level == vstorage->num_levels()) { in CompactRange()
608 inputs[level - start_level].level = level; in CompactRange()
1041 if (c->start_level() == 0 || in RegisterCompaction()
1052 if (c->start_level() == 0 || in UnregisterCompaction()
1071 *start_level = level_file.first; in PickFilesMarkedForCompaction()
1073 (*start_level == 0) ? vstorage->base_level() : *start_level + 1; in PickFilesMarkedForCompaction()
[all …]
Dcompaction_picker_test.cc107 void SetCompactionInputFilesLevels(int level_count, int start_level) { in SetCompactionInputFilesLevels() argument
110 input_files_[i].level = start_level + i; in SetCompactionInputFilesLevels()
112 compaction_level_start_ = start_level; in SetCompactionInputFilesLevels()
533 ASSERT_EQ(0, compaction->start_level()); in TEST_F()
617 compaction->start_level() != compaction->output_level()); in TEST_F()
637 ASSERT_EQ(0, compaction->start_level()); in TEST_F()
661 ASSERT_EQ(4, compaction->start_level()); in TEST_F()
Dcompaction_picker.h197 int* start_level, int* output_level,
Dcompaction.h95 int start_level() const { return start_level_; } in start_level() function
Dcompaction_job.cc363 (static_cast<uint64_t>(compact_->compaction->start_level()) << 32) + in ReportStartedCompaction()
443 int start_lvl = c->start_level(); in GenSubcompactionBoundaries()
/rocksdb-6.9/db/
Ddb_universal_compaction_test.cc2189 int start_level = -1; in TEST_F() local
2198 start_level = compaction->start_level(); in TEST_F()
2218 ASSERT_EQ(0, start_level); in TEST_F()
2236 ASSERT_EQ(0, start_level); in TEST_F()
Dversion_set.h1043 int start_level, int end_level,
Dversion_set.cc5284 const Slice& end, int start_level, in ApproximateSize() argument
5297 assert(start_level <= end_level); in ApproximateSize()
5318 for (int level = start_level; level < end_level; ++level) { in ApproximateSize()
5590 c->start_level() == 0 && c->num_input_levels() > 2U) { in VerifyCompactionFileConsistency()
5596 for (int l = c->start_level() + 1; l < c->output_level(); l++) { in VerifyCompactionFileConsistency()
Ddb_test.cc4693 if (compaction->output_level() == 4 && compaction->start_level() == 3) { in TEST_F()
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc1171 info.base_input_level = c->start_level(); in NotifyOnCompactionBegin()
3050 compaction_job_info->base_input_level = c->start_level(); in BuildCompactionJobInfo()