Home
last modified time | relevance | path

Searched refs:num_cfs (Results 1 – 7 of 7) sorted by relevance

/rocksdb-6.9/db/
Ddb_flush_test.cc453 size_t num_cfs = handles_.size(); in TEST_P() local
454 ASSERT_EQ(3, num_cfs); in TEST_P()
485 size_t num_cfs = handles_.size(); in TEST_P() local
486 ASSERT_EQ(3, num_cfs); in TEST_P()
537 size_t num_cfs = handles_.size(); in TEST_P() local
538 ASSERT_EQ(3, num_cfs); in TEST_P()
576 size_t num_cfs = handles_.size(); in TEST_P() local
577 ASSERT_EQ(3, num_cfs); in TEST_P()
613 ASSERT_EQ(3, num_cfs); in TEST_P()
635 num_cfs = handles_.size(); in TEST_P()
[all …]
Ddb_with_timestamp_basic_test.cc466 size_t num_cfs = handles_.size(); in TEST_P() local
467 ASSERT_EQ(2, num_cfs); in TEST_P()
477 for (int cf = 0; cf != static_cast<int>(num_cfs); ++cf) { in TEST_P()
490 for (int cf = 0; cf != static_cast<int>(num_cfs); ++cf) { in TEST_P()
578 size_t num_cfs = handles_.size(); in TEST_P() local
579 ASSERT_EQ(2, num_cfs); in TEST_P()
607 for (int cf = 0; cf != static_cast<int>(num_cfs); ++cf) { in TEST_P()
642 for (int cf = 0; cf != static_cast<int>(num_cfs); ++cf) { in TEST_P()
671 size_t num_cfs = handles_.size(); in TEST_F() local
672 ASSERT_EQ(2, num_cfs); in TEST_F()
[all …]
Dmemtable_list_test.cc783 const int num_cfs = 3; in TEST_F() local
799 for (int i = 0; i != num_cfs; ++i) { in TEST_F()
806 std::vector<std::vector<MemTable*>> tables(num_cfs); in TEST_F()
832 std::vector<autovector<MemTable*>> flush_candidates(num_cfs); in TEST_F()
835 for (auto i = 0; i != num_cfs; ++i) { in TEST_F()
843 for (auto i = 0; i != num_cfs; ++i) { in TEST_F()
851 for (auto i = 0; i != num_cfs; ++i) { in TEST_F()
867 for (auto i = 0; i != num_cfs; ++i) { in TEST_F()
878 for (auto i = 0; i != num_cfs; ++i) { in TEST_F()
890 for (auto i = 0; i != num_cfs; ++i) { in TEST_F()
Ddb_basic_test.cc1743 size_t num_cfs = handles_.size(); in TEST_F() local
1744 ASSERT_EQ(3, num_cfs); in TEST_F()
1747 for (size_t cf = 0; cf != num_cfs; ++cf) { in TEST_F()
1758 for (size_t cf = 0; cf != num_cfs; ++cf) { in TEST_F()
1765 num_cfs = handles_.size(); in TEST_F()
1766 ASSERT_EQ(3, num_cfs); in TEST_F()
1767 for (size_t cf = 0; cf != num_cfs; ++cf) { in TEST_F()
1806 size_t num_cfs = handles_.size(); in TEST_F() local
1807 ASSERT_EQ(3, num_cfs); in TEST_F()
1860 size_t num_cfs = handles_.size(); in TEST_F() local
[all …]
Dexternal_sst_file_test.cc208 size_t num_cfs = column_families.size(); in GenerateAndAddExternalFiles() local
209 assert(ifos.size() == num_cfs); in GenerateAndAddExternalFiles()
210 assert(data.size() == num_cfs); in GenerateAndAddExternalFiles()
212 std::vector<IngestExternalFileArg> args(num_cfs); in GenerateAndAddExternalFiles()
213 for (size_t i = 0; i != num_cfs; ++i) { in GenerateAndAddExternalFiles()
218 true_data.size() == num_cfs ? &true_data[i] : nullptr); in GenerateAndAddExternalFiles()
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc317 for (int i = 0; i < num_cfs; ++i) { in AtomicFlushMemTablesToOutputFiles()
358 for (int i = 0; i != num_cfs; ++i) { in AtomicFlushMemTablesToOutputFiles()
377 for (int i = 0; i != num_cfs; ++i) { in AtomicFlushMemTablesToOutputFiles()
385 for (int i = 1; i != num_cfs; ++i) { in AtomicFlushMemTablesToOutputFiles()
391 if (num_cfs > 1) { in AtomicFlushMemTablesToOutputFiles()
455 for (int i = 0; i != num_cfs; ++i) { in AtomicFlushMemTablesToOutputFiles()
460 for (int i = 0; i != num_cfs; ++i) { in AtomicFlushMemTablesToOutputFiles()
513 for (int i = 0; i != num_cfs; ++i) { in AtomicFlushMemTablesToOutputFiles()
530 assert(num_cfs == in AtomicFlushMemTablesToOutputFiles()
532 for (int i = 0; i != num_cfs; ++i) { in AtomicFlushMemTablesToOutputFiles()
[all …]
Ddb_impl.cc3996 size_t num_cfs = args.size(); in IngestExternalFiles() local
3997 for (size_t i = 0; i != num_cfs; ++i) { in IngestExternalFiles()
4038 for (size_t i = 0; i != num_cfs; ++i) { in IngestExternalFiles()
4043 for (size_t i = 1; i != num_cfs; ++i) { in IngestExternalFiles()
4071 for (size_t i = 0; i != num_cfs; ++i) { in IngestExternalFiles()
4082 for (size_t i = 0; i != num_cfs; ++i) { in IngestExternalFiles()
4112 for (size_t i = 0; i != num_cfs; ++i) { in IngestExternalFiles()
4164 for (size_t i = 0; i != num_cfs; ++i) { in IngestExternalFiles()
4227 if (0 == i && num_cfs > 1) { in IngestExternalFiles()
4259 for (size_t i = 0; i != num_cfs; ++i) { in IngestExternalFiles()
[all …]