/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
H A D | spawn.rs | 33 let mut handles = Vec::with_capacity(num); in sdv_one_core_test() localVariable 36 handles.push(ylong_runtime::spawn(test_future(i))); in sdv_one_core_test() 39 for (times, handle) in handles.into_iter().enumerate() { in sdv_one_core_test() 50 let mut handles = Vec::with_capacity(num); in sdv_two_core_test() localVariable 53 handles.push(ylong_runtime::spawn(test_future(i))); in sdv_two_core_test() 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 [all …]
|
H A D | spawn_blocking.rs | 27 let mut handles = Vec::with_capacity(num); in ffrt_spawn_blocking_test() localVariable 29 handles.push(ylong_runtime::spawn_blocking(move || { in ffrt_spawn_blocking_test() 35 for (times, handle) in handles.into_iter().enumerate() { in ffrt_spawn_blocking_test() 40 let mut handles = Vec::with_capacity(num); in ffrt_spawn_blocking_test() localVariable 43 handles.push(task_builder.spawn_blocking(move || { in ffrt_spawn_blocking_test() 49 for (times, handle) in handles.into_iter().enumerate() { in ffrt_spawn_blocking_test() 68 let mut handles = Vec::with_capacity(num); in test_spawn() localVariable 70 handles.push(runtime.spawn_blocking(move || { in test_spawn() 80 let mut handles = Vec::with_capacity(num); in test_spawn() localVariable 93 let mut handles = Vec::with_capacity(num); in test_spawn() localVariable [all …]
|
H A D | singleton_runtime.rs | 48 let mut handles = Vec::with_capacity(SPAWN_NUM); in sdv_concurrently_runtime_spawn_async_in_async_task() localVariable 50 handles.push(ylong_runtime::spawn(test_async_in_async(i, i + 1))); in sdv_concurrently_runtime_spawn_async_in_async_task() 52 for (times, handle) in handles.into_iter().enumerate() { in sdv_concurrently_runtime_spawn_async_in_async_task() 76 let mut handles = Vec::with_capacity(SPAWN_NUM); in sdv_concurrently_spawn_async_in_async_task() localVariable 78 handles.push(ylong_runtime::spawn(test_async_in_async(i, i + 1))); in sdv_concurrently_spawn_async_in_async_task() 80 for (times, handle) in handles.into_iter().enumerate() { in sdv_concurrently_spawn_async_in_async_task() 104 let mut handles = Vec::with_capacity(SPAWN_NUM); in sdv_concurrently_task_builder_spawn_async_in_async_task() localVariable 107 handles.push(task_builder.spawn(test_async_in_async(i, i + 1))); in sdv_concurrently_task_builder_spawn_async_in_async_task() 109 for (times, handle) in handles.into_iter().enumerate() { in sdv_concurrently_task_builder_spawn_async_in_async_task()
|
H A D | async_pool.rs | 130 let handles = vec![ in sdv_async_pool_001() localVariable 149 for (times, handle) in handles.into_iter().enumerate() { in sdv_async_pool_001() 190 let handles = vec![ in sdv_async_pool_002() localVariable 209 for (times, handle) in handles.into_iter().enumerate() { in sdv_async_pool_002() 250 let handles = vec![ in sdv_async_pool_003() localVariable 269 for (times, handle) in handles.into_iter().enumerate() { in sdv_async_pool_003() 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 [all …]
|
H A D | signal.rs | 69 let mut handles = Vec::new(); in sdv_signal_recv_multi_thread_test() localVariable 72 handles.push(ylong_runtime::spawn(async move { in sdv_signal_recv_multi_thread_test() 80 for handle in handles { in sdv_signal_recv_multi_thread_test() 113 let mut handles = Vec::new(); in sdv_signal_poll_recv_multi_thread_test() localVariable 116 handles.push(ylong_runtime::spawn(async move { in sdv_signal_poll_recv_multi_thread_test() 124 for handle in handles { in sdv_signal_poll_recv_multi_thread_test()
|
H A D | yield.rs | 68 let mut handles = vec![]; in sdv_yield_now_single_worker() localVariable 81 handles.push(handle); in sdv_yield_now_single_worker() 84 for handle in handles { in sdv_yield_now_single_worker()
|
H A D | timer_test.rs | 39 let mut handles = Vec::new(); in simulate() localVariable 42 handles.push(ylong_runtime::spawn(async move { in simulate() 47 for handle in handles { in simulate()
|
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/ |
H A D | ylong_tokio_spawn.rs | 49 let mut handles = Vec::with_capacity(1000); in ylong_spawn() localVariable 55 handles.push(handle); in ylong_spawn() 59 for handle in handles { in ylong_spawn() 66 let mut handles = Vec::with_capacity(1000); in tokio_spawn() localVariable 73 handles.push(handle); in tokio_spawn() 77 for handle in handles { in tokio_spawn() 84 let mut handles = Vec::with_capacity(1000); in std_spawn() localVariable 90 handles.push(handle); in std_spawn() 94 for handle in handles { in std_spawn()
|
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/ |
H A D | ylong_runtime_signal.rs | 40 let mut handles = Vec::new(); in run_multi_thread_signal() localVariable 43 handles.push(ylong_runtime::spawn(async move { in run_multi_thread_signal() 51 for handle in handles { in run_multi_thread_signal() 59 let mut handles = Vec::new(); in run_multi_thread_signal() localVariable 62 handles.push(ylong_runtime::spawn(async move { in run_multi_thread_signal() 71 for handle in handles { in run_multi_thread_signal()
|
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
H A D | client.rs | 1252 let mut handles = vec![]; in ut_client_send_request() localVariable 1254 Handles: handles, in ut_client_send_request() 1330 let mut handles = vec![]; in ut_client_redirect() localVariable 1332 Handles: handles, in ut_client_redirect() 1380 Handles: handles, in ut_client_http_proxy() 1430 Handles: handles, in ut_client_send_trunk_body() 1473 Handles: handles, in ut_client_send_unknown_size() 1516 Handles: handles, in ut_client_recv_conn_close() 1561 Handles: handles, in ut_client_recv_http1_0_resp() 1607 Handles: handles, in ut_client_recv_invalid_http1_0_resp() [all …]
|
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/tests/ |
H A D | sdv_async_http_client_error.rs | 97 let mut handles = vec![]; in sdv_err_req_timeout() localVariable 103 Handles: handles, in sdv_err_req_timeout() 121 let handle = handles.pop().unwrap(); in sdv_err_req_timeout() 174 let mut handles = vec![]; in sdv_err_redirect_wrong_location() localVariable 180 Handles: handles, in sdv_err_redirect_wrong_location() 198 let handle = handles.pop().unwrap(); in sdv_err_redirect_wrong_location() 239 let mut handles = vec![]; in sdv_err_response_with_wrong_body_length() localVariable 245 Handles: handles, in sdv_err_response_with_wrong_body_length() 262 let handle = handles.pop().unwrap(); in sdv_err_response_with_wrong_body_length()
|
H A D | sdv_async_http_body_io.rs | 35 let mut handles = vec![]; in sdv_body_chunk_and_trailer() localVariable 41 Handles: handles, in sdv_body_chunk_and_trailer() 66 let handle = handles.pop().unwrap(); in sdv_body_chunk_and_trailer()
|
/ohos5.0/foundation/graphic/graphic_3d/lume/LumeRender/src/nodecontext/ |
H A D | node_context_descriptor_set_manager.cpp | 208 vector<RenderHandle> handles; in CreateDescriptorSets() local 209 handles.reserve(descriptorSetsLayoutBindings.size()); in CreateDescriptorSets() 217 handles.push_back(CreateDescriptorSet(ref.binding)); in CreateDescriptorSets() 219 return handles; in CreateDescriptorSets() 246 vector<RenderHandle> handles; in CreateOneFrameDescriptorSets() local 247 handles.reserve(descriptorSetsLayoutBindings.size()); in CreateOneFrameDescriptorSets() 249 handles.push_back(CreateOneFrameDescriptorSet(ref.binding)); in CreateOneFrameDescriptorSets() 251 return handles; in CreateOneFrameDescriptorSets() 279 RenderHandle handles[PipelineLayoutConstants::MAX_DESCRIPTOR_SET_COUNT]; in CreatePipelineDescriptorSetBinder() local 294 pipelineLayout, handles, descriptorSetLayoutBindings) }; in CreatePipelineDescriptorSetBinder() [all …]
|
/ohos5.0/foundation/multimedia/media_library/frameworks/services/media_mtp/src/payload_data/ |
H A D | get_object_handles_data.cpp | 60 auto handles = GetObjectHandles(); in Maker() local 61 if (handles == nullptr) { in Maker() 66 MtpPacketTool::PutAUInt32(outBuffer, handles->data(), handles->size()); in Maker()
|
H A D | get_object_references_data.cpp | 65 auto handles = GetObjectHandles(); in Maker() local 66 if (handles == nullptr) { in Maker() 69 MtpPacketTool::PutAUInt32(outBuffer, handles->data(), handles->size()); in Maker()
|
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/examples/ |
H A D | async_http_multi.rs | 22 let mut handles = Vec::new(); in main() localVariable 24 handles.push(ylong_runtime::spawn(async move { in main() 37 for handle in handles { in main()
|
H A D | async_certs_adapter.rs | 43 let mut handles = Vec::new(); in main() localVariable 54 handles.push(ylong_runtime::spawn(request(temp))); in main() 56 for handle in handles { in main()
|
/ohos5.0/base/hiviewdfx/faultloggerd/tools/panic_maker/ |
H A D | main.rs | 61 let mut handles = vec![]; in get_trace_in_multi_thread() localVariable 67 handles.push(handle); in get_trace_in_multi_thread() 69 for handle in handles { in get_trace_in_multi_thread()
|
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
H A D | mod.rs | 473 let mut handles = vec![]; in ut_ssl_tunnel_error() localVariable 475 Handles: handles, in ut_ssl_tunnel_error() 479 let handle = handles.pop().expect("No more handles !"); in ut_ssl_tunnel_error() 507 Handles: handles, in ut_ssl_tunnel_error() 517 let handle = handles.pop().expect("No more handles !"); in ut_ssl_tunnel_error() 547 Handles: handles, in ut_ssl_tunnel_error() 557 let handle = handles.pop().expect("No more handles !"); in ut_ssl_tunnel_error() 592 let mut handles = vec![]; in ut_ssl_tunnel_connect() localVariable 595 Handles: handles, in ut_ssl_tunnel_connect() 636 let mut handles = vec![]; in ut_ssl_tunnel_resp_beyond_size() localVariable [all …]
|
/ohos5.0/base/hiviewdfx/faultloggerd/test/unittest/stacktrace_rust/ |
H A D | main.rs | 35 let mut handles = vec![]; in test_get_trace_in_multithread() localVariable 44 handles.push(handle); in test_get_trace_in_multithread() 46 for handle in handles { in test_get_trace_in_multithread()
|
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
H A D | async_pool.rs | 46 handles: RwLock<Vec<Parker>>, field 77 handles: RwLock::new(Vec::new()), in new() 101 let join_handle = self.handles.read().unwrap(); in wake_up_all() 132 self.handles in wake_up_rand_one() 345 &self.handles 468 self.exe_mng_info.handles.write().unwrap().push(parker); in create_async_thread_pool() 776 executor_mng_info.handles.write().unwrap().push(parker_cpy); in ut_executor_mng_info_cancel() 807 executor_mng_info.handles.write().unwrap().push(parker_cpy); in ut_executor_mng_info_wake_up_all() 844 executor_mng_info.handles.write().unwrap().push(parker_cpy); in ut_executor_mng_info_wake_up_rand_one() 880 executor_mng_info.handles.write().unwrap().push(parker_cpy); in ut_executor_mng_info_wake_up_if_one_task_left() [all …]
|
/ohos5.0/docs/en/application-dev/reference/common/ |
H A D | _j_s_v_m___heap_statistics.md | 31 | size_t [totalGlobalHandlesSize](#totalglobalhandlessize) | Total size of global handles, in KB. | 32 | size_t [usedGlobalHandlesSize](#usedglobalhandlessize) | Size of the used global handles, in KB. … 107 Total size of global handles, in KB. 143 Size of the used global handles, in KB.
|
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
H A D | dispatcher.rs | 215 pub(crate) handles: Vec<crate::runtime::JoinHandle<()>>, 304 let mut handles = Vec::with_capacity(3); in new() localVariable 312 &mut handles, in new() 321 handles, in new() 332 handles: &mut Vec<crate::runtime::JoinHandle<()>>, in launch() 348 handles.push(send); in launch() 356 handles.push(recv); in launch() 363 handles.push(manager); in launch() 387 for handle in &self.handles { in drop()
|
/ohos5.0/foundation/graphic/graphic_3d/lume/LumeRender/src/device/ |
H A D | gpu_resource_cache.cpp | 136 vector<RenderHandleReference> handles(descs.size()); in ReserveGpuImages() local 137 for (size_t idx = 0; idx < handles.size(); ++idx) { in ReserveGpuImages() 138 handles[idx] = ReserveGpuImageImpl(descs[idx]); in ReserveGpuImages() 140 return handles; in ReserveGpuImages()
|
/ohos5.0/base/security/code_signature/test/unittest/ |
H A D | rust_key_enable_test.rs | 447 let mut handles = vec![]; in test_get_udid_concurrent() localVariable 454 handles.push(handle); in test_get_udid_concurrent() 457 for handle in handles { in test_get_udid_concurrent()
|