nginx: src/event/quic/ngx_event_quic

annotate src/event/quic/ngx_event_quic_streams.c @ 9065:2ee6f9729739 quic

QUIC: set stream error flag on reset. Now, when RESET_STREAM is sent or received, or when streams are closed, stream connection error flag is set. Previously, only stream state was changed, which resulted in setting the error flag only after calling recv()/send()/send_chain(). However, there are cases when none of these functions is called, but it's still important to know if the stream is being closed. For example, when an HTTP/3 request stream is blocked on insert count, receiving RESET_STREAM should trigger stream closure, which was not the case. The change also fixes ngx_http_upstream_check_broken_connection() and ngx_http_test_reading() with QUIC streams.

author	Roman Arutyunyan <arut@nginx.com>
date	Tue, 10 Jan 2023 17:42:40 +0400
parents	35e27117b593
children	03897c45798e

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
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	16 static ngx_int_t ngx_quic_do_reset_stream(ngx_quic_stream_t *qs,
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	17 ngx_uint_t err);
8938 23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	18 static ngx_int_t ngx_quic_shutdown_stream_send(ngx_connection_t *c);
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	19 static ngx_int_t ngx_quic_shutdown_stream_recv(ngx_connection_t *c);
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	20 static ngx_quic_stream_t ngx_quic_get_stream(ngx_connection_t c, uint64_t id);
8906 41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	21 static ngx_int_t ngx_quic_reject_stream(ngx_connection_t *c, uint64_t id);
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	22 static void ngx_quic_init_stream_handler(ngx_event_t *ev);
8886 66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	23 static void ngx_quic_init_streams_handler(ngx_connection_t *c);
9058 b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9053 diff changeset	24 static ngx_int_t ngx_quic_do_init_streams(ngx_connection_t *c);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	25 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	26 uint64_t id);
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	27 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	28 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	29 size_t size);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	30 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	31 size_t size);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	32 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	33 ngx_chain_t *in, off_t limit);
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	34 static ngx_int_t ngx_quic_stream_flush(ngx_quic_stream_t *qs);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	35 static void ngx_quic_stream_cleanup_handler(void *data);
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	36 static ngx_int_t ngx_quic_close_stream(ngx_quic_stream_t *qs);
9051 37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	37 static ngx_int_t ngx_quic_can_shutdown(ngx_connection_t *c);
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	38 static ngx_int_t ngx_quic_control_flow(ngx_quic_stream_t *qs, uint64_t last);
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	39 static ngx_int_t ngx_quic_update_flow(ngx_quic_stream_t *qs, uint64_t last);
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	40 static ngx_int_t ngx_quic_update_max_stream_data(ngx_quic_stream_t *qs);
8909 d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	41 static ngx_int_t ngx_quic_update_max_data(ngx_connection_t *c);
8993 7626aa7a2156 QUIC: stream event setting function. Roman Arutyunyan <arut@nginx.com> parents: 8990 diff changeset	42 static void ngx_quic_set_event(ngx_event_t *ev);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	43
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	44
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	45 ngx_connection_t *
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	46 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	47 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	48 uint64_t id;
8988 6434160b4b78 QUIC: allowed main QUIC connection for some operations. Roman Arutyunyan <arut@nginx.com> parents: 8968 diff changeset	49 ngx_connection_t *pc;
6434160b4b78 QUIC: allowed main QUIC connection for some operations. Roman Arutyunyan <arut@nginx.com> parents: 8968 diff changeset	50 ngx_quic_stream_t *nqs;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	51 ngx_quic_connection_t *qc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	52
8988 6434160b4b78 QUIC: allowed main QUIC connection for some operations. Roman Arutyunyan <arut@nginx.com> parents: 8968 diff changeset	53 pc = c->quic ? c->quic->parent : c;
6434160b4b78 QUIC: allowed main QUIC connection for some operations. Roman Arutyunyan <arut@nginx.com> parents: 8968 diff changeset	54 qc = ngx_quic_get_connection(pc);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	55
9051 37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	56 if (qc->closing) {
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	57 return NULL;
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	58 }
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	59
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	60 if (bidi) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	61 if (qc->streams.server_streams_bidi
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	62 >= qc->streams.server_max_streams_bidi)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	63 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	64 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	65 "quic too many server bidi streams:%uL",
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	66 qc->streams.server_streams_bidi);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	67 return NULL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	68 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	69
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	70 id = (qc->streams.server_streams_bidi << 2)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	71 \| NGX_QUIC_STREAM_SERVER_INITIATED;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	72
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	73 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	74 "quic creating server bidi stream"
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	75 " streams:%uL max:%uL id:0x%xL",
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	76 qc->streams.server_streams_bidi,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	77 qc->streams.server_max_streams_bidi, id);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	78
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	79 qc->streams.server_streams_bidi++;
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 } else {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	82 if (qc->streams.server_streams_uni
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	83 >= qc->streams.server_max_streams_uni)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	84 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	85 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	86 "quic too many server uni streams:%uL",
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 return NULL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	89 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	90
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	91 id = (qc->streams.server_streams_uni << 2)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	92 \| NGX_QUIC_STREAM_SERVER_INITIATED
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	93 \| NGX_QUIC_STREAM_UNIDIRECTIONAL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	94
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	95 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	96 "quic creating server uni stream"
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	97 " streams:%uL max:%uL id:0x%xL",
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	98 qc->streams.server_streams_uni,
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	99 qc->streams.server_max_streams_uni, id);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	100
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	101 qc->streams.server_streams_uni++;
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
8988 6434160b4b78 QUIC: allowed main QUIC connection for some operations. Roman Arutyunyan <arut@nginx.com> parents: 8968 diff changeset	104 nqs = ngx_quic_create_stream(pc, id);
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	105 if (nqs == NULL) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	106 return NULL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	107 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	108
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	109 return nqs->connection;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	110 }
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
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	113 void
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	114 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	115 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	116 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	117 ngx_rbtree_node_t **p;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	118 ngx_quic_stream_t qn, qnt;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	119
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	120 for ( ;; ) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	121 qn = (ngx_quic_stream_t *) node;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	122 qnt = (ngx_quic_stream_t *) temp;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	123
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	124 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	125
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	126 if (*p == sentinel) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	127 break;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	128 }
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 temp = *p;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	131 }
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 *p = node;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	134 node->parent = temp;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	135 node->left = sentinel;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	136 node->right = sentinel;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	137 ngx_rbt_red(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
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	140
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	141 ngx_quic_stream_t *
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	142 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	143 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	144 ngx_rbtree_node_t node, sentinel;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	145 ngx_quic_stream_t *qn;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	146
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	147 node = rbtree->root;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	148 sentinel = rbtree->sentinel;
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 while (node != sentinel) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	151 qn = (ngx_quic_stream_t *) node;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	152
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	153 if (id == qn->id) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	154 return qn;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	155 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	156
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	157 node = (id < qn->id) ? node->left : node->right;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	158 }
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 return NULL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	161 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	162
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	163
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	164 ngx_int_t
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	165 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	166 {
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	167 ngx_pool_t *pool;
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	168 ngx_queue_t *q;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	169 ngx_rbtree_t *tree;
9051 37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	170 ngx_connection_t *sc;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	171 ngx_rbtree_node_t *node;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	172 ngx_quic_stream_t *qs;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	173
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	174 while (!ngx_queue_empty(&qc->streams.uninitialized)) {
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	175 q = ngx_queue_head(&qc->streams.uninitialized);
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	176 ngx_queue_remove(q);
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	177
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	178 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	179 pool = qs->connection->pool;
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	180
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	181 ngx_close_connection(qs->connection);
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	182 ngx_destroy_pool(pool);
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	183 }
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	184
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	185 tree = &qc->streams.tree;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	186
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	187 if (tree->root == tree->sentinel) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	188 return NGX_OK;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	189 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	190
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	191 node = ngx_rbtree_min(tree->root, tree->sentinel);
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	192
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	193 while (node) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	194 qs = (ngx_quic_stream_t *) node;
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	195 node = ngx_rbtree_next(tree, node);
9051 37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	196 sc = qs->connection;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	197
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	198 qs->recv_state = NGX_QUIC_STREAM_RECV_RESET_RECVD;
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	199 qs->send_state = NGX_QUIC_STREAM_SEND_RESET_SENT;
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	200
9051 37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	201 if (sc == NULL) {
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	202 ngx_quic_close_stream(qs);
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	203 continue;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	204 }
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	205
9065 2ee6f9729739 QUIC: set stream error flag on reset. Roman Arutyunyan <arut@nginx.com> parents: 9064 diff changeset	206 sc->read->error = 1;
2ee6f9729739 QUIC: set stream error flag on reset. Roman Arutyunyan <arut@nginx.com> parents: 9064 diff changeset	207 sc->write->error = 1;
2ee6f9729739 QUIC: set stream error flag on reset. Roman Arutyunyan <arut@nginx.com> parents: 9064 diff changeset	208
9051 37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	209 ngx_quic_set_event(sc->read);
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	210 ngx_quic_set_event(sc->write);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	211
9051 37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	212 sc->close = 1;
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	213 sc->read->handler(sc->read);
8750 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
9051 37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	216 if (tree->root == tree->sentinel) {
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	217 return NGX_OK;
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	218 }
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	219
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	220 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, 0,
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	221 "quic connection has active streams");
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	222
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	223 return NGX_AGAIN;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	224 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	225
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	226
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	227 ngx_int_t
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	228 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	229 {
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	230 return ngx_quic_do_reset_stream(c->quic, err);
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	231 }
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	232
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	233
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	234 static ngx_int_t
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	235 ngx_quic_do_reset_stream(ngx_quic_stream_t *qs, ngx_uint_t err)
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	236 {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	237 ngx_connection_t *pc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	238 ngx_quic_frame_t *frame;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	239 ngx_quic_connection_t *qc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	240
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	241 if (qs->send_state == NGX_QUIC_STREAM_SEND_DATA_RECVD
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	242 \|\| qs->send_state == NGX_QUIC_STREAM_SEND_RESET_SENT
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	243 \|\| qs->send_state == NGX_QUIC_STREAM_SEND_RESET_RECVD)
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	244 {
8875 13cb758e6ac0 QUIC: reset stream only once. Roman Arutyunyan <arut@nginx.com> parents: 8861 diff changeset	245 return NGX_OK;
13cb758e6ac0 QUIC: reset stream only once. Roman Arutyunyan <arut@nginx.com> parents: 8861 diff changeset	246 }
13cb758e6ac0 QUIC: reset stream only once. Roman Arutyunyan <arut@nginx.com> parents: 8861 diff changeset	247
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	248 qs->send_state = NGX_QUIC_STREAM_SEND_RESET_SENT;
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	249 qs->send_final_size = qs->send_offset;
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	250
9065 2ee6f9729739 QUIC: set stream error flag on reset. Roman Arutyunyan <arut@nginx.com> parents: 9064 diff changeset	251 if (qs->connection) {
2ee6f9729739 QUIC: set stream error flag on reset. Roman Arutyunyan <arut@nginx.com> parents: 9064 diff changeset	252 qs->connection->write->error = 1;
2ee6f9729739 QUIC: set stream error flag on reset. Roman Arutyunyan <arut@nginx.com> parents: 9064 diff changeset	253 }
2ee6f9729739 QUIC: set stream error flag on reset. Roman Arutyunyan <arut@nginx.com> parents: 9064 diff changeset	254
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	255 pc = qs->parent;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	256 qc = ngx_quic_get_connection(pc);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	257
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	258 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, pc->log, 0,
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	259 "quic stream id:0x%xL reset", qs->id);
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	260
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	261 frame = ngx_quic_alloc_frame(pc);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	262 if (frame == NULL) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	263 return NGX_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	264 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	265
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	266 frame->level = ssl_encryption_application;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	267 frame->type = NGX_QUIC_FT_RESET_STREAM;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	268 frame->u.reset_stream.id = qs->id;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	269 frame->u.reset_stream.error_code = err;
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	270 frame->u.reset_stream.final_size = qs->send_offset;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	271
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	272 ngx_quic_queue_frame(qc, frame);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	273
9011 f9c788f3f5cc QUIC: ngx_quic_buffer_t object. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	274 ngx_quic_free_buffer(pc, &qs->send);
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	275
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	276 return NGX_OK;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	277 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	278
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	279
8890 b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	280 ngx_int_t
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	281 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	282 {
8938 23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	283 if (how == NGX_RDWR_SHUTDOWN \|\| how == NGX_WRITE_SHUTDOWN) {
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	284 if (ngx_quic_shutdown_stream_send(c) != NGX_OK) {
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	285 return NGX_ERROR;
8938 23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	286 }
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	287 }
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	288
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	289 if (how == NGX_RDWR_SHUTDOWN \|\| how == NGX_READ_SHUTDOWN) {
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	290 if (ngx_quic_shutdown_stream_recv(c) != NGX_OK) {
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	291 return NGX_ERROR;
8938 23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	292 }
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	293 }
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	294
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	295 return NGX_OK;
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	296 }
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	297
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	298
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	299 static ngx_int_t
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	300 ngx_quic_shutdown_stream_send(ngx_connection_t *c)
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	301 {
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	302 ngx_quic_stream_t *qs;
8890 b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	303
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	304 qs = c->quic;
8890 b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	305
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	306 if (qs->send_state != NGX_QUIC_STREAM_SEND_READY
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	307 && qs->send_state != NGX_QUIC_STREAM_SEND_SEND)
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	308 {
8890 b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	309 return NGX_OK;
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	310 }
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	311
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	312 qs->send_state = NGX_QUIC_STREAM_SEND_SEND;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	313 qs->send_final_size = c->sent;
8890 b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	314
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	315 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, qs->parent->log, 0,
8938 23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	316 "quic stream id:0x%xL send shutdown", qs->id);
8890 b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	317
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	318 return ngx_quic_stream_flush(qs);
8890 b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	319 }
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	320
b4c7853b0488 QUIC: added shutdown support in stream proxy. Vladimir Homutov <vl@nginx.com> parents: 8886 diff changeset	321
8938 23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	322 static ngx_int_t
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	323 ngx_quic_shutdown_stream_recv(ngx_connection_t *c)
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	324 {
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	325 ngx_connection_t *pc;
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	326 ngx_quic_frame_t *frame;
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	327 ngx_quic_stream_t *qs;
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	328 ngx_quic_connection_t *qc;
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	329
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	330 qs = c->quic;
8938 23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	331
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	332 if (qs->recv_state != NGX_QUIC_STREAM_RECV_RECV
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	333 && qs->recv_state != NGX_QUIC_STREAM_RECV_SIZE_KNOWN)
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	334 {
8938 23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	335 return NGX_OK;
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	336 }
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	337
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	338 pc = qs->parent;
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	339 qc = ngx_quic_get_connection(pc);
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	340
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	341 if (qc->conf->stream_close_code == 0) {
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	342 return NGX_OK;
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	343 }
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	344
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	345 frame = ngx_quic_alloc_frame(pc);
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	346 if (frame == NULL) {
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	347 return NGX_ERROR;
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	348 }
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	349
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	350 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, pc->log, 0,
8938 23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	351 "quic stream id:0x%xL recv shutdown", qs->id);
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	352
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	353 frame->level = ssl_encryption_application;
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	354 frame->type = NGX_QUIC_FT_STOP_SENDING;
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	355 frame->u.stop_sending.id = qs->id;
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	356 frame->u.stop_sending.error_code = qc->conf->stream_close_code;
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	357
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	358 ngx_quic_queue_frame(qc, frame);
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	359
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	360 return NGX_OK;
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	361 }
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	362
23880e4ad3e2 QUIC: write and full stream shutdown support. Roman Arutyunyan <arut@nginx.com> parents: 8937 diff changeset	363
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	364 static ngx_quic_stream_t *
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	365 ngx_quic_get_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	366 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	367 uint64_t min_id;
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	368 ngx_event_t *rev;
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	369 ngx_quic_stream_t *qs;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	370 ngx_quic_connection_t *qc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	371
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	372 qc = ngx_quic_get_connection(c);
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	373
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	374 qs = ngx_quic_find_stream(&qc->streams.tree, id);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	375
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	376 if (qs) {
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	377 return qs;
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	378 }
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	379
8905 832723a49026 QUIC: stop processing new client streams at the closing state. Sergey Kandaurov <pluknet@nginx.com> parents: 8890 diff changeset	380 if (qc->shutdown \|\| qc->closing) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	381 return NGX_QUIC_STREAM_GONE;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	382 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	383
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	384 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	385 "quic stream id:0x%xL is missing", id);
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	386
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	387 if (id & NGX_QUIC_STREAM_UNIDIRECTIONAL) {
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 if (id & NGX_QUIC_STREAM_SERVER_INITIATED) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	390 if ((id >> 2) < qc->streams.server_streams_uni) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	391 return NGX_QUIC_STREAM_GONE;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	392 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	393
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	394 qc->error = NGX_QUIC_ERR_STREAM_STATE_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	395 return NULL;
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 if ((id >> 2) < qc->streams.client_streams_uni) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	399 return NGX_QUIC_STREAM_GONE;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	400 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	401
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	402 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	403 qc->error = NGX_QUIC_ERR_STREAM_LIMIT_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	404 return NULL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	405 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	406
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	407 min_id = (qc->streams.client_streams_uni << 2)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	408 \| NGX_QUIC_STREAM_UNIDIRECTIONAL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	409 qc->streams.client_streams_uni = (id >> 2) + 1;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	410
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	411 } else {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	412
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	413 if (id & NGX_QUIC_STREAM_SERVER_INITIATED) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	414 if ((id >> 2) < qc->streams.server_streams_bidi) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	415 return NGX_QUIC_STREAM_GONE;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	416 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	417
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	418 qc->error = NGX_QUIC_ERR_STREAM_STATE_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	419 return NULL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	420 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	421
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	422 if ((id >> 2) < qc->streams.client_streams_bidi) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	423 return NGX_QUIC_STREAM_GONE;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	424 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	425
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	426 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	427 qc->error = NGX_QUIC_ERR_STREAM_LIMIT_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	428 return NULL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	429 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	430
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	431 min_id = (qc->streams.client_streams_bidi << 2);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	432 qc->streams.client_streams_bidi = (id >> 2) + 1;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	433 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	434
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	435 /*
8797 4715f3e669f1 QUIC: updated specification references. Sergey Kandaurov <pluknet@nginx.com> parents: 8791 diff changeset	436 * 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	437 *
8797 4715f3e669f1 QUIC: updated specification references. Sergey Kandaurov <pluknet@nginx.com> parents: 8791 diff changeset	438 * successive streams of each type are created with numerically increasing
4715f3e669f1 QUIC: updated specification references. Sergey Kandaurov <pluknet@nginx.com> parents: 8791 diff changeset	439 * 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	440 * 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	441 */
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	442
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	443 #if (NGX_SUPPRESS_WARN)
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	444 qs = NULL;
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	445 #endif
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	446
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	447 for ( /* void */ ; min_id <= id; min_id += 0x04) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	448
8779 f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	449 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	450
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	451 if (qs == NULL) {
8906 41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	452 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	453 return NULL;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	454 }
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 continue;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	457 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	458
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	459 ngx_queue_insert_tail(&qc->streams.uninitialized, &qs->queue);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	460
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	461 rev = qs->connection->read;
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	462 rev->handler = ngx_quic_init_stream_handler;
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	463
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	464 if (qc->streams.initialized) {
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	465 ngx_post_event(rev, &ngx_posted_events);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	466 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	467 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	468
8906 41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	469 if (qs == NULL) {
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	470 return NGX_QUIC_STREAM_GONE;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	471 }
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	472
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	473 return qs;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	474 }
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	475
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	476
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	477 static ngx_int_t
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	478 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	479 {
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	480 uint64_t code;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	481 ngx_quic_frame_t *frame;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	482 ngx_quic_connection_t *qc;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	483
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	484 qc = ngx_quic_get_connection(c);
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	485
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	486 code = (id & NGX_QUIC_STREAM_UNIDIRECTIONAL)
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	487 ? qc->conf->stream_reject_code_uni
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	488 : qc->conf->stream_reject_code_bidi;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	489
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	490 if (code == 0) {
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	491 return NGX_DECLINED;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	492 }
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	493
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	494 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	495 "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	496
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	497 frame = ngx_quic_alloc_frame(c);
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	498 if (frame == NULL) {
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	499 return NGX_ERROR;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	500 }
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	501
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	502 frame->level = ssl_encryption_application;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	503 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	504 frame->u.reset_stream.id = id;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	505 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	506 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	507
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	508 ngx_quic_queue_frame(qc, frame);
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	509
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	510 frame = ngx_quic_alloc_frame(c);
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	511 if (frame == NULL) {
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	512 return NGX_ERROR;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	513 }
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	514
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	515 frame->level = ssl_encryption_application;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	516 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	517 frame->u.stop_sending.id = id;
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	518 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	519
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	520 ngx_quic_queue_frame(qc, frame);
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	521
41caf5410110 QUIC: reject streams which we could not create. Roman Arutyunyan <arut@nginx.com> parents: 8905 diff changeset	522 return NGX_OK;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	523 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	524
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	525
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	526 static void
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	527 ngx_quic_init_stream_handler(ngx_event_t *ev)
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	528 {
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	529 ngx_connection_t *c;
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	530 ngx_quic_stream_t *qs;
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	531
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	532 c = ev->data;
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	533 qs = c->quic;
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	534
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	535 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	536
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	537 ngx_queue_remove(&qs->queue);
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	538
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	539 c->listening->handler(c);
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	540 }
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
8886 66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	543 ngx_int_t
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	544 ngx_quic_init_streams(ngx_connection_t *c)
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	545 {
8886 66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	546 ngx_int_t rc;
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	547 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	548
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	549 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	550
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	551 if (qc->streams.initialized) {
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	552 return NGX_OK;
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	553 }
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	554
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	555 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	556
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	557 if (rc == NGX_ERROR) {
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	558 return NGX_ERROR;
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	559 }
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	560
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	561 if (rc == NGX_AGAIN) {
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	562 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	563 return NGX_OK;
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	564 }
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	565
9058 b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9053 diff changeset	566 return ngx_quic_do_init_streams(c);
8886 66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	567 }
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	568
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	569
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	570 static void
66b4ff373dd9 QUIC: refactored OCSP validation in preparation for 0-RTT support. Sergey Kandaurov <pluknet@nginx.com> parents: 8876 diff changeset	571 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	572 {
9058 b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9053 diff changeset	573 if (ngx_quic_do_init_streams(c) != NGX_OK) {
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9053 diff changeset	574 ngx_quic_close_connection(c, NGX_ERROR);
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9053 diff changeset	575 }
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9053 diff changeset	576 }
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9053 diff changeset	577
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9053 diff changeset	578
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9053 diff changeset	579 static ngx_int_t
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9053 diff changeset	580 ngx_quic_do_init_streams(ngx_connection_t *c)
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9053 diff changeset	581 {
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	582 ngx_queue_t *q;
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	583 ngx_quic_stream_t *qs;
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	584 ngx_quic_connection_t *qc;
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	585
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	586 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	587
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	588 qc = ngx_quic_get_connection(c);
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	589
9058 b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9053 diff changeset	590 if (qc->conf->init) {
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9053 diff changeset	591 if (qc->conf->init(c) != NGX_OK) {
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9053 diff changeset	592 return NGX_ERROR;
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9053 diff changeset	593 }
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9053 diff changeset	594 }
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9053 diff changeset	595
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	596 for (q = ngx_queue_head(&qc->streams.uninitialized);
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	597 q != ngx_queue_sentinel(&qc->streams.uninitialized);
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	598 q = ngx_queue_next(q))
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	599 {
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	600 qs = ngx_queue_data(q, ngx_quic_stream_t, queue);
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	601 ngx_post_event(qs->connection->read, &ngx_posted_events);
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	602 }
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	603
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	604 qc->streams.initialized = 1;
9058 b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9053 diff changeset	605
b0c2234aaa9f QUIC: application init() callback. Roman Arutyunyan <arut@nginx.com> parents: 9053 diff changeset	606 return NGX_OK;
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	607 }
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	608
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	609
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	610 static ngx_quic_stream_t *
8779 f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	611 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	612 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	613 ngx_log_t *log;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	614 ngx_pool_t *pool;
9051 37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	615 ngx_uint_t reusable;
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	616 ngx_queue_t *q;
8760 baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	617 ngx_connection_t *sc;
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	618 ngx_quic_stream_t *qs;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	619 ngx_pool_cleanup_t *cln;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	620 ngx_quic_connection_t *qc;
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 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	623 "quic stream id:0x%xL create", id);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	624
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	625 qc = ngx_quic_get_connection(c);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	626
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	627 if (!ngx_queue_empty(&qc->streams.free)) {
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	628 q = ngx_queue_head(&qc->streams.free);
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	629 qs = ngx_queue_data(q, ngx_quic_stream_t, queue);
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	630 ngx_queue_remove(&qs->queue);
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	631
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	632 } else {
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	633 /*
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	634 * the number of streams is limited by transport
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	635 * parameters and application requirements
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	636 */
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	637
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	638 qs = ngx_palloc(c->pool, sizeof(ngx_quic_stream_t));
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	639 if (qs == NULL) {
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	640 return NULL;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	641 }
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	642 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	643
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	644 ngx_memzero(qs, sizeof(ngx_quic_stream_t));
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	645
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	646 qs->node.key = id;
225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	647 qs->parent = c;
225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	648 qs->id = id;
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	649 qs->send_final_size = (uint64_t) -1;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	650 qs->recv_final_size = (uint64_t) -1;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	651
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	652 pool = ngx_create_pool(NGX_DEFAULT_POOL_SIZE, c->log);
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	653 if (pool == NULL) {
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	654 ngx_queue_insert_tail(&qc->streams.free, &qs->queue);
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	655 return NULL;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	656 }
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 log = ngx_palloc(pool, sizeof(ngx_log_t));
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	659 if (log == NULL) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	660 ngx_destroy_pool(pool);
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	661 ngx_queue_insert_tail(&qc->streams.free, &qs->queue);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	662 return NULL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	663 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	664
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	665 log = c->log;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	666 pool->log = log;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	667
9051 37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	668 reusable = c->reusable;
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	669 ngx_reusable_connection(c, 0);
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	670
8860 a2cef164a924 QUIC: simplified stream fd initialization. Roman Arutyunyan <arut@nginx.com> parents: 8855 diff changeset	671 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	672 if (sc == NULL) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	673 ngx_destroy_pool(pool);
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	674 ngx_queue_insert_tail(&qc->streams.free, &qs->queue);
9051 37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	675 ngx_reusable_connection(c, reusable);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	676 return NULL;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	677 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	678
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	679 qs->connection = sc;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	680
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	681 sc->quic = qs;
8842 486c6a9be111 QUIC: store QUIC connection fd in stream fake connection. Roman Arutyunyan <arut@nginx.com> parents: 8841 diff changeset	682 sc->shared = 1;
8760 baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	683 sc->type = SOCK_STREAM;
baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	684 sc->pool = pool;
baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	685 sc->ssl = c->ssl;
baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	686 sc->sockaddr = c->sockaddr;
baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	687 sc->listening = c->listening;
baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	688 sc->addr_text = c->addr_text;
baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	689 sc->local_sockaddr = c->local_sockaddr;
baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	690 sc->local_socklen = c->local_socklen;
baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	691 sc->number = ngx_atomic_fetch_add(ngx_connection_counter, 1);
9063 e3760b9b7c8e HTTP/3: fixed $connection_time. Sergey Kandaurov <pluknet@nginx.com> parents: 9058 diff changeset	692 sc->start_time = c->start_time;
8861 630ecd703805 QUIC: set NGX_TCP_NODELAY_DISABLED for fake stream connections. Sergey Kandaurov <pluknet@nginx.com> parents: 8860 diff changeset	693 sc->tcp_nodelay = NGX_TCP_NODELAY_DISABLED;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	694
8760 baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	695 sc->recv = ngx_quic_stream_recv;
baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	696 sc->send = ngx_quic_stream_send;
baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	697 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	698
8760 baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	699 sc->read->log = log;
baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	700 sc->write->log = log;
baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	701
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	702 sc->read->handler = ngx_quic_empty_handler;
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	703 sc->write->handler = ngx_quic_empty_handler;
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	704
8760 baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	705 log->connection = sc->number;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	706
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	707 if ((id & NGX_QUIC_STREAM_UNIDIRECTIONAL) == 0
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	708 \|\| (id & NGX_QUIC_STREAM_SERVER_INITIATED))
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	709 {
9064 35e27117b593 QUIC: automatically add and never delete stream events. Roman Arutyunyan <arut@nginx.com> parents: 9063 diff changeset	710 sc->write->active = 1;
8760 baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	711 sc->write->ready = 1;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	712 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	713
9064 35e27117b593 QUIC: automatically add and never delete stream events. Roman Arutyunyan <arut@nginx.com> parents: 9063 diff changeset	714 if ((id & NGX_QUIC_STREAM_UNIDIRECTIONAL) == 0
35e27117b593 QUIC: automatically add and never delete stream events. Roman Arutyunyan <arut@nginx.com> parents: 9063 diff changeset	715 \|\| (id & NGX_QUIC_STREAM_SERVER_INITIATED) == 0)
35e27117b593 QUIC: automatically add and never delete stream events. Roman Arutyunyan <arut@nginx.com> parents: 9063 diff changeset	716 {
35e27117b593 QUIC: automatically add and never delete stream events. Roman Arutyunyan <arut@nginx.com> parents: 9063 diff changeset	717 sc->read->active = 1;
35e27117b593 QUIC: automatically add and never delete stream events. Roman Arutyunyan <arut@nginx.com> parents: 9063 diff changeset	718 }
35e27117b593 QUIC: automatically add and never delete stream events. Roman Arutyunyan <arut@nginx.com> parents: 9063 diff changeset	719
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	720 if (id & NGX_QUIC_STREAM_UNIDIRECTIONAL) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	721 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	722 qs->send_max_data = qc->ctp.initial_max_stream_data_uni;
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	723 qs->recv_state = NGX_QUIC_STREAM_RECV_DATA_READ;
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	724 qs->send_state = NGX_QUIC_STREAM_SEND_READY;
8779 f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	725
f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	726 } else {
f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	727 qs->recv_max_data = qc->tp.initial_max_stream_data_uni;
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	728 qs->recv_state = NGX_QUIC_STREAM_RECV_RECV;
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	729 qs->send_state = NGX_QUIC_STREAM_SEND_DATA_RECVD;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	730 }
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 } else {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	733 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	734 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	735 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	736
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	737 } else {
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	738 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	739 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	740 }
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	741
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	742 qs->recv_state = NGX_QUIC_STREAM_RECV_RECV;
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	743 qs->send_state = NGX_QUIC_STREAM_SEND_READY;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	744 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	745
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	746 qs->recv_window = qs->recv_max_data;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	747
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	748 cln = ngx_pool_cleanup_add(pool, 0);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	749 if (cln == NULL) {
8760 baf9551b4a5b QUIC: renamed stream field from c to connection. Roman Arutyunyan <arut@nginx.com> parents: 8756 diff changeset	750 ngx_close_connection(sc);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	751 ngx_destroy_pool(pool);
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	752 ngx_queue_insert_tail(&qc->streams.free, &qs->queue);
9051 37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	753 ngx_reusable_connection(c, reusable);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	754 return NULL;
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
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	757 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	758 cln->data = sc;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	759
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	760 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	761
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	762 return qs;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	763 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	764
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	765
9051 37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	766 void
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	767 ngx_quic_cancelable_stream(ngx_connection_t *c)
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	768 {
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	769 ngx_connection_t *pc;
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	770 ngx_quic_stream_t *qs;
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	771 ngx_quic_connection_t *qc;
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	772
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	773 qs = c->quic;
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	774 pc = qs->parent;
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	775 qc = ngx_quic_get_connection(pc);
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	776
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	777 if (!qs->cancelable) {
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	778 qs->cancelable = 1;
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	779
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	780 if (ngx_quic_can_shutdown(pc) == NGX_OK) {
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	781 ngx_reusable_connection(pc, 1);
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	782
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	783 if (qc->shutdown) {
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	784 ngx_quic_shutdown_quic(pc);
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	785 }
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	786 }
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	787 }
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	788 }
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	789
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	790
8827 fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	791 static void
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	792 ngx_quic_empty_handler(ngx_event_t *ev)
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	793 {
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	794 }
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	795
fe919fd63b0b QUIC: client certificate validation with OCSP. Sergey Kandaurov <pluknet@nginx.com> parents: 8820 diff changeset	796
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	797 static ssize_t
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	798 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	799 {
8947 6ccf3867959a QUIC: refactored ngx_quic_order_bufs() and ngx_quic_split_bufs(). Roman Arutyunyan <arut@nginx.com> parents: 8946 diff changeset	800 ssize_t len;
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	801 ngx_buf_t *b;
8947 6ccf3867959a QUIC: refactored ngx_quic_order_bufs() and ngx_quic_split_bufs(). Roman Arutyunyan <arut@nginx.com> parents: 8946 diff changeset	802 ngx_chain_t cl, in;
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	803 ngx_event_t *rev;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	804 ngx_connection_t *pc;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	805 ngx_quic_stream_t *qs;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	806
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	807 qs = c->quic;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	808 pc = qs->parent;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	809 rev = c->read;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	810
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	811 if (qs->recv_state == NGX_QUIC_STREAM_RECV_RESET_RECVD
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	812 \|\| qs->recv_state == NGX_QUIC_STREAM_RECV_RESET_READ)
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	813 {
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	814 qs->recv_state = NGX_QUIC_STREAM_RECV_RESET_READ;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	815 return NGX_ERROR;
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
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	818 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, pc->log, 0,
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	819 "quic stream id:0x%xL recv buf:%uz", qs->id, size);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	820
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	821 if (size == 0) {
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	822 return 0;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	823 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	824
9011 f9c788f3f5cc QUIC: ngx_quic_buffer_t object. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	825 in = ngx_quic_read_buffer(pc, &qs->recv, size);
8947 6ccf3867959a QUIC: refactored ngx_quic_order_bufs() and ngx_quic_split_bufs(). Roman Arutyunyan <arut@nginx.com> parents: 8946 diff changeset	826 if (in == NGX_CHAIN_ERROR) {
6ccf3867959a QUIC: refactored ngx_quic_order_bufs() and ngx_quic_split_bufs(). Roman Arutyunyan <arut@nginx.com> parents: 8946 diff changeset	827 return NGX_ERROR;
8779 f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	828 }
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	829
8947 6ccf3867959a QUIC: refactored ngx_quic_order_bufs() and ngx_quic_split_bufs(). Roman Arutyunyan <arut@nginx.com> parents: 8946 diff changeset	830 len = 0;
8779 f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	831
8947 6ccf3867959a QUIC: refactored ngx_quic_order_bufs() and ngx_quic_split_bufs(). Roman Arutyunyan <arut@nginx.com> parents: 8946 diff changeset	832 for (cl = in; cl; cl = cl->next) {
6ccf3867959a QUIC: refactored ngx_quic_order_bufs() and ngx_quic_split_bufs(). Roman Arutyunyan <arut@nginx.com> parents: 8946 diff changeset	833 b = cl->buf;
6ccf3867959a QUIC: refactored ngx_quic_order_bufs() and ngx_quic_split_bufs(). Roman Arutyunyan <arut@nginx.com> parents: 8946 diff changeset	834 len += b->last - b->pos;
6ccf3867959a QUIC: refactored ngx_quic_order_bufs() and ngx_quic_split_bufs(). Roman Arutyunyan <arut@nginx.com> parents: 8946 diff changeset	835 buf = ngx_cpymem(buf, b->pos, b->last - b->pos);
6ccf3867959a QUIC: refactored ngx_quic_order_bufs() and ngx_quic_split_bufs(). Roman Arutyunyan <arut@nginx.com> parents: 8946 diff changeset	836 }
6ccf3867959a QUIC: refactored ngx_quic_order_bufs() and ngx_quic_split_bufs(). Roman Arutyunyan <arut@nginx.com> parents: 8946 diff changeset	837
8948 19e063e955bf QUIC: renamed buffer-related functions. Roman Arutyunyan <arut@nginx.com> parents: 8947 diff changeset	838 ngx_quic_free_chain(pc, in);
8779 f52a2b77d406 QUIC: generic buffering for stream input. Roman Arutyunyan <arut@nginx.com> parents: 8761 diff changeset	839
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	840 if (len == 0) {
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	841 rev->ready = 0;
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	842
9003 6c1dfd072859 QUIC: switch stream to DATA_RECVD state. Roman Arutyunyan <arut@nginx.com> parents: 8993 diff changeset	843 if (qs->recv_state == NGX_QUIC_STREAM_RECV_DATA_RECVD
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	844 && qs->recv_offset == qs->recv_final_size)
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	845 {
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	846 qs->recv_state = NGX_QUIC_STREAM_RECV_DATA_READ;
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	847 }
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	848
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	849 if (qs->recv_state == NGX_QUIC_STREAM_RECV_DATA_READ) {
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	850 rev->eof = 1;
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	851 return 0;
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	852 }
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	853
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	854 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	855 "quic stream id:0x%xL recv() not ready", qs->id);
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	856 return NGX_AGAIN;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	857 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	858
8782 b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	859 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	860 "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	861
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	862 if (ngx_quic_update_flow(qs, qs->recv_offset + len) != NGX_OK) {
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	863 return NGX_ERROR;
8750 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 return len;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	867 }
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 static ssize_t
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	871 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	872 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	873 ngx_buf_t b;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	874 ngx_chain_t cl;
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 ngx_memzero(&b, sizeof(ngx_buf_t));
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	877
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	878 b.memory = 1;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	879 b.pos = buf;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	880 b.last = buf + size;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	881
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	882 cl.buf = &b;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	883 cl.next = NULL;
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 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	886 return NGX_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	887 }
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 if (b.pos == buf) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	890 return NGX_AGAIN;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	891 }
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 b.pos - buf;
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 ngx_chain_t *
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	898 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	899 {
9011 f9c788f3f5cc QUIC: ngx_quic_buffer_t object. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	900 uint64_t n, flow;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	901 ngx_event_t *wev;
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_stream_t *qs;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	904 ngx_quic_connection_t *qc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	905
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	906 qs = c->quic;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	907 pc = qs->parent;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	908 qc = ngx_quic_get_connection(pc);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	909 wev = c->write;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	910
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	911 if (qs->send_state != NGX_QUIC_STREAM_SEND_READY
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	912 && qs->send_state != NGX_QUIC_STREAM_SEND_SEND)
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	913 {
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	914 wev->error = 1;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	915 return NGX_CHAIN_ERROR;
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
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	918 qs->send_state = NGX_QUIC_STREAM_SEND_SEND;
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	919
9052 2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	920 flow = qs->acked + qc->conf->stream_buffer_size - qs->sent;
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	921
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	922 if (flow == 0) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	923 wev->ready = 0;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	924 return in;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	925 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	926
9011 f9c788f3f5cc QUIC: ngx_quic_buffer_t object. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	927 if (limit == 0 \|\| limit > (off_t) flow) {
8947 6ccf3867959a QUIC: refactored ngx_quic_order_bufs() and ngx_quic_split_bufs(). Roman Arutyunyan <arut@nginx.com> parents: 8946 diff changeset	928 limit = flow;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	929 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	930
9011 f9c788f3f5cc QUIC: ngx_quic_buffer_t object. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	931 n = qs->send.size;
f9c788f3f5cc QUIC: ngx_quic_buffer_t object. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	932
9052 2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	933 in = ngx_quic_write_buffer(pc, &qs->send, in, limit, qs->sent);
8947 6ccf3867959a QUIC: refactored ngx_quic_order_bufs() and ngx_quic_split_bufs(). Roman Arutyunyan <arut@nginx.com> parents: 8946 diff changeset	934 if (in == NGX_CHAIN_ERROR) {
6ccf3867959a QUIC: refactored ngx_quic_order_bufs() and ngx_quic_split_bufs(). Roman Arutyunyan <arut@nginx.com> parents: 8946 diff changeset	935 return NGX_CHAIN_ERROR;
6ccf3867959a QUIC: refactored ngx_quic_order_bufs() and ngx_quic_split_bufs(). Roman Arutyunyan <arut@nginx.com> parents: 8946 diff changeset	936 }
6ccf3867959a QUIC: refactored ngx_quic_order_bufs() and ngx_quic_split_bufs(). Roman Arutyunyan <arut@nginx.com> parents: 8946 diff changeset	937
9011 f9c788f3f5cc QUIC: ngx_quic_buffer_t object. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	938 n = qs->send.size - n;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	939 c->sent += n;
9052 2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	940 qs->sent += n;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	941 qc->streams.sent += n;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	942
9011 f9c788f3f5cc QUIC: ngx_quic_buffer_t object. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	943 if (flow == n) {
8947 6ccf3867959a QUIC: refactored ngx_quic_order_bufs() and ngx_quic_split_bufs(). Roman Arutyunyan <arut@nginx.com> parents: 8946 diff changeset	944 wev->ready = 0;
6ccf3867959a QUIC: refactored ngx_quic_order_bufs() and ngx_quic_split_bufs(). Roman Arutyunyan <arut@nginx.com> parents: 8946 diff changeset	945 }
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_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
9011 f9c788f3f5cc QUIC: ngx_quic_buffer_t object. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	948 "quic send_chain sent:%uL", n);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	949
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	950 if (ngx_quic_stream_flush(qs) != NGX_OK) {
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	951 return NGX_CHAIN_ERROR;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	952 }
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	953
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	954 return in;
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
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	958 static ngx_int_t
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	959 ngx_quic_stream_flush(ngx_quic_stream_t *qs)
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	960 {
9011 f9c788f3f5cc QUIC: ngx_quic_buffer_t object. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	961 off_t limit, len;
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	962 ngx_uint_t last;
9011 f9c788f3f5cc QUIC: ngx_quic_buffer_t object. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	963 ngx_chain_t *out;
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	964 ngx_quic_frame_t *frame;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	965 ngx_connection_t *pc;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	966 ngx_quic_connection_t *qc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	967
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	968 if (qs->send_state != NGX_QUIC_STREAM_SEND_SEND) {
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	969 return NGX_OK;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	970 }
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	971
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	972 pc = qs->parent;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	973 qc = ngx_quic_get_connection(pc);
8750 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 if (qc->streams.send_max_data == 0) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	976 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	977 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	978
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	979 limit = ngx_min(qc->streams.send_max_data - qc->streams.send_offset,
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	980 qs->send_max_data - qs->send_offset);
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	981
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	982 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, pc->log, 0,
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	983 "quic stream id:0x%xL flush limit:%O", qs->id, limit);
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	984
9011 f9c788f3f5cc QUIC: ngx_quic_buffer_t object. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	985 len = qs->send.offset;
f9c788f3f5cc QUIC: ngx_quic_buffer_t object. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	986
f9c788f3f5cc QUIC: ngx_quic_buffer_t object. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	987 out = ngx_quic_read_buffer(pc, &qs->send, limit);
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	988 if (out == NGX_CHAIN_ERROR) {
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	989 return NGX_ERROR;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	990 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	991
9011 f9c788f3f5cc QUIC: ngx_quic_buffer_t object. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	992 len = qs->send.offset - len;
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	993 last = 0;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	994
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	995 if (qs->send_final_size != (uint64_t) -1
9011 f9c788f3f5cc QUIC: ngx_quic_buffer_t object. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	996 && qs->send_final_size == qs->send.offset)
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	997 {
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	998 qs->send_state = NGX_QUIC_STREAM_SEND_DATA_SENT;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	999 last = 1;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1000 }
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1001
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1002 if (len == 0 && !last) {
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1003 return NGX_OK;
8750 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
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1006 frame = ngx_quic_alloc_frame(pc);
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1007 if (frame == NULL) {
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1008 return NGX_ERROR;
8750 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
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1011 frame->level = ssl_encryption_application;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1012 frame->type = NGX_QUIC_FT_STREAM;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1013 frame->data = out;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1014
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1015 frame->u.stream.off = 1;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1016 frame->u.stream.len = 1;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1017 frame->u.stream.fin = last;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1018
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1019 frame->u.stream.stream_id = qs->id;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1020 frame->u.stream.offset = qs->send_offset;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1021 frame->u.stream.length = len;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1022
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1023 ngx_quic_queue_frame(qc, frame);
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1024
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1025 qs->send_offset += len;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1026 qc->streams.send_offset += len;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1027
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1028 ngx_log_debug3(NGX_LOG_DEBUG_EVENT, pc->log, 0,
9011 f9c788f3f5cc QUIC: ngx_quic_buffer_t object. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	1029 "quic stream id:0x%xL flush len:%O last:%ui",
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1030 qs->id, len, last);
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1031
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1032 if (qs->connection == NULL) {
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1033 return ngx_quic_close_stream(qs);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1034 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1035
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1036 return NGX_OK;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1037 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1038
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1039
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1040 static void
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1041 ngx_quic_stream_cleanup_handler(void *data)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1042 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1043 ngx_connection_t *c = data;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1044
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1045 ngx_quic_stream_t *qs;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1046
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1047 qs = c->quic;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1048
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1049 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, qs->parent->log, 0,
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1050 "quic stream id:0x%xL cleanup", qs->id);
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1051
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1052 if (ngx_quic_shutdown_stream(c, NGX_RDWR_SHUTDOWN) != NGX_OK) {
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1053 ngx_quic_close_connection(c, NGX_ERROR);
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1054 return;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1055 }
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1056
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1057 qs->connection = NULL;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1058
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1059 if (ngx_quic_close_stream(qs) != NGX_OK) {
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1060 ngx_quic_close_connection(c, NGX_ERROR);
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1061 return;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1062 }
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1063 }
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1064
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1065
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1066 static ngx_int_t
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1067 ngx_quic_close_stream(ngx_quic_stream_t *qs)
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1068 {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1069 ngx_connection_t *pc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1070 ngx_quic_frame_t *frame;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1071 ngx_quic_connection_t *qc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1072
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1073 pc = qs->parent;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1074 qc = ngx_quic_get_connection(pc);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1075
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1076 if (!qc->closing) {
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1077 /* make sure everything is sent and final size is received */
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1078
9052 2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1079 if (qs->recv_state == NGX_QUIC_STREAM_RECV_RECV) {
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1080 return NGX_OK;
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1081 }
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1082
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1083 if (qs->send_state != NGX_QUIC_STREAM_SEND_DATA_RECVD
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1084 && qs->send_state != NGX_QUIC_STREAM_SEND_RESET_RECVD)
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1085 {
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1086 return NGX_OK;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1087 }
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1088 }
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1089
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1090 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, pc->log, 0,
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1091 "quic stream id:0x%xL close", qs->id);
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1092
9011 f9c788f3f5cc QUIC: ngx_quic_buffer_t object. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	1093 ngx_quic_free_buffer(pc, &qs->send);
f9c788f3f5cc QUIC: ngx_quic_buffer_t object. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	1094 ngx_quic_free_buffer(pc, &qs->recv);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1095
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1096 ngx_rbtree_delete(&qc->streams.tree, &qs->node);
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1097 ngx_queue_insert_tail(&qc->streams.free, &qs->queue);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1098
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1099 if (qc->closing) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1100 /* schedule handler call to continue ngx_quic_close_connection() */
9050 aaca8e111959 QUIC: post close event for connection close. Roman Arutyunyan <arut@nginx.com> parents: 9045 diff changeset	1101 ngx_post_event(&qc->close, &ngx_posted_events);
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1102 return NGX_OK;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1103 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1104
9053 740d7d6e8ff0 QUIC: do not send MAX_STREAMS in shutdown state. Roman Arutyunyan <arut@nginx.com> parents: 9052 diff changeset	1105 if (!pc->reusable && ngx_quic_can_shutdown(pc) == NGX_OK) {
740d7d6e8ff0 QUIC: do not send MAX_STREAMS in shutdown state. Roman Arutyunyan <arut@nginx.com> parents: 9052 diff changeset	1106 ngx_reusable_connection(pc, 1);
740d7d6e8ff0 QUIC: do not send MAX_STREAMS in shutdown state. Roman Arutyunyan <arut@nginx.com> parents: 9052 diff changeset	1107 }
740d7d6e8ff0 QUIC: do not send MAX_STREAMS in shutdown state. Roman Arutyunyan <arut@nginx.com> parents: 9052 diff changeset	1108
740d7d6e8ff0 QUIC: do not send MAX_STREAMS in shutdown state. Roman Arutyunyan <arut@nginx.com> parents: 9052 diff changeset	1109 if (qc->shutdown) {
740d7d6e8ff0 QUIC: do not send MAX_STREAMS in shutdown state. Roman Arutyunyan <arut@nginx.com> parents: 9052 diff changeset	1110 ngx_quic_shutdown_quic(pc);
740d7d6e8ff0 QUIC: do not send MAX_STREAMS in shutdown state. Roman Arutyunyan <arut@nginx.com> parents: 9052 diff changeset	1111 return NGX_OK;
740d7d6e8ff0 QUIC: do not send MAX_STREAMS in shutdown state. Roman Arutyunyan <arut@nginx.com> parents: 9052 diff changeset	1112 }
740d7d6e8ff0 QUIC: do not send MAX_STREAMS in shutdown state. Roman Arutyunyan <arut@nginx.com> parents: 9052 diff changeset	1113
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1114 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	1115 frame = ngx_quic_alloc_frame(pc);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1116 if (frame == NULL) {
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1117 return NGX_ERROR;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1118 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1119
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1120 frame->level = ssl_encryption_application;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1121 frame->type = NGX_QUIC_FT_MAX_STREAMS;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1122
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1123 if (qs->id & NGX_QUIC_STREAM_UNIDIRECTIONAL) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1124 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	1125 frame->u.max_streams.bidi = 0;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1126
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1127 } else {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1128 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	1129 frame->u.max_streams.bidi = 1;
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
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1132 ngx_quic_queue_frame(qc, frame);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1133 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1134
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1135 return NGX_OK;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1136 }
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
9051 37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1139 static ngx_int_t
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1140 ngx_quic_can_shutdown(ngx_connection_t *c)
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1141 {
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1142 ngx_rbtree_t *tree;
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1143 ngx_rbtree_node_t *node;
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1144 ngx_quic_stream_t *qs;
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1145 ngx_quic_connection_t *qc;
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1146
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1147 qc = ngx_quic_get_connection(c);
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1148
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1149 tree = &qc->streams.tree;
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1150
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1151 if (tree->root != tree->sentinel) {
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1152 for (node = ngx_rbtree_min(tree->root, tree->sentinel);
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1153 node;
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1154 node = ngx_rbtree_next(tree, node))
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1155 {
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1156 qs = (ngx_quic_stream_t *) node;
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1157
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1158 if (!qs->cancelable) {
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1159 return NGX_DECLINED;
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1160 }
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1161 }
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1162 }
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1163
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1164 return NGX_OK;
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1165 }
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1166
37d5dddabaea QUIC: reusable mode for main connection. Roman Arutyunyan <arut@nginx.com> parents: 9050 diff changeset	1167
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1168 ngx_int_t
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1169 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	1170 ngx_quic_frame_t *frame)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1171 {
8782 b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1172 uint64_t last;
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1173 ngx_quic_stream_t *qs;
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1174 ngx_quic_connection_t *qc;
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1175 ngx_quic_stream_frame_t *f;
8750 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 qc = ngx_quic_get_connection(c);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1178 f = &frame->u.stream;
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 if ((f->stream_id & NGX_QUIC_STREAM_UNIDIRECTIONAL)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1181 && (f->stream_id & NGX_QUIC_STREAM_SERVER_INITIATED))
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1182 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1183 qc->error = NGX_QUIC_ERR_STREAM_STATE_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1184 return NGX_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1185 }
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 /* no overflow since both values are 62-bit */
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1188 last = f->offset + f->length;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1189
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	1190 qs = ngx_quic_get_stream(c, f->stream_id);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1191
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1192 if (qs == NULL) {
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	1193 return NGX_ERROR;
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	1194 }
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1195
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	1196 if (qs == NGX_QUIC_STREAM_GONE) {
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	1197 return NGX_OK;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1198 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1199
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	1200 if (qs->recv_state != NGX_QUIC_STREAM_RECV_RECV
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	1201 && qs->recv_state != NGX_QUIC_STREAM_RECV_SIZE_KNOWN)
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	1202 {
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1203 return NGX_OK;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1204 }
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1205
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1206 if (ngx_quic_control_flow(qs, last) != NGX_OK) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1207 return NGX_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1208 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1209
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1210 if (qs->recv_final_size != (uint64_t) -1 && last > qs->recv_final_size) {
8782 b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1211 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	1212 return NGX_ERROR;
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1213 }
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1214
8962 47f45a98f892 QUIC: fixed handling STREAM FIN. Roman Arutyunyan <arut@nginx.com> parents: 8952 diff changeset	1215 if (last < qs->recv_offset) {
8782 b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1216 return NGX_OK;
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1217 }
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1218
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1219 if (f->fin) {
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1220 if (qs->recv_final_size != (uint64_t) -1 && qs->recv_final_size != last)
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1221 {
8782 b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1222 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	1223 return NGX_ERROR;
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1224 }
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1225
8783 60c6e8d8d3ae QUIC: make sure stream data size is lower than final size. Roman Arutyunyan <arut@nginx.com> parents: 8782 diff changeset	1226 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	1227 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	1228 return NGX_ERROR;
60c6e8d8d3ae QUIC: make sure stream data size is lower than final size. Roman Arutyunyan <arut@nginx.com> parents: 8782 diff changeset	1229 }
60c6e8d8d3ae QUIC: make sure stream data size is lower than final size. Roman Arutyunyan <arut@nginx.com> parents: 8782 diff changeset	1230
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1231 qs->recv_final_size = last;
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	1232 qs->recv_state = NGX_QUIC_STREAM_RECV_SIZE_KNOWN;
8782 b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1233 }
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1234
9011 f9c788f3f5cc QUIC: ngx_quic_buffer_t object. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	1235 if (ngx_quic_write_buffer(c, &qs->recv, frame->data, f->length, f->offset)
8947 6ccf3867959a QUIC: refactored ngx_quic_order_bufs() and ngx_quic_split_bufs(). Roman Arutyunyan <arut@nginx.com> parents: 8946 diff changeset	1236 == NGX_CHAIN_ERROR)
8784 7d32c3c93678 QUIC: call stream read handler on new data arrival. Roman Arutyunyan <arut@nginx.com> parents: 8783 diff changeset	1237 {
7d32c3c93678 QUIC: call stream read handler on new data arrival. Roman Arutyunyan <arut@nginx.com> parents: 8783 diff changeset	1238 return NGX_ERROR;
7d32c3c93678 QUIC: call stream read handler on new data arrival. Roman Arutyunyan <arut@nginx.com> parents: 8783 diff changeset	1239 }
7d32c3c93678 QUIC: call stream read handler on new data arrival. Roman Arutyunyan <arut@nginx.com> parents: 8783 diff changeset	1240
9003 6c1dfd072859 QUIC: switch stream to DATA_RECVD state. Roman Arutyunyan <arut@nginx.com> parents: 8993 diff changeset	1241 if (qs->recv_state == NGX_QUIC_STREAM_RECV_SIZE_KNOWN
9011 f9c788f3f5cc QUIC: ngx_quic_buffer_t object. Roman Arutyunyan <arut@nginx.com> parents: 9010 diff changeset	1242 && qs->recv.size == qs->recv_final_size)
9003 6c1dfd072859 QUIC: switch stream to DATA_RECVD state. Roman Arutyunyan <arut@nginx.com> parents: 8993 diff changeset	1243 {
6c1dfd072859 QUIC: switch stream to DATA_RECVD state. Roman Arutyunyan <arut@nginx.com> parents: 8993 diff changeset	1244 qs->recv_state = NGX_QUIC_STREAM_RECV_DATA_RECVD;
6c1dfd072859 QUIC: switch stream to DATA_RECVD state. Roman Arutyunyan <arut@nginx.com> parents: 8993 diff changeset	1245 }
6c1dfd072859 QUIC: switch stream to DATA_RECVD state. Roman Arutyunyan <arut@nginx.com> parents: 8993 diff changeset	1246
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1247 if (qs->connection == NULL) {
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1248 return ngx_quic_close_stream(qs);
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1249 }
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1250
9045 c6580dce98a8 QUIC: fixed triggering stream read event (ticket #2409). Roman Arutyunyan <arut@nginx.com> parents: 9012 diff changeset	1251 if (f->offset <= qs->recv_offset) {
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1252 ngx_quic_set_event(qs->connection->read);
8784 7d32c3c93678 QUIC: call stream read handler on new data arrival. Roman Arutyunyan <arut@nginx.com> parents: 8783 diff changeset	1253 }
7d32c3c93678 QUIC: call stream read handler on new data arrival. Roman Arutyunyan <arut@nginx.com> parents: 8783 diff changeset	1254
7d32c3c93678 QUIC: call stream read handler on new data arrival. Roman Arutyunyan <arut@nginx.com> parents: 8783 diff changeset	1255 return NGX_OK;
8750 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
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1258
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1259 ngx_int_t
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1260 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	1261 ngx_quic_max_data_frame_t *f)
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 ngx_rbtree_t *tree;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1264 ngx_rbtree_node_t *node;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1265 ngx_quic_stream_t *qs;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1266 ngx_quic_connection_t *qc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1267
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1268 qc = ngx_quic_get_connection(c);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1269 tree = &qc->streams.tree;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1270
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1271 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	1272 return NGX_OK;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1273 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1274
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1275 if (tree->root == tree->sentinel
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1276 \|\| qc->streams.send_offset < qc->streams.send_max_data)
8841 1f7f98638dc2 QUIC: fixed null pointer dereference in MAX_DATA handler. Mariano Di Martino <mariano.dimartino@uhasselt.be> parents: 8828 diff changeset	1277 {
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1278 /* not blocked on MAX_DATA */
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1279 qc->streams.send_max_data = f->max_data;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1280 return NGX_OK;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1281 }
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 qc->streams.send_max_data = f->max_data;
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1284 node = ngx_rbtree_min(tree->root, tree->sentinel);
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1285
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1286 while (node && qc->streams.send_offset < qc->streams.send_max_data) {
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1287
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1288 qs = (ngx_quic_stream_t *) node;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1289 node = ngx_rbtree_next(tree, node);
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1290
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1291 if (ngx_quic_stream_flush(qs) != NGX_OK) {
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1292 return NGX_ERROR;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1293 }
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1294 }
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1295
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1296 return NGX_OK;
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
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1299
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1300 ngx_int_t
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1301 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	1302 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	1303 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1304 return NGX_OK;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1305 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1306
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1307
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1308 ngx_int_t
8909 d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1309 ngx_quic_handle_data_blocked_frame(ngx_connection_t *c,
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1310 ngx_quic_header_t pkt, ngx_quic_data_blocked_frame_t f)
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1311 {
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1312 return ngx_quic_update_max_data(c);
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1313 }
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1314
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1315
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1316 ngx_int_t
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1317 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	1318 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	1319 {
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1320 ngx_quic_stream_t *qs;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1321 ngx_quic_connection_t *qc;
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 qc = ngx_quic_get_connection(c);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1324
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1325 if ((f->id & NGX_QUIC_STREAM_UNIDIRECTIONAL)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1326 && (f->id & NGX_QUIC_STREAM_SERVER_INITIATED))
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1327 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1328 qc->error = NGX_QUIC_ERR_STREAM_STATE_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1329 return NGX_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1330 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1331
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	1332 qs = ngx_quic_get_stream(c, f->id);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1333
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1334 if (qs == NULL) {
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	1335 return NGX_ERROR;
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	1336 }
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1337
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	1338 if (qs == NGX_QUIC_STREAM_GONE) {
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	1339 return NGX_OK;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1340 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1341
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1342 return ngx_quic_update_max_stream_data(qs);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1343 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1344
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1345
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1346 ngx_int_t
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1347 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	1348 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	1349 {
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1350 ngx_quic_stream_t *qs;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1351 ngx_quic_connection_t *qc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1352
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1353 qc = ngx_quic_get_connection(c);
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 if ((f->id & NGX_QUIC_STREAM_UNIDIRECTIONAL)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1356 && (f->id & NGX_QUIC_STREAM_SERVER_INITIATED) == 0)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1357 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1358 qc->error = NGX_QUIC_ERR_STREAM_STATE_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1359 return NGX_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1360 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1361
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	1362 qs = ngx_quic_get_stream(c, f->id);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1363
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1364 if (qs == NULL) {
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	1365 return NGX_ERROR;
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	1366 }
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1367
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	1368 if (qs == NGX_QUIC_STREAM_GONE) {
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	1369 return NGX_OK;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1370 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1371
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1372 if (f->limit <= qs->send_max_data) {
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1373 return NGX_OK;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1374 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1375
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1376 if (qs->send_offset < qs->send_max_data) {
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1377 /* not blocked on MAX_STREAM_DATA */
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1378 qs->send_max_data = f->limit;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1379 return NGX_OK;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1380 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1381
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1382 qs->send_max_data = f->limit;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1383
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1384 return ngx_quic_stream_flush(qs);
8750 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
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1387
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1388 ngx_int_t
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1389 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	1390 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	1391 {
9065 2ee6f9729739 QUIC: set stream error flag on reset. Roman Arutyunyan <arut@nginx.com> parents: 9064 diff changeset	1392 ngx_event_t *rev;
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1393 ngx_quic_stream_t *qs;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1394 ngx_quic_connection_t *qc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1395
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1396 qc = ngx_quic_get_connection(c);
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 if ((f->id & NGX_QUIC_STREAM_UNIDIRECTIONAL)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1399 && (f->id & NGX_QUIC_STREAM_SERVER_INITIATED))
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1400 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1401 qc->error = NGX_QUIC_ERR_STREAM_STATE_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1402 return NGX_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1403 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1404
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	1405 qs = ngx_quic_get_stream(c, f->id);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1406
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1407 if (qs == NULL) {
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	1408 return NGX_ERROR;
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	1409 }
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1410
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	1411 if (qs == NGX_QUIC_STREAM_GONE) {
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	1412 return NGX_OK;
8750 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
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	1415 if (qs->recv_state == NGX_QUIC_STREAM_RECV_RESET_RECVD
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	1416 \|\| qs->recv_state == NGX_QUIC_STREAM_RECV_RESET_READ)
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	1417 {
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	1418 return NGX_OK;
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	1419 }
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1420
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	1421 qs->recv_state = NGX_QUIC_STREAM_RECV_RESET_RECVD;
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	1422
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1423 if (ngx_quic_control_flow(qs, f->final_size) != NGX_OK) {
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1424 return NGX_ERROR;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1425 }
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1426
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1427 if (qs->recv_final_size != (uint64_t) -1
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1428 && qs->recv_final_size != f->final_size)
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1429 {
8782 b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1430 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	1431 return NGX_ERROR;
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1432 }
b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1433
8783 60c6e8d8d3ae QUIC: make sure stream data size is lower than final size. Roman Arutyunyan <arut@nginx.com> parents: 8782 diff changeset	1434 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	1435 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	1436 return NGX_ERROR;
60c6e8d8d3ae QUIC: make sure stream data size is lower than final size. Roman Arutyunyan <arut@nginx.com> parents: 8782 diff changeset	1437 }
60c6e8d8d3ae QUIC: make sure stream data size is lower than final size. Roman Arutyunyan <arut@nginx.com> parents: 8782 diff changeset	1438
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1439 qs->recv_final_size = f->final_size;
8782 b3f6ad181df4 QUIC: refactored CRYPTO and STREAM buffer ordering. Roman Arutyunyan <arut@nginx.com> parents: 8779 diff changeset	1440
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1441 if (ngx_quic_update_flow(qs, qs->recv_final_size) != NGX_OK) {
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1442 return NGX_ERROR;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1443 }
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1444
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1445 if (qs->connection == NULL) {
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1446 return ngx_quic_close_stream(qs);
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1447 }
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1448
9065 2ee6f9729739 QUIC: set stream error flag on reset. Roman Arutyunyan <arut@nginx.com> parents: 9064 diff changeset	1449 rev = qs->connection->read;
2ee6f9729739 QUIC: set stream error flag on reset. Roman Arutyunyan <arut@nginx.com> parents: 9064 diff changeset	1450 rev->error = 1;
2ee6f9729739 QUIC: set stream error flag on reset. Roman Arutyunyan <arut@nginx.com> parents: 9064 diff changeset	1451
2ee6f9729739 QUIC: set stream error flag on reset. Roman Arutyunyan <arut@nginx.com> parents: 9064 diff changeset	1452 ngx_quic_set_event(rev);
8750 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 return NGX_OK;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1455 }
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 ngx_int_t
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1459 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	1460 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	1461 {
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1462 ngx_quic_stream_t *qs;
8750 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->id & NGX_QUIC_STREAM_UNIDIRECTIONAL)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1468 && (f->id & NGX_QUIC_STREAM_SERVER_INITIATED) == 0)
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1469 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1470 qc->error = NGX_QUIC_ERR_STREAM_STATE_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1471 return NGX_ERROR;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1472 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1473
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	1474 qs = ngx_quic_get_stream(c, f->id);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1475
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1476 if (qs == NULL) {
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	1477 return NGX_ERROR;
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	1478 }
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1479
8937 0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	1480 if (qs == NGX_QUIC_STREAM_GONE) {
0692355a3519 QUIC: simplified stream initialization. Roman Arutyunyan <arut@nginx.com> parents: 8936 diff changeset	1481 return NGX_OK;
8750 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
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1484 if (ngx_quic_do_reset_stream(qs, f->error_code) != NGX_OK) {
8876 1ead7d64e993 QUIC: send RESET_STREAM in response to STOP_SENDING. Roman Arutyunyan <arut@nginx.com> parents: 8875 diff changeset	1485 return NGX_ERROR;
1ead7d64e993 QUIC: send RESET_STREAM in response to STOP_SENDING. Roman Arutyunyan <arut@nginx.com> parents: 8875 diff changeset	1486 }
1ead7d64e993 QUIC: send RESET_STREAM in response to STOP_SENDING. Roman Arutyunyan <arut@nginx.com> parents: 8875 diff changeset	1487
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1488 if (qs->connection == NULL) {
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1489 return ngx_quic_close_stream(qs);
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1490 }
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1491
8993 7626aa7a2156 QUIC: stream event setting function. Roman Arutyunyan <arut@nginx.com> parents: 8990 diff changeset	1492 ngx_quic_set_event(qs->connection->write);
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1493
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1494 return NGX_OK;
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
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1497
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1498 ngx_int_t
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1499 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	1500 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	1501 {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1502 ngx_quic_connection_t *qc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1503
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1504 qc = ngx_quic_get_connection(c);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1505
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1506 if (f->bidi) {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1507 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	1508 qc->streams.server_max_streams_bidi = f->limit;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1509
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1510 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	1511 "quic max_streams_bidi:%uL", f->limit);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1512 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1513
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1514 } else {
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1515 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	1516 qc->streams.server_max_streams_uni = f->limit;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1517
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1518 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	1519 "quic max_streams_uni:%uL", f->limit);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1520 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1521 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1522
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1523 return NGX_OK;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1524 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1525
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1526
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1527 void
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1528 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	1529 {
9052 2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1530 uint64_t acked;
8761 225e9f1dfe7c QUIC: renamed stream variables from sn to qs. Roman Arutyunyan <arut@nginx.com> parents: 8760 diff changeset	1531 ngx_quic_stream_t *qs;
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1532 ngx_quic_connection_t *qc;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1533
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1534 qc = ngx_quic_get_connection(c);
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1535
9052 2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1536 switch (f->type) {
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1537
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1538 case NGX_QUIC_FT_RESET_STREAM:
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1539
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1540 qs = ngx_quic_find_stream(&qc->streams.tree, f->u.reset_stream.id);
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1541 if (qs == NULL) {
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1542 return;
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1543 }
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1544
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1545 qs->send_state = NGX_QUIC_STREAM_SEND_RESET_RECVD;
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1546
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1547 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, c->log, 0,
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1548 "quic stream id:0x%xL ack reset final_size:%uL",
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1549 qs->id, f->u.reset_stream.final_size);
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1550
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1551 break;
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1552
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1553 case NGX_QUIC_FT_STREAM:
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1554
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1555 qs = ngx_quic_find_stream(&qc->streams.tree, f->u.stream.stream_id);
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1556 if (qs == NULL) {
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1557 return;
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1558 }
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1559
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1560 acked = qs->acked;
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1561 qs->acked += f->u.stream.length;
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1562
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1563 if (f->u.stream.fin) {
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1564 qs->fin_acked = 1;
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1565 }
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1566
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1567 if (qs->send_state == NGX_QUIC_STREAM_SEND_DATA_SENT
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1568 && qs->acked == qs->sent && qs->fin_acked)
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1569 {
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1570 qs->send_state = NGX_QUIC_STREAM_SEND_DATA_RECVD;
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1571 }
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1572
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1573 ngx_log_debug4(NGX_LOG_DEBUG_EVENT, c->log, 0,
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1574 "quic stream id:0x%xL ack len:%uL fin:%d unacked:%uL",
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1575 qs->id, f->u.stream.length, f->u.stream.fin,
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1576 qs->sent - qs->acked);
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1577
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1578 if (qs->connection
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1579 && qs->sent - acked == qc->conf->stream_buffer_size
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1580 && f->u.stream.length > 0)
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1581 {
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1582 ngx_quic_set_event(qs->connection->write);
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1583 }
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1584
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1585 break;
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1586
2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1587 default:
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1588 return;
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1589 }
41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1590
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1591 if (qs->connection == NULL) {
9052 2e51cf3ffd90 QUIC: defer stream removal until all its data is acked. Roman Arutyunyan <arut@nginx.com> parents: 9051 diff changeset	1592 ngx_quic_close_stream(qs);
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1593 }
8750 41807e581de9 QUIC: separate files for stream related processing. Vladimir Homutov <vl@nginx.com> parents: diff changeset	1594 }
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1595
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1596
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1597 static ngx_int_t
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1598 ngx_quic_control_flow(ngx_quic_stream_t *qs, uint64_t last)
8791 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 uint64_t len;
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1601 ngx_connection_t *pc;
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1602 ngx_quic_connection_t *qc;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1603
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1604 pc = qs->parent;
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1605 qc = ngx_quic_get_connection(pc);
8791 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 if (last <= qs->recv_last) {
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1608 return NGX_OK;
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
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1611 len = last - qs->recv_last;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1612
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1613 ngx_log_debug5(NGX_LOG_DEBUG_EVENT, pc->log, 0,
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1614 "quic stream id:0x%xL flow control msd:%uL/%uL md:%uL/%uL",
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1615 qs->id, last, qs->recv_max_data, qc->streams.recv_last + len,
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1616 qc->streams.recv_max_data);
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1617
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1618 qs->recv_last += len;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1619
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	1620 if (qs->recv_state == NGX_QUIC_STREAM_RECV_RECV
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	1621 && qs->recv_last > qs->recv_max_data)
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	1622 {
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1623 qc->error = NGX_QUIC_ERR_FLOW_CONTROL_ERROR;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1624 return NGX_ERROR;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1625 }
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1626
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1627 qc->streams.recv_last += len;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1628
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1629 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	1630 qc->error = NGX_QUIC_ERR_FLOW_CONTROL_ERROR;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1631 return NGX_ERROR;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1632 }
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1633
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1634 return NGX_OK;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1635 }
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1636
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1637
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1638 static ngx_int_t
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1639 ngx_quic_update_flow(ngx_quic_stream_t *qs, uint64_t last)
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1640 {
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1641 uint64_t len;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1642 ngx_connection_t *pc;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1643 ngx_quic_connection_t *qc;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1644
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1645 pc = qs->parent;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1646 qc = ngx_quic_get_connection(pc);
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1647
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1648 if (last <= qs->recv_offset) {
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1649 return NGX_OK;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1650 }
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1651
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1652 len = last - qs->recv_offset;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1653
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1654 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, pc->log, 0,
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1655 "quic stream id:0x%xL flow update %uL", qs->id, last);
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1656
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1657 qs->recv_offset += len;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1658
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	1659 if (qs->recv_max_data <= qs->recv_offset + qs->recv_window / 2) {
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1660 if (ngx_quic_update_max_stream_data(qs) != NGX_OK) {
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1661 return NGX_ERROR;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1662 }
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1663 }
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1664
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1665 qc->streams.recv_offset += len;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1666
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1667 if (qc->streams.recv_max_data
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1668 <= qc->streams.recv_offset + qc->streams.recv_window / 2)
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1669 {
8909 d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1670 if (ngx_quic_update_max_data(pc) != NGX_OK) {
8791 af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1671 return NGX_ERROR;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1672 }
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1673 }
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1674
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1675 return NGX_OK;
af33d1ef1c3c QUIC: stream flow control refactored. Roman Arutyunyan <arut@nginx.com> parents: 8784 diff changeset	1676 }
8855 9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1677
9ae239d2547d QUIC: separate event handling functions. Roman Arutyunyan <arut@nginx.com> parents: 8842 diff changeset	1678
8908 e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1679 static ngx_int_t
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1680 ngx_quic_update_max_stream_data(ngx_quic_stream_t *qs)
8908 e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1681 {
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1682 uint64_t recv_max_data;
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1683 ngx_connection_t *pc;
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1684 ngx_quic_frame_t *frame;
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1685 ngx_quic_connection_t *qc;
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1686
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1687 pc = qs->parent;
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1688 qc = ngx_quic_get_connection(pc);
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1689
8990 b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	1690 if (qs->recv_state != NGX_QUIC_STREAM_RECV_RECV) {
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	1691 return NGX_OK;
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	1692 }
b42a041d23a2 QUIC: introduced explicit stream states. Roman Arutyunyan <arut@nginx.com> parents: 8988 diff changeset	1693
8908 e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1694 recv_max_data = qs->recv_offset + qs->recv_window;
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1695
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1696 if (qs->recv_max_data == recv_max_data) {
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1697 return NGX_OK;
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1698 }
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1699
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1700 qs->recv_max_data = recv_max_data;
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1701
9010 a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1702 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, pc->log, 0,
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1703 "quic stream id:0x%xL flow update msd:%uL",
a5aebd51e4c7 QUIC: stream lingering. Roman Arutyunyan <arut@nginx.com> parents: 9005 diff changeset	1704 qs->id, qs->recv_max_data);
8908 e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1705
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1706 frame = ngx_quic_alloc_frame(pc);
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1707 if (frame == NULL) {
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1708 return NGX_ERROR;
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1709 }
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1710
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1711 frame->level = ssl_encryption_application;
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1712 frame->type = NGX_QUIC_FT_MAX_STREAM_DATA;
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1713 frame->u.max_stream_data.id = qs->id;
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1714 frame->u.max_stream_data.limit = qs->recv_max_data;
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1715
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1716 ngx_quic_queue_frame(qc, frame);
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1717
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1718 return NGX_OK;
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1719 }
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1720
e8cbbfabe547 QUIC: update stream flow control credit on STREAM_DATA_BLOCKED. Roman Arutyunyan <arut@nginx.com> parents: 8906 diff changeset	1721
8909 d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1722 static ngx_int_t
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1723 ngx_quic_update_max_data(ngx_connection_t *c)
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1724 {
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1725 uint64_t recv_max_data;
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1726 ngx_quic_frame_t *frame;
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1727 ngx_quic_connection_t *qc;
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1728
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1729 qc = ngx_quic_get_connection(c);
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1730
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1731 recv_max_data = qc->streams.recv_offset + qc->streams.recv_window;
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1732
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1733 if (qc->streams.recv_max_data == recv_max_data) {
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1734 return NGX_OK;
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1735 }
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1736
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1737 qc->streams.recv_max_data = recv_max_data;
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1738
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1739 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0,
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1740 "quic flow update md:%uL", qc->streams.recv_max_data);
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1741
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1742 frame = ngx_quic_alloc_frame(c);
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1743 if (frame == NULL) {
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1744 return NGX_ERROR;
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1745 }
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1746
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1747 frame->level = ssl_encryption_application;
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1748 frame->type = NGX_QUIC_FT_MAX_DATA;
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1749 frame->u.max_data.max_data = qc->streams.recv_max_data;
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1750
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1751 ngx_quic_queue_frame(qc, frame);
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1752
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1753 return NGX_OK;
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1754 }
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1755
d041b8d6ab0b QUIC: handle DATA_BLOCKED frame from client. Roman Arutyunyan <arut@nginx.com> parents: 8908 diff changeset	1756
8993 7626aa7a2156 QUIC: stream event setting function. Roman Arutyunyan <arut@nginx.com> parents: 8990 diff changeset	1757 static void
7626aa7a2156 QUIC: stream event setting function. Roman Arutyunyan <arut@nginx.com> parents: 8990 diff changeset	1758 ngx_quic_set_event(ngx_event_t *ev)
7626aa7a2156 QUIC: stream event setting function. Roman Arutyunyan <arut@nginx.com> parents: 8990 diff changeset	1759 {
7626aa7a2156 QUIC: stream event setting function. Roman Arutyunyan <arut@nginx.com> parents: 8990 diff changeset	1760 ev->ready = 1;
7626aa7a2156 QUIC: stream event setting function. Roman Arutyunyan <arut@nginx.com> parents: 8990 diff changeset	1761
7626aa7a2156 QUIC: stream event setting function. Roman Arutyunyan <arut@nginx.com> parents: 8990 diff changeset	1762 if (ev->active) {
7626aa7a2156 QUIC: stream event setting function. Roman Arutyunyan <arut@nginx.com> parents: 8990 diff changeset	1763 ngx_post_event(ev, &ngx_posted_events);
7626aa7a2156 QUIC: stream event setting function. Roman Arutyunyan <arut@nginx.com> parents: 8990 diff changeset	1764 }
7626aa7a2156 QUIC: stream event setting function. Roman Arutyunyan <arut@nginx.com> parents: 8990 diff changeset	1765 }

Mercurial > hg > nginx

annotate src/event/quic/ngx_event_quic_streams.c @ 9065:2ee6f9729739 quic