Commit 0accc7c5 authored by François Romieu's avatar François Romieu Committed by Jeff Garzik

[PATCH] via-velocity: Rx buffers allocation rework

Rework of the Rx buffers allocation:
- Rx irq handler (velocity_rx_srv): defer the Rx buffer allocation until
  the packet processing loop is done;
- a separate index related to the Rx descriptor ("rd_dirty") is introduced
  to distinguish the first Rx descriptor whose buffer has to be refilled.
  This way the driver does not need to confuse this descriptor with the
  most recently netif()ed one. Rationale: batch + rx_copybreak;
- dirty/empty Rx descriptors are identified through the whole driver
  via an adequate NULL pointer in the velocity_rd_info[] array (see
  velocity_rx_refill() and velocity_receive_frame());
- Rx descriptors need to be grouped by a multiple of 4 before they can
  be handed back to the asic (hardware constraint). This task is moved
  from the Rx processing loop to the Rx refill function;
- factorization of code in velocity_init_rd_ring().
parent 177d8df5
...@@ -485,7 +485,7 @@ static void velocity_rx_reset(struct velocity_info *vptr) ...@@ -485,7 +485,7 @@ static void velocity_rx_reset(struct velocity_info *vptr)
struct mac_regs * regs = vptr->mac_regs; struct mac_regs * regs = vptr->mac_regs;
int i; int i;
vptr->rd_used = vptr->rd_curr = 0; vptr->rd_dirty = vptr->rd_filled = vptr->rd_curr = 0;
/* /*
* Init state, all RD entries belong to the NIC * Init state, all RD entries belong to the NIC
...@@ -980,6 +980,49 @@ static void velocity_free_rings(struct velocity_info *vptr) ...@@ -980,6 +980,49 @@ static void velocity_free_rings(struct velocity_info *vptr)
pci_free_consistent(vptr->pdev, size, vptr->tx_bufs, vptr->tx_bufs_dma); pci_free_consistent(vptr->pdev, size, vptr->tx_bufs, vptr->tx_bufs_dma);
} }
static inline void velocity_give_many_rx_descs(struct velocity_info *vptr)
{
struct mac_regs *regs = vptr->mac_regs;
int avail, dirty, unusable;
/*
* RD number must be equal to 4X per hardware spec
* (programming guide rev 1.20, p.13)
*/
if (vptr->rd_filled < 4)
return;
unusable = vptr->rd_filled | 0x0003;
dirty = vptr->rd_dirty - unusable + 1;
for (avail = vptr->rd_filled & 0xfffc; avail; avail--) {
dirty = (dirty > 0) ? dirty - 1 : vptr->options.numrx - 1;
velocity_give_rx_desc(vptr->rd_ring + dirty);
}
writew(vptr->rd_filled & 0xfffc, &regs->RBRDU);
vptr->rd_filled = unusable;
}
static int velocity_rx_refill(struct velocity_info *vptr)
{
int dirty = vptr->rd_dirty, done = 0, ret = 0;
while (!vptr->rd_info[dirty].skb) {
ret = velocity_alloc_rx_buf(vptr, dirty);
if (ret < 0)
break;
done++;
dirty = (dirty < vptr->options.numrx - 1) ? dirty + 1 : 0;
}
if (done) {
vptr->rd_dirty = dirty;
vptr->rd_filled += done;
velocity_give_many_rx_descs(vptr);
}
return ret;
}
/** /**
* velocity_init_rd_ring - set up receive ring * velocity_init_rd_ring - set up receive ring
* @vptr: velocity to configure * @vptr: velocity to configure
...@@ -990,9 +1033,7 @@ static void velocity_free_rings(struct velocity_info *vptr) ...@@ -990,9 +1033,7 @@ static void velocity_free_rings(struct velocity_info *vptr)
static int velocity_init_rd_ring(struct velocity_info *vptr) static int velocity_init_rd_ring(struct velocity_info *vptr)
{ {
int i, ret = -ENOMEM; int ret = -ENOMEM;
struct rx_desc *rd;
struct velocity_rd_info *rd_info;
unsigned int rsize = sizeof(struct velocity_rd_info) * unsigned int rsize = sizeof(struct velocity_rd_info) *
vptr->options.numrx; vptr->options.numrx;
...@@ -1001,22 +1042,14 @@ static int velocity_init_rd_ring(struct velocity_info *vptr) ...@@ -1001,22 +1042,14 @@ static int velocity_init_rd_ring(struct velocity_info *vptr)
goto out; goto out;
memset(vptr->rd_info, 0, rsize); memset(vptr->rd_info, 0, rsize);
/* Init the RD ring entries */ vptr->rd_filled = vptr->rd_dirty = vptr->rd_curr = 0;
for (i = 0; i < vptr->options.numrx; i++) {
rd = &(vptr->rd_ring[i]);
rd_info = &(vptr->rd_info[i]);
ret = velocity_alloc_rx_buf(vptr, i); ret = velocity_rx_refill(vptr);
if (ret < 0) { if (ret < 0) {
VELOCITY_PRT(MSG_LEVEL_ERR, KERN_ERR VELOCITY_PRT(MSG_LEVEL_ERR, KERN_ERR
"%s: failed to allocate RX buffer.\n", "%s: failed to allocate RX buffer.\n", vptr->dev->name);
vptr->dev->name);
velocity_free_rd_ring(vptr); velocity_free_rd_ring(vptr);
goto out;
} }
velocity_give_rx_desc(rd);
}
vptr->rd_used = vptr->rd_curr = 0;
out: out:
return ret; return ret;
} }
...@@ -1160,22 +1193,14 @@ static void velocity_free_td_ring(struct velocity_info *vptr) ...@@ -1160,22 +1193,14 @@ static void velocity_free_td_ring(struct velocity_info *vptr)
static int velocity_rx_srv(struct velocity_info *vptr, int status) static int velocity_rx_srv(struct velocity_info *vptr, int status)
{ {
struct rx_desc *rd;
struct net_device_stats *stats = &vptr->stats; struct net_device_stats *stats = &vptr->stats;
struct mac_regs * regs = vptr->mac_regs;
int rd_curr = vptr->rd_curr; int rd_curr = vptr->rd_curr;
int works = 0; int works = 0;
while (1) { while (1) {
struct rx_desc *rd = vptr->rd_ring + rd_curr;
rd = &(vptr->rd_ring[rd_curr]); if (!vptr->rd_info[rd_curr].skb || (works++ > 15))
if ((vptr->rd_info[rd_curr]).skb == NULL) {
if (velocity_alloc_rx_buf(vptr, rd_curr) < 0)
break;
}
if (works++ > 15)
break; break;
if (rd->rdesc0.owner == OWNED_BY_NIC) if (rd->rdesc0.owner == OWNED_BY_NIC)
...@@ -1186,14 +1211,8 @@ static int velocity_rx_srv(struct velocity_info *vptr, int status) ...@@ -1186,14 +1211,8 @@ static int velocity_rx_srv(struct velocity_info *vptr, int status)
* FIXME: need to handle copybreak * FIXME: need to handle copybreak
*/ */
if ((rd->rdesc0.RSR & RSR_RXOK) || (!(rd->rdesc0.RSR & RSR_RXOK) && (rd->rdesc0.RSR & (RSR_CE | RSR_RL)))) { if ((rd->rdesc0.RSR & RSR_RXOK) || (!(rd->rdesc0.RSR & RSR_RXOK) && (rd->rdesc0.RSR & (RSR_CE | RSR_RL)))) {
if (velocity_receive_frame(vptr, rd_curr) == 0) { if (velocity_receive_frame(vptr, rd_curr) < 0)
if (velocity_alloc_rx_buf(vptr, rd_curr) < 0) {
VELOCITY_PRT(MSG_LEVEL_ERR, KERN_ERR "%s: can not allocate rx buf\n", vptr->dev->name);
break;
}
} else {
stats->rx_dropped++; stats->rx_dropped++;
}
} else { } else {
if (rd->rdesc0.RSR & RSR_CRC) if (rd->rdesc0.RSR & RSR_CRC)
stats->rx_crc_errors++; stats->rx_crc_errors++;
...@@ -1205,24 +1224,18 @@ static int velocity_rx_srv(struct velocity_info *vptr, int status) ...@@ -1205,24 +1224,18 @@ static int velocity_rx_srv(struct velocity_info *vptr, int status)
rd->inten = 1; rd->inten = 1;
if (++vptr->rd_used >= 4) {
int i, rd_prev = rd_curr;
for (i = 0; i < 4; i++) {
if (--rd_prev < 0)
rd_prev = vptr->options.numrx - 1;
velocity_give_rx_desc(vptr->rd_ring + rd_prev);
}
writew(4, &(regs->RBRDU));
vptr->rd_used -= 4;
}
vptr->dev->last_rx = jiffies; vptr->dev->last_rx = jiffies;
rd_curr++; rd_curr++;
if (rd_curr >= vptr->options.numrx) if (rd_curr >= vptr->options.numrx)
rd_curr = 0; rd_curr = 0;
} }
if (velocity_rx_refill(vptr) < 0) {
VELOCITY_PRT(MSG_LEVEL_ERR, KERN_ERR
"%s: rx buf allocation failure\n", vptr->dev->name);
}
vptr->rd_curr = rd_curr; vptr->rd_curr = rd_curr;
VAR_USED(stats); VAR_USED(stats);
return works; return works;
......
...@@ -1771,7 +1771,8 @@ struct velocity_info { ...@@ -1771,7 +1771,8 @@ struct velocity_info {
struct velocity_td_info *td_infos[TX_QUEUE_NO]; struct velocity_td_info *td_infos[TX_QUEUE_NO];
int rd_curr; int rd_curr;
int rd_used; int rd_dirty;
u32 rd_filled;
struct rx_desc *rd_ring; struct rx_desc *rd_ring;
struct velocity_rd_info *rd_info; /* It's an array */ struct velocity_rd_info *rd_info; /* It's an array */
......
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