Lines Matching refs:pkt_num
203 let pkt_num = pkt.pkt_num; in on_packet_sent() localVariable
208 cmp::max(self.largest_sent_pkt[epoch], pkt_num); in on_packet_sent()
232 self.hystart.start_round(pkt_num); in on_packet_sent()
283 .skip_while(|p| p.pkt_num < lowest_acked) in on_ack_received()
285 .take_while(|p| p.pkt_num <= largest_acked) in on_ack_received()
296 largest_newly_acked_pkt_num = unacked.pkt_num; in on_ack_received()
309 pkt_num: unacked.pkt_num, in on_ack_received()
316 trace!("{} packet newly acked {}", trace_id, unacked.pkt_num); in on_ack_received()
617 .take_while(|p| p.pkt_num <= largest_acked) in detect_lost_packets()
624 largest_acked >= unacked.pkt_num + PACKET_THRESHOLD in detect_lost_packets()
643 unacked.pkt_num, in detect_lost_packets()
724 if self.in_persistent_congestion(largest_lost_pkt.pkt_num) { in on_packets_lost()
885 pub pkt_num: u64, field
914 write!(f, "pkt_num={:?} ", self.pkt_num)?; in fmt()
933 pub pkt_num: u64, field
1013 pkt_num: 0, in loss_on_pto()
1039 pkt_num: 1, in loss_on_pto()
1065 pkt_num: 2, in loss_on_pto()
1091 pkt_num: 3, in loss_on_pto()
1149 pkt_num: 4, in loss_on_pto()
1175 pkt_num: 5, in loss_on_pto()
1239 pkt_num: 0, in loss_on_timer()
1265 pkt_num: 1, in loss_on_timer()
1291 pkt_num: 2, in loss_on_timer()
1317 pkt_num: 3, in loss_on_timer()
1392 pkt_num: 0, in loss_on_reordering()
1418 pkt_num: 1, in loss_on_reordering()
1444 pkt_num: 2, in loss_on_reordering()
1470 pkt_num: 3, in loss_on_reordering()