| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| D | signal.rs | 50 let handle = ylong_runtime::spawn(async move { in sdv_signal_recv_test() localVariable
94 let handle = ylong_runtime::spawn(async move { in sdv_signal_poll_recv_test() localVariable
136 let handle = ylong_runtime::spawn(async move { in sdv_signal_alarm() localVariable
151 let handle = ylong_runtime::spawn(async move { in sdv_signal_child() localVariable
166 let handle = ylong_runtime::spawn(async move { in sdv_signal_hangup() localVariable
181 let handle = ylong_runtime::spawn(async move { in sdv_signal_interrupt() localVariable
196 let handle = ylong_runtime::spawn(async move { in sdv_signal_io() localVariable
211 let handle = ylong_runtime::spawn(async move { in sdv_signal_pipe() localVariable
226 let handle = ylong_runtime::spawn(async move { in sdv_signal_terminate() localVariable
241 let handle = ylong_runtime::spawn(async move { in sdv_signal_user_defined1() localVariable
[all …]
|
| D | mpsc_test.rs | 30 let handle = ylong_runtime::spawn(async move { in sdv_unbounded_send_recv_test() localVariable
50 let handle = ylong_runtime::spawn(async move { in sdv_unbounded_send_recv_drop_test() localVariable
85 let handle = ylong_runtime::spawn(async move { in sdv_unbounded_send_recv_timeout_test() localVariable
105 let handle = ylong_runtime::spawn(async move { in sdv_bounded_send_recv_test() localVariable
127 let handle = ylong_runtime::spawn(async move { in sdv_bounded_send_recv_drop_test() localVariable
169 let handle = ylong_runtime::spawn(async move { in sdv_bounded_send_timeout_recv_timeout_test() localVariable
285 let handle = ylong_runtime::spawn(async move { in sdv_multi_send_recv_test() localVariable
305 let handle = ylong_runtime::spawn(async move { in sdv_multi_send_recv_test() localVariable
|
| D | process.rs | 29 let handle = ylong_runtime::spawn(async { in sdv_process_output_test() localVariable
48 let handle = ylong_runtime::spawn(async { in sdv_process_status_test() localVariable
66 let handle = ylong_runtime::spawn(async { in sdv_process_spawn_test() localVariable
92 let handle = ylong_runtime::spawn(async { in sdv_process_child_stdio_test() localVariable
140 let handle = ylong_runtime::spawn(async { in sdv_process_kill_test() localVariable
158 let handle = ylong_runtime::spawn(async { in sdv_process_try_wait_test() localVariable
181 let handle = ylong_runtime::spawn(async { in sdv_process_drop_test() localVariable
205 let handle = ylong_runtime::spawn(async { in sdv_process_stdio_test() localVariable
252 let handle = ylong_runtime::spawn(async { in sdv_process_child_stdio_convert_test() localVariable
276 let handle = ylong_runtime::spawn(async { in sdv_process_debug_test() localVariable
|
| D | select.rs | 36 let handle = ylong_runtime::spawn(async { in sdv_new_select_basic() localVariable
68 let handle = ylong_runtime::spawn(async { in sdv_new_select_channel() localVariable
105 let handle = ylong_runtime::spawn(async { in sdv_new_select_biased() localVariable
158 let handle = ylong_runtime::spawn(async { in sdv_new_select_match() localVariable
197 let handle = ylong_runtime::spawn(async { in sdv_new_select_precondition() localVariable
222 let handle = ylong_runtime::spawn(async { in sdv_new_select_panic() localVariable
|
| D | tcp_test.rs | 30 let handle = ylong_runtime::spawn(async move { in sdv_tcp_ipv6_connect() localVariable
34 let handle = ylong_runtime::spawn(async move { in sdv_tcp_ipv6_connect() localVariable
61 let handle = ylong_runtime::spawn(async { in sdv_tcp_listener_interface() localVariable
81 let handle = ylong_runtime::spawn(async move { in sdv_tcp_stream_try() localVariable
85 let handle = ylong_runtime::spawn(async move { in sdv_tcp_stream_try() localVariable
116 let handle = ylong_runtime::spawn(async move { in sdv_tcp_stream_basic() localVariable
120 let handle = ylong_runtime::spawn(async move { in sdv_tcp_stream_basic() localVariable
163 let handle = ylong_runtime::spawn(async { in sdv_tcp_stream_peek() localVariable
167 let handle = ylong_runtime::spawn(async move { in sdv_tcp_stream_peek() localVariable
191 let handle = ylong_runtime::spawn(async move { in sdv_tcp_global_runtime() localVariable
[all …]
|
| D | uds_test.rs | 71 let handle = ylong_runtime::spawn(client()); in sdv_uds_stream_test() localVariable
116 let handle = ylong_runtime::spawn(client()); in sdv_uds_datagram_test() localVariable
135 let handle = ylong_runtime::spawn(async { in sdv_uds_stream_try_test() localVariable
177 let handle = ylong_runtime::spawn(async { in sdv_uds_datagram_try_test() localVariable
221 let handle = ylong_runtime::spawn(async { in sdv_uds_listener_baisc_test() localVariable
244 let handle = ylong_runtime::spawn(async { in sdv_uds_stream_baisc_test() localVariable
266 let handle = ylong_runtime::spawn(async { in sdv_uds_datagram_baisc_test() localVariable
|
| D | udp_test.rs | 31 let handle = ylong_runtime::spawn(async { in sdv_udp_send_recv() localVariable
69 let handle = ylong_runtime::spawn(async { in sdv_udp_send_to_recv_from() localVariable
99 let handle = ylong_runtime::spawn(async move { in sdv_udp_recv() localVariable
113 let handle = thread::spawn(move || { in sdv_udp_recv() localVariable
114 let handle = ylong_runtime::spawn(async move { in sdv_udp_recv() localVariable
143 let handle = ylong_runtime::spawn(async move { in sdv_udp_try_recv_from() localVariable
180 let handle = ylong_runtime::spawn(async move { in sdv_udp_try_send() localVariable
202 let handle = ylong_runtime::spawn(async move { in sdv_udp_try_recv() localVariable
273 let handle = ylong_runtime::spawn(async move { in sdv_udp_send_recv_poll() localVariable
314 let handle = ylong_runtime::spawn(async move { in sdv_send_to_peek_from() localVariable
[all …]
|
| D | task_cancel.rs | 34 let handle = ylong_runtime::spawn(async move { in sdv_task_cancel_simple() localVariable
56 let handle = ylong_runtime::spawn(async move { in sdv_task_cancel_failed() localVariable
95 let handle = ylong_runtime::spawn(async move { in sdv_task_cancel_multiple() localVariable
|
| D | async_dir.rs | 27 let handle = ylong_runtime::spawn(async move { in sdv_async_dir() localVariable
62 let handle = ylong_runtime::spawn(async move { in sdv_async_dir_create_remove() localVariable
|
| D | async_fs.rs | 31 let handle = ylong_runtime::spawn(async move { in sdv_async_fs_write() localVariable
60 let handle = ylong_runtime::spawn(async move { in sdv_async_fs_read() localVariable
95 let handle = ylong_runtime::spawn(async move { in sdv_async_fs_rw() localVariable
100 let handle = ylong_runtime::spawn(async move { in sdv_async_fs_rw() localVariable
163 let handle = ylong_runtime::spawn(async move { in sdv_async_fs_read_to_end() localVariable
189 let handle = ylong_runtime::spawn(async move { in sdv_async_fs_seek() localVariable
252 let handle = ylong_runtime::spawn(async move { in sdv_async_fs_set_permission() localVariable
276 let handle = ylong_runtime::spawn(async move { in sdv_async_fs_sync_all() localVariable
|
| D | builder.rs | 47 let handle = runtime.spawn(test_future(1)); in sdv_set_builder_after_start() localVariable
75 let handle = runtime.spawn(test_future(1)); in sdv_set_builder_before_stop() localVariable
99 let handle = runtime.spawn(async { 1 }); in sdv_set_builder_after_start() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/ |
| D | sdv_async_http_client_error.rs | 76 let handle = ylong_runtime::spawn(async move { in sdv_err_start_connect_timeout() localVariable
121 let handle = handles.pop().unwrap(); in sdv_err_req_timeout() localVariable
136 let handle = ylong_runtime::spawn(async move { in sdv_err_req_timeout() localVariable
198 let handle = handles.pop().unwrap(); in sdv_err_redirect_wrong_location() localVariable
213 let handle = ylong_runtime::spawn(async move { in sdv_err_redirect_wrong_location() localVariable
262 let handle = handles.pop().unwrap(); in sdv_err_response_with_wrong_body_length() localVariable
277 let handle = ylong_runtime::spawn(async move { in sdv_err_response_with_wrong_body_length() localVariable
|
| D | sdv_async_https_pinning.rs | 72 let handle = handles_vec.pop().expect("No more handles !"); in sdv_client_public_key_pinning() localVariable
120 let handle = handles_vec.pop().expect("No more handles !"); in sdv_client_public_key_pinning() localVariable
169 let handle = handles_vec.pop().expect("No more handles !"); in sdv_client_public_key_pinning() localVariable
250 let handle = handles_vec.pop().expect("No more handles !"); in sdv_client_public_key_pinning_error() localVariable
|
| D | sdv_async_http2.rs | 155 let mut handle = start_http_server!(HTTP; server_fn); in sdv_async_h2_client_send_request() localVariable
165 let mut handle = rx.recv().expect("recv Handle failed !"); in sdv_async_h2_client_send_request() localVariable
235 let mut handle = start_http_server!(HTTP; server_fn); in sdv_async_h2_client_send_request_concurrently() localVariable
245 let mut handle = rx.recv().expect("recv Handle failed !"); in sdv_async_h2_client_send_request_concurrently() localVariable
252 let handle = rt.spawn(async move { in sdv_async_h2_client_send_request_concurrently() localVariable
|
| D | sdv_async_http_body_io.rs | 66 let handle = handles.pop().unwrap(); in sdv_body_chunk_and_trailer() localVariable
77 let handle = ylong_runtime::spawn(async move { in sdv_body_chunk_and_trailer() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| D | ylong_tokio_unbounded_mpsc.rs | 32 let handle = runtime.spawn(async move { localVariable
42 let handle = runtime.spawn(async move { localVariable
66 let handle = ylong_runtime::spawn(async move { localVariable
76 let handle = ylong_runtime::spawn(async move { localVariable
|
| D | ylong_tokio_bounded_mpsc.rs | 32 let handle = runtime.spawn(async move { localVariable
42 let handle = runtime.spawn(async move { localVariable
66 let handle = ylong_runtime::spawn(async move { localVariable
76 let handle = ylong_runtime::spawn(async move { localVariable
|
| D | ylong_tokio_task_creation.rs | 61 let handle = runtime.spawn(async move { localVariable
80 let handle = ylong_runtime::spawn(async move { localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/ |
| D | ylong_tokio_tcp_perf.rs | 36 let handle = runtime.spawn(async move { in ylong_create_client() localVariable
73 let handle = runtime.spawn(async move { in tokio_create_client() localVariable
113 let handle = runtime.spawn(async move { in main() localVariable
157 let handle = runtime.spawn(async move { in main() localVariable
|
| D | ylong_tokio_spawn.rs | 54 let handle = ylong_runtime::spawn(async_task()); in ylong_spawn() localVariable
72 let handle = runtime.spawn(async_task()); in tokio_spawn() localVariable
89 let handle = spawn(task); in std_spawn() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| D | client.rs | 1171 let handle = ylong_runtime::spawn(async move { in ut_client_request_redirect() localVariable
1186 let handle = ylong_runtime::spawn(async move { in ut_client_connect_http1_0() localVariable
1215 let handle = ylong_runtime::spawn(async move { in ut_client_request_http1_0_retry() localVariable
1237 let handle = ylong_runtime::spawn(async move { in ut_client_request_verify() localVariable
1262 let handle = handles.pop().expect("No more handles !"); in ut_client_send_request() localVariable
1279 let handle = ylong_runtime::spawn(async move { in ut_client_send_request() localVariable
1314 let handle = ylong_runtime::spawn(async move { in ut_client_connect_to() localVariable
1341 let handle = handles.pop().expect("No more handles !"); in ut_client_redirect() localVariable
1358 let handle = ylong_runtime::spawn(async move { in ut_client_redirect() localVariable
1388 let handle = handles.pop().expect("No more handles !"); in ut_client_http_proxy() localVariable
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/ |
| D | mod.rs | 472 let handle = crate::spawn(async move { in ut_signal_alarm() localVariable
487 let handle = crate::spawn(async move { in ut_signal_child() localVariable
502 let handle = crate::spawn(async move { in ut_signal_hangup() localVariable
517 let handle = crate::spawn(async move { in ut_signal_interrupt() localVariable
532 let handle = crate::spawn(async move { in ut_signal_io() localVariable
547 let handle = crate::spawn(async move { in ut_signal_pipe() localVariable
562 let handle = crate::spawn(async move { in ut_signal_terminate() localVariable
577 let handle = crate::spawn(async move { in ut_signal_user_defined1() localVariable
592 let handle = crate::spawn(async move { in ut_signal_user_defined2() localVariable
607 let handle = crate::spawn(async move { in ut_signal_window_change() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/common/ |
| D | mod.rs | 62 let handle = start_http_server!( localVariable
72 let handle = rx localVariable
88 let mut handle = start_http_server!( localVariable
103 let handle = rx localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/examples/ |
| D | ylong_runtime_create_thread_fail.rs | 25 let handle = thread::spawn(move || { in main() localVariable
32 let handle = ylong_runtime::spawn(async move { in main() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| D | mod.rs | 479 let handle = handles.pop().expect("No more handles !"); in ut_ssl_tunnel_error() localVariable
486 let handle = ylong_runtime::spawn(async move { in ut_ssl_tunnel_error() localVariable
517 let handle = handles.pop().expect("No more handles !"); in ut_ssl_tunnel_error() localVariable
523 let handle = ylong_runtime::spawn(async move { in ut_ssl_tunnel_error() localVariable
557 let handle = handles.pop().expect("No more handles !"); in ut_ssl_tunnel_error() localVariable
563 let handle = ylong_runtime::spawn(async move { in ut_ssl_tunnel_error() localVariable
604 let handle = handles.pop().expect("No more handles !"); in ut_ssl_tunnel_connect() localVariable
610 let handle = ylong_runtime::spawn(async move { in ut_ssl_tunnel_connect() localVariable
651 let handle = handles.pop().expect("No more handles !"); in ut_ssl_tunnel_resp_beyond_size() localVariable
657 let handle = ylong_runtime::spawn(async move { in ut_ssl_tunnel_resp_beyond_size() localVariable
|