| /rocksdb-6.9/db/compaction/ |
| D | compaction.cc | 75 void Compaction::GetBoundaryKeys( in GetBoundaryKeys()
161 bool Compaction::IsBottommostLevel( in IsBottommostLevel()
185 bool Compaction::TEST_IsBottommostLevel( in TEST_IsBottommostLevel()
191 bool Compaction::IsFullCompaction( in IsFullCompaction()
205 Compaction::Compaction(VersionStorageInfo* vstorage, in Compaction() function in ROCKSDB_NAMESPACE::Compaction
273 Compaction::~Compaction() { in ~Compaction()
295 bool Compaction::IsTrivialMove() const { in IsTrivialMove()
402 const char* Compaction::InputLevelSummary( in InputLevelSummary()
443 void Compaction::ResetNextCompactionIndex() { in ResetNextCompactionIndex()
528 bool Compaction::IsOutputLevelEmpty() const { in IsOutputLevelEmpty()
[all …]
|
| D | compaction_picker.h | 32 class Compaction; variable
57 virtual Compaction* PickCompaction(
73 virtual Compaction* CompactRange(
101 void ReleaseCompactionFiles(Compaction* c, Status status);
205 void RegisterCompaction(Compaction* c);
208 void UnregisterCompaction(Compaction* c);
210 std::set<Compaction*>* level0_compactions_in_progress() { in level0_compactions_in_progress()
230 std::set<Compaction*> level0_compactions_in_progress_;
234 std::unordered_set<Compaction*> compactions_in_progress_;
250 Compaction* PickCompaction( in PickCompaction()
[all …]
|
| D | compaction_picker_test.cc | 140 std::unique_ptr<Compaction> compaction(level_compaction_picker.PickCompaction( in TEST_F()
439 std::unique_ptr<Compaction> compaction( in TEST_F()
473 std::unique_ptr<Compaction> compaction( in TEST_F()
499 std::unique_ptr<Compaction> compaction( in TEST_F()
527 std::unique_ptr<Compaction> compaction( in TEST_F()
557 std::unique_ptr<Compaction> compaction( in TEST_F()
583 std::unique_ptr<Compaction> compaction( in TEST_F()
613 std::unique_ptr<Compaction> compaction( in TEST_F()
633 std::unique_ptr<Compaction> compaction( in TEST_F()
657 std::unique_ptr<Compaction> compaction( in TEST_F()
[all …]
|
| D | compaction_picker_fifo.cc | 37 Compaction* FIFOCompactionPicker::PickTTLCompaction( in PickTTLCompaction()
102 Compaction* c = new Compaction( in PickTTLCompaction()
110 Compaction* FIFOCompactionPicker::PickSizeCompaction( in PickSizeCompaction()
140 Compaction* c = new Compaction( in PickSizeCompaction()
191 Compaction* c = new Compaction( in PickSizeCompaction()
199 Compaction* FIFOCompactionPicker::PickCompaction( in PickCompaction()
205 Compaction* c = nullptr; in PickCompaction()
216 Compaction* FIFOCompactionPicker::CompactRange( in CompactRange()
231 Compaction* c = in CompactRange()
|
| D | compaction_picker_universal.cc | 50 Compaction* PickCompaction();
85 Compaction* PickCompactionToReduceSortedRuns(
89 Compaction* PickCompactionToReduceSizeAmp();
91 Compaction* PickDeleteTriggeredCompaction();
97 Compaction* PickCompactionToOldest(size_t start_index,
104 Compaction* PickPeriodicCompaction();
110 bool IsInputFilesNonOverlapping(Compaction* c);
395 Compaction* c = nullptr; in PickCompaction()
746 return new Compaction( in PickCompactionToReduceSortedRuns()
954 return new Compaction( in PickDeleteTriggeredCompaction()
[all …]
|
| D | compaction_picker_fifo.h | 22 virtual Compaction* PickCompaction(
27 virtual Compaction* CompactRange(
42 Compaction* PickTTLCompaction(const std::string& cf_name,
47 Compaction* PickSizeCompaction(const std::string& cf_name,
|
| D | compaction.h | 69 class Compaction {
71 Compaction(VersionStorageInfo* input_version,
84 Compaction(const Compaction&) = delete;
85 void operator=(const Compaction&) = delete;
87 ~Compaction();
|
| D | compaction_picker_level.cc | 62 Compaction* PickCompaction();
76 Compaction* GetCompaction();
347 Compaction* LevelCompactionBuilder::PickCompaction() { in PickCompaction()
369 Compaction* c = GetCompaction(); in PickCompaction()
376 Compaction* LevelCompactionBuilder::GetCompaction() { in GetCompaction()
377 auto c = new Compaction( in GetCompaction()
550 Compaction* LevelCompactionPicker::PickCompaction( in PickCompaction()
|
| D | compaction_picker.cc | 160 void CompactionPicker::ReleaseCompactionFiles(Compaction* c, Status status) { in ReleaseCompactionFiles()
288 for (Compaction* c : compactions_in_progress_) { in RangeOverlapWithCompaction()
331 Compaction* CompactionPicker::CompactFiles( in CompactFiles()
358 auto c = new Compaction( in CompactFiles()
564 Compaction* CompactionPicker::CompactRange( in CompactRange()
628 Compaction* c = new Compaction( in CompactRange()
780 Compaction* compaction = new Compaction( in CompactRange()
1034 void CompactionPicker::RegisterCompaction(Compaction* c) { in RegisterCompaction()
1048 void CompactionPicker::UnregisterCompaction(Compaction* c) { in UnregisterCompaction()
|
| D | compaction_iterator.h | 30 explicit CompactionProxy(const Compaction* compaction) in CompactionProxy()
59 const Compaction* compaction_;
69 const Compaction* compaction = nullptr,
|
| D | compaction_job.cc | 108 const Compaction* compaction;
158 SubcompactionState(Compaction* c, Slice* _start, Slice* _end, in SubcompactionState()
237 Compaction* const compaction;
247 explicit CompactionState(Compaction* c) in CompactionState()
353 void CompactionJob::ReportStartedCompaction(Compaction* compaction) { in ReportStartedCompaction()
1421 Compaction::InputLevelSummaryBuffer inputs_summary; in InstallCompactionResults()
1430 Compaction::InputLevelSummaryBuffer inputs_summary; in InstallCompactionResults()
1593 Compaction* compaction = compact_->compaction; in UpdateCompactionStats()
1637 const Compaction* compaction = compact_->compaction; in UpdateCompactionInputStatsHelper()
1685 Compaction* compaction = compact_->compaction; in LogCompaction()
[all …]
|
| D | compaction_job.h | 65 CompactionJob(int job_id, Compaction* compaction,
119 void ReportStartedCompaction(Compaction* compaction);
|
| D | compaction_picker_level.h | 23 virtual Compaction* PickCompaction(
|
| D | compaction_picker_universal.h | 21 virtual Compaction* PickCompaction(
|
| /rocksdb-6.9/db/ |
| D | column_family.h | 38 class Compaction; variable
389 Compaction* PickCompaction(const MutableCFOptions& mutable_options,
414 Compaction* CompactRange(const MutableCFOptions& mutable_cf_options,
|
| D | db_compaction_test.cc | 3496 Compaction* compaction = reinterpret_cast<Compaction*>(arg); in TEST_F()
3565 Compaction* compaction = reinterpret_cast<Compaction*>(arg); in TEST_F()
3612 Compaction* compaction = reinterpret_cast<Compaction*>(arg); in TEST_F()
3666 Compaction* compaction = reinterpret_cast<Compaction*>(arg); in TEST_F()
3813 Compaction* compaction = reinterpret_cast<Compaction*>(arg); in TEST_F()
3897 Compaction* compaction = reinterpret_cast<Compaction*>(arg); in TEST_F()
3968 Compaction* compaction = reinterpret_cast<Compaction*>(arg); in TEST_F()
4082 Compaction* compaction = reinterpret_cast<Compaction*>(arg); in TEST_F()
|
| D | db_dynamic_level_test.cc | 338 Compaction* compaction = reinterpret_cast<Compaction*>(arg); in TEST_F()
|
| D | version_set.h | 60 class Compaction; variable
1032 const Compaction* c, RangeDelAggregator* range_del_agg,
1053 bool VerifyCompactionFileConsistency(Compaction* c);
|
| D | db_universal_compaction_test.cc | 402 Compaction* c = static_cast<Compaction*>(arg); in TEST_P()
483 Compaction* c = static_cast<Compaction*>(arg); in TEST_P()
2194 Compaction* compaction = reinterpret_cast<Compaction*>(arg); in TEST_F()
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2014-04-21-indexing-sst-files-for-better-lookup-performance.markdown | 16 Compaction is scheduled periodically to pick up files from an upper level and merges them with file…
|
| D | 2015-07-23-dynamic-level.markdown | 2 title: Dynamic Level Size for Level-Based Compaction
|
| D | 2015-10-27-getthreadlist.markdown | 68 <td >Compaction
|
| /rocksdb-6.9/file/ |
| D | sst_file_manager_impl.h | 84 void OnCompactionCompletion(Compaction* c);
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl.h | 1046 void NotifyOnCompactionBegin(ColumnFamilyData* cfd, Compaction* c,
1050 void NotifyOnCompactionCompleted(ColumnFamilyData* cfd, Compaction* c,
1298 Compaction* compaction;
1667 void BuildCompactionJobInfo(const ColumnFamilyData* cfd, Compaction* c,
|
| D | db_impl_compaction_flush.cc | 1000 std::unique_ptr<Compaction> c; in CompactFilesImpl()
1144 void DBImpl::NotifyOnCompactionBegin(ColumnFamilyData* cfd, Compaction* c, in NotifyOnCompactionBegin()
1220 ColumnFamilyData* cfd, Compaction* c, const Status& st, in NotifyOnCompactionCompleted()
1508 Compaction* compaction = nullptr; in RunManualCompaction()
2489 std::unique_ptr<Compaction> c; in BackgroundCompaction()
3041 const ColumnFamilyData* cfd, Compaction* c, const Status& st, in BuildCompactionJobInfo()
|