Home
last modified time | relevance | path

Searched refs:cf_handles (Results 1 – 8 of 8) sorted by relevance

/rocksdb-6.9/java/rocksjni/
Drocksjni.cc135 open_fn(*opt, db_path, column_families, &cf_handles, &db); in rocksdb_open_helper()
151 results[i] = reinterpret_cast<jlong>(cf_handles[i - 1]); in rocksdb_open_helper()
390 db->CreateColumnFamilies(cf_descriptors, &cf_handles); in Java_org_rocksdb_RocksDB_createColumnFamilies__J_3J_3_3B()
449 cf_handles.push_back(cf_handle); in Java_org_rocksdb_RocksDB_dropColumnFamilies()
1636 cf_handles.push_back(cf_handle); in multi_get_helper()
1699 if (cf_handles.size() == 0) { in multi_get_helper()
1702 s = db->MultiGet(rOpt, cf_handles, keys, &values); in multi_get_helper()
2050 cf_handles.push_back(cf_handle); in Java_org_rocksdb_RocksDB_iterators()
2658 db->EnableAutoCompaction(cf_handles); in Java_org_rocksdb_RocksDB_enableAutoCompaction()
2751 cf_handles.push_back(db->DefaultColumnFamily()); in Java_org_rocksdb_RocksDB_flush()
[all …]
Dtransaction.cc249 std::vector<ROCKSDB_NAMESPACE::ColumnFamilyHandle*> cf_handles; in txn_column_families_helper() local
268 cf_handles.push_back(cf_handle); in txn_column_families_helper()
273 return cf_handles; in txn_column_families_helper()
/rocksdb-6.9/utilities/checkpoint/
Dcheckpoint_test.cc685 std::vector<ROCKSDB_NAMESPACE::ColumnFamilyHandle*> cf_handles; in TEST_F() local
687 column_families, &cf_handles, &snapshotDB)); in TEST_F()
690 ASSERT_OK(snapshotDB->Get(read_options, cf_handles[1], "foocfa", &value)); in TEST_F()
695 delete cf_handles[0]; in TEST_F()
696 delete cf_handles[1]; in TEST_F()
697 delete cf_handles[2]; in TEST_F()
/rocksdb-6.9/db_stress_tool/
Dcf_consistency_stress.cc312 std::vector<ColumnFamilyHandle*> cf_handles; in TestCheckpoint() local
329 &cf_handles, &checkpoint_db); in TestCheckpoint()
333 for (auto cfh : cf_handles) { in TestCheckpoint()
336 cf_handles.clear(); in TestCheckpoint()
Ddb_stress_test_base.cc1329 std::vector<ColumnFamilyHandle*> cf_handles; in TestCheckpoint() local
1346 &cf_handles, &checkpoint_db); in TestCheckpoint()
1355 ReadOptions(), cf_handles[rand_column_families[i]], key, &value); in TestCheckpoint()
1372 for (auto cfh : cf_handles) { in TestCheckpoint()
1375 cf_handles.clear(); in TestCheckpoint()
/rocksdb-6.9/db/
Dc_test.c1739 rocksdb_column_family_handle_t* cf_handles[3]; in main() local
1741 db_options, dbname, 3, cf_names, cf_opts, cf_handles, &err); in main()
1745 CheckTxnGetCF(txn_cf, roptions, cf_handles[0], "key", "value"); in main()
1746 CheckTxnGetCF(txn_cf, roptions, cf_handles[1], "key_cf1", "val_cf1"); in main()
1747 CheckTxnGetCF(txn_cf, roptions, cf_handles[2], "key_cf2", "val_cf2"); in main()
1750 rocksdb_column_family_handle_destroy(cf_handles[0]); in main()
1751 rocksdb_column_family_handle_destroy(cf_handles[1]); in main()
1752 rocksdb_column_family_handle_destroy(cf_handles[2]); in main()
Dcolumn_family_test.cc791 std::vector<ColumnFamilyHandle*> cf_handles; in TEST_P() local
795 ASSERT_OK(db_->CreateColumnFamilies(cf_options, cf_names, &cf_handles)); in TEST_P()
797 ASSERT_OK(db_->Put(write_options, cf_handles[i - 1], "foo", "bar")); in TEST_P()
799 ASSERT_OK(db_->DropColumnFamilies(cf_handles)); in TEST_P()
801 for (auto* handle : cf_handles) { in TEST_P()
804 cf_handles.clear(); in TEST_P()
808 ASSERT_OK(db_->CreateColumnFamilies(cf_descriptors, &cf_handles)); in TEST_P()
810 ASSERT_OK(db_->Put(write_options, cf_handles[i - 1], "foo", "bar")); in TEST_P()
812 ASSERT_OK(db_->DropColumnFamilies(cf_handles)); in TEST_P()
813 for (auto* handle : cf_handles) { in TEST_P()
Ddb_test.cc2223 std::vector<ColumnFamilyHandle*> cf_handles; in TEST_F() local
2229 DB::Open(opts, snapdir, column_families, &cf_handles, &snapdb); in TEST_F()
2235 stat = snapdb->Get(roptions, cf_handles[i < 40], Key(i), &val); in TEST_F()
2238 for (auto cfh : cf_handles) { in TEST_F()