123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825 |
- /*
- * Copyright 2022 The OpenSSL Project Authors. All Rights Reserved.
- *
- * Licensed under the Apache License 2.0 (the "License"). You may not use
- * this file except in compliance with the License. You can obtain a copy
- * in the file LICENSE in the source distribution or at
- * https://www.openssl.org/source/license.html
- */
- #include <openssl/macros.h>
- #include <openssl/objects.h>
- #include "quic_local.h"
- #include "internal/quic_vlint.h"
- #include "internal/quic_wire.h"
- OSSL_SAFE_MATH_UNSIGNED(uint64_t, uint64_t)
- /*
- * QUIC Wire Format Encoding
- * =========================
- */
- int ossl_quic_wire_encode_padding(WPACKET *pkt, size_t num_bytes)
- {
- /*
- * PADDING is frame type zero, which as a variable-length integer is
- * represented as a single zero byte. As an optimisation, just use memset.
- */
- return WPACKET_memset(pkt, 0, num_bytes);
- }
- static int encode_frame_hdr(WPACKET *pkt, uint64_t frame_type)
- {
- return WPACKET_quic_write_vlint(pkt, frame_type);
- }
- int ossl_quic_wire_encode_frame_ping(WPACKET *pkt)
- {
- return encode_frame_hdr(pkt, OSSL_QUIC_FRAME_TYPE_PING);
- }
- int ossl_quic_wire_encode_frame_ack(WPACKET *pkt,
- uint32_t ack_delay_exponent,
- const OSSL_QUIC_FRAME_ACK *ack)
- {
- uint64_t frame_type = ack->ecn_present ? OSSL_QUIC_FRAME_TYPE_ACK_WITH_ECN
- : OSSL_QUIC_FRAME_TYPE_ACK_WITHOUT_ECN;
- uint64_t largest_ackd, first_ack_range, ack_delay_enc;
- size_t i, num_ack_ranges = ack->num_ack_ranges;
- OSSL_TIME delay;
- if (num_ack_ranges == 0)
- return 0;
- delay = ossl_time_divide(ossl_time_divide(ack->delay_time, OSSL_TIME_US),
- 1UL << ack_delay_exponent);
- ack_delay_enc = ossl_time2ticks(delay);
- largest_ackd = ack->ack_ranges[0].end;
- first_ack_range = ack->ack_ranges[0].end - ack->ack_ranges[0].start;
- if (!encode_frame_hdr(pkt, frame_type)
- || !WPACKET_quic_write_vlint(pkt, largest_ackd)
- || !WPACKET_quic_write_vlint(pkt, ack_delay_enc)
- || !WPACKET_quic_write_vlint(pkt, num_ack_ranges - 1)
- || !WPACKET_quic_write_vlint(pkt, first_ack_range))
- return 0;
- for (i = 1; i < num_ack_ranges; ++i) {
- uint64_t gap, range_len;
- gap = ack->ack_ranges[i - 1].start - ack->ack_ranges[i].end - 2;
- range_len = ack->ack_ranges[i].end - ack->ack_ranges[i].start;
- if (!WPACKET_quic_write_vlint(pkt, gap)
- || !WPACKET_quic_write_vlint(pkt, range_len))
- return 0;
- }
- if (ack->ecn_present)
- if (!WPACKET_quic_write_vlint(pkt, ack->ect0)
- || !WPACKET_quic_write_vlint(pkt, ack->ect1)
- || !WPACKET_quic_write_vlint(pkt, ack->ecnce))
- return 0;
- return 1;
- }
- int ossl_quic_wire_encode_frame_reset_stream(WPACKET *pkt,
- const OSSL_QUIC_FRAME_RESET_STREAM *f)
- {
- if (!encode_frame_hdr(pkt, OSSL_QUIC_FRAME_TYPE_RESET_STREAM)
- || !WPACKET_quic_write_vlint(pkt, f->stream_id)
- || !WPACKET_quic_write_vlint(pkt, f->app_error_code)
- || !WPACKET_quic_write_vlint(pkt, f->final_size))
- return 0;
- return 1;
- }
- int ossl_quic_wire_encode_frame_stop_sending(WPACKET *pkt,
- const OSSL_QUIC_FRAME_STOP_SENDING *f)
- {
- if (!encode_frame_hdr(pkt, OSSL_QUIC_FRAME_TYPE_STOP_SENDING)
- || !WPACKET_quic_write_vlint(pkt, f->stream_id)
- || !WPACKET_quic_write_vlint(pkt, f->app_error_code))
- return 0;
- return 1;
- }
- int ossl_quic_wire_encode_frame_crypto_hdr(WPACKET *pkt,
- const OSSL_QUIC_FRAME_CRYPTO *f)
- {
- if (!encode_frame_hdr(pkt, OSSL_QUIC_FRAME_TYPE_CRYPTO)
- || !WPACKET_quic_write_vlint(pkt, f->offset)
- || !WPACKET_quic_write_vlint(pkt, f->len))
- return 0;
- return 1;
- }
- void *ossl_quic_wire_encode_frame_crypto(WPACKET *pkt,
- const OSSL_QUIC_FRAME_CRYPTO *f)
- {
- unsigned char *p = NULL;
- if (!ossl_quic_wire_encode_frame_crypto_hdr(pkt, f)
- || !WPACKET_allocate_bytes(pkt, f->len, &p))
- return NULL;
- if (f->data != NULL)
- memcpy(p, f->data, f->len);
- return p;
- }
- int ossl_quic_wire_encode_frame_new_token(WPACKET *pkt,
- const unsigned char *token,
- size_t token_len)
- {
- if (!encode_frame_hdr(pkt, OSSL_QUIC_FRAME_TYPE_NEW_TOKEN)
- || !WPACKET_quic_write_vlint(pkt, token_len)
- || !WPACKET_memcpy(pkt, token, token_len))
- return 0;
- return 1;
- }
- int ossl_quic_wire_encode_frame_stream_hdr(WPACKET *pkt,
- const OSSL_QUIC_FRAME_STREAM *f)
- {
- uint64_t frame_type = OSSL_QUIC_FRAME_TYPE_STREAM;
- if (f->offset != 0)
- frame_type |= OSSL_QUIC_FRAME_FLAG_STREAM_OFF;
- if (f->has_explicit_len)
- frame_type |= OSSL_QUIC_FRAME_FLAG_STREAM_LEN;
- if (f->is_fin)
- frame_type |= OSSL_QUIC_FRAME_FLAG_STREAM_FIN;
- if (!encode_frame_hdr(pkt, frame_type)
- || !WPACKET_quic_write_vlint(pkt, f->stream_id))
- return 0;
- if (f->offset != 0 && !WPACKET_quic_write_vlint(pkt, f->offset))
- return 0;
- if (f->has_explicit_len && !WPACKET_quic_write_vlint(pkt, f->len))
- return 0;
- return 1;
- }
- void *ossl_quic_wire_encode_frame_stream(WPACKET *pkt,
- const OSSL_QUIC_FRAME_STREAM *f)
- {
- unsigned char *p = NULL;
- if (!ossl_quic_wire_encode_frame_stream_hdr(pkt, f))
- return NULL;
- if (!WPACKET_allocate_bytes(pkt, f->len, &p))
- return NULL;
- if (f->data != NULL)
- memcpy(p, f->data, f->len);
- return p;
- }
- int ossl_quic_wire_encode_frame_max_data(WPACKET *pkt,
- uint64_t max_data)
- {
- if (!encode_frame_hdr(pkt, OSSL_QUIC_FRAME_TYPE_MAX_DATA)
- || !WPACKET_quic_write_vlint(pkt, max_data))
- return 0;
- return 1;
- }
- int ossl_quic_wire_encode_frame_max_stream_data(WPACKET *pkt,
- uint64_t stream_id,
- uint64_t max_data)
- {
- if (!encode_frame_hdr(pkt, OSSL_QUIC_FRAME_TYPE_MAX_STREAM_DATA)
- || !WPACKET_quic_write_vlint(pkt, stream_id)
- || !WPACKET_quic_write_vlint(pkt, max_data))
- return 0;
- return 1;
- }
- int ossl_quic_wire_encode_frame_max_streams(WPACKET *pkt,
- char is_uni,
- uint64_t max_streams)
- {
- if (!encode_frame_hdr(pkt, is_uni ? OSSL_QUIC_FRAME_TYPE_MAX_STREAMS_UNI
- : OSSL_QUIC_FRAME_TYPE_MAX_STREAMS_BIDI)
- || !WPACKET_quic_write_vlint(pkt, max_streams))
- return 0;
- return 1;
- }
- int ossl_quic_wire_encode_frame_data_blocked(WPACKET *pkt,
- uint64_t max_data)
- {
- if (!encode_frame_hdr(pkt, OSSL_QUIC_FRAME_TYPE_DATA_BLOCKED)
- || !WPACKET_quic_write_vlint(pkt, max_data))
- return 0;
- return 1;
- }
- int ossl_quic_wire_encode_frame_stream_data_blocked(WPACKET *pkt,
- uint64_t stream_id,
- uint64_t max_stream_data)
- {
- if (!encode_frame_hdr(pkt, OSSL_QUIC_FRAME_TYPE_STREAM_DATA_BLOCKED)
- || !WPACKET_quic_write_vlint(pkt, stream_id)
- || !WPACKET_quic_write_vlint(pkt, max_stream_data))
- return 0;
- return 1;
- }
- int ossl_quic_wire_encode_frame_streams_blocked(WPACKET *pkt,
- char is_uni,
- uint64_t max_streams)
- {
- if (!encode_frame_hdr(pkt, is_uni ? OSSL_QUIC_FRAME_TYPE_STREAMS_BLOCKED_UNI
- : OSSL_QUIC_FRAME_TYPE_STREAMS_BLOCKED_BIDI)
- || !WPACKET_quic_write_vlint(pkt, max_streams))
- return 0;
- return 1;
- }
- int ossl_quic_wire_encode_frame_new_conn_id(WPACKET *pkt,
- const OSSL_QUIC_FRAME_NEW_CONN_ID *f)
- {
- if (f->conn_id.id_len > QUIC_MAX_CONN_ID_LEN)
- return 0;
- if (!encode_frame_hdr(pkt, OSSL_QUIC_FRAME_TYPE_NEW_CONN_ID)
- || !WPACKET_quic_write_vlint(pkt, f->seq_num)
- || !WPACKET_quic_write_vlint(pkt, f->retire_prior_to)
- || !WPACKET_put_bytes_u8(pkt, f->conn_id.id_len)
- || !WPACKET_memcpy(pkt, f->conn_id.id, f->conn_id.id_len)
- || !WPACKET_memcpy(pkt, f->stateless_reset_token,
- sizeof(f->stateless_reset_token)))
- return 0;
- return 1;
- }
- int ossl_quic_wire_encode_frame_retire_conn_id(WPACKET *pkt,
- uint64_t seq_num)
- {
- if (!encode_frame_hdr(pkt, OSSL_QUIC_FRAME_TYPE_RETIRE_CONN_ID)
- || !WPACKET_quic_write_vlint(pkt, seq_num))
- return 0;
- return 1;
- }
- int ossl_quic_wire_encode_frame_path_challenge(WPACKET *pkt,
- uint64_t data)
- {
- if (!encode_frame_hdr(pkt, OSSL_QUIC_FRAME_TYPE_PATH_CHALLENGE)
- || !WPACKET_put_bytes_u64(pkt, data))
- return 0;
- return 1;
- }
- int ossl_quic_wire_encode_frame_path_response(WPACKET *pkt,
- uint64_t data)
- {
- if (!encode_frame_hdr(pkt, OSSL_QUIC_FRAME_TYPE_PATH_RESPONSE)
- || !WPACKET_put_bytes_u64(pkt, data))
- return 0;
- return 1;
- }
- int ossl_quic_wire_encode_frame_conn_close(WPACKET *pkt,
- const OSSL_QUIC_FRAME_CONN_CLOSE *f)
- {
- if (!encode_frame_hdr(pkt, f->is_app ? OSSL_QUIC_FRAME_TYPE_CONN_CLOSE_APP
- : OSSL_QUIC_FRAME_TYPE_CONN_CLOSE_TRANSPORT)
- || !WPACKET_quic_write_vlint(pkt, f->error_code))
- return 0;
- if (!f->is_app && !WPACKET_quic_write_vlint(pkt, f->frame_type))
- return 0;
- if (!WPACKET_quic_write_vlint(pkt, f->reason_len)
- || !WPACKET_memcpy(pkt, f->reason, f->reason_len))
- return 0;
- return 1;
- }
- int ossl_quic_wire_encode_frame_handshake_done(WPACKET *pkt)
- {
- return encode_frame_hdr(pkt, OSSL_QUIC_FRAME_TYPE_HANDSHAKE_DONE);
- }
- unsigned char *ossl_quic_wire_encode_transport_param_bytes(WPACKET *pkt,
- uint64_t id,
- const unsigned char *value,
- size_t value_len)
- {
- unsigned char *b = NULL;
- if (!WPACKET_quic_write_vlint(pkt, id)
- || !WPACKET_quic_write_vlint(pkt, value_len)
- || !WPACKET_allocate_bytes(pkt, value_len, (unsigned char **)&b))
- return NULL;
- if (value != NULL)
- memcpy(b, value, value_len);
- return b;
- }
- int ossl_quic_wire_encode_transport_param_int(WPACKET *pkt,
- uint64_t id,
- uint64_t value)
- {
- if (!WPACKET_quic_write_vlint(pkt, id)
- || !WPACKET_quic_write_vlint(pkt, ossl_quic_vlint_encode_len(value))
- || !WPACKET_quic_write_vlint(pkt, value))
- return 0;
- return 1;
- }
- /*
- * QUIC Wire Format Decoding
- * =========================
- */
- int ossl_quic_wire_peek_frame_header(PACKET *pkt, uint64_t *type)
- {
- return PACKET_peek_quic_vlint(pkt, type);
- }
- int ossl_quic_wire_skip_frame_header(PACKET *pkt, uint64_t *type)
- {
- return PACKET_get_quic_vlint(pkt, type);
- }
- static int expect_frame_header_mask(PACKET *pkt,
- uint64_t expected_frame_type,
- uint64_t mask_bits,
- uint64_t *actual_frame_type)
- {
- uint64_t actual_frame_type_;
- if (!ossl_quic_wire_skip_frame_header(pkt, &actual_frame_type_)
- || (actual_frame_type_ & ~mask_bits) != expected_frame_type)
- return 0;
- if (actual_frame_type != NULL)
- *actual_frame_type = actual_frame_type_;
- return 1;
- }
- static int expect_frame_header(PACKET *pkt, uint64_t expected_frame_type)
- {
- uint64_t actual_frame_type;
- if (!ossl_quic_wire_skip_frame_header(pkt, &actual_frame_type)
- || actual_frame_type != expected_frame_type)
- return 0;
- return 1;
- }
- int ossl_quic_wire_peek_frame_ack_num_ranges(const PACKET *orig_pkt,
- uint64_t *total_ranges)
- {
- PACKET pkt = *orig_pkt;
- uint64_t ack_range_count;
- if (!expect_frame_header_mask(&pkt, OSSL_QUIC_FRAME_TYPE_ACK_WITHOUT_ECN,
- 1, NULL)
- || !PACKET_skip_quic_vlint(&pkt)
- || !PACKET_skip_quic_vlint(&pkt)
- || !PACKET_get_quic_vlint(&pkt, &ack_range_count))
- return 0;
- /* (cannot overflow because QUIC vlints can only encode up to 2**62-1) */
- *total_ranges = ack_range_count + 1;
- return 1;
- }
- int ossl_quic_wire_decode_frame_ack(PACKET *pkt,
- uint32_t ack_delay_exponent,
- OSSL_QUIC_FRAME_ACK *ack,
- uint64_t *total_ranges) {
- uint64_t frame_type, largest_ackd, ack_delay_raw;
- uint64_t ack_range_count, first_ack_range, start, end, i;
- /* This call matches both ACK_WITHOUT_ECN and ACK_WITH_ECN. */
- if (!expect_frame_header_mask(pkt, OSSL_QUIC_FRAME_TYPE_ACK_WITHOUT_ECN,
- 1, &frame_type)
- || !PACKET_get_quic_vlint(pkt, &largest_ackd)
- || !PACKET_get_quic_vlint(pkt, &ack_delay_raw)
- || !PACKET_get_quic_vlint(pkt, &ack_range_count)
- || !PACKET_get_quic_vlint(pkt, &first_ack_range))
- return 0;
- if (first_ack_range > largest_ackd)
- return 0;
- start = largest_ackd - first_ack_range;
- if (ack != NULL) {
- int err = 0;
- ack->delay_time
- = ossl_time_multiply(ossl_ticks2time(OSSL_TIME_US),
- safe_mul_uint64_t(ack_delay_raw,
- 1UL << ack_delay_exponent,
- &err));
- if (err)
- ack->delay_time = ossl_time_infinite();
- if (ack->num_ack_ranges > 0) {
- ack->ack_ranges[0].end = largest_ackd;
- ack->ack_ranges[0].start = start;
- }
- }
- for (i = 0; i < ack_range_count; ++i) {
- uint64_t gap, len;
- if (!PACKET_get_quic_vlint(pkt, &gap)
- || !PACKET_get_quic_vlint(pkt, &len))
- return 0;
- end = start - gap - 2;
- if (start < gap + 2 || len > end)
- return 0;
- if (ack != NULL && i + 1 < ack->num_ack_ranges) {
- ack->ack_ranges[i + 1].start = start = end - len;
- ack->ack_ranges[i + 1].end = end;
- }
- }
- if (ack != NULL && ack_range_count + 1 < ack->num_ack_ranges)
- ack->num_ack_ranges = ack_range_count + 1;
- if (total_ranges != NULL)
- *total_ranges = ack_range_count + 1;
- if (frame_type == OSSL_QUIC_FRAME_TYPE_ACK_WITH_ECN) {
- uint64_t ect0, ect1, ecnce;
- if (!PACKET_get_quic_vlint(pkt, &ect0)
- || !PACKET_get_quic_vlint(pkt, &ect1)
- || !PACKET_get_quic_vlint(pkt, &ecnce))
- return 0;
- if (ack != NULL) {
- ack->ect0 = ect0;
- ack->ect1 = ect1;
- ack->ecnce = ecnce;
- ack->ecn_present = 1;
- }
- } else if (ack != NULL) {
- ack->ecn_present = 0;
- }
- return 1;
- }
- int ossl_quic_wire_decode_frame_reset_stream(PACKET *pkt,
- OSSL_QUIC_FRAME_RESET_STREAM *f)
- {
- if (!expect_frame_header(pkt, OSSL_QUIC_FRAME_TYPE_RESET_STREAM)
- || !PACKET_get_quic_vlint(pkt, &f->stream_id)
- || !PACKET_get_quic_vlint(pkt, &f->app_error_code)
- || !PACKET_get_quic_vlint(pkt, &f->final_size))
- return 0;
- return 1;
- }
- int ossl_quic_wire_decode_frame_stop_sending(PACKET *pkt,
- OSSL_QUIC_FRAME_STOP_SENDING *f)
- {
- if (!expect_frame_header(pkt, OSSL_QUIC_FRAME_TYPE_STOP_SENDING)
- || !PACKET_get_quic_vlint(pkt, &f->stream_id)
- || !PACKET_get_quic_vlint(pkt, &f->app_error_code))
- return 0;
- return 1;
- }
- int ossl_quic_wire_decode_frame_crypto(PACKET *pkt,
- OSSL_QUIC_FRAME_CRYPTO *f)
- {
- if (!expect_frame_header(pkt, OSSL_QUIC_FRAME_TYPE_CRYPTO)
- || !PACKET_get_quic_vlint(pkt, &f->offset)
- || !PACKET_get_quic_vlint(pkt, &f->len))
- return 0;
- if (PACKET_remaining(pkt) < f->len)
- return 0;
- f->data = PACKET_data(pkt);
- if (!PACKET_forward(pkt, f->len))
- return 0;
- return 1;
- }
- int ossl_quic_wire_decode_frame_new_token(PACKET *pkt,
- const unsigned char **token,
- size_t *token_len)
- {
- uint64_t token_len_;
- if (!expect_frame_header(pkt, OSSL_QUIC_FRAME_TYPE_NEW_TOKEN)
- || !PACKET_get_quic_vlint(pkt, &token_len_))
- return 0;
- if (token_len_ > SIZE_MAX)
- return 0;
- *token = PACKET_data(pkt);
- *token_len = token_len_;
- if (!PACKET_forward(pkt, token_len_))
- return 0;
- return 1;
- }
- int ossl_quic_wire_decode_frame_stream(PACKET *pkt,
- OSSL_QUIC_FRAME_STREAM *f)
- {
- uint64_t frame_type;
- /* This call matches all STREAM values (low 3 bits are masked). */
- if (!expect_frame_header_mask(pkt, OSSL_QUIC_FRAME_TYPE_STREAM,
- OSSL_QUIC_FRAME_FLAG_STREAM_MASK,
- &frame_type)
- || !PACKET_get_quic_vlint(pkt, &f->stream_id))
- return 0;
- if ((frame_type & OSSL_QUIC_FRAME_FLAG_STREAM_OFF) != 0) {
- if (!PACKET_get_quic_vlint(pkt, &f->offset))
- return 0;
- } else {
- f->offset = 0;
- }
- f->has_explicit_len = ((frame_type & OSSL_QUIC_FRAME_FLAG_STREAM_LEN) != 0);
- f->is_fin = ((frame_type & OSSL_QUIC_FRAME_FLAG_STREAM_FIN) != 0);
- if (f->has_explicit_len) {
- if (!PACKET_get_quic_vlint(pkt, &f->len))
- return 0;
- } else {
- f->len = PACKET_remaining(pkt);
- }
- f->data = PACKET_data(pkt);
- if (!PACKET_forward(pkt, f->len))
- return 0;
- return 1;
- }
- int ossl_quic_wire_decode_frame_max_data(PACKET *pkt,
- uint64_t *max_data)
- {
- if (!expect_frame_header(pkt, OSSL_QUIC_FRAME_TYPE_MAX_DATA)
- || !PACKET_get_quic_vlint(pkt, max_data))
- return 0;
- return 1;
- }
- int ossl_quic_wire_decode_frame_max_stream_data(PACKET *pkt,
- uint64_t *stream_id,
- uint64_t *max_stream_data)
- {
- if (!expect_frame_header(pkt, OSSL_QUIC_FRAME_TYPE_MAX_STREAM_DATA)
- || !PACKET_get_quic_vlint(pkt, stream_id)
- || !PACKET_get_quic_vlint(pkt, max_stream_data))
- return 0;
- return 1;
- }
- int ossl_quic_wire_decode_frame_max_streams(PACKET *pkt,
- uint64_t *max_streams)
- {
- /* This call matches both MAX_STREAMS_BIDI and MAX_STREAMS_UNI. */
- if (!expect_frame_header_mask(pkt, OSSL_QUIC_FRAME_TYPE_MAX_STREAMS_BIDI,
- 1, NULL)
- || !PACKET_get_quic_vlint(pkt, max_streams))
- return 0;
- return 1;
- }
- int ossl_quic_wire_decode_frame_data_blocked(PACKET *pkt,
- uint64_t *max_data)
- {
- if (!expect_frame_header(pkt, OSSL_QUIC_FRAME_TYPE_DATA_BLOCKED)
- || !PACKET_get_quic_vlint(pkt, max_data))
- return 0;
- return 1;
- }
- int ossl_quic_wire_decode_frame_stream_data_blocked(PACKET *pkt,
- uint64_t *stream_id,
- uint64_t *max_stream_data)
- {
- if (!expect_frame_header(pkt, OSSL_QUIC_FRAME_TYPE_STREAM_DATA_BLOCKED)
- || !PACKET_get_quic_vlint(pkt, stream_id)
- || !PACKET_get_quic_vlint(pkt, max_stream_data))
- return 0;
- return 1;
- }
- int ossl_quic_wire_decode_frame_streams_blocked(PACKET *pkt,
- uint64_t *max_streams)
- {
- /* This call matches both STREAMS_BLOCKED_BIDI and STREAMS_BLOCKED_UNI. */
- if (!expect_frame_header_mask(pkt, OSSL_QUIC_FRAME_TYPE_STREAMS_BLOCKED_BIDI,
- 1, NULL)
- || !PACKET_get_quic_vlint(pkt, max_streams))
- return 0;
- return 1;
- }
- int ossl_quic_wire_decode_frame_new_conn_id(PACKET *pkt,
- OSSL_QUIC_FRAME_NEW_CONN_ID *f)
- {
- unsigned int len;
- if (!expect_frame_header(pkt, OSSL_QUIC_FRAME_TYPE_NEW_CONN_ID)
- || !PACKET_get_quic_vlint(pkt, &f->seq_num)
- || !PACKET_get_quic_vlint(pkt, &f->retire_prior_to)
- || !PACKET_get_1(pkt, &len)
- || len > QUIC_MAX_CONN_ID_LEN)
- return 0;
- f->conn_id.id_len = (unsigned char)len;
- if (!PACKET_copy_bytes(pkt, f->conn_id.id, len))
- return 0;
- /* Clear unused bytes to allow consistent memcmp. */
- if (len < QUIC_MAX_CONN_ID_LEN)
- memset(f->conn_id.id + len, 0, QUIC_MAX_CONN_ID_LEN - len);
- if (!PACKET_copy_bytes(pkt, f->stateless_reset_token,
- sizeof(f->stateless_reset_token)))
- return 0;
- return 1;
- }
- int ossl_quic_wire_decode_frame_retire_conn_id(PACKET *pkt,
- uint64_t *seq_num)
- {
- if (!expect_frame_header(pkt, OSSL_QUIC_FRAME_TYPE_RETIRE_CONN_ID)
- || !PACKET_get_quic_vlint(pkt, seq_num))
- return 0;
- return 1;
- }
- int ossl_quic_wire_decode_frame_path_challenge(PACKET *pkt,
- uint64_t *data)
- {
- if (!expect_frame_header(pkt, OSSL_QUIC_FRAME_TYPE_PATH_CHALLENGE)
- || !PACKET_get_net_8(pkt, data))
- return 0;
- return 1;
- }
- int ossl_quic_wire_decode_frame_path_response(PACKET *pkt,
- uint64_t *data)
- {
- if (!expect_frame_header(pkt, OSSL_QUIC_FRAME_TYPE_PATH_RESPONSE)
- || !PACKET_get_net_8(pkt, data))
- return 0;
- return 1;
- }
- int ossl_quic_wire_decode_frame_conn_close(PACKET *pkt,
- OSSL_QUIC_FRAME_CONN_CLOSE *f)
- {
- uint64_t frame_type, reason_len;
- /* This call matches both CONN_CLOSE_TRANSPORT and CONN_CLOSE_APP. */
- if (!expect_frame_header_mask(pkt, OSSL_QUIC_FRAME_TYPE_CONN_CLOSE_TRANSPORT,
- 1, &frame_type)
- || !PACKET_get_quic_vlint(pkt, &f->error_code))
- return 0;
- f->is_app = ((frame_type & 1) != 0);
- if (!f->is_app) {
- if (!PACKET_get_quic_vlint(pkt, &f->frame_type))
- return 0;
- } else {
- f->frame_type = 0;
- }
- if (!PACKET_get_quic_vlint(pkt, &reason_len)
- || reason_len > SIZE_MAX)
- return 0;
- if (!PACKET_get_bytes(pkt, (const unsigned char **)&f->reason, reason_len))
- return 0;
- f->reason_len = reason_len;
- return 1;
- }
- size_t ossl_quic_wire_decode_padding(PACKET *pkt)
- {
- const unsigned char *start = PACKET_data(pkt), *end = PACKET_end(pkt),
- *p = start;
- while (p < end && *p == 0)
- ++p;
- if (!PACKET_forward(pkt, p - start))
- return 0;
- return p - start;
- }
- int ossl_quic_wire_decode_frame_ping(PACKET *pkt)
- {
- return expect_frame_header(pkt, OSSL_QUIC_FRAME_TYPE_PING);
- }
- int ossl_quic_wire_decode_frame_handshake_done(PACKET *pkt)
- {
- return expect_frame_header(pkt, OSSL_QUIC_FRAME_TYPE_HANDSHAKE_DONE);
- }
- int ossl_quic_wire_peek_transport_param(PACKET *pkt, uint64_t *id)
- {
- return PACKET_peek_quic_vlint(pkt, id);
- }
- const unsigned char *ossl_quic_wire_decode_transport_param_bytes(PACKET *pkt,
- uint64_t *id,
- size_t *len)
- {
- uint64_t len_;
- const unsigned char *b = NULL;
- if (!PACKET_get_quic_vlint(pkt, id)
- || !PACKET_get_quic_vlint(pkt, &len_))
- return NULL;
- if (len_ > SIZE_MAX
- || !PACKET_get_bytes(pkt, (const unsigned char **)&b, (size_t)len_))
- return NULL;
- *len = (size_t)len_;
- return b;
- }
- int ossl_quic_wire_decode_transport_param_int(PACKET *pkt,
- uint64_t *id,
- uint64_t *value)
- {
- PACKET sub;
- sub.curr = ossl_quic_wire_decode_transport_param_bytes(pkt,
- id, &sub.remaining);
- if (sub.curr == NULL)
- return 0;
- if (!PACKET_get_quic_vlint(&sub, value))
- return 0;
- return 1;
- }
|