| /rocksdb-6.9/utilities/transactions/ |
| D | transaction_db_mutex_impl.cc | 46 void Notify() override { cv_.notify_one(); } in Notify()
48 void NotifyAll() override { cv_.notify_all(); } in NotifyAll()
51 std::condition_variable cv_; member in ROCKSDB_NAMESPACE::TransactionDBCondVarImpl
98 cv_.wait(lock); in Wait()
115 cv_.wait(lock); in WaitFor()
118 auto cv_status = cv_.wait_for(lock, duration); in WaitFor()
|
| /rocksdb-6.9/util/ |
| D | channel.h | 26 cv_.notify_all(); in sendEof()
43 cv_.notify_one(); in write()
51 cv_.wait(lk, [&] { return eof_ || !buffer_.empty(); }); in read()
57 cv_.notify_one(); in read()
62 std::condition_variable cv_;
|
| /rocksdb-6.9/test_util/ |
| D | sync_point_impl.cc | 42 cv_.notify_all(); in LoadDependency()
63 cv_.notify_all(); in LoadDependencyAndMarkers()
78 cv_.wait(lock); in ClearCallBack()
86 cv_.wait(lock); in ClearAllCallBacks()
111 cv_.wait(lock); in Process()
126 cv_.notify_all(); in Process()
|
| D | sync_point_impl.h | 37 std::condition_variable cv_; member
|
| /rocksdb-6.9/port/ |
| D | port_posix.cc | 98 PthreadCall("init cv", pthread_cond_init(&cv_, nullptr)); in CondVar()
101 CondVar::~CondVar() { PthreadCall("destroy cv", pthread_cond_destroy(&cv_)); } in ~CondVar()
107 PthreadCall("wait", pthread_cond_wait(&cv_, &mu_->mu_)); in Wait()
121 int err = pthread_cond_timedwait(&cv_, &mu_->mu_, &ts); in TimedWait()
135 PthreadCall("signal", pthread_cond_signal(&cv_)); in Signal()
139 PthreadCall("broadcast", pthread_cond_broadcast(&cv_)); in SignalAll()
|
| D | port_posix.h | 160 pthread_cond_t cv_;
|
| /rocksdb-6.9/file/ |
| D | delete_scheduler.cc | 34 cv_(&mu_), in DeleteScheduler()
48 cv_.SignalAll(); in ~DeleteScheduler()
97 cv_.SignalAll(); in DeleteFile()
196 cv_.Wait(); in BackgroundEmptyTrash()
242 while (!closing_ && !cv_.TimedWait(start_time + total_penlty)) {} in BackgroundEmptyTrash()
256 cv_.SignalAll(); in BackgroundEmptyTrash()
351 cv_.Wait(); in WaitForEmptyTrash()
|
| D | sst_file_manager_impl.cc | 37 cv_(&mu_), in SstFileManagerImpl()
55 cv_.SignalAll(); in Close()
350 cv_.TimedWait(wait_until); in ClearError()
|
| D | delete_scheduler.h | 128 InstrumentedCondVar cv_; variable
|
| D | sst_file_manager_impl.h | 173 port::CondVar cv_; variable
|
| /rocksdb-6.9/port/win/ |
| D | port_win.cc | 79 cv_.wait(lk); in Wait()
106 std::cv_status cvStatus = cv_.wait_for(lk, relTimeUs); in TimedWait()
121 void CondVar::Signal() { cv_.notify_one(); } in Signal()
123 void CondVar::SignalAll() { cv_.notify_all(); } in SignalAll()
|
| D | port_win.h | 216 std::condition_variable cv_;
|
| /rocksdb-6.9/cache/ |
| D | cache_bench.cc | 58 : cv_(&mu_), in SharedState()
73 return &cv_; in GetCondVar()
106 port::CondVar cv_; member in ROCKSDB_NAMESPACE::__anonccaf61260111::SharedState
|
| /rocksdb-6.9/db_stress_tool/ |
| D | db_stress_shared_state.h | 41 : cv_(&mu_), in SharedState()
180 port::CondVar* GetCondVar() { return &cv_; } in GetCondVar()
333 port::CondVar cv_; variable
|
| /rocksdb-6.9/db/ |
| D | forward_iterator_bench.cc | 281 cv_.wait_for(lock, std::chrono::seconds(1)); in run()
308 cv_.notify_all(); in ~StatsThread()
315 std::condition_variable cv_; member
|
| D | error_handler_fs_test.cc | 63 cv_(&mutex_), in ErrorHandlerFSListener()
81 cv_.SignalAll(); in OnTableFileCreationStarted()
94 cv_.SignalAll(); in OnErrorRecoveryCompleted()
100 cv_.Wait(/*abs_time_us*/); in WaitForRecovery()
112 cv_.Wait(/*abs_time_us*/); in WaitForTableFileCreationStarted()
141 InstrumentedCondVar cv_; member in ROCKSDB_NAMESPACE::ErrorHandlerFSListener
|
| /rocksdb-6.9/tools/ |
| D | db_bench_tool.cc | 2326 cv_(&mutex_), in ErrorHandlerListener()
2343 cv_.SignalAll(); in OnErrorRecoveryCompleted()
2349 cv_.TimedWait(abs_time_us); in WaitForRecovery()
2362 InstrumentedCondVar cv_; member in ROCKSDB_NAMESPACE::Benchmark::ErrorHandlerListener
|