285   for (SubcompactionState& sc : compact_->sub_compact_states) {  in AggregateStatistics()
286     compact_->total_bytes += sc.total_bytes;  in AggregateStatistics()
287     compact_->num_output_records += sc.num_output_records;  in AggregateStatistics()
290     for (SubcompactionState& sc : compact_->sub_compact_states) {  in AggregateStatistics()
310       compact_(new CompactionState(compaction)),  in CompactionJob()
341   const auto* cfd = compact_->compaction->column_family_data();  in CompactionJob()
349   assert(compact_ == nullptr);  in ~CompactionJob()
354   const auto* cfd = compact_->compaction->column_family_data();  in ReportStartedCompaction()
363       (static_cast<uint64_t>(compact_->compaction->start_level()) << 32) +  in ReportStartedCompaction()
364           compact_->compaction->output_level());  in ReportStartedCompaction()
402   auto* c = compact_->compaction;  in Prepare()
405              compact_->compaction->level()) > 0);  in Prepare()
421       compact_->sub_compact_states.emplace_back(c, start, end, sizes_[i]);  in Prepare()
424                       compact_->sub_compact_states.size());  in Prepare()
426     compact_->sub_compact_states.emplace_back(c, nullptr, nullptr);  in Prepare()
439   auto* c = compact_->compaction;  in GenSubcompactionBoundaries()
504   auto* v = compact_->compaction->input_version();  in GenSubcompactionBoundaries()
573   const size_t num_threads = compact_->sub_compact_states.size();  in Run()
580   for (size_t i = 1; i < compact_->sub_compact_states.size(); i++) {  in Run()
582                              &compact_->sub_compact_states[i]);  in Run()
587   ProcessKeyValueCompaction(&compact_->sub_compact_states[0]);  in Run()
596   for (size_t i = 0; i < compact_->sub_compact_states.size(); i++) {  in Run()
598         compact_->sub_compact_states[i].compaction_job_stats.cpu_micros;  in Run()
609   for (const auto& state : compact_->sub_compact_states) {  in Run()
628     for (const auto& state : compact_->sub_compact_states) {  in Run()
633     ColumnFamilyData* cfd = compact_->compaction->column_family_data();  in Run()
635         compact_->compaction->mutable_cf_options()->prefix_extractor.get();  in Run()
654                 compact_->compaction->output_level()),  in Run()
656             /*skip_filters=*/false, compact_->compaction->output_level(),  in Run()
674     for (size_t i = 1; i < compact_->sub_compact_states.size(); i++) {  in Run()
676                                std::ref(compact_->sub_compact_states[i].status));  in Run()
678     verify_table(compact_->sub_compact_states[0].status);  in Run()
682     for (const auto& state : compact_->sub_compact_states) {  in Run()
691   for (const auto& state : compact_->sub_compact_states) {  in Run()
699   compact_->compaction->SetOutputTableProperties(std::move(tp));  in Run()
708   compact_->status = status;  in Run()
716   Status status = compact_->status;  in Install()
717   ColumnFamilyData* cfd = compact_->compaction->column_family_data();  in Install()
719       compact_->compaction->output_level(), thread_pri_, compaction_stats_);  in Install()
760       bytes_written_per_sec, compact_->compaction->output_level(),  in Install()
768       CompressionTypeToString(compact_->compaction->output_compression())  in Install()
778          << compact_->compaction->output_level() << "num_output_files"  in Install()
779          << compact_->NumOutputFiles() << "total_output_size"  in Install()
780          << compact_->total_bytes << "num_input_records"  in Install()
782          << compact_->num_output_records << "num_subcompactions"  in Install()
783          << compact_->sub_compact_states.size() << "output_compression"  in Install()
784          << CompressionTypeToString(compact_->compaction->output_compression());  in Install()
873       snapshot_checker_, compact_->compaction->level(),  in ProcessKeyValueCompaction()
1415   auto* compaction = compact_->compaction;  in InstallCompactionResults()
1434         compaction->InputLevelSummary(&inputs_summary), compact_->total_bytes);  in InstallCompactionResults()
1438   compaction->AddInputDeletions(compact_->compaction->edit());  in InstallCompactionResults()
1440   for (const auto& sub_compact : compact_->sub_compact_states) {  in InstallCompactionResults()
1559   for (SubcompactionState& sub_compact : compact_->sub_compact_states) {  in CleanupCompaction()
1577   delete compact_;  in CleanupCompaction()
1578   compact_ = nullptr;  in CleanupCompaction()
1593   Compaction* compaction = compact_->compaction;  in UpdateCompactionStats()
1612   for (const auto& sub_compact : compact_->sub_compact_states) {  in UpdateCompactionStats()
1637   const Compaction* compaction = compact_->compaction;  in UpdateCompactionInputStatsHelper()
1667     compaction_job_stats_->num_output_records = compact_->num_output_records;  in UpdateCompactionJobStats()
1670     if (compact_->NumOutputFiles() > 0U) {  in UpdateCompactionJobStats()
1671       CopyPrefix(compact_->SmallestUserKey(),  in UpdateCompactionJobStats()
1674       CopyPrefix(compact_->LargestUserKey(),  in UpdateCompactionJobStats()
1685   Compaction* compaction = compact_->compaction;  in LogCompaction()