| /external/rust/crates/tokio/tests/ |
| 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_blocking_threads() localVariable
28 let rt = current_thread(); in num_idle_blocking_threads() localVariable
52 let rt = tokio::runtime::Builder::new_current_thread() in blocking_queue_depth() localVariable
84 let rt = current_thread(); in remote_schedule_count() localVariable
98 let rt = threaded(); in remote_schedule_count() localVariable
115 let rt = current_thread(); in worker_park_count() localVariable
123 let rt = threaded(); in worker_park_count() localVariable
138 let rt = current_thread(); in worker_noop_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
216 let rt = rt(); localVariable
228 let rt = rt(); localVariable
248 let rt = rt(); localVariable
266 let rt = rt(); localVariable
278 let rt = rt(); localVariable
[all …]
|
| D | rt_common.rs | 96 let rt = rt(); localVariable
110 let rt = rt(); localVariable
128 let rt = rt(); localVariable
145 let rt = rt(); localVariable
168 let rt = rt(); localVariable
196 let rt = rt(); localVariable
247 let rt = rt(); localVariable
295 let rt = rt(); localVariable
320 let rt = rt(); localVariable
335 let rt = rt(); localVariable
[all …]
|
| D | rt_basic.rs | 32 let rt = rt(); in spawned_task_does_not_progress_without_block_on() localVariable
85 let rt = rt(); in no_extra_poll() localVariable
123 let rt = rt(); in acquire_mutex_in_drop() localVariable
173 let rt = rt(); in drop_tasks_in_context() localVariable
194 let rt = rt(); in wake_in_drop_after_panic() localVariable
212 let rt = rt(); in spawn_two() localVariable
245 let rt = rt(); in spawn_remote() localVariable
284 let rt = tokio::runtime::Builder::new_current_thread() in timeout_panics_when_no_time_handle() localVariable
303 let rt = Builder::new_current_thread() in shutdown_on_panic() localVariable
322 let rt = Builder::new_current_thread() in spawns_do_nothing() localVariable
[all …]
|
| D | net_panic.rs | 23 let rt = runtime_without_io(); in udp_socket_from_std_panic_caller() localVariable
41 let rt = runtime_without_io(); in tcp_listener_from_std_panic_caller() localVariable
61 let rt = runtime_without_io(); in tcp_stream_from_std_panic_caller() localVariable
82 let rt = runtime_without_io(); in unix_listener_bind_panic_caller() localVariable
104 let rt = runtime_without_io(); in unix_listener_from_std_panic_caller() localVariable
127 let rt = runtime_without_io(); in unix_stream_from_std_panic_caller() localVariable
154 let rt = runtime_without_io(); in unix_datagram_from_std_panic_caller() localVariable
172 let rt = runtime_without_io(); in server_options_max_instances_panic_caller() localVariable
|
| D | rt_threaded.rs | 44 let rt = rt(); in many_oneshot_futures() localVariable
69 let rt = rt(); in spawn_two() localVariable
106 let rt = rt(); in many_multishot_futures() localVariable
165 let rt = rt(); in spawn_shutdown() localVariable
232 let rt = runtime::Builder::new_multi_thread() in drop_threadpool_drops_futures() localVariable
271 let rt = tokio::runtime::Builder::new_multi_thread() in start_stop_callbacks_called() localVariable
304 let rt = rt(); in blocking() localVariable
371 let rt = tokio::runtime::Builder::new_multi_thread() in coop_and_block_in_place() localVariable
420 let rt = tokio::runtime::Builder::new_multi_thread() in yield_after_block_in_place() localVariable
429 let rt = tokio::runtime::Builder::new_current_thread() in yield_after_block_in_place() localVariable
[all …]
|
| D | sync_panic.rs | 30 let rt = current_thread(); in mutex_blocking_lock_panic_caller() localVariable
46 let rt = current_thread(); in oneshot_blocking_recv_panic_caller() localVariable
74 let rt = current_thread(); in rwlock_blocking_read_panic_caller() localVariable
90 let rt = current_thread(); in rwlock_blocking_write_panic_caller() localVariable
118 let rt = current_thread(); in mpsc_bounded_receiver_blocking_recv_panic_caller() localVariable
134 let rt = current_thread(); in mpsc_bounded_sender_blocking_send_panic_caller() localVariable
150 let rt = current_thread(); in mpsc_unbounded_receiver_blocking_recv_panic_caller() localVariable
|
| D | task_abort.rs | 22 let rt = Builder::new_multi_thread() in test_abort_without_panic_3157() localVariable
55 let rt = Builder::new_current_thread().build().unwrap(); in test_abort_without_panic_3662() localVariable
128 let rt = Builder::new_current_thread().build().unwrap(); in remote_abort_local_set_3929() localVariable
150 let rt = Builder::new_current_thread().enable_time().build().unwrap(); in test_abort_wakes_task_3964() localVariable
181 let rt = Builder::new_current_thread().enable_time().build().unwrap(); in test_abort_task_that_panics_on_drop_contained() localVariable
205 let rt = Builder::new_current_thread().enable_time().build().unwrap(); in test_abort_task_that_panics_on_drop_returned() localVariable
|
| D | io_driver_drop.rs | 10 let rt = rt(); in tcp_doesnt_block() localVariable
29 let rt = rt(); in drop_wakes() localVariable
49 fn rt() -> runtime::Runtime { in rt() function
|
| D | task_local_set.rs | 145 let rt = runtime::Builder::new_current_thread() in enter_guard_spawn() localVariable
166 let rt = runtime::Builder::new_current_thread() in local_threadpool_blocking_in_place() localVariable
282 let rt = runtime::Runtime::new().unwrap(); in join_local_future_elsewhere() localVariable
335 let rt = rt(); in drop_cancels_tasks() localVariable
408 let rt = rt(); in drop_cancels_remote_tasks() localVariable
435 let rt = rt(); in local_tasks_wake_join_all() localVariable
582 rt: Runtime, in store_local_set_in_thread_local_with_runtime() field
688 fn rt() -> runtime::Runtime { in rt() function
|
| D | time_panic.rs | 18 let rt = current_thread(); in pause_panic_caller() localVariable
35 let rt = current_thread(); in resume_panic_caller() localVariable
76 let rt = Builder::new_current_thread().build().unwrap(); in timeout_panic_caller() localVariable
|
| D | task_blocking.rs | 86 let rt = runtime::Runtime::new().unwrap(); in yes_block_in_threaded_block_on() localVariable
95 let rt = runtime::Builder::new_current_thread().build().unwrap(); in no_block_in_current_thread_block_on() localVariable
147 let rt = tokio::runtime::Builder::new_current_thread() in can_shutdown_with_zero_timeout_in_runtime() localVariable
159 let rt = tokio::runtime::Builder::new_current_thread() in can_shutdown_now_in_runtime() localVariable
|
| D | signal_multi_rt.rs | 27 let rt = rt(); in multi_loop() localVariable
49 fn rt() -> 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/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
79 let rt = rt(false); in drop_timer() localVariable
112 let rt = rt(false); in change_waker() localVariable
149 let rt = rt(false); in reset_future() localVariable
212 let rt = rt(true); in poll_process_levels() localVariable
249 let rt = rt(true); in poll_process_levels_targeted() localVariable
|
| /external/rust/crates/tokio-util/tests/ |
| D | panic.rs | 95 let rt = basic(); in local_pool_handle_spawn_pinned_by_idx_panic_caller() localVariable
111 let rt = basic(); in delay_queue_insert_at_panic_caller() localVariable
132 let rt = basic(); in delay_queue_insert_panic_caller() localVariable
149 let rt = basic(); in delay_queue_remove_panic_caller() localVariable
168 let rt = basic(); in delay_queue_reset_at_panic_caller() localVariable
189 let rt = basic(); in delay_queue_reset_panic_caller() localVariable
207 let rt = basic(); in delay_queue_reserve_panic_caller() 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/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
|
| D | loom_join_set.rs | 7 let rt = Builder::new_multi_thread() in test_join_set() localVariable
52 let rt = Builder::new_multi_thread() in abort_all_during_completion() localVariable
|
| /external/rust/crates/tokio/src/signal/windows/ |
| D | sys.rs | 136 let rt = rt(); in ctrl_c() localVariable
155 let rt = rt(); in ctrl_break() localVariable
173 let rt = rt(); in ctrl_close() localVariable
191 let rt = rt(); in ctrl_shutdown() localVariable
209 let rt = rt(); in ctrl_logoff() localVariable
225 fn rt() -> Runtime { in rt() function
|
| /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
|
| D | ragged_merge_dims_op_test.py | 179 rt, argument
256 rt, argument
|
| /external/mesa3d/src/broadcom/compiler/ |
| D | v3d_nir_lower_logic_ops.c | 188 v3d_get_format_swizzle_for_rt(struct v3d_compile *c, int rt) in v3d_get_format_swizzle_for_rt()
205 v3d_nir_get_tlb_color(nir_builder *b, int rt, int sample) in v3d_nir_get_tlb_color()
227 int rt, int sample) in v3d_emit_logic_op_raw()
249 int rt, int sample, in v3d_emit_logic_op_unorm()
268 nir_ssa_def *src, int rt, int sample) in v3d_nir_emit_logic_op()
296 nir_alu_type type, int rt, int sample) in v3d_emit_ms_output()
315 int rt) in v3d_nir_lower_logic_op_instr()
370 const int rt = driver_loc; in v3d_nir_lower_logic_ops_block() local
|
| /external/oss-fuzz/projects/quickjs/ |
| D | fuzz_eval.c | 22 JSRuntime *rt; variable
27 static int interrupt_handler(JSRuntime *rt, void *opaque) in interrupt_handler()
|
| D | fuzz_compile.c | 23 JSRuntime *rt; variable
28 static int interrupt_handler(JSRuntime *rt, void *opaque) in interrupt_handler()
|