# HG changeset patch
# User Roman Arutyunyan <arut@nginx.com>
# Date 1672932528 -14400
# Thu Jan 05 19:28:48 2023 +0400
# Branch quic
# Node ID 18cc0fb5509d09d241d1235c754031304fa51685
# Parent f89ce033b2fa161f7258f824dcf3c6ef2051f45f
QUIC: set stream error flag on reset.

Now, when RESET_STREAM is sent or received, or when streams are closed, stream
connection error flag is set. Previously, only stream state was changed, which
resulted in setting the error flag only after calling
recv()/send()/send_chain(). However, there are cases when none of these
functions is called, but it's still important to know if the stream is being
closed. For example, when an HTTP/3 request stream is blocked on insert count,
receiving RESET_STREAM should trigger stream closure, which was not the case.

The change also fixes ngx_http_test_reading() and
ngx_http_upstream_check_broken_connection() with QUIC streams.

diff --git a/src/event/quic/ngx_event_quic_streams.c b/src/event/quic/ngx_event_quic_streams.c
--- a/src/event/quic/ngx_event_quic_streams.c
+++ b/src/event/quic/ngx_event_quic_streams.c
@@ -203,6 +203,9 @@ ngx_quic_close_streams(ngx_connection_t
continue;
}

+ sc->read->error = 1;
+ sc->write->error = 1;
+
ngx_quic_set_event(sc->read);
ngx_quic_set_event(sc->write);

@@ -245,6 +248,10 @@ ngx_quic_do_reset_stream(ngx_quic_stream
qs->send_state = NGX_QUIC_STREAM_SEND_RESET_SENT;
qs->send_final_size = qs->send_offset;

+ if (qs->connection) {
+ qs->connection->write->error = 1;
+ }
+
pc = qs->parent;
qc = ngx_quic_get_connection(pc);

@@ -804,7 +811,6 @@ ngx_quic_stream_recv(ngx_connection_t *c
|| qs->recv_state == NGX_QUIC_STREAM_RECV_RESET_READ)
{
qs->recv_state = NGX_QUIC_STREAM_RECV_RESET_READ;
- rev->error = 1;
return NGX_ERROR;
}

@@ -1382,6 +1388,7 @@ ngx_int_t
ngx_quic_handle_reset_stream_frame(ngx_connection_t *c,
ngx_quic_header_t *pkt, ngx_quic_reset_stream_frame_t *f)
{
+ ngx_event_t *rev;
ngx_quic_stream_t *qs;
ngx_quic_connection_t *qc;

@@ -1438,7 +1445,10 @@ ngx_quic_handle_reset_stream_frame(ngx_c
return ngx_quic_close_stream(qs);
}

- ngx_quic_set_event(qs->connection->read);
+ rev = qs->connection->read;
+ rev->error = 1;
+
+ ngx_quic_set_event(rev);

return NGX_OK;
}
_______________________________________________
nginx-devel mailing list
nginx-devel@nginx.org
https://mailman.nginx.org/mailman/listinfo/nginx-devel