Home
last modified time | relevance | path

Searched refs:tx1 (Results 1 – 25 of 41) sorted by relevance

12

/external/linux-kselftest/tools/testing/selftests/timers/
Dadjtick.c118 struct timex tx1; in check_tick_adj() local
120 tx1.modes = ADJ_TICK; in check_tick_adj()
121 tx1.modes |= ADJ_OFFSET; in check_tick_adj()
122 tx1.modes |= ADJ_FREQUENCY; in check_tick_adj()
123 tx1.modes |= ADJ_STATUS; in check_tick_adj()
125 tx1.status = STA_PLL; in check_tick_adj()
126 tx1.offset = 0; in check_tick_adj()
127 tx1.freq = 0; in check_tick_adj()
128 tx1.tick = tickval; in check_tick_adj()
130 adjtimex(&tx1); in check_tick_adj()
[all …]
Draw_skew.c96 struct timex tx1, tx2; in main() local
105 tx1.modes = 0; in main()
106 adjtimex(&tx1); in main()
111 if (tx1.offset) in main()
132 ppm = (tx1.freq + tx2.freq) * 1000 / 2; in main()
133 ppm = (long long)tx1.freq * 1000; 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/tests/
Dbasic_combinators.rs7 let (tx1, rx) = mpsc::channel(); in basic_future_combinators()
8 let tx2 = tx1.clone(); in basic_future_combinators()
9 let tx3 = tx1.clone(); in basic_future_combinators()
13 tx1.send(x).unwrap(); // Send 1 in basic_future_combinators()
14 tx1.send(2).unwrap(); // Send 2 in basic_future_combinators()
32 let (tx1, rx) = mpsc::channel(); in basic_try_future_combinators()
33 let tx2 = tx1.clone(); in basic_try_future_combinators()
34 let tx3 = tx1.clone(); in basic_try_future_combinators()
35 let tx4 = tx1.clone(); in basic_try_future_combinators()
36 let tx5 = tx1.clone(); in basic_try_future_combinators()
[all …]
Doneshot.rs9 let (tx1, rx1) = oneshot::channel::<i32>(); in oneshot_send1()
12 let t = thread::spawn(|| tx1.send(1).unwrap()); in oneshot_send1()
26 let (tx1, rx1) = oneshot::channel::<i32>(); in oneshot_send2()
29 thread::spawn(|| tx1.send(1).unwrap()).join().unwrap(); in oneshot_send2()
42 let (tx1, rx1) = oneshot::channel::<i32>(); in oneshot_send3()
46 thread::spawn(|| tx1.send(1).unwrap()).join().unwrap(); in oneshot_send3()
57 let (tx1, rx1) = oneshot::channel::<i32>(); in oneshot_drop_tx1()
60 drop(tx1); in oneshot_drop_tx1()
74 let (tx1, rx1) = oneshot::channel::<i32>(); in oneshot_drop_tx2()
77 let t = thread::spawn(|| drop(tx1)); in oneshot_drop_tx2()
Deager_drop.rs9 let (tx1, rx1) = mpsc::channel::<()>(); in map_ok()
13 .map_ok(move |_| { let _tx1 = tx1; panic!("should not run"); }) in map_ok()
31 let (tx1, rx1) = mpsc::channel::<()>(); in map_err()
35 .map_err(move |_| { let _tx1 = tx1; panic!("should not run"); }) in map_err()
74 let (tx1, rx1) = mpsc::channel::<()>(); in then_drops_eagerly()
77 FutureData { _data: tx1, future: rx0.unwrap_or_else(|_| { panic!() }) } in then_drops_eagerly()
98 let (tx1, rx1) = mpsc::channel::<()>(); in and_then_drops_eagerly()
101 FutureData { _data: tx1, future: rx0.unwrap_or_else(|_| { panic!() }) } in and_then_drops_eagerly()
122 let (tx1, rx1) = mpsc::channel::<()>(); in or_else_drops_eagerly()
125 FutureData { _data: tx1, future: rx0.unwrap_or_else(|_| { panic!() }) } in or_else_drops_eagerly()
Dasync_await_macros.rs22 let (tx1, rx1) = oneshot::channel::<i32>(); in join()
33 tx1.send(1).unwrap(); in join()
47 let (tx1, rx1) = oneshot::channel::<i32>(); in select()
49 tx1.send(1).unwrap(); in select()
70 let (tx1, rx1) = oneshot::channel::<i32>(); in select_biased()
72 tx1.send(1).unwrap(); in select_biased()
94 let (mut tx1, rx1) = mpsc::channel::<i32>(1); in select_streams()
107 tx1.send(2).await.unwrap(); in select_streams()
109 tx1_opt = Some(tx1); in select_streams()
142 let (tx1, rx1) = oneshot::channel::<i32>(); in select_can_move_uncompleted_futures()
[all …]
Dready_queue.rs18 let (tx1, rx1) = oneshot::channel(); in basic_usage()
33 tx1.send("world").unwrap(); in basic_usage()
52 let (tx1, rx1) = oneshot::channel(); in resolving_errors()
67 drop(tx1); in resolving_errors()
86 let (mut tx1, rx1) = oneshot::channel::<()>(); in dropping_ready_queue()
96 assert!(!tx1.poll_canceled(cx).is_ready()); in dropping_ready_queue()
102 assert!(tx1.poll_canceled(cx).is_ready()); in dropping_ready_queue()
Dsink_fanout.rs9 let (tx1, rx1) = mpsc::channel(1); in it_works()
11 let tx = tx1.fanout(tx2).sink_map_err(|_| ()); in it_works()
/external/rust/crates/futures-channel/tests/
Dmpsc-close.rs29 let (mut tx1, mut rx) = mpsc::channel(1); in multiple_senders_disconnect()
30 let (tx2, mut tx3, mut tx4) = (tx1.clone(), tx1.clone(), tx1.clone()); in multiple_senders_disconnect()
34 tx1.disconnect(); in multiple_senders_disconnect()
38 assert!(tx1.is_closed()); in multiple_senders_disconnect()
51 let (mut tx1, mut rx) = mpsc::unbounded(); in multiple_senders_disconnect()
52 let (tx2, mut tx3, mut tx4) = (tx1.clone(), tx1.clone(), tx1.clone()); in multiple_senders_disconnect()
56 tx1.disconnect(); in multiple_senders_disconnect()
60 assert!(tx1.is_closed()); in multiple_senders_disconnect()
76 let (mut tx1, mut rx) = mpsc::channel(1); in multiple_senders_close_channel()
77 let mut tx2 = tx1.clone(); in multiple_senders_close_channel()
[all …]
Dmpsc.rs65 let (mut tx1, rx) = mpsc::channel::<i32>(16); in send_shared_recv()
67 let mut tx2 = tx1.clone(); in send_shared_recv()
69 block_on(tx1.send(1)).unwrap(); in send_shared_recv()
618 let (mut tx1, mut rx) = mpsc::channel(1); in send_backpressure_multi_senders()
619 let mut tx2 = tx1.clone(); in send_backpressure_multi_senders()
620 block_on(tx1.send(1)).unwrap(); in send_backpressure_multi_senders()
/external/rust/crates/tokio/src/sync/tests/
Dloom_mpsc.rs48 let (tx1, rx) = mpsc::channel::<()>(16); in closing_bounded_rx()
49 let tx2 = tx1.clone(); in closing_bounded_rx()
54 block_on(tx1.closed()); in closing_bounded_rx()
62 let (tx1, mut rx) = mpsc::channel::<()>(16); in closing_and_sending()
63 let tx1 = Arc::new(tx1); in closing_and_sending() localVariable
64 let tx2 = tx1.clone(); in closing_and_sending()
67 tx1.try_send(()).unwrap(); in closing_and_sending()
89 let (tx1, rx) = mpsc::unbounded_channel::<()>(); in closing_unbounded_rx()
90 let tx2 = tx1.clone(); in closing_unbounded_rx()
95 block_on(tx1.closed()); in closing_unbounded_rx()
Dloom_broadcast.rs12 let (tx1, mut rx) = broadcast::channel(2); in broadcast_send()
13 let tx1 = Arc::new(tx1); in broadcast_send() localVariable
14 let tx2 = tx1.clone(); in broadcast_send()
18 assert_ok!(tx1.send("one")); in broadcast_send()
19 assert_ok!(tx1.send("two")); in broadcast_send()
20 assert_ok!(tx1.send("three")); in broadcast_send()
/external/rust/crates/tokio/tests/
Dsync_mpsc.rs51 let tx1 = tx.clone(); in reserve_disarm() localVariable
57 let permit1 = assert_ok!(tx1.reserve().await); in reserve_disarm()
81 let mut r1 = task::spawn(tx1.reserve()); in reserve_disarm()
122 let (tx1, mut rx) = mpsc::channel(1); in start_send_past_cap()
123 let tx2 = tx1.clone(); in start_send_past_cap()
125 assert_ok!(tx1.try_send(())); in start_send_past_cap()
127 let mut r1 = Box::pin(tx1.reserve()); in start_send_past_cap()
142 drop(tx1); in start_send_past_cap()
277 let (tx1, mut rx) = mpsc::channel::<i32>(1); in recv_close_gets_none_reserved()
278 let tx2 = tx1.clone(); in recv_close_gets_none_reserved()
[all …]
Dmacros_try_join.rs35 let (tx1, rx1) = oneshot::channel::<&str>(); in two_await()
47 tx1.send("hello").unwrap(); in two_await()
56 let (tx1, rx1) = oneshot::channel::<&str>(); in err_abort_early()
72 drop(tx1); in err_abort_early()
Dmacros_select.rs105 let (tx1, rx1) = oneshot::channel::<i32>(); in one_ready()
108 tx1.send(1).unwrap(); in one_ready()
122 let (tx1, mut rx1) = mpsc::unbounded_channel::<i32>(); in select_streams()
129 assert_ok!(tx1.send(2)); in select_streams()
135 drop((tx1, tx2)); in select_streams()
161 let (tx1, mut rx1) = oneshot::channel::<i32>(); in move_uncompleted_futures()
164 tx1.send(1).unwrap(); in move_uncompleted_futures()
327 let (tx1, mut rx1) = oneshot::channel(); in join_with_select()
346 assert_ok!(tx1.send(123)); in join_with_select()
Drt_common.rs149 let (tx1, rx1) = oneshot::channel();
153 assert_ok!(tx1.send("ZOMG"));
360 let (tx1, rx1) = oneshot::channel();
372 assert_ok!(tx1.send(()));
565 let (tx1, rx1) = oneshot::channel();
572 tx1.send(()).unwrap();
761 let (tx1, rx1) = oneshot::channel();
782 let mut opt_tx1 = Some(tx1);
784 let tx1 = opt_tx1.take().unwrap(); localVariable
786 tx1.send(()).unwrap();
[all …]
Dmacros_join.rs35 let (tx1, rx1) = oneshot::channel::<&str>(); in two_await()
48 tx1.send("hello").unwrap(); in two_await()
Drt_basic.rs107 let (tx1, rx1) = oneshot::channel(); in acquire_mutex_in_drop()
126 tx1.send(()).unwrap(); in acquire_mutex_in_drop()
/external/rust/crates/rusqlite/src/
Dbusy.rs93 let tx1 = db1 in test_default_busy() localVariable
104 tx1.rollback().unwrap(); in test_default_busy()
119 let tx1 = db1 in test_busy_timeout() localVariable
124 tx1.rollback().unwrap(); in test_busy_timeout()
158 let tx1 = db1 in test_busy_handler() localVariable
163 tx1.rollback().unwrap(); in test_busy_handler()
/external/rust/crates/crossbeam-channel/tests/
Dmpsc.rs364 let (tx1, rx1) = channel::<()>(); in send_from_outside_runtime()
367 tx1.send(()).unwrap(); in send_from_outside_runtime()
398 let (tx1, rx1) = channel::<i32>(); in no_runtime()
405 tx1.send(1).unwrap(); in no_runtime()
900 let (tx1, rx1) = channel::<i32>(); in try_recv_states()
905 tx1.send(1).unwrap(); in try_recv_states()
908 drop(tx1); in try_recv_states()
1532 let (tx1, rx1) = sync_channel::<i32>(1); in try_recv_states()
1537 tx1.send(1).unwrap(); in try_recv_states()
1540 drop(tx1); in try_recv_states()
[all …]
/external/rust/crates/tokio-stream/tests/
Dstream_merge.rs26 let (tx1, rx1) = mpsc::unbounded_channel_stream(); in merge_async_streams()
35 tx1.send(1).unwrap(); in merge_async_streams()
47 drop(tx1); in merge_async_streams()
Dstream_chain.rs44 let (tx1, rx1) = mpsc::unbounded_channel_stream(); in pending_first()
57 tx1.send(1).unwrap(); in pending_first()
63 drop(tx1); in pending_first()
Dstream_stream_map.rs85 let (tx1, rx1) = mpsc::unbounded_channel_stream(); in multiple_entries()
96 assert_ok!(tx1.send(1)); in multiple_entries()
114 assert_ok!(tx1.send(3)); in multiple_entries()
133 drop(tx1); in multiple_entries()
174 let (tx1, rx1) = mpsc::unbounded_channel_stream(); in replace()
188 tx1.send(1).unwrap(); in replace()
/external/mesa3d/src/amd/addrlib/src/r800/
Dsiaddrlib.cpp1093 UINT_32 tx0, tx1; in TileCoordToMaskElementIndex() local
1097 tx1 = _BIT(tx,1); in TileCoordToMaskElementIndex()
1106 elemIdx2 = tx1; in TileCoordToMaskElementIndex()
1107 elemIdx1 = tx1 ^ ty1; in TileCoordToMaskElementIndex()
1108 elemIdx0 = tx1 ^ ty0; in TileCoordToMaskElementIndex()
1114 elemIdx1 = tx1; in TileCoordToMaskElementIndex()
1115 elemIdx0 = tx1 ^ ty1; in TileCoordToMaskElementIndex()
1121 elemIdx0 = tx1^ty0; in TileCoordToMaskElementIndex()
1122 elemIdx1 = tx1; in TileCoordToMaskElementIndex()
1128 elemIdx0 = tx1^ty0; in TileCoordToMaskElementIndex()
[all …]
/external/pdfium/third_party/libopenjpeg20/
Dpi.c376 pi->poc.tx1 = pi->tx1; in opj_pi_next_rpcl()
381 for (pi->x = pi->poc.tx0; pi->x < pi->poc.tx1; in opj_pi_next_rpcl()
409 trx1 = opj_int_ceildiv(pi->tx1, (OPJ_INT32)(comp->dx << levelno)); in opj_pi_next_rpcl()
512 pi->poc.tx1 = pi->tx1; in opj_pi_next_pcrl()
516 for (pi->x = pi->poc.tx0; pi->x < pi->poc.tx1; in opj_pi_next_pcrl()
543 trx1 = opj_int_ceildiv(pi->tx1, (OPJ_INT32)(comp->dx << levelno)); in opj_pi_next_pcrl()
646 pi->poc.tx1 = pi->tx1; in opj_pi_next_cprl()
650 for (pi->x = pi->poc.tx0; pi->x < pi->poc.tx1; in opj_pi_next_cprl()
674 trx1 = opj_int_ceildiv(pi->tx1, (OPJ_INT32)(comp->dx << levelno)); in opj_pi_next_cprl()
1470 l_current_pi->tx1 = l_tx1; in opj_pi_create_decode()
[all …]

12