nginx: src/http/v3/ngx_http_v3

annotate src/http/v3/ngx_http_v3_request.c @ 8924:d6ef13c5fd8e quic

QUIC: simplified configuration. Directives that set transport parameters are removed from the configuration. Corresponding values are derived from the quic configuration or initialized to default. Whenever possible, quic configuration parameters are taken from higher-level protocol settings, i.e. HTTP/3.

author	Vladimir Homutov <vl@nginx.com>
date	Mon, 06 Dec 2021 15:19:54 +0300
parents	be08b858086a
children	e4952530e6af

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
8922 be08b858086a HTTP/3: http3_hq directive and NGX_HTTP_V3_HQ macro. Roman Arutyunyan <arut@nginx.com> parents: 8921 diff changeset	13 #if (NGX_HTTP_V3_HQ)
8921 33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	14 static void ngx_http_v3_init_hq_stream(ngx_connection_t *c);
8922 be08b858086a HTTP/3: http3_hq directive and NGX_HTTP_V3_HQ macro. Roman Arutyunyan <arut@nginx.com> parents: 8921 diff changeset	15 #endif
8921 33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	16 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	17 static void ngx_http_v3_wait_request_handler(ngx_event_t *rev);
8725 98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	18 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	19 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	20 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	21 ngx_str_t name, ngx_str_t value);
8682 916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	22 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	23 ngx_str_t name, ngx_str_t value);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	24 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	25 ngx_str_t name, ngx_str_t value);
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	26 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	27 static ngx_int_t ngx_http_v3_process_request_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
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	59 ngx_http_v3_init(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);
8922 be08b858086a HTTP/3: http3_hq directive and NGX_HTTP_V3_HQ macro. Roman Arutyunyan <arut@nginx.com> parents: 8921 diff changeset	70 h3scf = ngx_http_get_module_srv_conf(hc->conf_ctx, 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	71
8922 be08b858086a HTTP/3: http3_hq directive and NGX_HTTP_V3_HQ macro. Roman Arutyunyan <arut@nginx.com> parents: 8921 diff changeset	72 if (c->quic == NULL) {
8924 d6ef13c5fd8e QUIC: simplified configuration. Vladimir Homutov <vl@nginx.com> parents: 8922 diff changeset	73 h3scf->quic.timeout = clcf->keepalive_timeout;
8921 33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	74 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	75 return;
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	76 }
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 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	79
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	80 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	81 hc->ssl_servername = 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->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	83
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	84 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	85 }
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	86
8922 be08b858086a HTTP/3: http3_hq directive and NGX_HTTP_V3_HQ macro. Roman Arutyunyan <arut@nginx.com> parents: 8921 diff changeset	87 #if (NGX_HTTP_V3_HQ)
be08b858086a HTTP/3: http3_hq directive and NGX_HTTP_V3_HQ macro. Roman Arutyunyan <arut@nginx.com> parents: 8921 diff changeset	88 if (h3scf->hq) {
8921 33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	89 ngx_http_v3_init_hq_stream(c);
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	90 return;
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	91 }
8922 be08b858086a HTTP/3: http3_hq directive and NGX_HTTP_V3_HQ macro. Roman Arutyunyan <arut@nginx.com> parents: 8921 diff changeset	92 #endif
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	93
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	94 if (ngx_http_v3_init_session(c) != NGX_OK) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	95 ngx_http_close_connection(c);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	96 return;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	97 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	98
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	99 if (c->quic->id & NGX_QUIC_STREAM_UNIDIRECTIONAL) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	100 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	101
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	102 } else {
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	103 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	104 }
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	105 }
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	106
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	107
8922 be08b858086a HTTP/3: http3_hq directive and NGX_HTTP_V3_HQ macro. Roman Arutyunyan <arut@nginx.com> parents: 8921 diff changeset	108 #if (NGX_HTTP_V3_HQ)
be08b858086a HTTP/3: http3_hq directive and NGX_HTTP_V3_HQ macro. Roman Arutyunyan <arut@nginx.com> parents: 8921 diff changeset	109
8921 33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	110 static void
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	111 ngx_http_v3_init_hq_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	112 {
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	113 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	114 ngx_event_t *rev;
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	115 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	116 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	117 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	118
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	119 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 init hq stream");
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	120
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	121 #if (NGX_STAT_STUB)
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	122 (void) ngx_atomic_fetch_add(ngx_stat_active, 1);
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	123 #endif
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	124
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	125 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	126
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	127 /* Use HTTP/3 General Protocol Error Code 0x101 for finalization */
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	128
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	129 if (c->quic->id & NGX_QUIC_STREAM_UNIDIRECTIONAL) {
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	130 ngx_quic_finalize_connection(c->quic->parent,
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	131 NGX_HTTP_V3_ERR_GENERAL_PROTOCOL_ERROR,
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	132 "unexpected uni stream");
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	133 ngx_http_close_connection(c);
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	134 return;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	135 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	136
8921 33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	137 clcf = ngx_http_get_module_loc_conf(hc->conf_ctx, ngx_http_core_module);
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	138
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	139 n = c->quic->id >> 2;
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	140
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	141 if (n >= clcf->keepalive_requests) {
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	142 ngx_quic_finalize_connection(c->quic->parent,
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	143 NGX_HTTP_V3_ERR_GENERAL_PROTOCOL_ERROR,
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	144 "reached maximum number of requests");
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	145 ngx_http_close_connection(c);
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	146 return;
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	147 }
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	148
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	149 if (ngx_current_msec - c->quic->parent->start_time
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	150 > clcf->keepalive_time)
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	151 {
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	152 ngx_quic_finalize_connection(c->quic->parent,
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	153 NGX_HTTP_V3_ERR_GENERAL_PROTOCOL_ERROR,
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	154 "reached maximum time for requests");
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	155 ngx_http_close_connection(c);
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	156 return;
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	157 }
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	158
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	159 rev = c->read;
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	160
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	161 if (rev->ready) {
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	162 rev->handler(rev);
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	163 return;
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	164 }
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	165
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	166 cscf = ngx_http_get_module_srv_conf(hc->conf_ctx, ngx_http_core_module);
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	167
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	168 ngx_add_timer(rev, cscf->client_header_timeout);
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	169 ngx_reusable_connection(c, 1);
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	170
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	171 if (ngx_handle_read_event(rev, 0) != NGX_OK) {
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	172 ngx_http_close_connection(c);
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	173 return;
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	174 }
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	175 }
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	176
8922 be08b858086a HTTP/3: http3_hq directive and NGX_HTTP_V3_HQ macro. Roman Arutyunyan <arut@nginx.com> parents: 8921 diff changeset	177 #endif
be08b858086a HTTP/3: http3_hq directive and NGX_HTTP_V3_HQ macro. Roman Arutyunyan <arut@nginx.com> parents: 8921 diff changeset	178
8921 33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	179
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	180 static void
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	181 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	182 {
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	183 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	184 ngx_event_t *rev;
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	185 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	186 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	187 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	188 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	189
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	190 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	191
8863 33578b8d453d HTTP/3: fixed ngx_stat_active counter. Roman Arutyunyan <arut@nginx.com> parents: 8854 diff changeset	192 #if (NGX_STAT_STUB)
33578b8d453d HTTP/3: fixed ngx_stat_active counter. Roman Arutyunyan <arut@nginx.com> parents: 8854 diff changeset	193 (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	194 #endif
33578b8d453d HTTP/3: fixed ngx_stat_active counter. Roman Arutyunyan <arut@nginx.com> parents: 8854 diff changeset	195
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	196 hc = c->data;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	197
8723 265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8707 diff changeset	198 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	199
8826 c35b255d80dc HTTP/3: close connection on keepalive_requests * 2. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	200 n = c->quic->id >> 2;
c35b255d80dc HTTP/3: close connection on keepalive_requests * 2. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	201
c35b255d80dc HTTP/3: close connection on keepalive_requests * 2. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	202 if (n >= clcf->keepalive_requests * 2) {
c35b255d80dc HTTP/3: close connection on keepalive_requests * 2. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	203 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	204 "too many requests per connection");
c35b255d80dc HTTP/3: close connection on keepalive_requests * 2. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	205 ngx_http_close_connection(c);
c35b255d80dc HTTP/3: close connection on keepalive_requests * 2. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	206 return;
c35b255d80dc HTTP/3: close connection on keepalive_requests * 2. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	207 }
c35b255d80dc HTTP/3: close connection on keepalive_requests * 2. Roman Arutyunyan <arut@nginx.com> parents: 8807 diff changeset	208
8768 40d710a66aef HTTP/3: ngx_http_v3_get_session() macro. Roman Arutyunyan <arut@nginx.com> parents: 8742 diff changeset	209 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	210
8742 47a43b011dec HTTP/3: keepalive_time support. Sergey Kandaurov <pluknet@nginx.com> parents: 8727 diff changeset	211 if (h3c->goaway) {
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	212 c->close = 1;
8723 265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8707 diff changeset	213 ngx_http_close_connection(c);
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8707 diff changeset	214 return;
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8707 diff changeset	215 }
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8707 diff changeset	216
8742 47a43b011dec HTTP/3: keepalive_time support. Sergey Kandaurov <pluknet@nginx.com> parents: 8727 diff changeset	217 if (n + 1 == clcf->keepalive_requests
47a43b011dec HTTP/3: keepalive_time support. Sergey Kandaurov <pluknet@nginx.com> parents: 8727 diff changeset	218 \|\| ngx_current_msec - c->quic->parent->start_time
47a43b011dec HTTP/3: keepalive_time support. Sergey Kandaurov <pluknet@nginx.com> parents: 8727 diff changeset	219 > clcf->keepalive_time)
47a43b011dec HTTP/3: keepalive_time support. Sergey Kandaurov <pluknet@nginx.com> parents: 8727 diff changeset	220 {
47a43b011dec HTTP/3: keepalive_time support. Sergey Kandaurov <pluknet@nginx.com> parents: 8727 diff changeset	221 h3c->goaway = 1;
47a43b011dec HTTP/3: keepalive_time support. Sergey Kandaurov <pluknet@nginx.com> parents: 8727 diff changeset	222
8723 265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8707 diff changeset	223 if (ngx_http_v3_send_goaway(c, (n + 1) << 2) != NGX_OK) {
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8707 diff changeset	224 ngx_http_close_connection(c);
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8707 diff changeset	225 return;
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8707 diff changeset	226 }
8724 fc64ab301bad QUIC: connection shutdown. Roman Arutyunyan <arut@nginx.com> parents: 8723 diff changeset	227
fc64ab301bad QUIC: connection shutdown. Roman Arutyunyan <arut@nginx.com> parents: 8723 diff changeset	228 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	229 "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	230 }
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8707 diff changeset	231
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	232 rev = c->read;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	233 rev->handler = ngx_http_v3_wait_request_handler;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	234 c->write->handler = ngx_http_empty_handler;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	235
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	236 if (rev->ready) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	237 rev->handler(rev);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	238 return;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	239 }
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	240
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	241 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	242
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	243 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	244 ngx_reusable_connection(c, 1);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	245
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	246 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	247 ngx_http_close_connection(c);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	248 return;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	249 }
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
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	253 static void
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	254 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	255 {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	256 size_t size;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	257 ssize_t n;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	258 ngx_buf_t *b;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	259 ngx_connection_t *c;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	260 ngx_pool_cleanup_t *cln;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	261 ngx_http_request_t *r;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	262 ngx_http_connection_t *hc;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	263 ngx_http_v3_session_t *h3c;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	264 ngx_http_core_srv_conf_t *cscf;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	265
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	266 c = rev->data;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	267
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	268 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	269
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	270 if (rev->timedout) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	271 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	272 c->timedout = 1;
8725 98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	273 ngx_http_close_connection(c);
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	274 return;
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	275 }
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	276
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	277 if (c->close) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	278 ngx_http_close_connection(c);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	279 return;
8725 98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	280 }
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	281
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	282 hc = c->data;
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	283 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	284
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	285 size = cscf->client_header_buffer_size;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	286
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	287 b = c->buffer;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	288
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	289 if (b == NULL) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	290 b = ngx_create_temp_buf(c->pool, size);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	291 if (b == NULL) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	292 ngx_http_close_connection(c);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	293 return;
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
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	296 c->buffer = b;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	297
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	298 } else if (b->start == NULL) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	299
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	300 b->start = ngx_palloc(c->pool, size);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	301 if (b->start == 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 b->pos = b->start;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	307 b->last = b->start;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	308 b->end = b->last + size;
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
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	311 n = c->recv(c, b->last, size);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	312
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	313 if (n == NGX_AGAIN) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	314
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	315 if (!rev->timer_set) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	316 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	317 ngx_reusable_connection(c, 1);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	318 }
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	319
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	320 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	321 ngx_http_close_connection(c);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	322 return;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	323 }
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 /*
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	326 * 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	327 */
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 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	330 b->start = NULL;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	331 }
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	332
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	333 return;
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 if (n == NGX_ERROR) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	337 ngx_http_close_connection(c);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	338 return;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	339 }
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	340
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	341 if (n == 0) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	342 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	343 "client closed connection");
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	344 ngx_http_close_connection(c);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	345 return;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	346 }
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	347
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	348 b->last += n;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	349
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	350 c->log->action = "reading client request";
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	351
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	352 ngx_reusable_connection(c, 0);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	353
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	354 r = ngx_http_create_request(c);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	355 if (r == NULL) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	356 ngx_http_close_connection(c);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	357 return;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	358 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	359
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	360 r->http_version = NGX_HTTP_VERSION_30;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	361
8706 3057bae4dba7 HTTP/3: introduced ngx_http_v3_parse_t structure. Roman Arutyunyan <arut@nginx.com> parents: 8690 diff changeset	362 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	363 if (r->v3_parse == NULL) {
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	364 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	365 return;
3057bae4dba7 HTTP/3: introduced ngx_http_v3_parse_t structure. Roman Arutyunyan <arut@nginx.com> parents: 8690 diff changeset	366 }
3057bae4dba7 HTTP/3: introduced ngx_http_v3_parse_t structure. Roman Arutyunyan <arut@nginx.com> parents: 8690 diff changeset	367
8707 ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	368 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	369 * cscf->large_client_header_buffers.num;
ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	370
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	371 c->data = r;
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	372 c->requests = (c->quic->id >> 2) + 1;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	373
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	374 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	375 if (cln == NULL) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	376 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	377 return;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	378 }
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	379
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	380 cln->handler = ngx_http_v3_cleanup_request;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	381 cln->data = r;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	382
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	383 h3c = ngx_http_v3_get_session(c);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	384 h3c->nrequests++;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	385
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	386 if (h3c->keepalive.timer_set) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	387 ngx_del_timer(&h3c->keepalive);
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	388 }
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	389
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	390 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	391 ngx_http_v3_process_request(rev);
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
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	394
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	395 void
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	396 ngx_http_v3_reset_connection(ngx_connection_t *c)
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	397 {
8904 d2c193aa8480 HTTP/3: send Stream Cancellation instruction. Roman Arutyunyan <arut@nginx.com> parents: 8903 diff changeset	398 ngx_http_v3_srv_conf_t *h3scf;
d2c193aa8480 HTTP/3: send Stream Cancellation instruction. Roman Arutyunyan <arut@nginx.com> parents: 8903 diff changeset	399
8922 be08b858086a HTTP/3: http3_hq directive and NGX_HTTP_V3_HQ macro. Roman Arutyunyan <arut@nginx.com> parents: 8921 diff changeset	400 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	401
8922 be08b858086a HTTP/3: http3_hq directive and NGX_HTTP_V3_HQ macro. Roman Arutyunyan <arut@nginx.com> parents: 8921 diff changeset	402 #if (NGX_HTTP_V3_HQ)
be08b858086a HTTP/3: http3_hq directive and NGX_HTTP_V3_HQ macro. Roman Arutyunyan <arut@nginx.com> parents: 8921 diff changeset	403 if (h3scf->hq) {
8921 33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 diff changeset	404 return;
33226ac61076 HTTP/3: merged ngx_http_quic_module into ngx_http_v3_module. Roman Arutyunyan <arut@nginx.com> parents: 8904 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 #endif
8904 d2c193aa8480 HTTP/3: send Stream Cancellation instruction. Roman Arutyunyan <arut@nginx.com> parents: 8903 diff changeset	407
d2c193aa8480 HTTP/3: send Stream Cancellation instruction. Roman Arutyunyan <arut@nginx.com> parents: 8903 diff changeset	408 if (h3scf->max_table_capacity > 0 && !c->read->eof) {
d2c193aa8480 HTTP/3: send Stream Cancellation instruction. Roman Arutyunyan <arut@nginx.com> parents: 8903 diff changeset	409 (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	410 }
d2c193aa8480 HTTP/3: send Stream Cancellation instruction. Roman Arutyunyan <arut@nginx.com> parents: 8903 diff changeset	411
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	412 if (c->timedout) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	413 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	414
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	415 } else if (c->close) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	416 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	417
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	418 } else if (c->requests == 0 \|\| c->error) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	419 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	420 }
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	421 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	422
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	423
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	424 static void
8725 98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	425 ngx_http_v3_cleanup_request(void *data)
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	426 {
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	427 ngx_http_request_t *r = data;
8725 98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	428
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	429 ngx_connection_t *c;
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	430 ngx_http_v3_session_t *h3c;
8725 98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	431 ngx_http_core_loc_conf_t *clcf;
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	432
8903 0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	433 c = r->connection;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	434
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	435 if (!r->response_sent) {
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	436 c->error = 1;
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	437 }
0d3bf08eaac0 HTTP/3: allowed QUIC stream connection reuse. Roman Arutyunyan <arut@nginx.com> parents: 8902 diff changeset	438
8768 40d710a66aef HTTP/3: ngx_http_v3_get_session() macro. Roman Arutyunyan <arut@nginx.com> parents: 8742 diff changeset	439 h3c = ngx_http_v3_get_session(c);
8725 98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	440
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	441 if (--h3c->nrequests == 0) {
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	442 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	443 ngx_add_timer(&h3c->keepalive, clcf->keepalive_timeout);
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 }
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	446
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	447
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8724 diff changeset	448 static void
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	449 ngx_http_v3_process_request(ngx_event_t *rev)
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	450 {
8838 d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8835 diff changeset	451 u_char *p;
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	452 ssize_t n;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	453 ngx_buf_t *b;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	454 ngx_int_t rc;
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	455 ngx_connection_t *c;
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	456 ngx_http_request_t *r;
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	457 ngx_http_v3_session_t *h3c;
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	458 ngx_http_core_srv_conf_t *cscf;
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	459 ngx_http_v3_parse_headers_t *st;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	460
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	461 c = rev->data;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	462 r = c->data;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	463
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	464 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	465
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	466 if (rev->timedout) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	467 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	468 c->timedout = 1;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	469 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	470 return;
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
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	473 h3c = ngx_http_v3_get_session(c);
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	474
8706 3057bae4dba7 HTTP/3: introduced ngx_http_v3_parse_t structure. Roman Arutyunyan <arut@nginx.com> parents: 8690 diff changeset	475 st = &r->v3_parse->headers;
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	476
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	477 b = r->header_in;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	478
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	479 for ( ;; ) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	480
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	481 if (b->pos == b->last) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	482
8685 dbe33ef9cd9a HTTP/3: call ngx_handle_read_event() from client header handler. Roman Arutyunyan <arut@nginx.com> parents: 8682 diff changeset	483 if (rev->ready) {
dbe33ef9cd9a HTTP/3: call ngx_handle_read_event() from client header handler. Roman Arutyunyan <arut@nginx.com> parents: 8682 diff changeset	484 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	485
dbe33ef9cd9a HTTP/3: call ngx_handle_read_event() from client header handler. Roman Arutyunyan <arut@nginx.com> parents: 8682 diff changeset	486 } else {
dbe33ef9cd9a HTTP/3: call ngx_handle_read_event() from client header handler. Roman Arutyunyan <arut@nginx.com> parents: 8682 diff changeset	487 n = NGX_AGAIN;
8679 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
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	490 if (n == NGX_AGAIN) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	491 if (!rev->timer_set) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	492 cscf = ngx_http_get_module_srv_conf(r,
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	493 ngx_http_core_module);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	494 ngx_add_timer(rev, cscf->client_header_timeout);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	495 }
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 if (ngx_handle_read_event(rev, 0) != NGX_OK) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	498 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	499 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	500
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	501 break;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	502 }
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 if (n == 0) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	505 ngx_log_error(NGX_LOG_INFO, c->log, 0,
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	506 "client prematurely closed connection");
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 if (n == 0 \|\| n == NGX_ERROR) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	510 c->error = 1;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	511 c->log->action = "reading client request";
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	512
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	513 ngx_http_finalize_request(r, NGX_HTTP_BAD_REQUEST);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	514 break;
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 b->pos = b->start;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	518 b->last = b->start + n;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	519 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	520
8838 d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8835 diff changeset	521 p = b->pos;
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8835 diff changeset	522
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8835 diff changeset	523 rc = ngx_http_v3_parse_headers(c, st, b);
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	524
8460 72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	525 if (rc > 0) {
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	526 ngx_quic_reset_stream(c, rc);
925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	527 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	528 "client sent invalid header");
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	529 ngx_http_finalize_request(r, NGX_HTTP_BAD_REQUEST);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	530 break;
8460 72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	531 }
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	532
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	533 if (rc == NGX_ERROR) {
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	534 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	535 break;
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	536 }
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	537
8880 a09bcc304eef HTTP/3: fixed request length calculation. Roman Arutyunyan <arut@nginx.com> parents: 8863 diff changeset	538 r->request_length += b->pos - p;
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	539 h3c->total_bytes += b->pos - p;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	540
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	541 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	542 ngx_http_close_request(r, NGX_HTTP_CLOSE);
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	543 break;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	544 }
8880 a09bcc304eef HTTP/3: fixed request length calculation. Roman Arutyunyan <arut@nginx.com> parents: 8863 diff changeset	545
8456 c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8452 diff changeset	546 if (rc == NGX_BUSY) {
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	547 if (rev->error) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	548 ngx_http_close_request(r, NGX_HTTP_CLOSE);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	549 break;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	550 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	551
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	552 if (ngx_handle_read_event(rev, 0) != NGX_OK) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	553 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	554 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	555
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	556 break;
8456 c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8452 diff changeset	557 }
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 8452 diff changeset	558
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	559 if (rc == NGX_AGAIN) {
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	560 continue;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	561 }
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	562
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	563 /* rc == NGX_OK \|\| rc == NGX_DONE */
8233 1e45c02f6376 HTTP/3 $request_line variable. Roman Arutyunyan <arut@nginx.com> parents: 8230 diff changeset	564
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	565 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	566 &st->field_rep.field.name,
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	567 &st->field_rep.field.value);
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	568
8807 0ac25efb2da3 HTTP/3: quic-qpack term updates. Sergey Kandaurov <pluknet@nginx.com> parents: 8770 diff changeset	569 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	570 &st->field_rep.field.value)
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	571 != NGX_OK)
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	572 {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	573 break;
8405 d2759e4cc437 HTTP/3: split header parser in two functions. Roman Arutyunyan <arut@nginx.com> parents: 8394 diff changeset	574 }
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	575
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	576 if (rc == NGX_DONE) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	577 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	578 break;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	579 }
8405 d2759e4cc437 HTTP/3: split header parser in two functions. Roman Arutyunyan <arut@nginx.com> parents: 8394 diff changeset	580
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	581 ngx_http_process_request(r);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	582 break;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	583 }
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	584 }
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	585
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	586 ngx_http_run_posted_requests(c);
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	587
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	588 return;
8405 d2759e4cc437 HTTP/3: split header parser in two functions. Roman Arutyunyan <arut@nginx.com> parents: 8394 diff changeset	589 }
d2759e4cc437 HTTP/3: split header parser in two functions. Roman Arutyunyan <arut@nginx.com> parents: 8394 diff changeset	590
d2759e4cc437 HTTP/3: split header parser in two functions. Roman Arutyunyan <arut@nginx.com> parents: 8394 diff changeset	591
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	592 static ngx_int_t
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	593 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	594 ngx_str_t *value)
8405 d2759e4cc437 HTTP/3: split header parser in two functions. Roman Arutyunyan <arut@nginx.com> parents: 8394 diff changeset	595 {
8707 ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	596 size_t len;
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	597 ngx_table_elt_t *h;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	598 ngx_http_header_t *hh;
8682 916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	599 ngx_http_core_srv_conf_t *cscf;
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	600 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	601
8707 ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	602 len = name->len + value->len;
ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	603
ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	604 if (len > r->v3_parse->header_limit) {
ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	605 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	606 "client sent too large header");
ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	607 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	608 return NGX_ERROR;
ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	609 }
ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	610
ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	611 r->v3_parse->header_limit -= len;
ffcaf0aad9f2 HTTP/3: limited client header size. Roman Arutyunyan <arut@nginx.com> parents: 8706 diff changeset	612
8682 916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	613 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	614 ngx_http_finalize_request(r, NGX_HTTP_BAD_REQUEST);
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	615 return NGX_ERROR;
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	616 }
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	617
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	618 if (r->invalid_header) {
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	619 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	620
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	621 if (cscf->ignore_invalid_headers) {
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	622 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	623 "client sent invalid header: \"%V\"", name);
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	624
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	625 return NGX_OK;
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	626 }
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	627 }
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	628
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	629 if (name->len && name->data[0] == ':') {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	630 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	631 }
8452 a6675a976560 HTTP/3: fixed dropping first non-pseudo header. Roman Arutyunyan <arut@nginx.com> parents: 8451 diff changeset	632
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	633 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	634 return NGX_ERROR;
8405 d2759e4cc437 HTTP/3: split header parser in two functions. Roman Arutyunyan <arut@nginx.com> parents: 8394 diff changeset	635 }
d2759e4cc437 HTTP/3: split header parser in two functions. Roman Arutyunyan <arut@nginx.com> parents: 8394 diff changeset	636
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	637 h = ngx_list_push(&r->headers_in.headers);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	638 if (h == NULL) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	639 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	640 return NGX_ERROR;
8405 d2759e4cc437 HTTP/3: split header parser in two functions. Roman Arutyunyan <arut@nginx.com> parents: 8394 diff changeset	641 }
d2759e4cc437 HTTP/3: split header parser in two functions. Roman Arutyunyan <arut@nginx.com> parents: 8394 diff changeset	642
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	643 h->key = *name;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	644 h->value = *value;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	645 h->lowcase_key = h->key.data;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	646 h->hash = ngx_hash_key(h->key.data, h->key.len);
8406 66feab03d9b7 HTTP/3: restricted symbols in header names. Roman Arutyunyan <arut@nginx.com> parents: 8405 diff changeset	647
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	648 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	649
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	650 hh = ngx_hash_find(&cmcf->headers_in_hash, h->hash,
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	651 h->lowcase_key, h->key.len);
8406 66feab03d9b7 HTTP/3: restricted symbols in header names. Roman Arutyunyan <arut@nginx.com> parents: 8405 diff changeset	652
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	653 if (hh && hh->handler(r, h, hh->offset) != NGX_OK) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	654 return NGX_ERROR;
8406 66feab03d9b7 HTTP/3: restricted symbols in header names. Roman Arutyunyan <arut@nginx.com> parents: 8405 diff changeset	655 }
66feab03d9b7 HTTP/3: restricted symbols in header names. Roman Arutyunyan <arut@nginx.com> parents: 8405 diff changeset	656
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	657 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	658 "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	659 return NGX_OK;
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	660 }
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	661
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	662
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	663 static ngx_int_t
8682 916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	664 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	665 ngx_str_t *value)
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	666 {
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	667 u_char ch;
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	668 ngx_uint_t i;
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	669 ngx_http_core_srv_conf_t *cscf;
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	670
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	671 r->invalid_header = 0;
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	672
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	673 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	674
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	675 for (i = (name->data[0] == ':'); i != name->len; i++) {
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	676 ch = name->data[i];
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	677
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	678 if ((ch >= 'a' && ch <= 'z')
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	679 \|\| (ch == '-')
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	680 \|\| (ch >= '0' && ch <= '9')
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	681 \|\| (ch == '_' && cscf->underscores_in_headers))
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	682 {
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	683 continue;
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	684 }
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	685
8832 0d35b1ff6af5 HTTP/3: disabled control characters and space in header names. Sergey Kandaurov <pluknet@nginx.com> parents: 8826 diff changeset	686 if (ch <= 0x20 \|\| ch == 0x7f \|\| ch == ':'
8682 916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	687 \|\| (ch >= 'A' && ch <= 'Z'))
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	688 {
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	689 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	690 "client sent invalid header name: \"%V\"", name);
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	691
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	692 return NGX_ERROR;
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	693 }
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	694
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	695 r->invalid_header = 1;
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	696 }
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	697
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	698 for (i = 0; i != value->len; i++) {
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	699 ch = value->data[i];
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	700
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	701 if (ch == '\0' \|\| ch == LF \|\| ch == CR) {
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	702 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	703 "client sent header \"%V\" with "
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	704 "invalid value: \"%V\"", name, value);
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 return NGX_ERROR;
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 }
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 return NGX_OK;
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	711 }
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
916a2e1d6617 HTTP/3: client header validation. Roman Arutyunyan <arut@nginx.com> parents: 8680 diff changeset	714 static ngx_int_t
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	715 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	716 ngx_str_t *value)
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	717 {
8680 58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	718 u_char ch, c;
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	719 ngx_uint_t i;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	720
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	721 if (r->request_line.len) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	722 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	723 "client sent out of order pseudo-headers");
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	724 goto failed;
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	725 }
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	726
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	727 if (name->len == 7 && ngx_strncmp(name->data, ":method", 7) == 0) {
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	728
8680 58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	729 if (r->method_name.len) {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	730 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	731 "client sent duplicate \":method\" header");
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	732 goto failed;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	733 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	734
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	735 if (value->len == 0) {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	736 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	737 "client sent empty \":method\" header");
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	738 goto failed;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	739 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	740
8650 9dce2978e4fd HTTP/3: eliminated r->method_start. Roman Arutyunyan <arut@nginx.com> parents: 8630 diff changeset	741 r->method_name = *value;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	742
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	743 for (i = 0; i < sizeof(ngx_http_v3_methods)
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	744 / sizeof(ngx_http_v3_methods[0]); i++)
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	745 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	746 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	747 && ngx_strncmp(value->data,
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	748 ngx_http_v3_methods[i].name.data, value->len)
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	749 == 0)
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	750 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	751 r->method = ngx_http_v3_methods[i].method;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	752 break;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	753 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	754 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	755
8680 58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	756 for (i = 0; i < value->len; i++) {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	757 ch = value->data[i];
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	758
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	759 if ((ch < 'A' \|\| ch > 'Z') && ch != '_' && ch != '-') {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	760 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	761 "client sent invalid method: \"%V\"", value);
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	762 goto failed;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	763 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	764 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	765
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	766 ngx_log_debug2(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	767 "http3 method \"%V\" %ui", value, r->method);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	768 return NGX_OK;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	769 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	770
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	771 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	772
8680 58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	773 if (r->uri_start) {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	774 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	775 "client sent duplicate \":path\" header");
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	776 goto failed;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	777 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	778
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	779 if (value->len == 0) {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	780 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	781 "client sent empty \":path\" header");
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	782 goto failed;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	783 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	784
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	785 r->uri_start = value->data;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	786 r->uri_end = value->data + value->len;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	787
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	788 if (ngx_http_parse_uri(r) != NGX_OK) {
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	789 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	790 "client sent invalid \":path\" header: \"%V\"",
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	791 value);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	792 goto failed;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	793 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	794
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	795 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	796 "http3 path \"%V\"", value);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	797 return NGX_OK;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	798 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	799
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	800 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	801
8680 58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	802 if (r->schema.len) {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	803 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	804 "client sent duplicate \":scheme\" header");
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	805 goto failed;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	806 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	807
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	808 if (value->len == 0) {
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 empty \":scheme\" 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 for (i = 0; i < value->len; i++) {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	815 ch = value->data[i];
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	816
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	817 c = (u_char) (ch \| 0x20);
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	818 if (c >= 'a' && c <= 'z') {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	819 continue;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	820 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	821
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	822 if (((ch >= '0' && ch <= '9')
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	823 \|\| ch == '+' \|\| ch == '-' \|\| ch == '.')
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	824 && i > 0)
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	825 {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	826 continue;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	827 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	828
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	829 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	830 "client sent invalid \":scheme\" header: \"%V\"",
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	831 value);
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	832 goto failed;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	833 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	834
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	835 r->schema = *value;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	836
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	837 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	838 "http3 schema \"%V\"", value);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	839 return NGX_OK;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	840 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	841
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	842 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	843
8680 58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	844 if (r->host_start) {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	845 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	846 "client sent duplicate \":authority\" header");
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	847 goto failed;
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
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	850 r->host_start = value->data;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	851 r->host_end = value->data + value->len;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	852
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	853 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	854 "http3 authority \"%V\"", value);
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	855 return NGX_OK;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	856 }
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	857
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	858 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	859 "client sent unknown pseudo-header \"%V\"", name);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	860
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	861 failed:
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	862
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	863 ngx_http_finalize_request(r, NGX_HTTP_BAD_REQUEST);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	864 return NGX_ERROR;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	865 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	866
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	867
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	868 static ngx_int_t
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	869 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	870 {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	871 size_t len;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	872 u_char *p;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	873 ngx_int_t rc;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	874 ngx_str_t host;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	875
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	876 if (r->request_line.len) {
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	877 return NGX_OK;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	878 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	879
8680 58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	880 if (r->method_name.len == 0) {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	881 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	882 "client sent no \":method\" header");
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	883 goto failed;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	884 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	885
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	886 if (r->schema.len == 0) {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	887 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	888 "client sent no \":scheme\" header");
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	889 goto failed;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	890 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	891
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	892 if (r->uri_start == NULL) {
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	893 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	894 "client sent no \":path\" header");
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	895 goto failed;
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	896 }
58acdba9b3b2 HTTP/3: client pseudo-headers restrictions. Roman Arutyunyan <arut@nginx.com> parents: 8679 diff changeset	897
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	898 len = r->method_name.len + 1
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	899 + (r->uri_end - r->uri_start) + 1
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	900 + sizeof("HTTP/3.0") - 1;
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 p = ngx_pnalloc(r->pool, len);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	903 if (p == NULL) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	904 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	905 return NGX_ERROR;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	906 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	907
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	908 r->request_line.data = p;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	909
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	910 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	911 *p++ = ' ';
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	912 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	913 *p++ = ' ';
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	914 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	915
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	916 r->request_line.len = p - r->request_line.data;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	917
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	918 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	919 "http3 request line: \"%V\"", &r->request_line);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	920
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	921 ngx_str_set(&r->http_protocol, "HTTP/3.0");
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	922
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	923 if (ngx_http_process_request_uri(r) != NGX_OK) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	924 return NGX_ERROR;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	925 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	926
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	927 if (r->host_end) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	928
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	929 host.len = r->host_end - r->host_start;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	930 host.data = r->host_start;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	931
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	932 rc = ngx_http_validate_host(&host, r->pool, 0);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	933
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	934 if (rc == NGX_DECLINED) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	935 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	936 "client sent invalid host in request line");
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	937 goto failed;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	938 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	939
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	940 if (rc == NGX_ERROR) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	941 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	942 return NGX_ERROR;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	943 }
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 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	946 return NGX_ERROR;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	947 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	948
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	949 r->headers_in.server = host;
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
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	952 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	953 sizeof(ngx_table_elt_t))
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	954 != NGX_OK)
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_http_close_request(r, NGX_HTTP_INTERNAL_SERVER_ERROR);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	957 return NGX_ERROR;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	958 }
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	959
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8219 diff changeset	960 return NGX_OK;
8679 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 failed:
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 ngx_http_finalize_request(r, NGX_HTTP_BAD_REQUEST);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	965 return NGX_ERROR;
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
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 static ngx_int_t
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	970 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	971 {
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	972 ssize_t n;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	973 ngx_buf_t *b;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	974 ngx_connection_t *c;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	975
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	976 c = r->connection;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	977
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	978 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	979 return NGX_ERROR;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	980 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	981
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	982 if (r->headers_in.server.len == 0) {
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	983 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	984 "client sent neither \":authority\" nor \"Host\" header");
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	985 goto failed;
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
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	988 if (r->headers_in.host) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	989 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	990 \|\| ngx_memcmp(r->headers_in.host->value.data,
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	991 r->headers_in.server.data,
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	992 r->headers_in.server.len)
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	993 != 0)
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	994 {
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	995 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	996 "client sent \":authority\" and \"Host\" headers "
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	997 "with different values");
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	998 goto failed;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	999 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1000 }
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 if (r->headers_in.content_length) {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1003 r->headers_in.content_length_n =
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1004 ngx_atoof(r->headers_in.content_length->value.data,
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1005 r->headers_in.content_length->value.len);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1006
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1007 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	1008 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	1009 "client sent invalid \"Content-Length\" header");
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1010 goto failed;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1011 }
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 } else {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1014 b = r->header_in;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1015 n = b->last - b->pos;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1016
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1017 if (n == 0) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1018 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	1019
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1020 if (n == NGX_ERROR) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1021 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	1022 return NGX_ERROR;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1023 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1024
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1025 if (n > 0) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1026 b->pos = b->start;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1027 b->last = b->start + n;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1028 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1029 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1030
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1031 if (n != 0) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1032 r->headers_in.chunked = 1;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1033 }
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1034 }
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1035
8854 7416d3b2fac5 HTTP/3: added CONNECT and TRACE methods rejection. Sergey Kandaurov <pluknet@nginx.com> parents: 8847 diff changeset	1036 if (r->method == NGX_HTTP_CONNECT) {
7416d3b2fac5 HTTP/3: added CONNECT and TRACE methods rejection. Sergey Kandaurov <pluknet@nginx.com> parents: 8847 diff changeset	1037 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	1038 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	1039 return NGX_ERROR;
7416d3b2fac5 HTTP/3: added CONNECT and TRACE methods rejection. Sergey Kandaurov <pluknet@nginx.com> parents: 8847 diff changeset	1040 }
7416d3b2fac5 HTTP/3: added CONNECT and TRACE methods rejection. Sergey Kandaurov <pluknet@nginx.com> parents: 8847 diff changeset	1041
7416d3b2fac5 HTTP/3: added CONNECT and TRACE methods rejection. Sergey Kandaurov <pluknet@nginx.com> parents: 8847 diff changeset	1042 if (r->method == NGX_HTTP_TRACE) {
7416d3b2fac5 HTTP/3: added CONNECT and TRACE methods rejection. Sergey Kandaurov <pluknet@nginx.com> parents: 8847 diff changeset	1043 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	1044 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	1045 return NGX_ERROR;
7416d3b2fac5 HTTP/3: added CONNECT and TRACE methods rejection. Sergey Kandaurov <pluknet@nginx.com> parents: 8847 diff changeset	1046 }
7416d3b2fac5 HTTP/3: added CONNECT and TRACE methods rejection. Sergey Kandaurov <pluknet@nginx.com> parents: 8847 diff changeset	1047
8679 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1048 return NGX_OK;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1049
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1050 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 ngx_http_finalize_request(r, NGX_HTTP_BAD_REQUEST);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8665 diff changeset	1053 return NGX_ERROR;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	1054 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	1055
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	1056
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1057 ngx_int_t
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1058 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	1059 {
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1060 size_t preread;
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1061 ngx_int_t rc;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1062 ngx_chain_t *cl, out;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1063 ngx_http_request_body_t *rb;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1064 ngx_http_core_loc_conf_t *clcf;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1065
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1066 rb = r->request_body;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1067
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1068 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	1069
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1070 if (preread) {
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 /* 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	1073
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1074 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	1075 "http3 client request body preread %uz", preread);
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 out.buf = r->header_in;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1078 out.next = NULL;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1079 cl = &out;
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 } else {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1082 cl = NULL;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1083 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1084
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1085 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	1086 if (rc != NGX_OK) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1087 return rc;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1088 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1089
8847 e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1090 if (rb->rest == 0 && rb->last_saved) {
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1091 /* the whole request body was pre-read */
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1092 r->request_body_no_buffering = 0;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1093 rb->post_handler(r);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1094 return NGX_OK;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1095 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1096
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1097 if (rb->rest < 0) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1098 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	1099 "negative request body rest");
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1100 return NGX_HTTP_INTERNAL_SERVER_ERROR;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1101 }
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1102
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1103 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	1104
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1105 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	1106 if (rb->buf == NULL) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1107 return NGX_HTTP_INTERNAL_SERVER_ERROR;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1108 }
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1109
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1110 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	1111 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	1112
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1113 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	1114 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1115
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1116
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1117 static void
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1118 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	1119 {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1120 ngx_int_t rc;
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1121
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1122 if (r->connection->read->timedout) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1123 r->connection->timedout = 1;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1124 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	1125 return;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1126 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1127
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1128 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	1129
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1130 if (rc >= NGX_HTTP_SPECIAL_RESPONSE) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1131 ngx_http_finalize_request(r, rc);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1132 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1133 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1134
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1135
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1136 ngx_int_t
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1137 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	1138 {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1139 ngx_int_t rc;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1140
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1141 if (r->connection->read->timedout) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1142 r->connection->timedout = 1;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1143 return NGX_HTTP_REQUEST_TIME_OUT;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1144 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1145
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1146 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	1147
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1148 if (rc == NGX_OK) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1149 r->reading_body = 0;
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1150 }
5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1151
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1152 return rc;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1153 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1154
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1155
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1156 static ngx_int_t
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1157 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	1158 {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1159 off_t rest;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1160 size_t size;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1161 ssize_t n;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1162 ngx_int_t rc;
8847 e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1163 ngx_uint_t flush;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1164 ngx_chain_t out;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1165 ngx_connection_t *c;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1166 ngx_http_request_body_t *rb;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1167 ngx_http_core_loc_conf_t *clcf;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1168
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1169 c = r->connection;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1170 rb = r->request_body;
8847 e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1171 flush = 1;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1172
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1173 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	1174 "http3 read client request body");
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1175
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1176 for ( ;; ) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1177 for ( ;; ) {
8847 e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1178 if (rb->rest == 0) {
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1179 break;
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1180 }
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1181
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1182 if (rb->buf->last == rb->buf->end) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1183
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1184 /* update chains */
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1185
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1186 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	1187
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1188 if (rc != NGX_OK) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1189 return rc;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1190 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1191
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1192 if (rb->busy != NULL) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1193 if (r->request_body_no_buffering) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1194 if (c->read->timer_set) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1195 ngx_del_timer(c->read);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1196 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1197
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1198 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	1199 return NGX_HTTP_INTERNAL_SERVER_ERROR;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1200 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1201
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1202 return NGX_AGAIN;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1203 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1204
8847 e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1205 if (rb->filter_need_buffering) {
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1206 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	1207 ngx_http_core_module);
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1208 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	1209
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1210 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	1211 return NGX_HTTP_INTERNAL_SERVER_ERROR;
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1212 }
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1213
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1214 return NGX_AGAIN;
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1215 }
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1216
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1217 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	1218 "busy buffers after request body flush");
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1219
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1220 return NGX_HTTP_INTERNAL_SERVER_ERROR;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1221 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1222
8847 e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1223 flush = 0;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1224 rb->buf->pos = rb->buf->start;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1225 rb->buf->last = rb->buf->start;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1226 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1227
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1228 size = rb->buf->end - rb->buf->last;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1229 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	1230
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1231 if ((off_t) size > rest) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1232 size = (size_t) rest;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1233 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1234
8847 e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1235 if (size == 0) {
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1236 break;
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1237 }
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1238
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1239 n = c->recv(c, rb->buf->last, size);
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 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	1242 "http3 client request body recv %z", n);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1243
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1244 if (n == NGX_AGAIN) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1245 break;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1246 }
8460 72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 8456 diff changeset	1247
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1248 if (n == 0) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1249 rb->buf->last_buf = 1;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1250 }
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 if (n == NGX_ERROR) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1253 c->error = 1;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1254 return NGX_HTTP_BAD_REQUEST;
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
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1257 rb->buf->last += n;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1258
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1259 /* pass buffer to request body filter chain */
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1260
8847 e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1261 flush = 0;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1262 out.buf = rb->buf;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1263 out.next = NULL;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1264
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1265 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	1266
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1267 if (rc != NGX_OK) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1268 return rc;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1269 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1270
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1271 if (rb->rest == 0) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1272 break;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1273 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1274
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1275 if (rb->buf->last < rb->buf->end) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1276 break;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1277 }
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1278 }
5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1279
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1280 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	1281 "http3 client request body rest %O", rb->rest);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1282
8847 e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1283 if (flush) {
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1284 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	1285
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1286 if (rc != NGX_OK) {
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1287 return rc;
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1288 }
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1289 }
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1290
e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1291 if (rb->rest == 0 && rb->last_saved) {
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1292 break;
8549 d70a38acaea0 HTTP/3: skip unknown frames on request stream. Roman Arutyunyan <arut@nginx.com> parents: 8548 diff changeset	1293 }
d70a38acaea0 HTTP/3: skip unknown frames on request stream. Roman Arutyunyan <arut@nginx.com> parents: 8548 diff changeset	1294
8847 e29c1ede905f HTTP/3: reading body buffering in filters. Roman Arutyunyan <arut@nginx.com> parents: 8838 diff changeset	1295 if (!c->read->ready \|\| rb->rest == 0) {
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1296
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1297 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	1298 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	1299
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1300 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	1301 return NGX_HTTP_INTERNAL_SERVER_ERROR;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1302 }
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 return NGX_AGAIN;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1305 }
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1306 }
5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1307
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1308 if (c->read->timer_set) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1309 ngx_del_timer(c->read);
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1310 }
5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1311
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1312 if (!r->request_body_no_buffering) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1313 r->read_event_handler = ngx_http_block_reading;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1314 rb->post_handler(r);
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1315 }
5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1316
8548 9ffef6054abf HTTP/3: fixed handling request body eof. Roman Arutyunyan <arut@nginx.com> parents: 8511 diff changeset	1317 return NGX_OK;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1318 }
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1319
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1320
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1321 static ngx_int_t
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1322 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	1323 {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1324 off_t max;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1325 size_t size;
8838 d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8835 diff changeset	1326 u_char *p;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1327 ngx_int_t rc;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1328 ngx_buf_t *b;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1329 ngx_uint_t last;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1330 ngx_chain_t cl, out, tl, *ll;
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1331 ngx_http_v3_session_t *h3c;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1332 ngx_http_request_body_t *rb;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1333 ngx_http_core_loc_conf_t *clcf;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1334 ngx_http_core_srv_conf_t *cscf;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1335 ngx_http_v3_parse_data_t *st;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1336
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1337 rb = r->request_body;
8706 3057bae4dba7 HTTP/3: introduced ngx_http_v3_parse_t structure. Roman Arutyunyan <arut@nginx.com> parents: 8690 diff changeset	1338 st = &r->v3_parse->body;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1339
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1340 h3c = ngx_http_v3_get_session(r->connection);
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1341
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1342 if (rb->rest == -1) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1343
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1344 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	1345 "http3 request body filter");
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1346
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1347 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	1348
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1349 rb->rest = cscf->large_client_header_buffers.size;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1350 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1351
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1352 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	1353
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1354 max = r->headers_in.content_length_n;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1355
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1356 if (max == -1 && clcf->client_max_body_size) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1357 max = clcf->client_max_body_size;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1358 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1359
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1360 out = NULL;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1361 ll = &out;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1362 last = 0;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1363
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1364 for (cl = in; cl; cl = cl->next) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1365
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1366 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	1367 "http3 body buf "
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1368 "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	1369 cl->buf->temporary, cl->buf->in_file,
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1370 cl->buf->start, cl->buf->pos,
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1371 cl->buf->last - cl->buf->pos,
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1372 cl->buf->file_pos,
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1373 cl->buf->file_last - cl->buf->file_pos);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1374
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1375 if (cl->buf->last_buf) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1376 last = 1;
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 b = NULL;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1380
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1381 while (cl->buf->pos < cl->buf->last) {
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 if (st->length == 0) {
8838 d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8835 diff changeset	1384 p = cl->buf->pos;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1385
8838 d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8835 diff changeset	1386 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	1387
d6e191a583cc HTTP/3: bulk parse functions. Roman Arutyunyan <arut@nginx.com> parents: 8835 diff changeset	1388 r->request_length += cl->buf->pos - p;
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1389 h3c->total_bytes += cl->buf->pos - p;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1390
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1391 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	1392 return NGX_HTTP_CLOSE;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1393 }
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1394
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1395 if (rc == NGX_AGAIN) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1396 continue;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1397 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1398
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1399 if (rc == NGX_DONE) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1400 last = 1;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1401 goto done;
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
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1404 if (rc > 0) {
8902 925572184d4a HTTP/3: adjusted QUIC connection finalization. Roman Arutyunyan <arut@nginx.com> parents: 8881 diff changeset	1405 ngx_quic_reset_stream(r->connection, rc);
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1406 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	1407 "client sent invalid body");
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1408 return NGX_HTTP_BAD_REQUEST;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1409 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1410
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1411 if (rc == NGX_ERROR) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1412 return NGX_HTTP_INTERNAL_SERVER_ERROR;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1413 }
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 /* rc == NGX_OK */
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1416 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1417
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1418 if (max != -1 && (uint64_t) (max - rb->received) < st->length) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1419 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	1420 "client intended to send too large "
8690 a9034b10dacc HTTP/3: fixed format specifier. Roman Arutyunyan <arut@nginx.com> parents: 8689 diff changeset	1421 "body: %O+%ui bytes",
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1422 rb->received, st->length);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1423
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1424 return NGX_HTTP_REQUEST_ENTITY_TOO_LARGE;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1425 }
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1426
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1427 if (b
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1428 && st->length <= 128
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1429 && (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	1430 {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1431 rb->received += st->length;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1432 r->request_length += st->length;
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1433 h3c->total_bytes += st->length;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1434 h3c->payload_bytes += st->length;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1435
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1436 if (st->length < 8) {
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 while (st->length) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1439 b->last++ = cl->buf->pos++;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1440 st->length--;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1441 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1442
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1443 } else {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1444 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	1445 b->last += st->length;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1446 cl->buf->pos += st->length;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1447 st->length = 0;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1448 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1449
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1450 continue;
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
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1453 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	1454 if (tl == NULL) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1455 return NGX_HTTP_INTERNAL_SERVER_ERROR;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1456 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1457
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1458 b = tl->buf;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1459
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1460 ngx_memzero(b, sizeof(ngx_buf_t));
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1461
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1462 b->temporary = 1;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1463 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	1464 b->start = cl->buf->pos;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1465 b->pos = cl->buf->pos;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1466 b->last = cl->buf->last;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1467 b->end = cl->buf->end;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1468 b->flush = r->request_body_no_buffering;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1469
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1470 *ll = tl;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1471 ll = &tl->next;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1472
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1473 size = cl->buf->last - cl->buf->pos;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1474
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1475 if (size > st->length) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1476 cl->buf->pos += (size_t) st->length;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1477 rb->received += st->length;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1478 r->request_length += st->length;
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1479 h3c->total_bytes += st->length;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1480 h3c->payload_bytes += st->length;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1481 st->length = 0;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1482
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1483 } else {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1484 st->length -= size;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1485 rb->received += size;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1486 r->request_length += size;
8881 72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1487 h3c->total_bytes += size;
72b304f6207c HTTP/3: traffic-based flood detection. Roman Arutyunyan <arut@nginx.com> parents: 8880 diff changeset	1488 h3c->payload_bytes += size;
8689 6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1489 cl->buf->pos = cl->buf->last;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1490 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1491
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1492 b->last = cl->buf->pos;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1493 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1494 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1495
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1496 done:
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1497
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1498 if (last) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1499
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1500 if (st->length > 0) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1501 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	1502 "client prematurely closed stream");
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1503 r->connection->error = 1;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1504 return NGX_HTTP_BAD_REQUEST;
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
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1507 if (r->headers_in.content_length_n == -1) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1508 r->headers_in.content_length_n = rb->received;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1509
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1510 } 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	1511 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	1512 "client sent less body data than expected: "
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1513 "%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	1514 rb->received, r->headers_in.content_length_n);
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1515 return NGX_HTTP_BAD_REQUEST;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1516 }
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->rest = 0;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1519
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1520 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	1521 if (tl == NULL) {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1522 return NGX_HTTP_INTERNAL_SERVER_ERROR;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1523 }
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 b = tl->buf;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1526
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1527 ngx_memzero(b, sizeof(ngx_buf_t));
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1528
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1529 b->last_buf = 1;
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1530
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1531 *ll = tl;
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 } else {
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1534
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1535 /* 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	1536
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1537 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	1538
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1539 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	1540 }
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1541
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1542 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	1543
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1544 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	1545 (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	1546
6bd8ed493b85 HTTP/3: refactored request body parser. Roman Arutyunyan <arut@nginx.com> parents: 8685 diff changeset	1547 return rc;
8295 5649079a41f4 Parsing HTTP/3 request body. Roman Arutyunyan <arut@nginx.com> parents: 8292 diff changeset	1548 }

Mercurial > hg > nginx

annotate src/http/v3/ngx_http_v3_request.c @ 8924:d6ef13c5fd8e quic