Home
last modified time | relevance | path

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

/rocksdb-6.9/db/compaction/
Dcompaction_picker_fifo.cc43 const std::vector<FileMetaData*>& level_files = vstorage->LevelFiles(kLevel0); in PickTTLCompaction() local
44 uint64_t total_size = GetTotalFilesSize(level_files); in PickTTLCompaction()
72 for (auto ritr = level_files.rbegin(); ritr != level_files.rend(); ++ritr) { in PickTTLCompaction()
114 const std::vector<FileMetaData*>& level_files = vstorage->LevelFiles(kLevel0); in PickSizeCompaction() local
115 uint64_t total_size = GetTotalFilesSize(level_files); in PickSizeCompaction()
119 level_files.size() == 0) { in PickSizeCompaction()
122 level_files.size() > 0) { in PickSizeCompaction()
134 level_files, in PickSizeCompaction()
175 for (auto ritr = level_files.rbegin(); ritr != level_files.rend(); ++ritr) { in PickSizeCompaction()
Dcompaction_picker_level.cc476 const std::vector<FileMetaData*>& level_files = in PickFileToCompact() local
483 auto* f = level_files[index]; in PickFileToCompact()
533 const std::vector<FileMetaData*>& level_files = in PickIntraL0Compaction() local
535 if (level_files.size() < in PickIntraL0Compaction()
538 level_files[0]->being_compacted) { in PickIntraL0Compaction()
543 return FindIntraL0Compaction(level_files, kMinFilesForIntraL0Compaction, in PickIntraL0Compaction()
Dcompaction_picker.cc38 bool FindIntraL0Compaction(const std::vector<FileMetaData*>& level_files, in FindIntraL0Compaction() argument
48 for (; start < level_files.size(); start++) { in FindIntraL0Compaction()
49 if (level_files[start]->being_compacted) { in FindIntraL0Compaction()
56 if (level_files[start]->fd.largest_seqno <= earliest_mem_seqno) { in FindIntraL0Compaction()
60 if (start >= level_files.size()) { in FindIntraL0Compaction()
65 level_files[start]->compensated_file_size; in FindIntraL0Compaction()
72 for (limit = start + 1; limit < level_files.size(); ++limit) { in FindIntraL0Compaction()
73 compact_bytes += static_cast<size_t>(level_files[limit]->fd.file_size); in FindIntraL0Compaction()
74 compensated_compact_bytes += level_files[limit]->compensated_file_size; in FindIntraL0Compaction()
76 if (level_files[limit]->being_compacted || in FindIntraL0Compaction()
[all …]
Dcompaction.cc496 for (const auto& level_files : inputs_) { in OutputFilePreallocationSize() local
497 for (const auto& file : level_files.files) { in OutputFilePreallocationSize()
548 for (const auto& level_files : inputs_) { in MinInputFileOldestAncesterTime() local
549 for (const auto& file : level_files.files) { in MinInputFileOldestAncesterTime()
Dcompaction_job_test.cc308 auto level_files = input_files[level]; local
312 level_files.begin(), level_files.end());
314 num_input_files += level_files.size();
Dcompaction_picker.h297 const std::vector<FileMetaData*>& level_files, size_t min_files_to_compact,
/rocksdb-6.9/db/
Dversion_builder.cc212 auto& level_files = vstorage->LevelFiles(level); in CheckConsistency() local
214 if (level_files.empty()) { in CheckConsistency()
218 assert(level_files[0]); in CheckConsistency()
220 vstorage, level_files[0]->oldest_blob_file_number); in CheckConsistency()
225 for (size_t i = 1; i < level_files.size(); i++) { in CheckConsistency()
226 assert(level_files[i]); in CheckConsistency()
228 vstorage, level_files[i]->oldest_blob_file_number); in CheckConsistency()
233 auto f1 = level_files[i - 1]; in CheckConsistency()
234 auto f2 = level_files[i]; in CheckConsistency()
Dforward_iterator.cc432 const std::vector<FileMetaData*>& level_files = in SeekInternal() local
434 if (level_files.empty()) { in SeekInternal()
442 f_idx = FindFileInRange(level_files, internal_key, 0, in SeekInternal()
443 static_cast<uint32_t>(level_files.size())); in SeekInternal()
447 if (f_idx < level_files.size()) { in SeekInternal()
765 const auto& level_files = vstorage->LevelFiles(level); in BuildLevelIterators() local
766 if ((level_files.empty()) || in BuildLevelIterators()
769 level_files[0]->smallest.user_key()) < in BuildLevelIterators()
772 if (!level_files.empty()) { in BuildLevelIterators()
777 cfd_, read_options_, level_files, in BuildLevelIterators()
Dexternal_sst_file_ingestion_job.cc570 const std::vector<FileMetaData*>& level_files = in AssignLevelAndSeqnoForIngestedFile() local
573 (*max_element(level_files.begin(), level_files.end(), in AssignLevelAndSeqnoForIngestedFile()
Dversion_set.cc2576 auto* level_files = &files_[level]; in AddFile() local
2579 if (level > 0 && !level_files->empty() && in AddFile()
2581 (*level_files)[level_files->size() - 1]->largest, f->smallest) >= 0) { in AddFile()
2582 auto* f2 = (*level_files)[level_files->size() - 1]; in AddFile()
2599 level_files->push_back(f); in AddFile()
/rocksdb-6.9/db/db_impl/
Ddb_impl.cc3278 std::vector<FileMetaData*> level_files; in DeleteFilesInRanges() local
3294 i, begin_key, end_key, &level_files, -1 /* hint_index */, in DeleteFilesInRanges()
3297 for (uint32_t j = 0; j < level_files.size(); j++) { in DeleteFilesInRanges()
3298 level_file = level_files[j]; in DeleteFilesInRanges()