Searched refs:payload_queue (Results 1 – 5 of 5) sorted by relevance
5 pub(crate) mod payload_queue; module
8 use super::payload_queue::*;
44 payload_queue: PayloadQueue, field127 payload_queue: PayloadQueue::new(Arc::new(AtomicUsize::new(0))), in new()904 let can_push = self.payload_queue.can_push(d, self.peer_last_tsn); in handle_data()910 self.payload_queue.push(d.clone(), self.peer_last_tsn); in handle_data()917 self.payload_queue.push(d.clone(), self.peer_last_tsn); in handle_data()963 while self.payload_queue.pop(self.peer_last_tsn + 1).is_some() { in handle_peer_last_tsn_and_acknowledgement()976 let has_packet_loss = !self.payload_queue.is_empty(); in handle_peer_last_tsn_and_acknowledgement()981 self.payload_queue in handle_peer_last_tsn_and_acknowledgement()1694 self.payload_queue.pop(self.peer_last_tsn + 1); // may not exist in handle_forward_tsn()2065 gap_ack_blocks: self.payload_queue.get_gap_ack_blocks(self.peer_last_tsn), in create_selective_ack_chunk()[all …]
33 use crate::queue::payload_queue::PayloadQueue;
208 a.payload_queue.push( in test_handle_forward_tsn_forward_1for1_missing()258 a.payload_queue.push( in test_handle_forward_tsn_forward_1for2_missing()