Home
last modified time | relevance | path

Searched refs:VersionStorageInfo (Results 1 – 25 of 26) sorted by relevance

12

/rocksdb-6.9/db/compaction/
Dcompaction_picker.h33 class VersionStorageInfo; variable
59 VersionStorageInfo* vstorage, LogBuffer* log_buffer,
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,
261 VersionStorageInfo* /*vstorage*/, in CompactRange() argument
[all …]
Dcompaction.h65 class VersionStorageInfo; variable
71 Compaction(VersionStorageInfo* input_version,
267 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,
321 VersionStorageInfo* input_vstorage_;
Dcompaction_picker_fifo.h24 VersionStorageInfo* version, LogBuffer* log_buffer,
29 VersionStorageInfo* vstorage, int input_level, int output_level,
39 const VersionStorageInfo* vstorage) const override;
44 VersionStorageInfo* version,
49 VersionStorageInfo* version,
Dcompaction_picker_fifo.cc32 const VersionStorageInfo* vstorage) const { in NeedsCompaction()
39 VersionStorageInfo* vstorage, LogBuffer* log_buffer) { in PickTTLCompaction()
112 VersionStorageInfo* vstorage, LogBuffer* log_buffer) { in PickSizeCompaction()
201 VersionStorageInfo* vstorage, LogBuffer* log_buffer, in PickCompaction()
218 VersionStorageInfo* vstorage, int input_level, int output_level, in CompactRange()
Dcompaction_picker.cc102 const VersionStorageInfo* vstorage, in GetCompressionType()
136 const VersionStorageInfo* vstorage, in GetCompressionOptions()
243 VersionStorageInfo* vstorage, in ExpandInputsToCleanCut()
334 VersionStorageInfo* vstorage, const MutableCFOptions& mutable_cf_options, in CompactFiles()
371 std::unordered_set<uint64_t>* input_set, const VersionStorageInfo* vstorage, in GetCompactionInputsFromFileNumbers()
419 bool CompactionPicker::IsRangeInCompaction(VersionStorageInfo* vstorage, in IsRangeInCompaction()
443 VersionStorageInfo* vstorage, CompactionInputFiles* inputs, in SetupOtherInputs()
551 VersionStorageInfo* vstorage, const CompactionInputFiles& inputs, in GetGrandparents()
566 VersionStorageInfo* vstorage, int input_level, int output_level, in CompactRange()
1060 const std::string& cf_name, VersionStorageInfo* vstorage, int* start_level, in PickFilesMarkedForCompaction()
[all …]
Dcompaction.cc76 VersionStorageInfo* vstorage, in GetBoundaryKeys()
117 VersionStorageInfo* vstorage, std::vector<CompactionInputFiles> inputs) { in PopulateWithAtomicBoundaries()
162 int output_level, VersionStorageInfo* vstorage, in IsBottommostLevel()
186 int output_level, VersionStorageInfo* vstorage, in TEST_IsBottommostLevel()
192 VersionStorageInfo* vstorage, in IsFullCompaction()
205 Compaction::Compaction(VersionStorageInfo* vstorage, in Compaction()
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_level.cc21 const VersionStorageInfo* vstorage) const { in NeedsCompaction()
47 VersionStorageInfo* vstorage, in LevelCompactionBuilder()
101 VersionStorageInfo* vstorage_;
552 VersionStorageInfo* vstorage, LogBuffer* log_buffer, in PickCompaction()
Dcompaction_picker_universal.cc38 VersionStorageInfo* vstorage, in UniversalCompactionBuilder()
118 VersionStorageInfo* vstorage_;
123 const VersionStorageInfo& vstorage, const ImmutableCFOptions& ioptions,
265 const VersionStorageInfo* vstorage) const { in NeedsCompaction()
281 VersionStorageInfo* vstorage, LogBuffer* log_buffer, in PickCompaction()
328 const VersionStorageInfo& vstorage, const ImmutableCFOptions& /*ioptions*/, in CalculateSortedRuns()
389 VersionStorageInfo::LevelSummaryStorage tmp; in PickCompaction()
Dcompaction_picker_test.cc42 std::unique_ptr<VersionStorageInfo> vstorage_;
76 vstorage_.reset(new VersionStorageInfo(&icmp_, ucmp_, options_.num_levels, in NewVersionStorage()
Dcompaction_job.cc728 VersionStorageInfo::LevelSummaryStorage tmp; in Install()
/rocksdb-6.9/db/
Dversion_builder_test.cc25 VersionStorageInfo vstorage_;
95 const VersionStorageInfo::BlobFiles& blob_files, in GetBlobFileMetaData()
120 void UnrefFilesInVersion(VersionStorageInfo* new_vstorage) { in UnrefFilesInVersion()
158 VersionStorageInfo new_vstorage(&icmp_, ucmp_, options_.num_levels, in TEST_F()
196 VersionStorageInfo new_vstorage(&icmp_, ucmp_, options_.num_levels, in TEST_F()
239 VersionStorageInfo new_vstorage(&icmp_, ucmp_, options_.num_levels, in TEST_F()
285 VersionStorageInfo new_vstorage(&icmp_, ucmp_, options_.num_levels, in TEST_F()
300 VersionStorageInfo new_vstorage(&icmp_, ucmp_, options_.num_levels, in TEST_F()
372 VersionStorageInfo new_vstorage(&icmp_, ucmp_, options_.num_levels, in TEST_F()
479 VersionStorageInfo new_vstorage(&icmp_, ucmp_, options_.num_levels, in TEST_F()
[all …]
Dversion_builder.cc92 VersionStorageInfo* base_vstorage_;
112 VersionStorageInfo* base_vstorage) in Rep()
175 const VersionStorageInfo* vstorage, uint64_t blob_file_number) const { in CheckConsistencyOfOldestBlobFileReference()
200 Status CheckConsistency(VersionStorageInfo* vstorage) { in CheckConsistency()
502 VersionStorageInfo* vstorage, in AddBlobFileIfNeeded()
514 void SaveBlobFilesTo(VersionStorageInfo* vstorage) const { in SaveBlobFilesTo()
580 Status SaveTo(VersionStorageInfo* vstorage) { in SaveTo()
736 void MaybeAddFile(VersionStorageInfo* vstorage, int level, FileMetaData* f) { in MaybeAddFile()
748 VersionStorageInfo* base_vstorage, in VersionBuilder()
760 Status VersionBuilder::SaveTo(VersionStorageInfo* vstorage) { in SaveTo()
Dversion_builder.h20 class VersionStorageInfo; variable
33 VersionStorageInfo* base_vstorage, Logger* info_log = nullptr);
38 Status SaveTo(VersionStorageInfo* vstorage);
Dversion_set.h108 class VersionStorageInfo {
110 VersionStorageInfo(const InternalKeyComparator* internal_comparator,
113 VersionStorageInfo* src_vstorage,
116 VersionStorageInfo(const VersionStorageInfo&) = delete;
117 void operator=(const VersionStorageInfo&) = delete;
118 ~VersionStorageInfo();
683 VersionStorageInfo* storage_info() { return &storage_info_; } in storage_info()
738 VersionStorageInfo storage_info_;
Dversion_set.cc735 VersionStorageInfo::~VersionStorageInfo() { delete[] files_; } in ~VersionStorageInfo()
1659 VersionStorageInfo::VersionStorageInfo( in VersionStorageInfo() function in ROCKSDB_NAMESPACE::VersionStorageInfo
2066 void VersionStorageInfo::GenerateLevelFilesBrief() { in GenerateLevelFilesBrief()
2224 int VersionStorageInfo::MaxInputLevel() const { in MaxInputLevel()
2348 void VersionStorageInfo::ComputeCompactionScore( in ComputeCompactionScore()
2476 void VersionStorageInfo::ComputeExpiredTtlFiles( in ComputeExpiredTtlFiles()
2602 void VersionStorageInfo::AddBlobFile( in AddBlobFile()
2624 void VersionStorageInfo::SetFinalized() { in SetFinalized()
2871 bool VersionStorageInfo::OverlapInLevel(int level, in OverlapInLevel()
2887 void VersionStorageInfo::GetOverlappingInputs( in GetOverlappingInputs()
[all …]
Dforward_iterator.h27 class VersionStorageInfo; variable
98 void BuildLevelIterators(const VersionStorageInfo* vstorage);
Dforward_iterator.cc396 const VersionStorageInfo* vstorage = sv_->current->storage_info(); in SeekInternal()
762 void ForwardIterator::BuildLevelIterators(const VersionStorageInfo* vstorage) { in BuildLevelIterators()
881 const VersionStorageInfo* vstorage = sv_->current->storage_info(); in DeleteCurrentIter()
913 const VersionStorageInfo* vstorage = sv_->current->storage_info(); in TEST_CheckDeletedIters()
Dcolumn_family_test.cc2565 VersionStorageInfo* vstorage = cfd->current()->storage_info(); in TEST_P()
2744 VersionStorageInfo* vstorage = cfd->current()->storage_info(); in TEST_P()
2809 VersionStorageInfo* vstorage = cfd->current()->storage_info(); in TEST_P()
2813 VersionStorageInfo* vstorage1 = cfd1->current()->storage_info(); in TEST_P()
2885 VersionStorageInfo* vstorage = cfd->current()->storage_info(); in TEST_P()
2889 VersionStorageInfo* vstorage1 = cfd1->current()->storage_info(); in TEST_P()
Dversion_set_test.cc107 VersionStorageInfo vstorage_;
1918 VersionStorageInfo* vstorage = cfd->current()->storage_info(); in TEST_F()
1969 VersionStorageInfo* vstorage = cfd->current()->storage_info(); in TEST_F()
2018 VersionStorageInfo* vstorage = cfd->current()->storage_info(); in TEST_F()
Dcolumn_family.h34 class VersionStorageInfo; variable
Dinternal_stats.cc1104 const VersionStorageInfo* vstorage = cfd_->current()->storage_info(); in DumpCFMapStats()
/rocksdb-6.9/db/db_impl/
Ddb_impl_secondary.cc522 VersionStorageInfo::LevelSummaryStorage tmp; in TryCatchUpWithPrimary()
Ddb_impl_compaction_flush.cc204 VersionStorageInfo::LevelSummaryStorage tmp; in FlushMemTableToOutputFile()
539 VersionStorageInfo::LevelSummaryStorage tmp; in AtomicFlushMemTablesToOutputFiles()
2759 VersionStorageInfo::LevelSummaryStorage tmp; in BackgroundCompaction()

12