nginx-quic: src/http/v3/ngx_http_v3

annotate src/http/v3/ngx_http_v3_streams.c @ 8546:d80365ca678d quic

HTTP/3: require mandatory uni streams before additional ones. As per quic-http-34: Endpoints SHOULD create the HTTP control stream as well as the unidirectional streams required by mandatory extensions (such as the QPACK encoder and decoder streams) first, and then create additional streams as allowed by their peer. Previously, client could create and destroy additional uni streams unlimited number of times before creating mandatory streams.

author	Roman Arutyunyan <arut@nginx.com>
date	Thu, 29 Jul 2021 10:03:36 +0300
parents	0ac25efb2da3
children	054f9be0aaf9

rev	line source
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	1
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	2 /*
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	3 * Copyright (C) Roman Arutyunyan
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	4 * Copyright (C) Nginx, Inc.
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	5 */
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	6
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	7
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	8 #include <ngx_config.h>
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	9 #include <ngx_core.h>
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	10 #include <ngx_http.h>
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	11
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	12
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	13 typedef struct {
8432 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	14 ngx_http_v3_parse_uni_t parse;
7749 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	15 ngx_int_t index;
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	16 } ngx_http_v3_uni_stream_t;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	17
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	18
8015 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	19 typedef struct {
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	20 ngx_queue_t queue;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	21 uint64_t id;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	22 ngx_connection_t *connection;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	23 ngx_uint_t *npushing;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	24 } ngx_http_v3_push_t;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	25
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	26
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	27 static void ngx_http_v3_close_uni_stream(ngx_connection_t *c);
7692 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 7681 diff changeset	28 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	29 static void ngx_http_v3_dummy_write_handler(ngx_event_t *wev);
8015 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	30 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	31 static ngx_connection_t ngx_http_v3_get_uni_stream(ngx_connection_t c,
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	32 ngx_uint_t type);
8360 98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8359 diff changeset	33
98c4020f1c9a HTTP/3: keepalive timeout. Roman Arutyunyan <arut@nginx.com> parents: 8359 diff changeset	34
8272 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8200 diff changeset	35 void
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8200 diff changeset	36 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	37 {
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8200 diff changeset	38 ngx_http_v3_uni_stream_t *us;
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8200 diff changeset	39
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8200 diff changeset	40 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 init uni stream");
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	41
8359 fc64ab301bad QUIC: connection shutdown. Roman Arutyunyan <arut@nginx.com> parents: 8358 diff changeset	42 c->quic->cancelable = 1;
fc64ab301bad QUIC: connection shutdown. Roman Arutyunyan <arut@nginx.com> parents: 8358 diff changeset	43
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	44 us = ngx_pcalloc(c->pool, sizeof(ngx_http_v3_uni_stream_t));
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	45 if (us == NULL) {
8272 e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8200 diff changeset	46 ngx_http_close_connection(c);
e1eb7f4ca9f1 HTTP/3: refactored request parser. Roman Arutyunyan <arut@nginx.com> parents: 8200 diff changeset	47 return;
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	48 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	49
7749 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	50 us->index = -1;
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	51
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	52 c->data = us;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	53
8432 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	54 c->read->handler = ngx_http_v3_uni_read_handler;
7747 618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 7694 diff changeset	55 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	56
8432 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	57 ngx_http_v3_uni_read_handler(c->read);
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	58 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	59
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	60
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	61 static void
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	62 ngx_http_v3_close_uni_stream(ngx_connection_t *c)
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	63 {
7749 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	64 ngx_pool_t *pool;
8430 67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8429 diff changeset	65 ngx_http_v3_session_t *h3c;
7749 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	66 ngx_http_v3_uni_stream_t *us;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	67
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	68 us = c->data;
8428 40d710a66aef HTTP/3: ngx_http_v3_get_session() macro. Roman Arutyunyan <arut@nginx.com> parents: 8427 diff changeset	69 h3c = ngx_http_v3_get_session(c);
7749 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	70
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	71 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	72
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	73 if (us->index >= 0) {
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	74 h3c->known_streams[us->index] = NULL;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	75 }
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	76
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	77 c->destroyed = 1;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	78
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	79 pool = c->pool;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	80
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	81 ngx_close_connection(c);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	82
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	83 ngx_destroy_pool(pool);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	84 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	85
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	86
8432 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	87 ngx_int_t
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	88 ngx_http_v3_register_uni_stream(ngx_connection_t *c, uint64_t type)
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	89 {
8432 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	90 ngx_int_t index;
8430 67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8429 diff changeset	91 ngx_http_v3_session_t *h3c;
7749 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	92 ngx_http_v3_uni_stream_t *us;
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	93
8546 d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8508 diff changeset	94 h3c = ngx_http_v3_get_session(c);
d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8508 diff changeset	95
8432 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	96 switch (type) {
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	97
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	98 case NGX_HTTP_V3_STREAM_ENCODER:
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	99
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	100 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0,
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	101 "http3 encoder stream");
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	102 index = NGX_HTTP_V3_STREAM_CLIENT_ENCODER;
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	103 break;
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	104
8432 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	105 case NGX_HTTP_V3_STREAM_DECODER:
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	106
8432 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	107 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0,
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	108 "http3 decoder stream");
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	109 index = NGX_HTTP_V3_STREAM_CLIENT_DECODER;
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	110 break;
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	111
8432 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	112 case NGX_HTTP_V3_STREAM_CONTROL:
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	113
8432 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	114 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0,
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	115 "http3 control stream");
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	116 index = NGX_HTTP_V3_STREAM_CLIENT_CONTROL;
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	117
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	118 break;
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	119
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	120 default:
7955 72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 7951 diff changeset	121
8432 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	122 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	123 "http3 stream 0x%02xL", type);
8546 d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8508 diff changeset	124
d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8508 diff changeset	125 if (h3c->known_streams[NGX_HTTP_V3_STREAM_CLIENT_ENCODER] == NULL
d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8508 diff changeset	126 \|\| h3c->known_streams[NGX_HTTP_V3_STREAM_CLIENT_DECODER] == NULL
d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8508 diff changeset	127 \|\| h3c->known_streams[NGX_HTTP_V3_STREAM_CLIENT_CONTROL] == NULL)
d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8508 diff changeset	128 {
d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8508 diff changeset	129 ngx_log_error(NGX_LOG_INFO, c->log, 0, "missing mandatory stream");
d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8508 diff changeset	130 return NGX_HTTP_V3_ERR_STREAM_CREATION_ERROR;
d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8508 diff changeset	131 }
d80365ca678d HTTP/3: require mandatory uni streams before additional ones. Roman Arutyunyan <arut@nginx.com> parents: 8508 diff changeset	132
8432 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	133 index = -1;
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	134 }
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	135
8432 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	136 if (index >= 0) {
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	137 if (h3c->known_streams[index]) {
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	138 ngx_log_error(NGX_LOG_INFO, c->log, 0, "stream exists");
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	139 return NGX_HTTP_V3_ERR_STREAM_CREATION_ERROR;
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	140 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	141
8432 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	142 h3c->known_streams[index] = c;
7692 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 7681 diff changeset	143
8432 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	144 us = c->data;
345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	145 us->index = index;
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	146 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	147
8432 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	148 return NGX_OK;
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	149 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	150
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	151
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	152 static void
7692 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 7681 diff changeset	153 ngx_http_v3_uni_read_handler(ngx_event_t *rev)
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	154 {
7692 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 7681 diff changeset	155 u_char buf[128];
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	156 ssize_t n;
7692 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 7681 diff changeset	157 ngx_int_t rc, i;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 7681 diff changeset	158 ngx_connection_t *c;
7749 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	159 ngx_http_v3_uni_stream_t *us;
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	160
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	161 c = rev->data;
7749 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	162 us = c->data;
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	163
7692 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 7681 diff changeset	164 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 read handler");
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	165
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	166 while (rev->ready) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	167
7692 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 7681 diff changeset	168 n = c->recv(c, buf, sizeof(buf));
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	169
7955 72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 7951 diff changeset	170 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	171 rc = NGX_HTTP_V3_ERR_INTERNAL_ERROR;
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	172 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	173 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	174
7955 72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 7951 diff changeset	175 if (n == 0) {
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 7951 diff changeset	176 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	177 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	178 goto failed;
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 7951 diff changeset	179 }
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 7951 diff changeset	180
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 7951 diff changeset	181 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	182 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	183 return;
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 7951 diff changeset	184 }
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 7951 diff changeset	185
7692 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 7681 diff changeset	186 if (n == NGX_AGAIN) {
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	187 break;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	188 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	189
7692 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 7681 diff changeset	190 for (i = 0; i < n; i++) {
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	191
8432 345370fdd32d HTTP/3: moved parsing uni stream type to ngx_http_v3_parse.c. Roman Arutyunyan <arut@nginx.com> parents: 8431 diff changeset	192 rc = ngx_http_v3_parse_uni(c, &us->parse, buf[i]);
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	193
7955 72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 7951 diff changeset	194 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	195 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	196 "http3 read done");
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 7951 diff changeset	197 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	198 return;
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 7951 diff changeset	199 }
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 7951 diff changeset	200
72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 7951 diff changeset	201 if (rc > 0) {
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	202 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	203 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	204
7955 72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 7951 diff changeset	205 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	206 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	207 goto failed;
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	208 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	209 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	210 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	211
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	212 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	213 rc = NGX_HTTP_V3_ERR_INTERNAL_ERROR;
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	214 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	215 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	216
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	217 return;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	218
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	219 failed:
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	220
7955 72f9ff4e0a88 HTTP/3: close QUIC connection with HTTP/QPACK errors when needed. Roman Arutyunyan <arut@nginx.com> parents: 7951 diff changeset	221 ngx_http_v3_finalize_connection(c, rc, "stream error");
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	222 ngx_http_v3_close_uni_stream(c);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	223 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	224
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	225
7747 618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 7694 diff changeset	226 static void
618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 7694 diff changeset	227 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	228 {
618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 7694 diff changeset	229 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	230
618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 7694 diff changeset	231 c = wev->data;
618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 7694 diff changeset	232
618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 7694 diff changeset	233 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	234
618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 7694 diff changeset	235 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	236 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	237 NULL);
7747 618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 7694 diff changeset	238 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	239 }
618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 7694 diff changeset	240 }
618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 7694 diff changeset	241
618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 7694 diff changeset	242
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	243 /* XXX async & buffered stream writes */
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	244
8015 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	245 ngx_connection_t *
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	246 ngx_http_v3_create_push_stream(ngx_connection_t *c, uint64_t push_id)
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	247 {
8430 67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8429 diff changeset	248 u_char p, buf[NGX_HTTP_V3_VARLEN_INT_LEN 2];
67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8429 diff changeset	249 size_t n;
67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8429 diff changeset	250 ngx_connection_t *sc;
67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8429 diff changeset	251 ngx_pool_cleanup_t *cln;
67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8429 diff changeset	252 ngx_http_v3_push_t *push;
67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8429 diff changeset	253 ngx_http_v3_session_t *h3c;
8015 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	254
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	255 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	256 "http3 create push stream id:%uL", push_id);
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	257
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	258 sc = ngx_quic_open_stream(c, 0);
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	259 if (sc == NULL) {
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	260 return NULL;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	261 }
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	262
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	263 p = buf;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	264 p = (u_char *) ngx_http_v3_encode_varlen_int(p, NGX_HTTP_V3_STREAM_PUSH);
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	265 p = (u_char *) ngx_http_v3_encode_varlen_int(p, push_id);
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	266 n = p - buf;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	267
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	268 if (sc->send(sc, buf, n) != (ssize_t) n) {
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	269 goto failed;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	270 }
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	271
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	272 cln = ngx_pool_cleanup_add(sc->pool, sizeof(ngx_http_v3_push_t));
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	273 if (cln == NULL) {
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	274 goto failed;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	275 }
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	276
8428 40d710a66aef HTTP/3: ngx_http_v3_get_session() macro. Roman Arutyunyan <arut@nginx.com> parents: 8427 diff changeset	277 h3c = ngx_http_v3_get_session(c);
8015 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	278 h3c->npushing++;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	279
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	280 cln->handler = ngx_http_v3_push_cleanup;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	281
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	282 push = cln->data;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	283 push->id = push_id;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	284 push->connection = sc;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	285 push->npushing = &h3c->npushing;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	286
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	287 ngx_queue_insert_tail(&h3c->pushing, &push->queue);
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	288
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	289 return sc;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	290
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	291 failed:
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	292
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	293 ngx_http_v3_close_uni_stream(sc);
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	294
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	295 return NULL;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	296 }
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	297
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	298
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	299 static void
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	300 ngx_http_v3_push_cleanup(void *data)
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	301 {
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	302 ngx_http_v3_push_t *push = data;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	303
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	304 ngx_queue_remove(&push->queue);
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	305 (*push->npushing)--;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	306 }
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	307
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	308
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	309 static ngx_connection_t *
7749 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	310 ngx_http_v3_get_uni_stream(ngx_connection_t *c, ngx_uint_t type)
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	311 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	312 u_char buf[NGX_HTTP_V3_VARLEN_INT_LEN];
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	313 size_t n;
7749 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	314 ngx_int_t index;
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	315 ngx_connection_t *sc;
8430 67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8429 diff changeset	316 ngx_http_v3_session_t *h3c;
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	317 ngx_http_v3_uni_stream_t *us;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	318
7749 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	319 switch (type) {
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	320 case NGX_HTTP_V3_STREAM_ENCODER:
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	321 index = NGX_HTTP_V3_STREAM_SERVER_ENCODER;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	322 break;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	323 case NGX_HTTP_V3_STREAM_DECODER:
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	324 index = NGX_HTTP_V3_STREAM_SERVER_DECODER;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	325 break;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	326 case NGX_HTTP_V3_STREAM_CONTROL:
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	327 index = NGX_HTTP_V3_STREAM_SERVER_CONTROL;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	328 break;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	329 default:
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	330 index = -1;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	331 }
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	332
8428 40d710a66aef HTTP/3: ngx_http_v3_get_session() macro. Roman Arutyunyan <arut@nginx.com> parents: 8427 diff changeset	333 h3c = ngx_http_v3_get_session(c);
7749 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	334
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	335 if (index >= 0) {
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	336 if (h3c->known_streams[index]) {
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	337 return h3c->known_streams[index];
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	338 }
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	339 }
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	340
8013 455a8536eaa7 QUIC: limited the number of server-initiated streams. Roman Arutyunyan <arut@nginx.com> parents: 8010 diff changeset	341 sc = ngx_quic_open_stream(c, 0);
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	342 if (sc == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	343 return NULL;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	344 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	345
8359 fc64ab301bad QUIC: connection shutdown. Roman Arutyunyan <arut@nginx.com> parents: 8358 diff changeset	346 sc->quic->cancelable = 1;
fc64ab301bad QUIC: connection shutdown. Roman Arutyunyan <arut@nginx.com> parents: 8358 diff changeset	347
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	348 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	349 "http3 create uni stream, type:%ui", type);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	350
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	351 us = ngx_pcalloc(sc->pool, sizeof(ngx_http_v3_uni_stream_t));
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	352 if (us == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	353 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	354 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	355
7749 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	356 us->index = index;
dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	357
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	358 sc->data = us;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	359
7747 618a65de08b3 When closing a QUIC connection, wait for all streams to finish. Roman Arutyunyan <arut@nginx.com> parents: 7694 diff changeset	360 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	361 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	362
7880 c101438c69a4 HTTP/3: prevent array access by negative index for unknown streams. Roman Arutyunyan <arut@nginx.com> parents: 7839 diff changeset	363 if (index >= 0) {
c101438c69a4 HTTP/3: prevent array access by negative index for unknown streams. Roman Arutyunyan <arut@nginx.com> parents: 7839 diff changeset	364 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	365 }
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	366
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	367 n = (u_char *) ngx_http_v3_encode_varlen_int(buf, type) - buf;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	368
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	369 if (sc->send(sc, buf, n) != (ssize_t) n) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	370 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	371 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	372
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	373 return sc;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	374
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	375 failed:
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	376
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	377 ngx_http_v3_close_uni_stream(sc);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	378
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	379 return NULL;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	380 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	381
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	382
8434 f4d3f5d93a82 HTTP/3: moved session initialization to a separate file. Roman Arutyunyan <arut@nginx.com> parents: 8432 diff changeset	383 ngx_int_t
7951 c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 7880 diff changeset	384 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	385 {
8429 9ec3e71f8a61 HTTP/3: reference h3c directly from ngx_http_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 8428 diff changeset	386 u_char p, buf[NGX_HTTP_V3_VARLEN_INT_LEN 6];
9ec3e71f8a61 HTTP/3: reference h3c directly from ngx_http_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 8428 diff changeset	387 size_t n;
9ec3e71f8a61 HTTP/3: reference h3c directly from ngx_http_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 8428 diff changeset	388 ngx_connection_t *cc;
9ec3e71f8a61 HTTP/3: reference h3c directly from ngx_http_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 8428 diff changeset	389 ngx_http_v3_srv_conf_t *h3scf;
8013 455a8536eaa7 QUIC: limited the number of server-initiated streams. Roman Arutyunyan <arut@nginx.com> parents: 8010 diff changeset	390
7951 c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 7880 diff changeset	391 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	392
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 7880 diff changeset	393 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	394 if (cc == NULL) {
8013 455a8536eaa7 QUIC: limited the number of server-initiated streams. Roman Arutyunyan <arut@nginx.com> parents: 8010 diff changeset	395 return NGX_DECLINED;
7951 c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 7880 diff changeset	396 }
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 7880 diff changeset	397
8429 9ec3e71f8a61 HTTP/3: reference h3c directly from ngx_http_connection_t. Roman Arutyunyan <arut@nginx.com> parents: 8428 diff changeset	398 h3scf = ngx_http_v3_get_module_srv_conf(c, ngx_http_v3_module);
7951 c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 7880 diff changeset	399
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 7880 diff changeset	400 n = ngx_http_v3_encode_varlen_int(NULL,
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 7880 diff changeset	401 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	402 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	403 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	404 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	405
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 7880 diff changeset	406 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	407 NGX_HTTP_V3_FRAME_SETTINGS);
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 7880 diff changeset	408 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	409 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	410 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	411 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	412 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	413 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	414 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	415 n = p - buf;
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 7880 diff changeset	416
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 7880 diff changeset	417 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	418 goto failed;
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 7880 diff changeset	419 }
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 7880 diff changeset	420
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 7880 diff changeset	421 return NGX_OK;
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 7880 diff changeset	422
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 7880 diff changeset	423 failed:
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 7880 diff changeset	424
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 7880 diff changeset	425 ngx_http_v3_close_uni_stream(cc);
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 7880 diff changeset	426
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 7880 diff changeset	427 return NGX_ERROR;
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 7880 diff changeset	428 }
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 7880 diff changeset	429
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 7880 diff changeset	430
c9538aef3211 HTTP/3: refactored dynamic table implementation. Roman Arutyunyan <arut@nginx.com> parents: 7880 diff changeset	431 ngx_int_t
8358 265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8354 diff changeset	432 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	433 {
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8354 diff changeset	434 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	435 size_t n;
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8354 diff changeset	436 ngx_connection_t *cc;
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8354 diff changeset	437
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8354 diff changeset	438 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	439
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8354 diff changeset	440 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	441 if (cc == NULL) {
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8354 diff changeset	442 return NGX_DECLINED;
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8354 diff changeset	443 }
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8354 diff changeset	444
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8354 diff changeset	445 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	446 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	447 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	448 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	449 n = p - buf;
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8354 diff changeset	450
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8354 diff changeset	451 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	452 goto failed;
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8354 diff changeset	453 }
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8354 diff changeset	454
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8354 diff changeset	455 return NGX_OK;
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8354 diff changeset	456
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8354 diff changeset	457 failed:
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8354 diff changeset	458
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8354 diff changeset	459 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	460
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8354 diff changeset	461 return NGX_ERROR;
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8354 diff changeset	462 }
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8354 diff changeset	463
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8354 diff changeset	464
265062a99043 HTTP/3: send GOAWAY when last request is accepted. Roman Arutyunyan <arut@nginx.com> parents: 8354 diff changeset	465 ngx_int_t
8431 0981329169ea HTTP/3: renamed ngx_http_v3_client_XXX() functions. Roman Arutyunyan <arut@nginx.com> parents: 8430 diff changeset	466 ngx_http_v3_send_ref_insert(ngx_connection_t *c, ngx_uint_t dynamic,
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	467 ngx_uint_t index, ngx_str_t *value)
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	468 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	469 u_char p, buf[NGX_HTTP_V3_PREFIX_INT_LEN 2];
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	470 size_t n;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	471 ngx_connection_t *ec;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	472
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	473 ngx_log_debug3(NGX_LOG_DEBUG_HTTP, c->log, 0,
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	474 "http3 client ref insert, %s[%ui] \"%V\"",
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	475 dynamic ? "dynamic" : "static", index, value);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	476
7749 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	477 ec = ngx_http_v3_get_uni_stream(c, NGX_HTTP_V3_STREAM_ENCODER);
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	478 if (ec == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	479 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	480 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	481
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	482 p = buf;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	483
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	484 *p = (dynamic ? 0x80 : 0xc0);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	485 p = (u_char *) ngx_http_v3_encode_prefix_int(p, index, 6);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	486
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	487 /* XXX option for huffman? */
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	488 *p = 0;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	489 p = (u_char *) ngx_http_v3_encode_prefix_int(p, value->len, 7);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	490
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	491 n = p - buf;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	492
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	493 if (ec->send(ec, buf, n) != (ssize_t) n) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	494 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	495 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	496
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	497 if (ec->send(ec, value->data, value->len) != (ssize_t) value->len) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	498 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	499 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	500
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	501 return NGX_OK;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	502
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	503 failed:
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	504
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	505 ngx_http_v3_close_uni_stream(ec);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	506
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	507 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	508 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	509
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	510
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	511 ngx_int_t
8431 0981329169ea HTTP/3: renamed ngx_http_v3_client_XXX() functions. Roman Arutyunyan <arut@nginx.com> parents: 8430 diff changeset	512 ngx_http_v3_send_insert(ngx_connection_t c, ngx_str_t name, ngx_str_t *value)
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	513 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	514 u_char buf[NGX_HTTP_V3_PREFIX_INT_LEN];
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	515 size_t n;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	516 ngx_connection_t *ec;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	517
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	518 ngx_log_debug2(NGX_LOG_DEBUG_HTTP, c->log, 0,
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	519 "http3 client insert \"%V\":\"%V\"", name, value);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	520
7749 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	521 ec = ngx_http_v3_get_uni_stream(c, NGX_HTTP_V3_STREAM_ENCODER);
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	522 if (ec == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	523 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	524 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	525
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	526 /* XXX option for huffman? */
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	527 buf[0] = 0x40;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	528 n = (u_char *) ngx_http_v3_encode_prefix_int(buf, name->len, 5) - buf;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	529
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	530 if (ec->send(ec, buf, n) != (ssize_t) n) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	531 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	532 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	533
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	534 if (ec->send(ec, name->data, name->len) != (ssize_t) name->len) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	535 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	536 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	537
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	538 /* XXX option for huffman? */
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	539 buf[0] = 0;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	540 n = (u_char *) ngx_http_v3_encode_prefix_int(buf, value->len, 7) - buf;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	541
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	542 if (ec->send(ec, buf, n) != (ssize_t) n) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	543 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	544 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	545
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	546 if (ec->send(ec, value->data, value->len) != (ssize_t) value->len) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	547 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	548 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	549
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	550 return NGX_OK;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	551
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	552 failed:
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	553
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	554 ngx_http_v3_close_uni_stream(ec);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	555
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	556 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	557 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	558
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	559
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	560 ngx_int_t
8431 0981329169ea HTTP/3: renamed ngx_http_v3_client_XXX() functions. Roman Arutyunyan <arut@nginx.com> parents: 8430 diff changeset	561 ngx_http_v3_send_set_capacity(ngx_connection_t *c, ngx_uint_t capacity)
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	562 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	563 u_char buf[NGX_HTTP_V3_PREFIX_INT_LEN];
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	564 size_t n;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	565 ngx_connection_t *ec;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	566
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	567 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	568 "http3 client set capacity %ui", capacity);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	569
7749 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	570 ec = ngx_http_v3_get_uni_stream(c, NGX_HTTP_V3_STREAM_ENCODER);
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	571 if (ec == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	572 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	573 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	574
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	575 buf[0] = 0x20;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	576 n = (u_char *) ngx_http_v3_encode_prefix_int(buf, capacity, 5) - buf;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	577
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	578 if (ec->send(ec, buf, n) != (ssize_t) n) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	579 ngx_http_v3_close_uni_stream(ec);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	580 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	581 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	582
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	583 return NGX_OK;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	584 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	585
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	586
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	587 ngx_int_t
8431 0981329169ea HTTP/3: renamed ngx_http_v3_client_XXX() functions. Roman Arutyunyan <arut@nginx.com> parents: 8430 diff changeset	588 ngx_http_v3_send_duplicate(ngx_connection_t *c, ngx_uint_t index)
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	589 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	590 u_char buf[NGX_HTTP_V3_PREFIX_INT_LEN];
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	591 size_t n;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	592 ngx_connection_t *ec;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	593
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	594 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	595 "http3 client duplicate %ui", index);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	596
7749 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	597 ec = ngx_http_v3_get_uni_stream(c, NGX_HTTP_V3_STREAM_ENCODER);
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	598 if (ec == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	599 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	600 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	601
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	602 buf[0] = 0;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	603 n = (u_char *) ngx_http_v3_encode_prefix_int(buf, index, 5) - buf;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	604
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	605 if (ec->send(ec, buf, n) != (ssize_t) n) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	606 ngx_http_v3_close_uni_stream(ec);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	607 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	608 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	609
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	610 return NGX_OK;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	611 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	612
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	613
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	614 ngx_int_t
8508 0ac25efb2da3 HTTP/3: quic-qpack term updates. Sergey Kandaurov <pluknet@nginx.com> parents: 8497 diff changeset	615 ngx_http_v3_send_ack_section(ngx_connection_t *c, ngx_uint_t stream_id)
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	616 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	617 u_char buf[NGX_HTTP_V3_PREFIX_INT_LEN];
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	618 size_t n;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	619 ngx_connection_t *dc;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	620
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	621 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
8508 0ac25efb2da3 HTTP/3: quic-qpack term updates. Sergey Kandaurov <pluknet@nginx.com> parents: 8497 diff changeset	622 "http3 client ack section %ui", stream_id);
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	623
7749 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	624 dc = ngx_http_v3_get_uni_stream(c, NGX_HTTP_V3_STREAM_DECODER);
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	625 if (dc == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	626 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	627 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	628
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	629 buf[0] = 0x80;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	630 n = (u_char *) ngx_http_v3_encode_prefix_int(buf, stream_id, 7) - buf;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	631
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	632 if (dc->send(dc, buf, n) != (ssize_t) n) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	633 ngx_http_v3_close_uni_stream(dc);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	634 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	635 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	636
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	637 return NGX_OK;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	638 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	639
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	640
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	641 ngx_int_t
8431 0981329169ea HTTP/3: renamed ngx_http_v3_client_XXX() functions. Roman Arutyunyan <arut@nginx.com> parents: 8430 diff changeset	642 ngx_http_v3_send_cancel_stream(ngx_connection_t *c, ngx_uint_t stream_id)
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	643 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	644 u_char buf[NGX_HTTP_V3_PREFIX_INT_LEN];
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	645 size_t n;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	646 ngx_connection_t *dc;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	647
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	648 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	649 "http3 client cancel stream %ui", stream_id);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	650
7749 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	651 dc = ngx_http_v3_get_uni_stream(c, NGX_HTTP_V3_STREAM_DECODER);
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	652 if (dc == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	653 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	654 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	655
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	656 buf[0] = 0x40;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	657 n = (u_char *) ngx_http_v3_encode_prefix_int(buf, stream_id, 6) - buf;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	658
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	659 if (dc->send(dc, buf, n) != (ssize_t) n) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	660 ngx_http_v3_close_uni_stream(dc);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	661 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	662 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	663
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	664 return NGX_OK;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	665 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	666
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	667
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	668 ngx_int_t
8431 0981329169ea HTTP/3: renamed ngx_http_v3_client_XXX() functions. Roman Arutyunyan <arut@nginx.com> parents: 8430 diff changeset	669 ngx_http_v3_send_inc_insert_count(ngx_connection_t *c, ngx_uint_t inc)
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	670 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	671 u_char buf[NGX_HTTP_V3_PREFIX_INT_LEN];
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	672 size_t n;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	673 ngx_connection_t *dc;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	674
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	675 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	676 "http3 client increment insert count %ui", inc);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	677
7749 dadbc66e9fca Simplifed handling HTTP/3 streams. Roman Arutyunyan <arut@nginx.com> parents: 7747 diff changeset	678 dc = ngx_http_v3_get_uni_stream(c, NGX_HTTP_V3_STREAM_DECODER);
7681 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	679 if (dc == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	680 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	681 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	682
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	683 buf[0] = 0;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	684 n = (u_char *) ngx_http_v3_encode_prefix_int(buf, inc, 6) - buf;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	685
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	686 if (dc->send(dc, buf, n) != (ssize_t) n) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	687 ngx_http_v3_close_uni_stream(dc);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	688 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	689 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	690
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	691 return NGX_OK;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	692 }
8015 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	693
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	694
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	695 ngx_int_t
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	696 ngx_http_v3_set_max_push_id(ngx_connection_t *c, uint64_t max_push_id)
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	697 {
8430 67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8429 diff changeset	698 ngx_http_v3_session_t *h3c;
8015 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	699
8428 40d710a66aef HTTP/3: ngx_http_v3_get_session() macro. Roman Arutyunyan <arut@nginx.com> parents: 8427 diff changeset	700 h3c = ngx_http_v3_get_session(c);
8015 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	701
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	702 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	703 "http3 MAX_PUSH_ID:%uL", max_push_id);
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	704
8354 5cb5b568282b HTTP/3: do not push until a MAX_PUSH_ID frame is received. Sergey Kandaurov <pluknet@nginx.com> parents: 8272 diff changeset	705 if (h3c->max_push_id != (uint64_t) -1 && max_push_id < h3c->max_push_id) {
8015 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	706 return NGX_HTTP_V3_ERR_ID_ERROR;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	707 }
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	708
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	709 h3c->max_push_id = max_push_id;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	710
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	711 return NGX_OK;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	712 }
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	713
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	714
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	715 ngx_int_t
8497 1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8434 diff changeset	716 ngx_http_v3_goaway(ngx_connection_t *c, uint64_t push_id)
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8434 diff changeset	717 {
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8434 diff changeset	718 ngx_http_v3_session_t *h3c;
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8434 diff changeset	719
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8434 diff changeset	720 h3c = ngx_http_v3_get_session(c);
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8434 diff changeset	721
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8434 diff changeset	722 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 GOAWAY:%uL", push_id);
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8434 diff changeset	723
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8434 diff changeset	724 h3c->goaway_push_id = push_id;
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8434 diff changeset	725
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8434 diff changeset	726 return NGX_OK;
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8434 diff changeset	727 }
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8434 diff changeset	728
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8434 diff changeset	729
1fec68e322d0 HTTP/3: client GOAWAY support. Roman Arutyunyan <arut@nginx.com> parents: 8434 diff changeset	730 ngx_int_t
8015 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	731 ngx_http_v3_cancel_push(ngx_connection_t *c, uint64_t push_id)
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	732 {
8430 67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8429 diff changeset	733 ngx_queue_t *q;
67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8429 diff changeset	734 ngx_http_request_t *r;
67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8429 diff changeset	735 ngx_http_v3_push_t *push;
67f0eb150047 HTTP/3: renamed ngx_http_v3_connection_t to ngx_http_v3_session_t. Roman Arutyunyan <arut@nginx.com> parents: 8429 diff changeset	736 ngx_http_v3_session_t *h3c;
8015 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	737
8428 40d710a66aef HTTP/3: ngx_http_v3_get_session() macro. Roman Arutyunyan <arut@nginx.com> parents: 8427 diff changeset	738 h3c = ngx_http_v3_get_session(c);
8015 0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	739
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	740 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	741 "http3 CANCEL_PUSH:%uL", push_id);
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	742
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	743 if (push_id >= h3c->next_push_id) {
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	744 return NGX_HTTP_V3_ERR_ID_ERROR;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	745 }
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	746
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	747 for (q = ngx_queue_head(&h3c->pushing);
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	748 q != ngx_queue_sentinel(&h3c->pushing);
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	749 q = ngx_queue_next(&h3c->pushing))
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	750 {
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	751 push = (ngx_http_v3_push_t *) q;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	752
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	753 if (push->id != push_id) {
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	754 continue;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	755 }
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	756
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	757 r = push->connection->data;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	758
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	759 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	760 "http3 cancel push");
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	761
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	762 ngx_http_finalize_request(r, NGX_HTTP_CLOSE);
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	763
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	764 break;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	765 }
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	766
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	767 return NGX_OK;
0596fe1aee16 HTTP/3: server pushes. Roman Arutyunyan <arut@nginx.com> parents: 8013 diff changeset	768 }
8427 33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8360 diff changeset	769
33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8360 diff changeset	770
33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8360 diff changeset	771 ngx_int_t
33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8360 diff changeset	772 ngx_http_v3_cancel_stream(ngx_connection_t *c, ngx_uint_t stream_id)
33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8360 diff changeset	773 {
33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8360 diff changeset	774 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8360 diff changeset	775 "http3 cancel stream %ui", stream_id);
33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8360 diff changeset	776
33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8360 diff changeset	777 /* we do not use dynamic tables */
33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8360 diff changeset	778
33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8360 diff changeset	779 return NGX_OK;
33ec97749b5f HTTP/3: moved Stream Cancellation stub to ngx_http_v3_streams.c. Roman Arutyunyan <arut@nginx.com> parents: 8360 diff changeset	780 }

Mercurial > hg > nginx-quic

annotate src/http/v3/ngx_http_v3_streams.c @ 8546:d80365ca678d quic