From patchwork Fri Feb 26 08:51:02 2016 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: Santosh Shukla X-Patchwork-Id: 10867 Return-Path: X-Original-To: patchwork@dpdk.org Delivered-To: patchwork@dpdk.org Received: from [92.243.14.124] (localhost [IPv6:::1]) by dpdk.org (Postfix) with ESMTP id 2689F2C4B; Fri, 26 Feb 2016 09:51:25 +0100 (CET) Received: from mail-pf0-f174.google.com (mail-pf0-f174.google.com [209.85.192.174]) by dpdk.org (Postfix) with ESMTP id 996622C49 for ; Fri, 26 Feb 2016 09:51:23 +0100 (CET) Received: by mail-pf0-f174.google.com with SMTP id q63so48756442pfb.0 for ; Fri, 26 Feb 2016 00:51:23 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=mvista-com.20150623.gappssmtp.com; s=20150623; h=from:to:cc:subject:date:message-id; bh=BFRW/PzZ/y6yCpfRb4qb5O6aX6CFH/A05mDfGUNKgIk=; b=UrSnOuUyJ+zNfBoPUr6UprbpITTJKBImmIMBD43FldWHUr194dhvwSkq7Q8HBYc43v LZOVX5SHV4pqhsB8sZB60WyrJ45EUdlfnmP5lp+H7vNMUDVzLZQYm/E4wVZbDs66IEjP BxWolermAOE65CsUvXVyazf98gjYYo9dydW5QA5nhga/vK8myRCBiWQZBaUt4Zei0h7T Q8X4tJ8E1218iTzDOTw/rSveJbVcsGDvaxWYSBj3VHj7vPRRmRGtnDDS5jj/YyCZKXQo ToQ+Wfn51ICQ9ondPBETnDP9HmPB6LtrYNur5TDOBNnsTGmdYkNZVATZ+UkBnjDYvhgy Z8uw== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:from:to:cc:subject:date:message-id; bh=BFRW/PzZ/y6yCpfRb4qb5O6aX6CFH/A05mDfGUNKgIk=; b=MT90fFy1Ur42S5Z5BXVP6H73oW3GNhwe39NcKtlg388cOMv+m5L42Nv1M5r1n7DZHc fbqkSL1phAbmmksXfN6CDHvCNGOUNDI6wSbghqsw+RRNnQlwyrTW4TlkWc3a4Sbzn6O+ XhGxqd3UodSaRl9RpXJ2X4ej2DXaHN0RQm+ucdAmJNiAvfYQ46NanwHoZIiZBEtduq0q Et84BJw/3QEMsOJNMscjd4ctd60IWvoFeRVj8AKCJd6gugsFCT+oh65cvm0qM36R4h0U MuH29JeUrDXVxjHwzks83Bx1otkj5UOZH0zo34iSAtKPJDxQihOO66Uq7YqGRkF/8Im1 AFrQ== X-Gm-Message-State: AD7BkJJXSDJs8URmE0mQ+jIKvIORa6z0HF8y416I55LRkh8BWPZlkHWwY5BP6AOMZqHAyDb3 X-Received: by 10.98.66.81 with SMTP id p78mr458414pfa.43.1456476683027; Fri, 26 Feb 2016 00:51:23 -0800 (PST) Received: from santosh-Latitude-E5530-non-vPro.mvista.com ([106.194.52.14]) by smtp.gmail.com with ESMTPSA id n68sm17542546pfj.46.2016.02.26.00.51.19 (version=TLS1_1 cipher=ECDHE-RSA-AES128-SHA bits=128/128); Fri, 26 Feb 2016 00:51:21 -0800 (PST) From: Santosh Shukla To: dev@dpdk.org Date: Fri, 26 Feb 2016 14:21:02 +0530 Message-Id: <1456476662-23081-1-git-send-email-sshukla@mvista.com> X-Mailer: git-send-email 1.7.9.5 Subject: [dpdk-dev] [PATCH v1] virtio: Use cpuflag for vector api X-BeenThere: dev@dpdk.org X-Mailman-Version: 2.1.15 Precedence: list List-Id: patches and discussions about DPDK List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Errors-To: dev-bounces@dpdk.org Sender: "dev" Check cpuflag macro before using vectored api. -virtio_recv_pkts_vec() uses _sse3__ simd instruction for now so added cpuflag. - Also wrap other vectored freind api ie.. 1) virtqueue_enqueue_recv_refill_simple 2) virtio_rxq_vec_setup todo: 1) Move virtio_recv_pkts_vec() implementation to drivers/virtio/virtio_vec_.h file. 2) Remove use_simple_rxtx flag, so that virtio/virtio_vec_.h files to provide vectored/non-vectored rx/tx apis. Signed-off-by: Santosh Shukla --- - v1: This is a rework of patch [1]. Note: This patch will let non-x86 arch to use virtio pmd. [1] http://dpdk.org/dev/patchwork/patch/10429/ drivers/net/virtio/virtio_rxtx.c | 16 +++++++++++++++- drivers/net/virtio/virtio_rxtx.h | 2 ++ drivers/net/virtio/virtio_rxtx_simple.c | 11 ++++++++++- 3 files changed, 27 insertions(+), 2 deletions(-) diff --git a/drivers/net/virtio/virtio_rxtx.c b/drivers/net/virtio/virtio_rxtx.c index 41a1366..ec0b8de 100644 --- a/drivers/net/virtio/virtio_rxtx.c +++ b/drivers/net/virtio/virtio_rxtx.c @@ -67,7 +67,9 @@ #define VIRTIO_SIMPLE_FLAGS ((uint32_t)ETH_TXQ_FLAGS_NOMULTSEGS | \ ETH_TXQ_FLAGS_NOOFFLOADS) +#ifdef RTE_MACHINE_CPUFLAG_SSSE3 static int use_simple_rxtx; +#endif static void vq_ring_free_chain(struct virtqueue *vq, uint16_t desc_idx) @@ -307,12 +309,13 @@ virtio_dev_vring_start(struct virtqueue *vq, int queue_type) nbufs = 0; error = ENOSPC; +#ifdef RTE_MACHINE_CPUFLAG_SSSE3 if (use_simple_rxtx) for (i = 0; i < vq->vq_nentries; i++) { vq->vq_ring.avail->ring[i] = i; vq->vq_ring.desc[i].flags = VRING_DESC_F_WRITE; } - +#endif memset(&vq->fake_mbuf, 0, sizeof(vq->fake_mbuf)); for (i = 0; i < RTE_PMD_VIRTIO_RX_MAX_BURST; i++) vq->sw_ring[vq->vq_nentries + i] = &vq->fake_mbuf; @@ -325,9 +328,11 @@ virtio_dev_vring_start(struct virtqueue *vq, int queue_type) /****************************************** * Enqueue allocated buffers * *******************************************/ +#ifdef RTE_MACHINE_CPUFLAG_SSSE3 if (use_simple_rxtx) error = virtqueue_enqueue_recv_refill_simple(vq, m); else +#endif error = virtqueue_enqueue_recv_refill(vq, m); if (error) { rte_pktmbuf_free(m); @@ -340,6 +345,7 @@ virtio_dev_vring_start(struct virtqueue *vq, int queue_type) PMD_INIT_LOG(DEBUG, "Allocated %d bufs", nbufs); } else if (queue_type == VTNET_TQ) { +#ifdef RTE_MACHINE_CPUFLAG_SSSE3 if (use_simple_rxtx) { int mid_idx = vq->vq_nentries >> 1; for (i = 0; i < mid_idx; i++) { @@ -357,6 +363,7 @@ virtio_dev_vring_start(struct virtqueue *vq, int queue_type) for (i = mid_idx; i < vq->vq_nentries; i++) vq->vq_ring.avail->ring[i] = i; } +#endif } } @@ -423,7 +430,9 @@ virtio_dev_rx_queue_setup(struct rte_eth_dev *dev, dev->data->rx_queues[queue_idx] = vq; +#ifdef RTE_MACHINE_CPUFLAG_SSSE3 virtio_rxq_vec_setup(vq); +#endif return 0; } @@ -449,7 +458,10 @@ virtio_dev_tx_queue_setup(struct rte_eth_dev *dev, const struct rte_eth_txconf *tx_conf) { uint8_t vtpci_queue_idx = 2 * queue_idx + VTNET_SQ_TQ_QUEUE_IDX; + +#ifdef RTE_MACHINE_CPUFLAG_SSSE3 struct virtio_hw *hw = dev->data->dev_private; +#endif struct virtqueue *vq; uint16_t tx_free_thresh; int ret; @@ -462,6 +474,7 @@ virtio_dev_tx_queue_setup(struct rte_eth_dev *dev, return -EINVAL; } +#ifdef RTE_MACHINE_CPUFLAG_SSSE3 /* Use simple rx/tx func if single segment and no offloads */ if ((tx_conf->txq_flags & VIRTIO_SIMPLE_FLAGS) == VIRTIO_SIMPLE_FLAGS && !vtpci_with_feature(hw, VIRTIO_NET_F_MRG_RXBUF)) { @@ -470,6 +483,7 @@ virtio_dev_tx_queue_setup(struct rte_eth_dev *dev, dev->rx_pkt_burst = virtio_recv_pkts_vec; use_simple_rxtx = 1; } +#endif ret = virtio_dev_queue_setup(dev, VTNET_TQ, queue_idx, vtpci_queue_idx, nb_desc, socket_id, &vq); diff --git a/drivers/net/virtio/virtio_rxtx.h b/drivers/net/virtio/virtio_rxtx.h index 831e492..a76c3e5 100644 --- a/drivers/net/virtio/virtio_rxtx.h +++ b/drivers/net/virtio/virtio_rxtx.h @@ -33,7 +33,9 @@ #define RTE_PMD_VIRTIO_RX_MAX_BURST 64 +#ifdef RTE_MACHINE_CPUFLAG_SSSE3 int virtio_rxq_vec_setup(struct virtqueue *rxq); int virtqueue_enqueue_recv_refill_simple(struct virtqueue *vq, struct rte_mbuf *m); +#endif diff --git a/drivers/net/virtio/virtio_rxtx_simple.c b/drivers/net/virtio/virtio_rxtx_simple.c index 3a1de9d..be51d7c 100644 --- a/drivers/net/virtio/virtio_rxtx_simple.c +++ b/drivers/net/virtio/virtio_rxtx_simple.c @@ -37,7 +37,9 @@ #include #include -#include +#ifdef __SSE3__ +#include +#endif #include #include @@ -66,6 +68,7 @@ #pragma GCC diagnostic ignored "-Wcast-qual" #endif +#ifdef RTE_MACHINE_CPUFLAG_SSSE3 int __attribute__((cold)) virtqueue_enqueue_recv_refill_simple(struct virtqueue *vq, struct rte_mbuf *cookie) @@ -90,6 +93,7 @@ virtqueue_enqueue_recv_refill_simple(struct virtqueue *vq, return 0; } +#endif static inline void virtio_rxq_rearm_vec(struct virtqueue *rxvq) @@ -130,6 +134,7 @@ virtio_rxq_rearm_vec(struct virtqueue *rxvq) vq_update_avail_idx(rxvq); } +#ifdef RTE_MACHINE_CPUFLAG_SSSE3 /* virtio vPMD receive routine, only accept(nb_pkts >= RTE_VIRTIO_DESC_PER_LOOP) * * This routine is for non-mergeable RX, one desc for each guest buffer. @@ -291,6 +296,7 @@ virtio_recv_pkts_vec(void *rx_queue, struct rte_mbuf **rx_pkts, rxvq->packets += nb_pkts_received; return nb_pkts_received; } +#endif #define VIRTIO_TX_FREE_THRESH 32 #define VIRTIO_TX_MAX_FREE_BUF_SZ 32 @@ -398,6 +404,7 @@ virtio_xmit_pkts_simple(void *tx_queue, struct rte_mbuf **tx_pkts, return nb_pkts; } +#ifdef RTE_MACHINE_CPUFLAG_SSSE3 int __attribute__((cold)) virtio_rxq_vec_setup(struct virtqueue *rxq) { @@ -416,3 +423,5 @@ virtio_rxq_vec_setup(struct virtqueue *rxq) return 0; } +#endif +