Lines Matching refs:read_options
1448 InternalIterator* DBImpl::NewInternalIterator(const ReadOptions& read_options, in NewInternalIterator() argument
1460 !read_options.total_order_seek && in NewInternalIterator()
1464 super_version->mem->NewIterator(read_options, arena)); in NewInternalIterator()
1467 if (!read_options.ignore_range_deletions) { in NewInternalIterator()
1469 super_version->mem->NewRangeTombstoneIterator(read_options, sequence)); in NewInternalIterator()
1474 super_version->imm->AddIterators(read_options, &merge_iter_builder); in NewInternalIterator()
1475 if (!read_options.ignore_range_deletions) { in NewInternalIterator()
1476 s = super_version->imm->AddRangeTombstoneIterators(read_options, arena, in NewInternalIterator()
1483 if (read_options.read_tier != kMemtableTier) { in NewInternalIterator()
1484 super_version->current->AddIterators(read_options, file_options_, in NewInternalIterator()
1490 read_options.background_purge_on_iterator_cleanup || in NewInternalIterator()
1509 Status DBImpl::Get(const ReadOptions& read_options, in Get() argument
1512 return Get(read_options, column_family, key, value, /*timestamp=*/nullptr); in Get()
1515 Status DBImpl::Get(const ReadOptions& read_options, in Get() argument
1522 Status s = GetImpl(read_options, key, get_impl_options); in Get()
1526 Status DBImpl::GetImpl(const ReadOptions& read_options, const Slice& key, in GetImpl() argument
1554 if (read_options.snapshot != nullptr) { in GetImpl()
1560 reinterpret_cast<const SnapshotImpl*>(read_options.snapshot)->number_; in GetImpl()
1601 LookupKey lkey(key, snapshot, read_options.timestamp); in GetImpl()
1604 bool skip_memtable = (read_options.read_tier == kPersistedTier && in GetImpl()
1616 read_options, get_impl_options.callback, in GetImpl()
1624 &max_covering_tombstone_seq, read_options, in GetImpl()
1636 read_options, nullptr, nullptr, false)) { in GetImpl()
1642 read_options)) { in GetImpl()
1655 read_options, lkey, get_impl_options.value, timestamp, &s, in GetImpl()
1701 const ReadOptions& read_options, in MultiGet() argument
1704 return MultiGet(read_options, column_family, keys, values, in MultiGet()
1709 const ReadOptions& read_options, in MultiGet() argument
1738 read_options, nullptr, iter_deref_lambda, &multiget_cf_data, in MultiGet()
1767 LookupKey lkey(keys[i], consistent_seqnum, read_options.timestamp); in MultiGet()
1775 (read_options.read_tier == kPersistedTier && in MultiGet()
1780 &max_covering_tombstone_seq, read_options)) { in MultiGet()
1785 &max_covering_tombstone_seq, read_options)) { in MultiGet()
1793 super_version->current->Get(read_options, lkey, &pinnable_val, timestamp, in MultiGet()
1831 const ReadOptions& read_options, ReadCallback* callback, in MultiCFSnapshot() argument
1844 if (read_options.snapshot != nullptr) { in MultiCFSnapshot()
1854 static_cast<const SnapshotImpl*>(read_options.snapshot)->number_; in MultiCFSnapshot()
1895 if (read_options.snapshot == nullptr) { in MultiCFSnapshot()
1906 *snapshot = reinterpret_cast<const SnapshotImpl*>(read_options.snapshot) in MultiCFSnapshot()
1918 if (read_options.snapshot != nullptr || last_try) { in MultiCFSnapshot()
1953 void DBImpl::MultiGet(const ReadOptions& read_options, const size_t num_keys, in MultiGet() argument
1957 return MultiGet(read_options, num_keys, column_families, keys, values, in MultiGet()
1961 void DBImpl::MultiGet(const ReadOptions& read_options, const size_t num_keys, in MultiGet() argument
2010 read_options, nullptr, iter_deref_lambda, &multiget_cf_data, in MultiGet()
2015 MultiGetImpl(read_options, cf_iter->start, cf_iter->num_keys, &sorted_keys, in MultiGet()
2089 void DBImpl::MultiGet(const ReadOptions& read_options, in MultiGet() argument
2093 return MultiGet(read_options, column_family, num_keys, keys, values, in MultiGet()
2097 void DBImpl::MultiGet(const ReadOptions& read_options, in MultiGet() argument
2114 MultiGetWithCallback(read_options, column_family, nullptr, &sorted_keys); in MultiGet()
2118 const ReadOptions& read_options, ColumnFamilyHandle* column_family, in MultiGetWithCallback() argument
2133 read_options, callback, iter_deref_lambda, &multiget_cf_data, in MultiGetWithCallback()
2142 if (callback && read_options.snapshot == nullptr) { in MultiGetWithCallback()
2161 MultiGetImpl(read_options, 0, num_keys, sorted_keys, in MultiGetWithCallback()
2169 const ReadOptions& read_options, size_t start_key, size_t num_keys, in MultiGetImpl() argument
2198 (read_options.read_tier == kPersistedTier && in MultiGetImpl()
2201 super_version->mem->MultiGet(read_options, &range, callback, in MultiGetImpl()
2204 super_version->imm->MultiGet(read_options, &range, callback, in MultiGetImpl()
2215 super_version->current->MultiGet(read_options, &range, callback, in MultiGetImpl()
2495 bool DBImpl::KeyMayExist(const ReadOptions& read_options, in KeyMayExist() argument
2504 ReadOptions roptions = read_options; in KeyMayExist()
2521 Iterator* DBImpl::NewIterator(const ReadOptions& read_options, in NewIterator() argument
2523 if (read_options.managed) { in NewIterator()
2528 if (read_options.read_tier == kPersistedTier) { in NewIterator()
2535 read_options.iter_start_seqnum > 0 && in NewIterator()
2536 read_options.iter_start_seqnum < preserve_deletes_seqnum_.load()) { in NewIterator()
2544 if (read_options.tailing) { in NewIterator()
2551 auto iter = new ForwardIterator(this, read_options, cfd, sv); in NewIterator()
2553 env_, read_options, *cfd->ioptions(), sv->mutable_cf_options, in NewIterator()
2562 auto snapshot = read_options.snapshot != nullptr in NewIterator()
2563 ? read_options.snapshot->GetSequenceNumber() in NewIterator()
2565 result = NewIteratorImpl(read_options, cfd, snapshot, read_callback); in NewIterator()
2570 ArenaWrappedDBIter* DBImpl::NewIteratorImpl(const ReadOptions& read_options, in NewIteratorImpl() argument
2621 env_, read_options, *cfd->ioptions(), sv->mutable_cf_options, snapshot, in NewIteratorImpl()
2624 read_options.snapshot != nullptr ? false : allow_refresh); in NewIteratorImpl()
2627 NewInternalIterator(read_options, cfd, sv, db_iter->GetArena(), in NewIteratorImpl()
2635 const ReadOptions& read_options, in NewIterators() argument
2638 if (read_options.managed) { in NewIterators()
2641 if (read_options.read_tier == kPersistedTier) { in NewIterators()
2648 if (read_options.tailing) { in NewIterators()
2656 auto iter = new ForwardIterator(this, read_options, cfd, sv); in NewIterators()
2658 env_, read_options, *cfd->ioptions(), sv->mutable_cf_options, in NewIterators()
2668 auto snapshot = read_options.snapshot != nullptr in NewIterators()
2669 ? read_options.snapshot->GetSequenceNumber() in NewIterators()
2675 NewIteratorImpl(read_options, cfd, snapshot, read_callback)); in NewIterators()
3150 const TransactionLogIterator::ReadOptions& read_options) { in GetUpdatesSince() argument
3155 return wal_manager_.GetUpdatesSince(seq, iter, read_options, versions_.get()); in GetUpdatesSince()
3861 ReadOptions read_options; in GetLatestSequenceForKey() local
3870 &max_covering_tombstone_seq, seq, read_options, in GetLatestSequenceForKey()
3897 &max_covering_tombstone_seq, seq, read_options, in GetLatestSequenceForKey()
3924 &max_covering_tombstone_seq, seq, read_options, in GetLatestSequenceForKey()
3951 sv->current->Get(read_options, lkey, nullptr, nullptr, &s, &merge_context, in GetLatestSequenceForKey()
4397 Status DBImpl::VerifyChecksum(const ReadOptions& read_options) { in VerifyChecksum() argument
4429 read_options, fname); in VerifyChecksum()