Home
last modified time | relevance | path

Searched refs:cfs (Results 1 – 15 of 15) sorted by relevance

/rocksdb-6.9/java/jmh/src/main/java/org/rocksdb/jmh/
DGetBenchmarks.java38 int cfs = 0; // number of column families field in GetBenchmarks
58 cfs = 1; in setup()
60 cfs = 20; in setup()
62 cfs = 100; in setup()
65 if (cfs > 0) { in setup()
67 for (int i = 1; i <= cfs; i++) { in setup()
77 for (int i = 0; i < cfs; i++) { in setup()
100 if (cfs == 0) { in getColumnFamily()
102 } else if (cfs == 1) { in getColumnFamily()
106 if (idx > cfs) { in getColumnFamily()
DMultiGetBenchmarks.java47 int cfs = 0; // number of column families field in MultiGetBenchmarks
67 cfs = 1; in setup()
69 cfs = 20; in setup()
71 cfs = 100; in setup()
74 if (cfs > 0) { in setup()
76 for (int i = 1; i <= cfs; i++) { in setup()
86 for (int i = 0; i < cfs; i++) { in setup()
109 if (cfs == 0) { in getColumnFamily()
111 } else if (cfs == 1) { in getColumnFamily()
115 if (idx > cfs) { in getColumnFamily()
DPutBenchmarks.java35 int cfs = 0; // number of column families field in PutBenchmarks
54 cfs = 1; in setup()
56 cfs = 20; in setup()
58 cfs = 100; in setup()
61 if (cfs > 0) { in setup()
63 for (int i = 1; i <= cfs; i++) { in setup()
84 if (cfs == 0) { in getColumnFamily()
86 } else if (cfs == 1) { in getColumnFamily()
90 if (idx > cfs) { in getColumnFamily()
/rocksdb-6.9/utilities/checkpoint/
Dcheckpoint_test.cc112 handles_.resize(cfi + cfs.size()); in CreateColumnFamilies()
113 for (auto cf : cfs) { in CreateColumnFamilies()
120 CreateColumnFamilies(cfs, options); in CreateAndReopenWithCF()
137 const std::vector<std::string>& cfs, in TryReopenWithColumnFamilies() argument
140 EXPECT_EQ(cfs.size(), options.size()); in TryReopenWithColumnFamilies()
142 for (size_t i = 0; i < cfs.size(); ++i) { in TryReopenWithColumnFamilies()
193 for (const auto& cf : cfs) { in ReadOnlyReopenWithColumnFamilies()
465 std::vector<std::string> cfs; in TEST_F() local
468 for (size_t i = 0; i < cfs.size(); ++i) { in TEST_F()
524 std::vector<std::string> cfs; in TEST_F() local
[all …]
/rocksdb-6.9/db/
Ddb_logical_block_size_cache_test.cc185 std::vector<ColumnFamilyHandle*> cfs; in TEST_F() local
194 for (ColumnFamilyHandle* cf : cfs) { in TEST_F()
205 ASSERT_OK(db->DestroyColumnFamilyHandle(cfs[0])); in TEST_F()
213 ASSERT_OK(db->DestroyColumnFamilyHandle(cfs[1])); in TEST_F()
248 std::vector<ColumnFamilyHandle*> cfs; in TEST_F() local
255 &cfs, &db)); in TEST_F()
265 &cfs, &db)); in TEST_F()
277 ASSERT_OK(db->DropColumnFamily(cfs[0])); in TEST_F()
278 ASSERT_OK(db->DropColumnFamily(cfs[1])); in TEST_F()
286 ASSERT_OK(db->DestroyColumnFamilyHandle(cfs[0])); in TEST_F()
[all …]
Ddb_test_util.cc586 handles_.resize(cfi + cfs.size()); in CreateColumnFamilies()
587 for (auto cf : cfs) { in CreateColumnFamilies()
595 CreateColumnFamilies(cfs, options); in CreateAndReopenWithCF()
596 std::vector<std::string> cfs_plus_default = cfs; in CreateAndReopenWithCF()
614 EXPECT_EQ(cfs.size(), options.size()); in TryReopenWithColumnFamilies()
616 for (size_t i = 0; i < cfs.size(); ++i) { in TryReopenWithColumnFamilies()
628 return TryReopenWithColumnFamilies(cfs, v_opts); in TryReopenWithColumnFamilies()
790 for (unsigned int i = 0; i < cfs.size(); ++i) { in MultiGet()
791 handles.push_back(handles_[cfs[i]]); in MultiGet()
806 result.resize(cfs.size()); in MultiGet()
[all …]
Ddb_basic_test.cc844 std::vector<ColumnFamilyHandle*> cfs; in TEST_F() local
860 cfs.push_back(handles_[0]); in TEST_F()
861 cfs.push_back(handles_[1]); in TEST_F()
1084 std::vector<int> cfs; in TEST_P() local
1100 cfs.clear(); in TEST_P()
1101 cfs.push_back(std::get<0>(cf_kv_vec[0])); in TEST_P()
1113 cfs.clear(); in TEST_P()
1171 std::vector<int> cfs; in TEST_P() local
1176 cfs.push_back(i); in TEST_P()
1230 std::vector<int> cfs; in TEST_P() local
[all …]
Ddb_test_util.h785 void CreateColumnFamilies(const std::vector<std::string>& cfs,
788 void CreateAndReopenWithCF(const std::vector<std::string>& cfs,
791 void ReopenWithColumnFamilies(const std::vector<std::string>& cfs,
794 void ReopenWithColumnFamilies(const std::vector<std::string>& cfs,
797 Status TryReopenWithColumnFamilies(const std::vector<std::string>& cfs,
800 Status TryReopenWithColumnFamilies(const std::vector<std::string>& cfs,
851 std::vector<std::string> MultiGet(std::vector<int> cfs,
Dlistener_test.cc854 const std::vector<std::string>& cfs) in ColumnFamilyHandleDeletionStartedListener() argument
855 : cfs_(cfs), counter(0) { in ColumnFamilyHandleDeletionStartedListener()
867 std::vector<std::string> cfs{"pikachu", "eevee", "Mewtwo"}; in TEST_F() local
869 std::make_shared<ColumnFamilyHandleDeletionStartedListener>(cfs); in TEST_F()
874 CreateAndReopenWithCF(cfs, options); in TEST_F()
Dcolumn_family_test.cc274 const std::vector<std::string>& cfs, in CreateColumnFamilies() argument
277 handles_.resize(cfi + cfs.size());
278 names_.resize(cfi + cfs.size());
279 for (size_t i = 0; i < cfs.size(); ++i) {
283 db_->CreateColumnFamily(current_cf_opt, cfs[i], &handles_[cfi]));
284 names_[cfi] = cfs[i];
308 void CreateColumnFamiliesAndReopen(const std::vector<std::string>& cfs) { in CreateColumnFamiliesAndReopen() argument
309 CreateColumnFamilies(cfs); in CreateColumnFamiliesAndReopen()
313 void DropColumnFamilies(const std::vector<int>& cfs) { in DropColumnFamilies() argument
314 for (auto cf : cfs) { in DropColumnFamilies()
Dc.cc975 std::vector<ColumnFamilyHandle*> cfs(num_keys); in rocksdb_multi_get_cf() local
978 cfs[i] = column_families[i]->rep; in rocksdb_multi_get_cf()
981 std::vector<Status> statuses = db->rep->MultiGet(options->rep, cfs, keys, &values); in rocksdb_multi_get_cf()
Ddb_test.cc2515 std::vector<std::string> cfs; in TEST_P() local
2517 cfs.push_back(ToString(i)); in TEST_P()
2520 CreateAndReopenWithCF(cfs, options); in TEST_P()
/rocksdb-6.9/db/compaction/
Dcompaction_job_stats_test.cc137 handles_.resize(cfi + cfs.size()); in CreateColumnFamilies()
138 for (auto cf : cfs) { in CreateColumnFamilies()
145 CreateColumnFamilies(cfs, options); in CreateAndReopenWithCF()
146 std::vector<std::string> cfs_plus_default = cfs; in CreateAndReopenWithCF()
153 ASSERT_OK(TryReopenWithColumnFamilies(cfs, options)); in ReopenWithColumnFamilies()
158 ASSERT_OK(TryReopenWithColumnFamilies(cfs, options)); in ReopenWithColumnFamilies()
162 const std::vector<std::string>& cfs, in TryReopenWithColumnFamilies() argument
165 EXPECT_EQ(cfs.size(), options.size()); in TryReopenWithColumnFamilies()
167 for (size_t i = 0; i < cfs.size(); ++i) { in TryReopenWithColumnFamilies()
177 std::vector<Options> v_opts(cfs.size(), options); in TryReopenWithColumnFamilies()
[all …]
/rocksdb-6.9/utilities/transactions/
Dtransaction_test.h114 Status ReOpenNoDelete(std::vector<ColumnFamilyDescriptor>& cfs, in ReOpenNoDelete() argument
127 s = TransactionDB::Open(options, txn_db_options, dbname, cfs, handles, in ReOpenNoDelete()
130 s = OpenWithStackableDB(cfs, handles); in ReOpenNoDelete()
150 Status OpenWithStackableDB(std::vector<ColumnFamilyDescriptor>& cfs, in OpenWithStackableDB() argument
153 TransactionDB::PrepareWrap(&options, &cfs, &compaction_enabled_cf_indices); in OpenWithStackableDB()
162 Status s = DBImpl::Open(options_copy, dbname, cfs, handles, &root_db, in OpenWithStackableDB()
/rocksdb-6.9/tools/rdb/
Ddb_wrapper.cc87 std::vector<std::string> cfs = {ROCKSDB_NAMESPACE::kDefaultColumnFamilyName}; in Open() local
96 cfs.push_back(*v8::String::Utf8Value(array->Get(i)->ToString())); in Open()
100 if (cfs.size() == 1) { in Open()
109 for (std::vector<int>::size_type i = 0; i < cfs.size(); i++) { in Open()
111 cfs[i], ROCKSDB_NAMESPACE::ColumnFamilyOptions())); in Open()
123 db_wrapper->columnFamilies_[cfs[i]] = handles[i]; in Open()