| /external/rust/android-crates-io/crates/tokio/tests/ |
| D | sync_watch.rs | 16 let (tx, mut rx) = watch::channel("one"); in single_rx_recv()
20 let mut t = spawn(rx.changed()); in single_rx_recv()
23 assert_eq!(*rx.borrow(), "one"); in single_rx_recv()
26 let mut t = spawn(rx.changed()); in single_rx_recv()
35 assert_eq!(*rx.borrow(), "two"); in single_rx_recv()
38 let mut t = spawn(rx.changed()); in single_rx_recv()
46 assert_eq!(*rx.borrow(), "two"); in single_rx_recv()
51 let (_tx, mut rx) = watch::channel("one"); in rx_version_underflow()
54 rx.mark_changed(); in rx_version_underflow()
55 rx.mark_changed(); in rx_version_underflow()
[all …]
|
| D | sync_oneshot.rs | 41 let (tx, rx) = oneshot::channel(); in send_recv()
42 let mut rx = task::spawn(rx); in send_recv() localVariable
44 assert_pending!(rx.poll()); in send_recv()
48 assert!(rx.is_woken()); in send_recv()
50 let val = assert_ready_ok!(rx.poll()); in send_recv()
56 let (tx, rx) = oneshot::channel(); in async_send_recv()
59 assert_eq!(1, assert_ok!(rx.await)); in async_send_recv()
64 let (tx, rx) = oneshot::channel::<i32>(); in close_tx()
65 let mut rx = task::spawn(rx); in close_tx() localVariable
67 assert_pending!(rx.poll()); in close_tx()
[all …]
|
| D | sync_mpsc.rs | 51 let (tx, mut rx) = mpsc::channel::<i32>(16); in send_recv_with_buffer()
63 let val = rx.recv().await; in send_recv_with_buffer()
66 let val = rx.recv().await; in send_recv_with_buffer()
69 let val = rx.recv().await; in send_recv_with_buffer()
76 let (tx, mut rx) = mpsc::channel::<i32>(2); in reserve_disarm()
98 rx.recv().await.unwrap(); in reserve_disarm()
116 let (tx, rx) = support::mpsc_stream::channel_stream::<i32>(16); in send_recv_stream_with_buffer()
117 let mut rx = Box::pin(rx); in send_recv_stream_with_buffer() localVariable
124 assert_eq!(Some(1), rx.next().await); in send_recv_stream_with_buffer()
125 assert_eq!(Some(2), rx.next().await); in send_recv_stream_with_buffer()
[all …]
|
| D | sync_broadcast.rs | 62 let (tx, mut rx) = broadcast::channel(16); in send_try_recv_bounded()
64 assert_empty!(rx); in send_try_recv_bounded()
69 let val = assert_recv!(rx); in send_try_recv_bounded()
72 assert_empty!(rx); in send_try_recv_bounded()
98 let (tx, mut rx) = broadcast::channel(16); in send_recv_bounded()
100 let mut recv = task::spawn(rx.recv()); in send_recv_bounded()
152 let (tx, mut rx) = broadcast::channel(1); in change_tasks()
154 let mut recv = Box::pin(rx.recv()); in change_tasks()
270 let mut rx = tx.subscribe(); in send_no_rx() localVariable
274 let val = assert_recv!(rx); in send_no_rx()
[all …]
|
| /external/tcpdump/tests/ |
| D | rx.out | 1 …1 1999-11-11 21:46:16.463334 IP 131.151.32.21.7001 > 131.151.1.59.7000: rx data fs call fetch-st…
2 …2 1999-11-11 21:46:16.483206 IP 131.151.1.59.7000 > 131.151.32.21.7001: rx data fs reply fetch-s…
3 …3 1999-11-11 21:46:16.889677 IP 131.151.32.21.7001 > 131.151.1.59.7000: rx ack first 2 serial 34…
4 …4 1999-11-11 21:46:24.151512 IP 131.151.32.21.7001 > 131.151.1.59.7000: rx data fs call makedir …
5 …5 1999-11-11 21:46:24.245048 IP 131.151.1.59.7000 > 131.151.32.91.7001: rx data cb call callback…
6 6 1999-11-11 21:46:24.255513 IP 131.151.32.91.7001 > 131.151.1.59.7000: rx data (28)
7 7 1999-11-11 21:46:24.255528 IP 131.151.32.91.7001 > 131.151.1.59.7000: rx data (28)
8 …8 1999-11-11 21:46:24.282365 IP 131.151.1.59.7000 > 131.151.32.21.7001: rx data fs reply makedir…
9 …9 1999-11-11 21:46:24.283047 IP 131.151.32.21.7001 > 131.151.1.59.7000: rx data fs call fetch-st…
10 …10 1999-11-11 21:46:24.284042 IP 131.151.1.59.7000 > 131.151.32.21.7001: rx data fs reply fetch-…
[all …]
|
| /external/jspecify/docs/static/img/ |
| D | jspecify-banner-spots.svg | 3 <rect y="811" width="353" height="132" rx="21" fill="#9B0000" fill-opacity="0.25"/>
4 <rect x="4109" y="2224" width="268" height="42" rx="21" fill="#FFCBCB" fill-opacity="0.25"/>
5 <rect x="7294" y="3497" width="481" height="154" rx="21" fill="#6CD0A0" fill-opacity="0.25"/>
6 <rect x="9954" y="4359" width="334" height="125" rx="21" fill="#FF000F" fill-opacity="0.25"/>
7 <rect x="15733" y="6297" width="1086" height="125" rx="21" fill="#00B35D" fill-opacity="0.25"/>
8 <rect x="187" y="1080" width="166" height="253" rx="21" fill="#139A41" fill-opacity="0.25"/>
9 <rect x="2037" y="2646" width="613" height="158" rx="21" fill="#9900BF" fill-opacity="0.25"/>
10 <rect x="9453" y="1318" width="395" height="90" rx="21" fill="#00B2FF" fill-opacity="0.25"/>
11 <rect x="7202" y="3295" width="184" height="80" rx="21" fill="#FA00FF" fill-opacity="0.25"/>
12 <rect x="1043" y="5171" width="540" height="187" rx="21" fill="#F5BCFE" fill-opacity="0.25"/>
[all …]
|
| D | jspecify-landing-bugs.svg | 2 <ellipse cx="378.5" cy="335.53" rx="378.5" ry="335.53" fill="#E1E6ED" fill-opacity="0.85"/>
4 <ellipse cx="327.127" cy="377.672" rx="252.458" ry="247.319" transform="rotate(4.66953 327.127 377.…
5 <ellipse cx="321.836" cy="371.439" rx="246.677" ry="241.538" transform="rotate(4.66953 321.836 371.…
9 <ellipse cx="378.5" cy="335.53" rx="378.5" ry="335.53" fill="white"/>
12 <rect x="136" y="88" width="329" height="43" rx="21.5" fill="#370997" fill-opacity="0.1"/>
13 <rect x="301" y="179" width="402" height="43" rx="21.5" fill="#370997" fill-opacity="0.1"/>
14 <rect x="26.2839" y="293.475" width="268.79" height="42.9698" rx="21.4849" fill="#099720" fill-opac…
15 <rect x="599.749" y="338.273" width="313.588" height="42.9698" rx="21.4849" fill="#970909" fill-opa…
16 <rect x="433" y="483" width="222" height="43" rx="21.5" fill="#0BACF1" fill-opacity="0.1"/>
18 <rect x="184.501" y="292.589" width="23.8129" height="5.37711" rx="2.68855" transform="rotate(15.94…
[all …]
|
| /external/rust/android-crates-io/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 | 20 let (mut tx, rx) = mpsc::channel::<i32>(16); in send_recv()
24 let v: Vec<_> = block_on(rx.collect()); in send_recv()
32 let (tx, rx) = mpsc::channel::<i32>(0); in send_recv_no_buffer()
33 pin_mut!(tx, rx); in send_recv_no_buffer()
48 assert_eq!(rx.as_mut().poll_next(cx), Poll::Ready(Some(1))); in send_recv_no_buffer()
57 assert_eq!(rx.as_mut().poll_next(cx), Poll::Ready(Some(2))); in send_recv_no_buffer()
66 let (mut tx1, rx) = mpsc::channel::<i32>(16); in send_shared_recv()
67 let mut rx = block_on_stream(rx); in send_shared_recv() localVariable
71 assert_eq!(rx.next(), Some(1)); in send_shared_recv()
74 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 …]
|
| /external/rust/android-crates-io/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 …]
|
| /external/rust/android-crates-io/crates/crossbeam-channel/tests/ |
| D | mpsc.rs | 177 $($name:pat = $rx:ident.$meth:ident() => $code:expr),+
183 $meth(($rx).inner) -> res => {
209 let (tx, rx) = channel::<i32>(); in smoke()
211 assert_eq!(rx.recv().unwrap(), 1); in smoke()
230 let (tx, rx) = channel::<i32>(); in smoke_shared()
232 assert_eq!(rx.recv().unwrap(), 1); in smoke_shared()
235 assert_eq!(rx.recv().unwrap(), 1); in smoke_shared()
240 let (tx, rx) = channel::<i32>(); in smoke_threads()
244 assert_eq!(rx.recv().unwrap(), 1); in smoke_threads()
250 let (tx, rx) = channel::<i32>(); in smoke_port_gone()
[all …]
|
| /external/swiftshader/third_party/llvm-16.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/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/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/swiftshader/third_party/llvm-16.0/llvm/lib/Target/CSKY/ |
| D | CSKYInstrFormats16Instr.td | 28 (outs mGPR:$rz), (ins mGPR:$rx, mGPR:$ry), !strconcat(opstr, "\t$rz, $rx, $ry"),
29 [(set mGPR:$rz, (opnode mGPR:$rx, mGPR:$ry)) ]> {
31 bits<3> rx;
34 let Inst{10 - 8} = rx;
41 AddrModeNone, (outs sGPR:$rz), (ins sGPR:$rZ, sGPR:$rx), !strconcat(opstr, "\t$rz, $rx"),
42 [(set sGPR:$rz, (opnode sGPR:$rZ, sGPR:$rx))]> {
44 bits<4> rx;
48 let Inst{5 - 2} = rx;
54 AddrModeNone, (outs sGPR:$rz), (ins sGPR:$rZ, sGPR:$rx), !strconcat(opstr, "\t$rz, $rx"),
57 bits<4> rx;
[all …]
|
| D | CSKYInstrFormats.td | 81 (outs GPR:$rz), (ins GPR:$rx,ImmType:$imm16),
82 !strconcat(op, "\t$rz, $rx, $imm16"), pattern> {
84 bits<5> rx;
87 let Inst{20 - 16} = rx;
132 : CSKY32Inst<AddrModeNone, 0x3a, (outs), (ins GPR:$rx),
133 !strconcat(op, "\t$rx"), pattern> {
134 bits<5> rx;
137 let Inst{20 - 16} = rx;
145 (ins GPR:$rx, operand:$imm2),
146 !strconcat(op, "\t$rx, $imm2"), pattern> {
[all …]
|
| /external/fonttools/Lib/fontTools/svgLib/path/ |
| D | shapes.py | 65 def _arc(self, c, rx, ry, x, y, large_arc): argument
68 % (c, _ntos(rx), _ntos(ry), large_arc, _ntos(x), _ntos(y))
71 def A(self, rx, ry, x, y, large_arc=0): argument
72 self._arc("A", rx, ry, x, y, large_arc)
74 def a(self, rx, ry, x, y, large_arc=0): argument
75 self._arc("a", rx, ry, x, y, large_arc)
116 rx = float(rect.attrib.get("rx", 0))
119 rx = _prefer_non_zero(rx, ry)
120 ry = _prefer_non_zero(ry, rx)
124 self.M(x + rx, y)
[all …]
|
| /external/rust/android-crates-io/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/rust/android-crates-io/crates/tokio/src/sync/tests/ |
| 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 …]
|
| 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 …]
|
| /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/android-crates-io/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 …]
|
![[all …]](/android-16.0.0_r2/more/external/jspecify/docs/static/img/jspecify-banner-spots.svg?refs=rx){kind=link}
![[all …]](/android-16.0.0_r2/more/external/jspecify/docs/static/img/jspecify-landing-bugs.svg?refs=rx){kind=link}