Lines Matching refs:compaction
108 const Compaction* compaction; member
160 : compaction(c), in SubcompactionState()
172 assert(compaction != nullptr); in SubcompactionState()
178 compaction = std::move(o.compaction); in operator =()
205 &compaction->column_family_data()->internal_comparator(); in ShouldStopBefore()
206 const std::vector<FileMetaData*>& grandparents = compaction->grandparents(); in ShouldStopBefore()
225 compaction->max_compaction_bytes()) { in ShouldStopBefore()
237 Compaction* const compaction; member
248 : compaction(c), in CompactionState()
297 int job_id, Compaction* compaction, const ImmutableDBOptions& db_options, in CompactionJob() argument
310 compact_(new CompactionState(compaction)), in CompactionJob()
312 compaction_stats_(compaction->compaction_reason(), 1), in CompactionJob()
341 const auto* cfd = compact_->compaction->column_family_data(); in CompactionJob()
345 ReportStartedCompaction(compaction); in CompactionJob()
353 void CompactionJob::ReportStartedCompaction(Compaction* compaction) { in ReportStartedCompaction() argument
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()
368 assert(compaction->IsTrivialMove() == false || in ReportStartedCompaction()
369 compaction->is_manual_compaction() == true); in ReportStartedCompaction()
373 compaction->is_manual_compaction() + in ReportStartedCompaction()
374 (compaction->deletion_compaction() << 1)); in ReportStartedCompaction()
378 compaction->CalculateTotalInputSize()); in ReportStartedCompaction()
393 compaction->is_manual_compaction(); in ReportStartedCompaction()
402 auto* c = compact_->compaction; in Prepare()
405 compact_->compaction->level()) > 0); in Prepare()
439 auto* c = compact_->compaction; in GenSubcompactionBoundaries()
504 auto* v = compact_->compaction->input_version(); in GenSubcompactionBoundaries()
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()
694 TableFileName(state.compaction->immutable_cf_options()->cf_paths, in Run()
699 compact_->compaction->SetOutputTableProperties(std::move(tp)); in Run()
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()
784 << CompressionTypeToString(compact_->compaction->output_compression()); in Install()
818 ColumnFamilyData* cfd = sub_compact->compaction->column_family_data(); in ProcessKeyValueCompaction()
827 sub_compact->compaction->CreateCompactionFilter(); in ProcessKeyValueCompaction()
843 sub_compact->compaction, &range_del_agg, file_options_for_read_)); in ProcessKeyValueCompaction()
873 snapshot_checker_, compact_->compaction->level(), in ProcessKeyValueCompaction()
897 &range_del_agg, sub_compact->compaction, compaction_filter, in ProcessKeyValueCompaction()
902 if (c_iter->Valid() && sub_compact->compaction->output_level() != 0) { in ProcessKeyValueCompaction()
956 if (sub_compact->compaction->output_level() != 0 && in ProcessKeyValueCompaction()
958 sub_compact->compaction->max_output_file_size()) { in ProcessKeyValueCompaction()
973 sub_compact->compaction->output_level() != 0 && in ProcessKeyValueCompaction()
1131 ColumnFamilyData* cfd = sub_compact->compaction->column_family_data(); in FinishCompactionOutputFile()
1348 TableFileName(sub_compact->compaction->immutable_cf_options()->cf_paths, in FinishCompactionOutputFile()
1375 TableFileName(sub_compact->compaction->immutable_cf_options()->cf_paths, in FinishCompactionOutputFile()
1415 auto* compaction = compact_->compaction; in InstallCompactionResults() local
1420 if (!versions_->VerifyCompactionFileConsistency(compaction)) { in InstallCompactionResults()
1424 compaction->column_family_data()->GetName().c_str(), in InstallCompactionResults()
1425 job_id_, compaction->InputLevelSummary(&inputs_summary)); in InstallCompactionResults()
1433 compaction->column_family_data()->GetName().c_str(), job_id_, in InstallCompactionResults()
1434 compaction->InputLevelSummary(&inputs_summary), compact_->total_bytes); in InstallCompactionResults()
1438 compaction->AddInputDeletions(compact_->compaction->edit()); in InstallCompactionResults()
1442 compaction->edit()->AddFile(compaction->output_level(), out.meta); in InstallCompactionResults()
1445 return versions_->LogAndApply(compaction->column_family_data(), in InstallCompactionResults()
1446 mutable_cf_options, compaction->edit(), in InstallCompactionResults()
1468 TableFileName(sub_compact->compaction->immutable_cf_options()->cf_paths, in OpenCompactionOutputFile()
1469 file_number, sub_compact->compaction->output_path_id()); in OpenCompactionOutputFile()
1471 ColumnFamilyData* cfd = sub_compact->compaction->column_family_data(); in OpenCompactionOutputFile()
1490 sub_compact->compaction->column_family_data()->GetName().c_str(), in OpenCompactionOutputFile()
1511 sub_compact->compaction->MinInputFileOldestAncesterTime(); in OpenCompactionOutputFile()
1520 sub_compact->compaction->output_path_id(), 0); in OpenCompactionOutputFile()
1530 sub_compact->compaction->OutputFilePreallocationSize())); in OpenCompactionOutputFile()
1532 sub_compact->compaction->immutable_cf_options()->listeners; in OpenCompactionOutputFile()
1545 *cfd->ioptions(), *(sub_compact->compaction->mutable_cf_options()), in OpenCompactionOutputFile()
1548 sub_compact->compaction->output_compression(), in OpenCompactionOutputFile()
1550 sub_compact->compaction->output_compression_opts(), in OpenCompactionOutputFile()
1551 sub_compact->compaction->output_level(), skip_filters, in OpenCompactionOutputFile()
1553 sub_compact->compaction->max_output_file_size(), current_time)); in OpenCompactionOutputFile()
1593 Compaction* compaction = compact_->compaction; in UpdateCompactionStats() local
1597 input_level < static_cast<int>(compaction->num_input_levels()); in UpdateCompactionStats()
1599 if (compaction->level(input_level) != compaction->output_level()) { in UpdateCompactionStats()
1637 const Compaction* compaction = compact_->compaction; in UpdateCompactionInputStatsHelper() local
1638 auto num_input_files = compaction->num_input_files(input_level); in UpdateCompactionInputStatsHelper()
1642 const auto* file_meta = compaction->input(input_level, i); in UpdateCompactionInputStatsHelper()
1685 Compaction* compaction = compact_->compaction; in LogCompaction() local
1686 ColumnFamilyData* cfd = compaction->column_family_data(); in LogCompaction()
1695 compaction->InputLevelSummary(&inputs_summary), compaction->score()); in LogCompaction()
1697 compaction->Summary(scratch, sizeof(scratch)); in LogCompaction()
1705 << GetCompactionReasonString(compaction->compaction_reason()); in LogCompaction()
1706 for (size_t i = 0; i < compaction->num_input_levels(); ++i) { in LogCompaction()
1707 stream << ("files_L" + ToString(compaction->level(i))); in LogCompaction()
1709 for (auto f : *compaction->inputs(i)) { in LogCompaction()
1714 stream << "score" << compaction->score() << "input_data_size" in LogCompaction()
1715 << compaction->CalculateTotalInputSize(); in LogCompaction()