| /third_party/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 | 125 CondVar() { gpr_cv_init(&cv_); }
126 ~CondVar() { gpr_cv_destroy(&cv_); }
131 void Signal() { gpr_cv_signal(&cv_); }
132 void SignalAll() { gpr_cv_broadcast(&cv_); }
136 return gpr_cv_wait(&cv_, &mu->mu_, ToGprTimeSpec(timeout)) != 0;
139 return gpr_cv_wait(&cv_, &mu->mu_, ToGprTimeSpec(deadline)) != 0;
143 gpr_cv cv_;
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/util/ |
| D | cond_var.cc | 30 cv_.wait(*lck, f); in Wait()
38 (void)cv_.wait_for(*lck, std::chrono::milliseconds(1)); in Wait()
55 void CondVar::NotifyOne() noexcept { cv_.notify_one(); } in NotifyOne()
57 void CondVar::NotifyAll() noexcept { cv_.notify_all(); } in NotifyAll()
69 cv_.notify_all(); in Interrupt()
|
| /third_party/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_;
|
| /third_party/flutter/engine/flutter/fml/synchronization/ |
| D | waitable_event.cc | 60 cv_.notify_one(); in Signal()
71 cv_.wait(locker); in Wait()
88 cv_.wait_for(locker, in WaitWithTimeout()
123 cv_.notify_all(); in Signal()
139 cv_.wait(locker); in Wait()
152 &locker, &cv_, in WaitWithTimeout()
|
| D | waitable_event.h | 66 std::condition_variable cv_;
108 std::condition_variable cv_;
|
| /third_party/boost/boost/fiber/cuda/ |
| D | waitfor.hpp | 60 cv_.notify_one(); in notify()
65 cv_.wait( lk, [this]{ return done_; }); in wait()
71 condition_variable cv_{}; member in boost::fibers::cuda::detail::single_stream_rendezvous
99 cv_.notify_one(); in notify()
105 cv_.wait( lk, [this]{ return stx_.empty(); }); in wait()
111 condition_variable cv_{}; member in boost::fibers::cuda::detail::many_streams_rendezvous
|
| /third_party/boost/boost/fiber/hip/ |
| D | waitfor.hpp | 60 cv_.notify_one(); in notify()
65 cv_.wait( lk, [this]{ return done_; }); in wait()
71 condition_variable cv_{}; member in boost::fibers::cuda::detail::single_stream_rendezvous
99 cv_.notify_one(); in notify()
105 cv_.wait( lk, [this]{ return stx_.empty(); }); in wait()
111 condition_variable cv_{}; member in boost::fibers::cuda::detail::many_streams_rendezvous
|
| /third_party/mindspore/mindspore/ccsrc/ps/core/communicator/ |
| D | task_executor.cc | 42 cv_.wait(lock); in TaskExecutor()
67 cv_.notify_one(); in TaskExecutor()
80 cv_.notify_all(); in ~TaskExecutor()
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/ |
| D | connector.h | 102 … RETURN_IF_NOT_OK(cv_.Wait(&lk, [this, worker_id]() { return expect_consumer_ == worker_id; })); in Pop()
109 cv_.NotifyAll(); in Pop()
183 rc = cv_.Register(vg->GetIntrpService()); in Register()
205 CondVar cv_; variable
|
| D | jagged_connector.h | 50 … RETURN_IF_NOT_OK(cv_.Wait(&lock, [this, worker_id]() { return expect_consumer_ == worker_id; })); in Pop()
72 cv_.NotifyAll(); in Pop()
|
| D | db_connector.h | 75 …RETURN_IF_NOT_OK(cv_.Wait(&lk, [this, worker_id]() { return (expect_consumer_ == worker_id) || end…
93 cv_.NotifyAll();
|
| D | gpu_item_connector.h | 53 … RETURN_IF_NOT_OK(cv_.Wait(&lock, [this, worker_id]() { return expect_consumer_ == worker_id; })); in Pop()
75 cv_.NotifyAll(); in Pop()
|
| /third_party/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
|
| /third_party/skia/third_party/externals/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()
|
| /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 | 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()
|
| /third_party/boost/libs/beast/test/extras/include/boost/beast/test/ |
| D | yield_to.hpp | 43 std::condition_variable cv_; member in boost::beast::test::enable_yield_to
116 cv_.wait(lock, [&]{ return running_ == 0; }); in yield_to()
131 cv_.notify_all(); in spawn()
|
| /third_party/grpc/src/cpp/server/ |
| D | dynamic_thread_pool.cc | 63 cv_.Wait(&mu_); in ThreadFunc()
100 cv_.SignalAll(); in ~DynamicThreadPool()
117 cv_.Signal(); in Add()
|
| /third_party/grpc/test/cpp/end2end/ |
| D | client_callback_end2end_test.cc | 312 cv_.notify_one(); in SendGenericEchoAsBidi()
334 cv_.wait(l); in SendGenericEchoAsBidi()
345 std::condition_variable cv_; in SendGenericEchoAsBidi() member in grpc::testing::__anon3934da2c0111::ClientCallbackEnd2endTest::SendGenericEchoAsBidi::Client
704 cv_.notify_one(); in OnDone()
709 cv_.wait(l); in Await()
733 std::condition_variable cv_; member in grpc::testing::__anon3934da2c0111::WriteClient
822 cv_.notify_one(); in TEST_P()
827 cv_.wait(l); in TEST_P()
836 std::condition_variable cv_; in TEST_P() member in grpc::testing::__anon3934da2c0111::TEST_P::UnaryClient
886 cv_.notify_one(); in TEST_P()
[all …]
|
| /third_party/skia/third_party/externals/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 __anonec395afd0111::Event
|
| /third_party/mindspore/mindspore/ccsrc/runtime/device/gpu/ |
| D | gpu_buffer_mgr.h | 43 cv_.notify_one(); in Signal()
49 … if (cv_.wait_for(lock, std::chrono::seconds(MAX_WAIT_TIME_IN_SEC)) == std::cv_status::timeout) { in Wait()
59 std::condition_variable cv_; variable
|
| /third_party/grpc/test/core/handshake/ |
| D | server_ssl_common.cc | 84 cv_.Signal(); in Activate()
89 cv_.WaitUntil(&mu_, [this] { return ready_; }); in Await()
95 grpc_core::CondVar cv_; member in __anon82a3c2a00111::ServerInfo
|
| /third_party/grpc/test/core/end2end/ |
| D | inproc_callback_test.cc | 68 gpr_cv_init(&cv_); in ShutdownCallback()
72 gpr_cv_destroy(&cv_); in ~ShutdownCallback()
83 gpr_cv_broadcast(&cv_); in Run()
91 while (!done_ && !gpr_cv_wait(&cv_, &mu_, deadline)) { in Wait()
101 gpr_cv cv_; member in __anonaf55b99f0111::ShutdownCallback
|