nginx-quic: src/http/v3/ngx_http_v3

annotate src/http/v3/ngx_http_v3_request.c @ 8758:e72db9162180 quic

QUIC: got rid of excessive "qsock" argument in ngx_quic_output.c. The output is always sent to the active path, which is stored in the quic connection. There is no need to pass it in arguments. When output has to be send to to a specific path (in rare cases, such as path probing), a separate method exists (ngx_quic_frame_sendto()).

author	Vladimir Homutov <vl@nginx.com>
date	Mon, 27 Dec 2021 13:52:57 +0300
parents	e4952530e6af
children	de7d36aa9bc7

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

Mercurial > hg > nginx-quic

annotate src/http/v3/ngx_http_v3_request.c @ 8758:e72db9162180 quic