Home
last modified time | relevance | path

Searched refs:level_file (Results 1 – 3 of 3) sorted by relevance

/rocksdb-6.9/db/compaction/
Dcompaction_picker_level.cc132 auto continuation = [&](std::pair<int, FileMetaData*> level_file) { in PickExpiredTtlFiles() argument
136 assert(!level_file.second->being_compacted); in PickExpiredTtlFiles()
137 start_level_ = level_file.first; in PickExpiredTtlFiles()
147 start_level_inputs_.files = {level_file.second}; in PickExpiredTtlFiles()
153 for (auto& level_file : vstorage_->ExpiredTtlFiles()) { in PickExpiredTtlFiles() local
154 if (continuation(level_file)) { in PickExpiredTtlFiles()
168 auto continuation = [&](std::pair<int, FileMetaData*> level_file) { in PickFilesMarkedForPeriodicCompaction() argument
172 assert(!level_file.second->being_compacted); in PickFilesMarkedForPeriodicCompaction()
173 output_level_ = start_level_ = level_file.first; in PickFilesMarkedForPeriodicCompaction()
180 start_level_inputs_.files = {level_file.second}; in PickFilesMarkedForPeriodicCompaction()
[all …]
Dcompaction_picker.cc1066 auto continuation = [&, cf_name](std::pair<int, FileMetaData*> level_file) { in PickFilesMarkedForCompaction() argument
1070 assert(!level_file.second->being_compacted); in PickFilesMarkedForCompaction()
1071 *start_level = level_file.first; in PickFilesMarkedForCompaction()
1079 start_level_inputs->files = {level_file.second}; in PickFilesMarkedForCompaction()
1094 for (auto& level_file : vstorage->FilesMarkedForCompaction()) { in PickFilesMarkedForCompaction() local
1095 if (continuation(level_file)) { in PickFilesMarkedForCompaction()
/rocksdb-6.9/db/db_impl/
Ddb_impl.cc3296 FileMetaData* level_file; in DeleteFilesInRanges() local
3298 level_file = level_files[j]; in DeleteFilesInRanges()
3299 if (level_file->being_compacted) { in DeleteFilesInRanges()
3302 if (deleted_files.find(level_file) != deleted_files.end()) { in DeleteFilesInRanges()
3306 cfd->user_comparator()->Compare(level_file->largest.user_key(), in DeleteFilesInRanges()
3311 edit.DeleteFile(i, level_file->fd.GetNumber()); in DeleteFilesInRanges()
3312 deleted_files.insert(level_file); in DeleteFilesInRanges()
3313 level_file->being_compacted = true; in DeleteFilesInRanges()