Home
last modified time | relevance | path

Searched refs:callback (Results 1 – 25 of 45) sorted by relevance

12

/rocksdb-6.9/db/
Dwrite_thread.h125 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()
Dmemtable.h214 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,
Dmemtable_list.h64 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,
Dmemtable_list.cc111 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()
Dmemtable.cc783 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/
Dwrite_prepared_txn.cc51 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()
Dwrite_unprepared_txn_db.cc67 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()
Dwrite_unprepared_txn.cc643 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 …]
Dwrite_prepared_txn_db.cc232 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()
Doptimistic_transaction.cc77 OptimisticTransactionCallback callback(this); in CommitWithSerialValidate() local
82 write_options_, GetWriteBatch()->GetWriteBatch(), &callback); in CommitWithSerialValidate()
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DStatisticsCollectorTest.java38 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/
Ddb_impl_write.cc47 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 …]
Ddb_impl_debug.cc274 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()
Ddb_impl.h228 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 …]
Ddb_impl.cc1555 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/
Drepeatable_thread.h64 void TEST_WaitForRun(std::function<void()> callback = nullptr) {
70 if (callback != nullptr) {
71 callback();
/rocksdb-6.9/utilities/persistent_cache/
Dblock_cache_tier_file.h82 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/
Dget_context.cc47 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()
Dget_context.h95 ReadCallback* callback = nullptr, bool* is_blob_index = nullptr,
105 ReadCallback* callback = nullptr, bool* is_blob_index = nullptr,
/rocksdb-6.9/test_util/
Dsync_point.cc37 const std::function<void(void*)>& callback) { in SetCallBack() argument
38 impl_->SetCallBack(point, callback); in SetCallBack()
Dsync_point_impl.h48 const std::function<void(void*)>& callback) { in SetCallBack()
50 callbacks_[point] = callback; in SetCallBack()
/rocksdb-6.9/cache/
Dsharded_cache.h40 virtual void ApplyToAllCacheEntries(void (*callback)(void*, size_t),
86 virtual void ApplyToAllCacheEntries(void (*callback)(void*, size_t),
Dsharded_cache.cc112 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/
Dwrite_batch_with_index.cc845 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/
Dwrite_batch_with_index.h266 PinnableSlice* value, ReadCallback* callback);
271 bool sorted_input, ReadCallback* callback);

12