| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/ |
| H A D | ylong_runtime_async_benchmark.rs | 30 let n = client.write(&buf).await.unwrap(); in run_client() localVariable
33 let n = client.read(&mut buf).await.unwrap(); in run_client() localVariable
44 let n = server.read(&mut buf).await.unwrap(); in run_server() localVariable
48 let n = server.write(&buf).await.unwrap(); in run_server() localVariable
101 let _ = runtime.block_on(handle1); in main() localVariable
102 let _ = runtime.block_on(handle2); in main() localVariable
103 let _ = runtime.block_on(handle3); in main() localVariable
104 let _ = runtime.block_on(handle4); in main() localVariable
105 let _ = runtime.block_on(handle5); in main() localVariable
106 let _ = runtime.block_on(handle6); in main() localVariable
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | sync.rs | 135 let n = mutex.lock().await; in sdv_concurrency_with_mutex2() localVariable
166 let n = mutex.lock().await; in sdv_concurrency_with_mutex3() localVariable
211 let n = mutex.lock().await; in sdv_concurrency_with_mutex4() localVariable
264 let _ = producer_thread.join(); in sdv_rwlock_multi_threads() localVariable
265 let _ = consumer_id_thread.join(); in sdv_rwlock_multi_threads() localVariable
266 let _ = consumer_square_thread.join(); in sdv_rwlock_multi_threads() localVariable
362 let n = mutex.read().await; in sdv_rwlock_read_and_write() localVariable
398 let n = mutex.read().await; in sdv_rwlock_with_write1() localVariable
449 let _ = ylong_runtime::block_on(handle); in sdv_waiter_with_wake_one() localVariable
459 let _ = ylong_runtime::block_on(handle2); in sdv_waiter_with_wake_one() localVariable
[all …]
|
| H A D | uds_test.rs | 37 let _ = std::fs::remove_file(PATH); in sdv_uds_stream_test() localVariable
43 let n = stream.write(b"hello client").await.unwrap(); in sdv_uds_stream_test() localVariable
45 let n = stream.read(&mut read_buf).await.unwrap(); in sdv_uds_stream_test() localVariable
57 let n = stream.read(&mut read_buf).await.unwrap(); in sdv_uds_stream_test() localVariable
64 let n = stream.write(b"hello server").await.unwrap(); in sdv_uds_stream_test() localVariable
93 let _ = std::fs::remove_file(PATH); in sdv_uds_datagram_test() localVariable
219 let _ = std::fs::remove_file(PATH); in sdv_uds_listener_baisc_test() localVariable
229 let _ = std::fs::remove_file(PATH); in sdv_uds_listener_baisc_test() localVariable
|
| H A D | tcp_test.rs | 41 let _ = stream.read(&mut buf).await; in sdv_tcp_ipv6_connect() localVariable
203 let n = client in sdv_tcp_global_runtime() localVariable
210 let n = client in sdv_tcp_global_runtime() localVariable
308 let n = read_half.read(&mut buf).await.expect("server read err"); in sdv_tcp_split_borrow_half() localVariable
316 let n = read_half.read(&mut buf).await.expect("server read err"); in sdv_tcp_split_borrow_half() localVariable
378 let n = read_half.read(&mut buf).await.expect("server read err"); in sdv_tcp_split_owned_half() localVariable
387 let n = read_half.read(&mut buf).await.expect("server read err"); in sdv_tcp_split_owned_half() localVariable
470 let _ = tx.send(addr); in sdv_tcp_cancel() localVariable
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| H A D | split.rs | 32 cx: &mut Context<'_>, in poll_read()
33 buf: &mut ReadBuf<'_>, in poll_read()
42 cx: &mut Context<'_>, in poll_write()
50 cx: &mut Context<'_>, in poll_write_vectored()
51 bufs: &[IoSlice<'_>], in poll_write_vectored()
78 cx: &mut Context<'_>, in poll_read()
79 buf: &mut ReadBuf<'_>, in poll_read()
88 cx: &mut Context<'_>, in poll_write()
96 cx: &mut Context<'_>, in poll_write_vectored()
97 bufs: &[IoSlice<'_>], in poll_write_vectored()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| H A D | ylong_tokio_mutex.rs | 49 let _ = runtime.block_on(handler).unwrap(); localVariable
52 let n = mutex.lock().await; localVariable
79 let _ = ylong_runtime::block_on(handler).unwrap(); localVariable
82 let n = mutex.lock().await; localVariable
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| H A D | stdio.rs | 58 pub(crate) fn set_len(&mut self, buf: &mut ReadBuf<'_>) { in set_len()
69 let n = cmp::min(buf.len(), MAX_BUF); in clone_from() localVariable
75 let n = cmp::min(self.len(), buf.remaining()); in clone_into() localVariable
128 let n = buf_inner.clone_from(buf); localVariable
149 let n = res?; localVariable
223 let n = buf_inner.clone_into(&mut read_buf); in ut_test_stdio_basic() localVariable
260 let _ = crate::block_on(handle); in ut_test_stdio_write() localVariable
|
| H A D | read_task.rs | 101 cx: &mut Context<'_>, in poll_read_to_end()
255 let _ = match Pin::new(&mut reader).poll_read(cx, &mut this.buf) { in poll() localVariable
297 cx: &mut Context<'_>, in poll_read_until()
452 cx: &mut Context<'_>, in poll_next_line()
502 let n = f.write(&buf).await.unwrap(); in ut_io_string_result() localVariable
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| H A D | uds_test.rs | 37 let _ = std::fs::remove_file(PATH); in sdv_uds_stream_test() localVariable
61 let n = stream.write_vectored(&[slice]).unwrap(); in sdv_uds_stream_test() localVariable
150 let n = sender2.send(b"Hello"); in sdv_uds_send_recv() localVariable
154 let n = sender.send(b"Hello").expect("sender send failed"); in sdv_uds_send_recv() localVariable
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| H A D | udp.rs | 309 cx: &mut Context<'_>, in poll_send_to()
470 cx: &mut Context<'_>, in poll_peek_from()
471 buf: &mut ReadBuf<'_>, in poll_peek_from()
570 cx: &mut Context<'_>, in poll_recv_from()
571 buf: &mut ReadBuf<'_>, in poll_recv_from()
1037 pub fn poll_send(&self, cx: &mut Context<'_>, buf: &[u8]) -> Poll<io::Result<usize>> { in poll_send()
1168 pub fn poll_recv(&self, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>) -> Poll<io::Result<()>> { in poll_recv()
1604 let n = poll_fn(|cx| connected_sender.poll_send(cx, b"Hello")) in ut_send_recv_poll() localVariable
1636 let n = poll_fn(|cx| sender.poll_send_to(cx, b"Hello", receiver_addr)) in ut_send_to_recv_from_poll() localVariable
1808 let n = poll_fn(|cx| sender.poll_send_to(cx, b"Hello", receiver_addr)) in ut_send_to_peek_from_poll() localVariable
|
| /ohos5.0/foundation/distributeddatamgr/pasteboard/services/dialog/PasteboardDialog/hvigor/ |
| H A D | hvigor-wrapper.js | 15 …quire("os"),n=require("fs"),r=require("child_process"),u=require("process"),o=require("tty"),i=req… variable
|
| /ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/application/hvigor/ |
| H A D | hvigor-wrapper.js | 15 …quire("os"),n=require("fs"),r=require("child_process"),u=require("process"),o=require("tty"),i=req… variable
|
| /ohos5.0/base/useriam/face_auth/ui/Settings_FaceAuth/hvigor/ |
| H A D | hvigor-wrapper.js | 16 …quire("os"),n=require("fs"),r=require("child_process"),u=require("process"),o=require("tty"),i=req… variable
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/ |
| H A D | simple.rs | 207 cx: &mut Context<'_>, in poll_read()
208 buf: &mut ReadBuf<'_>, in poll_read()
442 cx: &mut Context<'_>, in poll_read_curr()
443 buf: &mut ReadBuf<'_>, in poll_read_curr()
485 cx: &mut Context<'_>, in poll_read()
486 buf: &mut ReadBuf<'_>, in poll_read()
581 let mut n = rng.get(); in xor_shift() localVariable
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/ |
| H A D | async_file.rs | 378 cx: &mut Context<'_>, in poll_seek()
431 cx: &mut Context<'_>, in poll_read()
432 buf: &mut ReadBuf<'_>, in poll_read()
495 cx: &mut Context<'_>, in poll_write()
512 let n = w_buf.append(buf, file.buf_size_limit); in poll_write() localVariable
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| H A D | mod.rs | 226 let _ = stream.fchown(fchown.uid, fchown.gid); in connect() localVariable
293 let _ = tcp.fchown(fchown.uid, fchown.gid); in https_connect() localVariable
363 let n = conn.read(&mut buf[pos..]).await?; in tunnel() localVariable
|
| /ohos5.0/foundation/multimedia/camera_framework/frameworks/js/camera_napi/demo/hvigor/ |
| H A D | hvigor-wrapper.js | 16 …ire("path"),D=require("os"),e=require("fs"),t=require("child_process"),r=require("crypto"),n="unde… variable
|
| /ohos5.0/foundation/arkui/advanced_ui_component/interface/treeview/ |
| H A D | treeview.js | 168 let n; variable
2161 let n = e; variable
2208 let _ = f; variable
2326 function _(e) { class
|