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