nginx: src/http/v3/ngx_http_v3

annotate src/http/v3/ngx_http_v3_streams.c @ 8226:268f4389130d quic

Refactored HTTP/3 parser.

author	Roman Arutyunyan <arut@nginx.com>
date	Wed, 18 Mar 2020 13:46:35 +0300
parents	38c0898b6df7
children	ac41c53e446d

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 uint32_t signature; /* QSTR */
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	19
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	20 ngx_http_v3_handler_pt handler;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	21 void *data;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	22
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	23 ngx_uint_t type;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	24 ngx_uint_t client; /* unsigned client:1; */
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	25 } ngx_http_v3_uni_stream_t;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	26
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	27
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	28 static void ngx_http_v3_close_uni_stream(ngx_connection_t *c);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	29 static void ngx_http_v3_uni_stream_cleanup(void *data);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	30 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	31 static void ngx_http_v3_uni_read_handler(ngx_event_t *rev);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	32 static ngx_connection_t ngx_http_v3_create_uni_stream(ngx_connection_t c,
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	33 ngx_uint_t type);
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	34 static ngx_connection_t ngx_http_v3_get_control(ngx_connection_t c);
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	35 static ngx_connection_t ngx_http_v3_get_encoder(ngx_connection_t c);
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	36 static ngx_connection_t ngx_http_v3_get_decoder(ngx_connection_t c);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	37
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	38
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	39 void
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	40 ngx_http_v3_handle_client_uni_stream(ngx_connection_t *c)
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	41 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	42 ngx_pool_cleanup_t *cln;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	43 ngx_http_v3_uni_stream_t *us;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	44
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	45 c->log->connection = c->number;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	46
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	47 /* XXX */
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	48 (void) ngx_http_v3_get_control(c);
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	49 (void) ngx_http_v3_get_encoder(c);
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	50 (void) ngx_http_v3_get_decoder(c);
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	51
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	52 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	53 "http3 new uni stream id:0x%uxL", c->qs->id);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	54
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	55 us = ngx_pcalloc(c->pool, sizeof(ngx_http_v3_uni_stream_t));
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	56 if (us == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	57 ngx_http_v3_close_uni_stream(c);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	58 return;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	59 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	60
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	61 us->signature = NGX_HTTP_V3_STREAM;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	62 us->client = 1;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	63 us->type = (ngx_uint_t) -1;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	64
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	65 c->data = us;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	66
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	67 cln = ngx_pool_cleanup_add(c->pool, 0);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	68 if (cln == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	69 ngx_http_v3_close_uni_stream(c);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	70 return;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	71 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	72
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	73 cln->handler = ngx_http_v3_uni_stream_cleanup;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	74 cln->data = c;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	75
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	76 c->read->handler = ngx_http_v3_read_uni_stream_type;
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	77 ngx_http_v3_read_uni_stream_type(c->read);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	78 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	79
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	80
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	81 static void
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	82 ngx_http_v3_close_uni_stream(ngx_connection_t *c)
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	83 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	84 ngx_pool_t *pool;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	85
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	86 c->destroyed = 1;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	87
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	88 pool = c->pool;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	89
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	90 ngx_close_connection(c);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	91
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	92 ngx_destroy_pool(pool);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	93 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	94
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	95
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	96 static void
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	97 ngx_http_v3_uni_stream_cleanup(void *data)
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	98 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	99 ngx_connection_t *c = data;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	100
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	101 ngx_http_v3_connection_t *h3c;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	102 ngx_http_v3_uni_stream_t *us;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	103
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	104 us = c->data;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	105 h3c = c->qs->parent->data;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	106
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	107 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 close stream");
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	108
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	109 switch (us->type) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	110
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	111 case NGX_HTTP_V3_STREAM_ENCODER:
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	112
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	113 if (us->client) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	114 h3c->client_encoder = NULL;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	115 } else {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	116 h3c->server_encoder = NULL;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	117 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	118
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	119 break;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	120
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	121 case NGX_HTTP_V3_STREAM_DECODER:
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	122
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	123 if (us->client) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	124 h3c->client_decoder = NULL;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	125 } else {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	126 h3c->server_decoder = NULL;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	127 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	128
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	129 break;
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	130
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	131 case NGX_HTTP_V3_STREAM_CONTROL:
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	132
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	133 if (us->client) {
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	134 h3c->client_control = NULL;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	135 } else {
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	136 h3c->server_control = NULL;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	137 }
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	138
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	139 break;
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
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	144 static void
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	145 ngx_http_v3_read_uni_stream_type(ngx_event_t *rev)
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	146 {
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	147 u_char ch;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	148 ssize_t n;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	149 ngx_connection_t *c;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	150 ngx_http_v3_connection_t *h3c;
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	151 ngx_http_v3_uni_stream_t *st;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	152
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	153 c = rev->data;
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	154 st = c->data;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	155 h3c = c->qs->parent->data;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	156
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	157 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	158
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	159 while (rev->ready) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	160
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	161 n = c->recv(c, &ch, 1);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	162
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	163 if (n == NGX_ERROR) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	164 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	165 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	166
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	167 if (n == NGX_AGAIN \|\| n != 1) {
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	168 break;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	169 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	170
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	171 st->type = ch;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	172
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	173 switch (st->type) {
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	174
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	175 case NGX_HTTP_V3_STREAM_ENCODER:
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	176
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	177 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0,
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	178 "http3 encoder stream");
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	179
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	180 if (h3c->client_encoder) {
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	181 goto failed;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	182 }
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	183
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	184 h3c->client_encoder = c;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	185 st->handler = ngx_http_v3_parse_encoder;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	186 n = sizeof(ngx_http_v3_parse_encoder_t);
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	187
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	188 break;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	189
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	190 case NGX_HTTP_V3_STREAM_DECODER:
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	191
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	192 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0,
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	193 "http3 decoder stream");
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	194
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	195 if (h3c->client_decoder) {
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	196 goto failed;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	197 }
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	198
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	199 h3c->client_decoder = c;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	200 st->handler = ngx_http_v3_parse_decoder;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	201 n = sizeof(ngx_http_v3_parse_decoder_t);
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	202
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	203 break;
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_CONTROL:
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 control stream");
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	209
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	210 if (h3c->client_control) {
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	211 goto failed;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	212 }
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 h3c->client_control = c;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	215 st->handler = ngx_http_v3_parse_control;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	216 n = sizeof(ngx_http_v3_parse_control_t);
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 break;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	219
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	220 default:
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	221
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	222 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	223 "http3 stream 0x%02xi", st->type);
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	224 n = 0;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	225 }
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	226
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	227 if (n) {
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	228 st->data = ngx_pcalloc(c->pool, n);
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	229 if (st->data == NULL) {
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	230 goto failed;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	231 }
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	232 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	233
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	234 rev->handler = ngx_http_v3_uni_read_handler;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	235 ngx_http_v3_uni_read_handler(rev);
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	236 return;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	237 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	238
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	239 if (ngx_handle_read_event(rev, 0) != NGX_OK) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	240 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	241 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	242
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	243 return;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	244
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	245 failed:
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	246
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	247 ngx_http_v3_close_uni_stream(c);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	248 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	249
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	250
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	251 static void
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	252 ngx_http_v3_uni_read_handler(ngx_event_t *rev)
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	253 {
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	254 u_char buf[128];
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	255 ssize_t n;
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	256 ngx_int_t rc, i;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	257 ngx_connection_t *c;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	258 ngx_http_v3_uni_stream_t *st;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	259
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	260 c = rev->data;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	261 st = c->data;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	262
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	263 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	264
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	265 while (rev->ready) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	266
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	267 n = c->recv(c, buf, sizeof(buf));
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 if (n == NGX_ERROR \|\| n == 0) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	270 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	271 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	272
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	273 if (n == NGX_AGAIN) {
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	274 break;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	275 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	276
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	277 if (st->handler == NULL) {
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	278 continue;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	279 }
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	280
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	281 for (i = 0; i < n; i++) {
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	282
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	283 rc = st->handler(c, st->data, buf[i]);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	284
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	285 if (rc == NGX_ERROR) {
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	286 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	287 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	288
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	289 if (rc == NGX_DONE) {
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	290 goto done;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	291 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	292
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	293 /* rc == NGX_AGAIN */
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	294 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	295 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	296
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	297 if (ngx_handle_read_event(rev, 0) != NGX_OK) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	298 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	299 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	300
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	301 return;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	302
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	303 done:
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	304
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	305 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http3 read done");
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	306
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	307 failed:
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	308
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	309 ngx_http_v3_close_uni_stream(c);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	310 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	311
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	312
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	313 /* XXX async & buffered stream writes */
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	314
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	315 static ngx_connection_t *
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	316 ngx_http_v3_create_uni_stream(ngx_connection_t *c, ngx_uint_t type)
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	317 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	318 u_char buf[NGX_HTTP_V3_VARLEN_INT_LEN];
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	319 size_t n;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	320 ngx_connection_t *sc;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	321 ngx_pool_cleanup_t *cln;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	322 ngx_http_v3_uni_stream_t *us;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	323
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	324 sc = ngx_quic_create_uni_stream(c->qs->parent);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	325 if (sc == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	326 return NULL;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	327 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	328
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	329 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	330 "http3 create uni stream, type:%ui", type);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	331
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	332 us = ngx_pcalloc(sc->pool, sizeof(ngx_http_v3_uni_stream_t));
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	333 if (us == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	334 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	335 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	336
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	337 us->signature = NGX_HTTP_V3_STREAM;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	338 us->type = type;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	339 sc->data = us;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	340
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	341 cln = ngx_pool_cleanup_add(sc->pool, 0);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	342 if (cln == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	343 goto failed;
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 cln->handler = ngx_http_v3_uni_stream_cleanup;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	347 cln->data = sc;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	348
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	349 n = (u_char *) ngx_http_v3_encode_varlen_int(buf, type) - buf;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	350
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	351 if (sc->send(sc, buf, n) != (ssize_t) n) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	352 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	353 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	354
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	355 return sc;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	356
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	357 failed:
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	358
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	359 ngx_http_v3_close_uni_stream(sc);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	360
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	361 return NULL;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	362 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	363
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	364
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	365 static ngx_connection_t *
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	366 ngx_http_v3_get_control(ngx_connection_t *c)
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	367 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	368 ngx_http_v3_connection_t *h3c;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	369
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	370 h3c = c->qs->parent->data;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	371
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	372 if (h3c->server_encoder == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	373 h3c->server_encoder = ngx_http_v3_create_uni_stream(c,
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	374 NGX_HTTP_V3_STREAM_CONTROL);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	375 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	376
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	377 return h3c->server_encoder;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	378 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	379
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	380
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	381 static ngx_connection_t *
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	382 ngx_http_v3_get_encoder(ngx_connection_t *c)
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	383 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	384 ngx_http_v3_connection_t *h3c;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	385
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	386 h3c = c->qs->parent->data;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	387
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	388 if (h3c->server_encoder == NULL) {
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	389 h3c->server_encoder = ngx_http_v3_create_uni_stream(c,
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	390 NGX_HTTP_V3_STREAM_ENCODER);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	391 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	392
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	393 return h3c->server_encoder;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	394 }
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	395
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	396
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	397 static ngx_connection_t *
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	398 ngx_http_v3_get_decoder(ngx_connection_t *c)
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	399 {
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	400 ngx_http_v3_connection_t *h3c;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	401
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	402 h3c = c->qs->parent->data;
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	403
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	404 if (h3c->server_encoder == NULL) {
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	405 h3c->server_encoder = ngx_http_v3_create_uni_stream(c,
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	406 NGX_HTTP_V3_STREAM_DECODER);
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	407 }
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	408
268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	409 return h3c->server_encoder;
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	410 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	411
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	412
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	413 ngx_int_t
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	414 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	415 ngx_uint_t index, ngx_str_t *value)
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	416 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	417 u_char p, buf[NGX_HTTP_V3_PREFIX_INT_LEN 2];
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	418 size_t n;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	419 ngx_connection_t *ec;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	420
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	421 ngx_log_debug3(NGX_LOG_DEBUG_HTTP, c->log, 0,
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	422 "http3 client ref insert, %s[%ui] \"%V\"",
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	423 dynamic ? "dynamic" : "static", index, value);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	424
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	425 ec = ngx_http_v3_get_encoder(c);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	426 if (ec == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	427 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	428 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	429
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	430 p = buf;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	431
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	432 *p = (dynamic ? 0x80 : 0xc0);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	433 p = (u_char *) ngx_http_v3_encode_prefix_int(p, index, 6);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	434
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	435 /* XXX option for huffman? */
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	436 *p = 0;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	437 p = (u_char *) ngx_http_v3_encode_prefix_int(p, value->len, 7);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	438
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	439 n = p - buf;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	440
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	441 if (ec->send(ec, buf, n) != (ssize_t) n) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	442 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	443 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	444
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	445 if (ec->send(ec, value->data, value->len) != (ssize_t) value->len) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	446 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	447 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	448
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	449 return NGX_OK;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	450
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	451 failed:
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	452
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	453 ngx_http_v3_close_uni_stream(ec);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	454
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	455 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	456 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	457
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	458
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	459 ngx_int_t
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	460 ngx_http_v3_client_insert(ngx_connection_t c, ngx_str_t name,
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	461 ngx_str_t *value)
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	462 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	463 u_char buf[NGX_HTTP_V3_PREFIX_INT_LEN];
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	464 size_t n;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	465 ngx_connection_t *ec;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	466
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	467 ngx_log_debug2(NGX_LOG_DEBUG_HTTP, c->log, 0,
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	468 "http3 client insert \"%V\":\"%V\"", name, value);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	469
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	470 ec = ngx_http_v3_get_encoder(c);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	471 if (ec == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	472 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	473 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	474
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	475 /* XXX option for huffman? */
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	476 buf[0] = 0x40;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	477 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	478
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	479 if (ec->send(ec, buf, n) != (ssize_t) n) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	480 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	481 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	482
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	483 if (ec->send(ec, name->data, name->len) != (ssize_t) name->len) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	484 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	485 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	486
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	487 /* XXX option for huffman? */
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	488 buf[0] = 0;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	489 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	490
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	491 if (ec->send(ec, buf, n) != (ssize_t) n) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	492 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	493 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	494
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	495 if (ec->send(ec, value->data, value->len) != (ssize_t) value->len) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	496 goto failed;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	497 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	498
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	499 return NGX_OK;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	500
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	501 failed:
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	502
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	503 ngx_http_v3_close_uni_stream(ec);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	504
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	505 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	506 }
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 ngx_int_t
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	510 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	511 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	512 u_char buf[NGX_HTTP_V3_PREFIX_INT_LEN];
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	513 size_t n;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	514 ngx_connection_t *ec;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	515
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	516 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	517 "http3 client set capacity %ui", capacity);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	518
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	519 ec = ngx_http_v3_get_encoder(c);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	520 if (ec == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	521 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	522 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	523
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	524 buf[0] = 0x20;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	525 n = (u_char *) ngx_http_v3_encode_prefix_int(buf, capacity, 5) - buf;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	526
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	527 if (ec->send(ec, buf, n) != (ssize_t) n) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	528 ngx_http_v3_close_uni_stream(ec);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	529 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	530 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	531
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	532 return NGX_OK;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	533 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	534
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	535
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	536 ngx_int_t
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	537 ngx_http_v3_client_duplicate(ngx_connection_t *c, ngx_uint_t index)
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	538 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	539 u_char buf[NGX_HTTP_V3_PREFIX_INT_LEN];
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	540 size_t n;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	541 ngx_connection_t *ec;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	542
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	543 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	544 "http3 client duplicate %ui", index);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	545
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	546 ec = ngx_http_v3_get_encoder(c);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	547 if (ec == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	548 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	549 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	550
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	551 buf[0] = 0;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	552 n = (u_char *) ngx_http_v3_encode_prefix_int(buf, index, 5) - buf;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	553
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	554 if (ec->send(ec, buf, n) != (ssize_t) n) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	555 ngx_http_v3_close_uni_stream(ec);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	556 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	557 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	558
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	559 return NGX_OK;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	560 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	561
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	562
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	563 ngx_int_t
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	564 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	565 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	566 u_char buf[NGX_HTTP_V3_PREFIX_INT_LEN];
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	567 size_t n;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	568 ngx_connection_t *dc;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	569
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	570 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	571 "http3 client ack header %ui", stream_id);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	572
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	573 dc = ngx_http_v3_get_decoder(c);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	574 if (dc == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	575 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	576 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	577
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	578 buf[0] = 0x80;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	579 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	580
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	581 if (dc->send(dc, buf, n) != (ssize_t) n) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	582 ngx_http_v3_close_uni_stream(dc);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	583 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	584 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	585
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	586 return NGX_OK;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	587 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	588
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	589
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	590 ngx_int_t
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	591 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	592 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	593 u_char buf[NGX_HTTP_V3_PREFIX_INT_LEN];
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	594 size_t n;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	595 ngx_connection_t *dc;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	596
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	597 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	598 "http3 client cancel stream %ui", stream_id);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	599
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	600 dc = ngx_http_v3_get_decoder(c);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	601 if (dc == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	602 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	603 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	604
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	605 buf[0] = 0x40;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	606 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	607
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	608 if (dc->send(dc, buf, n) != (ssize_t) n) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	609 ngx_http_v3_close_uni_stream(dc);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	610 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	611 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	612
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	613 return NGX_OK;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	614 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	615
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	616
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	617 ngx_int_t
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	618 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	619 {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	620 u_char buf[NGX_HTTP_V3_PREFIX_INT_LEN];
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	621 size_t n;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	622 ngx_connection_t *dc;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	623
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	624 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	625 "http3 client increment insert count %ui", inc);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	626
8226 268f4389130d Refactored HTTP/3 parser. Roman Arutyunyan <arut@nginx.com> parents: 8215 diff changeset	627 dc = ngx_http_v3_get_decoder(c);
8215 38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	628 if (dc == NULL) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	629 return NGX_ERROR;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	630 }
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	631
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	632 buf[0] = 0;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	633 n = (u_char *) ngx_http_v3_encode_prefix_int(buf, inc, 6) - buf;
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	634
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	635 if (dc->send(dc, buf, n) != (ssize_t) n) {
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	636 ngx_http_v3_close_uni_stream(dc);
38c0898b6df7 HTTP/3. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	637 return NGX_ERROR;
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 }

Mercurial > hg > nginx

annotate src/http/v3/ngx_http_v3_streams.c @ 8226:268f4389130d quic