Home
last modified time | relevance | path

Searched refs:num_input_files (Results 1 – 12 of 12) sorted by relevance

/rocksdb-6.9/db/compaction/
Dcompaction_picker_test.cc167 ASSERT_EQ(2U, compaction->num_input_files(0)); in TEST_F()
180 ASSERT_EQ(1U, compaction->num_input_files(0)); in TEST_F()
198 ASSERT_EQ(1U, compaction->num_input_files(0)); in TEST_F()
199 ASSERT_EQ(2U, compaction->num_input_files(1)); in TEST_F()
229 ASSERT_EQ(1U, compaction->num_input_files(0)); in TEST_F()
276 ASSERT_EQ(2U, compaction->num_input_files(0)); in TEST_F()
300 ASSERT_EQ(2U, compaction->num_input_files(0)); in TEST_F()
325 ASSERT_EQ(2U, compaction->num_input_files(0)); in TEST_F()
354 ASSERT_EQ(2U, compaction->num_input_files(0)); in TEST_F()
357 ASSERT_EQ(2U, compaction->num_input_files(1)); in TEST_F()
[all …]
Dcompaction_job_stats_test.cc453 ASSERT_EQ(current_stats.num_input_files, in Verify()
454 stats.num_input_files); in Verify()
571 size_t num_input_files, size_t num_input_files_at_output_level, in NewManualCompactionJobStats() argument
580 stats.num_input_files = num_input_files; in NewManualCompactionJobStats()
588 num_input_records / num_input_files, in NewManualCompactionJobStats()
589 key_size, value_size, compression_ratio) * num_input_files; in NewManualCompactionJobStats()
Dcompaction_picker_universal.cc175 if (c->num_input_files(l) != 0) { in create_level_heap()
177 for (size_t i = 0; i < c->num_input_files(0); i++) { in create_level_heap()
251 curr.index < c->num_input_files(curr.level) - 1) { in IsInputFilesNonOverlapping()
493 if (c->num_input_files(level_index) != 0) { in PickCompaction()
Dcompaction_job_test.cc42 ASSERT_EQ(compaction_job_stats.num_input_files, 0U); in VerifyInitializationOfCompactionJobStats()
305 size_t num_input_files = 0; local
314 num_input_files += level_files.size();
349 ASSERT_EQ(compaction_job_stats_.num_input_files, num_input_files);
Dcompaction_job.cc1638 auto num_input_files = compaction->num_input_files(input_level); in UpdateCompactionInputStatsHelper() local
1639 *num_files += static_cast<int>(num_input_files); in UpdateCompactionInputStatsHelper()
1641 for (size_t i = 0; i < num_input_files; ++i) { in UpdateCompactionInputStatsHelper()
1659 compaction_job_stats_->num_input_files = in UpdateCompactionJobStats()
Dcompaction.h111 size_t num_input_files(size_t compaction_input_level) const { in num_input_files() function
/rocksdb-6.9/util/
Dcompaction_job_stats_impl.cc17 num_input_files = 0; in Reset()
55 num_input_files += stats.num_input_files; in Add()
/rocksdb-6.9/include/rocksdb/
Dcompaction_job_stats.h29 size_t num_input_files; member
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc2678 assert(c->num_input_files(1) == 0); in BackgroundCompaction()
2683 compaction_job_stats.num_input_files = c->num_input_files(0); in BackgroundCompaction()
2701 c->num_input_files(0)); in BackgroundCompaction()
2716 compaction_job_stats.num_input_files = c->num_input_files(0); in BackgroundCompaction()
2728 for (size_t i = 0; i < c->num_input_files(l); i++) { in BackgroundCompaction()
/rocksdb-6.9/java/rocksjni/
Dcompaction_job_stats.cc97 return static_cast<jlong>(compact_job_stats->num_input_files); in Java_org_rocksdb_CompactionJobStats_numInputFiles()
/rocksdb-6.9/file/
Dsst_file_manager_impl.cc95 for (size_t j = 0; j < c->num_input_files(i); j++) { in OnCompactionCompletion()
/rocksdb-6.9/db/
Dversion_set.cc5606 for (size_t i = 0; i < c->num_input_files(input); ++i) { in VerifyCompactionFileConsistency()