| /external/rust/crates/tokio/tests/ |
| D | sync_notify.rs | 17 let mut notified = spawn(async { notify.notified().await }); in notify_notified_one() localVariable
20 assert_ready!(notified.poll()); in notify_notified_one()
26 let mut notified = spawn(async { notify.notified().await }); in notified_one_notify() localVariable
28 assert_pending!(notified.poll()); in notified_one_notify()
31 assert!(notified.is_woken()); in notified_one_notify()
32 assert_ready!(notified.poll()); in notified_one_notify()
38 let mut notified1 = spawn(async { notify.notified().await }); in notified_multi_notify()
39 let mut notified2 = spawn(async { notify.notified().await }); in notified_multi_notify()
58 let mut notified1 = spawn(async { notify.notified().await }); in notify_notified_multi()
59 let mut notified2 = spawn(async { notify.notified().await }); in notify_notified_multi()
[all …]
|
| /external/pigweed/pw_sync_freertos/ |
| D | timed_thread_notification.cc | 64 const bool notified = native_handle().notified; in try_acquire_until() local
66 if (notified || (SystemClock::now() >= deadline)) { in try_acquire_until()
67 native_handle().notified = false; in try_acquire_until()
68 return notified; in try_acquire_until()
101 const bool notified = native_handle().notified; in try_acquire_until() local
102 native_handle().notified = false; in try_acquire_until()
104 return notified; in try_acquire_until()
|
| D | thread_notification.cc | 59 if (native_type_.notified) { in acquire()
60 native_type_.notified = false; in acquire()
78 native_type_.notified = false; in acquire()
95 native_type_.notified = true; in release()
119 native_type_.notified = true; in release()
|
| /external/abseil-cpp/absl/synchronization/ |
| D | notification.cc | 58 bool notified = HasBeenNotifiedInternal(&this->notified_yet_); in WaitForNotificationWithTimeout() local
59 if (!notified) { in WaitForNotificationWithTimeout()
60 notified = this->mutex_.LockWhenWithTimeout( in WaitForNotificationWithTimeout()
64 return notified; in WaitForNotificationWithTimeout()
68 bool notified = HasBeenNotifiedInternal(&this->notified_yet_); in WaitForNotificationWithDeadline() local
69 if (!notified) { in WaitForNotificationWithDeadline()
70 notified = this->mutex_.LockWhenWithDeadline( in WaitForNotificationWithDeadline()
74 return notified; in WaitForNotificationWithDeadline()
|
| /external/cronet/third_party/abseil-cpp/absl/synchronization/ |
| D | notification.cc | 57 bool notified = HasBeenNotifiedInternal(&this->notified_yet_); in WaitForNotificationWithTimeout() local
58 if (!notified) { in WaitForNotificationWithTimeout()
59 notified = this->mutex_.LockWhenWithTimeout( in WaitForNotificationWithTimeout()
63 return notified; in WaitForNotificationWithTimeout()
67 bool notified = HasBeenNotifiedInternal(&this->notified_yet_); in WaitForNotificationWithDeadline() local
68 if (!notified) { in WaitForNotificationWithDeadline()
69 notified = this->mutex_.LockWhenWithDeadline( in WaitForNotificationWithDeadline()
73 return notified; in WaitForNotificationWithDeadline()
|
| /external/libtextclassifier/abseil-cpp/absl/synchronization/ |
| D | notification.cc | 58 bool notified = HasBeenNotifiedInternal(&this->notified_yet_); in WaitForNotificationWithTimeout() local
59 if (!notified) { in WaitForNotificationWithTimeout()
60 notified = this->mutex_.LockWhenWithTimeout( in WaitForNotificationWithTimeout()
64 return notified; in WaitForNotificationWithTimeout()
68 bool notified = HasBeenNotifiedInternal(&this->notified_yet_); in WaitForNotificationWithDeadline() local
69 if (!notified) { in WaitForNotificationWithDeadline()
70 notified = this->mutex_.LockWhenWithDeadline( in WaitForNotificationWithDeadline()
74 return notified; in WaitForNotificationWithDeadline()
|
| /external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/synchronization/ |
| D | notification.cc | 58 bool notified = HasBeenNotifiedInternal(&this->notified_yet_); in WaitForNotificationWithTimeout() local
59 if (!notified) { in WaitForNotificationWithTimeout()
60 notified = this->mutex_.LockWhenWithTimeout( in WaitForNotificationWithTimeout()
64 return notified; in WaitForNotificationWithTimeout()
68 bool notified = HasBeenNotifiedInternal(&this->notified_yet_); in WaitForNotificationWithDeadline() local
69 if (!notified) { in WaitForNotificationWithDeadline()
70 notified = this->mutex_.LockWhenWithDeadline( in WaitForNotificationWithDeadline()
74 return notified; in WaitForNotificationWithDeadline()
|
| /external/angle/third_party/abseil-cpp/absl/synchronization/ |
| D | notification.cc | 57 bool notified = HasBeenNotifiedInternal(&this->notified_yet_); in WaitForNotificationWithTimeout() local
58 if (!notified) { in WaitForNotificationWithTimeout()
59 notified = this->mutex_.LockWhenWithTimeout( in WaitForNotificationWithTimeout()
63 return notified; in WaitForNotificationWithTimeout()
67 bool notified = HasBeenNotifiedInternal(&this->notified_yet_); in WaitForNotificationWithDeadline() local
68 if (!notified) { in WaitForNotificationWithDeadline()
69 notified = this->mutex_.LockWhenWithDeadline( in WaitForNotificationWithDeadline()
73 return notified; in WaitForNotificationWithDeadline()
|
| /external/tensorflow/third_party/absl/abseil-cpp/absl/synchronization/ |
| D | notification.cc | 58 bool notified = HasBeenNotifiedInternal(&this->notified_yet_); in WaitForNotificationWithTimeout() local
59 if (!notified) { in WaitForNotificationWithTimeout()
60 notified = this->mutex_.LockWhenWithTimeout( in WaitForNotificationWithTimeout()
64 return notified; in WaitForNotificationWithTimeout()
68 bool notified = HasBeenNotifiedInternal(&this->notified_yet_); in WaitForNotificationWithDeadline() local
69 if (!notified) { in WaitForNotificationWithDeadline()
70 notified = this->mutex_.LockWhenWithDeadline( in WaitForNotificationWithDeadline()
74 return notified; in WaitForNotificationWithDeadline()
|
| /external/webrtc/third_party/abseil-cpp/absl/synchronization/ |
| D | notification.cc | 57 bool notified = HasBeenNotifiedInternal(&this->notified_yet_); in WaitForNotificationWithTimeout() local
58 if (!notified) { in WaitForNotificationWithTimeout()
59 notified = this->mutex_.LockWhenWithTimeout( in WaitForNotificationWithTimeout()
63 return notified; in WaitForNotificationWithTimeout()
67 bool notified = HasBeenNotifiedInternal(&this->notified_yet_); in WaitForNotificationWithDeadline() local
68 if (!notified) { in WaitForNotificationWithDeadline()
69 notified = this->mutex_.LockWhenWithDeadline( in WaitForNotificationWithDeadline()
73 return notified; in WaitForNotificationWithDeadline()
|
| /external/openscreen/third_party/abseil/src/absl/synchronization/ |
| D | notification.cc | 58 bool notified = HasBeenNotifiedInternal(&this->notified_yet_); in WaitForNotificationWithTimeout() local
59 if (!notified) { in WaitForNotificationWithTimeout()
60 notified = this->mutex_.LockWhenWithTimeout( in WaitForNotificationWithTimeout()
64 return notified; in WaitForNotificationWithTimeout()
68 bool notified = HasBeenNotifiedInternal(&this->notified_yet_); in WaitForNotificationWithDeadline() local
69 if (!notified) { in WaitForNotificationWithDeadline()
70 notified = this->mutex_.LockWhenWithDeadline( in WaitForNotificationWithDeadline()
74 return notified; in WaitForNotificationWithDeadline()
|
| /external/rust/crates/tokio/src/sync/tests/ |
| D | loom_notify.rs | 15 rx.notified().await; in notify_one()
29 let notified1 = notify.notified(); in notify_waiters()
30 let notified2 = notify.notified(); in notify_waiters()
61 let notified = notify.notified(); in notify_waiters_and_one() localVariable
64 notified.await; in notify_waiters_and_one()
86 notify.notified().await; in notify_multi()
99 notify.notified().await; in notify_multi()
116 let mut recv = Box::pin(rx1.notified()); in notify_drop()
128 rx2.notified().await; in notify_drop()
131 rx2.notified().await; in notify_drop()
|
| D | notify.rs | 42 let future = notify.notified(); in notify_clones_waker_before_lock()
53 let mut fut1 = tokio_test::task::spawn(notify.notified()); in notify_simple()
56 let mut fut2 = tokio_test::task::spawn(notify.notified()); in notify_simple()
|
| /external/rust/crates/tokio/src/runtime/tests/ |
| D | task.rs | 52 let (notified, join) = unowned( in create_drop1()
60 drop(notified); in create_drop1()
69 let (notified, join) = unowned( in create_drop2()
79 drop(notified); in create_drop2()
86 let (notified, join) = unowned( in drop_abort_handle1()
97 drop(notified); in drop_abort_handle1()
106 let (notified, join) = unowned( in drop_abort_handle2()
115 drop(notified); in drop_abort_handle2()
127 let (notified, join) = unowned( in create_shutdown1()
137 notified.shutdown(); in create_shutdown1()
[all …]
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/fork/ |
| D | 18-1.c | 50 static int notified; variable
59 notified = (int)getpid(); in notification()
75 notified = 0; in main()
113 if (notified != 0) { in main()
114 if (notified == (int)getpid()) { in main()
138 if (notified != (int)getpid()) { in main()
139 output("Notified value: %d\n", notified); in main()
|
| /external/pigweed/pw_sync_freertos/public/pw_sync_freertos/ |
| D | thread_notification_inline.h | 35 .notified = false, in ThreadNotification()
44 const bool notified = native_type_.notified; in try_acquire() local
45 native_type_.notified = false; in try_acquire()
46 return notified; in try_acquire()
|
| /external/tensorflow/tensorflow/tsl/platform/default/ |
| D | notification.h | 63 bool notified = HasBeenNotified(); in WaitForNotificationWithTimeout() local
64 if (!notified) { in WaitForNotificationWithTimeout()
67 notified = HasBeenNotified(); in WaitForNotificationWithTimeout()
68 } while (!notified && in WaitForNotificationWithTimeout()
72 return notified; in WaitForNotificationWithTimeout()
|
| /external/ltp/testcases/kernel/syscalls/mq_notify/ |
| D | mq_notify01.c | 26 static volatile sig_atomic_t notified, cmp_ok; variable
93 notified = 1; in sigfunc()
99 notified = 1; in tfunc()
109 notified = cmp_ok = 1; in do_test()
113 notified = cmp_ok = 0; in do_test()
126 notified = cmp_ok = 0; in do_test()
166 while (!notified) in do_test()
|
| /external/rust/crates/tokio/src/sync/ |
| D | notify.rs | 226 notified: Option<NotificationType>, field
384 pub fn notified(&self) -> Notified<'_> { in notified() method
394 notified: None, in notified()
529 assert!(waiter.notified.is_none()); in notify_waiters()
531 waiter.notified = Some(NotificationType::AllWaiters); in notify_waiters()
600 assert!(waiter.notified.is_none()); in notify_locked()
602 waiter.notified = Some(NotificationType::OneWaiter); in notify_locked()
859 if w.notified.is_some() { in poll_notified()
863 w.notified = None; in poll_notified()
936 unsafe { (*waiter.get()).notified }, in drop()
|
| /external/rust/crates/tokio/src/runtime/scheduler/multi_thread/ |
| D | handle.rs | 46 let (handle, notified) = me.shared.owned.bind(future, me.clone(), id); in bind_new_task()
48 if let Some(notified) = notified { in bind_new_task()
49 me.schedule_task(notified, false); in bind_new_task()
|
| /external/rust/crates/tokio/src/runtime/task/ |
| D | list.rs | 94 let (task, notified, join) = super::new_task(task, scheduler, id); in bind()
105 drop(notified); in bind()
110 (join, Some(notified)) in bind()
198 let (task, notified, join) = super::new_task(task, scheduler, id); in bind()
207 drop(notified); in bind()
214 (join, Some(notified)) in bind()
|
| /external/rust/crates/tokio/src/util/ |
| D | idle_notified_set.rs | 50 notified: LinkedList<T>, field
130 notified: LinkedList::new(), in new()
191 let entry = lock.notified.pop_back()?; in pop_notified()
234 get_ptrs(&mut lock.notified, &mut ptrs); in for_each()
304 move_to_new_list(&mut lock.notified, &mut all_entries.all_entries); in drain()
352 List::Notified => &mut lock.notified, in remove()
401 assert!(lock.notified.is_empty()); in drop()
426 lock.notified.push_front(me); in wake_by_ref()
|
| /external/libchrome/mojo/public/cpp/system/tests/ |
| D | simple_watcher_unittest.cc | 52 bool notified = false; in TEST_F() local
60 notified = true; in TEST_F()
68 EXPECT_TRUE(notified); in TEST_F()
280 [](base::RunLoop* loop, bool* notified, MojoResult result) { in TEST_F() argument
282 *notified = true; in TEST_F()
294 [](base::RunLoop* loop, bool* notified, MojoResult result) { in TEST_F() argument
296 *notified = true; in TEST_F()
|
| /external/guice/core/test/com/google/inject/ |
| D | ProvisionListenerTest.java | 736 final AtomicBoolean notified = new AtomicBoolean();
747 new SpecialChecker(Foo.class, getClass().getName() + ".configure(", notified));
750 assertTrue(notified.get());
754 final AtomicBoolean notified = new AtomicBoolean();
771 new SpecialChecker(Foo.class, getClass().getName() + ".configure(", notified));
774 assertTrue(notified.get());
782 final AtomicBoolean notified = new AtomicBoolean();
789 new SpecialChecker(Foo.class, object.getClass().getName(), notified));
793 assertTrue(notified.get());
801 private final AtomicBoolean notified;
[all …]
|
| /external/libchrome/libchrome_tools/patch/ |
| D | observer_list_unittest.patch | 22 // Verify that observers are notified on the correct sequence.
35 // from a notification, it is itself notified.
52 // notified.
|