Home
last modified time | relevance | path

Searched refs:cfh (Results 1 – 25 of 43) sorted by relevance

12

/rocksdb-6.9/java/rocksjni/
Dcolumnfamilyhandle.cc24 auto* cfh = reinterpret_cast<ROCKSDB_NAMESPACE::ColumnFamilyHandle*>(jhandle); in Java_org_rocksdb_ColumnFamilyHandle_getName() local
25 std::string cf_name = cfh->GetName(); in Java_org_rocksdb_ColumnFamilyHandle_getName()
37 auto* cfh = reinterpret_cast<ROCKSDB_NAMESPACE::ColumnFamilyHandle*>(jhandle); in Java_org_rocksdb_ColumnFamilyHandle_getID() local
38 const int32_t id = cfh->GetID(); in Java_org_rocksdb_ColumnFamilyHandle_getID()
50 auto* cfh = reinterpret_cast<ROCKSDB_NAMESPACE::ColumnFamilyHandle*>(jhandle); in Java_org_rocksdb_ColumnFamilyHandle_getDescriptor() local
52 ROCKSDB_NAMESPACE::Status s = cfh->GetDescriptor(&desc); in Java_org_rocksdb_ColumnFamilyHandle_getDescriptor()
69 auto* cfh = reinterpret_cast<ROCKSDB_NAMESPACE::ColumnFamilyHandle*>(jhandle); in Java_org_rocksdb_ColumnFamilyHandle_disposeInternal() local
70 assert(cfh != nullptr); in Java_org_rocksdb_ColumnFamilyHandle_disposeInternal()
71 delete cfh; in Java_org_rocksdb_ColumnFamilyHandle_disposeInternal()
/rocksdb-6.9/db_stress_tool/
Dcf_consistency_stress.cc35 batch.Merge(cfh, key, v); in TestPut()
37 batch.Put(cfh, key, v); in TestPut()
61 batch.Delete(cfh, key); in TestDelete()
91 batch.DeleteRange(cfh, key, end_key); in TestDeleteRange()
126 auto cfh = in TestGet() local
256 auto cfh = in TestPrefixScan() local
333 for (auto cfh : cf_handles) { in TestCheckpoint() local
334 delete cfh; in TestCheckpoint()
474 assert(nullptr != cfh); in VerifyDb()
478 cfh->GetName().c_str(), in VerifyDb()
[all …]
Dno_batched_ops_stress.cc212 s = txn->Put(cfh, keys.back(), v); in TestMultiGet()
214 s = txn->Merge(cfh, keys.back(), v); in TestMultiGet()
219 s = txn->Delete(cfh, keys.back()); in TestMultiGet()
282 Iterator* iter = db_->NewIterator(ro_copy, cfh); in TestPrefixScan()
341 s = db_->Merge(write_opts, cfh, key, v); in TestPut()
347 s = txn->Merge(cfh, key, v); in TestPut()
356 s = db_->Put(write_opts, cfh, key, v); in TestPut()
362 s = txn->Put(cfh, key, v); in TestPut()
412 s = db_->Delete(write_opts, cfh, key); in TestDelete()
418 s = txn->Delete(cfh, key); in TestDelete()
[all …]
Dbatched_ops_stress.cc36 auto cfh = column_families_[rand_column_families[0]]; in TestPut() local
43 batch.Merge(cfh, keys[i], value_slices[i]); in TestPut()
45 batch.Put(cfh, keys[i], value_slices[i]); in TestPut()
71 auto cfh = column_families_[rand_column_families[0]]; in TestDelete() local
75 batch.Delete(cfh, keys[i]); in TestDelete()
127 auto cfh = column_families_[rand_column_families[0]]; in TestGet() local
133 s = db_->Get(readoptionscopy, cfh, key_slices[i], &from_db); in TestGet()
191 ColumnFamilyHandle* cfh = column_families_[rand_column_families[0]]; in TestMultiGet() local
197 db_->MultiGet(readoptionscopy, cfh, num_prefixes, key_slices.data(), in TestMultiGet()
255 auto cfh = column_families_[rand_column_families[0]]; in TestPrefixScan() local
[all …]
Ddb_stress_test_base.cc348 for (auto cfh : column_families_) { in PreloadDbAndReopenAsReadOnly() local
358 s = db_->Merge(write_opts, cfh, key, v); in PreloadDbAndReopenAsReadOnly()
364 s = txn->Merge(cfh, key, v); in PreloadDbAndReopenAsReadOnly()
373 s = db_->Put(write_opts, cfh, key, v); in PreloadDbAndReopenAsReadOnly()
379 s = txn->Put(cfh, key, v); in PreloadDbAndReopenAsReadOnly()
447 auto cfh = column_families_[rand_cf_idx]; in SetOptions() local
448 return db_->SetOptions(cfh, opts); in SetOptions()
767 db->GetColumnFamilyMetaData(cfh, &cfmd); in GetWhiteBoxKeys()
859 auto cfh = column_families_[rand_column_families[0]]; in TestIterate() local
1372 for (auto cfh : cf_handles) { in TestCheckpoint() local
[all …]
/rocksdb-6.9/db/db_impl/
Ddb_impl_debug.cc50 auto cfh = reinterpret_cast<ColumnFamilyHandleImpl*>(column_family); in TEST_MaxNextLevelOverlappingBytes() local
51 cfd = cfh->cfd(); in TEST_MaxNextLevelOverlappingBytes()
60 auto cfh = reinterpret_cast<ColumnFamilyHandleImpl*>(column_family); in TEST_GetFilesMetaData() local
61 auto cfd = cfh->cfd(); in TEST_GetFilesMetaData()
91 auto cfh = reinterpret_cast<ColumnFamilyHandleImpl*>(column_family); in TEST_CompactRange() local
92 cfd = cfh->cfd(); in TEST_CompactRange()
126 ColumnFamilyHandle* cfh) { in TEST_FlushMemTable() argument
131 if (cfh == nullptr) { in TEST_FlushMemTable()
134 auto cfhi = reinterpret_cast<ColumnFamilyHandleImpl*>(cfh); in TEST_FlushMemTable()
156 cfd = cfh->cfd(); in TEST_WaitForFlushMemTable()
[all …]
Ddb_impl_readonly.cc38 auto cfh = reinterpret_cast<ColumnFamilyHandleImpl*>(column_family); in Get() local
39 auto cfd = cfh->cfd(); in Get()
73 auto cfh = reinterpret_cast<ColumnFamilyHandleImpl*>(column_family); in NewIterator() local
74 auto cfd = cfh->cfd(); in NewIterator()
112 for (auto cfh : column_families) { in NewIterators() local
113 auto* cfd = reinterpret_cast<ColumnFamilyHandleImpl*>(cfh)->cfd(); in NewIterators()
Ddb_impl.cc873 auto* cfh = in TablesRangeTombstoneSummary() local
1322 cfd = cfh->cfd(); in NewInternalIterator()
1534 auto cfh = in GetImpl() local
1536 auto cfd = cfh->cfd(); in GetImpl()
1723 auto cfd = cfh->cfd(); in MultiGet()
2432 auto cfd = cfh->cfd(); in DropColumnFamilyImpl()
2542 auto cfd = cfh->cfd(); in NewIterator()
2781 auto cfd = cfh->cfd(); in GetPropertiesOfAllTables()
2803 auto cfd = cfh->cfd(); in GetPropertiesOfTablesInRange()
3104 auto cfd = cfh->cfd(); in GetApproximateSizes()
[all …]
Ddb_impl_secondary.cc325 auto cfh = static_cast<ColumnFamilyHandleImpl*>(column_family); in GetImpl() local
326 ColumnFamilyData* cfd = cfh->cfd(); in GetImpl()
391 auto cfh = reinterpret_cast<ColumnFamilyHandleImpl*>(column_family); in NewIterator() local
392 auto cfd = cfh->cfd(); in NewIterator()
450 for (auto cfh : column_families) { in NewIterators() local
451 ColumnFamilyData* cfd = static_cast<ColumnFamilyHandleImpl*>(cfh)->cfd(); in NewIterators()
Ddb_impl_compaction_flush.cc682 auto cfd = cfh->cfd(); in CompactRange()
1345 return cfh->cfd()->NumberLevels(); in NumberLevels()
1355 return cfh->cfd() in Level0StopWriteTrigger()
1364 cfh->GetName().c_str()); in Flush()
1367 s = AtomicFlushMemTables({cfh->cfd()}, flush_options, in Flush()
1383 for (auto cfh : column_families) { in Flush() local
1384 s = Flush(flush_options, cfh); in Flush()
1393 for (auto cfh : column_families) { in Flush() local
1394 auto cfhi = static_cast<ColumnFamilyHandleImpl*>(cfh); in Flush()
1404 cfds.emplace_back(cfh->cfd()); in Flush()
[all …]
Ddb_impl_experimental.cc25 auto cfh = reinterpret_cast<ColumnFamilyHandleImpl*>(column_family); in SuggestCompactRange() local
26 auto cfd = cfh->cfd(); in SuggestCompactRange()
/rocksdb-6.9/db/
Ddb_flush_test.cc466 auto cfh = static_cast<ColumnFamilyHandleImpl*>(handles_[i]); in TEST_P() local
467 ASSERT_EQ(0, cfh->cfd()->imm()->NumNotFlushed()); in TEST_P()
468 ASSERT_TRUE(cfh->cfd()->mem()->IsEmpty()); in TEST_P()
504 ASSERT_EQ(0, cfh->cfd()->imm()->NumNotFlushed()); in TEST_P()
505 ASSERT_TRUE(cfh->cfd()->mem()->IsEmpty()); in TEST_P()
510 ASSERT_EQ(0, cfh->cfd()->imm()->NumNotFlushed()); in TEST_P()
511 ASSERT_FALSE(cfh->cfd()->mem()->IsEmpty()); in TEST_P()
551 for (auto* cfh : handles_) { in TEST_P() local
552 dbfull()->TEST_WaitForFlushMemTable(cfh); in TEST_P()
556 ASSERT_EQ(1, cfh->cfd()->imm()->NumNotFlushed()); in TEST_P()
[all …]
Ddeletefile_test.cc276 ColumnFamilyHandle* cfh = nullptr; in TEST_F() local
278 ASSERT_OK(db_->CreateColumnFamily(co, "dropme", &cfh)); in TEST_F()
280 ASSERT_OK(db_->Put(wo, cfh, "pika", "chu")); in TEST_F()
281 ASSERT_OK(db_->Flush(fo, cfh)); in TEST_F()
285 ASSERT_OK(db_->DropColumnFamily(cfh)); in TEST_F()
289 delete cfh; in TEST_F()
Ddb_with_timestamp_basic_test.cc491 ColumnFamilyHandle* cfh = handles_[cf]; in TEST_P() local
494 ASSERT_OK(db_->Get(ropts, cfh, Key1(j), &value)); in TEST_P()
584 ColumnFamilyHandle* cfh) { in TEST_P() argument
595 ASSERT_OK(db_->Get(ropts, cfh, Key1(j), &value, &timestamp)); in TEST_P()
643 ColumnFamilyHandle* cfh = handles_[cf]; in TEST_P() local
644 verify_records_func(i, 0, kNumKeysPerTimestamp - 1, cfh); in TEST_P()
676 const auto& verify_records_func = [&](size_t i, ColumnFamilyHandle* cfh) { in TEST_F() argument
695 std::vector<ColumnFamilyHandle*> cfhs(keys.size(), cfh); in TEST_F()
733 ColumnFamilyHandle* cfh = handles_[cf]; in TEST_F() local
734 verify_records_func(i, cfh); in TEST_F()
Dimport_column_family_test.cc416 ColumnFamilyHandle* cfh = nullptr; in TEST_F() local
419 *metadata_ptr_, &cfh)); in TEST_F()
420 ASSERT_NE(cfh, nullptr); in TEST_F()
424 db_copy->Get(ReadOptions(), cfh, Key(i), &value); in TEST_F()
427 db_copy->DropColumnFamily(cfh); in TEST_F()
428 db_copy->DestroyColumnFamilyHandle(cfh); in TEST_F()
Dcolumn_family_test.cc572 ASSERT_EQ(i, cfh->GetID()); in TEST_P()
2944 ColumnFamilyHandle* cfh; in TEST_P() local
2949 ASSERT_OK(db_->Flush(FlushOptions(), cfh)); in TEST_P()
2950 ASSERT_OK(db_->DropColumnFamily(cfh)); in TEST_P()
2951 ASSERT_OK(db_->DestroyColumnFamilyHandle(cfh)); in TEST_P()
2955 ColumnFamilyHandle* cfh; in TEST_P() local
2959 ASSERT_OK(db_->Flush(FlushOptions(), cfh)); in TEST_P()
2960 ASSERT_OK(db_->DropColumnFamily(cfh)); in TEST_P()
2966 ColumnFamilyHandle* cfh; in TEST_P() local
2970 ASSERT_OK(db_->Flush(FlushOptions(), cfh)); in TEST_P()
[all …]
Dc_test.c1205 rocksdb_column_family_handle_t* cfh; in main()
1206 cfh = rocksdb_create_column_family(db, db_options, "cf1", &err); in main()
1207 rocksdb_column_family_handle_destroy(cfh); in main()
1636 rocksdb_column_family_handle_t* cfh; in main() local
1637 cfh = rocksdb_transactiondb_create_column_family(txn_db, options, in main()
1641 rocksdb_transactiondb_put_cf(txn_db, woptions, cfh, "cf_foo", 6, "cf_hello", in main()
1644 CheckTxnDBGetCF(txn_db, roptions, cfh, "cf_foo", "cf_hello"); in main()
1646 rocksdb_transactiondb_delete_cf(txn_db, woptions, cfh, "cf_foo", 6, &err); in main()
1648 CheckTxnDBGetCF(txn_db, roptions, cfh, "cf_foo", NULL); in main()
1650 rocksdb_column_family_handle_destroy(cfh); in main()
/rocksdb-6.9/utilities/
Ddebug.cc24 Status GetAllKeyVersions(DB* db, ColumnFamilyHandle* cfh, Slice begin_key, in GetAllKeyVersions() argument
30 if (nullptr == cfh) { in GetAllKeyVersions()
39 auto icmp = InternalKeyComparator(idb->GetOptions(cfh).comparator); in GetAllKeyVersions()
44 kMaxSequenceNumber, cfh)); in GetAllKeyVersions()
/rocksdb-6.9/db/blob/
Ddb_blob_index_test.cc46 ColumnFamilyHandle* cfh() { return dbfull()->DefaultColumnFamily(); } in cfh() function in ROCKSDB_NAMESPACE::DBBlobIndexTest
49 return reinterpret_cast<ColumnFamilyHandleImpl*>(cfh())->cfd(); in cfd()
68 get_impl_options.column_family = cfh(); in GetImpl()
202 ASSERT_OK(dbfull()->DeleteRange(WriteOptions(), cfh(), "key6", "key9")); in TEST_F()
361 dbfull()->DeleteRange(WriteOptions(), cfh(), get_key(15), get_key(16))); in TEST_F()
404 cfh(), {{"max_sequential_skip_in_iterations", "0"}})); in TEST_F()
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DColumnFamilyTest.java72 final ColumnFamilyHandle cfh = db.getDefaultColumnFamily(); in defaultColumnFamily() local
74 assertThat(cfh).isNotNull(); in defaultColumnFamily()
76 assertThat(cfh.getName()).isEqualTo("default".getBytes(UTF_8)); in defaultColumnFamily()
77 assertThat(cfh.getID()).isEqualTo(0); in defaultColumnFamily()
78 assertThat(cfh.getDescriptor().getName()).isEqualTo("default".getBytes(UTF_8)); in defaultColumnFamily()
83 db.put(cfh, key, value); in defaultColumnFamily()
85 final byte[] actualValue = db.get(cfh, key); in defaultColumnFamily()
87 assertThat(cfh).isNotNull(); in defaultColumnFamily()
90 cfh.close(); in defaultColumnFamily()
/rocksdb-6.9/table/
Dsst_file_writer.cc38 cfh(_cfh), in Rep()
53 ColumnFamilyHandle* cfh; member
230 if (r->cfh != nullptr) { in Open()
233 cf_id = r->cfh->GetID(); in Open()
234 r->column_family_name = r->cfh->GetName(); in Open()
/rocksdb-6.9/utilities/transactions/
Dtransaction_util.cc27 auto cfh = reinterpret_cast<ColumnFamilyHandleImpl*>(column_family); in CheckKeyForConflicts() local
28 auto cfd = cfh->cfd(); in CheckKeyForConflicts()
33 cfh->GetName()); in CheckKeyForConflicts()
/rocksdb-6.9/utilities/blob_db/
Dblob_db_impl_filesnapshot.cc101 auto cfh = reinterpret_cast<ColumnFamilyHandleImpl*>(DefaultColumnFamily()); in GetLiveFilesMetaData() local
102 filemetadata.column_family_name = cfh->GetName(); in GetLiveFilesMetaData()
/rocksdb-6.9/utilities/write_batch_with_index/
Dwrite_batch_with_index_internal.cc252 auto cfh = reinterpret_cast<ColumnFamilyHandleImpl*>(column_family); in GetFromBatch() local
253 merge_operator = cfh->cfd()->ioptions()->merge_operator; in GetFromBatch()
/rocksdb-6.9/trace_replay/
Dtrace_replay.cc178 for (ColumnFamilyHandle* cfh : handles) { in Replayer()
179 cf_map_[cfh->GetID()] = cfh; in Replayer()

12