nginx-quic: src/stream/ngx_stream

annotate src/stream/ngx_stream_handler.c @ 8240:43f3574b3e6f quic

QUIC: fixed handling of clients connected to wildcard address. The patch replaces c->send() occurences with c->send_chain(), because the latter accounts for the local address, which may be different if the wildcard listener is used. Previously, server sent response to client using address different from one client connected to.

author	Vladimir Homutov <vl@nginx.com>
date	Mon, 07 Dec 2020 14:06:00 +0300
parents	279ad36f2f4b
children	e96c20b6f655

rev	line source
6115 61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	1
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	2 /*
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	3 * Copyright (C) Roman Arutyunyan
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	4 * Copyright (C) Nginx, Inc.
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	5 */
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	6
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	7
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	8 #include <ngx_config.h>
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	9 #include <ngx_core.h>
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	10 #include <ngx_event.h>
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	11 #include <ngx_stream.h>
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	12
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	13
6693 3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	14 static void ngx_stream_log_session(ngx_stream_session_t *s);
6674 38143d1abdec Stream: the $status variable. Roman Arutyunyan <arut@nginx.com> parents: 6669 diff changeset	15 static void ngx_stream_close_connection(ngx_connection_t *c);
6115 61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	16 static u_char ngx_stream_log_error(ngx_log_t log, u_char *buf, size_t len);
6680 7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	17 static void ngx_stream_proxy_protocol_handler(ngx_event_t *rev);
6115 61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	18
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	19
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	20 void
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	21 ngx_stream_init_connection(ngx_connection_t *c)
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	22 {
6175 8807a2369b1a Stream: access module. Vladimir Homutov <vl@nginx.com> parents: 6129 diff changeset	23 u_char text[NGX_SOCKADDR_STRLEN];
8807a2369b1a Stream: access module. Vladimir Homutov <vl@nginx.com> parents: 6129 diff changeset	24 size_t len;
8807a2369b1a Stream: access module. Vladimir Homutov <vl@nginx.com> parents: 6129 diff changeset	25 ngx_uint_t i;
6669 164a0824ce20 Stream: the $session_time variable. Vladimir Homutov <vl@nginx.com> parents: 6607 diff changeset	26 ngx_time_t *tp;
6679 40e8ce405859 Stream: postpone session initialization under accept mutex. Dmitry Volyntsev <xeioex@nginx.com> parents: 6678 diff changeset	27 ngx_event_t *rev;
6175 8807a2369b1a Stream: access module. Vladimir Homutov <vl@nginx.com> parents: 6129 diff changeset	28 struct sockaddr *sa;
8807a2369b1a Stream: access module. Vladimir Homutov <vl@nginx.com> parents: 6129 diff changeset	29 ngx_stream_port_t *port;
8807a2369b1a Stream: access module. Vladimir Homutov <vl@nginx.com> parents: 6129 diff changeset	30 struct sockaddr_in *sin;
8807a2369b1a Stream: access module. Vladimir Homutov <vl@nginx.com> parents: 6129 diff changeset	31 ngx_stream_in_addr_t *addr;
8807a2369b1a Stream: access module. Vladimir Homutov <vl@nginx.com> parents: 6129 diff changeset	32 ngx_stream_session_t *s;
8807a2369b1a Stream: access module. Vladimir Homutov <vl@nginx.com> parents: 6129 diff changeset	33 ngx_stream_addr_conf_t *addr_conf;
6115 61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	34 #if (NGX_HAVE_INET6)
6175 8807a2369b1a Stream: access module. Vladimir Homutov <vl@nginx.com> parents: 6129 diff changeset	35 struct sockaddr_in6 *sin6;
8807a2369b1a Stream: access module. Vladimir Homutov <vl@nginx.com> parents: 6129 diff changeset	36 ngx_stream_in6_addr_t *addr6;
6115 61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	37 #endif
6175 8807a2369b1a Stream: access module. Vladimir Homutov <vl@nginx.com> parents: 6129 diff changeset	38 ngx_stream_core_srv_conf_t *cscf;
8807a2369b1a Stream: access module. Vladimir Homutov <vl@nginx.com> parents: 6129 diff changeset	39 ngx_stream_core_main_conf_t *cmcf;
6115 61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	40
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	41 /* find the server configuration for the address:port */
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	42
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	43 port = c->listening->servers;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	44
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	45 if (port->naddrs > 1) {
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	46
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	47 /*
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	48 * There are several addresses on this port and one of them
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	49 * is the "*:port" wildcard so getsockname() is needed to determine
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	50 * the server address.
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	51 *
6436 8f038068f4bc Stream: UDP proxy. Roman Arutyunyan <arut@nginx.com> parents: 6223 diff changeset	52 * AcceptEx() and recvmsg() already gave this address.
6115 61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	53 */
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	54
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	55 if (ngx_connection_local_sockaddr(c, NULL, 0) != NGX_OK) {
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	56 ngx_stream_close_connection(c);
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	57 return;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	58 }
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	59
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	60 sa = c->local_sockaddr;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	61
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	62 switch (sa->sa_family) {
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	63
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	64 #if (NGX_HAVE_INET6)
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	65 case AF_INET6:
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	66 sin6 = (struct sockaddr_in6 *) sa;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	67
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	68 addr6 = port->addrs;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	69
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	70 /* the last address is "" /
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	71
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	72 for (i = 0; i < port->naddrs - 1; i++) {
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	73 if (ngx_memcmp(&addr6[i].addr6, &sin6->sin6_addr, 16) == 0) {
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	74 break;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	75 }
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	76 }
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	77
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	78 addr_conf = &addr6[i].conf;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	79
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	80 break;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	81 #endif
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	82
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	83 default: /* AF_INET */
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	84 sin = (struct sockaddr_in *) sa;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	85
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	86 addr = port->addrs;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	87
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	88 /* the last address is "" /
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	89
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	90 for (i = 0; i < port->naddrs - 1; i++) {
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	91 if (addr[i].addr == sin->sin_addr.s_addr) {
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	92 break;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	93 }
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	94 }
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	95
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	96 addr_conf = &addr[i].conf;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	97
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	98 break;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	99 }
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	100
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	101 } else {
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	102 switch (c->local_sockaddr->sa_family) {
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	103
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	104 #if (NGX_HAVE_INET6)
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	105 case AF_INET6:
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	106 addr6 = port->addrs;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	107 addr_conf = &addr6[0].conf;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	108 break;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	109 #endif
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	110
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	111 default: /* AF_INET */
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	112 addr = port->addrs;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	113 addr_conf = &addr[0].conf;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	114 break;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	115 }
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	116 }
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	117
8000 893b3313f53c QUIC: added "quic" listen parameter in Stream. Roman Arutyunyan <arut@nginx.com> parents: 6693 diff changeset	118 #if (NGX_STREAM_QUIC)
893b3313f53c QUIC: added "quic" listen parameter in Stream. Roman Arutyunyan <arut@nginx.com> parents: 6693 diff changeset	119
893b3313f53c QUIC: added "quic" listen parameter in Stream. Roman Arutyunyan <arut@nginx.com> parents: 6693 diff changeset	120 if (addr_conf->quic) {
8101 bed310672f39 QUIC: moved ssl configuration pointer to quic configuration. Vladimir Homutov <vl@nginx.com> parents: 8001 diff changeset	121 ngx_quic_conf_t *qcf;
8000 893b3313f53c QUIC: added "quic" listen parameter in Stream. Roman Arutyunyan <arut@nginx.com> parents: 6693 diff changeset	122
8200 279ad36f2f4b QUIC: renamed c->qs to c->quic. Roman Arutyunyan <arut@nginx.com> parents: 8101 diff changeset	123 if (c->quic == NULL) {
8000 893b3313f53c QUIC: added "quic" listen parameter in Stream. Roman Arutyunyan <arut@nginx.com> parents: 6693 diff changeset	124 c->log->connection = c->number;
893b3313f53c QUIC: added "quic" listen parameter in Stream. Roman Arutyunyan <arut@nginx.com> parents: 6693 diff changeset	125
893b3313f53c QUIC: added "quic" listen parameter in Stream. Roman Arutyunyan <arut@nginx.com> parents: 6693 diff changeset	126 qcf = ngx_stream_get_module_srv_conf(addr_conf->ctx,
893b3313f53c QUIC: added "quic" listen parameter in Stream. Roman Arutyunyan <arut@nginx.com> parents: 6693 diff changeset	127 ngx_stream_quic_module);
8101 bed310672f39 QUIC: moved ssl configuration pointer to quic configuration. Vladimir Homutov <vl@nginx.com> parents: 8001 diff changeset	128 ngx_quic_run(c, qcf);
8000 893b3313f53c QUIC: added "quic" listen parameter in Stream. Roman Arutyunyan <arut@nginx.com> parents: 6693 diff changeset	129 return;
893b3313f53c QUIC: added "quic" listen parameter in Stream. Roman Arutyunyan <arut@nginx.com> parents: 6693 diff changeset	130 }
893b3313f53c QUIC: added "quic" listen parameter in Stream. Roman Arutyunyan <arut@nginx.com> parents: 6693 diff changeset	131 }
893b3313f53c QUIC: added "quic" listen parameter in Stream. Roman Arutyunyan <arut@nginx.com> parents: 6693 diff changeset	132
893b3313f53c QUIC: added "quic" listen parameter in Stream. Roman Arutyunyan <arut@nginx.com> parents: 6693 diff changeset	133 #endif
893b3313f53c QUIC: added "quic" listen parameter in Stream. Roman Arutyunyan <arut@nginx.com> parents: 6693 diff changeset	134
6115 61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	135 s = ngx_pcalloc(c->pool, sizeof(ngx_stream_session_t));
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	136 if (s == NULL) {
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	137 ngx_stream_close_connection(c);
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	138 return;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	139 }
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	140
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	141 s->signature = NGX_STREAM_MODULE;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	142 s->main_conf = addr_conf->ctx->main_conf;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	143 s->srv_conf = addr_conf->ctx->srv_conf;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	144
6679 40e8ce405859 Stream: postpone session initialization under accept mutex. Dmitry Volyntsev <xeioex@nginx.com> parents: 6678 diff changeset	145 #if (NGX_STREAM_SSL)
40e8ce405859 Stream: postpone session initialization under accept mutex. Dmitry Volyntsev <xeioex@nginx.com> parents: 6678 diff changeset	146 s->ssl = addr_conf->ssl;
40e8ce405859 Stream: postpone session initialization under accept mutex. Dmitry Volyntsev <xeioex@nginx.com> parents: 6678 diff changeset	147 #endif
40e8ce405859 Stream: postpone session initialization under accept mutex. Dmitry Volyntsev <xeioex@nginx.com> parents: 6678 diff changeset	148
6692 56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: 6684 diff changeset	149 if (c->buffer) {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: 6684 diff changeset	150 s->received += c->buffer->last - c->buffer->pos;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: 6684 diff changeset	151 }
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: 6684 diff changeset	152
6115 61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	153 s->connection = c;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	154 c->data = s;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	155
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	156 cscf = ngx_stream_get_module_srv_conf(s, ngx_stream_core_module);
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	157
6129 187aa751ad62 Core: the ngx_set_connection_log() macro. Vladimir Homutov <vl@nginx.com> parents: 6115 diff changeset	158 ngx_set_connection_log(c, cscf->error_log);
6115 61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	159
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	160 len = ngx_sock_ntop(c->sockaddr, c->socklen, text, NGX_SOCKADDR_STRLEN, 1);
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	161
6461 a01e315b3a78 Stream: additional logging for UDP. Vladimir Homutov <vl@nginx.com> parents: 6436 diff changeset	162 ngx_log_error(NGX_LOG_INFO, c->log, 0, "%uA %sclient %s connected to %V",
a01e315b3a78 Stream: additional logging for UDP. Vladimir Homutov <vl@nginx.com> parents: 6436 diff changeset	163 c->number, c->type == SOCK_DGRAM ? "udp " : "",
a01e315b3a78 Stream: additional logging for UDP. Vladimir Homutov <vl@nginx.com> parents: 6436 diff changeset	164 len, text, &addr_conf->addr_text);
6115 61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	165
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	166 c->log->connection = c->number;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	167 c->log->handler = ngx_stream_log_error;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	168 c->log->data = s;
6693 3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	169 c->log->action = "initializing session";
6115 61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	170 c->log_error = NGX_ERROR_INFO;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	171
6682 db422604ceb0 Stream: allow using the session context inside handlers. Dmitry Volyntsev <xeioex@nginx.com> parents: 6680 diff changeset	172 s->ctx = ngx_pcalloc(c->pool, sizeof(void ) ngx_stream_max_module);
db422604ceb0 Stream: allow using the session context inside handlers. Dmitry Volyntsev <xeioex@nginx.com> parents: 6680 diff changeset	173 if (s->ctx == NULL) {
db422604ceb0 Stream: allow using the session context inside handlers. Dmitry Volyntsev <xeioex@nginx.com> parents: 6680 diff changeset	174 ngx_stream_close_connection(c);
db422604ceb0 Stream: allow using the session context inside handlers. Dmitry Volyntsev <xeioex@nginx.com> parents: 6680 diff changeset	175 return;
db422604ceb0 Stream: allow using the session context inside handlers. Dmitry Volyntsev <xeioex@nginx.com> parents: 6680 diff changeset	176 }
db422604ceb0 Stream: allow using the session context inside handlers. Dmitry Volyntsev <xeioex@nginx.com> parents: 6680 diff changeset	177
6175 8807a2369b1a Stream: access module. Vladimir Homutov <vl@nginx.com> parents: 6129 diff changeset	178 cmcf = ngx_stream_get_module_main_conf(s, ngx_stream_core_module);
8807a2369b1a Stream: access module. Vladimir Homutov <vl@nginx.com> parents: 6129 diff changeset	179
6607 c70b7f4537e1 Stream: variables and script. Vladimir Homutov <vl@nginx.com> parents: 6461 diff changeset	180 s->variables = ngx_pcalloc(s->connection->pool,
c70b7f4537e1 Stream: variables and script. Vladimir Homutov <vl@nginx.com> parents: 6461 diff changeset	181 cmcf->variables.nelts
c70b7f4537e1 Stream: variables and script. Vladimir Homutov <vl@nginx.com> parents: 6461 diff changeset	182 * sizeof(ngx_stream_variable_value_t));
c70b7f4537e1 Stream: variables and script. Vladimir Homutov <vl@nginx.com> parents: 6461 diff changeset	183
c70b7f4537e1 Stream: variables and script. Vladimir Homutov <vl@nginx.com> parents: 6461 diff changeset	184 if (s->variables == NULL) {
c70b7f4537e1 Stream: variables and script. Vladimir Homutov <vl@nginx.com> parents: 6461 diff changeset	185 ngx_stream_close_connection(c);
c70b7f4537e1 Stream: variables and script. Vladimir Homutov <vl@nginx.com> parents: 6461 diff changeset	186 return;
c70b7f4537e1 Stream: variables and script. Vladimir Homutov <vl@nginx.com> parents: 6461 diff changeset	187 }
c70b7f4537e1 Stream: variables and script. Vladimir Homutov <vl@nginx.com> parents: 6461 diff changeset	188
6669 164a0824ce20 Stream: the $session_time variable. Vladimir Homutov <vl@nginx.com> parents: 6607 diff changeset	189 tp = ngx_timeofday();
164a0824ce20 Stream: the $session_time variable. Vladimir Homutov <vl@nginx.com> parents: 6607 diff changeset	190 s->start_sec = tp->sec;
164a0824ce20 Stream: the $session_time variable. Vladimir Homutov <vl@nginx.com> parents: 6607 diff changeset	191 s->start_msec = tp->msec;
164a0824ce20 Stream: the $session_time variable. Vladimir Homutov <vl@nginx.com> parents: 6607 diff changeset	192
6679 40e8ce405859 Stream: postpone session initialization under accept mutex. Dmitry Volyntsev <xeioex@nginx.com> parents: 6678 diff changeset	193 rev = c->read;
6693 3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	194 rev->handler = ngx_stream_session_handler;
6679 40e8ce405859 Stream: postpone session initialization under accept mutex. Dmitry Volyntsev <xeioex@nginx.com> parents: 6678 diff changeset	195
6680 7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	196 if (addr_conf->proxy_protocol) {
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	197 c->log->action = "reading PROXY protocol";
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	198
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	199 rev->handler = ngx_stream_proxy_protocol_handler;
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	200
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	201 if (!rev->ready) {
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	202 ngx_add_timer(rev, cscf->proxy_protocol_timeout);
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	203
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	204 if (ngx_handle_read_event(rev, 0) != NGX_OK) {
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	205 ngx_stream_finalize_session(s,
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	206 NGX_STREAM_INTERNAL_SERVER_ERROR);
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	207 }
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	208
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	209 return;
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	210 }
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	211 }
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	212
6679 40e8ce405859 Stream: postpone session initialization under accept mutex. Dmitry Volyntsev <xeioex@nginx.com> parents: 6678 diff changeset	213 if (ngx_use_accept_mutex) {
40e8ce405859 Stream: postpone session initialization under accept mutex. Dmitry Volyntsev <xeioex@nginx.com> parents: 6678 diff changeset	214 ngx_post_event(rev, &ngx_posted_events);
40e8ce405859 Stream: postpone session initialization under accept mutex. Dmitry Volyntsev <xeioex@nginx.com> parents: 6678 diff changeset	215 return;
40e8ce405859 Stream: postpone session initialization under accept mutex. Dmitry Volyntsev <xeioex@nginx.com> parents: 6678 diff changeset	216 }
40e8ce405859 Stream: postpone session initialization under accept mutex. Dmitry Volyntsev <xeioex@nginx.com> parents: 6678 diff changeset	217
40e8ce405859 Stream: postpone session initialization under accept mutex. Dmitry Volyntsev <xeioex@nginx.com> parents: 6678 diff changeset	218 rev->handler(rev);
40e8ce405859 Stream: postpone session initialization under accept mutex. Dmitry Volyntsev <xeioex@nginx.com> parents: 6678 diff changeset	219 }
40e8ce405859 Stream: postpone session initialization under accept mutex. Dmitry Volyntsev <xeioex@nginx.com> parents: 6678 diff changeset	220
40e8ce405859 Stream: postpone session initialization under accept mutex. Dmitry Volyntsev <xeioex@nginx.com> parents: 6678 diff changeset	221
40e8ce405859 Stream: postpone session initialization under accept mutex. Dmitry Volyntsev <xeioex@nginx.com> parents: 6678 diff changeset	222 static void
6680 7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	223 ngx_stream_proxy_protocol_handler(ngx_event_t *rev)
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	224 {
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	225 u_char *p, buf[NGX_PROXY_PROTOCOL_MAX_HEADER];
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	226 size_t size;
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	227 ssize_t n;
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	228 ngx_err_t err;
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	229 ngx_connection_t *c;
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	230 ngx_stream_session_t *s;
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	231 ngx_stream_core_srv_conf_t *cscf;
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	232
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	233 c = rev->data;
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	234 s = c->data;
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	235
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	236 ngx_log_debug0(NGX_LOG_DEBUG_STREAM, c->log, 0,
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	237 "stream PROXY protocol handler");
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	238
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	239 if (rev->timedout) {
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	240 ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, "client timed out");
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	241 ngx_stream_finalize_session(s, NGX_STREAM_OK);
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	242 return;
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	243 }
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	244
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	245 n = recv(c->fd, (char *) buf, sizeof(buf), MSG_PEEK);
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	246
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	247 err = ngx_socket_errno;
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	248
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	249 ngx_log_debug1(NGX_LOG_DEBUG_STREAM, c->log, 0, "recv(): %z", n);
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	250
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	251 if (n == -1) {
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	252 if (err == NGX_EAGAIN) {
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	253 rev->ready = 0;
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	254
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	255 if (!rev->timer_set) {
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	256 cscf = ngx_stream_get_module_srv_conf(s,
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	257 ngx_stream_core_module);
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	258
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	259 ngx_add_timer(rev, cscf->proxy_protocol_timeout);
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	260 }
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	261
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	262 if (ngx_handle_read_event(rev, 0) != NGX_OK) {
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	263 ngx_stream_finalize_session(s,
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	264 NGX_STREAM_INTERNAL_SERVER_ERROR);
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	265 }
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	266
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	267 return;
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	268 }
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	269
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	270 ngx_connection_error(c, err, "recv() failed");
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	271
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	272 ngx_stream_finalize_session(s, NGX_STREAM_OK);
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	273 return;
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	274 }
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	275
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	276 if (rev->timer_set) {
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	277 ngx_del_timer(rev);
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	278 }
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	279
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	280 p = ngx_proxy_protocol_read(c, buf, buf + n);
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	281
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	282 if (p == NULL) {
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	283 ngx_stream_finalize_session(s, NGX_STREAM_BAD_REQUEST);
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	284 return;
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	285 }
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	286
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	287 size = p - buf;
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	288
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	289 if (c->recv(c, buf, size) != (ssize_t) size) {
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	290 ngx_stream_finalize_session(s, NGX_STREAM_INTERNAL_SERVER_ERROR);
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	291 return;
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	292 }
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	293
6693 3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	294 c->log->action = "initializing session";
3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	295
3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	296 ngx_stream_session_handler(rev);
6680 7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	297 }
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	298
7357abd1fa8c Stream: the "proxy_protocol" parameter of the "listen" directive. Dmitry Volyntsev <xeioex@nginx.com> parents: 6679 diff changeset	299
6693 3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	300 void
3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	301 ngx_stream_session_handler(ngx_event_t *rev)
6679 40e8ce405859 Stream: postpone session initialization under accept mutex. Dmitry Volyntsev <xeioex@nginx.com> parents: 6678 diff changeset	302 {
6693 3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	303 ngx_connection_t *c;
3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	304 ngx_stream_session_t *s;
6679 40e8ce405859 Stream: postpone session initialization under accept mutex. Dmitry Volyntsev <xeioex@nginx.com> parents: 6678 diff changeset	305
40e8ce405859 Stream: postpone session initialization under accept mutex. Dmitry Volyntsev <xeioex@nginx.com> parents: 6678 diff changeset	306 c = rev->data;
40e8ce405859 Stream: postpone session initialization under accept mutex. Dmitry Volyntsev <xeioex@nginx.com> parents: 6678 diff changeset	307 s = c->data;
40e8ce405859 Stream: postpone session initialization under accept mutex. Dmitry Volyntsev <xeioex@nginx.com> parents: 6678 diff changeset	308
6693 3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	309 ngx_stream_core_run_phases(s);
6115 61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	310 }
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	311
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	312
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	313 void
6674 38143d1abdec Stream: the $status variable. Roman Arutyunyan <arut@nginx.com> parents: 6669 diff changeset	314 ngx_stream_finalize_session(ngx_stream_session_t *s, ngx_uint_t rc)
38143d1abdec Stream: the $status variable. Roman Arutyunyan <arut@nginx.com> parents: 6669 diff changeset	315 {
38143d1abdec Stream: the $status variable. Roman Arutyunyan <arut@nginx.com> parents: 6669 diff changeset	316 ngx_log_debug1(NGX_LOG_DEBUG_STREAM, s->connection->log, 0,
38143d1abdec Stream: the $status variable. Roman Arutyunyan <arut@nginx.com> parents: 6669 diff changeset	317 "finalize stream session: %i", rc);
38143d1abdec Stream: the $status variable. Roman Arutyunyan <arut@nginx.com> parents: 6669 diff changeset	318
38143d1abdec Stream: the $status variable. Roman Arutyunyan <arut@nginx.com> parents: 6669 diff changeset	319 s->status = rc;
38143d1abdec Stream: the $status variable. Roman Arutyunyan <arut@nginx.com> parents: 6669 diff changeset	320
6693 3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	321 ngx_stream_log_session(s);
3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	322
3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	323 ngx_stream_close_connection(s->connection);
3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	324 }
3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	325
3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	326
3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	327 static void
3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	328 ngx_stream_log_session(ngx_stream_session_t *s)
3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	329 {
3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	330 ngx_uint_t i, n;
3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	331 ngx_stream_handler_pt *log_handler;
3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	332 ngx_stream_core_main_conf_t *cmcf;
3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	333
6678 0125b151c9a5 Stream: log module. Vladimir Homutov <vl@nginx.com> parents: 6674 diff changeset	334 cmcf = ngx_stream_get_module_main_conf(s, ngx_stream_core_module);
0125b151c9a5 Stream: log module. Vladimir Homutov <vl@nginx.com> parents: 6674 diff changeset	335
6693 3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	336 log_handler = cmcf->phases[NGX_STREAM_LOG_PHASE].handlers.elts;
3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	337 n = cmcf->phases[NGX_STREAM_LOG_PHASE].handlers.nelts;
3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	338
3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	339 for (i = 0; i < n; i++) {
3908156a51fa Stream: phases. Roman Arutyunyan <arut@nginx.com> parents: 6692 diff changeset	340 log_handler[i](s);
6678 0125b151c9a5 Stream: log module. Vladimir Homutov <vl@nginx.com> parents: 6674 diff changeset	341 }
6674 38143d1abdec Stream: the $status variable. Roman Arutyunyan <arut@nginx.com> parents: 6669 diff changeset	342 }
38143d1abdec Stream: the $status variable. Roman Arutyunyan <arut@nginx.com> parents: 6669 diff changeset	343
38143d1abdec Stream: the $status variable. Roman Arutyunyan <arut@nginx.com> parents: 6669 diff changeset	344
38143d1abdec Stream: the $status variable. Roman Arutyunyan <arut@nginx.com> parents: 6669 diff changeset	345 static void
6115 61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	346 ngx_stream_close_connection(ngx_connection_t *c)
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	347 {
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	348 ngx_pool_t *pool;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	349
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	350 ngx_log_debug1(NGX_LOG_DEBUG_STREAM, c->log, 0,
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	351 "close stream connection: %d", c->fd);
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	352
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	353 #if (NGX_STREAM_SSL)
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	354
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	355 if (c->ssl) {
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	356 if (ngx_ssl_shutdown(c) == NGX_AGAIN) {
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	357 c->ssl->handler = ngx_stream_close_connection;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	358 return;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	359 }
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	360 }
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	361
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	362 #endif
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	363
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	364 #if (NGX_STAT_STUB)
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	365 (void) ngx_atomic_fetch_add(ngx_stat_active, -1);
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	366 #endif
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	367
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	368 pool = c->pool;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	369
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	370 ngx_close_connection(c);
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	371
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	372 ngx_destroy_pool(pool);
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	373 }
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	374
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	375
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	376 static u_char *
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	377 ngx_stream_log_error(ngx_log_t log, u_char buf, size_t len)
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	378 {
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	379 u_char *p;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	380 ngx_stream_session_t *s;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	381
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	382 if (log->action) {
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	383 p = ngx_snprintf(buf, len, " while %s", log->action);
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	384 len -= p - buf;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	385 buf = p;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	386 }
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	387
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	388 s = log->data;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	389
6461 a01e315b3a78 Stream: additional logging for UDP. Vladimir Homutov <vl@nginx.com> parents: 6436 diff changeset	390 p = ngx_snprintf(buf, len, ", %sclient: %V, server: %V",
a01e315b3a78 Stream: additional logging for UDP. Vladimir Homutov <vl@nginx.com> parents: 6436 diff changeset	391 s->connection->type == SOCK_DGRAM ? "udp " : "",
6115 61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	392 &s->connection->addr_text,
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	393 &s->connection->listening->addr_text);
6223 d1f94042c29c Stream: fixed potential error log buffer overrun. Vladimir Homutov <vl@nginx.com> parents: 6221 diff changeset	394 len -= p - buf;
d1f94042c29c Stream: fixed potential error log buffer overrun. Vladimir Homutov <vl@nginx.com> parents: 6221 diff changeset	395 buf = p;
6115 61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	396
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	397 if (s->log_handler) {
6223 d1f94042c29c Stream: fixed potential error log buffer overrun. Vladimir Homutov <vl@nginx.com> parents: 6221 diff changeset	398 p = s->log_handler(log, buf, len);
6115 61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	399 }
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	400
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	401 return p;
61d7ae76647d Stream: port from NGINX+. Ruslan Ermilov <ru@nginx.com> parents: diff changeset	402 }

Mercurial > hg > nginx-quic

annotate src/stream/ngx_stream_handler.c @ 8240:43f3574b3e6f quic