nginx: src/http/v3/ngx_http_v3

annotate src/http/v3/ngx_http_v3_uni.c @ 9189:fcec773dd249

QUIC: avoid partial expansion of PATH_CHALLENGE/PATH_RESPONSE. By default packets with these frames are expanded to 1200 bytes. Previously, if anti-amplification limit did not allow this expansion, it was limited to whatever size was allowed. However RFC 9000 clearly states no partial expansion should happen in both cases. Section 8.2.1. Initiating Path Validation: An endpoint MUST expand datagrams that contain a PATH_CHALLENGE frame to at least the smallest allowed maximum datagram size of 1200 bytes, unless the anti-amplification limit for the path does not permit sending a datagram of this size. Section 8.2.2. Path Validation Responses: An endpoint MUST expand datagrams that contain a PATH_RESPONSE frame to at least the smallest allowed maximum datagram size of 1200 bytes. ... However, an endpoint MUST NOT expand the datagram containing the PATH_RESPONSE if the resulting data exceeds the anti-amplification limit.

author	Roman Arutyunyan <arut@nginx.com>
date	Wed, 29 Nov 2023 18:13:25 +0400
parents	f742b1b46901
children

rev	line source
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	1
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	2 /*
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	3 * Copyright (C) Roman Arutyunyan
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	4 * Copyright (C) Nginx, Inc.
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	5 */
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	6
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	7
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	8 #include <ngx_config.h>
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	9 #include <ngx_core.h>
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	10 #include <ngx_http.h>
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	11
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	12
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	13 typedef struct {
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	14 ngx_http_v3_parse_uni_t parse;
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	15 ngx_int_t index;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	16 } ngx_http_v3_uni_stream_t;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	17
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	18
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	19 static void ngx_http_v3_close_uni_stream(ngx_connection_t *c);
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	20 static void ngx_http_v3_uni_read_handler(ngx_event_t *rev);
8991 3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	21 static void ngx_http_v3_uni_dummy_read_handler(ngx_event_t *wev);
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	22 static void ngx_http_v3_uni_dummy_write_handler(ngx_event_t *wev);
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	23 static ngx_connection_t ngx_http_v3_get_uni_stream(ngx_connection_t c,
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	24 ngx_uint_t type);
8725 98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	25
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	26
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8630 diff changeset	27 void
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8630 diff changeset	28 ngx_http_v3_init_uni_stream(ngx_connection_t *c)
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8630 diff changeset	29 {
8824 054f9be0aaf9 HTTP/3: http3_max_uni_streams directive. Roman Arutyunyan <arut@nginx.com> parents: 8821 diff changeset	30 uint64_t n;
9054 6546c2ae1c7b HTTP/3: unified hq code with regular HTTP/3 code. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	31 ngx_http_v3_session_t *h3c;
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8630 diff changeset	32 ngx_http_v3_uni_stream_t *us;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8630 diff changeset	33
9054 6546c2ae1c7b HTTP/3: unified hq code with regular HTTP/3 code. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	34 h3c = ngx_http_v3_get_session(c);
6546c2ae1c7b HTTP/3: unified hq code with regular HTTP/3 code. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	35 if (h3c->hq) {
6546c2ae1c7b HTTP/3: unified hq code with regular HTTP/3 code. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	36 ngx_http_v3_finalize_connection(c,
6546c2ae1c7b HTTP/3: unified hq code with regular HTTP/3 code. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	37 NGX_HTTP_V3_ERR_STREAM_CREATION_ERROR,
6546c2ae1c7b HTTP/3: unified hq code with regular HTTP/3 code. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	38 "uni stream in hq mode");
6546c2ae1c7b HTTP/3: unified hq code with regular HTTP/3 code. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	39 c->data = NULL;
6546c2ae1c7b HTTP/3: unified hq code with regular HTTP/3 code. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	40 ngx_http_v3_close_uni_stream(c);
6546c2ae1c7b HTTP/3: unified hq code with regular HTTP/3 code. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	41 return;
6546c2ae1c7b HTTP/3: unified hq code with regular HTTP/3 code. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	42 }
6546c2ae1c7b HTTP/3: unified hq code with regular HTTP/3 code. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	43
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8630 diff changeset	44 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 init uni stream");
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	45
8824 054f9be0aaf9 HTTP/3: http3_max_uni_streams directive. Roman Arutyunyan <arut@nginx.com> parents: 8821 diff changeset	46 n = c->quic->id >> 2;
054f9be0aaf9 HTTP/3: http3_max_uni_streams directive. Roman Arutyunyan <arut@nginx.com> parents: 8821 diff changeset	47
8924 d6ef13c5fd8e QUIC: simplified configuration. Vladimir Homutov <vl@nginx.com> parents: 8903 diff changeset	48 if (n >= NGX_HTTP_V3_MAX_UNI_STREAMS) {
8824 054f9be0aaf9 HTTP/3: http3_max_uni_streams directive. Roman Arutyunyan <arut@nginx.com> parents: 8821 diff changeset	49 ngx_http_v3_finalize_connection(c,
054f9be0aaf9 HTTP/3: http3_max_uni_streams directive. Roman Arutyunyan <arut@nginx.com> parents: 8821 diff changeset	50 NGX_HTTP_V3_ERR_STREAM_CREATION_ERROR,
054f9be0aaf9 HTTP/3: http3_max_uni_streams directive. Roman Arutyunyan <arut@nginx.com> parents: 8821 diff changeset	51 "reached maximum number of uni streams");
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	52 c->data = NULL;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	53 ngx_http_v3_close_uni_stream(c);
8824 054f9be0aaf9 HTTP/3: http3_max_uni_streams directive. Roman Arutyunyan <arut@nginx.com> parents: 8821 diff changeset	54 return;
054f9be0aaf9 HTTP/3: http3_max_uni_streams directive. Roman Arutyunyan <arut@nginx.com> parents: 8821 diff changeset	55 }
054f9be0aaf9 HTTP/3: http3_max_uni_streams directive. Roman Arutyunyan <arut@nginx.com> parents: 8821 diff changeset	56
9051 37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	57 ngx_quic_cancelable_stream(c);
8724 fc64ab301bad QUIC: connection shutdown. Roman Arutyunyan <arut@nginx.com> parents: 8723 diff changeset	58
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	59 us = ngx_pcalloc(c->pool, sizeof(ngx_http_v3_uni_stream_t));
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	60 if (us == NULL) {
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	61 ngx_http_v3_finalize_connection(c,
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	62 NGX_HTTP_V3_ERR_INTERNAL_ERROR,
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	63 "memory allocation error");
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	64 c->data = NULL;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	65 ngx_http_v3_close_uni_stream(c);
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8630 diff changeset	66 return;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	67 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	68
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	69 us->index = -1;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	70
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	71 c->data = us;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	72
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	73 c->read->handler = ngx_http_v3_uni_read_handler;
8991 3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	74 c->write->handler = ngx_http_v3_uni_dummy_write_handler;
8281 618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 8228 diff changeset	75
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	76 ngx_http_v3_uni_read_handler(c->read);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	77 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	78
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	79
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	80 static void
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	81 ngx_http_v3_close_uni_stream(ngx_connection_t *c)
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	82 {
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	83 ngx_pool_t *pool;
8770 67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8769 diff changeset	84 ngx_http_v3_session_t *h3c;
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	85 ngx_http_v3_uni_stream_t *us;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	86
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	87 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 close stream");
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	88
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	89 us = c->data;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	90
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	91 if (us && us->index >= 0) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	92 h3c = ngx_http_v3_get_session(c);
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	93 h3c->known_streams[us->index] = NULL;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	94 }
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	95
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	96 c->destroyed = 1;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	97
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	98 pool = c->pool;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	99
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	100 ngx_close_connection(c);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	101
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	102 ngx_destroy_pool(pool);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	103 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	104
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	105
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	106 ngx_int_t
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	107 ngx_http_v3_register_uni_stream(ngx_connection_t *c, uint64_t type)
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	108 {
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	109 ngx_int_t index;
8770 67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8769 diff changeset	110 ngx_http_v3_session_t *h3c;
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	111 ngx_http_v3_uni_stream_t *us;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	112
8821 d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	113 h3c = ngx_http_v3_get_session(c);
d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	114
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	115 switch (type) {
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	116
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	117 case NGX_HTTP_V3_STREAM_ENCODER:
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	118
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	119 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0,
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	120 "http3 encoder stream");
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	121 index = NGX_HTTP_V3_STREAM_CLIENT_ENCODER;
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	122 break;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	123
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	124 case NGX_HTTP_V3_STREAM_DECODER:
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	125
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	126 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0,
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	127 "http3 decoder stream");
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	128 index = NGX_HTTP_V3_STREAM_CLIENT_DECODER;
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	129 break;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	130
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	131 case NGX_HTTP_V3_STREAM_CONTROL:
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	132
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	133 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0,
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	134 "http3 control stream");
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	135 index = NGX_HTTP_V3_STREAM_CLIENT_CONTROL;
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	136
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	137 break;
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	138
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	139 default:
8460 72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	140
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	141 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	142 "http3 stream 0x%02xL", type);
8821 d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	143
d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	144 if (h3c->known_streams[NGX_HTTP_V3_STREAM_CLIENT_ENCODER] == NULL
d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	145 \|\| h3c->known_streams[NGX_HTTP_V3_STREAM_CLIENT_DECODER] == NULL
d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	146 \|\| h3c->known_streams[NGX_HTTP_V3_STREAM_CLIENT_CONTROL] == NULL)
d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	147 {
d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	148 ngx_log_error(NGX_LOG_INFO, c->log, 0, "missing mandatory stream");
d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	149 return NGX_HTTP_V3_ERR_STREAM_CREATION_ERROR;
d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	150 }
d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	151
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	152 index = -1;
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	153 }
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	154
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	155 if (index >= 0) {
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	156 if (h3c->known_streams[index]) {
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	157 ngx_log_error(NGX_LOG_INFO, c->log, 0, "stream exists");
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	158 return NGX_HTTP_V3_ERR_STREAM_CREATION_ERROR;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	159 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	160
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	161 h3c->known_streams[index] = c;
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	162
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	163 us = c->data;
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	164 us->index = index;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	165 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	166
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	167 return NGX_OK;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	168 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	169
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	170
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	171 static void
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	172 ngx_http_v3_uni_read_handler(ngx_event_t *rev)
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	173 {
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	174 u_char buf[128];
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	175 ssize_t n;
8838 d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	176 ngx_buf_t b;
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	177 ngx_int_t rc;
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	178 ngx_connection_t *c;
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	179 ngx_http_v3_session_t *h3c;
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	180 ngx_http_v3_uni_stream_t *us;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	181
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	182 c = rev->data;
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	183 us = c->data;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	184
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	185 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 read handler");
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	186
9051 37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	187 if (c->close) {
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	188 ngx_http_v3_close_uni_stream(c);
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	189 return;
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	190 }
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	191
8838 d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	192 ngx_memzero(&b, sizeof(ngx_buf_t));
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	193
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	194 while (rev->ready) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	195
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	196 n = c->recv(c, buf, sizeof(buf));
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	197
8460 72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	198 if (n == NGX_ERROR) {
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	199 rc = NGX_HTTP_V3_ERR_INTERNAL_ERROR;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	200 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	201 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	202
8460 72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	203 if (n == 0) {
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	204 if (us->index >= 0) {
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	205 rc = NGX_HTTP_V3_ERR_CLOSED_CRITICAL_STREAM;
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	206 goto failed;
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	207 }
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	208
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	209 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 read eof");
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	210 ngx_http_v3_close_uni_stream(c);
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	211 return;
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	212 }
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	213
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	214 if (n == NGX_AGAIN) {
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	215 break;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	216 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	217
8838 d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	218 b.pos = buf;
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	219 b.last = buf + n;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	220
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	221 h3c = ngx_http_v3_get_session(c);
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	222 h3c->total_bytes += n;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	223
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	224 if (ngx_http_v3_check_flood(c) != NGX_OK) {
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	225 ngx_http_v3_close_uni_stream(c);
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	226 return;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	227 }
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	228
8838 d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	229 rc = ngx_http_v3_parse_uni(c, &us->parse, &b);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	230
8838 d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	231 if (rc == NGX_DONE) {
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	232 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0,
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	233 "http3 read done");
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	234 ngx_http_v3_close_uni_stream(c);
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	235 return;
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	236 }
8460 72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	237
8838 d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	238 if (rc > 0) {
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	239 goto failed;
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	240 }
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	241
8838 d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	242 if (rc != NGX_AGAIN) {
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	243 rc = NGX_HTTP_V3_ERR_GENERAL_PROTOCOL_ERROR;
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	244 goto failed;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	245 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	246 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	247
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	248 if (ngx_handle_read_event(rev, 0) != NGX_OK) {
8460 72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	249 rc = NGX_HTTP_V3_ERR_INTERNAL_ERROR;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	250 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	251 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	252
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	253 return;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	254
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	255 failed:
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	256
8460 72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	257 ngx_http_v3_finalize_connection(c, rc, "stream error");
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	258 ngx_http_v3_close_uni_stream(c);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	259 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	260
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	261
8281 618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 8228 diff changeset	262 static void
8991 3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	263 ngx_http_v3_uni_dummy_read_handler(ngx_event_t *rev)
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	264 {
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	265 u_char ch;
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	266 ngx_connection_t *c;
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	267
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	268 c = rev->data;
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	269
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	270 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 dummy read handler");
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	271
9051 37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	272 if (c->close) {
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	273 ngx_http_v3_close_uni_stream(c);
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	274 return;
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	275 }
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	276
8991 3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	277 if (rev->ready) {
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	278 if (c->recv(c, &ch, 1) != 0) {
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	279 ngx_http_v3_finalize_connection(c, NGX_HTTP_V3_ERR_NO_ERROR, NULL);
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	280 ngx_http_v3_close_uni_stream(c);
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	281 return;
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	282 }
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	283 }
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	284
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	285 if (ngx_handle_read_event(rev, 0) != NGX_OK) {
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	286 ngx_http_v3_finalize_connection(c, NGX_HTTP_V3_ERR_INTERNAL_ERROR,
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	287 NULL);
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	288 ngx_http_v3_close_uni_stream(c);
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	289 }
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	290 }
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	291
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	292
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	293 static void
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	294 ngx_http_v3_uni_dummy_write_handler(ngx_event_t *wev)
8281 618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 8228 diff changeset	295 {
618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 8228 diff changeset	296 ngx_connection_t *c;
618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 8228 diff changeset	297
618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 8228 diff changeset	298 c = wev->data;
618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 8228 diff changeset	299
618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 8228 diff changeset	300 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 dummy write handler");
618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 8228 diff changeset	301
618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 8228 diff changeset	302 if (ngx_handle_write_event(wev, 0) != NGX_OK) {
8460 72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	303 ngx_http_v3_finalize_connection(c, NGX_HTTP_V3_ERR_INTERNAL_ERROR,
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	304 NULL);
8281 618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 8228 diff changeset	305 ngx_http_v3_close_uni_stream(c);
618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 8228 diff changeset	306 }
618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 8228 diff changeset	307 }
618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 8228 diff changeset	308
618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 8228 diff changeset	309
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	310 static ngx_connection_t *
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	311 ngx_http_v3_get_uni_stream(ngx_connection_t *c, ngx_uint_t type)
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	312 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	313 u_char buf[NGX_HTTP_V3_VARLEN_INT_LEN];
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	314 size_t n;
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	315 ngx_int_t index;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	316 ngx_connection_t *sc;
8770 67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8769 diff changeset	317 ngx_http_v3_session_t *h3c;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	318 ngx_http_v3_uni_stream_t *us;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	319
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	320 switch (type) {
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	321 case NGX_HTTP_V3_STREAM_ENCODER:
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	322 index = NGX_HTTP_V3_STREAM_SERVER_ENCODER;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	323 break;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	324 case NGX_HTTP_V3_STREAM_DECODER:
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	325 index = NGX_HTTP_V3_STREAM_SERVER_DECODER;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	326 break;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	327 case NGX_HTTP_V3_STREAM_CONTROL:
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	328 index = NGX_HTTP_V3_STREAM_SERVER_CONTROL;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	329 break;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	330 default:
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	331 index = -1;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	332 }
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	333
8768 40d710a66aef HTTP/3: ngx_http_v3_get_session() macro. Roman Arutyunyan <arut@nginx.com> parents: 8767 diff changeset	334 h3c = ngx_http_v3_get_session(c);
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	335
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	336 if (index >= 0) {
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	337 if (h3c->known_streams[index]) {
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	338 return h3c->known_streams[index];
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	339 }
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	340 }
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	341
8495 455a8536eaa7 QUIC: limited the number of server-initiated streams. Roman Arutyunyan <arut@nginx.com> parents: 8492 diff changeset	342 sc = ngx_quic_open_stream(c, 0);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	343 if (sc == NULL) {
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	344 goto failed;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	345 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	346
9051 37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	347 ngx_quic_cancelable_stream(sc);
8724 fc64ab301bad QUIC: connection shutdown. Roman Arutyunyan <arut@nginx.com> parents: 8723 diff changeset	348
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	349 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	350 "http3 create uni stream, type:%ui", type);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	351
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	352 us = ngx_pcalloc(sc->pool, sizeof(ngx_http_v3_uni_stream_t));
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	353 if (us == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	354 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	355 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	356
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	357 us->index = index;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	358
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	359 sc->data = us;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	360
8991 3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	361 sc->read->handler = ngx_http_v3_uni_dummy_read_handler;
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	362 sc->write->handler = ngx_http_v3_uni_dummy_write_handler;
8281 618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 8228 diff changeset	363
8403 c101438c69a4 HTTP/3: prevent array access by negative index for unknown streams. Roman Arutyunyan <arut@nginx.com> parents: 8362 diff changeset	364 if (index >= 0) {
c101438c69a4 HTTP/3: prevent array access by negative index for unknown streams. Roman Arutyunyan <arut@nginx.com> parents: 8362 diff changeset	365 h3c->known_streams[index] = sc;
c101438c69a4 HTTP/3: prevent array access by negative index for unknown streams. Roman Arutyunyan <arut@nginx.com> parents: 8362 diff changeset	366 }
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	367
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	368 n = (u_char *) ngx_http_v3_encode_varlen_int(buf, type) - buf;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	369
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	370 h3c = ngx_http_v3_get_session(c);
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	371 h3c->total_bytes += n;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	372
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	373 if (sc->send(sc, buf, n) != (ssize_t) n) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	374 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	375 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	376
8991 3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	377 ngx_post_event(sc->read, &ngx_posted_events);
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	378
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	379 return sc;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	380
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	381 failed:
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	382
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	383 ngx_log_error(NGX_LOG_ERR, c->log, 0, "failed to create server stream");
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	384
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	385 ngx_http_v3_finalize_connection(c, NGX_HTTP_V3_ERR_STREAM_CREATION_ERROR,
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	386 "failed to create server stream");
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	387 if (sc) {
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	388 ngx_http_v3_close_uni_stream(sc);
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	389 }
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	390
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	391 return NULL;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	392 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	393
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	394
8774 f4d3f5d93a82 HTTP/3: moved session initialization to a separate file. Roman Arutyunyan <arut@nginx.com> parents: 8772 diff changeset	395 ngx_int_t
8456 c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	396 ngx_http_v3_send_settings(ngx_connection_t *c)
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	397 {
8769 9ec3e71f8a61 HTTP/3: reference h3c directly from ngx_http_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 8768 diff changeset	398 u_char p, buf[NGX_HTTP_V3_VARLEN_INT_LEN 6];
9ec3e71f8a61 HTTP/3: reference h3c directly from ngx_http_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 8768 diff changeset	399 size_t n;
9ec3e71f8a61 HTTP/3: reference h3c directly from ngx_http_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 8768 diff changeset	400 ngx_connection_t *cc;
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	401 ngx_http_v3_session_t *h3c;
8769 9ec3e71f8a61 HTTP/3: reference h3c directly from ngx_http_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 8768 diff changeset	402 ngx_http_v3_srv_conf_t *h3scf;
8495 455a8536eaa7 QUIC: limited the number of server-initiated streams. Roman Arutyunyan <arut@nginx.com> parents: 8492 diff changeset	403
8456 c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	404 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 send settings");
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	405
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	406 cc = ngx_http_v3_get_uni_stream(c, NGX_HTTP_V3_STREAM_CONTROL);
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	407 if (cc == NULL) {
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	408 return NGX_ERROR;
8456 c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	409 }
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	410
8769 9ec3e71f8a61 HTTP/3: reference h3c directly from ngx_http_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 8768 diff changeset	411 h3scf = ngx_http_v3_get_module_srv_conf(c, ngx_http_v3_module);
8456 c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	412
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	413 n = ngx_http_v3_encode_varlen_int(NULL,
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	414 NGX_HTTP_V3_PARAM_MAX_TABLE_CAPACITY);
8492 65c1fc5fae15 HTTP/3: renamed server configuration variables from v3cf to h3scf. Roman Arutyunyan <arut@nginx.com> parents: 8481 diff changeset	415 n += ngx_http_v3_encode_varlen_int(NULL, h3scf->max_table_capacity);
8456 c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	416 n += ngx_http_v3_encode_varlen_int(NULL, NGX_HTTP_V3_PARAM_BLOCKED_STREAMS);
8492 65c1fc5fae15 HTTP/3: renamed server configuration variables from v3cf to h3scf. Roman Arutyunyan <arut@nginx.com> parents: 8481 diff changeset	417 n += ngx_http_v3_encode_varlen_int(NULL, h3scf->max_blocked_streams);
8456 c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	418
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	419 p = (u_char *) ngx_http_v3_encode_varlen_int(buf,
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	420 NGX_HTTP_V3_FRAME_SETTINGS);
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	421 p = (u_char *) ngx_http_v3_encode_varlen_int(p, n);
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	422 p = (u_char *) ngx_http_v3_encode_varlen_int(p,
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	423 NGX_HTTP_V3_PARAM_MAX_TABLE_CAPACITY);
8492 65c1fc5fae15 HTTP/3: renamed server configuration variables from v3cf to h3scf. Roman Arutyunyan <arut@nginx.com> parents: 8481 diff changeset	424 p = (u_char *) ngx_http_v3_encode_varlen_int(p, h3scf->max_table_capacity);
8456 c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	425 p = (u_char *) ngx_http_v3_encode_varlen_int(p,
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	426 NGX_HTTP_V3_PARAM_BLOCKED_STREAMS);
8492 65c1fc5fae15 HTTP/3: renamed server configuration variables from v3cf to h3scf. Roman Arutyunyan <arut@nginx.com> parents: 8481 diff changeset	427 p = (u_char *) ngx_http_v3_encode_varlen_int(p, h3scf->max_blocked_streams);
8456 c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	428 n = p - buf;
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	429
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	430 h3c = ngx_http_v3_get_session(c);
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	431 h3c->total_bytes += n;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	432
8456 c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	433 if (cc->send(cc, buf, n) != (ssize_t) n) {
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	434 goto failed;
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	435 }
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	436
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	437 return NGX_OK;
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	438
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	439 failed:
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	440
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	441 ngx_log_error(NGX_LOG_ERR, c->log, 0, "failed to send settings");
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	442
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	443 ngx_http_v3_finalize_connection(c, NGX_HTTP_V3_ERR_EXCESSIVE_LOAD,
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	444 "failed to send settings");
8456 c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	445 ngx_http_v3_close_uni_stream(cc);
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	446
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	447 return NGX_ERROR;
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	448 }
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	449
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	450
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	451 ngx_int_t
8723 265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	452 ngx_http_v3_send_goaway(ngx_connection_t *c, uint64_t id)
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	453 {
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	454 u_char p, buf[NGX_HTTP_V3_VARLEN_INT_LEN 3];
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	455 size_t n;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	456 ngx_connection_t *cc;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	457 ngx_http_v3_session_t *h3c;
8723 265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	458
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	459 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 send goaway %uL", id);
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	460
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	461 cc = ngx_http_v3_get_uni_stream(c, NGX_HTTP_V3_STREAM_CONTROL);
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	462 if (cc == NULL) {
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	463 return NGX_ERROR;
8723 265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	464 }
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	465
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	466 n = ngx_http_v3_encode_varlen_int(NULL, id);
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	467 p = (u_char *) ngx_http_v3_encode_varlen_int(buf, NGX_HTTP_V3_FRAME_GOAWAY);
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	468 p = (u_char *) ngx_http_v3_encode_varlen_int(p, n);
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	469 p = (u_char *) ngx_http_v3_encode_varlen_int(p, id);
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	470 n = p - buf;
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	471
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	472 h3c = ngx_http_v3_get_session(c);
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	473 h3c->total_bytes += n;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	474
8723 265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	475 if (cc->send(cc, buf, n) != (ssize_t) n) {
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	476 goto failed;
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	477 }
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	478
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	479 return NGX_OK;
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	480
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	481 failed:
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	482
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	483 ngx_log_error(NGX_LOG_ERR, c->log, 0, "failed to send goaway");
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	484
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	485 ngx_http_v3_finalize_connection(c, NGX_HTTP_V3_ERR_EXCESSIVE_LOAD,
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	486 "failed to send goaway");
8723 265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	487 ngx_http_v3_close_uni_stream(cc);
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	488
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	489 return NGX_ERROR;
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	490 }
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	491
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	492
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	493 ngx_int_t
8807 0ac25efb2da3 HTTP/3: quic-qpack term updates. Sergey Kandaurov <pluknet@nginx.com> parents: 8796 diff changeset	494 ngx_http_v3_send_ack_section(ngx_connection_t *c, ngx_uint_t stream_id)
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	495 {
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	496 u_char buf[NGX_HTTP_V3_PREFIX_INT_LEN];
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	497 size_t n;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	498 ngx_connection_t *dc;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	499 ngx_http_v3_session_t *h3c;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	500
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	501 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	502 "http3 send section acknowledgement %ui", stream_id);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	503
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	504 dc = ngx_http_v3_get_uni_stream(c, NGX_HTTP_V3_STREAM_DECODER);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	505 if (dc == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	506 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	507 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	508
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	509 buf[0] = 0x80;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	510 n = (u_char *) ngx_http_v3_encode_prefix_int(buf, stream_id, 7) - buf;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	511
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	512 h3c = ngx_http_v3_get_session(c);
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	513 h3c->total_bytes += n;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	514
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	515 if (dc->send(dc, buf, n) != (ssize_t) n) {
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	516 goto failed;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	517 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	518
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	519 return NGX_OK;
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	520
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	521 failed:
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	522
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	523 ngx_log_error(NGX_LOG_ERR, c->log, 0,
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	524 "failed to send section acknowledgement");
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	525
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	526 ngx_http_v3_finalize_connection(c, NGX_HTTP_V3_ERR_EXCESSIVE_LOAD,
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	527 "failed to send section acknowledgement");
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	528 ngx_http_v3_close_uni_stream(dc);
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	529
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	530 return NGX_ERROR;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	531 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	532
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	533
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	534 ngx_int_t
8771 0981329169ea HTTP/3: renamed ngx_http_v3_client_XXX() functions. Roman Arutyunyan <arut@nginx.com> parents: 8770 diff changeset	535 ngx_http_v3_send_cancel_stream(ngx_connection_t *c, ngx_uint_t stream_id)
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	536 {
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	537 u_char buf[NGX_HTTP_V3_PREFIX_INT_LEN];
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	538 size_t n;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	539 ngx_connection_t *dc;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	540 ngx_http_v3_session_t *h3c;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	541
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	542 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	543 "http3 send stream cancellation %ui", stream_id);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	544
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	545 dc = ngx_http_v3_get_uni_stream(c, NGX_HTTP_V3_STREAM_DECODER);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	546 if (dc == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	547 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	548 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	549
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	550 buf[0] = 0x40;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	551 n = (u_char *) ngx_http_v3_encode_prefix_int(buf, stream_id, 6) - buf;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	552
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	553 h3c = ngx_http_v3_get_session(c);
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	554 h3c->total_bytes += n;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	555
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	556 if (dc->send(dc, buf, n) != (ssize_t) n) {
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	557 goto failed;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	558 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	559
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	560 return NGX_OK;
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	561
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	562 failed:
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	563
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	564 ngx_log_error(NGX_LOG_ERR, c->log, 0, "failed to send stream cancellation");
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	565
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	566 ngx_http_v3_finalize_connection(c, NGX_HTTP_V3_ERR_EXCESSIVE_LOAD,
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	567 "failed to send stream cancellation");
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	568 ngx_http_v3_close_uni_stream(dc);
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	569
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	570 return NGX_ERROR;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	571 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	572
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	573
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	574 ngx_int_t
8771 0981329169ea HTTP/3: renamed ngx_http_v3_client_XXX() functions. Roman Arutyunyan <arut@nginx.com> parents: 8770 diff changeset	575 ngx_http_v3_send_inc_insert_count(ngx_connection_t *c, ngx_uint_t inc)
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	576 {
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	577 u_char buf[NGX_HTTP_V3_PREFIX_INT_LEN];
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	578 size_t n;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	579 ngx_connection_t *dc;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	580 ngx_http_v3_session_t *h3c;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	581
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	582 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	583 "http3 send insert count increment %ui", inc);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	584
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	585 dc = ngx_http_v3_get_uni_stream(c, NGX_HTTP_V3_STREAM_DECODER);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	586 if (dc == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	587 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	588 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	589
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	590 buf[0] = 0;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	591 n = (u_char *) ngx_http_v3_encode_prefix_int(buf, inc, 6) - buf;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	592
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	593 h3c = ngx_http_v3_get_session(c);
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	594 h3c->total_bytes += n;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	595
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	596 if (dc->send(dc, buf, n) != (ssize_t) n) {
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	597 goto failed;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	598 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	599
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	600 return NGX_OK;
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	601
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	602 failed:
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	603
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	604 ngx_log_error(NGX_LOG_ERR, c->log, 0,
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	605 "failed to send insert count increment");
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	606
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	607 ngx_http_v3_finalize_connection(c, NGX_HTTP_V3_ERR_EXCESSIVE_LOAD,
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	608 "failed to send insert count increment");
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	609 ngx_http_v3_close_uni_stream(dc);
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	610
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	611 return NGX_ERROR;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	612 }
8497 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	613
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	614
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	615 ngx_int_t
8767 33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8725 diff changeset	616 ngx_http_v3_cancel_stream(ngx_connection_t *c, ngx_uint_t stream_id)
33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8725 diff changeset	617 {
33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8725 diff changeset	618 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8725 diff changeset	619 "http3 cancel stream %ui", stream_id);
33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8725 diff changeset	620
33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8725 diff changeset	621 /* we do not use dynamic tables */
33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8725 diff changeset	622
33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8725 diff changeset	623 return NGX_OK;
33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8725 diff changeset	624 }

Mercurial > hg > nginx

annotate src/http/v3/ngx_http_v3_uni.c @ 9189:fcec773dd249