Home
last modified time | relevance | path

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

12345678910>>...278

/external/rust/crates/tokio/tests/
Dsync_notify.rs4 use tokio::sync::Notify;
9 impl AssertSend for Notify {} implementation
13 let notify = Notify::new(); in notify_notified_one() localVariable
14 let mut notified = spawn(async { notify.notified().await }); in notify_notified_one()
16 notify.notify_one(); in notify_notified_one()
22 let notify = Notify::new(); in notified_one_notify() localVariable
23 let mut notified = spawn(async { notify.notified().await }); in notified_one_notify()
27 notify.notify_one(); in notified_one_notify()
34 let notify = Notify::new(); in notified_multi_notify() localVariable
35 let mut notified1 = spawn(async { notify.notified().await }); in notified_multi_notify()
[all …]
/external/rust/crates/tokio/src/sync/
Dnotify.rs2 // due to the usage of `Notify` within the `rt` feature set.
22 /// Notify a single task to wake up.
24 /// `Notify` provides a basic mechanism to notify a single task of an event.
25 /// `Notify` itself does not carry any data. Instead, it is to be used to signal
28 /// `Notify` can be thought of as a [`Semaphore`] starting with 0 permits.
32 /// The synchronization details of `Notify` are similar to
33 /// [`thread::park`][park] and [`Thread::unpark`][unpark] from std. A [`Notify`]
51 /// use tokio::sync::Notify;
56 /// let notify = Arc::new(Notify::new());
57 /// let notify2 = notify.clone();
[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/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_multi() localVariable
53 let notify = notify.clone(); in notify_multi() localVariable
57 notify.notified().await; in notify_multi()
58 notify.notify_one(); in notify_multi()
[all …]
/external/python/cpython3/PC/bdist_wininst/
Dextract.c28 BOOL ensure_directory(char *pathname, char *new_part, NOTIFYPROC notify) in ensure_directory() argument
36 if (!CreateDirectory(pathname, NULL) && notify) in ensure_directory()
37 notify(SYSTEM_ERROR, in ensure_directory()
40 notify(DIR_CREATED, pathname); in ensure_directory()
46 if (notify) in ensure_directory()
47 notify(SYSTEM_ERROR, in ensure_directory()
62 NOTIFYPROC notify) in map_new_file() argument
80 if (notify && notify(CAN_OVERWRITE, filename)) in map_new_file()
88 if (notify) in map_new_file()
89 notify(FILE_OVERWRITTEN, filename); in map_new_file()
[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/adhd/cras/src/server/
Dcras_observer.h57 /* Notify observers of output volume change. */
60 /* Notify observers of output mute change. */
64 /* Notify observers of capture gain change. */
67 /* Notify observers of capture mute change. */
70 /* Notify observers of a nodes list change. */
73 /* Notify observers of active output node change. */
77 /* Notify observers of output node volume change. */
81 /* Notify observers of node left-right swap change. */
85 /* Notify observers of input node gain change. */
88 /* Notify observers of suspend state changed. */
[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 …]
Dsignal-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()
/external/rust/crates/tokio/src/runtime/tests/
Dloom_oneshot.rs1 use loom::sync::Notify;
7 notify: Notify::new(), in channel()
28 notify: Notify, field
35 self.inner.notify.notify(); in send()
46 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/tensorflow/tensorflow/core/kernels/batching_util/
Dshared_batch_scheduler_test.cc204 first_batch_processed.Notify(); in TEST()
206 second_batch_processed.Notify(); in TEST()
208 third_batch_processed.Notify(); in TEST()
252 start_teardown.Notify(); in TEST()
254 stop_teardown.Notify(); in TEST()
263 first_batch_processed.Notify(); in TEST()
265 second_batch_processed.Notify(); in TEST()
306 first_batch_processed.Notify(); in TEST()
308 second_batch_processed.Notify(); in TEST()
334 start_teardown.Notify(); in TEST()
[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/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/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/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/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:
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/llvm-project/lldb/source/Target/
DPathMappingList.cpp64 ConstString replacement, bool notify) { in Append() argument
67 if (notify && m_callback) in Append()
71 void PathMappingList::Append(const PathMappingList &rhs, bool notify) { in Append() argument
77 if (notify && m_callback) in Append()
84 bool notify) { in Insert() argument
93 if (notify && m_callback) in Insert()
99 bool notify) { in Replace() argument
104 if (notify && m_callback) in Replace()
109 bool PathMappingList::Remove(size_t index, bool notify) { in Remove() argument
116 if (notify && m_callback) in Remove()
[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 …]
/external/grpc-grpc/src/core/ext/transport/chttp2/client/
Dchttp2_connector.cc50 grpc_closure* notify; member
132 // effects of scheduling c->notify: we start sending RPCs immediately in on_handshake_done()
149 grpc_closure* notify = c->notify; in on_handshake_done() local
150 c->notify = nullptr; in on_handshake_done()
151 GRPC_CLOSURE_SCHED(notify, error); in on_handshake_done()
182 grpc_closure* notify = c->notify; in connected() local
183 c->notify = nullptr; in connected()
184 GRPC_CLOSURE_SCHED(notify, error); in connected()
200 grpc_closure* notify) { in chttp2_connector_connect() argument
205 GPR_ASSERT(c->notify == nullptr); in chttp2_connector_connect()
[all …]
/external/libcups/scheduler/
Dsubscriptions.h83 char *owner; /* notify-subscriber-user-name */
84 char *recipient; /* notify-recipient-uri, if applicable */
85 unsigned char user_data[64]; /* notify-user-data */
86 int user_data_len; /* Length of notify-user-data */
87 int lease; /* notify-lease-duration */
88 int interval; /* notify-time-interval */
89 cupsd_printer_t *dest; /* notify-printer-uri, if any */
90 cupsd_job_t *job; /* notify-job-id, if any */
117 /* Default notify-lease-duration */
119 /* Maximum notify-lease-duration */
/external/autotest/frontend/client/src/autotest/common/
DXhrJsonRpcProxy.java33 notify.showError("Unable to connect to server"); in sendRequest()
38 notify.setLoading(true); in sendRequest()
49 notify.setLoading(false); in onError()
50 notify.showError("Unable to make RPC call", exception.toString()); in onError()
55 notify.setLoading(false); in onResponseReceived()
60 notify.showError("Received error " + Integer.toString(statusCode) + " " + in onResponseReceived()
77 JsonRpcProxy.notify.showError(exc.toString(), responseText); in handleResponseText()

12345678910>>...278