| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| D | mpsc_test.rs | 38 let _ = ylong_runtime::block_on(handle); in sdv_unbounded_send_recv_test() localVariable
57 let _ = ylong_runtime::block_on(handle); in sdv_unbounded_send_recv_drop_test() localVariable
93 let _ = ylong_runtime::block_on(handle); in sdv_unbounded_send_recv_timeout_test() localVariable
115 let _ = ylong_runtime::block_on(handle); in sdv_bounded_send_recv_test() localVariable
136 let _ = ylong_runtime::block_on(handle); in sdv_bounded_send_recv_drop_test() localVariable
178 let _ = ylong_runtime::block_on(handle); in sdv_bounded_send_timeout_recv_timeout_test() localVariable
238 let _ = tx.send(i); in sdv_mpsc_len() localVariable
242 let _ = rx.try_recv(); in sdv_mpsc_len() localVariable
246 let _ = rx.try_recv(); in sdv_mpsc_len() localVariable
252 let _ = tx.try_send(i); in sdv_mpsc_len() localVariable
[all …]
|
| D | signal.rs | 57 let _ = ylong_runtime::block_on(handle); in sdv_signal_recv_test() localVariable
81 let _ = ylong_runtime::block_on(handle); in sdv_signal_recv_multi_thread_test() localVariable
101 let _ = ylong_runtime::block_on(handle); in sdv_signal_poll_recv_test() localVariable
125 let _ = ylong_runtime::block_on(handle); in sdv_signal_poll_recv_multi_thread_test() localVariable
141 let _ = ylong_runtime::block_on(handle); in sdv_signal_alarm() localVariable
156 let _ = ylong_runtime::block_on(handle); in sdv_signal_child() localVariable
171 let _ = ylong_runtime::block_on(handle); in sdv_signal_hangup() localVariable
186 let _ = ylong_runtime::block_on(handle); in sdv_signal_interrupt() localVariable
201 let _ = ylong_runtime::block_on(handle); in sdv_signal_io() localVariable
216 let _ = ylong_runtime::block_on(handle); in sdv_signal_pipe() localVariable
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/ |
| D | ylong_runtime_async_benchmark.rs | 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
107 let _ = runtime.block_on(handle7); in main() localVariable
108 let _ = runtime.block_on(handle8); in main() localVariable
109 let _ = runtime.block_on(handle9); in main() localVariable
110 let _ = runtime.block_on(handle10); in main() localVariable
|
| D | ylong_tokio_tcp_perf.rs | 120 let _ = match socket.read(&mut buf).await { in main() localVariable
135 let _ = socket.write(b"hello client").await.unwrap(); in main() localVariable
164 let _ = match socket.read(&mut buf).await { in main() localVariable
179 let _ = socket.write(b"hello client").await.unwrap(); in main() localVariable
|
| /commonlibrary/rust/ylong_json/tests/ |
| D | sdv_adapter_test.rs | 40 let _ = CString::from_raw(target); localVariable
46 let _ = CString::from_raw(target); localVariable
56 let _ = CString::from_raw(target); localVariable
66 let _ = CString::from_raw(target); localVariable
79 let _ = CString::from_raw(target); localVariable
84 let _ = CString::from_raw(target); localVariable
97 let _ = CString::from_raw(target); localVariable
107 let _ = CString::from_raw(target); localVariable
117 let _ = CString::from_raw(target); localVariable
127 let _ = CString::from_raw(target); localVariable
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| D | async_read.rs | 43 cx: &mut Context<'_>, in poll_read()
44 buf: &mut ReadBuf<'_>, in poll_read()
52 cx: &mut Context<'_>, in poll_read()
53 buf: &mut ReadBuf<'_>, in poll_read()
63 cx: &mut Context<'_>, in poll_read()
64 buf: &mut ReadBuf<'_>, in poll_read()
78 cx: &mut Context<'_>, in poll_read()
79 buf: &mut ReadBuf<'_>, in poll_read()
212 _cx: &mut Context<'_>, in poll_read()
213 buf: &mut ReadBuf<'_>, in poll_read()
|
| D | async_seek.rs | 40 cx: &mut Context<'_>, in poll_seek()
51 cx: &mut Context<'_>, in poll_seek()
61 cx: &mut Context<'_>, in poll_seek()
71 cx: &mut Context<'_>, in poll_seek()
138 fn rewind(&mut self) -> SeekTask<'_, Self> in rewind()
169 fn stream_position(&mut self) -> SeekTask<'_, Self> in stream_position()
|
| D | async_write.rs | 42 cx: &mut Context<'_>, in poll_write()
52 cx: &mut Context<'_>, in poll_write_vectored()
53 bufs: &[IoSlice<'_>], in poll_write_vectored()
153 cx: &mut Context<'_>, in poll_write()
161 cx: &mut Context<'_>, in poll_write_vectored()
162 bufs: &[IoSlice<'_>], in poll_write_vectored()
274 fn flush(&mut self) -> FlushTask<'_, Self> in flush()
290 fn shutdown(&mut self) -> ShutdownTask<'_, Self> in shutdown()
|
| D | stdin.rs | 48 cx: &mut Context<'_>, in poll_read()
49 buf: &mut ReadBuf<'_>, in poll_read()
109 fn as_fd(&self) -> BorrowedFd<'_> { in as_fd()
126 fn as_handle(&self) -> BorrowedHandle<'_> { in as_handle()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/examples/ |
| D | async_certs_adapter.rs | 27 let _ = certs.version().unwrap(); in verify() localVariable
29 let _ = certs.issuer().unwrap(); in verify() localVariable
31 let _ = certs.cert_name().unwrap(); in verify() localVariable
36 let _ = certs.cmp_pem_cert(contents.as_bytes()).unwrap(); in verify() localVariable
57 let _ = ylong_runtime::block_on(handle); in main() localVariable
|
| D | async_http_multi.rs | 34 let _ = Downloader::console(response).download().await; in main() localVariable
38 let _ = ylong_runtime::block_on(handle); in main() localVariable
|
| D | async_http.rs | 26 let _ = ylong_runtime::block_on(handle); in main() localVariable
43 let _ = Downloader::console(response).download().await; in client_send() localVariable
|
| /commonlibrary/rust/ylong_json/benches/ |
| D | serialize_json_cmp.rs | 35 let _ = value.to_compact_string(); in null_serialize_perf_ylong_json() localVariable
45 let _ = value.to_compact_string(); in boolean_serialize_perf_ylong_json() localVariable
55 let _ = value.to_compact_string(); in number_serialize_perf_ylong_json() localVariable
65 let _ = value.to_compact_string(); in string_serialize_perf_ylong_json() localVariable
75 let _ = value.to_compact_string(); in array_serialize_perf_ylong_json() localVariable
85 let _ = value.to_compact_string(); in object_serialize_perf_ylong_json() localVariable
95 let _ = value.to_compact_string(); in exp1_serialize_perf_ylong_json() localVariable
105 let _ = value.to_compact_string(); in exp2_serialize_perf_ylong_json() localVariable
115 let _ = value.to_compact_string(); in exp3_serialize_perf_ylong_json() localVariable
125 let _ = value.to_compact_string(); in exp4_serialize_perf_ylong_json() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/ |
| D | socket.rs | 37 let _ = syscall!(close(socket)); in set_non_block() localVariable
42 let _ = syscall!(close(socket)); in set_non_block() localVariable
47 let _ = syscall!(close(socket)); in set_non_block() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/ |
| D | mod.rs | 357 let _ = global.write(&[1]); in signal_action() localVariable
403 let _ = SignalDriver::get_mut_ref(); in signal() localVariable
477 let _ = crate::block_on(handle); in ut_signal_alarm() localVariable
492 let _ = crate::block_on(handle); in ut_signal_child() localVariable
507 let _ = crate::block_on(handle); in ut_signal_hangup() localVariable
522 let _ = crate::block_on(handle); in ut_signal_interrupt() localVariable
537 let _ = crate::block_on(handle); in ut_signal_io() localVariable
552 let _ = crate::block_on(handle); in ut_signal_pipe() localVariable
567 let _ = crate::block_on(handle); in ut_signal_terminate() localVariable
582 let _ = crate::block_on(handle); in ut_signal_user_defined1() localVariable
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| D | ylong_tokio_signal.rs | 47 let _ = runtime.block_on(handler).unwrap(); localVariable
69 let _ = runtime.block_on(handler).unwrap(); localVariable
96 let _ = runtime.block_on(handler).unwrap(); localVariable
118 let _ = runtime.block_on(handler).unwrap(); localVariable
|
| D | ylong_tokio_runtime_init.rs | 32 let _ = tokio_runtime(); in tokio_init() localVariable
40 let _ = ylong_runtime::builder::RuntimeBuilder::new_multi_thread() in ylong_init() localVariable
|
| D | ylong_tokio_spawn_blocking.rs | 38 let _ = runtime.block_on(handler).unwrap(); localVariable
59 let _ = ylong_runtime::block_on(handler).unwrap(); localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| 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()
|
| /commonlibrary/rust/ylong_json/src/ |
| D | adapter.rs | 68 let _ = Box::from_raw(string); in ylong_json_free_string() localVariable
100 let _ = Box::from_raw(item as *mut JsonValue); in ylong_json_delete() localVariable
685 let _ = node.remove_self(); in ylong_json_delete_array_node() localVariable
1089 let _ = node.remove_self(); in ylong_json_delete_object_node() localVariable
1141 let _ = Box::from_raw(str); in ut_ylong_json_parse() localVariable
1155 let _ = Box::from_raw(str); in ut_ylong_json_parse() localVariable
1189 let _ = Box::from_raw(str); in ut_ylong_json_free_string() localVariable
1221 let _ = Box::from_raw(str); in ut_ylong_json_print_unformatted() localVariable
1248 let _ = Box::from_raw(str); in ut_ylong_json_delete() localVariable
1290 let _ = Box::from_raw(str); in ut_ylong_json_duplicate() localVariable
[all …]
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| D | manager.rs | 149 cx: &mut Context<'_>, in manage_pending_state()
230 cx: &mut Context<'_>, in input_stream_frame()
292 cx: &mut Context<'_>, in poll_recv_frame()
400 cx: &mut Context<'_>, in recv_go_away_frame()
442 cx: &mut Context<'_>, in recv_reset_frame()
462 cx: &mut Context<'_>, in recv_header_frame()
480 fn recv_data_frame(&mut self, cx: &mut Context<'_>, frame: Frame) -> Poll<Result<(), H2Error>> { in recv_data_frame()
534 cx: &mut Context<'_>, in manage_resp_error()
557 cx: &mut Context<'_>, in manage_stream_error()
602 cx: &mut Context<'_>, in manage_conn_error()
[all …]
|
| /commonlibrary/rust/ylong_json/src/value/array/ |
| D | linked_list.rs | 126 pub fn iter(&self) -> Iter<'_, JsonValue> { in iter()
139 pub fn iter_mut(&mut self) -> IterMut<'_, JsonValue> { in iter_mut()
292 fn get_cursor(&self, index: usize) -> Option<Cursor<'_, JsonValue>> { in get_cursor()
303 let _ = cursor.index()?; in get_cursor() localVariable
312 let _ = cursor.index()?; in get_cursor() localVariable
321 fn get_cursor_mut(&mut self, index: usize) -> Option<CursorMut<'_, JsonValue>> { in get_cursor_mut()
332 let _ = cursor.index()?; in get_cursor_mut() localVariable
341 let _ = cursor.index()?; in get_cursor_mut() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/ |
| D | mix.rs | 35 cx: &mut Context<'_>, in poll_read()
36 buf: &mut ReadBuf<'_>, in poll_read()
52 ctx: &mut Context<'_>, in poll_write()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/ |
| D | listener.rs | 124 fn as_fd(&self) -> BorrowedFd<'_> { in as_fd()
148 let _ = std::fs::remove_file(PATH); in ut_uds_listener_baisc_test() localVariable
159 let _ = std::fs::remove_file(PATH); in ut_uds_listener_baisc_test() localVariable
174 let _ = std::fs::remove_file(PATH); in ut_uds_listener_read_write_test() localVariable
209 let _ = std::fs::remove_file(PATH); in ut_uds_listener_read_write_test() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/pty_process/ |
| D | pty.rs | 167 fn as_fd(&self) -> BorrowedFd<'_> { in as_fd()
181 cx: &mut Context<'_>, in poll_read()
182 buf: &mut ReadBuf<'_>, in poll_read()
191 cx: &mut Context<'_>, in poll_write()
231 cx: &mut Context<'_>, in poll_read()
232 buf: &mut ReadBuf<'_>, in poll_read()
268 cx: &mut Context<'_>, in poll_write()
290 cx: &mut Context<'_>, in poll_read()
291 buf: &mut ReadBuf<'_>, in poll_read()
327 cx: &mut Context<'_>, in poll_write()
|