| /external/mesa3d/src/gallium/frontends/nine/ |
| D | nine_shader.c | 527 #define IS_VS (tx->processor == PIPE_SHADER_VERTEX)
528 #define IS_PS (tx->processor == PIPE_SHADER_FRAGMENT)
530 #define FAILURE_VOID(cond) if ((cond)) {tx->failure=1;return;}
548 nine_record_outputs(struct shader_translator *tx, BYTE Usage, BYTE UsageIndex, in nine_record_outputs() argument
551 tx->output_info[tx->num_outputs].output_semantic = Usage; in nine_record_outputs()
552 tx->output_info[tx->num_outputs].output_semantic_index = UsageIndex; in nine_record_outputs()
553 tx->output_info[tx->num_outputs].mask = mask; in nine_record_outputs()
554 tx->output_info[tx->num_outputs].output_index = output_index; in nine_record_outputs()
555 tx->num_outputs++; in nine_record_outputs()
558 static struct ureg_src nine_float_constant_src(struct shader_translator *tx, int idx) in nine_float_constant_src() argument
[all …]
|
| /external/rust/crates/tokio/tests/ |
| D | sync_oneshot.rs | 38 let (tx, rx) = oneshot::channel(); in send_recv()
43 assert_ok!(tx.send(1)); in send_recv()
53 let (tx, rx) = oneshot::channel(); in async_send_recv()
55 assert_ok!(tx.send(1)); in async_send_recv()
61 let (tx, rx) = oneshot::channel::<i32>(); in close_tx()
66 drop(tx); in close_tx()
76 let (tx, _) = oneshot::channel(); in close_rx()
78 assert_err!(tx.send(1)); in close_rx()
82 let (tx, rx) = oneshot::channel(); in close_rx()
83 let mut tx = task::spawn(tx); in close_rx() localVariable
[all …]
|
| D | sync_broadcast.rs | 61 let (tx, mut rx) = broadcast::channel(16); in send_try_recv_bounded()
65 let n = assert_ok!(tx.send("hello")); in send_try_recv_bounded()
76 let (tx, mut rx1) = broadcast::channel(16); in send_two_recv()
77 let mut rx2 = tx.subscribe(); in send_two_recv()
82 let n = assert_ok!(tx.send("hello")); in send_two_recv()
97 let (tx, mut rx) = broadcast::channel(16); in send_recv_bounded()
103 assert_ok!(tx.send("hello")); in send_recv_bounded()
112 let (tx, mut rx1) = broadcast::channel(16); in send_two_recv_bounded()
113 let mut rx2 = tx.subscribe(); in send_two_recv_bounded()
121 assert_ok!(tx.send("hello")); in send_two_recv_bounded()
[all …]
|
| D | sync_mpsc.rs | 29 let (tx, mut rx) = mpsc::channel::<i32>(16); in send_recv_with_buffer()
33 let permit = tx.reserve().await.unwrap(); in send_recv_with_buffer()
37 tx.try_send(2).unwrap(); in send_recv_with_buffer()
39 drop(tx); in send_recv_with_buffer()
54 let (tx, mut rx) = mpsc::channel::<i32>(2); in reserve_disarm()
55 let tx1 = tx.clone(); in reserve_disarm()
56 let tx2 = tx.clone(); in reserve_disarm()
57 let tx3 = tx.clone(); in reserve_disarm()
58 let tx4 = tx; in reserve_disarm()
94 let (tx, rx) = support::mpsc_stream::channel_stream::<i32>(16); in send_recv_stream_with_buffer()
[all …]
|
| D | sync_mpsc_weak.rs | 15 let (tx, mut rx) = channel(11); in weak_sender()
18 let tx_weak = tx.clone().downgrade(); in weak_sender()
21 if tx.send(i).await.is_err() { in weak_sender()
189 let (tx, mut rx) = mpsc::channel(3); in test_msgs_dropped_on_rx_drop()
191 tx.send(Msg {}).await.unwrap(); in test_msgs_dropped_on_rx_drop()
192 tx.send(Msg {}).await.unwrap(); in test_msgs_dropped_on_rx_drop()
195 let sent_fut = tx.send(Msg {}); in test_msgs_dropped_on_rx_drop()
207 assert!(tx.send(Msg {}).await.is_err()); in test_msgs_dropped_on_rx_drop()
215 let (tx, _rx) = mpsc::channel::<i32>(1); in downgrade_upgrade_sender_success()
216 let weak_tx = tx.downgrade(); in downgrade_upgrade_sender_success()
[all …]
|
| D | sync_watch.rs | 14 let (tx, mut rx) = watch::channel("one"); in single_rx_recv()
27 tx.send("two").unwrap(); in single_rx_recv()
39 drop(tx); in single_rx_recv()
49 let (tx, mut rx1) = watch::channel("one"); in multi_rx()
70 tx.send("two").unwrap(); in multi_rx()
84 tx.send("three").unwrap(); in multi_rx()
105 tx.send("four").unwrap(); in multi_rx()
118 let (tx, mut rx) = watch::channel("one"); in rx_observes_final_value()
119 drop(tx); in rx_observes_final_value()
129 let (tx, mut rx) = watch::channel("one"); in rx_observes_final_value()
[all …]
|
| /external/strace/tests/ |
| D | adjtimex.c | 46 TAIL_ALLOC_OBJECT_CONST_PTR(struct timex, tx); in main()
47 memset(tx, 0, sizeof(*tx)); in main()
49 state = adjtimex(tx); in main()
55 (intmax_t) tx->offset, in main()
56 (intmax_t) tx->freq, in main()
57 (intmax_t) tx->maxerror, in main()
58 (intmax_t) tx->esterror); in main()
59 if (tx->status) in main()
60 printflags(adjtimex_status, (unsigned int) tx->status, NULL); in main()
71 (intmax_t) tx->constant, in main()
[all …]
|
| /external/strace/tests-m32/ |
| D | adjtimex.c | 46 TAIL_ALLOC_OBJECT_CONST_PTR(struct timex, tx); in main()
47 memset(tx, 0, sizeof(*tx)); in main()
49 state = adjtimex(tx); in main()
55 (intmax_t) tx->offset, in main()
56 (intmax_t) tx->freq, in main()
57 (intmax_t) tx->maxerror, in main()
58 (intmax_t) tx->esterror); in main()
59 if (tx->status) in main()
60 printflags(adjtimex_status, (unsigned int) tx->status, NULL); in main()
71 (intmax_t) tx->constant, in main()
[all …]
|
| /external/strace/tests-mx32/ |
| D | adjtimex.c | 46 TAIL_ALLOC_OBJECT_CONST_PTR(struct timex, tx); in main()
47 memset(tx, 0, sizeof(*tx)); in main()
49 state = adjtimex(tx); in main()
55 (intmax_t) tx->offset, in main()
56 (intmax_t) tx->freq, in main()
57 (intmax_t) tx->maxerror, in main()
58 (intmax_t) tx->esterror); in main()
59 if (tx->status) in main()
60 printflags(adjtimex_status, (unsigned int) tx->status, NULL); in main()
71 (intmax_t) tx->constant, in main()
[all …]
|
| /external/rust/crates/crossbeam-channel/tests/ |
| D | mpsc.rs | 211 let (tx, rx) = channel::<i32>(); in smoke()
212 tx.send(1).unwrap(); in smoke()
218 let (tx, _rx) = channel::<Box<isize>>(); in drop_full()
219 tx.send(Box::new(1)).unwrap(); in drop_full()
224 let (tx, _rx) = channel::<Box<isize>>(); in drop_full_shared()
225 drop(tx.clone()); in drop_full_shared()
226 drop(tx.clone()); in drop_full_shared()
227 tx.send(Box::new(1)).unwrap(); in drop_full_shared()
232 let (tx, rx) = channel::<i32>(); in smoke_shared()
233 tx.send(1).unwrap(); in smoke_shared()
[all …]
|
| /external/libese/apps/boot/ |
| D | boot.c | 68 struct EseSgBuffer tx[2]; in ese_boot_session_open() local
112 tx[0].base = &chan; in ese_boot_session_open()
113 tx[0].len = 1; in ese_boot_session_open()
114 tx[1].base = (uint8_t *)&kSelectApplet[1]; in ese_boot_session_open()
115 tx[1].len = sizeof(kSelectApplet) - 1; in ese_boot_session_open()
118 rx_len = ese_transceive_sg(ese, tx, 2, &rx, 1); in ese_boot_session_open()
172 struct EseSgBuffer tx[4]; in ese_boot_lock_xget() local
185 tx[0].base = &chan; in ese_boot_lock_xget()
186 tx[0].len = 1; in ese_boot_lock_xget()
187 tx[1].base = (uint8_t *)&kGetLockState[1]; in ese_boot_lock_xget()
[all …]
|
| /external/linux-kselftest/tools/testing/selftests/timers/ |
| D | leap-a-day.c | 97 struct timex tx; in clear_time_state() local
106 tx.modes = ADJ_STATUS; in clear_time_state()
107 tx.status = STA_PLL; in clear_time_state()
108 ret = adjtimex(&tx); in clear_time_state()
111 tx.modes = ADJ_MAXERROR; in clear_time_state()
112 tx.maxerror = 0; in clear_time_state()
113 ret = adjtimex(&tx); in clear_time_state()
116 tx.modes = ADJ_STATUS; in clear_time_state()
117 tx.status = 0; in clear_time_state()
118 ret = adjtimex(&tx); in clear_time_state()
[all …]
|
| D | valid-adjtimex.c | 44 static int clock_adjtime(clockid_t id, struct timex *tx) in clock_adjtime() argument
46 return syscall(__NR_clock_adjtime, id, tx); in clock_adjtime()
53 struct timex tx; in clear_time_state() local
56 tx.modes = ADJ_STATUS; in clear_time_state()
57 tx.status = 0; in clear_time_state()
58 ret = adjtimex(&tx); in clear_time_state()
117 struct timex tx; in validate_freq() local
123 memset(&tx, 0, sizeof(struct timex)); in validate_freq()
129 tx.modes = ADJ_FREQUENCY; in validate_freq()
130 tx.freq = valid_freq[i]; in validate_freq()
[all …]
|
| /external/strace/ |
| D | print_timex.c | 47 struct_timex tx; in MPERS_PRINTER_DECL() local
49 if (umove_or_printaddr(tcp, addr, &tx)) in MPERS_PRINTER_DECL()
53 printflags(adjtimex_modes, tx.modes, "ADJ_???"); in MPERS_PRINTER_DECL()
55 (intmax_t) tx.offset, (intmax_t) tx.freq, in MPERS_PRINTER_DECL()
56 (uintmax_t) tx.maxerror, (uintmax_t) tx.esterror); in MPERS_PRINTER_DECL()
57 printflags(adjtimex_status, tx.status, "STA_???"); in MPERS_PRINTER_DECL()
59 (intmax_t) tx.constant, (uintmax_t) tx.precision, in MPERS_PRINTER_DECL()
60 (intmax_t) tx.tolerance); in MPERS_PRINTER_DECL()
61 MPERS_FUNC_NAME(print_struct_timeval)(&tx.time); in MPERS_PRINTER_DECL()
63 (intmax_t) tx.tick, (intmax_t) tx.ppsfreq, (intmax_t) tx.jitter); in MPERS_PRINTER_DECL()
[all …]
|
| /external/ltp/testcases/kernel/syscalls/clock_adjtime/ |
| D | clock_adjtime.h | 104 union tx{ union
107 } tx; member
114 return &t->tx.kern_old_timex; in tst_timex_get()
116 return &t->tx.kern_timex; in tst_timex_get()
133 #define TIMEX_SHOW(tx, mode, fmt) \ argument
147 tx.modes, \
148 tx.offset, \
149 tx.freq, \
150 tx.maxerror, \
151 tx.esterror, \
[all …]
|
| /external/rust/crates/rayon-core/src/spawn/ |
| D | test.rs | 12 let (tx, rx) = channel(); in spawn_then_join_in_worker()
14 spawn(move || tx.send(22).unwrap()); in spawn_then_join_in_worker()
22 let (tx, rx) = channel(); in spawn_then_join_outside_worker()
23 spawn(move || tx.send(22).unwrap()); in spawn_then_join_outside_worker()
30 let (tx, rx) = channel(); in panic_fwd()
32 let tx = Mutex::new(tx); in panic_fwd() localVariable
34 let tx = tx.lock().unwrap(); in panic_fwd() localVariable
37 tx.send(1).unwrap(); in panic_fwd()
39 tx.send(2).unwrap(); in panic_fwd()
42 tx.send(3).unwrap(); in panic_fwd()
[all …]
|
| /external/mesa3d/src/gallium/drivers/nouveau/nv50/ |
| D | nv50_transfer.c | 256 struct nv50_transfer *tx; in nv50_miptree_transfer_map() local
264 tx = CALLOC_STRUCT(nv50_transfer); in nv50_miptree_transfer_map()
265 if (!tx) in nv50_miptree_transfer_map()
268 pipe_resource_reference(&tx->base.resource, res); in nv50_miptree_transfer_map()
270 tx->base.level = level; in nv50_miptree_transfer_map()
271 tx->base.usage = usage; in nv50_miptree_transfer_map()
272 tx->base.box = *box; in nv50_miptree_transfer_map()
275 tx->nblocksx = box->width << mt->ms_x; in nv50_miptree_transfer_map()
276 tx->nblocksy = box->height << mt->ms_y; in nv50_miptree_transfer_map()
278 tx->nblocksx = util_format_get_nblocksx(res->format, box->width); in nv50_miptree_transfer_map()
[all …]
|
| /external/mesa3d/src/gallium/drivers/nouveau/ |
| D | nouveau_buffer.c | 142 struct nouveau_transfer *tx, bool permit_pb) in nouveau_transfer_staging() argument
144 const unsigned adj = tx->base.box.x & NOUVEAU_MIN_BUFFER_MAP_ALIGN_MASK; in nouveau_transfer_staging()
145 const unsigned size = align(tx->base.box.width, 4) + adj; in nouveau_transfer_staging()
151 tx->map = align_malloc(size, NOUVEAU_MIN_BUFFER_MAP_ALIGN); in nouveau_transfer_staging()
152 if (tx->map) in nouveau_transfer_staging()
153 tx->map += adj; in nouveau_transfer_staging()
155 tx->mm = in nouveau_transfer_staging()
156 nouveau_mm_allocate(nv->screen->mm_GART, size, &tx->bo, &tx->offset); in nouveau_transfer_staging()
157 if (tx->bo) { in nouveau_transfer_staging()
158 tx->offset += adj; in nouveau_transfer_staging()
[all …]
|
| /external/rust/crates/futures-channel/tests/ |
| D | oneshot.rs | 11 let (mut tx, rx) = oneshot::channel::<u32>(); in smoke_poll()
14 assert!(tx.poll_canceled(cx).is_pending()); in smoke_poll()
15 assert!(tx.poll_canceled(cx).is_pending()); in smoke_poll()
17 assert!(tx.poll_canceled(cx).is_ready()); in smoke_poll()
18 assert!(tx.poll_canceled(cx).is_ready()); in smoke_poll()
27 let (mut tx, rx) = oneshot::channel::<u32>(); in cancel_notifies()
30 block_on(tx.cancellation()); in cancel_notifies()
40 let (tx, rx) = mpsc::channel::<(Sender<_>, mpsc::Sender<_>)>(); in cancel_lots()
42 for (mut tx, tx2) in rx { in cancel_lots()
43 block_on(tx.cancellation()); in cancel_lots()
[all …]
|
| D | mpsc.rs | 19 let (mut tx, rx) = mpsc::channel::<i32>(16); in send_recv()
21 block_on(tx.send(1)).unwrap(); in send_recv()
22 drop(tx); in send_recv()
31 let (tx, rx) = mpsc::channel::<i32>(0); in send_recv_no_buffer()
32 pin_mut!(tx, rx); in send_recv_no_buffer()
34 assert!(tx.as_mut().poll_flush(cx).is_ready()); in send_recv_no_buffer()
35 assert!(tx.as_mut().poll_ready(cx).is_ready()); in send_recv_no_buffer()
38 assert!(tx.as_mut().start_send(1).is_ok()); in send_recv_no_buffer()
39 assert!(tx.as_mut().poll_ready(cx).is_pending()); in send_recv_no_buffer()
43 assert!(tx.as_mut().start_send(0).unwrap_err().is_full()); in send_recv_no_buffer()
[all …]
|
| /external/rust/crates/futures-channel/benches/ |
| D | sync_mpsc.rs | 23 let (tx, mut rx) = mpsc::unbounded(); in unbounded_1_tx()
31 UnboundedSender::unbounded_send(&tx, i).unwrap(); in unbounded_1_tx()
44 let (tx, mut rx) = mpsc::unbounded(); in unbounded_100_tx()
46 let tx: Vec<_> = (0..100).map(|_| tx.clone()).collect(); in unbounded_100_tx() localVariable
50 for (i, x) in tx.iter().enumerate() { in unbounded_100_tx()
65 let (tx, mut rx) = mpsc::unbounded(); in unbounded_uncontended()
68 UnboundedSender::unbounded_send(&tx, i).expect("send"); in unbounded_uncontended()
77 tx: Sender<u32>, field
87 let mut tx = Pin::new(&mut this.tx); in poll_next() localVariable
89 ready!(tx.as_mut().poll_ready(cx)).unwrap(); in poll_next()
[all …]
|
| /external/libese/apps/weaver/ |
| D | weaver.c | 76 struct EseSgBuffer tx[2]; in ese_weaver_session_open() local
120 tx[0].base = &chan; in ese_weaver_session_open()
121 tx[0].len = 1; in ese_weaver_session_open()
122 tx[1].base = (uint8_t *)&kSelectApplet[1]; in ese_weaver_session_open()
123 tx[1].len = sizeof(kSelectApplet) - 1; in ese_weaver_session_open()
126 rx_len = ese_transceive_sg(ese, tx, 2, &rx, 1); in ese_weaver_session_open()
234 struct EseSgBuffer tx[5]; in ese_weaver_write() local
236 tx[0].base = &chan; in ese_weaver_write()
237 tx[0].len = 1; in ese_weaver_write()
238 tx[1].base = (uint8_t *)&kWrite[1]; in ese_weaver_write()
[all …]
|
| /external/mesa3d/src/gallium/drivers/nouveau/nvc0/ |
| D | nvc0_transfer.c | 383 struct nvc0_transfer *tx; in nvc0_miptree_transfer_map() local
401 tx = CALLOC_STRUCT(nvc0_transfer); in nvc0_miptree_transfer_map()
402 if (!tx) in nvc0_miptree_transfer_map()
405 pipe_resource_reference(&tx->base.resource, res); in nvc0_miptree_transfer_map()
407 tx->base.level = level; in nvc0_miptree_transfer_map()
408 tx->base.usage = usage; in nvc0_miptree_transfer_map()
409 tx->base.box = *box; in nvc0_miptree_transfer_map()
412 tx->nblocksx = box->width << mt->ms_x; in nvc0_miptree_transfer_map()
413 tx->nblocksy = box->height << mt->ms_y; in nvc0_miptree_transfer_map()
415 tx->nblocksx = util_format_get_nblocksx(res->format, box->width); in nvc0_miptree_transfer_map()
[all …]
|
| /external/mesa3d/src/gallium/drivers/nouveau/nv30/ |
| D | nv30_miptree.c | 283 struct nv30_transfer *tx; in nv30_miptree_transfer_map() local
287 tx = CALLOC_STRUCT(nv30_transfer); in nv30_miptree_transfer_map()
288 if (!tx) in nv30_miptree_transfer_map()
290 pipe_resource_reference(&tx->base.resource, pt); in nv30_miptree_transfer_map()
291 tx->base.level = level; in nv30_miptree_transfer_map()
292 tx->base.usage = usage; in nv30_miptree_transfer_map()
293 tx->base.box = *box; in nv30_miptree_transfer_map()
294 tx->base.stride = align(util_format_get_nblocksx(pt->format, box->width) * in nv30_miptree_transfer_map()
296 tx->base.layer_stride = util_format_get_nblocksy(pt->format, box->height) * in nv30_miptree_transfer_map()
297 tx->base.stride; in nv30_miptree_transfer_map()
[all …]
|
| /external/rust/crates/tokio/src/sync/tests/ |
| D | loom_oneshot.rs | 11 let (tx, rx) = oneshot::channel(); in smoke()
14 tx.send(1).unwrap(); in smoke()
25 let (tx, mut rx) = oneshot::channel(); in changing_rx_task()
28 tx.send(1).unwrap(); in changing_rx_task()
62 let (tx, mut rx) = oneshot::channel(); in try_recv_close()
64 let _ = tx.send(()); in try_recv_close()
76 let (tx, mut rx) = oneshot::channel(); in recv_closed()
79 let _ = tx.send(1); in recv_closed()
94 tx: &'a mut oneshot::Sender<i32>, field
98 fn new(tx: &'a mut oneshot::Sender<i32>) -> Self { in new()
[all …]
|