summaryrefslogtreecommitdiff
path: root/db/compaction
diff options
context:
space:
mode:
authormrambacher <mrambach@gmail.com>2021-06-16 16:50:43 -0700
committerFacebook GitHub Bot <facebook-github-bot@users.noreply.github.com>2021-06-16 16:51:38 -0700
commitd5bd0039b9e2b6a3af58617ea591c29cb726f74b (patch)
tree4ff8fa7b3a979ae56102d83082955d65b2a37db3 /db/compaction
parent25be1ed66a354ee1d665d7a28eb20d36afc75e90 (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.h4
-rw-r--r--db/compaction/compaction_iterator.h6
-rw-r--r--db/compaction/compaction_job.cc19
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());
}