From patchwork Wed Dec 19 01:04:51 2018 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: William Tu X-Patchwork-Id: 1015776 X-Patchwork-Delegate: bpf@iogearbox.net Return-Path: X-Original-To: patchwork-incoming-netdev@ozlabs.org Delivered-To: patchwork-incoming-netdev@ozlabs.org Authentication-Results: ozlabs.org; spf=none (mailfrom) smtp.mailfrom=vger.kernel.org (client-ip=209.132.180.67; helo=vger.kernel.org; envelope-from=netdev-owner@vger.kernel.org; receiver=) Authentication-Results: ozlabs.org; dmarc=pass (p=none dis=none) header.from=gmail.com Authentication-Results: ozlabs.org; dkim=pass (2048-bit key; unprotected) header.d=gmail.com header.i=@gmail.com header.b="kcte1mcf"; dkim-atps=neutral Received: from vger.kernel.org (vger.kernel.org [209.132.180.67]) by ozlabs.org (Postfix) with ESMTP id 43KGdl6lKWz9s3Z for ; Wed, 19 Dec 2018 11:55:23 +1100 (AEDT) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S1727201AbeLSAzO (ORCPT ); Tue, 18 Dec 2018 19:55:14 -0500 Received: from mail-pg1-f193.google.com ([209.85.215.193]:43871 "EHLO mail-pg1-f193.google.com" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S1726629AbeLSAzO (ORCPT ); Tue, 18 Dec 2018 19:55:14 -0500 Received: by mail-pg1-f193.google.com with SMTP id v28so8610101pgk.10 for ; Tue, 18 Dec 2018 16:55:13 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=from:to:subject:date:message-id:in-reply-to:references; bh=jOstfbjtAxNawOiZh1MSt3i0YqYJFmWM3pu2A6FDbnU=; b=kcte1mcfAOuIXUnEH5FYNRC25SCDKjSzbzUQHfWTSFVKCjL+XxBgOruD/jDPmpXMU1 cKDAOi0E92EIjWSc5RIMsJlU/zxx1tVko+t6FbnSlBuJX31viXCgBkCFDxkxbEDEa4zu 6mUIaQbM4u1dp2Y5caBfe+S9WTNd8/aCplgWWE3rejgoKMmYcXIJucQBT7PA5VVWXaYm 7Ffum2AGZuMUZX8rThZA07fBUeE0OYwfAZ/gNG+++vHbecCWSctTqCNfL5qrNPMFKJn9 wDtedvD2tHxkd+hu1TgvavOkUb6L6YhNpqtb1BipUakcENwPK32H1+d8jVcUU7AoIPj/ YhNA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:from:to:subject:date:message-id:in-reply-to :references; bh=jOstfbjtAxNawOiZh1MSt3i0YqYJFmWM3pu2A6FDbnU=; b=J4hrq0UQHZjXnC9Uj9xLNVP7WG3pq2SJowP2gvfD3VNyCuMaMg+Eb5VwSIfHff+Qe0 1If6bR+kUNqbyN6eioWqVKKPBhXOExpb0XoAIssxTZnlAtKPaja75ynpaxpBbGo0SMho 3fHZxZ02z4SerTb8V0FZQGrhiq83GWCG6NqBvgpEefLynv5iroheDqIfWuj+YisiQRbu aOzyN2SszcS+a+UhKsiWWOuf0mhiyVJLmdTzIkqQlNkzgBmxlZyfpocluHEBf92mmdkP NQyLjox0XSFSHSAgpOY60fLKZdBcGTNvvbPqE3tuzA+HZfkA+GJwCtf/3BHiMte9eacK gzZw== X-Gm-Message-State: AA+aEWamwucPM8qBF6MK38aONPjhGyB0qqZ008UrlAjP2MgDasW+wznu y+4scz1nXxx356j1KW+zMt8= X-Google-Smtp-Source: AFSGD/VtTLfASzDt1A7mXuEVKNl8otSngBEcEPjZpajBgndRFb+q4dUF5CbT9qEd076c7lCZlRxNww== X-Received: by 2002:a63:1f1c:: with SMTP id f28mr5223600pgf.193.1545180913093; Tue, 18 Dec 2018 16:55:13 -0800 (PST) Received: from sc9-mailhost2.vmware.com ([66.170.99.1]) by smtp.gmail.com with ESMTPSA id c13sm38964804pfe.93.2018.12.18.16.55.12 (version=TLS1_2 cipher=ECDHE-RSA-AES128-SHA bits=128/128); Tue, 18 Dec 2018 16:55:12 -0800 (PST) From: William Tu To: bjorn.topel@gmail.com, magnus.karlsson@gmail.com, ast@kernel.org, daniel@iogearbox.net, netdev@vger.kernel.org, makita.toshiaki@lab.ntt.co.jp, yihung.wei@gmail.com Subject: [bpf-next RFCv2 1/3] xsk: add xsk_umem_consume_tx_virtual. Date: Tue, 18 Dec 2018 17:04:51 -0800 Message-Id: <1545181493-8743-2-git-send-email-u9012063@gmail.com> X-Mailer: git-send-email 2.7.4 In-Reply-To: <1545181493-8743-1-git-send-email-u9012063@gmail.com> References: <1545181493-8743-1-git-send-email-u9012063@gmail.com> Sender: netdev-owner@vger.kernel.org Precedence: bulk List-ID: X-Mailing-List: netdev@vger.kernel.org Currently the xsk_umem_consume_tx expects only the physical NICs so the api returns a dma address. This patch introduce the new function to return the virtual address, when XSK is used by a virtual device. Signed-off-by: William Tu --- include/net/xdp_sock.h | 7 +++++++ net/xdp/xdp_umem.c | 1 + net/xdp/xsk.c | 21 +++++++++++++++++++-- 3 files changed, 27 insertions(+), 2 deletions(-) diff --git a/include/net/xdp_sock.h b/include/net/xdp_sock.h index 13acb9803a6d..7fefe74f7fb5 100644 --- a/include/net/xdp_sock.h +++ b/include/net/xdp_sock.h @@ -81,6 +81,7 @@ u64 *xsk_umem_peek_addr(struct xdp_umem *umem, u64 *addr); void xsk_umem_discard_addr(struct xdp_umem *umem); void xsk_umem_complete_tx(struct xdp_umem *umem, u32 nb_entries); bool xsk_umem_consume_tx(struct xdp_umem *umem, dma_addr_t *dma, u32 *len); +bool xsk_umem_consume_tx_virtual(struct xdp_umem *umem, void **addr, u32 *len); void xsk_umem_consume_tx_done(struct xdp_umem *umem); struct xdp_umem_fq_reuse *xsk_reuseq_prepare(u32 nentries); struct xdp_umem_fq_reuse *xsk_reuseq_swap(struct xdp_umem *umem, @@ -165,6 +166,12 @@ static inline bool xsk_umem_consume_tx(struct xdp_umem *umem, dma_addr_t *dma, return false; } +static inline bool xsk_umem_consume_tx_virtual(struct xdp_umem *umem, + void **vaddr, u32 *len) +{ + return false; +} + static inline void xsk_umem_consume_tx_done(struct xdp_umem *umem) { } diff --git a/net/xdp/xdp_umem.c b/net/xdp/xdp_umem.c index a264cf2accd0..424ae2538f9f 100644 --- a/net/xdp/xdp_umem.c +++ b/net/xdp/xdp_umem.c @@ -60,6 +60,7 @@ struct xdp_umem *xdp_get_umem_from_qid(struct net_device *dev, return NULL; } +EXPORT_SYMBOL(xdp_get_umem_from_qid); static void xdp_clear_umem_at_qid(struct net_device *dev, u16 queue_id) { diff --git a/net/xdp/xsk.c b/net/xdp/xsk.c index 07156f43d295..a6ca0c0f0330 100644 --- a/net/xdp/xsk.c +++ b/net/xdp/xsk.c @@ -170,7 +170,8 @@ void xsk_umem_consume_tx_done(struct xdp_umem *umem) } EXPORT_SYMBOL(xsk_umem_consume_tx_done); -bool xsk_umem_consume_tx(struct xdp_umem *umem, dma_addr_t *dma, u32 *len) +static bool __xsk_umem_consume_tx(struct xdp_umem *umem, dma_addr_t *dma, + void **vaddr, u32 *len) { struct xdp_desc desc; struct xdp_sock *xs; @@ -183,7 +184,12 @@ bool xsk_umem_consume_tx(struct xdp_umem *umem, dma_addr_t *dma, u32 *len) if (xskq_produce_addr_lazy(umem->cq, desc.addr)) goto out; - *dma = xdp_umem_get_dma(umem, desc.addr); + if (dma) + *dma = xdp_umem_get_dma(umem, desc.addr); + + if (vaddr) + *vaddr = xdp_umem_get_data(umem, desc.addr); + *len = desc.len; xskq_discard_desc(xs->tx); @@ -195,8 +201,19 @@ bool xsk_umem_consume_tx(struct xdp_umem *umem, dma_addr_t *dma, u32 *len) rcu_read_unlock(); return false; } + +bool xsk_umem_consume_tx(struct xdp_umem *umem, dma_addr_t *dma, u32 *len) +{ + return __xsk_umem_consume_tx(umem, dma, NULL, len); +} EXPORT_SYMBOL(xsk_umem_consume_tx); +bool xsk_umem_consume_tx_virtual(struct xdp_umem *umem, void **addr, u32 *len) +{ + return __xsk_umem_consume_tx(umem, NULL, addr, len); +} +EXPORT_SYMBOL(xsk_umem_consume_tx_virtual); + static int xsk_zc_xmit(struct sock *sk) { struct xdp_sock *xs = xdp_sk(sk); From patchwork Wed Dec 19 01:04:52 2018 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: William Tu X-Patchwork-Id: 1015777 X-Patchwork-Delegate: bpf@iogearbox.net Return-Path: X-Original-To: patchwork-incoming-netdev@ozlabs.org Delivered-To: patchwork-incoming-netdev@ozlabs.org Authentication-Results: ozlabs.org; spf=none (mailfrom) smtp.mailfrom=vger.kernel.org (client-ip=209.132.180.67; helo=vger.kernel.org; envelope-from=netdev-owner@vger.kernel.org; receiver=) Authentication-Results: ozlabs.org; dmarc=pass (p=none dis=none) header.from=gmail.com Authentication-Results: ozlabs.org; dkim=pass (2048-bit key; unprotected) header.d=gmail.com header.i=@gmail.com header.b="ZMQ7F/fZ"; dkim-atps=neutral Received: from vger.kernel.org (vger.kernel.org [209.132.180.67]) by ozlabs.org (Postfix) with ESMTP id 43KGdm57p7z9s1c for ; Wed, 19 Dec 2018 11:55:24 +1100 (AEDT) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S1727280AbeLSAzQ (ORCPT ); Tue, 18 Dec 2018 19:55:16 -0500 Received: from mail-pg1-f194.google.com ([209.85.215.194]:44954 "EHLO mail-pg1-f194.google.com" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S1726629AbeLSAzP (ORCPT ); Tue, 18 Dec 2018 19:55:15 -0500 Received: by mail-pg1-f194.google.com with SMTP id t13so8608250pgr.11 for ; Tue, 18 Dec 2018 16:55:14 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=from:to:subject:date:message-id:in-reply-to:references; bh=5V7IDoU0URcB9RwjD6T7/u6eLbOjAJV4Qq04SrGOew0=; b=ZMQ7F/fZ3ANB3PEs8lyC44d/z75X0Lq8OKF4cLyi2nTiufmjLVajXqtZnIl0zHTzuV S1KIBoUmIziTLX8w8B3es1UoGtOxGDyxPbJchMkufWu5bkZwffgaNP5OawURJE4ZIXhj eH7Oc8VGFGS8iRaTjmVN6zwOiNa2+JmhhXLv9RS3iCpV4f8Y1M58AIXbYapCIo2sxiKE rvVaNkTSs/knoSBecTAQ7B2JWn2Z27m7tCZ/iKjrkLAkhuJfheUAbAfkuun4LaaZ5c6G AbVNftoW+i1SMSu9MorESkblnQA5lQ+InlZoyJc1mgKSCneExCB/h/tE0+tH2AkPFkyE WEkw== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:from:to:subject:date:message-id:in-reply-to :references; bh=5V7IDoU0URcB9RwjD6T7/u6eLbOjAJV4Qq04SrGOew0=; b=KVlaA4HdtaujPItK65RCxT+pSH7UAGC1mcG8xTwFlmImc1rhO/SlHQQ6NagQD/VHW/ dCBtmayUPjfNm32OLRL3P+AD15yabpxMmFqn9EQHHXHrBNkSjy0gdKyVKJq/eP8Mddmt O7SQXYIZSc8IkCjLSctND2sK8lrWwH1Jakci2janzkujjH88M/aJRS7PaWFl0zahBKFb 8zPUeAGKqJIBrNd4jX0vq7zzTVTn/NUGt5bOsf4Cg0JwBwifxGHVZoUjBd1+VpAy1ibe zhGt5/TAvsrAC0+fkE7t8Wf1U302buhU9v0Pjx4E6TJFHJ8jIT6qRIGqsite/2C3q098 /skA== X-Gm-Message-State: AA+aEWZGyb9kgXrEaWnHddKki7xYq0wP9gU1Lbdj8mUJfLQS8T3Xa7WL B5N6xsdHuQwLGr0voTD5SEA= X-Google-Smtp-Source: AFSGD/VQEBMn24hkdDwSPrQD9eakxdQVY0JIcxKAJD6Eq9x6l12hiOoBXfbqGcnuSxcLmSR4GBWw2A== X-Received: by 2002:a63:89c2:: with SMTP id v185mr16245357pgd.97.1545180914210; Tue, 18 Dec 2018 16:55:14 -0800 (PST) Received: from sc9-mailhost2.vmware.com ([66.170.99.1]) by smtp.gmail.com with ESMTPSA id c13sm38964804pfe.93.2018.12.18.16.55.13 (version=TLS1_2 cipher=ECDHE-RSA-AES128-SHA bits=128/128); Tue, 18 Dec 2018 16:55:13 -0800 (PST) From: William Tu To: bjorn.topel@gmail.com, magnus.karlsson@gmail.com, ast@kernel.org, daniel@iogearbox.net, netdev@vger.kernel.org, makita.toshiaki@lab.ntt.co.jp, yihung.wei@gmail.com Subject: [bpf-next RFCv2 2/3] veth: support AF_XDP. Date: Tue, 18 Dec 2018 17:04:52 -0800 Message-Id: <1545181493-8743-3-git-send-email-u9012063@gmail.com> X-Mailer: git-send-email 2.7.4 In-Reply-To: <1545181493-8743-1-git-send-email-u9012063@gmail.com> References: <1545181493-8743-1-git-send-email-u9012063@gmail.com> Sender: netdev-owner@vger.kernel.org Precedence: bulk List-ID: X-Mailing-List: netdev@vger.kernel.org The patch adds support for AF_XDP async xmit. Users can use AF_XDP on both side of the veth and get better performance, with the cost of ksoftirqd doing the xmit. The veth_xsk_async_xmit simply kicks the napi function, veth_poll, to run, and the transmit logic is implemented there. Tested using two namespaces, one runs xdpsock and the other runs xdp_rxq_info. A simple script comparing the performance with/without AF_XDP shows improvement from 724Kpps to 1.1Mpps. ip netns add at_ns0 ip link add p0 type veth peer name p1 ip link set p0 netns at_ns0 ip link set dev p1 up ip netns exec at_ns0 ip link set dev p0 up # receiver ip netns exec at_ns0 xdp_rxq_info --dev p0 --action XDP_DROP # sender xdpsock -i p1 -t -N -z or xdpsock -i p1 -t -S Signed-off-by: William Tu --- drivers/net/veth.c | 199 ++++++++++++++++++++++++++++++++++++++++++++++++++++- 1 file changed, 197 insertions(+), 2 deletions(-) diff --git a/drivers/net/veth.c b/drivers/net/veth.c index f412ea1cef18..0ce89820ce70 100644 --- a/drivers/net/veth.c +++ b/drivers/net/veth.c @@ -25,6 +25,10 @@ #include #include #include +#include +#include +#include +#include #define DRV_NAME "veth" #define DRV_VERSION "1.0" @@ -53,6 +57,8 @@ struct veth_rq { bool rx_notify_masked; struct ptr_ring xdp_ring; struct xdp_rxq_info xdp_rxq; + struct xdp_umem *xsk_umem; + u16 qid; }; struct veth_priv { @@ -737,15 +743,108 @@ static int veth_xdp_rcv(struct veth_rq *rq, int budget, unsigned int *xdp_xmit) return done; } +static int veth_xsk_send(struct napi_struct *napi, int budget) +{ + struct veth_rq *rq = + container_of(napi, struct veth_rq, xdp_napi); + int done = 0; + + /* tx: use netif_tx_napi_add? */ + while (rq->xsk_umem && budget--) { + struct veth_priv *priv, *peer_priv; + struct net_device *dev, *peer_dev; + unsigned int inner_xdp_xmit = 0; + unsigned int metasize = 0; + struct veth_rq *peer_rq; + struct xdp_frame *xdpf; + bool dropped = false; + struct sk_buff *skb; + struct page *page; + void *vaddr; + void *addr; + u32 len; + + if (!xsk_umem_consume_tx_virtual(rq->xsk_umem, &vaddr, &len)) + break; + + page = dev_alloc_page(); + if (!page) { + pr_warn("veth: page allocation fails\n"); + xsk_umem_complete_tx(rq->xsk_umem, 1); + xsk_umem_consume_tx_done(rq->xsk_umem); + return -ENOMEM; + } + + addr = page_to_virt(page); + xdpf = addr; + memset(xdpf, 0, sizeof(*xdpf)); + + addr += sizeof(*xdpf); + memcpy(addr, vaddr, len); + + xdpf->data = addr + metasize; + xdpf->len = len; + xdpf->headroom = 0; + xdpf->metasize = metasize; + xdpf->mem.type = MEM_TYPE_PAGE_SHARED; + + /* Invoke peer rq to rcv */ + dev = rq->dev; + priv = netdev_priv(dev); + peer_dev = priv->peer; + peer_priv = netdev_priv(peer_dev); + peer_rq = &peer_priv->rq[rq->qid]; + + /* put into peer rq */ + skb = veth_xdp_rcv_one(peer_rq, xdpf, &inner_xdp_xmit); + if (!skb) { + /* Peer side has XDP program attached */ + if (inner_xdp_xmit & VETH_XDP_TX) { + /* Not supported */ + pr_warn("veth: peer XDP_TX not supported\n"); + xdp_return_frame(xdpf); + dropped = true; + goto skip_tx; + } else if (inner_xdp_xmit & VETH_XDP_REDIR) { + xdp_do_flush_map(); + } else { + dropped = true; + } + } else { + /* Peer side has no XDP attached */ + napi_gro_receive(&peer_rq->xdp_napi, skb); + } +skip_tx: + xsk_umem_complete_tx(rq->xsk_umem, 1); + xsk_umem_consume_tx_done(rq->xsk_umem); + + /* update peer stats */ + u64_stats_update_begin(&peer_rq->stats.syncp); + peer_rq->stats.xdp_packets++; + peer_rq->stats.xdp_bytes += len; + if (dropped) + rq->stats.xdp_drops++; + u64_stats_update_end(&peer_rq->stats.syncp); + done++; + } + + return done; +} + static int veth_poll(struct napi_struct *napi, int budget) { struct veth_rq *rq = container_of(napi, struct veth_rq, xdp_napi); unsigned int xdp_xmit = 0; - int done; + int done = 0; + int tx_done; + + tx_done = veth_xsk_send(napi, budget); + if (tx_done > 0) + done += tx_done; xdp_set_return_frame_no_direct(); - done = veth_xdp_rcv(rq, budget, &xdp_xmit); + done += veth_xdp_rcv(rq, budget, &xdp_xmit); if (done < budget && napi_complete_done(napi, done)) { /* Write rx_notify_masked before reading ptr_ring */ @@ -776,6 +875,7 @@ static int veth_napi_add(struct net_device *dev) err = ptr_ring_init(&rq->xdp_ring, VETH_RING_SIZE, GFP_KERNEL); if (err) goto err_xdp_ring; + rq->qid = i; } for (i = 0; i < dev->real_num_rx_queues; i++) { @@ -812,6 +912,7 @@ static void veth_napi_del(struct net_device *dev) netif_napi_del(&rq->xdp_napi); rq->rx_notify_masked = false; ptr_ring_cleanup(&rq->xdp_ring, veth_ptr_free); + rq->qid = -1; } } @@ -836,6 +937,7 @@ static int veth_enable_xdp(struct net_device *dev) /* Save original mem info as it can be overwritten */ rq->xdp_mem = rq->xdp_rxq.mem; + rq->qid = i; } err = veth_napi_add(dev); @@ -1115,6 +1217,78 @@ static u32 veth_xdp_query(struct net_device *dev) return 0; } +int veth_xsk_umem_query(struct net_device *dev, struct xdp_umem **umem, + u16 qid) +{ + struct xdp_umem *queried_umem; + + queried_umem = xdp_get_umem_from_qid(dev, qid); + + if (!queried_umem) + return -EINVAL; + + *umem = queried_umem; + return 0; +} + +static int veth_xsk_umem_enable(struct net_device *dev, + struct xdp_umem *umem, + u16 qid) +{ + struct veth_priv *priv = netdev_priv(dev); + struct xdp_umem_fq_reuse *reuseq; + int err = 0; + + if (qid >= dev->real_num_rx_queues) + return -EINVAL; + + reuseq = xsk_reuseq_prepare(priv->rq[0].xdp_ring.size); + if (!reuseq) + return -ENOMEM; + + xsk_reuseq_free(xsk_reuseq_swap(umem, reuseq)); + + priv->rq[qid].xsk_umem = umem; + return err; +} + +static int veth_xsk_umem_disable(struct net_device *dev, + u16 qid) +{ + struct veth_priv *priv = netdev_priv(dev); + struct xdp_umem *umem; + + umem = xdp_get_umem_from_qid(dev, qid); + if (!umem) + return -EINVAL; + + priv->rq[qid].xsk_umem = NULL; + return 0; +} + +int veth_xsk_umem_setup(struct net_device *dev, struct xdp_umem *umem, + u16 qid) +{ + return umem ? veth_xsk_umem_enable(dev, umem, qid) : + veth_xsk_umem_disable(dev, qid); +} + +int veth_xsk_async_xmit(struct net_device *dev, u32 qid) +{ + struct veth_priv *priv = netdev_priv(dev); + struct veth_rq *rq; + + rq = &priv->rq[qid]; + + if (qid >= dev->real_num_rx_queues) + return -ENXIO; + + if (!napi_if_scheduled_mark_missed(&rq->xdp_napi)) + napi_schedule(&rq->xdp_napi); + + return 0; +} + static int veth_xdp(struct net_device *dev, struct netdev_bpf *xdp) { switch (xdp->command) { @@ -1123,6 +1297,26 @@ static int veth_xdp(struct net_device *dev, struct netdev_bpf *xdp) case XDP_QUERY_PROG: xdp->prog_id = veth_xdp_query(dev); return 0; + case XDP_QUERY_XSK_UMEM: + return veth_xsk_umem_query(dev, &xdp->xsk.umem, + xdp->xsk.queue_id); + case XDP_SETUP_XSK_UMEM: { + struct veth_priv *priv; + int err; + + /* Enable XDP on both sides */ + err = veth_enable_xdp(dev); + if (err) + return err; + + priv = netdev_priv(dev); + err = veth_enable_xdp(priv->peer); + if (err) + return err; + + return veth_xsk_umem_setup(dev, xdp->xsk.umem, + xdp->xsk.queue_id); + } default: return -EINVAL; } @@ -1145,6 +1339,7 @@ static const struct net_device_ops veth_netdev_ops = { .ndo_set_rx_headroom = veth_set_rx_headroom, .ndo_bpf = veth_xdp, .ndo_xdp_xmit = veth_xdp_xmit, + .ndo_xsk_async_xmit = veth_xsk_async_xmit, }; #define VETH_FEATURES (NETIF_F_SG | NETIF_F_FRAGLIST | NETIF_F_HW_CSUM | \ From patchwork Wed Dec 19 01:04:53 2018 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: William Tu X-Patchwork-Id: 1015778 X-Patchwork-Delegate: bpf@iogearbox.net Return-Path: X-Original-To: patchwork-incoming-netdev@ozlabs.org Delivered-To: patchwork-incoming-netdev@ozlabs.org Authentication-Results: ozlabs.org; spf=none (mailfrom) smtp.mailfrom=vger.kernel.org (client-ip=209.132.180.67; helo=vger.kernel.org; envelope-from=netdev-owner@vger.kernel.org; receiver=) Authentication-Results: ozlabs.org; dmarc=pass (p=none dis=none) header.from=gmail.com Authentication-Results: ozlabs.org; dkim=pass (2048-bit key; unprotected) header.d=gmail.com header.i=@gmail.com header.b="EAe2osi7"; dkim-atps=neutral Received: from vger.kernel.org (vger.kernel.org [209.132.180.67]) by ozlabs.org (Postfix) with ESMTP id 43KGdn4VvFz9s3Z for ; Wed, 19 Dec 2018 11:55:25 +1100 (AEDT) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S1727541AbeLSAzR (ORCPT ); Tue, 18 Dec 2018 19:55:17 -0500 Received: from mail-pg1-f181.google.com ([209.85.215.181]:40634 "EHLO mail-pg1-f181.google.com" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S1726629AbeLSAzQ (ORCPT ); Tue, 18 Dec 2018 19:55:16 -0500 Received: by mail-pg1-f181.google.com with SMTP id z10so8618488pgp.7 for ; Tue, 18 Dec 2018 16:55:15 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=from:to:subject:date:message-id:in-reply-to:references; bh=IL1HdoG7f7b4Z+/dVhvpoRhu3cmc1w9Xu0Sqvt8ovTw=; b=EAe2osi7LstIwRy3q5hSb6CrmpytVdiw2Cjg+B4ViXqmSMe0UT77O01ANU9TU6iXUQ F8hP3+hgqajIK/dlLSnxW7uRR76W4ef5FUBUsHPpNmuFgyRILYzoI89hW9F2NKh7ZGDy M547nvcALCB+qXPUMVGFDdVluav6dqplX+iU87eAYhzI2nIQoWi2dBDESYl7gHWC8xzN up2RLE6ZXor5jt75ni4r9vTu+ylo8/KwmjjoHmXsKXWPail5lSkyqBPgC2sUeH+Wke8N eGZDe5gfh55mStR/rGvSGcwq3gT1HiNbQ8bCGdh2W/0j0LOdPrAyHbLs9+suI3tV6euV jDQg== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:from:to:subject:date:message-id:in-reply-to :references; bh=IL1HdoG7f7b4Z+/dVhvpoRhu3cmc1w9Xu0Sqvt8ovTw=; b=Gym7Xh8pkhQWhO0JIuYHQKuxKIu/dO+Y+rAHt8WMFTkQzmvERADJ8eUBvgoYMZr+ER Hcqs515g6xv/EojSJqulM1xL1xHMsfMFhkuJoePI/67Tdg7nhEIgqxRFq7QJwf4jP8qj HrZH/mlDPQrCpu5U/yODrPUHGxBKo/b1+wFIRtBKTYFc3bDsefa3WFV7XBPUHhQ5GVh0 8XBjp7CaUaWq/2ypa3avBmemhjB0FingzL8HK5Bwt2fxxhdirJ79LJUWbEmTVpe+Hl10 XFVt1+6M32Za0RzjdcfrwupLOhHGqYqr9mv21pFbNab88AK1SM7a1cmaKBh2zbUQLuk3 Ingg== X-Gm-Message-State: AA+aEWag1ihE49qf4chvuIAq1cuex5TRSkzOg57DECAWSePN4P+BW0Sp rIDhjBnI9zzo4nhGQA1RVVM= X-Google-Smtp-Source: AFSGD/UvYXRCch1m3Fdu7p+iUDte7VFgFF0C+qytM+vX2OW6OeFNi8xHvRR8rSeNhnqNE+XtKi1NIg== X-Received: by 2002:a63:981:: with SMTP id 123mr1187492pgj.444.1545180915204; Tue, 18 Dec 2018 16:55:15 -0800 (PST) Received: from sc9-mailhost2.vmware.com ([66.170.99.1]) by smtp.gmail.com with ESMTPSA id c13sm38964804pfe.93.2018.12.18.16.55.14 (version=TLS1_2 cipher=ECDHE-RSA-AES128-SHA bits=128/128); Tue, 18 Dec 2018 16:55:14 -0800 (PST) From: William Tu To: bjorn.topel@gmail.com, magnus.karlsson@gmail.com, ast@kernel.org, daniel@iogearbox.net, netdev@vger.kernel.org, makita.toshiaki@lab.ntt.co.jp, yihung.wei@gmail.com Subject: [bpf-next RFCv2 3/3] samples: bpf: add veth AF_XDP example. Date: Tue, 18 Dec 2018 17:04:53 -0800 Message-Id: <1545181493-8743-4-git-send-email-u9012063@gmail.com> X-Mailer: git-send-email 2.7.4 In-Reply-To: <1545181493-8743-1-git-send-email-u9012063@gmail.com> References: <1545181493-8743-1-git-send-email-u9012063@gmail.com> Sender: netdev-owner@vger.kernel.org Precedence: bulk List-ID: X-Mailing-List: netdev@vger.kernel.org Add example use cases for AF_XDP socket on two namespaces. The script runs sender at the root namespace, and receiver at the at_ns0 namespace with different XDP actions. Signed-off-by: William Tu --- samples/bpf/test_veth_afxdp.sh | 67 ++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 67 insertions(+) create mode 100755 samples/bpf/test_veth_afxdp.sh diff --git a/samples/bpf/test_veth_afxdp.sh b/samples/bpf/test_veth_afxdp.sh new file mode 100755 index 000000000000..b65311cf15f7 --- /dev/null +++ b/samples/bpf/test_veth_afxdp.sh @@ -0,0 +1,67 @@ +#!/bin/bash +# SPDX-License-Identifier: GPL-2.0 + +# The script runs the sender at the root namespace, and +# the receiver at the namespace at_ns0, with different mode +# 1. XDP_DROP +# 2. XDP_TX +# 3. XDP_PASS +# 4. XDP_REDIRECT +# 5. Generic XDP + +XDPSOCK=./xdpsock +XDP_RXQ_INFO=./xdp_rxq_info + +ip netns add at_ns0 +ip link add p0 type veth peer name p1 +ip link set p0 netns at_ns0 +ip link set dev p1 up +ip netns exec at_ns0 ip link set dev p0 up + +# send at root namespace +test_xdp_drop() +{ + echo "[Peer] XDP_DROP" + ip netns exec at_ns0 $XDP_RXQ_INFO --dev p0 --action XDP_DROP & + $XDPSOCK -i p1 -t -N -z &> /tmp/t &> /dev/null & +} + +test_xdp_pass() +{ + echo "[Peer] XDP_PASS" + ip netns exec at_ns0 $XDP_RXQ_INFO --dev p0 --action XDP_PASS & + $XDPSOCK -i p1 -t -N -z &> /tmp/t &> /dev/null & +} + +test_xdp_tx() +{ + echo "[Peer] XDP_TX" + ip netns exec at_ns0 $XDP_RXQ_INFO --dev p0 --action XDP_TX & + $XDPSOCK -i p1 -t -N -z &> /tmp/t &> /dev/null & +} + +test_generic_xdp() +{ + echo "[Peer] Generic XDP" + ip netns exec at_ns0 $XDPSOCK -i p0 -r -S & + $XDPSOCK -i p1 -t -N -z &> /tmp/t &> /dev/null & +} + +test_xdp_redirect() +{ + echo "[Peer] XDP_REDIRECT" + ip netns exec at_ns0 $XDPSOCK -i p0 -r -N & + $XDPSOCK -i p1 -t -N -z &> /tmp/t &> /dev/null & +} + +cleanup() { + killall xdpsock + killall xdp_rxq_info + ip netns del at_ns0 + ip link del p1 +} + +trap cleanup 0 3 6 + +test_xdp_drop +cleanup