| /external/rust/crates/futures/tests/ |
| D | oneshot.rs | 10 let (tx2, rx2) = mpsc::channel(); in oneshot_send1()
13 rx1.map_ok(move |x| tx2.send(x)).run_in_background(); in oneshot_send1()
27 let (tx2, rx2) = mpsc::channel(); in oneshot_send2()
30 rx1.map_ok(move |x| tx2.send(x).unwrap()).run_in_background(); in oneshot_send2()
43 let (tx2, rx2) = mpsc::channel(); in oneshot_send3()
45 rx1.map_ok(move |x| tx2.send(x).unwrap()).run_in_background(); in oneshot_send3()
58 let (tx2, rx2) = mpsc::channel(); in oneshot_drop_tx1()
61 rx1.map(move |result| tx2.send(result).unwrap()).run_in_background(); in oneshot_drop_tx1()
75 let (tx2, rx2) = mpsc::channel(); in oneshot_drop_tx2()
78 rx1.map(move |result| tx2.send(result).unwrap()).run_in_background(); in oneshot_drop_tx2()
|
| D | eager_drop.rs | 10 let (tx2, rx2) = mpsc::channel::<()>(); in map_ok()
16 tx2.send(()).unwrap() in map_ok()
32 let (tx2, rx2) = mpsc::channel::<()>(); in map_err()
38 tx2.send(()).unwrap() in map_err()
75 let (tx2, rx2) = mpsc::channel::<()>(); in then_drops_eagerly()
80 tx2.send(()).unwrap(); in then_drops_eagerly()
99 let (tx2, rx2) = mpsc::channel::<()>(); in and_then_drops_eagerly()
104 tx2.send(()).unwrap(); in and_then_drops_eagerly()
123 let (tx2, rx2) = mpsc::channel::<()>(); in or_else_drops_eagerly()
128 tx2.send(()).unwrap(); in or_else_drops_eagerly()
|
| D | basic_combinators.rs | 8 let tx2 = tx1.clone(); in basic_future_combinators() localVariable
17 tx2.send(x).unwrap(); // Send 3 in basic_future_combinators()
18 tx2.send(4).unwrap(); // Send 4 in basic_future_combinators()
33 let tx2 = tx1.clone(); in basic_try_future_combinators() localVariable
50 tx2.send(x).unwrap(); // Should not run in basic_try_future_combinators()
51 tx2.send(-1).unwrap(); in basic_try_future_combinators()
|
| D | ready_queue.rs | 19 let (tx2, rx2) = oneshot::channel(); in basic_usage()
28 tx2.send("hello").unwrap(); in basic_usage()
53 let (tx2, rx2) = oneshot::channel(); in resolving_errors()
62 drop(tx2); in resolving_errors()
87 let (mut tx2, rx2) = oneshot::channel::<()>(); in dropping_ready_queue()
97 assert!(!tx2.poll_canceled(cx).is_ready()); in dropping_ready_queue()
103 assert!(tx2.poll_canceled(cx).is_ready()); in dropping_ready_queue()
|
| D | async_await_macros.rs | 23 let (tx2, rx2) = oneshot::channel::<i32>(); in join()
35 tx2.send(2).unwrap(); in join()
95 let (mut tx2, rx2) = mpsc::channel::<i32>(1); in select_streams()
108 tx2.send(3).await.unwrap(); in select_streams()
110 tx2_opt = Some(tx2); in select_streams()
143 let (tx2, rx2) = oneshot::channel::<i32>(); in select_can_move_uncompleted_futures()
145 tx2.send(2).unwrap(); in select_can_move_uncompleted_futures()
|
| D | sink_fanout.rs | 10 let (tx2, rx2) = mpsc::channel(2); in it_works()
11 let tx = tx1.fanout(tx2).sink_map_err(|_| ()); in it_works()
|
| /external/linux-kselftest/tools/testing/selftests/timers/ |
| D | raw_skew.c | 96 struct timex tx1, tx2; in main() local
120 tx2.modes = 0; in main()
121 adjtimex(&tx2); in main()
132 ppm = (tx1.freq + tx2.freq) * 1000 / 2; in main()
138 if (tx1.offset || tx2.offset || in main()
139 tx1.freq != tx2.freq || tx1.tick != tx2.tick) { in main()
|
| /external/rust/crates/futures-channel/tests/ |
| D | mpsc-close.rs | 30 let (tx2, mut tx3, mut tx4) = (tx1.clone(), tx1.clone(), tx1.clone()); in multiple_senders_disconnect()
35 drop(tx2); in multiple_senders_disconnect()
52 let (tx2, mut tx3, mut tx4) = (tx1.clone(), tx1.clone(), tx1.clone()); in multiple_senders_disconnect()
57 drop(tx2); in multiple_senders_disconnect()
77 let mut tx2 = tx1.clone(); in multiple_senders_close_channel() localVariable
83 assert!(tx2.is_closed()); in multiple_senders_close_channel()
85 let err = block_on(tx2.send(5)).unwrap_err(); in multiple_senders_close_channel()
93 let mut tx2 = tx1.clone(); in multiple_senders_close_channel() localVariable
99 assert!(tx2.is_closed()); in multiple_senders_close_channel()
101 let err = block_on(tx2.send(5)).unwrap_err(); in multiple_senders_close_channel()
|
| D | oneshot.rs | 40 for (mut tx, tx2) in rx { in cancel_lots()
42 tx2.send(()).unwrap(); in cancel_lots()
48 let (tx2, rx2) = mpsc::channel(); in cancel_lots()
49 tx.send((otx, tx2)).unwrap(); in cancel_lots()
84 let (tx2, rx2) = mpsc::channel(); in close_wakes()
90 tx2.send(()).unwrap(); in close_wakes()
|
| /external/rust/crates/tokio/src/sync/tests/ |
| D | loom_mpsc.rs | 49 let tx2 = tx1.clone(); in closing_bounded_rx() localVariable
55 block_on(tx2.closed()); in closing_bounded_rx()
64 let tx2 = tx1.clone(); in closing_and_sending() localVariable
71 block_on(tx2.closed()); in closing_and_sending()
90 let tx2 = tx1.clone(); in closing_unbounded_rx() localVariable
96 block_on(tx2.closed()); in closing_unbounded_rx()
|
| D | loom_broadcast.rs | 14 let tx2 = tx1.clone(); in broadcast_send() localVariable
26 assert_ok!(tx2.send("eins")); in broadcast_send()
27 assert_ok!(tx2.send("zwei")); in broadcast_send()
28 assert_ok!(tx2.send("drei")); in broadcast_send()
190 let tx2 = tx.clone(); in drop_multiple_rx_with_overflow() localVariable
194 let _ = tx2.send(()); in drop_multiple_rx_with_overflow()
|
| /external/rust/crates/crossbeam-channel/tests/ |
| D | mpsc.rs | 262 let tx2 = tx.clone(); in smoke_shared_port_gone2() localVariable
264 assert!(tx2.send(1).is_err()); in smoke_shared_port_gone2()
280 let tx2 = tx.clone(); in port_gone_concurrent_shared() localVariable
284 while tx.send(1).is_ok() && tx2.send(1).is_ok() {} in port_gone_concurrent_shared()
298 let tx2 = tx.clone(); in smoke_chan_gone_shared() localVariable
300 drop(tx2); in smoke_chan_gone_shared()
365 let (tx2, rx2) = channel::<i32>(); in send_from_outside_runtime()
375 tx2.send(1).unwrap(); in send_from_outside_runtime()
399 let (tx2, rx2) = channel::<i32>(); in no_runtime()
402 tx2.send(2).unwrap(); in no_runtime()
[all …]
|
| /external/rust/crates/tokio-stream/tests/ |
| D | stream_merge.rs | 27 let (tx2, rx2) = mpsc::unbounded_channel_stream(); in merge_async_streams()
41 tx2.send(2).unwrap(); in merge_async_streams()
51 tx2.send(3).unwrap(); in merge_async_streams()
56 drop(tx2); in merge_async_streams()
|
| D | stream_chain.rs | 45 let (tx2, rx2) = mpsc::unbounded_channel_stream(); in pending_first()
52 tx2.send(2).unwrap(); in pending_first()
72 drop(tx2); in pending_first()
|
| D | stream_stream_map.rs | 86 let (tx2, rx2) = mpsc::unbounded_channel_stream(); in multiple_entries()
105 assert_ok!(tx2.send(2)); in multiple_entries()
115 assert_ok!(tx2.send(4)); in multiple_entries()
136 drop(tx2); in multiple_entries()
175 let (tx2, rx2) = mpsc::unbounded_channel_stream(); in replace()
191 tx2.send(2).unwrap(); in replace()
|
| /external/rust/crates/tokio/tests/ |
| D | sync_mpsc.rs | 52 let tx2 = tx.clone(); in reserve_disarm() localVariable
58 let permit2 = assert_ok!(tx2.reserve().await); in reserve_disarm()
123 let tx2 = tx1.clone(); in start_send_past_cap() localVariable
131 let mut r2 = task::spawn(tx2.reserve()); in start_send_past_cap()
143 drop(tx2); in start_send_past_cap()
278 let tx2 = tx1.clone(); in recv_close_gets_none_reserved() localVariable
281 let mut permit2 = task::spawn(tx2.reserve()); in recv_close_gets_none_reserved()
358 let tx2 = tx1.clone(); in drop_permit_releases_permit() localVariable
362 let mut reserve2 = task::spawn(tx2.reserve()); in drop_permit_releases_permit()
482 let tx2 = tx1.clone(); in permit_available_not_acquired_close() localVariable
[all …]
|
| D | macros_select.rs | 123 let (tx2, mut rx2) = mpsc::unbounded_channel::<i32>(); in select_streams()
126 assert_ok!(tx2.send(1)); in select_streams()
132 assert_ok!(tx2.send(3)); in select_streams()
135 drop((tx1, tx2)); in select_streams()
162 let (tx2, mut rx2) = oneshot::channel::<i32>(); in move_uncompleted_futures()
165 tx2.send(2).unwrap(); in move_uncompleted_futures()
328 let (tx2, mut rx2) = oneshot::channel(); in join_with_select()
350 assert_ok!(tx2.send(456)); in join_with_select()
488 let (tx2, rx2) = oneshot::channel::<i32>(); in biased_one_not_ready()
491 tx2.send(2).unwrap(); in biased_one_not_ready()
|
| D | macros_try_join.rs | 36 let (tx2, rx2) = oneshot::channel::<u32>(); in two_await()
43 tx2.send(123).unwrap(); in two_await()
57 let (tx2, rx2) = oneshot::channel::<u32>(); in err_abort_early()
68 tx2.send(123).unwrap(); in err_abort_early()
|
| D | macros_join.rs | 36 let (tx2, rx2) = oneshot::channel::<u32>(); in two_await()
44 tx2.send(123).unwrap(); in two_await()
|
| /external/rust/crates/parking_lot/src/ |
| D | fair_mutex.rs | 142 let tx2 = tx.clone(); in lots_and_lots() localVariable
146 tx2.send(()).unwrap(); in lots_and_lots()
148 let tx2 = tx.clone(); in lots_and_lots() localVariable
152 tx2.send(()).unwrap(); in lots_and_lots()
|
| D | mutex.rs | 153 let tx2 = tx.clone(); in lots_and_lots() localVariable
157 tx2.send(()).unwrap(); in lots_and_lots()
159 let tx2 = tx.clone(); in lots_and_lots() localVariable
163 tx2.send(()).unwrap(); in lots_and_lots()
|
| /external/bouncycastle/bcprov/src/main/java/org/bouncycastle/math/ |
| D | Primes.java | 528 BigInteger tx2 = x.subtract(ONE).divide(c0x2).add(ONE).shiftLeft(1); in implSTRandomPrime() local
531 BigInteger c = tx2.multiply(c0).add(ONE); in implSTRandomPrime()
541 tx2 = ONE.shiftLeft(length - 1).subtract(ONE).divide(c0x2).add(ONE).shiftLeft(1); in implSTRandomPrime()
542 c = tx2.multiply(c0).add(ONE); in implSTRandomPrime()
558 tx2 = tx2.add(BigInteger.valueOf(dt)); in implSTRandomPrime()
561 BigInteger z = a.modPow(tx2, c); in implSTRandomPrime()
|
| /external/bouncycastle/repackaged/bcprov/src/main/java/com/android/org/bouncycastle/math/ |
| D | Primes.java | 532 BigInteger tx2 = x.subtract(ONE).divide(c0x2).add(ONE).shiftLeft(1); in implSTRandomPrime() local
535 BigInteger c = tx2.multiply(c0).add(ONE); in implSTRandomPrime()
545 tx2 = ONE.shiftLeft(length - 1).subtract(ONE).divide(c0x2).add(ONE).shiftLeft(1); in implSTRandomPrime()
546 c = tx2.multiply(c0).add(ONE); in implSTRandomPrime()
562 tx2 = tx2.add(BigInteger.valueOf(dt)); in implSTRandomPrime()
565 BigInteger z = a.modPow(tx2, c); in implSTRandomPrime()
|
| /external/bouncycastle/repackaged_platform/bcprov/src/main/java/com/android/internal/org/bouncycastle/math/ |
| D | Primes.java | 532 BigInteger tx2 = x.subtract(ONE).divide(c0x2).add(ONE).shiftLeft(1); in implSTRandomPrime() local
535 BigInteger c = tx2.multiply(c0).add(ONE); in implSTRandomPrime()
545 tx2 = ONE.shiftLeft(length - 1).subtract(ONE).divide(c0x2).add(ONE).shiftLeft(1); in implSTRandomPrime()
546 c = tx2.multiply(c0).add(ONE); in implSTRandomPrime()
562 tx2 = tx2.add(BigInteger.valueOf(dt)); in implSTRandomPrime()
565 BigInteger z = a.modPow(tx2, c); in implSTRandomPrime()
|
| /external/rust/crates/rusqlite/src/ |
| D | unlock_notify.rs | 117 let tx2 = Transaction::new(&mut db2, TransactionBehavior::Immediate).unwrap(); in test_unlock_notify() localVariable
118 tx2.execute_batch("INSERT INTO foo VALUES (42)").unwrap(); in test_unlock_notify()
122 tx2.commit().unwrap(); in test_unlock_notify()
|