From mboxrd@z Thu Jan 1 00:00:00 1970 Received: from gandalf.ozlabs.org (gandalf.ozlabs.org [150.107.74.76]) by passt.top (Postfix) with ESMTPS id 473145A026A for ; Fri, 25 Nov 2022 08:29:26 +0100 (CET) Received: by gandalf.ozlabs.org (Postfix, from userid 1007) id 4NJRM42Tc1z4xTr; Fri, 25 Nov 2022 18:29:20 +1100 (AEDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gibson.dropbear.id.au; s=201602; t=1669361360; bh=OIESNmotZNJw7PRnNPACzuqEDIhPbJqL87492ZotRMw=; h=From:To:Cc:Subject:Date:In-Reply-To:References:From; b=Am420nC+7SyikGARi+yLhS/I/fwbbnRJPqM6ww1HYC7J/mmGLP+umgTdfGFkxZrT2 kD4CvTLA2Y/SBmdWUU/28wiTsaCJE9+rOLCqHMgK16aRLQrF2OTNHLaEU+af8EfWN3 IdRRMdca/940gJxTrZfp+eoqaaK+3haT21AmF8es= From: David Gibson To: Stefano Brivio , passt-dev@passt.top Subject: [PATCH v3 12/16] udp: Make UDP_SPLICE_FRAMES and UDP_TAP_FRAMES_MEM the same thing Date: Fri, 25 Nov 2022 18:29:12 +1100 Message-Id: <20221125072916.3060938-13-david@gibson.dropbear.id.au> X-Mailer: git-send-email 2.38.1 In-Reply-To: <20221125072916.3060938-1-david@gibson.dropbear.id.au> References: <20221125072916.3060938-1-david@gibson.dropbear.id.au> MIME-Version: 1.0 Content-Transfer-Encoding: 8bit Message-ID-Hash: DVZPL6W3BYNWF6JTLTYTEBA4RAUORWL6 X-Message-ID-Hash: DVZPL6W3BYNWF6JTLTYTEBA4RAUORWL6 X-MailFrom: dgibson@gandalf.ozlabs.org X-Mailman-Rule-Misses: dmarc-mitigation; no-senders; approved; emergency; loop; banned-address; member-moderation; nonmember-moderation; administrivia; implicit-dest; max-recipients; max-size; news-moderation; no-subject; digests; suspicious-header CC: David Gibson X-Mailman-Version: 3.3.3 Precedence: list List-Id: Development discussion and patches for passt Archived-At: Archived-At: List-Archive: List-Archive: List-Help: List-Owner: List-Post: List-Subscribe: List-Unsubscribe: These two constants have the same value, and there's not a lot of reason they'd ever need to be different. Future changes will further integrate the spliced and "tap" paths so that these need to be the same. So, merge them into UDP_MAX_FRAMES. Signed-off-by: David Gibson --- udp.c | 55 +++++++++++++++++++++++++++---------------------------- 1 file changed, 27 insertions(+), 28 deletions(-) diff --git a/udp.c b/udp.c index 25a37c6..c7e05c8 100644 --- a/udp.c +++ b/udp.c @@ -118,9 +118,8 @@ #include "log.h" #define UDP_CONN_TIMEOUT 180 /* s, timeout for ephemeral or local bind */ -#define UDP_SPLICE_FRAMES 32 -#define UDP_TAP_FRAMES_MEM 32 -#define UDP_TAP_FRAMES (c->mode == MODE_PASST ? UDP_TAP_FRAMES_MEM : 1) +#define UDP_MAX_FRAMES 32 /* max # of frames to receive at once */ +#define UDP_TAP_FRAMES (c->mode == MODE_PASST ? UDP_MAX_FRAMES : 1) /** * struct udp_tap_port - Port tracking based on tap-facing source port @@ -188,7 +187,7 @@ static struct udp4_l2_buf_t { uint8_t data[USHRT_MAX - (sizeof(struct iphdr) + sizeof(struct udphdr))]; } __attribute__ ((packed, aligned(__alignof__(unsigned int)))) -udp4_l2_buf[UDP_TAP_FRAMES_MEM]; +udp4_l2_buf[UDP_MAX_FRAMES]; /** * udp6_l2_buf_t - Pre-cooked IPv6 packet buffers for tap connections @@ -218,30 +217,30 @@ struct udp6_l2_buf_t { #else } __attribute__ ((packed, aligned(__alignof__(unsigned int)))) #endif -udp6_l2_buf[UDP_TAP_FRAMES_MEM]; +udp6_l2_buf[UDP_MAX_FRAMES]; static struct sockaddr_storage udp_splice_namebuf; -static uint8_t udp_splice_buf[UDP_SPLICE_FRAMES][USHRT_MAX]; +static uint8_t udp_splice_buf[UDP_MAX_FRAMES][USHRT_MAX]; /* recvmmsg()/sendmmsg() data for tap */ -static struct iovec udp4_l2_iov_sock [UDP_TAP_FRAMES_MEM]; -static struct iovec udp6_l2_iov_sock [UDP_TAP_FRAMES_MEM]; +static struct iovec udp4_l2_iov_sock [UDP_MAX_FRAMES]; +static struct iovec udp6_l2_iov_sock [UDP_MAX_FRAMES]; -static struct iovec udp4_l2_iov_tap [UDP_TAP_FRAMES_MEM]; -static struct iovec udp6_l2_iov_tap [UDP_TAP_FRAMES_MEM]; +static struct iovec udp4_l2_iov_tap [UDP_MAX_FRAMES]; +static struct iovec udp6_l2_iov_tap [UDP_MAX_FRAMES]; -static struct mmsghdr udp4_l2_mh_sock [UDP_TAP_FRAMES_MEM]; -static struct mmsghdr udp6_l2_mh_sock [UDP_TAP_FRAMES_MEM]; +static struct mmsghdr udp4_l2_mh_sock [UDP_MAX_FRAMES]; +static struct mmsghdr udp6_l2_mh_sock [UDP_MAX_FRAMES]; -static struct mmsghdr udp4_l2_mh_tap [UDP_TAP_FRAMES_MEM]; -static struct mmsghdr udp6_l2_mh_tap [UDP_TAP_FRAMES_MEM]; +static struct mmsghdr udp4_l2_mh_tap [UDP_MAX_FRAMES]; +static struct mmsghdr udp6_l2_mh_tap [UDP_MAX_FRAMES]; /* recvmmsg()/sendmmsg() data for "spliced" connections */ -static struct iovec udp_iov_recv [UDP_SPLICE_FRAMES]; -static struct mmsghdr udp_mmh_recv [UDP_SPLICE_FRAMES]; +static struct iovec udp_iov_recv [UDP_MAX_FRAMES]; +static struct mmsghdr udp_mmh_recv [UDP_MAX_FRAMES]; -static struct iovec udp_iov_sendto [UDP_SPLICE_FRAMES]; -static struct mmsghdr udp_mmh_sendto [UDP_SPLICE_FRAMES]; +static struct iovec udp_iov_sendto [UDP_MAX_FRAMES]; +static struct mmsghdr udp_mmh_sendto [UDP_MAX_FRAMES]; /** * udp_invert_portmap() - Compute reverse port translations for return packets @@ -286,7 +285,7 @@ void udp_update_l2_buf(const unsigned char *eth_d, const unsigned char *eth_s, { int i; - for (i = 0; i < UDP_TAP_FRAMES_MEM; i++) { + for (i = 0; i < UDP_MAX_FRAMES; i++) { struct udp4_l2_buf_t *b4 = &udp4_l2_buf[i]; struct udp6_l2_buf_t *b6 = &udp6_l2_buf[i]; @@ -330,7 +329,7 @@ static void udp_sock4_iov_init(void) }; } - for (i = 0, h = udp4_l2_mh_sock; i < UDP_TAP_FRAMES_MEM; i++, h++) { + for (i = 0, h = udp4_l2_mh_sock; i < UDP_MAX_FRAMES; i++, h++) { struct msghdr *mh = &h->msg_hdr; mh->msg_name = &udp4_l2_buf[i].s_in; @@ -342,7 +341,7 @@ static void udp_sock4_iov_init(void) mh->msg_iovlen = 1; } - for (i = 0, h = udp4_l2_mh_tap; i < UDP_TAP_FRAMES_MEM; i++, h++) { + for (i = 0, h = udp4_l2_mh_tap; i < UDP_MAX_FRAMES; i++, h++) { struct msghdr *mh = &h->msg_hdr; udp4_l2_iov_tap[i].iov_base = &udp4_l2_buf[i].vnet_len; @@ -370,7 +369,7 @@ static void udp_sock6_iov_init(void) }; } - for (i = 0, h = udp6_l2_mh_sock; i < UDP_TAP_FRAMES_MEM; i++, h++) { + for (i = 0, h = udp6_l2_mh_sock; i < UDP_MAX_FRAMES; i++, h++) { struct msghdr *mh = &h->msg_hdr; mh->msg_name = &udp6_l2_buf[i].s_in6; @@ -382,7 +381,7 @@ static void udp_sock6_iov_init(void) mh->msg_iovlen = 1; } - for (i = 0, h = udp6_l2_mh_tap; i < UDP_TAP_FRAMES_MEM; i++, h++) { + for (i = 0, h = udp6_l2_mh_tap; i < UDP_MAX_FRAMES; i++, h++) { struct msghdr *mh = &h->msg_hdr; udp6_l2_iov_tap[i].iov_base = &udp6_l2_buf[i].vnet_len; @@ -516,7 +515,7 @@ static void udp_sock_handler_splice(const struct ctx *c, union epoll_ref ref, if (!(events & EPOLLIN)) return; - n = recvmmsg(ref.r.s, udp_mmh_recv, UDP_SPLICE_FRAMES, 0, NULL); + n = recvmmsg(ref.r.s, udp_mmh_recv, UDP_MAX_FRAMES, 0, NULL); if (n <= 0) return; @@ -1166,7 +1165,7 @@ static void udp_splice_iov_init(void) struct iovec *iov; int i; - for (i = 0, h = udp_mmh_recv; i < UDP_SPLICE_FRAMES; i++, h++) { + for (i = 0, h = udp_mmh_recv; i < UDP_MAX_FRAMES; i++, h++) { struct msghdr *mh = &h->msg_hdr; if (!i) { @@ -1177,12 +1176,12 @@ static void udp_splice_iov_init(void) mh->msg_iov = &udp_iov_recv[i]; mh->msg_iovlen = 1; } - for (i = 0, iov = udp_iov_recv; i < UDP_SPLICE_FRAMES; i++, iov++) { + for (i = 0, iov = udp_iov_recv; i < UDP_MAX_FRAMES; i++, iov++) { iov->iov_base = udp_splice_buf[i]; iov->iov_len = sizeof(udp_splice_buf[i]); } - for (i = 0, h = udp_mmh_sendto; i < UDP_SPLICE_FRAMES; i++, h++) { + for (i = 0, h = udp_mmh_sendto; i < UDP_MAX_FRAMES; i++, h++) { struct msghdr *mh = &h->msg_hdr; mh->msg_name = &udp_splice_namebuf; @@ -1191,7 +1190,7 @@ static void udp_splice_iov_init(void) mh->msg_iov = &udp_iov_sendto[i]; mh->msg_iovlen = 1; } - for (i = 0, iov = udp_iov_sendto; i < UDP_SPLICE_FRAMES; i++, iov++) + for (i = 0, iov = udp_iov_sendto; i < UDP_MAX_FRAMES; i++, iov++) iov->iov_base = udp_splice_buf[i]; } -- 2.38.1