QUIC_STREAM_MAP
QUIC_STREAM_MAP *ossl_quic_channel_get_qsm(QUIC_CHANNEL *ch);
int ossl_quic_stream_map_init(QUIC_STREAM_MAP *qsm,
void ossl_quic_stream_map_cleanup(QUIC_STREAM_MAP *qsm);
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 ossl_quic_stream_map_visit(QUIC_STREAM_MAP *qsm,
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);
void ossl_quic_stream_map_set_rr_stepping(QUIC_STREAM_MAP *qsm, size_t stepping);
int ossl_quic_stream_map_is_local_allowed_by_stream_limit(QUIC_STREAM_MAP *qsm,
int ossl_quic_stream_map_ensure_send_part_id(QUIC_STREAM_MAP *qsm,
int ossl_quic_stream_map_notify_all_data_sent(QUIC_STREAM_MAP *qsm,
int ossl_quic_stream_map_notify_totally_acked(QUIC_STREAM_MAP *qsm,
int ossl_quic_stream_map_reset_stream_send_part(QUIC_STREAM_MAP *qsm,
int ossl_quic_stream_map_notify_reset_stream_acked(QUIC_STREAM_MAP *qsm,
int ossl_quic_stream_map_notify_size_known_recv_part(QUIC_STREAM_MAP *qsm,
int ossl_quic_stream_map_notify_totally_received(QUIC_STREAM_MAP *qsm,
int ossl_quic_stream_map_notify_totally_read(QUIC_STREAM_MAP *qsm,
int ossl_quic_stream_map_notify_reset_recv_part(QUIC_STREAM_MAP *qsm,
int ossl_quic_stream_map_notify_app_read_reset_recv_part(QUIC_STREAM_MAP *qsm,
int ossl_quic_stream_map_stop_sending_recv_part(QUIC_STREAM_MAP *qsm,
int ossl_quic_stream_map_schedule_stop_sending(QUIC_STREAM_MAP *qsm,
void ossl_quic_stream_map_push_accept_queue(QUIC_STREAM_MAP *qsm,
QUIC_STREAM *ossl_quic_stream_map_peek_accept_queue(QUIC_STREAM_MAP *qsm);
void ossl_quic_stream_map_remove_from_accept_queue(QUIC_STREAM_MAP *qsm,
size_t ossl_quic_stream_map_get_accept_queue_len(QUIC_STREAM_MAP *qsm, int is_uni);
size_t ossl_quic_stream_map_get_total_accept_queue_len(QUIC_STREAM_MAP *qsm);
void ossl_quic_stream_map_gc(QUIC_STREAM_MAP *qsm);
void ossl_quic_stream_map_begin_shutdown_flush(QUIC_STREAM_MAP *qsm);
int ossl_quic_stream_map_is_shutdown_flush_finished(QUIC_STREAM_MAP *qsm);
QUIC_STREAM_MAP *qsm;
void ossl_quic_stream_iter_init(QUIC_STREAM_ITER *it, QUIC_STREAM_MAP *qsm,
QUIC_STREAM_MAP *qsm; /* QUIC Streams Map */
QUIC_STREAM_MAP *ossl_quic_channel_get_qsm(QUIC_CHANNEL *ch)
QUIC_STREAM_MAP qsm;
QUIC_STREAM_MAP *qsm;
QUIC_STREAM_MAP *qsm = ossl_quic_channel_get_qsm(qc->ch);
QUIC_STREAM_MAP *qsm;
QUIC_STREAM_MAP *qsm;
QUIC_STREAM_MAP *qsm = ossl_quic_channel_get_qsm(ctx->qc->ch);
QUIC_STREAM_MAP *qsm = ossl_quic_channel_get_qsm(qc->ch);
QUIC_STREAM_MAP *qsm;
QUIC_STREAM_MAP *qsm;
QUIC_STREAM_MAP *qsm = arg;
void ossl_quic_stream_map_cleanup(QUIC_STREAM_MAP *qsm)
void ossl_quic_stream_map_visit(QUIC_STREAM_MAP *qsm,
QUIC_STREAM *ossl_quic_stream_map_alloc(QUIC_STREAM_MAP *qsm,
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,
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)
void ossl_quic_stream_map_set_rr_stepping(QUIC_STREAM_MAP *qsm, size_t stepping)
static int qsm_ready_for_gc(QUIC_STREAM_MAP *qsm, QUIC_STREAM *qs)
int ossl_quic_stream_map_is_local_allowed_by_stream_limit(QUIC_STREAM_MAP *qsm,
void ossl_quic_stream_map_update_state(QUIC_STREAM_MAP *qsm, QUIC_STREAM *s)
int ossl_quic_stream_map_ensure_send_part_id(QUIC_STREAM_MAP *qsm,
int ossl_quic_stream_map_notify_all_data_sent(QUIC_STREAM_MAP *qsm,
static void shutdown_flush_done(QUIC_STREAM_MAP *qsm, QUIC_STREAM *qs)
int ossl_quic_stream_map_notify_totally_acked(QUIC_STREAM_MAP *qsm,
int ossl_quic_stream_map_reset_stream_send_part(QUIC_STREAM_MAP *qsm,
int ossl_quic_stream_map_notify_reset_stream_acked(QUIC_STREAM_MAP *qsm,
int ossl_quic_stream_map_notify_size_known_recv_part(QUIC_STREAM_MAP *qsm,
int ossl_quic_stream_map_notify_totally_received(QUIC_STREAM_MAP *qsm,
int ossl_quic_stream_map_notify_totally_read(QUIC_STREAM_MAP *qsm,
int ossl_quic_stream_map_notify_reset_recv_part(QUIC_STREAM_MAP *qsm,
int ossl_quic_stream_map_notify_app_read_reset_recv_part(QUIC_STREAM_MAP *qsm,
int ossl_quic_stream_map_stop_sending_recv_part(QUIC_STREAM_MAP *qsm,
int ossl_quic_stream_map_schedule_stop_sending(QUIC_STREAM_MAP *qsm, QUIC_STREAM *qs)
QUIC_STREAM *ossl_quic_stream_map_peek_accept_queue(QUIC_STREAM_MAP *qsm)
void ossl_quic_stream_map_push_accept_queue(QUIC_STREAM_MAP *qsm,
static QUIC_RXFC *qsm_get_max_streams_rxfc(QUIC_STREAM_MAP *qsm, QUIC_STREAM *s)
void ossl_quic_stream_map_remove_from_accept_queue(QUIC_STREAM_MAP *qsm,
size_t ossl_quic_stream_map_get_accept_queue_len(QUIC_STREAM_MAP *qsm, int is_uni)
size_t ossl_quic_stream_map_get_total_accept_queue_len(QUIC_STREAM_MAP *qsm)
void ossl_quic_stream_map_gc(QUIC_STREAM_MAP *qsm)
QUIC_STREAM_MAP *qsm = arg;
void ossl_quic_stream_map_begin_shutdown_flush(QUIC_STREAM_MAP *qsm)
int ossl_quic_stream_map_is_shutdown_flush_finished(QUIC_STREAM_MAP *qsm)
void ossl_quic_stream_iter_init(QUIC_STREAM_ITER *it, QUIC_STREAM_MAP *qsm,
int ossl_quic_stream_map_init(QUIC_STREAM_MAP *qsm,
QUIC_STREAM_MAP *qsm = ossl_quic_channel_get_qsm(srv->ch);
QUIC_STREAM_MAP qsm;