Home
last modified time | relevance | path

Searched refs:read_options (Results 1 – 25 of 88) sorted by relevance

1234

/rocksdb-6.9/db/
Ddb_tailing_iter_test.cc27 ReadOptions read_options; in TEST_F() local
28 read_options.tailing = true; in TEST_F()
46 ReadOptions read_options; in TEST_F() local
47 read_options.tailing = true; in TEST_F()
68 ReadOptions read_options; in TEST_F() local
69 read_options.tailing = true; in TEST_F()
131 ReadOptions read_options; in TEST_F() local
260 ReadOptions read_options; in TEST_F() local
298 ReadOptions read_options; in TEST_F() local
331 ReadOptions read_options; in TEST_F() local
[all …]
Dprefix_test.cc179 Status s = db->Get(read_options, key, &result); in Get()
306 ReadOptions read_options; in TEST() local
356 ReadOptions read_options; in TEST_F() local
386 iter.reset(db->NewIterator(read_options)); in TEST_F()
529 ReadOptions read_options; in TEST_F() local
546 read_options.prefix_same_as_start = true; in TEST_F()
581 ReadOptions read_options; in TEST_F() local
688 ReadOptions read_options; in TEST_F() local
804 ReadOptions read_options; in TEST_F() local
837 ReadOptions read_options; in TEST_F() local
[all …]
Ddb_bloom_filter_test.cc1539 ReadOptions read_options; in TEST_F() local
1547 ReadOptions read_options; in TEST_F() local
1561 ReadOptions read_options; in TEST_F() local
1575 ReadOptions read_options; in TEST_F() local
1588 ReadOptions read_options; in TEST_F() local
1603 ReadOptions read_options; in TEST_F() local
1618 ReadOptions read_options; in TEST_F() local
1631 ReadOptions read_options; in TEST_F() local
1661 ReadOptions read_options; in TEST_F() local
1793 ReadOptions read_options; in TEST_F() local
[all …]
Ddb_block_cache_test.cc150 ReadOptions read_options; in TEST_F() local
151 read_options.fill_cache = false; in TEST_F()
166 iter = db_->NewIterator(read_options); in TEST_F()
175 ReadOptions read_options; in TEST_F() local
204 iter = db_->NewIterator(read_options); in TEST_F()
228 ReadOptions read_options; in TEST_F() local
267 iter = db_->NewIterator(read_options); in TEST_F()
278 iter = db_->NewIterator(read_options); in TEST_F()
347 ReadOptions read_options; in TEST_F() local
348 read_options.fill_cache = false; in TEST_F()
[all …]
Ddeletefile_test.cc237 ReadOptions read_options; in TEST_F() local
238 read_options.background_purge_on_iterator_cleanup = true; in TEST_F()
239 itr = db_->NewIterator(read_options); in TEST_F()
344 ReadOptions read_options; in TEST_F() local
346 itr = db_->NewIterator(read_options); in TEST_F()
382 ReadOptions read_options; in TEST_F() local
383 read_options.background_purge_on_iterator_cleanup = true; in TEST_F()
384 Iterator* itr1 = db_->NewIterator(read_options); in TEST_F()
386 Iterator* itr2 = db_->NewIterator(read_options); in TEST_F()
418 ReadOptions read_options; in TEST_F() local
[all …]
Darena_wrapped_db_iter.cc33 void ArenaWrappedDBIter::Init(Env* env, const ReadOptions& read_options, in Init() argument
43 db_iter_ = new (mem) DBIter(env, read_options, cf_options, mutable_cf_options, in Init()
88 Env* env, const ReadOptions& read_options, in NewArenaWrappedDbIterator() argument
95 iter->Init(env, read_options, cf_options, mutable_cf_options, sequence, in NewArenaWrappedDbIterator()
99 iter->StoreRefreshInfo(read_options, db_impl, cfd, read_callback, in NewArenaWrappedDbIterator()
Dperf_context_test.cc73 ReadOptions read_options; in TEST_F() local
96 auto status = db->Get(read_options, key, &value); in TEST_F()
110 std::unique_ptr<Iterator> iter(db->NewIterator(read_options)); in TEST_F()
212 ReadOptions read_options; in ProfileQueries() local
307 ASSERT_OK(db->Get(read_options, key, &value)); in ProfileQueries()
317 db->MultiGet(read_options, multiget_keys, &values); in ProfileQueries()
421 ASSERT_OK(db->Get(read_options, key, &value)); in ProfileQueries()
431 db->MultiGet(read_options, multiget_keys, &values); in ProfileQueries()
515 ReadOptions read_options; in TEST_F() local
823 ReadOptions read_options; in TEST_F() local
[all …]
Dwrite_callback_test.cc156 ReadOptions read_options; in TEST_F() local
353 db->Get(read_options, kvp.first, &value).IsNotFound()); in TEST_F()
355 ASSERT_OK(db->Get(read_options, kvp.first, &value)); in TEST_F()
378 ReadOptions read_options; in TEST_F() local
401 s = db->Get(read_options, "a", &value); in TEST_F()
415 s = db->Get(read_options, "a", &value); in TEST_F()
428 s = db->Get(read_options, "a", &value); in TEST_F()
Darena_wrapped_db_iter.h72 void Init(Env* env, const ReadOptions& read_options,
82 void StoreRefreshInfo(const ReadOptions& read_options, DBImpl* db_impl, in StoreRefreshInfo() argument
85 read_options_ = read_options; in StoreRefreshInfo()
108 Env* env, const ReadOptions& read_options,
/rocksdb-6.9/utilities/transactions/
Doptimistic_transaction_test.cc79 ReadOptions read_options; in TEST_P() local
100 txn_db->Get(read_options, "foo", &value); in TEST_P()
108 ReadOptions read_options; in TEST_P() local
142 ReadOptions read_options; in TEST_P() local
219 ReadOptions read_options; in TEST_P() local
340 ReadOptions read_options; in TEST_P() local
445 ReadOptions read_options; in TEST_P() local
739 ReadOptions read_options; in TEST_P() local
938 ReadOptions read_options; in TEST_P() local
1036 read_options.snapshot = snapshot; in TEST_P()
[all …]
Dtransaction_test.cc121 ReadOptions read_options; in TEST_P() local
155 ReadOptions read_options; in TEST_P() local
262 ReadOptions read_options; in TEST_P() local
356 ReadOptions read_options; in TEST_P() local
481 ReadOptions read_options; in TEST_P() local
693 ReadOptions read_options; in TEST_P() local
805 ReadOptions read_options; in TEST_P() local
1218 ReadOptions read_options; in TEST_P() local
1289 ReadOptions read_options; in TEST_P() local
1491 ReadOptions read_options; in TEST_P() local
[all …]
Dtransaction_base.cc241 Status TransactionBaseImpl::Get(const ReadOptions& read_options, in Get() argument
247 auto s = Get(read_options, column_family, key, &pinnable_val); in Get()
254 Status TransactionBaseImpl::Get(const ReadOptions& read_options, in Get() argument
266 if (!do_validate && read_options.snapshot != nullptr) { in GetForUpdate()
278 s = Get(read_options, column_family, key, &pinnable_val); in GetForUpdate()
292 if (!do_validate && read_options.snapshot != nullptr) { in GetForUpdate()
301 s = Get(read_options, column_family, key, pinnable_val); in GetForUpdate()
307 const ReadOptions& read_options, in MultiGet() argument
333 const ReadOptions& read_options, in MultiGetForUpdate() argument
361 Iterator* db_iter = db_->NewIterator(read_options); in GetIterator()
[all …]
/rocksdb-6.9/examples/
Dtransaction_example.cc29 ReadOptions read_options; in main() local
44 s = txn->Get(read_options, "abc", &value); in main()
52 s = txn_db->Get(read_options, "abc", &value); in main()
66 s = txn->Get(read_options, "xyz", &value); in main()
98 s = txn->Get(read_options, "abc", &value); in main()
103 read_options.snapshot = snapshot; in main()
104 s = txn->Get(read_options, "abc", &value); in main()
118 read_options.snapshot = nullptr; in main()
138 s = txn->Get(read_options, "x", &value); in main()
169 read_options.snapshot = nullptr; in main()
[all …]
Doptimistic_transaction_example.cc30 ReadOptions read_options; in main() local
45 s = txn->Get(read_options, "abc", &value); in main()
53 s = db->Get(read_options, "abc", &value); in main()
69 s = db->Get(read_options, "xyz", &value); in main()
73 s = db->Get(read_options, "abc", &value); in main()
95 read_options.snapshot = snapshot; in main()
109 read_options.snapshot = nullptr; in main()
140 s = db->Get(read_options, "x", &value); in main()
163 read_options.snapshot = nullptr; in main()
166 s = db->Get(read_options, "x", &value); in main()
[all …]
/rocksdb-6.9/db/db_impl/
Ddb_impl_readonly.cc30 Status DBImplReadOnly::Get(const ReadOptions& read_options, in Get() argument
53 &max_covering_tombstone_seq, read_options)) { in Get()
58 super_version->current->Get(read_options, lkey, pinnable_val, in Get()
71 Iterator* DBImplReadOnly::NewIterator(const ReadOptions& read_options, in NewIterator() argument
78 read_options.snapshot != nullptr in NewIterator()
79 ? reinterpret_cast<const SnapshotImpl*>(read_options.snapshot) in NewIterator()
84 env_, read_options, *cfd->ioptions(), super_version->mutable_cf_options, in NewIterator()
96 const ReadOptions& read_options, in NewIterators() argument
107 read_options.snapshot != nullptr in NewIterators()
108 ? reinterpret_cast<const SnapshotImpl*>(read_options.snapshot) in NewIterators()
[all …]
Ddb_impl_secondary.cc314 return GetImpl(read_options, column_family, key, value); in Get()
382 if (read_options.managed) { in NewIterator()
386 if (read_options.read_tier == kPersistedTier) { in NewIterator()
394 if (read_options.tailing) { in NewIterator()
397 } else if (read_options.snapshot != nullptr) { in NewIterator()
409 const ReadOptions& read_options, ColumnFamilyData* cfd, in NewIteratorImpl() argument
426 const ReadOptions& read_options, in NewIterators() argument
429 if (read_options.managed) { in NewIterators()
432 if (read_options.read_tier == kPersistedTier) { in NewIterators()
442 if (read_options.tailing) { in NewIterators()
[all …]
Ddb_impl.cc1460 !read_options.total_order_seek && in NewInternalIterator()
1554 if (read_options.snapshot != nullptr) { in GetImpl()
1701 const ReadOptions& read_options, in MultiGet() argument
1709 const ReadOptions& read_options, in MultiGet() argument
2504 ReadOptions roptions = read_options; in KeyMayExist()
2523 if (read_options.managed) { in NewIterator()
2544 if (read_options.tailing) { in NewIterator()
2635 const ReadOptions& read_options, in NewIterators() argument
2638 if (read_options.managed) { in NewIterators()
2648 if (read_options.tailing) { in NewIterators()
[all …]
/rocksdb-6.9/utilities/write_batch_with_index/
Dwrite_batch_with_index.cc37 const ReadOptions* read_options = nullptr) in BaseDeltaIterator() argument
45 iterate_upper_bound_(read_options ? read_options->iterate_upper_bound in BaseDeltaIterator()
662 const ReadOptions* read_options) { in NewIteratorWithBase() argument
669 read_options); in NewIteratorWithBase()
796 const ReadOptions& read_options, in GetFromBatchAndDB() argument
814 return GetFromBatchAndDB(db, read_options, db->DefaultColumnFamily(), key, in GetFromBatchAndDB()
827 GetFromBatchAndDB(db, read_options, column_family, key, &pinnable_val); in GetFromBatchAndDB()
884 s = db->Get(read_options, column_family, key, pinnable_val); in GetFromBatchAndDB()
891 ->GetImpl(read_options, key, get_impl_options); in GetFromBatchAndDB()
932 MultiGetFromBatchAndDB(db, read_options, column_family, num_keys, keys, in MultiGetFromBatchAndDB()
[all …]
/rocksdb-6.9/table/block_based/
Dindex_reader_common.cc14 const ReadOptions& read_options, bool use_cache, GetContext* get_context, in ReadIndexBlock() argument
27 prefetch_buffer, read_options, rep->footer.index_handle(), in ReadIndexBlock()
45 ReadOptions read_options; in GetOrReadIndexBlock() local
47 read_options.read_tier = kBlockCacheTier; in GetOrReadIndexBlock()
50 return ReadIndexBlock(table_, /*prefetch_buffer=*/nullptr, read_options, in GetOrReadIndexBlock()
Dfilter_block_reader_common.cc17 const ReadOptions& read_options, bool use_cache, GetContext* get_context, in ReadFilterBlock() argument
30 table->RetrieveBlock(prefetch_buffer, read_options, rep->filter_handle, in ReadFilterBlock()
77 ReadOptions read_options; in GetOrReadFilterBlock() local
79 read_options.read_tier = kBlockCacheTier; in GetOrReadFilterBlock()
82 return ReadFilterBlock(table_, nullptr /* prefetch_buffer */, read_options, in GetOrReadFilterBlock()
Dblock_based_table_reader.cc876 ReadOptions read_options; in ReadRangeDelBlock() local
878 read_options, range_del_handle, in ReadRangeDelBlock()
1165 read_options.fill_cache) { in GetDataBlockFromCache()
2024 read_options.auto_prefix_mode || in NewIterator()
2027 read_options, in NewIterator()
2050 const ReadOptions& read_options) { in NewRangeTombstoneIterator() argument
2055 if (read_options.snapshot != nullptr) { in NewRangeTombstoneIterator()
2138 read_options.snapshot != nullptr; in Get()
2360 ReadOptions ro = read_options; in MultiGet()
2696 s = VerifyChecksumInBlocks(read_options, iiter); in VerifyChecksum()
[all …]
Duncompression_dict_reader.cc46 const ReadOptions& read_options, bool use_cache, GetContext* get_context, in ReadUncompressionDictionary() argument
60 prefetch_buffer, read_options, rep->compression_dict_handle, in ReadUncompressionDictionary()
87 ReadOptions read_options; in GetOrReadUncompressionDictionary() local
89 read_options.read_tier = kBlockCacheTier; in GetOrReadUncompressionDictionary()
92 return ReadUncompressionDictionary(table_, prefetch_buffer, read_options, in GetOrReadUncompressionDictionary()
/rocksdb-6.9/include/rocksdb/utilities/
Dwrite_batch_with_index.h206 Status GetFromBatchAndDB(DB* db, const ReadOptions& read_options,
210 Status GetFromBatchAndDB(DB* db, const ReadOptions& read_options,
213 Status GetFromBatchAndDB(DB* db, const ReadOptions& read_options,
218 Status GetFromBatchAndDB(DB* db, const ReadOptions& read_options,
222 void MultiGetFromBatchAndDB(DB* db, const ReadOptions& read_options,
264 Status GetFromBatchAndDB(DB* db, const ReadOptions& read_options,
267 void MultiGetFromBatchAndDB(DB* db, const ReadOptions& read_options,
/rocksdb-6.9/table/
Dmeta_blocks.cc211 ReadOptions read_options; in ReadProperties() local
212 read_options.verify_checksums = verify_checksum; in ReadProperties()
372 ReadOptions read_options; in ReadTableProperties() local
373 read_options.verify_checksums = false; in ReadTableProperties()
377 file, nullptr /* prefetch_buffer */, footer, read_options, in ReadTableProperties()
442 ReadOptions read_options; in FindMetaBlock() local
443 read_options.verify_checksums = false; in FindMetaBlock()
446 file, nullptr /* prefetch_buffer */, footer, read_options, in FindMetaBlock()
485 ReadOptions read_options; in ReadMetaBlock() local
486 read_options.verify_checksums = false; in ReadMetaBlock()
[all …]
/rocksdb-6.9/test_util/
Dtransaction_test_util.cc31 const ReadOptions& read_options, uint64_t num_keys, uint16_t num_sets, in RandomTransactionInserter() argument
35 read_options_(read_options), in RandomTransactionInserter()
88 DB* db, Transaction* txn, ReadOptions& read_options, uint16_t set_i, in DBGet() argument
107 s = txn->GetForUpdate(read_options, key, &value); in DBGet()
109 s = txn->Get(read_options, key, &value); in DBGet()
112 s = db->Get(read_options, key, &value); in DBGet()
315 ReadOptions read_options; in Verify() local

1234