diff options
author | mrambacher <mrambach@gmail.com> | 2021-06-16 16:50:43 -0700 |
---|---|---|
committer | Facebook GitHub Bot <facebook-github-bot@users.noreply.github.com> | 2021-06-16 16:51:38 -0700 |
commit | d5bd0039b9e2b6a3af58617ea591c29cb726f74b (patch) | |
tree | 4ff8fa7b3a979ae56102d83082955d65b2a37db3 /db/compaction | |
parent | 25be1ed66a354ee1d665d7a28eb20d36afc75e90 (diff) |
Rename ImmutableOptions variables (#8409)
Summary:
This is the next part of the ImmutableOptions cleanup. After changing the use of ImmutableCFOptions to ImmutableOptions, there were places in the code that had did something like "ImmutableOptions* immutable_cf_options", where "cf" referred to the "old" type.
This change simply renames the variables to match the current type. No new functionality is introduced.
Pull Request resolved: https://github.com/facebook/rocksdb/pull/8409
Reviewed By: pdillinger
Differential Revision: D29166248
Pulled By: mrambacher
fbshipit-source-id: 96de97f8e743f5c5160f02246e3ed8269556dc6f
Diffstat (limited to 'db/compaction')
-rw-r--r-- | db/compaction/compaction.h | 4 | ||||
-rw-r--r-- | db/compaction/compaction_iterator.h | 6 | ||||
-rw-r--r-- | db/compaction/compaction_job.cc | 19 |
3 files changed, 15 insertions, 14 deletions
diff --git a/db/compaction/compaction.h b/db/compaction/compaction.h index ae4cd57e8..eda9bf002 100644 --- a/db/compaction/compaction.h +++ b/db/compaction/compaction.h @@ -223,9 +223,9 @@ class Compaction { // How many total levels are there? int number_levels() const { return number_levels_; } - // Return the ImmutableCFOptions that should be used throughout the compaction + // Return the ImmutableOptions that should be used throughout the compaction // procedure - const ImmutableOptions* immutable_cf_options() const { + const ImmutableOptions* immutable_options() const { return &immutable_options_; } diff --git a/db/compaction/compaction_iterator.h b/db/compaction/compaction_iterator.h index 7c459a767..65df5c444 100644 --- a/db/compaction/compaction_iterator.h +++ b/db/compaction/compaction_iterator.h @@ -104,7 +104,7 @@ class CompactionIterator { explicit RealCompaction(const Compaction* compaction) : compaction_(compaction) { assert(compaction_); - assert(compaction_->immutable_cf_options()); + assert(compaction_->immutable_options()); assert(compaction_->mutable_cf_options()); } @@ -126,11 +126,11 @@ class CompactionIterator { } bool allow_ingest_behind() const override { - return compaction_->immutable_cf_options()->allow_ingest_behind; + return compaction_->immutable_options()->allow_ingest_behind; } bool preserve_deletes() const override { - return compaction_->immutable_cf_options()->preserve_deletes; + return compaction_->immutable_options()->preserve_deletes; } bool enable_blob_garbage_collection() const override { diff --git a/db/compaction/compaction_job.cc b/db/compaction/compaction_job.cc index 38b0a3a80..a8e0bd596 100644 --- a/db/compaction/compaction_job.cc +++ b/db/compaction/compaction_job.cc @@ -553,9 +553,10 @@ void CompactionJob::GenSubcompactionBoundaries() { int base_level = v->storage_info()->base_level(); uint64_t max_output_files = static_cast<uint64_t>(std::ceil( sum / min_file_fill_percent / - MaxFileSizeForLevel(*(c->mutable_cf_options()), out_lvl, - c->immutable_cf_options()->compaction_style, base_level, - c->immutable_cf_options()->level_compaction_dynamic_level_bytes))); + MaxFileSizeForLevel( + *(c->mutable_cf_options()), out_lvl, + c->immutable_options()->compaction_style, base_level, + c->immutable_options()->level_compaction_dynamic_level_bytes))); uint64_t subcompactions = std::min({static_cast<uint64_t>(ranges.size()), static_cast<uint64_t>(c->max_subcompactions()), @@ -754,7 +755,7 @@ Status CompactionJob::Run() { for (const auto& state : compact_->sub_compact_states) { for (const auto& output : state.outputs) { auto fn = - TableFileName(state.compaction->immutable_cf_options()->cf_paths, + TableFileName(state.compaction->immutable_options()->cf_paths, output.meta.fd.GetNumber(), output.meta.fd.GetPathId()); tp[fn] = output.table_properties; } @@ -1017,7 +1018,7 @@ void CompactionJob::ProcessKeyValueCompactionWithCompactionService( for (const auto& file : compaction_result.output_files) { uint64_t file_num = versions_->NewFileNumber(); auto src_file = compaction_result.output_path + "/" + file.file_name; - auto tgt_file = TableFileName(compaction->immutable_cf_options()->cf_paths, + auto tgt_file = TableFileName(compaction->immutable_options()->cf_paths, file_num, compaction->output_path_id()); s = fs_->RenameFile(src_file, tgt_file, IOOptions(), nullptr); if (!s.ok()) { @@ -1176,7 +1177,7 @@ void CompactionJob::ProcessKeyValueCompaction(SubcompactionState* sub_compact) { std::unique_ptr<BlobFileBuilder> blob_file_builder( mutable_cf_options->enable_blob_files ? new BlobFileBuilder(versions_, fs_.get(), - sub_compact->compaction->immutable_cf_options(), + sub_compact->compaction->immutable_options(), mutable_cf_options, &file_options_, job_id_, cfd->GetID(), cfd->GetName(), Env::IOPriority::IO_LOW, write_hint_, @@ -1698,7 +1699,7 @@ Status CompactionJob::FinishCompactionOutputFile( // This happens when the output level is bottom level, at the same time // the sub_compact output nothing. std::string fname = - TableFileName(sub_compact->compaction->immutable_cf_options()->cf_paths, + TableFileName(sub_compact->compaction->immutable_options()->cf_paths, meta->fd.GetNumber(), meta->fd.GetPathId()); // TODO(AR) it is not clear if there are any larger implications if @@ -1942,7 +1943,7 @@ Status CompactionJob::OpenCompactionOutputFile( writable_file->SetPreallocationBlockSize(static_cast<size_t>( sub_compact->compaction->OutputFilePreallocationSize())); const auto& listeners = - sub_compact->compaction->immutable_cf_options()->listeners; + sub_compact->compaction->immutable_options()->listeners; sub_compact->outfile.reset(new WritableFileWriter( std::move(writable_file), fname, file_options_, db_options_.clock, io_tracer_, db_options_.stats, listeners, @@ -2124,7 +2125,7 @@ void CompactionJob::LogCompaction() { } std::string CompactionJob::GetTableFileName(uint64_t file_number) { - return TableFileName(compact_->compaction->immutable_cf_options()->cf_paths, + return TableFileName(compact_->compaction->immutable_options()->cf_paths, file_number, compact_->compaction->output_path_id()); } |