Home
last modified time | relevance | path

Searched refs:vstorage (Results 1 – 25 of 27) sorted by relevance

12

/rocksdb-6.9/db/compaction/
Dcompaction_picker.cc114 level >= (vstorage->num_non_empty_levels() - 1)) { in GetCompressionType()
346 base_level = vstorage->base_level(); in CompactFiles()
380 matched_input_files.resize(vstorage->num_levels()); in GetCompactionInputsFromFileNumbers()
386 for (auto file : vstorage->LevelFiles(level)) { in GetCompactionInputsFromFileNumbers()
458 assert(vstorage->NumLevelFiles(l) == 0); in SetupOtherInputs()
517 ExpandInputsToCleanCut(cf_name, vstorage, in SetupOtherInputs()
578 assert(vstorage->num_levels() > 1); in CompactRange()
591 for (; start_level < vstorage->num_levels() && in CompactRange()
595 if (start_level == vstorage->num_levels()) { in CompactRange()
742 output_level = vstorage->base_level(); in CompactRange()
[all …]
Dcompaction_picker_fifo.cc32 const VersionStorageInfo* vstorage) const { in NeedsCompaction()
34 return vstorage->CompactionScore(kLevel0) >= 1; in NeedsCompaction()
39 VersionStorageInfo* vstorage, LogBuffer* log_buffer) { in PickTTLCompaction() argument
105 {}, /* is manual */ false, vstorage->CompactionScore(0), in PickTTLCompaction()
112 VersionStorageInfo* vstorage, LogBuffer* log_buffer) { in PickSizeCompaction() argument
141 vstorage, ioptions_, mutable_cf_options, {comp_inputs}, 0, in PickSizeCompaction()
146 /* is manual */ false, vstorage->CompactionScore(0), in PickSizeCompaction()
194 {}, /* is manual */ false, vstorage->CompactionScore(0), in PickSizeCompaction()
201 VersionStorageInfo* vstorage, LogBuffer* log_buffer, in PickCompaction() argument
203 assert(vstorage->num_levels() == 1); in PickCompaction()
[all …]
Dcompaction_picker.h59 VersionStorageInfo* vstorage, LogBuffer* log_buffer,
75 VersionStorageInfo* vstorage, int input_level, int output_level,
114 int output_level, VersionStorageInfo* vstorage,
123 const VersionStorageInfo* vstorage,
169 VersionStorageInfo* vstorage,
174 bool IsRangeInCompaction(VersionStorageInfo* vstorage,
185 VersionStorageInfo* vstorage,
190 void GetGrandparents(VersionStorageInfo* vstorage,
196 VersionStorageInfo* vstorage,
200 bool GetOverlappingL0Files(VersionStorageInfo* vstorage,
[all …]
Dcompaction.cc76 VersionStorageInfo* vstorage, in GetBoundaryKeys() argument
162 int output_level, VersionStorageInfo* vstorage, in IsBottommostLevel() argument
167 for (const auto* file : vstorage->LevelFiles(0)) { in IsBottommostLevel()
186 int output_level, VersionStorageInfo* vstorage, in TEST_IsBottommostLevel() argument
188 return IsBottommostLevel(output_level, vstorage, inputs); in TEST_IsBottommostLevel()
192 VersionStorageInfo* vstorage, in IsFullCompaction() argument
196 for (int l = 0; l < vstorage->num_levels(); l++) { in IsFullCompaction()
197 total_num_files += vstorage->NumLevelFiles(l); in IsFullCompaction()
205 Compaction::Compaction(VersionStorageInfo* vstorage, in Compaction() argument
218 : input_vstorage_(vstorage), in Compaction()
[all …]
Dcompaction_picker_level.cc21 const VersionStorageInfo* vstorage) const { in NeedsCompaction()
22 if (!vstorage->ExpiredTtlFiles().empty()) { in NeedsCompaction()
25 if (!vstorage->FilesMarkedForPeriodicCompaction().empty()) { in NeedsCompaction()
28 if (!vstorage->BottommostFilesMarkedForCompaction().empty()) { in NeedsCompaction()
31 if (!vstorage->FilesMarkedForCompaction().empty()) { in NeedsCompaction()
34 for (int i = 0; i <= vstorage->MaxInputLevel(); i++) { in NeedsCompaction()
35 if (vstorage->CompactionScore(i) >= 1) { in NeedsCompaction()
47 VersionStorageInfo* vstorage, in LevelCompactionBuilder() argument
54 vstorage_(vstorage), in LevelCompactionBuilder()
552 VersionStorageInfo* vstorage, LogBuffer* log_buffer, in PickCompaction() argument
[all …]
Dcompaction_picker_universal.cc38 VersionStorageInfo* vstorage, in UniversalCompactionBuilder() argument
45 vstorage_(vstorage), in UniversalCompactionBuilder()
265 const VersionStorageInfo* vstorage) const { in NeedsCompaction()
267 if (vstorage->CompactionScore(kLevel0) >= 1) { in NeedsCompaction()
270 if (!vstorage->FilesMarkedForPeriodicCompaction().empty()) { in NeedsCompaction()
273 if (!vstorage->FilesMarkedForCompaction().empty()) { in NeedsCompaction()
281 VersionStorageInfo* vstorage, LogBuffer* log_buffer, in PickCompaction() argument
284 mutable_cf_options, vstorage, this, in PickCompaction()
331 for (FileMetaData* f : vstorage.LevelFiles(0)) { in CalculateSortedRuns()
335 for (int level = 1; level < vstorage.num_levels(); level++) { in CalculateSortedRuns()
[all …]
Dcompaction.h267 int output_level, VersionStorageInfo* vstorage,
301 static void GetBoundaryKeys(VersionStorageInfo* vstorage,
310 VersionStorageInfo* vstorage, std::vector<CompactionInputFiles> inputs);
315 int output_level, VersionStorageInfo* vstorage,
318 static bool IsFullCompaction(VersionStorageInfo* vstorage,
Dcompaction_picker_level.h25 VersionStorageInfo* vstorage, LogBuffer* log_buffer,
29 const VersionStorageInfo* vstorage) const override;
Dcompaction_picker_universal.h23 VersionStorageInfo* vstorage, LogBuffer* log_buffer,
28 const VersionStorageInfo* vstorage) const override;
Dcompaction_picker_fifo.h29 VersionStorageInfo* vstorage, int input_level, int output_level,
39 const VersionStorageInfo* vstorage) const override;
/rocksdb-6.9/db/
Dversion_builder.cc176 assert(vstorage); in CheckConsistencyOfOldestBlobFileReference()
502 VersionStorageInfo* vstorage, in AddBlobFileIfNeeded() argument
504 assert(vstorage); in AddBlobFileIfNeeded()
508 vstorage->AddBlobFile(meta); in AddBlobFileIfNeeded()
516 assert(vstorage); in SaveBlobFilesTo()
586 s = CheckConsistency(vstorage); in SaveTo()
597 vstorage->Reserve(level, in SaveTo()
633 SaveBlobFilesTo(vstorage); in SaveTo()
635 s = CheckConsistency(vstorage); in SaveTo()
739 vstorage->RemoveCurrentStats(f); in MaybeAddFile()
[all …]
Dcompacted_db_impl.cc105 auto* vstorage = version_->storage_info(); in Init() local
106 if (vstorage->num_non_empty_levels() == 0) { in Init()
109 const LevelFilesBrief& l0 = vstorage->LevelFilesBrief(0); in Init()
115 if (vstorage->num_non_empty_levels() > 1) { in Init()
122 for (int i = 1; i < vstorage->num_non_empty_levels() - 1; ++i) { in Init()
123 if (vstorage->LevelFilesBrief(i).num_files > 0) { in Init()
128 int level = vstorage->num_non_empty_levels() - 1; in Init()
129 if (vstorage->LevelFilesBrief(level).num_files > 0) { in Init()
130 files_ = vstorage->LevelFilesBrief(level); in Init()
Dforward_iterator.cc433 vstorage->LevelFiles(level); in SeekInternal()
637 const auto* vstorage = sv_->current->storage_info(); in RebuildIterators() local
638 const auto& l0_files = vstorage->LevelFiles(0); in RebuildIterators()
660 BuildLevelIterators(vstorage); in RebuildIterators()
698 const auto* vstorage = sv_->current->storage_info(); in RenewIterators() local
699 const auto& l0_files = vstorage->LevelFiles(0); in RenewIterators()
763 level_iters_.reserve(vstorage->num_levels() - 1); in BuildLevelIterators()
765 const auto& level_files = vstorage->LevelFiles(level); in BuildLevelIterators()
882 const std::vector<FileMetaData*>& l0 = vstorage->LevelFiles(0); in DeleteCurrentIter()
926 (!vstorage->LevelFiles(level).empty())) { in TEST_CheckDeletedIters()
[all …]
Dcolumn_family_test.cc2676 vstorage->set_l0_delay_trigger_count(0); in TEST_P()
2695 vstorage->set_l0_delay_trigger_count(0); in TEST_P()
2707 vstorage->set_l0_delay_trigger_count(50); in TEST_P()
2772 vstorage->set_l0_delay_trigger_count(7); in TEST_P()
2776 vstorage->set_l0_delay_trigger_count(9); in TEST_P()
2780 vstorage->set_l0_delay_trigger_count(6); in TEST_P()
2789 vstorage->set_l0_delay_trigger_count(5); in TEST_P()
2793 vstorage->set_l0_delay_trigger_count(7); in TEST_P()
2797 vstorage->set_l0_delay_trigger_count(3); in TEST_P()
2929 vstorage->set_l0_delay_trigger_count(9); in TEST_P()
[all …]
Dinternal_stats.cc536 const auto* vstorage = cfd_->current()->storage_info(); in HandleNumFilesAtLevel() local
572 vstorage->NumLevelFiles(level), in HandleLevelStats()
573 vstorage->NumLevelBytes(level) / kMB); in HandleLevelStats()
808 *value = vstorage->base_level(); in HandleBaseLevel()
841 const auto* vstorage = version->storage_info(); in HandleEstimateLiveDataSize() local
842 *value = vstorage->EstimateLiveDataSize(); in HandleEstimateLiveDataSize()
1108 ? vstorage->num_levels() - 1 in DumpCFMapStats()
1116 vstorage->CompactionScore(i); in DumpCFMapStats()
1121 for (auto* f : vstorage->LevelFiles(level)) { in DumpCFMapStats()
1135 int files = vstorage->NumLevelFiles(level); in DumpCFMapStats()
[all …]
Dexternal_sst_file_ingestion_job.cc312 auto vstorage = cfd_->current()->storage_info(); in UpdateStats() local
313 for (int level = 0; level < vstorage->num_levels(); ++level) { in UpdateStats()
314 stream << vstorage->NumLevelFiles(level); in UpdateStats()
545 auto* vstorage = cfd_->current()->storage_info(); in AssignLevelAndSeqnoForIngestedFile() local
548 if (lvl > 0 && lvl < vstorage->base_level()) { in AssignLevelAndSeqnoForIngestedFile()
552 if (vstorage->NumLevelFiles(lvl) > 0) { in AssignLevelAndSeqnoForIngestedFile()
571 vstorage->LevelFiles(lvl); in AssignLevelAndSeqnoForIngestedFile()
615 auto* vstorage = cfd_->current()->storage_info(); in CheckLevelForIngestedBehindFile() local
627 for (auto file : vstorage->LevelFiles(lvl)) { in CheckLevelForIngestedBehindFile()
697 auto* vstorage = cfd_->current()->storage_info(); in IngestedFileFitInLevel() local
[all …]
Dcolumn_family.cc852 auto* vstorage = current_->storage_info(); in RecalculateWriteStallConditions() local
855 vstorage->estimated_compaction_needed_bytes(); in RecalculateWriteStallConditions()
858 imm()->NumNotFlushed(), vstorage->l0_delay_trigger_count(), in RecalculateWriteStallConditions()
915 bool near_stop = vstorage->l0_delay_trigger_count() >= in RecalculateWriteStallConditions()
930 name_.c_str(), vstorage->l0_delay_trigger_count(), in RecalculateWriteStallConditions()
955 name_.c_str(), vstorage->estimated_compaction_needed_bytes(), in RecalculateWriteStallConditions()
959 if (vstorage->l0_delay_trigger_count() >= in RecalculateWriteStallConditions()
969 name_.c_str(), vstorage->l0_delay_trigger_count()); in RecalculateWriteStallConditions()
970 } else if (vstorage->estimated_compaction_needed_bytes() >= in RecalculateWriteStallConditions()
1095 auto* vstorage = super_version->current->storage_info(); in RangesOverlapWithMemtables() local
[all …]
Dflush_job.cc264 auto vstorage = cfd_->current()->storage_info(); in Run() local
265 for (int level = 0; level < vstorage->num_levels(); ++level) { in Run()
266 stream << vstorage->NumLevelFiles(level); in Run()
Dversion_set.cc1423 auto* vstorage = storage_info(); in GetColumnFamilyMetaData() local
4878 auto* vstorage = current_version->storage_info(); in ReduceNumberOfLevels() local
4879 int current_levels = vstorage->num_levels(); in ReduceNumberOfLevels()
4890 int file_num = vstorage->NumLevelFiles(i); in ReduceNumberOfLevels()
4913 new_files_list[i] = vstorage->LevelFiles(i); in ReduceNumberOfLevels()
4920 delete[] vstorage -> files_; in ReduceNumberOfLevels()
4921 vstorage->files_ = new_files_list; in ReduceNumberOfLevels()
4922 vstorage->num_levels_ = new_levels; in ReduceNumberOfLevels()
5292 const auto* vstorage = v->storage_info(); in ApproximateSize() local
5484 const auto* vstorage = v->storage_info(); in AddLiveFiles() local
[all …]
Dversion_builder.h38 Status SaveTo(VersionStorageInfo* vstorage);
Dforward_iterator.h98 void BuildLevelIterators(const VersionStorageInfo* vstorage);
Dversion_set_test.cc1918 VersionStorageInfo* vstorage = cfd->current()->storage_info(); in TEST_F() local
1919 const std::vector<FileMetaData*>& files = vstorage->LevelFiles(0); in TEST_F()
1969 VersionStorageInfo* vstorage = cfd->current()->storage_info(); in TEST_F() local
1970 const std::vector<FileMetaData*>& files = vstorage->LevelFiles(0); in TEST_F()
2018 VersionStorageInfo* vstorage = cfd->current()->storage_info(); in TEST_F() local
2019 const std::vector<FileMetaData*>& files = vstorage->LevelFiles(0); in TEST_F()
/rocksdb-6.9/db/db_impl/
Ddb_impl_experimental.cc36 auto vstorage = cfd->current()->storage_info(); in SuggestCompactRange() local
37 for (int level = 0; level < vstorage->num_non_empty_levels() - 1; ++level) { in SuggestCompactRange()
39 vstorage->GetOverlappingInputs( in SuggestCompactRange()
48 vstorage->ComputeCompactionScore(*cfd->ioptions(), in SuggestCompactRange()
71 const auto* vstorage = cfd->current()->storage_info(); in PromoteL0() local
73 if (target_level >= vstorage->num_levels()) { in PromoteL0()
83 auto l0_files = vstorage->LevelFiles(0); in PromoteL0()
115 if (vstorage->NumLevelFiles(level) > 0) { in PromoteL0()
Ddb_impl.cc1137 const auto* vstorage = cfd->current()->storage_info(); in FindMinimumEmptyLevelFitting() local
1141 if (vstorage->NumLevelFiles(i) > 0) break; in FindMinimumEmptyLevelFitting()
1143 if (vstorage->MaxBytesForLevel(i) < vstorage->NumLevelBytes(level)) { in FindMinimumEmptyLevelFitting()
3270 auto* vstorage = input_version->storage_info(); in DeleteFilesInRanges() local
3274 if (vstorage->LevelFiles(i).empty() || in DeleteFilesInRanges()
3275 !vstorage->OverlapInLevel(i, begin, end)) { in DeleteFilesInRanges()
3293 vstorage->GetCleanInputsWithinInterval( in DeleteFilesInRanges()
4414 VersionStorageInfo* vstorage = sv->current->storage_info(); in VerifyChecksum() local
4422 for (int i = 0; i < vstorage->num_non_empty_levels() && s.ok(); i++) { in VerifyChecksum()
4423 for (size_t j = 0; j < vstorage->LevelFilesBrief(i).num_files && s.ok(); in VerifyChecksum()
[all …]
Ddb_impl_compaction_flush.cc1289 auto* vstorage = cfd->current()->storage_info(); in ReFitLevel() local
1297 if (vstorage->NumLevelFiles(l) > 0) { in ReFitLevel()
1310 for (const auto& f : vstorage->LevelFiles(level)) { in ReFitLevel()
1840 const auto* vstorage = cfd->current()->storage_info(); in WaitUntilFlushWouldNotStallWrites() local
1848 vstorage->l0_delay_trigger_count() < in WaitUntilFlushWouldNotStallWrites()
1859 vstorage->l0_delay_trigger_count() + 1, in WaitUntilFlushWouldNotStallWrites()
1860 vstorage->estimated_compaction_needed_bytes(), mutable_cf_options) in WaitUntilFlushWouldNotStallWrites()

12