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