Lines Matching refs:f
69 auto cmp = [&](const FdWithKeyRange& f, const Slice& k) -> bool { in FindFileInRange() argument
70 return icmp.InternalKeyComparator::Compare(f.largest_key, k) < 0; in FindFileInRange()
157 FdWithKeyRange* f = &curr_file_level_->files[curr_index_in_curr_level_]; in GetNextFile() local
178 user_key_, ExtractUserKey(f->smallest_key)) <= 0); in GetNextFile()
181 user_key_, ExtractUserKey(f->smallest_key)); in GetNextFile()
184 user_key_, ExtractUserKey(f->largest_key)); in GetNextFile()
212 prev_file_->largest_key, f->smallest_key); in GetNextFile()
222 prev_file_ = f; in GetNextFile()
231 return f; in GetNextFile()
409 FdWithKeyRange* f = nullptr; in GetNextFileInLevelWithKeys() local
435 f = &curr_file_level_->files[fp_ctx.curr_index_in_curr_level]; in GetNextFileInLevelWithKeys()
454 ExtractUserKey(f->smallest_key)) <= 0); in GetNextFileInLevelWithKeys()
457 user_key, ExtractUserKey(f->smallest_key)); in GetNextFileInLevelWithKeys()
460 user_key, ExtractUserKey(f->largest_key)); in GetNextFileInLevelWithKeys()
503 *fd = f; in GetNextFileInLevelWithKeys()
541 FdWithKeyRange* f; in GetNextFile() local
543 if (!GetNextFileInLevelWithKeys(&next_file_range, &curr_file_index, &f, in GetNextFile()
563 return f; in GetNextFile()
747 FileMetaData* f = storage_info_.files_[level][i]; in ~Version() local
748 assert(f->refs > 0); in ~Version()
749 f->refs--; in ~Version()
750 if (f->refs <= 0) { in ~Version()
752 uint32_t path_id = f->fd.GetPathId(); in ~Version()
755 ObsoleteFileInfo(f, cfd_->ioptions()->cf_paths[path_id].path)); in ~Version()
790 FdWithKeyRange& f = file_level->files[i]; in DoGenerateLevelFilesBrief() local
791 f.fd = files[i]->fd; in DoGenerateLevelFilesBrief()
792 f.file_metadata = files[i]; in DoGenerateLevelFilesBrief()
793 f.smallest_key = Slice(mem, smallest_size); in DoGenerateLevelFilesBrief()
794 f.largest_key = Slice(mem + smallest_size, largest_size); in DoGenerateLevelFilesBrief()
799 const Slice* user_key, const FdWithKeyRange* f) { in AfterFile() argument
803 ExtractUserKey(f->largest_key)) > 0); in AfterFile()
807 const Slice* user_key, const FdWithKeyRange* f) { in BeforeFile() argument
811 ExtractUserKey(f->smallest_key)) < 0); in BeforeFile()
824 const FdWithKeyRange* f = &(file_level.files[i]); in SomeFileOverlapsRange() local
825 if (AfterFile(ucmp, smallest_user_key, f) || in SomeFileOverlapsRange()
826 BeforeFile(ucmp, largest_user_key, f)) { in SomeFileOverlapsRange()
1774 FdWithKeyRange* f = fp.GetNextFile(); in Get() local
1776 while (f != nullptr) { in Get()
1783 sample_file_read_inc(f->file_metadata); in Get()
1791 read_options, *internal_comparator(), *f->file_metadata, ikey, in Get()
1844 f = fp.GetNextFile(); in Get()
1921 FdWithKeyRange* f = fp.GetNextFile(); in MultiGet() local
1923 while (f != nullptr) { in MultiGet()
1930 read_options, *internal_comparator(), *f->file_metadata, &file_range, in MultiGet()
1964 sample_file_read_inc(f->file_metadata); in MultiGet()
2021 f = fp.GetNextFile(); in MultiGet()
2259 for (auto* f : files_[0]) { in EstimateCompactionBytesNeeded() local
2260 level_size += f->fd.GetFileSize(); in EstimateCompactionBytesNeeded()
2281 for (auto* f : files_[level]) { in EstimateCompactionBytesNeeded() local
2282 level_size2 += f->fd.GetFileSize(); in EstimateCompactionBytesNeeded()
2289 for (auto* f : files_[level]) { in EstimateCompactionBytesNeeded() local
2290 level_size += f->fd.GetFileSize(); in EstimateCompactionBytesNeeded()
2308 for (auto* f : files_[level + 1]) { in EstimateCompactionBytesNeeded() local
2309 bytes_next_level += f->fd.GetFileSize(); in EstimateCompactionBytesNeeded()
2334 for (FileMetaData* f : files) { in GetExpiredTtlFilesCount()
2335 if (!f->being_compacted) { in GetExpiredTtlFilesCount()
2336 uint64_t oldest_ancester_time = f->TryGetOldestAncesterTime(); in GetExpiredTtlFilesCount()
2367 for (auto* f : files_[level]) { in ComputeCompactionScore() local
2368 if (!f->being_compacted) { in ComputeCompactionScore()
2369 total_size += f->compensated_file_size; in ComputeCompactionScore()
2415 for (auto f : files_[level]) { in ComputeCompactionScore() local
2416 if (!f->being_compacted) { in ComputeCompactionScore()
2417 level_bytes_no_compacting += f->compensated_file_size; in ComputeCompactionScore()
2468 for (auto* f : files_[level]) { in ComputeFilesMarkedForCompaction() local
2469 if (!f->being_compacted && f->marked_for_compaction) { in ComputeFilesMarkedForCompaction()
2470 files_marked_for_compaction_.emplace_back(level, f); in ComputeFilesMarkedForCompaction()
2490 for (FileMetaData* f : files_[level]) { in ComputeExpiredTtlFiles()
2491 if (!f->being_compacted) { in ComputeExpiredTtlFiles()
2492 uint64_t oldest_ancester_time = f->TryGetOldestAncesterTime(); in ComputeExpiredTtlFiles()
2495 expired_ttl_files_.emplace_back(level, f); in ComputeExpiredTtlFiles()
2526 for (auto f : files_[level]) { in ComputeFilesMarkedForPeriodicCompaction() local
2527 if (!f->being_compacted) { in ComputeFilesMarkedForPeriodicCompaction()
2534 uint64_t file_modification_time = f->TryGetFileCreationTime(); in ComputeFilesMarkedForPeriodicCompaction()
2536 file_modification_time = f->TryGetOldestAncesterTime(); in ComputeFilesMarkedForPeriodicCompaction()
2539 auto file_path = TableFileName(ioptions.cf_paths, f->fd.GetNumber(), in ComputeFilesMarkedForPeriodicCompaction()
2540 f->fd.GetPathId()); 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
2581 (*level_files)[level_files->size() - 1]->largest, f->smallest) >= 0) { in AddFile()
2587 f->fd.GetNumber(), f->smallest.DebugString(true).c_str(), in AddFile()
2588 f->largest.DebugString(true).c_str(), level, f2->fd.GetNumber(), in AddFile()
2598 f->refs++; in AddFile()
2599 level_files->push_back(f); in AddFile()
2794 FdWithKeyRange& f = level0_sorted_file[i]; in GenerateLevel0NonOverlapping() local
2796 if (internal_comparator_->Compare(prev.largest_key, f.smallest_key) >= 0) { in GenerateLevel0NonOverlapping()
2809 const FdWithKeyRange& f = level_files_brief_[level].files[file_idx]; in GenerateBottommostFiles() local
2816 Slice smallest_user_key = ExtractUserKey(f.smallest_key); in GenerateBottommostFiles()
2817 Slice largest_user_key = ExtractUserKey(f.largest_key); in GenerateBottommostFiles()
2822 f.file_metadata); in GenerateBottommostFiles()
2931 FdWithKeyRange* f = &(level_files_brief_[level].files[*iter]); in GetOverlappingInputs() local
2932 const Slice file_start = ExtractUserKey(f->smallest_key); in GetOverlappingInputs()
2933 const Slice file_limit = ExtractUserKey(f->largest_key); in GetOverlappingInputs()
3021 auto cmp = [&user_cmp, &within_interval](const FdWithKeyRange& f, in GetOverlappingInputsRangeBinarySearch()
3023 auto& file_key = within_interval ? f.file_metadata->smallest in GetOverlappingInputsRangeBinarySearch()
3024 : f.file_metadata->largest; in GetOverlappingInputsRangeBinarySearch()
3049 const FdWithKeyRange& f) { in GetOverlappingInputsRangeBinarySearch() argument
3050 auto& file_key = within_interval ? f.file_metadata->largest in GetOverlappingInputsRangeBinarySearch()
3051 : f.file_metadata->smallest; in GetOverlappingInputsRangeBinarySearch()
3148 for (const auto& f : files_[level]) { in LevelFileSummary() local
3151 AppendHumanBytes(f->fd.GetFileSize(), sztxt, sizeof(sztxt)); in LevelFileSummary()
3154 f->fd.GetNumber(), f->fd.smallest_seqno, sztxt, in LevelFileSummary()
3155 static_cast<int>(f->being_compacted)); in LevelFileSummary()
3172 for (const auto& f : files_[level]) { in MaxNextLevelOverlappingBytes() local
3173 GetOverlappingInputs(level + 1, &f->smallest, &f->largest, &overlaps); in MaxNextLevelOverlappingBytes()
3234 for (const auto& f : files_[i]) { in CalculateBaseBytes() local
3235 total_size += f->fd.GetFileSize(); in CalculateBaseBytes()
3256 for (const auto& f : files_[0]) { in CalculateBaseBytes() local
3257 l0_size += f->fd.GetFileSize(); in CalculateBaseBytes()
5247 for (const auto& f : in WriteCurrentStateToManifest() local
5249 edit.AddFile(level, f->fd.GetNumber(), f->fd.GetPathId(), in WriteCurrentStateToManifest()
5250 f->fd.GetFileSize(), f->smallest, f->largest, in WriteCurrentStateToManifest()
5251 f->fd.smallest_seqno, f->fd.largest_seqno, in WriteCurrentStateToManifest()
5252 f->marked_for_compaction, f->oldest_blob_file_number, in WriteCurrentStateToManifest()
5253 f->oldest_ancester_time, f->file_creation_time, in WriteCurrentStateToManifest()
5254 f->file_checksum, f->file_checksum_func_name); in WriteCurrentStateToManifest()
5410 uint64_t VersionSet::ApproximateOffsetOf(Version* v, const FdWithKeyRange& f, in ApproximateOffsetOf() argument
5418 if (icmp.Compare(f.largest_key, key) <= 0) { in ApproximateOffsetOf()
5420 result = f.fd.GetFileSize(); in ApproximateOffsetOf()
5421 } else if (icmp.Compare(f.smallest_key, key) > 0) { in ApproximateOffsetOf()
5430 key, f.file_metadata->fd, caller, icmp, in ApproximateOffsetOf()
5437 uint64_t VersionSet::ApproximateSize(Version* v, const FdWithKeyRange& f, in ApproximateSize() argument
5445 if (icmp.Compare(f.largest_key, start) <= 0 || in ApproximateSize()
5446 icmp.Compare(f.smallest_key, end) > 0) { in ApproximateSize()
5451 if (icmp.Compare(f.smallest_key, start) >= 0) { in ApproximateSize()
5453 return ApproximateOffsetOf(v, f, end, caller); in ApproximateSize()
5456 if (icmp.Compare(f.largest_key, end) < 0) { in ApproximateSize()
5459 uint64_t start_offset = ApproximateOffsetOf(v, f, start, caller); in ApproximateSize()
5460 assert(f.fd.GetFileSize() >= start_offset); in ApproximateSize()
5461 return f.fd.GetFileSize() - start_offset; in ApproximateSize()
5470 start, end, f.file_metadata->fd, caller, icmp, in ApproximateSize()
5610 FileMetaData* f = vstorage->files_[level][j]; in VerifyCompactionFileConsistency() local
5611 if (f->fd.GetNumber() == number) { in VerifyCompactionFileConsistency()
5696 for (auto& f : obsolete_files_) { in GetObsoleteFiles() local
5697 if (f.metadata->fd.GetNumber() < min_pending_output) { in GetObsoleteFiles()
5698 files->push_back(std::move(f)); in GetObsoleteFiles()
5700 pending_files.push_back(std::move(f)); in GetObsoleteFiles()