Commit 96587661 authored by Lennert Buytenhek's avatar Lennert Buytenhek

mv643xx_eth: move port_receive() into its only caller

The port_receive() function is a remnant of the original mv643xx_eth
HAL split.  This patch moves port_receive() into its caller, so that
the top and the bottom half of RX processing no longer communicate
via the HAL FUNC_RET_STATUS/pkt_info mechanism abstraction anymore.
Signed-off-by: default avatarLennert Buytenhek <buytenh@marvell.com>
Acked-by: default avatarDale Farnsworth <dale@farnsworth.org>
parent 5daffe94
...@@ -518,64 +518,38 @@ static inline void mv643xx_eth_rx_refill_descs_timer_wrapper(unsigned long data) ...@@ -518,64 +518,38 @@ static inline void mv643xx_eth_rx_refill_descs_timer_wrapper(unsigned long data)
mv643xx_eth_rx_refill_descs((struct net_device *)data); mv643xx_eth_rx_refill_descs((struct net_device *)data);
} }
static FUNC_RET_STATUS port_receive(struct mv643xx_eth_private *mp, static int mv643xx_eth_receive_queue(struct net_device *dev, int budget)
struct pkt_info *pkt_info)
{ {
int rx_next_curr_desc, rx_curr_desc, rx_used_desc; struct mv643xx_eth_private *mp = netdev_priv(dev);
volatile struct rx_desc *rx_desc; struct net_device_stats *stats = &dev->stats;
unsigned int command_status; unsigned int received_packets = 0;
unsigned long flags;
spin_lock_irqsave(&mp->lock, flags);
/* Get the Rx Desc ring 'curr and 'used' indexes */
rx_curr_desc = mp->rx_curr_desc;
rx_used_desc = mp->rx_used_desc;
rx_desc = &mp->rx_desc_area[rx_curr_desc];
/* The following parameters are used to save readings from memory */
command_status = rx_desc->cmd_sts;
rmb();
/* Nothing to receive... */ while (budget-- > 0) {
if (command_status & BUFFER_OWNED_BY_DMA) { struct sk_buff *skb;
spin_unlock_irqrestore(&mp->lock, flags); volatile struct rx_desc *rx_desc;
return ETH_END_OF_JOB; unsigned int cmd_sts;
} unsigned long flags;
pkt_info->byte_cnt = rx_desc->byte_cnt - ETH_HW_IP_ALIGN; spin_lock_irqsave(&mp->lock, flags);
pkt_info->cmd_sts = command_status;
pkt_info->buf_ptr = rx_desc->buf_ptr + ETH_HW_IP_ALIGN;
pkt_info->return_info = mp->rx_skb[rx_curr_desc];
pkt_info->l4i_chk = rx_desc->buf_size;
/* rx_desc = &mp->rx_desc_area[mp->rx_curr_desc];
* Clean the return info field to indicate that the
* packet has been moved to the upper layers
*/
mp->rx_skb[rx_curr_desc] = NULL;
/* Update current index in data structure */ cmd_sts = rx_desc->cmd_sts;
rx_next_curr_desc = (rx_curr_desc + 1) % mp->rx_ring_size; if (cmd_sts & BUFFER_OWNED_BY_DMA) {
mp->rx_curr_desc = rx_next_curr_desc; spin_unlock_irqrestore(&mp->lock, flags);
break;
}
rmb();
spin_unlock_irqrestore(&mp->lock, flags); skb = mp->rx_skb[mp->rx_curr_desc];
mp->rx_skb[mp->rx_curr_desc] = NULL;
return ETH_OK; mp->rx_curr_desc = (mp->rx_curr_desc + 1) % mp->rx_ring_size;
}
static int mv643xx_eth_receive_queue(struct net_device *dev, int budget) spin_unlock_irqrestore(&mp->lock, flags);
{
struct mv643xx_eth_private *mp = netdev_priv(dev);
struct net_device_stats *stats = &dev->stats;
unsigned int received_packets = 0;
struct sk_buff *skb;
struct pkt_info pkt_info;
while (budget-- > 0 && port_receive(mp, &pkt_info) == ETH_OK) { dma_unmap_single(NULL, rx_desc->buf_ptr + ETH_HW_IP_ALIGN,
dma_unmap_single(NULL, pkt_info.buf_ptr, ETH_RX_SKB_SIZE, ETH_RX_SKB_SIZE, DMA_FROM_DEVICE);
DMA_FROM_DEVICE);
mp->rx_desc_count--; mp->rx_desc_count--;
received_packets++; received_packets++;
...@@ -584,18 +558,17 @@ static int mv643xx_eth_receive_queue(struct net_device *dev, int budget) ...@@ -584,18 +558,17 @@ static int mv643xx_eth_receive_queue(struct net_device *dev, int budget)
* Note byte count includes 4 byte CRC count * Note byte count includes 4 byte CRC count
*/ */
stats->rx_packets++; stats->rx_packets++;
stats->rx_bytes += pkt_info.byte_cnt; stats->rx_bytes += rx_desc->byte_cnt - ETH_HW_IP_ALIGN;
skb = pkt_info.return_info;
/* /*
* In case received a packet without first / last bits on OR * In case received a packet without first / last bits on OR
* the error summary bit is on, the packets needs to be dropeed. * the error summary bit is on, the packets needs to be dropeed.
*/ */
if (((pkt_info.cmd_sts & (RX_FIRST_DESC | RX_LAST_DESC)) != if (((cmd_sts & (RX_FIRST_DESC | RX_LAST_DESC)) !=
(RX_FIRST_DESC | RX_LAST_DESC)) (RX_FIRST_DESC | RX_LAST_DESC))
|| (pkt_info.cmd_sts & ERROR_SUMMARY)) { || (cmd_sts & ERROR_SUMMARY)) {
stats->rx_dropped++; stats->rx_dropped++;
if ((pkt_info.cmd_sts & (RX_FIRST_DESC | if ((cmd_sts & (RX_FIRST_DESC | RX_LAST_DESC)) !=
RX_LAST_DESC)) !=
(RX_FIRST_DESC | RX_LAST_DESC)) { (RX_FIRST_DESC | RX_LAST_DESC)) {
if (net_ratelimit()) if (net_ratelimit())
printk(KERN_ERR printk(KERN_ERR
...@@ -603,7 +576,7 @@ static int mv643xx_eth_receive_queue(struct net_device *dev, int budget) ...@@ -603,7 +576,7 @@ static int mv643xx_eth_receive_queue(struct net_device *dev, int budget)
"on multiple descriptors\n", "on multiple descriptors\n",
dev->name); dev->name);
} }
if (pkt_info.cmd_sts & ERROR_SUMMARY) if (cmd_sts & ERROR_SUMMARY)
stats->rx_errors++; stats->rx_errors++;
dev_kfree_skb_irq(skb); dev_kfree_skb_irq(skb);
...@@ -612,12 +585,12 @@ static int mv643xx_eth_receive_queue(struct net_device *dev, int budget) ...@@ -612,12 +585,12 @@ static int mv643xx_eth_receive_queue(struct net_device *dev, int budget)
* The -4 is for the CRC in the trailer of the * The -4 is for the CRC in the trailer of the
* received packet * received packet
*/ */
skb_put(skb, pkt_info.byte_cnt - 4); skb_put(skb, rx_desc->byte_cnt - ETH_HW_IP_ALIGN - 4);
if (pkt_info.cmd_sts & LAYER_4_CHECKSUM_OK) { if (cmd_sts & LAYER_4_CHECKSUM_OK) {
skb->ip_summed = CHECKSUM_UNNECESSARY; skb->ip_summed = CHECKSUM_UNNECESSARY;
skb->csum = htons( skb->csum = htons(
(pkt_info.cmd_sts & 0x0007fff8) >> 3); (cmd_sts & 0x0007fff8) >> 3);
} }
skb->protocol = eth_type_trans(skb, dev); skb->protocol = eth_type_trans(skb, dev);
#ifdef MV643XX_ETH_NAPI #ifdef MV643XX_ETH_NAPI
......
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