lsquic_parse.h revision 9626cfc2
110c492f0SDmitri Tikhonov/* Copyright (c) 2017 - 2018 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" 850aadb33SDmitri Tikhonov 950aadb33SDmitri Tikhonovstruct lsquic_packet_in; 109626cfc2SDmitri Tikhonovstruct lsquic_packet_out; 119626cfc2SDmitri Tikhonovstruct packin_parse_state; 1250aadb33SDmitri Tikhonovstruct stream_frame; 139626cfc2SDmitri Tikhonovenum packet_out_flags; 1450aadb33SDmitri Tikhonov 1550aadb33SDmitri Tikhonov#define LSQUIC_PARSE_ACK_TIMESTAMPS 0 1650aadb33SDmitri Tikhonov 1750aadb33SDmitri Tikhonovtypedef struct ack_info 1850aadb33SDmitri Tikhonov{ 1950aadb33SDmitri Tikhonov unsigned n_timestamps; /* 0 to 255 */ 2050aadb33SDmitri Tikhonov unsigned n_ranges; /* This is at least 1 */ 2150aadb33SDmitri Tikhonov /* Largest acked is ack_info.ranges[0].high */ 2250aadb33SDmitri Tikhonov lsquic_time_t lack_delta; 23bfc7bfd8SDmitri Tikhonov struct lsquic_packno_range ranges[256]; 2450aadb33SDmitri Tikhonov#if LSQUIC_PARSE_ACK_TIMESTAMPS 2550aadb33SDmitri Tikhonov struct { 2650aadb33SDmitri Tikhonov /* Currently we just read these timestamps in (assuming it is 2750aadb33SDmitri Tikhonov * compiled in, of course), but do not do anything with them. 2850aadb33SDmitri Tikhonov * When we do, the representation of these fields should be 2950aadb33SDmitri Tikhonov * switched to whatever is most appropriate/efficient. 3050aadb33SDmitri Tikhonov */ 3150aadb33SDmitri Tikhonov unsigned char packet_delta; 3250aadb33SDmitri Tikhonov uint64_t delta_usec; 3350aadb33SDmitri Tikhonov } timestamps[255]; 3450aadb33SDmitri Tikhonov#endif 3550aadb33SDmitri Tikhonov} ack_info_t; 3650aadb33SDmitri Tikhonov 3716a9b66aSDmitri Tikhonovstruct short_ack_info 3816a9b66aSDmitri Tikhonov{ 3916a9b66aSDmitri Tikhonov unsigned sai_n_timestamps; 4016a9b66aSDmitri Tikhonov lsquic_time_t sai_lack_delta; 4116a9b66aSDmitri Tikhonov struct lsquic_packno_range sai_range; 4216a9b66aSDmitri Tikhonov}; 4316a9b66aSDmitri Tikhonov 4450aadb33SDmitri Tikhonov#define largest_acked(acki) (+(acki)->ranges[0].high) 4550aadb33SDmitri Tikhonov 4650aadb33SDmitri Tikhonov#define smallest_acked(acki) (+(acki)->ranges[(acki)->n_ranges - 1].low) 4750aadb33SDmitri Tikhonov 4850aadb33SDmitri Tikhonov/* gaf_: generate ACK frame */ 4950aadb33SDmitri Tikhonovstruct lsquic_packno_range; 5050aadb33SDmitri Tikhonovtypedef const struct lsquic_packno_range * 5150aadb33SDmitri Tikhonov (*gaf_rechist_first_f) (void *rechist); 5250aadb33SDmitri Tikhonovtypedef const struct lsquic_packno_range * 5350aadb33SDmitri Tikhonov (*gaf_rechist_next_f) (void *rechist); 5450aadb33SDmitri Tikhonovtypedef lsquic_time_t 5550aadb33SDmitri Tikhonov (*gaf_rechist_largest_recv_f) (void *rechist); 5650aadb33SDmitri Tikhonov 5750aadb33SDmitri Tikhonov/* gsf_: generate stream frame */ 5850aadb33SDmitri Tikhonovtypedef size_t (*gsf_read_f) (void *stream, void *buf, size_t len, int *fin); 5950aadb33SDmitri Tikhonov 6050aadb33SDmitri Tikhonov/* This structure contains functions that parse and generate packets and 6150aadb33SDmitri Tikhonov * frames in version-specific manner. To begin with, there is difference 6250aadb33SDmitri Tikhonov * between GQUIC's little-endian (Q038 and lower) and big-endian formats 639626cfc2SDmitri Tikhonov * (Q039 and higher). Q044 uses different format for packet headers. 6450aadb33SDmitri Tikhonov */ 6550aadb33SDmitri Tikhonovstruct parse_funcs 6650aadb33SDmitri Tikhonov{ 6750aadb33SDmitri Tikhonov /* Return buf length */ 6850aadb33SDmitri Tikhonov int 699626cfc2SDmitri Tikhonov (*pf_gen_reg_pkt_header) (const struct lsquic_conn *, 709626cfc2SDmitri Tikhonov const struct lsquic_packet_out *, unsigned char *, size_t); 7150aadb33SDmitri Tikhonov void 7250aadb33SDmitri Tikhonov (*pf_parse_packet_in_finish) (struct lsquic_packet_in *packet_in, 7350aadb33SDmitri Tikhonov struct packin_parse_state *); 7450aadb33SDmitri Tikhonov enum QUIC_FRAME_TYPE 7550aadb33SDmitri Tikhonov (*pf_parse_frame_type) (unsigned char); 7650aadb33SDmitri Tikhonov /* Return used buffer length */ 7750aadb33SDmitri Tikhonov int 7850aadb33SDmitri Tikhonov (*pf_gen_stream_frame) (unsigned char *buf, size_t bufsz, 7950aadb33SDmitri Tikhonov uint32_t stream_id, uint64_t offset, 80bfc7bfd8SDmitri Tikhonov int fin, size_t size, gsf_read_f, void *stream); 8150aadb33SDmitri Tikhonov int 8250aadb33SDmitri Tikhonov (*pf_parse_stream_frame) (const unsigned char *buf, size_t rem_packet_sz, 8350aadb33SDmitri Tikhonov struct stream_frame *); 8450aadb33SDmitri Tikhonov int 8550aadb33SDmitri Tikhonov (*pf_parse_ack_frame) (const unsigned char *buf, size_t buf_len, 8650aadb33SDmitri Tikhonov ack_info_t *ack_info); 8750aadb33SDmitri Tikhonov int 8850aadb33SDmitri Tikhonov (*pf_gen_ack_frame) (unsigned char *outbuf, size_t outbuf_sz, 8950aadb33SDmitri Tikhonov gaf_rechist_first_f, gaf_rechist_next_f, 9050aadb33SDmitri Tikhonov gaf_rechist_largest_recv_f, void *rechist, lsquic_time_t now, 9116a9b66aSDmitri Tikhonov int *has_missing, lsquic_packno_t *largest_received); 9250aadb33SDmitri Tikhonov int 9350aadb33SDmitri Tikhonov (*pf_gen_stop_waiting_frame) (unsigned char *buf, size_t buf_len, 9450aadb33SDmitri Tikhonov lsquic_packno_t cur_packno, enum lsquic_packno_bits, 9550aadb33SDmitri Tikhonov lsquic_packno_t least_unacked_packno); 9650aadb33SDmitri Tikhonov int 9750aadb33SDmitri Tikhonov (*pf_parse_stop_waiting_frame) (const unsigned char *buf, size_t buf_len, 9850aadb33SDmitri Tikhonov lsquic_packno_t cur_packno, enum lsquic_packno_bits, 9950aadb33SDmitri Tikhonov lsquic_packno_t *least_unacked); 10050aadb33SDmitri Tikhonov int 10150aadb33SDmitri Tikhonov (*pf_skip_stop_waiting_frame) (size_t buf_len, enum lsquic_packno_bits); 10250aadb33SDmitri Tikhonov int 10350aadb33SDmitri Tikhonov (*pf_gen_window_update_frame) (unsigned char *buf, int buf_len, 10450aadb33SDmitri Tikhonov uint32_t stream_id, uint64_t offset); 10550aadb33SDmitri Tikhonov int 10650aadb33SDmitri Tikhonov (*pf_parse_window_update_frame) (const unsigned char *buf, size_t buf_len, 10750aadb33SDmitri Tikhonov uint32_t *stream_id, uint64_t *offset); 10850aadb33SDmitri Tikhonov int 10950aadb33SDmitri Tikhonov (*pf_gen_blocked_frame) (unsigned char *buf, size_t buf_len, 11050aadb33SDmitri Tikhonov uint32_t stream_id); 11150aadb33SDmitri Tikhonov int 11250aadb33SDmitri Tikhonov (*pf_parse_blocked_frame) (const unsigned char *buf, size_t buf_len, 11350aadb33SDmitri Tikhonov uint32_t *stream_id); 11450aadb33SDmitri Tikhonov int 11550aadb33SDmitri Tikhonov (*pf_gen_rst_frame) (unsigned char *buf, size_t buf_len, uint32_t stream_id, 11650aadb33SDmitri Tikhonov uint64_t offset, uint32_t error_code); 11750aadb33SDmitri Tikhonov int 11850aadb33SDmitri Tikhonov (*pf_parse_rst_frame) (const unsigned char *buf, size_t buf_len, 11950aadb33SDmitri Tikhonov uint32_t *stream_id, uint64_t *offset, uint32_t *error_code); 12050aadb33SDmitri Tikhonov int 12150aadb33SDmitri Tikhonov (*pf_gen_connect_close_frame) (unsigned char *buf, int buf_len, 12250aadb33SDmitri Tikhonov uint32_t error_code, const char *reason, int reason_len); 12350aadb33SDmitri Tikhonov int 12450aadb33SDmitri Tikhonov (*pf_parse_connect_close_frame) (const unsigned char *buf, size_t buf_len, 12550aadb33SDmitri Tikhonov uint32_t *error_code, uint16_t *reason_length, 12650aadb33SDmitri Tikhonov uint8_t *reason_offset); 12750aadb33SDmitri Tikhonov int 12850aadb33SDmitri Tikhonov (*pf_gen_goaway_frame) (unsigned char *buf, size_t buf_len, 12950aadb33SDmitri Tikhonov uint32_t error_code, uint32_t last_good_stream_id, 13050aadb33SDmitri Tikhonov const char *reason, size_t reason_len); 13150aadb33SDmitri Tikhonov int 13250aadb33SDmitri Tikhonov (*pf_parse_goaway_frame) (const unsigned char *buf, size_t buf_len, 13350aadb33SDmitri Tikhonov uint32_t *error_code, uint32_t *last_good_stream_id, 13450aadb33SDmitri Tikhonov uint16_t *reason_length, const char **reason); 13550aadb33SDmitri Tikhonov int 13650aadb33SDmitri Tikhonov (*pf_gen_ping_frame) (unsigned char *buf, int buf_len); 137a4e24689SBob Perper#ifndef NDEBUG 13850aadb33SDmitri Tikhonov /* These float reading and writing functions assume `mem' has at least 13950aadb33SDmitri Tikhonov * 2 bytes. 14050aadb33SDmitri Tikhonov */ 14150aadb33SDmitri Tikhonov void 14250aadb33SDmitri Tikhonov (*pf_write_float_time16) (lsquic_time_t time_us, void *mem); 14350aadb33SDmitri Tikhonov uint64_t 14450aadb33SDmitri Tikhonov (*pf_read_float_time16) (const void *mem); 145a4e24689SBob Perper#endif 14650aadb33SDmitri Tikhonov size_t 14750aadb33SDmitri Tikhonov (*pf_calc_stream_frame_header_sz) (uint32_t stream_id, uint64_t offset); 148c51ce338SDmitri Tikhonov void 149c51ce338SDmitri Tikhonov (*pf_turn_on_fin) (unsigned char *); 1509626cfc2SDmitri Tikhonov 1519626cfc2SDmitri Tikhonov size_t 1529626cfc2SDmitri Tikhonov (*pf_packout_size) (const struct lsquic_conn *, 1539626cfc2SDmitri Tikhonov const struct lsquic_packet_out *); 1549626cfc2SDmitri Tikhonov 1559626cfc2SDmitri Tikhonov size_t 1569626cfc2SDmitri Tikhonov (*pf_packout_header_size) (const struct lsquic_conn *, 1579626cfc2SDmitri Tikhonov enum packet_out_flags); 15850aadb33SDmitri Tikhonov}; 15950aadb33SDmitri Tikhonov 16050aadb33SDmitri Tikhonovextern const struct parse_funcs lsquic_parse_funcs_gquic_le; 16150aadb33SDmitri Tikhonov/* Q039 and later are big-endian: */ 16250aadb33SDmitri Tikhonovextern const struct parse_funcs lsquic_parse_funcs_gquic_Q039; 1639626cfc2SDmitri Tikhonovextern const struct parse_funcs lsquic_parse_funcs_gquic_Q044; 16450aadb33SDmitri Tikhonov 16550aadb33SDmitri Tikhonov#define select_pf_by_ver(ver) ( \ 166052a1c28SDmitri Tikhonov ((1 << (ver)) & (1 << LSQVER_035)) \ 16797028223SDmitri Tikhonov ? &lsquic_parse_funcs_gquic_le \ 1689626cfc2SDmitri Tikhonov : (ver) < LSQVER_044 \ 1699626cfc2SDmitri Tikhonov ? &lsquic_parse_funcs_gquic_Q039 \ 1709626cfc2SDmitri Tikhonov : &lsquic_parse_funcs_gquic_Q044) 17150aadb33SDmitri Tikhonov 17250aadb33SDmitri Tikhonovint 1739626cfc2SDmitri Tikhonovlsquic_gquic_parse_packet_in_begin (struct lsquic_packet_in *, size_t length, 17450aadb33SDmitri Tikhonov int is_server, struct packin_parse_state *); 17550aadb33SDmitri Tikhonov 1769626cfc2SDmitri Tikhonovint 1779626cfc2SDmitri Tikhonovlsquic_iquic_parse_packet_in_long_begin (struct lsquic_packet_in *, 1789626cfc2SDmitri Tikhonov size_t length, int is_server, struct packin_parse_state *state); 1799626cfc2SDmitri Tikhonov 1809626cfc2SDmitri Tikhonovint 1819626cfc2SDmitri Tikhonovlsquic_iquic_parse_packet_in_short_begin (struct lsquic_packet_in *, 1829626cfc2SDmitri Tikhonov size_t length, int is_server, struct packin_parse_state *state); 1839626cfc2SDmitri Tikhonov 18450aadb33SDmitri Tikhonovenum QUIC_FRAME_TYPE 18550aadb33SDmitri Tikhonovparse_frame_type_gquic_Q035_thru_Q039 (unsigned char first_byte); 18650aadb33SDmitri Tikhonov 18750aadb33SDmitri Tikhonovsize_t 18850aadb33SDmitri Tikhonovcalc_stream_frame_header_sz_gquic (uint32_t stream_id, uint64_t offset); 18950aadb33SDmitri Tikhonov 1909626cfc2SDmitri Tikhonovsize_t 1919626cfc2SDmitri Tikhonovlsquic_gquic_packout_size (const struct lsquic_conn *, 1929626cfc2SDmitri Tikhonov const struct lsquic_packet_out *); 1939626cfc2SDmitri Tikhonov 1949626cfc2SDmitri Tikhonovsize_t 1959626cfc2SDmitri Tikhonovlsquic_gquic_packout_header_size (const struct lsquic_conn *conn, 1969626cfc2SDmitri Tikhonov enum packet_out_flags flags); 1979626cfc2SDmitri Tikhonov 1989626cfc2SDmitri Tikhonovsize_t 1999626cfc2SDmitri Tikhonovlsquic_gquic_po_header_sz (enum packet_out_flags flags); 2009626cfc2SDmitri Tikhonov 20150aadb33SDmitri Tikhonov/* This maps two bits as follows: 20250aadb33SDmitri Tikhonov * 00 -> 1 20350aadb33SDmitri Tikhonov * 01 -> 2 20450aadb33SDmitri Tikhonov * 10 -> 4 20550aadb33SDmitri Tikhonov * 11 -> 6 20650aadb33SDmitri Tikhonov * 20750aadb33SDmitri Tikhonov * Assumes that only two low bits are set. 20850aadb33SDmitri Tikhonov */ 20950aadb33SDmitri Tikhonov#define twobit_to_1246(bits) ((bits) * 2 + !(bits)) 21050aadb33SDmitri Tikhonov 21150aadb33SDmitri Tikhonov/* This maps two bits as follows: 21250aadb33SDmitri Tikhonov * 00 -> 1 21350aadb33SDmitri Tikhonov * 01 -> 2 21450aadb33SDmitri Tikhonov * 10 -> 4 21550aadb33SDmitri Tikhonov * 11 -> 8 21650aadb33SDmitri Tikhonov * 21750aadb33SDmitri Tikhonov * Assumes that only two low bits are set. 21850aadb33SDmitri Tikhonov */ 21950aadb33SDmitri Tikhonov#define twobit_to_1248(bits) (1 << (bits)) 22050aadb33SDmitri Tikhonov 22150aadb33SDmitri Tikhonovchar * 22250aadb33SDmitri Tikhonovacki2str (const struct ack_info *acki, size_t *sz); 22350aadb33SDmitri Tikhonov 224c51ce338SDmitri Tikhonovvoid 225c51ce338SDmitri Tikhonovlsquic_turn_on_fin_Q035_thru_Q039 (unsigned char *); 226c51ce338SDmitri Tikhonov 22750aadb33SDmitri Tikhonov#endif 228