| /third_party/mindspore/mindspore/ccsrc/pipeline/jit/static_analysis/ |
| D | async_eval_result.h | 263 int Ready() const { return ready_; } in Ready()
268 if (ready_) { in GetResult()
277 MS_LOG(DEBUG) << this << " after enter waiting ready: " << ready_ << " thread id:" << threadId_ in GetResult()
279 condition_var_.wait(lock, [this] { return ready_; }); in GetResult()
280 … MS_LOG(DEBUG) << this << " received notify and wake up: " << ready_ << " thread id:" << threadId_ in GetResult()
292 ready_ = ready_ | 1; // Set the first bit = 1 in SetReady()
293 …MS_LOG(DEBUG) << this << " notify ready: " << ready_ << " result: " << abstract_ptr_->TryGetResult… in SetReady()
303 ready_ = ready_ | 2; // Set the second bit = 1 in SetException()
304 MS_LOG(DEBUG) << this << " notify ready: " << ready_; in SetException()
313 ready_ = ready_ | 4; // Set the third bit = 1 in SetEndLessLoopException()
[all …]
|
| /third_party/boost/boost/fiber/future/detail/ |
| D | shared_state.hpp | 44 bool ready_{ false }; member in boost::fibers::detail::shared_state_base
49 ready_ = true; in mark_ready_and_notify_()
56 if ( ! ready_) { in owner_destroyed_()
65 if ( BOOST_UNLIKELY( ready_) ) { in set_exception_()
80 waiters_.wait( lk, [this](){ return ready_; }); in wait_()
87 return waiters_.wait_for( lk, timeout_duration, [this](){ return ready_; }) in wait_for_()
96 return waiters_.wait_until( lk, timeout_time, [this](){ return ready_; }) in wait_until_()
164 if ( BOOST_UNLIKELY( ready_) ) { in set_value_()
173 if ( BOOST_UNLIKELY( ready_) ) { in set_value_()
195 if ( ready_ && ! except_) { in ~shared_state()
[all …]
|
| /third_party/boost/boost/asio/impl/ |
| D | spawn.hpp | 46 ready_(0), in coro_handler()
56 if (--*ready_ == 0) in operator ()()
64 if (--*ready_ == 0) in operator ()()
72 atomic_count* ready_; member in boost::asio::detail::coro_handler
85 ready_(0), in coro_handler()
93 if (--*ready_ == 0) in operator ()()
100 if (--*ready_ == 0) in operator ()()
108 atomic_count* ready_; member in boost::asio::detail::coro_handler
178 ready_(2) in coro_async_result()
180 h.ready_ = &ready_; in coro_async_result()
[all …]
|
| /third_party/boost/libs/asio/include/boost/asio/impl/ |
| D | spawn.hpp | 46 ready_(0), in coro_handler()
56 if (--*ready_ == 0) in operator ()()
64 if (--*ready_ == 0) in operator ()()
72 atomic_count* ready_; member in boost::asio::detail::coro_handler
85 ready_(0), in coro_handler()
93 if (--*ready_ == 0) in operator ()()
100 if (--*ready_ == 0) in operator ()()
108 atomic_count* ready_; member in boost::asio::detail::coro_handler
178 ready_(2) in coro_async_result()
180 h.ready_ = &ready_; in coro_async_result()
[all …]
|
| /third_party/grpc/src/core/lib/gprpp/ |
| D | thd_windows.cc | 61 gpr_cv_init(&ready_); in ThreadInternalsWindows()
98 gpr_cv_destroy(&ready_); in ~ThreadInternalsWindows()
104 gpr_cv_signal(&ready_); in Start()
119 gpr_cv_wait(&g_thd_info->thread->ready_, &g_thd_info->thread->mu_, in thread_body()
145 gpr_cv ready_; member in __anona234cc0a0111::ThreadInternalsWindows
|
| D | thd_posix.cc | 78 gpr_cv_init(&ready_); in ThreadInternalsPosix()
131 gpr_cv_wait(&arg.thread->ready_, &arg.thread->mu_, in ThreadInternalsPosix()
161 gpr_cv_destroy(&ready_); in ~ThreadInternalsPosix()
167 gpr_cv_signal(&ready_); in Start()
175 gpr_cv ready_; member in grpc_core::__anon6b884cf20111::ThreadInternalsPosix
|
| /third_party/boost/libs/exception/test/ |
| D | copy_exception_test.cpp | 48 ready_ (false) in future()
57 ready_ = true; in set_exception()
65 while (! ready_) in get_exception()
72 bool ready_; member in future
|
| /third_party/boost/libs/iostreams/src/ |
| D | bzip2.cpp | 80 : params_(params), stream_(new bz_stream), ready_(false) in bzip2_base()
116 if (!ready_) return bzip2::ok; in end()
117 ready_ = false; in end()
164 ready_ = true; in do_init()
|
| /third_party/boost/libs/asio/include/boost/asio/detail/ |
| D | win_iocp_operation.hpp | 79 ready_ = 0; in reset()
87 long ready_; member in boost::asio::detail::win_iocp_operation
|
| /third_party/boost/boost/asio/detail/ |
| D | win_iocp_operation.hpp | 79 ready_ = 0; in reset()
87 long ready_; member in boost::asio::detail::win_iocp_operation
|
| /third_party/grpc/test/core/handshake/ |
| D | server_ssl_common.cc | 83 ready_ = true; in Activate()
89 cv_.WaitUntil(&mu_, [this] { return ready_; }); in Await()
96 bool ready_ = false; member in __anon82a3c2a00111::ServerInfo
|
| /third_party/flutter/skia/third_party/externals/libwebp/src/dec/ |
| D | vp8_dec.c | 62 dec->ready_ = 0; in VP8New()
93 dec->ready_ = 0; in VP8SetError()
389 dec->ready_ = 1; in VP8GetHeaders()
682 if (!dec->ready_) { in VP8Decode()
687 assert(dec->ready_); in VP8Decode()
707 dec->ready_ = 0; in VP8Decode()
721 dec->ready_ = 0; in VP8Clear()
|
| D | vp8i_dec.h | 184 int ready_; // true if ready to decode a picture with VP8Decode() member
|
| D | idec_dec.c | 452 if (!dec->ready_) { in DecodeRemaining()
503 dec->ready_ = 0; in DecodeRemaining()
|
| /third_party/mindspore/mindspore/core/load_mindir/ |
| D | infer_mindir.cc | 68 std::deque<AnfNodePtr> ready_; member in mindspore::__anone6c6b8370111::MindIREngine
76 while (!ready_.empty()) { in InferShape()
77 auto current = ready_.front(); in InferShape()
79 ready_.pop_front(); in InferShape()
124 ready_.push_back(node); in Init()
132 ready_.push_back(node); in Init()
476 ready_.push_back(user.first); in UpdateReady()
|
| /third_party/skia/third_party/externals/libwebp/src/dec/ |
| D | vp8_dec.c | 62 dec->ready_ = 0; in VP8New()
93 dec->ready_ = 0; in VP8SetError()
389 dec->ready_ = 1; in VP8GetHeaders()
680 if (!dec->ready_) { in VP8Decode()
685 assert(dec->ready_); in VP8Decode()
705 dec->ready_ = 0; in VP8Decode()
719 dec->ready_ = 0; in VP8Clear()
|
| D | vp8i_dec.h | 184 int ready_; // true if ready to decode a picture with VP8Decode() member
|
| /third_party/ninja/src/ |
| D | build.cc | 318 ready_.clear(); in Reset()
383 if (ready_.empty()) in FindWork()
385 set<Edge*>::iterator e = ready_.begin(); in FindWork()
387 ready_.erase(e); in FindWork()
406 pool->RetrieveReadyEdges(&ready_); in ScheduleWork()
409 ready_.insert(edge); in ScheduleWork()
421 edge->pool()->RetrieveReadyEdges(&ready_); in EdgeFinished()
665 printf("ready: %d\n", (int)ready_.size()); in Dump()
|
| D | build.h | 125 set<Edge*> ready_; member
|
| /third_party/boost/libs/asio/include/boost/asio/detail/impl/ |
| D | win_iocp_io_context.ipp | 305 op->ready_ = 1;
325 op->ready_ = 1;
352 if (::InterlockedCompareExchange(&op->ready_, 1, 0) == 1)
370 op->ready_ = 1;
393 op->ready_ = 1;
467 if (::InterlockedCompareExchange(&op->ready_, 1, 0) == 1)
|
| /third_party/boost/boost/asio/detail/impl/ |
| D | win_iocp_io_context.ipp | 305 op->ready_ = 1;
325 op->ready_ = 1;
352 if (::InterlockedCompareExchange(&op->ready_, 1, 0) == 1)
370 op->ready_ = 1;
393 op->ready_ = 1;
467 if (::InterlockedCompareExchange(&op->ready_, 1, 0) == 1)
|
| /third_party/node/src/ |
| D | node_platform.cc | 60 uv_sem_init(&ready_, 0); in Start()
62 uv_sem_wait(&ready_); in Start()
63 uv_sem_destroy(&ready_); in Start()
86 uv_sem_post(&ready_); in Run()
157 uv_sem_t ready_; member in node::WorkerThreadsTaskRunner::DelayedTaskScheduler
|
| /third_party/boost/boost/iostreams/filter/ |
| D | bzip2.hpp | 161 bool& ready() { return ready_; } in ready()
187 bool ready_; member in boost::iostreams::detail::bzip2_base
|
| /third_party/cef/libcef/browser/extensions/ |
| D | extension_system.cc | 179 ready_.Signal(); in Init()
477 return ready_; in ready()
481 return ready_.is_signaled(); in is_ready()
|
| D | extension_system.h | 185 base::OneShotEvent ready_; variable
|