nginx: src/event/quic/ngx_event_quic

annotate src/event/quic/ngx_event_quic_udp.c @ 9017:c2f5d79cde64 quic

QUIC: separate UDP framework for QUIC. Previously, QUIC used the existing UDP framework, which was created for UDP in Stream. However the way QUIC connections are created and looked up is different from the way UDP connections in Stream are created and looked up. Now these two implementations are decoupled.

author	Roman Arutyunyan <arut@nginx.com>
date	Wed, 20 Apr 2022 16:01:17 +0400
parents	src/event/ngx_event_udp.c@ce6d9cf0f567
children	af5adec171b4

rev	line source
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	1
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	2 /*
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	3 * Copyright (C) Roman Arutyunyan
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	4 * Copyright (C) Nginx, Inc.
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	5 */
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	6
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	7
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	8 #include <ngx_config.h>
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	9 #include <ngx_core.h>
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	10 #include <ngx_event.h>
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	11 #include <ngx_event_quic_connection.h>
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	12
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	13
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	14 static void ngx_quic_close_accepted_connection(ngx_connection_t *c);
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	15 static ngx_connection_t ngx_quic_lookup_connection(ngx_listening_t ls,
8732 db58c7ef1d7c QUIC: do not handle empty dcid. Roman Arutyunyan <arut@nginx.com> parents: 8731 diff changeset	16 ngx_str_t key, struct sockaddr local_sockaddr, socklen_t local_socklen);
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	17
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	18
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	19 void
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	20 ngx_quic_recvmsg(ngx_event_t *ev)
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	21 {
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	22 ssize_t n;
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	23 ngx_str_t key;
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	24 ngx_buf_t buf;
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	25 ngx_log_t *log;
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	26 ngx_err_t err;
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	27 socklen_t socklen, local_socklen;
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	28 ngx_event_t rev, wev;
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	29 struct iovec iov[1];
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	30 struct msghdr msg;
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	31 ngx_sockaddr_t sa, lsa;
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	32 struct sockaddr sockaddr, local_sockaddr;
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	33 ngx_listening_t *ls;
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	34 ngx_event_conf_t *ecf;
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	35 ngx_connection_t c, lc;
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	36 ngx_quic_socket_t *qsock;
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	37 static u_char buffer[65535];
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	38
8003 0f6cc8f73744 Core: added function for local source address cmsg. Vladimir Homutov <vl@nginx.com> parents: 7820 diff changeset	39 #if (NGX_HAVE_ADDRINFO_CMSG)
0f6cc8f73744 Core: added function for local source address cmsg. Vladimir Homutov <vl@nginx.com> parents: 7820 diff changeset	40 u_char msg_control[CMSG_SPACE(sizeof(ngx_addrinfo_t))];
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	41 #endif
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	42
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	43 if (ev->timedout) {
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	44 if (ngx_enable_accept_events((ngx_cycle_t *) ngx_cycle) != NGX_OK) {
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	45 return;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	46 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	47
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	48 ev->timedout = 0;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	49 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	50
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	51 ecf = ngx_event_get_conf(ngx_cycle->conf_ctx, ngx_event_core_module);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	52
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	53 if (!(ngx_event_flags & NGX_USE_KQUEUE_EVENT)) {
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	54 ev->available = ecf->multi_accept;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	55 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	56
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	57 lc = ev->data;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	58 ls = lc->listening;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	59 ev->ready = 0;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	60
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	61 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0,
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	62 "quic recvmsg on %V, ready: %d",
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	63 &ls->addr_text, ev->available);
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	64
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	65 do {
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	66 ngx_memzero(&msg, sizeof(struct msghdr));
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	67
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	68 iov[0].iov_base = (void *) buffer;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	69 iov[0].iov_len = sizeof(buffer);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	70
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	71 msg.msg_name = &sa;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	72 msg.msg_namelen = sizeof(ngx_sockaddr_t);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	73 msg.msg_iov = iov;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	74 msg.msg_iovlen = 1;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	75
8003 0f6cc8f73744 Core: added function for local source address cmsg. Vladimir Homutov <vl@nginx.com> parents: 7820 diff changeset	76 #if (NGX_HAVE_ADDRINFO_CMSG)
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	77 if (ls->wildcard) {
8003 0f6cc8f73744 Core: added function for local source address cmsg. Vladimir Homutov <vl@nginx.com> parents: 7820 diff changeset	78 msg.msg_control = &msg_control;
0f6cc8f73744 Core: added function for local source address cmsg. Vladimir Homutov <vl@nginx.com> parents: 7820 diff changeset	79 msg.msg_controllen = sizeof(msg_control);
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	80
8003 0f6cc8f73744 Core: added function for local source address cmsg. Vladimir Homutov <vl@nginx.com> parents: 7820 diff changeset	81 ngx_memzero(&msg_control, sizeof(msg_control));
0f6cc8f73744 Core: added function for local source address cmsg. Vladimir Homutov <vl@nginx.com> parents: 7820 diff changeset	82 }
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	83 #endif
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	84
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	85 n = recvmsg(lc->fd, &msg, 0);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	86
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	87 if (n == -1) {
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	88 err = ngx_socket_errno;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	89
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	90 if (err == NGX_EAGAIN) {
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	91 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, ev->log, err,
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	92 "quic recvmsg() not ready");
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	93 return;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	94 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	95
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	96 ngx_log_error(NGX_LOG_ALERT, ev->log, err, "quic recvmsg() failed");
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	97
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	98 return;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	99 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	100
8003 0f6cc8f73744 Core: added function for local source address cmsg. Vladimir Homutov <vl@nginx.com> parents: 7820 diff changeset	101 #if (NGX_HAVE_ADDRINFO_CMSG)
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	102 if (msg.msg_flags & (MSG_TRUNC\|MSG_CTRUNC)) {
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	103 ngx_log_error(NGX_LOG_ALERT, ev->log, 0,
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	104 "quic recvmsg() truncated data");
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	105 continue;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	106 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	107 #endif
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	108
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	109 sockaddr = msg.msg_name;
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	110 socklen = msg.msg_namelen;
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	111
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	112 if (socklen > (socklen_t) sizeof(ngx_sockaddr_t)) {
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	113 socklen = sizeof(ngx_sockaddr_t);
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	114 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	115
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	116 #if (NGX_HAVE_UNIX_DOMAIN)
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	117
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	118 if (sockaddr->sa_family == AF_UNIX) {
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	119 struct sockaddr_un saun = (struct sockaddr_un ) sockaddr;
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	120
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	121 if (socklen <= (socklen_t) offsetof(struct sockaddr_un, sun_path)
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	122 \|\| saun->sun_path[0] == '\0')
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	123 {
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	124 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, ngx_cycle->log, 0,
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	125 "unbound unix socket");
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	126 goto next;
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	127 }
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	128 }
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	129
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	130 #endif
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	131
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	132 local_sockaddr = ls->sockaddr;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	133 local_socklen = ls->socklen;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	134
8003 0f6cc8f73744 Core: added function for local source address cmsg. Vladimir Homutov <vl@nginx.com> parents: 7820 diff changeset	135 #if (NGX_HAVE_ADDRINFO_CMSG)
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	136
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	137 if (ls->wildcard) {
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	138 struct cmsghdr *cmsg;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	139
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	140 ngx_memcpy(&lsa, local_sockaddr, local_socklen);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	141 local_sockaddr = &lsa.sockaddr;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	142
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	143 for (cmsg = CMSG_FIRSTHDR(&msg);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	144 cmsg != NULL;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	145 cmsg = CMSG_NXTHDR(&msg, cmsg))
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	146 {
8003 0f6cc8f73744 Core: added function for local source address cmsg. Vladimir Homutov <vl@nginx.com> parents: 7820 diff changeset	147 if (ngx_get_srcaddr_cmsg(cmsg, local_sockaddr) == NGX_OK) {
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	148 break;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	149 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	150 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	151 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	152
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	153 #endif
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	154
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	155 if (ngx_quic_get_packet_dcid(ev->log, buffer, n, &key) != NGX_OK) {
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	156 goto next;
8732 db58c7ef1d7c QUIC: do not handle empty dcid. Roman Arutyunyan <arut@nginx.com> parents: 8731 diff changeset	157 }
db58c7ef1d7c QUIC: do not handle empty dcid. Roman Arutyunyan <arut@nginx.com> parents: 8731 diff changeset	158
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	159 c = ngx_quic_lookup_connection(ls, &key, local_sockaddr, local_socklen);
7286 d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	160
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	161 if (c) {
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	162
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	163 #if (NGX_DEBUG)
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	164 if (c->log->log_level & NGX_LOG_DEBUG_EVENT) {
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	165 ngx_log_handler_pt handler;
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	166
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	167 handler = c->log->handler;
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	168 c->log->handler = NULL;
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	169
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	170 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, c->log, 0,
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	171 "quic recvmsg: fd:%d n:%z", c->fd, n);
7286 d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	172
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	173 c->log->handler = handler;
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	174 }
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	175 #endif
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	176
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	177 ngx_memzero(&buf, sizeof(ngx_buf_t));
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	178
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	179 buf.pos = buffer;
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	180 buf.last = buffer + n;
8733 385d511b5064 QUIC: fixed udp buffer initialization. Vladimir Homutov <vl@nginx.com> parents: 8732 diff changeset	181 buf.start = buf.pos;
385d511b5064 QUIC: fixed udp buffer initialization. Vladimir Homutov <vl@nginx.com> parents: 8732 diff changeset	182 buf.end = buffer + sizeof(buffer);
7286 d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	183
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	184 qsock = ngx_quic_get_socket(c);
7286 d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	185
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	186 ngx_memcpy(&qsock->sockaddr.sockaddr, sockaddr, socklen);
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	187 qsock->socklen = socklen;
8734 c61fcdc1b8e3 UDP: extended datagram context. Vladimir Homutov <vl@nginx.com> parents: 8733 diff changeset	188
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	189 c->udp->buffer = &buf;
7440 6d4bc025c5a7 Prevented scheduling events on a shared connection. Roman Arutyunyan <arut@nginx.com> parents: 7393 diff changeset	190
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	191 rev = c->read;
7286 d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	192 rev->ready = 1;
7440 6d4bc025c5a7 Prevented scheduling events on a shared connection. Roman Arutyunyan <arut@nginx.com> parents: 7393 diff changeset	193 rev->active = 0;
7286 d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	194
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	195 rev->handler(rev);
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	196
7391 27559d4a5151 Stream: fixed possible use of a freed connection. Vladimir Homutov <vl@nginx.com> parents: 7286 diff changeset	197 if (c->udp) {
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	198 c->udp->buffer = NULL;
7391 27559d4a5151 Stream: fixed possible use of a freed connection. Vladimir Homutov <vl@nginx.com> parents: 7286 diff changeset	199 }
27559d4a5151 Stream: fixed possible use of a freed connection. Vladimir Homutov <vl@nginx.com> parents: 7286 diff changeset	200
7286 d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	201 rev->ready = 0;
7440 6d4bc025c5a7 Prevented scheduling events on a shared connection. Roman Arutyunyan <arut@nginx.com> parents: 7393 diff changeset	202 rev->active = 1;
7286 d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	203
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	204 goto next;
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	205 }
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	206
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	207 #if (NGX_STAT_STUB)
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	208 (void) ngx_atomic_fetch_add(ngx_stat_accepted, 1);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	209 #endif
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	210
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	211 ngx_accept_disabled = ngx_cycle->connection_n / 8
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	212 - ngx_cycle->free_connection_n;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	213
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	214 c = ngx_get_connection(lc->fd, ev->log);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	215 if (c == NULL) {
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	216 return;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	217 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	218
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	219 c->shared = 1;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	220 c->type = SOCK_DGRAM;
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	221 c->socklen = socklen;
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	222
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	223 #if (NGX_STAT_STUB)
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	224 (void) ngx_atomic_fetch_add(ngx_stat_active, 1);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	225 #endif
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	226
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	227 c->pool = ngx_create_pool(ls->pool_size, ev->log);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	228 if (c->pool == NULL) {
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	229 ngx_quic_close_accepted_connection(c);
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	230 return;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	231 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	232
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	233 c->sockaddr = ngx_palloc(c->pool, NGX_SOCKADDRLEN);
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	234 if (c->sockaddr == NULL) {
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	235 ngx_quic_close_accepted_connection(c);
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	236 return;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	237 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	238
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	239 ngx_memcpy(c->sockaddr, sockaddr, socklen);
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	240
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	241 log = ngx_palloc(c->pool, sizeof(ngx_log_t));
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	242 if (log == NULL) {
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	243 ngx_quic_close_accepted_connection(c);
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	244 return;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	245 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	246
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	247 *log = ls->log;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	248
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	249 c->log = log;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	250 c->pool->log = log;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	251 c->listening = ls;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	252
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	253 if (local_sockaddr == &lsa.sockaddr) {
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	254 local_sockaddr = ngx_palloc(c->pool, local_socklen);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	255 if (local_sockaddr == NULL) {
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	256 ngx_quic_close_accepted_connection(c);
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	257 return;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	258 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	259
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	260 ngx_memcpy(local_sockaddr, &lsa, local_socklen);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	261 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	262
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	263 c->local_sockaddr = local_sockaddr;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	264 c->local_socklen = local_socklen;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	265
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	266 c->buffer = ngx_create_temp_buf(c->pool, n);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	267 if (c->buffer == NULL) {
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	268 ngx_quic_close_accepted_connection(c);
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	269 return;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	270 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	271
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	272 c->buffer->last = ngx_cpymem(c->buffer->last, buffer, n);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	273
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	274 rev = c->read;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	275 wev = c->write;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	276
7440 6d4bc025c5a7 Prevented scheduling events on a shared connection. Roman Arutyunyan <arut@nginx.com> parents: 7393 diff changeset	277 rev->active = 1;
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	278 wev->ready = 1;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	279
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	280 rev->log = log;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	281 wev->log = log;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	282
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	283 /*
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	284 * TODO: MT: - ngx_atomic_fetch_add()
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	285 * or protection by critical section or light mutex
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	286 *
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	287 * TODO: MP: - allocated in a shared memory
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	288 * - ngx_atomic_fetch_add()
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	289 * or protection by critical section or light mutex
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	290 */
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	291
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	292 c->number = ngx_atomic_fetch_add(ngx_connection_counter, 1);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	293
7820 fdc3d40979b0 Introduced the "keepalive_time" directive. Maxim Dounin <mdounin@mdounin.ru> parents: 7440 diff changeset	294 c->start_time = ngx_current_msec;
fdc3d40979b0 Introduced the "keepalive_time" directive. Maxim Dounin <mdounin@mdounin.ru> parents: 7440 diff changeset	295
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	296 #if (NGX_STAT_STUB)
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	297 (void) ngx_atomic_fetch_add(ngx_stat_handled, 1);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	298 #endif
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	299
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	300 if (ls->addr_ntop) {
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	301 c->addr_text.data = ngx_pnalloc(c->pool, ls->addr_text_max_len);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	302 if (c->addr_text.data == NULL) {
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	303 ngx_quic_close_accepted_connection(c);
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	304 return;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	305 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	306
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	307 c->addr_text.len = ngx_sock_ntop(c->sockaddr, c->socklen,
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	308 c->addr_text.data,
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	309 ls->addr_text_max_len, 0);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	310 if (c->addr_text.len == 0) {
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	311 ngx_quic_close_accepted_connection(c);
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	312 return;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	313 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	314 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	315
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	316 #if (NGX_DEBUG)
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	317 {
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	318 ngx_str_t addr;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	319 u_char text[NGX_SOCKADDR_STRLEN];
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	320
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	321 ngx_debug_accepted_connection(ecf, c);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	322
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	323 if (log->log_level & NGX_LOG_DEBUG_EVENT) {
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	324 addr.data = text;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	325 addr.len = ngx_sock_ntop(c->sockaddr, c->socklen, text,
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	326 NGX_SOCKADDR_STRLEN, 1);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	327
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	328 ngx_log_debug4(NGX_LOG_DEBUG_EVENT, log, 0,
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	329 "*%uA quic recvmsg: %V fd:%d n:%z",
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	330 c->number, &addr, c->fd, n);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	331 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	332
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	333 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	334 #endif
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	335
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	336 log->data = NULL;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	337 log->handler = NULL;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	338
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	339 ls->handler(c);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	340
7286 d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	341 next:
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	342
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	343 if (ngx_event_flags & NGX_USE_KQUEUE_EVENT) {
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	344 ev->available -= n;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	345 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	346
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	347 } while (ev->available);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	348 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	349
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	350
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	351 static void
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	352 ngx_quic_close_accepted_connection(ngx_connection_t *c)
7285 88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	353 {
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	354 ngx_free_connection(c);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	355
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	356 c->fd = (ngx_socket_t) -1;
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	357
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	358 if (c->pool) {
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	359 ngx_destroy_pool(c->pool);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	360 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	361
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	362 #if (NGX_STAT_STUB)
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	363 (void) ngx_atomic_fetch_add(ngx_stat_active, -1);
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	364 #endif
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	365 }
88a624c9b491 Events: moved ngx_recvmsg() to new file src/event/ngx_event_udp.c. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	366
7286 d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	367
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	368 void
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	369 ngx_quic_rbtree_insert_value(ngx_rbtree_node_t *temp,
7286 d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	370 ngx_rbtree_node_t node, ngx_rbtree_node_t sentinel)
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	371 {
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	372 ngx_int_t rc;
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	373 ngx_connection_t c, ct;
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	374 ngx_rbtree_node_t **p;
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	375 ngx_quic_socket_t qsock, qsockt;
7286 d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	376
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	377 for ( ;; ) {
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	378
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	379 if (node->key < temp->key) {
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	380
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	381 p = &temp->left;
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	382
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	383 } else if (node->key > temp->key) {
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	384
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	385 p = &temp->right;
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	386
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	387 } else { /* node->key == temp->key */
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	388
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	389 qsock = (ngx_quic_socket_t *) node;
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	390 c = qsock->udp.connection;
7286 d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	391
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	392 qsockt = (ngx_quic_socket_t *) temp;
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	393 ct = qsockt->udp.connection;
7286 d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	394
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	395 rc = ngx_memn2cmp(qsock->sid.id, qsockt->sid.id,
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	396 qsock->sid.len, qsockt->sid.len);
7286 d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	397
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	398 if (rc == 0 && c->listening->wildcard) {
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	399 rc = ngx_cmp_sockaddr(c->local_sockaddr, c->local_socklen,
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	400 ct->local_sockaddr, ct->local_socklen, 1);
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	401 }
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	402
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	403 p = (rc < 0) ? &temp->left : &temp->right;
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	404 }
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	405
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	406 if (*p == sentinel) {
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	407 break;
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	408 }
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	409
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	410 temp = *p;
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	411 }
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	412
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	413 *p = node;
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	414 node->parent = temp;
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	415 node->left = sentinel;
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	416 node->right = sentinel;
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	417 ngx_rbt_red(node);
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	418 }
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	419
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	420
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	421 static ngx_connection_t *
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	422 ngx_quic_lookup_connection(ngx_listening_t ls, ngx_str_t key,
8628 45db1b5c1706 QUIC: connection multiplexing per port. Roman Arutyunyan <arut@nginx.com> parents: 7440 diff changeset	423 struct sockaddr *local_sockaddr, socklen_t local_socklen)
7286 d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	424 {
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	425 uint32_t hash;
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	426 ngx_int_t rc;
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	427 ngx_connection_t *c;
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	428 ngx_rbtree_node_t node, sentinel;
c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	429 ngx_quic_socket_t *qsock;
7286 d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	430
8732 db58c7ef1d7c QUIC: do not handle empty dcid. Roman Arutyunyan <arut@nginx.com> parents: 8731 diff changeset	431 if (key->len == 0) {
db58c7ef1d7c QUIC: do not handle empty dcid. Roman Arutyunyan <arut@nginx.com> parents: 8731 diff changeset	432 return NULL;
7286 d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	433 }
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	434
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	435 node = ls->rbtree.root;
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	436 sentinel = ls->rbtree.sentinel;
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	437 hash = ngx_crc32_long(key->data, key->len);
7286 d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	438
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	439 while (node != sentinel) {
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	440
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	441 if (hash < node->key) {
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	442 node = node->left;
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	443 continue;
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	444 }
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	445
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	446 if (hash > node->key) {
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	447 node = node->right;
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	448 continue;
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	449 }
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	450
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	451 /* hash == node->key */
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	452
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	453 qsock = (ngx_quic_socket_t *) node;
7286 d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	454
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	455 rc = ngx_memn2cmp(key->data, qsock->sid.id, key->len, qsock->sid.len);
7286 d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	456
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	457 c = qsock->udp.connection;
7286 d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	458
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	459 if (rc == 0 && ls->wildcard) {
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	460 rc = ngx_cmp_sockaddr(local_sockaddr, local_socklen,
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	461 c->local_sockaddr, c->local_socklen, 1);
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	462 }
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	463
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	464 if (rc == 0) {
9017 c2f5d79cde64 QUIC: separate UDP framework for QUIC. Roman Arutyunyan <arut@nginx.com> parents: 9008 diff changeset	465 c->udp = &qsock->udp;
7286 d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	466 return c;
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	467 }
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	468
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	469 node = (rc < 0) ? node->left : node->right;
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	470 }
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	471
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	472 return NULL;
d27aa9060c95 Stream: udp streams. Roman Arutyunyan <arut@nginx.com> parents: 7285 diff changeset	473 }

Mercurial > hg > nginx

annotate src/event/quic/ngx_event_quic_udp.c @ 9017:c2f5d79cde64 quic