network.h

Go to the documentation of this file.

 
#ifndef IMQUIC_NETWORK_H
#define IMQUIC_NETWORK_H
 
#include <stdint.h>
#include <sys/socket.h>
 
#include <picoquic.h>
 
#include "../imquic/imquic.h"
#include "configuration.h"
#include "loop.h"
#include "moq.h"
#include "roq.h"
#include "refcount.h"

void imquic_network_init(void);
void imquic_network_deinit(void);

typedef struct imquic_network_address {
        struct sockaddr_storage addr;
        socklen_t addrlen;
} imquic_network_address;

char *imquic_network_address_str(imquic_network_address *address, char *output, size_t outlen, gboolean add_port);
uint16_t imquic_network_address_port(imquic_network_address *address);

typedef struct imquic_network_endpoint {
        void *source;
        char *name;
        gboolean is_server;
        int fd;
        uint16_t port, remote_port;
        imquic_network_address local_address;
        imquic_network_address remote_address;
        /* Picoquic context */
        picoquic_quic_t *qc;
        /* Picoquic timer */
        struct imquic_source *timer;
        char *sni;
        gboolean raw_quic;
        char **alpn;
        gboolean webtransport;
        char *h3_path;
        char **wt_protocols;
        GHashTable *connections, *connections_by_cnx;
        uint64_t conns_num;
        gboolean internal_callbacks;
        void (* new_connection)(imquic_connection *conn, void *user_data);
        void (* stream_incoming)(imquic_connection *conn, uint64_t stream_id,
                uint8_t *bytes, uint64_t length, gboolean complete);
        void (* datagram_incoming)(imquic_connection *conn, uint8_t *bytes, uint64_t length);
        void (* reset_stream_incoming)(imquic_connection *conn, uint64_t stream_id, uint64_t error_code);
        void (* connection_gone)(imquic_connection *conn);
        void (* connection_failed)(void *user_data);
        void *user_data;
        uint64_t protocol;
        union {
                imquic_moq_callbacks moq;
                imquic_roq_callbacks roq;
        } callbacks;
        char *qlog_path;
        gboolean qlog_sequential;
        gboolean qlog_quic, qlog_http3,
                qlog_roq, qlog_roq_packets,
                qlog_moq, qlog_moq_messages, qlog_moq_objects;
        uint32_t moq_version;
        imquic_mutex mutex;
        volatile gint started;
        volatile gint shutting;
        volatile gint destroyed;
        imquic_refcount ref;
} imquic_network_endpoint;

imquic_network_endpoint *imquic_network_endpoint_create(imquic_configuration *config);

int imquic_network_endpoint_start(imquic_network_endpoint *ne);
void imquic_network_endpoint_add_connection(imquic_network_endpoint *ne, imquic_connection *conn, gboolean lock_mutex);
void imquic_network_endpoint_remove_connection(imquic_network_endpoint *ne, imquic_connection *conn, gboolean lock_mutex);
/*" \brief Callback function, triggered when there's packets to send on
 * one of the connections managed by this network endpoint
 * @param ne The imquic_network_endpoint instance to send packets for
 * @returns Always G_SOURCE_REMOVE, since a timer is recreated every time */
int imquic_network_send_packet(imquic_network_endpoint *ne);
void imquic_network_endpoint_shutdown(imquic_network_endpoint *ne);
void imquic_network_endpoint_destroy(imquic_network_endpoint *ne);
 
#endif