Merge git://git.kernel.org/pub/scm/linux/kernel/git/netdev/net

Conflicts:

MAINTAINERS
 - keep Chandrasekar
drivers/net/ethernet/mellanox/mlx5/core/en_main.c
 - simple fix + trust the code re-added to param.c in -next is fine
include/linux/bpf.h
 - trivial
include/linux/ethtool.h
 - trivial, fix kdoc while at it
include/linux/skmsg.h
 - move to relevant place in tcp.c, comment re-wrapped
net/core/skmsg.c
 - add the sk = sk // sk = NULL around calls
net/tipc/crypto.c
 - trivial

Signed-off-by: Jakub Kicinski <kuba@kernel.org>

diff --cc Documentation/devicetree/bindings/net/brcm,bcm4908-enet.yaml
Simple merge

diff --cc Documentation/networking/ethtool-netlink.rst
Simple merge

diff --cc MAINTAINERS
Simple merge

diff --cc arch/x86/net/bpf_jit_comp.c
Simple merge

diff --cc arch/x86/net/bpf_jit_comp32.c
Simple merge

diff --cc drivers/bluetooth/btusb.c
Simple merge

diff --cc drivers/net/can/spi/mcp251x.c
Simple merge

diff --cc drivers/net/can/usb/peak_usb/pcan_usb_core.c
Simple merge

diff --cc drivers/net/dsa/lantiq_gswip.c
index 26d0e3bb5dea722d1520d0e4bb5b2cb8d8978e3b,bf5c62e5c0b0effc077b1e6c5e3fd94738051f56..314ae78bbdd63d46ff9f016e6102432aa48af66e
--- 1/drivers/net/dsa/lantiq_gswip.c
--- 2/drivers/net/dsa/lantiq_gswip.c
+++ b/drivers/net/dsa/lantiq_gswip.c
@@@ -1496,8 -1475,115 +1524,114 @@@ unsupported
        bitmap_zero(supported, __ETHTOOL_LINK_MODE_MASK_NBITS);
        dev_err(ds->dev, "Unsupported interface '%s' for port %d\n",
                phy_modes(state->interface), port);
 -      return;
  }
  
+ static void gswip_port_set_link(struct gswip_priv *priv, int port, bool link)
+ {
+       u32 mdio_phy;
+ 
+       if (link)
+               mdio_phy = GSWIP_MDIO_PHY_LINK_UP;
+       else
+               mdio_phy = GSWIP_MDIO_PHY_LINK_DOWN;
+ 
+       gswip_mdio_mask(priv, GSWIP_MDIO_PHY_LINK_MASK, mdio_phy,
+                       GSWIP_MDIO_PHYp(port));
+ }
+ 
+ static void gswip_port_set_speed(struct gswip_priv *priv, int port, int speed,
+                                phy_interface_t interface)
+ {
+       u32 mdio_phy = 0, mii_cfg = 0, mac_ctrl_0 = 0;
+ 
+       switch (speed) {
+       case SPEED_10:
+               mdio_phy = GSWIP_MDIO_PHY_SPEED_M10;
+ 
+               if (interface == PHY_INTERFACE_MODE_RMII)
+                       mii_cfg = GSWIP_MII_CFG_RATE_M50;
+               else
+                       mii_cfg = GSWIP_MII_CFG_RATE_M2P5;
+ 
+               mac_ctrl_0 = GSWIP_MAC_CTRL_0_GMII_MII;
+               break;
+ 
+       case SPEED_100:
+               mdio_phy = GSWIP_MDIO_PHY_SPEED_M100;
+ 
+               if (interface == PHY_INTERFACE_MODE_RMII)
+                       mii_cfg = GSWIP_MII_CFG_RATE_M50;
+               else
+                       mii_cfg = GSWIP_MII_CFG_RATE_M25;
+ 
+               mac_ctrl_0 = GSWIP_MAC_CTRL_0_GMII_MII;
+               break;
+ 
+       case SPEED_1000:
+               mdio_phy = GSWIP_MDIO_PHY_SPEED_G1;
+ 
+               mii_cfg = GSWIP_MII_CFG_RATE_M125;
+ 
+               mac_ctrl_0 = GSWIP_MAC_CTRL_0_GMII_RGMII;
+               break;
+       }
+ 
+       gswip_mdio_mask(priv, GSWIP_MDIO_PHY_SPEED_MASK, mdio_phy,
+                       GSWIP_MDIO_PHYp(port));
+       gswip_mii_mask_cfg(priv, GSWIP_MII_CFG_RATE_MASK, mii_cfg, port);
+       gswip_switch_mask(priv, GSWIP_MAC_CTRL_0_GMII_MASK, mac_ctrl_0,
+                         GSWIP_MAC_CTRL_0p(port));
+ }
+ 
+ static void gswip_port_set_duplex(struct gswip_priv *priv, int port, int duplex)
+ {
+       u32 mac_ctrl_0, mdio_phy;
+ 
+       if (duplex == DUPLEX_FULL) {
+               mac_ctrl_0 = GSWIP_MAC_CTRL_0_FDUP_EN;
+               mdio_phy = GSWIP_MDIO_PHY_FDUP_EN;
+       } else {
+               mac_ctrl_0 = GSWIP_MAC_CTRL_0_FDUP_DIS;
+               mdio_phy = GSWIP_MDIO_PHY_FDUP_DIS;
+       }
+ 
+       gswip_switch_mask(priv, GSWIP_MAC_CTRL_0_FDUP_MASK, mac_ctrl_0,
+                         GSWIP_MAC_CTRL_0p(port));
+       gswip_mdio_mask(priv, GSWIP_MDIO_PHY_FDUP_MASK, mdio_phy,
+                       GSWIP_MDIO_PHYp(port));
+ }
+ 
+ static void gswip_port_set_pause(struct gswip_priv *priv, int port,
+                                bool tx_pause, bool rx_pause)
+ {
+       u32 mac_ctrl_0, mdio_phy;
+ 
+       if (tx_pause && rx_pause) {
+               mac_ctrl_0 = GSWIP_MAC_CTRL_0_FCON_RXTX;
+               mdio_phy = GSWIP_MDIO_PHY_FCONTX_EN |
+                          GSWIP_MDIO_PHY_FCONRX_EN;
+       } else if (tx_pause) {
+               mac_ctrl_0 = GSWIP_MAC_CTRL_0_FCON_TX;
+               mdio_phy = GSWIP_MDIO_PHY_FCONTX_EN |
+                          GSWIP_MDIO_PHY_FCONRX_DIS;
+       } else if (rx_pause) {
+               mac_ctrl_0 = GSWIP_MAC_CTRL_0_FCON_RX;
+               mdio_phy = GSWIP_MDIO_PHY_FCONTX_DIS |
+                          GSWIP_MDIO_PHY_FCONRX_EN;
+       } else {
+               mac_ctrl_0 = GSWIP_MAC_CTRL_0_FCON_NONE;
+               mdio_phy = GSWIP_MDIO_PHY_FCONTX_DIS |
+                          GSWIP_MDIO_PHY_FCONRX_DIS;
+       }
+ 
+       gswip_switch_mask(priv, GSWIP_MAC_CTRL_0_FCON_MASK,
+                         mac_ctrl_0, GSWIP_MAC_CTRL_0p(port));
+       gswip_mdio_mask(priv,
+                       GSWIP_MDIO_PHY_FCONTX_MASK |
+                       GSWIP_MDIO_PHY_FCONRX_MASK,
+                       mdio_phy, GSWIP_MDIO_PHYp(port));
+ }
+ 
  static void gswip_phylink_mac_config(struct dsa_switch *ds, int port,
                                     unsigned int mode,
                                     const struct phylink_link_state *state)

diff --cc drivers/net/ethernet/broadcom/bcm4908_enet.c
Simple merge

diff --cc drivers/net/ethernet/cadence/macb_main.c
Simple merge

diff --cc drivers/net/ethernet/chelsio/cxgb4/cudbg_lib.c
Simple merge

diff --cc drivers/net/ethernet/hisilicon/hns3/hns3pf/hclge_main.c
Simple merge

diff --cc drivers/net/ethernet/hisilicon/hns3/hns3vf/hclgevf_main.c
Simple merge

diff --cc drivers/net/ethernet/intel/i40e/i40e_debugfs.c
Simple merge

diff --cc drivers/net/ethernet/intel/i40e/i40e_ethtool.c
Simple merge

diff --cc drivers/net/ethernet/intel/i40e/i40e_main.c
Simple merge

diff --cc drivers/net/ethernet/intel/i40e/i40e_txrx.c
Simple merge

diff --cc drivers/net/ethernet/intel/i40e/i40e_xsk.c
Simple merge

diff --cc drivers/net/ethernet/intel/ice/ice.h
Simple merge

diff --cc drivers/net/ethernet/intel/ice/ice_common.c
Simple merge

diff --cc drivers/net/ethernet/intel/ice/ice_controlq.h
Simple merge

diff --cc drivers/net/ethernet/intel/ice/ice_dcb.c
Simple merge

diff --cc drivers/net/ethernet/intel/ice/ice_ethtool.c
Simple merge

diff --cc drivers/net/ethernet/intel/ice/ice_lib.c
Simple merge

diff --cc drivers/net/ethernet/intel/ice/ice_main.c
Simple merge

diff --cc drivers/net/ethernet/intel/ice/ice_switch.c
Simple merge

diff --cc drivers/net/ethernet/intel/ice/ice_type.h
Simple merge

diff --cc drivers/net/ethernet/mellanox/mlx5/core/dev.c
Simple merge

diff --cc drivers/net/ethernet/mellanox/mlx5/core/en.h
Simple merge

diff --cc drivers/net/ethernet/mellanox/mlx5/core/en/tc_ct.c
Simple merge

diff --cc drivers/net/ethernet/mellanox/mlx5/core/en/tc_tun.h
Simple merge

diff --cc drivers/net/ethernet/mellanox/mlx5/core/en/tc_tun_encap.c
Simple merge

diff --cc drivers/net/ethernet/mellanox/mlx5/core/en_accel/ktls_rx.c
Simple merge

diff --cc drivers/net/ethernet/mellanox/mlx5/core/en_ethtool.c
Simple merge

diff --cc drivers/net/ethernet/mellanox/mlx5/core/en_main.c
index 773449c1424b72c9f7d76eb57e4d3970e4de62e1,5db63b9f3b70d99a36d2f6a6e6043ee6f085b74f..2f47608bb9b9e2ff6e5ca6cbee7c2a642c58acdb
--- 1/drivers/net/ethernet/mellanox/mlx5/core/en_main.c
--- 2/drivers/net/ethernet/mellanox/mlx5/core/en_main.c
+++ b/drivers/net/ethernet/mellanox/mlx5/core/en_main.c
@@@ -1040,7 -1090,8 +1040,8 @@@ static int mlx5e_alloc_icosq(struct mlx
        int err;
  
        sq->channel   = c;
 -      sq->uar_map   = mdev->mlx5e_res.bfreg.map;
 +      sq->uar_map   = mdev->mlx5e_res.hw_objs.bfreg.map;
+       sq->reserved_room = param->stop_room;
  
        param->wq.db_numa_node = cpu_to_node(c->cpu);
        err = mlx5_wq_cyc_create(mdev, &param->wq, sqc_wq, wq, &sq->wq_ctrl);

diff --cc drivers/net/ethernet/mellanox/mlx5/core/en_rep.c
Simple merge

diff --cc drivers/net/ethernet/mellanox/mlx5/core/en_stats.c
Simple merge

diff --cc drivers/net/ethernet/mellanox/mlx5/core/en_stats.h
Simple merge

diff --cc drivers/net/ethernet/mellanox/mlx5/core/eq.c
Simple merge

diff --cc drivers/net/ethernet/mellanox/mlx5/core/eswitch_offloads.c
index 8b82f44bd6a74b4b07fbce4a5bc5862579a2476d,d4a2f8d1ee9f154d0ce71cb4ff5ca983b6635d88..ab32f685cbb7f70eaea01fc9ea0cee21cd8fb271
--- 1/drivers/net/ethernet/mellanox/mlx5/core/eswitch_offloads.c
--- 2/drivers/net/ethernet/mellanox/mlx5/core/eswitch_offloads.c
+++ b/drivers/net/ethernet/mellanox/mlx5/core/eswitch_offloads.c
@@@ -413,15 -558,10 +421,13 @@@ esw_setup_dests(struct mlx5_flow_destin
        int err = 0;
  
        if (!mlx5_eswitch_termtbl_required(esw, attr, flow_act, spec) &&
-           MLX5_CAP_GEN(esw_attr->in_mdev, reg_c_preserve) &&
-           mlx5_eswitch_vport_match_metadata_enabled(esw) &&
-           MLX5_CAP_ESW_FLOWTABLE_FDB(esw->dev, ignore_flow_level))
+           esw_src_port_rewrite_supported(esw))
                attr->flags |= MLX5_ESW_ATTR_FLAG_SRC_REWRITE;
  
 -      if (attr->dest_ft) {
 +      if (attr->flags & MLX5_ESW_ATTR_FLAG_SAMPLE) {
 +              esw_setup_sampler_dest(dest, flow_act, esw_attr, *i);
 +              (*i)++;
 +      } else if (attr->dest_ft) {
                esw_setup_ft_dest(dest, flow_act, esw, attr, spec, *i);
                (*i)++;
        } else if (attr->flags & MLX5_ESW_ATTR_FLAG_SLOW_PATH) {

diff --cc drivers/net/ethernet/mellanox/mlxsw/spectrum.h
Simple merge

diff --cc drivers/net/ethernet/mellanox/mlxsw/spectrum_ipip.c
Simple merge

diff --cc drivers/net/ethernet/microchip/lan743x_main.c
Simple merge

diff --cc drivers/net/ethernet/netronome/nfp/flower/main.h
Simple merge

diff --cc drivers/net/ethernet/xilinx/xilinx_axienet.h
Simple merge

diff --cc drivers/net/ethernet/xilinx/xilinx_axienet_main.c
Simple merge

diff --cc drivers/net/geneve.c
Simple merge

diff --cc drivers/net/tun.c
Simple merge

diff --cc drivers/net/virtio_net.c
Simple merge

diff --cc drivers/net/vxlan.c
Simple merge

diff --cc include/linux/avf/virtchnl.h
Simple merge

diff --cc include/linux/bpf.h
index 9fdd839b418ca757750c006c5a30ca61b5126dcb,fdac0534ce79d9b69fd0f5aa40452010f0cb24f0..c9b7a876b0c89dd182d3c0f1d72e69487b2f5539
--- 1/include/linux/bpf.h
--- 2/include/linux/bpf.h
+++ b/include/linux/bpf.h
@@@ -40,7 -40,7 +40,8 @@@ struct bpf_local_storage
  struct bpf_local_storage_map;
  struct kobject;
  struct mem_cgroup;
+ struct module;
 +struct bpf_func_state;
  
  extern struct idr btf_idr;
  extern spinlock_t btf_idr_lock;

diff --cc include/linux/ethtool.h
index 5c631a29899417aaf7f576018c2fb84acab6442f,cdca84e6dd6b0f1f4c3b10db596afb6e45609044..4290e2fa3117e970475ad6217926e584b8f1890a
--- 1/include/linux/ethtool.h
--- 2/include/linux/ethtool.h
+++ b/include/linux/ethtool.h
@@@ -573,13 -573,12 +575,22 @@@ struct ethtool_phy_ops 
   */
  void ethtool_set_ethtool_phy_ops(const struct ethtool_phy_ops *ops);
  
 -/*
++/**
+  * ethtool_params_from_link_mode - Derive link parameters from a given link mode
+  * @link_ksettings: Link parameters to be derived from the link mode
+  * @link_mode: Link mode
+  */
+ void
+ ethtool_params_from_link_mode(struct ethtool_link_ksettings *link_ksettings,
+                             enum ethtool_link_mode_bit_indices link_mode);
++
 +/**
 + * ethtool_sprintf - Write formatted string to ethtool string data
 + * @data: Pointer to start of string to update
 + * @fmt: Format of string to write
 + *
 + * Write formatted string to data. Update data to point at start of
 + * next string.
 + */
 +extern __printf(2, 3) void ethtool_sprintf(u8 **data, const char *fmt, ...);
  #endif /* _LINUX_ETHTOOL_H */

diff --cc include/linux/mlx5/mlx5_ifc.h
Simple merge

diff --cc include/linux/skmsg.h
index f78e90a04a69b733707fb94fcd157d398c46b143,822c048934e3f6689e4e950e7139ad55f8934124..e242bf3d2b4a39b269a5fcf85b34d037badae826
--- 1/include/linux/skmsg.h
--- 2/include/linux/skmsg.h
+++ b/include/linux/skmsg.h
@@@ -403,9 -341,27 +403,8 @@@ static inline void sk_psock_cork_free(s
  static inline void sk_psock_restore_proto(struct sock *sk,
                                          struct sk_psock *psock)
  {
-       sk->sk_prot->unhash = psock->saved_unhash;
 -      if (inet_csk_has_ulp(sk)) {
 -              /* TLS does not have an unhash proto in SW cases, but we need
 -               * to ensure we stop using the sock_map unhash routine because
 -               * the associated psock is being removed. So use the original
 -               * unhash handler.
 -               */
 -              WRITE_ONCE(sk->sk_prot->unhash, psock->saved_unhash);
 -              tcp_update_ulp(sk, psock->sk_proto, psock->saved_write_space);
 -      } else {
 -              sk->sk_write_space = psock->saved_write_space;
 -              /* Pairs with lockless read in sk_clone_lock() */
 -              WRITE_ONCE(sk->sk_prot, psock->sk_proto);
 -      }
 +      if (psock->psock_update_sk_prot)
 +              psock->psock_update_sk_prot(sk, true);
  }
  
  static inline void sk_psock_set_state(struct sk_psock *psock,

diff --cc include/net/sock.h
Simple merge

diff --cc include/uapi/linux/ethtool.h
Simple merge

diff --cc kernel/bpf/disasm.c
Simple merge

diff --cc kernel/bpf/verifier.c
Simple merge

diff --cc kernel/fork.c
Simple merge

diff --cc net/core/dev.c
Simple merge

diff --cc net/core/rtnetlink.c
Simple merge

diff --cc net/core/skmsg.c
index 92a83c02562a7902de5b980994feb5f38c1ebe8a,5def3a2e85be9c597238266fd57a96a21af49e9e..43ce17a6a58529781a48947ff4013d1f3b981adf
--- 1/net/core/skmsg.c
--- 2/net/core/skmsg.c
+++ b/net/core/skmsg.c
@@@ -900,17 -806,12 +900,13 @@@ int sk_psock_tls_strp_read(struct sk_ps
        int ret = __SK_PASS;
  
        rcu_read_lock();
 -      prog = READ_ONCE(psock->progs.skb_verdict);
 +      prog = READ_ONCE(psock->progs.stream_verdict);
        if (likely(prog)) {
-               /* We skip full set_owner_r here because if we do a SK_PASS
-                * or SK_DROP we can skip skb memory accounting and use the
-                * TLS context.
-                */
                skb->sk = psock->sk;
 -              tcp_skb_bpf_redirect_clear(skb);
 -              ret = sk_psock_bpf_run(psock, prog, skb);
 -              ret = sk_psock_map_verd(ret, tcp_skb_bpf_redirect_fetch(skb));
 +              skb_dst_drop(skb);
 +              skb_bpf_redirect_clear(skb);
 +              ret = bpf_prog_run_pin_on_cpu(prog, skb);
 +              ret = sk_psock_map_verd(ret, skb_bpf_redirect_fetch(skb));
                skb->sk = NULL;
        }
        sk_psock_tls_verdict_apply(skb, psock->sk, ret);
@@@ -995,13 -876,13 +991,14 @@@ static void sk_psock_strp_read(struct s
                kfree_skb(skb);
                goto out;
        }
-       skb_set_owner_r(skb, sk);
 -      prog = READ_ONCE(psock->progs.skb_verdict);
 +      prog = READ_ONCE(psock->progs.stream_verdict);
        if (likely(prog)) {
 -              tcp_skb_bpf_redirect_clear(skb);
 -              ret = sk_psock_bpf_run(psock, prog, skb);
 -              ret = sk_psock_map_verd(ret, tcp_skb_bpf_redirect_fetch(skb));
+               skb->sk = sk;
 +              skb_dst_drop(skb);
 +              skb_bpf_redirect_clear(skb);
 +              ret = bpf_prog_run_pin_on_cpu(prog, skb);
 +              ret = sk_psock_map_verd(ret, skb_bpf_redirect_fetch(skb));
+               skb->sk = NULL;
        }
        sk_psock_verdict_apply(psock, skb, ret);
  out:
@@@ -1115,15 -953,13 +1112,16 @@@ static int sk_psock_verdict_recv(read_d
                kfree_skb(skb);
                goto out;
        }
-       skb_set_owner_r(skb, sk);
 -      prog = READ_ONCE(psock->progs.skb_verdict);
 +      prog = READ_ONCE(psock->progs.stream_verdict);
 +      if (!prog)
 +              prog = READ_ONCE(psock->progs.skb_verdict);
        if (likely(prog)) {
 -              tcp_skb_bpf_redirect_clear(skb);
 -              ret = sk_psock_bpf_run(psock, prog, skb);
 -              ret = sk_psock_map_verd(ret, tcp_skb_bpf_redirect_fetch(skb));
+               skb->sk = sk;
 +              skb_dst_drop(skb);
 +              skb_bpf_redirect_clear(skb);
 +              ret = bpf_prog_run_pin_on_cpu(prog, skb);
 +              ret = sk_psock_map_verd(ret, skb_bpf_redirect_fetch(skb));
+               skb->sk = NULL;
        }
        sk_psock_verdict_apply(psock, skb, ret);
  out:

diff --cc net/ethtool/ioctl.c
Simple merge

diff --cc net/ipv4/esp4.c
Simple merge

diff --cc net/ipv4/tcp_bpf.c
index 3d622a0d075339d05090110b2673fa447a97f2cd,bc7d2a586e18307cb54cff1e8104234b378c1654..4f49c12dae53829c692a56531141fc8d00a51771
--- 1/net/ipv4/tcp_bpf.c
--- 2/net/ipv4/tcp_bpf.c
+++ b/net/ipv4/tcp_bpf.c
@@@ -505,23 -606,9 +505,29 @@@ int tcp_bpf_update_proto(struct sock *s
        int family = sk->sk_family == AF_INET6 ? TCP_BPF_IPV6 : TCP_BPF_IPV4;
        int config = psock->progs.msg_parser   ? TCP_BPF_TX   : TCP_BPF_BASE;
  
 +      if (restore) {
 +              if (inet_csk_has_ulp(sk)) {
++                      /* TLS does not have an unhash proto in SW cases,
++                       * but we need to ensure we stop using the sock_map
++                       * unhash routine because the associated psock is being
++                       * removed. So use the original unhash handler.
++                       */
++                      WRITE_ONCE(sk->sk_prot->unhash, psock->saved_unhash);
 +                      tcp_update_ulp(sk, psock->sk_proto, psock->saved_write_space);
 +              } else {
 +                      sk->sk_write_space = psock->saved_write_space;
 +                      /* Pairs with lockless read in sk_clone_lock() */
 +                      WRITE_ONCE(sk->sk_prot, psock->sk_proto);
 +              }
 +              return 0;
 +      }
 +
 +      if (inet_csk_has_ulp(sk))
 +              return -EINVAL;
 +
        if (sk->sk_family == AF_INET6) {
                if (tcp_bpf_assert_proto_ops(psock->sk_proto))
 -                      return ERR_PTR(-EINVAL);
 +                      return -EINVAL;
  
                tcp_bpf_check_v6_needs_rebuild(psock->sk_proto);
        }

diff --cc net/ipv4/udp.c
Simple merge

diff --cc net/ipv6/addrconf.c
Simple merge

diff --cc net/ipv6/ip6_vti.c
Simple merge

diff --cc net/ipv6/route.c
Simple merge

diff --cc net/mac80211/cfg.c
Simple merge

diff --cc net/mptcp/protocol.c
Simple merge

diff --cc net/openvswitch/conntrack.c
Simple merge

diff --cc net/qrtr/qrtr.c
Simple merge

diff --cc net/rds/send.c
Simple merge

diff --cc net/sched/cls_api.c
Simple merge

diff --cc net/tipc/crypto.c
Simple merge

diff --cc net/tipc/net.c
Simple merge

diff --cc net/tipc/node.c
Simple merge

diff --cc net/tipc/socket.c
Simple merge

diff --cc tools/lib/bpf/xsk.c
index 95da0e19f4a5fea0c70399ea80e0f7b85393ea65,d24b5cc720ec6799e779e00e82c63a1ad3385ca0..cea62cc3e4561901aae5fdbe4bd768bb39c5c850
--- 1/tools/lib/bpf/xsk.c
--- 2/tools/lib/bpf/xsk.c
+++ b/tools/lib/bpf/xsk.c
@@@ -1063,9 -906,8 +1071,9 @@@ int xsk_socket__create_shared(struct xs
                }
        }
        xsk->ctx = ctx;
 +      xsk->ctx->has_bpf_link = xsk_probe_bpf_link();
  
-       if (rx) {
+       if (rx && !rx_setup_done) {
                err = setsockopt(xsk->fd, SOL_XDP, XDP_RX_RING,
                                 &xsk->config.rx_size,
                                 sizeof(xsk->config.rx_size));