| /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/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()
|
| D | mutex.h | 34 &this->cv_, &lock.mutex()->mu_, std::chrono::system_clock::now() + dur); in wait_for()
|
| /external/webrtc/webrtc/system_wrappers/source/ |
| D | logging_unittest.cc | 34 cv_->Wake(); in Print()
41 cv_(ConditionVariableWrapper::CreateConditionVariable()), in LoggingTest()
59 rtc::scoped_ptr<ConditionVariableWrapper> cv_; member in webrtc::__anon8de184290111::LoggingTest
71 cv_->SleepCS(*crit_.get(), 2000); in TEST_F()
|
| /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/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/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()
|
| D | dynamic_thread_pool.h | 54 std::condition_variable cv_; variable
|
| /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::__anon3016a1e20111::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 __anon27387b800111::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_ GUARDED_BY(mu_);
|
| /external/tensorflow/tensorflow/compiler/xla/service/cpu/ |
| D | xfeed_manager.cc | 53 cv_.notify_one(); in EnqueueBuffersAtomically()
61 cv_.wait(l); in BlockingDequeueBuffer()
|
| D | xfeed_manager.h | 95 tensorflow::condition_variable cv_; variable
|
| /external/libchrome/base/synchronization/ |
| D | waitable_event_posix.cc | 92 : fired_(false), signaling_event_(nullptr), lock_(), cv_(&lock_) {} in SyncWaiter()
103 cv_.Broadcast(); in Fire()
143 return &cv_; in cv()
150 base::ConditionVariable cv_; member in base::SyncWaiter
|
| D | condition_variable.h | 108 CHROME_CONDITION_VARIABLE cv_;
|
| /external/tensorflow/tensorflow/core/util/ |
| D | tensor_slice_reader_cache.cc | 77 cv_.wait(l); in GetReader()
112 cv_.notify_all(); in GetReader()
|
| D | tensor_slice_reader_cache.h | 81 condition_variable cv_; variable
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | function_testlib.cc | 64 cv_.wait(ml); in AwaitState()
72 cv_.notify_all(); in MoveToState()
|
| D | function_testlib.h | 36 condition_variable cv_; variable
|
| D | ring_alg.h | 104 condition_variable cv_; variable
|
| D | ring_alg.cc | 80 cv_.notify_one(); in Enqueue()
89 cv_.wait(l); in Dequeue()
|
| /external/eigen/unsupported/Eigen/CXX11/src/Tensor/ |
| D | TensorDeviceThreadPool.h | 46 cv_.notify_all(); in Notify()
54 cv_.wait(l); in Wait()
60 std::condition_variable cv_; variable
|
| /external/grpc-grpc/test/core/end2end/ |
| D | inproc_callback_test.cc | 66 gpr_cv_init(&cv_); in ShutdownCallback()
78 gpr_cv_broadcast(&cv_); in Run()
86 while (!done_ && !gpr_cv_wait(&cv_, &mu_, deadline)) { in Wait()
96 gpr_cv cv_; member in __anon4ebb02100111::ShutdownCallback
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | thread_stress_test.cc | 346 cv_.wait(l); in Wait()
392 cv_.notify_all(); in AsyncCompleteRpc()
400 std::condition_variable cv_; member in grpc::testing::AsyncClientEnd2endTest
|