nginx: src/event/quic/ngx_event_quic

annotate src/event/quic/ngx_event_quic_streams.c @ 8906:41caf5410110 quic

QUIC: reject streams which we could not create. The reasons why a stream may not be created by server currently include hitting worker_connections limit and memory allocation error. Previously in these cases the entire QUIC connection was closed and all its streams were shut down. Now the new stream is rejected and existing streams continue working. To reject an HTTP/3 request stream, RESET_STREAM and STOP_SENDING with H3_REQUEST_REJECTED error code are sent to client. HTTP/3 uni streams and Stream streams are not rejected.

author	Roman Arutyunyan <arut@nginx.com>
date	Thu, 11 Nov 2021 19:07:00 +0300
parents	832723a49026
children	e8cbbfabe547

rev	line source
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	2 /*
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	3 * Copyright (C) Nginx, Inc.
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	4 */
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	5
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	6
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	7 #include <ngx_config.h>
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	8 #include <ngx_core.h>
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	9 #include <ngx_event.h>
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	10 #include <ngx_event_quic_connection.h>
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	11
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	12
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	13 #define NGX_QUIC_STREAM_GONE (void *) -1
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	14
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	15
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	16 static ngx_quic_stream_t ngx_quic_create_client_stream(ngx_connection_t c,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	17 uint64_t id);
8906 41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	18 static ngx_int_t ngx_quic_reject_stream(ngx_connection_t *c, uint64_t id);
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	19 static ngx_int_t ngx_quic_init_stream(ngx_quic_stream_t *qs);
8886 66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	20 static void ngx_quic_init_streams_handler(ngx_connection_t *c);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	21 static ngx_quic_stream_t ngx_quic_create_stream(ngx_connection_t c,
8779 f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	22 uint64_t id);
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	23 static void ngx_quic_empty_handler(ngx_event_t *ev);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	24 static ssize_t ngx_quic_stream_recv(ngx_connection_t c, u_char buf,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	25 size_t size);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	26 static ssize_t ngx_quic_stream_send(ngx_connection_t c, u_char buf,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	27 size_t size);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	28 static ngx_chain_t ngx_quic_stream_send_chain(ngx_connection_t c,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	29 ngx_chain_t *in, off_t limit);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	30 static size_t ngx_quic_max_stream_flow(ngx_connection_t *c);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	31 static void ngx_quic_stream_cleanup_handler(void *data);
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	32 static ngx_int_t ngx_quic_control_flow(ngx_connection_t *c, uint64_t last);
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	33 static ngx_int_t ngx_quic_update_flow(ngx_connection_t *c, uint64_t last);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	34
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	35
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	36 ngx_connection_t *
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	37 ngx_quic_open_stream(ngx_connection_t *c, ngx_uint_t bidi)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	38 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	39 uint64_t id;
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	40 ngx_quic_stream_t qs, nqs;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	41 ngx_quic_connection_t *qc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	42
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	43 qs = c->quic;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	44 qc = ngx_quic_get_connection(qs->parent);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	45
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	46 if (bidi) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	47 if (qc->streams.server_streams_bidi
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	48 >= qc->streams.server_max_streams_bidi)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	49 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	50 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	51 "quic too many server bidi streams:%uL",
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	52 qc->streams.server_streams_bidi);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	53 return NULL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	54 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	55
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	56 id = (qc->streams.server_streams_bidi << 2)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	57 \| NGX_QUIC_STREAM_SERVER_INITIATED;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	58
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	59 ngx_log_debug3(NGX_LOG_DEBUG_EVENT, c->log, 0,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	60 "quic creating server bidi stream"
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	61 " streams:%uL max:%uL id:0x%xL",
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	62 qc->streams.server_streams_bidi,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	63 qc->streams.server_max_streams_bidi, id);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	64
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	65 qc->streams.server_streams_bidi++;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	66
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	67 } else {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	68 if (qc->streams.server_streams_uni
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	69 >= qc->streams.server_max_streams_uni)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	70 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	71 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	72 "quic too many server uni streams:%uL",
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	73 qc->streams.server_streams_uni);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	74 return NULL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	75 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	76
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	77 id = (qc->streams.server_streams_uni << 2)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	78 \| NGX_QUIC_STREAM_SERVER_INITIATED
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	79 \| NGX_QUIC_STREAM_UNIDIRECTIONAL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	80
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	81 ngx_log_debug3(NGX_LOG_DEBUG_EVENT, c->log, 0,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	82 "quic creating server uni stream"
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	83 " streams:%uL max:%uL id:0x%xL",
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	84 qc->streams.server_streams_uni,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	85 qc->streams.server_max_streams_uni, id);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	86
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	87 qc->streams.server_streams_uni++;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	88 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	89
8779 f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	90 nqs = ngx_quic_create_stream(qs->parent, id);
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	91 if (nqs == NULL) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	92 return NULL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	93 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	94
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	95 return nqs->connection;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	96 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	97
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	98
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	99 void
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	100 ngx_quic_rbtree_insert_stream(ngx_rbtree_node_t *temp,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	101 ngx_rbtree_node_t node, ngx_rbtree_node_t sentinel)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	102 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	103 ngx_rbtree_node_t **p;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	104 ngx_quic_stream_t qn, qnt;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	105
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	106 for ( ;; ) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	107 qn = (ngx_quic_stream_t *) node;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	108 qnt = (ngx_quic_stream_t *) temp;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	109
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	110 p = (qn->id < qnt->id) ? &temp->left : &temp->right;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	111
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	112 if (*p == sentinel) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	113 break;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	114 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	115
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	116 temp = *p;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	117 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	118
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	119 *p = node;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	120 node->parent = temp;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	121 node->left = sentinel;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	122 node->right = sentinel;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	123 ngx_rbt_red(node);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	124 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	125
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	126
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	127 ngx_quic_stream_t *
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	128 ngx_quic_find_stream(ngx_rbtree_t *rbtree, uint64_t id)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	129 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	130 ngx_rbtree_node_t node, sentinel;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	131 ngx_quic_stream_t *qn;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	132
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	133 node = rbtree->root;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	134 sentinel = rbtree->sentinel;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	135
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	136 while (node != sentinel) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	137 qn = (ngx_quic_stream_t *) node;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	138
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	139 if (id == qn->id) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	140 return qn;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	141 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	142
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	143 node = (id < qn->id) ? node->left : node->right;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	144 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	145
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	146 return NULL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	147 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	148
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	149
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	150 ngx_int_t
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	151 ngx_quic_close_streams(ngx_connection_t c, ngx_quic_connection_t qc)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	152 {
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	153 ngx_pool_t *pool;
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	154 ngx_queue_t *q;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	155 ngx_event_t rev, wev;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	156 ngx_rbtree_t *tree;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	157 ngx_rbtree_node_t *node;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	158 ngx_quic_stream_t *qs;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	159
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	160 #if (NGX_DEBUG)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	161 ngx_uint_t ns;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	162 #endif
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	163
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	164 while (!ngx_queue_empty(&qc->streams.uninitialized)) {
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	165 q = ngx_queue_head(&qc->streams.uninitialized);
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	166 ngx_queue_remove(q);
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	167
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	168 qs = ngx_queue_data(q, ngx_quic_stream_t, queue);
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	169 pool = qs->connection->pool;
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	170
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	171 ngx_close_connection(qs->connection);
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	172 ngx_destroy_pool(pool);
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	173 }
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	174
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	175 tree = &qc->streams.tree;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	176
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	177 if (tree->root == tree->sentinel) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	178 return NGX_OK;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	179 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	180
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	181 #if (NGX_DEBUG)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	182 ns = 0;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	183 #endif
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	184
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	185 for (node = ngx_rbtree_min(tree->root, tree->sentinel);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	186 node;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	187 node = ngx_rbtree_next(tree, node))
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	188 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	189 qs = (ngx_quic_stream_t *) node;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	190
8760 baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	191 rev = qs->connection->read;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	192 rev->error = 1;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	193 rev->ready = 1;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	194
8760 baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	195 wev = qs->connection->write;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	196 wev->error = 1;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	197 wev->ready = 1;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	198
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	199 ngx_post_event(rev, &ngx_posted_events);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	200
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	201 if (rev->timer_set) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	202 ngx_del_timer(rev);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	203 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	204
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	205 #if (NGX_DEBUG)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	206 ns++;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	207 #endif
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	208 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	209
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	210 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	211 "quic connection has %ui active streams", ns);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	212
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	213 return NGX_AGAIN;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	214 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	215
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	216
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	217 ngx_int_t
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	218 ngx_quic_reset_stream(ngx_connection_t *c, ngx_uint_t err)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	219 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	220 ngx_event_t *wev;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	221 ngx_connection_t *pc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	222 ngx_quic_frame_t *frame;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	223 ngx_quic_stream_t *qs;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	224 ngx_quic_connection_t *qc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	225
8875 13cb758e6ac0 QUIC: reset stream only once. Roman Arutyunyan <arut@nginx.com> parents: 8861 diff changeset	226 wev = c->write;
13cb758e6ac0 QUIC: reset stream only once. Roman Arutyunyan <arut@nginx.com> parents: 8861 diff changeset	227
13cb758e6ac0 QUIC: reset stream only once. Roman Arutyunyan <arut@nginx.com> parents: 8861 diff changeset	228 if (wev->error) {
13cb758e6ac0 QUIC: reset stream only once. Roman Arutyunyan <arut@nginx.com> parents: 8861 diff changeset	229 return NGX_OK;
13cb758e6ac0 QUIC: reset stream only once. Roman Arutyunyan <arut@nginx.com> parents: 8861 diff changeset	230 }
13cb758e6ac0 QUIC: reset stream only once. Roman Arutyunyan <arut@nginx.com> parents: 8861 diff changeset	231
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	232 qs = c->quic;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	233 pc = qs->parent;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	234 qc = ngx_quic_get_connection(pc);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	235
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	236 frame = ngx_quic_alloc_frame(pc);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	237 if (frame == NULL) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	238 return NGX_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	239 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	240
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	241 frame->level = ssl_encryption_application;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	242 frame->type = NGX_QUIC_FT_RESET_STREAM;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	243 frame->u.reset_stream.id = qs->id;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	244 frame->u.reset_stream.error_code = err;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	245 frame->u.reset_stream.final_size = c->sent;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	246
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	247 ngx_quic_queue_frame(qc, frame);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	248
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	249 wev->error = 1;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	250 wev->ready = 1;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	251
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	252 return NGX_OK;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	253 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	254
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	255
8890 b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	256 ngx_int_t
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	257 ngx_quic_shutdown_stream(ngx_connection_t *c, int how)
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	258 {
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	259 ngx_event_t *wev;
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	260 ngx_connection_t *pc;
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	261 ngx_quic_frame_t *frame;
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	262 ngx_quic_stream_t *qs;
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	263 ngx_quic_connection_t *qc;
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	264
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	265 if (how != NGX_WRITE_SHUTDOWN) {
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	266 return NGX_OK;
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	267 }
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	268
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	269 wev = c->write;
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	270
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	271 if (wev->error) {
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	272 return NGX_OK;
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	273 }
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	274
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	275 qs = c->quic;
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	276 pc = qs->parent;
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	277 qc = ngx_quic_get_connection(pc);
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	278
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	279 frame = ngx_quic_alloc_frame(pc);
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	280 if (frame == NULL) {
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	281 return NGX_ERROR;
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	282 }
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	283
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	284 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	285 "quic stream id:0x%xL shutdown", qs->id);
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	286
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	287 frame->level = ssl_encryption_application;
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	288 frame->type = NGX_QUIC_FT_STREAM;
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	289 frame->u.stream.off = 1;
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	290 frame->u.stream.len = 1;
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	291 frame->u.stream.fin = 1;
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	292
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	293 frame->u.stream.stream_id = qs->id;
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	294 frame->u.stream.offset = c->sent;
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	295 frame->u.stream.length = 0;
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	296
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	297 ngx_quic_queue_frame(qc, frame);
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	298
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	299 wev->ready = 1;
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	300 wev->error = 1;
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	301
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	302 return NGX_OK;
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	303 }
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	304
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	305
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	306 static ngx_quic_stream_t *
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	307 ngx_quic_create_client_stream(ngx_connection_t *c, uint64_t id)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	308 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	309 uint64_t min_id;
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	310 ngx_quic_stream_t *qs;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	311 ngx_quic_connection_t *qc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	312
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	313 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	314 "quic stream id:0x%xL is new", id);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	315
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	316 qc = ngx_quic_get_connection(c);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	317
8905 832723a49026 QUIC: stop processing new client streams at the closing state. Sergey Kandaurov <pluknet@nginx.com> parents: 8890 diff changeset	318 if (qc->shutdown \|\| qc->closing) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	319 return NGX_QUIC_STREAM_GONE;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	320 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	321
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	322 if (id & NGX_QUIC_STREAM_UNIDIRECTIONAL) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	323
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	324 if (id & NGX_QUIC_STREAM_SERVER_INITIATED) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	325 if ((id >> 2) < qc->streams.server_streams_uni) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	326 return NGX_QUIC_STREAM_GONE;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	327 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	328
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	329 qc->error = NGX_QUIC_ERR_STREAM_STATE_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	330 return NULL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	331 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	332
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	333 if ((id >> 2) < qc->streams.client_streams_uni) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	334 return NGX_QUIC_STREAM_GONE;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	335 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	336
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	337 if ((id >> 2) >= qc->streams.client_max_streams_uni) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	338 qc->error = NGX_QUIC_ERR_STREAM_LIMIT_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	339 return NULL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	340 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	341
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	342 min_id = (qc->streams.client_streams_uni << 2)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	343 \| NGX_QUIC_STREAM_UNIDIRECTIONAL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	344 qc->streams.client_streams_uni = (id >> 2) + 1;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	345
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	346 } else {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	347
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	348 if (id & NGX_QUIC_STREAM_SERVER_INITIATED) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	349 if ((id >> 2) < qc->streams.server_streams_bidi) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	350 return NGX_QUIC_STREAM_GONE;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	351 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	352
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	353 qc->error = NGX_QUIC_ERR_STREAM_STATE_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	354 return NULL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	355 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	356
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	357 if ((id >> 2) < qc->streams.client_streams_bidi) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	358 return NGX_QUIC_STREAM_GONE;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	359 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	360
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	361 if ((id >> 2) >= qc->streams.client_max_streams_bidi) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	362 qc->error = NGX_QUIC_ERR_STREAM_LIMIT_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	363 return NULL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	364 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	365
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	366 min_id = (qc->streams.client_streams_bidi << 2);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	367 qc->streams.client_streams_bidi = (id >> 2) + 1;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	368 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	369
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	370 /*
8797 4715f3e669f1 QUIC: updated specification references. Sergey Kandaurov <pluknet@nginx.com> parents: 8791 diff changeset	371 * RFC 9000, 2.1. Stream Types and Identifiers
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	372 *
8797 4715f3e669f1 QUIC: updated specification references. Sergey Kandaurov <pluknet@nginx.com> parents: 8791 diff changeset	373 * successive streams of each type are created with numerically increasing
4715f3e669f1 QUIC: updated specification references. Sergey Kandaurov <pluknet@nginx.com> parents: 8791 diff changeset	374 * stream IDs. A stream ID that is used out of order results in all
4715f3e669f1 QUIC: updated specification references. Sergey Kandaurov <pluknet@nginx.com> parents: 8791 diff changeset	375 * streams of that type with lower-numbered stream IDs also being opened.
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	376 */
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	377
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	378 for ( /* void */ ; min_id < id; min_id += 0x04) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	379
8779 f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	380 qs = ngx_quic_create_stream(c, min_id);
8906 41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	381
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	382 if (qs == NULL) {
8906 41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	383 if (ngx_quic_reject_stream(c, min_id) != NGX_OK) {
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	384 return NULL;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	385 }
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	386
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	387 continue;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	388 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	389
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	390 if (ngx_quic_init_stream(qs) != NGX_OK) {
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	391 return NULL;
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	392 }
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	393
8905 832723a49026 QUIC: stop processing new client streams at the closing state. Sergey Kandaurov <pluknet@nginx.com> parents: 8890 diff changeset	394 if (qc->shutdown \|\| qc->closing) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	395 return NGX_QUIC_STREAM_GONE;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	396 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	397 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	398
8906 41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	399 qs = ngx_quic_create_stream(c, id);
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	400
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	401 if (qs == NULL) {
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	402 if (ngx_quic_reject_stream(c, id) != NGX_OK) {
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	403 return NULL;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	404 }
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	405
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	406 return NGX_QUIC_STREAM_GONE;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	407 }
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	408
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	409 return qs;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	410 }
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	411
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	412
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	413 static ngx_int_t
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	414 ngx_quic_reject_stream(ngx_connection_t *c, uint64_t id)
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	415 {
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	416 uint64_t code;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	417 ngx_quic_frame_t *frame;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	418 ngx_quic_connection_t *qc;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	419
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	420 qc = ngx_quic_get_connection(c);
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	421
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	422 code = (id & NGX_QUIC_STREAM_UNIDIRECTIONAL)
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	423 ? qc->conf->stream_reject_code_uni
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	424 : qc->conf->stream_reject_code_bidi;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	425
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	426 if (code == 0) {
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	427 return NGX_DECLINED;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	428 }
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	429
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	430 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, c->log, 0,
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	431 "quic stream id:0x%xL reject err:0x%xL", id, code);
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	432
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	433 frame = ngx_quic_alloc_frame(c);
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	434 if (frame == NULL) {
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	435 return NGX_ERROR;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	436 }
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	437
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	438 frame->level = ssl_encryption_application;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	439 frame->type = NGX_QUIC_FT_RESET_STREAM;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	440 frame->u.reset_stream.id = id;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	441 frame->u.reset_stream.error_code = code;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	442 frame->u.reset_stream.final_size = 0;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	443
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	444 ngx_quic_queue_frame(qc, frame);
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	445
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	446 frame = ngx_quic_alloc_frame(c);
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	447 if (frame == NULL) {
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	448 return NGX_ERROR;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	449 }
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	450
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	451 frame->level = ssl_encryption_application;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	452 frame->type = NGX_QUIC_FT_STOP_SENDING;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	453 frame->u.stop_sending.id = id;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	454 frame->u.stop_sending.error_code = code;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	455
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	456 ngx_quic_queue_frame(qc, frame);
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	457
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	458 return NGX_OK;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	459 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	460
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	461
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	462 static ngx_int_t
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	463 ngx_quic_init_stream(ngx_quic_stream_t *qs)
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	464 {
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	465 ngx_connection_t *c;
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	466 ngx_quic_connection_t *qc;
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	467
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	468 qc = ngx_quic_get_connection(qs->parent);
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	469
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	470 c = qs->connection;
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	471
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	472 if (!qc->streams.initialized) {
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	473 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, 0,
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	474 "quic postpone stream init");
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	475
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	476 ngx_queue_insert_tail(&qc->streams.uninitialized, &qs->queue);
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	477 return NGX_OK;
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	478 }
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	479
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	480 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, 0, "quic init stream");
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	481
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	482 c->listening->handler(c);
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	483
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	484 return NGX_OK;
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	485 }
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	486
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	487
8886 66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	488 ngx_int_t
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	489 ngx_quic_init_streams(ngx_connection_t *c)
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	490 {
8886 66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	491 ngx_int_t rc;
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	492 ngx_quic_connection_t *qc;
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	493
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	494 qc = ngx_quic_get_connection(c);
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	495
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	496 if (qc->streams.initialized) {
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	497 return NGX_OK;
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	498 }
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	499
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	500 rc = ngx_ssl_ocsp_validate(c);
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	501
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	502 if (rc == NGX_ERROR) {
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	503 return NGX_ERROR;
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	504 }
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	505
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	506 if (rc == NGX_AGAIN) {
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	507 c->ssl->handler = ngx_quic_init_streams_handler;
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	508 return NGX_OK;
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	509 }
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	510
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	511 ngx_quic_init_streams_handler(c);
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	512
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	513 return NGX_OK;
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	514 }
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	515
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	516
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	517 static void
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	518 ngx_quic_init_streams_handler(ngx_connection_t *c)
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	519 {
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	520 ngx_queue_t *q;
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	521 ngx_quic_stream_t *qs;
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	522 ngx_quic_connection_t *qc;
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	523
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	524 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, 0, "quic init streams");
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	525
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	526 qc = ngx_quic_get_connection(c);
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	527
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	528 while (!ngx_queue_empty(&qc->streams.uninitialized)) {
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	529 q = ngx_queue_head(&qc->streams.uninitialized);
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	530 ngx_queue_remove(q);
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	531
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	532 qs = ngx_queue_data(q, ngx_quic_stream_t, queue);
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	533
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	534 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, qs->connection->log, 0,
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	535 "quic init postponed stream");
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	536
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	537 qs->connection->listening->handler(qs->connection);
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	538 }
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	539
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	540 qc->streams.initialized = 1;
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	541 }
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	542
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	543
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	544 static ngx_quic_stream_t *
8779 f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	545 ngx_quic_create_stream(ngx_connection_t *c, uint64_t id)
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	546 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	547 ngx_log_t *log;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	548 ngx_pool_t *pool;
8760 baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	549 ngx_connection_t *sc;
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	550 ngx_quic_stream_t *qs;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	551 ngx_pool_cleanup_t *cln;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	552 ngx_quic_connection_t *qc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	553
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	554 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	555 "quic stream id:0x%xL create", id);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	556
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	557 qc = ngx_quic_get_connection(c);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	558
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	559 pool = ngx_create_pool(NGX_DEFAULT_POOL_SIZE, c->log);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	560 if (pool == NULL) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	561 return NULL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	562 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	563
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	564 qs = ngx_pcalloc(pool, sizeof(ngx_quic_stream_t));
225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	565 if (qs == NULL) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	566 ngx_destroy_pool(pool);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	567 return NULL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	568 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	569
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	570 qs->node.key = id;
225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	571 qs->parent = c;
225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	572 qs->id = id;
8782 b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	573 qs->final_size = (uint64_t) -1;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	574
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	575 log = ngx_palloc(pool, sizeof(ngx_log_t));
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	576 if (log == NULL) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	577 ngx_destroy_pool(pool);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	578 return NULL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	579 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	580
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	581 log = c->log;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	582 pool->log = log;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	583
8860 a2cef164a924 QUIC: simplified stream fd initialization. Roman Arutyunyan <arut@nginx.com> parents: 8855 diff changeset	584 sc = ngx_get_connection(c->fd, log);
8760 baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	585 if (sc == NULL) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	586 ngx_destroy_pool(pool);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	587 return NULL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	588 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	589
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	590 qs->connection = sc;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	591
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	592 sc->quic = qs;
8842 486c6a9be111 QUIC: store QUIC connection fd in stream fake connection. Roman Arutyunyan <arut@nginx.com> parents: 8841 diff changeset	593 sc->shared = 1;
8760 baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	594 sc->type = SOCK_STREAM;
baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	595 sc->pool = pool;
baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	596 sc->ssl = c->ssl;
baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	597 sc->sockaddr = c->sockaddr;
baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	598 sc->listening = c->listening;
baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	599 sc->addr_text = c->addr_text;
baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	600 sc->local_sockaddr = c->local_sockaddr;
baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	601 sc->local_socklen = c->local_socklen;
baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	602 sc->number = ngx_atomic_fetch_add(ngx_connection_counter, 1);
8861 630ecd703805 QUIC: set NGX_TCP_NODELAY_DISABLED for fake stream connections. Sergey Kandaurov <pluknet@nginx.com> parents: 8860 diff changeset	603 sc->tcp_nodelay = NGX_TCP_NODELAY_DISABLED;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	604
8760 baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	605 sc->recv = ngx_quic_stream_recv;
baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	606 sc->send = ngx_quic_stream_send;
baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	607 sc->send_chain = ngx_quic_stream_send_chain;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	608
8760 baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	609 sc->read->log = log;
baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	610 sc->write->log = log;
baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	611
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	612 sc->read->handler = ngx_quic_empty_handler;
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	613 sc->write->handler = ngx_quic_empty_handler;
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	614
8760 baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	615 log->connection = sc->number;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	616
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	617 if ((id & NGX_QUIC_STREAM_UNIDIRECTIONAL) == 0
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	618 \|\| (id & NGX_QUIC_STREAM_SERVER_INITIATED))
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	619 {
8760 baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	620 sc->write->ready = 1;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	621 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	622
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	623 if (id & NGX_QUIC_STREAM_UNIDIRECTIONAL) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	624 if (id & NGX_QUIC_STREAM_SERVER_INITIATED) {
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	625 qs->send_max_data = qc->ctp.initial_max_stream_data_uni;
8779 f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	626
f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	627 } else {
f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	628 qs->recv_max_data = qc->tp.initial_max_stream_data_uni;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	629 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	630
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	631 } else {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	632 if (id & NGX_QUIC_STREAM_SERVER_INITIATED) {
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	633 qs->send_max_data = qc->ctp.initial_max_stream_data_bidi_remote;
8779 f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	634 qs->recv_max_data = qc->tp.initial_max_stream_data_bidi_local;
f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	635
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	636 } else {
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	637 qs->send_max_data = qc->ctp.initial_max_stream_data_bidi_local;
8779 f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	638 qs->recv_max_data = qc->tp.initial_max_stream_data_bidi_remote;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	639 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	640 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	641
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	642 qs->recv_window = qs->recv_max_data;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	643
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	644 cln = ngx_pool_cleanup_add(pool, 0);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	645 if (cln == NULL) {
8760 baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	646 ngx_close_connection(sc);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	647 ngx_destroy_pool(pool);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	648 return NULL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	649 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	650
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	651 cln->handler = ngx_quic_stream_cleanup_handler;
8760 baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	652 cln->data = sc;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	653
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	654 ngx_rbtree_insert(&qc->streams.tree, &qs->node);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	655
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	656 return qs;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	657 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	658
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	659
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	660 static void
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	661 ngx_quic_empty_handler(ngx_event_t *ev)
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	662 {
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	663 }
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	664
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	665
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	666 static ssize_t
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	667 ngx_quic_stream_recv(ngx_connection_t c, u_char buf, size_t size)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	668 {
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	669 ssize_t len, n;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	670 ngx_buf_t *b;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	671 ngx_chain_t cl, *ll;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	672 ngx_event_t *rev;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	673 ngx_connection_t *pc;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	674 ngx_quic_stream_t *qs;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	675
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	676 qs = c->quic;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	677 pc = qs->parent;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	678 rev = c->read;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	679
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	680 if (rev->error) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	681 return NGX_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	682 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	683
8782 b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	684 ngx_log_debug3(NGX_LOG_DEBUG_EVENT, c->log, 0,
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	685 "quic stream id:0x%xL recv eof:%d buf:%uz",
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	686 qs->id, rev->pending_eof, size);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	687
8782 b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	688 if (qs->in == NULL \|\| qs->in->buf->sync) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	689 rev->ready = 0;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	690
8782 b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	691 if (qs->recv_offset == qs->final_size) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	692 rev->eof = 1;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	693 return 0;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	694 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	695
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	696 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	697 "quic stream id:0x%xL recv() not ready", qs->id);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	698 return NGX_AGAIN;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	699 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	700
8779 f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	701 len = 0;
f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	702 cl = qs->in;
f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	703
f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	704 for (ll = &cl; ll; ll = &(ll)->next) {
f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	705 b = (*ll)->buf;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	706
8782 b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	707 if (b->sync) {
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	708 /* hole */
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	709 break;
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	710 }
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	711
8779 f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	712 n = ngx_min(b->last - b->pos, (ssize_t) size);
f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	713 buf = ngx_cpymem(buf, b->pos, n);
f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	714
f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	715 len += n;
f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	716 size -= n;
f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	717 b->pos += n;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	718
8779 f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	719 if (b->pos != b->last) {
f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	720 break;
f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	721 }
f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	722 }
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	723
8779 f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	724 qs->in = *ll;
f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	725 *ll = NULL;
f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	726
f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	727 ngx_quic_free_bufs(pc, cl);
f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	728
f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	729 if (qs->in == NULL) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	730 rev->ready = rev->pending_eof;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	731 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	732
8782 b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	733 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, c->log, 0,
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	734 "quic stream id:0x%xL recv len:%z", qs->id, len);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	735
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	736 if (ngx_quic_update_flow(c, qs->recv_offset + len) != NGX_OK) {
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	737 return NGX_ERROR;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	738 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	739
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	740 return len;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	741 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	742
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	743
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	744 static ssize_t
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	745 ngx_quic_stream_send(ngx_connection_t c, u_char buf, size_t size)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	746 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	747 ngx_buf_t b;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	748 ngx_chain_t cl;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	749
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	750 ngx_memzero(&b, sizeof(ngx_buf_t));
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	751
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	752 b.memory = 1;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	753 b.pos = buf;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	754 b.last = buf + size;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	755
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	756 cl.buf = &b;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	757 cl.next = NULL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	758
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	759 if (ngx_quic_stream_send_chain(c, &cl, 0) == NGX_CHAIN_ERROR) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	760 return NGX_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	761 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	762
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	763 if (b.pos == buf) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	764 return NGX_AGAIN;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	765 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	766
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	767 return b.pos - buf;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	768 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	769
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	770
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	771 static ngx_chain_t *
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	772 ngx_quic_stream_send_chain(ngx_connection_t c, ngx_chain_t in, off_t limit)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	773 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	774 size_t n, flow;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	775 ngx_event_t *wev;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	776 ngx_chain_t *cl;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	777 ngx_connection_t *pc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	778 ngx_quic_frame_t *frame;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	779 ngx_quic_stream_t *qs;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	780 ngx_quic_connection_t *qc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	781
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	782 qs = c->quic;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	783 pc = qs->parent;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	784 qc = ngx_quic_get_connection(pc);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	785 wev = c->write;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	786
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	787 if (wev->error) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	788 return NGX_CHAIN_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	789 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	790
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	791 flow = ngx_quic_max_stream_flow(c);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	792 if (flow == 0) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	793 wev->ready = 0;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	794 return in;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	795 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	796
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	797 n = (limit && (size_t) limit < flow) ? (size_t) limit : flow;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	798
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	799 frame = ngx_quic_alloc_frame(pc);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	800 if (frame == NULL) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	801 return NGX_CHAIN_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	802 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	803
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	804 frame->data = ngx_quic_copy_chain(pc, in, n);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	805 if (frame->data == NGX_CHAIN_ERROR) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	806 return NGX_CHAIN_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	807 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	808
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	809 for (n = 0, cl = frame->data; cl; cl = cl->next) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	810 n += ngx_buf_size(cl->buf);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	811 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	812
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	813 while (in && ngx_buf_size(in->buf) == 0) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	814 in = in->next;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	815 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	816
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	817 frame->level = ssl_encryption_application;
8820 4009f120cad4 QUIC: eliminated stream type from ngx_quic_stream_frame_t. Roman Arutyunyan <arut@nginx.com> parents: 8797 diff changeset	818 frame->type = NGX_QUIC_FT_STREAM;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	819 frame->u.stream.off = 1;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	820 frame->u.stream.len = 1;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	821 frame->u.stream.fin = 0;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	822
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	823 frame->u.stream.stream_id = qs->id;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	824 frame->u.stream.offset = c->sent;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	825 frame->u.stream.length = n;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	826
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	827 c->sent += n;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	828 qc->streams.sent += n;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	829
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	830 ngx_quic_queue_frame(qc, frame);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	831
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	832 wev->ready = (n < flow) ? 1 : 0;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	833
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	834 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	835 "quic send_chain sent:%uz", n);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	836
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	837 return in;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	838 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	839
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	840
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	841 static size_t
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	842 ngx_quic_max_stream_flow(ngx_connection_t *c)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	843 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	844 size_t size;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	845 uint64_t sent, unacked;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	846 ngx_quic_stream_t *qs;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	847 ngx_quic_connection_t *qc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	848
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	849 qs = c->quic;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	850 qc = ngx_quic_get_connection(qs->parent);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	851
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	852 size = NGX_QUIC_STREAM_BUFSIZE;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	853 sent = c->sent;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	854 unacked = sent - qs->acked;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	855
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	856 if (qc->streams.send_max_data == 0) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	857 qc->streams.send_max_data = qc->ctp.initial_max_data;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	858 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	859
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	860 if (unacked >= NGX_QUIC_STREAM_BUFSIZE) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	861 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, 0,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	862 "quic send flow hit buffer size");
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	863 return 0;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	864 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	865
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	866 if (unacked + size > NGX_QUIC_STREAM_BUFSIZE) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	867 size = NGX_QUIC_STREAM_BUFSIZE - unacked;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	868 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	869
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	870 if (qc->streams.sent >= qc->streams.send_max_data) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	871 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, 0,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	872 "quic send flow hit MAX_DATA");
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	873 return 0;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	874 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	875
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	876 if (qc->streams.sent + size > qc->streams.send_max_data) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	877 size = qc->streams.send_max_data - qc->streams.sent;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	878 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	879
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	880 if (sent >= qs->send_max_data) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	881 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, 0,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	882 "quic send flow hit MAX_STREAM_DATA");
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	883 return 0;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	884 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	885
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	886 if (sent + size > qs->send_max_data) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	887 size = qs->send_max_data - sent;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	888 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	889
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	890 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	891 "quic send flow:%uz", size);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	892
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	893 return size;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	894 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	895
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	896
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	897 static void
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	898 ngx_quic_stream_cleanup_handler(void *data)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	899 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	900 ngx_connection_t *c = data;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	901
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	902 ngx_connection_t *pc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	903 ngx_quic_frame_t *frame;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	904 ngx_quic_stream_t *qs;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	905 ngx_quic_connection_t *qc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	906
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	907 qs = c->quic;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	908 pc = qs->parent;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	909 qc = ngx_quic_get_connection(pc);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	910
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	911 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	912 "quic stream id:0x%xL cleanup", qs->id);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	913
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	914 ngx_rbtree_delete(&qc->streams.tree, &qs->node);
8779 f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	915 ngx_quic_free_bufs(pc, qs->in);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	916
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	917 if (qc->closing) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	918 /* schedule handler call to continue ngx_quic_close_connection() */
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	919 ngx_post_event(pc->read, &ngx_posted_events);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	920 return;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	921 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	922
8756 e29b7508b8b3 QUIC: avoid sending extra frames in case of error. Vladimir Homutov <vl@nginx.com> parents: 8755 diff changeset	923 if (qc->error) {
e29b7508b8b3 QUIC: avoid sending extra frames in case of error. Vladimir Homutov <vl@nginx.com> parents: 8755 diff changeset	924 goto done;
e29b7508b8b3 QUIC: avoid sending extra frames in case of error. Vladimir Homutov <vl@nginx.com> parents: 8755 diff changeset	925 }
e29b7508b8b3 QUIC: avoid sending extra frames in case of error. Vladimir Homutov <vl@nginx.com> parents: 8755 diff changeset	926
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	927 c->read->pending_eof = 1;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	928
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	929 (void) ngx_quic_update_flow(c, qs->recv_last);
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	930
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	931 if ((qs->id & NGX_QUIC_STREAM_SERVER_INITIATED) == 0
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	932 \|\| (qs->id & NGX_QUIC_STREAM_UNIDIRECTIONAL) == 0)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	933 {
8906 41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	934 if (!c->read->pending_eof && !c->read->error
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	935 && qc->conf->stream_close_code)
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	936 {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	937 frame = ngx_quic_alloc_frame(pc);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	938 if (frame == NULL) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	939 goto done;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	940 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	941
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	942 frame->level = ssl_encryption_application;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	943 frame->type = NGX_QUIC_FT_STOP_SENDING;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	944 frame->u.stop_sending.id = qs->id;
8906 41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	945 frame->u.stop_sending.error_code = qc->conf->stream_close_code;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	946
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	947 ngx_quic_queue_frame(qc, frame);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	948 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	949 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	950
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	951 if ((qs->id & NGX_QUIC_STREAM_SERVER_INITIATED) == 0) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	952 frame = ngx_quic_alloc_frame(pc);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	953 if (frame == NULL) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	954 goto done;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	955 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	956
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	957 frame->level = ssl_encryption_application;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	958 frame->type = NGX_QUIC_FT_MAX_STREAMS;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	959
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	960 if (qs->id & NGX_QUIC_STREAM_UNIDIRECTIONAL) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	961 frame->u.max_streams.limit = ++qc->streams.client_max_streams_uni;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	962 frame->u.max_streams.bidi = 0;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	963
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	964 } else {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	965 frame->u.max_streams.limit = ++qc->streams.client_max_streams_bidi;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	966 frame->u.max_streams.bidi = 1;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	967 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	968
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	969 ngx_quic_queue_frame(qc, frame);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	970
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	971 if (qs->id & NGX_QUIC_STREAM_UNIDIRECTIONAL) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	972 /* do not send fin for client unidirectional streams */
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	973 goto done;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	974 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	975 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	976
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	977 if (c->write->error) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	978 goto done;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	979 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	980
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	981 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	982 "quic stream id:0x%xL send fin", qs->id);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	983
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	984 frame = ngx_quic_alloc_frame(pc);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	985 if (frame == NULL) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	986 goto done;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	987 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	988
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	989 frame->level = ssl_encryption_application;
8820 4009f120cad4 QUIC: eliminated stream type from ngx_quic_stream_frame_t. Roman Arutyunyan <arut@nginx.com> parents: 8797 diff changeset	990 frame->type = NGX_QUIC_FT_STREAM;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	991 frame->u.stream.off = 1;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	992 frame->u.stream.len = 1;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	993 frame->u.stream.fin = 1;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	994
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	995 frame->u.stream.stream_id = qs->id;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	996 frame->u.stream.offset = c->sent;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	997 frame->u.stream.length = 0;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	998
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	999 ngx_quic_queue_frame(qc, frame);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1000
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1001 done:
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1002
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1003 (void) ngx_quic_output(pc);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1004
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1005 if (qc->shutdown) {
8828 a9f6540e61da QUIC: asynchronous shutdown. Roman Arutyunyan <arut@nginx.com> parents: 8827 diff changeset	1006 ngx_post_event(pc->read, &ngx_posted_events);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1007 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1008 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1009
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1010
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1011 ngx_int_t
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1012 ngx_quic_handle_stream_frame(ngx_connection_t c, ngx_quic_header_t pkt,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1013 ngx_quic_frame_t *frame)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1014 {
8782 b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1015 uint64_t last;
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1016 ngx_pool_t *pool;
8784 7d32c3c93678 QUIC: call stream read handler on new data arrival. Roman Arutyunyan <arut@nginx.com> parents: 8783 diff changeset	1017 ngx_event_t *rev;
8782 b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1018 ngx_connection_t *sc;
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1019 ngx_quic_stream_t *qs;
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1020 ngx_quic_connection_t *qc;
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1021 ngx_quic_stream_frame_t *f;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1022
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1023 qc = ngx_quic_get_connection(c);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1024 f = &frame->u.stream;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1025
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1026 if ((f->stream_id & NGX_QUIC_STREAM_UNIDIRECTIONAL)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1027 && (f->stream_id & NGX_QUIC_STREAM_SERVER_INITIATED))
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1028 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1029 qc->error = NGX_QUIC_ERR_STREAM_STATE_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1030 return NGX_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1031 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1032
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1033 /* no overflow since both values are 62-bit */
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1034 last = f->offset + f->length;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1035
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1036 qs = ngx_quic_find_stream(&qc->streams.tree, f->stream_id);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1037
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1038 if (qs == NULL) {
225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1039 qs = ngx_quic_create_client_stream(c, f->stream_id);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1040
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1041 if (qs == NULL) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1042 return NGX_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1043 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1044
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1045 if (qs == NGX_QUIC_STREAM_GONE) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1046 return NGX_OK;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1047 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1048
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1049 sc = qs->connection;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1050
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1051 if (ngx_quic_control_flow(sc, last) != NGX_OK) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1052 goto cleanup;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1053 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1054
8782 b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1055 if (f->fin) {
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1056 sc->read->pending_eof = 1;
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1057 qs->final_size = last;
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1058 }
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1059
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1060 if (f->offset == 0) {
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1061 sc->read->ready = 1;
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1062 }
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1063
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1064 if (ngx_quic_order_bufs(c, &qs->in, frame->data, f->offset) != NGX_OK) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1065 goto cleanup;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1066 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1067
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	1068 return ngx_quic_init_stream(qs);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1069 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1070
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1071 sc = qs->connection;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1072
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1073 rev = sc->read;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1074
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1075 if (rev->error) {
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1076 return NGX_OK;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1077 }
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1078
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1079 if (ngx_quic_control_flow(sc, last) != NGX_OK) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1080 return NGX_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1081 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1082
8782 b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1083 if (qs->final_size != (uint64_t) -1 && last > qs->final_size) {
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1084 qc->error = NGX_QUIC_ERR_FINAL_SIZE_ERROR;
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1085 return NGX_ERROR;
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1086 }
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1087
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1088 if (last <= qs->recv_offset) {
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1089 return NGX_OK;
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1090 }
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1091
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1092 if (f->offset < qs->recv_offset) {
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1093 ngx_quic_trim_bufs(frame->data, qs->recv_offset - f->offset);
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1094 f->offset = qs->recv_offset;
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1095 }
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1096
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1097 if (f->fin) {
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1098 if (qs->final_size != (uint64_t) -1 && qs->final_size != last) {
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1099 qc->error = NGX_QUIC_ERR_FINAL_SIZE_ERROR;
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1100 return NGX_ERROR;
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1101 }
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1102
8783 60c6e8d8d3ae QUIC: make sure stream data size is lower than final size. Roman Arutyunyan <arut@nginx.com> parents: 8782 diff changeset	1103 if (qs->recv_last > last) {
60c6e8d8d3ae QUIC: make sure stream data size is lower than final size. Roman Arutyunyan <arut@nginx.com> parents: 8782 diff changeset	1104 qc->error = NGX_QUIC_ERR_FINAL_SIZE_ERROR;
60c6e8d8d3ae QUIC: make sure stream data size is lower than final size. Roman Arutyunyan <arut@nginx.com> parents: 8782 diff changeset	1105 return NGX_ERROR;
60c6e8d8d3ae QUIC: make sure stream data size is lower than final size. Roman Arutyunyan <arut@nginx.com> parents: 8782 diff changeset	1106 }
60c6e8d8d3ae QUIC: make sure stream data size is lower than final size. Roman Arutyunyan <arut@nginx.com> parents: 8782 diff changeset	1107
8784 7d32c3c93678 QUIC: call stream read handler on new data arrival. Roman Arutyunyan <arut@nginx.com> parents: 8783 diff changeset	1108 rev->pending_eof = 1;
8782 b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1109 qs->final_size = last;
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1110 }
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1111
8784 7d32c3c93678 QUIC: call stream read handler on new data arrival. Roman Arutyunyan <arut@nginx.com> parents: 8783 diff changeset	1112 if (ngx_quic_order_bufs(c, &qs->in, frame->data,
7d32c3c93678 QUIC: call stream read handler on new data arrival. Roman Arutyunyan <arut@nginx.com> parents: 8783 diff changeset	1113 f->offset - qs->recv_offset)
7d32c3c93678 QUIC: call stream read handler on new data arrival. Roman Arutyunyan <arut@nginx.com> parents: 8783 diff changeset	1114 != NGX_OK)
7d32c3c93678 QUIC: call stream read handler on new data arrival. Roman Arutyunyan <arut@nginx.com> parents: 8783 diff changeset	1115 {
7d32c3c93678 QUIC: call stream read handler on new data arrival. Roman Arutyunyan <arut@nginx.com> parents: 8783 diff changeset	1116 return NGX_ERROR;
7d32c3c93678 QUIC: call stream read handler on new data arrival. Roman Arutyunyan <arut@nginx.com> parents: 8783 diff changeset	1117 }
7d32c3c93678 QUIC: call stream read handler on new data arrival. Roman Arutyunyan <arut@nginx.com> parents: 8783 diff changeset	1118
7d32c3c93678 QUIC: call stream read handler on new data arrival. Roman Arutyunyan <arut@nginx.com> parents: 8783 diff changeset	1119 if (f->offset == qs->recv_offset) {
7d32c3c93678 QUIC: call stream read handler on new data arrival. Roman Arutyunyan <arut@nginx.com> parents: 8783 diff changeset	1120 rev->ready = 1;
7d32c3c93678 QUIC: call stream read handler on new data arrival. Roman Arutyunyan <arut@nginx.com> parents: 8783 diff changeset	1121
7d32c3c93678 QUIC: call stream read handler on new data arrival. Roman Arutyunyan <arut@nginx.com> parents: 8783 diff changeset	1122 if (rev->active) {
7d32c3c93678 QUIC: call stream read handler on new data arrival. Roman Arutyunyan <arut@nginx.com> parents: 8783 diff changeset	1123 rev->handler(rev);
7d32c3c93678 QUIC: call stream read handler on new data arrival. Roman Arutyunyan <arut@nginx.com> parents: 8783 diff changeset	1124 }
7d32c3c93678 QUIC: call stream read handler on new data arrival. Roman Arutyunyan <arut@nginx.com> parents: 8783 diff changeset	1125 }
7d32c3c93678 QUIC: call stream read handler on new data arrival. Roman Arutyunyan <arut@nginx.com> parents: 8783 diff changeset	1126
7d32c3c93678 QUIC: call stream read handler on new data arrival. Roman Arutyunyan <arut@nginx.com> parents: 8783 diff changeset	1127 return NGX_OK;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1128
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1129 cleanup:
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1130
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1131 pool = sc->pool;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1132
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1133 ngx_close_connection(sc);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1134 ngx_destroy_pool(pool);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1135
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1136 return NGX_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1137 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1138
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1139
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1140 ngx_int_t
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1141 ngx_quic_handle_max_data_frame(ngx_connection_t *c,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1142 ngx_quic_max_data_frame_t *f)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1143 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1144 ngx_event_t *wev;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1145 ngx_rbtree_t *tree;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1146 ngx_rbtree_node_t *node;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1147 ngx_quic_stream_t *qs;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1148 ngx_quic_connection_t *qc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1149
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1150 qc = ngx_quic_get_connection(c);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1151 tree = &qc->streams.tree;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1152
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1153 if (f->max_data <= qc->streams.send_max_data) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1154 return NGX_OK;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1155 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1156
8841 1f7f98638dc2 QUIC: fixed null pointer dereference in MAX_DATA handler. Mariano Di Martino <mariano.dimartino@uhasselt.be> parents: 8828 diff changeset	1157 if (tree->root != tree->sentinel
1f7f98638dc2 QUIC: fixed null pointer dereference in MAX_DATA handler. Mariano Di Martino <mariano.dimartino@uhasselt.be> parents: 8828 diff changeset	1158 && qc->streams.sent >= qc->streams.send_max_data)
1f7f98638dc2 QUIC: fixed null pointer dereference in MAX_DATA handler. Mariano Di Martino <mariano.dimartino@uhasselt.be> parents: 8828 diff changeset	1159 {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1160
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1161 for (node = ngx_rbtree_min(tree->root, tree->sentinel);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1162 node;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1163 node = ngx_rbtree_next(tree, node))
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1164 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1165 qs = (ngx_quic_stream_t *) node;
8760 baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	1166 wev = qs->connection->write;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1167
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1168 if (wev->active) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1169 wev->ready = 1;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1170 ngx_post_event(wev, &ngx_posted_events);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1171 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1172 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1173 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1174
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1175 qc->streams.send_max_data = f->max_data;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1176
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1177 return NGX_OK;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1178 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1179
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1180
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1181 ngx_int_t
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1182 ngx_quic_handle_streams_blocked_frame(ngx_connection_t *c,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1183 ngx_quic_header_t pkt, ngx_quic_streams_blocked_frame_t f)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1184 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1185 return NGX_OK;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1186 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1187
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1188
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1189 ngx_int_t
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1190 ngx_quic_handle_stream_data_blocked_frame(ngx_connection_t *c,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1191 ngx_quic_header_t pkt, ngx_quic_stream_data_blocked_frame_t f)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1192 {
8779 f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	1193 uint64_t limit;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1194 ngx_quic_frame_t *frame;
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1195 ngx_quic_stream_t *qs;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1196 ngx_quic_connection_t *qc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1197
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1198 qc = ngx_quic_get_connection(c);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1199
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1200 if ((f->id & NGX_QUIC_STREAM_UNIDIRECTIONAL)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1201 && (f->id & NGX_QUIC_STREAM_SERVER_INITIATED))
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1202 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1203 qc->error = NGX_QUIC_ERR_STREAM_STATE_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1204 return NGX_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1205 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1206
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1207 qs = ngx_quic_find_stream(&qc->streams.tree, f->id);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1208
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1209 if (qs == NULL) {
225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1210 qs = ngx_quic_create_client_stream(c, f->id);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1211
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1212 if (qs == NULL) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1213 return NGX_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1214 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1215
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1216 if (qs == NGX_QUIC_STREAM_GONE) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1217 return NGX_OK;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1218 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1219
8779 f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	1220 limit = qs->recv_max_data;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1221
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	1222 if (ngx_quic_init_stream(qs) != NGX_OK) {
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	1223 return NGX_ERROR;
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	1224 }
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1225
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1226 } else {
8779 f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	1227 limit = qs->recv_max_data;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1228 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1229
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1230 frame = ngx_quic_alloc_frame(c);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1231 if (frame == NULL) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1232 return NGX_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1233 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1234
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1235 frame->level = pkt->level;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1236 frame->type = NGX_QUIC_FT_MAX_STREAM_DATA;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1237 frame->u.max_stream_data.id = f->id;
8779 f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	1238 frame->u.max_stream_data.limit = limit;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1239
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1240 ngx_quic_queue_frame(qc, frame);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1241
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1242 return NGX_OK;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1243 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1244
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1245
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1246 ngx_int_t
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1247 ngx_quic_handle_max_stream_data_frame(ngx_connection_t *c,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1248 ngx_quic_header_t pkt, ngx_quic_max_stream_data_frame_t f)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1249 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1250 uint64_t sent;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1251 ngx_event_t *wev;
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1252 ngx_quic_stream_t *qs;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1253 ngx_quic_connection_t *qc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1254
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1255 qc = ngx_quic_get_connection(c);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1256
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1257 if ((f->id & NGX_QUIC_STREAM_UNIDIRECTIONAL)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1258 && (f->id & NGX_QUIC_STREAM_SERVER_INITIATED) == 0)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1259 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1260 qc->error = NGX_QUIC_ERR_STREAM_STATE_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1261 return NGX_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1262 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1263
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1264 qs = ngx_quic_find_stream(&qc->streams.tree, f->id);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1265
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1266 if (qs == NULL) {
225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1267 qs = ngx_quic_create_client_stream(c, f->id);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1268
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1269 if (qs == NULL) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1270 return NGX_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1271 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1272
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1273 if (qs == NGX_QUIC_STREAM_GONE) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1274 return NGX_OK;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1275 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1276
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1277 if (f->limit > qs->send_max_data) {
225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1278 qs->send_max_data = f->limit;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1279 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1280
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	1281 return ngx_quic_init_stream(qs);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1282 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1283
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1284 if (f->limit <= qs->send_max_data) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1285 return NGX_OK;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1286 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1287
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1288 sent = qs->connection->sent;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1289
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1290 if (sent >= qs->send_max_data) {
225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1291 wev = qs->connection->write;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1292
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1293 if (wev->active) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1294 wev->ready = 1;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1295 ngx_post_event(wev, &ngx_posted_events);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1296 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1297 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1298
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1299 qs->send_max_data = f->limit;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1300
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1301 return NGX_OK;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1302 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1303
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1304
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1305 ngx_int_t
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1306 ngx_quic_handle_reset_stream_frame(ngx_connection_t *c,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1307 ngx_quic_header_t pkt, ngx_quic_reset_stream_frame_t f)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1308 {
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1309 ngx_pool_t *pool;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1310 ngx_event_t *rev;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1311 ngx_connection_t *sc;
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1312 ngx_quic_stream_t *qs;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1313 ngx_quic_connection_t *qc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1314
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1315 qc = ngx_quic_get_connection(c);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1316
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1317 if ((f->id & NGX_QUIC_STREAM_UNIDIRECTIONAL)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1318 && (f->id & NGX_QUIC_STREAM_SERVER_INITIATED))
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1319 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1320 qc->error = NGX_QUIC_ERR_STREAM_STATE_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1321 return NGX_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1322 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1323
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1324 qs = ngx_quic_find_stream(&qc->streams.tree, f->id);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1325
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1326 if (qs == NULL) {
225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1327 qs = ngx_quic_create_client_stream(c, f->id);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1328
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1329 if (qs == NULL) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1330 return NGX_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1331 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1332
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1333 if (qs == NGX_QUIC_STREAM_GONE) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1334 return NGX_OK;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1335 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1336
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1337 sc = qs->connection;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1338
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1339 rev = sc->read;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1340 rev->error = 1;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1341 rev->ready = 1;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1342
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1343 if (ngx_quic_control_flow(sc, f->final_size) != NGX_OK) {
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1344 goto cleanup;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1345 }
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1346
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1347 qs->final_size = f->final_size;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1348
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1349 if (ngx_quic_update_flow(sc, qs->final_size) != NGX_OK) {
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1350 goto cleanup;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1351 }
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1352
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	1353 return ngx_quic_init_stream(qs);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1354 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1355
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1356 sc = qs->connection;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1357
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1358 rev = sc->read;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1359 rev->error = 1;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1360 rev->ready = 1;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1361
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1362 if (ngx_quic_control_flow(sc, f->final_size) != NGX_OK) {
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1363 return NGX_ERROR;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1364 }
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1365
8782 b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1366 if (qs->final_size != (uint64_t) -1 && qs->final_size != f->final_size) {
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1367 qc->error = NGX_QUIC_ERR_FINAL_SIZE_ERROR;
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1368 return NGX_ERROR;
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1369 }
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1370
8783 60c6e8d8d3ae QUIC: make sure stream data size is lower than final size. Roman Arutyunyan <arut@nginx.com> parents: 8782 diff changeset	1371 if (qs->recv_last > f->final_size) {
60c6e8d8d3ae QUIC: make sure stream data size is lower than final size. Roman Arutyunyan <arut@nginx.com> parents: 8782 diff changeset	1372 qc->error = NGX_QUIC_ERR_FINAL_SIZE_ERROR;
60c6e8d8d3ae QUIC: make sure stream data size is lower than final size. Roman Arutyunyan <arut@nginx.com> parents: 8782 diff changeset	1373 return NGX_ERROR;
60c6e8d8d3ae QUIC: make sure stream data size is lower than final size. Roman Arutyunyan <arut@nginx.com> parents: 8782 diff changeset	1374 }
60c6e8d8d3ae QUIC: make sure stream data size is lower than final size. Roman Arutyunyan <arut@nginx.com> parents: 8782 diff changeset	1375
8782 b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1376 qs->final_size = f->final_size;
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1377
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1378 if (ngx_quic_update_flow(sc, qs->final_size) != NGX_OK) {
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1379 return NGX_ERROR;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1380 }
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1381
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1382 if (rev->active) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1383 rev->handler(rev);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1384 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1385
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1386 return NGX_OK;
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1387
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1388 cleanup:
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1389
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1390 pool = sc->pool;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1391
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1392 ngx_close_connection(sc);
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1393 ngx_destroy_pool(pool);
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1394
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1395 return NGX_ERROR;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1396 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1397
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1398
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1399 ngx_int_t
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1400 ngx_quic_handle_stop_sending_frame(ngx_connection_t *c,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1401 ngx_quic_header_t pkt, ngx_quic_stop_sending_frame_t f)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1402 {
8876 1ead7d64e993 QUIC: send RESET_STREAM in response to STOP_SENDING. Roman Arutyunyan <arut@nginx.com> parents: 8875 diff changeset	1403 ngx_pool_t *pool;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1404 ngx_event_t *wev;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1405 ngx_connection_t *sc;
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1406 ngx_quic_stream_t *qs;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1407 ngx_quic_connection_t *qc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1408
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1409 qc = ngx_quic_get_connection(c);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1410
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1411 if ((f->id & NGX_QUIC_STREAM_UNIDIRECTIONAL)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1412 && (f->id & NGX_QUIC_STREAM_SERVER_INITIATED) == 0)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1413 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1414 qc->error = NGX_QUIC_ERR_STREAM_STATE_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1415 return NGX_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1416 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1417
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1418 qs = ngx_quic_find_stream(&qc->streams.tree, f->id);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1419
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1420 if (qs == NULL) {
225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1421 qs = ngx_quic_create_client_stream(c, f->id);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1422
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1423 if (qs == NULL) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1424 return NGX_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1425 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1426
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1427 if (qs == NGX_QUIC_STREAM_GONE) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1428 return NGX_OK;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1429 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1430
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1431 sc = qs->connection;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1432
8876 1ead7d64e993 QUIC: send RESET_STREAM in response to STOP_SENDING. Roman Arutyunyan <arut@nginx.com> parents: 8875 diff changeset	1433 if (ngx_quic_reset_stream(sc, f->error_code) != NGX_OK) {
1ead7d64e993 QUIC: send RESET_STREAM in response to STOP_SENDING. Roman Arutyunyan <arut@nginx.com> parents: 8875 diff changeset	1434 pool = sc->pool;
1ead7d64e993 QUIC: send RESET_STREAM in response to STOP_SENDING. Roman Arutyunyan <arut@nginx.com> parents: 8875 diff changeset	1435
1ead7d64e993 QUIC: send RESET_STREAM in response to STOP_SENDING. Roman Arutyunyan <arut@nginx.com> parents: 8875 diff changeset	1436 ngx_close_connection(sc);
1ead7d64e993 QUIC: send RESET_STREAM in response to STOP_SENDING. Roman Arutyunyan <arut@nginx.com> parents: 8875 diff changeset	1437 ngx_destroy_pool(pool);
1ead7d64e993 QUIC: send RESET_STREAM in response to STOP_SENDING. Roman Arutyunyan <arut@nginx.com> parents: 8875 diff changeset	1438
1ead7d64e993 QUIC: send RESET_STREAM in response to STOP_SENDING. Roman Arutyunyan <arut@nginx.com> parents: 8875 diff changeset	1439 return NGX_ERROR;
1ead7d64e993 QUIC: send RESET_STREAM in response to STOP_SENDING. Roman Arutyunyan <arut@nginx.com> parents: 8875 diff changeset	1440 }
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1441
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	1442 return ngx_quic_init_stream(qs);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1443 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1444
8876 1ead7d64e993 QUIC: send RESET_STREAM in response to STOP_SENDING. Roman Arutyunyan <arut@nginx.com> parents: 8875 diff changeset	1445 if (ngx_quic_reset_stream(qs->connection, f->error_code) != NGX_OK) {
1ead7d64e993 QUIC: send RESET_STREAM in response to STOP_SENDING. Roman Arutyunyan <arut@nginx.com> parents: 8875 diff changeset	1446 return NGX_ERROR;
1ead7d64e993 QUIC: send RESET_STREAM in response to STOP_SENDING. Roman Arutyunyan <arut@nginx.com> parents: 8875 diff changeset	1447 }
1ead7d64e993 QUIC: send RESET_STREAM in response to STOP_SENDING. Roman Arutyunyan <arut@nginx.com> parents: 8875 diff changeset	1448
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1449 wev = qs->connection->write;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1450
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1451 if (wev->active) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1452 wev->handler(wev);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1453 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1454
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1455 return NGX_OK;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1456 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1457
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1458
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1459 ngx_int_t
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1460 ngx_quic_handle_max_streams_frame(ngx_connection_t *c,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1461 ngx_quic_header_t pkt, ngx_quic_max_streams_frame_t f)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1462 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1463 ngx_quic_connection_t *qc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1464
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1465 qc = ngx_quic_get_connection(c);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1466
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1467 if (f->bidi) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1468 if (qc->streams.server_max_streams_bidi < f->limit) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1469 qc->streams.server_max_streams_bidi = f->limit;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1470
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1471 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1472 "quic max_streams_bidi:%uL", f->limit);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1473 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1474
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1475 } else {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1476 if (qc->streams.server_max_streams_uni < f->limit) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1477 qc->streams.server_max_streams_uni = f->limit;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1478
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1479 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1480 "quic max_streams_uni:%uL", f->limit);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1481 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1482 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1483
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1484 return NGX_OK;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1485 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1486
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1487
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1488 void
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1489 ngx_quic_handle_stream_ack(ngx_connection_t c, ngx_quic_frame_t f)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1490 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1491 uint64_t sent, unacked;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1492 ngx_event_t *wev;
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1493 ngx_quic_stream_t *qs;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1494 ngx_quic_connection_t *qc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1495
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1496 qc = ngx_quic_get_connection(c);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1497
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1498 qs = ngx_quic_find_stream(&qc->streams.tree, f->u.stream.stream_id);
225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1499 if (qs == NULL) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1500 return;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1501 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1502
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1503 wev = qs->connection->write;
225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1504 sent = qs->connection->sent;
225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1505 unacked = sent - qs->acked;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1506
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1507 if (unacked >= NGX_QUIC_STREAM_BUFSIZE && wev->active) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1508 wev->ready = 1;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1509 ngx_post_event(wev, &ngx_posted_events);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1510 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1511
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1512 qs->acked += f->u.stream.length;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1513
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1514 ngx_log_debug3(NGX_LOG_DEBUG_EVENT, qs->connection->log, 0,
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1515 "quic stream ack len:%uL acked:%uL unacked:%uL",
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1516 f->u.stream.length, qs->acked, sent - qs->acked);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1517 }
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1518
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1519
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1520 static ngx_int_t
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1521 ngx_quic_control_flow(ngx_connection_t *c, uint64_t last)
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1522 {
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1523 uint64_t len;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1524 ngx_event_t *rev;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1525 ngx_quic_stream_t *qs;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1526 ngx_quic_connection_t *qc;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1527
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1528 rev = c->read;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1529 qs = c->quic;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1530 qc = ngx_quic_get_connection(qs->parent);
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1531
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1532 if (last <= qs->recv_last) {
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1533 return NGX_OK;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1534 }
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1535
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1536 len = last - qs->recv_last;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1537
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1538 ngx_log_debug4(NGX_LOG_DEBUG_EVENT, c->log, 0,
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1539 "quic flow control msd:%uL/%uL md:%uL/%uL",
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1540 last, qs->recv_max_data, qc->streams.recv_last + len,
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1541 qc->streams.recv_max_data);
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1542
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1543 qs->recv_last += len;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1544
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1545 if (!rev->error && qs->recv_last > qs->recv_max_data) {
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1546 qc->error = NGX_QUIC_ERR_FLOW_CONTROL_ERROR;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1547 return NGX_ERROR;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1548 }
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1549
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1550 qc->streams.recv_last += len;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1551
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1552 if (qc->streams.recv_last > qc->streams.recv_max_data) {
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1553 qc->error = NGX_QUIC_ERR_FLOW_CONTROL_ERROR;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1554 return NGX_ERROR;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1555 }
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1556
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1557 return NGX_OK;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1558 }
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1559
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1560
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1561 static ngx_int_t
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1562 ngx_quic_update_flow(ngx_connection_t *c, uint64_t last)
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1563 {
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1564 uint64_t len;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1565 ngx_event_t *rev;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1566 ngx_connection_t *pc;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1567 ngx_quic_frame_t *frame;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1568 ngx_quic_stream_t *qs;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1569 ngx_quic_connection_t *qc;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1570
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1571 rev = c->read;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1572 qs = c->quic;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1573 pc = qs->parent;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1574 qc = ngx_quic_get_connection(pc);
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1575
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1576 if (last <= qs->recv_offset) {
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1577 return NGX_OK;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1578 }
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1579
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1580 len = last - qs->recv_offset;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1581
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1582 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1583 "quic flow update %uL", last);
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1584
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1585 qs->recv_offset += len;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1586
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1587 if (!rev->pending_eof && !rev->error
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1588 && qs->recv_max_data <= qs->recv_offset + qs->recv_window / 2)
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1589 {
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1590 qs->recv_max_data = qs->recv_offset + qs->recv_window;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1591
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1592 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1593 "quic flow update msd:%uL", qs->recv_max_data);
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1594
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1595 frame = ngx_quic_alloc_frame(pc);
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1596 if (frame == NULL) {
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1597 return NGX_ERROR;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1598 }
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1599
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1600 frame->level = ssl_encryption_application;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1601 frame->type = NGX_QUIC_FT_MAX_STREAM_DATA;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1602 frame->u.max_stream_data.id = qs->id;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1603 frame->u.max_stream_data.limit = qs->recv_max_data;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1604
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1605 ngx_quic_queue_frame(qc, frame);
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1606 }
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1607
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1608 qc->streams.recv_offset += len;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1609
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1610 if (qc->streams.recv_max_data
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1611 <= qc->streams.recv_offset + qc->streams.recv_window / 2)
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1612 {
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1613 qc->streams.recv_max_data = qc->streams.recv_offset
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1614 + qc->streams.recv_window;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1615
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1616 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, pc->log, 0,
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1617 "quic flow update md:%uL", qc->streams.recv_max_data);
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1618
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1619 frame = ngx_quic_alloc_frame(pc);
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1620 if (frame == NULL) {
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1621 return NGX_ERROR;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1622 }
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1623
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1624 frame->level = ssl_encryption_application;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1625 frame->type = NGX_QUIC_FT_MAX_DATA;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1626 frame->u.max_data.max_data = qc->streams.recv_max_data;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1627
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1628 ngx_quic_queue_frame(qc, frame);
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1629 }
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1630
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1631 return NGX_OK;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1632 }
8855 9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1633
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1634
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1635 ngx_int_t
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1636 ngx_quic_handle_read_event(ngx_event_t *rev, ngx_uint_t flags)
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1637 {
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1638 if (!rev->active && !rev->ready) {
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1639 rev->active = 1;
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1640
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1641 } else if (rev->active && (rev->ready \|\| (flags & NGX_CLOSE_EVENT))) {
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1642 rev->active = 0;
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1643 }
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1644
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1645 return NGX_OK;
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1646 }
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1647
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1648
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1649 ngx_int_t
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1650 ngx_quic_handle_write_event(ngx_event_t *wev, size_t lowat)
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1651 {
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1652 if (!wev->active && !wev->ready) {
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1653 wev->active = 1;
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1654
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1655 } else if (wev->active && wev->ready) {
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1656 wev->active = 0;
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1657 }
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1658
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1659 return NGX_OK;
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1660 }

Mercurial > hg > nginx

annotate src/event/quic/ngx_event_quic_streams.c @ 8906:41caf5410110 quic