Lines Matching refs:pkt_num
64 return (unsigned long)pkt->pkt_num; in tx_pkt_info_hash()
70 if (a->pkt_num < b->pkt_num) in tx_pkt_info_compare()
72 if (a->pkt_num > b->pkt_num) in tx_pkt_info_compare()
129 if (!ossl_assert(pkt->pkt_num >= h->watermark)) in tx_pkt_history_add()
135 h->watermark = pkt->pkt_num + 1; in tx_pkt_history_add()
136 h->highest_sent = pkt->pkt_num; in tx_pkt_history_add()
142 tx_pkt_history_by_pkt_num(struct tx_pkt_history_st *h, uint64_t pkt_num) in tx_pkt_history_by_pkt_num() argument
146 key.pkt_num = pkt_num; in tx_pkt_history_by_pkt_num()
153 tx_pkt_history_remove(struct tx_pkt_history_st *h, uint64_t pkt_num) in tx_pkt_history_remove() argument
156 key.pkt_num = pkt_num; in tx_pkt_history_remove()
158 pkt = tx_pkt_history_by_pkt_num(h, pkt_num); in tx_pkt_history_remove()
712 if (range_contains(&ack->ack_ranges[ridx], pkt->pkt_num)) { in ackm_detect_and_remove_newly_acked_pkts()
714 tx_pkt_history_remove(h, pkt->pkt_num); in ackm_detect_and_remove_newly_acked_pkts()
720 } else if (pkt->pkt_num > ack->ack_ranges[ridx].end) { in ackm_detect_and_remove_newly_acked_pkts()
731 assert(pkt->pkt_num < ack->ack_ranges[ridx].start); in ackm_detect_and_remove_newly_acked_pkts()
784 if (pkt->pkt_num > ackm->largest_acked_pkt[pkt_space]) in ackm_detect_and_remove_lost_pkts()
792 >= pkt->pkt_num + K_PKT_THRESHOLD) { in ackm_detect_and_remove_lost_pkts()
793 tx_pkt_history_remove(h, pkt->pkt_num); in ackm_detect_and_remove_lost_pkts()
952 if (p->pkt_num > largest_pn_lost) in ackm_on_pkts_lost()
953 largest_pn_lost = p->pkt_num; in ackm_on_pkts_lost()
996 if (apkt->pkt_num > last_pn_acked) in ackm_on_pkts_acked()
997 last_pn_acked = apkt->pkt_num; in ackm_on_pkts_acked()
1185 if (na_pkts->pkt_num == ack->ack_ranges[0].end && in ossl_ackm_on_rx_ack_frame()
1354 *pn = p->pkt_num; in ossl_ackm_get_largest_unacked()
1390 static int ack_contains(const OSSL_QUIC_FRAME_ACK *ack, QUIC_PN pkt_num) in ack_contains() argument
1395 if (range_contains(&ack->ack_ranges[i], pkt_num)) in ack_contains()
1405 static int ackm_is_missing(OSSL_ACKM *ackm, int pkt_space, QUIC_PN pkt_num) in ackm_is_missing() argument
1412 && pkt_num <= ackm->ack[pkt_space].ack_ranges[0].end in ackm_is_missing()
1413 && !ack_contains(&ackm->ack[pkt_space], pkt_num); in ackm_is_missing()
1539 if (ossl_ackm_is_rx_pn_processable(ackm, pkt->pkt_num, pkt->pkt_space) != 1) in ossl_ackm_on_rx_packet()
1547 if (pkt->pkt_num > ackm->rx_largest_pn[pkt->pkt_space]) { in ossl_ackm_on_rx_packet()
1548 ackm->rx_largest_pn[pkt->pkt_space] = pkt->pkt_num; in ossl_ackm_on_rx_packet()
1558 was_missing = ackm_is_missing(ackm, pkt->pkt_space, pkt->pkt_num); in ossl_ackm_on_rx_packet()
1564 if (rx_pkt_history_add_pn(h, pkt->pkt_num) != 1) in ossl_ackm_on_rx_packet()
1690 tx_pkt_history_remove(h, pkt->pkt_num); in ossl_ackm_mark_packet_pseudo_lost()
