http3.h

Go to the documentation of this file.

 
#ifndef IMQUIC_HTTP3_H
#define IMQUIC_HTTP3_H
 
#include <glib.h>
 
#include "../imquic/imquic.h"
#include "qpack.h"
#include "buffer.h"
#include "stream.h"
#include "qlog.h"
#include "refcount.h"
 
typedef enum imquic_http3_stream_type {
        IMQUIC_HTTP3_CONTROL_STREAM = 0x00,
        IMQUIC_HTTP3_PUSH_STREAM = 0x01,
        IMQUIC_HTTP3_QPACK_ENCODER_STREAM = 0x02,
        IMQUIC_HTTP3_QPACK_DECODER_STREAM = 0x03
} imquic_http3_stream_type;
const char *imquic_http3_stream_type_str(imquic_http3_stream_type type);
 
typedef enum imquic_http3_frame_type {
        IMQUIC_HTTP3_DATA = 0x00,
        IMQUIC_HTTP3_HEADERS = 0x01,
        IMQUIC_HTTP3_CANCEL_PUSH = 0x03,
        IMQUIC_HTTP3_SETTINGS = 0x04,
        IMQUIC_HTTP3_PUSH_PROMISE = 0x05,
        IMQUIC_HTTP3_GOAWAY = 0x07,
        IMQUIC_HTTP3_MAX_PUSH_ID = 0x0d,
        IMQUIC_HTTP3_WEBTRANSPORT_UNI_STREAM = 0x54,
        IMQUIC_HTTP3_WEBTRANSPORT_STREAM = 0x41
} imquic_http3_frame_type;
const char *imquic_http3_frame_type_str(imquic_http3_frame_type type);
 
typedef enum imquic_http3_settings_type {
        IMQUIC_HTTP3_SETTINGS_QPACK_MAX_TABLE_CAPACITY = 0x01,
        IMQUIC_HTTP3_SETTINGS_MAX_FIELD_SECTION_SIZE = 0x06,
        IMQUIC_HTTP3_SETTINGS_QPACK_BLOCKED_STREAMS = 0x07,
        IMQUIC_HTTP3_SETTINGS_ENABLE_CONNECT_PROTOCOL = 0x08,
        IMQUIC_HTTP3_SETTINGS_H3_DATAGRAM = 0x33,
        IMQUIC_HTTP3_SETTINGS_ENABLE_WEBTRANSPORT = 0x2b603742,         /* FIXME Deprecated? */
        IMQUIC_HTTP3_SETTINGS_WEBTRANSPORT_MAX_SESSIONS = 0xc671706a,
} imquic_http3_settings_type;
const char *imquic_http3_settings_type_str(imquic_http3_settings_type type);
 
typedef enum imquic_http3_error_code {
        IMQUIC_HTTP3_H3_DATAGRAM_ERROR = 0x33,
        IMQUIC_HTTP3_H3_NO_ERROR = 0x0100,
        IMQUIC_HTTP3_H3_GENERAL_PROTOCOL_ERROR = 0x0101,
        IMQUIC_HTTP3_H3_INTERNAL_ERROR = 0x0102,
        IMQUIC_HTTP3_H3_STREAM_CREATION_ERROR = 0x0103,
        IMQUIC_HTTP3_H3_CLOSED_CRITICAL_STREAM = 0x0104,
        IMQUIC_HTTP3_H3_FRAME_UNEXPECTED = 0x0105,
        IMQUIC_HTTP3_H3_FRAME_ERROR = 0x0106,
        IMQUIC_HTTP3_H3_EXCESSIVE_LOAD = 0x0107,
        IMQUIC_HTTP3_H3_ID_ERROR = 0x0108,
        IMQUIC_HTTP3_H3_SETTINGS_ERROR = 0x0109,
        IMQUIC_HTTP3_H3_MISSING_SETTINGS = 0x010a,
        IMQUIC_HTTP3_H3_REQUEST_REJECTED = 0x010b,
        IMQUIC_HTTP3_H3_REQUEST_CANCELLED = 0x010c,
        IMQUIC_HTTP3_H3_REQUEST_INCOMPLETE = 0x010d,
        IMQUIC_HTTP3_H3_MESSAGE_ERROR = 0x010e,
        IMQUIC_HTTP3_H3_CONNECT_ERROR = 0x010f,
        IMQUIC_HTTP3_H3_VERSION_FALLBACK = 0x0110,
        IMQUIC_HTTP3_QPACK_DECOMPRESSION_FAILED = 0x0200,
        IMQUIC_HTTP3_QPACK_ENCODER_STREAM_ERROR = 0x0201,
        IMQUIC_HTTP3_QPACK_DECODER_STREAM_ERROR = 0x0202
} imquic_http3_error_code;
const char *imquic_http3_error_code_str(imquic_http3_error_code type);
 
typedef struct imquic_http3_connection {
        imquic_connection *conn;
        gboolean is_server;
        gboolean settings_sent, settings_received;
        uint64_t local_control_stream, remote_control_stream,
                local_qpack_encoder_stream, remote_qpack_encoder_stream,
                local_qpack_decoder_stream, remote_qpack_decoder_stream,
                request_stream;
        gboolean request_stream_set;
        gboolean has_bidi_streams;
        imquic_qpack_context *qpack;
        gboolean webtransport;
        char *subprotocol;
        GHashTable *buffers;
        volatile gint destroyed;
        imquic_refcount ref;
} imquic_http3_connection;
imquic_http3_connection *imquic_http3_connection_create(imquic_connection *conn, char *subprotocol);
void imquic_http3_connection_destroy(imquic_http3_connection *h3c);
 
void imquic_http3_process_stream_data(imquic_connection *conn, imquic_stream *stream, imquic_buffer_chunk *chunk, gboolean new_stream);
 
 
int imquic_http3_parse_request(imquic_http3_connection *h3c, imquic_stream *stream, uint8_t *bytes, size_t blen);
size_t imquic_http3_parse_request_headers(imquic_http3_connection *h3c, imquic_stream *stream, uint8_t *bytes, size_t blen);
size_t imquic_http3_parse_request_data(imquic_http3_connection *h3c, imquic_stream *stream, uint8_t *bytes, size_t blen);
int imquic_http3_parse_settings(imquic_http3_connection *h3c, imquic_stream *stream, uint8_t *bytes, size_t blen);
 
 
int imquic_http3_prepare_headers_request(imquic_http3_connection *h3c, uint8_t *es, size_t *es_len, uint8_t *rs, size_t *rs_len);
int imquic_http3_prepare_headers_response(imquic_http3_connection *h3c, uint8_t *es, size_t *es_len, uint8_t *rs, size_t *rs_len);
int imquic_http3_prepare_settings(imquic_http3_connection *h3c);
size_t imquic_http3_settings_add_int(uint8_t *bytes, size_t blen, imquic_http3_settings_type type, uint64_t number);
void imquic_http3_check_send_connect(imquic_http3_connection *h3c);
 
#ifdef HAVE_QLOG
 
void imquic_http3_qlog_parameters_set(imquic_qlog *qlog, gboolean local, gboolean extended_connect, gboolean h3_datagram);
void imquic_http3_qlog_stream_type_set(imquic_qlog *qlog, gboolean local, uint64_t stream_id, const char *type);
json_t *imquic_qlog_http3_prepare_content(json_t *parent, const char *name, gboolean array);
void imquic_qlog_http3_append_object(json_t *parent, const char *name, const char *value);
void imquic_http3_qlog_frame_created(imquic_qlog *qlog, uint64_t stream_id, uint64_t length, json_t *frame);
void imquic_http3_qlog_frame_parsed(imquic_qlog *qlog, uint64_t stream_id, uint64_t length, json_t *frame);
#endif
 
#endif