Contents

use super::Shared;

impl Shared {
    pub(crate) fn injection_queue_depth(&self) -> usize {
        self.inject.len()
    }
}

cfg_unstable_metrics! {
    impl Shared {
        pub(crate) fn worker_local_queue_depth(&self, worker: usize) -> usize {
            self.remotes[worker].steal.len()
        }
    }
}

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
wasmtime-30.0.2	./ext/cargo-vendor/tokio-1.43.0/src/runtime/scheduler/multi_thread/worker/metrics.rs
wasmtime-29.0.0	./ext/cargo-vendor/tokio-1.43.0/src/runtime/scheduler/multi_thread/worker/metrics.rs
wasmtime-28.0.0	./ext/cargo-vendor/tokio-1.43.0/src/runtime/scheduler/multi_thread/worker/metrics.rs
wasmtime-27.0.0	./ext/cargo-vendor/tokio-1.41.1/src/runtime/scheduler/multi_thread/worker/metrics.rs
wasmtime-26.0.0	./ext/cargo-vendor/tokio-1.41.0/src/runtime/scheduler/multi_thread/worker/metrics.rs