| 1 | use super::Shared; |
|---|---|
| 2 | |
| 3 | impl Shared { |
| 4 | pub(crate) fn injection_queue_depth(&self) -> usize { |
| 5 | self.inject.len() |
| 6 | } |
| 7 | } |
| 8 | |
| 9 | cfg_unstable_metrics! { |
| 10 | impl Shared { |
| 11 | pub(crate) fn worker_local_queue_depth(&self, worker: usize) -> usize { |
| 12 | self.remotes[worker].steal.len() |
| 13 | } |
| 14 | } |
| 15 | } |
| 16 |