| /src/crypto/external/apache2/openssl/dist/ssl/quic/ |
| quic_stream_map.c | 19 static void shutdown_flush_done(QUIC_STREAM_MAP *qsm, QUIC_STREAM *qs);
88 int ossl_quic_stream_map_init(QUIC_STREAM_MAP *qsm,
95 qsm->map = lh_QUIC_STREAM_new(hash_stream, cmp_stream);
96 qsm->active_list.prev = qsm->active_list.next = &qsm->active_list;
97 qsm->accept_list.prev = qsm->accept_list.next = &qsm->accept_list;
98 qsm->ready_for_gc_list.prev = qsm->ready_for_gc_list.nex
118 QUIC_STREAM_MAP *qsm = arg; local
808 QUIC_STREAM_MAP *qsm = arg; local
[all...] |
| quic_rx_depack.c | 210 ossl_quic_stream_map_notify_reset_recv_part(&ch->qsm, stream,
214 ossl_quic_stream_map_update_state(&ch->qsm, stream);
258 ossl_quic_stream_map_reset_stream_send_part(&ch->qsm, stream,
378 stream = ossl_quic_stream_map_get_by_id(&ch->qsm, stream_id);
585 ossl_quic_stream_map_notify_size_known_recv_part(&ch->qsm, stream,
637 ossl_quic_stream_map_notify_totally_received(&ch->qsm, stream);
648 ossl_quic_stream_map_update_state(&ch->qsm, s);
658 ossl_quic_stream_map_update_state(&ch->qsm, s);
668 ossl_quic_stream_map_update_state(&ch->qsm, s);
685 ossl_quic_stream_map_visit(&ch->qsm, update_streams, ch)
[all...] |
| quic_channel_local.h | 89 QUIC_STREAM_MAP qsm; member in struct:quic_channel_st
346 /* Have statm, qsm been initialised? Used to track cleanup. */
|
| quic_channel.c | 247 if (!ossl_quic_stream_map_init(&ch->qsm, get_stream_limit, ch,
266 txp_args.qsm = &ch->qsm;
411 ossl_quic_stream_map_cleanup(&ch->qsm);
544 return &ch->qsm;
614 return ossl_quic_stream_map_get_by_id(&ch->qsm, stream_id);
704 /* Used by QSM. */
1285 ossl_quic_stream_map_update_state(&ch->qsm, s);
1490 ossl_quic_stream_map_visit(&ch->qsm, txfc_bump_cwm_bidi, &v);
1509 ossl_quic_stream_map_visit(&ch->qsm, txfc_bump_cwm_uni, &v)
[all...] |
| quic_txp.c | 547 || args->qsm == NULL
1572 ossl_quic_stream_iter_init(&it, txp->args.qsm, 0);
1629 s = ossl_quic_stream_map_get_by_id(txp->args.qsm, stream_id);
1659 = ossl_quic_stream_map_get_by_id(txp->args.qsm, stream_id);
1665 ossl_quic_stream_map_update_state(txp->args.qsm, s);
1669 = ossl_quic_stream_map_get_by_id(txp->args.qsm, stream_id);
1674 ossl_quic_stream_map_schedule_stop_sending(txp->args.qsm, s);
1678 = ossl_quic_stream_map_get_by_id(txp->args.qsm, stream_id);
1684 ossl_quic_stream_map_update_state(txp->args.qsm, s);
1791 = ossl_quic_stream_map_get_by_id(txp->args.qsm, stream_id)
[all...] |
| quic_tserver.c | 486 QUIC_STREAM_MAP *qsm = ossl_quic_channel_get_qsm(srv->ch); local
487 QUIC_STREAM *qs = ossl_quic_stream_map_peek_accept_queue(qsm);
492 ossl_quic_stream_map_remove_from_accept_queue(qsm, qs, ossl_time_zero());
|
| quic_impl.c | 817 * stage, but is freed during the channel free when the whole QSM is freed.
1460 QUIC_STREAM_MAP *qsm; local
1465 qsm = ossl_quic_channel_get_qsm(qc->ch);
1467 ossl_quic_stream_map_begin_shutdown_flush(qsm);
1475 QUIC_STREAM_MAP *qsm = ossl_quic_channel_get_qsm(qc->ch); local
1478 && ossl_quic_stream_map_is_shutdown_flush_finished(qsm);
2764 QUIC_STREAM_MAP *qsm; local
2778 qsm = ossl_quic_channel_get_qsm(xso->conn->ch);
2780 if (!ossl_quic_stream_map_ensure_send_part_id(qsm, xso->stream)) {
2898 QUIC_STREAM_MAP *qsm; local
2981 QUIC_STREAM_MAP *qsm = ossl_quic_channel_get_qsm(ctx->qc->ch); local
3865 QUIC_STREAM_MAP *qsm = ossl_quic_channel_get_qsm(qc->ch); local
3886 QUIC_STREAM_MAP *qsm; local
3974 QUIC_STREAM_MAP *qsm; local
[all...] |
| /src/crypto/external/apache2/openssl/dist/include/internal/ |
| quic_stream_map.h | 381 * required is an optimisation which the QSM may, but is not obliged, to
420 * no longer required is an optimisation which the QSM may, but is not obliged,
582 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)
895 QUIC_STREAM_MAP *qsm; member in struct:quic_stream_iter_st
[all...] |
| quic_txp.h | 44 QUIC_STREAM_MAP *qsm; /* QUIC Streams Map */ member in struct:ossl_quic_tx_packetiser_args_st
|
| /src/crypto/external/apache2/openssl/dist/test/ |
| quic_txp_test.c | 68 QUIC_STREAM_MAP qsm; member in struct:helper
115 ossl_quic_stream_map_cleanup(&h->qsm);
203 if (!TEST_true(ossl_quic_stream_map_init(&h->qsm, NULL, NULL,
217 h->args.qsm = &h->qsm;
1506 if (!TEST_ptr(s = ossl_quic_stream_map_alloc(h.args.qsm, op->arg0,
1519 ossl_quic_stream_map_release(h.args.qsm, s);
1527 if (!TEST_ptr(s = ossl_quic_stream_map_get_by_id(h.args.qsm,
1538 ossl_quic_stream_map_update_state(h.args.qsm, s);
1543 if (!TEST_ptr(s = ossl_quic_stream_map_get_by_id(h.args.qsm,
[all...] |
