Home
last modified time | relevance | path

Searched refs:output_level (Results 1 – 25 of 33) sorted by relevance

12

/rocksdb-6.9/db/compaction/
Dcompaction_picker.cc289 if (c->output_level() == level && in RangeOverlapWithCompaction()
450 if (input_level == output_level) { in SetupOtherInputs()
630 output_level, in CompactRange()
692 assert(input_level == output_level); in CompactRange()
743 assert(output_level > 0); in CompactRange()
746 if (input_level != output_level) { in CompactRange()
782 output_level, in CompactRange()
899 } else if (output_level > 0) { in SanitizeCompactionInputFilesForAllLevels()
987 if (output_level < 0) { in SanitizeCompactionInputFiles()
1039 c->output_level() == 0 || in RegisterCompaction()
[all …]
Dcompaction_picker_universal.cc703 int output_level; in PickCompactionToReduceSortedRuns() local
707 output_level = 0; in PickCompactionToReduceSortedRuns()
716 output_level--; in PickCompactionToReduceSortedRuns()
748 output_level, in PickCompactionToReduceSortedRuns()
854 int output_level; in PickDeleteTriggeredCompaction() local
866 output_level = 0; in PickDeleteTriggeredCompaction()
893 for (output_level = start_level + 1; output_level < vstorage_->num_levels(); in PickDeleteTriggeredCompaction()
915 output_level--; in PickDeleteTriggeredCompaction()
956 output_level, in PickDeleteTriggeredCompaction()
1018 output_level--; in PickCompactionToOldest()
[all …]
Dcompaction_picker.h75 VersionStorageInfo* vstorage, int input_level, int output_level,
95 const int output_level) const;
114 int output_level, VersionStorageInfo* vstorage,
197 int* start_level, int* output_level,
202 int output_level, int* parent_index);
225 const ColumnFamilyMetaData& cf_meta, const int output_level) const;
Dcompaction.cc162 int output_level, VersionStorageInfo* vstorage, in IsBottommostLevel() argument
165 if (output_level == 0) { in IsBottommostLevel()
180 output_level, output_l0_idx); in IsBottommostLevel()
186 int output_level, VersionStorageInfo* vstorage, in TEST_IsBottommostLevel() argument
188 return IsBottommostLevel(output_level, vstorage, inputs); in TEST_IsBottommostLevel()
423 " files to L%d", output_level()); in InputLevelSummary()
504 output_level() > 0)) { in OutputFilePreallocationSize()
Dcompaction.h74 std::vector<CompactionInputFiles> inputs, int output_level,
98 int output_level() const { return output_level_; } in output_level() function
267 int output_level, VersionStorageInfo* vstorage,
315 int output_level, VersionStorageInfo* vstorage,
Dcompaction_picker_test.cc280 ASSERT_EQ(num_levels - 1, compaction->output_level()); in TEST_F()
304 ASSERT_EQ(num_levels - 2, compaction->output_level()); in TEST_F()
329 ASSERT_EQ(num_levels - 3, compaction->output_level()); in TEST_F()
362 ASSERT_EQ(num_levels - 3, compaction->output_level()); in TEST_F()
444 ASSERT_EQ(1, compaction->output_level()); in TEST_F()
532 ASSERT_EQ(4, compaction->output_level()); in TEST_F()
640 ASSERT_EQ(4, compaction->output_level()); in TEST_F()
665 ASSERT_EQ(4, compaction->output_level()); in TEST_F()
1671 ASSERT_EQ(0, compaction->output_level()); in TEST_F()
1701 ASSERT_EQ(0, compaction->output_level()); in TEST_F()
[all …]
Dcompaction_job.cc364 compact_->compaction->output_level()); in ReportStartedCompaction()
408 c->column_family_data()->CalculateSSTWriteHint(c->output_level()); in Prepare()
444 int out_lvl = c->output_level(); in GenSubcompactionBoundaries()
654 compact_->compaction->output_level()), in Run()
760 bytes_written_per_sec, compact_->compaction->output_level(), in Install()
778 << compact_->compaction->output_level() << "num_output_files" in Install()
902 if (c_iter->Valid() && sub_compact->compaction->output_level() != 0) { in ProcessKeyValueCompaction()
956 if (sub_compact->compaction->output_level() != 0 && in ProcessKeyValueCompaction()
973 sub_compact->compaction->output_level() != 0 && in ProcessKeyValueCompaction()
1551 sub_compact->compaction->output_level(), skip_filters, in OpenCompactionOutputFile()
[all …]
Dcompaction_picker_fifo.cc218 VersionStorageInfo* vstorage, int input_level, int output_level, in CompactRange() argument
225 (void)output_level; in CompactRange()
228 assert(output_level == 0); in CompactRange()
Dcompaction_picker_fifo.h29 VersionStorageInfo* vstorage, int input_level, int output_level,
Dcompaction_job_test.cc301 int output_level = 1, bool verify = true, argument
319 compaction_input_files, output_level, 1024 * 1024,
358 cfd->current()->storage_info()->LevelFiles(output_level);
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc773 int output_level; in CompactRange() local
782 output_level = level; in CompactRange()
796 output_level = level; in CompactRange()
802 output_level = level + 1; in CompactRange()
860 (void)output_level; in CompactFiles()
967 &input_set, cf_meta, output_level); in CompactFilesImpl()
1172 info.output_level = c->output_level(); in NotifyOnCompactionBegin()
1438 manual.output_level = output_level; in RunManualCompaction()
2782 c->output_level() == in BackgroundCompaction()
2807 output_level = c->output_level(); in BackgroundCompaction()
[all …]
Ddb_impl_debug.cc94 int output_level = in TEST_CompactRange() local
99 return RunManualCompaction(cfd, level, output_level, CompactRangeOptions(), in TEST_CompactRange()
Ddb_impl.h297 const std::vector<std::string>& input_file_names, const int output_level,
575 int output_level,
1282 int output_level; member
1532 const int output_level, int output_path_id,
/rocksdb-6.9/examples/
Dcompact_files_example.cc48 output_level(_output_level), in CompactionTask()
55 int output_level; member
118 task->output_level); in CompactFiles()
/rocksdb-6.9/utilities/blob_db/
Dblob_db.h211 const std::vector<std::string>& input_file_names, const int output_level,
218 const std::vector<std::string>& input_file_names, const int output_level,
227 return CompactFiles(compact_options, input_file_names, output_level,
Dblob_db_impl.h143 const std::vector<std::string>& input_file_names, const int output_level,
/rocksdb-6.9/db/
Ddb_universal_compaction_test.cc714 int output_level = *(static_cast<int*>(arg)); in TEST_P() local
715 ASSERT_EQ(output_level, 0); in TEST_P()
1171 int output_level = *(static_cast<int*>(arg)); in TEST_P() local
1172 ASSERT_EQ(output_level, 0); in TEST_P()
1216 int output_level = *(static_cast<int*>(arg)); in TEST_P() local
1217 ASSERT_EQ(output_level, 0); in TEST_P()
2190 int output_level = -1; in TEST_F() local
2199 output_level = compaction->output_level(); in TEST_F()
2219 ASSERT_EQ(4, output_level); in TEST_F()
2237 ASSERT_EQ(4, output_level); in TEST_F()
Dlistener_test.cc117 ASSERT_GT(files_by_level.size(), ci.output_level); in OnCompactionCompleted()
120 ASSERT_EQ(ci.output_file_infos[i].level, ci.output_level); in OnCompactionCompleted()
125 files_by_level[ci.output_level].begin(), in OnCompactionCompleted()
126 files_by_level[ci.output_level].end(), [&](const FileMetaData& meta) { in OnCompactionCompleted()
129 ASSERT_NE(it, files_by_level[ci.output_level].end()); in OnCompactionCompleted()
Dcompact_files_test.cc399 ASSERT_EQ(compaction_job_info.output_level, 0); in TEST_F()
Dcolumn_family.h415 int input_level, int output_level,
Ddb_dynamic_level_test.cc339 output_levels.insert(compaction->output_level()); in TEST_F()
/rocksdb-6.9/java/rocksjni/
Dcompaction_job_info.cc107 return static_cast<jint>(compact_job_info->output_level); in Java_org_rocksdb_CompactionJobInfo_outputLevel()
/rocksdb-6.9/include/rocksdb/utilities/
Dstackable_db.h253 const std::vector<std::string>& input_file_names, const int output_level,
258 output_level, output_path_id, output_file_names,
/rocksdb-6.9/include/rocksdb/
Dlistener.h226 int output_level; member
Ddb.h1124 const std::vector<std::string>& input_file_names, const int output_level,
1131 const std::vector<std::string>& input_file_names, const int output_level,
1136 input_file_names, output_level, output_path_id,

12