Browse Source

amd-xgbe: Fix napi Rx budget accounting

Currently the amd-xgbe driver increments the packets processed counter
each time a descriptor is processed.  Since a packet can be represented
by more than one descriptor incrementing the counter in this way is not
appropriate.  Also, since multiple descriptors cause the budget check
to be short circuited, sometimes the returned value from the poll
function would be larger than the budget value resulting in a WARN_ONCE
being triggered.

Update the polling logic to properly account for the number of packets
processed and exit when the budget value is reached.

Signed-off-by: Tom Lendacky <thomas.lendacky@amd.com>
Signed-off-by: David S. Miller <davem@davemloft.net>
Lendacky, Thomas 11 years ago
parent
commit
55ca6bcd73
1 changed files with 12 additions and 8 deletions
  1. 12 8
      drivers/net/ethernet/amd/xgbe/xgbe-drv.c

+ 12 - 8
drivers/net/ethernet/amd/xgbe/xgbe-drv.c

@@ -1598,7 +1598,8 @@ static int xgbe_rx_poll(struct xgbe_channel *channel, int budget)
 	struct skb_shared_hwtstamps *hwtstamps;
 	struct skb_shared_hwtstamps *hwtstamps;
 	unsigned int incomplete, error, context_next, context;
 	unsigned int incomplete, error, context_next, context;
 	unsigned int len, put_len, max_len;
 	unsigned int len, put_len, max_len;
-	int received = 0;
+	unsigned int received = 0;
+	int packet_count = 0;
 
 
 	DBGPR("-->xgbe_rx_poll: budget=%d\n", budget);
 	DBGPR("-->xgbe_rx_poll: budget=%d\n", budget);
 
 
@@ -1608,7 +1609,7 @@ static int xgbe_rx_poll(struct xgbe_channel *channel, int budget)
 
 
 	rdata = XGBE_GET_DESC_DATA(ring, ring->cur);
 	rdata = XGBE_GET_DESC_DATA(ring, ring->cur);
 	packet = &ring->packet_data;
 	packet = &ring->packet_data;
-	while (received < budget) {
+	while (packet_count < budget) {
 		DBGPR("  cur = %d\n", ring->cur);
 		DBGPR("  cur = %d\n", ring->cur);
 
 
 		/* First time in loop see if we need to restore state */
 		/* First time in loop see if we need to restore state */
@@ -1662,7 +1663,7 @@ read_again:
 			if (packet->errors)
 			if (packet->errors)
 				DBGPR("Error in received packet\n");
 				DBGPR("Error in received packet\n");
 			dev_kfree_skb(skb);
 			dev_kfree_skb(skb);
-			continue;
+			goto next_packet;
 		}
 		}
 
 
 		if (!context) {
 		if (!context) {
@@ -1677,7 +1678,7 @@ read_again:
 					}
 					}
 
 
 					dev_kfree_skb(skb);
 					dev_kfree_skb(skb);
-					continue;
+					goto next_packet;
 				}
 				}
 				memcpy(skb_tail_pointer(skb), rdata->skb->data,
 				memcpy(skb_tail_pointer(skb), rdata->skb->data,
 				       put_len);
 				       put_len);
@@ -1694,7 +1695,7 @@ read_again:
 
 
 		/* Stray Context Descriptor? */
 		/* Stray Context Descriptor? */
 		if (!skb)
 		if (!skb)
-			continue;
+			goto next_packet;
 
 
 		/* Be sure we don't exceed the configured MTU */
 		/* Be sure we don't exceed the configured MTU */
 		max_len = netdev->mtu + ETH_HLEN;
 		max_len = netdev->mtu + ETH_HLEN;
@@ -1705,7 +1706,7 @@ read_again:
 		if (skb->len > max_len) {
 		if (skb->len > max_len) {
 			DBGPR("packet length exceeds configured MTU\n");
 			DBGPR("packet length exceeds configured MTU\n");
 			dev_kfree_skb(skb);
 			dev_kfree_skb(skb);
-			continue;
+			goto next_packet;
 		}
 		}
 
 
 #ifdef XGMAC_ENABLE_RX_PKT_DUMP
 #ifdef XGMAC_ENABLE_RX_PKT_DUMP
@@ -1739,6 +1740,9 @@ read_again:
 
 
 		netdev->last_rx = jiffies;
 		netdev->last_rx = jiffies;
 		napi_gro_receive(&pdata->napi, skb);
 		napi_gro_receive(&pdata->napi, skb);
+
+next_packet:
+		packet_count++;
 	}
 	}
 
 
 	/* Check if we need to save state before leaving */
 	/* Check if we need to save state before leaving */
@@ -1752,9 +1756,9 @@ read_again:
 		rdata->state.error = error;
 		rdata->state.error = error;
 	}
 	}
 
 
-	DBGPR("<--xgbe_rx_poll: received = %d\n", received);
+	DBGPR("<--xgbe_rx_poll: packet_count = %d\n", packet_count);
 
 
-	return received;
+	return packet_count;
 }
 }
 
 
 static int xgbe_poll(struct napi_struct *napi, int budget)
 static int xgbe_poll(struct napi_struct *napi, int budget)