Searched refs:inflight_queue_length (Results 1 – 2 of 2) sorted by relevance
203 inflight_queue_length: Arc<AtomicUsize>, field260 if self.inflight_queue_length.load(Ordering::SeqCst) == 0 { in shutdown()309 let inflight_queue_length = Arc::clone(&ai.inflight_queue_length); in new() localVariable409 inflight_queue_length, in new()
16 pub(crate) inflight_queue_length: Arc<AtomicUsize>, field114 let inflight_queue_length = Arc::new(AtomicUsize::new(0)); in new() localVariable128 inflight_queue: PayloadQueue::new(Arc::clone(&inflight_queue_length)), in new()129 inflight_queue_length, in new()