Mercurial > hg > nginx-quic
annotate src/http/v3/ngx_http_v3_streams.c @ 8384:c61fcdc1b8e3 quic
UDP: extended datagram context.
Sometimes it is required to process datagram properties at higher level (i.e.
QUIC is interested in source address which may change and IP options). The
patch adds ngx_udp_dgram_t structure used to pass packet-related information
in c->udp.
| author | Vladimir Homutov <vl@nginx.com> |
|---|---|
| date | Fri, 02 Apr 2021 18:58:19 +0300 |
| parents | 98c4020f1c9a |
| children | 33ec97749b5f |
| rev | line source |
|---|---|
| 7681 | 1 |
| 2 /* | |
| 3 * Copyright (C) Roman Arutyunyan | |
| 4 * Copyright (C) Nginx, Inc. | |
| 5 */ | |
| 6 | |
| 7 | |
| 8 #include <ngx_config.h> | |
| 9 #include <ngx_core.h> | |
| 10 #include <ngx_http.h> | |
| 11 | |
| 12 | |
|
7692
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
13 typedef ngx_int_t (*ngx_http_v3_handler_pt)(ngx_connection_t *c, void *data, |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
14 u_char ch); |
| 7681 | 15 |
| 16 | |
| 17 typedef struct { | |
|
7692
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
18 ngx_http_v3_handler_pt handler; |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
19 void *data; |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
20 ngx_int_t index; |
| 7681 | 21 } ngx_http_v3_uni_stream_t; |
| 22 | |
| 23 | |
| 8015 | 24 typedef struct { |
| 25 ngx_queue_t queue; | |
| 26 uint64_t id; | |
| 27 ngx_connection_t *connection; | |
| 28 ngx_uint_t *npushing; | |
| 29 } ngx_http_v3_push_t; | |
| 30 | |
| 31 | |
|
8360
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
32 static void ngx_http_v3_keepalive_handler(ngx_event_t *ev); |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
33 static void ngx_http_v3_cleanup_session(void *data); |
| 7681 | 34 static void ngx_http_v3_close_uni_stream(ngx_connection_t *c); |
| 35 static void ngx_http_v3_read_uni_stream_type(ngx_event_t *rev); | |
|
7692
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
36 static void ngx_http_v3_uni_read_handler(ngx_event_t *rev); |
|
7747
618a65de08b3
When closing a QUIC connection, wait for all streams to finish.
Roman Arutyunyan <arut@nginx.com>
parents:
7694
diff
changeset
|
37 static void ngx_http_v3_dummy_write_handler(ngx_event_t *wev); |
| 8015 | 38 static void ngx_http_v3_push_cleanup(void *data); |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
39 static ngx_connection_t *ngx_http_v3_get_uni_stream(ngx_connection_t *c, |
| 7681 | 40 ngx_uint_t type); |
|
7999
0d2b2664b41c
QUIC: added "quic" listen parameter.
Roman Arutyunyan <arut@nginx.com>
parents:
7955
diff
changeset
|
41 static ngx_int_t ngx_http_v3_send_settings(ngx_connection_t *c); |
| 7681 | 42 |
| 43 | |
|
7999
0d2b2664b41c
QUIC: added "quic" listen parameter.
Roman Arutyunyan <arut@nginx.com>
parents:
7955
diff
changeset
|
44 ngx_int_t |
|
8272
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
45 ngx_http_v3_init_session(ngx_connection_t *c) |
| 7681 | 46 { |
|
8272
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
47 ngx_connection_t *pc; |
|
8360
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
48 ngx_pool_cleanup_t *cln; |
|
8272
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
49 ngx_http_connection_t *phc; |
|
7999
0d2b2664b41c
QUIC: added "quic" listen parameter.
Roman Arutyunyan <arut@nginx.com>
parents:
7955
diff
changeset
|
50 ngx_http_v3_connection_t *h3c; |
| 7681 | 51 |
|
8272
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
52 pc = c->quic->parent; |
|
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
53 phc = pc->data; |
|
7999
0d2b2664b41c
QUIC: added "quic" listen parameter.
Roman Arutyunyan <arut@nginx.com>
parents:
7955
diff
changeset
|
54 |
|
8272
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
55 if (phc->http3) { |
|
7999
0d2b2664b41c
QUIC: added "quic" listen parameter.
Roman Arutyunyan <arut@nginx.com>
parents:
7955
diff
changeset
|
56 return NGX_OK; |
|
0d2b2664b41c
QUIC: added "quic" listen parameter.
Roman Arutyunyan <arut@nginx.com>
parents:
7955
diff
changeset
|
57 } |
|
0d2b2664b41c
QUIC: added "quic" listen parameter.
Roman Arutyunyan <arut@nginx.com>
parents:
7955
diff
changeset
|
58 |
|
8272
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
59 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 init session"); |
|
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
60 |
|
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
61 h3c = ngx_pcalloc(pc->pool, sizeof(ngx_http_v3_connection_t)); |
|
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
62 if (h3c == NULL) { |
|
8013
455a8536eaa7
QUIC: limited the number of server-initiated streams.
Roman Arutyunyan <arut@nginx.com>
parents:
8010
diff
changeset
|
63 return NGX_ERROR; |
|
7999
0d2b2664b41c
QUIC: added "quic" listen parameter.
Roman Arutyunyan <arut@nginx.com>
parents:
7955
diff
changeset
|
64 } |
|
0d2b2664b41c
QUIC: added "quic" listen parameter.
Roman Arutyunyan <arut@nginx.com>
parents:
7955
diff
changeset
|
65 |
|
8272
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
66 h3c->hc = *phc; |
|
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
67 h3c->hc.http3 = 1; |
|
8354
5cb5b568282b
HTTP/3: do not push until a MAX_PUSH_ID frame is received.
Sergey Kandaurov <pluknet@nginx.com>
parents:
8272
diff
changeset
|
68 h3c->max_push_id = (uint64_t) -1; |
|
8272
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
69 |
|
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
70 ngx_queue_init(&h3c->blocked); |
|
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
71 ngx_queue_init(&h3c->pushing); |
|
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
72 |
|
8360
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
73 h3c->keepalive.log = pc->log; |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
74 h3c->keepalive.data = pc; |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
75 h3c->keepalive.handler = ngx_http_v3_keepalive_handler; |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
76 h3c->keepalive.cancelable = 1; |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
77 |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
78 cln = ngx_pool_cleanup_add(pc->pool, 0); |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
79 if (cln == NULL) { |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
80 return NGX_ERROR; |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
81 } |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
82 |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
83 cln->handler = ngx_http_v3_cleanup_session; |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
84 cln->data = h3c; |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
85 |
|
8272
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
86 pc->data = h3c; |
|
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
87 |
|
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
88 return ngx_http_v3_send_settings(c); |
|
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
89 } |
|
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
90 |
|
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
91 |
|
8360
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
92 static void |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
93 ngx_http_v3_keepalive_handler(ngx_event_t *ev) |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
94 { |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
95 ngx_connection_t *c; |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
96 |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
97 c = ev->data; |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
98 |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
99 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 keepalive handler"); |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
100 |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
101 ngx_quic_finalize_connection(c, NGX_HTTP_V3_ERR_NO_ERROR, |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
102 "keepalive timeout"); |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
103 } |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
104 |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
105 |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
106 static void |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
107 ngx_http_v3_cleanup_session(void *data) |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
108 { |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
109 ngx_http_v3_connection_t *h3c = data; |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
110 |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
111 if (h3c->keepalive.timer_set) { |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
112 ngx_del_timer(&h3c->keepalive); |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
113 } |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
114 } |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
115 |
|
98c4020f1c9a
HTTP/3: keepalive timeout.
Roman Arutyunyan <arut@nginx.com>
parents:
8359
diff
changeset
|
116 |
|
8272
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
117 void |
|
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
118 ngx_http_v3_init_uni_stream(ngx_connection_t *c) |
|
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
119 { |
|
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
120 ngx_http_v3_uni_stream_t *us; |
|
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
121 |
|
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
122 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 init uni stream"); |
| 7681 | 123 |
|
8359
fc64ab301bad
QUIC: connection shutdown.
Roman Arutyunyan <arut@nginx.com>
parents:
8358
diff
changeset
|
124 c->quic->cancelable = 1; |
|
fc64ab301bad
QUIC: connection shutdown.
Roman Arutyunyan <arut@nginx.com>
parents:
8358
diff
changeset
|
125 |
| 7681 | 126 us = ngx_pcalloc(c->pool, sizeof(ngx_http_v3_uni_stream_t)); |
| 127 if (us == NULL) { | |
|
8272
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
128 ngx_http_close_connection(c); |
|
e1eb7f4ca9f1
HTTP/3: refactored request parser.
Roman Arutyunyan <arut@nginx.com>
parents:
8200
diff
changeset
|
129 return; |
| 7681 | 130 } |
| 131 | |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
132 us->index = -1; |
| 7681 | 133 |
| 134 c->data = us; | |
| 135 | |
| 136 c->read->handler = ngx_http_v3_read_uni_stream_type; | |
|
7747
618a65de08b3
When closing a QUIC connection, wait for all streams to finish.
Roman Arutyunyan <arut@nginx.com>
parents:
7694
diff
changeset
|
137 c->write->handler = ngx_http_v3_dummy_write_handler; |
|
618a65de08b3
When closing a QUIC connection, wait for all streams to finish.
Roman Arutyunyan <arut@nginx.com>
parents:
7694
diff
changeset
|
138 |
|
7692
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
139 ngx_http_v3_read_uni_stream_type(c->read); |
| 7681 | 140 } |
| 141 | |
| 142 | |
| 143 static void | |
| 144 ngx_http_v3_close_uni_stream(ngx_connection_t *c) | |
| 145 { | |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
146 ngx_pool_t *pool; |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
147 ngx_http_v3_connection_t *h3c; |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
148 ngx_http_v3_uni_stream_t *us; |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
149 |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
150 us = c->data; |
|
8200
279ad36f2f4b
QUIC: renamed c->qs to c->quic.
Roman Arutyunyan <arut@nginx.com>
parents:
8015
diff
changeset
|
151 h3c = c->quic->parent->data; |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
152 |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
153 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 close stream"); |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
154 |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
155 if (us->index >= 0) { |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
156 h3c->known_streams[us->index] = NULL; |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
157 } |
| 7681 | 158 |
| 159 c->destroyed = 1; | |
| 160 | |
| 161 pool = c->pool; | |
| 162 | |
| 163 ngx_close_connection(c); | |
| 164 | |
| 165 ngx_destroy_pool(pool); | |
| 166 } | |
| 167 | |
| 168 | |
| 169 static void | |
| 170 ngx_http_v3_read_uni_stream_type(ngx_event_t *rev) | |
| 171 { | |
|
7692
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
172 u_char ch; |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
173 ssize_t n; |
|
7955
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
174 ngx_int_t index, rc; |
| 7681 | 175 ngx_connection_t *c; |
| 176 ngx_http_v3_connection_t *h3c; | |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
177 ngx_http_v3_uni_stream_t *us; |
| 7681 | 178 |
| 179 c = rev->data; | |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
180 us = c->data; |
|
8200
279ad36f2f4b
QUIC: renamed c->qs to c->quic.
Roman Arutyunyan <arut@nginx.com>
parents:
8015
diff
changeset
|
181 h3c = c->quic->parent->data; |
| 7681 | 182 |
| 183 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 read stream type"); | |
| 184 | |
| 185 while (rev->ready) { | |
| 186 | |
|
7692
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
187 n = c->recv(c, &ch, 1); |
| 7681 | 188 |
|
7955
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
189 if (n == NGX_AGAIN) { |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
190 break; |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
191 } |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
192 |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
193 if (n == 0) { |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
194 rc = NGX_HTTP_V3_ERR_GENERAL_PROTOCOL_ERROR; |
| 7681 | 195 goto failed; |
| 196 } | |
| 197 | |
|
7955
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
198 if (n != 1) { |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
199 rc = NGX_HTTP_V3_ERR_INTERNAL_ERROR; |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
200 goto failed; |
| 7681 | 201 } |
| 202 | |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
203 switch (ch) { |
|
7692
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
204 |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
205 case NGX_HTTP_V3_STREAM_ENCODER: |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
206 |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
207 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
208 "http3 encoder stream"); |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
209 |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
210 index = NGX_HTTP_V3_STREAM_CLIENT_ENCODER; |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
211 us->handler = ngx_http_v3_parse_encoder; |
|
7692
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
212 n = sizeof(ngx_http_v3_parse_encoder_t); |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
213 |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
214 break; |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
215 |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
216 case NGX_HTTP_V3_STREAM_DECODER: |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
217 |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
218 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
219 "http3 decoder stream"); |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
220 |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
221 index = NGX_HTTP_V3_STREAM_CLIENT_DECODER; |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
222 us->handler = ngx_http_v3_parse_decoder; |
|
7692
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
223 n = sizeof(ngx_http_v3_parse_decoder_t); |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
224 |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
225 break; |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
226 |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
227 case NGX_HTTP_V3_STREAM_CONTROL: |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
228 |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
229 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
230 "http3 control stream"); |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
231 |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
232 index = NGX_HTTP_V3_STREAM_CLIENT_CONTROL; |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
233 us->handler = ngx_http_v3_parse_control; |
|
7692
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
234 n = sizeof(ngx_http_v3_parse_control_t); |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
235 |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
236 break; |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
237 |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
238 default: |
| 7681 | 239 |
| 240 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, | |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
241 "http3 stream 0x%02xi", (ngx_int_t) ch); |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
242 index = -1; |
|
7692
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
243 n = 0; |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
244 } |
| 7681 | 245 |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
246 if (index >= 0) { |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
247 if (h3c->known_streams[index]) { |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
248 ngx_log_error(NGX_LOG_INFO, c->log, 0, "stream exists"); |
|
7955
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
249 rc = NGX_HTTP_V3_ERR_STREAM_CREATION_ERROR; |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
250 goto failed; |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
251 } |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
252 |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
253 us->index = index; |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
254 h3c->known_streams[index] = c; |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
255 } |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
256 |
|
7692
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
257 if (n) { |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
258 us->data = ngx_pcalloc(c->pool, n); |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
259 if (us->data == NULL) { |
|
7955
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
260 rc = NGX_HTTP_V3_ERR_INTERNAL_ERROR; |
|
7692
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
261 goto failed; |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
262 } |
| 7681 | 263 } |
| 264 | |
|
7692
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
265 rev->handler = ngx_http_v3_uni_read_handler; |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
266 ngx_http_v3_uni_read_handler(rev); |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
267 return; |
| 7681 | 268 } |
| 269 | |
| 270 if (ngx_handle_read_event(rev, 0) != NGX_OK) { | |
|
7955
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
271 rc = NGX_HTTP_V3_ERR_INTERNAL_ERROR; |
| 7681 | 272 goto failed; |
| 273 } | |
| 274 | |
| 275 return; | |
| 276 | |
| 277 failed: | |
| 278 | |
|
7955
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
279 ngx_http_v3_finalize_connection(c, rc, "could not read stream type"); |
| 7681 | 280 ngx_http_v3_close_uni_stream(c); |
| 281 } | |
| 282 | |
| 283 | |
| 284 static void | |
|
7692
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
285 ngx_http_v3_uni_read_handler(ngx_event_t *rev) |
| 7681 | 286 { |
|
7692
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
287 u_char buf[128]; |
| 7681 | 288 ssize_t n; |
|
7692
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
289 ngx_int_t rc, i; |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
290 ngx_connection_t *c; |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
291 ngx_http_v3_uni_stream_t *us; |
| 7681 | 292 |
| 293 c = rev->data; | |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
294 us = c->data; |
| 7681 | 295 |
|
7692
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
296 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 read handler"); |
| 7681 | 297 |
| 298 while (rev->ready) { | |
| 299 | |
|
7692
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
300 n = c->recv(c, buf, sizeof(buf)); |
| 7681 | 301 |
|
7955
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
302 if (n == NGX_ERROR) { |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
303 rc = NGX_HTTP_V3_ERR_INTERNAL_ERROR; |
| 7681 | 304 goto failed; |
| 305 } | |
| 306 | |
|
7955
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
307 if (n == 0) { |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
308 if (us->index >= 0) { |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
309 rc = NGX_HTTP_V3_ERR_CLOSED_CRITICAL_STREAM; |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
310 goto failed; |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
311 } |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
312 |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
313 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 read eof"); |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
314 ngx_http_v3_close_uni_stream(c); |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
315 return; |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
316 } |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
317 |
|
7692
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
318 if (n == NGX_AGAIN) { |
| 7681 | 319 break; |
| 320 } | |
| 321 | |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
322 if (us->handler == NULL) { |
|
7692
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
323 continue; |
|
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
324 } |
| 7681 | 325 |
|
7692
268f4389130d
Refactored HTTP/3 parser.
Roman Arutyunyan <arut@nginx.com>
parents:
7681
diff
changeset
|
326 for (i = 0; i < n; i++) { |
| 7681 | 327 |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
328 rc = us->handler(c, us->data, buf[i]); |
| 7681 | 329 |
|
7955
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
330 if (rc == NGX_DONE) { |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
331 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
332 "http3 read done"); |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
333 ngx_http_v3_close_uni_stream(c); |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
334 return; |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
335 } |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
336 |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
337 if (rc > 0) { |
| 7681 | 338 goto failed; |
| 339 } | |
| 340 | |
|
7955
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
341 if (rc != NGX_AGAIN) { |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
342 rc = NGX_HTTP_V3_ERR_GENERAL_PROTOCOL_ERROR; |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
343 goto failed; |
| 7681 | 344 } |
| 345 } | |
| 346 } | |
| 347 | |
| 348 if (ngx_handle_read_event(rev, 0) != NGX_OK) { | |
|
7955
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
349 rc = NGX_HTTP_V3_ERR_INTERNAL_ERROR; |
| 7681 | 350 goto failed; |
| 351 } | |
| 352 | |
| 353 return; | |
| 354 | |
| 355 failed: | |
| 356 | |
|
7955
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
357 ngx_http_v3_finalize_connection(c, rc, "stream error"); |
| 7681 | 358 ngx_http_v3_close_uni_stream(c); |
| 359 } | |
| 360 | |
| 361 | |
|
7747
618a65de08b3
When closing a QUIC connection, wait for all streams to finish.
Roman Arutyunyan <arut@nginx.com>
parents:
7694
diff
changeset
|
362 static void |
|
618a65de08b3
When closing a QUIC connection, wait for all streams to finish.
Roman Arutyunyan <arut@nginx.com>
parents:
7694
diff
changeset
|
363 ngx_http_v3_dummy_write_handler(ngx_event_t *wev) |
|
618a65de08b3
When closing a QUIC connection, wait for all streams to finish.
Roman Arutyunyan <arut@nginx.com>
parents:
7694
diff
changeset
|
364 { |
|
618a65de08b3
When closing a QUIC connection, wait for all streams to finish.
Roman Arutyunyan <arut@nginx.com>
parents:
7694
diff
changeset
|
365 ngx_connection_t *c; |
|
618a65de08b3
When closing a QUIC connection, wait for all streams to finish.
Roman Arutyunyan <arut@nginx.com>
parents:
7694
diff
changeset
|
366 |
|
618a65de08b3
When closing a QUIC connection, wait for all streams to finish.
Roman Arutyunyan <arut@nginx.com>
parents:
7694
diff
changeset
|
367 c = wev->data; |
|
618a65de08b3
When closing a QUIC connection, wait for all streams to finish.
Roman Arutyunyan <arut@nginx.com>
parents:
7694
diff
changeset
|
368 |
|
618a65de08b3
When closing a QUIC connection, wait for all streams to finish.
Roman Arutyunyan <arut@nginx.com>
parents:
7694
diff
changeset
|
369 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 dummy write handler"); |
|
618a65de08b3
When closing a QUIC connection, wait for all streams to finish.
Roman Arutyunyan <arut@nginx.com>
parents:
7694
diff
changeset
|
370 |
|
618a65de08b3
When closing a QUIC connection, wait for all streams to finish.
Roman Arutyunyan <arut@nginx.com>
parents:
7694
diff
changeset
|
371 if (ngx_handle_write_event(wev, 0) != NGX_OK) { |
|
7955
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
372 ngx_http_v3_finalize_connection(c, NGX_HTTP_V3_ERR_INTERNAL_ERROR, |
|
72f9ff4e0a88
HTTP/3: close QUIC connection with HTTP/QPACK errors when needed.
Roman Arutyunyan <arut@nginx.com>
parents:
7951
diff
changeset
|
373 NULL); |
|
7747
618a65de08b3
When closing a QUIC connection, wait for all streams to finish.
Roman Arutyunyan <arut@nginx.com>
parents:
7694
diff
changeset
|
374 ngx_http_v3_close_uni_stream(c); |
|
618a65de08b3
When closing a QUIC connection, wait for all streams to finish.
Roman Arutyunyan <arut@nginx.com>
parents:
7694
diff
changeset
|
375 } |
|
618a65de08b3
When closing a QUIC connection, wait for all streams to finish.
Roman Arutyunyan <arut@nginx.com>
parents:
7694
diff
changeset
|
376 } |
|
618a65de08b3
When closing a QUIC connection, wait for all streams to finish.
Roman Arutyunyan <arut@nginx.com>
parents:
7694
diff
changeset
|
377 |
|
618a65de08b3
When closing a QUIC connection, wait for all streams to finish.
Roman Arutyunyan <arut@nginx.com>
parents:
7694
diff
changeset
|
378 |
| 7681 | 379 /* XXX async & buffered stream writes */ |
| 380 | |
| 8015 | 381 ngx_connection_t * |
| 382 ngx_http_v3_create_push_stream(ngx_connection_t *c, uint64_t push_id) | |
| 383 { | |
| 384 u_char *p, buf[NGX_HTTP_V3_VARLEN_INT_LEN * 2]; | |
| 385 size_t n; | |
| 386 ngx_connection_t *sc; | |
| 387 ngx_pool_cleanup_t *cln; | |
| 388 ngx_http_v3_push_t *push; | |
| 389 ngx_http_v3_connection_t *h3c; | |
| 390 | |
| 391 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, | |
| 392 "http3 create push stream id:%uL", push_id); | |
| 393 | |
| 394 sc = ngx_quic_open_stream(c, 0); | |
| 395 if (sc == NULL) { | |
| 396 return NULL; | |
| 397 } | |
| 398 | |
| 399 p = buf; | |
| 400 p = (u_char *) ngx_http_v3_encode_varlen_int(p, NGX_HTTP_V3_STREAM_PUSH); | |
| 401 p = (u_char *) ngx_http_v3_encode_varlen_int(p, push_id); | |
| 402 n = p - buf; | |
| 403 | |
| 404 if (sc->send(sc, buf, n) != (ssize_t) n) { | |
| 405 goto failed; | |
| 406 } | |
| 407 | |
| 408 cln = ngx_pool_cleanup_add(sc->pool, sizeof(ngx_http_v3_push_t)); | |
| 409 if (cln == NULL) { | |
| 410 goto failed; | |
| 411 } | |
| 412 | |
|
8200
279ad36f2f4b
QUIC: renamed c->qs to c->quic.
Roman Arutyunyan <arut@nginx.com>
parents:
8015
diff
changeset
|
413 h3c = c->quic->parent->data; |
| 8015 | 414 h3c->npushing++; |
| 415 | |
| 416 cln->handler = ngx_http_v3_push_cleanup; | |
| 417 | |
| 418 push = cln->data; | |
| 419 push->id = push_id; | |
| 420 push->connection = sc; | |
| 421 push->npushing = &h3c->npushing; | |
| 422 | |
| 423 ngx_queue_insert_tail(&h3c->pushing, &push->queue); | |
| 424 | |
| 425 return sc; | |
| 426 | |
| 427 failed: | |
| 428 | |
| 429 ngx_http_v3_close_uni_stream(sc); | |
| 430 | |
| 431 return NULL; | |
| 432 } | |
| 433 | |
| 434 | |
| 435 static void | |
| 436 ngx_http_v3_push_cleanup(void *data) | |
| 437 { | |
| 438 ngx_http_v3_push_t *push = data; | |
| 439 | |
| 440 ngx_queue_remove(&push->queue); | |
| 441 (*push->npushing)--; | |
| 442 } | |
| 443 | |
| 444 | |
| 7681 | 445 static ngx_connection_t * |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
446 ngx_http_v3_get_uni_stream(ngx_connection_t *c, ngx_uint_t type) |
| 7681 | 447 { |
| 448 u_char buf[NGX_HTTP_V3_VARLEN_INT_LEN]; | |
| 449 size_t n; | |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
450 ngx_int_t index; |
| 7681 | 451 ngx_connection_t *sc; |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
452 ngx_http_v3_connection_t *h3c; |
| 7681 | 453 ngx_http_v3_uni_stream_t *us; |
| 454 | |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
455 switch (type) { |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
456 case NGX_HTTP_V3_STREAM_ENCODER: |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
457 index = NGX_HTTP_V3_STREAM_SERVER_ENCODER; |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
458 break; |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
459 case NGX_HTTP_V3_STREAM_DECODER: |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
460 index = NGX_HTTP_V3_STREAM_SERVER_DECODER; |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
461 break; |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
462 case NGX_HTTP_V3_STREAM_CONTROL: |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
463 index = NGX_HTTP_V3_STREAM_SERVER_CONTROL; |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
464 break; |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
465 default: |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
466 index = -1; |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
467 } |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
468 |
|
8200
279ad36f2f4b
QUIC: renamed c->qs to c->quic.
Roman Arutyunyan <arut@nginx.com>
parents:
8015
diff
changeset
|
469 h3c = c->quic->parent->data; |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
470 |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
471 if (index >= 0) { |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
472 if (h3c->known_streams[index]) { |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
473 return h3c->known_streams[index]; |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
474 } |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
475 } |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
476 |
|
8013
455a8536eaa7
QUIC: limited the number of server-initiated streams.
Roman Arutyunyan <arut@nginx.com>
parents:
8010
diff
changeset
|
477 sc = ngx_quic_open_stream(c, 0); |
| 7681 | 478 if (sc == NULL) { |
| 479 return NULL; | |
| 480 } | |
| 481 | |
|
8359
fc64ab301bad
QUIC: connection shutdown.
Roman Arutyunyan <arut@nginx.com>
parents:
8358
diff
changeset
|
482 sc->quic->cancelable = 1; |
|
fc64ab301bad
QUIC: connection shutdown.
Roman Arutyunyan <arut@nginx.com>
parents:
8358
diff
changeset
|
483 |
| 7681 | 484 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, |
| 485 "http3 create uni stream, type:%ui", type); | |
| 486 | |
| 487 us = ngx_pcalloc(sc->pool, sizeof(ngx_http_v3_uni_stream_t)); | |
| 488 if (us == NULL) { | |
| 489 goto failed; | |
| 490 } | |
| 491 | |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
492 us->index = index; |
|
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
493 |
| 7681 | 494 sc->data = us; |
| 495 | |
|
7747
618a65de08b3
When closing a QUIC connection, wait for all streams to finish.
Roman Arutyunyan <arut@nginx.com>
parents:
7694
diff
changeset
|
496 sc->read->handler = ngx_http_v3_uni_read_handler; |
|
618a65de08b3
When closing a QUIC connection, wait for all streams to finish.
Roman Arutyunyan <arut@nginx.com>
parents:
7694
diff
changeset
|
497 sc->write->handler = ngx_http_v3_dummy_write_handler; |
|
618a65de08b3
When closing a QUIC connection, wait for all streams to finish.
Roman Arutyunyan <arut@nginx.com>
parents:
7694
diff
changeset
|
498 |
|
7880
c101438c69a4
HTTP/3: prevent array access by negative index for unknown streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7839
diff
changeset
|
499 if (index >= 0) { |
|
c101438c69a4
HTTP/3: prevent array access by negative index for unknown streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7839
diff
changeset
|
500 h3c->known_streams[index] = sc; |
|
c101438c69a4
HTTP/3: prevent array access by negative index for unknown streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7839
diff
changeset
|
501 } |
| 7681 | 502 |
| 503 n = (u_char *) ngx_http_v3_encode_varlen_int(buf, type) - buf; | |
| 504 | |
| 505 if (sc->send(sc, buf, n) != (ssize_t) n) { | |
| 506 goto failed; | |
| 507 } | |
| 508 | |
| 509 return sc; | |
| 510 | |
| 511 failed: | |
| 512 | |
| 513 ngx_http_v3_close_uni_stream(sc); | |
| 514 | |
| 515 return NULL; | |
| 516 } | |
| 517 | |
| 518 | |
|
7999
0d2b2664b41c
QUIC: added "quic" listen parameter.
Roman Arutyunyan <arut@nginx.com>
parents:
7955
diff
changeset
|
519 static ngx_int_t |
|
7951
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
520 ngx_http_v3_send_settings(ngx_connection_t *c) |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
521 { |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
522 u_char *p, buf[NGX_HTTP_V3_VARLEN_INT_LEN * 6]; |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
523 size_t n; |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
524 ngx_connection_t *cc; |
|
8010
65c1fc5fae15
HTTP/3: renamed server configuration variables from v3cf to h3scf.
Roman Arutyunyan <arut@nginx.com>
parents:
7999
diff
changeset
|
525 ngx_http_v3_srv_conf_t *h3scf; |
|
7951
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
526 ngx_http_v3_connection_t *h3c; |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
527 |
|
8200
279ad36f2f4b
QUIC: renamed c->qs to c->quic.
Roman Arutyunyan <arut@nginx.com>
parents:
8015
diff
changeset
|
528 h3c = c->quic->parent->data; |
|
8013
455a8536eaa7
QUIC: limited the number of server-initiated streams.
Roman Arutyunyan <arut@nginx.com>
parents:
8010
diff
changeset
|
529 |
|
7951
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
530 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 send settings"); |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
531 |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
532 cc = ngx_http_v3_get_uni_stream(c, NGX_HTTP_V3_STREAM_CONTROL); |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
533 if (cc == NULL) { |
|
8013
455a8536eaa7
QUIC: limited the number of server-initiated streams.
Roman Arutyunyan <arut@nginx.com>
parents:
8010
diff
changeset
|
534 return NGX_DECLINED; |
|
7951
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
535 } |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
536 |
|
8010
65c1fc5fae15
HTTP/3: renamed server configuration variables from v3cf to h3scf.
Roman Arutyunyan <arut@nginx.com>
parents:
7999
diff
changeset
|
537 h3scf = ngx_http_get_module_srv_conf(h3c->hc.conf_ctx, ngx_http_v3_module); |
|
7951
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
538 |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
539 n = ngx_http_v3_encode_varlen_int(NULL, |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
540 NGX_HTTP_V3_PARAM_MAX_TABLE_CAPACITY); |
|
8010
65c1fc5fae15
HTTP/3: renamed server configuration variables from v3cf to h3scf.
Roman Arutyunyan <arut@nginx.com>
parents:
7999
diff
changeset
|
541 n += ngx_http_v3_encode_varlen_int(NULL, h3scf->max_table_capacity); |
|
7951
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
542 n += ngx_http_v3_encode_varlen_int(NULL, NGX_HTTP_V3_PARAM_BLOCKED_STREAMS); |
|
8010
65c1fc5fae15
HTTP/3: renamed server configuration variables from v3cf to h3scf.
Roman Arutyunyan <arut@nginx.com>
parents:
7999
diff
changeset
|
543 n += ngx_http_v3_encode_varlen_int(NULL, h3scf->max_blocked_streams); |
|
7951
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
544 |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
545 p = (u_char *) ngx_http_v3_encode_varlen_int(buf, |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
546 NGX_HTTP_V3_FRAME_SETTINGS); |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
547 p = (u_char *) ngx_http_v3_encode_varlen_int(p, n); |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
548 p = (u_char *) ngx_http_v3_encode_varlen_int(p, |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
549 NGX_HTTP_V3_PARAM_MAX_TABLE_CAPACITY); |
|
8010
65c1fc5fae15
HTTP/3: renamed server configuration variables from v3cf to h3scf.
Roman Arutyunyan <arut@nginx.com>
parents:
7999
diff
changeset
|
550 p = (u_char *) ngx_http_v3_encode_varlen_int(p, h3scf->max_table_capacity); |
|
7951
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
551 p = (u_char *) ngx_http_v3_encode_varlen_int(p, |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
552 NGX_HTTP_V3_PARAM_BLOCKED_STREAMS); |
|
8010
65c1fc5fae15
HTTP/3: renamed server configuration variables from v3cf to h3scf.
Roman Arutyunyan <arut@nginx.com>
parents:
7999
diff
changeset
|
553 p = (u_char *) ngx_http_v3_encode_varlen_int(p, h3scf->max_blocked_streams); |
|
7951
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
554 n = p - buf; |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
555 |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
556 if (cc->send(cc, buf, n) != (ssize_t) n) { |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
557 goto failed; |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
558 } |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
559 |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
560 return NGX_OK; |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
561 |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
562 failed: |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
563 |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
564 ngx_http_v3_close_uni_stream(cc); |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
565 |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
566 return NGX_ERROR; |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
567 } |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
568 |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
569 |
|
c9538aef3211
HTTP/3: refactored dynamic table implementation.
Roman Arutyunyan <arut@nginx.com>
parents:
7880
diff
changeset
|
570 ngx_int_t |
|
8358
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
571 ngx_http_v3_send_goaway(ngx_connection_t *c, uint64_t id) |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
572 { |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
573 u_char *p, buf[NGX_HTTP_V3_VARLEN_INT_LEN * 3]; |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
574 size_t n; |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
575 ngx_connection_t *cc; |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
576 |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
577 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 send goaway %uL", id); |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
578 |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
579 cc = ngx_http_v3_get_uni_stream(c, NGX_HTTP_V3_STREAM_CONTROL); |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
580 if (cc == NULL) { |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
581 return NGX_DECLINED; |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
582 } |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
583 |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
584 n = ngx_http_v3_encode_varlen_int(NULL, id); |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
585 p = (u_char *) ngx_http_v3_encode_varlen_int(buf, NGX_HTTP_V3_FRAME_GOAWAY); |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
586 p = (u_char *) ngx_http_v3_encode_varlen_int(p, n); |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
587 p = (u_char *) ngx_http_v3_encode_varlen_int(p, id); |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
588 n = p - buf; |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
589 |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
590 if (cc->send(cc, buf, n) != (ssize_t) n) { |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
591 goto failed; |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
592 } |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
593 |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
594 return NGX_OK; |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
595 |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
596 failed: |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
597 |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
598 ngx_http_v3_close_uni_stream(cc); |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
599 |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
600 return NGX_ERROR; |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
601 } |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
602 |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
603 |
|
265062a99043
HTTP/3: send GOAWAY when last request is accepted.
Roman Arutyunyan <arut@nginx.com>
parents:
8354
diff
changeset
|
604 ngx_int_t |
| 7681 | 605 ngx_http_v3_client_ref_insert(ngx_connection_t *c, ngx_uint_t dynamic, |
| 606 ngx_uint_t index, ngx_str_t *value) | |
| 607 { | |
| 608 u_char *p, buf[NGX_HTTP_V3_PREFIX_INT_LEN * 2]; | |
| 609 size_t n; | |
| 610 ngx_connection_t *ec; | |
| 611 | |
| 612 ngx_log_debug3(NGX_LOG_DEBUG_HTTP, c->log, 0, | |
| 613 "http3 client ref insert, %s[%ui] \"%V\"", | |
| 614 dynamic ? "dynamic" : "static", index, value); | |
| 615 | |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
616 ec = ngx_http_v3_get_uni_stream(c, NGX_HTTP_V3_STREAM_ENCODER); |
| 7681 | 617 if (ec == NULL) { |
| 618 return NGX_ERROR; | |
| 619 } | |
| 620 | |
| 621 p = buf; | |
| 622 | |
| 623 *p = (dynamic ? 0x80 : 0xc0); | |
| 624 p = (u_char *) ngx_http_v3_encode_prefix_int(p, index, 6); | |
| 625 | |
| 626 /* XXX option for huffman? */ | |
| 627 *p = 0; | |
| 628 p = (u_char *) ngx_http_v3_encode_prefix_int(p, value->len, 7); | |
| 629 | |
| 630 n = p - buf; | |
| 631 | |
| 632 if (ec->send(ec, buf, n) != (ssize_t) n) { | |
| 633 goto failed; | |
| 634 } | |
| 635 | |
| 636 if (ec->send(ec, value->data, value->len) != (ssize_t) value->len) { | |
| 637 goto failed; | |
| 638 } | |
| 639 | |
| 640 return NGX_OK; | |
| 641 | |
| 642 failed: | |
| 643 | |
| 644 ngx_http_v3_close_uni_stream(ec); | |
| 645 | |
| 646 return NGX_ERROR; | |
| 647 } | |
| 648 | |
| 649 | |
| 650 ngx_int_t | |
| 651 ngx_http_v3_client_insert(ngx_connection_t *c, ngx_str_t *name, | |
| 652 ngx_str_t *value) | |
| 653 { | |
| 654 u_char buf[NGX_HTTP_V3_PREFIX_INT_LEN]; | |
| 655 size_t n; | |
| 656 ngx_connection_t *ec; | |
| 657 | |
| 658 ngx_log_debug2(NGX_LOG_DEBUG_HTTP, c->log, 0, | |
| 659 "http3 client insert \"%V\":\"%V\"", name, value); | |
| 660 | |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
661 ec = ngx_http_v3_get_uni_stream(c, NGX_HTTP_V3_STREAM_ENCODER); |
| 7681 | 662 if (ec == NULL) { |
| 663 return NGX_ERROR; | |
| 664 } | |
| 665 | |
| 666 /* XXX option for huffman? */ | |
| 667 buf[0] = 0x40; | |
| 668 n = (u_char *) ngx_http_v3_encode_prefix_int(buf, name->len, 5) - buf; | |
| 669 | |
| 670 if (ec->send(ec, buf, n) != (ssize_t) n) { | |
| 671 goto failed; | |
| 672 } | |
| 673 | |
| 674 if (ec->send(ec, name->data, name->len) != (ssize_t) name->len) { | |
| 675 goto failed; | |
| 676 } | |
| 677 | |
| 678 /* XXX option for huffman? */ | |
| 679 buf[0] = 0; | |
| 680 n = (u_char *) ngx_http_v3_encode_prefix_int(buf, value->len, 7) - buf; | |
| 681 | |
| 682 if (ec->send(ec, buf, n) != (ssize_t) n) { | |
| 683 goto failed; | |
| 684 } | |
| 685 | |
| 686 if (ec->send(ec, value->data, value->len) != (ssize_t) value->len) { | |
| 687 goto failed; | |
| 688 } | |
| 689 | |
| 690 return NGX_OK; | |
| 691 | |
| 692 failed: | |
| 693 | |
| 694 ngx_http_v3_close_uni_stream(ec); | |
| 695 | |
| 696 return NGX_ERROR; | |
| 697 } | |
| 698 | |
| 699 | |
| 700 ngx_int_t | |
| 701 ngx_http_v3_client_set_capacity(ngx_connection_t *c, ngx_uint_t capacity) | |
| 702 { | |
| 703 u_char buf[NGX_HTTP_V3_PREFIX_INT_LEN]; | |
| 704 size_t n; | |
| 705 ngx_connection_t *ec; | |
| 706 | |
| 707 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, | |
| 708 "http3 client set capacity %ui", capacity); | |
| 709 | |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
710 ec = ngx_http_v3_get_uni_stream(c, NGX_HTTP_V3_STREAM_ENCODER); |
| 7681 | 711 if (ec == NULL) { |
| 712 return NGX_ERROR; | |
| 713 } | |
| 714 | |
| 715 buf[0] = 0x20; | |
| 716 n = (u_char *) ngx_http_v3_encode_prefix_int(buf, capacity, 5) - buf; | |
| 717 | |
| 718 if (ec->send(ec, buf, n) != (ssize_t) n) { | |
| 719 ngx_http_v3_close_uni_stream(ec); | |
| 720 return NGX_ERROR; | |
| 721 } | |
| 722 | |
| 723 return NGX_OK; | |
| 724 } | |
| 725 | |
| 726 | |
| 727 ngx_int_t | |
| 728 ngx_http_v3_client_duplicate(ngx_connection_t *c, ngx_uint_t index) | |
| 729 { | |
| 730 u_char buf[NGX_HTTP_V3_PREFIX_INT_LEN]; | |
| 731 size_t n; | |
| 732 ngx_connection_t *ec; | |
| 733 | |
| 734 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, | |
| 735 "http3 client duplicate %ui", index); | |
| 736 | |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
737 ec = ngx_http_v3_get_uni_stream(c, NGX_HTTP_V3_STREAM_ENCODER); |
| 7681 | 738 if (ec == NULL) { |
| 739 return NGX_ERROR; | |
| 740 } | |
| 741 | |
| 742 buf[0] = 0; | |
| 743 n = (u_char *) ngx_http_v3_encode_prefix_int(buf, index, 5) - buf; | |
| 744 | |
| 745 if (ec->send(ec, buf, n) != (ssize_t) n) { | |
| 746 ngx_http_v3_close_uni_stream(ec); | |
| 747 return NGX_ERROR; | |
| 748 } | |
| 749 | |
| 750 return NGX_OK; | |
| 751 } | |
| 752 | |
| 753 | |
| 754 ngx_int_t | |
| 755 ngx_http_v3_client_ack_header(ngx_connection_t *c, ngx_uint_t stream_id) | |
| 756 { | |
| 757 u_char buf[NGX_HTTP_V3_PREFIX_INT_LEN]; | |
| 758 size_t n; | |
| 759 ngx_connection_t *dc; | |
| 760 | |
| 761 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, | |
| 762 "http3 client ack header %ui", stream_id); | |
| 763 | |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
764 dc = ngx_http_v3_get_uni_stream(c, NGX_HTTP_V3_STREAM_DECODER); |
| 7681 | 765 if (dc == NULL) { |
| 766 return NGX_ERROR; | |
| 767 } | |
| 768 | |
| 769 buf[0] = 0x80; | |
| 770 n = (u_char *) ngx_http_v3_encode_prefix_int(buf, stream_id, 7) - buf; | |
| 771 | |
| 772 if (dc->send(dc, buf, n) != (ssize_t) n) { | |
| 773 ngx_http_v3_close_uni_stream(dc); | |
| 774 return NGX_ERROR; | |
| 775 } | |
| 776 | |
| 777 return NGX_OK; | |
| 778 } | |
| 779 | |
| 780 | |
| 781 ngx_int_t | |
| 782 ngx_http_v3_client_cancel_stream(ngx_connection_t *c, ngx_uint_t stream_id) | |
| 783 { | |
| 784 u_char buf[NGX_HTTP_V3_PREFIX_INT_LEN]; | |
| 785 size_t n; | |
| 786 ngx_connection_t *dc; | |
| 787 | |
| 788 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, | |
| 789 "http3 client cancel stream %ui", stream_id); | |
| 790 | |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
791 dc = ngx_http_v3_get_uni_stream(c, NGX_HTTP_V3_STREAM_DECODER); |
| 7681 | 792 if (dc == NULL) { |
| 793 return NGX_ERROR; | |
| 794 } | |
| 795 | |
| 796 buf[0] = 0x40; | |
| 797 n = (u_char *) ngx_http_v3_encode_prefix_int(buf, stream_id, 6) - buf; | |
| 798 | |
| 799 if (dc->send(dc, buf, n) != (ssize_t) n) { | |
| 800 ngx_http_v3_close_uni_stream(dc); | |
| 801 return NGX_ERROR; | |
| 802 } | |
| 803 | |
| 804 return NGX_OK; | |
| 805 } | |
| 806 | |
| 807 | |
| 808 ngx_int_t | |
| 809 ngx_http_v3_client_inc_insert_count(ngx_connection_t *c, ngx_uint_t inc) | |
| 810 { | |
| 811 u_char buf[NGX_HTTP_V3_PREFIX_INT_LEN]; | |
| 812 size_t n; | |
| 813 ngx_connection_t *dc; | |
| 814 | |
| 815 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, | |
| 816 "http3 client increment insert count %ui", inc); | |
| 817 | |
|
7749
dadbc66e9fca
Simplifed handling HTTP/3 streams.
Roman Arutyunyan <arut@nginx.com>
parents:
7747
diff
changeset
|
818 dc = ngx_http_v3_get_uni_stream(c, NGX_HTTP_V3_STREAM_DECODER); |
| 7681 | 819 if (dc == NULL) { |
| 820 return NGX_ERROR; | |
| 821 } | |
| 822 | |
| 823 buf[0] = 0; | |
| 824 n = (u_char *) ngx_http_v3_encode_prefix_int(buf, inc, 6) - buf; | |
| 825 | |
| 826 if (dc->send(dc, buf, n) != (ssize_t) n) { | |
| 827 ngx_http_v3_close_uni_stream(dc); | |
| 828 return NGX_ERROR; | |
| 829 } | |
| 830 | |
| 831 return NGX_OK; | |
| 832 } | |
| 8015 | 833 |
| 834 | |
| 835 ngx_int_t | |
| 836 ngx_http_v3_set_max_push_id(ngx_connection_t *c, uint64_t max_push_id) | |
| 837 { | |
| 838 ngx_http_v3_connection_t *h3c; | |
| 839 | |
|
8200
279ad36f2f4b
QUIC: renamed c->qs to c->quic.
Roman Arutyunyan <arut@nginx.com>
parents:
8015
diff
changeset
|
840 h3c = c->quic->parent->data; |
| 8015 | 841 |
| 842 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, | |
| 843 "http3 MAX_PUSH_ID:%uL", max_push_id); | |
| 844 | |
|
8354
5cb5b568282b
HTTP/3: do not push until a MAX_PUSH_ID frame is received.
Sergey Kandaurov <pluknet@nginx.com>
parents:
8272
diff
changeset
|
845 if (h3c->max_push_id != (uint64_t) -1 && max_push_id < h3c->max_push_id) { |
| 8015 | 846 return NGX_HTTP_V3_ERR_ID_ERROR; |
| 847 } | |
| 848 | |
| 849 h3c->max_push_id = max_push_id; | |
| 850 | |
| 851 return NGX_OK; | |
| 852 } | |
| 853 | |
| 854 | |
| 855 ngx_int_t | |
| 856 ngx_http_v3_cancel_push(ngx_connection_t *c, uint64_t push_id) | |
| 857 { | |
| 858 ngx_queue_t *q; | |
| 859 ngx_http_request_t *r; | |
| 860 ngx_http_v3_push_t *push; | |
| 861 ngx_http_v3_connection_t *h3c; | |
| 862 | |
|
8200
279ad36f2f4b
QUIC: renamed c->qs to c->quic.
Roman Arutyunyan <arut@nginx.com>
parents:
8015
diff
changeset
|
863 h3c = c->quic->parent->data; |
| 8015 | 864 |
| 865 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, | |
| 866 "http3 CANCEL_PUSH:%uL", push_id); | |
| 867 | |
| 868 if (push_id >= h3c->next_push_id) { | |
| 869 return NGX_HTTP_V3_ERR_ID_ERROR; | |
| 870 } | |
| 871 | |
| 872 for (q = ngx_queue_head(&h3c->pushing); | |
| 873 q != ngx_queue_sentinel(&h3c->pushing); | |
| 874 q = ngx_queue_next(&h3c->pushing)) | |
| 875 { | |
| 876 push = (ngx_http_v3_push_t *) q; | |
| 877 | |
| 878 if (push->id != push_id) { | |
| 879 continue; | |
| 880 } | |
| 881 | |
| 882 r = push->connection->data; | |
| 883 | |
| 884 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, r->connection->log, 0, | |
| 885 "http3 cancel push"); | |
| 886 | |
| 887 ngx_http_finalize_request(r, NGX_HTTP_CLOSE); | |
| 888 | |
| 889 break; | |
| 890 } | |
| 891 | |
| 892 return NGX_OK; | |
| 893 } |