Home
last modified time | relevance | path

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

/freebsd/crypto/openssl/ssl/quic/
H A Dquic_stream_map.c19 static void shutdown_flush_done(QUIC_STREAM_MAP *qsm, QUIC_STREAM *qs);
88 int ossl_quic_stream_map_init(QUIC_STREAM_MAP *qsm, in ossl_quic_stream_map_init() argument
95 qsm->map = lh_QUIC_STREAM_new(hash_stream, cmp_stream); in ossl_quic_stream_map_init()
96 qsm->active_list.prev = qsm->active_list.next = &qsm->active_list; in ossl_quic_stream_map_init()
97 qsm->accept_list.prev = qsm->accept_list.next = &qsm->accept_list; in ossl_quic_stream_map_init()
98 qsm->ready_for_gc_list.prev = qsm->ready_for_gc_list.next in ossl_quic_stream_map_init()
99 = &qsm->ready_for_gc_list; in ossl_quic_stream_map_init()
100 qsm->rr_stepping = 1; in ossl_quic_stream_map_init()
101 qsm->rr_counter = 0; in ossl_quic_stream_map_init()
102 qsm->rr_cur = NULL; in ossl_quic_stream_map_init()
[all …]
H A Dquic_rx_depack.c210 ossl_quic_stream_map_notify_reset_recv_part(&ch->qsm, stream, in depack_do_frame_reset_stream()
214 ossl_quic_stream_map_update_state(&ch->qsm, stream); in depack_do_frame_reset_stream()
258 ossl_quic_stream_map_reset_stream_send_part(&ch->qsm, stream, in depack_do_frame_stop_sending()
378 stream = ossl_quic_stream_map_get_by_id(&ch->qsm, stream_id); in depack_do_implicit_stream_create()
585 ossl_quic_stream_map_notify_size_known_recv_part(&ch->qsm, stream, in depack_do_frame_stream()
637 ossl_quic_stream_map_notify_totally_received(&ch->qsm, stream); in depack_do_frame_stream()
648 ossl_quic_stream_map_update_state(&ch->qsm, s); in update_streams()
658 ossl_quic_stream_map_update_state(&ch->qsm, s); in update_streams_bidi()
668 ossl_quic_stream_map_update_state(&ch->qsm, s); in update_streams_uni()
685 ossl_quic_stream_map_visit(&ch->qsm, update_streams, ch); in depack_do_frame_max_data()
[all …]
H A Dquic_txp.c547 || args->qsm == NULL in ossl_quic_tx_packetiser_new()
1572 ossl_quic_stream_iter_init(&it, txp->args.qsm, 0); in txp_should_try_staging()
1629 s = ossl_quic_stream_map_get_by_id(txp->args.qsm, stream_id); in get_sstream_by_id()
1659 = ossl_quic_stream_map_get_by_id(txp->args.qsm, stream_id); in on_regen_notify()
1665 ossl_quic_stream_map_update_state(txp->args.qsm, s); in on_regen_notify()
1669 = ossl_quic_stream_map_get_by_id(txp->args.qsm, stream_id); in on_regen_notify()
1674 ossl_quic_stream_map_schedule_stop_sending(txp->args.qsm, s); in on_regen_notify()
1678 = ossl_quic_stream_map_get_by_id(txp->args.qsm, stream_id); in on_regen_notify()
1684 ossl_quic_stream_map_update_state(txp->args.qsm, s); in on_regen_notify()
1791 = ossl_quic_stream_map_get_by_id(txp->args.qsm, stream_id); in on_confirm_notify()
[all …]
H A Dquic_channel.c247 if (!ossl_quic_stream_map_init(&ch->qsm, get_stream_limit, ch, in ch_init()
266 txp_args.qsm = &ch->qsm; in ch_init()
411 ossl_quic_stream_map_cleanup(&ch->qsm); in ch_cleanup()
544 return &ch->qsm; in ossl_quic_channel_get_qsm()
614 return ossl_quic_stream_map_get_by_id(&ch->qsm, stream_id); in ossl_quic_channel_get_stream_by_id()
1285 ossl_quic_stream_map_update_state(&ch->qsm, s); in do_update()
1490 ossl_quic_stream_map_visit(&ch->qsm, txfc_bump_cwm_bidi, &v); in ch_on_transport_params()
1509 ossl_quic_stream_map_visit(&ch->qsm, txfc_bump_cwm_uni, &v); in ch_on_transport_params()
1830 ossl_quic_stream_map_visit(&ch->qsm, do_update, ch); in ch_on_transport_params()
2139 ossl_quic_stream_map_gc(&ch->qsm); in ossl_quic_channel_subtick()
[all …]
H A Dquic_impl.c1460 QUIC_STREAM_MAP *qsm; in qc_shutdown_flush_init() local
1465 qsm = ossl_quic_channel_get_qsm(qc->ch); in qc_shutdown_flush_init()
1467 ossl_quic_stream_map_begin_shutdown_flush(qsm); in qc_shutdown_flush_init()
1475 QUIC_STREAM_MAP *qsm = ossl_quic_channel_get_qsm(qc->ch); in qc_shutdown_flush_finished() local
1478 && ossl_quic_stream_map_is_shutdown_flush_finished(qsm); in qc_shutdown_flush_finished()
2764 QUIC_STREAM_MAP *qsm; in quic_validate_for_write() local
2778 qsm = ossl_quic_channel_get_qsm(xso->conn->ch); in quic_validate_for_write()
2780 if (!ossl_quic_stream_map_ensure_send_part_id(qsm, xso->stream)) { in quic_validate_for_write()
2898 QUIC_STREAM_MAP *qsm; in quic_validate_for_read() local
2923 qsm = ossl_quic_channel_get_qsm(xso->conn->ch); in quic_validate_for_read()
[all …]
H A Dquic_tserver.c486 QUIC_STREAM_MAP *qsm = ossl_quic_channel_get_qsm(srv->ch); in ossl_quic_tserver_pop_incoming_stream() local
487 QUIC_STREAM *qs = ossl_quic_stream_map_peek_accept_queue(qsm); in ossl_quic_tserver_pop_incoming_stream()
492 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.h89 QUIC_STREAM_MAP qsm; member
/freebsd/crypto/openssl/include/internal/
H A Dquic_stream_map.h582 int ossl_quic_stream_map_init(QUIC_STREAM_MAP *qsm,
593 void ossl_quic_stream_map_cleanup(QUIC_STREAM_MAP *qsm);
604 QUIC_STREAM *ossl_quic_stream_map_alloc(QUIC_STREAM_MAP *qsm,
612 void ossl_quic_stream_map_release(QUIC_STREAM_MAP *qsm, QUIC_STREAM *stream);
618 void ossl_quic_stream_map_visit(QUIC_STREAM_MAP *qsm,
625 QUIC_STREAM *ossl_quic_stream_map_get_by_id(QUIC_STREAM_MAP *qsm,
639 void ossl_quic_stream_map_update_state(QUIC_STREAM_MAP *qsm, QUIC_STREAM *s);
645 void ossl_quic_stream_map_set_rr_stepping(QUIC_STREAM_MAP *qsm, size_t stepping);
654 int ossl_quic_stream_map_is_local_allowed_by_stream_limit(QUIC_STREAM_MAP *qsm,
680 int ossl_quic_stream_map_ensure_send_part_id(QUIC_STREAM_MAP *qsm,
[all …]
H A Dquic_txp.h44 QUIC_STREAM_MAP *qsm; /* QUIC Streams Map */ member
/freebsd/crypto/openssl/test/
H A Dquic_txp_test.c68 QUIC_STREAM_MAP qsm; member
115 ossl_quic_stream_map_cleanup(&h->qsm); in helper_cleanup()
203 if (!TEST_true(ossl_quic_stream_map_init(&h->qsm, NULL, NULL, in helper_init()
217 h->args.qsm = &h->qsm; in helper_init()
1506 if (!TEST_ptr(s = ossl_quic_stream_map_alloc(h.args.qsm, op->arg0, in run_script()
1519 ossl_quic_stream_map_release(h.args.qsm, s); in run_script()
1527 if (!TEST_ptr(s = ossl_quic_stream_map_get_by_id(h.args.qsm, in run_script()
1538 ossl_quic_stream_map_update_state(h.args.qsm, s); in run_script()
1543 if (!TEST_ptr(s = ossl_quic_stream_map_get_by_id(h.args.qsm, in run_script()
1552 if (!TEST_ptr(s = ossl_quic_stream_map_get_by_id(h.args.qsm, in run_script()
[all …]
/freebsd/crypto/openssl/doc/designs/quic-design/
H A Dtx-packetiser.md28 QUIC_STREAM_MAP *qsm; /* QUIC Streams Map */