| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| D | spawn.rs | 33 let mut handles = Vec::with_capacity(num); in sdv_one_core_test() localVariable
50 let mut handles = Vec::with_capacity(num); in sdv_two_core_test() localVariable
67 let mut handles = Vec::with_capacity(num); in sdv_three_core_test() localVariable
84 let mut handles = Vec::with_capacity(num); in sdv_four_core_test() localVariable
101 let mut handles = Vec::with_capacity(num); in sdv_eight_core_test() localVariable
118 let mut handles = Vec::with_capacity(num); in sdv_max_core_test() localVariable
135 let mut handles = Vec::with_capacity(num); in sdv_multi_future_in_async() localVariable
153 let mut handles = Vec::with_capacity(num); in sdv_multi_async_in_async() localVariable
|
| D | spawn_blocking.rs | 27 let mut handles = Vec::with_capacity(num); in ffrt_spawn_blocking_test() localVariable
40 let mut handles = Vec::with_capacity(num); in ffrt_spawn_blocking_test() localVariable
68 let mut handles = Vec::with_capacity(num); in test_spawn() localVariable
80 let mut handles = Vec::with_capacity(num); in test_spawn() localVariable
93 let mut handles = Vec::with_capacity(num); in test_spawn() localVariable
|
| D | async_pool.rs | 130 let handles = vec![ in sdv_async_pool_001() localVariable
190 let handles = vec![ in sdv_async_pool_002() localVariable
250 let handles = vec![ in sdv_async_pool_003() localVariable
310 let handles = vec![ in sdv_async_pool_004() localVariable
370 let handles = vec![ in sdv_async_pool_005() localVariable
430 let handles = vec![ in sdv_async_pool_006() localVariable
490 let handles = vec![ in sdv_async_pool_007() localVariable
550 let handles = vec![ in sdv_async_pool_008() localVariable
|
| D | singleton_runtime.rs | 48 let mut handles = Vec::with_capacity(SPAWN_NUM); in sdv_concurrently_runtime_spawn_async_in_async_task() localVariable
76 let mut handles = Vec::with_capacity(SPAWN_NUM); in sdv_concurrently_spawn_async_in_async_task() localVariable
104 let mut handles = Vec::with_capacity(SPAWN_NUM); in sdv_concurrently_task_builder_spawn_async_in_async_task() localVariable
|
| D | signal.rs | 69 let mut handles = Vec::new(); in sdv_signal_recv_multi_thread_test() localVariable
113 let mut handles = Vec::new(); in sdv_signal_poll_recv_multi_thread_test() localVariable
|
| D | yield.rs | 68 let mut handles = vec![]; in sdv_yield_now_single_worker() localVariable
|
| D | timer_test.rs | 39 let mut handles = Vec::new(); in simulate() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/ |
| D | ylong_tokio_spawn.rs | 49 let mut handles = Vec::with_capacity(1000); in ylong_spawn() localVariable
66 let mut handles = Vec::with_capacity(1000); in tokio_spawn() localVariable
84 let mut handles = Vec::with_capacity(1000); in std_spawn() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/ |
| D | sdv_async_http_client_error.rs | 97 let mut handles = vec![]; in sdv_err_req_timeout() localVariable
174 let mut handles = vec![]; in sdv_err_redirect_wrong_location() localVariable
239 let mut handles = vec![]; in sdv_err_response_with_wrong_body_length() localVariable
|
| D | sdv_async_http_body_io.rs | 35 let mut handles = vec![]; in sdv_body_chunk_and_trailer() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/examples/ |
| D | ylong_runtime_signal.rs | 40 let mut handles = Vec::new(); in run_multi_thread_signal() localVariable
59 let mut handles = Vec::new(); in run_multi_thread_signal() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/examples/ |
| D | async_http_multi.rs | 22 let mut handles = Vec::new(); in main() localVariable
|
| D | async_certs_adapter.rs | 43 let mut handles = Vec::new(); in main() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| D | client.rs | 1252 let mut handles = vec![]; in ut_client_send_request() localVariable
1330 let mut handles = vec![]; in ut_client_redirect() localVariable
1378 let mut handles = vec![]; in ut_client_http_proxy() localVariable
1428 let mut handles = vec![]; in ut_client_send_trunk_body() localVariable
1471 let mut handles = vec![]; in ut_client_send_unknown_size() localVariable
1514 let mut handles = vec![]; in ut_client_recv_conn_close() localVariable
1559 let mut handles = vec![]; in ut_client_recv_http1_0_resp() localVariable
1605 let mut handles = vec![]; in ut_client_recv_invalid_http1_0_resp() localVariable
1650 let mut handles = vec![]; in ut_client_recv_when_server_shutdown() localVariable
1685 let mut handles = vec![]; in ut_client_recv_error_resp_status() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| D | mod.rs | 473 let mut handles = vec![]; in ut_ssl_tunnel_error() localVariable
592 let mut handles = vec![]; in ut_ssl_tunnel_connect() localVariable
636 let mut handles = vec![]; in ut_ssl_tunnel_resp_beyond_size() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/builder/ |
| D | mod.rs | 247 let mut handles = vec![]; in ut_thread_pool_builder_current_thread() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| D | afd.rs | 241 pub handles: [AfdPollHandleInfo; 1], field
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/ |
| D | mod.rs | 452 let mut handles = Vec::new(); in ut_signal_recv_and_poll_recv() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| D | dispatcher.rs | 215 pub(crate) handles: Vec<crate::runtime::JoinHandle<()>>, field
304 let mut handles = Vec::with_capacity(3); in new() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| D | wheel.rs | 257 let mut handles = self.levels[expiration.level].take_slot(expiration.slot); in process_expiration() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | async_pool.rs | 46 handles: RwLock<Vec<Parker>>, field
|