Lines Matching refs:CompactionJob
107 struct CompactionJob::SubcompactionState {
236 struct CompactionJob::CompactionState {
241 std::vector<CompactionJob::SubcompactionState> sub_compact_states;
284 void CompactionJob::AggregateStatistics() { in AggregateStatistics()
296 CompactionJob::CompactionJob( in CompactionJob() function in ROCKSDB_NAMESPACE::CompactionJob
348 CompactionJob::~CompactionJob() { in ~CompactionJob()
353 void CompactionJob::ReportStartedCompaction(Compaction* compaction) { in ReportStartedCompaction()
397 void CompactionJob::Prepare() { in Prepare()
438 void CompactionJob::GenSubcompactionBoundaries() { in GenSubcompactionBoundaries()
566 Status CompactionJob::Run() { in Run()
581 thread_pool.emplace_back(&CompactionJob::ProcessKeyValueCompaction, this, in Run()
712 Status CompactionJob::Install(const MutableCFOptions& mutable_cf_options) { in Install()
813 void CompactionJob::ProcessKeyValueCompaction(SubcompactionState* sub_compact) { in ProcessKeyValueCompaction()
1079 void CompactionJob::RecordDroppedKeys( in RecordDroppedKeys()
1116 Status CompactionJob::FinishCompactionOutputFile( in FinishCompactionOutputFile()
1411 Status CompactionJob::InstallCompactionResults( in InstallCompactionResults()
1450 void CompactionJob::RecordCompactionIOStats() { in RecordCompactionIOStats()
1461 Status CompactionJob::OpenCompactionOutputFile( in OpenCompactionOutputFile()
1558 void CompactionJob::CleanupCompaction() { in CleanupCompaction()
1592 void CompactionJob::UpdateCompactionStats() { in UpdateCompactionStats()
1634 void CompactionJob::UpdateCompactionInputStatsHelper(int* num_files, in UpdateCompactionInputStatsHelper()
1649 void CompactionJob::UpdateCompactionJobStats( in UpdateCompactionJobStats()
1684 void CompactionJob::LogCompaction() { in LogCompaction()