Home
last modified time | relevance | path

Searched refs:FSDirectory (Results 1 – 23 of 23) sorted by relevance

/rocksdb-6.9/db/
Dflush_job.h70 LogBuffer* log_buffer, FSDirectory* db_directory,
71 FSDirectory* output_file_directory,
124 FSDirectory* db_directory_;
125 FSDirectory* output_file_directory_;
Dmemtable_list.h143 autovector<MemTable*>* to_delete, FSDirectory* db_directory,
267 autovector<MemTable*>* to_delete, FSDirectory* db_directory,
383 autovector<MemTable*>* to_delete, FSDirectory* db_directory,
425 autovector<MemTable*>* to_delete, FSDirectory* db_directory,
Dcolumn_family.h503 std::map<std::string, std::shared_ptr<FSDirectory>>* created_dirs);
505 FSDirectory* GetDataDir(size_t path_id) const;
598 std::vector<std::shared_ptr<FSDirectory>> data_dirs_;
Dversion_set.h834 InstrumentedMutex* mu, FSDirectory* db_directory = nullptr,
854 FSDirectory* db_directory = nullptr, bool new_descriptor_log = false,
873 InstrumentedMutex* mu, FSDirectory* db_directory = nullptr,
1208 InstrumentedMutex* mu, FSDirectory* db_directory,
1275 InstrumentedMutex* /*mu*/, FSDirectory* /*db_directory*/, in LogAndApply() argument
Dflush_job.cc95 LogBuffer* log_buffer, FSDirectory* db_directory, in FlushJob()
96 FSDirectory* output_file_directory, in FlushJob()
Dmemtable_list.cc391 autovector<MemTable*>* to_delete, FSDirectory* db_directory, in TryInstallMemtableFlushResults()
648 autovector<MemTable*>* to_delete, FSDirectory* db_directory, in InstallMemtableAtomicFlushResults()
Dcolumn_family.cc1363 std::map<std::string, std::shared_ptr<FSDirectory>>* created_dirs) { in AddDirectories()
1371 std::unique_ptr<FSDirectory> path_directory; in AddDirectories()
1387 FSDirectory* ColumnFamilyData::GetDataDir(size_t path_id) const { in GetDataDir()
Dversion_set.cc3637 FSDirectory* db_directory, bool new_descriptor_log, in ProcessManifestWrites()
4072 InstrumentedMutex* mu, FSDirectory* db_directory, bool new_descriptor_log, in LogAndApply()
/rocksdb-6.9/db/compaction/
Dcompaction_job.h70 LogBuffer* log_buffer, FSDirectory* db_directory,
71 FSDirectory* output_directory, Statistics* stats,
167 FSDirectory* db_directory_;
168 FSDirectory* output_directory_;
Dcompaction_job.cc301 FSDirectory* db_directory, FSDirectory* output_directory, Statistics* stats, in CompactionJob()
/rocksdb-6.9/test_util/
Dfault_injection_test_fs.h122 class TestFSDirectory : public FSDirectory {
125 FSDirectory* dir) in TestFSDirectory()
135 std::unique_ptr<FSDirectory> dir_;
147 std::unique_ptr<FSDirectory>* result,
Dfault_injection_test_fs.cc200 std::unique_ptr<FSDirectory>* result, IODebugContext* dbg) { in NewDirectory()
201 std::unique_ptr<FSDirectory> r; in NewDirectory()
/rocksdb-6.9/include/rocksdb/
Dfile_system.h36 class FSDirectory; variable
303 std::unique_ptr<FSDirectory>* result,
964 class FSDirectory {
966 virtual ~FSDirectory() {} in ~FSDirectory()
1063 std::unique_ptr<FSDirectory>* result, in NewDirectory()
1381 class FSDirectoryWrapper : public FSDirectory {
1383 explicit FSDirectoryWrapper(FSDirectory* target) : target_(target) {} in FSDirectoryWrapper()
1393 FSDirectory* target_;
/rocksdb-6.9/db/db_impl/
Ddb_impl.h89 FSDirectory* GetDataDir(size_t path_id) const { in GetDataDir()
91 FSDirectory* ret_dir = data_dirs_[path_id].get(); in GetDataDir()
99 FSDirectory* GetWalDir() { in GetWalDir()
106 FSDirectory* GetDbDir() { return db_dir_.get(); } in GetDbDir()
109 std::unique_ptr<FSDirectory> db_dir_;
110 std::vector<std::unique_ptr<FSDirectory>> data_dirs_;
111 std::unique_ptr<FSDirectory> wal_dir_;
851 std::unique_ptr<FSDirectory>* directory);
1637 FSDirectory* GetDataDir(ColumnFamilyData* cfd, size_t path_id) const;
Ddb_impl_open.cc304 std::unique_ptr<FSDirectory>* directory) { in CreateAndNewDirectory()
339 std::unique_ptr<FSDirectory> path_directory; in SetDirectories()
470 std::map<std::string, std::shared_ptr<FSDirectory>> created_dirs; in Recover()
Ddb_impl.cc897 FSDirectory* DBImpl::GetDataDir(ColumnFamilyData* cfd, size_t path_id) const { in GetDataDir()
899 FSDirectory* ret_dir = cfd->GetDataDir(path_id); in GetDataDir()
2362 std::map<std::string, std::shared_ptr<FSDirectory>> dummy_created_dirs; in CreateColumnFamilyImpl()
Ddb_impl_compaction_flush.cc311 autovector<FSDirectory*> distinct_output_dirs; in AtomicFlushMemTablesToOutputFiles()
319 FSDirectory* data_dir = GetDataDir(cfd, 0U); in AtomicFlushMemTablesToOutputFiles()
/rocksdb-6.9/env/
Dcomposite_env_wrapper.h258 explicit CompositeDirectoryWrapper(std::unique_ptr<FSDirectory>& target) in CompositeDirectoryWrapper()
271 std::unique_ptr<FSDirectory> target_;
380 std::unique_ptr<FSDirectory> dir; in NewDirectory()
838 class LegacyDirectoryWrapper : public FSDirectory {
940 std::unique_ptr<FSDirectory>* result, in NewDirectory()
Dio_posix.h376 class PosixDirectory : public FSDirectory {
Dfs_posix.cc531 std::unique_ptr<FSDirectory>* result, in NewDirectory()
/rocksdb-6.9/file/
Dfilename.h174 FSDirectory* directory_to_fsync);
Ddelete_scheduler.cc321 std::unique_ptr<FSDirectory> dir_obj; in DeleteTrashFile()
Dfilename.cc373 FSDirectory* directory_to_fsync) { in SetCurrentFile()