1 use super::Shared; 2 3 impl Shared { injection_queue_depth(&self) -> usize4 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