Searched refs:inflight_queue (Results 1 – 2 of 2) sorted by relevance
45 inflight_queue: PayloadQueue, field168 a.inflight_queue.get_num_bytes() in new()753 self.inflight_queue.get_num_bytes() in handle_init_ack()1091 if let Some(c) = self.inflight_queue.pop(i) { in process_selective_ack()1213 if self.inflight_queue.is_empty() { in on_cumulative_tsn_ack_point_advanced()1487 if !self.inflight_queue.is_empty() { in postprocess_sack()1514 if !self.inflight_queue.is_empty() { in handle_shutdown()1568 if let Some(c) = self.inflight_queue.get(i) { in create_forward_tsn()1832 self.inflight_queue.push_no_check(c.clone()); in move_pending_data_chunk_to_inflight_queue()2028 if let Some(c) = self.inflight_queue.get(tsn) { in get_data_packets_to_retransmit()[all …]
72 a.inflight_queue.push_no_check(ChunkPayloadData { in test_create_forward_tsn_forward_one_abandoned()102 a.inflight_queue.push_no_check(ChunkPayloadData { in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()113 a.inflight_queue.push_no_check(ChunkPayloadData { in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()124 a.inflight_queue.push_no_check(ChunkPayloadData { in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()