Home
last modified time | relevance | path

Searched refs:path_id (Results 1 – 17 of 17) sorted by relevance

/rocksdb-6.9/db/
Dversion_edit.cc87 uint64_t PackFileNumberAndPathId(uint64_t number, uint64_t path_id) { in PackFileNumberAndPathId() argument
89 return number | (path_id * (kFileNumberMask + 1)); in PackFileNumberAndPathId()
340 uint32_t path_id = 0; in DecodeNewFile4From() local
367 path_id = field[0]; in DecodeNewFile4From()
368 if (path_id > 3) { in DecodeNewFile4From()
419 FileDescriptor(number, path_id, file_size, smallest_seqno, largest_seqno); in DecodeNewFile4From()
567 uint32_t path_id = 0; in DecodeFrom() local
572 GetVarint32(&input, &path_id) && GetVarint64(&input, &file_size) && in DecodeFrom()
577 f.fd = FileDescriptor(number, path_id, file_size, smallest_seqno, in DecodeFrom()
Drepair.cc263 for (size_t path_id = 0; path_id < db_options_.db_paths.size(); path_id++) { in FindFiles() local
264 to_search_paths.push_back(db_options_.db_paths[path_id].path); in FindFiles()
281 for (size_t path_id = 0; path_id < to_search_paths.size(); path_id++) { in FindFiles() local
282 status = env_->GetChildren(to_search_paths[path_id], &filenames); in FindFiles()
303 table_fds_.emplace_back(number, static_cast<uint32_t>(path_id), in FindFiles()
Dversion_edit.h35 extern uint64_t PackFileNumberAndPathId(uint64_t number, uint64_t path_id);
52 FileDescriptor(uint64_t number, uint32_t path_id, uint64_t _file_size) in FileDescriptor()
53 : FileDescriptor(number, path_id, _file_size, kMaxSequenceNumber, 0) {} in FileDescriptor()
55 FileDescriptor(uint64_t number, uint32_t path_id, uint64_t _file_size, in FileDescriptor()
58 packed_number_and_path_id(PackFileNumberAndPathId(number, path_id)), in FileDescriptor()
Dexternal_sst_file_ingestion_job.cc150 for (auto path_id : ingestion_path_ids) { in Prepare() local
151 status = directories_->GetDataDir(path_id)->Fsync(IOOptions(), nullptr); in Prepare()
156 path_id, status.ToString().c_str()); in Prepare()
Dcolumn_family.cc1387 FSDirectory* ColumnFamilyData::GetDataDir(size_t path_id) const { in GetDataDir()
1392 assert(path_id < data_dirs_.size()); in GetDataDir()
1393 return data_dirs_[path_id].get(); in GetDataDir()
Dversion_builder_test.cc58 const char* largest, uint64_t file_size = 0, uint32_t path_id = 0, in Add() argument
66 file_number, path_id, file_size, GetInternalKey(smallest, smallest_seq), in Add()
Ddb_universal_compaction_test.cc1403 auto check_sstfilecount = [&](int path_id, int expected) { in TEST_P() argument
1404 ASSERT_EQ(expected, GetSstFileCount(options.db_paths[path_id].path)); in TEST_P()
1405 ASSERT_EQ(expected, GetSstFileCount(cf_opt1.cf_paths[path_id].path)); in TEST_P()
1406 ASSERT_EQ(expected, GetSstFileCount(cf_opt2.cf_paths[path_id].path)); in TEST_P()
Dversion_set.cc752 uint32_t path_id = f->fd.GetPathId(); in ~Version() local
753 assert(path_id < cfd_->ioptions()->cf_paths.size()); in ~Version()
755 ObsoleteFileInfo(f, cfd_->ioptions()->cf_paths[path_id].path)); in ~Version()
1430 uint32_t path_id = file->fd.GetPathId(); in GetColumnFamilyMetaData() local
1432 if (path_id < ioptions->cf_paths.size()) { in GetColumnFamilyMetaData()
1433 file_path = ioptions->cf_paths[path_id].path; in GetColumnFamilyMetaData()
5660 uint32_t path_id = file->fd.GetPathId(); in GetLiveFilesMetaData() local
5661 if (path_id < cfd->ioptions()->cf_paths.size()) { in GetLiveFilesMetaData()
5662 filemetadata.db_path = cfd->ioptions()->cf_paths[path_id].path; in GetLiveFilesMetaData()
Dcolumn_family.h505 FSDirectory* GetDataDir(size_t path_id) const;
Ddb_compaction_test.cc2238 auto check_sstfilecount = [&](int path_id, int expected) { in TEST_P() argument
2239 ASSERT_EQ(expected, GetSstFileCount(options.db_paths[path_id].path)); in TEST_P()
2240 ASSERT_EQ(expected, GetSstFileCount(cf_opt1.cf_paths[path_id].path)); in TEST_P()
2241 ASSERT_EQ(expected, GetSstFileCount(cf_opt2.cf_paths[path_id].path)); in TEST_P()
/rocksdb-6.9/db/db_impl/
Ddb_impl_files.cc112 for (size_t path_id = 0; path_id < immutable_db_options_.db_paths.size(); in FindObsoleteFiles() local
113 path_id++) { in FindObsoleteFiles()
114 paths.insert(immutable_db_options_.db_paths[path_id].path); in FindObsoleteFiles()
123 for (size_t path_id = 0; path_id < cfd->ioptions()->cf_paths.size(); in FindObsoleteFiles() local
124 path_id++) { in FindObsoleteFiles()
125 auto& path = cfd->ioptions()->cf_paths[path_id].path; in FindObsoleteFiles()
Ddb_impl.h89 FSDirectory* GetDataDir(size_t path_id) const { in GetDataDir() argument
90 assert(path_id < data_dirs_.size()); in GetDataDir()
91 FSDirectory* ret_dir = data_dirs_[path_id].get(); in GetDataDir()
1637 FSDirectory* GetDataDir(ColumnFamilyData* cfd, size_t path_id) const;
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()
901 return directories_.GetDataDir(path_id); in GetDataDir()
/rocksdb-6.9/file/
Dfilename.cc131 uint32_t path_id) { in TableFileName() argument
134 if (path_id >= db_paths.size()) { in TableFileName()
137 path = db_paths[path_id].path; in TableFileName()
142 void FormatFileNumber(uint64_t number, uint32_t path_id, char* out_buf, in FormatFileNumber() argument
144 if (path_id == 0) { in FormatFileNumber()
150 number, path_id); in FormatFileNumber()
Dfilename.h89 uint64_t number, uint32_t path_id);
94 extern void FormatFileNumber(uint64_t number, uint32_t path_id, char* out_buf,
/rocksdb-6.9/db/compaction/
Dcompaction_picker_universal.cc700 uint32_t path_id = in PickCompactionToReduceSortedRuns() local
751 LLONG_MAX, path_id, in PickCompactionToReduceSortedRuns()
952 uint32_t path_id = in PickDeleteTriggeredCompaction() local
959 /* max_grandparent_overlap_bytes */ LLONG_MAX, path_id, in PickDeleteTriggeredCompaction()
977 uint32_t path_id = in PickCompactionToOldest() local
1029 LLONG_MAX, path_id, in PickCompactionToOldest()
Dcompaction_picker_test.cc89 const char* largest, uint64_t file_size = 1, uint32_t path_id = 0, in Add() argument
94 file_number, path_id, file_size, in Add()