Home
last modified time | relevance | path

Searched refs:fs (Results 1 – 25 of 55) sorted by relevance

123

/rocksdb-6.9/file/
Dfile_util.cc20 Status CopyFile(FileSystem* fs, const std::string& source, in CopyFile() argument
29 s = fs->NewSequentialFile(source, soptions, &srcfile, nullptr); in CopyFile()
34 s = fs->NewWritableFile(destination, soptions, &destfile, nullptr); in CopyFile()
41 s = fs->GetFileSize(source, IOOptions(), &size, nullptr); in CopyFile()
72 Status CreateFile(FileSystem* fs, const std::string& destination, in CreateFile() argument
79 s = fs->NewWritableFile(destination, soptions, &destfile, nullptr); in CreateFile()
Dsst_file_manager_impl.cc22 SstFileManagerImpl::SstFileManagerImpl(Env* env, std::shared_ptr<FileSystem> fs, in SstFileManagerImpl() argument
28 fs_(fs), in SstFileManagerImpl()
486 std::shared_ptr<FileSystem> fs; in NewSstFileManager() local
489 fs = FileSystem::Default(); in NewSstFileManager()
491 fs.reset(new LegacyFileSystemWrapper(env)); in NewSstFileManager()
494 return NewSstFileManager(env, fs, info_log, trash_dir, rate_bytes_per_sec, in NewSstFileManager()
499 SstFileManager* NewSstFileManager(Env* env, std::shared_ptr<FileSystem> fs, in NewSstFileManager() argument
507 new SstFileManagerImpl(env, fs, info_log, rate_bytes_per_sec, in NewSstFileManager()
515 s = fs->GetChildren(trash_dir, IOOptions(), &files_in_trash, nullptr); in NewSstFileManager()
Dfile_util.h19 extern Status CopyFile(FileSystem* fs, const std::string& source,
23 extern Status CreateFile(FileSystem* fs, const std::string& destination,
Dread_write_util.cc17 IOStatus NewWritableFile(FileSystem* fs, const std::string& fname, in NewWritableFile() argument
20 IOStatus s = fs->NewWritableFile(fname, options, result, nullptr); in NewWritableFile()
Dfilename.cc371 IOStatus SetCurrentFile(FileSystem* fs, const std::string& dbname, in SetCurrentFile() argument
380 IOStatus s = WriteStringToFile(fs, contents.ToString() + "\n", tmp, true); in SetCurrentFile()
383 s = fs->RenameFile(tmp, CurrentFileName(dbname), IOOptions(), nullptr); in SetCurrentFile()
391 fs->DeleteFile(tmp, IOOptions(), nullptr); in SetCurrentFile()
Dread_write_util.h23 extern IOStatus NewWritableFile(FileSystem* fs, const std::string& fname,
Ddelete_scheduler.cc22 DeleteScheduler::DeleteScheduler(Env* env, FileSystem* fs, in DeleteScheduler() argument
28 fs_(fs), in DeleteScheduler()
/rocksdb-6.9/env/
Dfile_system.cc86 IOStatus WriteStringToFile(FileSystem* fs, const Slice& data, in WriteStringToFile() argument
90 IOStatus s = fs->NewWritableFile(fname, soptions, &file, nullptr); in WriteStringToFile()
99 fs->DeleteFile(fname, IOOptions(), nullptr); in WriteStringToFile()
104 IOStatus ReadFileToString(FileSystem* fs, const std::string& fname, in ReadFileToString() argument
110 fs->NewSequentialFile(fname, soptions, &file, nullptr)); in ReadFileToString()
Denv_posix.cc135 PosixEnv(const PosixEnv* default_env, std::shared_ptr<FileSystem> fs);
423 PosixEnv::PosixEnv(const PosixEnv* default_env, std::shared_ptr<FileSystem> fs) in PosixEnv() argument
424 : CompositeEnvWrapper(this, fs), in PosixEnv()
526 std::unique_ptr<Env> NewCompositeEnv(std::shared_ptr<FileSystem> fs) { in NewCompositeEnv() argument
528 return std::unique_ptr<Env>(new PosixEnv(default_env, fs)); in NewCompositeEnv()
Denv.cc29 Env::Env(std::shared_ptr<FileSystem> fs) in Env() argument
31 file_system_(fs) {} in Env()
476 std::unique_ptr<Env> NewCompositeEnv(std::shared_ptr<FileSystem> fs) { in NewCompositeEnv() argument
477 return std::unique_ptr<Env>(new CompositeEnvWrapper(Env::Default(), fs)); in NewCompositeEnv()
/rocksdb-6.9/db/
Dtransaction_log_impl.cc45 FileSystem* fs = options_->fs.get(); in OpenLogFile() local
49 EnvOptions optimized_env_options = fs->OptimizeForLogRead(soptions_); in OpenLogFile()
52 s = fs->NewSequentialFile(fname, optimized_env_options, &file, nullptr); in OpenLogFile()
55 s = fs->NewSequentialFile(fname, optimized_env_options, &file, nullptr); in OpenLogFile()
60 s = fs->NewSequentialFile(fname, optimized_env_options, in OpenLogFile()
Drepair_test.cc78 LegacyFileSystemWrapper fs(env_); in TEST_F() local
79 CreateFile(&fs, manifest_path, "blah", false /* use_fsync */); in TEST_F()
159 LegacyFileSystemWrapper fs(env_); in TEST_F() local
160 CreateFile(&fs, sst_path, "blah", false /* use_fsync */); in TEST_F()
Dconvenience.cc49 Status s = ioptions.fs->NewRandomAccessFile(file_path, in VerifySstFileChecksum()
53 s = ioptions.fs->GetFileSize(file_path, IOOptions(), &file_size, nullptr); in VerifySstFileChecksum()
Dbuilder.cc69 const std::string& dbname, Env* env, FileSystem* fs, in BuildTable() argument
125 s = NewWritableFile(fs, fname, &file, file_options); in BuildTable()
260 fs->DeleteFile(fname, IOOptions(), nullptr); in BuildTable()
Derror_handler_fs_test.cc132 void InjectFileCreationError(FaultInjectionTestFS* fs, int file_count, in InjectFileCreationError() argument
134 fault_fs_ = fs; in InjectFileCreationError()
974 std::shared_ptr<FileSystem> fs(fault_fs.back()); in TEST_F() local
975 fault_envs.emplace_back(new CompositeEnvWrapper(def_env, fs)); in TEST_F()
1075 std::shared_ptr<FileSystem> fs(fault_fs.back()); in TEST_F() local
1076 fault_envs.emplace_back(new CompositeEnvWrapper(def_env, fs)); in TEST_F()
Dimport_column_family_job.h32 fs_(db_options_.fs.get()), in ImportColumnFamilyJob()
/rocksdb-6.9/utilities/options/
Doptions_util.cc22 LegacyFileSystemWrapper fs(env); in LoadOptionsFromFile() local
23 Status s = parser.Parse(file_name, &fs, ignore_unknown_options, in LoadOptionsFromFile()
106 LegacyFileSystemWrapper fs(env); in CheckOptionsCompatibility() local
109 db_options, cf_names, cf_opts, dbpath + "/" + options_file_name, &fs, in CheckOptionsCompatibility()
/rocksdb-6.9/test_util/
Dfault_injection_test_fs.h65 FaultInjectionTestFS* fs);
101 FaultInjectionTestFS* fs);
124 explicit TestFSDirectory(FaultInjectionTestFS* fs, std::string dirname, in TestFSDirectory() argument
126 : fs_(fs), dirname_(dirname), dir_(dir) {} in TestFSDirectory()
Dfault_injection_test_fs.cc72 FaultInjectionTestFS* fs) in TestFSWritableFile() argument
76 fs_(fs) { in TestFSWritableFile()
144 FaultInjectionTestFS* fs) in TestFSRandomRWFile() argument
145 : target_(std::move(f)), file_opened_(true), fs_(fs) { in TestFSRandomRWFile()
/rocksdb-6.9/options/
Doptions_parser.h38 const std::string& file_name, FileSystem* fs);
53 Status Parse(const std::string& file_name, FileSystem* fs,
77 const std::string& file_name, FileSystem* fs,
Doptions_parser.cc40 const std::string& file_name, FileSystem* fs) { in PersistRocksDBOptions() argument
49 fs->NewWritableFile(file_name, FileOptions(), &wf, nullptr); in PersistRocksDBOptions()
107 db_opt, cf_names, cf_opts, file_name, fs); in PersistRocksDBOptions()
205 Status RocksDBOptionsParser::Parse(const std::string& file_name, FileSystem* fs, in Parse() argument
211 Status s = fs->NewSequentialFile(file_name, FileOptions(), &seq_file, in Parse()
661 const std::string& file_name, FileSystem* fs, in VerifyRocksDBOptionsFromFile() argument
673 parser.Parse(file_name, fs, ignore_unknown_options, file_readahead_size); in VerifyRocksDBOptionsFromFile()
Dcf_options.cc46 fs(db_options.fs.get()), in ImmutableCFOptions()
Ddb_options.cc29 fs(options.env->GetFileSystem()), in ImmutableDBOptions()
112 fs->Name()); in Dump()
/rocksdb-6.9/utilities/blob_db/
Dblob_file.h241 void SetFileSize(uint64_t fs) { file_size_ = fs; } in SetFileSize() argument
/rocksdb-6.9/db/db_impl/
Ddb_impl_open.cc303 FileSystem* fs, const std::string& dirname, in CreateAndNewDirectory() argument
312 IOStatus io_s = fs->CreateDirIfMissing(dirname, IOOptions(), nullptr); in CreateAndNewDirectory()
316 return fs->NewDirectory(dirname, IOOptions(), directory, nullptr); in CreateAndNewDirectory()
319 IOStatus Directories::SetDirectories(FileSystem* fs, const std::string& dbname, in SetDirectories() argument
322 IOStatus io_s = DBImpl::CreateAndNewDirectory(fs, dbname, &db_dir_); in SetDirectories()
327 io_s = DBImpl::CreateAndNewDirectory(fs, wal_dir, &wal_dir_); in SetDirectories()
340 io_s = DBImpl::CreateAndNewDirectory(fs, db_path, &path_directory); in SetDirectories()

123