stream.h

Go to the documentation of this file.

 
#ifndef IMQUIC_STREAM_H
#define IMQUIC_STREAM_H
 
#include <stdint.h>
 
#include <glib.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;
        imquic_stream_state in_state, out_state;
        size_t skip_in;
        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_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