Commit 6a6dc08f authored by David Vrabel's avatar David Vrabel Committed by David S. Miller

xen-netfront: use napi_complete() correctly to prevent Rx stalling

After d75b1ade (net: less interrupt
masking in NAPI) the napi instance is removed from the per-cpu list
prior to calling the n->poll(), and is only requeued if all of the
budget was used.  This inadvertently broke netfront because netfront
does not use NAPI correctly.

If netfront had not used all of its budget it would do a final check
for any Rx responses and avoid calling napi_complete() if there were
more responses.  It would still return under budget so it would never
be rescheduled.  The final check would also not re-enable the Rx
interrupt.

Additionally, xenvif_poll() would also call napi_complete() /after/
enabling the interrupt.  This resulted in a race between the
napi_complete() and the napi_schedule() in the interrupt handler.  The
use of local_irq_save/restore() avoided by race iff the handler is
running on the same CPU but not if it was running on a different CPU.

Fix both of these by always calling napi_compete() if the budget was
not all used, and then calling napi_schedule() if the final checks
says there's more work.
Signed-off-by: default avatarDavid Vrabel <david.vrabel@citrix.com>
Cc: Eric Dumazet <edumazet@google.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent f1fb521f
...@@ -977,7 +977,6 @@ static int xennet_poll(struct napi_struct *napi, int budget) ...@@ -977,7 +977,6 @@ static int xennet_poll(struct napi_struct *napi, int budget)
struct sk_buff_head rxq; struct sk_buff_head rxq;
struct sk_buff_head errq; struct sk_buff_head errq;
struct sk_buff_head tmpq; struct sk_buff_head tmpq;
unsigned long flags;
int err; int err;
spin_lock(&queue->rx_lock); spin_lock(&queue->rx_lock);
...@@ -1050,15 +1049,11 @@ static int xennet_poll(struct napi_struct *napi, int budget) ...@@ -1050,15 +1049,11 @@ static int xennet_poll(struct napi_struct *napi, int budget)
if (work_done < budget) { if (work_done < budget) {
int more_to_do = 0; int more_to_do = 0;
napi_gro_flush(napi, false); napi_complete(napi);
local_irq_save(flags);
RING_FINAL_CHECK_FOR_RESPONSES(&queue->rx, more_to_do); RING_FINAL_CHECK_FOR_RESPONSES(&queue->rx, more_to_do);
if (!more_to_do) if (more_to_do)
__napi_complete(napi); napi_schedule(napi);
local_irq_restore(flags);
} }
spin_unlock(&queue->rx_lock); spin_unlock(&queue->rx_lock);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment