QUIC_STREAM
QUIC_STREAM *ossl_quic_channel_get_stream_by_id(QUIC_CHANNEL *ch,
QUIC_STREAM *ossl_quic_channel_new_stream_local(QUIC_CHANNEL *ch, int is_uni);
QUIC_STREAM *ossl_quic_channel_new_stream_remote(QUIC_CHANNEL *ch,
void ossl_quic_channel_reject_stream(QUIC_CHANNEL *ch, QUIC_STREAM *qs);
void ossl_quic_stream_check(const QUIC_STREAM *s);
static ossl_inline ossl_unused int ossl_quic_stream_is_server_init(const QUIC_STREAM *s)
static ossl_inline ossl_unused int ossl_quic_stream_is_bidi(const QUIC_STREAM *s)
static ossl_inline ossl_unused int ossl_quic_stream_is_local_init(const QUIC_STREAM *s)
static ossl_inline ossl_unused int ossl_quic_stream_has_send(const QUIC_STREAM *s)
static ossl_inline ossl_unused int ossl_quic_stream_has_recv(const QUIC_STREAM *s)
static ossl_inline ossl_unused int ossl_quic_stream_has_send_buffer(const QUIC_STREAM *s)
static ossl_inline ossl_unused int ossl_quic_stream_send_is_reset(const QUIC_STREAM *s)
static ossl_inline ossl_unused int ossl_quic_stream_has_recv_buffer(const QUIC_STREAM *s)
static ossl_inline ossl_unused int ossl_quic_stream_recv_is_reset(const QUIC_STREAM *s)
static ossl_inline ossl_unused int ossl_quic_stream_send_get_final_size(const QUIC_STREAM *s,
static ossl_inline ossl_unused int ossl_quic_stream_recv_get_final_size(const QUIC_STREAM *s,
static ossl_inline ossl_unused int ossl_quic_stream_recv_pending(const QUIC_STREAM *s,
LHASH_OF(QUIC_STREAM) *map;
QUIC_STREAM *rr_cur;
QUIC_STREAM *ossl_quic_stream_map_alloc(QUIC_STREAM_MAP *qsm,
void ossl_quic_stream_map_release(QUIC_STREAM_MAP *qsm, QUIC_STREAM *stream);
void (*visit_cb)(QUIC_STREAM *stream, void *arg),
QUIC_STREAM *ossl_quic_stream_map_get_by_id(QUIC_STREAM_MAP *qsm,
void ossl_quic_stream_map_update_state(QUIC_STREAM_MAP *qsm, QUIC_STREAM *s);
QUIC_STREAM *qs);
QUIC_STREAM *qs);
QUIC_STREAM *qs);
QUIC_STREAM *qs,
QUIC_STREAM *qs);
QUIC_STREAM *qs,
QUIC_STREAM *qs);
QUIC_STREAM *qs);
QUIC_STREAM *qs,
QUIC_STREAM *qs);
QUIC_STREAM *qs,
QUIC_STREAM *qs);
QUIC_STREAM *s);
QUIC_STREAM *ossl_quic_stream_map_peek_accept_queue(QUIC_STREAM_MAP *qsm);
QUIC_STREAM *s,
QUIC_STREAM *txp_next;
QUIC_STREAM *first_stream, *stream;
static void txfc_bump_cwm_bidi(QUIC_STREAM *s, void *arg)
static void txfc_bump_cwm_uni(QUIC_STREAM *s, void *arg)
static void do_update(QUIC_STREAM *s, void *arg)
static int ch_init_new_stream(QUIC_CHANNEL *ch, QUIC_STREAM *qs,
QUIC_STREAM *ossl_quic_channel_new_stream_local(QUIC_CHANNEL *ch, int is_uni)
QUIC_STREAM *qs;
QUIC_STREAM *ossl_quic_channel_new_stream_remote(QUIC_CHANNEL *ch,
QUIC_STREAM *qs;
void ossl_quic_channel_reject_stream(QUIC_CHANNEL *ch, QUIC_STREAM *qs)
QUIC_STREAM *ossl_quic_channel_get_stream_by_id(QUIC_CHANNEL *ch,
QUIC_STREAM *qs;
QUIC_STREAM *qs;
static QUIC_XSO *create_xso_from_stream(QUIC_CONNECTION *qc, QUIC_STREAM *qs)
QUIC_STREAM *qs = NULL;
QUIC_STREAM *stream;
QUIC_STREAM *stream,
static QUIC_XSO *create_xso_from_stream(QUIC_CONNECTION *qc, QUIC_STREAM *qs);
QUIC_STREAM *qs;
QUIC_STREAM *qs;
QUIC_STREAM *qs;
QUIC_STREAM *qs;
QUIC_STREAM *qs,
QUIC_STREAM *stream;
QUIC_STREAM *stream = NULL;
QUIC_STREAM *stream = NULL;
QUIC_STREAM **result);
QUIC_STREAM **result)
QUIC_STREAM *stream;
QUIC_STREAM *stream;
static void update_streams(QUIC_STREAM *s, void *arg)
static void update_streams_bidi(QUIC_STREAM *s, void *arg)
static void update_streams_uni(QUIC_STREAM *s, void *arg)
QUIC_STREAM *stream;
QUIC_STREAM *stream;
static void release_each(QUIC_STREAM *stream, void *arg)
void (*visit_cb)(QUIC_STREAM *stream, void *arg),
QUIC_STREAM *ossl_quic_stream_map_alloc(QUIC_STREAM_MAP *qsm,
QUIC_STREAM *s;
QUIC_STREAM key;
DEFINE_LHASH_OF_EX(QUIC_STREAM);
void ossl_quic_stream_map_release(QUIC_STREAM_MAP *qsm, QUIC_STREAM *stream)
static void shutdown_flush_done(QUIC_STREAM_MAP *qsm, QUIC_STREAM *qs);
QUIC_STREAM *ossl_quic_stream_map_get_by_id(QUIC_STREAM_MAP *qsm,
QUIC_STREAM key;
static void stream_map_mark_active(QUIC_STREAM_MAP *qsm, QUIC_STREAM *s)
static void stream_map_mark_inactive(QUIC_STREAM_MAP *qsm, QUIC_STREAM *s)
static int stream_has_data_to_send(QUIC_STREAM *s)
static ossl_unused int qsm_send_part_permits_gc(const QUIC_STREAM *qs)
static int qsm_ready_for_gc(QUIC_STREAM_MAP *qsm, QUIC_STREAM *qs)
void ossl_quic_stream_map_update_state(QUIC_STREAM_MAP *qsm, QUIC_STREAM *s)
QUIC_STREAM *qs)
QUIC_STREAM *qs)
static void shutdown_flush_done(QUIC_STREAM_MAP *qsm, QUIC_STREAM *qs)
QUIC_STREAM *qs)
QUIC_STREAM *qs,
static QUIC_STREAM *list_next(QUIC_STREAM_LIST_NODE *l, QUIC_STREAM_LIST_NODE *n,
QUIC_STREAM *qs)
QUIC_STREAM *qs,
QUIC_STREAM *qs)
QUIC_STREAM *qs)
QUIC_STREAM *qs,
return (QUIC_STREAM *)(((char *)n) - off);
QUIC_STREAM *qs)
QUIC_STREAM *qs,
offsetof(QUIC_STREAM, active_node))
offsetof(QUIC_STREAM, accept_node))
int ossl_quic_stream_map_schedule_stop_sending(QUIC_STREAM_MAP *qsm, QUIC_STREAM *qs)
offsetof(QUIC_STREAM, accept_node))
offsetof(QUIC_STREAM, ready_for_gc_node))
QUIC_STREAM *ossl_quic_stream_map_peek_accept_queue(QUIC_STREAM_MAP *qsm)
QUIC_STREAM *s)
static unsigned long hash_stream(const QUIC_STREAM *s)
static QUIC_RXFC *qsm_get_max_streams_rxfc(QUIC_STREAM_MAP *qsm, QUIC_STREAM *s)
QUIC_STREAM *s,
QUIC_STREAM *qs;
static int eligible_for_shutdown_flush(QUIC_STREAM *qs)
static int cmp_stream(const QUIC_STREAM *a, const QUIC_STREAM *b)
static void begin_shutdown_flush_each(QUIC_STREAM *qs, void *arg)
QUIC_STREAM *qs;
QUIC_STREAM *qs;
QUIC_STREAM *qs;
QUIC_STREAM *qs;
QUIC_STREAM *qs;
QUIC_STREAM *qs;
QUIC_STREAM *qs;
QUIC_STREAM *qs = ossl_quic_stream_map_peek_accept_queue(qsm);
QUIC_STREAM *qs;
QUIC_STREAM *s;
QUIC_STREAM *s
QUIC_STREAM *s
QUIC_STREAM *s
QUIC_STREAM *s
QUIC_STREAM *s
QUIC_STREAM *s;
QUIC_STREAM *next_stream,
static void txp_enlink_tmp(QUIC_STREAM **tmp_head, QUIC_STREAM *stream)
QUIC_STREAM **tmp_head)
QUIC_STREAM *stream, *snext;
QUIC_STREAM *stream;
QUIC_STREAM *stream_head;
QUIC_STREAM *s;
QUIC_STREAM *s;
QUIC_STREAM *s;
QUIC_STREAM *s;
QUIC_STREAM *s;
QUIC_STREAM *s;