Lines Matching refs:level
745 for (int level = 0; level < storage_info_.num_levels_; level++) { in ~Version() local
746 for (size_t i = 0; i < storage_info_.files_[level].size(); i++) { in ~Version()
747 FileMetaData* f = storage_info_.files_[level][i]; in ~Version()
862 bool skip_filters, int level, RangeDelAggregator* range_del_agg, in LevelIterator() argument
877 level_(level), in LevelIterator()
1264 for (int level = 0; level < storage_info_.num_levels_; level++) { in GetPropertiesOfAllTables() local
1265 s = GetPropertiesOfAllTables(props, level); in GetPropertiesOfAllTables()
1283 for (int level = 0; level < storage_info_.num_levels_; level++) { in TablesRangeTombstoneSummary() local
1284 for (const auto& file_meta : storage_info_.files_[level]) { in TablesRangeTombstoneSummary()
1329 int level) { in GetPropertiesOfAllTables() argument
1330 for (const auto& file_meta : storage_info_.files_[level]) { in GetPropertiesOfAllTables()
1350 for (int level = 0; level < storage_info_.num_non_empty_levels(); level++) { in GetPropertiesOfTablesInRange() local
1356 storage_info_.GetOverlappingInputs(level, &k1, &k2, &files, -1, nullptr, in GetPropertiesOfTablesInRange()
1381 std::shared_ptr<const TableProperties>* tp, int level) { in GetAggregatedTableProperties() argument
1384 if (level < 0) { in GetAggregatedTableProperties()
1387 s = GetPropertiesOfAllTables(&props, level); in GetAggregatedTableProperties()
1425 for (int level = 0; level < cfd_->NumberLevels(); level++) { in GetColumnFamilyMetaData() local
1427 cf_meta->file_count += vstorage->LevelFiles(level).size(); in GetColumnFamilyMetaData()
1429 for (const auto& file : vstorage->LevelFiles(level)) { in GetColumnFamilyMetaData()
1453 level, level_size, std::move(files)); in GetColumnFamilyMetaData()
1460 for (int level = 0; level < storage_info_.num_levels_; level++) { in GetSstFilesSize() local
1461 for (const auto& file_meta : storage_info_.LevelFiles(level)) { in GetSstFilesSize()
1470 for (int level = 0; level < storage_info_.num_non_empty_levels_; level++) { in GetCreationTimeOfOldestFile() local
1471 for (FileMetaData* meta : storage_info_.LevelFiles(level)) { in GetCreationTimeOfOldestFile()
1503 for (int level = 0; level < num_levels_; ++level) { in GetEstimatedActiveKeys() local
1504 file_count += files_[level].size(); in GetEstimatedActiveKeys()
1519 int level) const { in GetEstimatedCompressionRatioAtLevel()
1520 assert(level < num_levels_); in GetEstimatedCompressionRatioAtLevel()
1523 for (auto* file_meta : files_[level]) { in GetEstimatedCompressionRatioAtLevel()
1539 for (int level = 0; level < storage_info_.num_non_empty_levels(); level++) { in AddIterators() local
1540 AddIteratorsForLevel(read_options, soptions, merge_iter_builder, level, in AddIterators()
1548 int level, in AddIteratorsForLevel() argument
1551 if (level >= storage_info_.num_non_empty_levels()) { in AddIteratorsForLevel()
1554 } else if (storage_info_.LevelFilesBrief(level).num_files == 0) { in AddIteratorsForLevel()
1562 if (level == 0) { in AddIteratorsForLevel()
1585 } else if (storage_info_.LevelFilesBrief(level).num_files > 0) { in AddIteratorsForLevel()
1592 cfd_->internal_comparator(), &storage_info_.LevelFilesBrief(level), in AddIteratorsForLevel()
1594 cfd_->internal_stats()->GetFileReadHist(level), in AddIteratorsForLevel()
1595 TableReaderCaller::kUserIterator, IsFilterSkipped(level), level, in AddIteratorsForLevel()
1604 int level, bool* overlap) { in OverlapWithLevelIterator() argument
1617 if (level == 0) { in OverlapWithLevelIterator()
1639 } else if (storage_info_.LevelFilesBrief(level).num_files > 0) { in OverlapWithLevelIterator()
1643 cfd_->internal_comparator(), &storage_info_.LevelFilesBrief(level), in OverlapWithLevelIterator()
1645 cfd_->internal_stats()->GetFileReadHist(level), in OverlapWithLevelIterator()
1646 TableReaderCaller::kUserIterator, IsFilterSkipped(level), level, in OverlapWithLevelIterator()
2058 bool Version::IsFilterSkipped(int level, bool is_file_last_in_level) { in IsFilterSkipped() argument
2062 (level > 0 || is_file_last_in_level) && in IsFilterSkipped()
2063 level == storage_info_.num_non_empty_levels() - 1; in IsFilterSkipped()
2068 for (int level = 0; level < num_non_empty_levels_; level++) { in GenerateLevelFilesBrief() local
2070 &level_files_brief_[level], files_[level], &arena_); in GenerateLevelFilesBrief()
2153 for (int level = 0; in UpdateAccumulatedStats() local
2154 level < storage_info_.num_levels_ && init_count < kMaxInitCount; in UpdateAccumulatedStats()
2155 ++level) { in UpdateAccumulatedStats()
2156 for (auto* file_meta : storage_info_.files_[level]) { in UpdateAccumulatedStats()
2178 for (int level = storage_info_.num_levels_ - 1; in UpdateAccumulatedStats() local
2179 storage_info_.accumulated_raw_value_size_ == 0 && level >= 0; in UpdateAccumulatedStats()
2180 --level) { in UpdateAccumulatedStats()
2181 for (int i = static_cast<int>(storage_info_.files_[level].size()) - 1; in UpdateAccumulatedStats()
2183 if (MaybeInitializeFileMetaData(storage_info_.files_[level][i])) { in UpdateAccumulatedStats()
2184 storage_info_.UpdateAccumulatedStats(storage_info_.files_[level][i]); in UpdateAccumulatedStats()
2198 for (int level = 0; level < num_levels_; level++) { in ComputeCompensatedSizes() local
2199 for (auto* file_meta : files_[level]) { in ComputeCompensatedSizes()
2276 for (int level = base_level(); level <= MaxInputLevel(); level++) { in EstimateCompactionBytesNeeded() local
2281 for (auto* f : files_[level]) { in EstimateCompactionBytesNeeded()
2289 for (auto* f : files_[level]) { in EstimateCompactionBytesNeeded()
2293 if (level == base_level() && level0_compact_triggered) { in EstimateCompactionBytesNeeded()
2300 uint64_t level_target = MaxBytesForLevel(level); in EstimateCompactionBytesNeeded()
2307 if (level + 1 < num_levels_) { in EstimateCompactionBytesNeeded()
2308 for (auto* f : files_[level + 1]) { in EstimateCompactionBytesNeeded()
2351 for (int level = 0; level <= MaxInputLevel(); level++) { in ComputeCompactionScore() local
2353 if (level == 0) { in ComputeCompactionScore()
2367 for (auto* f : files_[level]) { in ComputeCompactionScore()
2396 immutable_cf_options, mutable_cf_options, files_[level])), in ComputeCompactionScore()
2415 for (auto f : files_[level]) { in ComputeCompactionScore()
2421 MaxBytesForLevel(level); in ComputeCompactionScore()
2423 compaction_level_[level] = level; in ComputeCompactionScore()
2424 compaction_score_[level] = score; in ComputeCompactionScore()
2433 int level = compaction_level_[i]; in ComputeCompactionScore() local
2437 compaction_level_[j] = level; in ComputeCompactionScore()
2460 for (int level = num_levels() - 1; level >= 1; level--) { in ComputeFilesMarkedForCompaction() local
2461 if (!files_[level].empty()) { in ComputeFilesMarkedForCompaction()
2462 last_qualify_level = level - 1; in ComputeFilesMarkedForCompaction()
2467 for (int level = 0; level <= last_qualify_level; level++) { in ComputeFilesMarkedForCompaction() local
2468 for (auto* f : files_[level]) { in ComputeFilesMarkedForCompaction()
2470 files_marked_for_compaction_.emplace_back(level, f); in ComputeFilesMarkedForCompaction()
2489 for (int level = 0; level < num_levels() - 1; level++) { in ComputeExpiredTtlFiles() local
2490 for (FileMetaData* f : files_[level]) { in ComputeExpiredTtlFiles()
2495 expired_ttl_files_.emplace_back(level, f); in ComputeExpiredTtlFiles()
2525 for (int level = 0; level < num_levels(); level++) { in ComputeFilesMarkedForPeriodicCompaction() local
2526 for (auto f : files_[level]) { in ComputeFilesMarkedForPeriodicCompaction()
2552 files_marked_for_periodic_compaction_.emplace_back(level, f); in ComputeFilesMarkedForPeriodicCompaction()
2575 void VersionStorageInfo::AddFile(int level, FileMetaData* f, Logger* info_log) { in AddFile() argument
2576 auto* level_files = &files_[level]; in AddFile()
2579 if (level > 0 && !level_files->empty() && in AddFile()
2588 f->largest.DebugString(true).c_str(), level, f2->fd.GetNumber(), in AddFile()
2634 for (int level = 1; level < base_level(); level++) { in SetFinalized() local
2635 assert(NumLevelBytes(level) == 0); in SetFinalized()
2638 for (int level = base_level(); level < num_levels() - 1; level++) { in SetFinalized() local
2639 if (LevelFiles(level).size() == 0) { in SetFinalized()
2642 assert(MaxBytesForLevel(level) >= max_bytes_prev_level); in SetFinalized()
2643 max_bytes_prev_level = MaxBytesForLevel(level); in SetFinalized()
2646 for (int level = 0; level < num_levels(); level++) { in SetFinalized() local
2647 assert(LevelFiles(level).size() == 0 || in SetFinalized()
2648 LevelFiles(level).size() == LevelFilesBrief(level).num_files); in SetFinalized()
2649 if (level > 0 && NumLevelBytes(level) > 0) { in SetFinalized()
2652 if (LevelFiles(level).size() > 0) { in SetFinalized()
2653 assert(level < num_non_empty_levels()); in SetFinalized()
2722 for (int level = 0; level < num_levels() - 1; level++) { in UpdateFilesByCompactionPri() local
2723 const std::vector<FileMetaData*>& files = files_[level]; in UpdateFilesByCompactionPri()
2724 auto& files_by_compaction_pri = files_by_compaction_pri_[level]; in UpdateFilesByCompactionPri()
2759 SortFileByOverlappingRatio(*internal_comparator_, files_[level], in UpdateFilesByCompactionPri()
2760 files_[level + 1], &temp); in UpdateFilesByCompactionPri()
2771 next_file_to_compact_by_size_[level] = 0; in UpdateFilesByCompactionPri()
2772 assert(files_[level].size() == files_by_compaction_pri_[level].size()); in UpdateFilesByCompactionPri()
2806 for (size_t level = 0; level < level_files_brief_.size(); ++level) { in GenerateBottommostFiles() local
2807 for (size_t file_idx = 0; file_idx < level_files_brief_[level].num_files; in GenerateBottommostFiles()
2809 const FdWithKeyRange& f = level_files_brief_[level].files[file_idx]; in GenerateBottommostFiles()
2811 if (level == 0) { in GenerateBottommostFiles()
2819 static_cast<int>(level), in GenerateBottommostFiles()
2821 bottommost_files_.emplace_back(static_cast<int>(level), in GenerateBottommostFiles()
2871 bool VersionStorageInfo::OverlapInLevel(int level, in OverlapInLevel() argument
2874 if (level >= num_non_empty_levels_) { in OverlapInLevel()
2878 return SomeFileOverlapsRange(*internal_comparator_, (level > 0), in OverlapInLevel()
2879 level_files_brief_[level], smallest_user_key, in OverlapInLevel()
2888 int level, const InternalKey* begin, const InternalKey* end, in GetOverlappingInputs() argument
2891 if (level >= num_non_empty_levels_) { in GetOverlappingInputs()
2901 if (level > 0) { in GetOverlappingInputs()
2902 GetOverlappingInputsRangeBinarySearch(level, begin, end, inputs, hint_index, in GetOverlappingInputs()
2923 for (size_t i = 0; i < level_files_brief_[level].num_files; i++) { in GetOverlappingInputs()
2931 FdWithKeyRange* f = &(level_files_brief_[level].files[*iter]); in GetOverlappingInputs()
2944 inputs->emplace_back(files_[level][*iter]); in GetOverlappingInputs()
2978 int level, const InternalKey* begin, const InternalKey* end, in GetCleanInputsWithinInterval() argument
2984 if (level >= num_non_empty_levels_ || level == 0 || in GetCleanInputsWithinInterval()
2985 level_files_brief_[level].num_files == 0) { in GetCleanInputsWithinInterval()
2991 GetOverlappingInputsRangeBinarySearch(level, begin, end, inputs, in GetCleanInputsWithinInterval()
3004 int level, const InternalKey* begin, const InternalKey* end, in GetOverlappingInputsRangeBinarySearch() argument
3007 assert(level > 0); in GetOverlappingInputsRangeBinarySearch()
3010 const FdWithKeyRange* files = level_files_brief_[level].files; in GetOverlappingInputsRangeBinarySearch()
3011 const int num_files = static_cast<int>(level_files_brief_[level].num_files); in GetOverlappingInputsRangeBinarySearch()
3090 inputs->push_back(files_[level][i]); in GetOverlappingInputsRangeBinarySearch()
3095 if (end_index < static_cast<int>(files_[level].size())) { in GetOverlappingInputsRangeBinarySearch()
3096 **next_smallest = files_[level][end_index]->smallest; in GetOverlappingInputsRangeBinarySearch()
3103 uint64_t VersionStorageInfo::NumLevelBytes(int level) const { in NumLevelBytes()
3104 assert(level >= 0); in NumLevelBytes()
3105 assert(level < num_levels()); in NumLevelBytes()
3106 return TotalFileSize(files_[level]); in NumLevelBytes()
3146 int level) const { in LevelFileSummary()
3148 for (const auto& f : files_[level]) { in LevelFileSummary()
3161 if (files_[level].size() && len > 0) { in LevelFileSummary()
3171 for (int level = 1; level < num_levels() - 1; level++) { in MaxNextLevelOverlappingBytes() local
3172 for (const auto& f : files_[level]) { in MaxNextLevelOverlappingBytes()
3173 GetOverlappingInputs(level + 1, &f->smallest, &f->largest, &overlaps); in MaxNextLevelOverlappingBytes()
3183 uint64_t VersionStorageInfo::MaxBytesForLevel(int level) const { in MaxBytesForLevel()
3186 assert(level >= 0); in MaxBytesForLevel()
3187 assert(level < static_cast<int>(level_max_bytes_.size())); in MaxBytesForLevel()
3188 return level_max_bytes_[level]; in MaxBytesForLevel()
3391 for (int level = last_level + 1; level < num_levels(); level++) { in RangeMightExistAfterSortedRun() local
3395 if (files_[level].size() > 0 && in RangeMightExistAfterSortedRun()
3397 OverlapInLevel(level, &smallest_user_key, &largest_user_key))) { in RangeMightExistAfterSortedRun()
3405 for (int level = 0; level < storage_info_.num_levels(); level++) { in AddLiveFiles() local
3406 const std::vector<FileMetaData*>& files = storage_info_.files_[level]; in AddLiveFiles()
3415 for (int level = 0; level < storage_info_.num_levels_; level++) { in DebugString() local
3424 AppendNumberTo(&r, level); in DebugString()
3428 const std::vector<FileMetaData*>& files = storage_info_.files_[level]; in DebugString()
4949 for (int level = 0; level < cfd->NumberLevels(); level++) { in GetLiveFilesChecksumInfo() local
4951 cfd->current()->storage_info()->LevelFiles(level)) { in GetLiveFilesChecksumInfo()
5246 for (int level = 0; level < cfd->NumberLevels(); level++) { in WriteCurrentStateToManifest() local
5248 cfd->current()->storage_info()->LevelFiles(level)) { in WriteCurrentStateToManifest()
5249 edit.AddFile(level, f->fd.GetNumber(), f->fd.GetPathId(), in WriteCurrentStateToManifest()
5318 for (int level = start_level; level < end_level; ++level) { in ApproximateSize() local
5319 const LevelFilesBrief& files_brief = vstorage->LevelFilesBrief(level); in ApproximateSize()
5325 if (level == 0) { in ApproximateSize()
5335 assert(level > 0); in ApproximateSize()
5485 for (int level = 0; level < vstorage->num_levels(); level++) { in AddLiveFiles() local
5486 total_files += vstorage->LevelFiles(level).size(); in AddLiveFiles()
5532 const size_t space = (c->level() == 0 ? c->input_levels(0)->num_files + in MakeInputIterator()
5539 if (c->level(which) == 0) { in MakeInputIterator()
5605 int level = c->level(input); in VerifyCompactionFileConsistency() local
5609 for (size_t j = 0; j < vstorage->files_[level].size(); j++) { in VerifyCompactionFileConsistency()
5610 FileMetaData* f = vstorage->files_[level][j]; in VerifyCompactionFileConsistency()
5636 for (int level = 0; level < vstorage->num_levels(); level++) { in GetMetadataForFile() local
5637 for (const auto& file : vstorage->LevelFiles(level)) { in GetMetadataForFile()
5640 *filelevel = level; in GetMetadataForFile()
5655 for (int level = 0; level < cfd->NumberLevels(); level++) { in GetLiveFilesMetaData() local
5657 cfd->current()->storage_info()->LevelFiles(level)) { in GetLiveFilesMetaData()
5670 filemetadata.level = level; in GetLiveFilesMetaData()
5749 for (int level = 0; level < storage_info->num_levels_; level++) { in GetTotalSstFilesSize() local
5750 for (const auto& file_meta : storage_info->LevelFiles(level)) { in GetTotalSstFilesSize()