lsquic_parse.h revision 052a1c28
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; 1050aadb33SDmitri Tikhonovstruct stream_frame; 1150aadb33SDmitri Tikhonov 1250aadb33SDmitri Tikhonov#define LSQUIC_PARSE_ACK_TIMESTAMPS 0 1350aadb33SDmitri Tikhonov 1450aadb33SDmitri Tikhonovtypedef struct ack_info 1550aadb33SDmitri Tikhonov{ 1650aadb33SDmitri Tikhonov unsigned n_timestamps; /* 0 to 255 */ 1750aadb33SDmitri Tikhonov unsigned n_ranges; /* This is at least 1 */ 1850aadb33SDmitri Tikhonov /* Largest acked is ack_info.ranges[0].high */ 1950aadb33SDmitri Tikhonov lsquic_time_t lack_delta; 20bfc7bfd8SDmitri Tikhonov struct lsquic_packno_range ranges[256]; 2150aadb33SDmitri Tikhonov#if LSQUIC_PARSE_ACK_TIMESTAMPS 2250aadb33SDmitri Tikhonov struct { 2350aadb33SDmitri Tikhonov /* Currently we just read these timestamps in (assuming it is 2450aadb33SDmitri Tikhonov * compiled in, of course), but do not do anything with them. 2550aadb33SDmitri Tikhonov * When we do, the representation of these fields should be 2650aadb33SDmitri Tikhonov * switched to whatever is most appropriate/efficient. 2750aadb33SDmitri Tikhonov */ 2850aadb33SDmitri Tikhonov unsigned char packet_delta; 2950aadb33SDmitri Tikhonov uint64_t delta_usec; 3050aadb33SDmitri Tikhonov } timestamps[255]; 3150aadb33SDmitri Tikhonov#endif 3250aadb33SDmitri Tikhonov} ack_info_t; 3350aadb33SDmitri Tikhonov 3416a9b66aSDmitri Tikhonovstruct short_ack_info 3516a9b66aSDmitri Tikhonov{ 3616a9b66aSDmitri Tikhonov unsigned sai_n_timestamps; 3716a9b66aSDmitri Tikhonov lsquic_time_t sai_lack_delta; 3816a9b66aSDmitri Tikhonov struct lsquic_packno_range sai_range; 3916a9b66aSDmitri Tikhonov}; 4016a9b66aSDmitri Tikhonov 4150aadb33SDmitri Tikhonov#define largest_acked(acki) (+(acki)->ranges[0].high) 4250aadb33SDmitri Tikhonov 4350aadb33SDmitri Tikhonov#define smallest_acked(acki) (+(acki)->ranges[(acki)->n_ranges - 1].low) 4450aadb33SDmitri Tikhonov 4550aadb33SDmitri Tikhonov/* gaf_: generate ACK frame */ 4650aadb33SDmitri Tikhonovstruct lsquic_packno_range; 4750aadb33SDmitri Tikhonovtypedef const struct lsquic_packno_range * 4850aadb33SDmitri Tikhonov (*gaf_rechist_first_f) (void *rechist); 4950aadb33SDmitri Tikhonovtypedef const struct lsquic_packno_range * 5050aadb33SDmitri Tikhonov (*gaf_rechist_next_f) (void *rechist); 5150aadb33SDmitri Tikhonovtypedef lsquic_time_t 5250aadb33SDmitri Tikhonov (*gaf_rechist_largest_recv_f) (void *rechist); 5350aadb33SDmitri Tikhonov 5450aadb33SDmitri Tikhonov/* gsf_: generate stream frame */ 5550aadb33SDmitri Tikhonovtypedef size_t (*gsf_read_f) (void *stream, void *buf, size_t len, int *fin); 5650aadb33SDmitri Tikhonov 5750aadb33SDmitri Tikhonovstruct packin_parse_state { 5850aadb33SDmitri Tikhonov const unsigned char *pps_p; /* Pointer to packet number */ 5950aadb33SDmitri Tikhonov unsigned pps_nbytes; /* Number of bytes in packet number */ 6050aadb33SDmitri Tikhonov}; 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 6550aadb33SDmitri Tikhonov * (Q039 and higher). 6650aadb33SDmitri Tikhonov */ 6750aadb33SDmitri Tikhonovstruct parse_funcs 6850aadb33SDmitri Tikhonov{ 6950aadb33SDmitri Tikhonov int 7050aadb33SDmitri Tikhonov (*pf_gen_ver_nego_pkt) (unsigned char *buf, size_t bufsz, uint64_t conn_id, 7150aadb33SDmitri Tikhonov unsigned version_bitmask); 7250aadb33SDmitri Tikhonov /* Return buf length */ 7350aadb33SDmitri Tikhonov int 7450aadb33SDmitri Tikhonov (*pf_gen_reg_pkt_header) (unsigned char *buf, size_t bufsz, 7550aadb33SDmitri Tikhonov const lsquic_cid_t *, const lsquic_ver_tag_t *, 7650aadb33SDmitri Tikhonov const unsigned char *nonce, lsquic_packno_t, 7750aadb33SDmitri Tikhonov enum lsquic_packno_bits); 7850aadb33SDmitri Tikhonov void 7950aadb33SDmitri Tikhonov (*pf_parse_packet_in_finish) (struct lsquic_packet_in *packet_in, 8050aadb33SDmitri Tikhonov struct packin_parse_state *); 8150aadb33SDmitri Tikhonov enum QUIC_FRAME_TYPE 8250aadb33SDmitri Tikhonov (*pf_parse_frame_type) (unsigned char); 8350aadb33SDmitri Tikhonov /* Return used buffer length */ 8450aadb33SDmitri Tikhonov int 8550aadb33SDmitri Tikhonov (*pf_gen_stream_frame) (unsigned char *buf, size_t bufsz, 8650aadb33SDmitri Tikhonov uint32_t stream_id, uint64_t offset, 87bfc7bfd8SDmitri Tikhonov int fin, size_t size, gsf_read_f, void *stream); 8850aadb33SDmitri Tikhonov unsigned 8950aadb33SDmitri Tikhonov (*pf_parse_stream_frame_header_sz) (unsigned char type); 9050aadb33SDmitri Tikhonov int 9150aadb33SDmitri Tikhonov (*pf_parse_stream_frame) (const unsigned char *buf, size_t rem_packet_sz, 9250aadb33SDmitri Tikhonov struct stream_frame *); 9350aadb33SDmitri Tikhonov int 9450aadb33SDmitri Tikhonov (*pf_parse_ack_frame) (const unsigned char *buf, size_t buf_len, 9550aadb33SDmitri Tikhonov ack_info_t *ack_info); 9650aadb33SDmitri Tikhonov int 9750aadb33SDmitri Tikhonov (*pf_gen_ack_frame) (unsigned char *outbuf, size_t outbuf_sz, 9850aadb33SDmitri Tikhonov gaf_rechist_first_f, gaf_rechist_next_f, 9950aadb33SDmitri Tikhonov gaf_rechist_largest_recv_f, void *rechist, lsquic_time_t now, 10016a9b66aSDmitri Tikhonov int *has_missing, lsquic_packno_t *largest_received); 10150aadb33SDmitri Tikhonov int 10250aadb33SDmitri Tikhonov (*pf_gen_stop_waiting_frame) (unsigned char *buf, size_t buf_len, 10350aadb33SDmitri Tikhonov lsquic_packno_t cur_packno, enum lsquic_packno_bits, 10450aadb33SDmitri Tikhonov lsquic_packno_t least_unacked_packno); 10550aadb33SDmitri Tikhonov int 10650aadb33SDmitri Tikhonov (*pf_parse_stop_waiting_frame) (const unsigned char *buf, size_t buf_len, 10750aadb33SDmitri Tikhonov lsquic_packno_t cur_packno, enum lsquic_packno_bits, 10850aadb33SDmitri Tikhonov lsquic_packno_t *least_unacked); 10950aadb33SDmitri Tikhonov int 11050aadb33SDmitri Tikhonov (*pf_skip_stop_waiting_frame) (size_t buf_len, enum lsquic_packno_bits); 11150aadb33SDmitri Tikhonov int 11250aadb33SDmitri Tikhonov (*pf_gen_window_update_frame) (unsigned char *buf, int buf_len, 11350aadb33SDmitri Tikhonov uint32_t stream_id, uint64_t offset); 11450aadb33SDmitri Tikhonov int 11550aadb33SDmitri Tikhonov (*pf_parse_window_update_frame) (const unsigned char *buf, size_t buf_len, 11650aadb33SDmitri Tikhonov uint32_t *stream_id, uint64_t *offset); 11750aadb33SDmitri Tikhonov int 11850aadb33SDmitri Tikhonov (*pf_gen_blocked_frame) (unsigned char *buf, size_t buf_len, 11950aadb33SDmitri Tikhonov uint32_t stream_id); 12050aadb33SDmitri Tikhonov int 12150aadb33SDmitri Tikhonov (*pf_parse_blocked_frame) (const unsigned char *buf, size_t buf_len, 12250aadb33SDmitri Tikhonov uint32_t *stream_id); 12350aadb33SDmitri Tikhonov int 12450aadb33SDmitri Tikhonov (*pf_gen_rst_frame) (unsigned char *buf, size_t buf_len, uint32_t stream_id, 12550aadb33SDmitri Tikhonov uint64_t offset, uint32_t error_code); 12650aadb33SDmitri Tikhonov int 12750aadb33SDmitri Tikhonov (*pf_parse_rst_frame) (const unsigned char *buf, size_t buf_len, 12850aadb33SDmitri Tikhonov uint32_t *stream_id, uint64_t *offset, uint32_t *error_code); 12950aadb33SDmitri Tikhonov int 13050aadb33SDmitri Tikhonov (*pf_gen_connect_close_frame) (unsigned char *buf, int buf_len, 13150aadb33SDmitri Tikhonov uint32_t error_code, const char *reason, int reason_len); 13250aadb33SDmitri Tikhonov int 13350aadb33SDmitri Tikhonov (*pf_parse_connect_close_frame) (const unsigned char *buf, size_t buf_len, 13450aadb33SDmitri Tikhonov uint32_t *error_code, uint16_t *reason_length, 13550aadb33SDmitri Tikhonov uint8_t *reason_offset); 13650aadb33SDmitri Tikhonov int 13750aadb33SDmitri Tikhonov (*pf_gen_goaway_frame) (unsigned char *buf, size_t buf_len, 13850aadb33SDmitri Tikhonov uint32_t error_code, uint32_t last_good_stream_id, 13950aadb33SDmitri Tikhonov const char *reason, size_t reason_len); 14050aadb33SDmitri Tikhonov int 14150aadb33SDmitri Tikhonov (*pf_parse_goaway_frame) (const unsigned char *buf, size_t buf_len, 14250aadb33SDmitri Tikhonov uint32_t *error_code, uint32_t *last_good_stream_id, 14350aadb33SDmitri Tikhonov uint16_t *reason_length, const char **reason); 14450aadb33SDmitri Tikhonov int 14550aadb33SDmitri Tikhonov (*pf_gen_ping_frame) (unsigned char *buf, int buf_len); 146a4e24689SBob Perper#ifndef NDEBUG 14750aadb33SDmitri Tikhonov /* These float reading and writing functions assume `mem' has at least 14850aadb33SDmitri Tikhonov * 2 bytes. 14950aadb33SDmitri Tikhonov */ 15050aadb33SDmitri Tikhonov void 15150aadb33SDmitri Tikhonov (*pf_write_float_time16) (lsquic_time_t time_us, void *mem); 15250aadb33SDmitri Tikhonov uint64_t 15350aadb33SDmitri Tikhonov (*pf_read_float_time16) (const void *mem); 154a4e24689SBob Perper#endif 15550aadb33SDmitri Tikhonov size_t 15650aadb33SDmitri Tikhonov (*pf_calc_stream_frame_header_sz) (uint32_t stream_id, uint64_t offset); 157c51ce338SDmitri Tikhonov void 158c51ce338SDmitri Tikhonov (*pf_turn_on_fin) (unsigned char *); 15950aadb33SDmitri Tikhonov}; 16050aadb33SDmitri Tikhonov 16150aadb33SDmitri Tikhonovextern const struct parse_funcs lsquic_parse_funcs_gquic_le; 16250aadb33SDmitri Tikhonov/* Q039 and later are big-endian: */ 16350aadb33SDmitri Tikhonovextern const struct parse_funcs lsquic_parse_funcs_gquic_Q039; 1641b97e4afSDmitri Tikhonovextern const struct parse_funcs lsquic_parse_funcs_gquic_Q041; 16550aadb33SDmitri Tikhonov 16650aadb33SDmitri Tikhonov#define select_pf_by_ver(ver) ( \ 167052a1c28SDmitri Tikhonov ((1 << (ver)) & (1 << LSQVER_035)) \ 16850aadb33SDmitri Tikhonov ? &lsquic_parse_funcs_gquic_le : \ 169c95974e9SDmitri Tikhonov ((1 << (ver)) & (1 << LSQVER_041)) \ 170c95974e9SDmitri Tikhonov ? &lsquic_parse_funcs_gquic_Q041 \ 171c95974e9SDmitri Tikhonov : &lsquic_parse_funcs_gquic_Q039) 17250aadb33SDmitri Tikhonov 17350aadb33SDmitri Tikhonov/* This function is QUIC-version independent */ 17450aadb33SDmitri Tikhonovint 17550aadb33SDmitri Tikhonovparse_packet_in_begin (struct lsquic_packet_in *, size_t length, 17650aadb33SDmitri Tikhonov int is_server, struct packin_parse_state *); 17750aadb33SDmitri Tikhonov 17850aadb33SDmitri Tikhonovenum QUIC_FRAME_TYPE 17950aadb33SDmitri Tikhonovparse_frame_type_gquic_Q035_thru_Q039 (unsigned char first_byte); 18050aadb33SDmitri Tikhonov 18150aadb33SDmitri Tikhonovenum QUIC_FRAME_TYPE 1821b97e4afSDmitri Tikhonovparse_frame_type_gquic_Q041 (unsigned char first_byte); 18350aadb33SDmitri Tikhonov 18450aadb33SDmitri Tikhonovunsigned 18550aadb33SDmitri Tikhonovparse_stream_frame_header_sz_gquic (unsigned char type); 18650aadb33SDmitri Tikhonov 18750aadb33SDmitri Tikhonovsize_t 18850aadb33SDmitri Tikhonovcalc_stream_frame_header_sz_gquic (uint32_t stream_id, uint64_t offset); 18950aadb33SDmitri Tikhonov 19050aadb33SDmitri Tikhonov/* This maps two bits as follows: 19150aadb33SDmitri Tikhonov * 00 -> 1 19250aadb33SDmitri Tikhonov * 01 -> 2 19350aadb33SDmitri Tikhonov * 10 -> 4 19450aadb33SDmitri Tikhonov * 11 -> 6 19550aadb33SDmitri Tikhonov * 19650aadb33SDmitri Tikhonov * Assumes that only two low bits are set. 19750aadb33SDmitri Tikhonov */ 19850aadb33SDmitri Tikhonov#define twobit_to_1246(bits) ((bits) * 2 + !(bits)) 19950aadb33SDmitri Tikhonov 20050aadb33SDmitri Tikhonov/* This maps two bits as follows: 20150aadb33SDmitri Tikhonov * 00 -> 1 20250aadb33SDmitri Tikhonov * 01 -> 2 20350aadb33SDmitri Tikhonov * 10 -> 4 20450aadb33SDmitri Tikhonov * 11 -> 8 20550aadb33SDmitri Tikhonov * 20650aadb33SDmitri Tikhonov * Assumes that only two low bits are set. 20750aadb33SDmitri Tikhonov */ 20850aadb33SDmitri Tikhonov#define twobit_to_1248(bits) (1 << (bits)) 20950aadb33SDmitri Tikhonov 21050aadb33SDmitri Tikhonovchar * 21150aadb33SDmitri Tikhonovacki2str (const struct ack_info *acki, size_t *sz); 21250aadb33SDmitri Tikhonov 213c51ce338SDmitri Tikhonovvoid 214c51ce338SDmitri Tikhonovlsquic_turn_on_fin_Q035_thru_Q039 (unsigned char *); 215c51ce338SDmitri Tikhonov 21650aadb33SDmitri Tikhonov#endif 217