| /rocksdb-6.9/test_util/ |
| D | fault_injection_test_fs.cc | 64 return fs_->GetError(); in Fsync()
66 fs_->SyncDir(dirname_); in Fsync()
76 fs_(fs) { in TestFSWritableFile()
91 return fs_->GetError(); in Append()
102 return fs_->GetError(); in Close()
120 return fs_->GetError(); in Flush()
132 return fs_->GetError(); in Sync()
159 return fs_->GetError(); in Write()
168 return fs_->GetError(); in Read()
176 return fs_->GetError(); in Close()
[all …]
|
| D | fault_injection_test_fs.h | 91 FaultInjectionTestFS* fs_; variable
119 FaultInjectionTestFS* fs_; variable
126 : fs_(fs), dirname_(dirname), dir_(dir) {} in TestFSDirectory()
133 FaultInjectionTestFS* fs_;
|
| /rocksdb-6.9/file/ |
| D | delete_scheduler.cc | 28 fs_(fs), in DeleteScheduler()
65 s = fs_->DeleteFile(file_path, IOOptions(), nullptr); in DeleteFile()
79 s = fs_->DeleteFile(file_path, IOOptions(), nullptr); in DeleteFile()
88 fs_->GetFileSize(trash_file, IOOptions(), &trash_file_size, nullptr); in DeleteFile()
170 s = fs_->FileExists(*trash_file, IOOptions(), nullptr); in MarkAsTrash()
173 s = fs_->RenameFile(file_path, *trash_file, IOOptions(), nullptr); in MarkAsTrash()
267 Status s = fs_->GetFileSize(path_in_trash, IOOptions(), &file_size, nullptr); in DeleteTrashFile()
278 Status my_status = fs_->NumFileLinks(path_in_trash, IOOptions(), in DeleteTrashFile()
283 my_status = fs_->ReopenWritableFile(path_in_trash, FileOptions(), in DeleteTrashFile()
319 s = fs_->DeleteFile(path_in_trash, IOOptions(), nullptr); in DeleteTrashFile()
[all …]
|
| D | random_access_file_reader_test.cc | 33 fs_ = FileSystem::Default(); in SetUp()
35 ASSERT_OK(fs_->CreateDir(test_dir_, IOOptions(), nullptr)); in SetUp()
48 auto s = fs_->NewRandomAccessFile(Path(".direct"), opt, &f, nullptr); in IsDirectIOSupported()
54 ASSERT_OK(fs_->NewWritableFile(Path(fname), FileOptions(), &f, nullptr)); in Write()
63 ASSERT_OK(fs_->NewRandomAccessFile(fpath, opts, &f, nullptr)); in Read()
80 std::shared_ptr<FileSystem> fs_; member in ROCKSDB_NAMESPACE::RandomAccessFileReaderTest
94 EXPECT_OK(fs_->DeleteFile(Path(f), IOOptions(), nullptr)); in GetAlignment()
|
| D | sst_file_manager_impl.cc | 28 fs_(fs), in SstFileManagerImpl()
35 delete_scheduler_(env, fs_.get(), rate_bytes_per_sec, logger.get(), this, in SstFileManagerImpl()
65 Status s = fs_->GetFileSize(file_path, IOOptions(), &file_size, nullptr); in OnAddFile()
191 fs_->GetFreeSpace(fn, IOOptions(), &free_space, nullptr); in EnoughRoomForCompaction()
274 Status s = fs_->GetFreeSpace(path_, IOOptions(), &free_space, nullptr); in ClearError()
|
| D | delete_scheduler.h | 98 FileSystem* fs_; variable
|
| D | sst_file_manager_impl.h | 151 std::shared_ptr<FileSystem> fs_; variable
|
| /rocksdb-6.9/db/ |
| D | import_column_family_job.cc | 96 fs_->LinkFile(path_outside_db, path_inside_db, IOOptions(), nullptr); in Prepare()
103 status = CopyFile(fs_, path_outside_db, path_inside_db, 0, in Prepare()
120 fs_->DeleteFile(f.internal_file_path, IOOptions(), nullptr); in Prepare()
175 fs_->DeleteFile(f.internal_file_path, IOOptions(), nullptr); in Cleanup()
186 fs_->DeleteFile(f.external_file_path, IOOptions(), nullptr); in Cleanup()
204 Status status = fs_->GetFileSize(external_file, IOOptions(), in GetIngestedFileInfo()
215 status = fs_->NewRandomAccessFile(external_file, env_options_, in GetIngestedFileInfo()
|
| D | version_set_test.cc | 619 fs_(), in VersionSetTestBase()
645 fs_ = std::make_shared<LegacyFileSystemWrapper>(env_); in VersionSetTestBase()
649 db_options_.fs = fs_; in VersionSetTestBase()
747 Status s = SetCurrentFile(fs_.get(), dbname_, 1, nullptr); in NewDB()
767 std::shared_ptr<FileSystem> fs_; member in ROCKSDB_NAMESPACE::VersionSetTestBase
850 ASSERT_OK(SetCurrentFile(fs_.get(), dbname_, 1, nullptr)); in SetupValidAtomicGroup()
862 ASSERT_OK(SetCurrentFile(fs_.get(), dbname_, 1, nullptr)); in SetupIncompleteTrailingAtomicGroup()
1244 Status s = SetCurrentFile(fs_.get(), dbname_, 1, nullptr); in TEST_P()
1906 Status s = SetCurrentFile(fs_.get(), dbname_, 1, nullptr); in TEST_F()
1957 Status s = SetCurrentFile(fs_.get(), dbname_, 1, nullptr); in TEST_F()
[all …]
|
| D | external_sst_file_ingestion_job.cc | 105 fs_->LinkFile(path_outside_db, path_inside_db, IOOptions(), nullptr); in Prepare()
111 status = fs_->ReopenWritableFile(path_inside_db, env_options_, in Prepare()
137 status = CopyFile(fs_, path_outside_db, path_inside_db, 0, in Prepare()
364 Status status = fs_->GetFileSize(external_file, IOOptions(), in GetIngestedFileInfo()
375 status = fs_->NewRandomAccessFile(external_file, env_options_, in GetIngestedFileInfo()
659 fs_->NewRandomRWFile(file_to_ingest->internal_file_path, env_options_, in AssignGlobalSeqnoForIngestedFile()
|
| D | import_column_family_job.h | 32 fs_(db_options_.fs.get()), in ImportColumnFamilyJob()
64 FileSystem* fs_; variable
|
| D | wal_manager.h | 43 fs_(db_options.fs.get()), in db_options_()
94 FileSystem* fs_; variable
|
| D | external_sst_file_ingestion_job.h | 77 fs_(db_options.fs.get()), in ExternalSstFileIngestionJob()
162 FileSystem* fs_; variable
|
| D | wal_manager_test.cc | 50 fs_.reset(new LegacyFileSystemWrapper(env_.get())); in Init()
51 db_options_.fs = fs_; in Init()
116 std::shared_ptr<LegacyFileSystemWrapper> fs_; member in ROCKSDB_NAMESPACE::WalManagerTest
|
| D | flush_job_test.cc | 33 fs_(std::make_shared<LegacyFileSystemWrapper>(env_)), in FlushJobTest()
55 db_options_.fs = fs_;
111 s = SetCurrentFile(fs_.get(), dbname_, 1, nullptr); in NewDB()
115 std::shared_ptr<FileSystem> fs_; member in ROCKSDB_NAMESPACE::FlushJobTest
|
| D | version_set.cc | 3549 fs_(_db_options->fs.get()), in VersionSet()
3865 s = NewWritableFile(fs_, descriptor_fname, &descriptor_file, in ProcessManifestWrites()
4449 Status s = GetCurrentManifestPath(dbname_, fs_, &manifest_path, in Recover()
4461 s = fs_->NewSequentialFile(manifest_path, in Recover()
4637 FileSystem* const fs_; member in ROCKSDB_NAMESPACE::__anonc84eced60e11::ManifestPicker
4645 : dbname_(dbname), fs_(fs) {} in ManifestPicker()
4648 assert(fs_ != nullptr); in SeekToFirstManifest()
4716 ManifestPicker manifest_picker(dbname_, fs_); in TryRecover()
4750 s = fs_->NewSequentialFile(manifest_path, in TryRecoverFromOneManifest()
6174 s = GetCurrentManifestPath(dbname_, fs_, &manifest_path, in MaybeSwitchManifest()
[all …]
|
| D | wal_manager.cc | 468 Status status = fs_->NewSequentialFile(fname, in ReadFirstLine()
469 fs_->OptimizeForLogRead(file_options_), in ReadFirstLine()
|
| D | version_set.h | 699 FileSystem* fs_; variable
1153 FileSystem* const fs_; variable
|
| /rocksdb-6.9/options/ |
| D | options_test.cc | 1117 fs_.reset(new LegacyFileSystemWrapper(env_.get())); in OptionsParserTest()
1122 std::unique_ptr<LegacyFileSystemWrapper> fs_; member in ROCKSDB_NAMESPACE::OptionsParserTest
1383 ASSERT_NOK(parser.Parse(kTestFileName, fs_.get(), false, in TEST_F()
1386 ASSERT_OK(parser.Parse(kTestFileName, fs_.get(), in TEST_F()
1390 ASSERT_NOK(parser.Parse(kTestFileName, fs_.get(), in TEST_F()
1542 kOptionsFileName, fs_.get())); in TEST_F()
1611 kOptionsFileName, fs_.get())); in TEST_F()
1627 base_db_opt, cf_names, base_cf_opts, kOptionsFileName, fs_.get())); in TEST_F()
1650 base_db_opt, cf_names, base_cf_opts, kOptionsFileName, fs_.get())); in TEST_F()
1671 kOptionsFileName, fs_.get())); in TEST_F()
[all …]
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_open.cc | 276 s = NewWritableFile(fs_.get(), manifest, &file, file_options); in NewDB()
295 s = SetCurrentFile(fs_.get(), dbname_, 1, directories_.GetDbDir()); in NewDB()
297 fs_->DeleteFile(manifest, IOOptions(), nullptr); in NewDB()
360 Status s = directories_.SetDirectories(fs_.get(), dbname_, in Recover()
401 s = fs_->NewRandomAccessFile(current_fname, customized_fs, &idfile, in Recover()
438 s = fs_->FileExists(IdentityFileName(dbname_), IOOptions(), nullptr); in Recover()
788 status = fs_->NewSequentialFile(fname, in RecoverLogFiles()
1166 Status truncate_status = fs_->ReopenWritableFile( in RestoreAliveLogFiles()
1168 fs_->OptimizeForLogWrite( in RestoreAliveLogFiles()
1334 fs_->OptimizeForLogWrite(file_options_, db_options); in CreateWAL()
[all …]
|
| D | db_impl_secondary.cc | 148 Status status = fs_->NewSequentialFile( in MaybeInitLogReader()
149 fname, fs_->OptimizeForLogRead(file_options_), &file, in MaybeInitLogReader()
|
| /rocksdb-6.9/utilities/options/ |
| D | options_util_test.cc | 34 fs_.reset(new LegacyFileSystemWrapper(env_.get())); in OptionsUtilTest()
40 std::unique_ptr<LegacyFileSystemWrapper> fs_; member in ROCKSDB_NAMESPACE::OptionsUtilTest
64 PersistRocksDBOptions(db_opt, cf_names, cf_opts, kFileName, fs_.get()); in TEST_F()
125 PersistRocksDBOptions(db_opt, cf_names, cf_opts, kFileName, fs_.get()); in TEST_F()
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_job_test.cc | 75 fs_(std::make_shared<LegacyFileSystemWrapper>(env_)), in CompactionJobTest()
91 db_options_.fs = fs_; in CompactionJobTest()
284 s = SetCurrentFile(fs_.get(), dbname_, 1, nullptr); in NewDB()
367 std::shared_ptr<FileSystem> fs_; member in ROCKSDB_NAMESPACE::CompactionJobTest
|
| D | compaction_job.h | 159 FileSystem* fs_; variable
|
| /rocksdb-6.9/env/ |
| D | env_test.cc | 1995 fs_ = fs_default in TEST_P()
1999 env_ptr_ = NewCompositeEnv(fs_); in TEST_P()
2003 fs_.reset(); in TEST_P()
2007 composite_env_ptr_.reset(new CompositeEnvWrapper(env_ptr_.get(), fs_)); in TEST_P()
2022 std::shared_ptr<FileSystem> fs_; in TEST_P() member in ROCKSDB_NAMESPACE::EnvFSTestWithParam
2034 if (fs_) { in TEST_P()
2035 ASSERT_EQ(fs_.get(), env_->GetFileSystem().get()); in TEST_P()
|