| /src/crypto/openssl/include/internal/ |
| H A D | quic_stream_map.h | 86 QUIC_STREAM *txp_next;
327 void ossl_quic_stream_check(const QUIC_STREAM *s);
333 static ossl_inline ossl_unused int ossl_quic_stream_is_server_init(const QUIC_STREAM *s) in ossl_quic_stream_is_server_init()
341 static ossl_inline ossl_unused int ossl_quic_stream_is_bidi(const QUIC_STREAM *s) in ossl_quic_stream_is_bidi()
347 static ossl_inline ossl_unused int ossl_quic_stream_is_local_init(const QUIC_STREAM *s) in ossl_quic_stream_is_local_init()
359 static ossl_inline ossl_unused int ossl_quic_stream_has_send(const QUIC_STREAM *s) in ossl_quic_stream_has_send()
372 static ossl_inline ossl_unused int ossl_quic_stream_has_recv(const QUIC_STREAM *s) in ossl_quic_stream_has_recv()
394 static ossl_inline ossl_unused int ossl_quic_stream_has_send_buffer(const QUIC_STREAM *s) in ossl_quic_stream_has_send_buffer()
410 static ossl_inline ossl_unused int ossl_quic_stream_send_is_reset(const QUIC_STREAM *s) in ossl_quic_stream_send_is_reset()
427 static ossl_inline ossl_unused int ossl_quic_stream_has_recv_buffer(const QUIC_STREAM *s) in ossl_quic_stream_has_recv_buffer()
[all …]
|
| H A D | quic_channel.h | 334 QUIC_STREAM *ossl_quic_channel_get_stream_by_id(QUIC_CHANNEL *ch,
373 QUIC_STREAM *ossl_quic_channel_new_stream_local(QUIC_CHANNEL *ch, int is_uni);
381 QUIC_STREAM *ossl_quic_channel_new_stream_remote(QUIC_CHANNEL *ch,
399 void ossl_quic_channel_reject_stream(QUIC_CHANNEL *ch, QUIC_STREAM *qs);
|
| H A D | quic_predef.h | 27 typedef struct quic_stream_st QUIC_STREAM; typedef
|
| /src/crypto/openssl/ssl/quic/ |
| H A D | quic_stream_map.c | 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, accept_node))
72 offsetof(QUIC_STREAM, ready_for_gc_node))
74 static unsigned long hash_stream(const QUIC_STREAM *s) in hash_stream()
79 static int cmp_stream(const QUIC_STREAM *a, const QUIC_STREAM *b) in cmp_stream()
[all …]
|
| H A D | quic_tserver.c | 260 QUIC_STREAM *qs; in ossl_quic_tserver_read()
318 QUIC_STREAM *qs; in ossl_quic_tserver_has_read_ended()
370 QUIC_STREAM *qs; in ossl_quic_tserver_write()
398 QUIC_STREAM *qs; in ossl_quic_tserver_conclude()
421 QUIC_STREAM *qs; in ossl_quic_tserver_stream_new()
447 QUIC_STREAM *qs; in ossl_quic_tserver_stream_has_peer_stop_sending()
464 QUIC_STREAM *qs; in ossl_quic_tserver_stream_has_peer_reset_stream()
487 QUIC_STREAM *qs = ossl_quic_stream_map_peek_accept_queue(qsm); in ossl_quic_tserver_pop_incoming_stream()
500 QUIC_STREAM *qs; in ossl_quic_tserver_is_stream_totally_acked()
|
| H A D | quic_rx_depack.c | 35 QUIC_STREAM **result);
147 QUIC_STREAM *stream = NULL; in depack_do_frame_reset_stream()
223 QUIC_STREAM *stream = NULL; in depack_do_frame_stop_sending()
370 QUIC_STREAM **result) in depack_do_implicit_stream_create()
372 QUIC_STREAM *stream; in depack_do_implicit_stream_create()
503 QUIC_STREAM *stream; in depack_do_frame_stream()
644 static void update_streams(QUIC_STREAM *s, void *arg) in update_streams()
651 static void update_streams_bidi(QUIC_STREAM *s, void *arg) in update_streams_bidi()
661 static void update_streams_uni(QUIC_STREAM *s, void *arg) in update_streams_uni()
695 QUIC_STREAM *stream; in depack_do_frame_max_stream_data()
[all …]
|
| H A D | quic_txp.c | 414 QUIC_STREAM *stream_head;
1624 QUIC_STREAM *s; in get_sstream_by_id()
1658 QUIC_STREAM *s in on_regen_notify()
1668 QUIC_STREAM *s in on_regen_notify()
1677 QUIC_STREAM *s in on_regen_notify()
1790 QUIC_STREAM *s in on_confirm_notify()
1800 QUIC_STREAM *s in on_confirm_notify()
1854 QUIC_STREAM *s; in on_sstream_updated()
2274 QUIC_STREAM *next_stream, in txp_generate_stream_frames()
2479 static void txp_enlink_tmp(QUIC_STREAM **tmp_head, QUIC_STREAM *stream) in txp_enlink_tmp()
[all …]
|
| H A D | quic_local.h | 43 QUIC_STREAM *stream;
|
| H A D | quic_channel.c | 611 QUIC_STREAM *ossl_quic_channel_get_stream_by_id(QUIC_CHANNEL *ch, in ossl_quic_channel_get_stream_by_id()
1263 static void txfc_bump_cwm_bidi(QUIC_STREAM *s, void *arg) in txfc_bump_cwm_bidi()
1272 static void txfc_bump_cwm_uni(QUIC_STREAM *s, void *arg) in txfc_bump_cwm_uni()
1281 static void do_update(QUIC_STREAM *s, void *arg) in do_update()
3741 static int ch_init_new_stream(QUIC_CHANNEL *ch, QUIC_STREAM *qs, in ch_init_new_stream()
3856 QUIC_STREAM *ossl_quic_channel_new_stream_local(QUIC_CHANNEL *ch, int is_uni) in ossl_quic_channel_new_stream_local()
3858 QUIC_STREAM *qs; in ossl_quic_channel_new_stream_local()
3893 QUIC_STREAM *ossl_quic_channel_new_stream_remote(QUIC_CHANNEL *ch, in ossl_quic_channel_new_stream_remote()
3898 QUIC_STREAM *qs; in ossl_quic_channel_new_stream_remote()
3937 void ossl_quic_channel_reject_stream(QUIC_CHANNEL *ch, QUIC_STREAM *qs) in ossl_quic_channel_reject_stream()
|
| H A D | quic_impl.c | 30 static QUIC_XSO *create_xso_from_stream(QUIC_CONNECTION *qc, QUIC_STREAM *qs);
2088 QUIC_STREAM *qs;
2122 QUIC_STREAM *qs; in qc_wait_for_default_xso_for_read()
2205 static QUIC_XSO *create_xso_from_stream(QUIC_CONNECTION *qc, QUIC_STREAM *qs) in create_xso_from_stream()
2268 QUIC_STREAM *qs = NULL; in quic_conn_stream_new()
2888 QUIC_STREAM *stream;
2935 QUIC_STREAM *stream, in quic_read_actual()
3198 QUIC_STREAM *qs; in ossl_quic_conn_stream_conclude()
3857 QUIC_STREAM *qs;
3887 QUIC_STREAM *qs; in ossl_quic_accept_stream()
[all …]
|
| /src/crypto/openssl/doc/designs/quic-design/ |
| H A D | rx-depacketizer.md | 20 Represented by an `QUIC_STREAM` object (yet to be defined).
148 [^2]: Immediately terminates the appropriate receiving stream `QUIC_STREAM`
153 [^3]: Immediately terminates the appropriate sending stream `QUIC_STREAM`
157 [^4]: The frame payload (Stream Data) is passed as is to the `QUIC_STREAM`
|
| H A D | glossary.md | 188 **QS:** See `QUIC_STREAM`.
190 **QSM:** QUIC Streams Mapper. Manages internal `QUIC_STREAM` objects and maps
208 `QUIC_STREAM` instances. The `QUIC_CHANNEL` code is fused tightly with the RXDP.
223 **QUIC_STREAM**: Internal object tracking a QUIC stream. Unlike an XSO this is
224 not part of the APL. An XSO wraps a QUIC_STREAM once that stream is exposed as
226 `QUIC_XSO` is to a `QUIC_STREAM`.
|
| H A D | quic-concurrency.md | 65 mutations of QUIC core objects (`QUIC_CHANNEL`, `QUIC_STREAM`, etc.) on the
92 Under this model, QUIC core objects (`QUIC_CHANNEL`, `QUIC_STREAM`, etc.) will
138 objects (`QUIC_CHANNEL`, `QUIC_STREAM`, etc.)
|
| H A D | tx-packetiser.md | 60 Represented by an QUIC_STREAM object.
83 - QUIC_STREAM_MAP: Maps stream IDs to QUIC_STREAM objects and tracks which
106 (QUIC_STREAM), which are iterated on a rotating round robin basis. Each
107 QUIC_STREAM provides access to the various components, such as a QUIC_SSTREAM
|
| /src/crypto/openssl/test/ |
| H A D | quic_txp_test.c | 1504 QUIC_STREAM *s; in run_script()
1524 QUIC_STREAM *s; in run_script()
1541 QUIC_STREAM *s; in run_script()
1550 QUIC_STREAM *s; in run_script()
1566 QUIC_STREAM *s; in run_script()
1587 QUIC_STREAM *s; in run_script()
|
| /src/crypto/openssl/doc/designs/quic-design/server/ |
| H A D | quic-server-api.md | 188 `QUIC_STREAM` object. There is no specific object in the `QUIC_TSERVER` APL for
192 `QUIC_STREAM` corresponds exactly to a QUIC stream. In server operation,
214 | QSSO | `QUIC_XSO` | `QUIC_STREAM` |
419 QSSO (QUIC_XSO/QUIC_STREAM)
428 QSSO (QUIC_XSO/QUIC_STREAM)
443 QSSO (QUIC_XSO/QUIC_STREAM)
463 | QSSO | `QUIC_XSO` | `QUIC_STREAM` | 4 | |
|