| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/tests/ |
| D | rt_basic.rs | 296 let rt = tokio::runtime::Builder::new_current_thread() in timeout_panics_when_no_time_handle()
315 let rt = Builder::new_current_thread() in shutdown_on_panic()
334 let rt = Builder::new_current_thread() in spawns_do_nothing()
364 let rt = Builder::new_current_thread() in shutdown_all_concurrent_block_on()
400 let rt1 = tokio::runtime::Builder::new_current_thread() in rng_seed()
411 let rt2 = tokio::runtime::Builder::new_current_thread() in rng_seed()
436 let rt1 = tokio::runtime::Builder::new_current_thread() in rng_seed_multi_enter()
443 let rt2 = tokio::runtime::Builder::new_current_thread() in rng_seed_multi_enter()
456 tokio::runtime::Builder::new_current_thread() in rt()
|
| D | task_abort.rs | 57 let rt = Builder::new_current_thread().build().unwrap(); in test_abort_without_panic_3662()
130 let rt = Builder::new_current_thread().build().unwrap(); in remote_abort_local_set_3929()
152 let rt = Builder::new_current_thread().enable_time().build().unwrap(); in test_abort_wakes_task_3964()
183 let rt = Builder::new_current_thread().enable_time().build().unwrap(); in test_abort_task_that_panics_on_drop_contained()
207 let rt = Builder::new_current_thread().enable_time().build().unwrap(); in test_abort_task_that_panics_on_drop_returned()
230 let rt = Builder::new_current_thread().build().unwrap(); in test_join_error_display()
281 let rt = Builder::new_current_thread().build().unwrap(); in test_join_error_debug()
|
| D | task_blocking.rs | 95 let rt = runtime::Builder::new_current_thread().build().unwrap(); in no_block_in_current_thread_block_on()
107 let inner = tokio::runtime::Builder::new_current_thread() in can_enter_current_thread_rt_from_within_block_in_place()
125 let _ = tokio::runtime::Builder::new_current_thread() in useful_panic_message_when_dropping_rt_in_rt()
146 let rt = tokio::runtime::Builder::new_current_thread() in can_shutdown_with_zero_timeout_in_runtime()
158 let rt = tokio::runtime::Builder::new_current_thread() in can_shutdown_now_in_runtime()
|
| D | sync_once_cell.rs | 145 let rt = runtime::Builder::new_current_thread() in get_or_init()
170 let rt = runtime::Builder::new_current_thread() in get_or_init_panic()
195 let rt = runtime::Builder::new_current_thread() in set_and_get()
228 let rt = runtime::Builder::new_current_thread() in set_while_initializing()
253 let rt = runtime::Builder::new_current_thread() in get_or_try_init()
|
| D | io_panic.rs | 142 let rt = Builder::new_current_thread().build().unwrap(); in async_fd_new_panic_caller()
165 let rt = Builder::new_current_thread().build().unwrap(); in async_fd_with_interest_panic_caller()
187 let rt = Builder::new_current_thread().build().unwrap(); in async_fd_try_new_panic_caller()
210 let rt = Builder::new_current_thread().build().unwrap(); in async_fd_try_with_interest_panic_caller()
|
| D | rt_unstable_metrics.rs | 68 let rt = tokio::runtime::Builder::new_current_thread() in blocking_queue_depth()
388 let rt = tokio::runtime::Builder::new_current_thread() in log_histogram()
444 let rt = tokio::runtime::Builder::new_current_thread() in log_histogram_default_configuration()
461 tokio::runtime::Builder::new_current_thread() in worker_poll_count_histogram()
509 let rt = tokio::runtime::Builder::new_current_thread() in worker_poll_count_histogram_range()
523 let rt = tokio::runtime::Builder::new_current_thread() in worker_poll_count_histogram_range()
544 tokio::runtime::Builder::new_current_thread() in worker_poll_count_histogram_disabled_without_explicit_enable()
870 tokio::runtime::Builder::new_current_thread() in current_thread()
|
| D | rt_handle_block_on.rs | 58 tokio::runtime::Builder::new_current_thread()
498 fn new_current_thread() -> Runtime { in new_current_thread() function
499 tokio::runtime::Builder::new_current_thread() in new_current_thread()
511 let rt = new_current_thread(); in test_with_runtimes()
|
| D | task_hooks.rs | 22 let runtime = Builder::new_current_thread() in spawn_task_hook_fires()
57 let runtime = Builder::new_current_thread() in terminate_task_hook_fires()
|
| D | time_panic.rs | 77 let rt = Builder::new_current_thread().build().unwrap(); in timeout_panic_caller()
90 tokio::runtime::Builder::new_current_thread() in current_thread()
|
| D | io_driver.rs | 50 let rt = runtime::Builder::new_current_thread() in test_drop_on_notify()
96 let rt = runtime::Builder::new_current_thread().build().unwrap(); in panics_when_io_disabled()
|
| D | task_panic.rs | 18 let rt = Builder::new_current_thread().enable_all().build().unwrap(); in block_in_place_panic_caller()
47 let rt = Builder::new_current_thread().enable_all().build().unwrap(); in local_set_block_on_panic_caller()
|
| D | task_local_set.rs | 146 let rt = runtime::Builder::new_current_thread() in enter_guard_spawn()
167 let rt = runtime::Builder::new_current_thread() in local_threadpool_blocking_in_place()
613 rt: tokio::runtime::Builder::new_current_thread() in store_local_set_in_thread_local_with_runtime()
713 tokio::runtime::Builder::new_current_thread() in rt()
|
| D | dump.rs | 31 let rt = runtime::Builder::new_current_thread() in current_thread()
128 let rt = runtime::Builder::new_current_thread() in current_thread()
|
| D | signal_panic.rs | 19 let rt = Builder::new_current_thread().build().unwrap(); in signal_panic_caller()
|
| D | signal_drop_rt.rs | 41 tokio::runtime::Builder::new_current_thread() in rt()
|
| D | signal_multi_rt.rs | 51 tokio::runtime::Builder::new_current_thread() in rt()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/runtime/tests/ |
| D | loom_blocking.rs | 30 let rt = runtime::Builder::new_current_thread().build().unwrap(); in spawn_mandatory_blocking_should_always_run()
51 let rt = runtime::Builder::new_current_thread().build().unwrap(); in spawn_mandatory_blocking_should_run_even_when_shutting_down_from_other_thread()
80 let rt = crate::runtime::Builder::new_current_thread() in spawn_blocking_when_paused()
|
| D | loom_current_thread.rs | 56 let rt1 = Arc::new(Builder::new_current_thread().build().unwrap()); in block_on_num_polls()
74 let rt = Builder::new_current_thread().build().unwrap(); in assert_no_unnecessary_polls()
|
| D | loom_local.rs | 18 let rt = Builder::new_current_thread().build().unwrap(); in wake_during_shutdown()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/io/ |
| D | stdio_common.rs | 187 crate::runtime::Builder::new_current_thread() in test_splitter()
204 crate::runtime::Builder::new_current_thread() in test_pseudo_text()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/runtime/time/tests/ |
| D | mod.rs | 20 let rt = crate::runtime::Builder::new_current_thread() in block_on()
36 crate::runtime::Builder::new_current_thread() in rt()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio-test/src/ |
| D | lib.rs | 30 let rt = runtime::Builder::new_current_thread() in block_on()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/runtime/tests/loom_current_thread/ |
| D | yield_now.rs | 29 runtime::Builder::new_current_thread().build().unwrap() in mk_runtime()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/hyper/src/client/ |
| D | dispatch.rs | 397 let rt = tokio::runtime::Builder::new_current_thread() in giver_queue_throughput()
420 let rt = tokio::runtime::Builder::new_current_thread() in giver_queue_not_ready()
|
| /aosp_15_r20/packages/modules/Bluetooth/system/rust/src/utils/ |
| D | task.rs | 20 &Builder::new_current_thread().enable_time().start_paused(true).build().unwrap(), in block_on_locally()
|