From patchwork Fri Nov 11 13:07:15 2011 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: Krishna Kumar X-Patchwork-Id: 125172 X-Patchwork-Delegate: davem@davemloft.net Return-Path: X-Original-To: patchwork-incoming@ozlabs.org Delivered-To: patchwork-incoming@ozlabs.org Received: from vger.kernel.org (vger.kernel.org [209.132.180.67]) by ozlabs.org (Postfix) with ESMTP id DA4C41007D4 for ; Sat, 12 Nov 2011 00:54:52 +1100 (EST) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S1752220Ab1KKNyt (ORCPT ); Fri, 11 Nov 2011 08:54:49 -0500 Received: from e28smtp05.in.ibm.com ([122.248.162.5]:51202 "EHLO e28smtp05.in.ibm.com" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S1751676Ab1KKNys (ORCPT ); Fri, 11 Nov 2011 08:54:48 -0500 Received: from /spool/local by e28smtp05.in.ibm.com with IBM ESMTP SMTP Gateway: Authorized Use Only! Violators will be prosecuted for from ; Fri, 11 Nov 2011 18:42:06 +0530 Received: from d28relay03.in.ibm.com ([9.184.220.60]) by e28smtp05.in.ibm.com ([192.168.1.135]) with IBM ESMTP SMTP Gateway: Authorized Use Only! Violators will be prosecuted; Fri, 11 Nov 2011 18:40:30 +0530 Received: from d28av01.in.ibm.com (d28av01.in.ibm.com [9.184.220.63]) by d28relay03.in.ibm.com (8.13.8/8.13.8/NCO v10.0) with ESMTP id pABD85On4272206; Fri, 11 Nov 2011 18:38:05 +0530 Received: from d28av01.in.ibm.com (loopback [127.0.0.1]) by d28av01.in.ibm.com (8.14.4/8.13.1/NCO v10.0 AVout) with ESMTP id pABD84rN015566; Fri, 11 Nov 2011 18:38:05 +0530 Received: from krkumar2.in.ibm.com ([9.124.214.183]) by d28av01.in.ibm.com (8.14.4/8.13.1/NCO v10.0 AVin) with ESMTP id pABD847a012978; Fri, 11 Nov 2011 18:38:04 +0530 From: Krishna Kumar To: rusty@rustcorp.com.au, mst@redhat.com Cc: netdev@vger.kernel.org, kvm@vger.kernel.org, davem@davemloft.net, Krishna Kumar , virtualization@lists.linux-foundation.org Date: Fri, 11 Nov 2011 18:37:15 +0530 Message-Id: <20111111130715.9878.31409.sendpatchset@krkumar2.in.ibm.com> In-Reply-To: <20111111130223.9878.59517.sendpatchset@krkumar2.in.ibm.com> References: <20111111130223.9878.59517.sendpatchset@krkumar2.in.ibm.com> Subject: [RFC] [ver3 PATCH 6/6] virtio_net: Convert virtio_net driver to use find_vqs_irq x-cbid: 11111113-8256-0000-0000-0000001C34D9 Sender: netdev-owner@vger.kernel.org Precedence: bulk List-ID: X-Mailing-List: netdev@vger.kernel.org Convert virtio_net driver to use find_vqs_irq(). The TX vq's share a single irq, while the RX vq's have individual irq's. The skb_xmit_done handler also checks if any work is required. Signed-off-by: krkumar2@in.ibm.com --- drivers/net/virtio_net.c | 29 ++++++++++++++++++++++------- 1 file changed, 22 insertions(+), 7 deletions(-) -- To unsubscribe from this list: send the line "unsubscribe netdev" in the body of a message to majordomo@vger.kernel.org More majordomo info at http://vger.kernel.org/majordomo-info.html diff -ruNp org/drivers/net/virtio_net.c new/drivers/net/virtio_net.c --- org/drivers/net/virtio_net.c 2011-11-11 16:45:17.000000000 +0530 +++ new/drivers/net/virtio_net.c 2011-11-11 16:48:45.000000000 +0530 @@ -163,11 +163,13 @@ static void skb_xmit_done(struct virtque struct virtnet_info *vi = vq->vdev->priv; int qnum = vq->queue_index / 2; /* RX/TX vqs are allocated in pairs */ - /* Suppress further interrupts. */ - virtqueue_disable_cb(vq); + if (__netif_subqueue_stopped(vi->dev, qnum)) { + /* Suppress further interrupts. */ + virtqueue_disable_cb(vq); - /* We were probably waiting for more output buffers. */ - netif_wake_subqueue(vi->dev, qnum); + /* We were probably waiting for more output buffers. */ + netif_wake_subqueue(vi->dev, qnum); + } } static void set_skb_frag(struct sk_buff *skb, struct page *page, @@ -1120,6 +1122,7 @@ static void setup_cvq(struct virtnet_inf static int invoke_find_vqs(struct virtnet_info *vi) { + unsigned long *flags = NULL; vq_callback_t **callbacks; struct virtqueue **vqs; int ret = -ENOMEM; @@ -1141,6 +1144,14 @@ static int invoke_find_vqs(struct virtne if (!vqs || !callbacks || !names) goto err; + if (vi->num_queue_pairs > 1) { + int num = (total_vqs + BITS_PER_LONG - 1) / BITS_PER_LONG; + + flags = kzalloc(num * sizeof(*flags), GFP_KERNEL); + if (!flags) + goto err; + } + /* Allocate/initialize parameters for recv virtqueues */ for (i = 0; i < vi->num_queue_pairs * 2; i += 2) { callbacks[i] = skb_recv_done; @@ -1155,6 +1166,8 @@ static int invoke_find_vqs(struct virtne names[i] = kasprintf(GFP_KERNEL, "output.%d", i / 2); if (!names[i]) goto err; + if (flags) + set_bit(i, flags); } /* Parameters for control virtqueue, if any */ @@ -1163,9 +1176,9 @@ static int invoke_find_vqs(struct virtne names[i - 1] = "control"; } - ret = vi->vdev->config->find_vqs(vi->vdev, total_vqs, vqs, callbacks, - (const char **)names); - + ret = vi->vdev->config->find_vqs_irq(vi->vdev, total_vqs, vqs, + callbacks, (const char **)names, + flags); if (ret) goto err; @@ -1174,6 +1187,8 @@ static int invoke_find_vqs(struct virtne setup_cvq(vi, vqs, vi->num_queue_pairs * 2); err: + kfree(flags); + if (ret && names) for (i = 0; i < vi->num_queue_pairs * 2; i++) kfree(names[i]);