| /external/rust/crates/tokio/tests/ |
| D | sync_oneshot.rs | 38 let (tx, rx) = oneshot::channel(); in send_recv()
39 let mut rx = task::spawn(rx); in send_recv() localVariable
41 assert_pending!(rx.poll()); in send_recv()
45 assert!(rx.is_woken()); in send_recv()
47 let val = assert_ready_ok!(rx.poll()); in send_recv()
53 let (tx, rx) = oneshot::channel(); in async_send_recv()
56 assert_eq!(1, assert_ok!(rx.await)); in async_send_recv()
61 let (tx, rx) = oneshot::channel::<i32>(); in close_tx()
62 let mut rx = task::spawn(rx); in close_tx() localVariable
64 assert_pending!(rx.poll()); in close_tx()
[all …]
|
| D | sync_mpsc.rs | 29 let (tx, mut rx) = mpsc::channel::<i32>(16); in send_recv_with_buffer()
41 let val = rx.recv().await; in send_recv_with_buffer()
44 let val = rx.recv().await; in send_recv_with_buffer()
47 let val = rx.recv().await; in send_recv_with_buffer()
54 let (tx, mut rx) = mpsc::channel::<i32>(2); in reserve_disarm()
76 rx.recv().await.unwrap(); in reserve_disarm()
94 let (tx, rx) = support::mpsc_stream::channel_stream::<i32>(16); in send_recv_stream_with_buffer()
95 let mut rx = Box::pin(rx); in send_recv_stream_with_buffer() localVariable
102 assert_eq!(Some(1), rx.next().await); in send_recv_stream_with_buffer()
103 assert_eq!(Some(2), rx.next().await); in send_recv_stream_with_buffer()
[all …]
|
| D | sync_watch.rs | 14 let (tx, mut rx) = watch::channel("one"); in single_rx_recv()
18 let mut t = spawn(rx.changed()); in single_rx_recv()
21 assert_eq!(*rx.borrow(), "one"); in single_rx_recv()
24 let mut t = spawn(rx.changed()); in single_rx_recv()
33 assert_eq!(*rx.borrow(), "two"); in single_rx_recv()
36 let mut t = spawn(rx.changed()); in single_rx_recv()
44 assert_eq!(*rx.borrow(), "two"); in single_rx_recv()
118 let (tx, mut rx) = watch::channel("one"); in rx_observes_final_value()
122 let mut t1 = spawn(rx.changed()); in rx_observes_final_value()
125 assert_eq!(*rx.borrow(), "one"); in rx_observes_final_value()
[all …]
|
| D | sync_broadcast.rs | 61 let (tx, mut rx) = broadcast::channel(16); in send_try_recv_bounded()
63 assert_empty!(rx); in send_try_recv_bounded()
68 let val = assert_recv!(rx); in send_try_recv_bounded()
71 assert_empty!(rx); in send_try_recv_bounded()
97 let (tx, mut rx) = broadcast::channel(16); in send_recv_bounded()
99 let mut recv = task::spawn(rx.recv()); in send_recv_bounded()
151 let (tx, mut rx) = broadcast::channel(1); in change_tasks()
153 let mut recv = Box::pin(rx.recv()); in change_tasks()
269 let mut rx = tx.subscribe(); in send_no_rx() localVariable
273 let val = assert_recv!(rx); in send_no_rx()
[all …]
|
| /external/tcpdump/tests/ |
| D | rx.out | 1 …1 21:46:16.463334 IP 131.151.32.21.7001 > 131.151.1.59.7000: rx data fs call fetch-status fid 53…
2 … 2 21:46:16.483206 IP 131.151.1.59.7000 > 131.151.32.21.7001: rx data fs reply fetch-status (148)
3 …3 21:46:16.889677 IP 131.151.32.21.7001 > 131.151.1.59.7000: rx ack first 2 serial 347 reason de…
4 …4 21:46:24.151512 IP 131.151.32.21.7001 > 131.151.1.59.7000: rx data fs call makedir fid 5368710…
5 …5 21:46:24.245048 IP 131.151.1.59.7000 > 131.151.32.91.7001: rx data cb call callback fid 536871…
6 6 21:46:24.255513 IP 131.151.32.91.7001 > 131.151.1.59.7000: rx data (28)
7 7 21:46:24.255528 IP 131.151.32.91.7001 > 131.151.1.59.7000: rx data (28)
8 …8 21:46:24.282365 IP 131.151.1.59.7000 > 131.151.32.21.7001: rx data fs reply makedir new fid 53…
9 …9 21:46:24.283047 IP 131.151.32.21.7001 > 131.151.1.59.7000: rx data fs call fetch-status fid 53…
10 …10 21:46:24.284042 IP 131.151.1.59.7000 > 131.151.32.21.7001: rx data fs reply fetch-status (148)
[all …]
|
| /external/rust/crates/futures-channel/tests/ |
| D | mpsc-size_hint.rs | 6 let (tx, mut rx) = mpsc::unbounded::<u32>(); in unbounded_size_hint()
7 assert_eq!((0, None), rx.size_hint()); in unbounded_size_hint()
9 assert_eq!((1, None), rx.size_hint()); in unbounded_size_hint()
10 rx.try_next().unwrap().unwrap(); in unbounded_size_hint()
11 assert_eq!((0, None), rx.size_hint()); in unbounded_size_hint()
14 assert_eq!((2, None), rx.size_hint()); in unbounded_size_hint()
16 assert_eq!((2, Some(2)), rx.size_hint()); in unbounded_size_hint()
17 rx.try_next().unwrap().unwrap(); in unbounded_size_hint()
18 assert_eq!((1, Some(1)), rx.size_hint()); in unbounded_size_hint()
19 rx.try_next().unwrap().unwrap(); in unbounded_size_hint()
[all …]
|
| D | mpsc.rs | 19 let (mut tx, rx) = mpsc::channel::<i32>(16); in send_recv()
23 let v: Vec<_> = block_on(rx.collect()); 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()
47 assert_eq!(rx.as_mut().poll_next(cx), Poll::Ready(Some(1))); in send_recv_no_buffer()
56 assert_eq!(rx.as_mut().poll_next(cx), Poll::Ready(Some(2))); in send_recv_no_buffer()
65 let (mut tx1, rx) = mpsc::channel::<i32>(16); in send_shared_recv()
66 let mut rx = block_on_stream(rx); in send_shared_recv() localVariable
70 assert_eq!(rx.next(), Some(1)); in send_shared_recv()
73 assert_eq!(rx.next(), Some(2)); in send_shared_recv()
[all …]
|
| D | oneshot.rs | 11 let (mut tx, rx) = oneshot::channel::<u32>(); in smoke_poll()
12 let mut rx = Some(rx); in smoke_poll() localVariable
16 drop(rx.take()); in smoke_poll()
27 let (mut tx, rx) = oneshot::channel::<u32>(); in cancel_notifies()
32 drop(rx); 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()
62 let (mut tx, rx) = oneshot::channel::<u32>(); in cancel_after_sender_drop_doesnt_notify()
66 drop(rx); in cancel_after_sender_drop_doesnt_notify()
71 let (mut tx, mut rx) = oneshot::channel::<u32>(); in close()
[all …]
|
| D | mpsc-close.rs | 27 let (mut tx1, mut rx) = mpsc::channel(1); in multiple_senders_disconnect()
41 assert_eq!(block_on(rx.next()), Some(5)); in multiple_senders_disconnect()
45 assert_eq!(block_on(rx.next()), None); in multiple_senders_disconnect()
49 let (mut tx1, mut rx) = mpsc::unbounded(); in multiple_senders_disconnect()
63 assert_eq!(block_on(rx.next()), Some(5)); in multiple_senders_disconnect()
67 assert_eq!(block_on(rx.next()), None); in multiple_senders_disconnect()
74 let (mut tx1, mut rx) = mpsc::channel(1); in multiple_senders_close_channel()
86 assert_eq!(block_on(rx.next()), None); in multiple_senders_close_channel()
90 let (tx1, mut rx) = mpsc::unbounded(); in multiple_senders_close_channel()
102 assert_eq!(block_on(rx.next()), None); in multiple_senders_close_channel()
[all …]
|
| /external/rust/crates/futures/tests/ |
| D | eventual.rs | 15 let (tx, rx) = mpsc::channel(); in join1()
17 assert_eq!(rx.recv(), Ok((1, 2))); in join1()
18 assert!(rx.recv().is_err()); in join1()
27 let (tx, rx) = mpsc::channel(); in join2()
29 assert!(rx.try_recv().is_err()); in join2()
31 assert!(rx.try_recv().is_err()); in join2()
33 assert_eq!(rx.recv(), Ok((1, 2))); in join2()
34 assert!(rx.recv().is_err()); in join2()
43 let (tx, rx) = mpsc::channel(); in join3()
45 assert!(rx.try_recv().is_err()); in join3()
[all …]
|
| D | future_shared.rs | 21 let (tx, rx) = oneshot::channel::<i32>(); in send_shared_oneshot_and_wait_on_multiple_threads()
22 let f = rx.shared(); in send_shared_oneshot_and_wait_on_multiple_threads()
57 let (tx, rx) = oneshot::channel::<u32>(); in drop_on_one_task_ok()
58 let f1 = rx.shared(); in drop_on_one_task_ok()
132 let (tx, rx) = oneshot::channel::<i32>(); in downgrade()
133 let shared = rx.shared(); in downgrade()
160 let (tx, rx) = oneshot::channel::<i32>(); in ptr_eq()
161 let shared = rx.shared(); in ptr_eq()
192 let (_tx, rx) = oneshot::channel::<i32>(); in ptr_eq()
193 let shared4 = rx.shared(); in ptr_eq()
[all …]
|
| /external/swiftshader/third_party/llvm-10.0/llvm/lib/CodeGen/ |
| D | ExecutionDomainFix.cpp | 70 void ExecutionDomainFix::setLiveReg(int rx, DomainValue *dv) { in setLiveReg() argument
71 assert(unsigned(rx) < NumRegs && "Invalid index"); in setLiveReg()
74 if (LiveRegs[rx] == dv) in setLiveReg()
76 if (LiveRegs[rx]) in setLiveReg()
77 release(LiveRegs[rx]); in setLiveReg()
78 LiveRegs[rx] = retain(dv); in setLiveReg()
81 void ExecutionDomainFix::kill(int rx) { in kill() argument
82 assert(unsigned(rx) < NumRegs && "Invalid index"); in kill()
84 if (!LiveRegs[rx]) in kill()
87 release(LiveRegs[rx]); in kill()
[all …]
|
| /external/rust/crates/crossbeam-channel/tests/ |
| D | mpsc.rs | 181 $($name:pat = $rx:ident.$meth:ident() => $code:expr),+
185 $meth(($rx).inner) -> res => {
211 let (tx, rx) = channel::<i32>(); in smoke()
213 assert_eq!(rx.recv().unwrap(), 1); in smoke()
232 let (tx, rx) = channel::<i32>(); in smoke_shared()
234 assert_eq!(rx.recv().unwrap(), 1); in smoke_shared()
237 assert_eq!(rx.recv().unwrap(), 1); in smoke_shared()
242 let (tx, rx) = channel::<i32>(); in smoke_threads()
246 assert_eq!(rx.recv().unwrap(), 1); in smoke_threads()
252 let (tx, rx) = channel::<i32>(); in smoke_port_gone()
[all …]
|
| /external/llvm/lib/CodeGen/ |
| D | ExecutionDepsFix.cpp | 194 void setLiveReg(int rx, DomainValue *DV);
195 void kill(int rx);
196 void force(int rx, unsigned domain);
272 void ExeDepsFix::setLiveReg(int rx, DomainValue *dv) { in setLiveReg() argument
273 assert(unsigned(rx) < NumRegs && "Invalid index"); in setLiveReg()
276 if (LiveRegs[rx].Value == dv) in setLiveReg()
278 if (LiveRegs[rx].Value) in setLiveReg()
279 release(LiveRegs[rx].Value); in setLiveReg()
280 LiveRegs[rx].Value = retain(dv); in setLiveReg()
284 void ExeDepsFix::kill(int rx) { in kill() argument
[all …]
|
| /external/fonttools/Lib/fontTools/svgLib/path/ |
| D | shapes.py | 65 def _arc(self, c, rx, ry, x, y, large_arc): argument
66 self._add('%s%s,%s 0 %d 1 %s,%s' % (c, _ntos(rx), _ntos(ry), large_arc,
69 def A(self, rx, ry, x, y, large_arc=0): argument
70 self._arc('A', rx, ry, x, y, large_arc)
72 def a(self, rx, ry, x, y, large_arc=0): argument
73 self._arc('a', rx, ry, x, y, large_arc)
114 rx = float(rect.attrib.get('rx', 0))
117 rx = _prefer_non_zero(rx, ry)
118 ry = _prefer_non_zero(ry, rx)
122 self.M(x + rx, y)
[all …]
|
| /external/rust/crates/tokio/src/sync/tests/ |
| D | loom_mpsc.rs | 12 let (tx, mut rx) = mpsc::channel(16); in closing_tx()
19 let v = block_on(rx.recv()); in closing_tx()
22 let v = block_on(rx.recv()); in closing_tx()
30 let (tx, mut rx) = mpsc::unbounded_channel(); in closing_unbounded_tx()
37 let v = block_on(rx.recv()); in closing_unbounded_tx()
40 let v = block_on(rx.recv()); in closing_unbounded_tx()
48 let (tx1, rx) = mpsc::channel::<()>(16); in closing_bounded_rx()
51 drop(rx); in closing_bounded_rx()
62 let (tx1, mut rx) = mpsc::channel::<()>(16); in closing_and_sending()
75 let v = block_on(rx.recv()); in closing_and_sending()
[all …]
|
| D | loom_oneshot.rs | 11 let (tx, rx) = oneshot::channel(); in smoke()
17 let value = block_on(rx).unwrap(); in smoke()
25 let (tx, mut rx) = oneshot::channel(); in changing_rx_task()
31 let rx = thread::spawn(move || { in changing_rx_task() localVariable
32 let ready = block_on(poll_fn(|cx| match Pin::new(&mut rx).poll(cx) { in changing_rx_task()
44 Some(rx) in changing_rx_task()
50 if let Some(rx) = rx { in changing_rx_task()
52 let value = block_on(rx).unwrap(); in changing_rx_task()
62 let (tx, mut rx) = oneshot::channel(); in try_recv_close()
67 rx.close(); in try_recv_close()
[all …]
|
| /external/rust/crates/tokio-stream/tests/ |
| D | stream_merge.rs | 29 let mut rx = task::spawn(rx1.merge(rx2)); in merge_async_streams() localVariable
31 assert_eq!(rx.size_hint(), (0, None)); in merge_async_streams()
33 assert_pending!(rx.poll_next()); in merge_async_streams()
37 assert!(rx.is_woken()); in merge_async_streams()
38 assert_eq!(Some(1), assert_ready!(rx.poll_next())); in merge_async_streams()
40 assert_pending!(rx.poll_next()); in merge_async_streams()
43 assert!(rx.is_woken()); in merge_async_streams()
44 assert_eq!(Some(2), assert_ready!(rx.poll_next())); in merge_async_streams()
45 assert_pending!(rx.poll_next()); in merge_async_streams()
48 assert!(rx.is_woken()); in merge_async_streams()
[all …]
|
| /external/libese/apps/boot/tests/ |
| D | ese_app_boot_tests.cpp | 63 ese_sg_from_buf(rx_sg, rx_nsg, 0, invocation.rx.size(), invocation.rx.data()); in EseTransceive()
64 uint32_t rx_total = invocation.rx.size(); in EseTransceive()
70 std::vector<uint8_t> rx; member
106 trans_.invocations[0].rx.resize(3); in TEST_F()
107 trans_.invocations[0].rx[0] = 0x01; // Channel in TEST_F()
108 trans_.invocations[0].rx[1] = 0x90; // Return code in TEST_F()
109 trans_.invocations[0].rx[2] = 0x00; in TEST_F()
115 trans_.invocations[1].rx.resize(2); in TEST_F()
116 trans_.invocations[1].rx[0] = 0x90; in TEST_F()
117 trans_.invocations[1].rx[1] = 0x00; in TEST_F()
[all …]
|
| /external/libese/apps/boot/ |
| D | boot.c | 69 struct EseSgBuffer rx; in ese_boot_session_open() local
116 rx.base = &rx_buf[0]; in ese_boot_session_open()
117 rx.len = sizeof(rx_buf); in ese_boot_session_open()
118 rx_len = ese_transceive_sg(ese, tx, 2, &rx, 1); in ese_boot_session_open()
173 struct EseSgBuffer rx[3]; in ese_boot_lock_xget() local
200 rx[0].base = &reply[0]; in ese_boot_lock_xget()
201 rx[0].len = sizeof(reply); in ese_boot_lock_xget()
203 rx[1].base = lockData; in ese_boot_lock_xget()
204 rx[1].len = maxSize; in ese_boot_lock_xget()
207 rx[2].base = &apdu_status[0]; in ese_boot_lock_xget()
[all …]
|
| /external/rust/crates/futures/tests_disabled/ |
| D | stream.rs | 38 let (tx, rx) = mpsc::channel(1); in list()
40 Box::new(rx.then(|r| r.unwrap())) in list()
44 let (tx, rx) = mpsc::channel(1); in err_list()
46 Box::new(rx.then(|r| r.unwrap())) in err_list()
173 let (tx, rx) = mpsc::channel(1); in buffered()
181 let mut rx = rx.buffered(2); in buffered() localVariable
182 sassert_empty(&mut rx); in buffered()
184 sassert_empty(&mut rx); in buffered()
186 let mut rx = block_on_stream(rx); in buffered() localVariable
187 assert_eq!(rx.next(), Some(Ok(5))); in buffered()
[all …]
|
| /external/libwebsockets/lib/roles/ws/ext/ |
| D | extension-permessage-deflate.c | 179 (void)inflateEnd(&priv->rx); in lws_extension_callback_pm_deflate()
192 pmdrx->eb_in.len, priv->rx.avail_in); in lws_extension_callback_pm_deflate()
220 pmdrx->eb_in.len, priv->rx.avail_in, wsi->ws->final); in lws_extension_callback_pm_deflate()
225 if (inflateInit2(&priv->rx, in lws_extension_callback_pm_deflate()
248 if (priv->rx.avail_in && pmdrx->eb_in.token && in lws_extension_callback_pm_deflate()
251 priv->rx.avail_in); in lws_extension_callback_pm_deflate()
255 if (!priv->rx.avail_in && pmdrx->eb_in.token && pmdrx->eb_in.len) { in lws_extension_callback_pm_deflate()
256 priv->rx.next_in = (unsigned char *)pmdrx->eb_in.token; in lws_extension_callback_pm_deflate()
257 priv->rx.avail_in = (uInt)pmdrx->eb_in.len; in lws_extension_callback_pm_deflate()
260 priv->rx.next_out = priv->buf_rx_inflated + LWS_PRE; in lws_extension_callback_pm_deflate()
[all …]
|
| /external/virglrenderer/src/gallium/auxiliary/util/ |
| D | u_texture.c | 49 float rx, ry, rz; in util_map_texcoords2d_onto_cubemap() local
69 rx = 1; in util_map_texcoords2d_onto_cubemap()
74 rx = -1; in util_map_texcoords2d_onto_cubemap()
79 rx = sc; in util_map_texcoords2d_onto_cubemap()
84 rx = sc; in util_map_texcoords2d_onto_cubemap()
89 rx = sc; in util_map_texcoords2d_onto_cubemap()
94 rx = -sc; in util_map_texcoords2d_onto_cubemap()
99 rx = ry = rz = 0; in util_map_texcoords2d_onto_cubemap()
103 out_str[0] = rx; /*s*/ in util_map_texcoords2d_onto_cubemap()
|
| /external/mesa3d/src/gallium/auxiliary/util/ |
| D | u_texture.c | 49 float rx, ry, rz; in util_map_texcoords2d_onto_cubemap() local
69 rx = 1; in util_map_texcoords2d_onto_cubemap()
74 rx = -1; in util_map_texcoords2d_onto_cubemap()
79 rx = sc; in util_map_texcoords2d_onto_cubemap()
84 rx = sc; in util_map_texcoords2d_onto_cubemap()
89 rx = sc; in util_map_texcoords2d_onto_cubemap()
94 rx = -sc; in util_map_texcoords2d_onto_cubemap()
99 rx = ry = rz = 0; in util_map_texcoords2d_onto_cubemap()
103 out_str[0] = rx; /*s*/ in util_map_texcoords2d_onto_cubemap()
|
| /external/rust/crates/tokio-stream/src/wrappers/ |
| D | watch.rs | 79 mut rx: Receiver<T>, in make_future()
81 let result = rx.changed().await; in make_future()
82 (result, rx) in make_future()
87 pub fn new(rx: Receiver<T>) -> Self { in new()
89 inner: ReusableBoxFuture::new(async move { (Ok(()), rx) }), in new()
94 pub fn from_changes(rx: Receiver<T>) -> Self { in from_changes()
96 inner: ReusableBoxFuture::new(make_future(rx)), in from_changes()
105 let (result, mut rx) = ready!(self.inner.poll(cx)); in poll_next()
108 let received = (*rx.borrow_and_update()).clone(); in poll_next()
109 self.inner.set(make_future(rx)); in poll_next()
[all …]
|