Home
last modified time | relevance | path

Searched full:notify (Results 1 – 25 of 7733) sorted by relevance

12345678910>>...310

/external/rust/crates/tokio/tests/
Dsync_notify.rs7 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/
Dfib_notifications.sh84 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/
Dloom_notify.rs1 use crate::sync::Notify;
10 let tx = Arc::new(Notify::new()); in notify_one()
27 let notify = Arc::new(Notify::new()); in notify_waiters() localVariable
28 let tx = notify.clone(); in notify_waiters()
29 let notified1 = notify.notified(); in notify_waiters()
30 let notified2 = notify.notified(); in notify_waiters()
48 let notify = Arc::new(Notify::new()); in notify_waiters_and_one() localVariable
49 let tx1 = notify.clone(); in notify_waiters_and_one()
50 let tx2 = notify.clone(); in notify_waiters_and_one()
61 let notified = notify.notified(); in notify_waiters_and_one()
[all …]
Dnotify.rs1 use crate::sync::Notify;
15 let arc = ManuallyDrop::new(Arc::<Notify>::from_raw(data as *const Notify)); in notify_clones_waker_before_lock() constant
17 // Notify wait list is locked. in notify_clones_waker_before_lock()
24 let _ = Arc::<Notify>::from_raw(data as *const Notify); in notify_clones_waker_before_lock() constant
35 let notify = Arc::new(Notify::new()); in notify_clones_waker_before_lock() localVariable
36 let notify2 = notify.clone(); in notify_clones_waker_before_lock()
42 let future = notify.notified(); in notify_clones_waker_before_lock()
51 let notify = Notify::new(); in notify_simple() localVariable
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()
[all …]
/external/libcups/test/
D4.4-subscription-ops.test26 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/
Dnotify.rs2 // due to the usage of `Notify` within the `rt` feature set.
26 /// `Notify` provides a basic mechanism to notify a single task of an event.
27 /// `Notify` itself does not carry any data. Instead, it is to be used to signal
30 /// A `Notify` can be thought of as a [`Semaphore`] starting with 0 permits. The
35 /// The synchronization details of `Notify` are similar to
36 /// [`thread::park`][park] and [`Thread::unpark`][unpark] from std. A [`Notify`]
54 /// use tokio::sync::Notify;
59 /// let notify = Arc::new(Notify::new());
60 /// let notify2 = notify.clone();
68 /// notify.notify_one();
[all …]
/external/python/cpython2/PC/bdist_wininst/
Dextract.c29 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/perfetto/src/base/threading/
Dthread_pool_unittest.cc30 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/grpc-grpc/src/core/lib/transport/
Dconnectivity_state.cc69 GRPC_CLOSURE_SCHED(w->notify, error); in grpc_connectivity_state_destroy()
108 grpc_closure* notify) { in grpc_connectivity_state_notify_on_state_change() argument
113 gpr_log(GPR_INFO, "CONWATCH: %p %s: unsubscribe notify=%p", tracker, in grpc_connectivity_state_notify_on_state_change()
114 tracker->name, notify); in grpc_connectivity_state_notify_on_state_change()
116 gpr_log(GPR_INFO, "CONWATCH: %p %s: from %s [cur=%s] notify=%p", tracker, in grpc_connectivity_state_notify_on_state_change()
118 grpc_connectivity_state_name(cur), notify); in grpc_connectivity_state_notify_on_state_change()
123 if (w != nullptr && w->notify == notify) { in grpc_connectivity_state_notify_on_state_change()
124 GRPC_CLOSURE_SCHED(notify, GRPC_ERROR_CANCELLED); in grpc_connectivity_state_notify_on_state_change()
131 if (rm_candidate != nullptr && rm_candidate->notify == notify) { in grpc_connectivity_state_notify_on_state_change()
132 GRPC_CLOSURE_SCHED(notify, GRPC_ERROR_CANCELLED); in grpc_connectivity_state_notify_on_state_change()
[all …]
/external/wayland/tests/
Dnewsignal-test.c55 /* 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 …]
/external/cronet/base/
Dcallback_list_unittest.cc134 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/rust/crates/tokio/src/runtime/tests/
Dloom_oneshot.rs2 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/libcups/examples/
Dcreate-printer-subscription.test21 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/cronet/base/test/android/javatests/src/org/chromium/base/test/util/
DPayloadCallbackHelper.java71 * @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/python/google-api-python-client/docs/dyn/
Dcontactcenterinsights_v1.projects.locations.html139 …notify the corresponding Pub/Sub topic. Keys are notification triggers. Supported keys are: * &quo…
163 …notify the corresponding Pub/Sub topic. Keys are notification triggers. Supported keys are: * &quo…
186 …notify the corresponding Pub/Sub topic. Keys are notification triggers. Supported keys are: * &quo…
/external/tensorflow/third_party/absl/abseil-cpp/absl/synchronization/
Dnotification.h28 // * `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/openscreen/third_party/abseil/src/absl/synchronization/
Dnotification.h28 // * `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/webrtc/third_party/abseil-cpp/absl/synchronization/
Dnotification.h28 // * `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/
Dnotification.h28 // * `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/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/synchronization/
Dnotification.h28 // * `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/
Dnotification.h28 // * `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/
Dnotification.h28 // * `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/
Dnotification.h28 // * `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/arm-trusted-firmware/plat/nvidia/tegra/drivers/bpmp_ipc/
Divc.c266 * Notify only upon transition from full to non-full. in tegra_ivc_read()
271 ivc->notify(ivc); in tegra_ivc_read()
313 * Notify only upon transition from full to non-full. in tegra_ivc_read_advance()
318 ivc->notify(ivc); in tegra_ivc_read_advance()
361 * Notify only upon transition from empty to non-empty. in tegra_ivc_write()
366 ivc->notify(ivc); in tegra_ivc_write()
404 * Notify only upon transition from empty to non-empty. in tegra_ivc_write_advance()
409 ivc->notify(ivc); in tegra_ivc_write_advance()
418 ivc->notify(ivc); in tegra_ivc_channel_reset()
429 * SYNC ACK reset counters; move to EST; notify
[all …]
/external/ltp/testcases/kernel/syscalls/mq_notify/
Dmq_notify01.c32 int notify; member
40 .notify = SIGEV_NONE,
46 .notify = SIGEV_SIGNAL,
52 .notify = SIGEV_THREAD,
58 .notify = SIGEV_NONE,
64 .notify = SIGEV_NONE,
70 .notify = SIGEV_NONE,
76 .notify = SIGEV_NONE,
108 ev.sigev_notify = tc->notify; in do_test()
111 switch (tc->notify) { in do_test()
[all …]

12345678910>>...310