lists.openwall.net   lists  /  announce  owl-users  owl-dev  john-users  john-dev  passwdqc-users  yescrypt  popa3d-users  /  oss-security  kernel-hardening  musl  sabotage  tlsify  passwords  /  crypt-dev  xvendor  /  Bugtraq  Full-Disclosure  linux-kernel  linux-netdev  linux-ext4  linux-hardening  linux-cve-announce  PHC 
Open Source and information security mailing list archives
 
Hash Suite: Windows password security audit tool. GUI, reports in PDF.
[<prev] [next>] [<thread-prev] [thread-next>] [day] [month] [year] [list]
Message-ID: <20150519153558.GE26335@zion.uk.xensource.com>
Date:	Tue, 19 May 2015 16:35:58 +0100
From:	Wei Liu <wei.liu2@...rix.com>
To:	Joao Martins <joao.martins@...lab.eu>
CC:	<xen-devel@...ts.xenproject.org>, <netdev@...r.kernel.org>,
	<wei.liu2@...rix.com>, <ian.campbell@...rix.com>,
	<david.vrabel@...rix.com>, <boris.ostrovsky@...cle.com>,
	<konrad.wilk@...cle.com>
Subject: Re: [RFC PATCH 06/13] xen-netback: copy buffer on xenvif_start_xmit()

On Tue, May 12, 2015 at 07:18:30PM +0200, Joao Martins wrote:
> By introducing persistent grants we speed up the RX thread with the
> decreased copy cost, that leads to a throughput decrease of 20%.
> It is observed that the rx_queue stays mostly at 10% of its capacity,
> as opposed to full capacity when using grant copy. And a finer measure
> with lock_stat (below with pkt_size 64, burst 1) shows much higher wait
> queue contention on queue->wq, which hints that the RX kthread is
> waits/wake_up more often, that is actually doing work.
> 
> Without persistent grants:
> 
> class name    con-bounces    contentions   waittime-min   waittime-max
> waittime-total   waittime-avg    acq-bounces   acquisitions   holdtime-min
> holdtime-max holdtime-total   holdtime-avg
> --------------------------------------------------------------------------
> &queue->wq:   792            792           0.36          24.36
> 1140.30           1.44           4208        1002671           0.00
> 46.75      538164.02           0.54
> ----------
> &queue->wq    326          [<ffffffff8115949f>] __wake_up+0x2f/0x80
> &queue->wq    410          [<ffffffff811592bf>] finish_wait+0x4f/0xa0
> &queue->wq     56          [<ffffffff811593eb>] prepare_to_wait+0x2b/0xb0
> ----------
> &queue->wq    202          [<ffffffff811593eb>] prepare_to_wait+0x2b/0xb0
> &queue->wq    467          [<ffffffff8115949f>] __wake_up+0x2f/0x80
> &queue->wq    123          [<ffffffff811592bf>] finish_wait+0x4f/0xa0
> 
> With persistent grants:
> 
> &queue->wq:   61834          61836           0.32          30.12
> 99710.27           1.61         241400        1125308           0.00
> 75.61     1106578.82           0.98
> ----------
> &queue->wq     5079        [<ffffffff8115949f>] __wake_up+0x2f/0x80
> &queue->wq    56280        [<ffffffff811592bf>] finish_wait+0x4f/0xa0
> &queue->wq      479        [<ffffffff811593eb>] prepare_to_wait+0x2b/0xb0
> ----------
> &queue->wq     1005        [<ffffffff811592bf>] finish_wait+0x4f/0xa0
> &queue->wq    56761        [<ffffffff8115949f>] __wake_up+0x2f/0x80
> &queue->wq     4072        [<ffffffff811593eb>] prepare_to_wait+0x2b/0xb0
> 
> Also, with persistent grants, we don't require batching grant copy ops
> (besides the initial copy+map) which makes me believe that deferring
> the skb to the RX kthread just adds up unnecessary overhead (for this
> particular case). This patch proposes copying the buffer on
> xenvif_start_xmit(), which lets us both remove the contention on
> queue->wq and lock on rx_queue. Here, an alternative to
> xenvif_rx_action routine is added namely xenvif_rx_map() that maps
> and copies the buffer to the guest. This is only used when persistent
> grants are used, since it would otherwise mean an hypercall per
> packet.
> 
> Improvements are up to a factor of 2.14 with a single queue getting us
> from 1.04 Mpps to 1.7 Mpps (burst 1, pkt_size 64) and 1.5 to 2.6 Mpps
> (burst 2, pkt_size 64) compared to using the kthread. Maximum with grant
> copy is 1.2 Mpps, irrespective of the burst. All of this, measured on
> an Intel(R) Xeon(R) CPU E5-1650 v2 @ 3.50GHz.
> 
> Signed-off-by: Joao Martins <joao.martins@...lab.eu>
> ---
>  drivers/net/xen-netback/common.h    |  2 ++
>  drivers/net/xen-netback/interface.c | 11 +++++---
>  drivers/net/xen-netback/netback.c   | 52 +++++++++++++++++++++++++++++--------
>  3 files changed, 51 insertions(+), 14 deletions(-)
> 
> diff --git a/drivers/net/xen-netback/common.h b/drivers/net/xen-netback/common.h
> index 23deb6a..f3ece12 100644
> --- a/drivers/net/xen-netback/common.h
> +++ b/drivers/net/xen-netback/common.h
> @@ -363,6 +363,8 @@ void xenvif_kick_thread(struct xenvif_queue *queue);
>  
>  int xenvif_dealloc_kthread(void *data);
>  
> +int xenvif_rx_map(struct xenvif_queue *queue, struct sk_buff *skb);
> +
>  void xenvif_rx_queue_tail(struct xenvif_queue *queue, struct sk_buff *skb);
>  
>  /* Determine whether the needed number of slots (req) are available,
> diff --git a/drivers/net/xen-netback/interface.c b/drivers/net/xen-netback/interface.c
> index 1103568..dfe2b7b 100644
> --- a/drivers/net/xen-netback/interface.c
> +++ b/drivers/net/xen-netback/interface.c
> @@ -109,7 +109,8 @@ static irqreturn_t xenvif_rx_interrupt(int irq, void *dev_id)
>  {
>  	struct xenvif_queue *queue = dev_id;
>  
> -	xenvif_kick_thread(queue);
> +	if (!queue->vif->persistent_grants)
> +		xenvif_kick_thread(queue);
>  
>  	return IRQ_HANDLED;
>  }
> @@ -168,8 +169,12 @@ static int xenvif_start_xmit(struct sk_buff *skb, struct net_device *dev)
>  	cb = XENVIF_RX_CB(skb);
>  	cb->expires = jiffies + vif->drain_timeout;
>  
> -	xenvif_rx_queue_tail(queue, skb);
> -	xenvif_kick_thread(queue);
> +	if (!queue->vif->persistent_grants) {
> +		xenvif_rx_queue_tail(queue, skb);
> +		xenvif_kick_thread(queue);
> +	} else if (xenvif_rx_map(queue, skb)) {
> +		return NETDEV_TX_BUSY;
> +	}
>  

We now have two different functions for guest RX, one is xenvif_rx_map,
the other is xenvif_rx_action. They look very similar. Can we only have
one?

>  	return NETDEV_TX_OK;
>  
> diff --git a/drivers/net/xen-netback/netback.c b/drivers/net/xen-netback/netback.c
> index c4f57d7..228df92 100644
> --- a/drivers/net/xen-netback/netback.c
> +++ b/drivers/net/xen-netback/netback.c
> @@ -883,9 +883,48 @@ static bool xenvif_rx_submit(struct xenvif_queue *queue,
>  	return !!ret;
>  }
>  
> +int xenvif_rx_map(struct xenvif_queue *queue, struct sk_buff *skb)
> +{
> +	int ret = -EBUSY;
> +	struct netrx_pending_operations npo = {
> +		.copy  = queue->grant_copy_op,
> +		.meta  = queue->meta
> +	};
> +
> +	if (!xenvif_rx_ring_slots_available(queue, XEN_NETBK_LEGACY_SLOTS_MAX))

I think you meant XEN_NETBK_RX_SLOTS_MAX?

> +		goto done;
> +
> +	xenvif_rx_build_gops(queue, &npo, skb);
> +
> +	BUG_ON(npo.meta_prod > ARRAY_SIZE(queue->meta));
> +	if (!npo.copy_done && !npo.copy_prod)
> +		goto done;
> +
> +	BUG_ON(npo.map_prod > MAX_GRANT_COPY_OPS);
> +	if (npo.map_prod) {
> +		ret = gnttab_map_refs(queue->rx_map_ops,
> +				      NULL,
> +				      queue->rx_pages_to_map,
> +				      npo.map_prod);
> +		BUG_ON(ret);
> +	}
> +
> +	BUG_ON(npo.copy_prod > MAX_GRANT_COPY_OPS);
> +	if (npo.copy_prod)
> +		gnttab_batch_copy(npo.copy, npo.copy_prod);
> +
> +	if (xenvif_rx_submit(queue, &npo, skb))
> +		notify_remote_via_irq(queue->rx_irq);
> +
> +	ret = 0; /* clear error */

No need to have that comment.

> +done:
> +	if (xenvif_queue_stopped(queue))
> +		xenvif_wake_queue(queue);
> +	return ret;
> +}
> +
>  static void xenvif_rx_action(struct xenvif_queue *queue)
>  {
> -	int ret;
>  	struct sk_buff *skb;
>  	struct sk_buff_head rxq;
>  	bool need_to_notify = false;
> @@ -905,22 +944,13 @@ static void xenvif_rx_action(struct xenvif_queue *queue)
>  	}
>  
>  	BUG_ON(npo.meta_prod > XEN_NETIF_RX_RING_SIZE);
> -	if (!npo.copy_done && !npo.copy_prod)
> +	if (!npo.copy_prod)

You modified this line back and forth. You could just avoid modifying it
in you previous patch to implement RX persistent grants.

>  		return;
>  
>  	BUG_ON(npo.copy_prod > MAX_GRANT_COPY_OPS);
>  	if (npo.copy_prod)
>  		gnttab_batch_copy(npo.copy, npo.copy_prod);
>  
> -	BUG_ON(npo.map_prod > MAX_GRANT_COPY_OPS);
> -	if (npo.map_prod) {
> -		ret = gnttab_map_refs(queue->rx_map_ops,
> -				      NULL,
> -				      queue->rx_pages_to_map,
> -				      npo.map_prod);
> -		BUG_ON(ret);
> -	}
> -

And this? You delete the hunk you added in previous patch.

Wei.

>  	while ((skb = __skb_dequeue(&rxq)) != NULL)
>  		need_to_notify |= xenvif_rx_submit(queue, &npo, skb);
>  
> -- 
> 2.1.3
--
To unsubscribe from this list: send the line "unsubscribe netdev" in
the body of a message to majordomo@...r.kernel.org
More majordomo info at  http://vger.kernel.org/majordomo-info.html

Powered by blists - more mailing lists

Powered by Openwall GNU/*/Linux Powered by OpenVZ