| /rocksdb-6.9/db/ |
| D | read_callback.h | 12 class ReadCallback {
14 ReadCallback(SequenceNumber last_visible_seq) in ReadCallback() function
16 ReadCallback(SequenceNumber last_visible_seq, SequenceNumber min_uncommitted) in ReadCallback() function
19 virtual ~ReadCallback() {} in ~ReadCallback()
|
| D | arena_wrapped_db_iter.h | 77 ReadCallback* read_callback, DBImpl* db_impl, ColumnFamilyData* cfd,
83 ColumnFamilyData* cfd, ReadCallback* read_callback, in StoreRefreshInfo()
99 ReadCallback* read_callback_;
112 ReadCallback* read_callback, DBImpl* db_impl = nullptr,
|
| D | memtable.h | 214 const ReadOptions& read_opts, ReadCallback* callback = nullptr,
224 const ReadOptions& read_opts, ReadCallback* callback = nullptr,
230 const ReadOptions& read_opts, ReadCallback* callback = nullptr,
239 ReadCallback* callback, bool* is_blob);
545 ReadCallback* callback, bool* is_blob_index,
|
| D | memtable_list.h | 64 const ReadOptions& read_opts, ReadCallback* callback = nullptr,
70 const ReadOptions& read_opts, ReadCallback* callback = nullptr,
79 ReadCallback* callback, bool* is_blob);
158 ReadCallback* callback = nullptr,
|
| D | db_iter.h | 119 ReadCallback* read_callback, DBImpl* db_impl, ColumnFamilyData* cfd,
279 ReadCallback* read_callback_;
353 ReadCallback* read_callback, DBImpl* db_impl = nullptr,
|
| D | arena_wrapped_db_iter.cc | 39 ReadCallback* read_callback, DBImpl* db_impl, in Init()
92 ReadCallback* read_callback, DBImpl* db_impl, ColumnFamilyData* cfd, in NewArenaWrappedDbIterator()
|
| D | memtable_list.cc | 111 ReadCallback* callback, bool* is_blob_index) { in Get()
118 MultiGetRange* range, ReadCallback* callback, in MultiGet()
155 const ReadOptions& read_opts, ReadCallback* callback, bool* is_blob_index) { in GetFromList()
|
| D | memtable.cc | 614 ReadCallback* callback_;
783 ReadCallback* callback, bool* is_blob_index, bool do_merge) { in Get()
842 bool do_merge, ReadCallback* callback, in GetFromTable()
871 ReadCallback* callback, bool* is_blob) { in MultiGet()
|
| D | db_merge_operator_test.cc | 17 class TestReadCallback : public ReadCallback {
21 : ReadCallback(snapshot_seq), in TestReadCallback()
|
| D | version_set.h | 612 SequenceNumber* seq = nullptr, ReadCallback* callback = nullptr,
616 ReadCallback* callback = nullptr, bool* is_blob = nullptr);
|
| D | db_iter.cc | 41 ReadCallback* read_callback, DBImpl* db_impl, in DBIter()
1380 ReadCallback* read_callback, DBImpl* db_impl, in NewDBIterator()
|
| D | db_iterator_test.cc | 24 class DummyReadCallback : public ReadCallback {
26 DummyReadCallback() : ReadCallback(kMaxSequenceNumber) {} in DummyReadCallback()
2860 TEST_F(DBIteratorWithReadCallbackTest, ReadCallback) { in TEST_F() argument
2861 class TestReadCallback : public ReadCallback { in TEST_F()
2864 : ReadCallback(_max_visible_seq) {} in TEST_F()
|
| /rocksdb-6.9/table/ |
| D | get_context.h | 95 ReadCallback* callback = nullptr, bool* is_blob_index = nullptr,
105 ReadCallback* callback = nullptr, bool* is_blob_index = nullptr,
183 ReadCallback* callback_;
|
| D | get_context.cc | 47 PinnedIteratorsManager* _pinned_iters_mgr, ReadCallback* callback, in GetContext()
80 ReadCallback* callback, bool* is_blob_index, uint64_t tracing_get_id) in GetContext()
|
| /rocksdb-6.9/include/rocksdb/utilities/ |
| D | write_batch_with_index.h | 31 class ReadCallback; variable
266 PinnableSlice* value, ReadCallback* callback);
271 bool sorted_input, ReadCallback* callback);
|
| /rocksdb-6.9/utilities/transactions/ |
| D | transaction_util.h | 69 ReadCallback* snap_checker = nullptr,
97 ReadCallback* snap_checker = nullptr,
|
| D | write_unprepared_txn.h | 54 class WriteUnpreparedTxnReadCallback : public ReadCallback {
65 : ReadCallback(CalcMaxVisibleSeq(unprep_seqs, snapshot), min_uncommitted), in WriteUnpreparedTxnReadCallback()
217 ReadCallback* callback, const ReadOptions& roptions);
|
| D | transaction_util.cc | 23 SequenceNumber snap_seq, bool cache_only, ReadCallback* snap_checker, in CheckKeyForConflicts()
53 ReadCallback* snap_checker, in CheckKey()
|
| D | write_unprepared_txn_db.cc | 42 class InvalidSnapshotReadCallback : public ReadCallback { in RollbackRecoveredTransaction()
45 : ReadCallback(snapshot) {} in RollbackRecoveredTransaction()
|
| D | write_prepared_txn_db.h | 801 class WritePreparedTxnReadCallback : public ReadCallback {
804 : ReadCallback(snapshot), in WritePreparedTxnReadCallback()
810 : ReadCallback(snapshot, min_uncommitted), in WritePreparedTxnReadCallback()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_readonly.cc | 82 ReadCallback* read_callback = nullptr; // No read callback provided. in NewIterator()
99 ReadCallback* read_callback = nullptr; // No read callback provided. in NewIterators()
|
| D | db_impl_secondary.cc | 393 ReadCallback* read_callback = nullptr; // No read callback provided. in NewIterator()
410 SequenceNumber snapshot, ReadCallback* read_callback) { in NewIteratorImpl()
436 ReadCallback* read_callback = nullptr; // No read callback provided. in NewIterators()
|
| D | db_impl.h | 228 ReadCallback* callback,
457 ReadCallback* callback = nullptr;
483 ReadCallback* read_callback,
1757 const ReadOptions& read_options, ReadCallback* callback,
1769 SuperVersion* sv, SequenceNumber snap_seqnum, ReadCallback* callback,
|
| D | db_impl_secondary.h | 99 ReadCallback* read_callback);
|
| /rocksdb-6.9/utilities/write_batch_with_index/ |
| D | write_batch_with_index.cc | 845 const Slice& key, PinnableSlice* pinnable_val, ReadCallback* callback) { in GetFromBatchAndDB()
939 Status* statuses, bool sorted_input, ReadCallback* callback) { in MultiGetFromBatchAndDB()
|