Home
last modified time | relevance | path

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

/openssl/ssl/quic/
H A Dquic_ackm.c769 now = ackm->now(ackm->now_arg); in ackm_detect_and_remove_lost_pkts()
854 return ossl_time_add(ackm->now(ackm->now_arg), duration); in ackm_get_pto_time_and_space()
980 ackm->cc_method->on_data_lost_finished(ackm->cc_data, flags); in ackm_on_pkts_lost()
1016 ackm->cc_method->on_data_acked(ackm->cc_data, &ainfo); in ackm_on_pkts_acked()
1052 return ackm; in ossl_ackm_new()
1109 ackm->cc_method->on_data_sent(ackm->cc_data, pkt->num_bytes); in ossl_ackm_on_tx_packet()
1141 ackm->cc_method->on_ecn(ackm->cc_data, &ecn_info); in ackm_process_ecn()
1187 OSSL_TIME now = ackm->now(ackm->now_arg), ack_delay; in ossl_ackm_on_rx_ack_frame()
1254 ackm->cc_method->on_data_invalidated(ackm->cc_data, in ossl_ackm_on_pkt_space_discarded()
1383 && ossl_time_compare(ackm->now(ackm->now_arg), in ossl_ackm_is_ack_desired()
[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.c246 if ((ch->ackm = ossl_ackm_new(get_time, ch, &ch->statm, in ch_init()
268 txp_args.ackm = ch->ackm; in ch_init()
369 if (ch->ackm != NULL) in ch_cleanup()
385 ossl_ackm_free(ch->ackm); in ch_cleanup()
655 OSSL_TIME pto = ossl_ackm_get_pto_duration(ch->ackm); in txku_in_progress()
793 pto = ossl_ackm_get_pto_duration(ch->ackm); in rxku_detected()
1393 ossl_ackm_set_rx_max_ack_delay(ch->ackm, in ch_on_transport_params()
1942 ossl_ackm_on_timeout(ch->ackm); in ossl_quic_channel_subtick()
2734 ossl_ackm_on_pkt_space_discarded(ch->ackm, pn_space); in ch_discard_el()
2774 ossl_ackm_on_handshake_confirmed(ch->ackm); in ossl_quic_channel_on_handshake_confirmed()
[all …]
H A Dquic_channel_local.h82 OSSL_ACKM *ackm; member
H A Dquic_txp.c462 || args->ackm == NULL in ossl_quic_tx_packetiser_new()
480 txp->args.cfq, txp->args.ackm, txp->args.txpim, in ossl_quic_tx_packetiser_new()
1293 = ossl_ackm_get0_probe_request(txp->args.ackm); in txp_determine_archetype()
1380 = ossl_ackm_get0_probe_request(txp->args.ackm); in txp_should_try_staging()
1395 if (a.allow_ack && (ossl_ackm_is_ack_desired(txp->args.ackm, pn_space) in txp_should_try_staging()
1838 || ossl_ackm_is_ack_desired(txp->args.ackm, pn_space)) in txp_generate_pre_token()
1839 && (ack = ossl_ackm_get_ack_frame(txp->args.ackm, pn_space)) != NULL) { in txp_generate_pre_token()
3034 = ossl_ackm_get0_probe_request(txp->args.ackm); in txp_pkt_commit()
3146 ossl_ackm_get_ack_deadline(txp->args.ackm, pn_space)); in ossl_quic_tx_packetiser_get_deadline()
H A Dquic_rx_depack.c126 if (!ossl_ackm_on_rx_ack_frame(ch->ackm, &ack, in depack_do_frame_ack()
1464 ossl_ackm_on_rx_packet(ch->ackm, &ackm_data); in ossl_quic_handle_frames()
/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,
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);
176 int ossl_ackm_on_handshake_confirmed(OSSL_ACKM *ackm);
177 int ossl_ackm_on_timeout(OSSL_ACKM *ackm);
179 OSSL_TIME ossl_ackm_get_loss_detection_deadline(OSSL_ACKM *ackm);
209 int ossl_ackm_is_ack_desired(OSSL_ACKM *ackm, int pkt_space);
282 int ossl_ackm_mark_packet_pseudo_lost(OSSL_ACKM *ackm,
[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
/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()
108 if (!TEST_ptr(h->ackm)) in helper_init()
356 ossl_ackm_set_loss_detection_deadline_callback(h.ackm, in test_tx_ack_case_actual()
428 probe = *ossl_ackm_get0_probe_request(h.ackm); in test_tx_ack_case_actual()
443 if (!TEST_int_eq(ossl_ackm_on_timeout(h.ackm), 1)) in test_tx_ack_case_actual()
448 probe = *ossl_ackm_get0_probe_request(h.ackm); in test_tx_ack_case_actual()
[all …]
H A Dquic_fifd_test.c52 OSSL_ACKM *ackm; member
203 if (!TEST_true(ossl_ackm_on_rx_ack_frame(info->ackm, &ack, in test_generic()
246 || !TEST_true(ossl_ackm_on_rx_ack_frame(info->ackm, &ack, in test_generic()
296 if (!TEST_true(ossl_ackm_on_pkt_space_discarded(info->ackm, pn_space))) in test_generic()
329 || !TEST_ptr(info.ackm = ossl_ackm_new(fake_now, NULL, in test_fifd()
333 || !TEST_true(ossl_ackm_on_handshake_confirmed(info.ackm)) in test_fifd()
336 || !TEST_true(ossl_quic_fifd_init(&info.fifd, info.cfq, info.ackm, in test_fifd()
360 ossl_ackm_free(info.ackm); in test_fifd()
H A Dquic_txp_test.c90 ossl_ackm_on_pkt_space_discarded(h->args.ackm, pn_space); in helper_cleanup()
104 ossl_ackm_free(h->args.ackm); in helper_cleanup()
182 if (!TEST_ptr(h->args.ackm = ossl_ackm_new(fake_now, NULL, in helper_init()
565 if (!TEST_true(ossl_ackm_on_rx_packet(h->args.ackm, &rx_pkt))) in schedule_ack()
1127 OSSL_ACKM_PROBE_INFO *probe = ossl_ackm_get0_probe_request(h->args.ackm); in gen_probe_initial()
1155 OSSL_ACKM_PROBE_INFO *probe = ossl_ackm_get0_probe_request(h->args.ackm); in gen_probe_handshake()
1184 OSSL_ACKM_PROBE_INFO *probe = ossl_ackm_get0_probe_request(h->args.ackm); in gen_probe_1rtt()
/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);
206 int ossl_ackm_on_rx_datagram(OSSL_ACKM *ackm, size_t num_bytes);
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);
390 int ossl_ackm_is_ack_desired(OSSL_ACKM *ackm, int pkt_space);
471 int ossl_ackm_get_probe_request(OSSL_ACKM *ackm, int clear,
496 void ossl_ackm_set_loss_detection_deadline_callback(OSSL_ACKM *ackm,
[all …]
H A Dquic-fifm.md448 QUIC_ACKM *ackm,
H A Dtx-packetiser.md27 OSSL_ACKM *ackm; /* QUIC Acknowledgement Manager */

Completed in 147 milliseconds