Home
last modified time | relevance | path

Searched refs:callback_ (Results 1 – 6 of 6) sorted by relevance

/rocksdb-6.9/db/
Dwrite_callback_test.cc89 WriteOP(bool should_fail = false) { callback_.should_fail_ = should_fail; } in TEST_F()
99 callback_.was_called_.store(false); in TEST_F()
102 MockWriteCallback callback_; in TEST_F() member
278 write_op.callback_.allow_batching_ = allow_batching; in TEST_F()
289 if (!write_op.callback_.should_fail_ && !seq_per_batch) { in TEST_F()
293 if (!write_op.callback_.should_fail_ && seq_per_batch) { in TEST_F()
318 woptions, &write_op.write_batch_, &write_op.callback_, in TEST_F()
323 woptions, &write_op.write_batch_, &write_op.callback_); in TEST_F()
326 if (write_op.callback_.should_fail_) { in TEST_F()
349 ASSERT_TRUE(w.callback_.was_called_.load()); in TEST_F()
[all …]
Dmemtable.cc614 ReadCallback* callback_; member
618 if (callback_) { in CheckCallback()
619 return callback_->IsVisible(_seq); in CheckCallback()
863 saver.callback_ = callback; in GetFromTable()
/rocksdb-6.9/table/
Dget_context.h148 if (callback_) { in CheckCallback()
149 return callback_->IsVisible(seq); in CheckCallback()
156 bool has_callback() const { return callback_ != nullptr; } in has_callback()
183 ReadCallback* callback_; variable
Dget_context.cc64 callback_(callback), in GetContext()
/rocksdb-6.9/utilities/persistent_cache/
Dblock_cache_tier_file.h263 : file_(file), buf_(buf), file_off_(file_off), callback_(callback) {} in IO()
273 std::function<void()> callback_; // Callback on completion member
Dblock_cache_tier_file.cc586 io.callback_(); in ThreadMain()