annotate src/http/v3/ngx_http_v3_request.c @ 8904:d2c193aa8480 quic

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