Home
last modified time | relevance | path

Searched refs:handles_ (Results 1 – 25 of 34) sorted by relevance

12

/rocksdb-6.9/db/
Ddb_flush_test.cc336 ASSERT_EQ(2, handles_.size()); in TEST_F()
344 handles_.resize(1); in TEST_F()
551 for (auto* cfh : handles_) { in TEST_P()
635 num_cfs = handles_.size(); in TEST_P()
681 ASSERT_EQ(2, handles_.size()); in TEST_P()
694 handles_[1] = nullptr; in TEST_P()
697 delete handles_[0]; in TEST_P()
698 handles_.clear(); in TEST_P()
719 ASSERT_EQ(2, handles_.size()); in TEST_P()
730 delete handles_[1]; in TEST_P()
[all …]
Dcolumn_family_test.cc88 for (auto h : handles_) { in ~ColumnFamilyTestBase()
177 for (auto h : handles_) { in Close()
182 handles_.clear(); in Close()
276 int cfi = static_cast<int>(handles_.size());
277 handles_.resize(cfi + cfs.size());
316 db_->DestroyColumnFamilyHandle(handles_[cf]); in DropColumnFamilies()
317 handles_[cf] = nullptr; in DropColumnFamilies()
491 assert(num_per_cf.size() == handles_.size()); in AssertNumberOfImmutableMemtables()
541 std::vector<ColumnFamilyHandle*> handles_; member in ROCKSDB_NAMESPACE::ColumnFamilyTestBase
570 for (size_t i = 0; i < handles_.size(); ++i) { in TEST_P()
[all …]
Ddb_test_util.cc585 size_t cfi = handles_.size(); in CreateColumnFamilies()
586 handles_.resize(cfi + cfs.size()); in CreateColumnFamilies()
636 for (auto h : handles_) { in Close()
639 handles_.clear(); in Close()
655 handles_[i]->GetDescriptor(&cfdescriptor); in Destroy()
715 return db_->Merge(wo, handles_[cf], k, v); in Put()
717 return db_->Put(wo, handles_[cf], k, v); in Put()
727 return db_->Merge(wo, handles_[cf], k, v); in Merge()
791 handles.push_back(handles_[cfs[i]]); in MultiGet()
1051 handles_[cf], in CompressionRatioAtLevel()
[all …]
Ddb_properties_test.cc44 handles_[1], "rocksdb.num-entries-active-mem-table", &num)); in TEST_F()
127 for (auto* handle : handles_) { in TEST_F()
137 for (auto* handle : handles_) { in TEST_F()
151 for (auto* handle : handles_) { in TEST_F()
630 ASSERT_TRUE(dbfull()->GetProperty(handles_[1], in TEST_F()
644 ASSERT_TRUE(dbfull()->GetProperty(handles_[1], in TEST_F()
664 ASSERT_TRUE(dbfull()->GetProperty(handles_[1], in TEST_F()
684 ASSERT_TRUE(dbfull()->GetProperty(handles_[1], in TEST_F()
701 ASSERT_OK(dbfull()->Delete(writeOpt, handles_[1], "k2")); in TEST_F()
703 ASSERT_OK(dbfull()->Delete(writeOpt, handles_[1], "k3")); in TEST_F()
[all …]
Ddb_tailing_iter_test.cc49 std::unique_ptr<Iterator> iter(db_->NewIterator(read_options, handles_[1])); in TEST_F()
71 std::unique_ptr<Iterator> iter(db_->NewIterator(read_options, handles_[1])); in TEST_F()
72 std::unique_ptr<Iterator> itern(db_->NewIterator(read_options, handles_[1])); in TEST_F()
139 std::unique_ptr<Iterator> iter(db_->NewIterator(read_options, handles_[1])); in TEST_F()
140 std::unique_ptr<Iterator> itern(db_->NewIterator(read_options, handles_[1])); in TEST_F()
141 std::unique_ptr<Iterator> iterh(db_->NewIterator(read_options, handles_[1])); in TEST_F()
237 iter.reset(db_->NewIterator(read_options, handles_[1])); in TEST_F()
263 std::unique_ptr<Iterator> iter(db_->NewIterator(read_options, handles_[1])); in TEST_F()
405 std::unique_ptr<Iterator> it(db_->NewIterator(read_options, handles_[1])); in TEST_F()
466 db_->GetColumnFamilyMetaData(handles_[1], &meta); in TEST_F()
[all …]
Ddb_log_iter_test.cc219 batch.Put(handles_[1], "key1", DummyString(1024)); in TEST_F()
220 batch.Put(handles_[0], "key2", DummyString(1024)); in TEST_F()
221 batch.Put(handles_[1], "key3", DummyString(1024)); in TEST_F()
222 batch.Delete(handles_[0], "key2"); in TEST_F()
239 batch.Put(handles_[1], "key1", DummyString(1024)); in TEST_F()
240 batch.Put(handles_[0], "key2", DummyString(1024)); in TEST_F()
242 batch.Put(handles_[1], "key3", DummyString(1024)); in TEST_F()
244 batch.Delete(handles_[0], "key2"); in TEST_F()
Ddb_compaction_filter_test.cc316 dbfull()->TEST_CompactRange(0, nullptr, nullptr, handles_[1]); in TEST_F()
319 dbfull()->TEST_CompactRange(1, nullptr, nullptr, handles_[1]); in TEST_F()
340 &arena, &range_del_agg, kMaxSequenceNumber, handles_[1])); in TEST_F()
368 dbfull()->TEST_CompactRange(0, nullptr, nullptr, handles_[1]); in TEST_F()
371 dbfull()->TEST_CompactRange(1, nullptr, nullptr, handles_[1]); in TEST_F()
400 dbfull()->TEST_CompactRange(0, nullptr, nullptr, handles_[1]); in TEST_F()
403 dbfull()->TEST_CompactRange(1, nullptr, nullptr, handles_[1]); in TEST_F()
411 db_->NewIterator(ReadOptions(), handles_[1])); in TEST_F()
430 &arena, &range_del_agg, kMaxSequenceNumber, handles_[1])); in TEST_F()
500 dbfull()->TEST_CompactRange(0, nullptr, nullptr, handles_[1]); in TEST_P()
[all …]
Ddb_basic_test.cc384 ASSERT_OK(dbfull()->Put(writeOpt, handles_[0], "foo", "v1")); in TEST_F()
860 cfs.push_back(handles_[0]); in TEST_F()
861 cfs.push_back(handles_[1]); in TEST_F()
1658 ASSERT_EQ(2, handles_.size()); in TEST_F()
1743 size_t num_cfs = handles_.size(); in TEST_F()
1765 num_cfs = handles_.size(); in TEST_F()
1806 size_t num_cfs = handles_.size(); in TEST_F()
1835 iter.reset(db_->NewIterator(read_opts, handles_[1])); in TEST_F()
1841 iter.reset(db_->NewIterator(read_opts, handles_[2])); in TEST_F()
1860 size_t num_cfs = handles_.size(); in TEST_F()
[all …]
Dexternal_sst_file_test.cc2401 column_families.push_back(handles_[0]); in TEST_P()
2402 column_families.push_back(handles_[1]); in TEST_P()
2403 column_families.push_back(handles_[2]); in TEST_P()
2429 ASSERT_EQ(3, handles_.size()); in TEST_P()
2476 column_families.push_back(handles_[0]); in TEST_P()
2477 column_families.push_back(handles_[1]); in TEST_P()
2478 column_families.push_back(handles_[2]); in TEST_P()
2551 ASSERT_EQ(3, handles_.size()); in TEST_P()
2623 ASSERT_EQ(3, handles_.size()); in TEST_P()
2693 ASSERT_EQ(3, handles_.size()); in TEST_P()
[all …]
Ddb_universal_compaction_test.cc367 dbfull()->TEST_WaitForFlushMemTable(handles_[1]); in TEST_P()
425 dbfull()->TEST_WaitForFlushMemTable(handles_[1]); in TEST_P()
441 ->GetOptions(handles_[1]) in TEST_P()
444 ASSERT_OK(dbfull()->SetOptions(handles_[1], in TEST_P()
448 ->GetOptions(handles_[1]) in TEST_P()
518 handles_[1], in TEST_P()
522 ->GetOptions(handles_[1]) in TEST_P()
526 ->GetOptions(handles_[1]) in TEST_P()
581 dbfull()->TEST_WaitForFlushMemTable(handles_[1]); in TEST_P()
605 CompactionOptions(), handles_[1], in TEST_P()
[all …]
Ddb_bloom_filter_test.cc876 ASSERT_OK(dbfull()->DropColumnFamily(handles_[1])); in TEST_F()
877 dbfull()->DestroyColumnFamilyHandle(handles_[1]); in TEST_F()
878 handles_[1] = nullptr; in TEST_F()
1809 db_->NewIterator(read_options, handles_[2])); in TEST_F()
1821 db_->NewIterator(read_options, handles_[2])); in TEST_F()
1826 ASSERT_OK(dbfull()->DropColumnFamily(handles_[2])); in TEST_F()
1827 dbfull()->DestroyColumnFamilyHandle(handles_[2]); in TEST_F()
1828 handles_[2] = nullptr; in TEST_F()
1829 ASSERT_OK(dbfull()->DropColumnFamily(handles_[1])); in TEST_F()
1830 dbfull()->DestroyColumnFamilyHandle(handles_[1]); in TEST_F()
[all …]
Dimport_column_family_test.cc73 SstFileWriter sfw_cf1(EnvOptions(), options, handles_[1]); in TEST_F()
136 SstFileWriter sfw_cf1(EnvOptions(), options, handles_[1]); in TEST_F()
279 db_->CompactRange(CompactRangeOptions(), handles_[1], nullptr, nullptr)); in TEST_F()
297 ASSERT_OK(checkpoint->ExportColumnFamily(handles_[1], export_files_dir_, in TEST_F()
388 db_->CompactRange(CompactRangeOptions(), handles_[1], nullptr, nullptr)); in TEST_F()
407 ASSERT_OK(checkpoint->ExportColumnFamily(handles_[1], export_files_dir_, in TEST_F()
462 SstFileWriter sfw_cf1(EnvOptions(), options, handles_[1]); in TEST_F()
494 SstFileWriter sfw_cf1(EnvOptions(), mismatch_options, handles_[1]); in TEST_F()
516 SstFileWriter sfw_cf1(EnvOptions(), options, handles_[1]); in TEST_F()
Ddb_test.cc504 ASSERT_OK(db_->Put(wopt, handles_[1], "bar", "one")); in TEST_F()
523 multiget_cfs.push_back(handles_[1]); in TEST_F()
524 multiget_cfs.push_back(handles_[1]); in TEST_F()
558 multiget_cfs.push_back(handles_[1]); in TEST_F()
573 ASSERT_OK(db_->Delete(wopt, handles_[1], "foo")); in TEST_F()
575 ASSERT_OK(db_->Delete(wopt, handles_[1], "bar")); in TEST_F()
4149 db_->DropColumnFamily(handles_[2]); in TEST_F()
4150 delete handles_[2]; in TEST_F()
4151 handles_.erase(handles_.begin() + 2); in TEST_F()
5839 batch.Put(handles_[0], Slice(data), Slice(data)); in TEST_F()
[all …]
Ddb_io_failure_test.cc299 dbfull()->TEST_WaitForFlushMemTable(handles_[1]); in TEST_F()
350 dbfull()->TEST_WaitForFlushMemTable(handles_[1]); in TEST_F()
362 ASSERT_OK(dbfull()->SetOptions(handles_[1], in TEST_F()
405 dbfull()->TEST_WaitForFlushMemTable(handles_[1]); in TEST_F()
453 ASSERT_OK(dbfull()->SetOptions(handles_[1], in TEST_F()
496 dbfull()->TEST_WaitForFlushMemTable(handles_[1]); in TEST_F()
545 ASSERT_OK(dbfull()->SetOptions(handles_[1], in TEST_F()
Ddb_test2.cc220 dbfull()->TEST_WaitForFlushMemTable(handles_[0]); in TEST_P()
221 dbfull()->TEST_WaitForFlushMemTable(handles_[1]); in TEST_P()
222 dbfull()->TEST_WaitForFlushMemTable(handles_[2]); in TEST_P()
968 db_->Flush(FlushOptions(), handles_[0]); in TEST_F()
2757 it = db_->NewIterator(ropt, handles_[1]); in TEST_F()
2776 it = db_->NewIterator(ropt, handles_[1]); in TEST_F()
2788 it = db_->NewIterator(ropt, handles_[1]); in TEST_F()
3798 ASSERT_EQ(handles_.size(), 2); in TEST_F()
3984 for (auto h : handles_) { in TEST_F()
3987 handles_.clear(); in TEST_F()
[all …]
Dlistener_test.cc115 test_->dbfull()->TEST_GetFilesMetaData(test_->handles_[ci.cf_id], in OnCompactionCompleted()
199 ASSERT_OK(dbfull()->CompactRange(CompactRangeOptions(), handles_[i], in TEST_F()
275 test_->dbfull()->TEST_GetFilesMetaData(test_->handles_[info.cf_id], in OnFlushCompleted()
493 db_->GetColumnFamilyMetaData(handles_[1], &cf_meta); in TEST_F()
501 db_->Flush(fo, handles_[1]); in TEST_F()
502 db_->GetColumnFamilyMetaData(handles_[1], &cf_meta); in TEST_F()
875 ASSERT_EQ(handles_.size(), 4); in TEST_F()
876 delete handles_[3]; in TEST_F()
877 delete handles_[2]; in TEST_F()
878 delete handles_[1]; in TEST_F()
[all …]
Ddeletefile_test.cc497 ASSERT_OK(db_->Put(WriteOptions(), handles_[1], test::RandomKey(&rnd, 10), in TEST_F()
500 ASSERT_OK(db_->Flush(FlushOptions(), handles_[1])); in TEST_F()
502 ASSERT_OK(db_->Put(WriteOptions(), handles_[1], test::RandomKey(&rnd, 10), in TEST_F()
505 ASSERT_OK(db_->Flush(FlushOptions(), handles_[1])); in TEST_F()
522 std::unique_ptr<Iterator> itr(db_->NewIterator(ReadOptions(), handles_[1])); in TEST_F()
535 std::unique_ptr<Iterator> itr(db_->NewIterator(ReadOptions(), handles_[1])); in TEST_F()
Ddb_with_timestamp_basic_test.cc466 size_t num_cfs = handles_.size(); in TEST_P()
491 ColumnFamilyHandle* cfh = handles_[cf]; in TEST_P()
578 size_t num_cfs = handles_.size(); in TEST_P()
614 verify_records_func(i, memtable_get_start, j, handles_[cf]); in TEST_P()
627 db_->CompactFiles(compact_opt, handles_[cf], in TEST_P()
643 ColumnFamilyHandle* cfh = handles_[cf]; in TEST_P()
671 size_t num_cfs = handles_.size(); in TEST_F()
715 batch.Put(handles_[cf], Key1(j), in TEST_F()
721 verify_records_func(i, handles_[cf]); in TEST_F()
733 ColumnFamilyHandle* cfh = handles_[cf]; in TEST_F()
Ddb_iterator_test.cc99 auto* iter = db_->NewIterator(ropt, handles_[1]); in TEST_P()
137 iter = NewIterator(non_blocking_opts, handles_[1]); in TEST_P()
154 iter = NewIterator(non_blocking_opts, handles_[1]); in TEST_P()
561 iter = NewIterator(ReadOptions(), handles_[1]); in TEST_P()
572 iter = NewIterator(ReadOptions(), handles_[1]); in TEST_P()
589 iter = NewIterator(ReadOptions(), handles_[1]); in TEST_P()
604 iter = NewIterator(ReadOptions(), handles_[1]); in TEST_P()
813 ColumnFamilyHandle* cf = handles_[1]; in TEST_P()
822 handles_.erase(std::begin(handles_) + 1); in TEST_P()
836 ColumnFamilyHandle* cf = handles_[1]; in TEST_P()
[all …]
Ddb_options_test.cc113 ASSERT_OK(dbfull()->SetOptions(handles_[0], options_default)); in TEST_F()
114 ASSERT_OK(dbfull()->SetOptions(handles_[1], options_foo)); in TEST_F()
116 GetMutableCFOptionsMap(dbfull()->GetOptions(handles_[0]))); in TEST_F()
118 GetMutableCFOptionsMap(dbfull()->GetOptions(handles_[1]))); in TEST_F()
492 for (size_t cf = 0; cf < handles_.size(); ++cf) { in TEST_F()
498 for (size_t cf = 0; cf < handles_.size(); ++cf) { in TEST_F()
499 dbfull()->TEST_WaitForFlushMemTable(handles_[cf]); in TEST_F()
Ddb_wal_test.cc140 ASSERT_OK(dbfull()->Put(writeOpt, handles_[1], "foo", "v1")); in TEST_F()
141 ASSERT_OK(dbfull()->Put(writeOpt, handles_[1], "bar", "v1")); in TEST_F()
148 ASSERT_OK(dbfull()->Put(writeOpt, handles_[1], "bar", "v2")); in TEST_F()
150 ASSERT_OK(dbfull()->Put(writeOpt, handles_[1], "foo", "v2")); in TEST_F()
158 ASSERT_OK(dbfull()->Put(writeOpt, handles_[1], "bar", "v3")); in TEST_F()
160 ASSERT_OK(dbfull()->Put(writeOpt, handles_[1], "foo", "v3")); in TEST_F()
315 dbfull()->TEST_GetFilesMetaData(handles_[1], &files); in TEST_F()
737 dbfull()->TEST_WaitForFlushMemTable(handles_[2]); in TEST_F()
791 dbfull()->TEST_WaitForFlushMemTable(handles_[3]); in TEST_F()
811 dbfull()->TEST_WaitForFlushMemTable(handles_[3]); in TEST_F()
/rocksdb-6.9/db/compaction/
Dcompaction_job_stats_test.cc89 std::vector<ColumnFamilyHandle*> handles_; member in ROCKSDB_NAMESPACE::CompactionJobStatsTest
136 size_t cfi = handles_.size(); in CreateColumnFamilies()
137 handles_.resize(cfi + cfs.size()); in CreateColumnFamilies()
186 for (auto h : handles_) { in Close()
189 handles_.clear(); in Close()
219 return db_->Flush(FlushOptions(), handles_[cf]); in Flush()
229 return db_->Put(wo, handles_[cf], k, v); in Put()
237 return db_->Delete(WriteOptions(), handles_[cf], k); in Delete()
260 Status s = db_->Get(options, handles_[cf], k, &result); in Get()
308 db_->GetApproximateSizes(handles_[1], &r, 1, &size); in Size()
[all …]
/rocksdb-6.9/utilities/checkpoint/
Dcheckpoint_test.cc46 std::vector<ColumnFamilyHandle*> handles_; member in ROCKSDB_NAMESPACE::CheckpointTest
111 size_t cfi = handles_.size(); in CreateColumnFamilies()
112 handles_.resize(cfi + cfs.size()); in CreateColumnFamilies()
114 ASSERT_OK(db_->CreateColumnFamily(cf_opts, cf, &handles_[cfi++])); in CreateColumnFamilies()
161 for (auto h : handles_) { in CompactAll()
167 for (auto h : handles_) { in Close()
170 handles_.clear(); in Close()
210 return db_->Flush(FlushOptions(), handles_[cf]); in Flush()
220 return db_->Put(wo, handles_[cf], k, v); in Put()
228 return db_->Delete(WriteOptions(), handles_[cf], k); in Delete()
[all …]
/rocksdb-6.9/utilities/transactions/
Dwrite_unprepared_txn.cc412 const std::map<uint32_t, ColumnFamilyHandle*>& handles_; in FlushWriteBatchWithSavePointToDB() member
417 : wb_(wb), handles_(handles) {} in FlushWriteBatchWithSavePointToDB()
420 return wb_->Put(handles_.at(cf), key, value); in FlushWriteBatchWithSavePointToDB()
424 return wb_->Delete(handles_.at(cf), key); in FlushWriteBatchWithSavePointToDB()
428 return wb_->SingleDelete(handles_.at(cf), key); in FlushWriteBatchWithSavePointToDB()
432 return wb_->Merge(handles_.at(cf), key, value); in FlushWriteBatchWithSavePointToDB()
Dwrite_unprepared_txn_db.cc70 std::map<uint32_t, ColumnFamilyHandle*>& handles_; in RollbackRecoveredTransaction() member
84 handles_(handles), in RollbackRecoveredTransaction()
102 auto cf_handle = handles_[cf]; in RollbackRecoveredTransaction()

12