diff --git a/include/rocksdb/env.h b/include/rocksdb/env.h index e9f5bca4b..98e4b816a 100644 --- a/include/rocksdb/env.h +++ b/include/rocksdb/env.h @@ -57,10 +57,10 @@ const size_t kDefaultPageSize = 4 * 1024; // Options while opening a file to read/write struct EnvOptions { - // construct with default Options + // Construct with default Options EnvOptions(); - // construct from Options + // Construct from Options explicit EnvOptions(const DBOptions& options); // If true, then use mmap to read data @@ -95,10 +95,10 @@ struct EnvOptions { // WAL writes bool fallocate_with_keep_size = true; - // See DBOPtions doc + // See DBOptions doc size_t compaction_readahead_size; - // See DBOPtions doc + // See DBOptions doc size_t random_access_max_buffer_size; // See DBOptions doc diff --git a/include/rocksdb/sst_file_writer.h b/include/rocksdb/sst_file_writer.h index 8e974084a..066c6f316 100644 --- a/include/rocksdb/sst_file_writer.h +++ b/include/rocksdb/sst_file_writer.h @@ -8,7 +8,10 @@ #ifndef ROCKSDB_LITE #pragma once + +#include #include + #include "rocksdb/env.h" #include "rocksdb/options.h" #include "rocksdb/table_properties.h" @@ -19,7 +22,7 @@ namespace rocksdb { class Comparator; // ExternalSstFileInfo include information about sst files created -// using SstFileWriter +// using SstFileWriter. struct ExternalSstFileInfo { ExternalSstFileInfo() {} ExternalSstFileInfo(const std::string& _file_path, @@ -45,25 +48,28 @@ struct ExternalSstFileInfo { }; // SstFileWriter is used to create sst files that can be added to database later -// All keys in files generated by SstFileWriter will have sequence number = 0 +// All keys in files generated by SstFileWriter will have sequence number = 0. class SstFileWriter { public: // User can pass `column_family` to specify that the the generated file will // be ingested into this column_family, note that passing nullptr means that // the column_family is unknown. // If invalidate_page_cache is set to true, SstFileWriter will give the OS a - // hint that this file pages is not needed everytime we write 1MB to the file + // hint that this file pages is not needed everytime we write 1MB to the file. + // To use the rate limiter an io_priority smaller than IO_TOTAL can be passed. SstFileWriter(const EnvOptions& env_options, const Options& options, ColumnFamilyHandle* column_family = nullptr, - bool invalidate_page_cache = true) + bool invalidate_page_cache = true, + Env::IOPriority io_priority = Env::IOPriority::IO_TOTAL) : SstFileWriter(env_options, options, options.comparator, column_family, - invalidate_page_cache) {} + invalidate_page_cache, io_priority) {} // Deprecated API SstFileWriter(const EnvOptions& env_options, const Options& options, const Comparator* user_comparator, ColumnFamilyHandle* column_family = nullptr, - bool invalidate_page_cache = true); + bool invalidate_page_cache = true, + Env::IOPriority io_priority = Env::IOPriority::IO_TOTAL); ~SstFileWriter(); @@ -77,7 +83,7 @@ class SstFileWriter { // Finalize writing to sst file and close file. // // An optional ExternalSstFileInfo pointer can be passed to the function - // which will be populated with information about the created sst file + // which will be populated with information about the created sst file. Status Finish(ExternalSstFileInfo* file_info = nullptr); // Return the current file size. @@ -87,7 +93,7 @@ class SstFileWriter { void InvalidatePageCache(bool closing); struct Rep; - Rep* rep_; + std::unique_ptr rep_; }; } // namespace rocksdb diff --git a/table/sst_file_writer.cc b/table/sst_file_writer.cc index 88b0be3a9..0aa9a97ec 100644 --- a/table/sst_file_writer.cc +++ b/table/sst_file_writer.cc @@ -28,11 +28,12 @@ const size_t kFadviseTrigger = 1024 * 1024; // 1MB struct SstFileWriter::Rep { Rep(const EnvOptions& _env_options, const Options& options, - const Comparator* _user_comparator, ColumnFamilyHandle* _cfh, - bool _invalidate_page_cache) + Env::IOPriority _io_priority, const Comparator* _user_comparator, + ColumnFamilyHandle* _cfh, bool _invalidate_page_cache) : env_options(_env_options), ioptions(options), mutable_cf_options(options), + io_priority(_io_priority), internal_comparator(_user_comparator), cfh(_cfh), invalidate_page_cache(_invalidate_page_cache), @@ -43,15 +44,16 @@ struct SstFileWriter::Rep { EnvOptions env_options; ImmutableCFOptions ioptions; MutableCFOptions mutable_cf_options; + Env::IOPriority io_priority; InternalKeyComparator internal_comparator; ExternalSstFileInfo file_info; InternalKey ikey; std::string column_family_name; ColumnFamilyHandle* cfh; // If true, We will give the OS a hint that this file pages is not needed - // everytime we write 1MB to the file + // everytime we write 1MB to the file. bool invalidate_page_cache; - // the size of the file during the last time we called Fadvise to remove + // The size of the file during the last time we called Fadvise to remove // cached pages from page cache. uint64_t last_fadvise_size; }; @@ -60,9 +62,10 @@ SstFileWriter::SstFileWriter(const EnvOptions& env_options, const Options& options, const Comparator* user_comparator, ColumnFamilyHandle* column_family, - bool invalidate_page_cache) - : rep_(new Rep(env_options, options, user_comparator, column_family, - invalidate_page_cache)) { + bool invalidate_page_cache, + Env::IOPriority io_priority) + : rep_(new Rep(env_options, options, io_priority, user_comparator, + column_family, invalidate_page_cache)) { rep_->file_info.file_size = 0; } @@ -72,12 +75,10 @@ SstFileWriter::~SstFileWriter() { // abandon the builder. rep_->builder->Abandon(); } - - delete rep_; } Status SstFileWriter::Open(const std::string& file_path) { - Rep* r = rep_; + Rep* r = rep_.get(); Status s; std::unique_ptr sst_file; s = r->ioptions.env->NewWritableFile(file_path, &sst_file, r->env_options); @@ -85,6 +86,8 @@ Status SstFileWriter::Open(const std::string& file_path) { return s; } + sst_file->SetIOPriority(r->io_priority); + CompressionType compression_type; if (r->ioptions.bottommost_compression != kDisableCompressionOption) { compression_type = r->ioptions.bottommost_compression; @@ -146,7 +149,7 @@ Status SstFileWriter::Open(const std::string& file_path) { } Status SstFileWriter::Add(const Slice& user_key, const Slice& value) { - Rep* r = rep_; + Rep* r = rep_.get(); if (!r->builder) { return Status::InvalidArgument("File is not opened"); } @@ -166,7 +169,7 @@ Status SstFileWriter::Add(const Slice& user_key, const Slice& value) { ValueType::kTypeValue /* Put */); r->builder->Add(r->ikey.Encode(), value); - // update file info + // Update file info r->file_info.num_entries++; r->file_info.largest_key.assign(user_key.data(), user_key.size()); r->file_info.file_size = r->builder->FileSize(); @@ -177,7 +180,7 @@ Status SstFileWriter::Add(const Slice& user_key, const Slice& value) { } Status SstFileWriter::Finish(ExternalSstFileInfo* file_info) { - Rep* r = rep_; + Rep* r = rep_.get(); if (!r->builder) { return Status::InvalidArgument("File is not opened"); } @@ -208,7 +211,7 @@ Status SstFileWriter::Finish(ExternalSstFileInfo* file_info) { } void SstFileWriter::InvalidatePageCache(bool closing) { - Rep* r = rep_; + Rep* r = rep_.get(); if (r->invalidate_page_cache == false) { // Fadvise disabled return;