From nobody Fri Jan 2 05:48:06 2026 Return-Path: X-Spam-Checker-Version: SpamAssassin 3.4.0 (2014-02-07) on aws-us-west-2-korg-lkml-1.web.codeaurora.org Received: from vger.kernel.org (vger.kernel.org [23.128.96.18]) by smtp.lore.kernel.org (Postfix) with ESMTP id D8690CDB465 for ; Mon, 16 Oct 2023 07:16:05 +0000 (UTC) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S232278AbjJPHQE (ORCPT ); Mon, 16 Oct 2023 03:16:04 -0400 Received: from lindbergh.monkeyblade.net ([23.128.96.19]:35190 "EHLO lindbergh.monkeyblade.net" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S232065AbjJPHPm (ORCPT ); Mon, 16 Oct 2023 03:15:42 -0400 Received: from mail-ej1-x632.google.com (mail-ej1-x632.google.com [IPv6:2a00:1450:4864:20::632]) by lindbergh.monkeyblade.net (Postfix) with ESMTPS id 53021E1; Mon, 16 Oct 2023 00:15:39 -0700 (PDT) Received: by mail-ej1-x632.google.com with SMTP id a640c23a62f3a-991c786369cso662597966b.1; Mon, 16 Oct 2023 00:15:39 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20230601; t=1697440538; x=1698045338; darn=vger.kernel.org; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:from:to:cc:subject:date :message-id:reply-to; bh=n0AxUwpswyDtB5yjnz9mIbeKoD0NUiZwXlK+ltnPKKo=; b=SN9Z1figx/jFHm/7Z2h8TV3InwmvyDoGzN0yYug/mmPvTDsaslGrknHoxrNqQdVEkM ev9WvNb6CoEHwsqJOiOVzCG1sclwAq6dhFPSZ+wGFRLqqJfqPemUfwlKWqPCxn+Fdf2Q Fl5pBkYg5+nv9BRcd9ERuCA8lc81PGLRk7NbT7/lC69UWHj+YW0dP7lqiqSvKgqspSvD 939x8CzSANqf7ul3/YvVK65qj4BuzTIrCf3MzkAG3RWUsZTz+2evxBFwgcv16waQQ+jY Mnz6hxz62VYF2MEiJLfS15xQ6yABgDgS++XFveZQfM/8PdENbeYOyVhVcd5AuBq6p3uS MRfQ== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20230601; t=1697440538; x=1698045338; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:x-gm-message-state:from:to:cc :subject:date:message-id:reply-to; bh=n0AxUwpswyDtB5yjnz9mIbeKoD0NUiZwXlK+ltnPKKo=; b=G7GUl1VScSqCnZivAMC7P2ysqkvMxSeONbqeSfKbyo6vgJImfUDkhCFDAzIegiVteF kvt2kUFjZwzt+9ODnGRLyOte8JcR2WaQQvrGQvVmCqOcRVDfju5U3WvA5/Fli+72eH3j 8W5BreclH+2CWOsOgVOhBqfxPbQe3vLYHpy7gqkMZwQU/tLEz5RE4lG6A65nkVnrz9pI 3dYoOr8Frg4/r+VK8wYdmV3Qh8cfp58SXdWvgOVwNshM1qvgBXrfJdqyrYq9/BIF2Rke KyOJmzQXbYjGHsi20hC72Ucz1qf8cwrIAH7KEq7QvjEMqFEwG0bBEVCh4lBvxl9m/PEh iwfg== X-Gm-Message-State: AOJu0YyzGMQmmBTPT9HuNfPM7GX7quW2G3ngtXyWWuKPZk5HUosLgTtS izEY1NO9Lfqx6li+VYV3vvXJ6SWfbAE= X-Google-Smtp-Source: AGHT+IFh8D5mzTkkxqwh6377RoocEclrt8JX1EQjIOYAv/rntDjzzKqRtBsgg2RBTenf/ztoyg8MkQ== X-Received: by 2002:a17:907:9407:b0:9c4:b8c9:1bf2 with SMTP id dk7-20020a170907940700b009c4b8c91bf2mr494949ejc.60.1697440537712; Mon, 16 Oct 2023 00:15:37 -0700 (PDT) Received: from tp.home.arpa (host-79-55-64-40.retail.telecomitalia.it. [79.55.64.40]) by smtp.gmail.com with ESMTPSA id jl25-20020a17090775d900b00992e265495csm3419471ejc.212.2023.10.16.00.15.37 (version=TLS1_3 cipher=TLS_AES_256_GCM_SHA384 bits=256/256); Mon, 16 Oct 2023 00:15:37 -0700 (PDT) From: Beniamino Galvani To: netdev@vger.kernel.org Cc: "David S . Miller" , Jakub Kicinski , Paolo Abeni , David Ahern , Guillaume Nault , linux-kernel@vger.kernel.org Subject: [PATCH net-next v2 6/7] geneve: use generic function for tunnel IPv4 route lookup Date: Mon, 16 Oct 2023 09:15:25 +0200 Message-Id: <20231016071526.2958108-7-b.galvani@gmail.com> X-Mailer: git-send-email 2.40.1 In-Reply-To: <20231016071526.2958108-1-b.galvani@gmail.com> References: <20231016071526.2958108-1-b.galvani@gmail.com> MIME-Version: 1.0 Content-Transfer-Encoding: quoted-printable Precedence: bulk List-ID: X-Mailing-List: linux-kernel@vger.kernel.org Content-Type: text/plain; charset="utf-8" The route lookup can be done now via generic function udp_tunnel_dst_lookup() to replace the custom implementation in geneve_get_v4_rt(). Suggested-by: Guillaume Nault Signed-off-by: Beniamino Galvani --- drivers/net/geneve.c | 98 +++++++++++++++----------------------------- 1 file changed, 32 insertions(+), 66 deletions(-) diff --git a/drivers/net/geneve.c b/drivers/net/geneve.c index 572c3e36b209..23041eeec121 100644 --- a/drivers/net/geneve.c +++ b/drivers/net/geneve.c @@ -800,58 +800,6 @@ static u8 geneve_get_dsfield(struct sk_buff *skb, stru= ct net_device *dev, return dsfield; } =20 -static struct rtable *geneve_get_v4_rt(struct sk_buff *skb, - struct net_device *dev, - struct geneve_sock *gs4, - struct flowi4 *fl4, - const struct ip_tunnel_info *info, - __be16 dport, __be16 sport, - __u8 *full_tos) -{ - bool use_cache =3D ip_tunnel_dst_cache_usable(skb, info); - struct geneve_dev *geneve =3D netdev_priv(dev); - struct dst_cache *dst_cache; - struct rtable *rt =3D NULL; - __u8 tos; - - if (!gs4) - return ERR_PTR(-EIO); - - memset(fl4, 0, sizeof(*fl4)); - fl4->flowi4_mark =3D skb->mark; - fl4->flowi4_proto =3D IPPROTO_UDP; - fl4->daddr =3D info->key.u.ipv4.dst; - fl4->saddr =3D info->key.u.ipv4.src; - fl4->fl4_dport =3D dport; - fl4->fl4_sport =3D sport; - fl4->flowi4_flags =3D info->key.flow_flags; - - tos =3D geneve_get_dsfield(skb, dev, info, &use_cache); - fl4->flowi4_tos =3D RT_TOS(tos); - if (full_tos) - *full_tos =3D tos; - - dst_cache =3D (struct dst_cache *)&info->dst_cache; - if (use_cache) { - rt =3D dst_cache_get_ip4(dst_cache, &fl4->saddr); - if (rt) - return rt; - } - rt =3D ip_route_output_key(geneve->net, fl4); - if (IS_ERR(rt)) { - netdev_dbg(dev, "no route to %pI4\n", &fl4->daddr); - return ERR_PTR(-ENETUNREACH); - } - if (rt->dst.dev =3D=3D dev) { /* is this necessary? */ - netdev_dbg(dev, "circular route to %pI4\n", &fl4->daddr); - ip_rt_put(rt); - return ERR_PTR(-ELOOP); - } - if (use_cache) - dst_cache_set_ip4(dst_cache, &rt->dst, fl4->saddr); - return rt; -} - #if IS_ENABLED(CONFIG_IPV6) static struct dst_entry *geneve_get_v6_dst(struct sk_buff *skb, struct net_device *dev, @@ -911,19 +859,28 @@ static int geneve_xmit_skb(struct sk_buff *skb, struc= t net_device *dev, struct geneve_sock *gs4 =3D rcu_dereference(geneve->sock4); const struct ip_tunnel_key *key =3D &info->key; struct rtable *rt; - struct flowi4 fl4; - __u8 full_tos; + bool use_cache; __u8 tos, ttl; __be16 df =3D 0; + __be32 saddr; __be16 sport; int err; =20 if (!pskb_inet_may_pull(skb)) return -EINVAL; =20 + if (!gs4) + return -EIO; + + use_cache =3D ip_tunnel_dst_cache_usable(skb, info); + tos =3D geneve_get_dsfield(skb, dev, info, &use_cache); sport =3D udp_flow_src_port(geneve->net, skb, 1, USHRT_MAX, true); - rt =3D geneve_get_v4_rt(skb, dev, gs4, &fl4, info, - geneve->cfg.info.key.tp_dst, sport, &full_tos); + + rt =3D udp_tunnel_dst_lookup(skb, dev, geneve->net, 0, &saddr, + &info->key, + sport, geneve->cfg.info.key.tp_dst, tos, + use_cache ? + (struct dst_cache *)&info->dst_cache : NULL); if (IS_ERR(rt)) return PTR_ERR(rt); =20 @@ -946,8 +903,8 @@ static int geneve_xmit_skb(struct sk_buff *skb, struct = net_device *dev, return -ENOMEM; } =20 - unclone->key.u.ipv4.dst =3D fl4.saddr; - unclone->key.u.ipv4.src =3D fl4.daddr; + unclone->key.u.ipv4.dst =3D saddr; + unclone->key.u.ipv4.src =3D info->key.u.ipv4.dst; } =20 if (!pskb_may_pull(skb, ETH_HLEN)) { @@ -961,13 +918,12 @@ static int geneve_xmit_skb(struct sk_buff *skb, struc= t net_device *dev, return -EMSGSIZE; } =20 + tos =3D ip_tunnel_ecn_encap(tos, ip_hdr(skb), skb); if (geneve->cfg.collect_md) { - tos =3D ip_tunnel_ecn_encap(key->tos, ip_hdr(skb), skb); ttl =3D key->ttl; =20 df =3D key->tun_flags & TUNNEL_DONT_FRAGMENT ? htons(IP_DF) : 0; } else { - tos =3D ip_tunnel_ecn_encap(full_tos, ip_hdr(skb), skb); if (geneve->cfg.ttl_inherit) ttl =3D ip_tunnel_get_ttl(ip_hdr(skb), skb); else @@ -995,7 +951,7 @@ static int geneve_xmit_skb(struct sk_buff *skb, struct = net_device *dev, if (unlikely(err)) return err; =20 - udp_tunnel_xmit_skb(rt, gs4->sock->sk, skb, fl4.saddr, fl4.daddr, + udp_tunnel_xmit_skb(rt, gs4->sock->sk, skb, saddr, info->key.u.ipv4.dst, tos, ttl, df, sport, geneve->cfg.info.key.tp_dst, !net_eq(geneve->net, dev_net(geneve->dev)), !(info->key.tun_flags & TUNNEL_CSUM)); @@ -1144,19 +1100,29 @@ static int geneve_fill_metadata_dst(struct net_devi= ce *dev, struct sk_buff *skb) =20 if (ip_tunnel_info_af(info) =3D=3D AF_INET) { struct rtable *rt; - struct flowi4 fl4; - struct geneve_sock *gs4 =3D rcu_dereference(geneve->sock4); + bool use_cache; + __be32 saddr; + u8 tos; + + if (!gs4) + return -EIO; + + use_cache =3D ip_tunnel_dst_cache_usable(skb, info); + tos =3D geneve_get_dsfield(skb, dev, info, &use_cache); sport =3D udp_flow_src_port(geneve->net, skb, 1, USHRT_MAX, true); =20 - rt =3D geneve_get_v4_rt(skb, dev, gs4, &fl4, info, - geneve->cfg.info.key.tp_dst, sport, NULL); + rt =3D udp_tunnel_dst_lookup(skb, dev, geneve->net, 0, &saddr, + &info->key, + sport, geneve->cfg.info.key.tp_dst, + tos, + use_cache ? &info->dst_cache : NULL); if (IS_ERR(rt)) return PTR_ERR(rt); =20 ip_rt_put(rt); - info->key.u.ipv4.src =3D fl4.saddr; + info->key.u.ipv4.src =3D saddr; #if IS_ENABLED(CONFIG_IPV6) } else if (ip_tunnel_info_af(info) =3D=3D AF_INET6) { struct dst_entry *dst; --=20 2.40.1