Home
last modified time | relevance | path

Searched refs:rxfc (Results 1 – 12 of 12) sorted by relevance

/openssl/ssl/quic/
H A Dquic_fc.c180 rxfc->epoch_start = rxfc->now(rxfc->now_arg); in rxfc_start_epoch()
181 rxfc->esrwm = rxfc->rwm; in rxfc_start_epoch()
187 uint64_t credit = rxfc->cwm - rxfc->swm; in on_rx_controlled_bytes()
203 if (!rxfc->standalone && rxfc->parent == NULL) in ossl_quic_rxfc_on_rx_stream_frame()
206 if (rxfc->is_fin && ((is_fin && rxfc->hwm != end) || end > rxfc->hwm)) { in ossl_quic_rxfc_on_rx_stream_frame()
237 uint64_t window_rem = rxfc->cwm - rxfc->rwm; in rxfc_cwm_bump_desired()
277 uint64_t b = rxfc->rwm - rxfc->esrwm; in rxfc_should_bump_window_size()
283 now = rxfc->now(rxfc->now_arg); in rxfc_should_bump_window_size()
320 new_cwm = rxfc->rwm + rxfc->cur_window_size; in rxfc_update_cwm()
344 if (rxfc->parent == NULL && !rxfc->standalone) in ossl_quic_rxfc_on_retire()
[all …]
H A Dquic_rstream.c18 QUIC_RXFC *rxfc; member
24 QUIC_RSTREAM *ossl_quic_rstream_new(QUIC_RXFC *rxfc, in ossl_quic_rstream_new() argument
39 ret->rxfc = rxfc; in ossl_quic_rstream_new()
160 if (qrs->rxfc != NULL in ossl_quic_rstream_read()
161 && !ossl_quic_rxfc_on_retire(qrs->rxfc, *readbytes, rtt)) in ossl_quic_rstream_read()
253 if (qrs->rxfc != NULL) { in ossl_quic_rstream_release_record()
256 if (!ossl_quic_rxfc_on_retire(qrs->rxfc, offset, rtt)) in ossl_quic_rstream_release_record()
H A Dquic_rx_depack.c184 if (!ossl_quic_rxfc_on_rx_stream_frame(&stream->rxfc, in depack_do_frame_reset_stream()
194 fce = ossl_quic_rxfc_get_error(&stream->rxfc, 0); in depack_do_frame_reset_stream()
269 QUIC_RXFC *rxfc; in depack_do_frame_crypto() local
293 rxfc = &ch->crypto_rxfc[ackm_data->pkt_space]; in depack_do_frame_crypto()
295 if (!ossl_quic_rxfc_on_rx_stream_frame(rxfc, f.offset + f.len, in depack_do_frame_crypto()
304 if (ossl_quic_rxfc_get_error(rxfc, 0) != OSSL_QUIC_ERR_NO_ERROR) { in depack_do_frame_crypto()
537 if (!ossl_quic_rxfc_on_rx_stream_frame(&stream->rxfc, in depack_do_frame_stream()
548 fce = ossl_quic_rxfc_get_error(&stream->rxfc, 0); in depack_do_frame_stream()
H A Dquic_tserver.c297 if (!ossl_quic_rxfc_on_retire(&qs->rxfc, *bytes_read, in ossl_quic_tserver_read()
H A Dquic_stream_map.c363 || ossl_quic_rxfc_has_cwm_changed(&s->rxfc, 0)))) in ossl_quic_stream_map_update_state()
H A Dquic_txp.c2499 || ossl_quic_rxfc_has_cwm_changed(&stream->rxfc, 0))) { in txp_generate_stream_related()
2505 cwm = ossl_quic_rxfc_get_cwm(&stream->rxfc); in txp_generate_stream_related()
2960 ossl_quic_rxfc_has_cwm_changed(&stream->rxfc, 1); in txp_pkt_commit()
H A Dquic_channel.c3439 if (!ossl_quic_rxfc_init(&qs->rxfc, &ch->conn_rxfc, in ch_init_new_stream()
H A Dquic_impl.c2696 if (!ossl_quic_rxfc_on_retire(&stream->rxfc, *bytes_read, in quic_read_actual()
/openssl/include/internal/
H A Dquic_fc.h153 int ossl_quic_rxfc_init(QUIC_RXFC *rxfc, QUIC_RXFC *conn_rxfc,
164 int ossl_quic_rxfc_init_standalone(QUIC_RXFC *rxfc,
173 QUIC_RXFC *ossl_quic_rxfc_get_parent(QUIC_RXFC *rxfc);
178 void ossl_quic_rxfc_set_max_window_size(QUIC_RXFC *rxfc,
199 int ossl_quic_rxfc_on_rx_stream_frame(QUIC_RXFC *rxfc,
219 int ossl_quic_rxfc_on_retire(QUIC_RXFC *rxfc,
232 uint64_t ossl_quic_rxfc_get_cwm(const QUIC_RXFC *rxfc);
239 uint64_t ossl_quic_rxfc_get_swm(const QUIC_RXFC *rxfc);
245 uint64_t ossl_quic_rxfc_get_rwm(const QUIC_RXFC *rxfc);
251 uint64_t ossl_quic_rxfc_get_credit(const QUIC_RXFC *rxfc);
[all …]
H A Dquic_stream_map.h156 QUIC_RXFC rxfc; /* NULL if TX-only */ member
499 if (!ossl_assert(ossl_quic_rxfc_get_final_size(&s->rxfc, final_size))) in ossl_quic_stream_recv_get_final_size()
H A Dquic_stream.h324 QUIC_RSTREAM *ossl_quic_rstream_new(QUIC_RXFC *rxfc,
/openssl/test/
H A Dquic_txp_test.c1493 || !TEST_true(ossl_quic_rxfc_init(&s->rxfc, &h.conn_rxfc, in run_script()
1497 || !TEST_ptr(s->rstream = ossl_quic_rstream_new(&s->rxfc, in run_script()

Completed in 66 milliseconds