| /rocksdb-6.9/db/ |
| D | db_flush_test.cc | 49 no_wait.wait = false; in TEST_F()
95 flush_options.wait = false; in TEST_F()
131 flush_options.wait = false; in TEST_F()
257 flush_options.wait = true; in TEST_P()
297 flush_opts.wait = false; in TEST_F()
436 flush_opts.wait = false; in TEST_F()
546 flush_opts.wait = false; in TEST_P()
626 flush_opts.wait = true; in TEST_P()
686 flush_opts.wait = false; in TEST_P()
|
| D | convenience.cc | 16 void CancelAllBackgroundWork(DB* db, bool wait) { in CancelAllBackgroundWork() argument
18 ->CancelAllBackgroundWork(wait); in CancelAllBackgroundWork()
|
| D | fault_injection_test.cc | 278 flush_options.wait = true; in DeleteAllData()
406 flush_options.wait = false; in TEST_P()
451 flush_options.wait = true; in TEST_P()
492 flush_options.wait = false; in TEST_P()
|
| D | merge_test.cc | 255 o.wait = true; in testCounters()
325 o.wait = true; in testPartialMerge()
|
| D | db_log_iter_test.cc | 131 flush_options.wait = false; in TEST_F()
|
| D | db_write_test.cc | 100 fopt.wait = false; in TEST_P()
|
| /rocksdb-6.9/util/ |
| D | repeatable_thread.h | 81 bool wait(uint64_t delay) { in wait() function
114 if (!wait(initial_delay_us_)) { in thread()
126 } while (wait(delay_us_)); in thread()
|
| D | thread_list_test.cc | 46 bg_cv_.wait(l); in Run()
70 bg_cv_.wait(l); in WaitUntilDone()
|
| D | channel.h | 51 cv_.wait(lk, [&] { return eof_ || !buffer_.empty(); }); in read()
|
| D | timer_queue.h | 157 m_checkWork.wait(lk); in run()
|
| D | threadpool_imp.cc | 197 bgsignal_.wait(lock); in BGThread()
|
| /rocksdb-6.9/test_util/ |
| D | sync_point_impl.cc | 78 cv_.wait(lock); in ClearCallBack()
86 cv_.wait(lock); in ClearAllCallBacks()
111 cv_.wait(lock); in Process()
|
| /rocksdb-6.9/utilities/transactions/ |
| D | transaction_db_mutex_impl.cc | 98 cv_.wait(lock); in Wait()
115 cv_.wait(lock); in WaitFor()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_debug.cc | 125 Status DBImpl::TEST_FlushMemTable(bool wait, bool allow_write_stall, in TEST_FlushMemTable() argument
128 fo.wait = wait; in TEST_FlushMemTable()
|
| D | db_impl.h | 659 void CancelAllBackgroundWork(bool wait);
883 Status TEST_FlushMemTable(bool wait = true, bool allow_write_stall = false,
1482 switch_cv_.wait(guard, in WaitForPendingWrites()
|
| /rocksdb-6.9/third-party/folly/folly/synchronization/ |
| D | ParkingLot.h | 35 std::cv_status wait(std::chrono::time_point<Clock, Duration> deadline) { in wait() function
42 cond_.wait(nodeLock); in wait()
270 auto status = node.wait(deadline); in park_until()
|
| D | Baton.h | 156 void wait(const WaitOptions& opt = wait_options()) noexcept {
|
| /rocksdb-6.9/tools/ |
| D | ldb_cmd_test.cc | 95 fopts.wait = true; in TEST_F()
270 fopts.wait = true; in TEST_F()
357 fopts.wait = true; in TEST_F()
483 fopts.wait = true; in TEST_F()
|
| /rocksdb-6.9/third-party/folly/folly/synchronization/detail/ |
| D | Sleeper.h | 45 void wait() noexcept { in wait() function
|
| /rocksdb-6.9/include/rocksdb/ |
| D | options.h | 1430 bool wait; member
1437 FlushOptions() : wait(true), allow_write_stall(false) {} in FlushOptions()
|
| D | convenience.h | 320 void CancelAllBackgroundWork(DB* db, bool wait = false);
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | FlushOptions.java | 85 final boolean wait); in setWaitForFlush() argument
|
| /rocksdb-6.9/third-party/folly/folly/synchronization/test/ |
| D | DistributedMutexTest.cpp | 629 done.wait(); in TEST()
633 start.wait(); in TEST()
652 start.wait(); in TEST()
846 release.wait(); in TEST()
853 ready.wait(); in TEST()
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2018-02-05-rocksdb-5-10-2-released.markdown | 15 … and `key_lock_wait_time`, which measure the number of times transactions wait on key locks and to…
|
| /rocksdb-6.9/port/win/ |
| D | port_win.cc | 79 cv_.wait(lk); in Wait()
|