nginx: src/http/v3/ngx_http_v3

annotate src/http/v3/ngx_http_v3_uni.c @ 9051:37d5dddabaea quic

QUIC: reusable mode for main connection. The connection is automatically switched to this mode by transport layer when there are no non-cancelable streams. Currently, cancelable streams are HTTP/3 encoder/decoder/control streams.

author	Roman Arutyunyan <arut@nginx.com>
date	Tue, 29 Nov 2022 17:46:46 +0400
parents	a5aebd51e4c7
children	6546c2ae1c7b

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
8497 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	19 typedef struct {
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	20 ngx_queue_t queue;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	21 uint64_t id;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	22 ngx_connection_t *connection;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	23 ngx_uint_t *npushing;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	24 } ngx_http_v3_push_t;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	25
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	26
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	27 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	28 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	29 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	30 static void ngx_http_v3_uni_dummy_write_handler(ngx_event_t *wev);
8497 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	31 static void ngx_http_v3_push_cleanup(void *data);
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	32 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	33 ngx_uint_t type);
8725 98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	34
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	35
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8630 diff changeset	36 void
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8630 diff changeset	37 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	38 {
8824 054f9be0aaf9 HTTP/3: http3_max_uni_streams directive. Roman Arutyunyan <arut@nginx.com> parents: 8821 diff changeset	39 uint64_t n;
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8630 diff changeset	40 ngx_http_v3_uni_stream_t *us;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8630 diff changeset	41
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8630 diff changeset	42 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	43
8824 054f9be0aaf9 HTTP/3: http3_max_uni_streams directive. Roman Arutyunyan <arut@nginx.com> parents: 8821 diff changeset	44 n = c->quic->id >> 2;
054f9be0aaf9 HTTP/3: http3_max_uni_streams directive. Roman Arutyunyan <arut@nginx.com> parents: 8821 diff changeset	45
8924 d6ef13c5fd8e QUIC: simplified configuration. Vladimir Homutov <vl@nginx.com> parents: 8903 diff changeset	46 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	47 ngx_http_v3_finalize_connection(c,
054f9be0aaf9 HTTP/3: http3_max_uni_streams directive. Roman Arutyunyan <arut@nginx.com> parents: 8821 diff changeset	48 NGX_HTTP_V3_ERR_STREAM_CREATION_ERROR,
054f9be0aaf9 HTTP/3: http3_max_uni_streams directive. Roman Arutyunyan <arut@nginx.com> parents: 8821 diff changeset	49 "reached maximum number of uni streams");
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	50 c->data = NULL;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	51 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	52 return;
054f9be0aaf9 HTTP/3: http3_max_uni_streams directive. Roman Arutyunyan <arut@nginx.com> parents: 8821 diff changeset	53 }
054f9be0aaf9 HTTP/3: http3_max_uni_streams directive. Roman Arutyunyan <arut@nginx.com> parents: 8821 diff changeset	54
9051 37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	55 ngx_quic_cancelable_stream(c);
8724 fc64ab301bad QUIC: connection shutdown. Roman Arutyunyan <arut@nginx.com> parents: 8723 diff changeset	56
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	57 us = ngx_pcalloc(c->pool, sizeof(ngx_http_v3_uni_stream_t));
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	58 if (us == NULL) {
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	59 ngx_http_v3_finalize_connection(c,
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	60 NGX_HTTP_V3_ERR_INTERNAL_ERROR,
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	61 "memory allocation error");
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	62 c->data = NULL;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	63 ngx_http_v3_close_uni_stream(c);
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8630 diff changeset	64 return;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	65 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	66
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	67 us->index = -1;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	68
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	69 c->data = us;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	70
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	71 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	72 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	73
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	74 ngx_http_v3_uni_read_handler(c->read);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	75 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	76
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	77
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	78 static void
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	79 ngx_http_v3_close_uni_stream(ngx_connection_t *c)
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	80 {
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	81 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	82 ngx_http_v3_session_t *h3c;
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	83 ngx_http_v3_uni_stream_t *us;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	84
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	85 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	86
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	87 us = c->data;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	88
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	89 if (us && us->index >= 0) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	90 h3c = ngx_http_v3_get_session(c);
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	91 h3c->known_streams[us->index] = NULL;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	92 }
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	93
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	94 c->destroyed = 1;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	95
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	96 pool = c->pool;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	97
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	98 ngx_close_connection(c);
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_destroy_pool(pool);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	101 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	102
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	103
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	104 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	105 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	106 {
8772 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_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	108 ngx_http_v3_session_t *h3c;
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	109 ngx_http_v3_uni_stream_t *us;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	110
8821 d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	111 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	112
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	113 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	114
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	115 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	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 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	118 "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	119 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	120 break;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	121
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	122 case NGX_HTTP_V3_STREAM_DECODER:
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 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	125 "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	126 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	127 break;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	128
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	129 case NGX_HTTP_V3_STREAM_CONTROL:
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 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	132 "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	133 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	134
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	135 break;
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 default:
8460 72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	138
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	139 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	140 "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	141
d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	142 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	143 \|\| 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	144 \|\| 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	145 {
d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	146 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	147 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	148 }
d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	149
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	150 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	151 }
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	152
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	153 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	154 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	155 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	156 return NGX_HTTP_V3_ERR_STREAM_CREATION_ERROR;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	157 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	158
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	159 h3c->known_streams[index] = c;
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 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 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	162 us->index = index;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	163 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	164
8772 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8771 diff changeset	165 return NGX_OK;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	166 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	167
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	168
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	169 static void
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	170 ngx_http_v3_uni_read_handler(ngx_event_t *rev)
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	171 {
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	172 u_char buf[128];
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	173 ssize_t n;
8838 d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	174 ngx_buf_t b;
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	175 ngx_int_t rc;
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	176 ngx_connection_t *c;
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	177 ngx_http_v3_session_t *h3c;
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	178 ngx_http_v3_uni_stream_t *us;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	179
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	180 c = rev->data;
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	181 us = c->data;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	182
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	183 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	184
9051 37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	185 if (c->close) {
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	186 ngx_http_v3_close_uni_stream(c);
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	187 return;
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	188 }
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	189
8838 d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	190 ngx_memzero(&b, sizeof(ngx_buf_t));
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	191
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	192 while (rev->ready) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	193
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	194 n = c->recv(c, buf, sizeof(buf));
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	195
8460 72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	196 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	197 rc = NGX_HTTP_V3_ERR_INTERNAL_ERROR;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	198 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	199 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	200
8460 72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	201 if (n == 0) {
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	202 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	203 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	204 goto failed;
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	205 }
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	206
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	207 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	208 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	209 return;
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	210 }
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	211
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	212 if (n == NGX_AGAIN) {
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	213 break;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	214 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	215
8838 d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	216 b.pos = buf;
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	217 b.last = buf + n;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	218
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	219 h3c = ngx_http_v3_get_session(c);
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	220 h3c->total_bytes += n;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	221
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	222 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	223 ngx_http_v3_close_uni_stream(c);
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	224 return;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	225 }
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	226
8838 d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	227 rc = ngx_http_v3_parse_uni(c, &us->parse, &b);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	228
8838 d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	229 if (rc == NGX_DONE) {
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	230 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	231 "http3 read done");
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	232 ngx_http_v3_close_uni_stream(c);
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	233 return;
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	234 }
8460 72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	235
8838 d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	236 if (rc > 0) {
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	237 goto failed;
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	238 }
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	239
8838 d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	240 if (rc != NGX_AGAIN) {
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	241 rc = NGX_HTTP_V3_ERR_GENERAL_PROTOCOL_ERROR;
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8824 diff changeset	242 goto failed;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	243 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	244 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	245
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	246 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	247 rc = NGX_HTTP_V3_ERR_INTERNAL_ERROR;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	248 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	249 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	250
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	251 return;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	252
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	253 failed:
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	254
8460 72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	255 ngx_http_v3_finalize_connection(c, rc, "stream error");
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	256 ngx_http_v3_close_uni_stream(c);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	257 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	258
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	259
8281 618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 8228 diff changeset	260 static void
8991 3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	261 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	262 {
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	263 u_char ch;
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	264 ngx_connection_t *c;
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	265
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	266 c = rev->data;
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 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	269
9051 37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	270 if (c->close) {
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	271 ngx_http_v3_close_uni_stream(c);
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	272 return;
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	273 }
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	274
8991 3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	275 if (rev->ready) {
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	276 if (c->recv(c, &ch, 1) != 0) {
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	277 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	278 ngx_http_v3_close_uni_stream(c);
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	279 return;
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	280 }
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	281 }
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 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	284 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	285 NULL);
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	286 ngx_http_v3_close_uni_stream(c);
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	287 }
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	288 }
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 static void
3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	292 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	293 {
618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 8228 diff changeset	294 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	295
618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 8228 diff changeset	296 c = wev->data;
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 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	299
618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 8228 diff changeset	300 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	301 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	302 NULL);
8281 618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 8228 diff changeset	303 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	304 }
618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 8228 diff changeset	305 }
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
8497 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	308 ngx_connection_t *
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	309 ngx_http_v3_create_push_stream(ngx_connection_t *c, uint64_t push_id)
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	310 {
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	311 u_char p, buf[NGX_HTTP_V3_VARLEN_INT_LEN 2];
67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8769 diff changeset	312 size_t n;
67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8769 diff changeset	313 ngx_connection_t *sc;
67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8769 diff changeset	314 ngx_pool_cleanup_t *cln;
67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8769 diff changeset	315 ngx_http_v3_push_t *push;
67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8769 diff changeset	316 ngx_http_v3_session_t *h3c;
8497 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	317
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	318 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	319 "http3 create push stream id:%uL", push_id);
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	320
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	321 sc = ngx_quic_open_stream(c, 0);
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	322 if (sc == NULL) {
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	323 goto failed;
8497 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	324 }
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	325
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	326 p = buf;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	327 p = (u_char *) ngx_http_v3_encode_varlen_int(p, NGX_HTTP_V3_STREAM_PUSH);
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	328 p = (u_char *) ngx_http_v3_encode_varlen_int(p, push_id);
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	329 n = p - buf;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	330
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	331 h3c = ngx_http_v3_get_session(c);
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	332 h3c->total_bytes += n;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	333
8497 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	334 if (sc->send(sc, buf, n) != (ssize_t) n) {
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	335 goto failed;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	336 }
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	337
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	338 cln = ngx_pool_cleanup_add(sc->pool, sizeof(ngx_http_v3_push_t));
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	339 if (cln == NULL) {
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	340 goto failed;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	341 }
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	342
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	343 h3c->npushing++;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	344
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	345 cln->handler = ngx_http_v3_push_cleanup;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	346
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	347 push = cln->data;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	348 push->id = push_id;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	349 push->connection = sc;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	350 push->npushing = &h3c->npushing;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	351
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	352 ngx_queue_insert_tail(&h3c->pushing, &push->queue);
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	353
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	354 return sc;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	355
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	356 failed:
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	357
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	358 ngx_log_error(NGX_LOG_ERR, c->log, 0, "failed to create push stream");
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	359
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	360 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	361 "failed to create push stream");
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	362 if (sc) {
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	363 ngx_http_v3_close_uni_stream(sc);
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	364 }
8497 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	365
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	366 return NULL;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	367 }
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	368
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	369
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	370 static void
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	371 ngx_http_v3_push_cleanup(void *data)
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	372 {
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	373 ngx_http_v3_push_t *push = data;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	374
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	375 ngx_queue_remove(&push->queue);
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	376 (*push->npushing)--;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	377 }
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	378
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	379
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	380 static ngx_connection_t *
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	381 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	382 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	383 u_char buf[NGX_HTTP_V3_VARLEN_INT_LEN];
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	384 size_t n;
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	385 ngx_int_t index;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	386 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	387 ngx_http_v3_session_t *h3c;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	388 ngx_http_v3_uni_stream_t *us;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	389
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	390 switch (type) {
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	391 case NGX_HTTP_V3_STREAM_ENCODER:
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	392 index = NGX_HTTP_V3_STREAM_SERVER_ENCODER;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	393 break;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	394 case NGX_HTTP_V3_STREAM_DECODER:
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	395 index = NGX_HTTP_V3_STREAM_SERVER_DECODER;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	396 break;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	397 case NGX_HTTP_V3_STREAM_CONTROL:
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	398 index = NGX_HTTP_V3_STREAM_SERVER_CONTROL;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	399 break;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	400 default:
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	401 index = -1;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	402 }
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	403
8768 40d710a66aef HTTP/3: ngx_http_v3_get_session() macro. Roman Arutyunyan <arut@nginx.com> parents: 8767 diff changeset	404 h3c = ngx_http_v3_get_session(c);
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	405
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	406 if (index >= 0) {
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	407 if (h3c->known_streams[index]) {
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	408 return h3c->known_streams[index];
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	409 }
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	410 }
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	411
8495 455a8536eaa7 QUIC: limited the number of server-initiated streams. Roman Arutyunyan <arut@nginx.com> parents: 8492 diff changeset	412 sc = ngx_quic_open_stream(c, 0);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	413 if (sc == NULL) {
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	414 goto failed;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	415 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	416
9051 37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	417 ngx_quic_cancelable_stream(sc);
8724 fc64ab301bad QUIC: connection shutdown. Roman Arutyunyan <arut@nginx.com> parents: 8723 diff changeset	418
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	419 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	420 "http3 create uni stream, type:%ui", type);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	421
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	422 us = ngx_pcalloc(sc->pool, sizeof(ngx_http_v3_uni_stream_t));
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	423 if (us == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	424 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	425 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	426
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	427 us->index = index;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	428
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	429 sc->data = us;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	430
8991 3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	431 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	432 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	433
8403 c101438c69a4 HTTP/3: prevent array access by negative index for unknown streams. Roman Arutyunyan <arut@nginx.com> parents: 8362 diff changeset	434 if (index >= 0) {
c101438c69a4 HTTP/3: prevent array access by negative index for unknown streams. Roman Arutyunyan <arut@nginx.com> parents: 8362 diff changeset	435 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	436 }
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	437
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	438 n = (u_char *) ngx_http_v3_encode_varlen_int(buf, type) - buf;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	439
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	440 h3c = ngx_http_v3_get_session(c);
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	441 h3c->total_bytes += n;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	442
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	443 if (sc->send(sc, buf, n) != (ssize_t) n) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	444 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	445 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	446
8991 3436b441239b HTTP/3: proper uni stream closure detection. Roman Arutyunyan <arut@nginx.com> parents: 8925 diff changeset	447 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	448
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	449 return sc;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	450
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	451 failed:
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	452
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	453 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	454
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	455 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	456 "failed to create server stream");
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	457 if (sc) {
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	458 ngx_http_v3_close_uni_stream(sc);
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	459 }
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	460
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	461 return NULL;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	462 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	463
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	464
8774 f4d3f5d93a82 HTTP/3: moved session initialization to a separate file. Roman Arutyunyan <arut@nginx.com> parents: 8772 diff changeset	465 ngx_int_t
8456 c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	466 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	467 {
8769 9ec3e71f8a61 HTTP/3: reference h3c directly from ngx_http_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 8768 diff changeset	468 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	469 size_t n;
9ec3e71f8a61 HTTP/3: reference h3c directly from ngx_http_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 8768 diff changeset	470 ngx_connection_t *cc;
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	471 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	472 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	473
8456 c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	474 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	475
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	476 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	477 if (cc == NULL) {
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	478 return NGX_ERROR;
8456 c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	479 }
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	480
8769 9ec3e71f8a61 HTTP/3: reference h3c directly from ngx_http_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 8768 diff changeset	481 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	482
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	483 n = ngx_http_v3_encode_varlen_int(NULL,
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	484 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	485 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	486 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	487 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	488
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	489 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	490 NGX_HTTP_V3_FRAME_SETTINGS);
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	491 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	492 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	493 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	494 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	495 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	496 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	497 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	498 n = p - buf;
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	499
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	500 h3c = ngx_http_v3_get_session(c);
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	501 h3c->total_bytes += n;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	502
8456 c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	503 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	504 goto failed;
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	505 }
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	506
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	507 return NGX_OK;
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	508
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	509 failed:
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	510
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	511 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	512
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	513 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	514 "failed to send settings");
8456 c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	515 ngx_http_v3_close_uni_stream(cc);
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	516
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	517 return NGX_ERROR;
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	518 }
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	519
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	520
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8403 diff changeset	521 ngx_int_t
8723 265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	522 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	523 {
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	524 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	525 size_t n;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	526 ngx_connection_t *cc;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	527 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	528
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	529 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	530
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	531 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	532 if (cc == NULL) {
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	533 return NGX_ERROR;
8723 265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	534 }
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	535
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	536 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	537 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	538 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	539 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	540 n = p - buf;
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	541
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	542 h3c = ngx_http_v3_get_session(c);
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	543 h3c->total_bytes += n;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	544
8723 265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	545 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	546 goto failed;
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	547 }
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	548
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	549 return NGX_OK;
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	550
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	551 failed:
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	552
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	553 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	554
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	555 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	556 "failed to send goaway");
8723 265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	557 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	558
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	559 return NGX_ERROR;
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	560 }
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	561
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	562
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8719 diff changeset	563 ngx_int_t
8807 0ac25efb2da3 HTTP/3: quic-qpack term updates. Sergey Kandaurov <pluknet@nginx.com> parents: 8796 diff changeset	564 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	565 {
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	566 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	567 size_t n;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	568 ngx_connection_t *dc;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	569 ngx_http_v3_session_t *h3c;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	570
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	571 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	572 "http3 send section acknowledgement %ui", stream_id);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	573
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	574 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	575 if (dc == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	576 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	577 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	578
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	579 buf[0] = 0x80;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	580 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	581
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	582 h3c = ngx_http_v3_get_session(c);
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	583 h3c->total_bytes += n;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	584
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	585 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	586 goto failed;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	587 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	588
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	589 return NGX_OK;
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	590
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	591 failed:
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	592
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	593 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	594 "failed to send section acknowledgement");
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	595
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	596 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	597 "failed to send section acknowledgement");
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	598 ngx_http_v3_close_uni_stream(dc);
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	599
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	600 return NGX_ERROR;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	601 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	602
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	603
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	604 ngx_int_t
8771 0981329169ea HTTP/3: renamed ngx_http_v3_client_XXX() functions. Roman Arutyunyan <arut@nginx.com> parents: 8770 diff changeset	605 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	606 {
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	607 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	608 size_t n;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	609 ngx_connection_t *dc;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	610 ngx_http_v3_session_t *h3c;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	611
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	612 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	613 "http3 send stream cancellation %ui", stream_id);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	614
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	615 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	616 if (dc == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	617 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	618 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	619
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	620 buf[0] = 0x40;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	621 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	622
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	623 h3c = ngx_http_v3_get_session(c);
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	624 h3c->total_bytes += n;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	625
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	626 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	627 goto failed;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	628 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	629
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	630 return NGX_OK;
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	631
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	632 failed:
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	633
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	634 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	635
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	636 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	637 "failed to send stream cancellation");
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	638 ngx_http_v3_close_uni_stream(dc);
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	639
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	640 return NGX_ERROR;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	641 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	642
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	643
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	644 ngx_int_t
8771 0981329169ea HTTP/3: renamed ngx_http_v3_client_XXX() functions. Roman Arutyunyan <arut@nginx.com> parents: 8770 diff changeset	645 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	646 {
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	647 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	648 size_t n;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	649 ngx_connection_t *dc;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	650 ngx_http_v3_session_t *h3c;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	651
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	652 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	653 "http3 send insert count increment %ui", inc);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	654
8283 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 8281 diff changeset	655 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	656 if (dc == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	657 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	658 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	659
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	660 buf[0] = 0;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	661 n = (u_char *) ngx_http_v3_encode_prefix_int(buf, inc, 6) - buf;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	662
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	663 h3c = ngx_http_v3_get_session(c);
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	664 h3c->total_bytes += n;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8879 diff changeset	665
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	666 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	667 goto failed;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	668 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	669
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	670 return NGX_OK;
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	671
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	672 failed:
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	673
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	674 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	675 "failed to send insert count increment");
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	676
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	677 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	678 "failed to send insert count increment");
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	679 ngx_http_v3_close_uni_stream(dc);
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	680
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	681 return NGX_ERROR;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	682 }
8497 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	683
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	684
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	685 ngx_int_t
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	686 ngx_http_v3_set_max_push_id(ngx_connection_t *c, uint64_t max_push_id)
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	687 {
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	688 ngx_http_v3_session_t *h3c;
8497 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	689
8768 40d710a66aef HTTP/3: ngx_http_v3_get_session() macro. Roman Arutyunyan <arut@nginx.com> parents: 8767 diff changeset	690 h3c = ngx_http_v3_get_session(c);
8497 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	691
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	692 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	693 "http3 MAX_PUSH_ID:%uL", max_push_id);
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	694
8719 5cb5b568282b HTTP/3: do not push until a MAX_PUSH_ID frame is received. Sergey Kandaurov <pluknet@nginx.com> parents: 8679 diff changeset	695 if (h3c->max_push_id != (uint64_t) -1 && max_push_id < h3c->max_push_id) {
8497 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	696 return NGX_HTTP_V3_ERR_ID_ERROR;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	697 }
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	698
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	699 h3c->max_push_id = max_push_id;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	700
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	701 return NGX_OK;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	702 }
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	703
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	704
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	705 ngx_int_t
8796 1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8774 diff changeset	706 ngx_http_v3_goaway(ngx_connection_t *c, uint64_t push_id)
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8774 diff changeset	707 {
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8774 diff changeset	708 ngx_http_v3_session_t *h3c;
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8774 diff changeset	709
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8774 diff changeset	710 h3c = ngx_http_v3_get_session(c);
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8774 diff changeset	711
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8774 diff changeset	712 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 GOAWAY:%uL", push_id);
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8774 diff changeset	713
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8774 diff changeset	714 h3c->goaway_push_id = push_id;
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8774 diff changeset	715
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8774 diff changeset	716 return NGX_OK;
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8774 diff changeset	717 }
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8774 diff changeset	718
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8774 diff changeset	719
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8774 diff changeset	720 ngx_int_t
8497 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	721 ngx_http_v3_cancel_push(ngx_connection_t *c, uint64_t push_id)
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	722 {
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	723 ngx_queue_t *q;
67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8769 diff changeset	724 ngx_http_request_t *r;
67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8769 diff changeset	725 ngx_http_v3_push_t *push;
67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8769 diff changeset	726 ngx_http_v3_session_t *h3c;
8497 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	727
8768 40d710a66aef HTTP/3: ngx_http_v3_get_session() macro. Roman Arutyunyan <arut@nginx.com> parents: 8767 diff changeset	728 h3c = ngx_http_v3_get_session(c);
8497 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	729
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	730 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	731 "http3 CANCEL_PUSH:%uL", push_id);
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	732
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	733 if (push_id >= h3c->next_push_id) {
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	734 return NGX_HTTP_V3_ERR_ID_ERROR;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	735 }
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	736
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	737 for (q = ngx_queue_head(&h3c->pushing);
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	738 q != ngx_queue_sentinel(&h3c->pushing);
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	739 q = ngx_queue_next(&h3c->pushing))
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	740 {
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	741 push = (ngx_http_v3_push_t *) q;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	742
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	743 if (push->id != push_id) {
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	744 continue;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	745 }
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	746
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	747 r = push->connection->data;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	748
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	749 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	750 "http3 cancel push");
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	751
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	752 ngx_http_finalize_request(r, NGX_HTTP_CLOSE);
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	753
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	754 break;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	755 }
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	756
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	757 return NGX_OK;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8495 diff changeset	758 }
8767 33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8725 diff changeset	759
33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8725 diff changeset	760
33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8725 diff changeset	761 ngx_int_t
33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8725 diff changeset	762 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	763 {
33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8725 diff changeset	764 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	765 "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	766
33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8725 diff changeset	767 /* 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	768
33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8725 diff changeset	769 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	770 }

Mercurial > hg > nginx

annotate src/http/v3/ngx_http_v3_uni.c @ 9051:37d5dddabaea quic