| /rocksdb-6.9/db/ |
| D | write_thread.h | 125 WriteCallback* callback; member
148 callback(nullptr), in Writer()
169 callback(_callback), in batch()
185 if (callback != nullptr) { in CheckCallback()
186 callback_status = callback->Callback(db); in CheckCallback()
206 assert(callback == nullptr || callback_status.ok()); in FinalStatus()
211 assert(callback != nullptr); in FinalStatus()
217 assert(callback == nullptr || callback_status.ok()); in FinalStatus()
223 return (callback != nullptr) && !callback_status.ok(); in CallbackFailed()
|
| D | memtable.h | 214 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,
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,
74 max_covering_tombstone_seq, &seq, read_opts, callback,
79 ReadCallback* callback, bool* is_blob);
158 ReadCallback* callback = nullptr,
|
| D | memtable_list.cc | 111 ReadCallback* callback, bool* is_blob_index) { in Get() argument
113 max_covering_tombstone_seq, seq, read_opts, callback, in Get()
118 MultiGetRange* range, ReadCallback* callback, in MultiGet() argument
121 memtable->MultiGet(read_options, range, callback, is_blob); in MultiGet()
155 const ReadOptions& read_opts, ReadCallback* callback, bool* is_blob_index) { in GetFromList() argument
163 read_opts, callback, is_blob_index); in GetFromList()
|
| D | memtable.cc | 783 ReadCallback* callback, bool* is_blob_index, bool do_merge) { in Get() argument
827 GetFromTable(key, *max_covering_tombstone_seq, do_merge, callback, in Get()
842 bool do_merge, ReadCallback* callback, in GetFromTable() argument
863 saver.callback_ = callback; in GetFromTable()
871 ReadCallback* callback, bool* is_blob) { in MultiGet() argument
922 callback, is_blob, iter->value->GetSelf(), iter->timestamp, in MultiGet()
|
| /rocksdb-6.9/utilities/transactions/ |
| D | write_prepared_txn.cc | 51 WritePreparedTxnReadCallback callback(wpt_db_, snap_seq, min_uncommitted, in MultiGet() local
55 &callback); in MultiGet()
56 if (UNLIKELY(!callback.valid() || in MultiGet()
71 WritePreparedTxnReadCallback callback(wpt_db_, snap_seq, min_uncommitted, in Get() local
74 pinnable_val, &callback); in Get()
75 if (LIKELY(callback.valid() && in Get()
76 wpt_db_->ValidateSnapshot(callback.max_visible_seq(), in Get()
255 WritePreparedTxnReadCallback callback; in RollbackInternal() member
270 callback(wpt_db, snap_seq), // disable min_uncommitted optimization in RollbackInternal()
297 get_impl_options.callback = &callback; in RollbackInternal()
|
| D | write_unprepared_txn_db.cc | 67 InvalidSnapshotReadCallback callback; in RollbackRecoveredTransaction() member
80 callback(snap_seq), in RollbackRecoveredTransaction()
107 get_impl_options.callback = &callback; in RollbackRecoveredTransaction()
369 : callback(txn_db, sequence, min_uncommitted, txn->unprep_seqs_, in IteratorState()
372 SequenceNumber MaxVisibleSeq() { return callback.max_visible_seq(); } in MaxVisibleSeq()
374 WriteUnpreparedTxnReadCallback callback; member
462 &state->callback, !ALLOW_BLOB, !ALLOW_REFRESH); in NewIterator()
|
| D | write_unprepared_txn.cc | 643 ReadCallback* callback, const ReadOptions& roptions) { in WriteRollbackKeys() argument
653 get_impl_options.callback = callback; in WriteRollbackKeys()
708 WritePreparedTxnReadCallback callback(wpt_db_, read_at_seq); in RollbackInternal() local
712 WriteRollbackKeys(GetTrackedKeys(), &rollback_batch, &callback, roptions); in RollbackInternal()
854 WriteUnpreparedTxnReadCallback callback(wupt_db_, snap_seq, min_uncommitted, in RollbackToSavePointInternal() local
857 WriteRollbackKeys(tracked_keys, &write_batch_, &callback, roptions); in RollbackToSavePointInternal()
915 WriteUnpreparedTxnReadCallback callback(wupt_db_, snap_seq, min_uncommitted, in MultiGet() local
919 &callback); in MultiGet()
920 if (UNLIKELY(!callback.valid() || in MultiGet()
938 value, &callback); in Get()
[all …]
|
| D | write_prepared_txn_db.cc | 232 WritePreparedTxnReadCallback callback(this, snap_seq, min_uncommitted, in Get() local
239 get_impl_options.callback = &callback; in Get()
241 if (LIKELY(callback.valid() && ValidateSnapshot(callback.max_visible_seq(), in Get()
308 : callback(txn_db, sequence, min_uncommitted, kBackedByDBSnapshot), in IteratorState()
311 WritePreparedTxnReadCallback callback; member
349 db_impl_->NewIteratorImpl(options, cfd, snapshot_seq, &state->callback, in NewIterator()
386 db_impl_->NewIteratorImpl(options, cfd, snapshot_seq, &state->callback, in NewIterators()
|
| D | optimistic_transaction.cc | 77 OptimisticTransactionCallback callback(this); in CommitWithSerialValidate() local
82 write_options_, GetWriteBatch()->GetWriteBatch(), &callback); in CommitWithSerialValidate()
|
| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | StatisticsCollectorTest.java | 38 final StatsCallbackMock callback = new StatsCallbackMock(); in statisticsCollector() local
40 new StatsCollectorInput(stats, callback); in statisticsCollector()
48 assertThat(callback.tickerCallbackCount).isGreaterThan(0); in statisticsCollector()
49 assertThat(callback.histCallbackCount).isGreaterThan(0); in statisticsCollector()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_write.cc | 47 PreReleaseCallback* callback) { in SetRecoverableStatePreReleaseCallback() argument
48 recoverable_state_pre_release_callback_.reset(callback); in SetRecoverableStatePreReleaseCallback()
58 WriteCallback* callback) { in WriteWithCallback() argument
59 return WriteImpl(write_options, my_batch, callback, nullptr); in WriteWithCallback()
67 WriteBatch* my_batch, WriteCallback* callback, in WriteImpl() argument
144 status = UnorderedWriteMemtable(write_options, my_batch, callback, in WriteImpl()
156 WriteThread::Writer w(write_options, my_batch, callback, log_ref, in WriteImpl()
469 WriteThread::Writer w(write_options, my_batch, callback, log_ref, in PipelinedWriteImpl()
474 if (w.callback && !w.callback->AllowWriteBatching()) { in PipelinedWriteImpl()
607 WriteThread::Writer w(write_options, my_batch, callback, log_ref, in UnorderedWriteMemtable()
[all …]
|
| D | db_impl_debug.cc | 274 void DBImpl::TEST_WaitForDumpStatsRun(std::function<void()> callback) const { in TEST_WaitForDumpStatsRun()
276 thread_dump_stats_->TEST_WaitForRun(callback); in TEST_WaitForDumpStatsRun()
280 void DBImpl::TEST_WaitForPersistStatsRun(std::function<void()> callback) const { in TEST_WaitForPersistStatsRun()
282 thread_persist_stats_->TEST_WaitForRun(callback); in TEST_WaitForPersistStatsRun()
|
| D | db_impl.h | 228 ReadCallback* callback,
457 ReadCallback* callback = nullptr; member
508 WriteCallback* callback);
835 void SetRecoverableStatePreReleaseCallback(PreReleaseCallback* callback);
962 void TEST_WaitForDumpStatsRun(std::function<void()> callback) const;
963 void TEST_WaitForPersistStatsRun(std::function<void()> callback) const;
1084 WriteCallback* callback = nullptr,
1091 WriteCallback* callback = nullptr,
1118 WriteBatch* updates, WriteCallback* callback, uint64_t* log_used,
1757 const ReadOptions& read_options, ReadCallback* callback,
[all …]
|
| D | db_impl.cc | 1555 if (get_impl_options.callback) { in GetImpl()
1571 if (get_impl_options.callback) { in GetImpl()
1576 get_impl_options.callback->Refresh(snapshot); in GetImpl()
1625 get_impl_options.callback, in GetImpl()
1831 const ReadOptions& read_options, ReadCallback* callback, in MultiCFSnapshot() argument
1855 if (callback) { in MultiCFSnapshot()
2119 ReadCallback* callback, in MultiGetWithCallback() argument
2142 if (callback && read_options.snapshot == nullptr) { in MultiGetWithCallback()
2147 callback->Refresh(consistent_seqnum); in MultiGetWithCallback()
2158 consistent_seqnum = callback->max_visible_seq(); in MultiGetWithCallback()
[all …]
|
| /rocksdb-6.9/util/ |
| D | repeatable_thread.h | 64 void TEST_WaitForRun(std::function<void()> callback = nullptr) {
70 if (callback != nullptr) {
71 callback();
|
| /rocksdb-6.9/utilities/persistent_cache/ |
| D | block_cache_tier_file.h | 82 const std::function<void()> callback) = 0;
262 const uint64_t file_off, const std::function<void()> callback) in IO()
263 : file_(file), buf_(buf), file_off_(file_off), callback_(callback) {} in IO()
283 const std::function<void()> callback) override;
|
| /rocksdb-6.9/table/ |
| D | get_context.cc | 47 PinnedIteratorsManager* _pinned_iters_mgr, ReadCallback* callback, in GetContext() argument
64 callback_(callback), in GetContext()
80 ReadCallback* callback, bool* is_blob_index, uint64_t tracing_get_id) in GetContext() argument
84 callback, is_blob_index, tracing_get_id) {} in GetContext()
|
| D | get_context.h | 95 ReadCallback* callback = nullptr, bool* is_blob_index = nullptr,
105 ReadCallback* callback = nullptr, bool* is_blob_index = nullptr,
|
| /rocksdb-6.9/test_util/ |
| D | sync_point.cc | 37 const std::function<void(void*)>& callback) { in SetCallBack() argument
38 impl_->SetCallBack(point, callback); in SetCallBack()
|
| D | sync_point_impl.h | 48 const std::function<void(void*)>& callback) { in SetCallBack()
50 callbacks_[point] = callback; in SetCallBack()
|
| /rocksdb-6.9/cache/ |
| D | sharded_cache.h | 40 virtual void ApplyToAllCacheEntries(void (*callback)(void*, size_t),
86 virtual void ApplyToAllCacheEntries(void (*callback)(void*, size_t),
|
| D | sharded_cache.cc | 112 void ShardedCache::ApplyToAllCacheEntries(void (*callback)(void*, size_t), in ApplyToAllCacheEntries()
116 GetShard(s)->ApplyToAllCacheEntries(callback, thread_safe); in ApplyToAllCacheEntries()
|
| /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() argument
883 if (!callback) { in GetFromBatchAndDB()
889 get_impl_options.callback = callback; in GetFromBatchAndDB()
939 Status* statuses, bool sorted_input, ReadCallback* callback) { in MultiGetFromBatchAndDB() argument
998 ->MultiGetWithCallback(read_options, column_family, callback, in MultiGetFromBatchAndDB()
|
| /rocksdb-6.9/include/rocksdb/utilities/ |
| D | write_batch_with_index.h | 266 PinnableSlice* value, ReadCallback* callback);
271 bool sorted_input, ReadCallback* callback);
|