Home
last modified time | relevance | path

Searched refs:lvl (Results 1 – 4 of 4) sorted by relevance

/rocksdb-6.9/db/
Dexternal_sst_file_ingestion_job.cc547 for (int lvl = 0; lvl < cfd_->NumberLevels(); lvl++) { in AssignLevelAndSeqnoForIngestedFile() local
548 if (lvl > 0 && lvl < vstorage->base_level()) { in AssignLevelAndSeqnoForIngestedFile()
552 if (vstorage->NumLevelFiles(lvl) > 0) { in AssignLevelAndSeqnoForIngestedFile()
556 file_to_ingest->largest_internal_key.user_key(), lvl, in AssignLevelAndSeqnoForIngestedFile()
569 if (compaction_style == kCompactionStyleUniversal && lvl != 0) { in AssignLevelAndSeqnoForIngestedFile()
571 vstorage->LevelFiles(lvl); in AssignLevelAndSeqnoForIngestedFile()
581 IngestedFileFitInLevel(file_to_ingest, lvl)) { in AssignLevelAndSeqnoForIngestedFile()
593 if (IngestedFileFitInLevel(file_to_ingest, lvl)) { in AssignLevelAndSeqnoForIngestedFile()
594 target_level = lvl; in AssignLevelAndSeqnoForIngestedFile()
626 for (int lvl = 0; lvl < cfd_->NumberLevels() - 1; lvl++) { in CheckLevelForIngestedBehindFile() local
[all …]
Dversion_set_test.cc1798 const std::string& _key, int lvl) in SstInfo()
1802 level(lvl) {} in SstInfo()
/rocksdb-6.9/db/compaction/
Dcompaction.cc367 for (int lvl = output_level_ + 1; lvl < number_levels_; lvl++) { in KeyNotExistsBeyondOutputLevel() local
369 input_vstorage_->LevelFiles(lvl); in KeyNotExistsBeyondOutputLevel()
370 for (; level_ptrs->at(lvl) < files.size(); level_ptrs->at(lvl)++) { in KeyNotExistsBeyondOutputLevel()
371 auto* f = files[level_ptrs->at(lvl)]; in KeyNotExistsBeyondOutputLevel()
Dcompaction_job.cc449 int lvl = c->level(lvl_idx); in GenSubcompactionBoundaries() local
450 if (lvl >= start_lvl && lvl <= out_lvl) { in GenSubcompactionBoundaries()
458 if (lvl == 0) { in GenSubcompactionBoundaries()
470 if (lvl == out_lvl) { in GenSubcompactionBoundaries()