Home
last modified time | relevance | path

Searched refs:read_opts (Results 1 – 18 of 18) sorted by relevance

/rocksdb-6.9/db/
Ddb_range_del_test.cc274 ReadOptions read_opts; in TEST_F() local
484 ReadOptions read_opts; in TEST_F() local
519 ReadOptions read_opts; in TEST_F() local
610 ReadOptions read_opts; in TEST_F() local
701 ReadOptions read_opts; in TEST_F() local
734 ReadOptions read_opts; in TEST_F() local
760 ReadOptions read_opts; in TEST_F() local
794 ReadOptions read_opts; in TEST_F() local
828 ReadOptions read_opts; in TEST_F() local
1424 ReadOptions read_opts; in TEST_F() local
[all …]
Ddb_with_timestamp_basic_test.cc199 ReadOptions read_opts; in TEST_F() local
201 read_opts.timestamp = &read_ts; in TEST_F()
278 ReadOptions read_opts; in TEST_F() local
281 read_opts.timestamp = &read_ts; in TEST_F()
320 ReadOptions read_opts; in TEST_F() local
323 read_opts.timestamp = &ts; in TEST_F()
367 ReadOptions read_opts; in TEST_F() local
370 read_opts.timestamp = &ts; in TEST_F()
407 ReadOptions read_opts; in TEST_F() local
411 read_opts.timestamp = &ts; in TEST_F()
[all …]
Dmemtable_list.h64 const ReadOptions& read_opts, ReadCallback* callback = nullptr,
70 const ReadOptions& read_opts, ReadCallback* callback = nullptr,
74 max_covering_tombstone_seq, &seq, read_opts, callback,
86 const ReadOptions& read_opts);
96 SequenceNumber* seq, const ReadOptions& read_opts,
102 const ReadOptions& read_opts,
106 max_covering_tombstone_seq, &seq, read_opts,
110 Status AddRangeTombstoneIterators(const ReadOptions& read_opts, Arena* arena,
157 SequenceNumber* seq, const ReadOptions& read_opts,
Dmemtable_list.cc110 SequenceNumber* seq, const ReadOptions& read_opts, in Get() argument
113 max_covering_tombstone_seq, seq, read_opts, callback, in Get()
130 SequenceNumber* max_covering_tombstone_seq, const ReadOptions& read_opts) { in GetMergeOperands() argument
134 read_opts, nullptr, nullptr, false); in GetMergeOperands()
145 SequenceNumber* seq, const ReadOptions& read_opts, bool* is_blob_index) { in GetFromHistory() argument
147 max_covering_tombstone_seq, seq, read_opts, in GetFromHistory()
163 read_opts, callback, is_blob_index); in GetFromList()
187 const ReadOptions& read_opts, Arena* /*arena*/, in AddRangeTombstoneIterators() argument
192 SequenceNumber read_seq = read_opts.snapshot != nullptr in AddRangeTombstoneIterators()
193 ? read_opts.snapshot->GetSequenceNumber() in AddRangeTombstoneIterators()
[all …]
Dmemtable.h214 const ReadOptions& read_opts, ReadCallback* callback = nullptr,
217 max_covering_tombstone_seq, seq, read_opts, callback,
224 const ReadOptions& read_opts, ReadCallback* callback = nullptr,
230 const ReadOptions& read_opts, ReadCallback* callback = nullptr,
234 max_covering_tombstone_seq, &seq, read_opts, callback,
Dcolumn_family.cc1076 ReadOptions read_opts; in RangesOverlapWithMemtables() local
1077 read_opts.total_order_seek = true; in RangesOverlapWithMemtables()
1080 super_version->mem->NewIterator(read_opts, &arena)); in RangesOverlapWithMemtables()
1081 super_version->imm->AddIterators(read_opts, &merge_iter_builder); in RangesOverlapWithMemtables()
1087 super_version->mem->NewRangeTombstoneIterator(read_opts, read_seq); in RangesOverlapWithMemtables()
1090 super_version->imm->AddRangeTombstoneIterators(read_opts, nullptr /* arena */, in RangesOverlapWithMemtables()
Ddb_basic_test.cc1829 ReadOptions read_opts; in TEST_F() local
1830 read_opts.total_order_seek = true; in TEST_F()
1832 std::unique_ptr<Iterator> iter(db_->NewIterator(read_opts, handles_[0])); 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()
1879 ReadOptions read_opts; in TEST_F() local
1880 read_opts.total_order_seek = true; in TEST_F()
1881 std::unique_ptr<Iterator> iter(db_->NewIterator(read_opts, handles_[0])); in TEST_F()
1884 iter.reset(db_->NewIterator(read_opts, handles_[1])); in TEST_F()
Dmemtable.cc782 SequenceNumber* seq, const ReadOptions& read_opts, in Get() argument
792 NewRangeTombstoneIterator(read_opts, in Get()
Dexternal_sst_file_test.cc2498 ReadOptions read_opts; in TEST_P() local
2499 read_opts.total_order_seek = true; in TEST_P()
2500 read_opts.snapshot = dbfull()->GetSnapshot(); in TEST_P()
2505 iters[i] = dbfull()->NewIterator(read_opts, handles_[i]); in TEST_P()
2544 dbfull()->ReleaseSnapshot(read_opts.snapshot); in TEST_P()
Ddb_iterator_test.cc2838 ReadOptions read_opts; in TEST_P() local
2839 read_opts.iterate_lower_bound = &lower_bound; in TEST_P()
2840 std::unique_ptr<Iterator> iter(NewIterator(read_opts)); in TEST_P()
/rocksdb-6.9/db/db_impl/
Ddb_secondary_test.cc658 ReadOptions read_opts; in TEST_F() local
659 read_opts.verify_checksums = true; in TEST_F()
660 std::unique_ptr<Iterator> it1(db1->NewIterator(read_opts)); in TEST_F()
661 std::unique_ptr<Iterator> it2(db2->NewIterator(read_opts)); in TEST_F()
673 ASSERT_OK(db2->Get(read_opts, it1->key(), &value)); in TEST_F()
678 ASSERT_OK(db1->Get(read_opts, it2->key(), &value)); in TEST_F()
717 ReadOptions read_opts; in TEST_F() local
718 read_opts.verify_checksums = true; in TEST_F()
734 ASSERT_OK(db2->Get(read_opts, handles2[i], it1->key(), &value)); in TEST_F()
739 ASSERT_OK(db1->Get(read_opts, handles1[i], it2->key(), &value)); in TEST_F()
[all …]
/rocksdb-6.9/db_stress_tool/
Dno_batched_ops_stress.cc140 Status TestGet(ThreadState* thread, const ReadOptions& read_opts, in TestGet() argument
147 Status s = db_->Get(read_opts, cfh, key, &from_db); in TestGet()
163 ThreadState* thread, const ReadOptions& read_opts, in TestMultiGet() argument
234 db_->MultiGet(read_opts, cfh, num_keys, keys.data(), values.data(), in TestMultiGet()
238 txn->MultiGet(read_opts, cfh, num_keys, keys.data(), values.data(), in TestMultiGet()
263 Status TestPrefixScan(ThreadState* thread, const ReadOptions& read_opts, in TestPrefixScan() argument
273 ReadOptions ro_copy = read_opts; in TestPrefixScan()
303 const ReadOptions& read_opts, in TestPut() argument
328 Status s = db_->Get(read_opts, cfh, k, &from_db); in TestPut()
329 if (!VerifyValue(rand_column_family, rand_key, read_opts, shared, from_db, in TestPut()
Ddb_stress_test_base.h72 virtual Status TestGet(ThreadState* thread, const ReadOptions& read_opts,
77 ThreadState* thread, const ReadOptions& read_opts,
82 const ReadOptions& read_opts,
87 const ReadOptions& read_opts,
143 virtual Status TestIterate(ThreadState* thread, const ReadOptions& read_opts,
Ddb_stress_test_base.cc489 ReadOptions read_opts(FLAGS_verify_checksum, true); in OperateDb() local
698 TestMultiGet(thread, read_opts, rand_column_families, rand_keys); in OperateDb()
701 TestGet(thread, read_opts, rand_column_families, rand_keys); in OperateDb()
710 TestPrefixScan(thread, read_opts, rand_column_families, rand_keys); in OperateDb()
714 TestPut(thread, write_opts, read_opts, rand_column_families, rand_keys, in OperateDb()
733 TestIterate(thread, read_opts, rand_column_families, rand_keys); in OperateDb()
815 const ReadOptions& read_opts, in TestIterate() argument
820 ReadOptions readoptionscopy = read_opts; in TestIterate()
Dcf_consistency_stress.cc203 ThreadState* thread, const ReadOptions& read_opts, in TestMultiGet() argument
219 db_->MultiGet(read_opts, cfh, num_keys, keys.data(), values.data(), in TestMultiGet()
/rocksdb-6.9/utilities/checkpoint/
Dcheckpoint_test.cc741 ReadOptions read_opts; in TEST_F() local
743 ASSERT_OK(snapshot_db->Get(read_opts, "key1", &get_result)); in TEST_F()
764 ReadOptions read_opts; in TEST_F() local
766 ASSERT_OK(snapshot_db->Get(read_opts, "foo", &get_result)); in TEST_F()
798 ReadOptions read_opts; in TEST_F() local
801 s = snapshot_db->Get(read_opts, snapshot_handles[i], "foo", &get_result); in TEST_F()
/rocksdb-6.9/java/rocksjni/
Drocksjni.cc1828 ROCKSDB_NAMESPACE::ReadOptions read_opts = in key_may_exist_helper() local
1845 read_opts, cf_handle, key_slice, value, value_found); in key_may_exist_helper()
/rocksdb-6.9/tools/
Ddb_bench_tool.cc4087 ReadOptions read_opts; in InitializeOptionsGeneral() local
4088 read_opts.total_order_seek = true; in InitializeOptionsGeneral()
4089 Iterator* iter = db_.db->NewIterator(read_opts); in InitializeOptionsGeneral()