Received: by 2002:a05:6358:3188:b0:123:57c1:9b43 with SMTP id q8csp945794rwd; Wed, 7 Jun 2023 08:55:51 -0700 (PDT) X-Google-Smtp-Source: ACHHUZ5RFwwx3fh51Ew+Ce9joC8Hyvai5mXPxvkjFHAKGJRsJvTTo1lX7050/xCO4NNwJT2edavf X-Received: by 2002:a17:90a:1e:b0:259:bf3e:5f90 with SMTP id 30-20020a17090a001e00b00259bf3e5f90mr780267pja.24.1686153350641; Wed, 07 Jun 2023 08:55:50 -0700 (PDT) ARC-Seal: i=1; a=rsa-sha256; t=1686153350; cv=none; d=google.com; s=arc-20160816; b=HAYav9moxqHLQBHXYmpeQe3oIEJC+b7suA2YMg/e/lsAtLOrypNnImkYkVXSs2GTxL YUHLuTXZB4mgcI+WbicxvZZSSN/wTlLPaRGDbbcYci4wFBWUMdDzN44hhFrIPHgJ+3Ox hDS+Z9CZYUgoGOcJMeTYS6nOP0BsODZEyfBi6/ec9IGJjLSsgrzgKJ/JsGEg2xhjZV2U dNaeXzDf0YaJFDbc5C/zd0NlTFfx9Mip/GDMHbDCM0qBSTl9rA27NryYHobuS1ndAoIu 08+LPjhC/w/Zl3Hh91i8+hu/8ljJe3CZne7uqpX37Iua9+XXTL5Ofr5MAbBHwy6wEq15 oReA== ARC-Message-Signature: i=1; a=rsa-sha256; c=relaxed/relaxed; d=google.com; s=arc-20160816; h=list-id:precedence:content-transfer-encoding:mime-version :references:in-reply-to:message-id:date:subject:cc:to:from :dkim-signature; bh=QApyFybCc0hqZkg39fC3yOeu77CaRCOeQPkvCE9VX+E=; b=IjgIaX9lxBBAHk2pi+4nzT46KeFstltsbpyKj18mpIopajsTpl7XzntL0+oI6eHG3W rujIaQJCIixZrY5wGfqFx51MOButrO37ePSdCdSqkmDd+mF7G0OZNL63p3wFY8tI4Dbp ovRhTTp/KCrFG0+UDYpKIHcQ5u+3rP7Qn9lYDXq07AGRcxrzhWab9agtE2hb02I+O66w MjgcR10GUb59NxCIyzPdaGh+PxHnGbZ0gDI9CPoJyMiSO96mhlmZM6cIwlSu6/l/ZZqx PbocUa9ujjLArs6Twhus22vRK7STF6kKdvQYz/B/BTmuxTelDEMZ+pelKFem5hAyNYll 6b/A== ARC-Authentication-Results: i=1; mx.google.com; dkim=pass header.i=@amazon.com header.s=amazon201209 header.b=kPb9IYal; spf=pass (google.com: domain of linux-kernel-owner@vger.kernel.org designates 2620:137:e000::1:20 as permitted sender) smtp.mailfrom=linux-kernel-owner@vger.kernel.org; dmarc=pass (p=QUARANTINE sp=QUARANTINE dis=NONE) header.from=amazon.com Return-Path: Received: from out1.vger.email (out1.vger.email. [2620:137:e000::1:20]) by mx.google.com with ESMTP id oj10-20020a17090b4d8a00b002536c5eb7cfsi1299980pjb.58.2023.06.07.08.55.35; Wed, 07 Jun 2023 08:55:50 -0700 (PDT) Received-SPF: pass (google.com: domain of linux-kernel-owner@vger.kernel.org designates 2620:137:e000::1:20 as permitted sender) client-ip=2620:137:e000::1:20; Authentication-Results: mx.google.com; dkim=pass header.i=@amazon.com header.s=amazon201209 header.b=kPb9IYal; spf=pass (google.com: domain of linux-kernel-owner@vger.kernel.org designates 2620:137:e000::1:20 as permitted sender) smtp.mailfrom=linux-kernel-owner@vger.kernel.org; dmarc=pass (p=QUARANTINE sp=QUARANTINE dis=NONE) header.from=amazon.com Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S241058AbjFGPdH (ORCPT + 99 others); Wed, 7 Jun 2023 11:33:07 -0400 Received: from lindbergh.monkeyblade.net ([23.128.96.19]:45044 "EHLO lindbergh.monkeyblade.net" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S241320AbjFGPdC (ORCPT ); Wed, 7 Jun 2023 11:33:02 -0400 Received: from smtp-fw-9102.amazon.com (smtp-fw-9102.amazon.com [207.171.184.29]) by lindbergh.monkeyblade.net (Postfix) with ESMTPS id 449E21BC6; Wed, 7 Jun 2023 08:32:56 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=amazon.com; i=@amazon.com; q=dns/txt; s=amazon201209; t=1686151977; x=1717687977; h=from:to:cc:subject:date:message-id:in-reply-to: references:mime-version:content-transfer-encoding; bh=QApyFybCc0hqZkg39fC3yOeu77CaRCOeQPkvCE9VX+E=; b=kPb9IYalbjlPmqPC2iEYfyjhJ/9z4Y9Nbg0t0kFp7RhOayuXftGoF0Za /4u6b6OwalX8FjEVu8aQrDCDXvaihQTvXWnKRD1YHDkFv3DAAxIGj9r5f C1ZGHTE8PcFW2xW+5uPAEt5YUrBVmWrZ2wx7JnHuE0Ytws7vCczE6pr6c A=; X-IronPort-AV: E=Sophos;i="6.00,224,1681171200"; d="scan'208";a="344248396" Received: from pdx4-co-svc-p1-lb2-vlan2.amazon.com (HELO email-inbound-relay-pdx-2a-m6i4x-1cca8d67.us-west-2.amazon.com) ([10.25.36.210]) by smtp-border-fw-9102.sea19.amazon.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384; 07 Jun 2023 15:32:51 +0000 Received: from EX19MTAUWC002.ant.amazon.com (pdx1-ws-svc-p6-lb9-vlan2.pdx.amazon.com [10.236.137.194]) by email-inbound-relay-pdx-2a-m6i4x-1cca8d67.us-west-2.amazon.com (Postfix) with ESMTPS id 04F428B750; Wed, 7 Jun 2023 15:32:49 +0000 (UTC) Received: from EX19D004ANA001.ant.amazon.com (10.37.240.138) by EX19MTAUWC002.ant.amazon.com (10.250.64.143) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.2.1118.26; Wed, 7 Jun 2023 15:32:43 +0000 Received: from 88665a182662.ant.amazon.com (10.119.185.127) by EX19D004ANA001.ant.amazon.com (10.37.240.138) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.2.1118.26; Wed, 7 Jun 2023 15:32:40 +0000 From: Kuniyuki Iwashima To: CC: , , , , , , , , , , , , , , , Subject: Re: [PATCH net-next v5 07/14] ipv4, ipv6: Use splice_eof() to flush Date: Wed, 7 Jun 2023 08:32:32 -0700 Message-ID: <20230607153232.93980-1-kuniyu@amazon.com> X-Mailer: git-send-email 2.30.2 In-Reply-To: <20230607140559.2263470-8-dhowells@redhat.com> References: <20230607140559.2263470-8-dhowells@redhat.com> MIME-Version: 1.0 Content-Transfer-Encoding: 8bit Content-Type: text/plain X-Originating-IP: [10.119.185.127] X-ClientProxiedBy: EX19D046UWA003.ant.amazon.com (10.13.139.18) To EX19D004ANA001.ant.amazon.com (10.37.240.138) X-Spam-Status: No, score=-4.0 required=5.0 tests=BAYES_00,DKIMWL_WL_HIGH, DKIM_SIGNED,DKIM_VALID,DKIM_VALID_AU,HEADER_FROM_DIFFERENT_DOMAINS, RCVD_IN_DNSWL_MED,RCVD_IN_MSPIKE_H5,RCVD_IN_MSPIKE_WL,SPF_HELO_NONE, T_SCC_BODY_TEXT_LINE,T_SPF_PERMERROR autolearn=ham autolearn_force=no version=3.4.6 X-Spam-Checker-Version: SpamAssassin 3.4.6 (2021-04-09) on lindbergh.monkeyblade.net Precedence: bulk List-ID: X-Mailing-List: linux-kernel@vger.kernel.org From: David Howells Date: Wed, 7 Jun 2023 15:05:52 +0100 > Allow splice to undo the effects of MSG_MORE after prematurely ending a > splice/sendfile due to getting an EOF condition (->splice_read() returned > 0) after splice had called sendmsg() with MSG_MORE set when the user didn't > set MSG_MORE. > > For UDP, a pending packet will not be emitted if the socket is closed > before it is flushed; with this change, it be flushed by ->splice_eof(). > > For TCP, it's not clear that MSG_MORE is actually effective. > > Suggested-by: Linus Torvalds > Link: https://lore.kernel.org/r/CAHk-=wh=V579PDYvkpnTobCLGczbgxpMgGmmhqiTyE34Cpi5Gg@mail.gmail.com/ > Signed-off-by: David Howells > cc: Eric Dumazet > cc: Willem de Bruijn > cc: David Ahern > cc: "David S. Miller" > cc: Jakub Kicinski > cc: Paolo Abeni > cc: Jens Axboe > cc: Matthew Wilcox > cc: netdev@vger.kernel.org > --- > include/net/inet_common.h | 1 + > include/net/tcp.h | 1 + > include/net/udp.h | 1 + > net/ipv4/af_inet.c | 18 ++++++++++++++++++ > net/ipv4/tcp.c | 16 ++++++++++++++++ > net/ipv4/tcp_ipv4.c | 1 + > net/ipv4/udp.c | 16 ++++++++++++++++ > net/ipv6/af_inet6.c | 1 + > net/ipv6/tcp_ipv6.c | 1 + > net/ipv6/udp.c | 18 ++++++++++++++++++ > 10 files changed, 74 insertions(+) > > diff --git a/include/net/inet_common.h b/include/net/inet_common.h > index 77f4b0ef5b92..a75333342c4e 100644 > --- a/include/net/inet_common.h > +++ b/include/net/inet_common.h > @@ -35,6 +35,7 @@ void __inet_accept(struct socket *sock, struct socket *newsock, > struct sock *newsk); > int inet_send_prepare(struct sock *sk); > int inet_sendmsg(struct socket *sock, struct msghdr *msg, size_t size); > +void inet_splice_eof(struct socket *sock); > ssize_t inet_sendpage(struct socket *sock, struct page *page, int offset, > size_t size, int flags); > int inet_recvmsg(struct socket *sock, struct msghdr *msg, size_t size, > diff --git a/include/net/tcp.h b/include/net/tcp.h > index 68990a8f556a..49611af31bb7 100644 > --- a/include/net/tcp.h > +++ b/include/net/tcp.h > @@ -327,6 +327,7 @@ int tcp_sendmsg(struct sock *sk, struct msghdr *msg, size_t size); > int tcp_sendmsg_locked(struct sock *sk, struct msghdr *msg, size_t size); > int tcp_sendmsg_fastopen(struct sock *sk, struct msghdr *msg, int *copied, > size_t size, struct ubuf_info *uarg); > +void tcp_splice_eof(struct socket *sock); > int tcp_sendpage(struct sock *sk, struct page *page, int offset, size_t size, > int flags); > int tcp_sendpage_locked(struct sock *sk, struct page *page, int offset, > diff --git a/include/net/udp.h b/include/net/udp.h > index 5cad44318d71..4ed0b47c5582 100644 > --- a/include/net/udp.h > +++ b/include/net/udp.h > @@ -278,6 +278,7 @@ int udp_get_port(struct sock *sk, unsigned short snum, > int udp_err(struct sk_buff *, u32); > int udp_abort(struct sock *sk, int err); > int udp_sendmsg(struct sock *sk, struct msghdr *msg, size_t len); > +void udp_splice_eof(struct socket *sock); > int udp_push_pending_frames(struct sock *sk); > void udp_flush_pending_frames(struct sock *sk); > int udp_cmsg_send(struct sock *sk, struct msghdr *msg, u16 *gso_size); > diff --git a/net/ipv4/af_inet.c b/net/ipv4/af_inet.c > index b5735b3551cf..6cfb78592836 100644 > --- a/net/ipv4/af_inet.c > +++ b/net/ipv4/af_inet.c > @@ -831,6 +831,21 @@ int inet_sendmsg(struct socket *sock, struct msghdr *msg, size_t size) > } > EXPORT_SYMBOL(inet_sendmsg); > > +void inet_splice_eof(struct socket *sock) > +{ > + const struct proto *prot; > + struct sock *sk = sock->sk; > + > + if (unlikely(inet_send_prepare(sk))) > + return; > + > + /* IPV6_ADDRFORM can change sk->sk_prot under us. */ > + prot = READ_ONCE(sk->sk_prot); > + if (prot->splice_eof) > + sk->sk_prot->splice_eof(sock); We need to use prot here. > +} > +EXPORT_SYMBOL_GPL(inet_splice_eof); > + > ssize_t inet_sendpage(struct socket *sock, struct page *page, int offset, > size_t size, int flags) > { > @@ -1050,6 +1065,7 @@ const struct proto_ops inet_stream_ops = { > #ifdef CONFIG_MMU > .mmap = tcp_mmap, > #endif > + .splice_eof = inet_splice_eof, > .sendpage = inet_sendpage, > .splice_read = tcp_splice_read, > .read_sock = tcp_read_sock, > @@ -1084,6 +1100,7 @@ const struct proto_ops inet_dgram_ops = { > .read_skb = udp_read_skb, > .recvmsg = inet_recvmsg, > .mmap = sock_no_mmap, > + .splice_eof = inet_splice_eof, > .sendpage = inet_sendpage, > .set_peek_off = sk_set_peek_off, > #ifdef CONFIG_COMPAT > @@ -1115,6 +1132,7 @@ static const struct proto_ops inet_sockraw_ops = { > .sendmsg = inet_sendmsg, > .recvmsg = inet_recvmsg, > .mmap = sock_no_mmap, > + .splice_eof = inet_splice_eof, > .sendpage = inet_sendpage, > #ifdef CONFIG_COMPAT > .compat_ioctl = inet_compat_ioctl, > diff --git a/net/ipv4/tcp.c b/net/ipv4/tcp.c > index 53b7751b68e1..09f03221a6f1 100644 > --- a/net/ipv4/tcp.c > +++ b/net/ipv4/tcp.c > @@ -1371,6 +1371,22 @@ int tcp_sendmsg(struct sock *sk, struct msghdr *msg, size_t size) > } > EXPORT_SYMBOL(tcp_sendmsg); > > +void tcp_splice_eof(struct socket *sock) > +{ > + struct sock *sk = sock->sk; > + struct tcp_sock *tp = tcp_sk(sk); > + int mss_now, size_goal; > + > + if (!tcp_write_queue_tail(sk)) > + return; > + > + lock_sock(sk); > + mss_now = tcp_send_mss(sk, &size_goal, 0); > + tcp_push(sk, 0, mss_now, tp->nonagle, size_goal); > + release_sock(sk); > +} > +EXPORT_SYMBOL_GPL(tcp_splice_eof); > + > /* > * Handle reading urgent data. BSD has very simple semantics for > * this, no blocking and very strange errors 8) > diff --git a/net/ipv4/tcp_ipv4.c b/net/ipv4/tcp_ipv4.c > index 53e9ce2f05bb..84a5d557dc1a 100644 > --- a/net/ipv4/tcp_ipv4.c > +++ b/net/ipv4/tcp_ipv4.c > @@ -3116,6 +3116,7 @@ struct proto tcp_prot = { > .keepalive = tcp_set_keepalive, > .recvmsg = tcp_recvmsg, > .sendmsg = tcp_sendmsg, > + .splice_eof = tcp_splice_eof, > .sendpage = tcp_sendpage, > .backlog_rcv = tcp_v4_do_rcv, > .release_cb = tcp_release_cb, > diff --git a/net/ipv4/udp.c b/net/ipv4/udp.c > index fd3dae081f3a..df5e407286d7 100644 > --- a/net/ipv4/udp.c > +++ b/net/ipv4/udp.c > @@ -1324,6 +1324,21 @@ int udp_sendmsg(struct sock *sk, struct msghdr *msg, size_t len) > } > EXPORT_SYMBOL(udp_sendmsg); > > +void udp_splice_eof(struct socket *sock) > +{ > + struct sock *sk = sock->sk; > + struct udp_sock *up = udp_sk(sk); > + > + if (!up->pending || READ_ONCE(up->corkflag)) > + return; > + > + lock_sock(sk); > + if (up->pending && !READ_ONCE(up->corkflag)) > + udp_push_pending_frames(sk); > + release_sock(sk); > +} > +EXPORT_SYMBOL_GPL(udp_splice_eof); > + > int udp_sendpage(struct sock *sk, struct page *page, int offset, > size_t size, int flags) > { > @@ -2918,6 +2933,7 @@ struct proto udp_prot = { > .getsockopt = udp_getsockopt, > .sendmsg = udp_sendmsg, > .recvmsg = udp_recvmsg, > + .splice_eof = udp_splice_eof, > .sendpage = udp_sendpage, > .release_cb = ip4_datagram_release_cb, > .hash = udp_lib_hash, > diff --git a/net/ipv6/af_inet6.c b/net/ipv6/af_inet6.c > index 2bbf13216a3d..564942bee067 100644 > --- a/net/ipv6/af_inet6.c > +++ b/net/ipv6/af_inet6.c > @@ -695,6 +695,7 @@ const struct proto_ops inet6_stream_ops = { > #ifdef CONFIG_MMU > .mmap = tcp_mmap, > #endif > + .splice_eof = inet_splice_eof, > .sendpage = inet_sendpage, > .sendmsg_locked = tcp_sendmsg_locked, > .sendpage_locked = tcp_sendpage_locked, > diff --git a/net/ipv6/tcp_ipv6.c b/net/ipv6/tcp_ipv6.c > index d657713d1c71..c17c8ff94b79 100644 > --- a/net/ipv6/tcp_ipv6.c > +++ b/net/ipv6/tcp_ipv6.c > @@ -2150,6 +2150,7 @@ struct proto tcpv6_prot = { > .keepalive = tcp_set_keepalive, > .recvmsg = tcp_recvmsg, > .sendmsg = tcp_sendmsg, > + .splice_eof = tcp_splice_eof, > .sendpage = tcp_sendpage, > .backlog_rcv = tcp_v6_do_rcv, > .release_cb = tcp_release_cb, > diff --git a/net/ipv6/udp.c b/net/ipv6/udp.c > index e5a337e6b970..6c5975b13ae3 100644 > --- a/net/ipv6/udp.c > +++ b/net/ipv6/udp.c > @@ -1653,6 +1653,23 @@ int udpv6_sendmsg(struct sock *sk, struct msghdr *msg, size_t len) > } > EXPORT_SYMBOL(udpv6_sendmsg); > > +static void udpv6_splice_eof(struct socket *sock) > +{ > + struct sock *sk = sock->sk; > + struct udp_sock *up = udp_sk(sk); > + > + if (!up->pending || READ_ONCE(up->corkflag)) > + return; > + > + if (up->pending == AF_INET) > + udp_splice_eof(sock); Do we need this ? > + > + lock_sock(sk); > + if (up->pending && !READ_ONCE(up->corkflag)) > + udp_push_pending_frames(sk); We should use udp_v6_push_pending_frames(sk) as up->pending could be AF_INET even after the test above. > + release_sock(sk); > +} > + > void udpv6_destroy_sock(struct sock *sk) > { > struct udp_sock *up = udp_sk(sk); > @@ -1764,6 +1781,7 @@ struct proto udpv6_prot = { > .getsockopt = udpv6_getsockopt, > .sendmsg = udpv6_sendmsg, > .recvmsg = udpv6_recvmsg, > + .splice_eof = udpv6_splice_eof, > .release_cb = ip6_datagram_release_cb, > .hash = udp_lib_hash, > .unhash = udp_lib_unhash,