/openssl/ssl/quic/ |
H A D | quic_wire.c | 74 first_ack_range = ack->ack_ranges[0].end - ack->ack_ranges[0].start; in ossl_quic_wire_encode_frame_ack() 86 gap = ack->ack_ranges[i - 1].start - ack->ack_ranges[i].end - 2; in ossl_quic_wire_encode_frame_ack() 87 range_len = ack->ack_ranges[i].end - ack->ack_ranges[i].start; in ossl_quic_wire_encode_frame_ack() 94 if (ack->ecn_present) in ossl_quic_wire_encode_frame_ack() 541 if (ack != NULL) { in ossl_quic_wire_decode_frame_ack() 543 ack->delay_time in ossl_quic_wire_decode_frame_ack() 568 if (ack != NULL && i + 1 < ack->num_ack_ranges) { in ossl_quic_wire_decode_frame_ack() 574 if (ack != NULL && ack_range_count + 1 < ack->num_ack_ranges) in ossl_quic_wire_decode_frame_ack() 588 if (ack != NULL) { in ossl_quic_wire_decode_frame_ack() 594 } else if (ack != NULL) { in ossl_quic_wire_decode_frame_ack() [all …]
|
H A D | quic_ackm.c | 677 assert(ack->num_ack_ranges > 0); in ackm_detect_and_remove_newly_acked_pkts() 704 if (ridx >= ack->num_ack_ranges) { in ackm_detect_and_remove_newly_acked_pkts() 1192 ack_delay = ack->delay_time; in ossl_ackm_on_rx_ack_frame() 1207 if (ack->ecn_present) in ossl_ackm_on_rx_ack_frame() 1394 for (i = 0; i < ack->num_ack_ranges; ++i) in ack_contains() 1612 ack->num_ack_ranges = i; in ackm_fill_rx_ack_ranges() 1618 OSSL_QUIC_FRAME_ACK *ack = &ackm->ack[pkt_space]; in ossl_ackm_get_ack_frame() local 1626 ack->delay_time = in ossl_ackm_get_ack_frame() 1629 ack->delay_time = ossl_time_zero(); in ossl_ackm_get_ack_frame() 1634 ack->ecn_present = 1; in ossl_ackm_get_ack_frame() [all …]
|
H A D | qlog_event_helpers.c | 210 OSSL_QUIC_FRAME_ACK ack; in log_frame_actual() local 241 ack.ack_ranges = ack_ranges; in log_frame_actual() 242 ack.num_ack_ranges = OSSL_NELEM(ack_ranges); in log_frame_actual() 248 if (ack.ecn_present) { in log_frame_actual() 249 QLOG_U64("ect1", ack.ect0); in log_frame_actual() 250 QLOG_U64("ect0", ack.ect1); in log_frame_actual() 251 QLOG_U64("ce", ack.ecnce); in log_frame_actual() 254 for (i = 0; i < ack.num_ack_ranges; ++i) { in log_frame_actual() 256 QLOG_U64(NULL, ack.ack_ranges[i].start); in log_frame_actual() 257 if (ack.ack_ranges[i].end != ack.ack_ranges[i].start) in log_frame_actual() [all …]
|
H A D | quic_trace.c | 78 OSSL_QUIC_FRAME_ACK ack; in frame_ack() local 91 ack.ack_ranges = ack_ranges; in frame_ack() 92 ack.num_ack_ranges = (size_t)total_ranges; in frame_ack() 95 if (!ossl_quic_wire_decode_frame_ack(pkt, 0, &ack, NULL)) in frame_ack() 99 (unsigned long long)ack.ack_ranges[0].end); in frame_ack() 101 (unsigned long long)ossl_time2ticks(ack.delay_time)); in frame_ack() 105 (unsigned long long)(ack.ack_ranges[0].end in frame_ack() 106 - ack.ack_ranges[0].start)); in frame_ack() 109 (unsigned long long)(ack.ack_ranges[i - 1].start in frame_ack() 112 (unsigned long long)(ack.ack_ranges[i].end in frame_ack() [all …]
|
H A D | quic_rx_depack.c | 66 OSSL_QUIC_FRAME_ACK ack; in depack_do_frame_ack() local 86 ack.ack_ranges = ch->ack_range_scratch; in depack_do_frame_ack() 87 ack.num_ack_ranges = (size_t)total_ranges; in depack_do_frame_ack() 89 if (!ossl_quic_wire_decode_frame_ack(pkt, ack_delay_exp, &ack, NULL)) in depack_do_frame_ack() 95 && ack.ack_ranges[0].end >= ch->txku_pn) { in depack_do_frame_ack() 126 if (!ossl_ackm_on_rx_ack_frame(ch->ackm, &ack, in depack_do_frame_ack()
|
H A D | quic_txp.c | 113 void (*ack_tx_cb)(const OSSL_QUIC_FRAME_ACK *ack, 621 void (*cb)(const OSSL_QUIC_FRAME_ACK *ack, in ossl_quic_tx_packetiser_set_ack_tx_cb() argument 1829 const OSSL_QUIC_FRAME_ACK *ack; in txp_generate_pre_token() local 1839 && (ack = ossl_ackm_get_ack_frame(txp->args.ackm, pn_space)) != NULL) { in txp_generate_pre_token() 1846 ack2 = *ack; in txp_generate_pre_token() 1857 if (ack->num_ack_ranges > 0) in txp_generate_pre_token() 1858 tpkt->ackm_pkt.largest_acked = ack->ack_ranges[0].end; in txp_generate_pre_token()
|
H A D | quic_channel.c | 100 static void ch_on_txp_ack_tx(const OSSL_QUIC_FRAME_ACK *ack, uint32_t pn_space, 841 static void ch_on_txp_ack_tx(const OSSL_QUIC_FRAME_ACK *ack, uint32_t pn_space, in ch_on_txp_ack_tx() argument 847 || !ossl_quic_frame_ack_contains_pn(ack, ch->rxku_trigger_pn)) in ch_on_txp_ack_tx()
|
/openssl/test/ |
H A D | quic_ackm_test.c | 343 OSSL_QUIC_FRAME_ACK ack = {0}; in test_tx_ack_case_actual() local 400 ack.num_ack_ranges = c->num_ack_ranges; in test_tx_ack_case_actual() 521 OSSL_QUIC_FRAME_ACK ack = {0}; in test_tx_ack_time_script() local 571 ack.ack_ranges = &ack_range; in test_tx_ack_time_script() 572 ack.num_ack_ranges = 1; in test_tx_ack_time_script() 909 const OSSL_QUIC_FRAME_ACK *ack; in test_rx_ack_actual() local 1004 ack = ossl_ackm_get_ack_frame(h.ackm, space); in test_rx_ack_actual() 1007 if (!TEST_ptr(ack)) in test_rx_ack_actual() 1013 for (i = 0; i < ack->num_ack_ranges; ++i) { in test_rx_ack_actual() 1014 if (!TEST_uint64_t_eq(ack->ack_ranges[i].start, in test_rx_ack_actual() [all …]
|
H A D | quic_fifd_test.c | 115 OSSL_QUIC_FRAME_ACK ack = {0}; in test_generic() local 191 ack.ack_ranges = ack_ranges; in test_generic() 192 ack.num_ack_ranges = 1; in test_generic() 203 if (!TEST_true(ossl_ackm_on_rx_ack_frame(info->ackm, &ack, in test_generic() 242 ack.ack_ranges = ack_ranges; in test_generic() 243 ack.num_ack_ranges = 1; in test_generic() 246 || !TEST_true(ossl_ackm_on_rx_ack_frame(info->ackm, &ack, in test_generic()
|
H A D | quic_txp_test.c | 65 OSSL_QUIC_FRAME_ACK ack; member 1394 h.frame.ack.ack_ranges = h.ack_ranges; in run_script() 1395 h.frame.ack.num_ack_ranges = OSSL_NELEM(h.ack_ranges); in run_script() 1398 &h.frame.ack, in run_script()
|
/openssl/include/internal/ |
H A D | quic_wire.h | 165 int ossl_quic_frame_ack_contains_pn(const OSSL_QUIC_FRAME_ACK *ack, QUIC_PN pn); 262 const OSSL_QUIC_FRAME_ACK *ack); 547 OSSL_QUIC_FRAME_ACK *ack,
|
H A D | quic_txp.h | 211 void (*cb)(const OSSL_QUIC_FRAME_ACK *ack,
|
H A D | quic_ackm.h | 164 int ossl_ackm_on_rx_ack_frame(OSSL_ACKM *ackm, const OSSL_QUIC_FRAME_ACK *ack,
|
/openssl/doc/designs/quic-design/ |
H A D | rx-depacketizer.md | 33 1. [Collect information for the ACK Manager](#collect-information-for-the-ack-manager) 103 | 0x02 | [ack 0x02] | [ACK manager] [^1] | | ✔ | ✔ |… 104 | 0x03 | [ack 0x03] | [ACK manager] [^1] | | ✔ | ✔ |… 176 [ack 0x02]: https://datatracker.ietf.org/doc/html/rfc9000#section-19.3 177 [ack 0x03]: https://datatracker.ietf.org/doc/html/rfc9000#section-19.3
|
H A D | quic-connID-retire.md | 70 before sending the retirement ack.
|
H A D | tx-packetiser.md | 265 | 0x02 | ack 0x02 | ✓ | ✓ | | ✓ | ✓ | ✓ | … 266 | 0x03 | ack 0x03 | ✓ | ✓ | | ✓ | ✓ | ✓ | … 314 | N | Not ack-eliciting. |
|
H A D | quic-ackm.md | 296 int ossl_ackm_on_rx_ack_frame(OSSL_ACKM *ackm, const OSSL_ACKM_ACK *ack,
|
H A D | quic-fault-injector.md | 307 * pre-parsed ack data that can be modified as required.
|
/openssl/test/recipes/75-test_quicapi_data/ |
H A D | ssltraceref-zlib.txt | 100 First ack range: 0 276 First ack range: 0 281 First ack range: 1
|
H A D | ssltraceref.txt | 98 First ack range: 0 274 First ack range: 0 279 First ack range: 1
|
/openssl/apps/ |
H A D | s_client.c | 268 int ack; member 276 p->ack = !SSL_session_reused(s) && hn != NULL; in ssl_servername_cb()
|