mirror of
https://github.com/facebook/rocksdb.git
synced 2024-12-04 20:02:50 +00:00
Revert "Remove Legacy and Custom FileWrapper classes from header files (#7851)"
This reverts commit 4a09d632c4
.
This commit is contained in:
parent
7343eb4a74
commit
a27cadfc93
|
@ -5,8 +5,6 @@
|
|||
|
||||
#ifndef ROCKSDB_LITE
|
||||
|
||||
#include "db/compaction/compaction_job.h"
|
||||
|
||||
#include <algorithm>
|
||||
#include <array>
|
||||
#include <cinttypes>
|
||||
|
@ -16,13 +14,13 @@
|
|||
|
||||
#include "db/blob/blob_index.h"
|
||||
#include "db/column_family.h"
|
||||
#include "db/compaction/compaction_job.h"
|
||||
#include "db/db_impl/db_impl.h"
|
||||
#include "db/error_handler.h"
|
||||
#include "db/version_set.h"
|
||||
#include "file/writable_file_writer.h"
|
||||
#include "rocksdb/cache.h"
|
||||
#include "rocksdb/db.h"
|
||||
#include "rocksdb/file_system.h"
|
||||
#include "rocksdb/options.h"
|
||||
#include "rocksdb/write_buffer_manager.h"
|
||||
#include "table/mock_table.h"
|
||||
|
@ -279,13 +277,12 @@ class CompactionJobTestBase : public testing::Test {
|
|||
new_db.SetLastSequence(0);
|
||||
|
||||
const std::string manifest = DescriptorFileName(dbname_, 1);
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
const auto& fs = env_->GetFileSystem();
|
||||
Status s = WritableFileWriter::Create(
|
||||
fs, manifest, fs->OptimizeForManifestWrite(env_options_), &file_writer,
|
||||
nullptr);
|
||||
|
||||
std::unique_ptr<WritableFile> file;
|
||||
Status s = env_->NewWritableFile(
|
||||
manifest, &file, env_->OptimizeForManifestWrite(env_options_));
|
||||
ASSERT_OK(s);
|
||||
std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(file)), manifest, env_options_));
|
||||
{
|
||||
log::Writer log(std::move(file_writer), 0, false);
|
||||
std::string record;
|
||||
|
|
|
@ -19,6 +19,7 @@
|
|||
#include "db/db_test_util.h"
|
||||
#include "db/log_format.h"
|
||||
#include "db/version_set.h"
|
||||
#include "env/composite_env_wrapper.h"
|
||||
#include "file/filename.h"
|
||||
#include "port/stack_trace.h"
|
||||
#include "rocksdb/cache.h"
|
||||
|
@ -538,15 +539,14 @@ TEST_F(CorruptionTest, RangeDeletionCorrupted) {
|
|||
ASSERT_EQ(static_cast<size_t>(1), metadata.size());
|
||||
std::string filename = dbname_ + metadata[0].name;
|
||||
|
||||
FileOptions file_opts;
|
||||
const auto& fs = options_.env->GetFileSystem();
|
||||
std::unique_ptr<RandomAccessFileReader> file_reader;
|
||||
ASSERT_OK(RandomAccessFileReader::Create(fs, filename, file_opts,
|
||||
&file_reader, nullptr));
|
||||
std::unique_ptr<RandomAccessFile> file;
|
||||
ASSERT_OK(options_.env->NewRandomAccessFile(filename, &file, EnvOptions()));
|
||||
std::unique_ptr<RandomAccessFileReader> file_reader(
|
||||
new RandomAccessFileReader(NewLegacyRandomAccessFileWrapper(file),
|
||||
filename));
|
||||
|
||||
uint64_t file_size;
|
||||
ASSERT_OK(
|
||||
fs->GetFileSize(filename, file_opts.io_options, &file_size, nullptr));
|
||||
ASSERT_OK(options_.env->GetFileSize(filename, &file_size));
|
||||
|
||||
BlockHandle range_del_handle;
|
||||
ASSERT_OK(FindMetaBlock(
|
||||
|
|
|
@ -8,10 +8,10 @@
|
|||
// found in the LICENSE file. See the AUTHORS file for names of contributors.
|
||||
|
||||
#include "db/db_test_util.h"
|
||||
#include "env/composite_env_wrapper.h"
|
||||
#include "options/options_helper.h"
|
||||
#include "port/port.h"
|
||||
#include "port/stack_trace.h"
|
||||
#include "rocksdb/file_system.h"
|
||||
#include "test_util/sync_point.h"
|
||||
#include "utilities/fault_injection_env.h"
|
||||
#include "utilities/fault_injection_fs.h"
|
||||
|
@ -1229,7 +1229,7 @@ class RecoveryTestHelper {
|
|||
*count = 0;
|
||||
|
||||
std::shared_ptr<Cache> table_cache = NewLRUCache(50, 0);
|
||||
FileOptions file_options;
|
||||
EnvOptions env_options;
|
||||
WriteBufferManager write_buffer_manager(db_options.db_write_buffer_size);
|
||||
|
||||
std::unique_ptr<VersionSet> versions;
|
||||
|
@ -1237,22 +1237,22 @@ class RecoveryTestHelper {
|
|||
WriteController write_controller;
|
||||
|
||||
versions.reset(new VersionSet(
|
||||
test->dbname_, &db_options, file_options, table_cache.get(),
|
||||
test->dbname_, &db_options, env_options, table_cache.get(),
|
||||
&write_buffer_manager, &write_controller,
|
||||
/*block_cache_tracer=*/nullptr, /*io_tracer=*/nullptr));
|
||||
|
||||
wal_manager.reset(
|
||||
new WalManager(db_options, file_options, /*io_tracer=*/nullptr));
|
||||
new WalManager(db_options, env_options, /*io_tracer=*/nullptr));
|
||||
|
||||
std::unique_ptr<log::Writer> current_log_writer;
|
||||
|
||||
for (size_t j = kWALFileOffset; j < wal_count + kWALFileOffset; j++) {
|
||||
uint64_t current_log_number = j;
|
||||
std::string fname = LogFileName(test->dbname_, current_log_number);
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
ASSERT_OK(WritableFileWriter::Create(db_options.env->GetFileSystem(),
|
||||
fname, file_options, &file_writer,
|
||||
nullptr));
|
||||
std::unique_ptr<WritableFile> file;
|
||||
ASSERT_OK(db_options.env->NewWritableFile(fname, &file, env_options));
|
||||
std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(file)), fname, env_options));
|
||||
current_log_writer.reset(
|
||||
new log::Writer(std::move(file_writer), current_log_number,
|
||||
db_options.recycle_log_file_num > 0));
|
||||
|
|
|
@ -16,7 +16,6 @@
|
|||
#include "db/version_set.h"
|
||||
#include "file/writable_file_writer.h"
|
||||
#include "rocksdb/cache.h"
|
||||
#include "rocksdb/file_system.h"
|
||||
#include "rocksdb/write_buffer_manager.h"
|
||||
#include "table/mock_table.h"
|
||||
#include "test_util/testharness.h"
|
||||
|
@ -75,13 +74,12 @@ class FlushJobTestBase : public testing::Test {
|
|||
}
|
||||
|
||||
const std::string manifest = DescriptorFileName(dbname_, 1);
|
||||
const auto& fs = env_->GetFileSystem();
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
Status s = WritableFileWriter::Create(
|
||||
fs, manifest, fs->OptimizeForManifestWrite(env_options_), &file_writer,
|
||||
nullptr);
|
||||
std::unique_ptr<WritableFile> file;
|
||||
Status s = env_->NewWritableFile(
|
||||
manifest, &file, env_->OptimizeForManifestWrite(env_options_));
|
||||
ASSERT_OK(s);
|
||||
|
||||
std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(file)), manifest, EnvOptions()));
|
||||
{
|
||||
log::Writer log(std::move(file_writer), 0, false);
|
||||
std::string record;
|
||||
|
|
11
db/repair.cc
11
db/repair.cc
|
@ -71,6 +71,7 @@
|
|||
#include "db/table_cache.h"
|
||||
#include "db/version_edit.h"
|
||||
#include "db/write_batch_internal.h"
|
||||
#include "env/composite_env_wrapper.h"
|
||||
#include "file/filename.h"
|
||||
#include "file/writable_file_writer.h"
|
||||
#include "options/cf_options.h"
|
||||
|
@ -357,14 +358,14 @@ class Repairer {
|
|||
|
||||
// Open the log file
|
||||
std::string logname = LogFileName(db_options_.wal_dir, log);
|
||||
const auto& fs = env_->GetFileSystem();
|
||||
std::unique_ptr<SequentialFileReader> lfile_reader;
|
||||
Status status = SequentialFileReader::Create(
|
||||
fs, logname, fs->OptimizeForLogRead(env_options_), &lfile_reader,
|
||||
nullptr);
|
||||
std::unique_ptr<SequentialFile> lfile;
|
||||
Status status = env_->NewSequentialFile(
|
||||
logname, &lfile, env_->OptimizeForLogRead(env_options_));
|
||||
if (!status.ok()) {
|
||||
return status;
|
||||
}
|
||||
std::unique_ptr<SequentialFileReader> lfile_reader(new SequentialFileReader(
|
||||
NewLegacySequentialFileWrapper(lfile), logname));
|
||||
|
||||
// Create the log reader.
|
||||
LogReporter reporter;
|
||||
|
|
|
@ -11,7 +11,6 @@
|
|||
|
||||
#include "db/db_impl/db_impl.h"
|
||||
#include "db/log_writer.h"
|
||||
#include "rocksdb/file_system.h"
|
||||
#include "table/block_based/block_based_table_factory.h"
|
||||
#include "table/mock_table.h"
|
||||
#include "test_util/testharness.h"
|
||||
|
@ -784,13 +783,13 @@ class VersionSetTestBase {
|
|||
}
|
||||
*last_seqno = last_seq;
|
||||
num_initial_edits_ = static_cast<int>(new_cfs.size() + 1);
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
const std::string manifest = DescriptorFileName(dbname_, 1);
|
||||
const auto& fs = env_->GetFileSystem();
|
||||
Status s = WritableFileWriter::Create(
|
||||
fs, manifest, fs->OptimizeForManifestWrite(env_options_), &file_writer,
|
||||
nullptr);
|
||||
std::unique_ptr<WritableFile> file;
|
||||
Status s = env_->NewWritableFile(
|
||||
manifest, &file, env_->OptimizeForManifestWrite(env_options_));
|
||||
ASSERT_OK(s);
|
||||
std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(file)), manifest, env_options_));
|
||||
{
|
||||
log_writer->reset(new log::Writer(std::move(file_writer), 0, false));
|
||||
std::string record;
|
||||
|
@ -2313,13 +2312,14 @@ class EmptyDefaultCfNewManifest : public VersionSetTestBase,
|
|||
assert(log_writer != nullptr);
|
||||
VersionEdit new_db;
|
||||
new_db.SetLogNumber(0);
|
||||
std::unique_ptr<WritableFile> file;
|
||||
const std::string manifest_path = DescriptorFileName(dbname_, 1);
|
||||
const auto& fs = env_->GetFileSystem();
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
Status s = WritableFileWriter::Create(
|
||||
fs, manifest_path, fs->OptimizeForManifestWrite(env_options_),
|
||||
&file_writer, nullptr);
|
||||
Status s = env_->NewWritableFile(
|
||||
manifest_path, &file, env_->OptimizeForManifestWrite(env_options_));
|
||||
ASSERT_OK(s);
|
||||
std::unique_ptr<WritableFileWriter> file_writer(
|
||||
new WritableFileWriter(NewLegacyWritableFileWrapper(std::move(file)),
|
||||
manifest_path, env_options_));
|
||||
log_writer->reset(new log::Writer(std::move(file_writer), 0, true));
|
||||
std::string record;
|
||||
ASSERT_TRUE(new_db.EncodeTo(&record));
|
||||
|
@ -2387,12 +2387,13 @@ class VersionSetTestEmptyDb
|
|||
new_db.SetDBId(db_id);
|
||||
}
|
||||
const std::string manifest_path = DescriptorFileName(dbname_, 1);
|
||||
const auto& fs = env_->GetFileSystem();
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
Status s = WritableFileWriter::Create(
|
||||
fs, manifest_path, fs->OptimizeForManifestWrite(env_options_),
|
||||
&file_writer, nullptr);
|
||||
std::unique_ptr<WritableFile> file;
|
||||
Status s = env_->NewWritableFile(
|
||||
manifest_path, &file, env_->OptimizeForManifestWrite(env_options_));
|
||||
ASSERT_OK(s);
|
||||
std::unique_ptr<WritableFileWriter> file_writer(
|
||||
new WritableFileWriter(NewLegacyWritableFileWrapper(std::move(file)),
|
||||
manifest_path, env_options_));
|
||||
{
|
||||
log_writer->reset(new log::Writer(std::move(file_writer), 0, false));
|
||||
std::string record;
|
||||
|
@ -2696,12 +2697,12 @@ class VersionSetTestMissingFiles : public VersionSetTestBase,
|
|||
assert(last_seqno != nullptr);
|
||||
assert(log_writer != nullptr);
|
||||
const std::string manifest = DescriptorFileName(dbname_, 1);
|
||||
const auto& fs = env_->GetFileSystem();
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
Status s = WritableFileWriter::Create(
|
||||
fs, manifest, fs->OptimizeForManifestWrite(env_options_), &file_writer,
|
||||
nullptr);
|
||||
std::unique_ptr<WritableFile> file;
|
||||
Status s = env_->NewWritableFile(
|
||||
manifest, &file, env_->OptimizeForManifestWrite(env_options_));
|
||||
ASSERT_OK(s);
|
||||
std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(file)), manifest, env_options_));
|
||||
log_writer->reset(new log::Writer(std::move(file_writer), 0, false));
|
||||
VersionEdit new_db;
|
||||
if (db_options_.write_dbid_to_manifest) {
|
||||
|
|
|
@ -5,21 +5,20 @@
|
|||
|
||||
#ifndef ROCKSDB_LITE
|
||||
|
||||
#include "db/wal_manager.h"
|
||||
|
||||
#include <map>
|
||||
#include <string>
|
||||
|
||||
#include "rocksdb/cache.h"
|
||||
#include "rocksdb/write_batch.h"
|
||||
#include "rocksdb/write_buffer_manager.h"
|
||||
|
||||
#include "db/column_family.h"
|
||||
#include "db/db_impl/db_impl.h"
|
||||
#include "db/log_writer.h"
|
||||
#include "db/version_set.h"
|
||||
#include "db/wal_manager.h"
|
||||
#include "env/mock_env.h"
|
||||
#include "file/writable_file_writer.h"
|
||||
#include "rocksdb/cache.h"
|
||||
#include "rocksdb/file_system.h"
|
||||
#include "rocksdb/write_batch.h"
|
||||
#include "rocksdb/write_buffer_manager.h"
|
||||
#include "table/mock_table.h"
|
||||
#include "test_util/testharness.h"
|
||||
#include "test_util/testutil.h"
|
||||
|
@ -82,10 +81,10 @@ class WalManagerTest : public testing::Test {
|
|||
void RollTheLog(bool /*archived*/) {
|
||||
current_log_number_++;
|
||||
std::string fname = ArchivedLogFileName(dbname_, current_log_number_);
|
||||
const auto& fs = env_->GetFileSystem();
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
ASSERT_OK(WritableFileWriter::Create(fs, fname, env_options_, &file_writer,
|
||||
nullptr));
|
||||
std::unique_ptr<WritableFile> file;
|
||||
ASSERT_OK(env_->NewWritableFile(fname, &file, env_options_));
|
||||
std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(file)), fname, env_options_));
|
||||
current_log_writer_.reset(new log::Writer(std::move(file_writer), 0, false));
|
||||
}
|
||||
|
||||
|
@ -124,9 +123,8 @@ class WalManagerTest : public testing::Test {
|
|||
TEST_F(WalManagerTest, ReadFirstRecordCache) {
|
||||
Init();
|
||||
std::string path = dbname_ + "/000001.log";
|
||||
std::unique_ptr<FSWritableFile> file;
|
||||
ASSERT_OK(env_->GetFileSystem()->NewWritableFile(path, FileOptions(), &file,
|
||||
nullptr));
|
||||
std::unique_ptr<WritableFile> file;
|
||||
ASSERT_OK(env_->NewWritableFile(path, &file, EnvOptions()));
|
||||
|
||||
SequenceNumber s;
|
||||
ASSERT_OK(wal_manager_->TEST_ReadFirstLine(path, 1 /* number */, &s));
|
||||
|
@ -136,8 +134,8 @@ TEST_F(WalManagerTest, ReadFirstRecordCache) {
|
|||
wal_manager_->TEST_ReadFirstRecord(kAliveLogFile, 1 /* number */, &s));
|
||||
ASSERT_EQ(s, 0U);
|
||||
|
||||
std::unique_ptr<WritableFileWriter> file_writer(
|
||||
new WritableFileWriter(std::move(file), path, FileOptions()));
|
||||
std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(file)), path, EnvOptions()));
|
||||
log::Writer writer(std::move(file_writer), 1,
|
||||
db_options_.recycle_log_file_num > 0);
|
||||
WriteBatch batch;
|
||||
|
|
272
env/composite_env_wrapper.h
vendored
272
env/composite_env_wrapper.h
vendored
|
@ -18,6 +18,7 @@
|
|||
|
||||
namespace ROCKSDB_NAMESPACE {
|
||||
|
||||
|
||||
class CompositeEnv : public Env {
|
||||
public:
|
||||
// Initialize a CompositeEnvWrapper that delegates all thread/time related
|
||||
|
@ -334,4 +335,275 @@ class CompositeEnvWrapper : public CompositeEnv {
|
|||
private:
|
||||
Env* env_target_;
|
||||
};
|
||||
|
||||
class LegacySequentialFileWrapper : public FSSequentialFile {
|
||||
public:
|
||||
explicit LegacySequentialFileWrapper(
|
||||
std::unique_ptr<SequentialFile>&& _target)
|
||||
: target_(std::move(_target)) {}
|
||||
|
||||
IOStatus Read(size_t n, const IOOptions& /*options*/, Slice* result,
|
||||
char* scratch, IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Read(n, result, scratch));
|
||||
}
|
||||
IOStatus Skip(uint64_t n) override {
|
||||
return status_to_io_status(target_->Skip(n));
|
||||
}
|
||||
bool use_direct_io() const override { return target_->use_direct_io(); }
|
||||
size_t GetRequiredBufferAlignment() const override {
|
||||
return target_->GetRequiredBufferAlignment();
|
||||
}
|
||||
IOStatus InvalidateCache(size_t offset, size_t length) override {
|
||||
return status_to_io_status(target_->InvalidateCache(offset, length));
|
||||
}
|
||||
IOStatus PositionedRead(uint64_t offset, size_t n,
|
||||
const IOOptions& /*options*/, Slice* result,
|
||||
char* scratch, IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(
|
||||
target_->PositionedRead(offset, n, result, scratch));
|
||||
}
|
||||
SequentialFile* target() { return target_.get(); }
|
||||
|
||||
private:
|
||||
std::unique_ptr<SequentialFile> target_;
|
||||
};
|
||||
|
||||
class LegacyRandomAccessFileWrapper : public FSRandomAccessFile {
|
||||
public:
|
||||
explicit LegacyRandomAccessFileWrapper(
|
||||
std::unique_ptr<RandomAccessFile>&& target)
|
||||
: target_(std::move(target)) {}
|
||||
|
||||
IOStatus Read(uint64_t offset, size_t n, const IOOptions& /*options*/,
|
||||
Slice* result, char* scratch,
|
||||
IODebugContext* /*dbg*/) const override {
|
||||
return status_to_io_status(target_->Read(offset, n, result, scratch));
|
||||
}
|
||||
IOStatus MultiRead(FSReadRequest* fs_reqs, size_t num_reqs,
|
||||
const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
std::vector<ReadRequest> reqs;
|
||||
Status status;
|
||||
|
||||
reqs.reserve(num_reqs);
|
||||
for (size_t i = 0; i < num_reqs; ++i) {
|
||||
ReadRequest req;
|
||||
|
||||
req.offset = fs_reqs[i].offset;
|
||||
req.len = fs_reqs[i].len;
|
||||
req.scratch = fs_reqs[i].scratch;
|
||||
req.status = Status::OK();
|
||||
|
||||
reqs.emplace_back(req);
|
||||
}
|
||||
status = target_->MultiRead(reqs.data(), num_reqs);
|
||||
for (size_t i = 0; i < num_reqs; ++i) {
|
||||
fs_reqs[i].result = reqs[i].result;
|
||||
fs_reqs[i].status = status_to_io_status(std::move(reqs[i].status));
|
||||
}
|
||||
return status_to_io_status(std::move(status));
|
||||
;
|
||||
}
|
||||
IOStatus Prefetch(uint64_t offset, size_t n, const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Prefetch(offset, n));
|
||||
}
|
||||
size_t GetUniqueId(char* id, size_t max_size) const override {
|
||||
return target_->GetUniqueId(id, max_size);
|
||||
};
|
||||
void Hint(AccessPattern pattern) override {
|
||||
target_->Hint((RandomAccessFile::AccessPattern)pattern);
|
||||
}
|
||||
bool use_direct_io() const override { return target_->use_direct_io(); }
|
||||
size_t GetRequiredBufferAlignment() const override {
|
||||
return target_->GetRequiredBufferAlignment();
|
||||
}
|
||||
IOStatus InvalidateCache(size_t offset, size_t length) override {
|
||||
return status_to_io_status(target_->InvalidateCache(offset, length));
|
||||
}
|
||||
|
||||
private:
|
||||
std::unique_ptr<RandomAccessFile> target_;
|
||||
};
|
||||
|
||||
class LegacyWritableFileWrapper : public FSWritableFile {
|
||||
public:
|
||||
explicit LegacyWritableFileWrapper(std::unique_ptr<WritableFile>&& _target)
|
||||
: target_(std::move(_target)) {}
|
||||
|
||||
IOStatus Append(const Slice& data, const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Append(data));
|
||||
}
|
||||
IOStatus Append(const Slice& data, const IOOptions& /*options*/,
|
||||
const DataVerificationInfo& /*verification_info*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Append(data));
|
||||
}
|
||||
IOStatus PositionedAppend(const Slice& data, uint64_t offset,
|
||||
const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->PositionedAppend(data, offset));
|
||||
}
|
||||
IOStatus PositionedAppend(const Slice& data, uint64_t offset,
|
||||
const IOOptions& /*options*/,
|
||||
const DataVerificationInfo& /*verification_info*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->PositionedAppend(data, offset));
|
||||
}
|
||||
IOStatus Truncate(uint64_t size, const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Truncate(size));
|
||||
}
|
||||
IOStatus Close(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Close());
|
||||
}
|
||||
IOStatus Flush(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Flush());
|
||||
}
|
||||
IOStatus Sync(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Sync());
|
||||
}
|
||||
IOStatus Fsync(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Fsync());
|
||||
}
|
||||
bool IsSyncThreadSafe() const override { return target_->IsSyncThreadSafe(); }
|
||||
|
||||
bool use_direct_io() const override { return target_->use_direct_io(); }
|
||||
|
||||
size_t GetRequiredBufferAlignment() const override {
|
||||
return target_->GetRequiredBufferAlignment();
|
||||
}
|
||||
|
||||
void SetWriteLifeTimeHint(Env::WriteLifeTimeHint hint) override {
|
||||
target_->SetWriteLifeTimeHint(hint);
|
||||
}
|
||||
|
||||
Env::WriteLifeTimeHint GetWriteLifeTimeHint() override {
|
||||
return target_->GetWriteLifeTimeHint();
|
||||
}
|
||||
|
||||
uint64_t GetFileSize(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return target_->GetFileSize();
|
||||
}
|
||||
|
||||
void SetPreallocationBlockSize(size_t size) override {
|
||||
target_->SetPreallocationBlockSize(size);
|
||||
}
|
||||
|
||||
void GetPreallocationStatus(size_t* block_size,
|
||||
size_t* last_allocated_block) override {
|
||||
target_->GetPreallocationStatus(block_size, last_allocated_block);
|
||||
}
|
||||
|
||||
size_t GetUniqueId(char* id, size_t max_size) const override {
|
||||
return target_->GetUniqueId(id, max_size);
|
||||
}
|
||||
|
||||
IOStatus InvalidateCache(size_t offset, size_t length) override {
|
||||
return status_to_io_status(target_->InvalidateCache(offset, length));
|
||||
}
|
||||
|
||||
IOStatus RangeSync(uint64_t offset, uint64_t nbytes,
|
||||
const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->RangeSync(offset, nbytes));
|
||||
}
|
||||
|
||||
void PrepareWrite(size_t offset, size_t len, const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
target_->PrepareWrite(offset, len);
|
||||
}
|
||||
|
||||
IOStatus Allocate(uint64_t offset, uint64_t len, const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Allocate(offset, len));
|
||||
}
|
||||
|
||||
WritableFile* target() { return target_.get(); }
|
||||
|
||||
private:
|
||||
std::unique_ptr<WritableFile> target_;
|
||||
};
|
||||
|
||||
class LegacyRandomRWFileWrapper : public FSRandomRWFile {
|
||||
public:
|
||||
explicit LegacyRandomRWFileWrapper(std::unique_ptr<RandomRWFile>&& target)
|
||||
: target_(std::move(target)) {}
|
||||
|
||||
bool use_direct_io() const override { return target_->use_direct_io(); }
|
||||
size_t GetRequiredBufferAlignment() const override {
|
||||
return target_->GetRequiredBufferAlignment();
|
||||
}
|
||||
IOStatus Write(uint64_t offset, const Slice& data,
|
||||
const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Write(offset, data));
|
||||
}
|
||||
IOStatus Read(uint64_t offset, size_t n, const IOOptions& /*options*/,
|
||||
Slice* result, char* scratch,
|
||||
IODebugContext* /*dbg*/) const override {
|
||||
return status_to_io_status(target_->Read(offset, n, result, scratch));
|
||||
}
|
||||
IOStatus Flush(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Flush());
|
||||
}
|
||||
IOStatus Sync(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Sync());
|
||||
}
|
||||
IOStatus Fsync(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Fsync());
|
||||
}
|
||||
IOStatus Close(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Close());
|
||||
}
|
||||
|
||||
private:
|
||||
std::unique_ptr<RandomRWFile> target_;
|
||||
};
|
||||
|
||||
class LegacyDirectoryWrapper : public FSDirectory {
|
||||
public:
|
||||
explicit LegacyDirectoryWrapper(std::unique_ptr<Directory>&& target)
|
||||
: target_(std::move(target)) {}
|
||||
|
||||
IOStatus Fsync(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Fsync());
|
||||
}
|
||||
size_t GetUniqueId(char* id, size_t max_size) const override {
|
||||
return target_->GetUniqueId(id, max_size);
|
||||
}
|
||||
|
||||
private:
|
||||
std::unique_ptr<Directory> target_;
|
||||
};
|
||||
|
||||
inline std::unique_ptr<FSSequentialFile> NewLegacySequentialFileWrapper(
|
||||
std::unique_ptr<SequentialFile>& file) {
|
||||
return std::unique_ptr<FSSequentialFile>(
|
||||
new LegacySequentialFileWrapper(std::move(file)));
|
||||
}
|
||||
|
||||
inline std::unique_ptr<FSRandomAccessFile> NewLegacyRandomAccessFileWrapper(
|
||||
std::unique_ptr<RandomAccessFile>& file) {
|
||||
return std::unique_ptr<FSRandomAccessFile>(
|
||||
new LegacyRandomAccessFileWrapper(std::move(file)));
|
||||
}
|
||||
|
||||
inline std::unique_ptr<FSWritableFile> NewLegacyWritableFileWrapper(
|
||||
std::unique_ptr<WritableFile>&& file) {
|
||||
return std::unique_ptr<FSWritableFile>(
|
||||
new LegacyWritableFileWrapper(std::move(file)));
|
||||
}
|
||||
|
||||
} // namespace ROCKSDB_NAMESPACE
|
||||
|
|
262
env/env.cc
vendored
262
env/env.cc
vendored
|
@ -62,256 +62,6 @@ class LegacySystemClock : public SystemClock {
|
|||
}
|
||||
};
|
||||
|
||||
class LegacySequentialFileWrapper : public FSSequentialFile {
|
||||
public:
|
||||
explicit LegacySequentialFileWrapper(
|
||||
std::unique_ptr<SequentialFile>&& _target)
|
||||
: target_(std::move(_target)) {}
|
||||
|
||||
IOStatus Read(size_t n, const IOOptions& /*options*/, Slice* result,
|
||||
char* scratch, IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Read(n, result, scratch));
|
||||
}
|
||||
IOStatus Skip(uint64_t n) override {
|
||||
return status_to_io_status(target_->Skip(n));
|
||||
}
|
||||
bool use_direct_io() const override { return target_->use_direct_io(); }
|
||||
size_t GetRequiredBufferAlignment() const override {
|
||||
return target_->GetRequiredBufferAlignment();
|
||||
}
|
||||
IOStatus InvalidateCache(size_t offset, size_t length) override {
|
||||
return status_to_io_status(target_->InvalidateCache(offset, length));
|
||||
}
|
||||
IOStatus PositionedRead(uint64_t offset, size_t n,
|
||||
const IOOptions& /*options*/, Slice* result,
|
||||
char* scratch, IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(
|
||||
target_->PositionedRead(offset, n, result, scratch));
|
||||
}
|
||||
|
||||
private:
|
||||
std::unique_ptr<SequentialFile> target_;
|
||||
};
|
||||
|
||||
class LegacyRandomAccessFileWrapper : public FSRandomAccessFile {
|
||||
public:
|
||||
explicit LegacyRandomAccessFileWrapper(
|
||||
std::unique_ptr<RandomAccessFile>&& target)
|
||||
: target_(std::move(target)) {}
|
||||
|
||||
IOStatus Read(uint64_t offset, size_t n, const IOOptions& /*options*/,
|
||||
Slice* result, char* scratch,
|
||||
IODebugContext* /*dbg*/) const override {
|
||||
return status_to_io_status(target_->Read(offset, n, result, scratch));
|
||||
}
|
||||
|
||||
IOStatus MultiRead(FSReadRequest* fs_reqs, size_t num_reqs,
|
||||
const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
std::vector<ReadRequest> reqs;
|
||||
Status status;
|
||||
|
||||
reqs.reserve(num_reqs);
|
||||
for (size_t i = 0; i < num_reqs; ++i) {
|
||||
ReadRequest req;
|
||||
|
||||
req.offset = fs_reqs[i].offset;
|
||||
req.len = fs_reqs[i].len;
|
||||
req.scratch = fs_reqs[i].scratch;
|
||||
req.status = Status::OK();
|
||||
|
||||
reqs.emplace_back(req);
|
||||
}
|
||||
status = target_->MultiRead(reqs.data(), num_reqs);
|
||||
for (size_t i = 0; i < num_reqs; ++i) {
|
||||
fs_reqs[i].result = reqs[i].result;
|
||||
fs_reqs[i].status = status_to_io_status(std::move(reqs[i].status));
|
||||
}
|
||||
return status_to_io_status(std::move(status));
|
||||
}
|
||||
|
||||
IOStatus Prefetch(uint64_t offset, size_t n, const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Prefetch(offset, n));
|
||||
}
|
||||
size_t GetUniqueId(char* id, size_t max_size) const override {
|
||||
return target_->GetUniqueId(id, max_size);
|
||||
}
|
||||
void Hint(AccessPattern pattern) override {
|
||||
target_->Hint((RandomAccessFile::AccessPattern)pattern);
|
||||
}
|
||||
bool use_direct_io() const override { return target_->use_direct_io(); }
|
||||
size_t GetRequiredBufferAlignment() const override {
|
||||
return target_->GetRequiredBufferAlignment();
|
||||
}
|
||||
IOStatus InvalidateCache(size_t offset, size_t length) override {
|
||||
return status_to_io_status(target_->InvalidateCache(offset, length));
|
||||
}
|
||||
|
||||
private:
|
||||
std::unique_ptr<RandomAccessFile> target_;
|
||||
};
|
||||
|
||||
class LegacyRandomRWFileWrapper : public FSRandomRWFile {
|
||||
public:
|
||||
explicit LegacyRandomRWFileWrapper(std::unique_ptr<RandomRWFile>&& target)
|
||||
: target_(std::move(target)) {}
|
||||
|
||||
bool use_direct_io() const override { return target_->use_direct_io(); }
|
||||
size_t GetRequiredBufferAlignment() const override {
|
||||
return target_->GetRequiredBufferAlignment();
|
||||
}
|
||||
IOStatus Write(uint64_t offset, const Slice& data,
|
||||
const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Write(offset, data));
|
||||
}
|
||||
IOStatus Read(uint64_t offset, size_t n, const IOOptions& /*options*/,
|
||||
Slice* result, char* scratch,
|
||||
IODebugContext* /*dbg*/) const override {
|
||||
return status_to_io_status(target_->Read(offset, n, result, scratch));
|
||||
}
|
||||
IOStatus Flush(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Flush());
|
||||
}
|
||||
IOStatus Sync(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Sync());
|
||||
}
|
||||
IOStatus Fsync(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Fsync());
|
||||
}
|
||||
IOStatus Close(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Close());
|
||||
}
|
||||
|
||||
private:
|
||||
std::unique_ptr<RandomRWFile> target_;
|
||||
};
|
||||
|
||||
class LegacyWritableFileWrapper : public FSWritableFile {
|
||||
public:
|
||||
explicit LegacyWritableFileWrapper(std::unique_ptr<WritableFile>&& _target)
|
||||
: target_(std::move(_target)) {}
|
||||
|
||||
IOStatus Append(const Slice& data, const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Append(data));
|
||||
}
|
||||
IOStatus Append(const Slice& data, const IOOptions& /*options*/,
|
||||
const DataVerificationInfo& /*verification_info*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Append(data));
|
||||
}
|
||||
IOStatus PositionedAppend(const Slice& data, uint64_t offset,
|
||||
const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->PositionedAppend(data, offset));
|
||||
}
|
||||
IOStatus PositionedAppend(const Slice& data, uint64_t offset,
|
||||
const IOOptions& /*options*/,
|
||||
const DataVerificationInfo& /*verification_info*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->PositionedAppend(data, offset));
|
||||
}
|
||||
IOStatus Truncate(uint64_t size, const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Truncate(size));
|
||||
}
|
||||
IOStatus Close(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Close());
|
||||
}
|
||||
IOStatus Flush(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Flush());
|
||||
}
|
||||
IOStatus Sync(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Sync());
|
||||
}
|
||||
IOStatus Fsync(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Fsync());
|
||||
}
|
||||
bool IsSyncThreadSafe() const override { return target_->IsSyncThreadSafe(); }
|
||||
|
||||
bool use_direct_io() const override { return target_->use_direct_io(); }
|
||||
|
||||
size_t GetRequiredBufferAlignment() const override {
|
||||
return target_->GetRequiredBufferAlignment();
|
||||
}
|
||||
|
||||
void SetWriteLifeTimeHint(Env::WriteLifeTimeHint hint) override {
|
||||
target_->SetWriteLifeTimeHint(hint);
|
||||
}
|
||||
|
||||
Env::WriteLifeTimeHint GetWriteLifeTimeHint() override {
|
||||
return target_->GetWriteLifeTimeHint();
|
||||
}
|
||||
|
||||
uint64_t GetFileSize(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return target_->GetFileSize();
|
||||
}
|
||||
|
||||
void SetPreallocationBlockSize(size_t size) override {
|
||||
target_->SetPreallocationBlockSize(size);
|
||||
}
|
||||
|
||||
void GetPreallocationStatus(size_t* block_size,
|
||||
size_t* last_allocated_block) override {
|
||||
target_->GetPreallocationStatus(block_size, last_allocated_block);
|
||||
}
|
||||
|
||||
size_t GetUniqueId(char* id, size_t max_size) const override {
|
||||
return target_->GetUniqueId(id, max_size);
|
||||
}
|
||||
|
||||
IOStatus InvalidateCache(size_t offset, size_t length) override {
|
||||
return status_to_io_status(target_->InvalidateCache(offset, length));
|
||||
}
|
||||
|
||||
IOStatus RangeSync(uint64_t offset, uint64_t nbytes,
|
||||
const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->RangeSync(offset, nbytes));
|
||||
}
|
||||
|
||||
void PrepareWrite(size_t offset, size_t len, const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
target_->PrepareWrite(offset, len);
|
||||
}
|
||||
|
||||
IOStatus Allocate(uint64_t offset, uint64_t len, const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Allocate(offset, len));
|
||||
}
|
||||
|
||||
private:
|
||||
std::unique_ptr<WritableFile> target_;
|
||||
};
|
||||
|
||||
class LegacyDirectoryWrapper : public FSDirectory {
|
||||
public:
|
||||
explicit LegacyDirectoryWrapper(std::unique_ptr<Directory>&& target)
|
||||
: target_(std::move(target)) {}
|
||||
|
||||
IOStatus Fsync(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return status_to_io_status(target_->Fsync());
|
||||
}
|
||||
size_t GetUniqueId(char* id, size_t max_size) const override {
|
||||
return target_->GetUniqueId(id, max_size);
|
||||
}
|
||||
|
||||
private:
|
||||
std::unique_ptr<Directory> target_;
|
||||
};
|
||||
|
||||
class LegacyFileSystemWrapper : public FileSystem {
|
||||
public:
|
||||
// Initialize an EnvWrapper that delegates all calls to *t
|
||||
|
@ -1009,18 +759,18 @@ EnvOptions::EnvOptions() {
|
|||
|
||||
Status NewEnvLogger(const std::string& fname, Env* env,
|
||||
std::shared_ptr<Logger>* result) {
|
||||
FileOptions options;
|
||||
EnvOptions options;
|
||||
// TODO: Tune the buffer size.
|
||||
options.writable_file_max_buffer_size = 1024 * 1024;
|
||||
std::unique_ptr<FSWritableFile> writable_file;
|
||||
const auto status = env->GetFileSystem()->NewWritableFile(
|
||||
fname, options, &writable_file, nullptr);
|
||||
std::unique_ptr<WritableFile> writable_file;
|
||||
const auto status = env->NewWritableFile(fname, &writable_file, options);
|
||||
if (!status.ok()) {
|
||||
return status;
|
||||
}
|
||||
|
||||
*result = std::make_shared<EnvLogger>(std::move(writable_file), fname,
|
||||
options, env);
|
||||
*result = std::make_shared<EnvLogger>(
|
||||
NewLegacyWritableFileWrapper(std::move(writable_file)), fname, options,
|
||||
env);
|
||||
return Status::OK();
|
||||
}
|
||||
|
||||
|
|
1
env/env_posix.cc
vendored
1
env/env_posix.cc
vendored
|
@ -123,7 +123,6 @@ class PosixDynamicLibrary : public DynamicLibrary {
|
|||
void* handle_;
|
||||
};
|
||||
#endif // !ROCKSDB_NO_DYNAMIC_EXTENSION
|
||||
|
||||
class PosixClock : public SystemClock {
|
||||
public:
|
||||
const char* Name() const override { return "PosixClock"; }
|
||||
|
|
|
@ -22,17 +22,6 @@
|
|||
#include "util/rate_limiter.h"
|
||||
|
||||
namespace ROCKSDB_NAMESPACE {
|
||||
Status RandomAccessFileReader::Create(
|
||||
const std::shared_ptr<FileSystem>& fs, const std::string& fname,
|
||||
const FileOptions& file_opts,
|
||||
std::unique_ptr<RandomAccessFileReader>* reader, IODebugContext* dbg) {
|
||||
std::unique_ptr<FSRandomAccessFile> file;
|
||||
Status s = fs->NewRandomAccessFile(fname, file_opts, &file, dbg);
|
||||
if (s.ok()) {
|
||||
reader->reset(new RandomAccessFileReader(std::move(file), fname));
|
||||
}
|
||||
return s;
|
||||
}
|
||||
|
||||
Status RandomAccessFileReader::Read(const IOOptions& opts, uint64_t offset,
|
||||
size_t n, Slice* result, char* scratch,
|
||||
|
|
|
@ -103,10 +103,6 @@ class RandomAccessFileReader {
|
|||
#endif
|
||||
}
|
||||
|
||||
static Status Create(const std::shared_ptr<FileSystem>& fs,
|
||||
const std::string& fname, const FileOptions& file_opts,
|
||||
std::unique_ptr<RandomAccessFileReader>* reader,
|
||||
IODebugContext* dbg);
|
||||
RandomAccessFileReader(const RandomAccessFileReader&) = delete;
|
||||
RandomAccessFileReader& operator=(const RandomAccessFileReader&) = delete;
|
||||
|
||||
|
|
|
@ -22,18 +22,6 @@
|
|||
#include "util/rate_limiter.h"
|
||||
|
||||
namespace ROCKSDB_NAMESPACE {
|
||||
Status SequentialFileReader::Create(
|
||||
const std::shared_ptr<FileSystem>& fs, const std::string& fname,
|
||||
const FileOptions& file_opts, std::unique_ptr<SequentialFileReader>* reader,
|
||||
IODebugContext* dbg) {
|
||||
std::unique_ptr<FSSequentialFile> file;
|
||||
Status s = fs->NewSequentialFile(fname, file_opts, &file, dbg);
|
||||
if (s.ok()) {
|
||||
reader->reset(new SequentialFileReader(std::move(file), fname));
|
||||
}
|
||||
return s;
|
||||
}
|
||||
|
||||
Status SequentialFileReader::Read(size_t n, Slice* result, char* scratch) {
|
||||
Status s;
|
||||
if (use_direct_io()) {
|
||||
|
|
|
@ -41,10 +41,6 @@ class SequentialFileReader {
|
|||
: file_name_(_file_name),
|
||||
file_(NewReadaheadSequentialFile(std::move(_file), _readahead_size),
|
||||
io_tracer, _file_name) {}
|
||||
static Status Create(const std::shared_ptr<FileSystem>& fs,
|
||||
const std::string& fname, const FileOptions& file_opts,
|
||||
std::unique_ptr<SequentialFileReader>* reader,
|
||||
IODebugContext* dbg);
|
||||
|
||||
SequentialFileReader(const SequentialFileReader&) = delete;
|
||||
SequentialFileReader& operator=(const SequentialFileReader&) = delete;
|
||||
|
|
|
@ -23,19 +23,6 @@
|
|||
#include "util/rate_limiter.h"
|
||||
|
||||
namespace ROCKSDB_NAMESPACE {
|
||||
Status WritableFileWriter::Create(const std::shared_ptr<FileSystem>& fs,
|
||||
const std::string& fname,
|
||||
const FileOptions& file_opts,
|
||||
std::unique_ptr<WritableFileWriter>* writer,
|
||||
IODebugContext* dbg) {
|
||||
std::unique_ptr<FSWritableFile> file;
|
||||
Status s = fs->NewWritableFile(fname, file_opts, &file, dbg);
|
||||
if (s.ok()) {
|
||||
writer->reset(new WritableFileWriter(std::move(file), fname, file_opts));
|
||||
}
|
||||
return s;
|
||||
}
|
||||
|
||||
IOStatus WritableFileWriter::Append(const Slice& data) {
|
||||
const char* src = data.data();
|
||||
size_t left = data.size();
|
||||
|
|
|
@ -196,10 +196,6 @@ class WritableFileWriter {
|
|||
}
|
||||
}
|
||||
|
||||
static Status Create(const std::shared_ptr<FileSystem>& fs,
|
||||
const std::string& fname, const FileOptions& file_opts,
|
||||
std::unique_ptr<WritableFileWriter>* writer,
|
||||
IODebugContext* dbg);
|
||||
WritableFileWriter(const WritableFileWriter&) = delete;
|
||||
|
||||
WritableFileWriter& operator=(const WritableFileWriter&) = delete;
|
||||
|
|
|
@ -58,15 +58,16 @@ TableReader* NewTableReader(const std::string& sst_file_path,
|
|||
// This code block is similar to SstFileReader::Open.
|
||||
|
||||
uint64_t file_size = 0;
|
||||
std::unique_ptr<RandomAccessFile> file;
|
||||
std::unique_ptr<RandomAccessFileReader> file_reader;
|
||||
std::unique_ptr<TableReader> table_reader;
|
||||
const auto& fs = options.env->GetFileSystem();
|
||||
FileOptions fopts(env_options);
|
||||
Status s = options.env->GetFileSize(sst_file_path, fopts.io_options,
|
||||
&file_size, nullptr);
|
||||
Status s = options.env->GetFileSize(sst_file_path, &file_size);
|
||||
if (s.ok()) {
|
||||
s = RandomAccessFileReader::Create(fs, sst_file_path, fopts, &file_reader,
|
||||
nullptr);
|
||||
s = options.env->NewRandomAccessFile(sst_file_path, &file, env_options);
|
||||
}
|
||||
if (s.ok()) {
|
||||
file_reader.reset(new RandomAccessFileReader(
|
||||
NewLegacyRandomAccessFileWrapper(file), sst_file_path));
|
||||
}
|
||||
if (s.ok()) {
|
||||
TableReaderOptions t_opt(cf_ioptions, /*prefix_extractor=*/nullptr,
|
||||
|
|
|
@ -1360,7 +1360,6 @@ Status WinEnv::GetThreadList(std::vector<ThreadStatus>* thread_list) {
|
|||
Status WinEnv::GetHostName(char* name, uint64_t len) {
|
||||
return winenv_io_.GetHostName(name, len);
|
||||
}
|
||||
|
||||
void WinEnv::Schedule(void (*function)(void*), void* arg, Env::Priority pri,
|
||||
void* tag, void (*unschedFunction)(void* arg)) {
|
||||
return winenv_threads_.Schedule(function, arg, pri, tag, unschedFunction);
|
||||
|
|
|
@ -24,6 +24,7 @@ namespace ROCKSDB_NAMESPACE {
|
|||
class SystemClock;
|
||||
|
||||
namespace port {
|
||||
|
||||
class WinLogger : public ROCKSDB_NAMESPACE::Logger {
|
||||
public:
|
||||
WinLogger(uint64_t (*gettid)(), const std::shared_ptr<SystemClock>& clock,
|
||||
|
|
|
@ -6,11 +6,11 @@
|
|||
#include "table/block_fetcher.h"
|
||||
|
||||
#include "db/table_properties_collector.h"
|
||||
#include "env/composite_env_wrapper.h"
|
||||
#include "file/file_util.h"
|
||||
#include "options/options_helper.h"
|
||||
#include "port/port.h"
|
||||
#include "port/stack_trace.h"
|
||||
#include "rocksdb/file_system.h"
|
||||
#include "table/block_based/binary_search_index_reader.h"
|
||||
#include "table/block_based/block_based_table_builder.h"
|
||||
#include "table/block_based/block_based_table_factory.h"
|
||||
|
@ -248,9 +248,11 @@ class BlockFetcherTest : public testing::Test {
|
|||
void NewFileWriter(const std::string& filename,
|
||||
std::unique_ptr<WritableFileWriter>* writer) {
|
||||
std::string path = Path(filename);
|
||||
FileOptions file_options;
|
||||
ASSERT_OK(WritableFileWriter::Create(env_->GetFileSystem(), path,
|
||||
file_options, writer, nullptr));
|
||||
EnvOptions env_options;
|
||||
std::unique_ptr<WritableFile> file;
|
||||
ASSERT_OK(env_->NewWritableFile(path, &file, env_options));
|
||||
writer->reset(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(file)), path, env_options));
|
||||
}
|
||||
|
||||
void NewFileReader(const std::string& filename, const FileOptions& opt,
|
||||
|
|
|
@ -5,16 +5,14 @@
|
|||
|
||||
#ifndef ROCKSDB_LITE
|
||||
|
||||
#include "table/cuckoo/cuckoo_table_builder.h"
|
||||
|
||||
#include <map>
|
||||
#include <string>
|
||||
#include <utility>
|
||||
#include <vector>
|
||||
#include <string>
|
||||
#include <map>
|
||||
#include <utility>
|
||||
|
||||
#include "file/random_access_file_reader.h"
|
||||
#include "file/writable_file_writer.h"
|
||||
#include "rocksdb/file_system.h"
|
||||
#include "table/cuckoo/cuckoo_table_builder.h"
|
||||
#include "table/meta_blocks.h"
|
||||
#include "test_util/testharness.h"
|
||||
#include "test_util/testutil.h"
|
||||
|
@ -37,7 +35,7 @@ class CuckooBuilderTest : public testing::Test {
|
|||
env_ = Env::Default();
|
||||
Options options;
|
||||
options.allow_mmap_reads = true;
|
||||
file_options_ = FileOptions(options);
|
||||
env_options_ = EnvOptions(options);
|
||||
}
|
||||
|
||||
void CheckFileContents(const std::vector<std::string>& keys,
|
||||
|
@ -56,11 +54,10 @@ class CuckooBuilderTest : public testing::Test {
|
|||
}
|
||||
}
|
||||
// Read file
|
||||
std::unique_ptr<RandomAccessFile> read_file;
|
||||
ASSERT_OK(env_->NewRandomAccessFile(fname, &read_file, env_options_));
|
||||
uint64_t read_file_size;
|
||||
ASSERT_OK(env_->GetFileSize(fname, &read_file_size));
|
||||
std::unique_ptr<RandomAccessFileReader> file_reader;
|
||||
ASSERT_OK(RandomAccessFileReader::Create(
|
||||
env_->GetFileSystem(), fname, file_options_, &file_reader, nullptr));
|
||||
|
||||
Options options;
|
||||
options.allow_mmap_reads = true;
|
||||
|
@ -68,6 +65,9 @@ class CuckooBuilderTest : public testing::Test {
|
|||
|
||||
// Assert Table Properties.
|
||||
TableProperties* props = nullptr;
|
||||
std::unique_ptr<RandomAccessFileReader> file_reader(
|
||||
new RandomAccessFileReader(NewLegacyRandomAccessFileWrapper(read_file),
|
||||
fname));
|
||||
ASSERT_OK(ReadTableProperties(file_reader.get(), read_file_size,
|
||||
kCuckooTableMagicNumber, ioptions,
|
||||
&props, true /* compression_type_missing */));
|
||||
|
@ -158,7 +158,7 @@ class CuckooBuilderTest : public testing::Test {
|
|||
|
||||
|
||||
Env* env_;
|
||||
FileOptions file_options_;
|
||||
EnvOptions env_options_;
|
||||
std::string fname;
|
||||
const double kHashTableRatio = 0.9;
|
||||
};
|
||||
|
@ -166,9 +166,10 @@ class CuckooBuilderTest : public testing::Test {
|
|||
TEST_F(CuckooBuilderTest, SuccessWithEmptyFile) {
|
||||
std::unique_ptr<WritableFile> writable_file;
|
||||
fname = test::PerThreadDBPath("EmptyFile");
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
ASSERT_OK(WritableFileWriter::Create(env_->GetFileSystem(), fname,
|
||||
file_options_, &file_writer, nullptr));
|
||||
ASSERT_OK(env_->NewWritableFile(fname, &writable_file, env_options_));
|
||||
std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(writable_file)), fname,
|
||||
EnvOptions()));
|
||||
CuckooTableBuilder builder(file_writer.get(), kHashTableRatio, 4, 100,
|
||||
BytewiseComparator(), 1, false, false,
|
||||
GetSliceHash, 0 /* column_family_id */,
|
||||
|
@ -206,10 +207,12 @@ TEST_F(CuckooBuilderTest, WriteSuccessNoCollisionFullKey) {
|
|||
}
|
||||
uint64_t expected_table_size = GetExpectedTableSize(keys.size());
|
||||
|
||||
std::unique_ptr<WritableFile> writable_file;
|
||||
fname = test::PerThreadDBPath("NoCollisionFullKey");
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
ASSERT_OK(WritableFileWriter::Create(env_->GetFileSystem(), fname,
|
||||
file_options_, &file_writer, nullptr));
|
||||
ASSERT_OK(env_->NewWritableFile(fname, &writable_file, env_options_));
|
||||
std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(writable_file)), fname,
|
||||
EnvOptions()));
|
||||
CuckooTableBuilder builder(file_writer.get(), kHashTableRatio, num_hash_fun,
|
||||
100, BytewiseComparator(), 1, false, false,
|
||||
GetSliceHash, 0 /* column_family_id */,
|
||||
|
@ -254,10 +257,12 @@ TEST_F(CuckooBuilderTest, WriteSuccessWithCollisionFullKey) {
|
|||
}
|
||||
uint64_t expected_table_size = GetExpectedTableSize(keys.size());
|
||||
|
||||
std::unique_ptr<WritableFile> writable_file;
|
||||
fname = test::PerThreadDBPath("WithCollisionFullKey");
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
ASSERT_OK(WritableFileWriter::Create(env_->GetFileSystem(), fname,
|
||||
file_options_, &file_writer, nullptr));
|
||||
ASSERT_OK(env_->NewWritableFile(fname, &writable_file, env_options_));
|
||||
std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(writable_file)), fname,
|
||||
EnvOptions()));
|
||||
CuckooTableBuilder builder(file_writer.get(), kHashTableRatio, num_hash_fun,
|
||||
100, BytewiseComparator(), 1, false, false,
|
||||
GetSliceHash, 0 /* column_family_id */,
|
||||
|
@ -301,11 +306,13 @@ TEST_F(CuckooBuilderTest, WriteSuccessWithCollisionAndCuckooBlock) {
|
|||
}
|
||||
uint64_t expected_table_size = GetExpectedTableSize(keys.size());
|
||||
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
std::unique_ptr<WritableFile> writable_file;
|
||||
uint32_t cuckoo_block_size = 2;
|
||||
fname = test::PerThreadDBPath("WithCollisionFullKey2");
|
||||
ASSERT_OK(WritableFileWriter::Create(env_->GetFileSystem(), fname,
|
||||
file_options_, &file_writer, nullptr));
|
||||
ASSERT_OK(env_->NewWritableFile(fname, &writable_file, env_options_));
|
||||
std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(writable_file)), fname,
|
||||
EnvOptions()));
|
||||
CuckooTableBuilder builder(
|
||||
file_writer.get(), kHashTableRatio, num_hash_fun, 100,
|
||||
BytewiseComparator(), cuckoo_block_size, false, false, GetSliceHash,
|
||||
|
@ -354,10 +361,12 @@ TEST_F(CuckooBuilderTest, WithCollisionPathFullKey) {
|
|||
}
|
||||
uint64_t expected_table_size = GetExpectedTableSize(keys.size());
|
||||
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
std::unique_ptr<WritableFile> writable_file;
|
||||
fname = test::PerThreadDBPath("WithCollisionPathFullKey");
|
||||
ASSERT_OK(WritableFileWriter::Create(env_->GetFileSystem(), fname,
|
||||
file_options_, &file_writer, nullptr));
|
||||
ASSERT_OK(env_->NewWritableFile(fname, &writable_file, env_options_));
|
||||
std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(writable_file)), fname,
|
||||
EnvOptions()));
|
||||
CuckooTableBuilder builder(file_writer.get(), kHashTableRatio, num_hash_fun,
|
||||
100, BytewiseComparator(), 1, false, false,
|
||||
GetSliceHash, 0 /* column_family_id */,
|
||||
|
@ -403,10 +412,12 @@ TEST_F(CuckooBuilderTest, WithCollisionPathFullKeyAndCuckooBlock) {
|
|||
}
|
||||
uint64_t expected_table_size = GetExpectedTableSize(keys.size());
|
||||
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
std::unique_ptr<WritableFile> writable_file;
|
||||
fname = test::PerThreadDBPath("WithCollisionPathFullKeyAndCuckooBlock");
|
||||
ASSERT_OK(WritableFileWriter::Create(env_->GetFileSystem(), fname,
|
||||
file_options_, &file_writer, nullptr));
|
||||
ASSERT_OK(env_->NewWritableFile(fname, &writable_file, env_options_));
|
||||
std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(writable_file)), fname,
|
||||
EnvOptions()));
|
||||
CuckooTableBuilder builder(file_writer.get(), kHashTableRatio, num_hash_fun,
|
||||
100, BytewiseComparator(), 2, false, false,
|
||||
GetSliceHash, 0 /* column_family_id */,
|
||||
|
@ -445,11 +456,12 @@ TEST_F(CuckooBuilderTest, WriteSuccessNoCollisionUserKey) {
|
|||
std::vector<uint64_t> expected_locations = {0, 1, 2, 3};
|
||||
uint64_t expected_table_size = GetExpectedTableSize(user_keys.size());
|
||||
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
std::unique_ptr<WritableFile> writable_file;
|
||||
fname = test::PerThreadDBPath("NoCollisionUserKey");
|
||||
ASSERT_OK(WritableFileWriter::Create(env_->GetFileSystem(), fname,
|
||||
file_options_, &file_writer, nullptr));
|
||||
|
||||
ASSERT_OK(env_->NewWritableFile(fname, &writable_file, env_options_));
|
||||
std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(writable_file)), fname,
|
||||
EnvOptions()));
|
||||
CuckooTableBuilder builder(file_writer.get(), kHashTableRatio, num_hash_fun,
|
||||
100, BytewiseComparator(), 1, false, false,
|
||||
GetSliceHash, 0 /* column_family_id */,
|
||||
|
@ -489,11 +501,12 @@ TEST_F(CuckooBuilderTest, WriteSuccessWithCollisionUserKey) {
|
|||
std::vector<uint64_t> expected_locations = {0, 1, 2, 3};
|
||||
uint64_t expected_table_size = GetExpectedTableSize(user_keys.size());
|
||||
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
std::unique_ptr<WritableFile> writable_file;
|
||||
fname = test::PerThreadDBPath("WithCollisionUserKey");
|
||||
ASSERT_OK(WritableFileWriter::Create(env_->GetFileSystem(), fname,
|
||||
file_options_, &file_writer, nullptr));
|
||||
|
||||
ASSERT_OK(env_->NewWritableFile(fname, &writable_file, env_options_));
|
||||
std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(writable_file)), fname,
|
||||
EnvOptions()));
|
||||
CuckooTableBuilder builder(file_writer.get(), kHashTableRatio, num_hash_fun,
|
||||
100, BytewiseComparator(), 1, false, false,
|
||||
GetSliceHash, 0 /* column_family_id */,
|
||||
|
@ -535,11 +548,12 @@ TEST_F(CuckooBuilderTest, WithCollisionPathUserKey) {
|
|||
std::vector<uint64_t> expected_locations = {0, 1, 3, 4, 2};
|
||||
uint64_t expected_table_size = GetExpectedTableSize(user_keys.size());
|
||||
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
std::unique_ptr<WritableFile> writable_file;
|
||||
fname = test::PerThreadDBPath("WithCollisionPathUserKey");
|
||||
ASSERT_OK(WritableFileWriter::Create(env_->GetFileSystem(), fname,
|
||||
file_options_, &file_writer, nullptr));
|
||||
|
||||
ASSERT_OK(env_->NewWritableFile(fname, &writable_file, env_options_));
|
||||
std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(writable_file)), fname,
|
||||
EnvOptions()));
|
||||
CuckooTableBuilder builder(file_writer.get(), kHashTableRatio, num_hash_fun,
|
||||
2, BytewiseComparator(), 1, false, false,
|
||||
GetSliceHash, 0 /* column_family_id */,
|
||||
|
@ -580,10 +594,12 @@ TEST_F(CuckooBuilderTest, FailWhenCollisionPathTooLong) {
|
|||
};
|
||||
hash_map = std::move(hm);
|
||||
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
std::unique_ptr<WritableFile> writable_file;
|
||||
fname = test::PerThreadDBPath("WithCollisionPathUserKey");
|
||||
ASSERT_OK(WritableFileWriter::Create(env_->GetFileSystem(), fname,
|
||||
file_options_, &file_writer, nullptr));
|
||||
ASSERT_OK(env_->NewWritableFile(fname, &writable_file, env_options_));
|
||||
std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(writable_file)), fname,
|
||||
EnvOptions()));
|
||||
CuckooTableBuilder builder(file_writer.get(), kHashTableRatio, num_hash_fun,
|
||||
2, BytewiseComparator(), 1, false, false,
|
||||
GetSliceHash, 0 /* column_family_id */,
|
||||
|
@ -607,10 +623,12 @@ TEST_F(CuckooBuilderTest, FailWhenSameKeyInserted) {
|
|||
uint32_t num_hash_fun = 4;
|
||||
std::string user_key = "repeatedkey";
|
||||
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
std::unique_ptr<WritableFile> writable_file;
|
||||
fname = test::PerThreadDBPath("FailWhenSameKeyInserted");
|
||||
ASSERT_OK(WritableFileWriter::Create(env_->GetFileSystem(), fname,
|
||||
file_options_, &file_writer, nullptr));
|
||||
ASSERT_OK(env_->NewWritableFile(fname, &writable_file, env_options_));
|
||||
std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(writable_file)), fname,
|
||||
EnvOptions()));
|
||||
CuckooTableBuilder builder(file_writer.get(), kHashTableRatio, num_hash_fun,
|
||||
100, BytewiseComparator(), 1, false, false,
|
||||
GetSliceHash, 0 /* column_family_id */,
|
||||
|
|
|
@ -68,7 +68,7 @@ class CuckooReaderTest : public testing::Test {
|
|||
CuckooReaderTest() {
|
||||
options.allow_mmap_reads = true;
|
||||
env = options.env;
|
||||
file_options = FileOptions(options);
|
||||
env_options = EnvOptions(options);
|
||||
}
|
||||
|
||||
void SetUp(int num) {
|
||||
|
@ -88,9 +88,12 @@ class CuckooReaderTest : public testing::Test {
|
|||
|
||||
void CreateCuckooFileAndCheckReader(
|
||||
const Comparator* ucomp = BytewiseComparator()) {
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
ASSERT_OK(WritableFileWriter::Create(env->GetFileSystem(), fname,
|
||||
file_options, &file_writer, nullptr));
|
||||
std::unique_ptr<WritableFile> writable_file;
|
||||
ASSERT_OK(env->NewWritableFile(fname, &writable_file, env_options));
|
||||
std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(writable_file)), fname,
|
||||
env_options));
|
||||
|
||||
CuckooTableBuilder builder(
|
||||
file_writer.get(), 0.9, kNumHashFunc, 100, ucomp, 2, false, false,
|
||||
GetSliceHash, 0 /* column_family_id */, kDefaultColumnFamilyName);
|
||||
|
@ -106,9 +109,11 @@ class CuckooReaderTest : public testing::Test {
|
|||
ASSERT_OK(file_writer->Close());
|
||||
|
||||
// Check reader now.
|
||||
std::unique_ptr<RandomAccessFileReader> file_reader;
|
||||
ASSERT_OK(RandomAccessFileReader::Create(
|
||||
env->GetFileSystem(), fname, file_options, &file_reader, nullptr));
|
||||
std::unique_ptr<RandomAccessFile> read_file;
|
||||
ASSERT_OK(env->NewRandomAccessFile(fname, &read_file, env_options));
|
||||
std::unique_ptr<RandomAccessFileReader> file_reader(
|
||||
new RandomAccessFileReader(NewLegacyRandomAccessFileWrapper(read_file),
|
||||
fname));
|
||||
const ImmutableCFOptions ioptions(options);
|
||||
CuckooTableReader reader(ioptions, std::move(file_reader), file_size, ucomp,
|
||||
GetSliceHash);
|
||||
|
@ -134,9 +139,11 @@ class CuckooReaderTest : public testing::Test {
|
|||
}
|
||||
|
||||
void CheckIterator(const Comparator* ucomp = BytewiseComparator()) {
|
||||
std::unique_ptr<RandomAccessFileReader> file_reader;
|
||||
ASSERT_OK(RandomAccessFileReader::Create(
|
||||
env->GetFileSystem(), fname, file_options, &file_reader, nullptr));
|
||||
std::unique_ptr<RandomAccessFile> read_file;
|
||||
ASSERT_OK(env->NewRandomAccessFile(fname, &read_file, env_options));
|
||||
std::unique_ptr<RandomAccessFileReader> file_reader(
|
||||
new RandomAccessFileReader(NewLegacyRandomAccessFileWrapper(read_file),
|
||||
fname));
|
||||
const ImmutableCFOptions ioptions(options);
|
||||
CuckooTableReader reader(ioptions, std::move(file_reader), file_size, ucomp,
|
||||
GetSliceHash);
|
||||
|
@ -204,7 +211,7 @@ class CuckooReaderTest : public testing::Test {
|
|||
uint64_t file_size;
|
||||
Options options;
|
||||
Env* env;
|
||||
FileOptions file_options;
|
||||
EnvOptions env_options;
|
||||
};
|
||||
|
||||
TEST_F(CuckooReaderTest, FileNotMmaped) {
|
||||
|
@ -323,11 +330,11 @@ TEST_F(CuckooReaderTest, WhenKeyNotFound) {
|
|||
}
|
||||
auto* ucmp = BytewiseComparator();
|
||||
CreateCuckooFileAndCheckReader();
|
||||
|
||||
std::unique_ptr<RandomAccessFileReader> file_reader;
|
||||
ASSERT_OK(RandomAccessFileReader::Create(
|
||||
env->GetFileSystem(), fname, file_options, &file_reader, nullptr));
|
||||
|
||||
std::unique_ptr<RandomAccessFile> read_file;
|
||||
ASSERT_OK(env->NewRandomAccessFile(fname, &read_file, env_options));
|
||||
std::unique_ptr<RandomAccessFileReader> file_reader(
|
||||
new RandomAccessFileReader(NewLegacyRandomAccessFileWrapper(read_file),
|
||||
fname));
|
||||
const ImmutableCFOptions ioptions(options);
|
||||
CuckooTableReader reader(ioptions, std::move(file_reader), file_size, ucmp,
|
||||
GetSliceHash);
|
||||
|
@ -408,13 +415,15 @@ void WriteFile(const std::vector<std::string>& keys,
|
|||
const uint64_t num, double hash_ratio) {
|
||||
Options options;
|
||||
options.allow_mmap_reads = true;
|
||||
const auto& fs = options.env->GetFileSystem();
|
||||
FileOptions file_options(options);
|
||||
Env* env = options.env;
|
||||
EnvOptions env_options = EnvOptions(options);
|
||||
std::string fname = GetFileName(num);
|
||||
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
ASSERT_OK(WritableFileWriter::Create(fs, fname, file_options, &file_writer,
|
||||
nullptr));
|
||||
std::unique_ptr<WritableFile> writable_file;
|
||||
ASSERT_OK(env->NewWritableFile(fname, &writable_file, env_options));
|
||||
std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(writable_file)), fname,
|
||||
env_options));
|
||||
CuckooTableBuilder builder(
|
||||
file_writer.get(), hash_ratio, 64, 1000, test::Uint64Comparator(), 5,
|
||||
false, FLAGS_identity_as_first_hash, nullptr, 0 /* column_family_id */,
|
||||
|
@ -431,11 +440,12 @@ void WriteFile(const std::vector<std::string>& keys,
|
|||
ASSERT_OK(file_writer->Close());
|
||||
|
||||
uint64_t file_size;
|
||||
ASSERT_OK(
|
||||
fs->GetFileSize(fname, file_options.io_options, &file_size, nullptr));
|
||||
std::unique_ptr<RandomAccessFileReader> file_reader;
|
||||
ASSERT_OK(RandomAccessFileReader::Create(fs, fname, file_options,
|
||||
&file_reader, nullptr));
|
||||
env->GetFileSize(fname, &file_size);
|
||||
std::unique_ptr<RandomAccessFile> read_file;
|
||||
ASSERT_OK(env->NewRandomAccessFile(fname, &read_file, env_options));
|
||||
std::unique_ptr<RandomAccessFileReader> file_reader(
|
||||
new RandomAccessFileReader(NewLegacyRandomAccessFileWrapper(read_file),
|
||||
fname));
|
||||
|
||||
const ImmutableCFOptions ioptions(options);
|
||||
CuckooTableReader reader(ioptions, std::move(file_reader), file_size,
|
||||
|
@ -459,16 +469,16 @@ void ReadKeys(uint64_t num, uint32_t batch_size) {
|
|||
Options options;
|
||||
options.allow_mmap_reads = true;
|
||||
Env* env = options.env;
|
||||
const auto& fs = options.env->GetFileSystem();
|
||||
FileOptions file_options(options);
|
||||
EnvOptions env_options = EnvOptions(options);
|
||||
std::string fname = GetFileName(num);
|
||||
|
||||
uint64_t file_size;
|
||||
ASSERT_OK(
|
||||
fs->GetFileSize(fname, file_options.io_options, &file_size, nullptr));
|
||||
std::unique_ptr<RandomAccessFileReader> file_reader;
|
||||
ASSERT_OK(RandomAccessFileReader::Create(fs, fname, file_options,
|
||||
&file_reader, nullptr));
|
||||
env->GetFileSize(fname, &file_size);
|
||||
std::unique_ptr<RandomAccessFile> read_file;
|
||||
ASSERT_OK(env->NewRandomAccessFile(fname, &read_file, env_options));
|
||||
std::unique_ptr<RandomAccessFileReader> file_reader(
|
||||
new RandomAccessFileReader(NewLegacyRandomAccessFileWrapper(read_file),
|
||||
fname));
|
||||
|
||||
const ImmutableCFOptions ioptions(options);
|
||||
CuckooTableReader reader(ioptions, std::move(file_reader), file_size,
|
||||
|
|
|
@ -265,14 +265,17 @@ TableBuilder* MockTableFactory::NewTableBuilder(
|
|||
|
||||
Status MockTableFactory::CreateMockTable(Env* env, const std::string& fname,
|
||||
KVVector file_contents) {
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
auto s = WritableFileWriter::Create(env->GetFileSystem(), fname,
|
||||
FileOptions(), &file_writer, nullptr);
|
||||
std::unique_ptr<WritableFile> file;
|
||||
auto s = env->NewWritableFile(fname, &file, EnvOptions());
|
||||
if (!s.ok()) {
|
||||
return s;
|
||||
}
|
||||
|
||||
WritableFileWriter file_writer(NewLegacyWritableFileWrapper(std::move(file)),
|
||||
fname, EnvOptions());
|
||||
|
||||
uint32_t id;
|
||||
s = GetAndWriteNextID(file_writer.get(), &id);
|
||||
s = GetAndWriteNextID(&file_writer, &id);
|
||||
if (s.ok()) {
|
||||
file_system_.files.insert({id, std::move(file_contents)});
|
||||
}
|
||||
|
|
|
@ -18,6 +18,7 @@
|
|||
#include "db/blob/blob_index.h"
|
||||
#include "db/memtable.h"
|
||||
#include "db/write_batch_internal.h"
|
||||
#include "env/composite_env_wrapper.h"
|
||||
#include "options/cf_options.h"
|
||||
#include "port/port.h"
|
||||
#include "rocksdb/db.h"
|
||||
|
@ -79,13 +80,11 @@ Status SstFileDumper::GetTableReader(const std::string& file_path) {
|
|||
// read table magic number
|
||||
Footer footer;
|
||||
|
||||
const auto& fs = options_.env->GetFileSystem();
|
||||
std::unique_ptr<FSRandomAccessFile> file;
|
||||
std::unique_ptr<RandomAccessFile> file;
|
||||
uint64_t file_size = 0;
|
||||
Status s = fs->NewRandomAccessFile(file_path, FileOptions(soptions_), &file,
|
||||
nullptr);
|
||||
Status s = options_.env->NewRandomAccessFile(file_path, &file, soptions_);
|
||||
if (s.ok()) {
|
||||
s = fs->GetFileSize(file_path, IOOptions(), &file_size, nullptr);
|
||||
s = options_.env->GetFileSize(file_path, &file_size);
|
||||
}
|
||||
|
||||
// check empty file
|
||||
|
@ -94,7 +93,8 @@ Status SstFileDumper::GetTableReader(const std::string& file_path) {
|
|||
return Status::Aborted(file_path, "Empty file");
|
||||
}
|
||||
|
||||
file_.reset(new RandomAccessFileReader(std::move(file), file_path));
|
||||
file_.reset(new RandomAccessFileReader(NewLegacyRandomAccessFileWrapper(file),
|
||||
file_path));
|
||||
|
||||
FilePrefetchBuffer prefetch_buffer(nullptr, 0, 0, true /* enable */,
|
||||
false /* track_min_offset */);
|
||||
|
@ -119,10 +119,9 @@ Status SstFileDumper::GetTableReader(const std::string& file_path) {
|
|||
if (magic_number == kPlainTableMagicNumber ||
|
||||
magic_number == kLegacyPlainTableMagicNumber) {
|
||||
soptions_.use_mmap_reads = true;
|
||||
|
||||
fs->NewRandomAccessFile(file_path, FileOptions(soptions_), &file,
|
||||
nullptr);
|
||||
file_.reset(new RandomAccessFileReader(std::move(file), file_path));
|
||||
options_.env->NewRandomAccessFile(file_path, &file, soptions_);
|
||||
file_.reset(new RandomAccessFileReader(
|
||||
NewLegacyRandomAccessFileWrapper(file), file_path));
|
||||
}
|
||||
options_.comparator = &internal_comparator_;
|
||||
// For old sst format, ReadTableProperties might fail but file can be read
|
||||
|
@ -193,14 +192,16 @@ Status SstFileDumper::DumpTable(const std::string& out_filename) {
|
|||
Status SstFileDumper::CalculateCompressedTableSize(
|
||||
const TableBuilderOptions& tb_options, size_t block_size,
|
||||
uint64_t* num_data_blocks, uint64_t* compressed_table_size) {
|
||||
std::unique_ptr<WritableFile> out_file;
|
||||
std::unique_ptr<Env> env(NewMemEnv(options_.env));
|
||||
std::unique_ptr<WritableFileWriter> dest_writer;
|
||||
Status s =
|
||||
WritableFileWriter::Create(env->GetFileSystem(), testFileName,
|
||||
FileOptions(soptions_), &dest_writer, nullptr);
|
||||
Status s = env->NewWritableFile(testFileName, &out_file, soptions_);
|
||||
if (!s.ok()) {
|
||||
return s;
|
||||
}
|
||||
std::unique_ptr<WritableFileWriter> dest_writer;
|
||||
dest_writer.reset(
|
||||
new WritableFileWriter(NewLegacyWritableFileWrapper(std::move(out_file)),
|
||||
testFileName, soptions_));
|
||||
BlockBasedTableOptions table_options;
|
||||
table_options.block_size = block_size;
|
||||
BlockBasedTableFactory block_based_tf(table_options);
|
||||
|
|
|
@ -10,10 +10,9 @@
|
|||
#include "db/arena_wrapped_db_iter.h"
|
||||
#include "db/db_iter.h"
|
||||
#include "db/dbformat.h"
|
||||
#include "env/composite_env_wrapper.h"
|
||||
#include "file/random_access_file_reader.h"
|
||||
#include "options/cf_options.h"
|
||||
#include "rocksdb/env.h"
|
||||
#include "rocksdb/file_system.h"
|
||||
#include "table/get_context.h"
|
||||
#include "table/table_builder.h"
|
||||
#include "table/table_reader.h"
|
||||
|
@ -43,17 +42,15 @@ Status SstFileReader::Open(const std::string& file_path) {
|
|||
auto r = rep_.get();
|
||||
Status s;
|
||||
uint64_t file_size = 0;
|
||||
std::unique_ptr<FSRandomAccessFile> file;
|
||||
std::unique_ptr<RandomAccessFile> file;
|
||||
std::unique_ptr<RandomAccessFileReader> file_reader;
|
||||
FileOptions fopts(r->soptions);
|
||||
const auto& fs = r->options.env->GetFileSystem();
|
||||
|
||||
s = fs->GetFileSize(file_path, fopts.io_options, &file_size, nullptr);
|
||||
s = r->options.env->GetFileSize(file_path, &file_size);
|
||||
if (s.ok()) {
|
||||
s = fs->NewRandomAccessFile(file_path, fopts, &file, nullptr);
|
||||
s = r->options.env->NewRandomAccessFile(file_path, &file, r->soptions);
|
||||
}
|
||||
if (s.ok()) {
|
||||
file_reader.reset(new RandomAccessFileReader(std::move(file), file_path));
|
||||
file_reader.reset(new RandomAccessFileReader(
|
||||
NewLegacyRandomAccessFileWrapper(file), file_path));
|
||||
}
|
||||
if (s.ok()) {
|
||||
TableReaderOptions t_opt(r->ioptions, r->moptions.prefix_extractor.get(),
|
||||
|
|
|
@ -8,8 +8,8 @@
|
|||
#include <vector>
|
||||
|
||||
#include "db/dbformat.h"
|
||||
#include "env/composite_env_wrapper.h"
|
||||
#include "file/writable_file_writer.h"
|
||||
#include "rocksdb/file_system.h"
|
||||
#include "rocksdb/table.h"
|
||||
#include "table/block_based/block_based_table_builder.h"
|
||||
#include "table/sst_file_writer_collectors.h"
|
||||
|
|
|
@ -13,10 +13,10 @@ int main() {
|
|||
|
||||
#include "db/db_impl/db_impl.h"
|
||||
#include "db/dbformat.h"
|
||||
#include "env/composite_env_wrapper.h"
|
||||
#include "file/random_access_file_reader.h"
|
||||
#include "monitoring/histogram.h"
|
||||
#include "rocksdb/db.h"
|
||||
#include "rocksdb/file_system.h"
|
||||
#include "rocksdb/slice_transform.h"
|
||||
#include "rocksdb/system_clock.h"
|
||||
#include "rocksdb/table.h"
|
||||
|
@ -92,13 +92,14 @@ void TableReaderBenchmark(Options& opts, EnvOptions& env_options,
|
|||
const MutableCFOptions moptions(cfo);
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
if (!through_db) {
|
||||
ASSERT_OK(WritableFileWriter::Create(env->GetFileSystem(), file_name,
|
||||
FileOptions(env_options), &file_writer,
|
||||
nullptr));
|
||||
std::unique_ptr<WritableFile> file;
|
||||
env->NewWritableFile(file_name, &file, env_options);
|
||||
|
||||
std::vector<std::unique_ptr<IntTblPropCollectorFactory> >
|
||||
int_tbl_prop_collector_factories;
|
||||
|
||||
file_writer.reset(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(file)), file_name, env_options));
|
||||
int unknown_level = -1;
|
||||
tb = opts.table_factory->NewTableBuilder(
|
||||
TableBuilderOptions(
|
||||
|
@ -132,19 +133,17 @@ void TableReaderBenchmark(Options& opts, EnvOptions& env_options,
|
|||
|
||||
std::unique_ptr<TableReader> table_reader;
|
||||
if (!through_db) {
|
||||
const auto& fs = env->GetFileSystem();
|
||||
FileOptions fopts(env_options);
|
||||
|
||||
std::unique_ptr<FSRandomAccessFile> raf;
|
||||
s = fs->NewRandomAccessFile(file_name, fopts, &raf, nullptr);
|
||||
std::unique_ptr<RandomAccessFile> raf;
|
||||
s = env->NewRandomAccessFile(file_name, &raf, env_options);
|
||||
if (!s.ok()) {
|
||||
fprintf(stderr, "Create File Error: %s\n", s.ToString().c_str());
|
||||
exit(1);
|
||||
}
|
||||
uint64_t file_size;
|
||||
fs->GetFileSize(file_name, fopts.io_options, &file_size, nullptr);
|
||||
env->GetFileSize(file_name, &file_size);
|
||||
std::unique_ptr<RandomAccessFileReader> file_reader(
|
||||
new RandomAccessFileReader(std::move(raf), file_name));
|
||||
new RandomAccessFileReader(NewLegacyRandomAccessFileWrapper(raf),
|
||||
file_name));
|
||||
s = opts.table_factory->NewTableReader(
|
||||
TableReaderOptions(ioptions, moptions.prefix_extractor.get(),
|
||||
env_options, ikc),
|
||||
|
|
|
@ -22,6 +22,7 @@
|
|||
#include "db/dbformat.h"
|
||||
#include "db/log_reader.h"
|
||||
#include "db/write_batch_internal.h"
|
||||
#include "env/composite_env_wrapper.h"
|
||||
#include "file/filename.h"
|
||||
#include "rocksdb/cache.h"
|
||||
#include "rocksdb/file_checksum.h"
|
||||
|
@ -2289,11 +2290,19 @@ class InMemoryHandler : public WriteBatch::Handler {
|
|||
void DumpWalFile(Options options, std::string wal_file, bool print_header,
|
||||
bool print_values, bool is_write_committed,
|
||||
LDBCommandExecuteResult* exec_state) {
|
||||
const auto& fs = options.env->GetFileSystem();
|
||||
FileOptions soptions(options);
|
||||
Env* env = options.env;
|
||||
EnvOptions soptions(options);
|
||||
std::unique_ptr<SequentialFileReader> wal_file_reader;
|
||||
Status status = SequentialFileReader::Create(fs, wal_file, soptions,
|
||||
&wal_file_reader, nullptr);
|
||||
|
||||
Status status;
|
||||
{
|
||||
std::unique_ptr<SequentialFile> file;
|
||||
status = env->NewSequentialFile(wal_file, &file, soptions);
|
||||
if (status.ok()) {
|
||||
wal_file_reader.reset(new SequentialFileReader(
|
||||
NewLegacySequentialFileWrapper(file), wal_file));
|
||||
}
|
||||
}
|
||||
if (!status.ok()) {
|
||||
if (exec_state) {
|
||||
*exec_state = LDBCommandExecuteResult::Failed("Failed to open WAL file " +
|
||||
|
|
|
@ -94,20 +94,21 @@ class SSTDumpToolTest : public testing::Test {
|
|||
|
||||
void createSST(const Options& opts, const std::string& file_name) {
|
||||
Env* test_env = opts.env;
|
||||
FileOptions file_options(opts);
|
||||
EnvOptions env_options(opts);
|
||||
ReadOptions read_options;
|
||||
const ImmutableCFOptions imoptions(opts);
|
||||
const MutableCFOptions moptions(opts);
|
||||
ROCKSDB_NAMESPACE::InternalKeyComparator ikc(opts.comparator);
|
||||
std::unique_ptr<TableBuilder> tb;
|
||||
|
||||
std::unique_ptr<WritableFile> file;
|
||||
ASSERT_OK(test_env->NewWritableFile(file_name, &file, env_options));
|
||||
|
||||
std::vector<std::unique_ptr<IntTblPropCollectorFactory> >
|
||||
int_tbl_prop_collector_factories;
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
ASSERT_OK(WritableFileWriter::Create(test_env->GetFileSystem(), file_name,
|
||||
file_options, &file_writer, nullptr));
|
||||
|
||||
std::unique_ptr<WritableFileWriter> file_writer(
|
||||
new WritableFileWriter(NewLegacyWritableFileWrapper(std::move(file)),
|
||||
file_name, EnvOptions()));
|
||||
std::string column_family_name;
|
||||
int unknown_level = -1;
|
||||
tb.reset(opts.table_factory->NewTableBuilder(
|
||||
|
|
|
@ -124,12 +124,9 @@ class TraceAnalyzerTest : public testing::Test {
|
|||
|
||||
void CheckFileContent(const std::vector<std::string>& cnt,
|
||||
std::string file_path, bool full_content) {
|
||||
const auto& fs = env_->GetFileSystem();
|
||||
FileOptions fopts(env_options_);
|
||||
|
||||
ASSERT_OK(fs->FileExists(file_path, fopts.io_options, nullptr));
|
||||
std::unique_ptr<FSSequentialFile> file;
|
||||
ASSERT_OK(fs->NewSequentialFile(file_path, fopts, &file, nullptr));
|
||||
ASSERT_OK(env_->FileExists(file_path));
|
||||
std::unique_ptr<SequentialFile> f_ptr;
|
||||
ASSERT_OK(env_->NewSequentialFile(file_path, &f_ptr, env_options_));
|
||||
|
||||
std::string get_line;
|
||||
std::istringstream iss;
|
||||
|
@ -137,6 +134,8 @@ class TraceAnalyzerTest : public testing::Test {
|
|||
std::vector<std::string> result;
|
||||
uint32_t count;
|
||||
Status s;
|
||||
std::unique_ptr<FSSequentialFile> file =
|
||||
NewLegacySequentialFileWrapper(f_ptr);
|
||||
SequentialFileReader sf_reader(std::move(file), file_path,
|
||||
4096 /* filereadahead_size */);
|
||||
|
||||
|
|
|
@ -1073,17 +1073,18 @@ Status TraceAnalyzer::ReProcessing() {
|
|||
std::vector<std::string> prefix(kTaTypeNum);
|
||||
std::istringstream iss;
|
||||
bool has_data = true;
|
||||
std::unique_ptr<FSSequentialFile> file;
|
||||
std::unique_ptr<SequentialFile> wkey_input_f;
|
||||
|
||||
s = env_->GetFileSystem()->NewSequentialFile(
|
||||
whole_key_path, FileOptions(env_options_), &file, nullptr);
|
||||
s = env_->NewSequentialFile(whole_key_path, &wkey_input_f, env_options_);
|
||||
if (!s.ok()) {
|
||||
fprintf(stderr, "Cannot open the whole key space file of CF: %u\n",
|
||||
cf_id);
|
||||
file.reset();
|
||||
wkey_input_f.reset();
|
||||
}
|
||||
|
||||
if (file) {
|
||||
if (wkey_input_f) {
|
||||
std::unique_ptr<FSSequentialFile> file;
|
||||
file = NewLegacySequentialFileWrapper(wkey_input_f);
|
||||
size_t kTraceFileReadaheadSize = 2 * 1024 * 1024;
|
||||
SequentialFileReader sf_reader(
|
||||
std::move(file), whole_key_path,
|
||||
|
|
|
@ -5,12 +5,11 @@
|
|||
//
|
||||
#include <algorithm>
|
||||
#include <vector>
|
||||
|
||||
#include "env/composite_env_wrapper.h"
|
||||
#include "file/random_access_file_reader.h"
|
||||
#include "file/readahead_raf.h"
|
||||
#include "file/sequence_file_reader.h"
|
||||
#include "file/writable_file_writer.h"
|
||||
#include "rocksdb/file_system.h"
|
||||
#include "test_util/testharness.h"
|
||||
#include "test_util/testutil.h"
|
||||
#include "util/random.h"
|
||||
|
@ -22,64 +21,42 @@ class WritableFileWriterTest : public testing::Test {};
|
|||
const uint32_t kMb = 1 << 20;
|
||||
|
||||
TEST_F(WritableFileWriterTest, RangeSync) {
|
||||
class FakeWF : public FSWritableFile {
|
||||
class FakeWF : public WritableFile {
|
||||
public:
|
||||
explicit FakeWF() : size_(0), last_synced_(0) {}
|
||||
~FakeWF() override {}
|
||||
|
||||
using FSWritableFile::Append;
|
||||
IOStatus Append(const Slice& data, const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
Status Append(const Slice& data) override {
|
||||
size_ += data.size();
|
||||
return IOStatus::OK();
|
||||
return Status::OK();
|
||||
}
|
||||
IOStatus Truncate(uint64_t /*size*/, const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return IOStatus::OK();
|
||||
}
|
||||
IOStatus Close(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
Status Truncate(uint64_t /*size*/) override { return Status::OK(); }
|
||||
Status Close() override {
|
||||
EXPECT_GE(size_, last_synced_ + kMb);
|
||||
EXPECT_LT(size_, last_synced_ + 2 * kMb);
|
||||
// Make sure random writes generated enough writes.
|
||||
EXPECT_GT(size_, 10 * kMb);
|
||||
return IOStatus::OK();
|
||||
}
|
||||
IOStatus Flush(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return IOStatus::OK();
|
||||
}
|
||||
IOStatus Sync(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return IOStatus::OK();
|
||||
}
|
||||
IOStatus Fsync(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return IOStatus::OK();
|
||||
return Status::OK();
|
||||
}
|
||||
Status Flush() override { return Status::OK(); }
|
||||
Status Sync() override { return Status::OK(); }
|
||||
Status Fsync() override { return Status::OK(); }
|
||||
void SetIOPriority(Env::IOPriority /*pri*/) override {}
|
||||
uint64_t GetFileSize(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return size_;
|
||||
}
|
||||
uint64_t GetFileSize() override { return size_; }
|
||||
void GetPreallocationStatus(size_t* /*block_size*/,
|
||||
size_t* /*last_allocated_block*/) override {}
|
||||
size_t GetUniqueId(char* /*id*/, size_t /*max_size*/) const override {
|
||||
return 0;
|
||||
}
|
||||
IOStatus InvalidateCache(size_t /*offset*/, size_t /*length*/) override {
|
||||
return IOStatus::OK();
|
||||
Status InvalidateCache(size_t /*offset*/, size_t /*length*/) override {
|
||||
return Status::OK();
|
||||
}
|
||||
|
||||
protected:
|
||||
IOStatus Allocate(uint64_t /*offset*/, uint64_t /*len*/,
|
||||
const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return IOStatus::OK();
|
||||
Status Allocate(uint64_t /*offset*/, uint64_t /*len*/) override {
|
||||
return Status::OK();
|
||||
}
|
||||
IOStatus RangeSync(uint64_t offset, uint64_t nbytes,
|
||||
const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
Status RangeSync(uint64_t offset, uint64_t nbytes) override {
|
||||
EXPECT_EQ(offset % 4096, 0u);
|
||||
EXPECT_EQ(nbytes % 4096, 0u);
|
||||
|
||||
|
@ -89,7 +66,7 @@ TEST_F(WritableFileWriterTest, RangeSync) {
|
|||
if (size_ > 2 * kMb) {
|
||||
EXPECT_LT(size_, last_synced_ + 2 * kMb);
|
||||
}
|
||||
return IOStatus::OK();
|
||||
return Status::OK();
|
||||
}
|
||||
|
||||
uint64_t size_;
|
||||
|
@ -100,7 +77,8 @@ TEST_F(WritableFileWriterTest, RangeSync) {
|
|||
env_options.bytes_per_sync = kMb;
|
||||
std::unique_ptr<FakeWF> wf(new FakeWF);
|
||||
std::unique_ptr<WritableFileWriter> writer(
|
||||
new WritableFileWriter(std::move(wf), "" /* don't care */, env_options));
|
||||
new WritableFileWriter(NewLegacyWritableFileWrapper(std::move(wf)),
|
||||
"" /* don't care */, env_options));
|
||||
Random r(301);
|
||||
Status s;
|
||||
std::unique_ptr<char[]> large_buf(new char[10 * kMb]);
|
||||
|
@ -121,7 +99,7 @@ TEST_F(WritableFileWriterTest, RangeSync) {
|
|||
}
|
||||
|
||||
TEST_F(WritableFileWriterTest, IncrementalBuffer) {
|
||||
class FakeWF : public FSWritableFile {
|
||||
class FakeWF : public WritableFile {
|
||||
public:
|
||||
explicit FakeWF(std::string* _file_data, bool _use_direct_io,
|
||||
bool _no_flush)
|
||||
|
@ -130,58 +108,37 @@ TEST_F(WritableFileWriterTest, IncrementalBuffer) {
|
|||
no_flush_(_no_flush) {}
|
||||
~FakeWF() override {}
|
||||
|
||||
using FSWritableFile::Append;
|
||||
IOStatus Append(const Slice& data, const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
Status Append(const Slice& data) override {
|
||||
file_data_->append(data.data(), data.size());
|
||||
size_ += data.size();
|
||||
return IOStatus::OK();
|
||||
return Status::OK();
|
||||
}
|
||||
using FSWritableFile::PositionedAppend;
|
||||
IOStatus PositionedAppend(const Slice& data, uint64_t pos,
|
||||
const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
Status PositionedAppend(const Slice& data, uint64_t pos) override {
|
||||
EXPECT_TRUE(pos % 512 == 0);
|
||||
EXPECT_TRUE(data.size() % 512 == 0);
|
||||
file_data_->resize(pos);
|
||||
file_data_->append(data.data(), data.size());
|
||||
size_ += data.size();
|
||||
return IOStatus::OK();
|
||||
return Status::OK();
|
||||
}
|
||||
|
||||
IOStatus Truncate(uint64_t size, const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
Status Truncate(uint64_t size) override {
|
||||
file_data_->resize(size);
|
||||
return IOStatus::OK();
|
||||
}
|
||||
IOStatus Close(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return IOStatus::OK();
|
||||
}
|
||||
IOStatus Flush(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return IOStatus::OK();
|
||||
}
|
||||
IOStatus Sync(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return IOStatus::OK();
|
||||
}
|
||||
IOStatus Fsync(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return IOStatus::OK();
|
||||
return Status::OK();
|
||||
}
|
||||
Status Close() override { return Status::OK(); }
|
||||
Status Flush() override { return Status::OK(); }
|
||||
Status Sync() override { return Status::OK(); }
|
||||
Status Fsync() override { return Status::OK(); }
|
||||
void SetIOPriority(Env::IOPriority /*pri*/) override {}
|
||||
uint64_t GetFileSize(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return size_;
|
||||
}
|
||||
uint64_t GetFileSize() override { return size_; }
|
||||
void GetPreallocationStatus(size_t* /*block_size*/,
|
||||
size_t* /*last_allocated_block*/) override {}
|
||||
size_t GetUniqueId(char* /*id*/, size_t /*max_size*/) const override {
|
||||
return 0;
|
||||
}
|
||||
IOStatus InvalidateCache(size_t /*offset*/, size_t /*length*/) override {
|
||||
return IOStatus::OK();
|
||||
Status InvalidateCache(size_t /*offset*/, size_t /*length*/) override {
|
||||
return Status::OK();
|
||||
}
|
||||
bool use_direct_io() const override { return use_direct_io_; }
|
||||
|
||||
|
@ -206,8 +163,9 @@ TEST_F(WritableFileWriterTest, IncrementalBuffer) {
|
|||
false,
|
||||
#endif
|
||||
no_flush));
|
||||
std::unique_ptr<WritableFileWriter> writer(new WritableFileWriter(
|
||||
std::move(wf), "" /* don't care */, env_options));
|
||||
std::unique_ptr<WritableFileWriter> writer(
|
||||
new WritableFileWriter(NewLegacyWritableFileWrapper(std::move(wf)),
|
||||
"" /* don't care */, env_options));
|
||||
|
||||
std::string target;
|
||||
for (int i = 0; i < 20; i++) {
|
||||
|
@ -230,41 +188,26 @@ TEST_F(WritableFileWriterTest, IncrementalBuffer) {
|
|||
|
||||
#ifndef ROCKSDB_LITE
|
||||
TEST_F(WritableFileWriterTest, AppendStatusReturn) {
|
||||
class FakeWF : public FSWritableFile {
|
||||
class FakeWF : public WritableFile {
|
||||
public:
|
||||
explicit FakeWF() : use_direct_io_(false), io_error_(false) {}
|
||||
|
||||
bool use_direct_io() const override { return use_direct_io_; }
|
||||
|
||||
using FSWritableFile::Append;
|
||||
IOStatus Append(const Slice& /*data*/, const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
Status Append(const Slice& /*data*/) override {
|
||||
if (io_error_) {
|
||||
return IOStatus::IOError("Fake IO error");
|
||||
return Status::IOError("Fake IO error");
|
||||
}
|
||||
return IOStatus::OK();
|
||||
return Status::OK();
|
||||
}
|
||||
using FSWritableFile::PositionedAppend;
|
||||
IOStatus PositionedAppend(const Slice& /*data*/, uint64_t,
|
||||
const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
Status PositionedAppend(const Slice& /*data*/, uint64_t) override {
|
||||
if (io_error_) {
|
||||
return IOStatus::IOError("Fake IO error");
|
||||
return Status::IOError("Fake IO error");
|
||||
}
|
||||
return IOStatus::OK();
|
||||
}
|
||||
IOStatus Close(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return IOStatus::OK();
|
||||
}
|
||||
IOStatus Flush(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return IOStatus::OK();
|
||||
}
|
||||
IOStatus Sync(const IOOptions& /*options*/,
|
||||
IODebugContext* /*dbg*/) override {
|
||||
return IOStatus::OK();
|
||||
return Status::OK();
|
||||
}
|
||||
Status Close() override { return Status::OK(); }
|
||||
Status Flush() override { return Status::OK(); }
|
||||
Status Sync() override { return Status::OK(); }
|
||||
void Setuse_direct_io(bool val) { use_direct_io_ = val; }
|
||||
void SetIOError(bool val) { io_error_ = val; }
|
||||
|
||||
|
@ -275,13 +218,15 @@ TEST_F(WritableFileWriterTest, AppendStatusReturn) {
|
|||
std::unique_ptr<FakeWF> wf(new FakeWF());
|
||||
wf->Setuse_direct_io(true);
|
||||
std::unique_ptr<WritableFileWriter> writer(
|
||||
new WritableFileWriter(std::move(wf), "" /* don't care */, EnvOptions()));
|
||||
new WritableFileWriter(NewLegacyWritableFileWrapper(std::move(wf)),
|
||||
"" /* don't care */, EnvOptions()));
|
||||
|
||||
ASSERT_OK(writer->Append(std::string(2 * kMb, 'a')));
|
||||
|
||||
// Next call to WritableFile::Append() should fail
|
||||
FakeWF* fwf = static_cast<FakeWF*>(writer->writable_file());
|
||||
fwf->SetIOError(true);
|
||||
LegacyWritableFileWrapper* file =
|
||||
static_cast<LegacyWritableFileWrapper*>(writer->writable_file());
|
||||
static_cast<FakeWF*>(file->target())->SetIOError(true);
|
||||
ASSERT_NOK(writer->Append(std::string(2 * kMb, 'b')));
|
||||
}
|
||||
#endif
|
||||
|
|
|
@ -1505,10 +1505,10 @@ Status BackupEngineImpl::CopyOrCreateFile(
|
|||
uint64_t size_limit, std::function<void()> progress_callback) {
|
||||
assert(src.empty() != contents.empty());
|
||||
Status s;
|
||||
std::unique_ptr<FSWritableFile> dst_file;
|
||||
std::unique_ptr<FSSequentialFile> src_file;
|
||||
FileOptions dst_file_options;
|
||||
dst_file_options.use_mmap_writes = false;
|
||||
std::unique_ptr<WritableFile> dst_file;
|
||||
std::unique_ptr<SequentialFile> src_file;
|
||||
EnvOptions dst_env_options;
|
||||
dst_env_options.use_mmap_writes = false;
|
||||
// TODO:(gzh) maybe use direct reads/writes here if possible
|
||||
if (size != nullptr) {
|
||||
*size = 0;
|
||||
|
@ -1520,22 +1520,21 @@ Status BackupEngineImpl::CopyOrCreateFile(
|
|||
size_limit = std::numeric_limits<uint64_t>::max();
|
||||
}
|
||||
|
||||
s = dst_env->GetFileSystem()->NewWritableFile(dst, dst_file_options,
|
||||
&dst_file, nullptr);
|
||||
s = dst_env->NewWritableFile(dst, &dst_file, dst_env_options);
|
||||
if (s.ok() && !src.empty()) {
|
||||
s = src_env->GetFileSystem()->NewSequentialFile(
|
||||
src, FileOptions(src_env_options), &src_file, nullptr);
|
||||
s = src_env->NewSequentialFile(src, &src_file, src_env_options);
|
||||
}
|
||||
if (!s.ok()) {
|
||||
return s;
|
||||
}
|
||||
|
||||
std::unique_ptr<WritableFileWriter> dest_writer(
|
||||
new WritableFileWriter(std::move(dst_file), dst, dst_file_options));
|
||||
std::unique_ptr<WritableFileWriter> dest_writer(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(dst_file)), dst, dst_env_options));
|
||||
std::unique_ptr<SequentialFileReader> src_reader;
|
||||
std::unique_ptr<char[]> buf;
|
||||
if (!src.empty()) {
|
||||
src_reader.reset(new SequentialFileReader(std::move(src_file), src));
|
||||
src_reader.reset(new SequentialFileReader(
|
||||
NewLegacySequentialFileWrapper(src_file), src));
|
||||
buf.reset(new char[copy_file_buffer_size_]);
|
||||
}
|
||||
|
||||
|
@ -1826,14 +1825,14 @@ Status BackupEngineImpl::ReadFileAndComputeChecksum(
|
|||
size_limit = std::numeric_limits<uint64_t>::max();
|
||||
}
|
||||
|
||||
std::unique_ptr<SequentialFileReader> src_reader;
|
||||
Status s = SequentialFileReader::Create(src_env->GetFileSystem(), src,
|
||||
FileOptions(src_env_options),
|
||||
&src_reader, nullptr);
|
||||
std::unique_ptr<SequentialFile> src_file;
|
||||
Status s = src_env->NewSequentialFile(src, &src_file, src_env_options);
|
||||
if (!s.ok()) {
|
||||
return s;
|
||||
}
|
||||
|
||||
std::unique_ptr<SequentialFileReader> src_reader(
|
||||
new SequentialFileReader(NewLegacySequentialFileWrapper(src_file), src));
|
||||
std::unique_ptr<char[]> buf(new char[copy_file_buffer_size_]);
|
||||
Slice data;
|
||||
|
||||
|
@ -2143,12 +2142,15 @@ Status BackupEngineImpl::BackupMeta::LoadFromFile(
|
|||
const std::unordered_map<std::string, uint64_t>& abs_path_to_size) {
|
||||
assert(Empty());
|
||||
Status s;
|
||||
std::unique_ptr<SequentialFileReader> backup_meta_reader;
|
||||
s = SequentialFileReader::Create(env_->GetFileSystem(), meta_filename_,
|
||||
FileOptions(), &backup_meta_reader, nullptr);
|
||||
std::unique_ptr<SequentialFile> backup_meta_file;
|
||||
s = env_->NewSequentialFile(meta_filename_, &backup_meta_file, EnvOptions());
|
||||
if (!s.ok()) {
|
||||
return s;
|
||||
}
|
||||
|
||||
std::unique_ptr<SequentialFileReader> backup_meta_reader(
|
||||
new SequentialFileReader(NewLegacySequentialFileWrapper(backup_meta_file),
|
||||
meta_filename_));
|
||||
std::unique_ptr<char[]> buf(new char[max_backup_meta_file_size_ + 1]);
|
||||
Slice data;
|
||||
s = backup_meta_reader->Read(max_backup_meta_file_size_, &data, buf.get());
|
||||
|
|
|
@ -15,6 +15,7 @@
|
|||
#include "db/blob/blob_index.h"
|
||||
#include "db/db_impl/db_impl.h"
|
||||
#include "db/write_batch_internal.h"
|
||||
#include "env/composite_env_wrapper.h"
|
||||
#include "file/file_util.h"
|
||||
#include "file/filename.h"
|
||||
#include "file/random_access_file_reader.h"
|
||||
|
@ -80,7 +81,7 @@ BlobDBImpl::BlobDBImpl(const std::string& dbname,
|
|||
bdb_options_(blob_db_options),
|
||||
db_options_(db_options),
|
||||
cf_options_(cf_options),
|
||||
file_options_(db_options),
|
||||
env_options_(db_options),
|
||||
statistics_(db_options_.statistics.get()),
|
||||
next_file_number_(1),
|
||||
flush_sequence_(0),
|
||||
|
@ -95,7 +96,7 @@ BlobDBImpl::BlobDBImpl(const std::string& dbname,
|
|||
blob_dir_ = (bdb_options_.path_relative)
|
||||
? dbname + "/" + bdb_options_.blob_dir
|
||||
: bdb_options_.blob_dir;
|
||||
file_options_.bytes_per_sync = blob_db_options.bytes_per_sync;
|
||||
env_options_.bytes_per_sync = blob_db_options.bytes_per_sync;
|
||||
}
|
||||
|
||||
BlobDBImpl::~BlobDBImpl() {
|
||||
|
@ -345,8 +346,7 @@ Status BlobDBImpl::OpenAllBlobFiles() {
|
|||
blob_file->MarkImmutable(/* sequence */ 0);
|
||||
|
||||
// Read file header and footer
|
||||
Status read_metadata_status =
|
||||
blob_file->ReadMetadata(env_->GetFileSystem(), file_options_);
|
||||
Status read_metadata_status = blob_file->ReadMetadata(env_, env_options_);
|
||||
if (read_metadata_status.IsCorruption()) {
|
||||
// Remove incomplete file.
|
||||
if (!obsolete_files_.empty()) {
|
||||
|
@ -679,7 +679,7 @@ Status BlobDBImpl::GetBlobFileReader(
|
|||
std::shared_ptr<RandomAccessFileReader>* reader) {
|
||||
assert(reader != nullptr);
|
||||
bool fresh_open = false;
|
||||
Status s = blob_file->GetReader(env_, file_options_, reader, &fresh_open);
|
||||
Status s = blob_file->GetReader(env_, env_options_, reader, &fresh_open);
|
||||
if (s.ok() && fresh_open) {
|
||||
assert(*reader != nullptr);
|
||||
open_file_count_++;
|
||||
|
@ -720,23 +720,21 @@ void BlobDBImpl::RegisterBlobFile(std::shared_ptr<BlobFile> blob_file) {
|
|||
|
||||
Status BlobDBImpl::CreateWriterLocked(const std::shared_ptr<BlobFile>& bfile) {
|
||||
std::string fpath(bfile->PathName());
|
||||
std::unique_ptr<FSWritableFile> wfile;
|
||||
const auto& fs = env_->GetFileSystem();
|
||||
std::unique_ptr<WritableFile> wfile;
|
||||
|
||||
Status s = fs->ReopenWritableFile(fpath, file_options_, &wfile, nullptr);
|
||||
Status s = env_->ReopenWritableFile(fpath, &wfile, env_options_);
|
||||
if (!s.ok()) {
|
||||
ROCKS_LOG_ERROR(db_options_.info_log,
|
||||
"Failed to open blob file for write: %s status: '%s'"
|
||||
" exists: '%s'",
|
||||
fpath.c_str(), s.ToString().c_str(),
|
||||
fs->FileExists(fpath, file_options_.io_options, nullptr)
|
||||
.ToString()
|
||||
.c_str());
|
||||
env_->FileExists(fpath).ToString().c_str());
|
||||
return s;
|
||||
}
|
||||
|
||||
std::unique_ptr<WritableFileWriter> fwriter;
|
||||
fwriter.reset(new WritableFileWriter(std::move(wfile), fpath, file_options_));
|
||||
fwriter.reset(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(wfile)), fpath, env_options_));
|
||||
|
||||
uint64_t boffset = bfile->GetFileSize();
|
||||
if (debug_level_ >= 2 && boffset) {
|
||||
|
|
|
@ -24,7 +24,6 @@
|
|||
#include "db/db_iter.h"
|
||||
#include "rocksdb/compaction_filter.h"
|
||||
#include "rocksdb/db.h"
|
||||
#include "rocksdb/file_system.h"
|
||||
#include "rocksdb/listener.h"
|
||||
#include "rocksdb/options.h"
|
||||
#include "rocksdb/statistics.h"
|
||||
|
@ -408,7 +407,7 @@ class BlobDBImpl : public BlobDB {
|
|||
BlobDBOptions bdb_options_;
|
||||
DBOptions db_options_;
|
||||
ColumnFamilyOptions cf_options_;
|
||||
FileOptions file_options_;
|
||||
EnvOptions env_options_;
|
||||
|
||||
// Raw pointer of statistic. db_options_ has a std::shared_ptr to hold
|
||||
// ownership.
|
||||
|
|
|
@ -15,6 +15,7 @@
|
|||
#include "db/column_family.h"
|
||||
#include "db/db_impl/db_impl.h"
|
||||
#include "db/dbformat.h"
|
||||
#include "env/composite_env_wrapper.h"
|
||||
#include "file/filename.h"
|
||||
#include "file/readahead_raf.h"
|
||||
#include "logging/logging.h"
|
||||
|
@ -150,7 +151,7 @@ void BlobFile::CloseRandomAccessLocked() {
|
|||
last_access_ = -1;
|
||||
}
|
||||
|
||||
Status BlobFile::GetReader(Env* env, const FileOptions& file_options,
|
||||
Status BlobFile::GetReader(Env* env, const EnvOptions& env_options,
|
||||
std::shared_ptr<RandomAccessFileReader>* reader,
|
||||
bool* fresh_open) {
|
||||
assert(reader != nullptr);
|
||||
|
@ -177,9 +178,8 @@ Status BlobFile::GetReader(Env* env, const FileOptions& file_options,
|
|||
return s;
|
||||
}
|
||||
|
||||
std::unique_ptr<FSRandomAccessFile> rfile;
|
||||
s = env->GetFileSystem()->NewRandomAccessFile(PathName(), file_options,
|
||||
&rfile, nullptr);
|
||||
std::unique_ptr<RandomAccessFile> rfile;
|
||||
s = env->NewRandomAccessFile(PathName(), &rfile, env_options);
|
||||
if (!s.ok()) {
|
||||
ROCKS_LOG_ERROR(info_log_,
|
||||
"Failed to open blob file for random-read: %s status: '%s'"
|
||||
|
@ -189,20 +189,18 @@ Status BlobFile::GetReader(Env* env, const FileOptions& file_options,
|
|||
return s;
|
||||
}
|
||||
|
||||
ra_file_reader_ =
|
||||
std::make_shared<RandomAccessFileReader>(std::move(rfile), PathName());
|
||||
ra_file_reader_ = std::make_shared<RandomAccessFileReader>(
|
||||
NewLegacyRandomAccessFileWrapper(rfile), PathName());
|
||||
*reader = ra_file_reader_;
|
||||
*fresh_open = true;
|
||||
return s;
|
||||
}
|
||||
|
||||
Status BlobFile::ReadMetadata(const std::shared_ptr<FileSystem>& fs,
|
||||
const FileOptions& file_options) {
|
||||
Status BlobFile::ReadMetadata(Env* env, const EnvOptions& env_options) {
|
||||
assert(Immutable());
|
||||
// Get file size.
|
||||
uint64_t file_size = 0;
|
||||
Status s =
|
||||
fs->GetFileSize(PathName(), file_options.io_options, &file_size, nullptr);
|
||||
Status s = env->GetFileSize(PathName(), &file_size);
|
||||
if (s.ok()) {
|
||||
file_size_ = file_size;
|
||||
} else {
|
||||
|
@ -221,15 +219,17 @@ Status BlobFile::ReadMetadata(const std::shared_ptr<FileSystem>& fs,
|
|||
}
|
||||
|
||||
// Create file reader.
|
||||
std::unique_ptr<RandomAccessFileReader> file_reader;
|
||||
s = RandomAccessFileReader::Create(fs, PathName(), file_options, &file_reader,
|
||||
nullptr);
|
||||
std::unique_ptr<RandomAccessFile> file;
|
||||
s = env->NewRandomAccessFile(PathName(), &file, env_options);
|
||||
if (!s.ok()) {
|
||||
ROCKS_LOG_ERROR(info_log_,
|
||||
"Failed to open blob file %" PRIu64 ", status: %s",
|
||||
file_number_, s.ToString().c_str());
|
||||
return s;
|
||||
}
|
||||
std::unique_ptr<RandomAccessFileReader> file_reader(
|
||||
new RandomAccessFileReader(NewLegacyRandomAccessFileWrapper(file),
|
||||
PathName()));
|
||||
|
||||
// Read file header.
|
||||
std::string header_buf;
|
||||
|
|
|
@ -15,7 +15,6 @@
|
|||
#include "file/random_access_file_reader.h"
|
||||
#include "port/port.h"
|
||||
#include "rocksdb/env.h"
|
||||
#include "rocksdb/file_system.h"
|
||||
#include "rocksdb/options.h"
|
||||
|
||||
namespace ROCKSDB_NAMESPACE {
|
||||
|
@ -209,10 +208,9 @@ class BlobFile {
|
|||
// Read blob file header and footer. Return corruption if file header is
|
||||
// malform or incomplete. If footer is malform or incomplete, set
|
||||
// footer_valid_ to false and return Status::OK.
|
||||
Status ReadMetadata(const std::shared_ptr<FileSystem>& fs,
|
||||
const FileOptions& file_options);
|
||||
Status ReadMetadata(Env* env, const EnvOptions& env_options);
|
||||
|
||||
Status GetReader(Env* env, const FileOptions& file_options,
|
||||
Status GetReader(Env* env, const EnvOptions& env_options,
|
||||
std::shared_ptr<RandomAccessFileReader>* reader,
|
||||
bool* fresh_open);
|
||||
|
||||
|
|
|
@ -33,15 +33,15 @@ Status NewWritableCacheFile(Env* const env, const std::string& filepath,
|
|||
return s;
|
||||
}
|
||||
|
||||
Status NewRandomAccessCacheFile(const std::shared_ptr<FileSystem>& fs,
|
||||
const std::string& filepath,
|
||||
std::unique_ptr<FSRandomAccessFile>* file,
|
||||
Status NewRandomAccessCacheFile(Env* const env, const std::string& filepath,
|
||||
std::unique_ptr<RandomAccessFile>* file,
|
||||
const bool use_direct_reads = true) {
|
||||
assert(fs.get());
|
||||
assert(env);
|
||||
|
||||
FileOptions opt;
|
||||
EnvOptions opt;
|
||||
opt.use_direct_reads = use_direct_reads;
|
||||
return fs->NewRandomAccessFile(filepath, opt, file, nullptr);
|
||||
Status s = env->NewRandomAccessFile(filepath, file, opt);
|
||||
return s;
|
||||
}
|
||||
|
||||
//
|
||||
|
@ -210,18 +210,17 @@ bool RandomAccessCacheFile::OpenImpl(const bool enable_direct_reads) {
|
|||
rwlock_.AssertHeld();
|
||||
|
||||
ROCKS_LOG_DEBUG(log_, "Opening cache file %s", Path().c_str());
|
||||
assert(env_);
|
||||
|
||||
std::unique_ptr<FSRandomAccessFile> file;
|
||||
Status status = NewRandomAccessCacheFile(env_->GetFileSystem(), Path(), &file,
|
||||
enable_direct_reads);
|
||||
std::unique_ptr<RandomAccessFile> file;
|
||||
Status status =
|
||||
NewRandomAccessCacheFile(env_, Path(), &file, enable_direct_reads);
|
||||
if (!status.ok()) {
|
||||
Error(log_, "Error opening random access file %s. %s", Path().c_str(),
|
||||
status.ToString().c_str());
|
||||
return false;
|
||||
}
|
||||
freader_.reset(new RandomAccessFileReader(std::move(file), Path(),
|
||||
env_->GetSystemClock()));
|
||||
freader_.reset(new RandomAccessFileReader(
|
||||
NewLegacyRandomAccessFileWrapper(file), Path(), env_->GetSystemClock()));
|
||||
|
||||
return true;
|
||||
}
|
||||
|
|
|
@ -4,14 +4,12 @@
|
|||
// (found in the LICENSE.Apache file in the root directory).
|
||||
|
||||
#include "rocksdb/utilities/sim_cache.h"
|
||||
|
||||
#include <atomic>
|
||||
|
||||
#include "env/composite_env_wrapper.h"
|
||||
#include "file/writable_file_writer.h"
|
||||
#include "monitoring/statistics.h"
|
||||
#include "port/port.h"
|
||||
#include "rocksdb/env.h"
|
||||
#include "rocksdb/file_system.h"
|
||||
#include "util/mutexlock.h"
|
||||
#include "util/string_util.h"
|
||||
|
||||
|
@ -37,7 +35,8 @@ class CacheActivityLogger {
|
|||
assert(env != nullptr);
|
||||
|
||||
Status status;
|
||||
FileOptions file_opts;
|
||||
EnvOptions env_opts;
|
||||
std::unique_ptr<WritableFile> log_file;
|
||||
|
||||
MutexLock l(&mutex_);
|
||||
|
||||
|
@ -45,11 +44,13 @@ class CacheActivityLogger {
|
|||
StopLoggingInternal();
|
||||
|
||||
// Open log file
|
||||
status = WritableFileWriter::Create(env->GetFileSystem(), activity_log_file,
|
||||
file_opts, &file_writer_, nullptr);
|
||||
status = env->NewWritableFile(activity_log_file, &log_file, env_opts);
|
||||
if (!status.ok()) {
|
||||
return status;
|
||||
}
|
||||
file_writer_.reset(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(log_file)), activity_log_file,
|
||||
env_opts));
|
||||
|
||||
max_logging_size_ = max_logging_size;
|
||||
activity_logging_enabled_.store(true);
|
||||
|
|
|
@ -92,13 +92,15 @@ uint64_t FileTraceWriter::GetFileSize() { return file_writer_->GetFileSize(); }
|
|||
Status NewFileTraceReader(Env* env, const EnvOptions& env_options,
|
||||
const std::string& trace_filename,
|
||||
std::unique_ptr<TraceReader>* trace_reader) {
|
||||
std::unique_ptr<RandomAccessFileReader> file_reader;
|
||||
Status s = RandomAccessFileReader::Create(
|
||||
env->GetFileSystem(), trace_filename, FileOptions(env_options),
|
||||
&file_reader, nullptr);
|
||||
std::unique_ptr<RandomAccessFile> trace_file;
|
||||
Status s = env->NewRandomAccessFile(trace_filename, &trace_file, env_options);
|
||||
if (!s.ok()) {
|
||||
return s;
|
||||
}
|
||||
|
||||
std::unique_ptr<RandomAccessFileReader> file_reader;
|
||||
file_reader.reset(new RandomAccessFileReader(
|
||||
NewLegacyRandomAccessFileWrapper(trace_file), trace_filename));
|
||||
trace_reader->reset(new FileTraceReader(std::move(file_reader)));
|
||||
return s;
|
||||
}
|
||||
|
@ -106,13 +108,16 @@ Status NewFileTraceReader(Env* env, const EnvOptions& env_options,
|
|||
Status NewFileTraceWriter(Env* env, const EnvOptions& env_options,
|
||||
const std::string& trace_filename,
|
||||
std::unique_ptr<TraceWriter>* trace_writer) {
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
Status s = WritableFileWriter::Create(env->GetFileSystem(), trace_filename,
|
||||
FileOptions(env_options), &file_writer,
|
||||
nullptr);
|
||||
std::unique_ptr<WritableFile> trace_file;
|
||||
Status s = env->NewWritableFile(trace_filename, &trace_file, env_options);
|
||||
if (!s.ok()) {
|
||||
return s;
|
||||
}
|
||||
|
||||
std::unique_ptr<WritableFileWriter> file_writer;
|
||||
file_writer.reset(new WritableFileWriter(
|
||||
NewLegacyWritableFileWrapper(std::move(trace_file)), trace_filename,
|
||||
env_options));
|
||||
trace_writer->reset(new FileTraceWriter(std::move(file_writer)));
|
||||
return s;
|
||||
}
|
||||
|
|
Loading…
Reference in a new issue