Fix typo in comments and code (#10233)

Summary:
Fix typo in comments and code.

Pull Request resolved: https://github.com/facebook/rocksdb/pull/10233

Test Plan: Existing unit tests should pass.

Reviewed By: jay-zhuang, anand1976

Differential Revision: D37356702

Pulled By: gitbw95

fbshipit-source-id: 32c019adcc6dcc95a9882b38147a310091368e51
main
Bo Wang 3 years ago committed by Facebook GitHub Bot
parent e103b87296
commit c073ed7601
  1. 7
      db/column_family.h
  2. 2
      db/db_impl/db_impl_compaction_flush.cc
  3. 2
      db/db_options_test.cc
  4. 2
      db/log_writer.h
  5. 2
      db/version_edit.h
  6. 4
      env/env_test.cc
  7. 2
      file/random_access_file_reader.h
  8. 2
      include/rocksdb/env.h
  9. 2
      include/rocksdb/file_system.h
  10. 2
      port/win/env_win.cc
  11. 4
      table/block_based/block_based_table_factory.cc
  12. 2
      table/block_fetcher.cc
  13. 10
      table/table_test.cc
  14. 2
      util/mutexlock.h

@ -480,11 +480,8 @@ class ColumnFamilyData {
const MutableCFOptions& mutable_cf_options, const MutableCFOptions& mutable_cf_options,
const ImmutableCFOptions& immutable_cf_options); const ImmutableCFOptions& immutable_cf_options);
// Recalculate some small conditions, which are changed only during // Recalculate some stall conditions, which are changed only during
// compaction, adding new memtable and/or // compaction, adding new memtable and/or recalculation of compaction score.
// recalculation of compaction score. These values are used in
// DBImpl::MakeRoomForWrite function to decide, if it need to make
// a write stall
WriteStallCondition RecalculateWriteStallConditions( WriteStallCondition RecalculateWriteStallConditions(
const MutableCFOptions& mutable_cf_options); const MutableCFOptions& mutable_cf_options);

@ -2237,7 +2237,7 @@ Status DBImpl::AtomicFlushMemTables(
// This method tries to avoid write stall (similar to CompactRange() behavior) // This method tries to avoid write stall (similar to CompactRange() behavior)
// it emulates how the SuperVersion / LSM would change if flush happens, checks // it emulates how the SuperVersion / LSM would change if flush happens, checks
// it against various constrains and delays flush if it'd cause write stall. // it against various constrains and delays flush if it'd cause write stall.
// Called should check status and flush_needed to see if flush already happened. // Caller should check status and flush_needed to see if flush already happened.
Status DBImpl::WaitUntilFlushWouldNotStallWrites(ColumnFamilyData* cfd, Status DBImpl::WaitUntilFlushWouldNotStallWrites(ColumnFamilyData* cfd,
bool* flush_needed) { bool* flush_needed) {
{ {

@ -453,7 +453,7 @@ TEST_F(DBOptionsTest, WritableFileMaxBufferSize) {
dbfull()->SetDBOptions({{"writable_file_max_buffer_size", "524288"}})); dbfull()->SetDBOptions({{"writable_file_max_buffer_size", "524288"}}));
buffer_size = 512 * 1024; buffer_size = 512 * 1024;
match_cnt = 0; match_cnt = 0;
unmatch_cnt = 0; // SetDBOptions() will create a WriteableFileWriter unmatch_cnt = 0; // SetDBOptions() will create a WritableFileWriter
ASSERT_EQ(buffer_size, ASSERT_EQ(buffer_size,
dbfull()->GetDBOptions().writable_file_max_buffer_size); dbfull()->GetDBOptions().writable_file_max_buffer_size);

@ -28,7 +28,7 @@ namespace log {
/** /**
* Writer is a general purpose log stream writer. It provides an append-only * Writer is a general purpose log stream writer. It provides an append-only
* abstraction for writing data. The details of the how the data is written is * abstraction for writing data. The details of the how the data is written is
* handled by the WriteableFile sub-class implementation. * handled by the WritableFile sub-class implementation.
* *
* File format: * File format:
* *

@ -316,7 +316,7 @@ struct FileMetaData {
}; };
// A compressed copy of file meta data that just contain minimum data needed // A compressed copy of file meta data that just contain minimum data needed
// to server read operations, while still keeping the pointer to full metadata // to serve read operations, while still keeping the pointer to full metadata
// of the file in case it is needed. // of the file in case it is needed.
struct FdWithKeyRange { struct FdWithKeyRange {
FileDescriptor fd; FileDescriptor fd;

4
env/env_test.cc vendored

@ -1980,7 +1980,7 @@ TEST_P(EnvPosixTestWithParam, PosixRandomRWFile) {
// Cannot open non-existing file. // Cannot open non-existing file.
ASSERT_NOK(env_->NewRandomRWFile(path, &file, EnvOptions())); ASSERT_NOK(env_->NewRandomRWFile(path, &file, EnvOptions()));
// Create the file using WriteableFile // Create the file using WritableFile
{ {
std::unique_ptr<WritableFile> wf; std::unique_ptr<WritableFile> wf;
ASSERT_OK(env_->NewWritableFile(path, &wf, EnvOptions())); ASSERT_OK(env_->NewWritableFile(path, &wf, EnvOptions()));
@ -2109,7 +2109,7 @@ TEST_P(EnvPosixTestWithParam, PosixRandomRWFileRandomized) {
ASSERT_NOK(env_->NewRandomRWFile(path, &file, EnvOptions())); ASSERT_NOK(env_->NewRandomRWFile(path, &file, EnvOptions()));
#endif #endif
// Create the file using WriteableFile // Create the file using WritableFile
{ {
std::unique_ptr<WritableFile> wf; std::unique_ptr<WritableFile> wf;
ASSERT_OK(env_->NewWritableFile(path, &wf, EnvOptions())); ASSERT_OK(env_->NewWritableFile(path, &wf, EnvOptions()));

@ -38,7 +38,7 @@ FSReadRequest Align(const FSReadRequest& r, size_t alignment);
// Otherwise, do nothing and return false. // Otherwise, do nothing and return false.
bool TryMerge(FSReadRequest* dest, const FSReadRequest& src); bool TryMerge(FSReadRequest* dest, const FSReadRequest& src);
// RandomAccessFileReader is a wrapper on top of Env::RandomAccessFile. It is // RandomAccessFileReader is a wrapper on top of FSRandomAccessFile. It is
// responsible for: // responsible for:
// - Handling Buffered and Direct reads appropriately. // - Handling Buffered and Direct reads appropriately.
// - Rate limiting compaction reads. // - Rate limiting compaction reads.

@ -876,7 +876,7 @@ class WritableFile {
virtual ~WritableFile(); virtual ~WritableFile();
// Append data to the end of the file // Append data to the end of the file
// Note: A WriteableFile object must support either Append or // Note: A WritableFile object must support either Append or
// PositionedAppend, so the users cannot mix the two. // PositionedAppend, so the users cannot mix the two.
virtual Status Append(const Slice& data) = 0; virtual Status Append(const Slice& data) = 0;

@ -951,7 +951,7 @@ class FSWritableFile {
virtual ~FSWritableFile() {} virtual ~FSWritableFile() {}
// Append data to the end of the file // Append data to the end of the file
// Note: A WriteableFile object must support either Append or // Note: A WritableFile object must support either Append or
// PositionedAppend, so the users cannot mix the two. // PositionedAppend, so the users cannot mix the two.
virtual IOStatus Append(const Slice& data, const IOOptions& options, virtual IOStatus Append(const Slice& data, const IOOptions& options,
IODebugContext* dbg) = 0; IODebugContext* dbg) = 0;

@ -410,7 +410,7 @@ IOStatus WinFileSystem::OpenWritableFile(
if (INVALID_HANDLE_VALUE == hFile) { if (INVALID_HANDLE_VALUE == hFile) {
auto lastError = GetLastError(); auto lastError = GetLastError();
return IOErrorFromWindowsError( return IOErrorFromWindowsError(
"Failed to create a NewWriteableFile: " + fname, lastError); "Failed to create a NewWritableFile: " + fname, lastError);
} }
// We will start writing at the end, appending // We will start writing at the end, appending

@ -387,7 +387,7 @@ static std::unordered_map<std::string, OptionTypeInfo>
{offsetof(struct BlockBasedTableOptions, block_cache), {offsetof(struct BlockBasedTableOptions, block_cache),
OptionType::kUnknown, OptionVerificationType::kNormal, OptionType::kUnknown, OptionVerificationType::kNormal,
(OptionTypeFlags::kCompareNever | OptionTypeFlags::kDontSerialize), (OptionTypeFlags::kCompareNever | OptionTypeFlags::kDontSerialize),
// Parses the input vsalue as a Cache // Parses the input value as a Cache
[](const ConfigOptions& opts, const std::string&, [](const ConfigOptions& opts, const std::string&,
const std::string& value, void* addr) { const std::string& value, void* addr) {
auto* cache = static_cast<std::shared_ptr<Cache>*>(addr); auto* cache = static_cast<std::shared_ptr<Cache>*>(addr);
@ -397,7 +397,7 @@ static std::unordered_map<std::string, OptionTypeInfo>
{offsetof(struct BlockBasedTableOptions, block_cache_compressed), {offsetof(struct BlockBasedTableOptions, block_cache_compressed),
OptionType::kUnknown, OptionVerificationType::kNormal, OptionType::kUnknown, OptionVerificationType::kNormal,
(OptionTypeFlags::kCompareNever | OptionTypeFlags::kDontSerialize), (OptionTypeFlags::kCompareNever | OptionTypeFlags::kDontSerialize),
// Parses the input vsalue as a Cache // Parses the input value as a Cache
[](const ConfigOptions& opts, const std::string&, [](const ConfigOptions& opts, const std::string&,
const std::string& value, void* addr) { const std::string& value, void* addr) {
auto* cache = static_cast<std::shared_ptr<Cache>*>(addr); auto* cache = static_cast<std::shared_ptr<Cache>*>(addr);

@ -126,7 +126,7 @@ inline void BlockFetcher::PrepareBufferForBlockFromFile() {
// cache miss read from device // cache miss read from device
if ((do_uncompress_ || ioptions_.allow_mmap_reads) && if ((do_uncompress_ || ioptions_.allow_mmap_reads) &&
block_size_with_trailer_ < kDefaultStackBufferSize) { block_size_with_trailer_ < kDefaultStackBufferSize) {
// If we've got a small enough hunk of data, read it in to the // If we've got a small enough chunk of data, read it in to the
// trivially allocated stack buffer instead of needing a full malloc() // trivially allocated stack buffer instead of needing a full malloc()
// //
// `GetBlockContents()` cannot return this data as its lifetime is tied to // `GetBlockContents()` cannot return this data as its lifetime is tied to

@ -1246,7 +1246,7 @@ class FileChecksumTestHelper {
} }
~FileChecksumTestHelper() {} ~FileChecksumTestHelper() {}
void CreateWriteableFile() { void CreateWritableFile() {
sink_ = new test::StringSink(); sink_ = new test::StringSink();
std::unique_ptr<FSWritableFile> holder(sink_); std::unique_ptr<FSWritableFile> holder(sink_);
file_writer_.reset(new WritableFileWriter( file_writer_.reset(new WritableFileWriter(
@ -3739,7 +3739,7 @@ TEST_P(BlockBasedTableTest, NoFileChecksum) {
std::string column_family_name; std::string column_family_name;
FileChecksumTestHelper f(true); FileChecksumTestHelper f(true);
f.CreateWriteableFile(); f.CreateWritableFile();
std::unique_ptr<TableBuilder> builder; std::unique_ptr<TableBuilder> builder;
builder.reset(ioptions.table_factory->NewTableBuilder( builder.reset(ioptions.table_factory->NewTableBuilder(
TableBuilderOptions(ioptions, moptions, *comparator, TableBuilderOptions(ioptions, moptions, *comparator,
@ -3774,7 +3774,7 @@ TEST_P(BlockBasedTableTest, Crc32cFileChecksum) {
options.file_checksum_gen_factory->CreateFileChecksumGenerator( options.file_checksum_gen_factory->CreateFileChecksumGenerator(
gen_context); gen_context);
FileChecksumTestHelper f(true); FileChecksumTestHelper f(true);
f.CreateWriteableFile(); f.CreateWritableFile();
f.SetFileChecksumGenerator(checksum_crc32c_gen1.release()); f.SetFileChecksumGenerator(checksum_crc32c_gen1.release());
std::unique_ptr<TableBuilder> builder; std::unique_ptr<TableBuilder> builder;
builder.reset(ioptions.table_factory->NewTableBuilder( builder.reset(ioptions.table_factory->NewTableBuilder(
@ -3876,7 +3876,7 @@ TEST_F(PlainTableTest, NoFileChecksum) {
std::string column_family_name; std::string column_family_name;
int unknown_level = -1; int unknown_level = -1;
FileChecksumTestHelper f(true); FileChecksumTestHelper f(true);
f.CreateWriteableFile(); f.CreateWritableFile();
std::unique_ptr<TableBuilder> builder(factory.NewTableBuilder( std::unique_ptr<TableBuilder> builder(factory.NewTableBuilder(
TableBuilderOptions(ioptions, moptions, ikc, TableBuilderOptions(ioptions, moptions, ikc,
@ -3915,7 +3915,7 @@ TEST_F(PlainTableTest, Crc32cFileChecksum) {
options.file_checksum_gen_factory->CreateFileChecksumGenerator( options.file_checksum_gen_factory->CreateFileChecksumGenerator(
gen_context); gen_context);
FileChecksumTestHelper f(true); FileChecksumTestHelper f(true);
f.CreateWriteableFile(); f.CreateWritableFile();
f.SetFileChecksumGenerator(checksum_crc32c_gen1.release()); f.SetFileChecksumGenerator(checksum_crc32c_gen1.release());
std::unique_ptr<TableBuilder> builder(factory.NewTableBuilder( std::unique_ptr<TableBuilder> builder(factory.NewTableBuilder(

@ -43,7 +43,7 @@ class MutexLock {
// //
// Acquire a ReadLock on the specified RWMutex. // Acquire a ReadLock on the specified RWMutex.
// The Lock will be automatically released then the // The Lock will be automatically released when the
// object goes out of scope. // object goes out of scope.
// //
class ReadLock { class ReadLock {

Loading…
Cancel
Save