| /external/rust/crates/tokio/tests/ |
| D | sync_notify.rs | 14 let mut notified = spawn(async { notify.notified().await }); in notify_notified_one() localVariable
17 assert_ready!(notified.poll()); in notify_notified_one()
23 let mut notified = spawn(async { notify.notified().await }); in notified_one_notify() localVariable
25 assert_pending!(notified.poll()); in notified_one_notify()
28 assert!(notified.is_woken()); in notified_one_notify()
29 assert_ready!(notified.poll()); in notified_one_notify()
35 let mut notified1 = spawn(async { notify.notified().await }); in notified_multi_notify()
36 let mut notified2 = spawn(async { notify.notified().await }); in notified_multi_notify()
55 let mut notified1 = spawn(async { notify.notified().await }); in notify_notified_multi()
56 let mut notified2 = spawn(async { notify.notified().await }); in notify_notified_multi()
[all …]
|
| /external/angle/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/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/webrtc/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/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/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/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/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()
57 notify.notified().await; in notify_multi()
70 notify.notified().await; in notify_multi()
87 let mut recv = Box::pin(rx1.notified()); in notify_drop()
99 rx2.notified().await; in notify_drop()
102 rx2.notified().await; in notify_drop()
|
| /external/tensorflow/tensorflow/core/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 | 137 notified: Option<NotificationType>, field
265 pub fn notified(&self) -> Notified<'_> { in notified() method
275 notified: None, in notified()
415 assert!(waiter.notified.is_none()); in notify_waiters()
417 waiter.notified = Some(NotificationType::AllWaiters); in notify_waiters()
490 assert!(waiter.notified.is_none()); in notify_locked()
492 waiter.notified = Some(NotificationType::OneWaiter); in notify_locked()
639 if w.notified.is_some() { in poll()
643 w.notified = None; in poll()
703 if let Some(NotificationType::OneWaiter) = unsafe { (*waiter.get()).notified } { in drop()
|
| D | watch.rs | 263 let notified = self.shared.notify_rx.notified(); in changed() localVariable
269 notified.await; in changed()
402 let notified = self.shared.notify_tx.notified(); in closed() localVariable
408 notified.await; in closed()
|
| /external/rust/crates/tokio/src/runtime/ |
| D | shell.rs | 50 let notified = self.notify.notified(); in block_on() localVariable
51 pin!(notified); in block_on()
55 if notified.as_mut().poll(cx).is_ready() { in block_on()
|
| D | basic_scheduler.rs | 166 let notified = self.notify.notified(); in block_on() localVariable
167 pin!(notified); in block_on()
171 if notified.as_mut().poll(cx).is_ready() { in block_on()
|
| /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.
|
| /external/testng/src/main/java/org/testng/junit/ |
| D | JUnit4TestRunner.java | 114 private List<Description> notified = new LinkedList<>();
118 notified.add(failure.getDescription());
135 notified.add(failure.getDescription());
149 if (!notified.contains(description)) {
|
| /external/llvm-project/lldb/unittests/Signals/ |
| D | UnixSignalsTest.cpp | 128 auto notified = signals.GetFilteredSignals(None, None, true); in TEST() local
130 EXPECT_EQ_ARRAYS(expected, notified); in TEST()
|
| /external/python/cpython3/Lib/test/ |
| D | test_subclassinit.py | 201 notified = []
205 notified.append(name)
214 self.assertCountEqual(notified, ['a', 'b', 'c', 'd', 'e'])
|
| /external/rust/crates/tokio/src/sync/mpsc/ |
| D | chan.rs | 158 let notified = self.inner.notify_rx_closed.notified(); in closed() localVariable
163 notified.await; in closed()
|
| /external/cldr/tools/java/org/unicode/cldr/util/data/external/ |
| D | iso_3166_status.txt | 72 … Benin (BJ, BEN, 204) and to a list of car vehicle distinguishing signs notified to the Secretary-…
87 …d ; Refers to Estonia and to a list of car vehicle distinguishing signs notified to the Secretary-…
92 … a car vehicle distinguishing signs which are in use but which were not notified to the Secretary-…
157 …to car vehicle distinguishing signs which are in use but which were not notified to the Secretary-…
230 …ved ; Refers to Haiti and to a list of car vehicle distinguishing signs notified to the Secretary-…
245 …d ; Refers to Finland and to a list of car vehicle distinguishing signs notified to the Secretary-…
298 …d ; Refers to Grenada and to a list of car vehicle distinguishing signs notified to the Secretary-…
300 …Refers to Saint Lucia and to a list of car vehicle distinguishing signs notified to the Secretary-…
303 …fers to Saint Vincent and to a list of car vehicle distinguishing signs notified to the Secretary-…
308 …; Refers to Venezuela and to a list of car vehicle distinguishing signs notified to the Secretary-…
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | rendezvous.cc | 134 bool notified = WaitForNotificationWithTimeout(&n, timeout_us); in Recv() local
135 if (!notified) { in Recv()
|
| /external/grpc-grpc/test/core/tsi/alts/handshaker/ |
| D | alts_tsi_handshaker_test.cc | 57 bool notified; member
86 n->notified = false; in notification_init()
96 n->notified = true; in signal()
103 while (!n->notified) { in wait()
106 n->notified = false; in wait()
|