| /external/rust/crates/grpcio-sys/grpc/src/core/lib/gprpp/ |
| D | fork.cc | 64 gpr_cv_init(&cv_); in ExecCtxState()
77 gpr_cv_wait(&cv_, &mu_, gpr_inf_future(GPR_CLOCK_REALTIME)); in IncExecCtxCount()
105 gpr_cv_broadcast(&cv_); in AllowExecCtx()
111 gpr_cv_destroy(&cv_); in ~ExecCtxState()
117 gpr_cv cv_; member in grpc_core::internal::ExecCtxState
125 gpr_cv_init(&cv_); in ThreadState()
139 gpr_cv_signal(&cv_); in DecThreadCount()
148 gpr_cv_wait(&cv_, &mu_, gpr_inf_future(GPR_CLOCK_REALTIME)); in AwaitThreads()
156 gpr_cv_destroy(&cv_); in ~ThreadState()
163 gpr_cv cv_; member in grpc_core::internal::ThreadState
|
| D | sync.h | 99 CondVar() { gpr_cv_init(&cv_); } in CondVar()
100 ~CondVar() { gpr_cv_destroy(&cv_); } in ~CondVar()
105 void Signal() { gpr_cv_signal(&cv_); } in Signal()
106 void Broadcast() { gpr_cv_broadcast(&cv_); } in Broadcast()
110 return gpr_cv_wait(&cv_, mu->get(), deadline); in Wait()
130 gpr_cv cv_;
|
| /external/grpc-grpc/src/core/lib/gprpp/ |
| D | fork.cc | 54 gpr_cv_init(&cv_); in ExecCtxState()
67 gpr_cv_wait(&cv_, &mu_, gpr_inf_future(GPR_CLOCK_REALTIME)); in IncExecCtxCount()
95 gpr_cv_broadcast(&cv_); in AllowExecCtx()
101 gpr_cv_destroy(&cv_); in ~ExecCtxState()
107 gpr_cv cv_; member in grpc_core::internal::ExecCtxState
115 gpr_cv_init(&cv_); in ThreadState()
129 gpr_cv_signal(&cv_); in DecThreadCount()
138 gpr_cv_wait(&cv_, &mu_, gpr_inf_future(GPR_CLOCK_REALTIME)); in AwaitThreads()
146 gpr_cv_destroy(&cv_); in ~ThreadState()
153 gpr_cv cv_; member in grpc_core::internal::ThreadState
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/ |
| D | sync.h | 120 CondVar() { g_core_codegen_interface->gpr_cv_init(&cv_); } in CondVar()
121 ~CondVar() { g_core_codegen_interface->gpr_cv_destroy(&cv_); } in ~CondVar()
126 void Signal() { g_core_codegen_interface->gpr_cv_signal(&cv_); } in Signal()
127 void Broadcast() { g_core_codegen_interface->gpr_cv_broadcast(&cv_); } in Broadcast()
134 return g_core_codegen_interface->gpr_cv_wait(&cv_, mu->get(), deadline); in Wait()
145 gpr_cv cv_;
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/ |
| D | sync.h | 120 CondVar() { g_core_codegen_interface->gpr_cv_init(&cv_); } in CondVar()
121 ~CondVar() { g_core_codegen_interface->gpr_cv_destroy(&cv_); } in ~CondVar()
126 void Signal() { g_core_codegen_interface->gpr_cv_signal(&cv_); } in Signal()
127 void Broadcast() { g_core_codegen_interface->gpr_cv_broadcast(&cv_); } in Broadcast()
134 return g_core_codegen_interface->gpr_cv_wait(&cv_, mu->get(), deadline); in Wait()
145 gpr_cv cv_;
|
| /external/tensorflow/tensorflow/core/platform/default/ |
| D | notification.h | 43 cv_.notify_all(); in Notify()
54 cv_.wait(l); in WaitForNotification()
69 cv_.wait_for(l, std::chrono::microseconds(timeout_in_us)) != in WaitForNotificationWithTimeout()
76 condition_variable cv_; // signaled when notified_ becomes non-zero variable
|
| D | mutex.cc | 89 nsync::nsync_cv_init(cv_cast(&cv_)); in condition_variable()
93 nsync::nsync_cv_wait(cv_cast(&cv_), mu_cast(&lock.mutex()->mu_)); in wait()
96 void condition_variable::notify_one() { nsync::nsync_cv_signal(cv_cast(&cv_)); } in notify_one()
99 nsync::nsync_cv_broadcast(cv_cast(&cv_)); in notify_all()
|
| /external/tensorflow/tensorflow/compiler/xla/service/gpu/ |
| D | xfeed_queue.h | 45 cv_.notify_one(); in EnqueueDestination()
60 cv_.wait(l); in BlockingGetNextDestination()
86 tensorflow::condition_variable cv_; variable
|
| /external/tensorflow/tensorflow/core/data/service/ |
| D | task_runner.cc | 249 cv_.notify_all(); in ~PrefetchThread()
257 cv_.wait(l); in Run()
269 cv_.notify_all(); in Run()
279 cv_.notify_all(); in Run()
284 cv_.notify_all(); in Run()
298 cv_.wait_for(l, std::chrono::microseconds(remaining_us)); in FillBuffer()
312 cv_.notify_all(); in FillBuffer()
|
| /external/grpc-grpc/test/cpp/interop/ |
| D | reconnect_interop_server.cc | 85 cv_.wait(lock); in Start()
115 cv_.notify_one(); in Stop()
149 cv_.notify_all(); in Shutdown()
159 std::condition_variable cv_; member in ReconnectServiceImpl
|
| /external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/synchronization/internal/ |
| D | per_thread_sem_test.cc | 51 cv_.wait(lock, [this]() { return count_ > 0; }); in Wait()
53 cv_.notify_one(); in Wait()
63 cv_.notify_one(); in Post()
68 std::condition_variable cv_; member in absl::synchronization_internal::SimpleSemaphore
|
| /external/libtextclassifier/abseil-cpp/absl/synchronization/internal/ |
| D | per_thread_sem_test.cc | 51 cv_.wait(lock, [this]() { return count_ > 0; }); in Wait()
53 cv_.notify_one(); in Wait()
63 cv_.notify_one(); in Post()
68 std::condition_variable cv_; member in absl::synchronization_internal::SimpleSemaphore
|
| D | waiter.cc | 219 const int err2 = pthread_cond_init(&cv_, 0); in Waiter()
234 const int err2 = pthread_cond_destroy(&cv_); in ~Waiter()
256 const int err = pthread_cond_wait(&cv_, &mu_); in Wait()
261 const int err = pthread_cond_timedwait(&cv_, &mu_, &abs_timeout); in Wait()
291 const int err = pthread_cond_signal(&cv_); in InternalCondVarPoke()
|
| /external/openscreen/third_party/abseil/src/absl/synchronization/internal/ |
| D | per_thread_sem_test.cc | 51 cv_.wait(lock, [this]() { return count_ > 0; }); in Wait()
53 cv_.notify_one(); in Wait()
63 cv_.notify_one(); in Post()
68 std::condition_variable cv_; member in absl::synchronization_internal::SimpleSemaphore
|
| D | waiter.cc | 155 const int err2 = pthread_cond_init(&cv_, 0); in Waiter()
170 const int err2 = pthread_cond_destroy(&cv_); in ~Waiter()
192 const int err = pthread_cond_wait(&cv_, &mu_); in Wait()
197 const int err = pthread_cond_timedwait(&cv_, &mu_, &abs_timeout); in Wait()
227 const int err = pthread_cond_signal(&cv_); in InternalCondVarPoke()
|
| /external/abseil-cpp/absl/synchronization/internal/ |
| D | per_thread_sem_test.cc | 50 cv_.wait(lock, [this]() { return count_ > 0; }); in Wait()
52 cv_.notify_one(); in Wait()
62 cv_.notify_one(); in Post()
67 std::condition_variable cv_; member in absl::synchronization_internal::SimpleSemaphore
|
| /external/webrtc/third_party/abseil-cpp/absl/synchronization/internal/ |
| D | per_thread_sem_test.cc | 50 cv_.wait(lock, [this]() { return count_ > 0; }); in Wait()
52 cv_.notify_one(); in Wait()
62 cv_.notify_one(); in Post()
67 std::condition_variable cv_; member in absl::synchronization_internal::SimpleSemaphore
|
| /external/angle/third_party/abseil-cpp/absl/synchronization/internal/ |
| D | per_thread_sem_test.cc | 51 cv_.wait(lock, [this]() { return count_ > 0; }); in Wait()
53 cv_.notify_one(); in Wait()
63 cv_.notify_one(); in Post()
68 std::condition_variable cv_; member in absl::synchronization_internal::SimpleSemaphore
|
| D | waiter.cc | 155 const int err2 = pthread_cond_init(&cv_, 0); in Waiter()
170 const int err2 = pthread_cond_destroy(&cv_); in ~Waiter()
192 const int err = pthread_cond_wait(&cv_, &mu_); in Wait()
197 const int err = pthread_cond_timedwait(&cv_, &mu_, &abs_timeout); in Wait()
227 const int err = pthread_cond_signal(&cv_); in InternalCondVarPoke()
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/server/ |
| D | dynamic_thread_pool.cc | 63 cv_.Wait(&mu_); in ThreadFunc()
100 cv_.Broadcast(); in ~DynamicThreadPool()
117 cv_.Signal(); in Add()
|
| /external/grpc-grpc/src/cpp/server/ |
| D | dynamic_thread_pool.cc | 63 cv_.wait(lock); in ThreadFunc()
100 cv_.notify_all(); in ~DynamicThreadPool()
117 cv_.notify_one(); in Add()
|
| /external/libchrome/base/task_scheduler/ |
| D | test_task_factory.cc | 23 : cv_(&lock_), in TestTaskFactory()
47 cv_.Wait(); in WaitForAllTasksToRun()
97 cv_.Signal(); in RunTaskCallback()
|
| /external/tensorflow/tensorflow/core/common_runtime/gpu/ |
| D | gpu_allocator_retry_test.cc | 84 cv_.wait_for(l, std::chrono::milliseconds(1)); in WaitTurn()
88 cv_.notify_all(); in WaitTurn()
98 cv_.notify_all(); in Done()
113 condition_variable cv_; member in tensorflow::__anon8bb5cd3e0111::AlternatingBarrier
|
| /external/swiftshader/third_party/marl/src/ |
| D | non_marl_bench.cpp | 35 cv_.wait(lock, [&] { return signalled_; }); in wait()
42 cv_.notify_all(); in signal()
46 std::condition_variable cv_; member in __anonfe5819dc0111::Event
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | mutex_ops.cc | 65 mutex_->cv_.notify_all(); in ~LockReleaser()
90 cv_.notify_all(); in AcquireAsync()
107 cv_.wait(lock); in AcquireAsync()
128 condition_variable cv_ TF_GUARDED_BY(mu_);
|