nginx: src/http/v3/ngx_http_v3

annotate src/http/v3/ngx_http_v3_request.c @ 9286:d9fe808c1841

HTTP/3: protection from recursion during connection reuse. When draining a connection associated with an HTTP/3 stream, calling ngx_http_v3_send_cancel_stream() might result in an attempt to obtain a connection for the decoder stream. This in turn will trigger draining of the very same connection. Depending on the client settings, this might either lead to stack overflow or will end up in decoder stream creation error and destroying the connection at some point, potentially resulting in use-after-free on stack. Fix is to make sure that connection reuse is disabled in ngx_http_v3_reset_stream(), so the recursion in question won't happen regardless of what called functions do.

author	Maxim Dounin <mdounin@mdounin.ru>
date	Sun, 02 Jun 2024 23:51:55 +0300
parents	199dc0d6b05b
children

rev	line source
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	1
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	2 /*
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	3 * Copyright (C) Roman Arutyunyan
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	4 * Copyright (C) Nginx, Inc.
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	5 */
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	6
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	7
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	8 #include <ngx_config.h>
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	9 #include <ngx_core.h>
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	10 #include <ngx_http.h>
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	11
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	12
8921 33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	13 static void ngx_http_v3_init_request_stream(ngx_connection_t *c);
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	14 static void ngx_http_v3_wait_request_handler(ngx_event_t *rev);
9059 b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	15 static void ngx_http_v3_cleanup_connection(void *data);
8725 98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	16 static void ngx_http_v3_cleanup_request(void *data);
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	17 static void ngx_http_v3_process_request(ngx_event_t *rev);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	18 static ngx_int_t ngx_http_v3_process_header(ngx_http_request_t *r,
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	19 ngx_str_t name, ngx_str_t value);
8682 916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	20 static ngx_int_t ngx_http_v3_validate_header(ngx_http_request_t *r,
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	21 ngx_str_t name, ngx_str_t value);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	22 static ngx_int_t ngx_http_v3_process_pseudo_header(ngx_http_request_t *r,
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	23 ngx_str_t name, ngx_str_t value);
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	24 static ngx_int_t ngx_http_v3_init_pseudo_headers(ngx_http_request_t *r);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	25 static ngx_int_t ngx_http_v3_process_request_header(ngx_http_request_t *r);
8958 10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	26 static ngx_int_t ngx_http_v3_cookie(ngx_http_request_t r, ngx_str_t value);
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	27 static ngx_int_t ngx_http_v3_construct_cookie_header(ngx_http_request_t *r);
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	28 static void ngx_http_v3_read_client_request_body_handler(ngx_http_request_t *r);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	29 static ngx_int_t ngx_http_v3_do_read_client_request_body(ngx_http_request_t *r);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	30 static ngx_int_t ngx_http_v3_request_body_filter(ngx_http_request_t *r,
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	31 ngx_chain_t *in);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	32
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	33
8665 96eb6915d244 HTTP/3: staticize ngx_http_v3_methods. Sergey Kandaurov <pluknet@nginx.com> parents: 8653 diff changeset	34 static const struct {
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	35 ngx_str_t name;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	36 ngx_uint_t method;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	37 } ngx_http_v3_methods[] = {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	38
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	39 { ngx_string("GET"), NGX_HTTP_GET },
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	40 { ngx_string("POST"), NGX_HTTP_POST },
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	41 { ngx_string("HEAD"), NGX_HTTP_HEAD },
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	42 { ngx_string("OPTIONS"), NGX_HTTP_OPTIONS },
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	43 { ngx_string("PROPFIND"), NGX_HTTP_PROPFIND },
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	44 { ngx_string("PUT"), NGX_HTTP_PUT },
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	45 { ngx_string("MKCOL"), NGX_HTTP_MKCOL },
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	46 { ngx_string("DELETE"), NGX_HTTP_DELETE },
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	47 { ngx_string("COPY"), NGX_HTTP_COPY },
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	48 { ngx_string("MOVE"), NGX_HTTP_MOVE },
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	49 { ngx_string("PROPPATCH"), NGX_HTTP_PROPPATCH },
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	50 { ngx_string("LOCK"), NGX_HTTP_LOCK },
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	51 { ngx_string("UNLOCK"), NGX_HTTP_UNLOCK },
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	52 { ngx_string("PATCH"), NGX_HTTP_PATCH },
8854 7416d3b2fac5 HTTP/3: added CONNECT and TRACE methods rejection. Sergey Kandaurov <pluknet@nginx.com> parents: 8847 diff changeset	53 { ngx_string("TRACE"), NGX_HTTP_TRACE },
7416d3b2fac5 HTTP/3: added CONNECT and TRACE methods rejection. Sergey Kandaurov <pluknet@nginx.com> parents: 8847 diff changeset	54 { ngx_string("CONNECT"), NGX_HTTP_CONNECT }
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	55 };
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	56
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	57
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	58 void
9057 7b83da3bdf9f HTTP/3: renamed functions. Roman Arutyunyan <arut@nginx.com> parents: 9055 diff changeset	59 ngx_http_v3_init_stream(ngx_connection_t *c)
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	60 {
8921 33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	61 ngx_http_connection_t hc, phc;
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	62 ngx_http_v3_srv_conf_t *h3scf;
8723 265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8707 diff changeset	63 ngx_http_core_loc_conf_t *clcf;
8921 33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	64
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	65 hc = c->data;
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	66
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	67 hc->ssl = 1;
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	68
8924 d6ef13c5fd8e QUIC: simplified configuration. Vladimir Homutov <vl@nginx.com> parents: 8922 diff changeset	69 clcf = ngx_http_get_module_loc_conf(hc->conf_ctx, ngx_http_core_module);
8921 33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	70
8922 be08b858086a HTTP/3: http3_hq directive and NGX_HTTP_V3_HQ macro. Roman Arutyunyan <arut@nginx.com> parents: 8921 diff changeset	71 if (c->quic == NULL) {
9159 6d3ca6f8db35 HTTP/3: moved variable initialization. Roman Arutyunyan <arut@nginx.com> parents: 9158 diff changeset	72 h3scf = ngx_http_get_module_srv_conf(hc->conf_ctx, ngx_http_v3_module);
9158 ad3d34ddfdcc QUIC: "handshake_timeout" configuration parameter. Roman Arutyunyan <arut@nginx.com> parents: 9104 diff changeset	73 h3scf->quic.idle_timeout = clcf->keepalive_timeout;
9159 6d3ca6f8db35 HTTP/3: moved variable initialization. Roman Arutyunyan <arut@nginx.com> parents: 9158 diff changeset	74
8921 33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	75 ngx_quic_run(c, &h3scf->quic);
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	76 return;
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	77 }
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	78
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	79 phc = ngx_http_quic_get_connection(c);
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	80
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	81 if (phc->ssl_servername) {
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	82 hc->ssl_servername = phc->ssl_servername;
9046 210ad79a8853 HTTP/3: fixed build without NGX_PCRE (broken by 0f5fc7a320db). Jiuzhou Cui <cuijiuzhou@alibaba-inc.com> parents: 9037 diff changeset	83 #if (NGX_PCRE)
9037 0f5fc7a320db HTTP/3: fixed server_name regex captures (ticket #2407). Sergey Kandaurov <pluknet@nginx.com> parents: 9027 diff changeset	84 hc->ssl_servername_regex = phc->ssl_servername_regex;
9046 210ad79a8853 HTTP/3: fixed build without NGX_PCRE (broken by 0f5fc7a320db). Jiuzhou Cui <cuijiuzhou@alibaba-inc.com> parents: 9037 diff changeset	85 #endif
8921 33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	86 hc->conf_ctx = phc->conf_ctx;
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	87
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	88 ngx_set_connection_log(c, clcf->error_log);
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	89 }
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	90
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	91 if (c->quic->id & NGX_QUIC_STREAM_UNIDIRECTIONAL) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	92 ngx_http_v3_init_uni_stream(c);
8921 33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	93
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	94 } else {
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	95 ngx_http_v3_init_request_stream(c);
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	96 }
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	97 }
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	98
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	99
9058 b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9057 diff changeset	100 ngx_int_t
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9057 diff changeset	101 ngx_http_v3_init(ngx_connection_t *c)
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9057 diff changeset	102 {
9081 c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	103 unsigned int len;
c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	104 const unsigned char *data;
9058 b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9057 diff changeset	105 ngx_http_v3_session_t *h3c;
9081 c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	106 ngx_http_v3_srv_conf_t *h3scf;
9058 b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9057 diff changeset	107 ngx_http_core_loc_conf_t *clcf;
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9057 diff changeset	108
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9057 diff changeset	109 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 init");
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9057 diff changeset	110
9161 4939fd04737f HTTP/3: postponed session creation to init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9159 diff changeset	111 if (ngx_http_v3_init_session(c) != NGX_OK) {
4939fd04737f HTTP/3: postponed session creation to init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9159 diff changeset	112 return NGX_ERROR;
4939fd04737f HTTP/3: postponed session creation to init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9159 diff changeset	113 }
4939fd04737f HTTP/3: postponed session creation to init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9159 diff changeset	114
9058 b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9057 diff changeset	115 h3c = ngx_http_v3_get_session(c);
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9057 diff changeset	116 clcf = ngx_http_v3_get_module_loc_conf(c, ngx_http_core_module);
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9057 diff changeset	117 ngx_add_timer(&h3c->keepalive, clcf->keepalive_timeout);
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9057 diff changeset	118
9081 c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	119 h3scf = ngx_http_v3_get_module_srv_conf(c, ngx_http_v3_module);
c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	120
c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	121 if (h3scf->enable_hq) {
c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	122 if (!h3scf->enable) {
c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	123 h3c->hq = 1;
c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	124 return NGX_OK;
c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	125 }
c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	126
c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	127 SSL_get0_alpn_selected(c->ssl->connection, &data, &len);
c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	128
c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	129 if (len == sizeof(NGX_HTTP_V3_HQ_PROTO) - 1
c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	130 && ngx_strncmp(data, NGX_HTTP_V3_HQ_PROTO, len) == 0)
c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	131 {
c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	132 h3c->hq = 1;
c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	133 return NGX_OK;
c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	134 }
9058 b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9057 diff changeset	135 }
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9057 diff changeset	136
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9057 diff changeset	137 return ngx_http_v3_send_settings(c);
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9057 diff changeset	138 }
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9057 diff changeset	139
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9057 diff changeset	140
9055 1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	141 void
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	142 ngx_http_v3_shutdown(ngx_connection_t *c)
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	143 {
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	144 ngx_http_v3_session_t *h3c;
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	145
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	146 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 shutdown");
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	147
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	148 h3c = ngx_http_v3_get_session(c);
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	149
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	150 if (h3c == NULL) {
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	151 ngx_quic_finalize_connection(c, NGX_HTTP_V3_ERR_NO_ERROR,
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	152 "connection shutdown");
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	153 return;
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	154 }
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	155
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	156 if (!h3c->goaway) {
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	157 h3c->goaway = 1;
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	158
9081 c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	159 if (!h3c->hq) {
9055 1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	160 (void) ngx_http_v3_send_goaway(c, h3c->next_request_id);
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	161 }
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	162
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	163 ngx_http_v3_shutdown_connection(c, NGX_HTTP_V3_ERR_NO_ERROR,
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	164 "connection shutdown");
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	165 }
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	166 }
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	167
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	168
8921 33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	169 static void
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	170 ngx_http_v3_init_request_stream(ngx_connection_t *c)
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	171 {
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	172 uint64_t n;
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	173 ngx_event_t *rev;
9059 b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	174 ngx_pool_cleanup_t *cln;
8921 33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	175 ngx_http_connection_t *hc;
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	176 ngx_http_v3_session_t *h3c;
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	177 ngx_http_core_loc_conf_t *clcf;
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	178 ngx_http_core_srv_conf_t *cscf;
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	179
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	180 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 init request stream");
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	181
8863 33578b8d453d HTTP/3: fixed ngx_stat_active counter. Roman Arutyunyan <arut@nginx.com> parents: 8854 diff changeset	182 #if (NGX_STAT_STUB)
33578b8d453d HTTP/3: fixed ngx_stat_active counter. Roman Arutyunyan <arut@nginx.com> parents: 8854 diff changeset	183 (void) ngx_atomic_fetch_add(ngx_stat_active, 1);
33578b8d453d HTTP/3: fixed ngx_stat_active counter. Roman Arutyunyan <arut@nginx.com> parents: 8854 diff changeset	184 #endif
33578b8d453d HTTP/3: fixed ngx_stat_active counter. Roman Arutyunyan <arut@nginx.com> parents: 8854 diff changeset	185
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	186 hc = c->data;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	187
8723 265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8707 diff changeset	188 clcf = ngx_http_get_module_loc_conf(hc->conf_ctx, ngx_http_core_module);
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8707 diff changeset	189
8826 c35b255d80dc HTTP/3: close connection on keepalive_requests * 2. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	190 n = c->quic->id >> 2;
c35b255d80dc HTTP/3: close connection on keepalive_requests * 2. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	191
c35b255d80dc HTTP/3: close connection on keepalive_requests * 2. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	192 if (n >= clcf->keepalive_requests * 2) {
c35b255d80dc HTTP/3: close connection on keepalive_requests * 2. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	193 ngx_http_v3_finalize_connection(c, NGX_HTTP_V3_ERR_EXCESSIVE_LOAD,
c35b255d80dc HTTP/3: close connection on keepalive_requests * 2. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	194 "too many requests per connection");
c35b255d80dc HTTP/3: close connection on keepalive_requests * 2. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	195 ngx_http_close_connection(c);
c35b255d80dc HTTP/3: close connection on keepalive_requests * 2. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	196 return;
c35b255d80dc HTTP/3: close connection on keepalive_requests * 2. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	197 }
c35b255d80dc HTTP/3: close connection on keepalive_requests * 2. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	198
8768 40d710a66aef HTTP/3: ngx_http_v3_get_session() macro. Roman Arutyunyan <arut@nginx.com> parents: 8742 diff changeset	199 h3c = ngx_http_v3_get_session(c);
8723 265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8707 diff changeset	200
8742 47a43b011dec HTTP/3: keepalive_time support. Sergey Kandaurov <pluknet@nginx.com> parents: 8727 diff changeset	201 if (h3c->goaway) {
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	202 c->close = 1;
8723 265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8707 diff changeset	203 ngx_http_close_connection(c);
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8707 diff changeset	204 return;
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8707 diff changeset	205 }
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8707 diff changeset	206
9055 1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	207 h3c->next_request_id = c->quic->id + 0x04;
1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	208
8742 47a43b011dec HTTP/3: keepalive_time support. Sergey Kandaurov <pluknet@nginx.com> parents: 8727 diff changeset	209 if (n + 1 == clcf->keepalive_requests
9063 e3760b9b7c8e HTTP/3: fixed $connection_time. Sergey Kandaurov <pluknet@nginx.com> parents: 9059 diff changeset	210 \|\| ngx_current_msec - c->start_time > clcf->keepalive_time)
8742 47a43b011dec HTTP/3: keepalive_time support. Sergey Kandaurov <pluknet@nginx.com> parents: 8727 diff changeset	211 {
47a43b011dec HTTP/3: keepalive_time support. Sergey Kandaurov <pluknet@nginx.com> parents: 8727 diff changeset	212 h3c->goaway = 1;
47a43b011dec HTTP/3: keepalive_time support. Sergey Kandaurov <pluknet@nginx.com> parents: 8727 diff changeset	213
9081 c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	214 if (!h3c->hq) {
9055 1192923be0aa QUIC: idle mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9054 diff changeset	215 if (ngx_http_v3_send_goaway(c, h3c->next_request_id) != NGX_OK) {
9054 6546c2ae1c7b HTTP/3: unified hq code with regular HTTP/3 code. Roman Arutyunyan <arut@nginx.com> parents: 9046 diff changeset	216 ngx_http_close_connection(c);
6546c2ae1c7b HTTP/3: unified hq code with regular HTTP/3 code. Roman Arutyunyan <arut@nginx.com> parents: 9046 diff changeset	217 return;
6546c2ae1c7b HTTP/3: unified hq code with regular HTTP/3 code. Roman Arutyunyan <arut@nginx.com> parents: 9046 diff changeset	218 }
8723 265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8707 diff changeset	219 }
8724 fc64ab301bad QUIC: connection shutdown. Roman Arutyunyan <arut@nginx.com> parents: 8723 diff changeset	220
fc64ab301bad QUIC: connection shutdown. Roman Arutyunyan <arut@nginx.com> parents: 8723 diff changeset	221 ngx_http_v3_shutdown_connection(c, NGX_HTTP_V3_ERR_NO_ERROR,
fc64ab301bad QUIC: connection shutdown. Roman Arutyunyan <arut@nginx.com> parents: 8723 diff changeset	222 "reached maximum number of requests");
8723 265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8707 diff changeset	223 }
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8707 diff changeset	224
9059 b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	225 cln = ngx_pool_cleanup_add(c->pool, 0);
b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	226 if (cln == NULL) {
b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	227 ngx_http_close_connection(c);
b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	228 return;
b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	229 }
b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	230
b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	231 cln->handler = ngx_http_v3_cleanup_connection;
b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	232 cln->data = c;
b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	233
b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	234 h3c->nrequests++;
b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	235
b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	236 if (h3c->keepalive.timer_set) {
b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	237 ngx_del_timer(&h3c->keepalive);
b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	238 }
b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	239
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	240 rev = c->read;
9054 6546c2ae1c7b HTTP/3: unified hq code with regular HTTP/3 code. Roman Arutyunyan <arut@nginx.com> parents: 9046 diff changeset	241
9081 c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	242 if (!h3c->hq) {
9054 6546c2ae1c7b HTTP/3: unified hq code with regular HTTP/3 code. Roman Arutyunyan <arut@nginx.com> parents: 9046 diff changeset	243 rev->handler = ngx_http_v3_wait_request_handler;
6546c2ae1c7b HTTP/3: unified hq code with regular HTTP/3 code. Roman Arutyunyan <arut@nginx.com> parents: 9046 diff changeset	244 c->write->handler = ngx_http_empty_handler;
6546c2ae1c7b HTTP/3: unified hq code with regular HTTP/3 code. Roman Arutyunyan <arut@nginx.com> parents: 9046 diff changeset	245 }
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	246
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	247 if (rev->ready) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	248 rev->handler(rev);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	249 return;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	250 }
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	251
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	252 cscf = ngx_http_get_module_srv_conf(hc->conf_ctx, ngx_http_core_module);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	253
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	254 ngx_add_timer(rev, cscf->client_header_timeout);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	255 ngx_reusable_connection(c, 1);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	256
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	257 if (ngx_handle_read_event(rev, 0) != NGX_OK) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	258 ngx_http_close_connection(c);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	259 return;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	260 }
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	261 }
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	262
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	263
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	264 static void
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	265 ngx_http_v3_wait_request_handler(ngx_event_t *rev)
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	266 {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	267 size_t size;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	268 ssize_t n;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	269 ngx_buf_t *b;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	270 ngx_connection_t *c;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	271 ngx_pool_cleanup_t *cln;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	272 ngx_http_request_t *r;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	273 ngx_http_connection_t *hc;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	274 ngx_http_core_srv_conf_t *cscf;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	275
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	276 c = rev->data;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	277
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	278 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 wait request handler");
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	279
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	280 if (rev->timedout) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	281 ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, "client timed out");
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	282 c->timedout = 1;
8725 98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	283 ngx_http_close_connection(c);
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	284 return;
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	285 }
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	286
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	287 if (c->close) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	288 ngx_http_close_connection(c);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	289 return;
8725 98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	290 }
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	291
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	292 hc = c->data;
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	293 cscf = ngx_http_get_module_srv_conf(hc->conf_ctx, ngx_http_core_module);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	294
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	295 size = cscf->client_header_buffer_size;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	296
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	297 b = c->buffer;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	298
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	299 if (b == NULL) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	300 b = ngx_create_temp_buf(c->pool, size);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	301 if (b == NULL) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	302 ngx_http_close_connection(c);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	303 return;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	304 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	305
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	306 c->buffer = b;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	307
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	308 } else if (b->start == NULL) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	309
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	310 b->start = ngx_palloc(c->pool, size);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	311 if (b->start == NULL) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	312 ngx_http_close_connection(c);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	313 return;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	314 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	315
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	316 b->pos = b->start;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	317 b->last = b->start;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	318 b->end = b->last + size;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	319 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	320
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	321 n = c->recv(c, b->last, size);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	322
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	323 if (n == NGX_AGAIN) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	324
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	325 if (!rev->timer_set) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	326 ngx_add_timer(rev, cscf->client_header_timeout);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	327 ngx_reusable_connection(c, 1);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	328 }
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	329
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	330 if (ngx_handle_read_event(rev, 0) != NGX_OK) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	331 ngx_http_close_connection(c);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	332 return;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	333 }
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	334
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	335 /*
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	336 * We are trying to not hold c->buffer's memory for an idle connection.
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	337 */
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	338
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	339 if (ngx_pfree(c->pool, b->start) == NGX_OK) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	340 b->start = NULL;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	341 }
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	342
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	343 return;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	344 }
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	345
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	346 if (n == NGX_ERROR) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	347 ngx_http_close_connection(c);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	348 return;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	349 }
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	350
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	351 if (n == 0) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	352 ngx_log_error(NGX_LOG_INFO, c->log, 0,
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	353 "client closed connection");
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	354 ngx_http_close_connection(c);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	355 return;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	356 }
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	357
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	358 b->last += n;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	359
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	360 c->log->action = "reading client request";
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	361
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	362 ngx_reusable_connection(c, 0);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	363
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	364 r = ngx_http_create_request(c);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	365 if (r == NULL) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	366 ngx_http_close_connection(c);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	367 return;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	368 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	369
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	370 r->http_version = NGX_HTTP_VERSION_30;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	371
8706 3057bae4dba7 HTTP/3: introduced ngx_http_v3_parse_t structure. Roman Arutyunyan <arut@nginx.com> parents: 8690 diff changeset	372 r->v3_parse = ngx_pcalloc(r->pool, sizeof(ngx_http_v3_parse_t));
3057bae4dba7 HTTP/3: introduced ngx_http_v3_parse_t structure. Roman Arutyunyan <arut@nginx.com> parents: 8690 diff changeset	373 if (r->v3_parse == NULL) {
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	374 ngx_http_close_request(r, NGX_HTTP_INTERNAL_SERVER_ERROR);
8706 3057bae4dba7 HTTP/3: introduced ngx_http_v3_parse_t structure. Roman Arutyunyan <arut@nginx.com> parents: 8690 diff changeset	375 return;
3057bae4dba7 HTTP/3: introduced ngx_http_v3_parse_t structure. Roman Arutyunyan <arut@nginx.com> parents: 8690 diff changeset	376 }
3057bae4dba7 HTTP/3: introduced ngx_http_v3_parse_t structure. Roman Arutyunyan <arut@nginx.com> parents: 8690 diff changeset	377
8707 ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	378 r->v3_parse->header_limit = cscf->large_client_header_buffers.size
ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	379 * cscf->large_client_header_buffers.num;
ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	380
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	381 c->data = r;
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	382 c->requests = (c->quic->id >> 2) + 1;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	383
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	384 cln = ngx_pool_cleanup_add(r->pool, 0);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	385 if (cln == NULL) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	386 ngx_http_close_request(r, NGX_HTTP_INTERNAL_SERVER_ERROR);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	387 return;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	388 }
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	389
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	390 cln->handler = ngx_http_v3_cleanup_request;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	391 cln->data = r;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	392
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	393 rev->handler = ngx_http_v3_process_request;
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	394 ngx_http_v3_process_request(rev);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	395 }
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	396
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	397
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	398 void
9057 7b83da3bdf9f HTTP/3: renamed functions. Roman Arutyunyan <arut@nginx.com> parents: 9055 diff changeset	399 ngx_http_v3_reset_stream(ngx_connection_t *c)
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	400 {
9081 c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	401 ngx_http_v3_session_t *h3c;
8904 d2c193aa8480 HTTP/3: send Stream Cancellation instruction. Roman Arutyunyan <arut@nginx.com> parents: 8903 diff changeset	402 ngx_http_v3_srv_conf_t *h3scf;
d2c193aa8480 HTTP/3: send Stream Cancellation instruction. Roman Arutyunyan <arut@nginx.com> parents: 8903 diff changeset	403
9286 d9fe808c1841 HTTP/3: protection from recursion during connection reuse. Maxim Dounin <mdounin@mdounin.ru> parents: 9275 diff changeset	404 ngx_reusable_connection(c, 0);
d9fe808c1841 HTTP/3: protection from recursion during connection reuse. Maxim Dounin <mdounin@mdounin.ru> parents: 9275 diff changeset	405
8922 be08b858086a HTTP/3: http3_hq directive and NGX_HTTP_V3_HQ macro. Roman Arutyunyan <arut@nginx.com> parents: 8921 diff changeset	406 h3scf = ngx_http_v3_get_module_srv_conf(c, ngx_http_v3_module);
8921 33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	407
9081 c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	408 h3c = ngx_http_v3_get_session(c);
c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	409
c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	410 if (h3scf->max_table_capacity > 0 && !c->read->eof && !h3c->hq
8927 e4952530e6af HTTP/3: avoid sending stream cancellation for pushed streams. Sergey Kandaurov <pluknet@nginx.com> parents: 8924 diff changeset	411 && (c->quic->id & NGX_QUIC_STREAM_UNIDIRECTIONAL) == 0)
e4952530e6af HTTP/3: avoid sending stream cancellation for pushed streams. Sergey Kandaurov <pluknet@nginx.com> parents: 8924 diff changeset	412 {
8904 d2c193aa8480 HTTP/3: send Stream Cancellation instruction. Roman Arutyunyan <arut@nginx.com> parents: 8903 diff changeset	413 (void) ngx_http_v3_send_cancel_stream(c, c->quic->id);
d2c193aa8480 HTTP/3: send Stream Cancellation instruction. Roman Arutyunyan <arut@nginx.com> parents: 8903 diff changeset	414 }
d2c193aa8480 HTTP/3: send Stream Cancellation instruction. Roman Arutyunyan <arut@nginx.com> parents: 8903 diff changeset	415
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	416 if (c->timedout) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	417 ngx_quic_reset_stream(c, NGX_HTTP_V3_ERR_GENERAL_PROTOCOL_ERROR);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	418
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	419 } else if (c->close) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	420 ngx_quic_reset_stream(c, NGX_HTTP_V3_ERR_REQUEST_REJECTED);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	421
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	422 } else if (c->requests == 0 \|\| c->error) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	423 ngx_quic_reset_stream(c, NGX_HTTP_V3_ERR_INTERNAL_ERROR);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	424 }
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	425 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	426
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	427
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	428 static void
9059 b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	429 ngx_http_v3_cleanup_connection(void *data)
8725 98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	430 {
9059 b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	431 ngx_connection_t *c = data;
8725 98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	432
8770 67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8768 diff changeset	433 ngx_http_v3_session_t *h3c;
8725 98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	434 ngx_http_core_loc_conf_t *clcf;
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	435
8768 40d710a66aef HTTP/3: ngx_http_v3_get_session() macro. Roman Arutyunyan <arut@nginx.com> parents: 8742 diff changeset	436 h3c = ngx_http_v3_get_session(c);
8725 98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	437
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	438 if (--h3c->nrequests == 0) {
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	439 clcf = ngx_http_v3_get_module_loc_conf(c, ngx_http_core_module);
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	440 ngx_add_timer(&h3c->keepalive, clcf->keepalive_timeout);
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	441 }
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	442 }
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	443
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	444
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	445 static void
9059 b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	446 ngx_http_v3_cleanup_request(void *data)
b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	447 {
b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	448 ngx_http_request_t *r = data;
b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	449
b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	450 if (!r->response_sent) {
b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	451 r->connection->error = 1;
b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	452 }
b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	453 }
b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	454
b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	455
b87a0dbc1150 HTTP/3: implement keepalive for hq. Roman Arutyunyan <arut@nginx.com> parents: 9058 diff changeset	456 static void
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	457 ngx_http_v3_process_request(ngx_event_t *rev)
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	458 {
8838 d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8835 diff changeset	459 u_char *p;
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	460 ssize_t n;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	461 ngx_buf_t *b;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	462 ngx_int_t rc;
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	463 ngx_connection_t *c;
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	464 ngx_http_request_t *r;
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	465 ngx_http_v3_session_t *h3c;
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	466 ngx_http_core_srv_conf_t *cscf;
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	467 ngx_http_v3_parse_headers_t *st;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	468
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	469 c = rev->data;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	470 r = c->data;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	471
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	472 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, rev->log, 0, "http3 process request");
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	473
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	474 if (rev->timedout) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	475 ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, "client timed out");
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	476 c->timedout = 1;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	477 ngx_http_close_request(r, NGX_HTTP_REQUEST_TIME_OUT);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	478 return;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	479 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	480
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	481 h3c = ngx_http_v3_get_session(c);
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	482
8706 3057bae4dba7 HTTP/3: introduced ngx_http_v3_parse_t structure. Roman Arutyunyan <arut@nginx.com> parents: 8690 diff changeset	483 st = &r->v3_parse->headers;
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	484
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	485 b = r->header_in;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	486
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	487 for ( ;; ) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	488
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	489 if (b->pos == b->last) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	490
8685 dbe33ef9cd9a HTTP/3: call ngx_handle_read_event() from client header handler. Roman Arutyunyan <arut@nginx.com> parents: 8682 diff changeset	491 if (rev->ready) {
dbe33ef9cd9a HTTP/3: call ngx_handle_read_event() from client header handler. Roman Arutyunyan <arut@nginx.com> parents: 8682 diff changeset	492 n = c->recv(c, b->start, b->end - b->start);
dbe33ef9cd9a HTTP/3: call ngx_handle_read_event() from client header handler. Roman Arutyunyan <arut@nginx.com> parents: 8682 diff changeset	493
dbe33ef9cd9a HTTP/3: call ngx_handle_read_event() from client header handler. Roman Arutyunyan <arut@nginx.com> parents: 8682 diff changeset	494 } else {
dbe33ef9cd9a HTTP/3: call ngx_handle_read_event() from client header handler. Roman Arutyunyan <arut@nginx.com> parents: 8682 diff changeset	495 n = NGX_AGAIN;
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	496 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	497
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	498 if (n == NGX_AGAIN) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	499 if (!rev->timer_set) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	500 cscf = ngx_http_get_module_srv_conf(r,
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	501 ngx_http_core_module);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	502 ngx_add_timer(rev, cscf->client_header_timeout);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	503 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	504
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	505 if (ngx_handle_read_event(rev, 0) != NGX_OK) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	506 ngx_http_close_request(r, NGX_HTTP_INTERNAL_SERVER_ERROR);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	507 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	508
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	509 break;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	510 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	511
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	512 if (n == 0) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	513 ngx_log_error(NGX_LOG_INFO, c->log, 0,
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	514 "client prematurely closed connection");
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	515 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	516
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	517 if (n == 0 \|\| n == NGX_ERROR) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	518 c->error = 1;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	519 c->log->action = "reading client request";
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	520
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	521 ngx_http_finalize_request(r, NGX_HTTP_BAD_REQUEST);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	522 break;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	523 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	524
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	525 b->pos = b->start;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	526 b->last = b->start + n;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	527 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	528
8838 d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8835 diff changeset	529 p = b->pos;
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8835 diff changeset	530
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8835 diff changeset	531 rc = ngx_http_v3_parse_headers(c, st, b);
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	532
8460 72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	533 if (rc > 0) {
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	534 ngx_quic_reset_stream(c, rc);
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	535 ngx_log_error(NGX_LOG_ERR, r->connection->log, 0,
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	536 "client sent invalid header");
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	537 ngx_http_finalize_request(r, NGX_HTTP_BAD_REQUEST);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	538 break;
8460 72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	539 }
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	540
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	541 if (rc == NGX_ERROR) {
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	542 ngx_http_close_request(r, NGX_HTTP_INTERNAL_SERVER_ERROR);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	543 break;
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	544 }
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	545
8880 a09bcc304eef HTTP/3: fixed request length calculation. Roman Arutyunyan <arut@nginx.com> parents: 8863 diff changeset	546 r->request_length += b->pos - p;
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	547 h3c->total_bytes += b->pos - p;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	548
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	549 if (ngx_http_v3_check_flood(c) != NGX_OK) {
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	550 ngx_http_close_request(r, NGX_HTTP_CLOSE);
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	551 break;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	552 }
8880 a09bcc304eef HTTP/3: fixed request length calculation. Roman Arutyunyan <arut@nginx.com> parents: 8863 diff changeset	553
8456 c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8452 diff changeset	554 if (rc == NGX_BUSY) {
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	555 if (rev->error) {
9066 eaa8dc3788e1 HTTP/3: trigger 400 (Bad Request) on stream error while blocked. Roman Arutyunyan <arut@nginx.com> parents: 9063 diff changeset	556 ngx_http_finalize_request(r, NGX_HTTP_BAD_REQUEST);
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	557 break;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	558 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	559
9067 6bb884dc7291 HTTP/3: insert count block timeout. Roman Arutyunyan <arut@nginx.com> parents: 9066 diff changeset	560 if (!rev->timer_set) {
6bb884dc7291 HTTP/3: insert count block timeout. Roman Arutyunyan <arut@nginx.com> parents: 9066 diff changeset	561 cscf = ngx_http_get_module_srv_conf(r,
6bb884dc7291 HTTP/3: insert count block timeout. Roman Arutyunyan <arut@nginx.com> parents: 9066 diff changeset	562 ngx_http_core_module);
6bb884dc7291 HTTP/3: insert count block timeout. Roman Arutyunyan <arut@nginx.com> parents: 9066 diff changeset	563 ngx_add_timer(rev, cscf->client_header_timeout);
6bb884dc7291 HTTP/3: insert count block timeout. Roman Arutyunyan <arut@nginx.com> parents: 9066 diff changeset	564 }
6bb884dc7291 HTTP/3: insert count block timeout. Roman Arutyunyan <arut@nginx.com> parents: 9066 diff changeset	565
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	566 if (ngx_handle_read_event(rev, 0) != NGX_OK) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	567 ngx_http_close_request(r, NGX_HTTP_INTERNAL_SERVER_ERROR);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	568 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	569
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	570 break;
8456 c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8452 diff changeset	571 }
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8452 diff changeset	572
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	573 if (rc == NGX_AGAIN) {
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	574 continue;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	575 }
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	576
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	577 /* rc == NGX_OK \|\| rc == NGX_DONE */
8233 1e45c02f6376 HTTP/3 $request_line variable. Roman Arutyunyan <arut@nginx.com> parents: 8230 diff changeset	578
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	579 h3c->payload_bytes += ngx_http_v3_encode_field_l(NULL,
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	580 &st->field_rep.field.name,
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	581 &st->field_rep.field.value);
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	582
8807 0ac25efb2da3 HTTP/3: quic-qpack term updates. Sergey Kandaurov <pluknet@nginx.com> parents: 8770 diff changeset	583 if (ngx_http_v3_process_header(r, &st->field_rep.field.name,
0ac25efb2da3 HTTP/3: quic-qpack term updates. Sergey Kandaurov <pluknet@nginx.com> parents: 8770 diff changeset	584 &st->field_rep.field.value)
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	585 != NGX_OK)
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	586 {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	587 break;
8405 d2759e4cc437 HTTP/3: split header parser in two functions. Roman Arutyunyan <arut@nginx.com> parents: 8394 diff changeset	588 }
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	589
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	590 if (rc == NGX_DONE) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	591 if (ngx_http_v3_process_request_header(r) != NGX_OK) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	592 break;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	593 }
8405 d2759e4cc437 HTTP/3: split header parser in two functions. Roman Arutyunyan <arut@nginx.com> parents: 8394 diff changeset	594
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	595 ngx_http_process_request(r);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	596 break;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	597 }
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	598 }
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	599
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	600 ngx_http_run_posted_requests(c);
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	601
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	602 return;
8405 d2759e4cc437 HTTP/3: split header parser in two functions. Roman Arutyunyan <arut@nginx.com> parents: 8394 diff changeset	603 }
d2759e4cc437 HTTP/3: split header parser in two functions. Roman Arutyunyan <arut@nginx.com> parents: 8394 diff changeset	604
d2759e4cc437 HTTP/3: split header parser in two functions. Roman Arutyunyan <arut@nginx.com> parents: 8394 diff changeset	605
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	606 static ngx_int_t
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	607 ngx_http_v3_process_header(ngx_http_request_t r, ngx_str_t name,
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	608 ngx_str_t *value)
8405 d2759e4cc437 HTTP/3: split header parser in two functions. Roman Arutyunyan <arut@nginx.com> parents: 8394 diff changeset	609 {
8707 ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	610 size_t len;
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	611 ngx_table_elt_t *h;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	612 ngx_http_header_t *hh;
8682 916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	613 ngx_http_core_srv_conf_t *cscf;
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	614 ngx_http_core_main_conf_t *cmcf;
8452 a6675a976560 HTTP/3: fixed dropping first non-pseudo header. Roman Arutyunyan <arut@nginx.com> parents: 8451 diff changeset	615
8958 10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	616 static ngx_str_t cookie = ngx_string("cookie");
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	617
8707 ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	618 len = name->len + value->len;
ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	619
ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	620 if (len > r->v3_parse->header_limit) {
ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	621 ngx_log_error(NGX_LOG_INFO, r->connection->log, 0,
ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	622 "client sent too large header");
ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	623 ngx_http_finalize_request(r, NGX_HTTP_REQUEST_HEADER_TOO_LARGE);
ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	624 return NGX_ERROR;
ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	625 }
ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	626
ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	627 r->v3_parse->header_limit -= len;
ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	628
8682 916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	629 if (ngx_http_v3_validate_header(r, name, value) != NGX_OK) {
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	630 ngx_http_finalize_request(r, NGX_HTTP_BAD_REQUEST);
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	631 return NGX_ERROR;
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	632 }
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	633
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	634 if (r->invalid_header) {
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	635 cscf = ngx_http_get_module_srv_conf(r, ngx_http_core_module);
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	636
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	637 if (cscf->ignore_invalid_headers) {
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	638 ngx_log_error(NGX_LOG_INFO, r->connection->log, 0,
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	639 "client sent invalid header: \"%V\"", name);
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	640
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	641 return NGX_OK;
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	642 }
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	643 }
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	644
8957 de7d36aa9bc7 Style. Roman Arutyunyan <arut@nginx.com> parents: 8927 diff changeset	645 if (name->len && name->data[0] == ':') {
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	646 return ngx_http_v3_process_pseudo_header(r, name, value);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	647 }
8452 a6675a976560 HTTP/3: fixed dropping first non-pseudo header. Roman Arutyunyan <arut@nginx.com> parents: 8451 diff changeset	648
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	649 if (ngx_http_v3_init_pseudo_headers(r) != NGX_OK) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	650 return NGX_ERROR;
8405 d2759e4cc437 HTTP/3: split header parser in two functions. Roman Arutyunyan <arut@nginx.com> parents: 8394 diff changeset	651 }
d2759e4cc437 HTTP/3: split header parser in two functions. Roman Arutyunyan <arut@nginx.com> parents: 8394 diff changeset	652
8958 10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	653 if (name->len == cookie.len
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	654 && ngx_memcmp(name->data, cookie.data, cookie.len) == 0)
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	655 {
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	656 if (ngx_http_v3_cookie(r, value) != NGX_OK) {
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	657 ngx_http_close_request(r, NGX_HTTP_INTERNAL_SERVER_ERROR);
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	658 return NGX_ERROR;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	659 }
8405 d2759e4cc437 HTTP/3: split header parser in two functions. Roman Arutyunyan <arut@nginx.com> parents: 8394 diff changeset	660
8958 10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	661 } else {
9275 199dc0d6b05b Added max_headers directive. Maxim Dounin <mdounin@mdounin.ru> parents: 9263 diff changeset	662 cscf = ngx_http_get_module_srv_conf(r, ngx_http_core_module);
199dc0d6b05b Added max_headers directive. Maxim Dounin <mdounin@mdounin.ru> parents: 9263 diff changeset	663
199dc0d6b05b Added max_headers directive. Maxim Dounin <mdounin@mdounin.ru> parents: 9263 diff changeset	664 if (r->headers_in.count++ >= cscf->max_headers) {
199dc0d6b05b Added max_headers directive. Maxim Dounin <mdounin@mdounin.ru> parents: 9263 diff changeset	665 ngx_log_error(NGX_LOG_INFO, r->connection->log, 0,
199dc0d6b05b Added max_headers directive. Maxim Dounin <mdounin@mdounin.ru> parents: 9263 diff changeset	666 "client sent too many header lines");
199dc0d6b05b Added max_headers directive. Maxim Dounin <mdounin@mdounin.ru> parents: 9263 diff changeset	667 ngx_http_finalize_request(r, NGX_HTTP_REQUEST_HEADER_TOO_LARGE);
199dc0d6b05b Added max_headers directive. Maxim Dounin <mdounin@mdounin.ru> parents: 9263 diff changeset	668 return NGX_ERROR;
199dc0d6b05b Added max_headers directive. Maxim Dounin <mdounin@mdounin.ru> parents: 9263 diff changeset	669 }
199dc0d6b05b Added max_headers directive. Maxim Dounin <mdounin@mdounin.ru> parents: 9263 diff changeset	670
8958 10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	671 h = ngx_list_push(&r->headers_in.headers);
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	672 if (h == NULL) {
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	673 ngx_http_close_request(r, NGX_HTTP_INTERNAL_SERVER_ERROR);
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	674 return NGX_ERROR;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	675 }
8406 66feab03d9b7 HTTP/3: restricted symbols in header names. Roman Arutyunyan <arut@nginx.com> parents: 8405 diff changeset	676
8958 10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	677 h->key = *name;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	678 h->value = *value;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	679 h->lowcase_key = h->key.data;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	680 h->hash = ngx_hash_key(h->key.data, h->key.len);
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	681
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	682 cmcf = ngx_http_get_module_main_conf(r, ngx_http_core_module);
8405 d2759e4cc437 HTTP/3: split header parser in two functions. Roman Arutyunyan <arut@nginx.com> parents: 8394 diff changeset	683
8958 10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	684 hh = ngx_hash_find(&cmcf->headers_in_hash, h->hash,
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	685 h->lowcase_key, h->key.len);
8406 66feab03d9b7 HTTP/3: restricted symbols in header names. Roman Arutyunyan <arut@nginx.com> parents: 8405 diff changeset	686
8958 10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	687 if (hh && hh->handler(r, h, hh->offset) != NGX_OK) {
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	688 return NGX_ERROR;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	689 }
8406 66feab03d9b7 HTTP/3: restricted symbols in header names. Roman Arutyunyan <arut@nginx.com> parents: 8405 diff changeset	690 }
66feab03d9b7 HTTP/3: restricted symbols in header names. Roman Arutyunyan <arut@nginx.com> parents: 8405 diff changeset	691
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	692 ngx_log_debug2(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	693 "http3 header: \"%V: %V\"", name, value);
8405 d2759e4cc437 HTTP/3: split header parser in two functions. Roman Arutyunyan <arut@nginx.com> parents: 8394 diff changeset	694 return NGX_OK;
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	695 }
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	696
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	697
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	698 static ngx_int_t
8682 916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	699 ngx_http_v3_validate_header(ngx_http_request_t r, ngx_str_t name,
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	700 ngx_str_t *value)
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	701 {
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	702 u_char ch;
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	703 ngx_uint_t i;
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	704 ngx_http_core_srv_conf_t *cscf;
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	705
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	706 r->invalid_header = 0;
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	707
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	708 cscf = ngx_http_get_module_srv_conf(r, ngx_http_core_module);
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	709
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	710 for (i = (name->data[0] == ':'); i != name->len; i++) {
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	711 ch = name->data[i];
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	712
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	713 if ((ch >= 'a' && ch <= 'z')
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	714 \|\| (ch == '-')
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	715 \|\| (ch >= '0' && ch <= '9')
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	716 \|\| (ch == '_' && cscf->underscores_in_headers))
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	717 {
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	718 continue;
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	719 }
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	720
8832 0d35b1ff6af5 HTTP/3: disabled control characters and space in header names. Sergey Kandaurov <pluknet@nginx.com> parents: 8826 diff changeset	721 if (ch <= 0x20 \|\| ch == 0x7f \|\| ch == ':'
8682 916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	722 \|\| (ch >= 'A' && ch <= 'Z'))
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	723 {
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	724 ngx_log_error(NGX_LOG_INFO, r->connection->log, 0,
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	725 "client sent invalid header name: \"%V\"", name);
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	726
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	727 return NGX_ERROR;
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	728 }
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	729
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	730 r->invalid_header = 1;
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	731 }
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	732
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	733 for (i = 0; i != value->len; i++) {
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	734 ch = value->data[i];
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	735
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	736 if (ch == '\0' \|\| ch == LF \|\| ch == CR) {
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	737 ngx_log_error(NGX_LOG_INFO, r->connection->log, 0,
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	738 "client sent header \"%V\" with "
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	739 "invalid value: \"%V\"", name, value);
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	740
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	741 return NGX_ERROR;
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	742 }
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	743 }
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	744
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	745 return NGX_OK;
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	746 }
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	747
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	748
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	749 static ngx_int_t
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	750 ngx_http_v3_process_pseudo_header(ngx_http_request_t r, ngx_str_t name,
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	751 ngx_str_t *value)
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	752 {
8680 58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	753 u_char ch, c;
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	754 ngx_uint_t i;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	755
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	756 if (r->request_line.len) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	757 ngx_log_error(NGX_LOG_INFO, r->connection->log, 0,
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	758 "client sent out of order pseudo-headers");
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	759 goto failed;
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	760 }
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	761
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	762 if (name->len == 7 && ngx_strncmp(name->data, ":method", 7) == 0) {
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	763
8680 58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	764 if (r->method_name.len) {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	765 ngx_log_error(NGX_LOG_INFO, r->connection->log, 0,
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	766 "client sent duplicate \":method\" header");
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	767 goto failed;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	768 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	769
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	770 if (value->len == 0) {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	771 ngx_log_error(NGX_LOG_INFO, r->connection->log, 0,
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	772 "client sent empty \":method\" header");
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	773 goto failed;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	774 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	775
8650 9dce2978e4fd HTTP/3: eliminated r->method_start. Roman Arutyunyan <arut@nginx.com> parents: 8630 diff changeset	776 r->method_name = *value;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	777
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	778 for (i = 0; i < sizeof(ngx_http_v3_methods)
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	779 / sizeof(ngx_http_v3_methods[0]); i++)
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	780 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	781 if (value->len == ngx_http_v3_methods[i].name.len
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	782 && ngx_strncmp(value->data,
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	783 ngx_http_v3_methods[i].name.data, value->len)
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	784 == 0)
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	785 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	786 r->method = ngx_http_v3_methods[i].method;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	787 break;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	788 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	789 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	790
8680 58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	791 for (i = 0; i < value->len; i++) {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	792 ch = value->data[i];
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	793
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	794 if ((ch < 'A' \|\| ch > 'Z') && ch != '_' && ch != '-') {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	795 ngx_log_error(NGX_LOG_INFO, r->connection->log, 0,
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	796 "client sent invalid method: \"%V\"", value);
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	797 goto failed;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	798 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	799 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	800
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	801 ngx_log_debug2(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	802 "http3 method \"%V\" %ui", value, r->method);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	803 return NGX_OK;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	804 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	805
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	806 if (name->len == 5 && ngx_strncmp(name->data, ":path", 5) == 0) {
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	807
8680 58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	808 if (r->uri_start) {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	809 ngx_log_error(NGX_LOG_INFO, r->connection->log, 0,
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	810 "client sent duplicate \":path\" header");
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	811 goto failed;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	812 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	813
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	814 if (value->len == 0) {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	815 ngx_log_error(NGX_LOG_INFO, r->connection->log, 0,
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	816 "client sent empty \":path\" header");
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	817 goto failed;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	818 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	819
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	820 r->uri_start = value->data;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	821 r->uri_end = value->data + value->len;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	822
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	823 if (ngx_http_parse_uri(r) != NGX_OK) {
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	824 ngx_log_error(NGX_LOG_INFO, r->connection->log, 0,
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	825 "client sent invalid \":path\" header: \"%V\"",
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	826 value);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	827 goto failed;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	828 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	829
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	830 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	831 "http3 path \"%V\"", value);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	832 return NGX_OK;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	833 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	834
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	835 if (name->len == 7 && ngx_strncmp(name->data, ":scheme", 7) == 0) {
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	836
8680 58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	837 if (r->schema.len) {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	838 ngx_log_error(NGX_LOG_INFO, r->connection->log, 0,
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	839 "client sent duplicate \":scheme\" header");
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	840 goto failed;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	841 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	842
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	843 if (value->len == 0) {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	844 ngx_log_error(NGX_LOG_INFO, r->connection->log, 0,
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	845 "client sent empty \":scheme\" header");
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	846 goto failed;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	847 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	848
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	849 for (i = 0; i < value->len; i++) {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	850 ch = value->data[i];
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	851
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	852 c = (u_char) (ch \| 0x20);
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	853 if (c >= 'a' && c <= 'z') {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	854 continue;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	855 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	856
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	857 if (((ch >= '0' && ch <= '9')
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	858 \|\| ch == '+' \|\| ch == '-' \|\| ch == '.')
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	859 && i > 0)
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	860 {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	861 continue;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	862 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	863
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	864 ngx_log_error(NGX_LOG_INFO, r->connection->log, 0,
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	865 "client sent invalid \":scheme\" header: \"%V\"",
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	866 value);
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	867 goto failed;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	868 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	869
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	870 r->schema = *value;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	871
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	872 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	873 "http3 schema \"%V\"", value);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	874 return NGX_OK;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	875 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	876
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	877 if (name->len == 10 && ngx_strncmp(name->data, ":authority", 10) == 0) {
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	878
8680 58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	879 if (r->host_start) {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	880 ngx_log_error(NGX_LOG_INFO, r->connection->log, 0,
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	881 "client sent duplicate \":authority\" header");
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	882 goto failed;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	883 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	884
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	885 r->host_start = value->data;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	886 r->host_end = value->data + value->len;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	887
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	888 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	889 "http3 authority \"%V\"", value);
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	890 return NGX_OK;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	891 }
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	892
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	893 ngx_log_error(NGX_LOG_INFO, r->connection->log, 0,
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	894 "client sent unknown pseudo-header \"%V\"", name);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	895
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	896 failed:
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	897
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	898 ngx_http_finalize_request(r, NGX_HTTP_BAD_REQUEST);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	899 return NGX_ERROR;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	900 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	901
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	902
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	903 static ngx_int_t
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	904 ngx_http_v3_init_pseudo_headers(ngx_http_request_t *r)
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	905 {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	906 size_t len;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	907 u_char *p;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	908 ngx_int_t rc;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	909 ngx_str_t host;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	910
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	911 if (r->request_line.len) {
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	912 return NGX_OK;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	913 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	914
8680 58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	915 if (r->method_name.len == 0) {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	916 ngx_log_error(NGX_LOG_INFO, r->connection->log, 0,
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	917 "client sent no \":method\" header");
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	918 goto failed;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	919 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	920
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	921 if (r->schema.len == 0) {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	922 ngx_log_error(NGX_LOG_INFO, r->connection->log, 0,
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	923 "client sent no \":scheme\" header");
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	924 goto failed;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	925 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	926
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	927 if (r->uri_start == NULL) {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	928 ngx_log_error(NGX_LOG_INFO, r->connection->log, 0,
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	929 "client sent no \":path\" header");
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	930 goto failed;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	931 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	932
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	933 len = r->method_name.len + 1
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	934 + (r->uri_end - r->uri_start) + 1
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	935 + sizeof("HTTP/3.0") - 1;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	936
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	937 p = ngx_pnalloc(r->pool, len);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	938 if (p == NULL) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	939 ngx_http_close_request(r, NGX_HTTP_INTERNAL_SERVER_ERROR);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	940 return NGX_ERROR;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	941 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	942
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	943 r->request_line.data = p;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	944
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	945 p = ngx_cpymem(p, r->method_name.data, r->method_name.len);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	946 *p++ = ' ';
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	947 p = ngx_cpymem(p, r->uri_start, r->uri_end - r->uri_start);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	948 *p++ = ' ';
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	949 p = ngx_cpymem(p, "HTTP/3.0", sizeof("HTTP/3.0") - 1);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	950
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	951 r->request_line.len = p - r->request_line.data;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	952
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	953 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	954 "http3 request line: \"%V\"", &r->request_line);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	955
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	956 ngx_str_set(&r->http_protocol, "HTTP/3.0");
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	957
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	958 if (ngx_http_process_request_uri(r) != NGX_OK) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	959 return NGX_ERROR;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	960 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	961
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	962 if (r->host_end) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	963
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	964 host.len = r->host_end - r->host_start;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	965 host.data = r->host_start;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	966
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	967 rc = ngx_http_validate_host(&host, r->pool, 0);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	968
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	969 if (rc == NGX_DECLINED) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	970 ngx_log_error(NGX_LOG_INFO, r->connection->log, 0,
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	971 "client sent invalid host in request line");
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	972 goto failed;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	973 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	974
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	975 if (rc == NGX_ERROR) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	976 ngx_http_close_request(r, NGX_HTTP_INTERNAL_SERVER_ERROR);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	977 return NGX_ERROR;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	978 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	979
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	980 if (ngx_http_set_virtual_server(r, &host) == NGX_ERROR) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	981 return NGX_ERROR;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	982 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	983
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	984 r->headers_in.server = host;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	985 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	986
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	987 if (ngx_list_init(&r->headers_in.headers, r->pool, 20,
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	988 sizeof(ngx_table_elt_t))
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	989 != NGX_OK)
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	990 {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	991 ngx_http_close_request(r, NGX_HTTP_INTERNAL_SERVER_ERROR);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	992 return NGX_ERROR;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	993 }
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	994
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	995 return NGX_OK;
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	996
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	997 failed:
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	998
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	999 ngx_http_finalize_request(r, NGX_HTTP_BAD_REQUEST);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1000 return NGX_ERROR;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1001 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1002
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1003
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1004 static ngx_int_t
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1005 ngx_http_v3_process_request_header(ngx_http_request_t *r)
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1006 {
9081 c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	1007 ssize_t n;
c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	1008 ngx_buf_t *b;
c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	1009 ngx_connection_t *c;
c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	1010 ngx_http_v3_session_t *h3c;
c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	1011 ngx_http_v3_srv_conf_t *h3scf;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1012
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1013 c = r->connection;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1014
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1015 if (ngx_http_v3_init_pseudo_headers(r) != NGX_OK) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1016 return NGX_ERROR;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1017 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1018
9081 c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	1019 h3c = ngx_http_v3_get_session(c);
c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	1020 h3scf = ngx_http_get_module_srv_conf(r, ngx_http_v3_module);
c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	1021
9104 69bae2437d74 HTTP/3: removed "http3" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9081 diff changeset	1022 if ((h3c->hq && !h3scf->enable_hq) \|\| (!h3c->hq && !h3scf->enable)) {
69bae2437d74 HTTP/3: removed "http3" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9081 diff changeset	1023 ngx_log_error(NGX_LOG_INFO, c->log, 0,
69bae2437d74 HTTP/3: removed "http3" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9081 diff changeset	1024 "client attempted to request the server name "
69bae2437d74 HTTP/3: removed "http3" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9081 diff changeset	1025 "for which the negotiated protocol is disabled");
69bae2437d74 HTTP/3: removed "http3" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9081 diff changeset	1026 ngx_http_finalize_request(r, NGX_HTTP_MISDIRECTED_REQUEST);
69bae2437d74 HTTP/3: removed "http3" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9081 diff changeset	1027 return NGX_ERROR;
9081 c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	1028 }
c851a2ed5ce8 HTTP/3: "quic" parameter of "listen" directive. Roman Arutyunyan <arut@nginx.com> parents: 9067 diff changeset	1029
8958 10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1030 if (ngx_http_v3_construct_cookie_header(r) != NGX_OK) {
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1031 return NGX_ERROR;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1032 }
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1033
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1034 if (r->headers_in.server.len == 0) {
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1035 ngx_log_error(NGX_LOG_INFO, c->log, 0,
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1036 "client sent neither \":authority\" nor \"Host\" header");
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1037 goto failed;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1038 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1039
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1040 if (r->headers_in.host) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1041 if (r->headers_in.host->value.len != r->headers_in.server.len
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1042 \|\| ngx_memcmp(r->headers_in.host->value.data,
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1043 r->headers_in.server.data,
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1044 r->headers_in.server.len)
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1045 != 0)
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1046 {
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1047 ngx_log_error(NGX_LOG_INFO, c->log, 0,
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1048 "client sent \":authority\" and \"Host\" headers "
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1049 "with different values");
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1050 goto failed;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1051 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1052 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1053
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1054 if (r->headers_in.content_length) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1055 r->headers_in.content_length_n =
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1056 ngx_atoof(r->headers_in.content_length->value.data,
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1057 r->headers_in.content_length->value.len);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1058
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1059 if (r->headers_in.content_length_n == NGX_ERROR) {
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1060 ngx_log_error(NGX_LOG_INFO, c->log, 0,
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1061 "client sent invalid \"Content-Length\" header");
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1062 goto failed;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1063 }
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1064
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1065 } else {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1066 b = r->header_in;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1067 n = b->last - b->pos;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1068
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1069 if (n == 0) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1070 n = c->recv(c, b->start, b->end - b->start);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1071
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1072 if (n == NGX_ERROR) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1073 ngx_http_close_request(r, NGX_HTTP_INTERNAL_SERVER_ERROR);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1074 return NGX_ERROR;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1075 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1076
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1077 if (n > 0) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1078 b->pos = b->start;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1079 b->last = b->start + n;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1080 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1081 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1082
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1083 if (n != 0) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1084 r->headers_in.chunked = 1;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1085 }
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1086 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1087
8854 7416d3b2fac5 HTTP/3: added CONNECT and TRACE methods rejection. Sergey Kandaurov <pluknet@nginx.com> parents: 8847 diff changeset	1088 if (r->method == NGX_HTTP_CONNECT) {
7416d3b2fac5 HTTP/3: added CONNECT and TRACE methods rejection. Sergey Kandaurov <pluknet@nginx.com> parents: 8847 diff changeset	1089 ngx_log_error(NGX_LOG_INFO, c->log, 0, "client sent CONNECT method");
7416d3b2fac5 HTTP/3: added CONNECT and TRACE methods rejection. Sergey Kandaurov <pluknet@nginx.com> parents: 8847 diff changeset	1090 ngx_http_finalize_request(r, NGX_HTTP_NOT_ALLOWED);
7416d3b2fac5 HTTP/3: added CONNECT and TRACE methods rejection. Sergey Kandaurov <pluknet@nginx.com> parents: 8847 diff changeset	1091 return NGX_ERROR;
7416d3b2fac5 HTTP/3: added CONNECT and TRACE methods rejection. Sergey Kandaurov <pluknet@nginx.com> parents: 8847 diff changeset	1092 }
7416d3b2fac5 HTTP/3: added CONNECT and TRACE methods rejection. Sergey Kandaurov <pluknet@nginx.com> parents: 8847 diff changeset	1093
7416d3b2fac5 HTTP/3: added CONNECT and TRACE methods rejection. Sergey Kandaurov <pluknet@nginx.com> parents: 8847 diff changeset	1094 if (r->method == NGX_HTTP_TRACE) {
7416d3b2fac5 HTTP/3: added CONNECT and TRACE methods rejection. Sergey Kandaurov <pluknet@nginx.com> parents: 8847 diff changeset	1095 ngx_log_error(NGX_LOG_INFO, c->log, 0, "client sent TRACE method");
7416d3b2fac5 HTTP/3: added CONNECT and TRACE methods rejection. Sergey Kandaurov <pluknet@nginx.com> parents: 8847 diff changeset	1096 ngx_http_finalize_request(r, NGX_HTTP_NOT_ALLOWED);
7416d3b2fac5 HTTP/3: added CONNECT and TRACE methods rejection. Sergey Kandaurov <pluknet@nginx.com> parents: 8847 diff changeset	1097 return NGX_ERROR;
7416d3b2fac5 HTTP/3: added CONNECT and TRACE methods rejection. Sergey Kandaurov <pluknet@nginx.com> parents: 8847 diff changeset	1098 }
7416d3b2fac5 HTTP/3: added CONNECT and TRACE methods rejection. Sergey Kandaurov <pluknet@nginx.com> parents: 8847 diff changeset	1099
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1100 return NGX_OK;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1101
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1102 failed:
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1103
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1104 ngx_http_finalize_request(r, NGX_HTTP_BAD_REQUEST);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1105 return NGX_ERROR;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	1106 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	1107
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	1108
8958 10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1109 static ngx_int_t
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1110 ngx_http_v3_cookie(ngx_http_request_t r, ngx_str_t value)
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1111 {
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1112 ngx_str_t *val;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1113 ngx_array_t *cookies;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1114
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1115 cookies = r->v3_parse->cookies;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1116
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1117 if (cookies == NULL) {
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1118 cookies = ngx_array_create(r->pool, 2, sizeof(ngx_str_t));
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1119 if (cookies == NULL) {
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1120 return NGX_ERROR;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1121 }
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1122
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1123 r->v3_parse->cookies = cookies;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1124 }
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1125
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1126 val = ngx_array_push(cookies);
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1127 if (val == NULL) {
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1128 return NGX_ERROR;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1129 }
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1130
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1131 val = value;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1132
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1133 return NGX_OK;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1134 }
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1135
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1136
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1137 static ngx_int_t
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1138 ngx_http_v3_construct_cookie_header(ngx_http_request_t *r)
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1139 {
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1140 u_char buf, p, *end;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1141 size_t len;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1142 ngx_str_t *vals;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1143 ngx_uint_t i;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1144 ngx_array_t *cookies;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1145 ngx_table_elt_t *h;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1146 ngx_http_header_t *hh;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1147 ngx_http_core_main_conf_t *cmcf;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1148
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1149 static ngx_str_t cookie = ngx_string("cookie");
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1150
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1151 cookies = r->v3_parse->cookies;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1152
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1153 if (cookies == NULL) {
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1154 return NGX_OK;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1155 }
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1156
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1157 vals = cookies->elts;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1158
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1159 i = 0;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1160 len = 0;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1161
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1162 do {
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1163 len += vals[i].len + 2;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1164 } while (++i != cookies->nelts);
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1165
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1166 len -= 2;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1167
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1168 buf = ngx_pnalloc(r->pool, len + 1);
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1169 if (buf == NULL) {
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1170 ngx_http_close_request(r, NGX_HTTP_INTERNAL_SERVER_ERROR);
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1171 return NGX_ERROR;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1172 }
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1173
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1174 p = buf;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1175 end = buf + len;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1176
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1177 for (i = 0; /* void */ ; i++) {
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1178
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1179 p = ngx_cpymem(p, vals[i].data, vals[i].len);
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1180
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1181 if (p == end) {
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1182 *p = '\0';
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1183 break;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1184 }
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1185
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1186 p++ = ';'; p++ = ' ';
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1187 }
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1188
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1189 h = ngx_list_push(&r->headers_in.headers);
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1190 if (h == NULL) {
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1191 ngx_http_close_request(r, NGX_HTTP_INTERNAL_SERVER_ERROR);
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1192 return NGX_ERROR;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1193 }
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1194
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1195 h->hash = ngx_hash(ngx_hash(ngx_hash(ngx_hash(
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1196 ngx_hash('c', 'o'), 'o'), 'k'), 'i'), 'e');
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1197
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1198 h->key.len = cookie.len;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1199 h->key.data = cookie.data;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1200
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1201 h->value.len = len;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1202 h->value.data = buf;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1203
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1204 h->lowcase_key = cookie.data;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1205
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1206 cmcf = ngx_http_get_module_main_conf(r, ngx_http_core_module);
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1207
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1208 hh = ngx_hash_find(&cmcf->headers_in_hash, h->hash,
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1209 h->lowcase_key, h->key.len);
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1210
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1211 if (hh == NULL) {
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1212 ngx_http_close_request(r, NGX_HTTP_INTERNAL_SERVER_ERROR);
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1213 return NGX_ERROR;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1214 }
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1215
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1216 if (hh->handler(r, h, hh->offset) != NGX_OK) {
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1217 /*
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1218 * request has been finalized already
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1219 * in ngx_http_process_multi_header_lines()
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1220 */
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1221 return NGX_ERROR;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1222 }
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1223
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1224 return NGX_OK;
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1225 }
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1226
10522e8dea41 HTTP/3: improved processing of multiple Cookie field lines. Sergey Kandaurov <pluknet@nginx.com> parents: 8957 diff changeset	1227
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1228 ngx_int_t
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1229 ngx_http_v3_read_request_body(ngx_http_request_t *r)
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1230 {
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1231 size_t preread;
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1232 ngx_int_t rc;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1233 ngx_chain_t *cl, out;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1234 ngx_http_request_body_t *rb;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1235 ngx_http_core_loc_conf_t *clcf;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1236
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1237 rb = r->request_body;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1238
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1239 preread = r->header_in->last - r->header_in->pos;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1240
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1241 if (preread) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1242
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1243 /* there is the pre-read part of the request body */
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1244
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1245 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1246 "http3 client request body preread %uz", preread);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1247
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1248 out.buf = r->header_in;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1249 out.next = NULL;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1250 cl = &out;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1251
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1252 } else {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1253 cl = NULL;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1254 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1255
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1256 rc = ngx_http_v3_request_body_filter(r, cl);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1257 if (rc != NGX_OK) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1258 return rc;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1259 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1260
8847 e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1261 if (rb->rest == 0 && rb->last_saved) {
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1262 /* the whole request body was pre-read */
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1263 r->request_body_no_buffering = 0;
9254 cb1e214efe41 Request body: provided log action for reading request body. Maxim Dounin <mdounin@mdounin.ru> parents: 9251 diff changeset	1264 r->connection->log->action = NULL;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1265 rb->post_handler(r);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1266 return NGX_OK;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1267 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1268
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1269 if (rb->rest < 0) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1270 ngx_log_error(NGX_LOG_ALERT, r->connection->log, 0,
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1271 "negative request body rest");
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1272 return NGX_HTTP_INTERNAL_SERVER_ERROR;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1273 }
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1274
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1275 clcf = ngx_http_get_module_loc_conf(r, ngx_http_core_module);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1276
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1277 rb->buf = ngx_create_temp_buf(r->pool, clcf->client_body_buffer_size);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1278 if (rb->buf == NULL) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1279 return NGX_HTTP_INTERNAL_SERVER_ERROR;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1280 }
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1281
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1282 r->read_event_handler = ngx_http_v3_read_client_request_body_handler;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1283 r->write_event_handler = ngx_http_request_empty_handler;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1284
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1285 return ngx_http_v3_do_read_client_request_body(r);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1286 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1287
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1288
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1289 static void
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1290 ngx_http_v3_read_client_request_body_handler(ngx_http_request_t *r)
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1291 {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1292 ngx_int_t rc;
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1293
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1294 if (r->connection->read->timedout) {
9255 208a4adb82ef Request body: logging of timeouts. Maxim Dounin <mdounin@mdounin.ru> parents: 9254 diff changeset	1295 ngx_log_error(NGX_LOG_INFO, r->connection->log, NGX_ETIMEDOUT,
208a4adb82ef Request body: logging of timeouts. Maxim Dounin <mdounin@mdounin.ru> parents: 9254 diff changeset	1296 "client timed out");
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1297 r->connection->timedout = 1;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1298 ngx_http_finalize_request(r, NGX_HTTP_REQUEST_TIME_OUT);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1299 return;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1300 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1301
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1302 rc = ngx_http_v3_do_read_client_request_body(r);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1303
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1304 if (rc >= NGX_HTTP_SPECIAL_RESPONSE) {
9259 81082b5521dd Request body: body is now cleared on errors. Maxim Dounin <mdounin@mdounin.ru> parents: 9255 diff changeset	1305
9263 388a801e9bb9 Request body: discarded body now treated as no body. Maxim Dounin <mdounin@mdounin.ru> parents: 9259 diff changeset	1306 r->discard_body = 1;
9259 81082b5521dd Request body: body is now cleared on errors. Maxim Dounin <mdounin@mdounin.ru> parents: 9255 diff changeset	1307 r->request_body->bufs = NULL;
81082b5521dd Request body: body is now cleared on errors. Maxim Dounin <mdounin@mdounin.ru> parents: 9255 diff changeset	1308
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1309 ngx_http_finalize_request(r, rc);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1310 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1311 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1312
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1313
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1314 ngx_int_t
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1315 ngx_http_v3_read_unbuffered_request_body(ngx_http_request_t *r)
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1316 {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1317 ngx_int_t rc;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1318
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1319 if (r->connection->read->timedout) {
9255 208a4adb82ef Request body: logging of timeouts. Maxim Dounin <mdounin@mdounin.ru> parents: 9254 diff changeset	1320 ngx_log_error(NGX_LOG_INFO, r->connection->log, NGX_ETIMEDOUT,
208a4adb82ef Request body: logging of timeouts. Maxim Dounin <mdounin@mdounin.ru> parents: 9254 diff changeset	1321 "client timed out");
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1322 r->connection->timedout = 1;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1323 return NGX_HTTP_REQUEST_TIME_OUT;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1324 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1325
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1326 rc = ngx_http_v3_do_read_client_request_body(r);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1327
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1328 if (rc == NGX_OK) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1329 r->reading_body = 0;
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1330 }
5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1331
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1332 return rc;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1333 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1334
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1335
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1336 static ngx_int_t
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1337 ngx_http_v3_do_read_client_request_body(ngx_http_request_t *r)
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1338 {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1339 off_t rest;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1340 size_t size;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1341 ssize_t n;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1342 ngx_int_t rc;
8847 e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1343 ngx_uint_t flush;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1344 ngx_chain_t out;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1345 ngx_connection_t *c;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1346 ngx_http_request_body_t *rb;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1347 ngx_http_core_loc_conf_t *clcf;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1348
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1349 c = r->connection;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1350 rb = r->request_body;
8847 e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1351 flush = 1;
9241 07ca679842de HTTP/3: synced request body reading changes to reduce diffs. Maxim Dounin <mdounin@mdounin.ru> parents: 9161 diff changeset	1352 n = NGX_AGAIN;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1353
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1354 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0,
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1355 "http3 read client request body");
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1356
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1357 for ( ;; ) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1358 for ( ;; ) {
8847 e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1359 if (rb->rest == 0) {
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1360 break;
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1361 }
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1362
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1363 if (rb->buf->last == rb->buf->end) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1364
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1365 /* update chains */
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1366
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1367 rc = ngx_http_v3_request_body_filter(r, NULL);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1368
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1369 if (rc != NGX_OK) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1370 return rc;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1371 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1372
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1373 if (rb->busy != NULL) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1374 if (r->request_body_no_buffering) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1375 if (c->read->timer_set) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1376 ngx_del_timer(c->read);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1377 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1378
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1379 if (ngx_handle_read_event(c->read, 0) != NGX_OK) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1380 return NGX_HTTP_INTERNAL_SERVER_ERROR;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1381 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1382
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1383 return NGX_AGAIN;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1384 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1385
8847 e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1386 if (rb->filter_need_buffering) {
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1387 clcf = ngx_http_get_module_loc_conf(r,
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1388 ngx_http_core_module);
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1389 ngx_add_timer(c->read, clcf->client_body_timeout);
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1390
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1391 if (ngx_handle_read_event(c->read, 0) != NGX_OK) {
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1392 return NGX_HTTP_INTERNAL_SERVER_ERROR;
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1393 }
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1394
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1395 return NGX_AGAIN;
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1396 }
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1397
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1398 ngx_log_error(NGX_LOG_ALERT, c->log, 0,
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1399 "busy buffers after request body flush");
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1400
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1401 return NGX_HTTP_INTERNAL_SERVER_ERROR;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1402 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1403
8847 e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1404 flush = 0;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1405 rb->buf->pos = rb->buf->start;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1406 rb->buf->last = rb->buf->start;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1407 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1408
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1409 size = rb->buf->end - rb->buf->last;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1410 rest = rb->rest - (rb->buf->last - rb->buf->pos);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1411
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1412 if ((off_t) size > rest) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1413 size = (size_t) rest;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1414 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1415
8847 e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1416 if (size == 0) {
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1417 break;
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1418 }
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1419
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1420 n = c->recv(c, rb->buf->last, size);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1421
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1422 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1423 "http3 client request body recv %z", n);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1424
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1425 if (n == NGX_AGAIN) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1426 break;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1427 }
8460 72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	1428
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1429 if (n == 0) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1430 rb->buf->last_buf = 1;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1431 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1432
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1433 if (n == NGX_ERROR) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1434 c->error = 1;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1435 return NGX_HTTP_BAD_REQUEST;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1436 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1437
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1438 rb->buf->last += n;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1439
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1440 /* pass buffer to request body filter chain */
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1441
8847 e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1442 flush = 0;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1443 out.buf = rb->buf;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1444 out.next = NULL;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1445
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1446 rc = ngx_http_v3_request_body_filter(r, &out);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1447
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1448 if (rc != NGX_OK) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1449 return rc;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1450 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1451
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1452 if (rb->rest == 0) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1453 break;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1454 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1455
9241 07ca679842de HTTP/3: synced request body reading changes to reduce diffs. Maxim Dounin <mdounin@mdounin.ru> parents: 9161 diff changeset	1456 if (!c->read->ready) {
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1457 break;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1458 }
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1459 }
5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1460
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1461 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1462 "http3 client request body rest %O", rb->rest);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1463
8847 e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1464 if (flush) {
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1465 rc = ngx_http_v3_request_body_filter(r, NULL);
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1466
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1467 if (rc != NGX_OK) {
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1468 return rc;
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1469 }
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1470 }
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1471
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1472 if (rb->rest == 0 && rb->last_saved) {
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1473 break;
8549 d70a38acaea0 HTTP/3: skip unknown frames on request stream. Roman Arutyunyan <arut@nginx.com> parents: 8548 diff changeset	1474 }
d70a38acaea0 HTTP/3: skip unknown frames on request stream. Roman Arutyunyan <arut@nginx.com> parents: 8548 diff changeset	1475
9241 07ca679842de HTTP/3: synced request body reading changes to reduce diffs. Maxim Dounin <mdounin@mdounin.ru> parents: 9161 diff changeset	1476 if (n == NGX_AGAIN \|\| !c->read->ready \|\| rb->rest == 0) {
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1477
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1478 clcf = ngx_http_get_module_loc_conf(r, ngx_http_core_module);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1479 ngx_add_timer(c->read, clcf->client_body_timeout);
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1480
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1481 if (ngx_handle_read_event(c->read, 0) != NGX_OK) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1482 return NGX_HTTP_INTERNAL_SERVER_ERROR;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1483 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1484
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1485 return NGX_AGAIN;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1486 }
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1487 }
5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1488
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1489 if (c->read->timer_set) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1490 ngx_del_timer(c->read);
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1491 }
5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1492
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1493 if (!r->request_body_no_buffering) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1494 r->read_event_handler = ngx_http_block_reading;
9254 cb1e214efe41 Request body: provided log action for reading request body. Maxim Dounin <mdounin@mdounin.ru> parents: 9251 diff changeset	1495 r->connection->log->action = NULL;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1496 rb->post_handler(r);
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1497 }
5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1498
8548 9ffef6054abf HTTP/3: fixed handling request body eof. Roman Arutyunyan <arut@nginx.com> parents: 8511 diff changeset	1499 return NGX_OK;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1500 }
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1501
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1502
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1503 static ngx_int_t
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1504 ngx_http_v3_request_body_filter(ngx_http_request_t r, ngx_chain_t in)
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1505 {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1506 size_t size;
8838 d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8835 diff changeset	1507 u_char *p;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1508 ngx_int_t rc;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1509 ngx_buf_t *b;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1510 ngx_uint_t last;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1511 ngx_chain_t cl, out, tl, *ll;
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1512 ngx_http_v3_session_t *h3c;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1513 ngx_http_request_body_t *rb;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1514 ngx_http_core_loc_conf_t *clcf;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1515 ngx_http_core_srv_conf_t *cscf;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1516 ngx_http_v3_parse_data_t *st;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1517
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1518 rb = r->request_body;
8706 3057bae4dba7 HTTP/3: introduced ngx_http_v3_parse_t structure. Roman Arutyunyan <arut@nginx.com> parents: 8690 diff changeset	1519 st = &r->v3_parse->body;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1520
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1521 h3c = ngx_http_v3_get_session(r->connection);
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1522
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1523 if (rb->rest == -1) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1524
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1525 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1526 "http3 request body filter");
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1527
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1528 cscf = ngx_http_get_module_srv_conf(r, ngx_http_core_module);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1529
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1530 rb->rest = cscf->large_client_header_buffers.size;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1531 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1532
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1533 out = NULL;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1534 ll = &out;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1535 last = 0;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1536
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1537 for (cl = in; cl; cl = cl->next) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1538
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1539 ngx_log_debug7(NGX_LOG_DEBUG_EVENT, r->connection->log, 0,
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1540 "http3 body buf "
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1541 "t:%d f:%d %p, pos %p, size: %z file: %O, size: %O",
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1542 cl->buf->temporary, cl->buf->in_file,
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1543 cl->buf->start, cl->buf->pos,
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1544 cl->buf->last - cl->buf->pos,
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1545 cl->buf->file_pos,
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1546 cl->buf->file_last - cl->buf->file_pos);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1547
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1548 if (cl->buf->last_buf) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1549 last = 1;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1550 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1551
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1552 b = NULL;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1553
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1554 while (cl->buf->pos < cl->buf->last) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1555
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1556 if (st->length == 0) {
8838 d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8835 diff changeset	1557 p = cl->buf->pos;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1558
8838 d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8835 diff changeset	1559 rc = ngx_http_v3_parse_data(r->connection, st, cl->buf);
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8835 diff changeset	1560
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8835 diff changeset	1561 r->request_length += cl->buf->pos - p;
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1562 h3c->total_bytes += cl->buf->pos - p;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1563
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1564 if (ngx_http_v3_check_flood(r->connection) != NGX_OK) {
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1565 return NGX_HTTP_CLOSE;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1566 }
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1567
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1568 if (rc == NGX_AGAIN) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1569 continue;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1570 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1571
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1572 if (rc == NGX_DONE) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1573 last = 1;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1574 goto done;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1575 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1576
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1577 if (rc > 0) {
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	1578 ngx_quic_reset_stream(r->connection, rc);
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1579 ngx_log_error(NGX_LOG_ERR, r->connection->log, 0,
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1580 "client sent invalid body");
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1581 return NGX_HTTP_BAD_REQUEST;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1582 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1583
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1584 if (rc == NGX_ERROR) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1585 return NGX_HTTP_INTERNAL_SERVER_ERROR;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1586 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1587
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1588 /* rc == NGX_OK */
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1589
9251 3728a0ed243a HTTP/3: fixed handling of request body larger than Content-Length. Maxim Dounin <mdounin@mdounin.ru> parents: 9241 diff changeset	1590 clcf = ngx_http_get_module_loc_conf(r, ngx_http_core_module);
3728a0ed243a HTTP/3: fixed handling of request body larger than Content-Length. Maxim Dounin <mdounin@mdounin.ru> parents: 9241 diff changeset	1591
3728a0ed243a HTTP/3: fixed handling of request body larger than Content-Length. Maxim Dounin <mdounin@mdounin.ru> parents: 9241 diff changeset	1592 if (clcf->client_max_body_size
3728a0ed243a HTTP/3: fixed handling of request body larger than Content-Length. Maxim Dounin <mdounin@mdounin.ru> parents: 9241 diff changeset	1593 && (uint64_t) (clcf->client_max_body_size - rb->received)
3728a0ed243a HTTP/3: fixed handling of request body larger than Content-Length. Maxim Dounin <mdounin@mdounin.ru> parents: 9241 diff changeset	1594 < st->length)
3728a0ed243a HTTP/3: fixed handling of request body larger than Content-Length. Maxim Dounin <mdounin@mdounin.ru> parents: 9241 diff changeset	1595 {
9027 f9d7930d0eed HTTP/3: skip empty request body buffers (ticket #2374). Roman Arutyunyan <arut@nginx.com> parents: 8958 diff changeset	1596 ngx_log_error(NGX_LOG_ERR, r->connection->log, 0,
f9d7930d0eed HTTP/3: skip empty request body buffers (ticket #2374). Roman Arutyunyan <arut@nginx.com> parents: 8958 diff changeset	1597 "client intended to send too large "
f9d7930d0eed HTTP/3: skip empty request body buffers (ticket #2374). Roman Arutyunyan <arut@nginx.com> parents: 8958 diff changeset	1598 "body: %O+%ui bytes",
f9d7930d0eed HTTP/3: skip empty request body buffers (ticket #2374). Roman Arutyunyan <arut@nginx.com> parents: 8958 diff changeset	1599 rb->received, st->length);
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1600
9027 f9d7930d0eed HTTP/3: skip empty request body buffers (ticket #2374). Roman Arutyunyan <arut@nginx.com> parents: 8958 diff changeset	1601 return NGX_HTTP_REQUEST_ENTITY_TOO_LARGE;
f9d7930d0eed HTTP/3: skip empty request body buffers (ticket #2374). Roman Arutyunyan <arut@nginx.com> parents: 8958 diff changeset	1602 }
f9d7930d0eed HTTP/3: skip empty request body buffers (ticket #2374). Roman Arutyunyan <arut@nginx.com> parents: 8958 diff changeset	1603
9251 3728a0ed243a HTTP/3: fixed handling of request body larger than Content-Length. Maxim Dounin <mdounin@mdounin.ru> parents: 9241 diff changeset	1604 if (r->headers_in.content_length_n != -1
3728a0ed243a HTTP/3: fixed handling of request body larger than Content-Length. Maxim Dounin <mdounin@mdounin.ru> parents: 9241 diff changeset	1605 && (uint64_t) (r->headers_in.content_length_n
3728a0ed243a HTTP/3: fixed handling of request body larger than Content-Length. Maxim Dounin <mdounin@mdounin.ru> parents: 9241 diff changeset	1606 - rb->received)
3728a0ed243a HTTP/3: fixed handling of request body larger than Content-Length. Maxim Dounin <mdounin@mdounin.ru> parents: 9241 diff changeset	1607 < st->length)
3728a0ed243a HTTP/3: fixed handling of request body larger than Content-Length. Maxim Dounin <mdounin@mdounin.ru> parents: 9241 diff changeset	1608 {
3728a0ed243a HTTP/3: fixed handling of request body larger than Content-Length. Maxim Dounin <mdounin@mdounin.ru> parents: 9241 diff changeset	1609 ngx_log_error(NGX_LOG_INFO, r->connection->log, 0,
3728a0ed243a HTTP/3: fixed handling of request body larger than Content-Length. Maxim Dounin <mdounin@mdounin.ru> parents: 9241 diff changeset	1610 "client intended to send body data "
3728a0ed243a HTTP/3: fixed handling of request body larger than Content-Length. Maxim Dounin <mdounin@mdounin.ru> parents: 9241 diff changeset	1611 "larger than declared");
3728a0ed243a HTTP/3: fixed handling of request body larger than Content-Length. Maxim Dounin <mdounin@mdounin.ru> parents: 9241 diff changeset	1612
3728a0ed243a HTTP/3: fixed handling of request body larger than Content-Length. Maxim Dounin <mdounin@mdounin.ru> parents: 9241 diff changeset	1613 return NGX_HTTP_BAD_REQUEST;
3728a0ed243a HTTP/3: fixed handling of request body larger than Content-Length. Maxim Dounin <mdounin@mdounin.ru> parents: 9241 diff changeset	1614 }
3728a0ed243a HTTP/3: fixed handling of request body larger than Content-Length. Maxim Dounin <mdounin@mdounin.ru> parents: 9241 diff changeset	1615
9027 f9d7930d0eed HTTP/3: skip empty request body buffers (ticket #2374). Roman Arutyunyan <arut@nginx.com> parents: 8958 diff changeset	1616 continue;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1617 }
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1618
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1619 if (b
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1620 && st->length <= 128
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1621 && (uint64_t) (cl->buf->last - cl->buf->pos) >= st->length)
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1622 {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1623 rb->received += st->length;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1624 r->request_length += st->length;
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1625 h3c->total_bytes += st->length;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1626 h3c->payload_bytes += st->length;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1627
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1628 if (st->length < 8) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1629
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1630 while (st->length) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1631 b->last++ = cl->buf->pos++;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1632 st->length--;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1633 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1634
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1635 } else {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1636 ngx_memmove(b->last, cl->buf->pos, st->length);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1637 b->last += st->length;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1638 cl->buf->pos += st->length;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1639 st->length = 0;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1640 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1641
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1642 continue;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1643 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1644
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1645 tl = ngx_chain_get_free_buf(r->pool, &rb->free);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1646 if (tl == NULL) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1647 return NGX_HTTP_INTERNAL_SERVER_ERROR;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1648 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1649
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1650 b = tl->buf;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1651
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1652 ngx_memzero(b, sizeof(ngx_buf_t));
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1653
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1654 b->temporary = 1;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1655 b->tag = (ngx_buf_tag_t) &ngx_http_read_client_request_body;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1656 b->start = cl->buf->pos;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1657 b->pos = cl->buf->pos;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1658 b->last = cl->buf->last;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1659 b->end = cl->buf->end;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1660 b->flush = r->request_body_no_buffering;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1661
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1662 *ll = tl;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1663 ll = &tl->next;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1664
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1665 size = cl->buf->last - cl->buf->pos;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1666
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1667 if (size > st->length) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1668 cl->buf->pos += (size_t) st->length;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1669 rb->received += st->length;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1670 r->request_length += st->length;
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1671 h3c->total_bytes += st->length;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1672 h3c->payload_bytes += st->length;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1673 st->length = 0;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1674
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1675 } else {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1676 st->length -= size;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1677 rb->received += size;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1678 r->request_length += size;
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1679 h3c->total_bytes += size;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1680 h3c->payload_bytes += size;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1681 cl->buf->pos = cl->buf->last;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1682 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1683
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1684 b->last = cl->buf->pos;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1685 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1686 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1687
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1688 done:
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1689
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1690 if (last) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1691
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1692 if (st->length > 0) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1693 ngx_log_error(NGX_LOG_INFO, r->connection->log, 0,
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1694 "client prematurely closed stream");
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1695 r->connection->error = 1;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1696 return NGX_HTTP_BAD_REQUEST;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1697 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1698
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1699 if (r->headers_in.content_length_n == -1) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1700 r->headers_in.content_length_n = rb->received;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1701
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1702 } else if (r->headers_in.content_length_n != rb->received) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1703 ngx_log_error(NGX_LOG_INFO, r->connection->log, 0,
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1704 "client sent less body data than expected: "
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1705 "%O out of %O bytes of request body received",
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1706 rb->received, r->headers_in.content_length_n);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1707 return NGX_HTTP_BAD_REQUEST;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1708 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1709
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1710 rb->rest = 0;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1711
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1712 tl = ngx_chain_get_free_buf(r->pool, &rb->free);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1713 if (tl == NULL) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1714 return NGX_HTTP_INTERNAL_SERVER_ERROR;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1715 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1716
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1717 b = tl->buf;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1718
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1719 ngx_memzero(b, sizeof(ngx_buf_t));
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1720
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1721 b->last_buf = 1;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1722
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1723 *ll = tl;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1724
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1725 } else {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1726
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1727 /* set rb->rest, amount of data we want to see next time */
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1728
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1729 cscf = ngx_http_get_module_srv_conf(r, ngx_http_core_module);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1730
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1731 rb->rest = (off_t) cscf->large_client_header_buffers.size;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1732 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1733
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1734 rc = ngx_http_top_request_body_filter(r, out);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1735
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1736 ngx_chain_update_chains(r->pool, &rb->free, &rb->busy, &out,
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1737 (ngx_buf_tag_t) &ngx_http_read_client_request_body);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1738
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1739 return rc;
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1740 }

Mercurial > hg > nginx

annotate src/http/v3/ngx_http_v3_request.c @ 9286:d9fe808c1841