| /external/rust/crates/tokio/tests/ |
| D | sync_notify.rs | 7 use tokio::sync::Notify; 12 impl AssertSend for Notify {} implementation 16 let notify = Notify::new(); in notify_notified_one() localVariable 17 let mut notified = spawn(async { notify.notified().await }); in notify_notified_one() 19 notify.notify_one(); in notify_notified_one() 25 let notify = Notify::new(); in notified_one_notify() localVariable 26 let mut notified = spawn(async { notify.notified().await }); in notified_one_notify() 30 notify.notify_one(); in notified_one_notify() 37 let notify = Notify::new(); in notified_multi_notify() localVariable 38 let mut notified1 = spawn(async { notify.notified().await }); in notified_multi_notify() [all …]
|
| /external/linux-kselftest/tools/testing/selftests/drivers/net/netdevsim/ |
| D | fib_notifications.sh | 84 local notify=$1; shift 89 ip netns exec testns1 sysctl -qw net.$ip.fib_notify_on_flag_change=$notify 114 local notify=0 117 route_addition_check $ip $notify $route $expected_num_notifications 120 notify=1 122 route_addition_check $ip $notify $route $expected_num_notifications 124 # notify=2 means emit notifications only for failed route installation, 127 notify=2 129 route_addition_check $ip $notify $route $expected_num_notifications 137 local notify=$1; shift [all …]
|
| /external/rust/crates/tokio/src/sync/tests/ |
| D | loom_notify.rs | 1 use crate::sync::Notify; 15 let tx = Arc::new(Notify::new()); in notify_one() 32 let notify = Arc::new(Notify::new()); in notify_waiters() localVariable 33 let tx = notify.clone(); in notify_waiters() 34 let notified1 = notify.notified(); in notify_waiters() 35 let notified2 = notify.notified(); in notify_waiters() 53 let notify = Arc::new(Notify::new()); in notify_waiters_and_one() localVariable 54 let tx1 = notify.clone(); in notify_waiters_and_one() 55 let tx2 = notify.clone(); in notify_waiters_and_one() 66 let notified = notify.notified(); in notify_waiters_and_one() [all …]
|
| D | notify.rs | 1 use crate::sync::Notify; 14 let ptr = data as *const Notify; in notify_clones_waker_before_lock() constant 15 Arc::<Notify>::increment_strong_count(ptr); in notify_clones_waker_before_lock() 17 // Notify wait list is locked. in notify_clones_waker_before_lock() 23 drop(Arc::<Notify>::from_raw(data as *const Notify)); in notify_clones_waker_before_lock() constant 34 let notify = Arc::new(Notify::new()); in notify_clones_waker_before_lock() localVariable 35 let notify2 = notify.clone(); in notify_clones_waker_before_lock() 41 let future = notify.notified(); in notify_clones_waker_before_lock() 53 let notify = Arc::new(Notify::new()); in notify_waiters_handles_panicking_waker() localVariable 55 struct PanickingWaker(Arc<Notify>); in notify_waiters_handles_panicking_waker() [all …]
|
| /external/libcups/test/ |
| D | 4.4-subscription-ops.test | 26 ATTR uri notify-recipient-uri testnotify:// 27 ATTR keyword notify-events printer-state-changed 28 ATTR integer notify-lease-duration 5 36 EXPECT notify-subscription-id 37 DISPLAY notify-subscription-id 55 ATTR integer notify-subscription-id $notify-subscription-id 81 ATTR uri notify-recipient-uri testnotify:// 82 ATTR keyword notify-events printer-state-changed 83 ATTR integer notify-lease-duration 5 86 ATTR uri notify-recipient-uri testnotify:// [all …]
|
| /external/rust/crates/tokio/src/sync/ |
| D | notify.rs | 2 // due to the usage of `Notify` within the `rt` feature set. 27 /// `Notify` provides a basic mechanism to notify a single task of an event. 28 /// `Notify` itself does not carry any data. Instead, it is to be used to signal 31 /// A `Notify` can be thought of as a [`Semaphore`] starting with 0 permits. The 36 /// The synchronization details of `Notify` are similar to 37 /// [`thread::park`][park] and [`Thread::unpark`][unpark] from std. A [`Notify`] 55 /// use tokio::sync::Notify; 60 /// let notify = Arc::new(Notify::new()); 61 /// let notify2 = notify.clone(); 69 /// notify.notify_one(); [all …]
|
| /external/python/cpython2/PC/bdist_wininst/ |
| D | extract.c | 29 BOOL ensure_directory(char *pathname, char *new_part, NOTIFYPROC notify) in ensure_directory() argument 37 if (!CreateDirectory(pathname, NULL) && notify) in ensure_directory() 38 notify(SYSTEM_ERROR, in ensure_directory() 41 notify(DIR_CREATED, pathname); in ensure_directory() 47 if (notify) in ensure_directory() 48 notify(SYSTEM_ERROR, in ensure_directory() 63 NOTIFYPROC notify) in map_new_file() argument 81 if (notify && notify(CAN_OVERWRITE, filename)) in map_new_file() 89 if (notify) in map_new_file() 90 notify(FILE_OVERWRITTEN, filename); in map_new_file() [all …]
|
| /external/grpc-grpc/test/cpp/ext/gcp/ |
| D | environment_autodetect_test.cc | 45 grpc_core::Notification* notify) { in GetNotifiedOnEnvironmentDetection() argument 46 env->NotifyOnDone([notify]() { notify->Notify(); }); in GetNotifiedOnEnvironmentDetection() 57 grpc_core::Notification notify; in TEST_F() local 58 GetNotifiedOnEnvironmentDetection(&env, ¬ify); in TEST_F() 59 notify.WaitForNotification(); in TEST_F() 70 grpc_core::Notification notify; in TEST_F() local 71 GetNotifiedOnEnvironmentDetection(&env, ¬ify); in TEST_F() 72 notify.WaitForNotification(); in TEST_F() 83 grpc_core::Notification notify; in TEST_F() local 84 GetNotifiedOnEnvironmentDetection(&env, ¬ify); in TEST_F() [all …]
|
| /external/perfetto/src/base/threading/ |
| D | thread_pool_unittest.cc | 30 base::WaitableEvent notify; member 42 first.notify.Notify(); in TEST() 48 second.notify.Notify(); in TEST() 52 first.notify.Wait(); in TEST() 55 first.wait.Notify(); in TEST() 57 second.notify.Wait(); in TEST() 59 second.wait.Notify(); in TEST() 69 first.notify.Notify(); in TEST() 76 second.notify.Notify(); in TEST() 79 second.wait.Notify(); in TEST() [all …]
|
| /external/google-cloud-java/java-contact-center-insights/proto-google-cloud-contact-center-insights-v1/src/main/java/com/google/cloud/contactcenterinsights/v1/ |
| D | SettingsOrBuilder.java | 209 * specified trigger occurs, Insights will notify the corresponding Pub/Sub 212 * * "all-triggers": Notify each time any of the supported triggers occurs. 213 * * "create-analysis": Notify each time an analysis is created. 214 * * "create-conversation": Notify each time a conversation is created. 215 * * "export-insights-data": Notify each time an export is complete. 216 * * "update-conversation": Notify each time a conversation is updated via 230 * specified trigger occurs, Insights will notify the corresponding Pub/Sub 233 * * "all-triggers": Notify each time any of the supported triggers occurs. 234 * * "create-analysis": Notify each time an analysis is created. 235 * * "create-conversation": Notify each time a conversation is created. [all …]
|
| /external/wayland/tests/ |
| D | newsignal-test.c | 55 /* we just need different values of notify */ in TEST() 56 struct wl_listener l1 = {.notify = (wl_notify_func_t) 0x1}; in TEST() 57 struct wl_listener l2 = {.notify = (wl_notify_func_t) 0x2}; in TEST() 58 struct wl_listener l3 = {.notify = (wl_notify_func_t) 0x3}; in TEST() 60 struct wl_listener l4 = {.notify = signal_notify}; in TEST() 87 struct wl_listener l1 = {.notify = signal_notify}; in TEST() 104 struct wl_listener l1 = {.notify = signal_notify}; in TEST() 105 struct wl_listener l2 = {.notify = signal_notify}; in TEST() 106 struct wl_listener l3 = {.notify = signal_notify}; in TEST() 151 signal.l1.notify = notify_remove; in TEST() [all …]
|
| D | signal-test.c | 55 /* we just need different values of notify */ in TEST() 56 struct wl_listener l1 = {.notify = (wl_notify_func_t) 0x1}; in TEST() 57 struct wl_listener l2 = {.notify = (wl_notify_func_t) 0x2}; in TEST() 58 struct wl_listener l3 = {.notify = (wl_notify_func_t) 0x3}; in TEST() 60 struct wl_listener l4 = {.notify = signal_notify}; in TEST() 87 struct wl_listener l1 = {.notify = signal_notify}; in TEST() 104 struct wl_listener l1 = {.notify = signal_notify}; in TEST() 105 struct wl_listener l2 = {.notify = signal_notify}; in TEST() 106 struct wl_listener l3 = {.notify = signal_notify}; in TEST() 145 struct wl_listener l1 = {.notify = signal_notify_mutable}; in TEST() [all …]
|
| /external/cronet/base/ |
| D | callback_list_unittest.cc | 134 c1.Notify(1); in TEST() 141 c2.Notify(1, 2); in TEST() 148 c3.Notify(1, 2, 3); in TEST() 155 c4.Notify(1, 2, 3, 4); in TEST() 162 c5.Notify(1, 2, 3, 4, 5); in TEST() 169 c6.Notify(1, 2, 3, 4, 5, 6); in TEST() 188 cb_reg.Notify(); in TEST() 199 cb_reg.Notify(); in TEST() 219 cb_reg.Notify(); in TEST() 224 // OnceCallbacks should auto-remove themselves after calling Notify(). in TEST() [all …]
|
| /external/libcups/examples/ |
| D | create-printer-subscription.test | 21 ATTR uri notify-recipient-uri $recipient 22 ATTR keyword notify-events printer-config-changed,printer-state-changed 28 EXPECT notify-subscription-id OF-TYPE integer WITH-VALUE >0 29 DISPLAY notify-subscription-id 47 ATTR keyword notify-pull-method ippget 48 ATTR keyword notify-events printer-config-changed,printer-state-changed 54 EXPECT notify-subscription-id OF-TYPE integer WITH-VALUE >0 55 DISPLAY notify-subscription-id
|
| /external/rust/crates/tokio/src/runtime/tests/ |
| D | loom_oneshot.rs | 2 use loom::sync::Notify; 6 notify: Notify::new(), in channel() 27 notify: Notify, field 34 self.inner.notify.notify(); in send() 45 self.inner.notify.wait(); in recv()
|
| /external/cronet/base/test/android/javatests/src/org/chromium/base/test/util/ |
| D | PayloadCallbackHelper.java | 71 * @return The nth payload provided to notify. Null is a valid return value if the callback was 73 * @throws IndexOutOfBoundsException If notify is not called at least the specified number of 87 * @return The nth payload provided to notify. Null is a valid return value if the callback was 89 * @throws IndexOutOfBoundsException If notify is not called at least the specified number of 99 * Returns the payload, blocking if notify has not been called yet. Verifies that {@link 101 * @return The payload provided to notify. Null is a valid return value if the callback was 103 * @throws IndexOutOfBoundsException If notify is never called. 110 // one payload. Other threads may be waiting to notify while this lock is held. Note this in getOnlyPayloadBlocking() 119 * @return The number of times notify has been called. 126 * Blocks until notify has been called the specified number of times. [all …]
|
| /external/tensorflow/third_party/absl/abseil-cpp/absl/synchronization/ |
| D | notification.h | 28 // * `Notify()` to set the notification's "notified" state to `true` and 29 // notify all waiting threads that the event has occurred. 32 // Note that while `Notify()` may only be called once, it is perfectly valid to 38 // it might not be safe to destroy a notification after calling `Notify()` since 42 // to `Notify()` in the other thread. 44 // Memory ordering: For any threads X and Y, if X calls `Notify()`, then any 45 // action taken by X before it calls `Notify()` is visible to thread Y after: 85 // `true`. Note that if `Notify()` has been previously called on this 103 // Notification::Notify() 106 // threads. Note: do not call `Notify()` multiple times on the same [all …]
|
| /external/webrtc/third_party/abseil-cpp/absl/synchronization/ |
| D | notification.h | 28 // * `Notify()` to set the notification's "notified" state to `true` and 29 // notify all waiting threads that the event has occurred. 32 // Note that while `Notify()` may only be called once, it is perfectly valid to 38 // it might not be safe to destroy a notification after calling `Notify()` since 42 // to `Notify()` in the other thread. 44 // Memory ordering: For any threads X and Y, if X calls `Notify()`, then any 45 // action taken by X before it calls `Notify()` is visible to thread Y after: 84 // `true`. Note that if `Notify()` has been previously called on this 102 // Notification::Notify() 105 // threads. Note: do not call `Notify()` multiple times on the same [all …]
|
| /external/cronet/third_party/abseil-cpp/absl/synchronization/ |
| D | notification.h | 28 // * `Notify()` to set the notification's "notified" state to `true` and 29 // notify all waiting threads that the event has occurred. 32 // Note that while `Notify()` may only be called once, it is perfectly valid to 38 // it might not be safe to destroy a notification after calling `Notify()` since 42 // to `Notify()` in the other thread. 44 // Memory ordering: For any threads X and Y, if X calls `Notify()`, then any 45 // action taken by X before it calls `Notify()` is visible to thread Y after: 84 // `true`. Note that if `Notify()` has been previously called on this 102 // Notification::Notify() 105 // threads. Note: do not call `Notify()` multiple times on the same [all …]
|
| /external/openscreen/third_party/abseil/src/absl/synchronization/ |
| D | notification.h | 28 // * `Notify()` to set the notification's "notified" state to `true` and 29 // notify all waiting threads that the event has occurred. 32 // Note that while `Notify()` may only be called once, it is perfectly valid to 38 // it might not be safe to destroy a notification after calling `Notify()` since 42 // to `Notify()` in the other thread. 44 // Memory ordering: For any threads X and Y, if X calls `Notify()`, then any 45 // action taken by X before it calls `Notify()` is visible to thread Y after: 84 // `true`. Note that if `Notify()` has been previously called on this 102 // Notification::Notify() 105 // threads. Note: do not call `Notify()` multiple times on the same [all …]
|
| /external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/synchronization/ |
| D | notification.h | 28 // * `Notify()` to set the notification's "notified" state to `true` and 29 // notify all waiting threads that the event has occurred. 32 // Note that while `Notify()` may only be called once, it is perfectly valid to 38 // it might not be safe to destroy a notification after calling `Notify()` since 42 // to `Notify()` in the other thread. 44 // Memory ordering: For any threads X and Y, if X calls `Notify()`, then any 45 // action taken by X before it calls `Notify()` is visible to thread Y after: 84 // `true`. Note that if `Notify()` has been previously called on this 102 // Notification::Notify() 105 // threads. Note: do not call `Notify()` multiple times on the same [all …]
|
| /external/angle/third_party/abseil-cpp/absl/synchronization/ |
| D | notification.h | 28 // * `Notify()` to set the notification's "notified" state to `true` and 29 // notify all waiting threads that the event has occurred. 32 // Note that while `Notify()` may only be called once, it is perfectly valid to 38 // it might not be safe to destroy a notification after calling `Notify()` since 42 // to `Notify()` in the other thread. 44 // Memory ordering: For any threads X and Y, if X calls `Notify()`, then any 45 // action taken by X before it calls `Notify()` is visible to thread Y after: 84 // `true`. Note that if `Notify()` has been previously called on this 102 // Notification::Notify() 105 // threads. Note: do not call `Notify()` multiple times on the same [all …]
|
| /external/abseil-cpp/absl/synchronization/ |
| D | notification.h | 28 // * `Notify()` to set the notification's "notified" state to `true` and 29 // notify all waiting threads that the event has occurred. 32 // Note that while `Notify()` may only be called once, it is perfectly valid to 38 // it might not be safe to destroy a notification after calling `Notify()` since 42 // to `Notify()` in the other thread. 44 // Memory ordering: For any threads X and Y, if X calls `Notify()`, then any 45 // action taken by X before it calls `Notify()` is visible to thread Y after: 84 // `true`. Note that if `Notify()` has been previously called on this 102 // Notification::Notify() 105 // threads. Note: do not call `Notify()` multiple times on the same [all …]
|
| /external/private-join-and-compute/third_party/abseil-cpp-20230125.2/absl/synchronization/ |
| D | notification.h | 28 // * `Notify()` to set the notification's "notified" state to `true` and 29 // notify all waiting threads that the event has occurred. 32 // Note that while `Notify()` may only be called once, it is perfectly valid to 38 // it might not be safe to destroy a notification after calling `Notify()` since 42 // to `Notify()` in the other thread. 44 // Memory ordering: For any threads X and Y, if X calls `Notify()`, then any 45 // action taken by X before it calls `Notify()` is visible to thread Y after: 84 // `true`. Note that if `Notify()` has been previously called on this 102 // Notification::Notify() 105 // threads. Note: do not call `Notify()` multiple times on the same [all …]
|
| /external/libtextclassifier/abseil-cpp/absl/synchronization/ |
| D | notification.h | 28 // * `Notify()` to set the notification's "notified" state to `true` and 29 // notify all waiting threads that the event has occurred. 32 // Note that while `Notify()` may only be called once, it is perfectly valid to 38 // it might not be safe to destroy a notification after calling `Notify()` since 42 // to `Notify()` in the other thread. 44 // Memory ordering: For any threads X and Y, if X calls `Notify()`, then any 45 // action taken by X before it calls `Notify()` is visible to thread Y after: 84 // `true`. Note that if `Notify()` has been previously called on this 102 // Notification::Notify() 105 // threads. Note: do not call `Notify()` multiple times on the same [all …]
|