nginx: src/http/v3/ngx_http_v3

annotate src/http/v3/ngx_http_v3_streams.c @ 8768:40d710a66aef quic

HTTP/3: ngx_http_v3_get_session() macro. It's used instead of accessing c->quic->parent->data directly. Apart from being simpler, it allows to change the way session is stored in the future by changing the macro.

author	Roman Arutyunyan <arut@nginx.com>
date	Fri, 30 Apr 2021 19:10:11 +0300
parents	33ec97749b5f
children	9ec3e71f8a61

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

Mercurial > hg > nginx

annotate src/http/v3/ngx_http_v3_streams.c @ 8768:40d710a66aef quic