lsquic_parse.h revision a74702c6
1a74702c6SGeorge Wang/* Copyright (c) 2017 - 2022 LiteSpeed Technologies Inc.  See LICENSE. */
250aadb33SDmitri Tikhonov#ifndef LSQUIC_PARSE_H
350aadb33SDmitri Tikhonov#define LSQUIC_PARSE_H 1
450aadb33SDmitri Tikhonov
550aadb33SDmitri Tikhonov#include <stdint.h>
650aadb33SDmitri Tikhonov
750aadb33SDmitri Tikhonov#include "lsquic_packet_common.h"
85392f7a3SLiteSpeed Tech#include "lsquic_packet_gquic.h"
9f07b3eaeSTyler Young#include "lsquic_shared_support.h"
1050aadb33SDmitri Tikhonov
115392f7a3SLiteSpeed Techstruct lsquic_conn;
1250aadb33SDmitri Tikhonovstruct lsquic_packet_in;
139626cfc2SDmitri Tikhonovstruct lsquic_packet_out;
149626cfc2SDmitri Tikhonovstruct packin_parse_state;
1550aadb33SDmitri Tikhonovstruct stream_frame;
165392f7a3SLiteSpeed Techstruct lsquic_cid;
179626cfc2SDmitri Tikhonovenum packet_out_flags;
185392f7a3SLiteSpeed Techenum lsquic_version;
195392f7a3SLiteSpeed Techenum stream_dir;
2050aadb33SDmitri Tikhonov
2150aadb33SDmitri Tikhonov
225392f7a3SLiteSpeed Techstruct ack_info
2350aadb33SDmitri Tikhonov{
245392f7a3SLiteSpeed Tech    enum packnum_space pns;
255392f7a3SLiteSpeed Tech    enum {
265392f7a3SLiteSpeed Tech        AI_ECN        = 1 << 0, /* ecn_counts[1,2,3] contain ECN counts */
275392f7a3SLiteSpeed Tech        AI_TRUNCATED  = 1 << 1, /* There were more ranges to parse, but we
285392f7a3SLiteSpeed Tech                                 * ran out of elements in `ranges'.
295392f7a3SLiteSpeed Tech                                 */
305392f7a3SLiteSpeed Tech    }               flags;
3150aadb33SDmitri Tikhonov    unsigned    n_ranges;       /* This is at least 1 */
3250aadb33SDmitri Tikhonov                                /* Largest acked is ack_info.ranges[0].high */
3350aadb33SDmitri Tikhonov    lsquic_time_t   lack_delta;
345392f7a3SLiteSpeed Tech    uint64_t        ecn_counts[4];
35bfc7bfd8SDmitri Tikhonov    struct lsquic_packno_range ranges[256];
3616a9b66aSDmitri Tikhonov};
3716a9b66aSDmitri Tikhonov
3850aadb33SDmitri Tikhonov#define largest_acked(acki) (+(acki)->ranges[0].high)
3950aadb33SDmitri Tikhonov
4050aadb33SDmitri Tikhonov#define smallest_acked(acki) (+(acki)->ranges[(acki)->n_ranges - 1].low)
4150aadb33SDmitri Tikhonov
425392f7a3SLiteSpeed Tech/* Chrome may send an empty ACK frame when it closes a connection.
435392f7a3SLiteSpeed Tech * We do not know why it occurs -- perhaps a bug in Chrome.
445392f7a3SLiteSpeed Tech */
455392f7a3SLiteSpeed Tech/* This macro cannot be used in IETF QUIC as zero is a valid packet number.
465392f7a3SLiteSpeed Tech * Hopefully the Chrome bug will have been fixed by then.
475392f7a3SLiteSpeed Tech */
485392f7a3SLiteSpeed Tech#define empty_ack_frame(acki) (largest_acked(acki) == 0)
495392f7a3SLiteSpeed Tech
5050aadb33SDmitri Tikhonov/* gaf_: generate ACK frame */
5150aadb33SDmitri Tikhonovstruct lsquic_packno_range;
5250aadb33SDmitri Tikhonovtypedef const struct lsquic_packno_range *
5350aadb33SDmitri Tikhonov    (*gaf_rechist_first_f)          (void *rechist);
5450aadb33SDmitri Tikhonovtypedef const struct lsquic_packno_range *
5550aadb33SDmitri Tikhonov    (*gaf_rechist_next_f)           (void *rechist);
5650aadb33SDmitri Tikhonovtypedef lsquic_time_t
5750aadb33SDmitri Tikhonov    (*gaf_rechist_largest_recv_f)   (void *rechist);
5850aadb33SDmitri Tikhonov
5950aadb33SDmitri Tikhonov/* gsf_: generate stream frame */
6050aadb33SDmitri Tikhonovtypedef size_t (*gsf_read_f) (void *stream, void *buf, size_t len, int *fin);
6150aadb33SDmitri Tikhonov
6250aadb33SDmitri Tikhonov/* This structure contains functions that parse and generate packets and
6350aadb33SDmitri Tikhonov * frames in version-specific manner.  To begin with, there is difference
6450aadb33SDmitri Tikhonov * between GQUIC's little-endian (Q038 and lower) and big-endian formats
655392f7a3SLiteSpeed Tech * (Q039 and higher).  Q046 and higher uses different format for packet headers.
6650aadb33SDmitri Tikhonov */
6750aadb33SDmitri Tikhonovstruct parse_funcs
6850aadb33SDmitri Tikhonov{
6950aadb33SDmitri Tikhonov    /* Return buf length */
7050aadb33SDmitri Tikhonov    int
719626cfc2SDmitri Tikhonov    (*pf_gen_reg_pkt_header) (const struct lsquic_conn *,
7249f1f4f6SDmitri Tikhonov                const struct lsquic_packet_out *, unsigned char *, size_t,
7349f1f4f6SDmitri Tikhonov                /* In Q050 and IETF QUIC, these are set: */
7449f1f4f6SDmitri Tikhonov                unsigned *packno_off, unsigned *packno_len);
7550aadb33SDmitri Tikhonov    void
7650aadb33SDmitri Tikhonov    (*pf_parse_packet_in_finish) (struct lsquic_packet_in *packet_in,
7750aadb33SDmitri Tikhonov                                                struct packin_parse_state *);
786aba801dSDmitri Tikhonov    enum quic_frame_type
79feca77f5SDmitri Tikhonov    (*pf_parse_frame_type) (const unsigned char *, size_t);
8014e3680dSDmitri Tikhonov    /* Return used buffer length or a negative value if there was not enough
8114e3680dSDmitri Tikhonov     * room to write the stream frame.  In the latter case, the negative of
8214e3680dSDmitri Tikhonov     * the negative return value is the number of bytes required.  The
8314e3680dSDmitri Tikhonov     * exception is -1, which is a generic error code, as we always need
8414e3680dSDmitri Tikhonov     * more than 1 byte to write a STREAM frame.
8514e3680dSDmitri Tikhonov     */
86b8fa6195SDmitri Tikhonov    /* pf_gen_stream_frame and pf_gen_crypto_frame must be adjacent so that
87b8fa6195SDmitri Tikhonov     * they can be cast to an array.
88b8fa6195SDmitri Tikhonov     */
8950aadb33SDmitri Tikhonov    int
9050aadb33SDmitri Tikhonov    (*pf_gen_stream_frame) (unsigned char *buf, size_t bufsz,
915392f7a3SLiteSpeed Tech                            lsquic_stream_id_t stream_id, uint64_t offset,
92bfc7bfd8SDmitri Tikhonov                            int fin, size_t size, gsf_read_f, void *stream);
93b8fa6195SDmitri Tikhonov    /* The two "UNUSED" parameters are here so that it matches
94b8fa6195SDmitri Tikhonov     * pf_gen_stream_frame.
95b8fa6195SDmitri Tikhonov     */
96b8fa6195SDmitri Tikhonov    int
97b8fa6195SDmitri Tikhonov    (*pf_gen_crypto_frame) (unsigned char *buf, size_t bufsz,
98b8fa6195SDmitri Tikhonov                            lsquic_stream_id_t UNUSED_1, uint64_t offset,
99b8fa6195SDmitri Tikhonov                            int UNUSED_2, size_t size, gsf_read_f, void *stream);
100b8fa6195SDmitri Tikhonov    /* pf_parse_stream_frame and pf_parse_crypto_frame must be adjacent so that
101b8fa6195SDmitri Tikhonov     * they can be cast to an array.
102b8fa6195SDmitri Tikhonov     */
10350aadb33SDmitri Tikhonov    int
10450aadb33SDmitri Tikhonov    (*pf_parse_stream_frame) (const unsigned char *buf, size_t rem_packet_sz,
10550aadb33SDmitri Tikhonov                                                    struct stream_frame *);
10650aadb33SDmitri Tikhonov    int
1075392f7a3SLiteSpeed Tech    (*pf_parse_crypto_frame) (const unsigned char *buf, size_t rem_packet_sz,
1085392f7a3SLiteSpeed Tech                                                    struct stream_frame *);
1092f2f4363SDmitri Tikhonov    /* Return true if STREAM frame extends to the end of the packet and thus
1102f2f4363SDmitri Tikhonov     * does not contain a Length field (no update).
1112f2f4363SDmitri Tikhonov     */
1122f2f4363SDmitri Tikhonov    int
1132f2f4363SDmitri Tikhonov    (*pf_dec_stream_frame_size) (unsigned char *buf, size_t new_size);
1145392f7a3SLiteSpeed Tech    int
11550aadb33SDmitri Tikhonov    (*pf_parse_ack_frame) (const unsigned char *buf, size_t buf_len,
1165392f7a3SLiteSpeed Tech                                    struct ack_info *ack_info, uint8_t exp);
11750aadb33SDmitri Tikhonov    int
11850aadb33SDmitri Tikhonov    (*pf_gen_ack_frame) (unsigned char *outbuf, size_t outbuf_sz,
11950aadb33SDmitri Tikhonov                gaf_rechist_first_f, gaf_rechist_next_f,
12050aadb33SDmitri Tikhonov                gaf_rechist_largest_recv_f, void *rechist, lsquic_time_t now,
1215392f7a3SLiteSpeed Tech                int *has_missing, lsquic_packno_t *largest_received,
1225392f7a3SLiteSpeed Tech                const uint64_t *ecn_counts);
12350aadb33SDmitri Tikhonov    int
12450aadb33SDmitri Tikhonov    (*pf_gen_stop_waiting_frame) (unsigned char *buf, size_t buf_len,
125c7d81ce1SDmitri Tikhonov                    lsquic_packno_t cur_packno, enum packno_bits,
12650aadb33SDmitri Tikhonov                    lsquic_packno_t least_unacked_packno);
12750aadb33SDmitri Tikhonov    int
12850aadb33SDmitri Tikhonov    (*pf_parse_stop_waiting_frame) (const unsigned char *buf, size_t buf_len,
129c7d81ce1SDmitri Tikhonov                     lsquic_packno_t cur_packno, enum packno_bits,
13050aadb33SDmitri Tikhonov                     lsquic_packno_t *least_unacked);
13150aadb33SDmitri Tikhonov    int
132c7d81ce1SDmitri Tikhonov    (*pf_skip_stop_waiting_frame) (size_t buf_len, enum packno_bits);
13350aadb33SDmitri Tikhonov    int
13450aadb33SDmitri Tikhonov    (*pf_gen_window_update_frame) (unsigned char *buf, int buf_len,
1355392f7a3SLiteSpeed Tech                                lsquic_stream_id_t stream_id, uint64_t offset);
13650aadb33SDmitri Tikhonov    int
13750aadb33SDmitri Tikhonov    (*pf_parse_window_update_frame) (const unsigned char *buf, size_t buf_len,
1385392f7a3SLiteSpeed Tech                              lsquic_stream_id_t *stream_id, uint64_t *offset);
1395392f7a3SLiteSpeed Tech    /* The third argument for pf_gen_blocked_frame() and pf_parse_blocked_frame()
1405392f7a3SLiteSpeed Tech     * is Stream ID for GQUIC and offset for IETF QUIC.  Since both of these are
1415392f7a3SLiteSpeed Tech     * uint64_t, we'll use the same function pointer.  Just have to be a little
1425392f7a3SLiteSpeed Tech     * careful here.
1435392f7a3SLiteSpeed Tech     */
14450aadb33SDmitri Tikhonov    int
14550aadb33SDmitri Tikhonov    (*pf_gen_blocked_frame) (unsigned char *buf, size_t buf_len,
1465392f7a3SLiteSpeed Tech                                                lsquic_stream_id_t stream_id);
14750aadb33SDmitri Tikhonov    int
14850aadb33SDmitri Tikhonov    (*pf_parse_blocked_frame) (const unsigned char *buf, size_t buf_len,
1495392f7a3SLiteSpeed Tech        /* TODO: rename third argument when dropping GQUIC */
1505392f7a3SLiteSpeed Tech                                                lsquic_stream_id_t *stream_id);
1515392f7a3SLiteSpeed Tech    unsigned
1525392f7a3SLiteSpeed Tech    (*pf_blocked_frame_size) (uint64_t);
1535392f7a3SLiteSpeed Tech    unsigned
1545392f7a3SLiteSpeed Tech    (*pf_rst_frame_size) (lsquic_stream_id_t stream_id, uint64_t final_size,
1555392f7a3SLiteSpeed Tech                                                        uint64_t error_code);
15650aadb33SDmitri Tikhonov    int
1575392f7a3SLiteSpeed Tech    (*pf_gen_rst_frame) (unsigned char *buf, size_t buf_len,
1585392f7a3SLiteSpeed Tech        lsquic_stream_id_t stream_id, uint64_t offset, uint64_t error_code);
15950aadb33SDmitri Tikhonov    int
16050aadb33SDmitri Tikhonov    (*pf_parse_rst_frame) (const unsigned char *buf, size_t buf_len,
1615392f7a3SLiteSpeed Tech        lsquic_stream_id_t *stream_id, uint64_t *offset, uint64_t *error_code);
1625392f7a3SLiteSpeed Tech    int
1635392f7a3SLiteSpeed Tech    (*pf_parse_stop_sending_frame) (const unsigned char *buf, size_t buf_len,
1645392f7a3SLiteSpeed Tech        lsquic_stream_id_t *stream_id, uint64_t *error_code);
1655392f7a3SLiteSpeed Tech    unsigned
1665392f7a3SLiteSpeed Tech    (*pf_stop_sending_frame_size) (lsquic_stream_id_t, uint64_t);
1675392f7a3SLiteSpeed Tech    int
1685392f7a3SLiteSpeed Tech    (*pf_gen_stop_sending_frame) (unsigned char *buf, size_t buf_len,
1695392f7a3SLiteSpeed Tech                                    lsquic_stream_id_t, uint64_t error_code);
1707d09751dSDmitri Tikhonov    size_t
1717d09751dSDmitri Tikhonov    (*pf_connect_close_frame_size) (int app_error, unsigned error_code,
1727d09751dSDmitri Tikhonov                                unsigned frame_type, size_t reason_len);
17350aadb33SDmitri Tikhonov    int
1745392f7a3SLiteSpeed Tech    (*pf_gen_connect_close_frame) (unsigned char *buf, size_t buf_len,
1755392f7a3SLiteSpeed Tech        int app_error, unsigned error_code, const char *reason, int reason_len);
17650aadb33SDmitri Tikhonov    int
17750aadb33SDmitri Tikhonov    (*pf_parse_connect_close_frame) (const unsigned char *buf, size_t buf_len,
1785392f7a3SLiteSpeed Tech                int *app_error, uint64_t *error_code, uint16_t *reason_length,
17950aadb33SDmitri Tikhonov                uint8_t *reason_offset);
18050aadb33SDmitri Tikhonov    int
18150aadb33SDmitri Tikhonov    (*pf_gen_goaway_frame) (unsigned char *buf, size_t buf_len,
1825392f7a3SLiteSpeed Tech                uint32_t error_code, lsquic_stream_id_t last_good_stream_id,
18350aadb33SDmitri Tikhonov                const char *reason, size_t reason_len);
18450aadb33SDmitri Tikhonov    int
18550aadb33SDmitri Tikhonov    (*pf_parse_goaway_frame) (const unsigned char *buf, size_t buf_len,
1865392f7a3SLiteSpeed Tech                uint32_t *error_code, lsquic_stream_id_t *last_good_stream_id,
18750aadb33SDmitri Tikhonov                uint16_t *reason_length, const char **reason);
18850aadb33SDmitri Tikhonov    int
18950aadb33SDmitri Tikhonov    (*pf_gen_ping_frame) (unsigned char *buf, int buf_len);
1905392f7a3SLiteSpeed Tech    int
1915392f7a3SLiteSpeed Tech    (*pf_parse_path_chal_frame) (const unsigned char *buf, size_t,
1925392f7a3SLiteSpeed Tech                                                            uint64_t *chal);
1935392f7a3SLiteSpeed Tech    int
1945392f7a3SLiteSpeed Tech    (*pf_parse_path_resp_frame) (const unsigned char *buf, size_t,
1955392f7a3SLiteSpeed Tech                                                            uint64_t *resp);
19650aadb33SDmitri Tikhonov    /* These float reading and writing functions assume `mem' has at least
19750aadb33SDmitri Tikhonov     * 2 bytes.
19850aadb33SDmitri Tikhonov     */
19950aadb33SDmitri Tikhonov    void
20050aadb33SDmitri Tikhonov    (*pf_write_float_time16) (lsquic_time_t time_us, void *mem);
20150aadb33SDmitri Tikhonov    uint64_t
20250aadb33SDmitri Tikhonov    (*pf_read_float_time16) (const void *mem);
2035392f7a3SLiteSpeed Tech    ssize_t
2045392f7a3SLiteSpeed Tech    (*pf_generate_simple_prst) (const lsquic_cid_t *cid,
2055392f7a3SLiteSpeed Tech                                                    unsigned char *, size_t);
20650aadb33SDmitri Tikhonov    size_t
2075392f7a3SLiteSpeed Tech    (*pf_calc_stream_frame_header_sz) (lsquic_stream_id_t stream_id,
2085392f7a3SLiteSpeed Tech                                            uint64_t offset, unsigned data_sz);
2095392f7a3SLiteSpeed Tech    size_t
2107a8b2eceSDmitri Tikhonov    (*pf_calc_crypto_frame_header_sz) (uint64_t offset, unsigned data_sz);
211c51ce338SDmitri Tikhonov    void
212c51ce338SDmitri Tikhonov    (*pf_turn_on_fin) (unsigned char *);
2139626cfc2SDmitri Tikhonov
2149626cfc2SDmitri Tikhonov    size_t
2159626cfc2SDmitri Tikhonov    (*pf_packout_size) (const struct lsquic_conn *,
2169626cfc2SDmitri Tikhonov                                            const struct lsquic_packet_out *);
2179626cfc2SDmitri Tikhonov
2185392f7a3SLiteSpeed Tech    /* This returns the high estimate of the header size.  Note that it
2195392f7a3SLiteSpeed Tech     * cannot account for the size of the token in the IETF QUIC Initial
2205392f7a3SLiteSpeed Tech     * packets as it does not know it.
2215392f7a3SLiteSpeed Tech     */
2229626cfc2SDmitri Tikhonov    size_t
2235392f7a3SLiteSpeed Tech    (*pf_packout_max_header_size) (const struct lsquic_conn *,
2244429f8eaSDmitri Tikhonov                    enum packet_out_flags, size_t dcid_len, enum header_type);
225c7d81ce1SDmitri Tikhonov
226c7d81ce1SDmitri Tikhonov    enum packno_bits
227c7d81ce1SDmitri Tikhonov    (*pf_calc_packno_bits) (lsquic_packno_t packno,
228c7d81ce1SDmitri Tikhonov                        lsquic_packno_t least_unacked, uint64_t n_in_flight);
229c7d81ce1SDmitri Tikhonov    unsigned
230c7d81ce1SDmitri Tikhonov    (*pf_packno_bits2len) (enum packno_bits);
2315392f7a3SLiteSpeed Tech
2325392f7a3SLiteSpeed Tech    int
2335392f7a3SLiteSpeed Tech    (*pf_parse_max_data) (const unsigned char *, size_t, uint64_t *);
2345392f7a3SLiteSpeed Tech    int
2355392f7a3SLiteSpeed Tech    (*pf_gen_max_data_frame) (unsigned char *, size_t, uint64_t);
2365392f7a3SLiteSpeed Tech    unsigned
2375392f7a3SLiteSpeed Tech    (*pf_max_data_frame_size) (uint64_t);
23803e6b668SDmitri Tikhonov    /*
23903e6b668SDmitri Tikhonov     * Returns number of bytes parsed on success or negative value on error:
24003e6b668SDmitri Tikhonov     *  -1  Out of input buffer
24103e6b668SDmitri Tikhonov     *  -2  Invalid CID length value
24203e6b668SDmitri Tikhonov     */
2435392f7a3SLiteSpeed Tech    int
2445392f7a3SLiteSpeed Tech    (*pf_parse_new_conn_id) (const unsigned char *, size_t, uint64_t *,
2455392f7a3SLiteSpeed Tech                        uint64_t *, lsquic_cid_t *, const unsigned char **);
2465392f7a3SLiteSpeed Tech    unsigned
2475392f7a3SLiteSpeed Tech    (*pf_stream_blocked_frame_size) (lsquic_stream_id_t, uint64_t);
2485392f7a3SLiteSpeed Tech    int
2495392f7a3SLiteSpeed Tech    (*pf_gen_stream_blocked_frame) (unsigned char *buf, size_t,
2505392f7a3SLiteSpeed Tech                                                lsquic_stream_id_t, uint64_t);
2515392f7a3SLiteSpeed Tech    int
2525392f7a3SLiteSpeed Tech    (*pf_parse_stream_blocked_frame) (const unsigned char *buf, size_t,
2535392f7a3SLiteSpeed Tech                                            lsquic_stream_id_t *, uint64_t *);
2545392f7a3SLiteSpeed Tech    unsigned
2555392f7a3SLiteSpeed Tech    (*pf_max_stream_data_frame_size) (lsquic_stream_id_t, uint64_t);
2565392f7a3SLiteSpeed Tech    int
2575392f7a3SLiteSpeed Tech    (*pf_gen_max_stream_data_frame) (unsigned char *buf, size_t,
2585392f7a3SLiteSpeed Tech                                                lsquic_stream_id_t, uint64_t);
2595392f7a3SLiteSpeed Tech    int
2605392f7a3SLiteSpeed Tech    (*pf_parse_max_stream_data_frame) (const unsigned char *buf, size_t,
2615392f7a3SLiteSpeed Tech                                            lsquic_stream_id_t *, uint64_t *);
2625392f7a3SLiteSpeed Tech    int
2635392f7a3SLiteSpeed Tech    (*pf_parse_new_token_frame) (const unsigned char *buf, size_t,
2645392f7a3SLiteSpeed Tech                            const unsigned char **token, size_t *token_size);
2655392f7a3SLiteSpeed Tech    size_t
2665392f7a3SLiteSpeed Tech    (*pf_new_connection_id_frame_size) (unsigned seqno, unsigned cid_len);
2675392f7a3SLiteSpeed Tech    int
2685392f7a3SLiteSpeed Tech    (*pf_gen_new_connection_id_frame) (unsigned char *buf, size_t,
2695392f7a3SLiteSpeed Tech                unsigned seqno, const struct lsquic_cid *,
2705392f7a3SLiteSpeed Tech                const unsigned char *token, size_t);
2715392f7a3SLiteSpeed Tech    size_t
2725392f7a3SLiteSpeed Tech    (*pf_retire_cid_frame_size) (uint64_t);
2735392f7a3SLiteSpeed Tech    int
2745392f7a3SLiteSpeed Tech    (*pf_gen_retire_cid_frame) (unsigned char *buf, size_t, uint64_t);
2755392f7a3SLiteSpeed Tech    int
2765392f7a3SLiteSpeed Tech    (*pf_parse_retire_cid_frame) (const unsigned char *buf, size_t, uint64_t *);
2775392f7a3SLiteSpeed Tech    size_t
2785392f7a3SLiteSpeed Tech    (*pf_new_token_frame_size) (size_t);
2795392f7a3SLiteSpeed Tech    int
2805392f7a3SLiteSpeed Tech    (*pf_gen_new_token_frame) (unsigned char *buf, size_t,
2815392f7a3SLiteSpeed Tech                                        const unsigned char *token, size_t);
2825392f7a3SLiteSpeed Tech    int
2835392f7a3SLiteSpeed Tech    (*pf_gen_streams_blocked_frame) (unsigned char *buf, size_t buf_len,
2845392f7a3SLiteSpeed Tech                                        enum stream_dir, uint64_t);
2855392f7a3SLiteSpeed Tech    int
2865392f7a3SLiteSpeed Tech    (*pf_parse_streams_blocked_frame) (const unsigned char *buf, size_t buf_len,
2875392f7a3SLiteSpeed Tech                                        enum stream_dir *, uint64_t *);
2885392f7a3SLiteSpeed Tech    unsigned
2895392f7a3SLiteSpeed Tech    (*pf_streams_blocked_frame_size) (uint64_t);
2905392f7a3SLiteSpeed Tech    int
2915392f7a3SLiteSpeed Tech    (*pf_gen_max_streams_frame) (unsigned char *buf, size_t buf_len,
2925392f7a3SLiteSpeed Tech                                        enum stream_dir, uint64_t);
2935392f7a3SLiteSpeed Tech    int
2945392f7a3SLiteSpeed Tech    (*pf_parse_max_streams_frame) (const unsigned char *buf, size_t buf_len,
2955392f7a3SLiteSpeed Tech                                        enum stream_dir *, uint64_t *);
2965392f7a3SLiteSpeed Tech    unsigned
2975392f7a3SLiteSpeed Tech    (*pf_max_streams_frame_size) (uint64_t);
2985392f7a3SLiteSpeed Tech    unsigned
2995392f7a3SLiteSpeed Tech    (*pf_path_chal_frame_size) (void);
3005392f7a3SLiteSpeed Tech    int
3015392f7a3SLiteSpeed Tech    (*pf_gen_path_chal_frame) (unsigned char *, size_t, uint64_t chal);
3025392f7a3SLiteSpeed Tech    unsigned
3035392f7a3SLiteSpeed Tech    (*pf_path_resp_frame_size) (void);
3045392f7a3SLiteSpeed Tech    int
3055392f7a3SLiteSpeed Tech    (*pf_gen_path_resp_frame) (unsigned char *, size_t, uint64_t resp);
3069fc12041SDmitri Tikhonov    int
3079fc12041SDmitri Tikhonov    (*pf_gen_handshake_done_frame) (unsigned char *buf, size_t buf_len);
3089fc12041SDmitri Tikhonov    int
3099fc12041SDmitri Tikhonov    (*pf_parse_handshake_done_frame) (const unsigned char *buf, size_t buf_len);
3109fc12041SDmitri Tikhonov    unsigned
3119fc12041SDmitri Tikhonov    (*pf_handshake_done_frame_size) (void);
312feca77f5SDmitri Tikhonov    int
313feca77f5SDmitri Tikhonov    (*pf_gen_ack_frequency_frame) (unsigned char *buf, size_t buf_len,
3143a537672SDmitri Tikhonov        uint64_t seqno, uint64_t pack_tol, uint64_t upd_mad, int ignore);
315feca77f5SDmitri Tikhonov    int
316feca77f5SDmitri Tikhonov    (*pf_parse_ack_frequency_frame) (const unsigned char *buf, size_t buf_len,
3173a537672SDmitri Tikhonov        uint64_t *seqno, uint64_t *pack_tol, uint64_t *upd_mad, int *ignore);
318feca77f5SDmitri Tikhonov    unsigned
319feca77f5SDmitri Tikhonov    (*pf_ack_frequency_frame_size) (uint64_t seqno, uint64_t pack_tol,
3203a537672SDmitri Tikhonov        uint64_t upd_mad /* Don't need to pass `ignore' */);
321afe3d363SDmitri Tikhonov    int
322afe3d363SDmitri Tikhonov    (*pf_gen_timestamp_frame) (unsigned char *buf, size_t buf_len, uint64_t);
323afe3d363SDmitri Tikhonov    int
324afe3d363SDmitri Tikhonov    (*pf_parse_timestamp_frame) (const unsigned char *buf, size_t, uint64_t *);
325b1a7c3f9SDmitri Tikhonov    int
326b1a7c3f9SDmitri Tikhonov    (*pf_parse_datagram_frame) (const unsigned char *buf, size_t, const void **,
327b1a7c3f9SDmitri Tikhonov                                                                    size_t *);
328b1a7c3f9SDmitri Tikhonov    int
329b1a7c3f9SDmitri Tikhonov    (*pf_gen_datagram_frame) (unsigned char *, size_t bufsz, size_t min_sz,
330b1a7c3f9SDmitri Tikhonov        size_t max_sz, ssize_t (*)(struct lsquic_conn *, void *, size_t),
331b1a7c3f9SDmitri Tikhonov        struct lsquic_conn *);
332b1a7c3f9SDmitri Tikhonov    unsigned
333b1a7c3f9SDmitri Tikhonov    (*pf_datagram_frame_size) (size_t);
33450aadb33SDmitri Tikhonov};
33550aadb33SDmitri Tikhonov
336f07b3eaeSTyler YoungLSQUIC_EXTERN const struct parse_funcs lsquic_parse_funcs_gquic_Q043;
337f07b3eaeSTyler YoungLSQUIC_EXTERN const struct parse_funcs lsquic_parse_funcs_gquic_Q046;
338f07b3eaeSTyler YoungLSQUIC_EXTERN const struct parse_funcs lsquic_parse_funcs_gquic_Q050;
339f07b3eaeSTyler YoungLSQUIC_EXTERN const struct parse_funcs lsquic_parse_funcs_ietf_v1;
34050aadb33SDmitri Tikhonov
3415392f7a3SLiteSpeed Tech#define select_pf_by_ver(ver) (                                             \
342fb96f4ddSDmitri Tikhonov    (1 << (ver)) & (1 << LSQVER_043)                     ?                  \
343fb96f4ddSDmitri Tikhonov                                         &lsquic_parse_funcs_gquic_Q043 :   \
3447a8b2eceSDmitri Tikhonov    (1 << (ver)) & (1 << LSQVER_046)                            ?           \
3455392f7a3SLiteSpeed Tech                                         &lsquic_parse_funcs_gquic_Q046 :   \
346084338b1SGeorge Wang    (1 << (ver)) & (1 << LSQVER_050)                            ?           \
3477a8b2eceSDmitri Tikhonov                                         &lsquic_parse_funcs_gquic_Q050 :   \
3485392f7a3SLiteSpeed Tech    &lsquic_parse_funcs_ietf_v1)
34950aadb33SDmitri Tikhonov
3505392f7a3SLiteSpeed Tech/* This function is gQUIC-version independent */
35150aadb33SDmitri Tikhonovint
3529626cfc2SDmitri Tikhonovlsquic_gquic_parse_packet_in_begin (struct lsquic_packet_in *, size_t length,
3535392f7a3SLiteSpeed Tech                int is_server, unsigned cid_len, struct packin_parse_state *);
35450aadb33SDmitri Tikhonov
3559626cfc2SDmitri Tikhonovint
3565392f7a3SLiteSpeed Techlsquic_Q046_parse_packet_in_short_begin (struct lsquic_packet_in *, size_t length,
3575392f7a3SLiteSpeed Tech                int is_server, unsigned, struct packin_parse_state *);
3589626cfc2SDmitri Tikhonov
3599626cfc2SDmitri Tikhonovint
3605392f7a3SLiteSpeed Techlsquic_Q046_parse_packet_in_long_begin (struct lsquic_packet_in *, size_t length,
3615392f7a3SLiteSpeed Tech                int is_server, unsigned, struct packin_parse_state *);
3629626cfc2SDmitri Tikhonov
3637a8b2eceSDmitri Tikhonovint
3647a8b2eceSDmitri Tikhonovlsquic_Q050_parse_packet_in_long_begin (struct lsquic_packet_in *, size_t length,
3657a8b2eceSDmitri Tikhonov                int is_server, unsigned, struct packin_parse_state *);
3667a8b2eceSDmitri Tikhonov
3676aba801dSDmitri Tikhonovenum quic_frame_type
368feca77f5SDmitri Tikhonovlsquic_parse_frame_type_gquic_Q035_thru_Q046 (const unsigned char *, size_t);
36950aadb33SDmitri Tikhonov
370feca77f5SDmitri Tikhonovextern const enum quic_frame_type lsquic_iquic_byte2type[0x40];
3715392f7a3SLiteSpeed Tech
37250aadb33SDmitri Tikhonovsize_t
373a5fa05f9SDmitri Tikhonovlsquic_calc_stream_frame_header_sz_gquic (lsquic_stream_id_t stream_id,
3745392f7a3SLiteSpeed Tech                                                    uint64_t offset, unsigned);
37550aadb33SDmitri Tikhonov
3769626cfc2SDmitri Tikhonovsize_t
3779626cfc2SDmitri Tikhonovlsquic_gquic_packout_size (const struct lsquic_conn *,
3789626cfc2SDmitri Tikhonov                                            const struct lsquic_packet_out *);
3799626cfc2SDmitri Tikhonov
3809626cfc2SDmitri Tikhonovsize_t
3819626cfc2SDmitri Tikhonovlsquic_gquic_packout_header_size (const struct lsquic_conn *conn,
3824429f8eaSDmitri Tikhonov                enum packet_out_flags flags, size_t unused, enum header_type);
3835392f7a3SLiteSpeed Tech
3845392f7a3SLiteSpeed Techsize_t
3855392f7a3SLiteSpeed Techlsquic_gquic_po_header_sz (enum packet_out_flags flags);
3865392f7a3SLiteSpeed Tech
3875392f7a3SLiteSpeed Techsize_t
3885392f7a3SLiteSpeed Techlsquic_gquic_packout_size (const struct lsquic_conn *,
3895392f7a3SLiteSpeed Tech                                            const struct lsquic_packet_out *);
3909626cfc2SDmitri Tikhonov
3919626cfc2SDmitri Tikhonovsize_t
3929626cfc2SDmitri Tikhonovlsquic_gquic_po_header_sz (enum packet_out_flags flags);
3939626cfc2SDmitri Tikhonov
39450aadb33SDmitri Tikhonov/* This maps two bits as follows:
39550aadb33SDmitri Tikhonov *  00  ->  1
39650aadb33SDmitri Tikhonov *  01  ->  2
39750aadb33SDmitri Tikhonov *  10  ->  4
39850aadb33SDmitri Tikhonov *  11  ->  6
39950aadb33SDmitri Tikhonov *
40050aadb33SDmitri Tikhonov * Assumes that only two low bits are set.
40150aadb33SDmitri Tikhonov */
40250aadb33SDmitri Tikhonov#define twobit_to_1246(bits) ((bits) * 2 + !(bits))
40350aadb33SDmitri Tikhonov
40450aadb33SDmitri Tikhonov/* This maps two bits as follows:
40550aadb33SDmitri Tikhonov *  00  ->  1
40650aadb33SDmitri Tikhonov *  01  ->  2
40750aadb33SDmitri Tikhonov *  10  ->  4
40850aadb33SDmitri Tikhonov *  11  ->  8
40950aadb33SDmitri Tikhonov *
41050aadb33SDmitri Tikhonov * Assumes that only two low bits are set.
41150aadb33SDmitri Tikhonov */
41250aadb33SDmitri Tikhonov#define twobit_to_1248(bits) (1 << (bits))
41350aadb33SDmitri Tikhonov
414de46bf2fSDmitri Tikhonov#define ECN_COUNTS_STR  " ECT(0): 01234567879012345678790;" \
415de46bf2fSDmitri Tikhonov                        " ECT(1): 01234567879012345678790;" \
416de46bf2fSDmitri Tikhonov                        " CE: 01234567879012345678790"
417de46bf2fSDmitri Tikhonov#define RANGES_TRUNCATED_STR " ranges truncated! "
418de46bf2fSDmitri Tikhonov
419de46bf2fSDmitri Tikhonov#define MAX_ACKI_STR_SZ (256 * (3 /* [-] */ + 20 /* ~0ULL */ * 2) \
420de46bf2fSDmitri Tikhonov                    + sizeof(ECN_COUNTS_STR) + sizeof(RANGES_TRUNCATED_STR))
421de46bf2fSDmitri Tikhonov
422de46bf2fSDmitri Tikhonovvoid
423de46bf2fSDmitri Tikhonovlsquic_acki2str (const struct ack_info *acki, char *, size_t);
42450aadb33SDmitri Tikhonov
425c51ce338SDmitri Tikhonovvoid
4267a8b2eceSDmitri Tikhonovlsquic_turn_on_fin_Q035_thru_Q046 (unsigned char *);
427c51ce338SDmitri Tikhonov
428c7d81ce1SDmitri Tikhonovenum packno_bits
429c7d81ce1SDmitri Tikhonovlsquic_gquic_calc_packno_bits (lsquic_packno_t packno,
430c7d81ce1SDmitri Tikhonov                        lsquic_packno_t least_unacked, uint64_t n_in_flight);
431c7d81ce1SDmitri Tikhonov
432c7d81ce1SDmitri Tikhonovunsigned
433c7d81ce1SDmitri Tikhonovlsquic_gquic_packno_bits2len (enum packno_bits);
434c7d81ce1SDmitri Tikhonov
435de46bf2fSDmitri Tikhonovint
436de46bf2fSDmitri Tikhonovlsquic_merge_acks (struct ack_info *dst, const struct ack_info *src);
437de46bf2fSDmitri Tikhonov
43850aadb33SDmitri Tikhonov#endif
439