| /external/pigweed/pw_sync/ |
| D | condition_variable_test.cc | 110 ConditionVariable condvar; in TEST() local
113 LambdaThread thread([&mutex, &condvar, &info = thread_info] { in TEST()
115 condvar.wait(l, [] { return true; }); in TEST()
124 ConditionVariable condvar; in TEST() local
127 LambdaThread thread([&mutex, &condvar, &info = thread_info] { in TEST()
129 condvar.wait(l, info.Predicate()); in TEST()
137 condvar.notify_one(); in TEST()
143 ConditionVariable condvar; in TEST() local
148 [&mutex, &condvar, &info = thread_info[0], &wait_order] { in TEST()
156 condvar.wait(l, predicate); in TEST()
[all …]
|
| /external/angle/third_party/abseil-cpp/absl/synchronization/ |
| D | lifetime_test.cc | 41 void ThreadOne(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadOne() argument
54 condvar->Wait(mutex); in ThreadOne()
59 void ThreadTwo(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadTwo() argument
69 condvar->Signal(); in ThreadTwo()
76 void RunTests(absl::Mutex* mutex, absl::CondVar* condvar) { in RunTests() argument
83 if (!condvar) { in RunTests()
84 condvar = &default_condvar; in RunTests()
87 std::thread thread_one(ThreadOne, mutex, condvar, ¬ification, &state); in RunTests()
88 std::thread thread_two(ThreadTwo, mutex, condvar, ¬ification, &state); in RunTests()
95 absl::CondVar condvar; in TestLocals() local
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/synchronization/ |
| D | lifetime_test.cc | 41 void ThreadOne(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadOne() argument
54 condvar->Wait(mutex); in ThreadOne()
59 void ThreadTwo(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadTwo() argument
69 condvar->Signal(); in ThreadTwo()
76 void RunTests(absl::Mutex* mutex, absl::CondVar* condvar) { in RunTests() argument
83 if (!condvar) { in RunTests()
84 condvar = &default_condvar; in RunTests()
87 std::thread thread_one(ThreadOne, mutex, condvar, ¬ification, &state); in RunTests()
88 std::thread thread_two(ThreadTwo, mutex, condvar, ¬ification, &state); in RunTests()
95 absl::CondVar condvar; in TestLocals() local
[all …]
|
| /external/tensorflow/third_party/absl/abseil-cpp/absl/synchronization/ |
| D | lifetime_test.cc | 41 void ThreadOne(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadOne() argument
54 condvar->Wait(mutex); in ThreadOne()
59 void ThreadTwo(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadTwo() argument
69 condvar->Signal(); in ThreadTwo()
76 void RunTests(absl::Mutex* mutex, absl::CondVar* condvar) { in RunTests() argument
83 if (!condvar) { in RunTests()
84 condvar = &default_condvar; in RunTests()
87 std::thread thread_one(ThreadOne, mutex, condvar, ¬ification, &state); in RunTests()
88 std::thread thread_two(ThreadTwo, mutex, condvar, ¬ification, &state); in RunTests()
95 absl::CondVar condvar; in TestLocals() local
[all …]
|
| /external/abseil-cpp/absl/synchronization/ |
| D | lifetime_test.cc | 41 void ThreadOne(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadOne() argument
54 condvar->Wait(mutex); in ThreadOne()
59 void ThreadTwo(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadTwo() argument
69 condvar->Signal(); in ThreadTwo()
76 void RunTests(absl::Mutex* mutex, absl::CondVar* condvar) { in RunTests() argument
83 if (!condvar) { in RunTests()
84 condvar = &default_condvar; in RunTests()
87 std::thread thread_one(ThreadOne, mutex, condvar, ¬ification, &state); in RunTests()
88 std::thread thread_two(ThreadTwo, mutex, condvar, ¬ification, &state); in RunTests()
95 absl::CondVar condvar; in TestLocals() local
[all …]
|
| /external/cronet/third_party/abseil-cpp/absl/synchronization/ |
| D | lifetime_test.cc | 41 void ThreadOne(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadOne() argument
54 condvar->Wait(mutex); in ThreadOne()
59 void ThreadTwo(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadTwo() argument
69 condvar->Signal(); in ThreadTwo()
76 void RunTests(absl::Mutex* mutex, absl::CondVar* condvar) { in RunTests() argument
83 if (!condvar) { in RunTests()
84 condvar = &default_condvar; in RunTests()
87 std::thread thread_one(ThreadOne, mutex, condvar, ¬ification, &state); in RunTests()
88 std::thread thread_two(ThreadTwo, mutex, condvar, ¬ification, &state); in RunTests()
95 absl::CondVar condvar; in TestLocals() local
[all …]
|
| /external/openscreen/third_party/abseil/src/absl/synchronization/ |
| D | lifetime_test.cc | 41 void ThreadOne(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadOne() argument
54 condvar->Wait(mutex); in ThreadOne()
59 void ThreadTwo(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadTwo() argument
69 condvar->Signal(); in ThreadTwo()
76 void RunTests(absl::Mutex* mutex, absl::CondVar* condvar) { in RunTests() argument
83 if (!condvar) { in RunTests()
84 condvar = &default_condvar; in RunTests()
87 std::thread thread_one(ThreadOne, mutex, condvar, ¬ification, &state); in RunTests()
88 std::thread thread_two(ThreadTwo, mutex, condvar, ¬ification, &state); in RunTests()
95 absl::CondVar condvar; in TestLocals() local
[all …]
|
| /external/libtextclassifier/abseil-cpp/absl/synchronization/ |
| D | lifetime_test.cc | 41 void ThreadOne(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadOne() argument
54 condvar->Wait(mutex); in ThreadOne()
59 void ThreadTwo(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadTwo() argument
69 condvar->Signal(); in ThreadTwo()
76 void RunTests(absl::Mutex* mutex, absl::CondVar* condvar) { in RunTests() argument
83 if (!condvar) { in RunTests()
84 condvar = &default_condvar; in RunTests()
87 std::thread thread_one(ThreadOne, mutex, condvar, ¬ification, &state); in RunTests()
88 std::thread thread_two(ThreadTwo, mutex, condvar, ¬ification, &state); in RunTests()
95 absl::CondVar condvar; in TestLocals() local
[all …]
|
| /external/webrtc/third_party/abseil-cpp/absl/synchronization/ |
| D | lifetime_test.cc | 41 void ThreadOne(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadOne() argument
54 condvar->Wait(mutex); in ThreadOne()
59 void ThreadTwo(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadTwo() argument
69 condvar->Signal(); in ThreadTwo()
76 void RunTests(absl::Mutex* mutex, absl::CondVar* condvar) { in RunTests() argument
83 if (!condvar) { in RunTests()
84 condvar = &default_condvar; in RunTests()
87 std::thread thread_one(ThreadOne, mutex, condvar, ¬ification, &state); in RunTests()
88 std::thread thread_two(ThreadTwo, mutex, condvar, ¬ification, &state); in RunTests()
95 absl::CondVar condvar; in TestLocals() local
[all …]
|
| /external/ruy/ruy/ |
| D | wait_test.cc | 37 std::condition_variable* condvar, std::mutex* mutex) in ThreadCountingUpToValue() argument
40 condvar_(condvar), in ThreadCountingUpToValue()
71 std::condition_variable condvar; in WaitTest() local
75 ThreadCountingUpToValue thread_callable(end_value, &value, &condvar, &mutex); in WaitTest()
83 ruy::Wait(condition, spin_duration, &condvar, &mutex); in WaitTest()
|
| D | wait.cc | 23 std::condition_variable* condvar, std::mutex* mutex) { in Wait() argument
41 condvar->wait(lock, condition); in Wait()
|
| D | wait.h | 64 std::condition_variable* condvar, std::mutex* mutex);
|
| /external/rust/crates/parking_lot_core/src/thread_parker/ |
| D | unix.rs | 31 condvar: UnsafeCell<libc::pthread_cond_t>, field
45 condvar: UnsafeCell::new(libc::PTHREAD_COND_INITIALIZER), in new()
77 let r = libc::pthread_cond_wait(self.condvar.get(), self.mutex.get()); in park()
97 let r = libc::pthread_cond_timedwait(self.condvar.get(), self.mutex.get(), &ts); in park_until()
108 let r = libc::pthread_cond_wait(self.condvar.get(), self.mutex.get()); in park_until()
155 let r = libc::pthread_cond_init(self.condvar.get(), attr.as_ptr()); in init()
172 let r = libc::pthread_cond_destroy(self.condvar.get()); in drop()
190 let r = libc::pthread_cond_signal((*self.thread_parker).condvar.get()); in unpark()
|
| /external/rust/crates/tokio/src/runtime/scheduler/multi_thread/ |
| D | park.rs | 30 condvar: Condvar, field
53 condvar: Condvar::new(), in new()
91 condvar: Condvar::new(), in clone()
153 m = self.condvar.wait(m).unwrap(); in park_condvar()
227 self.condvar.notify_one() in unpark_condvar()
235 self.condvar.notify_all(); in shutdown()
|
| /external/mesa3d/src/util/ |
| D | u_thread.h | 278 cnd_t condvar; member
287 cnd_init(&barrier->condvar); in util_barrier_init()
294 cnd_destroy(&barrier->condvar); in util_barrier_destroy()
308 cnd_wait(&barrier->condvar, &barrier->mutex); in util_barrier_wait()
313 cnd_broadcast(&barrier->condvar); in util_barrier_wait()
|
| /external/rust/crates/tokio/src/runtime/ |
| D | park.rs | 24 condvar: Condvar, field
49 condvar: Condvar::new(), in new()
117 m = self.condvar.wait(m).unwrap(); in park()
165 let (_m, _result) = self.condvar.wait_timeout(m, dur).unwrap(); in park_timeout()
200 self.condvar.notify_one() in unpark()
204 self.condvar.notify_all(); in shutdown()
|
| /external/virglrenderer/src/mesa/util/ |
| D | u_thread.h | 312 cnd_t condvar; member
321 cnd_init(&barrier->condvar); in util_barrier_init()
328 cnd_destroy(&barrier->condvar); in util_barrier_destroy()
342 cnd_wait(&barrier->condvar, &barrier->mutex); in util_barrier_wait()
347 cnd_broadcast(&barrier->condvar); in util_barrier_wait()
|
| /external/crosvm/common/sync/src/ |
| D | lib.rs | 24 mod condvar; module
27 pub use crate::condvar::Condvar;
|
| /external/libevent/ |
| D | evthread-internal.h | 153 #define EVTHREAD_ALLOC_COND(condvar) \ argument
155 (condvar) = evthread_cond_fns_.alloc_condition ? \
276 #define EVTHREAD_ALLOC_COND(condvar) \ argument
278 (condvar) = evthreadimpl_cond_alloc_(0); \
325 #define EVTHREAD_ALLOC_COND(condvar) EVUTIL_NIL_STMT_ argument
|
| /external/crosvm/cros_async/src/blocking/ |
| D | pool.rs | 51 .condvar in run_blocking_thread()
101 condvar: Condvar, field
146 self.condvar.notify_one(); in spawn()
231 condvar: Condvar::new(), in new()
253 condvar: Condvar::new(), in with_capacity()
297 self.inner.condvar.notify_all(); in shutdown()
478 state = inner.condvar.wait(state); in shutdown_with_pending_work()
|
| /external/mesa3d/include/c11/ |
| D | threads_win32.h | 97 CONDITION_VARIABLE condvar; member
331 WakeAllConditionVariable(&cond->condvar); in cnd_broadcast()
358 InitializeConditionVariable(&cond->condvar); in cnd_init()
376 WakeConditionVariable(&cond->condvar); in cnd_signal()
389 if (SleepConditionVariableCS(&cond->condvar, mtx, impl_timespec2msec(abs_time))) in cnd_timedwait()
403 SleepConditionVariableCS(&cond->condvar, mtx, INFINITE); in cnd_wait()
|
| /external/rust/crates/parking_lot/src/ |
| D | lib.rs | 15 mod condvar; module
41 pub use self::condvar::{Condvar, WaitTimeoutResult};
|
| /external/rust/crates/tokio/src/runtime/blocking/ |
| D | pool.rs | 79 condvar: Condvar, field
224 condvar: Condvar::new(), in new()
254 self.spawner.inner.condvar.notify_all(); in shutdown()
446 self.inner.condvar.notify_one(); in spawn_task()
520 let lock_result = self.condvar.wait_timeout(shared, self.keep_alive).unwrap(); in run()
581 self.condvar.notify_one(); in run()
|
| /external/rust/crates/tokio-test/src/ |
| D | task.rs | 40 condvar: Condvar, field
179 condvar: Condvar::new(), in new()
215 self.condvar.notify_one(); in wake()
|
| /external/rust/crates/rayon-core/src/sleep/ |
| D | mod.rs | 58 condvar: Condvar, field
228 is_blocked = sleep_state.condvar.wait(is_blocked).unwrap(); in sleep()
362 sleep_state.condvar.notify_one(); in wake_specific_thread()
|