Lines Matching refs:stream
492 if (( ctx.xso->stream->send_state == QUIC_SSTREAM_STATE_READY in ossl_quic_free()
493 || ctx.xso->stream->send_state == QUIC_SSTREAM_STATE_SEND) in ossl_quic_free()
494 && !ossl_quic_sstream_get_final_size(ctx.xso->stream->sstream, NULL)) in ossl_quic_free()
496 ctx.xso->stream, 0); in ossl_quic_free()
499 if ( ctx.xso->stream->recv_state == QUIC_RSTREAM_STATE_RECV in ossl_quic_free()
500 || ctx.xso->stream->recv_state == QUIC_RSTREAM_STATE_SIZE_KNOWN) in ossl_quic_free()
502 ctx.xso->stream, 0); in ossl_quic_free()
505 ctx.xso->stream->deleted = 1; in ossl_quic_free()
507 ctx.xso->stream); in ossl_quic_free()
710 if (xso->stream->rstream != NULL) in xso_update_options()
711 ossl_quic_rstream_set_cleanse(xso->stream->rstream, cleanse); in xso_update_options()
713 if (xso->stream->sstream != NULL) in xso_update_options()
714 ossl_quic_sstream_set_cleanse(xso->stream->sstream, cleanse); in xso_update_options()
1967 xso->stream = qs; in create_xso_from_stream()
2190 xso->stream); in quic_post_write()
2193 ossl_quic_sstream_fin(xso->stream->sstream); in quic_post_write()
2252 QUIC_SSTREAM *sstream = xso->stream->sstream; in xso_sstream_append()
2254 uint64_t cwm = ossl_quic_txfc_get_cwm(&xso->stream->txfc); in xso_sstream_append()
2490 if (xso == NULL || xso->stream == NULL) { in quic_validate_for_write()
2495 switch (xso->stream->send_state) { in quic_validate_for_write()
2504 if (!ossl_quic_stream_map_ensure_send_part_id(qsm, xso->stream)) { in quic_validate_for_write()
2513 if (ossl_quic_sstream_get_final_size(xso->stream->sstream, NULL)) { in quic_validate_for_write()
2609 QUIC_STREAM *stream; member
2623 if (xso == NULL || xso->stream == NULL) { in quic_validate_for_read()
2628 switch (xso->stream->recv_state) { in quic_validate_for_read()
2645 ossl_quic_stream_map_notify_app_read_reset_recv_part(qsm, xso->stream); in quic_validate_for_read()
2656 QUIC_STREAM *stream, in quic_read_actual() argument
2674 if (!ossl_quic_rstream_peek(stream->rstream, buf, buf_len, in quic_read_actual()
2679 if (!ossl_quic_rstream_read(stream->rstream, buf, buf_len, in quic_read_actual()
2696 if (!ossl_quic_rxfc_on_retire(&stream->rxfc, *bytes_read, in quic_read_actual()
2704 ossl_quic_stream_map_notify_totally_read(qsm, ctx->xso->stream); in quic_read_actual()
2709 stream); in quic_read_actual()
2731 if (!quic_read_actual(args->ctx, args->stream, in quic_read_again()
2783 if (!quic_read_actual(&ctx, ctx.xso->stream, buf, len, bytes_read, peek)) { in quic_read()
2802 args.stream = ctx.xso->stream; in quic_read()
2826 if (!quic_read_actual(&ctx, ctx.xso->stream, buf, len, bytes_read, peek)) { in quic_read()
2881 if (ctx.xso->stream == NULL) { in ossl_quic_pending_int()
2887 avail = ossl_quic_stream_recv_pending(ctx.xso->stream, in ossl_quic_pending_int()
2892 avail = ossl_quic_stream_recv_pending(ctx.xso->stream, in ossl_quic_pending_int()
2925 qs = ctx.xso->stream; in ossl_quic_conn_stream_conclude()
3014 if (ossl_quic_stream_is_bidi(ctx.xso->stream)) in ossl_quic_get_stream_type()
3017 if (ossl_quic_stream_is_server_init(ctx.xso->stream) != ctx.qc->as_server) in ossl_quic_get_stream_type()
3036 id = ctx.xso->stream->id; in ossl_quic_get_stream_id()
3055 is_local = ossl_quic_stream_is_local_init(ctx.xso->stream); in ossl_quic_is_stream_local()
3126 int ossl_quic_attach_stream(SSL *conn, SSL *stream) in ossl_quic_attach_stream() argument
3135 if (stream == NULL || stream->type != SSL_TYPE_QUIC_XSO) in ossl_quic_attach_stream()
3139 xso = (QUIC_XSO *)stream; in ossl_quic_attach_stream()
3422 if (!ossl_quic_stream_has_send(ctx->xso->stream)) { in qc_get_stream_write_buf_stat()
3427 if (ossl_quic_stream_has_send_buffer(ctx->xso->stream)) in qc_get_stream_write_buf_stat()
3428 value = getter(ctx->xso->stream->sstream); in qc_get_stream_write_buf_stat()
3654 qs = ctx.xso->stream; in ossl_quic_stream_reset()
3743 quic_classify_stream(ctx.qc, ctx.xso->stream, is_write, &state, NULL); in quic_get_stream_state()
3775 quic_classify_stream(ctx.qc, ctx.xso->stream, /*is_write=*/0, in quic_get_stream_error_code()
3816 if (!ossl_quic_stream_has_send(ctx.xso->stream)) { in ossl_quic_set_write_buffer_size()
3822 if (!ossl_quic_stream_has_send_buffer(ctx.xso->stream)) { in ossl_quic_set_write_buffer_size()
3831 if (!ossl_quic_sstream_set_buffer_size(ctx.xso->stream->sstream, size)) { in ossl_quic_set_write_buffer_size()
4039 if (xso->stream->recv_state == QUIC_RSTREAM_STATE_DATA_READ) in test_poll_event_r()
4042 return ossl_quic_stream_has_recv_buffer(xso->stream) in test_poll_event_r()
4043 && ossl_quic_rstream_available(xso->stream->rstream, &avail, &fin) in test_poll_event_r()
4051 return ossl_quic_stream_has_recv(xso->stream) in test_poll_event_er()
4052 && ossl_quic_stream_recv_is_reset(xso->stream) in test_poll_event_er()
4061 && ossl_quic_stream_has_send_buffer(xso->stream) in test_poll_event_w()
4062 && ossl_quic_sstream_get_buffer_avail(xso->stream->sstream) in test_poll_event_w()
4063 && !ossl_quic_sstream_get_final_size(xso->stream->sstream, NULL) in test_poll_event_w()
4071 return ossl_quic_stream_has_send(xso->stream) in test_poll_event_ew()
4072 && xso->stream->peer_stop_sending in test_poll_event_ew()
