Home
last modified time | relevance | path

Searched refs:qsm (Results 1 – 11 of 11) sorted by relevance

/openssl/ssl/quic/
H A Dquic_stream_map.c98 qsm->active_list.prev = qsm->active_list.next = &qsm->active_list; in ossl_quic_stream_map_init()
99 qsm->accept_list.prev = qsm->accept_list.next = &qsm->accept_list; in ossl_quic_stream_map_init()
100 qsm->ready_for_gc_list.prev = qsm->ready_for_gc_list.next in ossl_quic_stream_map_init()
127 ossl_quic_stream_map_visit(qsm, release_each, qsm); in ossl_quic_stream_map_cleanup()
130 qsm->map = NULL; in ossl_quic_stream_map_cleanup()
226 qsm->rr_cur = active_next(&qsm->active_list, s); in stream_map_mark_inactive()
772 return is_uni ? qsm->num_accept_uni : qsm->num_accept_bidi; in ossl_quic_stream_map_get_accept_queue_len()
829 ossl_quic_stream_map_visit(qsm, begin_shutdown_flush_each, qsm); in ossl_quic_stream_map_begin_shutdown_flush()
844 it->qsm = qsm; in ossl_quic_stream_iter_init()
847 && ++qsm->rr_counter >= qsm->rr_stepping) { in ossl_quic_stream_iter_init()
[all …]
H A Dquic_rx_depack.c209 ossl_quic_stream_map_notify_reset_recv_part(&ch->qsm, stream, in depack_do_frame_reset_stream()
213 ossl_quic_stream_map_update_state(&ch->qsm, stream); in depack_do_frame_reset_stream()
257 ossl_quic_stream_map_reset_stream_send_part(&ch->qsm, stream, in depack_do_frame_stop_sending()
374 stream = ossl_quic_stream_map_get_by_id(&ch->qsm, stream_id); in depack_do_implicit_stream_create()
646 ossl_quic_stream_map_update_state(&ch->qsm, s); in update_streams()
656 ossl_quic_stream_map_update_state(&ch->qsm, s); in update_streams_bidi()
666 ossl_quic_stream_map_update_state(&ch->qsm, s); in update_streams_uni()
683 ossl_quic_stream_map_visit(&ch->qsm, update_streams, ch); in depack_do_frame_max_data()
722 ossl_quic_stream_map_update_state(&ch->qsm, stream); in depack_do_frame_max_stream_data()
755 ossl_quic_stream_map_visit(&ch->qsm, update_streams_bidi, ch); in depack_do_frame_max_streams()
[all …]
H A Dquic_txp.c463 || args->qsm == NULL in ossl_quic_tx_packetiser_new()
1477 ossl_quic_stream_iter_init(&it, txp->args.qsm, 0); in txp_should_try_staging()
1534 s = ossl_quic_stream_map_get_by_id(txp->args.qsm, stream_id); in get_sstream_by_id()
1571 ossl_quic_stream_map_update_state(txp->args.qsm, s); in on_regen_notify()
1594 ossl_quic_stream_map_update_state(txp->args.qsm, s); in on_regen_notify()
1709 ossl_quic_stream_map_update_state(txp->args.qsm, s); in on_confirm_notify()
1725 ossl_quic_stream_map_update_state(txp->args.qsm, s); in on_confirm_notify()
1771 s = ossl_quic_stream_map_get_by_id(txp->args.qsm, stream_id); in on_sstream_updated()
1775 ossl_quic_stream_map_update_state(txp->args.qsm, s); in on_sstream_updated()
2411 for (ossl_quic_stream_iter_init(&it, txp->args.qsm, 1); in txp_generate_stream_related()
[all …]
H A Dquic_channel.c269 txp_args.qsm = &ch->qsm; in ch_init()
388 ossl_quic_stream_map_cleanup(&ch->qsm); in ch_cleanup()
504 return &ch->qsm; in ossl_quic_channel_get_qsm()
515 return ossl_quic_stream_map_get_by_id(&ch->qsm, stream_id); in ossl_quic_channel_get_stream_by_id()
1145 ossl_quic_stream_map_update_state(&ch->qsm, s); in do_update()
1682 ossl_quic_stream_map_visit(&ch->qsm, do_update, ch); in ch_on_transport_params()
1964 ossl_quic_stream_map_gc(&ch->qsm); in ossl_quic_channel_subtick()
3537 ossl_quic_stream_map_release(&ch->qsm, qs); in ossl_quic_channel_new_stream_local()
3557 qs = ossl_quic_stream_map_alloc(&ch->qsm, stream_id, in ossl_quic_channel_new_stream_remote()
3574 ossl_quic_stream_map_release(&ch->qsm, qs); in ossl_quic_channel_new_stream_remote()
[all …]
H A Dquic_impl.c1195 QUIC_STREAM_MAP *qsm; in qc_shutdown_flush_init() local
1200 qsm = ossl_quic_channel_get_qsm(qc->ch); in qc_shutdown_flush_init()
1202 ossl_quic_stream_map_begin_shutdown_flush(qsm); in qc_shutdown_flush_init()
2488 QUIC_STREAM_MAP *qsm; in quic_validate_for_write() local
2502 qsm = ossl_quic_channel_get_qsm(xso->conn->ch); in quic_validate_for_write()
2619 QUIC_STREAM_MAP *qsm; in quic_validate_for_read() local
2644 qsm = ossl_quic_channel_get_qsm(xso->conn->ch); in quic_validate_for_read()
3557 QUIC_STREAM_MAP *qsm; in ossl_quic_accept_stream() local
3573 qsm = ossl_quic_channel_get_qsm(ctx.qc->ch); in ossl_quic_accept_stream()
3575 qs = ossl_quic_stream_map_peek_accept_queue(qsm); in ossl_quic_accept_stream()
[all …]
H A Dquic_tserver.c482 QUIC_STREAM_MAP *qsm = ossl_quic_channel_get_qsm(srv->ch); in ossl_quic_tserver_pop_incoming_stream() local
483 QUIC_STREAM *qs = ossl_quic_stream_map_peek_accept_queue(qsm); in ossl_quic_tserver_pop_incoming_stream()
488 ossl_quic_stream_map_remove_from_accept_queue(qsm, qs, ossl_time_zero()); in ossl_quic_tserver_pop_incoming_stream()
H A Dquic_channel_local.h78 QUIC_STREAM_MAP qsm; member
/openssl/include/internal/
H A Dquic_stream_map.h580 int ossl_quic_stream_map_init(QUIC_STREAM_MAP *qsm,
591 void ossl_quic_stream_map_cleanup(QUIC_STREAM_MAP *qsm);
602 QUIC_STREAM *ossl_quic_stream_map_alloc(QUIC_STREAM_MAP *qsm,
616 void ossl_quic_stream_map_visit(QUIC_STREAM_MAP *qsm,
623 QUIC_STREAM *ossl_quic_stream_map_get_by_id(QUIC_STREAM_MAP *qsm,
678 int ossl_quic_stream_map_ensure_send_part_id(QUIC_STREAM_MAP *qsm,
693 int ossl_quic_stream_map_notify_all_data_sent(QUIC_STREAM_MAP *qsm,
774 int ossl_quic_stream_map_notify_totally_read(QUIC_STREAM_MAP *qsm,
825 void ossl_quic_stream_map_push_accept_queue(QUIC_STREAM_MAP *qsm,
859 void ossl_quic_stream_map_gc(QUIC_STREAM_MAP *qsm);
[all …]
H A Dquic_txp.h44 QUIC_STREAM_MAP *qsm; /* QUIC Streams Map */ member
/openssl/test/
H A Dquic_txp_test.c54 QUIC_STREAM_MAP qsm; member
101 ossl_quic_stream_map_cleanup(&h->qsm); in helper_cleanup()
188 if (!TEST_true(ossl_quic_stream_map_init(&h->qsm, NULL, NULL, in helper_init()
202 h->args.qsm = &h->qsm; in helper_init()
1500 ossl_quic_stream_map_release(h.args.qsm, s); in run_script()
1510 if (!TEST_ptr(s = ossl_quic_stream_map_get_by_id(h.args.qsm, in run_script()
1521 ossl_quic_stream_map_update_state(h.args.qsm, s); in run_script()
1528 if (!TEST_ptr(s = ossl_quic_stream_map_get_by_id(h.args.qsm, in run_script()
1547 ossl_quic_stream_map_update_state(h.args.qsm, s); in run_script()
1565 ossl_quic_stream_map_update_state(h.args.qsm, s); in run_script()
[all …]
/openssl/doc/designs/quic-design/
H A Dtx-packetiser.md28 QUIC_STREAM_MAP *qsm; /* QUIC Streams Map */

Completed in 83 milliseconds