Home
last modified time | relevance | path

Searched refs:file_meta (Results 1 – 17 of 17) sorted by relevance

/rocksdb-6.9/db/
Dflush_job_test.cc229 FileMetaData file_meta; in TEST_F() local
232 ASSERT_OK(flush_job.Run(nullptr, &file_meta)); in TEST_F()
239 ASSERT_EQ(1, file_meta.fd.smallest_seqno); in TEST_F()
241 ASSERT_EQ(10006, file_meta.fd.largest_seqno); in TEST_F()
242 ASSERT_EQ(17, file_meta.oldest_blob_file_number); in TEST_F()
244 ASSERT_EQ(10000, file_meta.fd.largest_seqno); in TEST_F()
295 FileMetaData file_meta; in TEST_F() local
305 ASSERT_EQ(0, file_meta.fd.smallest_seqno); in TEST_F()
307 file_meta.fd.largest_seqno); in TEST_F()
406 for (const auto& file_meta : file_metas) { in TEST_F() local
[all …]
Dtable_cache.h72 const FileMetaData& file_meta, RangeDelAggregator* range_del_agg,
90 const FileMetaData& file_meta, const Slice& k,
101 const FileMetaData& file_meta,
115 const FileMetaData& file_meta,
151 const FileDescriptor& file_meta,
Dversion_set.cc1361 file_meta->fd.GetNumber(), file_meta->fd.GetPathId()); in GetPropertiesOfTablesInRange()
1523 for (auto* file_meta : files_[level]) { in GetEstimatedCompressionRatioAtLevel() local
1525 sum_data_size_bytes += file_meta->raw_key_size + file_meta->raw_value_size; in GetEstimatedCompressionRatioAtLevel()
2088 if (file_meta->init_stats_from_file || in MaybeInitializeFileMetaData()
2120 file_meta->num_entries - file_meta->num_deletions; in UpdateAccumulatedStats()
2124 file_meta->num_entries - file_meta->num_deletions; in UpdateAccumulatedStats()
2130 if (file_meta->init_stats_from_file) { in RemoveCurrentStats()
2132 file_meta->num_entries - file_meta->num_deletions; in RemoveCurrentStats()
2205 file_meta->compensated_file_size = file_meta->fd.GetFileSize(); in ComputeCompensatedSizes()
2214 if (file_meta->num_deletions * 2 >= file_meta->num_entries) { in ComputeCompensatedSizes()
[all …]
Dtable_cache.cc177 const InternalKeyComparator& icomparator, const FileMetaData& file_meta, in NewIterator() argument
192 auto& fd = file_meta.fd; in NewIterator()
234 const InternalKey* smallest = &file_meta.smallest; in NewIterator()
235 const InternalKey* largest = &file_meta.largest; in NewIterator()
261 const FileMetaData& file_meta, in GetRangeTombstoneIterator() argument
263 const FileDescriptor& fd = file_meta.fd; in GetRangeTombstoneIterator()
355 const FileMetaData& file_meta, const Slice& k, in Get() argument
360 auto& fd = file_meta.fd; in Get()
436 const FileMetaData& file_meta, in MultiGet() argument
441 auto& fd = file_meta.fd; in MultiGet()
Dversion_builder.cc681 auto* file_meta = file_meta_pair.second; in LoadTableHandlers() local
683 if (!file_meta->table_reader_handle) { in LoadTableHandlers()
684 files_meta.emplace_back(file_meta, level); in LoadTableHandlers()
704 auto* file_meta = files_meta[file_idx].first; in LoadTableHandlers() local
708 file_meta->fd, &file_meta->table_reader_handle, prefix_extractor, in LoadTableHandlers()
712 if (file_meta->table_reader_handle != nullptr) { in LoadTableHandlers()
714 file_meta->fd.table_reader = table_cache_->GetTableReaderFromHandle( in LoadTableHandlers()
715 file_meta->table_reader_handle); in LoadTableHandlers()
Ddb_sst_test.cc1061 for (const auto& file_meta : live_files_meta) { in TEST_F() local
1062 live_sst_files_size += file_meta.size; in TEST_F()
1085 for (const auto& file_meta : live_files_meta) { in TEST_F() local
1086 live_sst_files_size += file_meta.size; in TEST_F()
1153 for (const auto& file_meta : live_files_meta) { in TEST_F() local
1154 live_sst_files_size += file_meta.size; in TEST_F()
1178 for (const auto& file_meta : live_files_meta) { in TEST_F() local
1179 live_sst_files_size += file_meta.size; in TEST_F()
Dmemtable_list.h142 const autovector<FileMetaData*>& file_meta,
382 const autovector<FileMetaData*>& file_meta,
424 InstrumentedMutex* mu, const autovector<FileMetaData*>& file_meta,
Dflush_job.cc194 FileMetaData* file_meta) { in Run() argument
251 if (s.ok() && file_meta != nullptr) { in Run()
252 *file_meta = meta_; in Run()
Dversion_set.h136 void UpdateAccumulatedStats(FileMetaData* file_meta);
139 void RemoveCurrentStats(FileMetaData* file_meta);
645 const FileMetaData* file_meta,
721 bool MaybeInitializeFileMetaData(FileMetaData* file_meta);
Dflush_job.h83 FileMetaData* file_meta = nullptr);
Ddb_compaction_test.cc2698 auto file_meta = PickFileRandomly(cf_meta, &rnd, &level); in TEST_P() local
2699 compaction_input_file_names.push_back(file_meta->name); in TEST_P()
2702 file_meta, &overlapping_file_names); in TEST_P()
/rocksdb-6.9/tools/
Dldb_cmd_test.cc116 Status VerifyChecksum(LiveFileMetaData& file_meta) { in VerifyChecksum() argument
123 std::string file_path = dbname_ + "/" + file_meta.name; in VerifyChecksum()
137 gen_context.file_name = file_meta.name; in VerifyChecksum()
156 std::string stored_checksum = file_meta.file_checksum; in VerifyChecksum()
157 std::string stored_checksum_func_name = file_meta.file_checksum_func_name; in VerifyChecksum()
161 "Checksum does not match! The file: " + file_meta.name + in VerifyChecksum()
Ddb_bench_tool.cc4692 for (auto file_meta : meta.levels[0].files) { in DoDeterministicCompact() local
4693 file_names.emplace_back(file_meta.name); in DoDeterministicCompact()
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc158 FileMetaData file_meta; in FlushMemTableToOutputFile() local
192 s = flush_job.Run(&logs_with_prep_tracker_, &file_meta); in FlushMemTableToOutputFile()
352 std::vector<FileMetaData> file_meta(num_cfs); in AtomicFlushMemTablesToOutputFiles() local
387 jobs[i]->Run(&logs_with_prep_tracker_, &file_meta[i]); in AtomicFlushMemTablesToOutputFiles()
398 assert(!file_meta.empty()); in AtomicFlushMemTablesToOutputFiles()
400 jobs[0]->Run(&logs_with_prep_tracker_, &file_meta[0]); in AtomicFlushMemTablesToOutputFiles()
519 tmp_file_meta.emplace_back(&file_meta[i]); in AtomicFlushMemTablesToOutputFiles()
612 const uint64_t file_number = file_meta->fd.GetNumber(); in NotifyOnFlushBegin()
620 info.smallest_seqno = file_meta->fd.smallest_seqno; in NotifyOnFlushBegin()
621 info.largest_seqno = file_meta->fd.largest_seqno; in NotifyOnFlushBegin()
[all …]
Ddb_impl.h1038 void NotifyOnFlushBegin(ColumnFamilyData* cfd, FileMetaData* file_meta,
/rocksdb-6.9/db/compaction/
Dcompaction_picker.cc1008 for (const auto& file_meta : level_meta.files) { in SanitizeCompactionInputFiles() local
1009 if (file_num == TableFileNameToNumber(file_meta.name)) { in SanitizeCompactionInputFiles()
1010 if (file_meta.being_compacted) { in SanitizeCompactionInputFiles()
Dcompaction_job.cc1642 const auto* file_meta = compaction->input(input_level, i); in UpdateCompactionInputStatsHelper() local
1643 *bytes_read += file_meta->fd.GetFileSize(); in UpdateCompactionInputStatsHelper()
1645 static_cast<uint64_t>(file_meta->num_entries); in UpdateCompactionInputStatsHelper()