Home
last modified time | relevance | path

Searched refs:oneshot (Results 1 – 25 of 70) sorted by relevance

123

/external/rust/crates/futures/tests/
Doneshot.rs3 use futures::channel::oneshot; in oneshot_send1()
9 let (tx1, rx1) = oneshot::channel::<i32>(); in oneshot_send1()
20 use futures::channel::oneshot; in oneshot_send2()
26 let (tx1, rx1) = oneshot::channel::<i32>(); in oneshot_send2()
36 use futures::channel::oneshot; in oneshot_send3()
42 let (tx1, rx1) = oneshot::channel::<i32>(); in oneshot_send3()
52 use futures::channel::oneshot; in oneshot_drop_tx1()
57 let (tx1, rx1) = oneshot::channel::<i32>(); in oneshot_drop_tx1()
63 assert_eq!(Err(oneshot::Canceled), rx2.recv().unwrap()); in oneshot_drop_tx1()
68 use futures::channel::oneshot; in oneshot_drop_tx2()
[all …]
Deventual.rs1 use futures::channel::oneshot;
23 let (c1, p1) = oneshot::channel::<i32>(); in join2()
24 let (c2, p2) = oneshot::channel::<i32>(); in join2()
37 let (c1, p1) = oneshot::channel::<i32>(); in join3()
38 let (c2, p2) = oneshot::channel::<i32>(); in join3()
50 let (c1, p1) = oneshot::channel::<i32>(); in join4()
51 let (c2, p2) = oneshot::channel::<i32>(); in join4()
63 let (c1, p1) = oneshot::channel::<i32>(); in join5()
64 let (c2, p2) = oneshot::channel::<i32>(); in join5()
65 let (c3, p3) = oneshot::channel::<i32>(); in join5()
[all …]
Dready_queue.rs10 use futures::channel::oneshot; in basic_usage()
18 let (tx1, rx1) = oneshot::channel(); in basic_usage()
19 let (tx2, rx2) = oneshot::channel(); in basic_usage()
20 let (tx3, rx3) = oneshot::channel(); in basic_usage()
44 use futures::channel::oneshot; in resolving_errors()
52 let (tx1, rx1) = oneshot::channel(); in resolving_errors()
53 let (tx2, rx2) = oneshot::channel(); in resolving_errors()
54 let (tx3, rx3) = oneshot::channel(); in resolving_errors()
64 assert_eq!(Poll::Ready(Some(Err(oneshot::Canceled))), queue.poll_next_unpin(cx)); in resolving_errors()
70 assert_eq!(Poll::Ready(Some(Err(oneshot::Canceled))), queue.poll_next_unpin(cx)); in resolving_errors()
[all …]
Dfutures_ordered.rs3 use futures::channel::oneshot; in works_1()
8 let (a_tx, a_rx) = oneshot::channel::<i32>(); in works_1()
9 let (b_tx, b_rx) = oneshot::channel::<i32>(); in works_1()
10 let (c_tx, c_rx) = oneshot::channel::<i32>(); in works_1()
29 use futures::channel::oneshot; in works_2()
34 let (a_tx, a_rx) = oneshot::channel::<i32>(); in works_2()
35 let (b_tx, b_rx) = oneshot::channel::<i32>(); in works_2()
36 let (c_tx, c_rx) = oneshot::channel::<i32>(); in works_2()
69 use futures::channel::oneshot; in queue_never_unblocked()
75 let (_a_tx, a_rx) = oneshot::channel::<Box<dyn Any + Send>>(); in queue_never_unblocked()
[all …]
Dfutures_unordered.rs42 use futures::channel::oneshot; in works_1()
46 let (a_tx, a_rx) = oneshot::channel::<i32>(); in works_1()
47 let (b_tx, b_rx) = oneshot::channel::<i32>(); in works_1()
48 let (c_tx, c_rx) = oneshot::channel::<i32>(); in works_1()
68 use futures::channel::oneshot; in works_2()
74 let (a_tx, a_rx) = oneshot::channel::<i32>(); in works_2()
75 let (b_tx, b_rx) = oneshot::channel::<i32>(); in works_2()
76 let (c_tx, c_rx) = oneshot::channel::<i32>(); in works_2()
115 use futures::channel::oneshot; in finished_future()
120 let (_a_tx, a_rx) = oneshot::channel::<i32>(); in finished_future()
[all …]
Dshared.rs16 use futures::channel::oneshot; in send_shared_oneshot_and_wait_on_multiple_threads()
20 let (tx, rx) = oneshot::channel::<i32>(); in send_shared_oneshot_and_wait_on_multiple_threads()
56 use futures::channel::oneshot; in drop_on_one_task_ok()
61 let (tx, rx) = oneshot::channel::<u32>(); in drop_on_one_task_ok()
65 let (tx2, rx2) = oneshot::channel::<u32>(); in drop_on_one_task_ok()
72 let (tx3, rx3) = oneshot::channel::<u32>(); in drop_on_one_task_ok()
111 use futures::channel::oneshot; in peek()
119 let (tx0, rx0) = oneshot::channel::<i32>(); in peek()
148 use futures::channel::oneshot; in downgrade()
152 let (tx, rx) = oneshot::channel::<i32>(); in downgrade()
[all …]
Dabortable.rs3 use futures::channel::oneshot; in abortable_works()
7 let (_tx, a_rx) = oneshot::channel::<()>(); in abortable_works()
16 use futures::channel::oneshot; in abortable_awakens()
21 let (_tx, a_rx) = oneshot::channel::<()>(); in abortable_awakens()
36 use futures::channel::oneshot; in abortable_resolves()
39 let (tx, a_rx) = oneshot::channel::<()>(); in abortable_resolves()
Dasync_await_macros.rs18 use futures::channel::oneshot; in join()
22 let (tx1, rx1) = oneshot::channel::<i32>(); in join()
23 let (tx2, rx2) = oneshot::channel::<i32>(); in join()
43 use futures::channel::oneshot; in select()
47 let (tx1, rx1) = oneshot::channel::<i32>(); in select()
48 let (_tx2, rx2) = oneshot::channel::<i32>(); in select()
65 use futures::channel::oneshot; in select_biased()
70 let (tx1, rx1) = oneshot::channel::<i32>(); in select_biased()
71 let (_tx2, rx2) = oneshot::channel::<i32>(); in select_biased()
138 use futures::channel::oneshot; in select_can_move_uncompleted_futures()
[all …]
Deager_drop.rs68 use futures::channel::oneshot; in then_drops_eagerly()
73 let (tx0, rx0) = oneshot::channel::<()>(); in then_drops_eagerly()
92 use futures::channel::oneshot; in and_then_drops_eagerly()
97 let (tx0, rx0) = oneshot::channel::<Result<(), ()>>(); in and_then_drops_eagerly()
116 use futures::channel::oneshot; in or_else_drops_eagerly()
121 let (tx0, rx0) = oneshot::channel::<Result<(), ()>>(); in or_else_drops_eagerly()
/external/rust/crates/tokio/tests/
Dsync_oneshot.rs4 use tokio::sync::oneshot;
5 use tokio::sync::oneshot::error::TryRecvError;
13 impl AssertSend for oneshot::Sender<i32> {}
14 impl AssertSend for oneshot::Receiver<i32> {}
19 impl<T> SenderExt for oneshot::Sender<T> {
30 let (tx, rx) = oneshot::channel(); in send_recv()
45 let (tx, rx) = oneshot::channel(); in async_send_recv()
53 let (tx, rx) = oneshot::channel::<i32>(); in close_tx()
68 let (tx, _) = oneshot::channel(); in close_rx()
74 let (tx, rx) = oneshot::channel(); in close_rx()
[all …]
Dmacros_try_join.rs2 use tokio::sync::oneshot;
35 let (tx1, rx1) = oneshot::channel::<&str>(); in two_await()
36 let (tx2, rx2) = oneshot::channel::<u32>(); in two_await()
56 let (tx1, rx1) = oneshot::channel::<&str>(); in err_abort_early()
57 let (tx2, rx2) = oneshot::channel::<u32>(); in err_abort_early()
58 let (_tx3, rx3) = oneshot::channel::<u32>(); in err_abort_early()
Drt_common.rs61 use tokio::sync::oneshot;
91 let (tx, rx) = oneshot::channel();
109 let (tx, rx) = oneshot::channel();
126 let (tx, rx) = oneshot::channel();
149 let (tx1, rx1) = oneshot::channel();
150 let (tx2, rx2) = oneshot::channel();
180 let (tx, rx) = oneshot::channel();
239 let (tx, rx) = oneshot::channel();
337 let (tx, rx) = oneshot::channel();
360 let (tx1, rx1) = oneshot::channel();
[all …]
Dmacros_select.rs2 use tokio::sync::{mpsc, oneshot};
105 let (tx1, rx1) = oneshot::channel::<i32>(); in one_ready()
106 let (_tx2, rx2) = oneshot::channel::<i32>(); in one_ready()
161 let (tx1, mut rx1) = oneshot::channel::<i32>(); in move_uncompleted_futures()
162 let (tx2, mut rx2) = oneshot::channel::<i32>(); in move_uncompleted_futures()
275 let (tx, rx) = oneshot::channel(); in future_panics_after_poll()
306 let (tx, rx) = oneshot::channel(); in disable_with_if()
327 let (tx1, mut rx1) = oneshot::channel(); in join_with_select()
328 let (tx2, mut rx2) = oneshot::channel(); in join_with_select()
487 let (_tx1, rx1) = oneshot::channel::<i32>(); in biased_one_not_ready()
[all …]
Drt_basic.rs5 use tokio::sync::oneshot;
17 let (tx, mut rx) = oneshot::channel(); in spawned_task_does_not_progress_without_block_on()
107 let (tx1, rx1) = oneshot::channel(); in acquire_mutex_in_drop()
108 let (tx2, rx2) = oneshot::channel(); in acquire_mutex_in_drop()
147 let (_tx, rx) = oneshot::channel::<()>(); in timeout_panics_when_no_time_handle()
Dtime_timeout.rs4 use tokio::sync::oneshot;
34 let (tx, rx) = oneshot::channel(); in future_and_deadline_in_future()
58 let (tx, rx) = oneshot::channel(); in future_and_timeout_in_future()
82 let (tx, rx) = oneshot::channel(); in very_large_timeout()
Dmacros_join.rs2 use tokio::sync::oneshot;
35 let (tx1, rx1) = oneshot::channel::<&str>(); in two_await()
36 let (tx2, rx2) = oneshot::channel::<u32>(); in two_await()
/external/linux-kselftest/tools/testing/selftests/watchdog/
Dwatchdog-test.c100 int oneshot = 0; in main() local
140 oneshot = 1; in main()
155 oneshot = 1; in main()
165 oneshot = 1; in main()
181 oneshot = 1; in main()
185 oneshot = 1; in main()
199 oneshot = 1; in main()
203 oneshot = 1; in main()
211 oneshot = 1; in main()
226 oneshot = 1; in main()
[all …]
/external/rust/crates/futures/tests_disabled/
Dall.rs3 use futures::channel::oneshot::{self, Canceled};
109 let (c, p) = oneshot::channel(); in smoke_oneshot()
114 let (c, p) = oneshot::channel::<i32>(); in smoke_oneshot()
120 let (a, b) = oneshot::channel::<i32>(); in smoke_oneshot()
125 let (c, mut p) = oneshot::channel::<i32>(); in smoke_oneshot()
129 let (c, p) = oneshot::channel::<i32>(); in smoke_oneshot()
140 let ((a, b), (c, d)) = (oneshot::channel::<i32>(), oneshot::channel::<i32>()); in select_cancels()
157 let ((a, b), (c, d)) = (oneshot::channel::<i32>(), oneshot::channel::<i32>()); in select_cancels()
174 let ((a, b), (c, d)) = (oneshot::channel::<i32>(), oneshot::channel::<i32>()); in join_cancels()
186 let ((a, b), (c, d)) = (oneshot::channel::<i32>(), oneshot::channel::<i32>()); in join_cancels()
[all …]
/external/rust/crates/futures-channel/tests/
Doneshot.rs1 use futures::channel::oneshot::{self, Sender};
11 let (mut tx, rx) = oneshot::channel::<u32>(); in smoke_poll()
27 let (mut tx, rx) = oneshot::channel::<u32>(); in cancel_notifies()
47 let (otx, orx) = oneshot::channel::<u32>(); in cancel_lots()
60 let (mut tx, rx) = oneshot::channel::<u32>(); in cancel_after_sender_drop_doesnt_notify()
69 let (mut tx, mut rx) = oneshot::channel::<u32>(); in close()
83 let (mut tx, mut rx) = oneshot::channel::<u32>(); in close_wakes()
96 let (tx, rx) = oneshot::channel::<u32>(); in is_canceled()
112 let (otx, mut orx) = oneshot::channel::<u32>(); in cancel_sends()
/external/rust/cxx/book/src/
Dasync.md27 For now the recommended approach is to handle the return codepath over a oneshot
28 channel (such as [`futures::channel::oneshot`]) represented in an opaque Rust
31 [`futures::channel::oneshot`]: https://docs.rs/futures/0.3.8/futures/channel/oneshot/index.html
36 use futures::channel::oneshot;
55 struct DoThingContext(oneshot::Sender<Ret>);
58 let (tx, rx) = oneshot::channel();
/external/rust/crates/tokio/src/sync/tests/
Dloom_oneshot.rs1 use crate::sync::oneshot;
11 let (tx, rx) = oneshot::channel(); in smoke()
25 let (tx, mut rx) = oneshot::channel(); in changing_rx_task()
65 tx: &'a mut oneshot::Sender<i32>,
69 fn new(tx: &'a mut oneshot::Sender<i32>) -> Self { in new()
88 let (mut tx, rx) = oneshot::channel::<i32>(); in changing_tx_task()
/external/rust/crates/tokio/src/runtime/blocking/
Dshutdown.rs7 use crate::sync::oneshot;
13 tx: Arc<oneshot::Sender<()>>,
18 rx: oneshot::Receiver<()>,
22 let (tx, rx) = oneshot::channel(); in channel()
/external/rust/crates/tokio/src/runtime/tests/
Dloom_pool.rs8 use crate::runtime::tests::loom_oneshot as oneshot;
54 let (tx, rx) = oneshot::channel(); in pool_multi_spawn()
84 let (block_tx, block_rx) = oneshot::channel(); in only_blocking_inner()
120 let (block_tx, block_rx) = oneshot::channel(); in blocking_and_regular_inner()
121 let (done_tx, done_rx) = oneshot::channel(); in blocking_and_regular_inner()
233 use crate::sync::oneshot; in shutdown_with_notification()
237 let (done_tx, done_rx) = oneshot::channel::<()>(); in shutdown_with_notification()
240 let (tx, rx) = oneshot::channel::<()>(); in shutdown_with_notification()
268 let (done_tx, done_rx) = oneshot::channel(); in pool_multi_notify()
/external/rust/crates/tokio/src/process/
Dwindows.rs21 use crate::sync::oneshot;
60 rx: oneshot::Receiver<()>,
62 tx: *mut Option<oneshot::Sender<()>>,
120 let (tx, rx) = oneshot::channel(); in poll()
160 let complete = &mut *(ptr as *mut Option<oneshot::Sender<()>>); in callback()
/external/rust/crates/tokio/tests/support/
Dmock_pool.rs1 use tokio::sync::oneshot;
16 rx: oneshot::Receiver<T>,
24 let (tx, rx) = oneshot::channel(); in run()

123