Home
last modified time | relevance | path

Searched refs:ackm (Results 1 – 15 of 15) sorted by relevance

/src/crypto/openssl/ssl/quic/
H A Dquic_ackm.c621 static struct tx_pkt_history_st *get_tx_history(OSSL_ACKM *ackm, int pkt_space) in get_tx_history() argument
623 assert(!ackm->discarded[pkt_space]); in get_tx_history()
625 return &ackm->tx_history[pkt_space]; in get_tx_history()
632 static struct rx_pkt_history_st *get_rx_history(OSSL_ACKM *ackm, int pkt_space) in get_rx_history() argument
634 assert(!ackm->discarded[pkt_space]); in get_rx_history()
636 return &ackm->rx_history[pkt_space]; in get_rx_history()
650 static uint64_t ackm_ack_eliciting_bytes_in_flight(OSSL_ACKM *ackm) in ackm_ack_eliciting_bytes_in_flight() argument
656 total += ackm->ack_eliciting_bytes_in_flight[i]; in ackm_ack_eliciting_bytes_in_flight()
674 static OSSL_ACKM_TX_PKT *ackm_detect_and_remove_newly_acked_pkts(OSSL_ACKM *ackm, in ackm_detect_and_remove_newly_acked_pkts() argument
695 h = get_tx_history(ackm, pkt_space); in ackm_detect_and_remove_newly_acked_pkts()
[all …]
H A Dquic_fifd.c18 OSSL_ACKM *ackm, in ossl_quic_fifd_init() argument
42 if (cfq == NULL || ackm == NULL || txpim == NULL in ossl_quic_fifd_init()
47 fifd->ackm = ackm; in ossl_quic_fifd_init()
304 return ossl_ackm_on_tx_packet(fifd->ackm, &pkt->ackm_pkt); in ossl_quic_fifd_pkt_commit()
H A Dquic_channel.c241 if ((ch->ackm = ossl_ackm_new(get_time, ch, &ch->statm, in ch_init()
265 txp_args.ackm = ch->ackm; in ch_init()
375 ossl_ackm_set_tx_max_ack_delay(ch->ackm, ossl_ms2time(ch->tx_max_ack_delay)); in ch_init()
376 ossl_ackm_set_rx_max_ack_delay(ch->ackm, ossl_ms2time(ch->rx_max_ack_delay)); in ch_init()
392 if (ch->ackm != NULL) in ch_cleanup()
396 ossl_ackm_on_pkt_space_discarded(ch->ackm, pn_space); in ch_cleanup()
408 ossl_ackm_free(ch->ackm); in ch_cleanup()
721 if (!ossl_ackm_is_rx_pn_processable(ch->ackm, pn, pn_space)) in rx_late_validate()
753 && ossl_ackm_get_largest_acked(ch->ackm, QUIC_PN_SPACE_APP) >= ch->txku_pn) { in txku_in_progress()
754 OSSL_TIME pto = ossl_ackm_get_pto_duration(ch->ackm); in txku_in_progress()
[all …]
H A Dquic_txp.c546 || args->ackm == NULL in ossl_quic_tx_packetiser_new()
565 txp->args.cfq, txp->args.ackm, txp->args.txpim, in ossl_quic_tx_packetiser_new()
1390 = ossl_ackm_get0_probe_request(txp->args.ackm); in txp_determine_archetype()
1478 = ossl_ackm_get0_probe_request(txp->args.ackm); in txp_should_try_staging()
1493 …if (a.allow_ack && (ossl_ackm_is_ack_desired(txp->args.ackm, pn_space) || (txp->want_ack & (1UL <<… in txp_should_try_staging()
1923 || ossl_ackm_is_ack_desired(txp->args.ackm, pn_space)) in txp_generate_pre_token()
1924 && (ack = ossl_ackm_get_ack_frame(txp->args.ackm, pn_space)) != NULL) { in txp_generate_pre_token()
3121 = ossl_ackm_get0_probe_request(txp->args.ackm); in txp_pkt_commit()
3233 ossl_ackm_get_ack_deadline(txp->args.ackm, pn_space)); in ossl_quic_tx_packetiser_get_deadline()
H A Dquic_channel_local.h93 OSSL_ACKM *ackm; member
H A Dquic_rx_depack.c127 if (!ossl_ackm_on_rx_ack_frame(ch->ackm, &ack, in depack_do_frame_ack()
1475 ossl_ackm_on_rx_packet(ch->ackm, &ackm_data); in ossl_quic_handle_frames()
/src/crypto/openssl/include/internal/
H A Dquic_ackm.h27 void ossl_ackm_free(OSSL_ACKM *ackm);
29 void ossl_ackm_set_loss_detection_deadline_callback(OSSL_ACKM *ackm,
34 void ossl_ackm_set_ack_deadline_callback(OSSL_ACKM *ackm,
46 void ossl_ackm_set_rx_max_ack_delay(OSSL_ACKM *ackm, OSSL_TIME rx_max_ack_delay);
55 void ossl_ackm_set_tx_max_ack_delay(OSSL_ACKM *ackm, OSSL_TIME tx_max_ack_delay);
131 int ossl_ackm_on_tx_packet(OSSL_ACKM *ackm, OSSL_ACKM_TX_PKT *pkt);
132 int ossl_ackm_on_rx_datagram(OSSL_ACKM *ackm, size_t num_bytes);
162 int ossl_ackm_on_rx_packet(OSSL_ACKM *ackm, const OSSL_ACKM_RX_PKT *pkt);
164 int ossl_ackm_on_rx_ack_frame(OSSL_ACKM *ackm, const OSSL_QUIC_FRAME_ACK *ack,
174 int ossl_ackm_on_pkt_space_discarded(OSSL_ACKM *ackm, int pkt_space);
[all …]
H A Dquic_fifd.h30 OSSL_ACKM *ackm; member
55 OSSL_ACKM *ackm,
H A Dquic_txp.h43 OSSL_ACKM *ackm; /* QUIC Acknowledgement Manager */ member
/src/crypto/openssl/test/
H A Dquic_ackm_test.c48 OSSL_ACKM *ackm; member
60 if (h->ackm != NULL) { in helper_destroy()
61 ossl_ackm_free(h->ackm); in helper_destroy()
62 h->ackm = NULL; in helper_destroy()
106 h->ackm = ossl_ackm_new(fake_now, NULL, &h->statm, in helper_init()
109 if (!TEST_ptr(h->ackm)) in helper_init()
360 ossl_ackm_set_loss_detection_deadline_callback(h.ackm, in test_tx_ack_case_actual()
383 if (!TEST_int_eq(ossl_ackm_on_tx_packet(h.ackm, tx), 1)) in test_tx_ack_case_actual()
389 if (!TEST_int_eq(ossl_ackm_on_pkt_space_discarded(h.ackm, space), 1)) in test_tx_ack_case_actual()
405 if (!TEST_int_eq(ossl_ackm_on_rx_ack_frame(h.ackm, &ack, space, fake_time), 1)) in test_tx_ack_case_actual()
[all …]
H A Dquic_fifd_test.c56 OSSL_ACKM *ackm; member
207 if (!TEST_true(ossl_ackm_on_rx_ack_frame(info->ackm, &ack, in test_generic()
250 || !TEST_true(ossl_ackm_on_rx_ack_frame(info->ackm, &ack, in test_generic()
300 if (!TEST_true(ossl_ackm_on_pkt_space_discarded(info->ackm, pn_space))) in test_generic()
333 || !TEST_ptr(info.ackm = ossl_ackm_new(fake_now, NULL, in test_fifd()
338 || !TEST_true(ossl_ackm_on_handshake_confirmed(info.ackm)) in test_fifd()
341 || !TEST_true(ossl_quic_fifd_init(&info.fifd, info.cfq, info.ackm, in test_fifd()
365 ossl_ackm_free(info.ackm); in test_fifd()
H A Dquic_txp_test.c104 ossl_ackm_on_pkt_space_discarded(h->args.ackm, pn_space); in helper_cleanup()
118 ossl_ackm_free(h->args.ackm); in helper_cleanup()
196 if (!TEST_ptr(h->args.ackm = ossl_ackm_new(fake_now, NULL, in helper_init()
587 if (!TEST_true(ossl_ackm_on_rx_packet(h->args.ackm, &rx_pkt))) in schedule_ack()
1149 OSSL_ACKM_PROBE_INFO *probe = ossl_ackm_get0_probe_request(h->args.ackm); in gen_probe_initial()
1177 OSSL_ACKM_PROBE_INFO *probe = ossl_ackm_get0_probe_request(h->args.ackm); in gen_probe_handshake()
1206 OSSL_ACKM_PROBE_INFO *probe = ossl_ackm_get0_probe_request(h->args.ackm); in gen_probe_1rtt()
/src/crypto/openssl/doc/designs/quic-design/
H A Dquic-ackm.md4 ![(Overview block diagram.)](images/ackm.png "QUIC ACK Manager Block Diagram")
102 void ossl_ackm_free(OSSL_ACKM *ackm);
189 int ossl_ackm_on_tx_packet(OSSL_ACKM *ackm, const OSSL_ACKM_TX_PKT *pkt);
206 int ossl_ackm_on_rx_datagram(OSSL_ACKM *ackm, size_t num_bytes);
245 int ossl_ackm_on_rx_packet(OSSL_ACKM *ackm, const OSSL_ACKM_RX_PKT *pkt);
296 int ossl_ackm_on_rx_ack_frame(OSSL_ACKM *ackm, const OSSL_ACKM_ACK *ack,
310 int ossl_ackm_on_pkt_space_discarded(OSSL_ACKM *ackm, int pkt_space);
322 int ossl_ackm_on_handshake_confirmed(OSSL_ACKM *ackm);
330 int ossl_ackm_on_timeout(OSSL_ACKM *ackm);
349 OSSL_TIME ossl_ackm_get_loss_detection_deadline(OSSL_ACKM *ackm);
[all …]
H A Dquic-fifm.md448 QUIC_ACKM *ackm,
H A Dtx-packetiser.md27 OSSL_ACKM *ackm; /* QUIC Acknowledgement Manager */