connection.h

Go to the documentation of this file.

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

const char *imquic_connection_id_str(picoquic_connection_id_t *cid, char *buffer, size_t blen);

struct imquic_connection {
        char *name;
        picoquic_cnx_t *piconn;
        gboolean is_server;
        gboolean just_started;
        gboolean have_params;
        char initial_cid_str[41];
        char *chosen_alpn;
        char *chosen_wt_protocol;
        uint64_t stream_next_uni, stream_next_bidi;
        GHashTable *streams;
        GAsyncQueue *queued_events;
        gboolean alpn_negotiated;
        gboolean connected, established;
        imquic_network_endpoint *socket;
        imquic_network_address peer;
        imquic_http3_connection *http3;
        imquic_source *loop_source;
        uint32_t dgram_id_in, dgram_id_out;
#ifdef HAVE_QLOG
        imquic_qlog *qlog;
#endif
        imquic_mutex mutex;
        volatile gint closing, closed, notified_close;
        volatile gint destroyed;
        imquic_refcount ref;
};

imquic_connection *imquic_connection_create(imquic_network_endpoint *socket, picoquic_cnx_t *piconn);
void imquic_connection_destroy(imquic_connection *conn);


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_notify_gone(imquic_connection *conn);
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, const char *reason);


typedef enum imquic_connection_event_type {
        IMQUIC_CONNECTION_EVENT_UNKNOWN = 0,
        IMQUIC_CONNECTION_EVENT_STREAM,
        IMQUIC_CONNECTION_EVENT_DATAGRAM,
        IMQUIC_CONNECTION_EVENT_RESET_STREAM,
        IMQUIC_CONNECTION_EVENT_CLOSE_CONN,
} imquic_connection_event_type;

typedef struct imquic_connection_event {
        /* Type of event we're queueing */
        imquic_connection_event_type type;
        /* Stream ID, where applicable */
        uint64_t stream_id;
        /* Data buffer, where applicable */
        imquic_buffer *data;
        /* FIN, where applicable */
        gboolean fin;
        /* Error code, where applicable */
        uint64_t error_code;
        /* Reason string, where applicable */
        char *reason;
} imquic_connection_event;

imquic_connection_event *imquic_connection_event_create(imquic_connection_event_type type);
void imquic_connection_event_destroy(imquic_connection_event *event);
 
#endif