Lines Matching refs:ackm
616 static struct tx_pkt_history_st *get_tx_history(OSSL_ACKM *ackm, int pkt_space) in get_tx_history() argument
618 assert(!ackm->discarded[pkt_space]); in get_tx_history()
620 return &ackm->tx_history[pkt_space]; in get_tx_history()
627 static struct rx_pkt_history_st *get_rx_history(OSSL_ACKM *ackm, int pkt_space) in get_rx_history() argument
629 assert(!ackm->discarded[pkt_space]); in get_rx_history()
631 return &ackm->rx_history[pkt_space]; in get_rx_history()
645 static uint64_t ackm_ack_eliciting_bytes_in_flight(OSSL_ACKM *ackm) in ackm_ack_eliciting_bytes_in_flight() argument
651 total += ackm->ack_eliciting_bytes_in_flight[i]; in ackm_ack_eliciting_bytes_in_flight()
669 static OSSL_ACKM_TX_PKT *ackm_detect_and_remove_newly_acked_pkts(OSSL_ACKM *ackm, in ackm_detect_and_remove_newly_acked_pkts() argument
690 h = get_tx_history(ackm, pkt_space); in ackm_detect_and_remove_newly_acked_pkts()
746 static OSSL_ACKM_TX_PKT *ackm_detect_and_remove_lost_pkts(OSSL_ACKM *ackm, in ackm_detect_and_remove_lost_pkts() argument
754 assert(ackm->largest_acked_pkt[pkt_space] != QUIC_PN_INVALID); in ackm_detect_and_remove_lost_pkts()
756 ossl_statm_get_rtt_info(ackm->statm, &rtt); in ackm_detect_and_remove_lost_pkts()
758 ackm->loss_time[pkt_space] = ossl_time_zero(); in ackm_detect_and_remove_lost_pkts()
769 now = ackm->now(ackm->now_arg); in ackm_detect_and_remove_lost_pkts()
772 h = get_tx_history(ackm, pkt_space); in ackm_detect_and_remove_lost_pkts()
784 if (pkt->pkt_num > ackm->largest_acked_pkt[pkt_space]) in ackm_detect_and_remove_lost_pkts()
791 || ackm->largest_acked_pkt[pkt_space] in ackm_detect_and_remove_lost_pkts()
799 if (ossl_time_is_zero(ackm->loss_time[pkt_space])) in ackm_detect_and_remove_lost_pkts()
800 ackm->loss_time[pkt_space] = in ackm_detect_and_remove_lost_pkts()
803 ackm->loss_time[pkt_space] = in ackm_detect_and_remove_lost_pkts()
804 ossl_time_min(ackm->loss_time[pkt_space], in ackm_detect_and_remove_lost_pkts()
812 static OSSL_TIME ackm_get_loss_time_and_space(OSSL_ACKM *ackm, int *pspace) in ackm_get_loss_time_and_space() argument
814 OSSL_TIME time = ackm->loss_time[QUIC_PN_SPACE_INITIAL]; in ackm_get_loss_time_and_space()
819 || ossl_time_compare(ackm->loss_time[i], time) == -1) { in ackm_get_loss_time_and_space()
820 time = ackm->loss_time[i]; in ackm_get_loss_time_and_space()
828 static OSSL_TIME ackm_get_pto_time_and_space(OSSL_ACKM *ackm, int *space) in ackm_get_pto_time_and_space() argument
835 ossl_statm_get_rtt_info(ackm->statm, &rtt); in ackm_get_pto_time_and_space()
844 (uint64_t)1 << min_u32(ackm->pto_count, in ackm_get_pto_time_and_space()
848 if (ackm_ack_eliciting_bytes_in_flight(ackm) == 0) { in ackm_get_pto_time_and_space()
849 assert(!ackm->peer_completed_addr_validation); in ackm_get_pto_time_and_space()
851 *space = ackm->discarded[QUIC_PN_SPACE_INITIAL] in ackm_get_pto_time_and_space()
854 return ossl_time_add(ackm->now(ackm->now_arg), duration); in ackm_get_pto_time_and_space()
858 if (ackm->ack_eliciting_bytes_in_flight[i] == 0) in ackm_get_pto_time_and_space()
863 if (!ackm->handshake_confirmed) in ackm_get_pto_time_and_space()
867 if (!ossl_time_is_infinite(ackm->rx_max_ack_delay)) { in ackm_get_pto_time_and_space()
869 = (uint64_t)1 << min_u32(ackm->pto_count, MAX_PTO_COUNT); in ackm_get_pto_time_and_space()
873 ossl_time_multiply(ackm->rx_max_ack_delay, in ackm_get_pto_time_and_space()
878 t = ossl_time_add(ackm->time_of_last_ack_eliciting_pkt[i], duration); in ackm_get_pto_time_and_space()
889 static void ackm_set_loss_detection_timer_actual(OSSL_ACKM *ackm, in ackm_set_loss_detection_timer_actual() argument
892 ackm->loss_detection_deadline = deadline; in ackm_set_loss_detection_timer_actual()
894 if (ackm->loss_detection_deadline_cb != NULL) in ackm_set_loss_detection_timer_actual()
895 ackm->loss_detection_deadline_cb(deadline, in ackm_set_loss_detection_timer_actual()
896 ackm->loss_detection_deadline_cb_arg); in ackm_set_loss_detection_timer_actual()
899 static int ackm_set_loss_detection_timer(OSSL_ACKM *ackm) in ackm_set_loss_detection_timer() argument
904 earliest_loss_time = ackm_get_loss_time_and_space(ackm, &space); in ackm_set_loss_detection_timer()
907 ackm_set_loss_detection_timer_actual(ackm, earliest_loss_time); in ackm_set_loss_detection_timer()
911 if (ackm_ack_eliciting_bytes_in_flight(ackm) == 0 in ackm_set_loss_detection_timer()
912 && ackm->peer_completed_addr_validation) { in ackm_set_loss_detection_timer()
918 ackm_set_loss_detection_timer_actual(ackm, ossl_time_zero()); in ackm_set_loss_detection_timer()
922 timeout = ackm_get_pto_time_and_space(ackm, &space); in ackm_set_loss_detection_timer()
923 ackm_set_loss_detection_timer_actual(ackm, timeout); in ackm_set_loss_detection_timer()
927 static int ackm_in_persistent_congestion(OSSL_ACKM *ackm, in ackm_in_persistent_congestion() argument
934 static void ackm_on_pkts_lost(OSSL_ACKM *ackm, int pkt_space, in ackm_on_pkts_lost() argument
947 ackm->bytes_in_flight -= p->num_bytes; in ackm_on_pkts_lost()
949 ackm->ack_eliciting_bytes_in_flight[p->pkt_space] in ackm_on_pkts_lost()
964 ackm->cc_method->on_data_lost(ackm->cc_data, &loss_info); in ackm_on_pkts_lost()
975 ossl_statm_get_rtt_info(ackm->statm, &rtt); in ackm_on_pkts_lost()
976 if (!ossl_time_is_zero(ackm->first_rtt_sample) in ackm_on_pkts_lost()
977 && ackm_in_persistent_congestion(ackm, lpkt)) in ackm_on_pkts_lost()
980 ackm->cc_method->on_data_lost_finished(ackm->cc_data, flags); in ackm_on_pkts_lost()
983 static void ackm_on_pkts_acked(OSSL_ACKM *ackm, const OSSL_ACKM_TX_PKT *apkt) in ackm_on_pkts_acked() argument
991 ackm->bytes_in_flight -= apkt->num_bytes; in ackm_on_pkts_acked()
993 ackm->ack_eliciting_bytes_in_flight[apkt->pkt_space] in ackm_on_pkts_acked()
1004 rx_pkt_history_bump_watermark(get_rx_history(ackm, in ackm_on_pkts_acked()
1016 ackm->cc_method->on_data_acked(ackm->cc_data, &ainfo); in ackm_on_pkts_acked()
1026 OSSL_ACKM *ackm; in ossl_ackm_new() local
1029 ackm = OPENSSL_zalloc(sizeof(OSSL_ACKM)); in ossl_ackm_new()
1030 if (ackm == NULL) in ossl_ackm_new()
1033 for (i = 0; i < (int)OSSL_NELEM(ackm->tx_history); ++i) { in ossl_ackm_new()
1034 ackm->largest_acked_pkt[i] = QUIC_PN_INVALID; in ossl_ackm_new()
1035 ackm->rx_ack_flush_deadline[i] = ossl_time_infinite(); in ossl_ackm_new()
1036 if (tx_pkt_history_init(&ackm->tx_history[i]) < 1) in ossl_ackm_new()
1040 for (i = 0; i < (int)OSSL_NELEM(ackm->rx_history); ++i) in ossl_ackm_new()
1041 rx_pkt_history_init(&ackm->rx_history[i]); in ossl_ackm_new()
1043 ackm->now = now; in ossl_ackm_new()
1044 ackm->now_arg = now_arg; in ossl_ackm_new()
1045 ackm->statm = statm; in ossl_ackm_new()
1046 ackm->cc_method = cc_method; in ossl_ackm_new()
1047 ackm->cc_data = cc_data; in ossl_ackm_new()
1049 ackm->rx_max_ack_delay = ossl_ms2time(QUIC_DEFAULT_MAX_ACK_DELAY); in ossl_ackm_new()
1050 ackm->tx_max_ack_delay = DEFAULT_TX_MAX_ACK_DELAY; in ossl_ackm_new()
1052 return ackm; in ossl_ackm_new()
1056 tx_pkt_history_destroy(&ackm->tx_history[i]); in ossl_ackm_new()
1058 OPENSSL_free(ackm); in ossl_ackm_new()
1062 void ossl_ackm_free(OSSL_ACKM *ackm) in ossl_ackm_free() argument
1066 if (ackm == NULL) in ossl_ackm_free()
1069 for (i = 0; i < OSSL_NELEM(ackm->tx_history); ++i) in ossl_ackm_free()
1070 if (!ackm->discarded[i]) { in ossl_ackm_free()
1071 tx_pkt_history_destroy(&ackm->tx_history[i]); in ossl_ackm_free()
1072 rx_pkt_history_destroy(&ackm->rx_history[i]); in ossl_ackm_free()
1075 OPENSSL_free(ackm); in ossl_ackm_free()
1078 int ossl_ackm_on_tx_packet(OSSL_ACKM *ackm, OSSL_ACKM_TX_PKT *pkt) in ossl_ackm_on_tx_packet() argument
1080 struct tx_pkt_history_st *h = get_tx_history(ackm, pkt->pkt_space); in ossl_ackm_on_tx_packet()
1084 || ossl_time_compare(ackm->time_of_last_ack_eliciting_pkt[pkt->pkt_space], in ossl_ackm_on_tx_packet()
1101 ackm->time_of_last_ack_eliciting_pkt[pkt->pkt_space] = pkt->time; in ossl_ackm_on_tx_packet()
1102 ackm->ack_eliciting_bytes_in_flight[pkt->pkt_space] in ossl_ackm_on_tx_packet()
1106 ackm->bytes_in_flight += pkt->num_bytes; in ossl_ackm_on_tx_packet()
1107 ackm_set_loss_detection_timer(ackm); in ossl_ackm_on_tx_packet()
1109 ackm->cc_method->on_data_sent(ackm->cc_data, pkt->num_bytes); in ossl_ackm_on_tx_packet()
1115 int ossl_ackm_on_rx_datagram(OSSL_ACKM *ackm, size_t num_bytes) in ossl_ackm_on_rx_datagram() argument
1121 static void ackm_process_ecn(OSSL_ACKM *ackm, const OSSL_QUIC_FRAME_ACK *ack, in ackm_process_ecn() argument
1132 if (ack->ecnce > ackm->peer_ecnce[pkt_space]) { in ackm_process_ecn()
1133 ackm->peer_ecnce[pkt_space] = ack->ecnce; in ackm_process_ecn()
1135 h = get_tx_history(ackm, pkt_space); in ackm_process_ecn()
1141 ackm->cc_method->on_ecn(ackm->cc_data, &ecn_info); in ackm_process_ecn()
1145 int ossl_ackm_on_rx_ack_frame(OSSL_ACKM *ackm, const OSSL_QUIC_FRAME_ACK *ack, in ossl_ackm_on_rx_ack_frame() argument
1151 if (ackm->largest_acked_pkt[pkt_space] == QUIC_PN_INVALID) in ossl_ackm_on_rx_ack_frame()
1152 ackm->largest_acked_pkt[pkt_space] = ack->ack_ranges[0].end; in ossl_ackm_on_rx_ack_frame()
1154 ackm->largest_acked_pkt[pkt_space] in ossl_ackm_on_rx_ack_frame()
1155 = ossl_quic_pn_max(ackm->largest_acked_pkt[pkt_space], in ossl_ackm_on_rx_ack_frame()
1162 if (!ackm->peer_completed_addr_validation in ossl_ackm_on_rx_ack_frame()
1164 ackm->peer_completed_addr_validation = 1; in ossl_ackm_on_rx_ack_frame()
1171 na_pkts = ackm_detect_and_remove_newly_acked_pkts(ackm, ack, pkt_space); in ossl_ackm_on_rx_ack_frame()
1174 ackm_set_loss_detection_timer(ackm); in ossl_ackm_on_rx_ack_frame()
1187 OSSL_TIME now = ackm->now(ackm->now_arg), ack_delay; in ossl_ackm_on_rx_ack_frame()
1188 if (ossl_time_is_zero(ackm->first_rtt_sample)) in ossl_ackm_on_rx_ack_frame()
1189 ackm->first_rtt_sample = now; in ossl_ackm_on_rx_ack_frame()
1193 if (ackm->handshake_confirmed) in ossl_ackm_on_rx_ack_frame()
1194 ack_delay = ossl_time_min(ack_delay, ackm->rx_max_ack_delay); in ossl_ackm_on_rx_ack_frame()
1196 ossl_statm_update_rtt(ackm->statm, ack_delay, in ossl_ackm_on_rx_ack_frame()
1208 ackm_process_ecn(ackm, ack, pkt_space); in ossl_ackm_on_rx_ack_frame()
1211 lost_pkts = ackm_detect_and_remove_lost_pkts(ackm, pkt_space); in ossl_ackm_on_rx_ack_frame()
1213 ackm_on_pkts_lost(ackm, pkt_space, lost_pkts, /*pseudo=*/0); in ossl_ackm_on_rx_ack_frame()
1215 ackm_on_pkts_acked(ackm, na_pkts); in ossl_ackm_on_rx_ack_frame()
1221 if (ackm->peer_completed_addr_validation) in ossl_ackm_on_rx_ack_frame()
1222 ackm->pto_count = 0; in ossl_ackm_on_rx_ack_frame()
1224 ackm_set_loss_detection_timer(ackm); in ossl_ackm_on_rx_ack_frame()
1228 int ossl_ackm_on_pkt_space_discarded(OSSL_ACKM *ackm, int pkt_space) in ossl_ackm_on_pkt_space_discarded() argument
1233 if (ackm->discarded[pkt_space]) in ossl_ackm_on_pkt_space_discarded()
1237 ackm->peer_completed_addr_validation = 1; in ossl_ackm_on_pkt_space_discarded()
1239 for (pkt = ossl_list_tx_history_head(&get_tx_history(ackm, pkt_space)->packets); in ossl_ackm_on_pkt_space_discarded()
1243 ackm->bytes_in_flight -= pkt->num_bytes; in ossl_ackm_on_pkt_space_discarded()
1250 tx_pkt_history_destroy(&ackm->tx_history[pkt_space]); in ossl_ackm_on_pkt_space_discarded()
1251 rx_pkt_history_destroy(&ackm->rx_history[pkt_space]); in ossl_ackm_on_pkt_space_discarded()
1254 ackm->cc_method->on_data_invalidated(ackm->cc_data, in ossl_ackm_on_pkt_space_discarded()
1257 ackm->time_of_last_ack_eliciting_pkt[pkt_space] = ossl_time_zero(); in ossl_ackm_on_pkt_space_discarded()
1258 ackm->loss_time[pkt_space] = ossl_time_zero(); in ossl_ackm_on_pkt_space_discarded()
1259 ackm->pto_count = 0; in ossl_ackm_on_pkt_space_discarded()
1260 ackm->discarded[pkt_space] = 1; in ossl_ackm_on_pkt_space_discarded()
1261 ackm->ack_eliciting_bytes_in_flight[pkt_space] = 0; in ossl_ackm_on_pkt_space_discarded()
1262 ackm_set_loss_detection_timer(ackm); in ossl_ackm_on_pkt_space_discarded()
1266 int ossl_ackm_on_handshake_confirmed(OSSL_ACKM *ackm) in ossl_ackm_on_handshake_confirmed() argument
1268 ackm->handshake_confirmed = 1; in ossl_ackm_on_handshake_confirmed()
1269 ackm->peer_completed_addr_validation = 1; in ossl_ackm_on_handshake_confirmed()
1270 ackm_set_loss_detection_timer(ackm); in ossl_ackm_on_handshake_confirmed()
1274 static void ackm_queue_probe_anti_deadlock_handshake(OSSL_ACKM *ackm) in ackm_queue_probe_anti_deadlock_handshake() argument
1276 ++ackm->pending_probe.anti_deadlock_handshake; in ackm_queue_probe_anti_deadlock_handshake()
1279 static void ackm_queue_probe_anti_deadlock_initial(OSSL_ACKM *ackm) in ackm_queue_probe_anti_deadlock_initial() argument
1281 ++ackm->pending_probe.anti_deadlock_initial; in ackm_queue_probe_anti_deadlock_initial()
1284 static void ackm_queue_probe(OSSL_ACKM *ackm, int pkt_space) in ackm_queue_probe() argument
1291 ++ackm->pending_probe.pto[pkt_space]; in ackm_queue_probe()
1294 int ossl_ackm_on_timeout(OSSL_ACKM *ackm) in ossl_ackm_on_timeout() argument
1300 earliest_loss_time = ackm_get_loss_time_and_space(ackm, &pkt_space); in ossl_ackm_on_timeout()
1303 lost_pkts = ackm_detect_and_remove_lost_pkts(ackm, pkt_space); in ossl_ackm_on_timeout()
1305 ackm_on_pkts_lost(ackm, pkt_space, lost_pkts, /*pseudo=*/0); in ossl_ackm_on_timeout()
1306 ackm_set_loss_detection_timer(ackm); in ossl_ackm_on_timeout()
1310 if (ackm_ack_eliciting_bytes_in_flight(ackm) == 0) { in ossl_ackm_on_timeout()
1311 assert(!ackm->peer_completed_addr_validation); in ossl_ackm_on_timeout()
1317 if (ackm->discarded[QUIC_PN_SPACE_INITIAL]) in ossl_ackm_on_timeout()
1318 ackm_queue_probe_anti_deadlock_handshake(ackm); in ossl_ackm_on_timeout()
1320 ackm_queue_probe_anti_deadlock_initial(ackm); in ossl_ackm_on_timeout()
1327 ackm_get_pto_time_and_space(ackm, &pkt_space); in ossl_ackm_on_timeout()
1328 ackm_queue_probe(ackm, pkt_space); in ossl_ackm_on_timeout()
1331 ++ackm->pto_count; in ossl_ackm_on_timeout()
1332 ackm_set_loss_detection_timer(ackm); in ossl_ackm_on_timeout()
1336 OSSL_TIME ossl_ackm_get_loss_detection_deadline(OSSL_ACKM *ackm) in ossl_ackm_get_loss_detection_deadline() argument
1338 return ackm->loss_detection_deadline; in ossl_ackm_get_loss_detection_deadline()
1341 OSSL_ACKM_PROBE_INFO *ossl_ackm_get0_probe_request(OSSL_ACKM *ackm) in ossl_ackm_get0_probe_request() argument
1343 return &ackm->pending_probe; in ossl_ackm_get0_probe_request()
1346 int ossl_ackm_get_largest_unacked(OSSL_ACKM *ackm, int pkt_space, QUIC_PN *pn) in ossl_ackm_get_largest_unacked() argument
1351 h = get_tx_history(ackm, pkt_space); in ossl_ackm_get_largest_unacked()
1379 int ossl_ackm_is_ack_desired(OSSL_ACKM *ackm, int pkt_space) in ossl_ackm_is_ack_desired() argument
1381 return ackm->rx_ack_desired[pkt_space] in ossl_ackm_is_ack_desired()
1382 || (!ossl_time_is_infinite(ackm->rx_ack_flush_deadline[pkt_space]) in ossl_ackm_is_ack_desired()
1383 && ossl_time_compare(ackm->now(ackm->now_arg), in ossl_ackm_is_ack_desired()
1384 ackm->rx_ack_flush_deadline[pkt_space]) >= 0); in ossl_ackm_is_ack_desired()
1405 static int ackm_is_missing(OSSL_ACKM *ackm, int pkt_space, QUIC_PN pkt_num) in ackm_is_missing() argument
1411 return ackm->ack[pkt_space].num_ack_ranges > 0 in ackm_is_missing()
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()
1420 static int ackm_has_newly_missing(OSSL_ACKM *ackm, int pkt_space) in ackm_has_newly_missing() argument
1424 h = get_rx_history(ackm, pkt_space); in ackm_has_newly_missing()
1441 return ackm->ack[pkt_space].num_ack_ranges > 0 in ackm_has_newly_missing()
1445 > ackm->ack[pkt_space].ack_ranges[0].end + 1; in ackm_has_newly_missing()
1448 static void ackm_set_flush_deadline(OSSL_ACKM *ackm, int pkt_space, in ackm_set_flush_deadline() argument
1451 ackm->rx_ack_flush_deadline[pkt_space] = deadline; in ackm_set_flush_deadline()
1453 if (ackm->ack_deadline_cb != NULL) in ackm_set_flush_deadline()
1454 ackm->ack_deadline_cb(ossl_ackm_get_ack_deadline(ackm, pkt_space), in ackm_set_flush_deadline()
1455 pkt_space, ackm->ack_deadline_cb_arg); in ackm_set_flush_deadline()
1459 static void ackm_queue_ack(OSSL_ACKM *ackm, int pkt_space) in ackm_queue_ack() argument
1461 ackm->rx_ack_desired[pkt_space] = 1; in ackm_queue_ack()
1464 ackm_set_flush_deadline(ackm, pkt_space, ossl_time_infinite()); in ackm_queue_ack()
1467 static void ackm_on_rx_ack_eliciting(OSSL_ACKM *ackm, in ackm_on_rx_ack_eliciting() argument
1473 if (ackm->rx_ack_desired[pkt_space]) in ackm_on_rx_ack_eliciting()
1477 ++ackm->rx_ack_eliciting_pkts_since_last_ack[pkt_space]; in ackm_on_rx_ack_eliciting()
1479 if (!ackm->rx_ack_generated[pkt_space] in ackm_on_rx_ack_eliciting()
1481 || ackm->rx_ack_eliciting_pkts_since_last_ack[pkt_space] in ackm_on_rx_ack_eliciting()
1483 || ackm_has_newly_missing(ackm, pkt_space)) { in ackm_on_rx_ack_eliciting()
1506 ackm_queue_ack(ackm, pkt_space); in ackm_on_rx_ack_eliciting()
1519 tx_max_ack_delay = ackm->tx_max_ack_delay; in ackm_on_rx_ack_eliciting()
1524 if (ossl_time_is_infinite(ackm->rx_ack_flush_deadline[pkt_space])) in ackm_on_rx_ack_eliciting()
1525 ackm_set_flush_deadline(ackm, pkt_space, in ackm_on_rx_ack_eliciting()
1528 ackm_set_flush_deadline(ackm, pkt_space, in ackm_on_rx_ack_eliciting()
1529 ossl_time_min(ackm->rx_ack_flush_deadline[pkt_space], in ackm_on_rx_ack_eliciting()
1534 int ossl_ackm_on_rx_packet(OSSL_ACKM *ackm, const OSSL_ACKM_RX_PKT *pkt) in ossl_ackm_on_rx_packet() argument
1536 struct rx_pkt_history_st *h = get_rx_history(ackm, pkt->pkt_space); in ossl_ackm_on_rx_packet()
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()
1549 ackm->rx_largest_time[pkt->pkt_space] = pkt->time; 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()
1573 ackm_on_rx_ack_eliciting(ackm, pkt->time, pkt->pkt_space, was_missing); in ossl_ackm_on_rx_packet()
1578 ++ackm->rx_ect0[pkt->pkt_space]; in ossl_ackm_on_rx_packet()
1581 ++ackm->rx_ect1[pkt->pkt_space]; in ossl_ackm_on_rx_packet()
1584 ++ackm->rx_ecnce[pkt->pkt_space]; in ossl_ackm_on_rx_packet()
1593 static void ackm_fill_rx_ack_ranges(OSSL_ACKM *ackm, int pkt_space, in ackm_fill_rx_ack_ranges() argument
1596 struct rx_pkt_history_st *h = get_rx_history(ackm, pkt_space); in ackm_fill_rx_ack_ranges()
1605 x != NULL && i < OSSL_NELEM(ackm->ack_ranges); in ackm_fill_rx_ack_ranges()
1607 ackm->ack_ranges[pkt_space][i].start = x->range.start; in ackm_fill_rx_ack_ranges()
1608 ackm->ack_ranges[pkt_space][i].end = x->range.end; in ackm_fill_rx_ack_ranges()
1611 ack->ack_ranges = ackm->ack_ranges[pkt_space]; in ackm_fill_rx_ack_ranges()
1615 const OSSL_QUIC_FRAME_ACK *ossl_ackm_get_ack_frame(OSSL_ACKM *ackm, in ossl_ackm_get_ack_frame() argument
1618 OSSL_QUIC_FRAME_ACK *ack = &ackm->ack[pkt_space]; in ossl_ackm_get_ack_frame()
1619 OSSL_TIME now = ackm->now(ackm->now_arg); in ossl_ackm_get_ack_frame()
1621 ackm_fill_rx_ack_ranges(ackm, pkt_space, ack); in ossl_ackm_get_ack_frame()
1623 if (!ossl_time_is_zero(ackm->rx_largest_time[pkt_space]) in ossl_ackm_get_ack_frame()
1624 && ossl_time_compare(now, ackm->rx_largest_time[pkt_space]) > 0 in ossl_ackm_get_ack_frame()
1627 ossl_time_subtract(now, ackm->rx_largest_time[pkt_space]); in ossl_ackm_get_ack_frame()
1631 ack->ect0 = ackm->rx_ect0[pkt_space]; in ossl_ackm_get_ack_frame()
1632 ack->ect1 = ackm->rx_ect1[pkt_space]; in ossl_ackm_get_ack_frame()
1633 ack->ecnce = ackm->rx_ecnce[pkt_space]; in ossl_ackm_get_ack_frame()
1636 ackm->rx_ack_eliciting_pkts_since_last_ack[pkt_space] = 0; in ossl_ackm_get_ack_frame()
1638 ackm->rx_ack_generated[pkt_space] = 1; in ossl_ackm_get_ack_frame()
1639 ackm->rx_ack_desired[pkt_space] = 0; in ossl_ackm_get_ack_frame()
1640 ackm_set_flush_deadline(ackm, pkt_space, ossl_time_infinite()); in ossl_ackm_get_ack_frame()
1645 OSSL_TIME ossl_ackm_get_ack_deadline(OSSL_ACKM *ackm, int pkt_space) in ossl_ackm_get_ack_deadline() argument
1647 if (ackm->rx_ack_desired[pkt_space]) in ossl_ackm_get_ack_deadline()
1651 return ackm->rx_ack_flush_deadline[pkt_space]; in ossl_ackm_get_ack_deadline()
1654 int ossl_ackm_is_rx_pn_processable(OSSL_ACKM *ackm, QUIC_PN pn, int pkt_space) in ossl_ackm_is_rx_pn_processable() argument
1656 struct rx_pkt_history_st *h = get_rx_history(ackm, pkt_space); in ossl_ackm_is_rx_pn_processable()
1661 void ossl_ackm_set_loss_detection_deadline_callback(OSSL_ACKM *ackm, in ossl_ackm_set_loss_detection_deadline_callback() argument
1666 ackm->loss_detection_deadline_cb = fn; in ossl_ackm_set_loss_detection_deadline_callback()
1667 ackm->loss_detection_deadline_cb_arg = arg; in ossl_ackm_set_loss_detection_deadline_callback()
1670 void ossl_ackm_set_ack_deadline_callback(OSSL_ACKM *ackm, in ossl_ackm_set_ack_deadline_callback() argument
1676 ackm->ack_deadline_cb = fn; in ossl_ackm_set_ack_deadline_callback()
1677 ackm->ack_deadline_cb_arg = arg; in ossl_ackm_set_ack_deadline_callback()
1680 int ossl_ackm_mark_packet_pseudo_lost(OSSL_ACKM *ackm, in ossl_ackm_mark_packet_pseudo_lost() argument
1683 struct tx_pkt_history_st *h = get_tx_history(ackm, pkt_space); in ossl_ackm_mark_packet_pseudo_lost()
1692 ackm_on_pkts_lost(ackm, pkt_space, pkt, /*pseudo=*/1); in ossl_ackm_mark_packet_pseudo_lost()
1696 OSSL_TIME ossl_ackm_get_pto_duration(OSSL_ACKM *ackm) in ossl_ackm_get_pto_duration() argument
1701 ossl_statm_get_rtt_info(ackm->statm, &rtt); in ossl_ackm_get_pto_duration()
1706 if (!ossl_time_is_infinite(ackm->rx_max_ack_delay)) in ossl_ackm_get_pto_duration()
1707 duration = ossl_time_add(duration, ackm->rx_max_ack_delay); in ossl_ackm_get_pto_duration()
1712 QUIC_PN ossl_ackm_get_largest_acked(OSSL_ACKM *ackm, int pkt_space) in ossl_ackm_get_largest_acked() argument
1714 return ackm->largest_acked_pkt[pkt_space]; in ossl_ackm_get_largest_acked()
1717 void ossl_ackm_set_rx_max_ack_delay(OSSL_ACKM *ackm, OSSL_TIME rx_max_ack_delay) in ossl_ackm_set_rx_max_ack_delay() argument
1719 ackm->rx_max_ack_delay = rx_max_ack_delay; in ossl_ackm_set_rx_max_ack_delay()
1722 void ossl_ackm_set_tx_max_ack_delay(OSSL_ACKM *ackm, OSSL_TIME tx_max_ack_delay) in ossl_ackm_set_tx_max_ack_delay() argument
1724 ackm->tx_max_ack_delay = tx_max_ack_delay; in ossl_ackm_set_tx_max_ack_delay()
