Home
last modified time | relevance | path

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

/rocksdb-6.9/db/compaction/
Dcompaction_picker.cc448 const int input_level = inputs->level; in SetupOtherInputs() local
450 if (input_level == output_level) { in SetupOtherInputs()
457 for (int l = input_level + 1; l < output_level; l++) { in SetupOtherInputs()
493 expanded_inputs.level = input_level; in SetupOtherInputs()
539 cf_name.c_str(), input_level, inputs->size(), in SetupOtherInputs()
573 if (input_level == ColumnFamilyData::kCompactAllLevels) { in CompactRange()
645 inputs.level = input_level; in CompactRange()
671 if (input_level > 0) { in CompactRange()
692 assert(input_level == output_level); in CompactRange()
741 assert(input_level == 0); in CompactRange()
[all …]
Dcompaction.cc406 for (auto& input_level : inputs_) { in InputLevelSummary() local
407 if (input_level.empty()) { in InputLevelSummary()
418 "%" ROCKSDB_PRIszt "@%d", input_level.size(), in InputLevelSummary()
419 input_level.level); in InputLevelSummary()
430 for (auto& input_level : inputs_) { in CalculateTotalInputSize() local
431 for (auto f : input_level.files) { in CalculateTotalInputSize()
Dcompaction_picker_fifo.cc218 VersionStorageInfo* vstorage, int input_level, int output_level, in CompactRange() argument
224 (void)input_level; in CompactRange()
227 assert(input_level == 0); in CompactRange()
Dcompaction_job.cc1596 for (int input_level = 0; in UpdateCompactionStats() local
1597 input_level < static_cast<int>(compaction->num_input_levels()); in UpdateCompactionStats()
1598 ++input_level) { in UpdateCompactionStats()
1599 if (compaction->level(input_level) != compaction->output_level()) { in UpdateCompactionStats()
1602 &compaction_stats_.bytes_read_non_output_levels, input_level); in UpdateCompactionStats()
1606 &compaction_stats_.bytes_read_output_level, input_level); in UpdateCompactionStats()
1636 int input_level) { in UpdateCompactionInputStatsHelper() argument
1638 auto num_input_files = compaction->num_input_files(input_level); in UpdateCompactionInputStatsHelper()
1642 const auto* file_meta = compaction->input(input_level, i); in UpdateCompactionInputStatsHelper()
Dcompaction_picker_fifo.h29 VersionStorageInfo* vstorage, int input_level, int output_level,
Dcompaction_job.h141 int* num_files, uint64_t* bytes_read, int input_level);
Dcompaction_picker.h75 VersionStorageInfo* vstorage, int input_level, int output_level,
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc1423 ColumnFamilyData* cfd, int input_level, int output_level, in RunManualCompaction() argument
1427 assert(input_level == ColumnFamilyData::kCompactAllLevels || in RunManualCompaction()
1428 input_level >= 0); in RunManualCompaction()
1437 manual.input_level = input_level; in RunManualCompaction()
1513 *manual.cfd->GetLatestMutableCFOptions(), manual.input_level, in RunManualCompaction()
2551 m->cfd->GetName().c_str(), m->input_level, in BackgroundCompaction()
2571 m->cfd->GetName().c_str(), m->input_level, c->output_level(), in BackgroundCompaction()
Ddb_impl.h574 Status RunManualCompaction(ColumnFamilyData* cfd, int input_level,
1281 int input_level; member
/rocksdb-6.9/db/
Dcolumn_family.h415 int input_level, int output_level,
Dcolumn_family.cc1125 const MutableCFOptions& mutable_cf_options, int input_level, in CompactRange() argument
1131 GetName(), mutable_cf_options, current_->storage_info(), input_level, in CompactRange()