Home
last modified time | relevance | path

Searched refs:txfc (Results 1 – 10 of 10) sorted by relevance

/src/crypto/openssl/ssl/quic/
H A Dquic_fc.c23 int ossl_quic_txfc_init(QUIC_TXFC *txfc, QUIC_TXFC *conn_txfc) in OSSL_SAFE_MATH_UNSIGNED()
28 txfc->swm = 0; in OSSL_SAFE_MATH_UNSIGNED()
29 txfc->cwm = 0; in OSSL_SAFE_MATH_UNSIGNED()
30 txfc->parent = conn_txfc; in OSSL_SAFE_MATH_UNSIGNED()
31 txfc->has_become_blocked = 0; in OSSL_SAFE_MATH_UNSIGNED()
35 QUIC_TXFC *ossl_quic_txfc_get_parent(QUIC_TXFC *txfc) in ossl_quic_txfc_get_parent() argument
37 return txfc->parent; in ossl_quic_txfc_get_parent()
40 int ossl_quic_txfc_bump_cwm(QUIC_TXFC *txfc, uint64_t cwm) in ossl_quic_txfc_bump_cwm() argument
42 if (cwm <= txfc->cwm) in ossl_quic_txfc_bump_cwm()
45 txfc->cwm = cwm; in ossl_quic_txfc_bump_cwm()
[all …]
H A Dquic_stream_map.c271 fc_credit = ossl_quic_txfc_get_credit(&s->txfc, 0); in stream_has_data_to_send()
272 fc_swm = ossl_quic_txfc_get_swm(&s->txfc); in stream_has_data_to_send()
484 qs->send_final_size = ossl_quic_txfc_get_swm(&qs->txfc); in ossl_quic_stream_map_reset_stream_send_part()
H A Dquic_txp.c2568 if (!ossl_assert(f.final_size <= ossl_quic_txfc_get_swm(&stream->txfc))) in txp_generate_stream_related()
2572 = f.final_size - ossl_quic_txfc_get_swm(&stream->txfc); in txp_generate_stream_related()
2627 &stream->txfc, in txp_generate_stream_related()
3057 if (!ossl_assert(ossl_quic_txfc_consume_credit(&stream->txfc, in txp_pkt_commit()
H A Dquic_channel.c1269 ossl_quic_txfc_bump_cwm(&s->txfc, *(uint64_t *)arg); in txfc_bump_cwm_bidi()
1278 ossl_quic_txfc_bump_cwm(&s->txfc, *(uint64_t *)arg); in txfc_bump_cwm_uni()
3758 if (!ossl_quic_txfc_init(&qs->txfc, &ch->conn_txfc)) in ch_init_new_stream()
3777 ossl_quic_txfc_bump_cwm(&qs->txfc, cwm); in ch_init_new_stream()
H A Dquic_rx_depack.c723 ossl_quic_txfc_bump_cwm(&stream->txfc, max_stream_data); in depack_do_frame_max_stream_data()
H A Dquic_impl.c2519 uint64_t cwm = ossl_quic_txfc_get_cwm(&xso->stream->txfc); in xso_sstream_append()
5176 && ossl_quic_txfc_get_cwm(&xso->stream->txfc) in test_poll_event_w()
/src/crypto/openssl/test/
H A Dquic_fc_test.c17 QUIC_TXFC conn_txfc, stream_txfc, *txfc, *parent_txfc; in test_txfc() local
25 txfc = is_stream ? &stream_txfc : &conn_txfc; in test_txfc()
28 if (!TEST_true(ossl_quic_txfc_bump_cwm(txfc, 2000))) in test_txfc()
34 if (!TEST_uint64_t_eq(ossl_quic_txfc_get_swm(txfc), 0)) in test_txfc()
37 if (!TEST_uint64_t_eq(ossl_quic_txfc_get_cwm(txfc), 2000)) in test_txfc()
40 if (!TEST_uint64_t_eq(ossl_quic_txfc_get_credit_local(txfc, 0), 2000)) in test_txfc()
43 if (!TEST_uint64_t_eq(ossl_quic_txfc_get_credit_local(txfc, 100), 1900)) in test_txfc()
47 if (!TEST_uint64_t_eq(ossl_quic_txfc_get_credit(txfc, 0), 2000)) in test_txfc()
50 if (!TEST_uint64_t_eq(ossl_quic_txfc_get_credit(txfc, 100), 1900)) in test_txfc()
54 if (!TEST_false(ossl_quic_txfc_has_become_blocked(txfc, 0))) in test_txfc()
[all …]
H A Dquic_txp_test.c1511 || !TEST_true(ossl_quic_txfc_init(&s->txfc, &h.conn_txfc)) in run_script()
1593 if (!TEST_true(ossl_quic_txfc_bump_cwm(&s->txfc, op->arg0))) in run_script()
/src/crypto/openssl/include/internal/
H A Dquic_fc.h37 int ossl_quic_txfc_init(QUIC_TXFC *txfc, QUIC_TXFC *conn_txfc);
43 QUIC_TXFC *ossl_quic_txfc_get_parent(QUIC_TXFC *txfc);
55 int ossl_quic_txfc_bump_cwm(QUIC_TXFC *txfc, uint64_t cwm);
67 uint64_t ossl_quic_txfc_get_credit(QUIC_TXFC *txfc, uint64_t consumed);
75 uint64_t ossl_quic_txfc_get_credit_local(QUIC_TXFC *txfc, uint64_t consumed);
92 int ossl_quic_txfc_consume_credit(QUIC_TXFC *txfc, uint64_t num_bytes);
99 int ossl_quic_txfc_consume_credit_local(QUIC_TXFC *txfc, uint64_t num_bytes);
108 int ossl_quic_txfc_has_become_blocked(QUIC_TXFC *txfc, int clear);
114 uint64_t ossl_quic_txfc_get_cwm(QUIC_TXFC *txfc);
120 uint64_t ossl_quic_txfc_get_swm(QUIC_TXFC *txfc);
H A Dquic_stream_map.h155 QUIC_TXFC txfc; /* NULL if RX-only */ member