diff options
Diffstat (limited to 'ssl/quic/quic_impl.c')
| -rw-r--r-- | ssl/quic/quic_impl.c | 11 |
1 files changed, 9 insertions, 2 deletions
diff --git a/ssl/quic/quic_impl.c b/ssl/quic/quic_impl.c index 3add9542ef..13d929b926 100644 --- a/ssl/quic/quic_impl.c +++ b/ssl/quic/quic_impl.c @@ -2441,6 +2441,11 @@ static int quic_write_nonblocking_epw(QCTX *ctx, const void *buf, size_t len, } quic_post_write(xso, *written > 0, 1); + + if (*written == 0) + /* SSL_write_ex returns 0 if it didn't read anything .*/ + return QUIC_RAISE_NORMAL_ERROR(ctx, SSL_ERROR_WANT_READ); + return 1; } @@ -2823,11 +2828,13 @@ static size_t ossl_quic_pending_int(const SSL *s, int check_channel) } if (check_channel) - avail = ossl_quic_stream_recv_pending(ctx.xso->stream) + avail = ossl_quic_stream_recv_pending(ctx.xso->stream, + /*include_fin=*/1) || ossl_quic_channel_has_pending(ctx.qc->ch) || ossl_quic_channel_is_term_any(ctx.qc->ch); else - avail = ossl_quic_stream_recv_pending(ctx.xso->stream); + avail = ossl_quic_stream_recv_pending(ctx.xso->stream, + /*include_fin=*/0); out: quic_unlock(ctx.qc); |