| /external/rust/android-crates-io/crates/tokio/tests/ |
| D | rt_unstable_metrics.rs | 22 let rt = current_thread(); in num_workers() localVariable
25 let rt = threaded(); in num_workers() localVariable
31 let rt = current_thread(); in num_blocking_threads() localVariable
36 let rt = threaded(); in num_blocking_threads() localVariable
44 let rt = current_thread(); in num_idle_blocking_threads() localVariable
68 let rt = tokio::runtime::Builder::new_current_thread() in blocking_queue_depth() localVariable
98 let rt = current_thread(); in spawned_tasks_count() localVariable
109 let rt = threaded(); in spawned_tasks_count() localVariable
125 let rt = current_thread(); in remote_schedule_count() localVariable
139 let rt = threaded(); in remote_schedule_count() localVariable
[all …]
|
| D | rt_handle_block_on.rs | 136 let rt = rt(); localVariable
147 let rt = rt(); localVariable
164 let rt = rt(); localVariable
180 let rt = rt(); localVariable
197 let rt = rt(); localVariable
217 let rt = rt(); localVariable
229 let rt = rt(); localVariable
249 let rt = rt(); localVariable
268 let rt = rt(); localVariable
280 let rt = rt(); localVariable
[all …]
|
| D | rt_common.rs | 131 let rt = rt(); localVariable
145 let rt = rt(); localVariable
163 let rt = rt(); localVariable
180 let rt = rt(); localVariable
203 let rt = rt(); localVariable
231 let rt = rt(); localVariable
282 let rt = rt(); localVariable
330 let rt = rt(); localVariable
355 let rt = rt(); localVariable
370 let rt = rt(); localVariable
[all …]
|
| D | rt_local.rs | 10 let rt = rt(); in test_spawn_local_in_runtime() localVariable
28 let rt = rt(); in test_spawn_from_handle() localVariable
44 let rt = rt(); in test_spawn_local_on_runtime_object() localVariable
60 let rt = rt(); in test_spawn_local_from_guard() localVariable
82 let rt = rt(); in test_spawn_local_from_guard_other_thread() localVariable
95 fn rt() -> tokio::runtime::LocalRuntime { in rt() function
|
| D | rt_metrics.rs | 11 let rt = current_thread(); in num_workers() localVariable
14 let rt = threaded(); in num_workers() localVariable
20 let rt = current_thread(); in num_alive_tasks() localVariable
30 let rt = threaded(); in num_alive_tasks() localVariable
54 let rt = current_thread(); in global_queue_depth_current_thread() localVariable
70 let rt = threaded(); in global_queue_depth_multi_thread() localVariable
|
| D | rt_basic.rs | 34 let rt = rt(); in spawned_task_does_not_progress_without_block_on() localVariable
87 let rt = rt(); in no_extra_poll() localVariable
125 let rt = rt(); in acquire_mutex_in_drop() localVariable
175 let rt = rt(); in drop_tasks_in_context() localVariable
194 let rt = rt(); in wake_in_drop_after_panic() localVariable
224 let rt = rt(); in spawn_two() localVariable
257 let rt = rt(); in spawn_remote() localVariable
296 let rt = tokio::runtime::Builder::new_current_thread() in timeout_panics_when_no_time_handle() localVariable
315 let rt = Builder::new_current_thread() in shutdown_on_panic() localVariable
334 let rt = Builder::new_current_thread() in spawns_do_nothing() localVariable
[all …]
|
| D | sync_panic.rs | 31 let rt = current_thread(); in mutex_blocking_lock_panic_caller() localVariable
47 let rt = current_thread(); in oneshot_blocking_recv_panic_caller() localVariable
75 let rt = current_thread(); in rwlock_blocking_read_panic_caller() localVariable
91 let rt = current_thread(); in rwlock_blocking_write_panic_caller() localVariable
119 let rt = current_thread(); in mpsc_bounded_receiver_blocking_recv_panic_caller() localVariable
135 let rt = current_thread(); in mpsc_bounded_receiver_blocking_recv_many_panic_caller() localVariable
151 let rt = current_thread(); in mpsc_bounded_sender_blocking_send_panic_caller() localVariable
167 let rt = current_thread(); in mpsc_unbounded_receiver_blocking_recv_panic_caller() localVariable
183 let rt = current_thread(); in mpsc_unbounded_receiver_blocking_recv_many_panic_caller() localVariable
|
| D | net_panic.rs | 25 let rt = runtime_without_io(); in udp_socket_from_std_panic_caller() localVariable
44 let rt = runtime_without_io(); in tcp_listener_from_std_panic_caller() localVariable
65 let rt = runtime_without_io(); in tcp_stream_from_std_panic_caller() localVariable
87 let rt = runtime_without_io(); in unix_listener_bind_panic_caller() localVariable
110 let rt = runtime_without_io(); in unix_listener_from_std_panic_caller() localVariable
134 let rt = runtime_without_io(); in unix_stream_from_std_panic_caller() localVariable
162 let rt = runtime_without_io(); in unix_datagram_from_std_panic_caller() localVariable
180 let rt = runtime_without_io(); in server_options_max_instances_panic_caller() localVariable
|
| D | rt_threaded.rs | 46 let rt = rt(); in many_oneshot_futures() localVariable
71 let rt = rt(); in spawn_two() localVariable
108 let rt = rt(); in many_multishot_futures() localVariable
175 let rt = runtime::Builder::new_multi_thread() in lifo_slot_budget() localVariable
194 let rt = rt(); in spawn_shutdown() localVariable
261 let rt = runtime::Builder::new_multi_thread() in drop_threadpool_drops_futures() localVariable
300 let rt = tokio::runtime::Builder::new_multi_thread() in start_stop_callbacks_called() localVariable
335 let rt = rt(); in blocking() localVariable
402 let rt = tokio::runtime::Builder::new_multi_thread() in coop_and_block_in_place() localVariable
451 let rt = tokio::runtime::Builder::new_multi_thread() in yield_after_block_in_place() localVariable
[all …]
|
| D | rt_threaded_alt.rs | 47 let rt = rt(); in many_oneshot_futures() localVariable
72 let rt = rt(); in spawn_two() localVariable
109 let rt = rt(); in many_multishot_futures() localVariable
176 let rt = runtime::Builder::new_multi_thread_alt() in lifo_slot_budget() localVariable
194 let rt = rt(); in spawn_shutdown() localVariable
261 let rt = runtime::Builder::new_multi_thread_alt() in drop_threadpool_drops_futures() localVariable
300 let rt = tokio::runtime::Builder::new_multi_thread_alt() in start_stop_callbacks_called() localVariable
333 let rt = rt(); in blocking_task() localVariable
400 let rt = tokio::runtime::Builder::new_multi_thread_alt() in coop_and_block_in_place() localVariable
449 let rt = tokio::runtime::Builder::new_multi_thread_alt() in yield_after_block_in_place() localVariable
[all …]
|
| D | task_abort.rs | 24 let rt = Builder::new_multi_thread() in test_abort_without_panic_3157() localVariable
57 let rt = Builder::new_current_thread().build().unwrap(); in test_abort_without_panic_3662() localVariable
130 let rt = Builder::new_current_thread().build().unwrap(); in remote_abort_local_set_3929() localVariable
152 let rt = Builder::new_current_thread().enable_time().build().unwrap(); in test_abort_wakes_task_3964() localVariable
183 let rt = Builder::new_current_thread().enable_time().build().unwrap(); in test_abort_task_that_panics_on_drop_contained() localVariable
207 let rt = Builder::new_current_thread().enable_time().build().unwrap(); in test_abort_task_that_panics_on_drop_returned() localVariable
230 let rt = Builder::new_current_thread().build().unwrap(); in test_join_error_display() localVariable
281 let rt = Builder::new_current_thread().build().unwrap(); in test_join_error_debug() localVariable
|
| D | dump.rs | 31 let rt = runtime::Builder::new_current_thread() in current_thread() localVariable
68 let rt = runtime::Builder::new_multi_thread() in multi_thread() localVariable
128 let rt = runtime::Builder::new_current_thread() in current_thread() localVariable
145 let rt = runtime::Builder::new_multi_thread() in multi_thread() localVariable
169 let rt = runtime::Builder::new_multi_thread() in notified_during_tracing() localVariable
|
| D | io_driver_drop.rs | 11 let rt = rt(); in tcp_doesnt_block() localVariable
31 let rt = rt(); in drop_wakes() localVariable
51 fn rt() -> runtime::Runtime { in rt() function
|
| D | time_panic.rs | 19 let rt = current_thread(); in pause_panic_caller() localVariable
36 let rt = current_thread(); in resume_panic_caller() localVariable
77 let rt = Builder::new_current_thread().build().unwrap(); in timeout_panic_caller() localVariable
|
| D | task_local_set.rs | 146 let rt = runtime::Builder::new_current_thread() in enter_guard_spawn() localVariable
167 let rt = runtime::Builder::new_current_thread() in local_threadpool_blocking_in_place() localVariable
283 let rt = runtime::Runtime::new().unwrap(); in join_local_future_elsewhere() localVariable
336 let rt = rt(); in drop_cancels_tasks() localVariable
411 let rt = rt(); in drop_cancels_remote_tasks() localVariable
438 let rt = rt(); in local_tasks_wake_join_all() localVariable
606 rt: Runtime, in store_local_set_in_thread_local_with_runtime() field
712 fn rt() -> runtime::Runtime { in rt() function
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | full_type_inference_util_test.cc | 37 const FullTypeDef& rt = ret.ValueOrDie(); in TEST() local
50 const FullTypeDef& rt = ret.ValueOrDie(); in TEST() local
66 const FullTypeDef& rt = ret.ValueOrDie(); in TEST() local
82 const FullTypeDef& rt = ret.ValueOrDie(); in TEST() local
95 const FullTypeDef& rt = ret.ValueOrDie(); in TEST() local
106 const FullTypeDef& rt = ret.ValueOrDie(); in TEST() local
119 const FullTypeDef& rt = ret.ValueOrDie(); in TEST() local
132 const FullTypeDef& rt = ret.ValueOrDie(); in TEST() local
143 const FullTypeDef& rt = ret.ValueOrDie(); in TEST() local
150 const FullTypeDef& rt = ret.ValueOrDie(); in ExpectInferredArrayOfTensor() local
[all …]
|
| /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() localVariable
35 fn rt(start_paused: bool) -> crate::runtime::Runtime { in rt() function
46 let rt = rt(false); in single_timer() localVariable
77 let rt = rt(false); in drop_timer() localVariable
111 let rt = rt(false); in change_waker() localVariable
146 let rt = rt(false); in reset_future() localVariable
208 let rt = rt(true); in poll_process_levels() localVariable
245 let rt = rt(true); in poll_process_levels_targeted() localVariable
267 let rt = rt(true); in instant_to_tick_max() localVariable
|
| /external/rust/android-crates-io/crates/uefi/src/ |
| D | runtime.rs | 40 let rt = runtime_services_raw_panicking(); in get_time() localVariable
41 let rt = unsafe { rt.as_ref() }; in get_time() localVariable
50 let rt = runtime_services_raw_panicking(); in get_time_and_caps() localVariable
51 let rt = unsafe { rt.as_ref() }; in get_time_and_caps() localVariable
69 let rt = runtime_services_raw_panicking(); in set_time() localVariable
70 let rt = unsafe { rt.as_ref() }; in set_time() localVariable
89 let rt = runtime_services_raw_panicking(); in variable_exists() localVariable
90 let rt = unsafe { rt.as_ref() }; in variable_exists() localVariable
138 let rt = runtime_services_raw_panicking(); in get_variable() localVariable
139 let rt = unsafe { rt.as_ref() }; in get_variable() localVariable
[all …]
|
| /external/rust/android-crates-io/crates/tokio-util/tests/ |
| D | panic.rs | 94 let rt = basic(); in local_pool_handle_spawn_pinned_by_idx_panic_caller() localVariable
110 let rt = basic(); in delay_queue_insert_at_panic_caller() localVariable
131 let rt = basic(); in delay_queue_insert_panic_caller() localVariable
148 let rt = basic(); in delay_queue_remove_panic_caller() localVariable
167 let rt = basic(); in delay_queue_reset_at_panic_caller() localVariable
188 let rt = basic(); in delay_queue_reset_panic_caller() localVariable
206 let rt = basic(); in delay_queue_reserve_panic_caller() localVariable
|
| /external/rust/android-crates-io/crates/tokio/src/runtime/tests/ |
| D | loom_blocking.rs | 10 let rt = mk_runtime(1); in blocking_shutdown() localVariable
30 let rt = runtime::Builder::new_current_thread().build().unwrap(); in spawn_mandatory_blocking_should_always_run() localVariable
51 let rt = runtime::Builder::new_current_thread().build().unwrap(); in spawn_mandatory_blocking_should_run_even_when_shutting_down_from_other_thread() localVariable
80 let rt = crate::runtime::Builder::new_current_thread() in spawn_blocking_when_paused() localVariable
|
| /external/tensorflow/tensorflow/core/function/ |
| D | runtime_client_test.cc | 174 Runtime rt(GlobalEagerContext()); in TEST() local
186 Runtime rt(*ctx); in TEST() local
198 Runtime rt(*ctx); in TEST() local
236 Runtime rt(*ectx); in TEST() local
254 Runtime rt(*ctx); in TEST() local
266 Runtime rt(*ctx); in TEST() local
279 Runtime rt(*ctx); in TEST() local
294 Runtime rt(*ctx); in TEST() local
|
| /external/rust/android-crates-io/crates/tokio/src/signal/windows/ |
| D | sys.rs | 135 let rt = rt(); in ctrl_c() localVariable
154 let rt = rt(); in ctrl_break() localVariable
172 let rt = rt(); in ctrl_close() localVariable
190 let rt = rt(); in ctrl_shutdown() localVariable
208 let rt = rt(); in ctrl_logoff() localVariable
224 fn rt() -> Runtime { in rt() function
|
| /external/mesa3d/src/gallium/drivers/etnaviv/ |
| D | etnaviv_emit.c | 159 const uint8_t rt = i - 1; in emit_halti5_only_state() local
163 const uint8_t rt = i - 1; in emit_halti5_only_state() local
169 const uint8_t rt = i - 1; in emit_halti5_only_state() local
173 const uint8_t rt = i - 1; in emit_halti5_only_state() local
582 const uint8_t rt = i - 1; in etna_emit_state() local
589 const uint8_t rt = i - 1; in etna_emit_state() local
599 const uint8_t rt = i - 1; in etna_emit_state() local
|
| /external/tensorflow/tensorflow/python/ops/ragged/ |
| D | ragged_print_op_test.py | 160 def testRaggedToString(self, rt, expected, summarize=None, ragged_rank=None): argument
171 rt, argument
185 def f(rt): argument
|
| /external/mesa3d/src/gallium/drivers/zink/ |
| D | zink_render_pass.c | 39 get_rt_loadop(const struct zink_rt_attrib *rt, bool clear) in get_rt_loadop()
50 get_color_rt_layout(const struct zink_rt_attrib *rt) in get_color_rt_layout()
56 get_zs_rt_layout(const struct zink_rt_attrib *rt) in get_zs_rt_layout()
83 struct zink_rt_attrib *rt = state->rts + i; in create_render_pass2() local
130 struct zink_rt_attrib *rt = state->rts + state->num_cbufs; in create_render_pass2() local
278 zink_render_pass_attachment_get_barrier_info(const struct zink_rt_attrib *rt, bool color, in zink_render_pass_attachment_get_barrier_info()
359 zink_init_zs_attachment(struct zink_context *ctx, struct zink_rt_attrib *rt) in zink_init_zs_attachment()
389 …achment(struct zink_context *ctx, const struct tc_renderpass_info *info, struct zink_rt_attrib *rt) in zink_tc_init_zs_attachment()
409 zink_init_color_attachment(struct zink_context *ctx, unsigned i, struct zink_rt_attrib *rt) in zink_init_color_attachment()
430 …ct zink_context *ctx, const struct tc_renderpass_info *info, unsigned i, struct zink_rt_attrib *rt) in zink_tc_init_color_attachment()
[all …]
|