| /external/rust/crates/tokio-util/tests/ |
| D | spawn_pinned.rs | 77 let join_handle = pool.spawn_pinned(|| async { in task_panic_propagates() localVariable
89 let join_handle = pool.spawn_pinned(|| async { "test" }); in task_panic_propagates() localVariable
101 let join_handle = pool.spawn_pinned(|| { in callback_panic_does_not_kill_worker() localVariable
115 let join_handle = pool.spawn_pinned(|| async { "test" }); in callback_panic_does_not_kill_worker() localVariable
131 let join_handle = pool.spawn_pinned(|| async move { in task_cancellation_propagates() localVariable
|
| /external/crosvm/swap/tests/ |
| D | page_handler.rs | 164 let join_handle = thread::spawn(move || { in handle_page_fault_zero_success_impl() localVariable
277 let join_handle = thread::spawn(move || { in handle_page_remove_success_impl() localVariable
301 let join_handle = thread::spawn(move || { in handle_page_remove_success_impl() localVariable
431 let join_handle = thread::spawn(move || { in move_to_staging_data_written_before_enabling_impl() localVariable
556 let join_handle = thread::spawn(move || { in move_to_staging_hugepage_chunks_impl() localVariable
736 let join_handle = thread::spawn(move || { in swap_out_success_impl() localVariable
816 let join_handle = thread::spawn(move || { in swap_out_handled_page_impl() localVariable
896 let join_handle = thread::spawn(move || { in swap_out_twice_impl() localVariable
934 let join_handle = thread::spawn(move || { in swap_out_twice_impl() localVariable
1050 let join_handle = thread::spawn(move || { in swap_in_success_impl() localVariable
[all …]
|
| /external/rust/crates/tokio/tests/ |
| D | join_handle_panic.rs | 14 let join_handle = tokio::spawn(async move { PanicsOnDrop }); in test_panics_do_not_propagate_when_dropping_join_handle() localVariable
|
| D | sync_semaphore_owned.rs | 57 let join_handle = tokio::spawn(async move { in acquire_many() localVariable
|
| /external/rust/crates/tokio-util/src/task/ |
| D | spawn_pinned.rs | 236 let join_handle = in spawn_pinned() localVariable
256 let join_handle = match receiver.await { in spawn_pinned() localVariable
|
| /external/crosvm/cros_async/src/ |
| D | tokio_executor.rs | 139 join_handle: Option<tokio::task::JoinHandle<T>>, field
|
| /external/crosvm/cros_async/src/sys/windows/ |
| D | wait_for_handle.rs | 294 let join_handle = spawn_with_timeout(|| { in test_signaled_event() localVariable
|
| /external/rust/beto-rust/common/handle_map/benches/ |
| D | benches.rs | 172 let join_handle = thread::spawn(move || { in bench_multithreaded() localVariable
|
| /external/crosvm/src/sys/windows/ |
| D | irq_wait.rs | 433 let join_handle = thread::Builder::new() in start() localVariable
|
| D | run_vcpu.rs | 602 let join_handle = vcpu_run_thread.run( in run_all_vcpus() localVariable
|
| /external/rust/beto-rust/common/handle_map/src/ |
| D | tests.rs | 54 let join_handle = thread::spawn(move || { in test_for_each_thread() localVariable
|
| /external/crosvm/swap/src/ |
| D | controller.rs | 1048 let join_handle = scope.spawn(|| { in handle_vmm_swap() localVariable
1124 let join_handle = scope.spawn(move || { in handle_vmm_swap() localVariable
|
| /external/toolchain-utils/rust-analyzer-chromiumos-wrapper/src/ |
| D | main.rs | 130 let join_handle = { in main() localVariable
|
| /external/crosvm/win_audio/src/win_audio_impl/ |
| D | mod.rs | 1950 let join_handle = thread::spawn(move || { in test_co_init_called_once_per_thread() localVariable
|