connection.h

Go to the documentation of this file.

 
#ifndef IMQUIC_CONNECTION_H
#define IMQUIC_CONNECTION_H
 
#include <stdint.h>
 
#include <glib.h>
 
#include "stream.h"
#include "buffer.h"
#include "crypto.h"
#include "network.h"
#include "http3.h"
#include "error.h"
#include "qlog.h"
#include "utils.h"
#include "listmap.h"
#include "refcount.h"

typedef struct imquic_connection_id {
        uint64_t seq;
        uint8_t id[20];
        size_t len;
        uint8_t token[16];
} imquic_connection_id;

const char *imquic_connection_id_str(imquic_connection_id *cid, char *buffer, size_t blen);
imquic_connection_id *imquic_connection_id_dup(imquic_connection_id *cid);
gboolean imquic_connection_id_equal(const void *a, const void *b);
guint imquic_connection_id_hash(gconstpointer v);

typedef struct imquic_connection_parameters {
        uint32_t max_idle_timeout;
        uint16_t max_udp_payload_size;
        uint16_t max_datagram_frame_size;
        uint64_t initial_max_data;
        uint64_t initial_max_stream_data_bidi_local;
        uint64_t initial_max_stream_data_bidi_remote;
        uint64_t initial_max_stream_data_uni;
        uint64_t initial_max_streams_bidi;
        uint64_t initial_max_streams_uni;
        uint8_t ack_delay_exponent;
        uint16_t max_ack_delay;
        gboolean disable_active_migration;
        uint16_t active_connection_id_limit;
} imquic_connection_parameters;

void imquic_connection_parameters_init(imquic_connection_parameters *params);

typedef struct imquic_connection_rtt {
        uint16_t latest;
        uint16_t smoothed;
        uint16_t rttvar;
        uint16_t min;
        int64_t first_sample;
} imquic_connection_rtt;

typedef struct imquic_connection_flow_control {
        uint64_t local_max_data, remote_max_data;
        uint64_t local_max_streams_bidi, remote_max_streams_bidi;
        uint64_t local_max_streams_uni, remote_max_streams_uni;
        uint64_t in_size, out_size;
} imquic_connection_flow_control;

struct imquic_connection {
        char *name;
        gboolean is_server;
        gboolean just_started;
        gboolean have_params;
        imquic_connection_id initial_cid;
        char client_initial_cid_str[41];
        imquic_connection_id local_cid, remote_cid;
        imquic_connection_id new_remote_cid;
        GList *connection_ids;
        enum ssl_encryption_level_t level;
        imquic_data_fixed retry_token;
        uint64_t pkn[4];
        imquic_connection_parameters local_params, remote_params;
        imquic_data alpn;
        char *chosen_alpn;
        char *chosen_wt_protocol;
        uint64_t stream_next_uni, stream_next_bidi;
        GHashTable *streams, *streams_done;
        GQueue *incoming_data;
        GQueue *outgoing_data, *outgoing_datagram;
        imquic_listmap *blocked_streams;
        volatile gint wakeup;
        imquic_connection_rtt rtt;
        imquic_connection_flow_control flow_control;
        GList *recvd[4];
        uint64_t largest[4];
        size_t ack_eliciting_in_flight[4];
        int64_t last_ack_eliciting_time[4];
        int64_t largest_time[4];
        int64_t loss_time[4];
        imquic_listmap *sent_pkts[4];
        uint64_t largest_acked[4];
        gboolean send_ack[5];
        imquic_protection keys[4];
        gboolean current_phase;
        SSL *ssl;
        imquic_buffer *crypto_in[4], *crypto_out[4];
        gboolean send_crypto;
        gboolean alpn_negotiated;
        gboolean connected, established;
        imquic_network_endpoint *socket;
        imquic_network_address peer;
        imquic_http3_connection *http3;
        imquic_source *ld_timer;
        int64_t last_activity;
        imquic_source *idle_timer;
        uint8_t pto_count;
        imquic_source *loop_source;
        uint32_t dgram_id_in, dgram_id_out;
#ifdef HAVE_QLOG
        imquic_qlog *qlog;
#endif
        void *user_data;
        imquic_mutex mutex;
        gboolean should_close;
        volatile gint closed;
        volatile gint destroyed;
        imquic_refcount ref;
};

imquic_connection *imquic_connection_create(imquic_network_endpoint *socket);
void imquic_connection_destroy(imquic_connection *conn);


void imquic_connection_change_level(imquic_connection *conn, enum ssl_encryption_level_t level);
void imquic_connection_update_rtt(imquic_connection *conn, int64_t sent_time, uint16_t ack_delay);
GList *imquic_connection_detect_lost(imquic_connection *conn);
void imquic_connection_update_loss_timer(imquic_connection *conn);
gboolean imquic_connection_loss_detection_timeout(gpointer user_data);


int imquic_connection_new_stream_id(imquic_connection *conn, gboolean bidirectional, uint64_t *stream_id);
int imquic_connection_send_on_datagram(imquic_connection *conn, uint8_t *bytes, uint64_t length);
int imquic_connection_send_on_stream(imquic_connection *conn, uint64_t stream_id,
        uint8_t *bytes, uint64_t length, gboolean complete);
void imquic_connection_notify_datagram_incoming(imquic_connection *conn, uint8_t *data, uint64_t length);
void imquic_connection_notify_stream_incoming(imquic_connection *conn, imquic_stream *stream, uint8_t *data, uint64_t length);
void imquic_connection_flush_stream(imquic_connection *conn, uint64_t stream_id);
void imquic_connection_reset_stream(imquic_connection *conn, uint64_t stream_id, uint64_t error_code);
void imquic_connection_close(imquic_connection *conn, uint64_t error_code, uint64_t frame_type, const char *reason);
 
#endif