Lines Matching refs:end
369 current_level_range_(*range, range->begin(), range->end()), in FilePickerMultiGet()
370 current_file_range_(*range, range->begin(), range->end()), in FilePickerMultiGet()
377 for (auto iter = range_->begin(); iter != range_->end(); ++iter) { in FilePickerMultiGet()
393 for (auto iter = range_->begin(); iter != range_->end(); ++iter) { in FilePickerMultiGet()
417 if (batch_iter_ != current_level_range_.end()) { in GetNextFileInLevelWithKeys()
419 for (; batch_iter_ != current_level_range_.end(); ++batch_iter_) { in GetNextFileInLevelWithKeys()
430 while (batch_iter_ != current_level_range_.end() && in GetNextFileInLevelWithKeys()
497 (batch_iter_ != current_level_range_.end()) in GetNextFileInLevelWithKeys()
512 if (batch_iter_ == current_level_range_.end()) { in GetNextFile()
536 current_level_range_.end()); in GetNextFile()
538 (batch_iter_ != current_level_range_.end()) in GetNextFile()
645 mget_iter != current_level_range_.end(); ++mget_iter) { in PrepareNextLevel()
671 MultiGetRange(*range_, range_->begin(), range_->end()); in PrepareNextLevel()
673 mget_iter != current_level_range_.end(); ++mget_iter) { in PrepareNextLevel()
1895 for (auto iter = range->begin(); iter != range->end(); ++iter) { in MultiGet()
1911 for (auto iter = range->begin(); iter != range->end(); in MultiGet()
1916 MultiGetRange file_picker_range(*range, range->begin(), range->end()); in MultiGet()
1943 for (auto iter = file_range.begin(); iter != file_range.end(); ++iter) { in MultiGet()
1950 for (auto iter = file_range.begin(); iter != file_range.end(); ++iter) { in MultiGet()
2025 for (auto iter = range->begin(); iter != range->end(); ++iter) { in MultiGet()
2609 assert(it == blob_files_.end() || it->first != blob_file_number); in AddBlobFile()
2684 while (next_level_it != next_level_files.end() && in SortFileByOverlappingRatio()
2689 while (next_level_it != next_level_files.end() && in SortFileByOverlappingRatio()
2705 std::sort(temp->begin(), temp->end(), in SortFileByOverlappingRatio()
2741 std::partial_sort(temp.begin(), temp.begin() + num, temp.end(), in UpdateFilesByCompactionPri()
2745 std::sort(temp.begin(), temp.end(), in UpdateFilesByCompactionPri()
2752 std::sort(temp.begin(), temp.end(), in UpdateFilesByCompactionPri()
2787 std::sort(level0_sorted_file.begin(), level0_sorted_file.end(), in GenerateLevel0NonOverlapping()
2888 int level, const InternalKey* begin, const InternalKey* end, in GetOverlappingInputs() argument
2902 GetOverlappingInputsRangeBinarySearch(level, begin, end, inputs, hint_index, in GetOverlappingInputs()
2917 if (end != nullptr) { in GetOverlappingInputs()
2918 user_end = end->user_key(); in GetOverlappingInputs()
2930 while (iter != index.end()) { in GetOverlappingInputs()
2938 } else if (end != nullptr && in GetOverlappingInputs()
2957 if (end != nullptr && in GetOverlappingInputs()
2978 int level, const InternalKey* begin, const InternalKey* end, in GetCleanInputsWithinInterval() argument
2991 GetOverlappingInputsRangeBinarySearch(level, begin, end, inputs, in GetCleanInputsWithinInterval()
3004 int level, const InternalKey* begin, const InternalKey* end, in GetOverlappingInputsRangeBinarySearch() argument
3045 if (end != nullptr) { in GetOverlappingInputsRangeBinarySearch()
3056 std::upper_bound(files + start_index, files + num_files, end, cmp) - in GetOverlappingInputsRangeBinarySearch()
3361 ranges.end() : ranges.lower_bound(&file->smallest); in EstimateLiveDataSize()
3362 found_end = (lb == ranges.end()); in EstimateLiveDataSize()
3825 assert(curr_state.find(cfd->GetID()) == curr_state.end()); in ProcessManifestWrites()
4207 column_families_not_found.end()); in ApplyOneVersionEditToBuilder()
4210 bool cf_in_builders = builders.find(edit.column_family_) != builders.end(); in ApplyOneVersionEditToBuilder()
4228 if (cf_options == name_to_options.end() && in ApplyOneVersionEditToBuilder()
4249 assert(builder != builders.end()); in ApplyOneVersionEditToBuilder()
4279 assert(builder != builders.end()); in ApplyOneVersionEditToBuilder()
4477 if (default_cf_iter == cf_name_to_options.end()) { in Recover()
4564 assert(builders_iter != builders.end()); in Recover()
4632 bool Valid() const { return manifest_file_iter_ != manifest_files_.end(); } in Valid()
4663 std::sort(manifest_files_.begin(), manifest_files_.end(), in SeekToFirstManifest()
4688 if (manifest_file_iter_ != manifest_files_.end()) { in GetNextManifest()
4820 column_family_names.end()) { in ListColumnFamilies()
4828 column_family_names.end()) { in ListColumnFamilies()
5024 builders.find(edit.column_family_) != builders.end(); in DumpManifest()
5071 assert(builder != builders.end()); in DumpManifest()
5129 assert(builders_iter != builders.end()); in DumpManifest()
5143 if (comparator != comparators.end()) { in DumpManifest()
5258 assert(iter != curr_state.end()); in WriteCurrentStateToManifest()
5284 const Slice& end, int start_level, in ApproximateSize() argument
5289 assert(icmp.Compare(start, end) <= 0); in ApproximateSize()
5346 if (icmp.Compare(files_brief.files[idx_end].largest_key, end) < 0) { in ApproximateSize()
5348 FindFileInRange(icmp, files_brief, end, idx_start, in ApproximateSize()
5362 ApproximateSize(v, files_brief.files[i], start, end, caller)); in ApproximateSize()
5396 total_full_size += ApproximateSize(v, *file_ptr, start, end, caller); in ApproximateSize()
5403 total_full_size += ApproximateOffsetOf(v, *file_ptr, end, caller); in ApproximateSize()
5438 const Slice& start, const Slice& end, in ApproximateSize() argument
5443 assert(icmp.Compare(start, end) <= 0); in ApproximateSize()
5446 icmp.Compare(f.smallest_key, end) > 0) { in ApproximateSize()
5453 return ApproximateOffsetOf(v, f, end, caller); in ApproximateSize()
5456 if (icmp.Compare(f.largest_key, end) < 0) { in ApproximateSize()
5470 start, end, f.file_metadata->fd, caller, icmp, in ApproximateSize()
5752 unique_files.end()) { in GetTotalSstFilesSize()
5803 if (default_cf_iter == cf_name_to_options.end()) { in Recover()
5855 assert(builder_iter != builders.end()); in Recover()
5908 assert(builders_iter != builders.end()); in Recover()
6049 if (builder_iter == active_version_builders_.end()) { in ReadAndApply()
6079 active_version_builders_.end() && in ApplyOneVersionEditToBuilder()
6088 assert(builder_iter != active_version_builders_.end()); in ApplyOneVersionEditToBuilder()