| /external/rust/crates/tokio/src/sync/tests/ |
| D | loom_watch.rs | 9 let (tx, mut rx1) = watch::channel(1); in smoke()
10 let mut rx2 = rx1.clone(); in smoke()
11 let mut rx3 = rx1.clone(); in smoke()
12 let mut rx4 = rx1.clone(); in smoke()
13 let mut rx5 = rx1.clone(); in smoke()
19 block_on(rx1.changed()).unwrap(); in smoke()
20 assert_eq!(*rx1.borrow(), 2); in smoke()
|
| D | loom_broadcast.rs | 53 let (tx, mut rx1) = broadcast::channel::<Arc<&'static str>>(16); in broadcast_two()
58 let v = assert_ok!(rx1.recv().await); in broadcast_two()
61 let v = assert_ok!(rx1.recv().await); in broadcast_two()
64 match assert_err!(rx1.recv().await) { in broadcast_two()
98 let (tx, mut rx1) = broadcast::channel(2); in broadcast_wrap()
106 match rx1.recv().await { in broadcast_wrap()
147 let (tx, mut rx1) = broadcast::channel(16); in drop_rx()
152 let v = assert_ok!(rx1.recv().await); in drop_rx()
155 let v = assert_ok!(rx1.recv().await); in drop_rx()
158 let v = assert_ok!(rx1.recv().await); in drop_rx()
[all …]
|
| D | loom_notify.rs | 83 let rx1 = notify.clone(); in notify_drop() localVariable
87 let mut recv = Box::pin(rx1.notified()); in notify_drop()
91 rx1.notify_one(); in notify_drop()
|
| /external/rust/crates/futures/tests/ |
| D | oneshot.rs | 9 let (tx1, rx1) = oneshot::channel::<i32>(); in oneshot_send1()
13 rx1.map_ok(move |x| tx2.send(x)).run_in_background(); in oneshot_send1()
26 let (tx1, rx1) = oneshot::channel::<i32>(); in oneshot_send2()
30 rx1.map_ok(move |x| tx2.send(x).unwrap()).run_in_background(); in oneshot_send2()
42 let (tx1, rx1) = oneshot::channel::<i32>(); in oneshot_send3()
45 rx1.map_ok(move |x| tx2.send(x).unwrap()).run_in_background(); in oneshot_send3()
57 let (tx1, rx1) = oneshot::channel::<i32>(); in oneshot_drop_tx1()
61 rx1.map(move |result| tx2.send(result).unwrap()).run_in_background(); in oneshot_drop_tx1()
74 let (tx1, rx1) = oneshot::channel::<i32>(); in oneshot_drop_tx2()
78 rx1.map(move |result| tx2.send(result).unwrap()).run_in_background(); in oneshot_drop_tx2()
|
| D | eager_drop.rs | 9 let (tx1, rx1) = mpsc::channel::<()>(); in map_ok()
15 assert!(rx1.recv().is_err()); in map_ok()
31 let (tx1, rx1) = mpsc::channel::<()>(); in map_err()
37 assert!(rx1.recv().is_err()); in map_err()
74 let (tx1, rx1) = mpsc::channel::<()>(); in then_drops_eagerly()
79 assert!(rx1.recv().is_err()); // tx1 should have been dropped in then_drops_eagerly()
98 let (tx1, rx1) = mpsc::channel::<()>(); in and_then_drops_eagerly()
103 assert!(rx1.recv().is_err()); // tx1 should have been dropped in and_then_drops_eagerly()
122 let (tx1, rx1) = mpsc::channel::<()>(); in or_else_drops_eagerly()
127 assert!(rx1.recv().is_err()); // tx1 should have been dropped in or_else_drops_eagerly()
|
| D | async_await_macros.rs | 22 let (tx1, rx1) = oneshot::channel::<i32>(); in join()
26 let res = join!(rx1, rx2); in join()
47 let (tx1, rx1) = oneshot::channel::<i32>(); in select()
53 res = rx1.fuse() => { in select()
70 let (tx1, rx1) = oneshot::channel::<i32>(); in select_biased()
76 res = rx1.fuse() => { in select_biased()
94 let (mut tx1, rx1) = mpsc::channel::<i32>(1); in select_streams()
96 let mut rx1 = rx1.fuse(); in select_streams() localVariable
104 _ = rx1.next() => panic!(), in select_streams()
117 x = rx1.next() => if let Some(x) = x { total += x; }, in select_streams()
[all …]
|
| D | ready_queue.rs | 18 let (tx1, rx1) = oneshot::channel(); in basic_usage()
22 queue.push(rx1); in basic_usage()
52 let (tx1, rx1) = oneshot::channel(); in resolving_errors()
56 queue.push(rx1); in resolving_errors()
86 let (mut tx1, rx1) = oneshot::channel::<()>(); in dropping_ready_queue()
90 queue.push(rx1); in dropping_ready_queue()
|
| D | stream.rs | 130 let (_, rx1) = mpsc::channel::<()>(1); in ready_chunks_panic_on_cap_zero()
132 let _ = rx1.ready_chunks(0); in ready_chunks_panic_on_cap_zero()
143 let (mut tx, rx1) = mpsc::channel::<i32>(16); in ready_chunks()
145 let mut s = rx1.ready_chunks(2); in ready_chunks()
|
| D | sink_fanout.rs | 9 let (tx1, rx1) = mpsc::channel(1); in it_works()
16 let collect_fut1 = rx1.collect::<Vec<_>>(); in it_works()
|
| /external/rust/crates/tokio/tests/ |
| D | sync_broadcast.rs | 73 let (tx, mut rx1) = broadcast::channel(16); in send_two_recv()
76 assert_empty!(rx1); in send_two_recv()
82 let val = assert_recv!(rx1); in send_two_recv()
88 assert_empty!(rx1); in send_two_recv()
109 let (tx, mut rx1) = broadcast::channel(16); in send_two_recv_bounded()
112 let mut recv1 = task::spawn(rx1.recv()); in send_two_recv_bounded()
130 let mut recv1 = task::spawn(rx1.recv()); in send_two_recv_bounded()
165 let (tx, mut rx1) = broadcast::channel(16); in send_slow_rx()
172 let mut recv1 = task::spawn(rx1.recv()); in send_slow_rx()
188 let val = assert_ready_ok!(task::spawn(rx1.recv()).poll()); in send_slow_rx()
[all …]
|
| D | sync_watch.rs | 46 let (tx, mut rx1) = watch::channel("one"); in multi_rx()
47 let mut rx2 = rx1.clone(); in multi_rx()
50 let mut t1 = spawn(rx1.changed()); in multi_rx()
56 assert_eq!(*rx1.borrow(), "one"); in multi_rx()
62 let mut t1 = spawn(rx1.changed()); in multi_rx()
74 assert_eq!(*rx1.borrow(), "two"); in multi_rx()
77 let mut t1 = spawn(rx1.changed()); in multi_rx()
89 assert_eq!(*rx1.borrow(), "three"); in multi_rx()
96 let mut t1 = spawn(rx1.changed()); in multi_rx()
107 assert_eq!(*rx1.borrow(), "four"); in multi_rx()
|
| D | macros_select.rs | 105 let (tx1, rx1) = oneshot::channel::<i32>(); in one_ready()
111 res = rx1 => { in one_ready()
122 let (tx1, mut rx1) = mpsc::unbounded_channel::<i32>(); in select_streams()
143 Some(x) = rx1.recv() => { in select_streams()
161 let (tx1, mut rx1) = oneshot::channel::<i32>(); in move_uncompleted_futures()
170 res = &mut rx1 => { in move_uncompleted_futures()
177 assert_eq!(1, assert_ok!(rx1.await)); in move_uncompleted_futures()
327 let (tx1, mut rx1) = oneshot::channel(); in join_with_select()
336 v1 = &mut rx1, if a.is_none() => a = Some(assert_ok!(v1)), in join_with_select()
487 let (_tx1, rx1) = oneshot::channel::<i32>(); in biased_one_not_ready()
[all …]
|
| D | macros_try_join.rs | 35 let (tx1, rx1) = oneshot::channel::<&str>(); in two_await()
39 task::spawn(async { tokio::try_join!(async { rx1.await }, async { rx2.await }) }); in two_await()
56 let (tx1, rx1) = oneshot::channel::<&str>(); in err_abort_early()
61 tokio::try_join!(async { rx1.await }, async { rx2.await }, async { in err_abort_early()
|
| D | macros_join.rs | 35 let (tx1, rx1) = oneshot::channel::<&str>(); in two_await()
39 tokio::join!(async { rx1.await.unwrap() }, async { rx2.await.unwrap() }) in two_await()
|
| D | rt_common.rs | 149 let (tx1, rx1) = oneshot::channel();
157 let msg = assert_ok!(rx1.await);
360 let (tx1, rx1) = oneshot::channel();
376 assert_ok!(rx1.await);
565 let (tx1, rx1) = oneshot::channel();
580 rx1.await.unwrap();
761 let (tx1, rx1) = oneshot::channel();
771 let _ = rx1.await;
1066 let (tx1, mut rx1) = mpsc::unbounded_channel();
1085 while rx1.recv().await.is_some() {
|
| D | task_local_set.rs | 437 let rx1 = RX1.load(SeqCst); in local_tasks_are_polled_after_tick() localVariable
439 println!("EXPECT = {}; RX1 = {}; RX2 = {}", EXPECTED, rx1, rx2); in local_tasks_are_polled_after_tick()
440 assert_eq!(EXPECTED, rx1); in local_tasks_are_polled_after_tick()
462 let (tx1, rx1) = oneshot::channel(); in acquire_mutex_in_drop()
472 let _ = rx1.await; in acquire_mutex_in_drop()
|
| D | rt_basic.rs | 107 let (tx1, rx1) = oneshot::channel(); in acquire_mutex_in_drop()
118 let _ = rx1.await; in acquire_mutex_in_drop()
|
| /external/rust/crates/crossbeam-channel/tests/ |
| D | mpsc.rs | 364 let (tx1, rx1) = channel::<()>(); in send_from_outside_runtime()
372 rx1.recv().unwrap(); in send_from_outside_runtime()
398 let (tx1, rx1) = channel::<i32>(); in no_runtime()
401 assert_eq!(rx1.recv().unwrap(), 1); in no_runtime()
900 let (tx1, rx1) = channel::<i32>(); in try_recv_states()
912 assert_eq!(rx1.try_recv(), Err(TryRecvError::Empty)); in try_recv_states()
915 assert_eq!(rx1.try_recv(), Ok(1)); in try_recv_states()
916 assert_eq!(rx1.try_recv(), Err(TryRecvError::Empty)); in try_recv_states()
919 assert_eq!(rx1.try_recv(), Err(TryRecvError::Disconnected)); in try_recv_states()
1532 let (tx1, rx1) = sync_channel::<i32>(1); in try_recv_states()
[all …]
|
| /external/rust/crates/tokio-stream/tests/ |
| D | stream_stream_map.rs | 85 let (tx1, rx1) = mpsc::unbounded_channel_stream(); in multiple_entries()
88 let rx1 = Box::pin(rx1); in multiple_entries() localVariable
91 map.insert("foo", rx1); in multiple_entries()
174 let (tx1, rx1) = mpsc::unbounded_channel_stream(); in replace()
177 let rx1 = Box::pin(rx1); in replace() localVariable
180 assert!(map.insert("foo", rx1).is_none()); in replace()
|
| D | stream_merge.rs | 26 let (tx1, rx1) = mpsc::unbounded_channel_stream(); in merge_async_streams()
29 let mut rx = task::spawn(rx1.merge(rx2)); in merge_async_streams()
|
| D | stream_chain.rs | 44 let (tx1, rx1) = mpsc::unbounded_channel_stream(); in pending_first()
47 let mut stream = task::spawn(rx1.chain(rx2)); in pending_first()
|
| /external/rust/crates/rayon-core/src/spawn/ |
| D | test.rs | 59 let (tx1, rx1) = channel(); in termination_while_things_are_executing()
78 let v = rx1.recv().unwrap(); in termination_while_things_are_executing()
|
| /external/rust/crates/parking_lot/src/ |
| D | once.rs | 425 let (tx1, rx1) = channel(); in wait_for_force_to_finish()
435 rx1.recv().unwrap(); in wait_for_force_to_finish()
|
| /external/rust/crates/once_cell/src/ |
| D | imp_std.rs | 333 let (tx1, rx1) = channel(); in wait_for_force_to_finish()
342 rx1.recv().unwrap(); in wait_for_force_to_finish()
|
| /external/autotest/client/tools/ |
| D | html_report.py | 1498 rx1 = re.compile('(\s+)')
1499 log_text = rx1.sub(' ', res['log'])
|