Searched refs:global_queue_interval (Results 1 – 12 of 12) sorted by relevance
| /external/rust/android-crates-io/crates/tokio/src/runtime/ |
| D | builder.rs | 104 pub(super) global_queue_interval: Option<u32>, field
313 global_queue_interval: None, in new()
921 pub fn global_queue_interval(&mut self, val: u32) -> &mut Self { in global_queue_interval() method
923 self.global_queue_interval = Some(val); in global_queue_interval()
1391 global_queue_interval: self.global_queue_interval, in build_current_thread_runtime_components()
1541 global_queue_interval: self.global_queue_interval,
1590 global_queue_interval: self.global_queue_interval,
|
| D | config.rs | 10 pub(crate) global_queue_interval: Option<u32>, field
|
| /external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/current_thread/ |
| D | mod.rs | 74 global_queue_interval: u32, field
140 let global_queue_interval = config in new() localVariable
141 .global_queue_interval in new()
168 global_queue_interval, in new()
316 if self.tick % self.global_queue_interval == 0 { in next_task()
|
| /external/rust/android-crates-io/crates/tokio/src/runtime/tests/ |
| D | loom_multi_thread_alt.rs | 326 .global_queue_interval(61) in fill_local_queue()
361 .global_queue_interval(61) in pool_concurrent_park_with_steal_with_inject()
464 .global_queue_interval(61) in mk_pool()
|
| /external/rust/android-crates-io/crates/tokio/tests/ |
| D | rt_panic.rs | 76 let _ = Builder::new_multi_thread().global_queue_interval(0).build(); in builder_global_queue_interval_panic_caller()
|
| D | rt_threaded_alt.rs | 499 .global_queue_interval(1) in global_queue_interval_set_to_one()
|
| D | rt_threaded.rs | 501 .global_queue_interval(1) in global_queue_interval_set_to_one()
|
| /external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/multi_thread/ |
| D | stats.rs | 57 if let Some(configured) = config.global_queue_interval { in tuned_global_queue_interval()
|
| D | worker.rs | 139 global_queue_interval: u32, field
271 global_queue_interval: stats.tuned_global_queue_interval(&config), in create()
784 if self.tick % self.global_queue_interval == 0 { in next_task()
1019 if u32::abs_diff(self.global_queue_interval, next) > 2 { in tune_global_queue_interval()
1020 self.global_queue_interval = next; in tune_global_queue_interval()
|
| /external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/multi_thread_alt/ |
| D | worker.rs | 101 global_queue_interval: u32, field
490 global_queue_interval: Stats::DEFAULT_GLOBAL_QUEUE_INTERVAL, in run()
674 self.global_queue_interval = core.stats.tuned_global_queue_interval(&cx.shared().config); in reset_acquired_core()
740 if self.num_seq_local_queue_polls % self.global_queue_interval == 0 { in next_notified_task()
1299 if u32::abs_diff(self.global_queue_interval, next) > 2 { in tune_global_queue_interval()
1300 self.global_queue_interval = next; in tune_global_queue_interval()
|
| D | stats.rs | 77 if let Some(configured) = config.global_queue_interval { in tuned_global_queue_interval()
|
| /external/rust/android-crates-io/crates/tokio/ |
| D | CHANGELOG.md | 290 - runtime: panic if `global_queue_interval` is zero ([#6445])
|