internal/roq.h

Go to the documentation of this file.

 
#ifndef IMQUIC_ROQ_INTERNAL_H
#define IMQUIC_ROQ_INTERNAL_H
 
#include <glib.h>
 
#include "../imquic/imquic.h"
#include "qlog.h"
#include "mutex.h"
#include "refcount.h"
 
#define IMQUIC_ROQ              7499633
 
void imquic_roq_init(void);
void imquic_roq_deinit(void);
 
typedef struct imquic_roq_endpoint {
        imquic_connection *conn;
        GHashTable *stream_flows_in, *stream_flows_out;
        GHashTable *packets;
        imquic_mutex mutex;
} imquic_roq_endpoint;
 
typedef struct imquic_roq_stream {
        uint64_t stream_id;
        uint64_t flow_id;
        uint64_t offset;
        volatile gint destroyed;
        imquic_refcount ref;
} imquic_roq_stream;
 
typedef struct imquic_roq_callbacks {
        void (* new_connection)(imquic_connection *conn, void *user_data);
        void (* rtp_incoming)(imquic_connection *conn, uint64_t flow_id, uint8_t *bytes, size_t blen);
        void (* connection_gone)(imquic_connection *conn);
} imquic_roq_callbacks;
 
 
void imquic_roq_new_connection(imquic_connection *conn, void *user_data);
void imquic_roq_stream_incoming(imquic_connection *conn, uint64_t stream_id,
        uint8_t *bytes, uint64_t offset, uint64_t length, gboolean complete);
void imquic_roq_datagram_incoming(imquic_connection *conn, uint8_t *bytes, uint64_t length);
void imquic_roq_connection_gone(imquic_connection *conn);
 
#ifdef HAVE_QLOG
 
void imquic_roq_qlog_add_rtp_packet(json_t *data, uint64_t flow_id, uint64_t length);
void imquic_roq_qlog_stream_opened(imquic_qlog *qlog, uint64_t stream_id, uint64_t flow_id);
void imquic_roq_qlog_stream_packet_created(imquic_qlog *qlog, uint64_t stream_id, uint64_t flow_id, uint64_t length);
void imquic_roq_qlog_stream_packet_parsed(imquic_qlog *qlog, uint64_t stream_id, uint64_t flow_id, uint64_t length);
void imquic_roq_qlog_datagram_packet_created(imquic_qlog *qlog, uint64_t flow_id, uint64_t length);
void imquic_roq_qlog_datagram_packet_parsed(imquic_qlog *qlog, uint64_t flow_id, uint64_t length);
#endif
 
#endif