Home
last modified time | relevance | path

Searched refs:handles (Results 1 – 25 of 59) sorted by relevance

123

/rocksdb-6.9/examples/
Dcolumn_families_example.cc43 std::vector<ColumnFamilyHandle*> handles; in main() local
44 s = DB::Open(DBOptions(), kDBPath, column_families, &handles, &db); in main()
48 s = db->Put(WriteOptions(), handles[1], Slice("key"), Slice("value")); in main()
51 s = db->Get(ReadOptions(), handles[1], Slice("key"), &value); in main()
56 batch.Put(handles[0], Slice("key2"), Slice("value2")); in main()
57 batch.Put(handles[1], Slice("key3"), Slice("value3")); in main()
58 batch.Delete(handles[0], Slice("key")); in main()
63 s = db->DropColumnFamily(handles[1]); in main()
67 for (auto handle : handles) { in main()
Dmulti_processes_example.cc159 std::vector<ColumnFamilyHandle*> handles; in CreateDB() local
170 handles.push_back(handle); in CreateDB()
174 for (auto h : handles) { in CreateDB()
177 handles.clear(); in CreateDB()
193 std::vector<ColumnFamilyHandle*> handles; in RunPrimary() local
209 for (auto h : handles) { in RunPrimary()
228 for (auto h : handles) { in RunPrimary()
231 handles.clear(); in RunPrimary()
237 for (auto h : handles) { in RunPrimary()
240 handles.clear(); in RunPrimary()
[all …]
Doptions_file_example.cc104 std::vector<ColumnFamilyHandle*> handles; in main() local
105 s = DB::Open(loaded_db_opt, kDBPath, loaded_cf_descs, &handles, &db); in main()
109 for (auto* handle : handles) { in main()
/rocksdb-6.9/utilities/transactions/
Doptimistic_transaction_db_impl.cc46 std::vector<ColumnFamilyHandle*> handles; in Open() local
47 Status s = Open(db_options, dbname, column_families, &handles, dbptr); in Open()
49 assert(handles.size() == 1); in Open()
52 delete handles[0]; in Open()
61 std::vector<ColumnFamilyHandle*>* handles, in Open() argument
65 column_families, handles, dbptr); in Open()
73 std::vector<ColumnFamilyHandle*>* handles, in Open() argument
92 s = DB::Open(db_options, dbname, column_families_copy, handles, &db); in Open()
Dpessimistic_transaction_db.cc88 const std::vector<ColumnFamilyHandle*>& handles) { in Initialize() argument
89 for (auto cf_ptr : handles) { in Initialize()
93 for (auto handle : handles) { in Initialize()
110 compaction_enabled_cf_handles.push_back(handles[index]); in Initialize()
200 std::vector<ColumnFamilyHandle*> handles; in Open() local
202 column_families, &handles, dbptr); in Open()
204 assert(handles.size() == 1); in Open()
207 delete handles[0]; in Open()
217 std::vector<ColumnFamilyHandle*>* handles, TransactionDB** dbptr) { in Open() argument
313 txn_db->UpdateCFComparatorMap(handles); in WrapDB()
[all …]
Doptimistic_transaction_test.cc72 assert(handles.size() == 1); in Open()
73 delete handles[0]; in Open()
629 batch.Put(handles[1], "AAA", "bar"); in TEST_P()
658 txn2->Delete(handles[2], "XXX"); in TEST_P()
659 txn2->Delete(handles[1], "XXX"); in TEST_P()
678 std::vector<ColumnFamilyHandle*> multiget_cfh = {handles[1], handles[2], in TEST_P()
679 handles[0], handles[2]}; in TEST_P()
693 txn->Delete(handles[2], "ZZZ"); in TEST_P()
694 txn->Put(handles[2], "ZZZ", "YYY"); in TEST_P()
696 txn->Delete(handles[2], "ZZZ"); in TEST_P()
[all …]
Dtransaction_test.h115 std::vector<ColumnFamilyHandle*>* handles) { in ReOpenNoDelete() argument
116 for (auto h : *handles) { in ReOpenNoDelete()
119 handles->clear(); in ReOpenNoDelete()
127 s = TransactionDB::Open(options, txn_db_options, dbname, cfs, handles, in ReOpenNoDelete()
130 s = OpenWithStackableDB(cfs, handles); in ReOpenNoDelete()
151 std::vector<ColumnFamilyHandle*>* handles) { in OpenWithStackableDB() argument
162 Status s = DBImpl::Open(options_copy, dbname, cfs, handles, &root_db, in OpenWithStackableDB()
169 *handles, &db); in OpenWithStackableDB()
184 std::vector<ColumnFamilyHandle*> handles; in OpenWithStackableDB() local
201 assert(handles.size() == 1); in OpenWithStackableDB()
[all …]
Dtransaction_test.cc2625 batch.Put(handles[1], "AAA", "bar"); in TEST_P()
2679 std::vector<ColumnFamilyHandle*> multiget_cfh = {handles[1], handles[2], in TEST_P()
2680 handles[0], handles[2]}; in TEST_P()
2699 s = txn->Delete(handles[2], "ZZZ"); in TEST_P()
2737 for (auto handle : handles) { in TEST_P()
2795 s = txn->Delete(handles[1], "bbb"); in TEST_P()
2821 for (auto handle : handles) { in TEST_P()
2919 for (auto handle : handles) { in TEST_P()
5203 for (auto handle : handles) { in TEST_P()
6062 for (auto h : handles) { in TEST_P()
[all …]
Dwrite_unprepared_txn_db.cc77 std::map<uint32_t, ColumnFamilyHandle*>& handles, in RollbackRecoveredTransaction()
84 handles_(handles), in RollbackRecoveredTransaction()
194 const std::vector<ColumnFamilyHandle*>& handles) { in Initialize() argument
220 for (auto cf_ptr : handles) { in Initialize()
224 for (auto handle : handles) { in Initialize()
241 compaction_enabled_cf_handles.push_back(handles[index]); in Initialize()
/rocksdb-6.9/utilities/ttl/
Dttl_test.cc628 std::vector<ColumnFamilyHandle*> handles; in TEST_F() local
631 &handles, &db_ttl_, {3, 5}, false)); in TEST_F()
632 ASSERT_EQ(handles.size(), 2U); in TEST_F()
636 handles.push_back(new_handle); in TEST_F()
639 PutValues(0, kSampleSize_, false, handles[0]); in TEST_F()
640 PutValues(0, kSampleSize_, false, handles[1]); in TEST_F()
641 PutValues(0, kSampleSize_, false, handles[2]); in TEST_F()
644 SleepCompactCheck(1, 0, kSampleSize_, true, false, handles[0]); in TEST_F()
645 SleepCompactCheck(0, 0, kSampleSize_, true, false, handles[1]); in TEST_F()
646 SleepCompactCheck(0, 0, kSampleSize_, true, false, handles[2]); in TEST_F()
[all …]
Ddb_ttl_impl.cc78 std::vector<ColumnFamilyHandle*> handles; in Open() local
79 Status s = DBWithTTL::Open(db_options, dbname, column_families, &handles, in Open()
82 assert(handles.size() == 1); in Open()
85 delete handles[0]; in Open()
93 std::vector<ColumnFamilyHandle*>* handles, DBWithTTL** dbptr, in Open() argument
113 handles, &db); in Open()
115 st = DB::Open(db_options, dbname, column_families_sanitized, handles, &db); in Open()
/rocksdb-6.9/db/db_impl/
Ddb_impl_readonly.cc145 std::vector<ColumnFamilyHandle*> handles; in OpenForReadOnly() local
147 s = DB::OpenForReadOnly(db_options, dbname, column_families, &handles, dbptr); in OpenForReadOnly()
149 assert(handles.size() == 1); in OpenForReadOnly()
152 delete handles[0]; in OpenForReadOnly()
160 std::vector<ColumnFamilyHandle*>* handles, DB** dbptr, in OpenForReadOnly() argument
163 handles->clear(); in OpenForReadOnly()
179 handles->push_back(new ColumnFamilyHandleImpl(cfd, impl, &impl->mutex_)); in OpenForReadOnly()
192 for (auto* h : *handles) { in OpenForReadOnly()
197 for (auto h : *handles) { in OpenForReadOnly()
200 handles->clear(); in OpenForReadOnly()
Ddb_impl_secondary.cc575 std::vector<ColumnFamilyHandle*> handles; in OpenAsSecondary() local
578 column_families, &handles, dbptr); in OpenAsSecondary()
580 assert(handles.size() == 1); in OpenAsSecondary()
581 delete handles[0]; in OpenAsSecondary()
590 std::vector<ColumnFamilyHandle*>* handles, DB** dbptr) { in OpenAsSecondary() argument
608 handles->clear(); in OpenAsSecondary()
628 handles->push_back(new ColumnFamilyHandleImpl(cfd, impl, &impl->mutex_)); in OpenAsSecondary()
642 for (auto h : *handles) { in OpenAsSecondary()
647 for (auto h : *handles) { in OpenAsSecondary()
650 handles->clear(); in OpenAsSecondary()
Ddb_impl_open.cc1299 std::vector<ColumnFamilyHandle*> handles; in Open() local
1303 assert(handles.size() == 2); in Open()
1305 assert(handles.size() == 1); in Open()
1309 if (db_options.persist_stats_to_disk && handles[1] != nullptr) { in Open()
1310 delete handles[1]; in Open()
1312 delete handles[0]; in Open()
1382 handles->clear(); in Open()
1449 handles->push_back( in Open()
1460 handles->push_back(handle); in Open()
1650 for (auto* h : *handles) { in Open()
[all …]
/rocksdb-6.9/utilities/blob_db/
Dblob_db.cc24 std::vector<ColumnFamilyHandle*> handles; in Open() local
26 &handles, blob_db); in Open()
28 assert(handles.size() == 1); in Open()
31 delete handles[0]; in Open()
39 std::vector<ColumnFamilyHandle*>* handles, in Open() argument
49 Status s = blob_db_impl->Open(handles); in Open()
/rocksdb-6.9/db/
Dc_test.c1223 rocksdb_column_family_handle_t* handles[2]; in main() local
1245 CheckGetCF(db, roptions, handles[1], "foo", "hello"); in main()
1255 CheckGetCF(db, roptions, handles[1], "foo", NULL); in main()
1266 CheckGetCF(db, roptions, handles[1], "baz", NULL); in main()
1267 CheckGetCF(db, roptions, handles[1], "bar", NULL); in main()
1268 CheckGetCF(db, roptions, handles[1], "box", "c"); in main()
1271 CheckPinGetCF(db, roptions, handles[1], "box", "c"); in main()
1275 const rocksdb_column_family_handle_t* get_handles[3] = { handles[0], handles[1], handles[1] }; in main()
1312 rocksdb_column_family_handle_t* iters_cf_handles[2] = { handles[0], handles[1] }; in main()
1336 rocksdb_drop_column_family(db, handles[1], &err); in main()
[all …]
Ddb_test2.cc3211 std::vector<ColumnFamilyHandle*> handles; in TEST_F() local
3236 for (auto handle : handles) { in TEST_F()
3286 std::vector<ColumnFamilyHandle*> handles; in TEST_F() local
3304 for (auto handle : handles) { in TEST_F()
3354 std::vector<ColumnFamilyHandle*> handles; in TEST_F() local
3375 for (auto handle : handles) { in TEST_F()
3454 std::vector<ColumnFamilyHandle*> handles; in TEST_F() local
3475 for (auto handle : handles) { in TEST_F()
3498 handles.clear(); in TEST_F()
3518 ASSERT_OK(db3->Delete(wo, handles[0], "c")); in TEST_F()
[all …]
Dmemtable_list_test.cc27 std::vector<ColumnFamilyHandle*> handles; member in ROCKSDB_NAMESPACE::MemTableListTest
45 Status s = DB::Open(options, dbname, cf_descs, &handles, &db); in CreateDB()
53 int sz = static_cast<int>(handles.size()); in CreateDB()
54 handles.resize(sz + 2); in CreateDB()
55 s = db->CreateColumnFamily(cf_opt1, "one", &handles[1]); in CreateDB()
57 s = db->CreateColumnFamily(cf_opt2, "two", &handles[2]); in CreateDB()
67 std::vector<ColumnFamilyDescriptor> cf_descs(handles.size()); in ~MemTableListTest()
68 for (int i = 0; i != static_cast<int>(handles.size()); ++i) { in ~MemTableListTest()
69 handles[i]->GetDescriptor(&cf_descs[i]); in ~MemTableListTest()
71 for (auto h : handles) { in ~MemTableListTest()
[all …]
/rocksdb-6.9/cache/
Dcache_test.cc572 std::vector<Cache::Handle*> handles(10); in TEST_P() local
599 cache->Release(handles[i]); in TEST_P()
609 cache->Release(handles[i]); in TEST_P()
617 std::vector<Cache::Handle*> handles(10); in TEST_P() local
622 SimpleDeleter<Value>::GetInstance(), &handles[i]); in TEST_P()
624 ASSERT_NE(nullptr, handles[i]); in TEST_P()
640 cache->Release(handles[i]); in TEST_P()
650 ASSERT_NE(nullptr, handles[i]); in TEST_P()
665 cache2->Release(handles[i]); in TEST_P()
675 std::vector<Cache::Handle*> handles(n+1); in TEST_P() local
[all …]
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DTtlDB.java132 final long[] handles = openCF(options.nativeHandle_, db_path, in open() local
135 final TtlDB ttlDB = new TtlDB(handles[0]); in open()
136 for (int i = 1; i < handles.length; i++) { in open()
137 columnFamilyHandles.add(new ColumnFamilyHandle(ttlDB, handles[i])); in open()
DOptimisticTransactionDB.java80 final long[] handles = open(dbOptions.nativeHandle_, path, cfNames, in open() local
83 new OptimisticTransactionDB(handles[0]); in open()
90 for (int i = 1; i < handles.length; i++) { in open()
91 columnFamilyHandles.add(new ColumnFamilyHandle(otdb, handles[i])); in open()
DTransactionDB.java90 final long[] handles = open(dbOptions.nativeHandle_, in open() local
92 final TransactionDB tdb = new TransactionDB(handles[0]); in open()
100 for (int i = 1; i < handles.length; i++) { in open()
101 columnFamilyHandles.add(new ColumnFamilyHandle(tdb, handles[i])); in open()
/rocksdb-6.9/monitoring/
Dthread_status_updater_debug.cc16 const std::vector<ColumnFamilyHandle*>& handles, bool check_exist) { in TEST_VerifyColumnFamilyInfoMap() argument
19 assert(cf_info_map_.size() == handles.size()); in TEST_VerifyColumnFamilyInfoMap()
21 for (auto* handle : handles) { in TEST_VerifyColumnFamilyInfoMap()
/rocksdb-6.9/include/rocksdb/utilities/
Dtransaction_db.h247 std::vector<ColumnFamilyHandle*>* handles,
260 const std::vector<ColumnFamilyHandle*>& handles,
269 const std::vector<ColumnFamilyHandle*>& handles, TransactionDB** dbptr);
/rocksdb-6.9/java/rocksjni/
Dttl.cc111 std::vector<ROCKSDB_NAMESPACE::ColumnFamilyHandle*> handles; in Java_org_rocksdb_TtlDB_openCF() local
114 *opt, db_path, column_families, &handles, &db, ttl_values, jread_only); in Java_org_rocksdb_TtlDB_openCF()
126 results[i] = reinterpret_cast<jlong>(handles[i - 1]); in Java_org_rocksdb_TtlDB_openCF()

123