Home
last modified time | relevance | path

Searched defs:join_handle (Results 1 – 25 of 33) sorted by relevance

12

/aosp_15_r20/external/crosvm/swap/tests/
H A Dpage_handler.rs164 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 …]
/aosp_15_r20/external/rust/android-crates-io/crates/tokio-util/tests/
Dspawn_pinned.rs80 let join_handle = pool.spawn_pinned(|| async { in task_panic_propagates() localVariable
92 let join_handle = pool.spawn_pinned(|| async { "test" }); in task_panic_propagates() localVariable
105 let join_handle = pool.spawn_pinned(|| { in callback_panic_does_not_kill_worker() localVariable
119 let join_handle = pool.spawn_pinned(|| async { "test" }); in callback_panic_does_not_kill_worker() localVariable
135 let join_handle = pool.spawn_pinned(|| async move { in task_cancellation_propagates() localVariable
/aosp_15_r20/prebuilts/rust/linux-musl-x86/1.80.1/lib/rustlib/src/rust/library/test/src/
H A Dlib.rs274 join_handle: Option<thread::JoinHandle<()>>, in run_tests() field
382 let join_handle = run_test(opts, !opts.run_tests, id, test, run_strategy, tx.clone()); in run_tests() localVariable
408 let join_handle = in run_tests() localVariable
465 let join_handle = run_test(opts, false, id, b, run_strategy, tx.clone()); in run_tests() localVariable
/aosp_15_r20/prebuilts/rust/linux-x86/1.81.0.u1/lib/rustlib/src/rust/library/test/src/
H A Dlib.rs273 join_handle: Option<thread::JoinHandle<()>>, in run_tests() field
381 let join_handle = run_test(opts, !opts.run_tests, id, test, run_strategy, tx.clone()); in run_tests() localVariable
407 let join_handle = in run_tests() localVariable
464 let join_handle = run_test(opts, false, id, b, run_strategy, tx.clone()); in run_tests() localVariable
/aosp_15_r20/prebuilts/rust/linux-x86/1.80.1/lib/rustlib/src/rust/library/test/src/
H A Dlib.rs274 join_handle: Option<thread::JoinHandle<()>>, in run_tests() field
382 let join_handle = run_test(opts, !opts.run_tests, id, test, run_strategy, tx.clone()); in run_tests() localVariable
408 let join_handle = in run_tests() localVariable
465 let join_handle = run_test(opts, false, id, b, run_strategy, tx.clone()); in run_tests() localVariable
/aosp_15_r20/prebuilts/rust/linux-x86/1.81.0/lib/rustlib/src/rust/library/test/src/
H A Dlib.rs273 join_handle: Option<thread::JoinHandle<()>>, in run_tests() field
381 let join_handle = run_test(opts, !opts.run_tests, id, test, run_strategy, tx.clone()); in run_tests() localVariable
407 let join_handle = in run_tests() localVariable
464 let join_handle = run_test(opts, false, id, b, run_strategy, tx.clone()); in run_tests() localVariable
/aosp_15_r20/prebuilts/rust/linux-musl-x86/1.81.0/lib/rustlib/src/rust/library/test/src/
H A Dlib.rs273 join_handle: Option<thread::JoinHandle<()>>, in run_tests() field
381 let join_handle = run_test(opts, !opts.run_tests, id, test, run_strategy, tx.clone()); in run_tests() localVariable
407 let join_handle = in run_tests() localVariable
464 let join_handle = run_test(opts, false, id, b, run_strategy, tx.clone()); in run_tests() localVariable
/aosp_15_r20/packages/modules/DnsResolver/doh/dispatcher/
Dmod.rs74 join_handle: task::JoinHandle<Result<()>>, field
88 let join_handle = runtime.spawn(async { in new() localVariable
/aosp_15_r20/external/rust/android-crates-io/crates/tokio-util/src/task/
Dspawn_pinned.rs236 let join_handle = in spawn_pinned() localVariable
256 let join_handle = match receiver.await { in spawn_pinned() localVariable
/aosp_15_r20/external/rust/android-crates-io/crates/tokio/tests/
Djoin_handle_panic.rs15 let join_handle = tokio::spawn(async move { PanicsOnDrop }); in test_panics_do_not_propagate_when_dropping_join_handle() localVariable
Dsync_semaphore_owned.rs57 let join_handle = tokio::spawn(async move { in acquire_many() localVariable
/aosp_15_r20/system/libfmq/tests/
H A Dfmq_test.rs54 let join_handle = std::thread::spawn(move || { in test_body() localVariable
/aosp_15_r20/external/crosvm/swap/src/
H A Dcontroller.rs1048 let join_handle = scope.spawn(|| { in handle_vmm_swap() localVariable
1124 let join_handle = scope.spawn(move || { in handle_vmm_swap() localVariable
/aosp_15_r20/frameworks/native/services/inputflinger/rust/
H A Dinput_filter.rs550 join_handle: Option<std::thread::JoinHandle<()>>, field
579 let join_handle = std::thread::Builder::new() in create_looper() localVariable
/aosp_15_r20/external/crosvm/cros_async/src/
H A Dtokio_executor.rs139 join_handle: Option<tokio::task::JoinHandle<T>>, field
/aosp_15_r20/external/crosvm/src/sys/windows/
H A Dirq_wait.rs433 let join_handle = thread::Builder::new() in start() localVariable
/aosp_15_r20/external/rust/beto-rust/common/handle_map/benches/
Dbenches.rs172 let join_handle = thread::spawn(move || { in bench_multithreaded() localVariable
/aosp_15_r20/external/rust/beto-rust/common/handle_map/src/
Dtests.rs54 let join_handle = thread::spawn(move || { in test_for_each_thread() localVariable
/aosp_15_r20/external/toolchain-utils/rust-analyzer-chromiumos-wrapper/src/
H A Dmain.rs130 let join_handle = { in main() localVariable
/aosp_15_r20/prebuilts/rust/linux-x86/1.80.1/lib/rustlib/src/rust/library/std/src/sync/mpsc/
H A Dtests.rs499 let join_handle = thread::spawn(move || rx.recv_timeout(Duration::from_secs(u64::MAX))); in very_long_recv_timeout_wont_panic() localVariable
/aosp_15_r20/system/security/keystore2/rkpd_client/src/
H A Dtests.rs73 let join_handle = std::thread::spawn(move || { in getKey() localVariable
/aosp_15_r20/prebuilts/rust/linux-x86/1.81.0/lib/rustlib/src/rust/library/std/src/sync/mpsc/
H A Dtests.rs499 let join_handle = thread::spawn(move || rx.recv_timeout(Duration::from_secs(u64::MAX))); in very_long_recv_timeout_wont_panic() localVariable
/aosp_15_r20/prebuilts/rust/linux-x86/1.81.0.u1/lib/rustlib/src/rust/library/std/src/sync/mpsc/
H A Dtests.rs499 let join_handle = thread::spawn(move || rx.recv_timeout(Duration::from_secs(u64::MAX))); in very_long_recv_timeout_wont_panic() localVariable
/aosp_15_r20/prebuilts/rust/linux-musl-x86/1.81.0/lib/rustlib/src/rust/library/std/src/sync/mpsc/
H A Dtests.rs499 let join_handle = thread::spawn(move || rx.recv_timeout(Duration::from_secs(u64::MAX))); in very_long_recv_timeout_wont_panic() localVariable
/aosp_15_r20/prebuilts/rust/linux-musl-x86/1.80.1/lib/rustlib/src/rust/library/std/src/sync/mpsc/
H A Dtests.rs499 let join_handle = thread::spawn(move || rx.recv_timeout(Duration::from_secs(u64::MAX))); in very_long_recv_timeout_wont_panic() localVariable

12