]> git.ipfire.org Git - thirdparty/linux.git/commitdiff
eth: mlx4: create a page pool for Rx
authorJakub Kicinski <kuba@kernel.org>
Thu, 13 Feb 2025 01:06:32 +0000 (17:06 -0800)
committerJakub Kicinski <kuba@kernel.org>
Tue, 18 Feb 2025 23:32:20 +0000 (15:32 -0800)
Create a pool per rx queue. Subsequent patches will make use of it.

Move fcs_del to a hole to make space for the pointer.

Per common "wisdom" base the page pool size on the ring size.
Note that the page pool cache size is in full pages, so just
round up the effective buffer size to pages.

Reviewed-by: Tariq Toukan <tariqt@nvidia.com>
Link: https://patch.msgid.link/20250213010635.1354034-2-kuba@kernel.org
Signed-off-by: Jakub Kicinski <kuba@kernel.org>
drivers/net/ethernet/mellanox/mlx4/en_rx.c
drivers/net/ethernet/mellanox/mlx4/mlx4_en.h

index 15c57e9517e9a118a2b6a96dbc1365431406f947..a8c0cf5d0d08338871c0104c9c8c0a1604da7ce9 100644 (file)
@@ -48,6 +48,7 @@
 #if IS_ENABLED(CONFIG_IPV6)
 #include <net/ip6_checksum.h>
 #endif
+#include <net/page_pool/helpers.h>
 
 #include "mlx4_en.h"
 
@@ -268,6 +269,7 @@ int mlx4_en_create_rx_ring(struct mlx4_en_priv *priv,
                           u32 size, u16 stride, int node, int queue_index)
 {
        struct mlx4_en_dev *mdev = priv->mdev;
+       struct page_pool_params pp = {};
        struct mlx4_en_rx_ring *ring;
        int err = -ENOMEM;
        int tmp;
@@ -286,9 +288,26 @@ int mlx4_en_create_rx_ring(struct mlx4_en_priv *priv,
        ring->log_stride = ffs(ring->stride) - 1;
        ring->buf_size = ring->size * ring->stride + TXBB_SIZE;
 
-       if (xdp_rxq_info_reg(&ring->xdp_rxq, priv->dev, queue_index, 0) < 0)
+       pp.flags = PP_FLAG_DMA_MAP;
+       pp.pool_size = size * DIV_ROUND_UP(priv->rx_skb_size, PAGE_SIZE);
+       pp.nid = node;
+       pp.napi = &priv->rx_cq[queue_index]->napi;
+       pp.netdev = priv->dev;
+       pp.dev = &mdev->dev->persist->pdev->dev;
+       pp.dma_dir = priv->dma_dir;
+
+       ring->pp = page_pool_create(&pp);
+       if (!ring->pp)
                goto err_ring;
 
+       if (xdp_rxq_info_reg(&ring->xdp_rxq, priv->dev, queue_index, 0) < 0)
+               goto err_pp;
+
+       err = xdp_rxq_info_reg_mem_model(&ring->xdp_rxq, MEM_TYPE_PAGE_POOL,
+                                        ring->pp);
+       if (err)
+               goto err_xdp_info;
+
        tmp = size * roundup_pow_of_two(MLX4_EN_MAX_RX_FRAGS *
                                        sizeof(struct mlx4_en_rx_alloc));
        ring->rx_info = kvzalloc_node(tmp, GFP_KERNEL, node);
@@ -319,6 +338,8 @@ err_info:
        ring->rx_info = NULL;
 err_xdp_info:
        xdp_rxq_info_unreg(&ring->xdp_rxq);
+err_pp:
+       page_pool_destroy(ring->pp);
 err_ring:
        kfree(ring);
        *pring = NULL;
@@ -445,6 +466,7 @@ void mlx4_en_destroy_rx_ring(struct mlx4_en_priv *priv,
        xdp_rxq_info_unreg(&ring->xdp_rxq);
        mlx4_free_hwq_res(mdev->dev, &ring->wqres, size * stride + TXBB_SIZE);
        kvfree(ring->rx_info);
+       page_pool_destroy(ring->pp);
        ring->rx_info = NULL;
        kfree(ring);
        *pring = NULL;
index 28b70dcc652e6970094427714685857b6361c207..29f48e63081b6c0dc4b6de6c24b7926dfb108e33 100644 (file)
@@ -335,10 +335,11 @@ struct mlx4_en_rx_ring {
        u16 stride;
        u16 log_stride;
        u16 cqn;        /* index of port CQ associated with this ring */
+       u8  fcs_del;
        u32 prod;
        u32 cons;
        u32 buf_size;
-       u8  fcs_del;
+       struct page_pool *pp;
        void *buf;
        void *rx_info;
        struct bpf_prog __rcu *xdp_prog;