bnxt_en: optimized XDP_REDIRECT support
authorAndy Gospodarek <gospo@broadcom.com>
Mon, 8 Jul 2019 21:53:03 +0000 (17:53 -0400)
committerDavid S. Miller <davem@davemloft.net>
Mon, 8 Jul 2019 22:15:24 +0000 (15:15 -0700)
This adds basic support for XDP_REDIRECT in the bnxt_en driver.  Next
patch adds the more optimized page pool support.

Signed-off-by: Andy Gospodarek <gospo@broadcom.com>
Signed-off-by: Michael Chan <michael.chan@broadcom.com>
Signed-off-by: David S. Miller <davem@davemloft.net>
drivers/net/ethernet/broadcom/bnxt/bnxt.c
drivers/net/ethernet/broadcom/bnxt/bnxt.h
drivers/net/ethernet/broadcom/bnxt/bnxt_xdp.c
drivers/net/ethernet/broadcom/bnxt/bnxt_xdp.h

index b7b62273c9550b078d4207893f302c1c819bb61f..d8f0846719e1fdacd104aee5d70c564e2003bc72 100644 (file)
@@ -1989,6 +1989,9 @@ static int __bnxt_poll_work(struct bnxt *bp, struct bnxt_cp_ring_info *cpr,
                }
        }
 
+       if (event & BNXT_REDIRECT_EVENT)
+               xdp_do_flush_map();
+
        if (event & BNXT_TX_EVENT) {
                struct bnxt_tx_ring_info *txr = bnapi->tx_ring;
                u16 prod = txr->tx_prod;
@@ -2254,9 +2257,23 @@ static void bnxt_free_tx_skbs(struct bnxt *bp)
 
                for (j = 0; j < max_idx;) {
                        struct bnxt_sw_tx_bd *tx_buf = &txr->tx_buf_ring[j];
-                       struct sk_buff *skb = tx_buf->skb;
+                       struct sk_buff *skb;
                        int k, last;
 
+                       if (i < bp->tx_nr_rings_xdp &&
+                           tx_buf->action == XDP_REDIRECT) {
+                               dma_unmap_single(&pdev->dev,
+                                       dma_unmap_addr(tx_buf, mapping),
+                                       dma_unmap_len(tx_buf, len),
+                                       PCI_DMA_TODEVICE);
+                               xdp_return_frame(tx_buf->xdpf);
+                               tx_buf->action = 0;
+                               tx_buf->xdpf = NULL;
+                               j++;
+                               continue;
+                       }
+
+                       skb = tx_buf->skb;
                        if (!skb) {
                                j++;
                                continue;
@@ -2517,6 +2534,13 @@ static int bnxt_alloc_rx_rings(struct bnxt *bp)
                if (rc < 0)
                        return rc;
 
+               rc = xdp_rxq_info_reg_mem_model(&rxr->xdp_rxq,
+                                               MEM_TYPE_PAGE_SHARED, NULL);
+               if (rc) {
+                       xdp_rxq_info_unreg(&rxr->xdp_rxq);
+                       return rc;
+               }
+
                rc = bnxt_alloc_ring(bp, &ring->ring_mem);
                if (rc)
                        return rc;
@@ -10233,6 +10257,7 @@ static const struct net_device_ops bnxt_netdev_ops = {
        .ndo_udp_tunnel_add     = bnxt_udp_tunnel_add,
        .ndo_udp_tunnel_del     = bnxt_udp_tunnel_del,
        .ndo_bpf                = bnxt_xdp,
+       .ndo_xdp_xmit           = bnxt_xdp_xmit,
        .ndo_bridge_getlink     = bnxt_bridge_getlink,
        .ndo_bridge_setlink     = bnxt_bridge_setlink,
        .ndo_get_devlink_port   = bnxt_get_devlink_port,
index bf12cfce64c2561aa1f5e8b536d3b4627210e9a1..8ac51fa818587b6bfb9abe95010138c37c8422c4 100644 (file)
@@ -587,13 +587,18 @@ struct nqe_cn {
 #define BNXT_HWRM_CHNL_CHIMP   0
 #define BNXT_HWRM_CHNL_KONG    1
 
-#define BNXT_RX_EVENT  1
-#define BNXT_AGG_EVENT 2
-#define BNXT_TX_EVENT  4
+#define BNXT_RX_EVENT          1
+#define BNXT_AGG_EVENT         2
+#define BNXT_TX_EVENT          4
+#define BNXT_REDIRECT_EVENT    8
 
 struct bnxt_sw_tx_bd {
-       struct sk_buff          *skb;
+       union {
+               struct sk_buff          *skb;
+               struct xdp_frame        *xdpf;
+       };
        DEFINE_DMA_UNMAP_ADDR(mapping);
+       DEFINE_DMA_UNMAP_LEN(len);
        u8                      is_gso;
        u8                      is_push;
        u8                      action;
index 41e232e133dbfe937e21439421616c27607690f4..12489d235eb997b4f445e6231436a9ee63ae7e0d 100644 (file)
@@ -53,6 +53,20 @@ static void __bnxt_xmit_xdp(struct bnxt *bp, struct bnxt_tx_ring_info *txr,
        tx_buf->action = XDP_TX;
 }
 
+static void __bnxt_xmit_xdp_redirect(struct bnxt *bp,
+                                    struct bnxt_tx_ring_info *txr,
+                                    dma_addr_t mapping, u32 len,
+                                    struct xdp_frame *xdpf)
+{
+       struct bnxt_sw_tx_bd *tx_buf;
+
+       tx_buf = bnxt_xmit_bd(bp, txr, mapping, len);
+       tx_buf->action = XDP_REDIRECT;
+       tx_buf->xdpf = xdpf;
+       dma_unmap_addr_set(tx_buf, mapping, mapping);
+       dma_unmap_len_set(tx_buf, len, 0);
+}
+
 void bnxt_tx_int_xdp(struct bnxt *bp, struct bnxt_napi *bnapi, int nr_pkts)
 {
        struct bnxt_tx_ring_info *txr = bnapi->tx_ring;
@@ -66,7 +80,17 @@ void bnxt_tx_int_xdp(struct bnxt *bp, struct bnxt_napi *bnapi, int nr_pkts)
        for (i = 0; i < nr_pkts; i++) {
                tx_buf = &txr->tx_buf_ring[tx_cons];
 
-               if (tx_buf->action == XDP_TX) {
+               if (tx_buf->action == XDP_REDIRECT) {
+                       struct pci_dev *pdev = bp->pdev;
+
+                       dma_unmap_single(&pdev->dev,
+                                        dma_unmap_addr(tx_buf, mapping),
+                                        dma_unmap_len(tx_buf, len),
+                                        PCI_DMA_TODEVICE);
+                       xdp_return_frame(tx_buf->xdpf);
+                       tx_buf->action = 0;
+                       tx_buf->xdpf = NULL;
+               } else if (tx_buf->action == XDP_TX) {
                        rx_doorbell_needed = true;
                        last_tx_cons = tx_cons;
                }
@@ -101,19 +125,19 @@ bool bnxt_rx_xdp(struct bnxt *bp, struct bnxt_rx_ring_info *rxr, u16 cons,
                return false;
 
        pdev = bp->pdev;
-       txr = rxr->bnapi->tx_ring;
        rx_buf = &rxr->rx_buf_ring[cons];
        offset = bp->rx_offset;
 
+       mapping = rx_buf->mapping - bp->rx_dma_offset;
+       dma_sync_single_for_cpu(&pdev->dev, mapping + offset, *len, bp->rx_dir);
+
+       txr = rxr->bnapi->tx_ring;
        xdp.data_hard_start = *data_ptr - offset;
        xdp.data = *data_ptr;
        xdp_set_data_meta_invalid(&xdp);
        xdp.data_end = *data_ptr + *len;
        xdp.rxq = &rxr->xdp_rxq;
        orig_data = xdp.data;
-       mapping = rx_buf->mapping - bp->rx_dma_offset;
-
-       dma_sync_single_for_cpu(&pdev->dev, mapping + offset, *len, bp->rx_dir);
 
        rcu_read_lock();
        act = bpf_prog_run_xdp(xdp_prog, &xdp);
@@ -149,6 +173,30 @@ bool bnxt_rx_xdp(struct bnxt *bp, struct bnxt_rx_ring_info *rxr, u16 cons,
                                NEXT_RX(rxr->rx_prod));
                bnxt_reuse_rx_data(rxr, cons, page);
                return true;
+       case XDP_REDIRECT:
+               /* if we are calling this here then we know that the
+                * redirect is coming from a frame received by the
+                * bnxt_en driver.
+                */
+               dma_unmap_page_attrs(&pdev->dev, mapping,
+                                    PAGE_SIZE, bp->rx_dir,
+                                    DMA_ATTR_WEAK_ORDERING);
+
+               /* if we are unable to allocate a new buffer, abort and reuse */
+               if (bnxt_alloc_rx_data(bp, rxr, rxr->rx_prod, GFP_ATOMIC)) {
+                       trace_xdp_exception(bp->dev, xdp_prog, act);
+                       bnxt_reuse_rx_data(rxr, cons, page);
+                       return true;
+               }
+
+               if (xdp_do_redirect(bp->dev, &xdp, xdp_prog)) {
+                       trace_xdp_exception(bp->dev, xdp_prog, act);
+                       __free_page(page);
+                       return true;
+               }
+
+               *event |= BNXT_REDIRECT_EVENT;
+               break;
        default:
                bpf_warn_invalid_xdp_action(act);
                /* Fall thru */
@@ -162,6 +210,56 @@ bool bnxt_rx_xdp(struct bnxt *bp, struct bnxt_rx_ring_info *rxr, u16 cons,
        return true;
 }
 
+int bnxt_xdp_xmit(struct net_device *dev, int num_frames,
+                 struct xdp_frame **frames, u32 flags)
+{
+       struct bnxt *bp = netdev_priv(dev);
+       struct bpf_prog *xdp_prog = READ_ONCE(bp->xdp_prog);
+       struct pci_dev *pdev = bp->pdev;
+       struct bnxt_tx_ring_info *txr;
+       dma_addr_t mapping;
+       int drops = 0;
+       int ring;
+       int i;
+
+       if (!test_bit(BNXT_STATE_OPEN, &bp->state) ||
+           !bp->tx_nr_rings_xdp ||
+           !xdp_prog)
+               return -EINVAL;
+
+       ring = smp_processor_id() % bp->tx_nr_rings_xdp;
+       txr = &bp->tx_ring[ring];
+
+       for (i = 0; i < num_frames; i++) {
+               struct xdp_frame *xdp = frames[i];
+
+               if (!txr || !bnxt_tx_avail(bp, txr) ||
+                   !(bp->bnapi[ring]->flags & BNXT_NAPI_FLAG_XDP)) {
+                       xdp_return_frame_rx_napi(xdp);
+                       drops++;
+                       continue;
+               }
+
+               mapping = dma_map_single(&pdev->dev, xdp->data, xdp->len,
+                                        DMA_TO_DEVICE);
+
+               if (dma_mapping_error(&pdev->dev, mapping)) {
+                       xdp_return_frame_rx_napi(xdp);
+                       drops++;
+                       continue;
+               }
+               __bnxt_xmit_xdp_redirect(bp, txr, mapping, xdp->len, xdp);
+       }
+
+       if (flags & XDP_XMIT_FLUSH) {
+               /* Sync BD data before updating doorbell */
+               wmb();
+               bnxt_db_write(bp, &txr->tx_db, txr->tx_prod);
+       }
+
+       return num_frames - drops;
+}
+
 /* Under rtnl_lock */
 static int bnxt_xdp_set(struct bnxt *bp, struct bpf_prog *prog)
 {
index 20e470cd4f99a84e0bb497ffd5d5f666bd12f666..0df40c3beb05024b68116679b6194173f73e1524 100644 (file)
@@ -18,5 +18,7 @@ bool bnxt_rx_xdp(struct bnxt *bp, struct bnxt_rx_ring_info *rxr, u16 cons,
                 struct page *page, u8 **data_ptr, unsigned int *len,
                 u8 *event);
 int bnxt_xdp(struct net_device *dev, struct netdev_bpf *xdp);
+int bnxt_xdp_xmit(struct net_device *dev, int num_frames,
+                 struct xdp_frame **frames, u32 flags);
 
 #endif