Home
last modified time | relevance | path

Searched refs:cf_paths (Results 1 – 25 of 28) sorted by relevance

12

/rocksdb-6.9/db/
Ddb_logical_block_size_cache_test.cc131 cf_options.cf_paths = {{cf_path_0_, 1024}, {cf_path_1_, 2048}}; in TEST_F()
177 cf_options.cf_paths = {{cf_path_0_, 1024}}; in TEST_F()
234 cf_options.cf_paths = {{cf_path_0_, 1024}}; in TEST_F()
321 cf_options.cf_paths = {{cf_path_0_, 1024}}; in TEST_F()
402 cf_options0.cf_paths = {{cf_path_0_, 1024}}; in TEST_F()
422 cf_options1.cf_paths = {{cf_path_1_, 1024}}; in TEST_F()
458 cf_options.cf_paths = {{cf_path_0_, 1024}}; in TEST_F()
Dcolumn_family.cc174 if (cf_options.cf_paths.size() > 1) { in CheckCFPathsSupported()
178 } else if (cf_options.cf_paths.empty() && in CheckCFPathsSupported()
324 for (size_t i = 0; i < result.cf_paths.size(); i++) { in SanitizeOptions()
325 DeleteScheduler::CleanupDirectory(db_options.env, sfm, result.cf_paths[i].path); in SanitizeOptions()
329 if (result.cf_paths.empty()) { in SanitizeOptions()
330 result.cf_paths = db_options.db_paths; in SanitizeOptions()
335 result.cf_paths.size() > 1U) { in SanitizeOptions()
476 paths.reserve(ioptions_.cf_paths.size()); in GetDbPaths()
477 for (const DbPath& db_path : ioptions_.cf_paths) { in GetDbPaths()
1367 for (auto& p : ioptions_.cf_paths) { in AddDirectories()
[all …]
Ddb_universal_compaction_test.cc1375 cf_opt1.cf_paths.emplace_back(dbname_ + "cf1", 300 * 1024); in TEST_P()
1376 cf_opt1.cf_paths.emplace_back(dbname_ + "cf1_2", 300 * 1024); in TEST_P()
1377 cf_opt1.cf_paths.emplace_back(dbname_ + "cf1_3", 500 * 1024); in TEST_P()
1378 cf_opt1.cf_paths.emplace_back(dbname_ + "cf1_4", 1024 * 1024 * 1024); in TEST_P()
1383 cf_opt2.cf_paths.emplace_back(dbname_ + "cf2", 300 * 1024); in TEST_P()
1384 cf_opt2.cf_paths.emplace_back(dbname_ + "cf2_2", 300 * 1024); in TEST_P()
1385 cf_opt2.cf_paths.emplace_back(dbname_ + "cf2_3", 500 * 1024); in TEST_P()
1386 cf_opt2.cf_paths.emplace_back(dbname_ + "cf2_4", 1024 * 1024 * 1024); 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.cc753 assert(path_id < cfd_->ioptions()->cf_paths.size()); in ~Version()
755 ObsoleteFileInfo(f, cfd_->ioptions()->cf_paths[path_id].path)); in ~Version()
1232 TableFileName(ioptions->cf_paths, file_meta->fd.GetNumber(), in GetTableProperties()
1360 TableFileName(cfd_->ioptions()->cf_paths, in GetPropertiesOfTablesInRange()
1432 if (path_id < ioptions->cf_paths.size()) { in GetColumnFamilyMetaData()
1433 file_path = ioptions->cf_paths[path_id].path; in GetColumnFamilyMetaData()
1435 assert(!ioptions->cf_paths.empty()); in GetColumnFamilyMetaData()
1436 file_path = ioptions->cf_paths.back().path; in GetColumnFamilyMetaData()
5661 if (path_id < cfd->ioptions()->cf_paths.size()) { in GetLiveFilesMetaData()
5664 assert(!cfd->ioptions()->cf_paths.empty()); in GetLiveFilesMetaData()
[all …]
Dimport_column_family_job.cc92 cfd_->ioptions()->cf_paths, f.fd.GetNumber(), f.fd.GetPathId()); in Prepare()
Dbuilder.cc103 std::string fname = TableFileName(ioptions.cf_paths, meta->fd.GetNumber(), in BuildTable()
Dcolumn_family_test.cc3308 cf_opt1.cf_paths.emplace_back(dbname_ + "_one_1", in TEST_P()
3317 ASSERT_EQ(1, GetSstFileCount(cf_opt1.cf_paths[0].path)); in TEST_P()
3333 cf_opt1.cf_paths.emplace_back(dbname_ + "_one_1", in TEST_P()
3335 cf_opt2.cf_paths.emplace_back(dbname_ + "_two_1", in TEST_P()
3344 ASSERT_EQ(1, GetSstFileCount(cf_opt1.cf_paths[0].path)); in TEST_P()
3350 ASSERT_EQ(1, GetSstFileCount(cf_opt2.cf_paths[0].path)); in TEST_P()
Ddb_compaction_test.cc2212 cf_opt1.cf_paths.emplace_back(dbname_ + "cf1", 500 * 1024); in TEST_P()
2213 cf_opt1.cf_paths.emplace_back(dbname_ + "cf1_2", 4 * 1024 * 1024); in TEST_P()
2214 cf_opt1.cf_paths.emplace_back(dbname_ + "cf1_3", 1024 * 1024 * 1024); in TEST_P()
2219 cf_opt2.cf_paths.emplace_back(dbname_ + "cf2", 500 * 1024); in TEST_P()
2220 cf_opt2.cf_paths.emplace_back(dbname_ + "cf2_2", 4 * 1024 * 1024); in TEST_P()
2221 cf_opt2.cf_paths.emplace_back(dbname_ + "cf2_3", 1024 * 1024 * 1024); 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()
Dflush_job.cc457 MakeTableFileName(cfd_->ioptions()->cf_paths[0].path, file_number); in GetFlushJobInfo()
Dmemtable_list_test.cc49 cf_opt1.cf_paths.emplace_back(dbname + "_one_1", in CreateDB()
51 cf_opt2.cf_paths.emplace_back(dbname + "_two_1", in CreateDB()
Dversion_edit_handler.cc541 MakeTableFileName(cfd->ioptions()->cf_paths[0].path, file_num); in MaybeCreateVersion()
Dexternal_sst_file_ingestion_job.cc101 TableFileName(cfd_->ioptions()->cf_paths, f.fd.GetNumber(), in Prepare()
Dtable_cache.cc94 TableFileName(ioptions_.cf_paths, fd.GetNumber(), fd.GetPathId()); in GetTableReader()
/rocksdb-6.9/db/compaction/
Dcompaction_picker_level.cc412 assert(!ioptions.cf_paths.empty()); in GetPathId()
415 uint64_t current_path_size = ioptions.cf_paths[0].target_size; in GetPathId()
425 while (p < ioptions.cf_paths.size() - 1) { in GetPathId()
452 current_path_size = ioptions.cf_paths[p].target_size; in GetPathId()
Dcompaction_picker_universal.cc547 assert(!ioptions.cf_paths.empty()); in GetPathId()
548 for (; p < ioptions.cf_paths.size() - 1; p++) { in GetPathId()
549 uint64_t target_size = ioptions.cf_paths[p].target_size; in GetPathId()
Dcompaction_job.cc694 TableFileName(state.compaction->immutable_cf_options()->cf_paths, in Run()
1348 TableFileName(sub_compact->compaction->immutable_cf_options()->cf_paths, in FinishCompactionOutputFile()
1375 TableFileName(sub_compact->compaction->immutable_cf_options()->cf_paths, in FinishCompactionOutputFile()
1468 TableFileName(sub_compact->compaction->immutable_cf_options()->cf_paths, in OpenCompactionOutputFile()
/rocksdb-6.9/options/
Dcf_options.cc79 cf_paths(cf_options.cf_paths), in ImmutableCFOptions()
Dcf_options.h125 std::vector<DbPath> cf_paths; member
Doptions_settable_test.cc363 {offset_of(&ColumnFamilyOptions::cf_paths), sizeof(std::vector<DbPath>)}, in TEST_F()
/rocksdb-6.9/db/db_impl/
Ddb_impl_files.cc123 for (size_t path_id = 0; path_id < cfd->ioptions()->cf_paths.size(); in FindObsoleteFiles()
125 auto& path = cfd->ioptions()->cf_paths[path_id].path; in FindObsoleteFiles()
676 for (const auto& cf_path : cfd->ioptions()->cf_paths) { in CleanupFilesAfterRecovery()
Ddb_impl_compaction_flush.cc229 cfd->ioptions()->cf_paths[0].path, file_meta.fd.GetNumber()); in FlushMemTableToOutputFile()
320 const std::string& curr_path = cfd->ioptions()->cf_paths[0].path; in AtomicFlushMemTablesToOutputFiles()
559 cfds[i]->ioptions()->cf_paths[0].path, file_meta[i].fd.GetNumber()); in AtomicFlushMemTablesToOutputFiles()
614 MakeTableFileName(cfd->ioptions()->cf_paths[0].path, file_number); in NotifyOnFlushBegin()
684 if (options.target_path_id >= cfd->ioptions()->cf_paths.size()) { in CompactRange()
957 if (cfd->ioptions()->cf_paths.size() == 1U) { in CompactFilesImpl()
1097 .push_back(TableFileName(c->immutable_cf_options()->cf_paths, in CompactFilesImpl()
1181 auto fn = TableFileName(c->immutable_cf_options()->cf_paths, in NotifyOnCompactionBegin()
1200 c->immutable_cf_options()->cf_paths, file_number, desc.GetPathId())); in NotifyOnCompactionBegin()
3060 auto fn = TableFileName(c->immutable_cf_options()->cf_paths, file_number, in BuildCompactionJobInfo()
[all …]
Ddb_impl_open.cc1398 for (auto& cf_path : cf.options.cf_paths) { in Open()
1595 if (!cf.options.cf_paths.empty()) { in Open()
1596 paths.emplace_back(cf.options.cf_paths[0].path); in Open()
/rocksdb-6.9/file/
Dsst_file_manager_impl.cc104 auto fn = TableFileName(c->immutable_cf_options()->cf_paths, in OnCompactionCompletion()
188 TableFileName(cfd->ioptions()->cf_paths, inputs[0][0]->fd.GetNumber(), in EnoughRoomForCompaction()
/rocksdb-6.9/db_stress_tool/
Ddb_stress_listener.h169 for (const auto& cf_path : cf.options.cf_paths) { in VerifyFileDir()
/rocksdb-6.9/include/rocksdb/
Doptions.h308 std::vector<DbPath> cf_paths; member

12