| /external/libchrome/mojo/public/cpp/system/ |
| wait.h | 21 // If |signals_state| is non-null, |handle| is valid, the wait is not cancelled
34 // |MOJO_RESULT_CANCELLED| if the wait was cancelled because |handle| was
37 Wait(Handle handle,
42 // A pseudonym for the above Wait() which always waits on
44 inline MojoResult Wait(Handle handle,
47 return Wait(handle, signals, MOJO_TRIGGER_CONDITION_SIGNALS_SATISFIED,
57 // This means that |WaitMany()| behaves as if |Wait()| were called on each
58 // handle/signals pair simultaneously, completing when the first |Wait()| would
61 // If |signals_states| is non-null, all other arguments are valid, and the wait
76 // |MOJO_RESULT_CANCELLED| if the wait was cancelled because a handle i
[all...] |
| /art/runtime/ |
| signal_set.h | 46 int Wait() {
|
| barrier.cc | 43 void Barrier::Wait(Thread* self) {
68 condition_->Wait(self);
|
| /external/llvm/include/llvm/Support/ |
| Threading.h | 69 enum InitStatus { Uninitialized = 0, Wait = 1, Done = 2 };
98 sys::cas_flag old_val = sys::CompareAndSwap(&flag, Wait, Uninitialized);
107 // Wait until any thread doing the call has finished.
|
| /external/swiftshader/third_party/llvm-7.0/llvm/include/llvm/Support/ |
| Threading.h | 73 enum InitStatus { Uninitialized = 0, Wait = 1, Done = 2 };
106 sys::cas_flag old_val = sys::CompareAndSwap(&flag.status, Wait, Uninitialized);
115 // Wait until any thread doing the call has finished.
|
| /external/swiftshader/third_party/llvm-subzero/include/llvm/Support/ |
| Threading.h | 69 enum InitStatus { Uninitialized = 0, Wait = 1, Done = 2 };
98 sys::cas_flag old_val = sys::CompareAndSwap(&flag, Wait, Uninitialized);
107 // Wait until any thread doing the call has finished.
|
| /external/syzkaller/vm/vmimpl/ |
| merger.go | 39 func (merger *OutputMerger) Wait() {
40 merger.wg.Wait()
|
| /external/webrtc/webrtc/base/ |
| event.cc | 49 bool Event::Wait(int milliseconds) {
81 bool Event::Wait(int milliseconds) {
|
| nullsocketserver.h | 25 virtual bool Wait(int cms, bool process_io) {
26 event_.Wait(cms);
|
| /external/webrtc/webrtc/system_wrappers/source/ |
| event_timer_win.cc | 40 EventTypeWrapper EventTimerWin::Wait(unsigned long max_time) {
|
| /art/openjdkjvmti/ |
| ti_monitor.cc | 54 // as the do not have the right semantics for recursive mutexes and waiting (wait only unlocks
138 bool Wait(art::Thread* self) {
140 cond_.wait(lk);
142 return Wait(self, wait_without_timeout);
145 bool Wait(art::Thread* self, uint64_t timeout_in_ms) {
149 return Wait(self, wait_with_timeout);
170 bool Wait(art::Thread* self, T how_to_wait) {
193 // TODO Give an extension to wait without suspension as well.
308 // valid call though. We treat it as though it was 0 and wait indefinitely.
310 ? monitor->Wait(self, static_cast<uint64_t>(millis)
[all...] |
| /art/test/132-daemon-locks-shutdown/src/ |
| Main.java | 28 Thread t = new Thread(new Wait(sync));
34 private static class Wait implements Runnable {
37 public Wait(Object obj) {
45 obj.wait(1);
|
| /external/chromium-trace/catapult/systrace/atrace_helper/jni/ |
| time_utils.cc | 51 bool PeriodicTimer::Wait() {
|
| /external/libchrome/base/synchronization/ |
| condition_variable_posix.cc | 65 void ConditionVariable::Wait() {
|
| /external/tensorflow/tensorflow/core/lib/core/ |
| blocking_counter.h | 48 inline void Wait() {
53 cond_var_.wait(l);
56 // Wait for the specified time, return false iff the count has not dropped to
|
| /external/v8/src/base/platform/ |
| condition-variable.cc | 72 void ConditionVariable::Wait(Mutex* mutex) {
135 void ConditionVariable::Wait(Mutex* mutex) {
|
| semaphore.cc | 44 void Semaphore::Wait() {
98 void Semaphore::Wait() {
114 // Wait for semaphore signalled or timeout.
158 void Semaphore::Wait() {
|
| /external/v8/src/heap/ |
| barrier.h | 26 // } while(!shared_barrier->Wait());
46 bool Wait() {
57 condition_.Wait(&mutex_);
|
| /external/webrtc/webrtc/examples/peerconnection/client/linux/ |
| main.cc | 31 virtual bool Wait(int cms, bool process_io) {
44 return rtc::PhysicalSocketServer::Wait(0/*cms == -1 ? 1 : cms*/,
|
| /external/webrtc/webrtc/voice_engine/test/auto_test/standard/ |
| rtp_rtcp_extensions.cc | 71 bool Wait() {
72 // Wait until we've received to specified number of packets.
108 EXPECT_FALSE(verifying_transport_.Wait());
116 EXPECT_TRUE(verifying_transport_.Wait());
123 EXPECT_FALSE(verifying_transport_.Wait());
131 EXPECT_TRUE(verifying_transport_.Wait());
142 EXPECT_TRUE(verifying_transport_.Wait());
154 EXPECT_TRUE(verifying_transport_.Wait());
|
| /external/libchrome/mojo/public/cpp/bindings/lib/ |
| sync_handle_registry.cc | 93 // stack frame is currently iterating over it in Wait().
114 // Regardless of whether or not we're nested within a Wait(), we need to
122 bool SyncHandleRegistry::Wait(const bool* should_stop[], size_t count) {
140 wait_set_.Wait(&ready_event, &num_ready_handles, &ready_handle,
|
| /external/lzma/CPP/Windows/ |
| Thread.h | 22 WRes Wait() { return Thread_Wait(&thread); }
|
| /device/google/cuttlefish_common/common/libs/threads/ |
| cuttlefish_thread.h | 93 int Wait() {
|
| /external/dng_sdk/source/ |
| dng_abort_sniffer.cpp | 45 void Wait (dng_priority priority);
127 void dng_priority_manager::Wait (dng_priority priority)
138 fCondition.Wait (fMutex);
210 gPriorityManager.Wait (sniffer->Priority ());
|
| /external/google-breakpad/src/tools/mac/upload_system_symbols/ |
| upload_system_symbols.go | 106 uq.Wait()
138 dq.Wait()
140 uq.Wait()
162 // Wait for all the workers in the pool to complete the workerFunc.
163 func (p *WorkerPool) Wait() {
164 p.wg.Wait()
188 // called before WorkerPool.Wait.
250 func (dq *DumpQueue) Wait() {
251 dq.WorkerPool.Wait()
329 fq.Wait()
[all...] |
