Lines Matching refs:snapshot

1553   SequenceNumber snapshot;  in GetImpl()  local
1554 if (read_options.snapshot != nullptr) { in GetImpl()
1557 snapshot = get_impl_options.callback->max_visible_seq(); in GetImpl()
1559 snapshot = in GetImpl()
1560 reinterpret_cast<const SnapshotImpl*>(read_options.snapshot)->number_; in GetImpl()
1568 snapshot = last_seq_same_as_publish_seq_ in GetImpl()
1576 get_impl_options.callback->Refresh(snapshot); in GetImpl()
1587 snapshot = get_impl_options.callback->max_visible_seq(); in GetImpl()
1601 LookupKey lkey(key, snapshot, read_options.timestamp); in GetImpl()
1834 T* cf_list, SequenceNumber* snapshot) { in MultiCFSnapshot() argument
1844 if (read_options.snapshot != nullptr) { in MultiCFSnapshot()
1853 *snapshot = in MultiCFSnapshot()
1854 static_cast<const SnapshotImpl*>(read_options.snapshot)->number_; in MultiCFSnapshot()
1856 *snapshot = std::max(*snapshot, callback->max_visible_seq()); in MultiCFSnapshot()
1869 *snapshot = last_seq_same_as_publish_seq_ in MultiCFSnapshot()
1895 if (read_options.snapshot == nullptr) { in MultiCFSnapshot()
1902 *snapshot = last_seq_same_as_publish_seq_ in MultiCFSnapshot()
1906 *snapshot = reinterpret_cast<const SnapshotImpl*>(read_options.snapshot) in MultiCFSnapshot()
1918 if (read_options.snapshot != nullptr || last_try) { in MultiCFSnapshot()
1932 if (seq > *snapshot) { in MultiCFSnapshot()
2142 if (callback && read_options.snapshot == nullptr) { in MultiGetWithCallback()
2171 SuperVersion* super_version, SequenceNumber snapshot, in MultiGetImpl() argument
2186 batch_size, snapshot); in MultiGetImpl()
2562 auto snapshot = read_options.snapshot != nullptr in NewIterator() local
2563 ? read_options.snapshot->GetSequenceNumber() in NewIterator()
2565 result = NewIteratorImpl(read_options, cfd, snapshot, read_callback); in NewIterator()
2572 SequenceNumber snapshot, 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()
2628 db_iter->GetRangeDelAggregator(), snapshot); in NewIteratorImpl()
2668 auto snapshot = read_options.snapshot != nullptr in NewIterators() local
2669 ? read_options.snapshot->GetSequenceNumber() in NewIterators()
2675 NewIteratorImpl(read_options, cfd, snapshot, read_callback)); in NewIterators()
2710 SnapshotImpl* snapshot = in GetSnapshotImpl() local
2715 return snapshot; in GetSnapshotImpl()