Searched refs:pending_queue (Results 1 – 5 of 5) sorted by relevance
6 pub(crate) mod pending_queue; module
194 use super::pending_queue::*;
7 use crate::queue::pending_queue::PendingQueue;72 pub(crate) pending_queue: Arc<PendingQueue>, field121 pending_queue: Arc<PendingQueue>, in new()128 pending_queue, in new()497 self.pending_queue.append(chunks).await; in send_payload_data()519 self.pending_queue.push(c).await; in send_reset_request()
46 pending_queue: Arc<PendingQueue>, field130 pending_queue: Arc::new(PendingQueue::new()), in new()1043 Arc::clone(&self.pending_queue), in create_stream()1217 self.pending_queue.len() in on_cumulative_tsn_ack_point_advanced()1242 if !self.in_fast_recovery && self.pending_queue.len() > 0 { in on_cumulative_tsn_ack_point_advanced()1260 self.pending_queue.len() in on_cumulative_tsn_ack_point_advanced()1736 self.pending_queue.push(c).await; in send_reset_request()1847 if self.pending_queue.len() == 0 { in pop_pending_data_chunks_to_send()1858 while let Some(c) = self.pending_queue.peek() { in pop_pending_data_chunks_to_send()1869 .pending_queue in pop_pending_data_chunks_to_send()[all …]
34 use crate::queue::pending_queue::PendingQueue;