1 files changed, 27 insertions, 9 deletions

diff --git a/net/core/netpoll.c b/net/core/netpoll.c
index 9cb781830380..471da451cd48 100644
--- a/net/core/netpoll.c
+++ b/net/core/netpoll.c
@@ -54,6 +54,7 @@ static atomic_t trapped;
                                 sizeof(struct iphdr) + sizeof(struct ethhdr))
 
 static void zap_completion_queue(void);
+static void arp_reply(struct sk_buff *skb);
 
 static void queue_process(void *p)
 {
@@ -153,6 +154,22 @@ static void poll_napi(struct netpoll *np)
         }
 }
 
+static void service_arp_queue(struct netpoll_info *npi)
+{
+        struct sk_buff *skb;
+
+        if (unlikely(!npi))
+                return;
+
+        skb = skb_dequeue(&npi->arp_tx);
+
+        while (skb != NULL) {
+                arp_reply(skb);
+                skb = skb_dequeue(&npi->arp_tx);
+        }
+        return;
+}
+
 void netpoll_poll(struct netpoll *np)
 {
         if(!np->dev || !netif_running(np->dev) || !np->dev->poll_controller)
@@ -163,6 +180,8 @@ void netpoll_poll(struct netpoll *np)
         if (np->dev->poll)
                 poll_napi(np);
 
+        service_arp_queue(np->dev->npinfo);
+
         zap_completion_queue();
 }
 
@@ -279,14 +298,10 @@ static void netpoll_send_skb(struct netpoll *np, struct sk_buff *skb)
                  * network drivers do not expect to be called if the queue is
                  * stopped.
                  */
-                if (netif_queue_stopped(np->dev)) {
-                        netif_tx_unlock(np->dev);
-                        netpoll_poll(np);
-                        udelay(50);
-                        continue;
-                }
+                status = NETDEV_TX_BUSY;
+                if (!netif_queue_stopped(np->dev))
+                        status = np->dev->hard_start_xmit(skb, np->dev);
 
-                status = np->dev->hard_start_xmit(skb, np->dev);
                 netif_tx_unlock(np->dev);
 
                 /* success */
@@ -446,7 +461,9 @@ int __netpoll_rx(struct sk_buff *skb)
         int proto, len, ulen;
         struct iphdr *iph;
         struct udphdr *uh;
-        struct netpoll *np = skb->dev->npinfo->rx_np;
+        struct netpoll_info *npi = skb->dev->npinfo;
+        struct netpoll *np = npi->rx_np;
+
 
         if (!np)
                 goto out;
@@ -456,7 +473,7 @@ int __netpoll_rx(struct sk_buff *skb)
         /* check if netpoll clients need ARP */
         if (skb->protocol == __constant_htons(ETH_P_ARP) &&
             atomic_read(&trapped)) {
-                arp_reply(skb);
+                skb_queue_tail(&npi->arp_tx, skb);
                 return 1;
         }
 
@@ -651,6 +668,7 @@ int netpoll_setup(struct netpoll *np)
                 npinfo->poll_owner = -1;
                 npinfo->tries = MAX_RETRIES;
                 spin_lock_init(&npinfo->rx_lock);
+                skb_queue_head_init(&npinfo->arp_tx);
         } else
                 npinfo = ndev->npinfo;