Home
last modified time | relevance | path

Searched refs:num_levels (Results 1 – 25 of 69) sorted by relevance

123

/rocksdb-6.9/db/compaction/
Dcompaction_picker_test.cc75 options_.num_levels = num_levels; in NewVersionStorage()
262 int num_levels = ioptions_.num_levels; in TEST_F() local
284 int num_levels = ioptions_.num_levels; in TEST_F() local
308 int num_levels = ioptions_.num_levels; in TEST_F() local
333 int num_levels = ioptions_.num_levels; in TEST_F() local
366 int num_levels = ioptions_.num_levels; in TEST_F() local
817 int num_levels = ioptions_.num_levels; in TEST_F() local
1234 int num_levels = ioptions_.num_levels; in TEST_F() local
1267 int num_levels = ioptions_.num_levels; in TEST_F() local
1294 int num_levels = ioptions_.num_levels; in TEST_F() local
[all …]
Dcompaction_picker_universal.cc335 for (int level = 1; level < vstorage.num_levels(); level++) { in CalculateSortedRuns()
705 output_level = vstorage_->num_levels() - 1; in PickCompactionToReduceSortedRuns()
714 (output_level == vstorage_->num_levels() - 1)) { in PickCompactionToReduceSortedRuns()
719 std::vector<CompactionInputFiles> inputs(vstorage_->num_levels()); in PickCompactionToReduceSortedRuns()
857 if (vstorage_->num_levels() == 1) { in PickDeleteTriggeredCompaction()
893 for (output_level = start_level + 1; output_level < vstorage_->num_levels(); in PickDeleteTriggeredCompaction()
901 if (output_level == vstorage_->num_levels()) { in PickDeleteTriggeredCompaction()
903 output_level = vstorage_->num_levels() - 1; in PickDeleteTriggeredCompaction()
913 output_level == vstorage_->num_levels() - 1) { in PickDeleteTriggeredCompaction()
981 std::vector<CompactionInputFiles> inputs(vstorage_->num_levels()); in PickCompactionToOldest()
[all …]
Dcompaction_picker.cc380 matched_input_files.resize(vstorage->num_levels()); in GetCompactionInputsFromFileNumbers()
385 for (int level = 0; level < vstorage->num_levels(); ++level) { in GetCompactionInputsFromFileNumbers()
578 assert(vstorage->num_levels() > 1); in CompactRange()
581 assert(output_level == vstorage->num_levels() - 2); in CompactRange()
583 assert(output_level == vstorage->num_levels() - 1); in CompactRange()
591 for (; start_level < vstorage->num_levels() && in CompactRange()
595 if (start_level == vstorage->num_levels()) { in CompactRange()
605 std::vector<CompactionInputFiles> inputs(vstorage->num_levels() - in CompactRange()
607 for (int level = start_level; level < vstorage->num_levels(); level++) { in CompactRange()
/rocksdb-6.9/utilities/option_change_migration/
Doption_change_migration.cc81 if (old_opts.num_levels <= new_opts.num_levels || in MigrateToUniversal()
96 metadata.levels.back().level >= new_opts.num_levels) { in MigrateToUniversal()
101 return CompactToLevel(old_opts, dbname, new_opts.num_levels - 1, true); in MigrateToUniversal()
110 if (old_opts.num_levels == 1) { in MigrateToLevelBase()
126 if (old_opts.num_levels == 1) { in MigrateToLevelBase()
128 } else if (new_opts.num_levels > old_opts.num_levels) { in MigrateToLevelBase()
130 return CompactToLevel(new_opts, dbname, new_opts.num_levels - 1, false); in MigrateToLevelBase()
134 return CompactToLevel(opts, dbname, new_opts.num_levels - 1, true); in MigrateToLevelBase()
Doption_change_migration_test.cc58 old_options.num_levels = level1_; in TEST_P()
92 new_options.num_levels = level2_; in TEST_P()
126 old_options.num_levels = level2_; in TEST_P()
161 new_options.num_levels = level1_; in TEST_P()
195 old_options.num_levels = level1_; in TEST_P()
235 new_options.num_levels = level2_; in TEST_P()
269 old_options.num_levels = level2_; in TEST_P()
310 new_options.num_levels = level1_; in TEST_P()
365 old_options.num_levels = 4; in TEST_F()
396 new_options.num_levels = 1; in TEST_F()
/rocksdb-6.9/db/
Dversion_builder_test.cc35 vstorage_(&icmp_, ucmp_, options_.num_levels, kCompactionStyleLevel, in VersionBuilderTest()
39 size_being_compacted_.resize(options_.num_levels); in VersionBuilderTest()
43 for (int i = 0; i < vstorage_.num_levels(); i++) { in ~VersionBuilderTest()
64 assert(level < vstorage_.num_levels()); in Add()
121 for (int i = 0; i < new_vstorage->num_levels(); i++) { in UnrefFilesInVersion()
158 VersionStorageInfo new_vstorage(&icmp_, ucmp_, options_.num_levels, in TEST_F()
196 VersionStorageInfo new_vstorage(&icmp_, ucmp_, options_.num_levels, in TEST_F()
239 VersionStorageInfo new_vstorage(&icmp_, ucmp_, options_.num_levels, in TEST_F()
285 VersionStorageInfo new_vstorage(&icmp_, ucmp_, options_.num_levels, in TEST_F()
300 VersionStorageInfo new_vstorage(&icmp_, ucmp_, options_.num_levels, in TEST_F()
[all …]
Ddb_universal_compaction_test.cc386 options.num_levels = 1; in TEST_P()
466 options.num_levels = 1; in TEST_P()
570 options.num_levels = 1; in TEST_P()
635 options.num_levels = 7; in TEST_P()
722 options.num_levels = 3; in TEST_P()
1179 options.num_levels = 2; in TEST_P()
1267 options.num_levels = 1; in TEST_P()
1369 options.num_levels = 1; in TEST_P()
1524 options.num_levels = 1; in TEST_P()
1967 opts.num_levels = 1; in TEST_F()
[all …]
Dfile_indexer.cc75 void FileIndexer::UpdateIndex(Arena* arena, const size_t num_levels, in UpdateIndex() argument
80 if (num_levels == 0) { // uint_32 0-1 would cause bad behavior in UpdateIndex()
81 num_levels_ = num_levels; in UpdateIndex()
86 num_levels_ = num_levels; in UpdateIndex()
87 next_level_index_.resize(num_levels); in UpdateIndex()
Ddb_dynamic_level_test.cc71 options.num_levels = 5; in TEST_F()
140 options.num_levels = 5; in TEST_F()
293 options.num_levels = kNumLevels; in TEST_F()
370 options.num_levels = 5; in TEST_F()
421 options.num_levels = 8; in TEST_F()
463 compact_options.target_level = options.num_levels - 1; in TEST_F()
Dcolumn_family_test.cc1340 one.num_levels = 1; in TEST_P()
1346 two.num_levels = 4; in TEST_P()
1412 one.num_levels = 1; in TEST_P()
1418 two.num_levels = 4; in TEST_P()
1512 one.num_levels = 1; in TEST_P()
1518 two.num_levels = 4; in TEST_P()
1608 one.num_levels = 1; in TEST_P()
1614 two.num_levels = 4; in TEST_P()
1707 one.num_levels = 1; in TEST_P()
1809 one.num_levels = 1; in TEST_P()
[all …]
Ddb_compaction_test.cc329 options.num_levels = 2; in TEST_P()
726 options.num_levels = 3; in TEST_P()
770 options.num_levels = 3; in TEST_F()
1259 options.num_levels = 7; in TEST_P()
1337 options.num_levels = 7; in TEST_P()
1478 options.num_levels = 4; in TEST_F()
1610 options.num_levels = 4; in TEST_F()
1731 options.num_levels = 4; in TEST_F()
1969 options.num_levels = 4; in TEST_P()
4800 opts.num_levels = 3; in TEST_F()
[all …]
Dversion_set.cc118 : num_levels_(num_levels), in FilePicker()
361 : num_levels_(num_levels), in FilePickerMultiGet()
2226 return num_levels() - 2; in MaxInputLevel()
2233 assert(num_levels() > 1); in MaxOutputLevel()
2234 return num_levels() - 2; in MaxOutputLevel()
2236 return num_levels() - 1; in MaxOutputLevel()
2429 for (int i = 0; i < num_levels() - 2; i++) { in ComputeCompactionScore()
3105 assert(level < num_levels()); in NumLevelBytes()
3123 for (int i = 0; i < num_levels(); i++) { in LevelSummary()
3200 for (int i = 1; i < num_levels(); i++) { in CalculateBaseBytes()
[all …]
Dcolumn_family.cc217 if (result.num_levels < 1) { in SanitizeOptions()
218 result.num_levels = 1; in SanitizeOptions()
221 result.num_levels < 2) { in SanitizeOptions()
222 result.num_levels = 2; in SanitizeOptions()
226 db_options.allow_ingest_behind && result.num_levels < 3) { in SanitizeOptions()
227 result.num_levels = 3; in SanitizeOptions()
260 result.num_levels = 1; in SanitizeOptions()
546 new InternalStats(ioptions_.num_levels, db_options.env, this)); in ColumnFamilyData()
Ddb_range_del_test.cc96 options.num_levels = 2; in TEST_F()
294 opts.num_levels = 2; in TEST_F()
349 options.num_levels = 3; in TEST_F()
408 options.num_levels = kNumLevels; in TEST_F()
462 opts.num_levels = 2; in TEST_F()
533 opts.num_levels = 2; in TEST_F()
585 opts.num_levels = 2; in TEST_F()
879 options.num_levels = 2; in TEST_F()
1258 options.num_levels = 2; in TEST_F()
Dexternal_sst_file_basic_test.cc842 options.num_levels = kNumLevels; in TEST_P()
877 ASSERT_EQ(1, NumTableFilesAtLevel(options.num_levels - 1)); in TEST_P()
888 ASSERT_EQ(1, NumTableFilesAtLevel(options.num_levels - 1)); in TEST_P()
898 ASSERT_EQ(1, NumTableFilesAtLevel(options.num_levels - 2)); in TEST_P()
899 ASSERT_EQ(1, NumTableFilesAtLevel(options.num_levels - 1)); in TEST_P()
911 ASSERT_EQ(1, NumTableFilesAtLevel(options.num_levels - 1)); in TEST_P()
925 ASSERT_EQ(2, NumTableFilesAtLevel(options.num_levels - 1)); in TEST_P()
Dforward_iterator.cc431 for (int32_t level = 1; level < vstorage->num_levels(); ++level) { in SeekInternal()
763 level_iters_.reserve(vstorage->num_levels() - 1); in BuildLevelIterators()
764 for (int32_t level = 1; level < vstorage->num_levels(); ++level) { in BuildLevelIterators()
895 for (int32_t level = 1; level < vstorage->num_levels(); ++level) { in DeleteCurrentIter()
924 for (int32_t level = 1; level < vstorage->num_levels(); ++level) { in TEST_CheckDeletedIters()
Dinternal_stats.h123 InternalStats(int num_levels, Env* env, ColumnFamilyData* cfd) in InternalStats() argument
127 comp_stats_(num_levels),
129 file_read_latency_(num_levels),
131 number_levels_(num_levels),
/rocksdb-6.9/options/
Doptions.cc59 num_levels(options.num_levels), in AdvancedColumnFamilyOptions()
93 static_cast<unsigned int>(num_levels)) { in AdvancedColumnFamilyOptions()
94 max_bytes_for_level_multiplier_additional.resize(num_levels, 1); in AdvancedColumnFamilyOptions()
158 ROCKS_LOG_HEADER(log, " Options.num_levels: %d", num_levels); in Dump()
395 num_levels = 2; in PrepareForBulkLoad()
546 compression_per_level.resize(num_levels); in OptimizeLevelStyleCompaction()
547 for (int i = 0; i < num_levels; ++i) { in OptimizeLevelStyleCompaction()
Dcf_options.cc69 num_levels(cf_options.num_levels), in ImmutableCFOptions()
112 void MutableCFOptions::RefreshDerivedOptions(int num_levels, in RefreshDerivedOptions() argument
114 max_file_size.resize(num_levels); in RefreshDerivedOptions()
115 for (int i = 0; i < num_levels; ++i) { in RefreshDerivedOptions()
Dcf_options.h105 int num_levels; member
170 RefreshDerivedOptions(options.num_levels, options.compaction_style); in MutableCFOptions()
206 void RefreshDerivedOptions(int num_levels, CompactionStyle compaction_style);
209 RefreshDerivedOptions(ioptions.num_levels, ioptions.compaction_style); in RefreshDerivedOptions()
/rocksdb-6.9/tools/
Dreduce_levels_test.cc82 Status ReduceLevelTest::OpenDB(bool create_if_missing, int num_levels) { in OpenDB() argument
84 opt.num_levels = num_levels; in OpenDB()
Ddb_bench_tool_test.cc127 opt.num_levels = 1; in TEST_F()
150 opt.num_levels = 12; in TEST_F()
/rocksdb-6.9/tools/advisor/test/input_files/
DOPTIONS-00000526 num_levels=7
42 num_levels=5
/rocksdb-6.9/include/rocksdb/
Dadvanced_options.h380 int num_levels = 7; member
512 std::vector<int>(num_levels, 1);
/rocksdb-6.9/test_util/
Dtestutil.cc343 cf_opt->num_levels = rnd->Uniform(100); in RandomInitCFOptions()
347 cf_opt->max_bytes_for_level_multiplier_additional.resize(cf_opt->num_levels); in RandomInitCFOptions()
348 for (int i = 0; i < cf_opt->num_levels; i++) { in RandomInitCFOptions()
391 RandomCompressionTypeVector(cf_opt->num_levels, in RandomInitCFOptions()

123