stream.h

Go to the documentation of this file.

 
#ifndef IMQUIC_STREAM_H
#define IMQUIC_STREAM_H
 
#include <stdint.h>
 
#include <glib.h>
 
#include "buffer.h"
#include "refcount.h"
 
typedef enum imquic_stream_state {
        IMQUIC_STREAM_INACTIVE,
        IMQUIC_STREAM_READY,
        IMQUIC_STREAM_BLOCKED,
        IMQUIC_STREAM_RESET,
        IMQUIC_STREAM_COMPLETE
} imquic_stream_state;
const char *imquic_stream_state_str(imquic_stream_state state);
 
typedef struct imquic_stream {
        uint64_t stream_id, actual_id;
        gboolean client_initiated, bidirectional;
        gboolean can_send, can_receive;
        uint64_t in_size, out_size;
        uint64_t in_finalsize, out_finalsize;
        imquic_stream_state in_state, out_state;
        size_t skip_in, skip_out;
        imquic_buffer *in_data, *out_data;
        uint64_t local_max_data, remote_max_data;
        imquic_mutex mutex;
        volatile gint destroyed;
        imquic_refcount ref;
} imquic_stream;
imquic_stream *imquic_stream_create(uint64_t stream_id, gboolean is_server);
gboolean imquic_stream_can_send(imquic_stream *stream, uint64_t offset, uint64_t length, gboolean verbose);
gboolean imquic_stream_can_receive(imquic_stream *stream, uint64_t offset, uint64_t length, gboolean verbose);
gboolean imquic_stream_mark_complete(imquic_stream *stream, gboolean incoming);
gboolean imquic_stream_is_done(imquic_stream *stream);
void imquic_stream_destroy(imquic_stream *stream);
 
 
void imquic_parse_stream_id(uint64_t stream_id, uint64_t *id, gboolean *client_initiated, gboolean *bidirectional);
uint64_t imquic_build_stream_id(uint64_t id, gboolean client_initiated, gboolean bidirectional);
 
#endif