]> err.no Git - linux-2.6/blobdiff - drivers/net/skge.c
[PATCH] skge: check the allocation of ring buffer
[linux-2.6] / drivers / net / skge.c
index 25e028b7ce48052d22f0366b998974bfdf413ca9..deca5066a4474c82cc0d42c63658802333d25717 100644 (file)
@@ -104,7 +104,6 @@ static const int txqaddr[] = { Q_XA1, Q_XA2 };
 static const int rxqaddr[] = { Q_R1, Q_R2 };
 static const u32 rxirqmask[] = { IS_R1_F, IS_R2_F };
 static const u32 txirqmask[] = { IS_XA1_F, IS_XA2_F };
-static const u32 portirqmask[] = { IS_PORT_1, IS_PORT_2 };
 
 static int skge_get_regs_len(struct net_device *dev)
 {
@@ -728,7 +727,7 @@ static struct ethtool_ops skge_ethtool_ops = {
  * Allocate ring elements and chain them together
  * One-to-one association of board descriptors with ring elements
  */
-static int skge_ring_alloc(struct skge_ring *ring, void *vaddr, u64 base)
+static int skge_ring_alloc(struct skge_ring *ring, void *vaddr, u32 base)
 {
        struct skge_tx_desc *d;
        struct skge_element *e;
@@ -2169,6 +2168,14 @@ static int skge_up(struct net_device *dev)
        if (!skge->mem)
                return -ENOMEM;
 
+       BUG_ON(skge->dma & 7);
+
+       if ((u64)skge->dma >> 32 != ((u64) skge->dma + skge->mem_size) >> 32) {
+               printk(KERN_ERR PFX "pci_alloc_consistent region crosses 4G boundary\n");
+               err = -EINVAL;
+               goto free_pci_mem;
+       }
+
        memset(skge->mem, 0, skge->mem_size);
 
        if ((err = skge_ring_alloc(&skge->rx_ring, skge->mem, skge->dma)))
@@ -2184,12 +2191,6 @@ static int skge_up(struct net_device *dev)
 
        skge->tx_avail = skge->tx_ring.count - 1;
 
-       /* Enable IRQ from port */
-       spin_lock_irq(&hw->hw_lock);
-       hw->intr_mask |= portirqmask[port];
-       skge_write32(hw, B0_IMSK, hw->intr_mask);
-       spin_unlock_irq(&hw->hw_lock);
-
        /* Initialize MAC */
        spin_lock_bh(&hw->phy_lock);
        if (hw->chip_id == CHIP_ID_GENESIS)
@@ -2246,11 +2247,6 @@ static int skge_down(struct net_device *dev)
        else
                yukon_stop(skge);
 
-       spin_lock_irq(&hw->hw_lock);
-       hw->intr_mask &= ~portirqmask[skge->port];
-       skge_write32(hw, B0_IMSK, hw->intr_mask);
-       spin_unlock_irq(&hw->hw_lock);
-
        /* Stop transmitter */
        skge_write8(hw, Q_ADDR(txqaddr[port], Q_CSR), CSR_STOP);
        skge_write32(hw, RB_ADDR(txqaddr[port], RB_CTRL),
@@ -2307,16 +2303,13 @@ static int skge_xmit_frame(struct sk_buff *skb, struct net_device *dev)
        int i;
        u32 control, len;
        u64 map;
-       unsigned long flags;
 
        skb = skb_padto(skb, ETH_ZLEN);
        if (!skb)
                return NETDEV_TX_OK;
 
-       local_irq_save(flags);
        if (!spin_trylock(&skge->tx_lock)) {
                /* Collision - tell upper layer to requeue */
-               local_irq_restore(flags);
                return NETDEV_TX_LOCKED;
        }
 
@@ -2327,7 +2320,7 @@ static int skge_xmit_frame(struct sk_buff *skb, struct net_device *dev)
                        printk(KERN_WARNING PFX "%s: ring full when queue awake!\n",
                               dev->name);
                }
-               spin_unlock_irqrestore(&skge->tx_lock, flags);
+               spin_unlock(&skge->tx_lock);
                return NETDEV_TX_BUSY;
        }
 
@@ -2403,7 +2396,7 @@ static int skge_xmit_frame(struct sk_buff *skb, struct net_device *dev)
        }
 
        dev->trans_start = jiffies;
-       spin_unlock_irqrestore(&skge->tx_lock, flags);
+       spin_unlock(&skge->tx_lock);
 
        return NETDEV_TX_OK;
 }
@@ -2416,7 +2409,7 @@ static inline void skge_tx_free(struct skge_hw *hw, struct skge_element *e)
                               pci_unmap_addr(e, mapaddr),
                               pci_unmap_len(e, maplen),
                               PCI_DMA_TODEVICE);
-               dev_kfree_skb_any(e->skb);
+               dev_kfree_skb(e->skb);
                e->skb = NULL;
        } else {
                pci_unmap_page(hw->pdev,
@@ -2430,15 +2423,14 @@ static void skge_tx_clean(struct skge_port *skge)
 {
        struct skge_ring *ring = &skge->tx_ring;
        struct skge_element *e;
-       unsigned long flags;
 
-       spin_lock_irqsave(&skge->tx_lock, flags);
+       spin_lock_bh(&skge->tx_lock);
        for (e = ring->to_clean; e != ring->to_use; e = e->next) {
                ++skge->tx_avail;
                skge_tx_free(skge->hw, e);
        }
        ring->to_clean = e;
-       spin_unlock_irqrestore(&skge->tx_lock, flags);
+       spin_unlock_bh(&skge->tx_lock);
 }
 
 static void skge_tx_timeout(struct net_device *dev)
@@ -2663,6 +2655,37 @@ resubmit:
        return NULL;
 }
 
+static void skge_tx_done(struct skge_port *skge)
+{
+       struct skge_ring *ring = &skge->tx_ring;
+       struct skge_element *e;
+
+       spin_lock(&skge->tx_lock);
+       for (e = ring->to_clean; prefetch(e->next), e != ring->to_use; e = e->next) {
+               struct skge_tx_desc *td = e->desc;
+               u32 control;
+
+               rmb();
+               control = td->control;
+               if (control & BMU_OWN)
+                       break;
+
+               if (unlikely(netif_msg_tx_done(skge)))
+                       printk(KERN_DEBUG PFX "%s: tx done slot %td status 0x%x\n",
+                              skge->netdev->name, e - ring->start, td->status);
+
+               skge_tx_free(skge->hw, e);
+               e->skb = NULL;
+               ++skge->tx_avail;
+       }
+       ring->to_clean = e;
+       skge_write8(skge->hw, Q_ADDR(txqaddr[skge->port], Q_CSR), CSR_IRQ_CL_F);
+
+       if (skge->tx_avail > MAX_SKB_FRAGS + 1)
+               netif_wake_queue(skge->netdev);
+
+       spin_unlock(&skge->tx_lock);
+}
 
 static int skge_poll(struct net_device *dev, int *budget)
 {
@@ -2670,8 +2693,10 @@ static int skge_poll(struct net_device *dev, int *budget)
        struct skge_hw *hw = skge->hw;
        struct skge_ring *ring = &skge->rx_ring;
        struct skge_element *e;
-       unsigned int to_do = min(dev->quota, *budget);
-       unsigned int work_done = 0;
+       int to_do = min(dev->quota, *budget);
+       int work_done = 0;
+
+       skge_tx_done(skge);
 
        for (e = ring->to_clean; prefetch(e->next), work_done < to_do; e = e->next) {
                struct skge_rx_desc *rd = e->desc;
@@ -2705,49 +2730,13 @@ static int skge_poll(struct net_device *dev, int *budget)
        if (work_done >=  to_do)
                return 1; /* not done */
 
-       spin_lock_irq(&hw->hw_lock);
-       __netif_rx_complete(dev);
-       hw->intr_mask |= portirqmask[skge->port];
+       netif_rx_complete(dev);
+       hw->intr_mask |= skge->port == 0 ? (IS_R1_F|IS_XA1_F) : (IS_R2_F|IS_XA2_F);
        skge_write32(hw, B0_IMSK, hw->intr_mask);
-       spin_unlock_irq(&hw->hw_lock);
 
        return 0;
 }
 
-static inline void skge_tx_intr(struct net_device *dev)
-{
-       struct skge_port *skge = netdev_priv(dev);
-       struct skge_hw *hw = skge->hw;
-       struct skge_ring *ring = &skge->tx_ring;
-       struct skge_element *e;
-
-       spin_lock(&skge->tx_lock);
-       for (e = ring->to_clean; prefetch(e->next), e != ring->to_use; e = e->next) {
-               struct skge_tx_desc *td = e->desc;
-               u32 control;
-
-               rmb();
-               control = td->control;
-               if (control & BMU_OWN)
-                       break;
-
-               if (unlikely(netif_msg_tx_done(skge)))
-                       printk(KERN_DEBUG PFX "%s: tx done slot %td status 0x%x\n",
-                              dev->name, e - ring->start, td->status);
-
-               skge_tx_free(hw, e);
-               e->skb = NULL;
-               ++skge->tx_avail;
-       }
-       ring->to_clean = e;
-       skge_write8(hw, Q_ADDR(txqaddr[skge->port], Q_CSR), CSR_IRQ_CL_F);
-
-       if (skge->tx_avail > MAX_SKB_FRAGS + 1)
-               netif_wake_queue(dev);
-
-       spin_unlock(&skge->tx_lock);
-}
-
 /* Parity errors seem to happen when Genesis is connected to a switch
  * with no other ports present. Heartbeat error??
  */
@@ -2855,12 +2844,11 @@ static void skge_extirq(unsigned long data)
        int port;
 
        spin_lock(&hw->phy_lock);
-       for (port = 0; port < 2; port++) {
+       for (port = 0; port < hw->ports; port++) {
                struct net_device *dev = hw->dev[port];
+               struct skge_port *skge = netdev_priv(dev);
 
-               if (dev && netif_running(dev)) {
-                       struct skge_port *skge = netdev_priv(dev);
-
+               if (netif_running(dev)) {
                        if (hw->chip_id != CHIP_ID_GENESIS)
                                yukon_phy_intr(skge);
                        else
@@ -2869,38 +2857,39 @@ static void skge_extirq(unsigned long data)
        }
        spin_unlock(&hw->phy_lock);
 
-       spin_lock_irq(&hw->hw_lock);
        hw->intr_mask |= IS_EXT_REG;
        skge_write32(hw, B0_IMSK, hw->intr_mask);
-       spin_unlock_irq(&hw->hw_lock);
 }
 
 static irqreturn_t skge_intr(int irq, void *dev_id, struct pt_regs *regs)
 {
        struct skge_hw *hw = dev_id;
-       u32 status = skge_read32(hw, B0_SP_ISRC);
+       u32 status;
 
-       if (status == 0 || status == ~0) /* hotplug or shared irq */
+       /* Reading this register masks IRQ */
+       status = skge_read32(hw, B0_SP_ISRC);
+       if (status == 0)
                return IRQ_NONE;
 
-       spin_lock(&hw->hw_lock);
-       if (status & IS_R1_F) {
+       if (status & IS_EXT_REG) {
+               hw->intr_mask &= ~IS_EXT_REG;
+               tasklet_schedule(&hw->ext_tasklet);
+       }
+
+       if (status & (IS_R1_F|IS_XA1_F)) {
                skge_write8(hw, Q_ADDR(Q_R1, Q_CSR), CSR_IRQ_CL_F);
-               hw->intr_mask &= ~IS_R1_F;
+               hw->intr_mask &= ~(IS_R1_F|IS_XA1_F);
                netif_rx_schedule(hw->dev[0]);
        }
 
-       if (status & IS_R2_F) {
+       if (status & (IS_R2_F|IS_XA2_F)) {
                skge_write8(hw, Q_ADDR(Q_R2, Q_CSR), CSR_IRQ_CL_F);
-               hw->intr_mask &= ~IS_R2_F;
+               hw->intr_mask &= ~(IS_R2_F|IS_XA2_F);
                netif_rx_schedule(hw->dev[1]);
        }
 
-       if (status & IS_XA1_F)
-               skge_tx_intr(hw->dev[0]);
-
-       if (status & IS_XA2_F)
-               skge_tx_intr(hw->dev[1]);
+       if (likely((status & hw->intr_mask) == 0))
+               return IRQ_HANDLED;
 
        if (status & IS_PA_TO_RX1) {
                struct skge_port *skge = netdev_priv(hw->dev[0]);
@@ -2929,13 +2918,7 @@ static irqreturn_t skge_intr(int irq, void *dev_id, struct pt_regs *regs)
        if (status & IS_HW_ERR)
                skge_error_irq(hw);
 
-       if (status & IS_EXT_REG) {
-               hw->intr_mask &= ~IS_EXT_REG;
-               tasklet_schedule(&hw->ext_tasklet);
-       }
-
        skge_write32(hw, B0_IMSK, hw->intr_mask);
-       spin_unlock(&hw->hw_lock);
 
        return IRQ_HANDLED;
 }
@@ -3081,7 +3064,10 @@ static int skge_reset(struct skge_hw *hw)
        else
                hw->ram_size = t8 * 4096;
 
-       hw->intr_mask = IS_HW_ERR | IS_EXT_REG;
+       hw->intr_mask = IS_HW_ERR | IS_EXT_REG | IS_PORT_1;
+       if (hw->ports > 1)
+               hw->intr_mask |= IS_PORT_2;
+
        if (hw->chip_id == CHIP_ID_GENESIS)
                genesis_init(hw);
        else {
@@ -3304,7 +3290,6 @@ static int __devinit skge_probe(struct pci_dev *pdev,
 
        hw->pdev = pdev;
        spin_lock_init(&hw->phy_lock);
-       spin_lock_init(&hw->hw_lock);
        tasklet_init(&hw->ext_tasklet, skge_extirq, (unsigned long) hw);
 
        hw->regs = ioremap_nocache(pci_resource_start(pdev, 0), 0x4000);