Lines Matching refs:QUIC_STREAM
17 DEFINE_LHASH_OF_EX(QUIC_STREAM);
19 static void shutdown_flush_done(QUIC_STREAM_MAP *qsm, QUIC_STREAM *qs);
46 static QUIC_STREAM *list_next(QUIC_STREAM_LIST_NODE *l, QUIC_STREAM_LIST_NODE *n, in list_next()
62 return (QUIC_STREAM *)(((char *)n) - off); in list_next()
66 offsetof(QUIC_STREAM, active_node))
68 offsetof(QUIC_STREAM, accept_node))
70 offsetof(QUIC_STREAM, ready_for_gc_node))
72 offsetof(QUIC_STREAM, accept_node))
74 offsetof(QUIC_STREAM, ready_for_gc_node))
76 static unsigned long hash_stream(const QUIC_STREAM *s) in hash_stream()
81 static int cmp_stream(const QUIC_STREAM *a, const QUIC_STREAM *b) in cmp_stream()
118 static void release_each(QUIC_STREAM *stream, void *arg) in release_each()
134 void (*visit_cb)(QUIC_STREAM *stream, void *arg), in ossl_quic_stream_map_visit()
140 QUIC_STREAM *ossl_quic_stream_map_alloc(QUIC_STREAM_MAP *qsm, in ossl_quic_stream_map_alloc()
144 QUIC_STREAM *s; in ossl_quic_stream_map_alloc()
145 QUIC_STREAM key; in ossl_quic_stream_map_alloc()
175 void ossl_quic_stream_map_release(QUIC_STREAM_MAP *qsm, QUIC_STREAM *stream) in ossl_quic_stream_map_release()
197 QUIC_STREAM *ossl_quic_stream_map_get_by_id(QUIC_STREAM_MAP *qsm, in ossl_quic_stream_map_get_by_id()
200 QUIC_STREAM key; in ossl_quic_stream_map_get_by_id()
207 static void stream_map_mark_active(QUIC_STREAM_MAP *qsm, QUIC_STREAM *s) in stream_map_mark_active()
220 static void stream_map_mark_inactive(QUIC_STREAM_MAP *qsm, QUIC_STREAM *s) in stream_map_mark_inactive()
241 static int stream_has_data_to_send(QUIC_STREAM *s) in stream_has_data_to_send()
280 static ossl_unused int qsm_send_part_permits_gc(const QUIC_STREAM *qs) in qsm_send_part_permits_gc()
292 static int qsm_ready_for_gc(QUIC_STREAM_MAP *qsm, QUIC_STREAM *qs) in qsm_ready_for_gc()
328 void ossl_quic_stream_map_update_state(QUIC_STREAM_MAP *qsm, QUIC_STREAM *s) in ossl_quic_stream_map_update_state()
380 QUIC_STREAM *qs) in ossl_quic_stream_map_ensure_send_part_id()
402 QUIC_STREAM *qs) in ossl_quic_stream_map_notify_all_data_sent()
420 static void shutdown_flush_done(QUIC_STREAM_MAP *qsm, QUIC_STREAM *qs) in shutdown_flush_done()
431 QUIC_STREAM *qs) in ossl_quic_stream_map_notify_totally_acked()
452 QUIC_STREAM *qs, in ossl_quic_stream_map_reset_stream_send_part()
513 QUIC_STREAM *qs) in ossl_quic_stream_map_notify_reset_stream_acked()
538 QUIC_STREAM *qs, in ossl_quic_stream_map_notify_size_known_recv_part()
555 QUIC_STREAM *qs) in ossl_quic_stream_map_notify_totally_received()
572 QUIC_STREAM *qs) in ossl_quic_stream_map_notify_totally_read()
592 QUIC_STREAM *qs, in ossl_quic_stream_map_notify_reset_recv_part()
638 QUIC_STREAM *qs) in ossl_quic_stream_map_notify_app_read_reset_recv_part()
654 QUIC_STREAM *qs, in ossl_quic_stream_map_stop_sending_recv_part()
699 int ossl_quic_stream_map_schedule_stop_sending(QUIC_STREAM_MAP *qsm, QUIC_STREAM *qs) in ossl_quic_stream_map_schedule_stop_sending()
732 QUIC_STREAM *ossl_quic_stream_map_peek_accept_queue(QUIC_STREAM_MAP *qsm) in ossl_quic_stream_map_peek_accept_queue()
738 QUIC_STREAM *s) in ossl_quic_stream_map_push_accept_queue()
747 static QUIC_RXFC *qsm_get_max_streams_rxfc(QUIC_STREAM_MAP *qsm, QUIC_STREAM *s) in qsm_get_max_streams_rxfc()
755 QUIC_STREAM *s, in ossl_quic_stream_map_remove_from_accept_queue()
783 QUIC_STREAM *qs, *qs_head, *qsn = NULL; in ossl_quic_stream_map_gc()
795 static int eligible_for_shutdown_flush(QUIC_STREAM *qs) in eligible_for_shutdown_flush()
814 static void begin_shutdown_flush_each(QUIC_STREAM *qs, void *arg) in begin_shutdown_flush_each()
