andreacavalli/rocksdb
0
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Cleanup unused variable pending_fsync_.

Browse Source 
Summary: Cleanup unused variable pending_fsync_.

Test Plan: make check

Subscribers: leveldb, andrewkr, dhruba

Differential Revision: https://reviews.facebook.net/D61581
This commit is contained in:
Dhruba Borthakur 2016-08-04 16:02:50 -07:00
parent 7cc0dbd66f
commit 34723b4c4a
2 changed files with 0 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
util/file_reader_writer.cc
View File

@ -51,7 +51,6 @@ Status WritableFileWriter::Append(const Slice& data) {
size_t left = data.size(); size_t left = data.size();
Status s; Status s;
pending_sync_ = true; pending_sync_ = true;
pending_fsync_ = true;
TEST_KILL_RANDOM("WritableFileWriter::Append:0", TEST_KILL_RANDOM("WritableFileWriter::Append:0",
rocksdb_kill_odds * REDUCE_ODDS2); rocksdb_kill_odds * REDUCE_ODDS2);
@ -218,9 +217,6 @@ Status WritableFileWriter::Sync(bool use_fsync) {
} }
TEST_KILL_RANDOM("WritableFileWriter::Sync:1", rocksdb_kill_odds); TEST_KILL_RANDOM("WritableFileWriter::Sync:1", rocksdb_kill_odds);
pending_sync_ = false; pending_sync_ = false;
if (use_fsync) {
pending_fsync_ = false;
}
return Status::OK(); return Status::OK();
} }

2
util/file_reader_writer.h
View File

@ -102,7 +102,6 @@ class WritableFileWriter {
// so we need to go back and write that page again // so we need to go back and write that page again
uint64_t next_write_offset_; uint64_t next_write_offset_;
bool pending_sync_; bool pending_sync_;
bool pending_fsync_;
const bool direct_io_; const bool direct_io_;
const bool use_os_buffer_; const bool use_os_buffer_;
uint64_t last_sync_size_; uint64_t last_sync_size_;
@ -118,7 +117,6 @@ class WritableFileWriter {
filesize_(0), filesize_(0),
next_write_offset_(0), next_write_offset_(0),
pending_sync_(false), pending_sync_(false),
pending_fsync_(false),
direct_io_(writable_file_->UseDirectIO()), direct_io_(writable_file_->UseDirectIO()),
use_os_buffer_(writable_file_->UseOSBuffer()), use_os_buffer_(writable_file_->UseOSBuffer()),
last_sync_size_(0), last_sync_size_(0),