tg3: Reset phy during bringup when using phylib
[safe/jmp/linux-2.6] / drivers / atm / solos-pci.c
index 2dca5ff..51eed67 100644 (file)
 #define FLASH_BUSY     0x60
 #define FPGA_MODE      0x5C
 #define FLASH_MODE     0x58
+#define TX_DMA_ADDR(port)      (0x40 + (4 * (port)))
+#define RX_DMA_ADDR(port)      (0x30 + (4 * (port)))
 
 #define DATA_RAM_SIZE  32768
-#define BUF_SIZE       4096
+#define BUF_SIZE       2048
+#define OLD_BUF_SIZE   4096 /* For FPGA versions <= 2*/
 #define FPGA_PAGE      528 /* FPGA flash page size*/
 #define SOLOS_PAGE     512 /* Solos flash page size*/
 #define FPGA_BLOCK     (FPGA_PAGE * 8) /* FPGA flash block size*/
 #define SOLOS_BLOCK    (SOLOS_PAGE * 8) /* Solos flash block size*/
 
-#define RX_BUF(card, nr) ((card->buffers) + (nr)*BUF_SIZE*2)
-#define TX_BUF(card, nr) ((card->buffers) + (nr)*BUF_SIZE*2 + BUF_SIZE)
+#define RX_BUF(card, nr) ((card->buffers) + (nr)*(card->buffer_size)*2)
+#define TX_BUF(card, nr) ((card->buffers) + (nr)*(card->buffer_size)*2 + (card->buffer_size))
+#define FLASH_BUF ((card->buffers) + 4*(card->buffer_size)*2)
 
-static int debug = 0;
+#define RX_DMA_SIZE    2048
+
+#define FPGA_VERSION(a,b) (((a) << 8) + (b))
+#define LEGACY_BUFFERS 2
+#define DMA_SUPPORTED  4
+
+static int reset = 0;
 static int atmdebug = 0;
 static int firmware_upgrade = 0;
 static int fpga_upgrade = 0;
+static int db_firmware_upgrade = 0;
+static int db_fpga_upgrade = 0;
 
 struct pkt_hdr {
        __le16 size;
@@ -78,6 +90,14 @@ struct pkt_hdr {
        __le16 type;
 };
 
+struct solos_skb_cb {
+       struct atm_vcc *vcc;
+       uint32_t dma_addr;
+};
+
+
+#define SKB_CB(skb)            ((struct solos_skb_cb *)skb->cb)
+
 #define PKT_DATA       0
 #define PKT_COMMAND    1
 #define PKT_POPEN      3
@@ -88,6 +108,7 @@ struct solos_card {
        void __iomem *config_regs;
        void __iomem *buffers;
        int nr_ports;
+       int tx_mask;
        struct pci_dev *dev;
        struct atm_dev *atmdev[4];
        struct tasklet_struct tlet;
@@ -98,8 +119,13 @@ struct solos_card {
        struct list_head param_queue;
        struct sk_buff_head tx_queue[4];
        struct sk_buff_head cli_queue[4];
+       struct sk_buff *tx_skb[4];
+       struct sk_buff *rx_skb[4];
        wait_queue_head_t param_wq;
        wait_queue_head_t fw_wq;
+       int using_dma;
+       int fpga_version;
+       int buffer_size;
 };
 
 
@@ -108,7 +134,6 @@ struct solos_param {
        pid_t pid;
        int port;
        struct sk_buff *response;
-       wait_queue_head_t wq;
 };
 
 #define SOLOS_CHAN(atmdev) ((int)(unsigned long)(atmdev)->phy_data)
@@ -117,18 +142,25 @@ MODULE_AUTHOR("Traverse Technologies <support@traverse.com.au>");
 MODULE_DESCRIPTION("Solos PCI driver");
 MODULE_VERSION(VERSION);
 MODULE_LICENSE("GPL");
-MODULE_PARM_DESC(debug, "Enable Loopback");
+MODULE_FIRMWARE("solos-FPGA.bin");
+MODULE_FIRMWARE("solos-Firmware.bin");
+MODULE_FIRMWARE("solos-db-FPGA.bin");
+MODULE_PARM_DESC(reset, "Reset Solos chips on startup");
 MODULE_PARM_DESC(atmdebug, "Print ATM data");
 MODULE_PARM_DESC(firmware_upgrade, "Initiate Solos firmware upgrade");
 MODULE_PARM_DESC(fpga_upgrade, "Initiate FPGA upgrade");
-module_param(debug, int, 0444);
+MODULE_PARM_DESC(db_firmware_upgrade, "Initiate daughter board Solos firmware upgrade");
+MODULE_PARM_DESC(db_fpga_upgrade, "Initiate daughter board FPGA upgrade");
+module_param(reset, int, 0444);
 module_param(atmdebug, int, 0644);
 module_param(firmware_upgrade, int, 0444);
 module_param(fpga_upgrade, int, 0444);
+module_param(db_firmware_upgrade, int, 0444);
+module_param(db_fpga_upgrade, int, 0444);
 
 static void fpga_queue(struct solos_card *card, int port, struct sk_buff *skb,
                       struct atm_vcc *vcc);
-static int fpga_tx(struct solos_card *);
+static uint32_t fpga_tx(struct solos_card *);
 static irqreturn_t solos_irq(int irq, void *dev_id);
 static struct atm_vcc* find_vcc(struct atm_dev *dev, short vpi, int vci);
 static int list_vccs(int vci);
@@ -281,13 +313,15 @@ static char *next_string(struct sk_buff *skb)
 {
        int i = 0;
        char *this = skb->data;
-
-       while (i < skb->len) {
+       
+       for (i = 0; i < skb->len; i++) {
                if (this[i] == '\n') {
                        this[i] = 0;
-                       skb_pull(skb, i);
+                       skb_pull(skb, i + 1);
                        return this;
                }
+               if (!isprint(this[i]))
+                       return NULL;
        }
        return NULL;
 }
@@ -297,14 +331,16 @@ static char *next_string(struct sk_buff *skb)
  * for the information therein. Fields are....
  *
  *     packet version
- *     TxBitRate       (version >= 1)
  *     RxBitRate       (version >= 1)
+ *     TxBitRate       (version >= 1)
  *     State           (version >= 1)
+ *     LocalSNRMargin  (version >= 1)
+ *     LocalLineAttn   (version >= 1)
  */       
 static int process_status(struct solos_card *card, int port, struct sk_buff *skb)
 {
-       char *str, *end, *state_str;
-       int ver, rate_up, rate_down, state, snr, attn;
+       char *str, *end, *state_str, *snr, *attn;
+       int ver, rate_up, rate_down;
 
        if (!card->atmdev[port])
                return -ENODEV;
@@ -321,43 +357,50 @@ static int process_status(struct solos_card *card, int port, struct sk_buff *skb
        }
 
        str = next_string(skb);
-       rate_up = simple_strtol(str, &end, 10);
+       if (!str)
+               return -EIO;
+       if (!strcmp(str, "ERROR")) {
+               dev_dbg(&card->dev->dev, "Status packet indicated Solos error on port %d (starting up?)\n",
+                        port);
+               return 0;
+       }
+
+       rate_down = simple_strtol(str, &end, 10);
        if (*end)
                return -EIO;
 
        str = next_string(skb);
-       rate_down = simple_strtol(str, &end, 10);
+       if (!str)
+               return -EIO;
+       rate_up = simple_strtol(str, &end, 10);
        if (*end)
                return -EIO;
 
        state_str = next_string(skb);
-       if (!strcmp(state_str, "Showtime"))
-               state = ATM_PHY_SIG_FOUND;
-       else {
-               state = ATM_PHY_SIG_LOST;
+       if (!state_str)
+               return -EIO;
+
+       /* Anything but 'Showtime' is down */
+       if (strcmp(state_str, "Showtime")) {
+               card->atmdev[port]->signal = ATM_PHY_SIG_LOST;
                release_vccs(card->atmdev[port]);
+               dev_info(&card->dev->dev, "Port %d: %s\n", port, state_str);
+               return 0;
        }
 
-       str = next_string(skb);
-       snr = simple_strtol(str, &end, 10);
-       if (*end)
+       snr = next_string(skb);
+       if (!snr)
                return -EIO;
-
-       str = next_string(skb);
-       attn = simple_strtol(str, &end, 10);
-       if (*end)
+       attn = next_string(skb);
+       if (!attn)
                return -EIO;
 
-       if (state == ATM_PHY_SIG_LOST && !rate_up && !rate_down)
-               dev_info(&card->dev->dev, "Port %d ATM state: %s\n",
-                        port, state_str);
-       else
-               dev_info(&card->dev->dev, "Port %d ATM state: %s (%d/%d kb/s, SNR %ddB, Attn %ddB)\n",
-                        port, state_str, rate_up/1000, rate_down/1000,
-                        snr, attn);
-
-       card->atmdev[port]->link_rate = rate_down;
-       card->atmdev[port]->signal = state;
+       dev_info(&card->dev->dev, "Port %d: %s @%d/%d kb/s%s%s%s%s\n",
+                port, state_str, rate_down/1000, rate_up/1000,
+                snr[0]?", SNR ":"", snr, attn[0]?", Attn ":"", attn);
+       
+       card->atmdev[port]->link_rate = rate_down / 424;
+       card->atmdev[port]->signal = ATM_PHY_SIG_FOUND;
 
        return 0;
 }
@@ -419,8 +462,6 @@ static int send_command(struct solos_card *card, int dev, const char *buf, size_
        struct sk_buff *skb;
        struct pkt_hdr *header;
 
-//     dev_dbg(&card->dev->dev, "size: %d\n", size);
-
        if (size > (BUF_SIZE - sizeof(*header))) {
                dev_dbg(&card->dev->dev, "Command is too big.  Dropping request\n");
                return 0;
@@ -490,12 +531,37 @@ static int flash_upgrade(struct solos_card *card, int chip)
        int numblocks = 0;
        int offset;
 
-       if (chip == 0) {
+       switch (chip) {
+       case 0:
                fw_name = "solos-FPGA.bin";
                blocksize = FPGA_BLOCK;
-       } else {
+               break;
+       case 1:
                fw_name = "solos-Firmware.bin";
                blocksize = SOLOS_BLOCK;
+               break;
+       case 2:
+               if (card->fpga_version > LEGACY_BUFFERS){
+                       fw_name = "solos-db-FPGA.bin";
+                       blocksize = FPGA_BLOCK;
+               } else {
+                       dev_info(&card->dev->dev, "FPGA version doesn't support"
+                                       " daughter board upgrades\n");
+                       return -EPERM;
+               }
+               break;
+       case 3:
+               if (card->fpga_version > LEGACY_BUFFERS){
+                       fw_name = "solos-Firmware.bin";
+                       blocksize = SOLOS_BLOCK;
+               } else {
+                       dev_info(&card->dev->dev, "FPGA version doesn't support"
+                                       " daughter board upgrades\n");
+                       return -EPERM;
+               }
+               break;
+       default:
+               return -ENODEV;
        }
 
        if (request_firmware(&fw, fw_name, &card->dev->dev))
@@ -512,8 +578,10 @@ static int flash_upgrade(struct solos_card *card, int chip)
        data32 = ioread32(card->config_regs + FPGA_MODE); 
 
        /* Set mode to Chip Erase */
-       dev_info(&card->dev->dev, "Set FPGA Flash mode to %s Chip Erase\n",
-                chip?"Solos":"FPGA");
+       if(chip == 0 || chip == 2)
+               dev_info(&card->dev->dev, "Set FPGA Flash mode to FPGA Chip Erase\n");
+       if(chip == 1 || chip == 3)
+               dev_info(&card->dev->dev, "Set FPGA Flash mode to Solos Chip Erase\n");
        iowrite32((chip * 2), card->config_regs + FLASH_MODE);
 
 
@@ -533,7 +601,10 @@ static int flash_upgrade(struct solos_card *card, int chip)
                /* Copy block to buffer, swapping each 16 bits */
                for(i = 0; i < blocksize; i += 4) {
                        uint32_t word = swahb32p((uint32_t *)(fw->data + offset + i));
-                       iowrite32(word, RX_BUF(card, 3) + i);
+                       if(card->fpga_version > LEGACY_BUFFERS)
+                               iowrite32(word, FLASH_BUF + i);
+                       else
+                               iowrite32(word, RX_BUF(card, 3) + i);
                }
 
                /* Specify block number and then trigger flash write */
@@ -555,77 +626,89 @@ static irqreturn_t solos_irq(int irq, void *dev_id)
        struct solos_card *card = dev_id;
        int handled = 1;
 
-       //ACK IRQ
        iowrite32(0, card->config_regs + IRQ_CLEAR);
-       //Disable IRQs from FPGA
-       iowrite32(0, card->config_regs + IRQ_EN_ADDR);
 
+       /* If we're up and running, just kick the tasklet to process TX/RX */
        if (card->atmdev[0])
                tasklet_schedule(&card->tlet);
        else
                wake_up(&card->fw_wq);
 
-       //Enable IRQs from FPGA
-       iowrite32(1, card->config_regs + IRQ_EN_ADDR);
        return IRQ_RETVAL(handled);
 }
 
 void solos_bh(unsigned long card_arg)
 {
        struct solos_card *card = (void *)card_arg;
-       int port;
        uint32_t card_flags;
-       uint32_t tx_mask;
        uint32_t rx_done = 0;
+       int port;
 
-       card_flags = ioread32(card->config_regs + FLAGS_ADDR);
-
-       /* The TX bits are set if the channel is busy; clear if not. We want to
-          invoke fpga_tx() unless _all_ the bits for active channels are set */
-       tx_mask = (1 << card->nr_ports) - 1;
-       if ((card_flags & tx_mask) != tx_mask)
-               fpga_tx(card);
+       /*
+        * Since fpga_tx() is going to need to read the flags under its lock,
+        * it can return them to us so that we don't have to hit PCI MMIO
+        * again for the same information
+        */
+       card_flags = fpga_tx(card);
 
        for (port = 0; port < card->nr_ports; port++) {
                if (card_flags & (0x10 << port)) {
-                       struct pkt_hdr header;
+                       struct pkt_hdr _hdr, *header;
                        struct sk_buff *skb;
                        struct atm_vcc *vcc;
                        int size;
 
-                       rx_done |= 0x10 << port;
+                       if (card->using_dma) {
+                               skb = card->rx_skb[port];
+                               card->rx_skb[port] = NULL;
 
-                       memcpy_fromio(&header, RX_BUF(card, port), sizeof(header));
+                               pci_unmap_single(card->dev, SKB_CB(skb)->dma_addr,
+                                                RX_DMA_SIZE, PCI_DMA_FROMDEVICE);
 
-                       size = le16_to_cpu(header.size);
+                               header = (void *)skb->data;
+                               size = le16_to_cpu(header->size);
+                               skb_put(skb, size + sizeof(*header));
+                               skb_pull(skb, sizeof(*header));
+                       } else {
+                               header = &_hdr;
 
-                       skb = alloc_skb(size + 1, GFP_ATOMIC);
-                       if (!skb) {
-                               if (net_ratelimit())
-                                       dev_warn(&card->dev->dev, "Failed to allocate sk_buff for RX\n");
-                               continue;
-                       }
+                               rx_done |= 0x10 << port;
+
+                               memcpy_fromio(header, RX_BUF(card, port), sizeof(*header));
 
-                       memcpy_fromio(skb_put(skb, size),
-                                     RX_BUF(card, port) + sizeof(header),
-                                     size);
+                               size = le16_to_cpu(header->size);
+                               if (size > (card->buffer_size - sizeof(*header))){
+                                       dev_warn(&card->dev->dev, "Invalid buffer size\n");
+                                       continue;
+                               }
 
+                               skb = alloc_skb(size + 1, GFP_ATOMIC);
+                               if (!skb) {
+                                       if (net_ratelimit())
+                                               dev_warn(&card->dev->dev, "Failed to allocate sk_buff for RX\n");
+                                       continue;
+                               }
+
+                               memcpy_fromio(skb_put(skb, size),
+                                             RX_BUF(card, port) + sizeof(*header),
+                                             size);
+                       }
                        if (atmdebug) {
                                dev_info(&card->dev->dev, "Received: device %d\n", port);
                                dev_info(&card->dev->dev, "size: %d VPI: %d VCI: %d\n",
-                                        size, le16_to_cpu(header.vpi),
-                                        le16_to_cpu(header.vci));
+                                        size, le16_to_cpu(header->vpi),
+                                        le16_to_cpu(header->vci));
                                print_buffer(skb);
                        }
 
-                       switch (le16_to_cpu(header.type)) {
+                       switch (le16_to_cpu(header->type)) {
                        case PKT_DATA:
-                               vcc = find_vcc(card->atmdev[port], le16_to_cpu(header.vpi),
-                                              le16_to_cpu(header.vci));
+                               vcc = find_vcc(card->atmdev[port], le16_to_cpu(header->vpi),
+                                              le16_to_cpu(header->vci));
                                if (!vcc) {
                                        if (net_ratelimit())
                                                dev_warn(&card->dev->dev, "Received packet for unknown VCI.VPI %d.%d on port %d\n",
-                                                        le16_to_cpu(header.vci), le16_to_cpu(header.vpi),
+                                                        le16_to_cpu(header->vci), le16_to_cpu(header->vpi),
                                                         port);
                                        continue;
                                }
@@ -635,8 +718,12 @@ void solos_bh(unsigned long card_arg)
                                break;
 
                        case PKT_STATUS:
-                               process_status(card, port, skb);
-                               dev_kfree_skb(skb);
+                               if (process_status(card, port, skb) &&
+                                   net_ratelimit()) {
+                                       dev_warn(&card->dev->dev, "Bad status packet of %d bytes on port %d:\n", skb->len, port);
+                                       print_buffer(skb);
+                               }
+                               dev_kfree_skb_any(skb);
                                break;
 
                        case PKT_COMMAND:
@@ -648,12 +735,32 @@ void solos_bh(unsigned long card_arg)
                                        if (net_ratelimit())
                                                dev_warn(&card->dev->dev, "Dropping console response on port %d\n",
                                                         port);
+                                       dev_kfree_skb_any(skb);
                                } else
                                        skb_queue_tail(&card->cli_queue[port], skb);
                                spin_unlock(&card->cli_queue_lock);
                                break;
                        }
                }
+               /* Allocate RX skbs for any ports which need them */
+               if (card->using_dma && card->atmdev[port] &&
+                   !card->rx_skb[port]) {
+                       struct sk_buff *skb = alloc_skb(RX_DMA_SIZE, GFP_ATOMIC);
+                       if (skb) {
+                               SKB_CB(skb)->dma_addr =
+                                       pci_map_single(card->dev, skb->data,
+                                                      RX_DMA_SIZE, PCI_DMA_FROMDEVICE);
+                               iowrite32(SKB_CB(skb)->dma_addr,
+                                         card->config_regs + RX_DMA_ADDR(port));
+                               card->rx_skb[port] = skb;
+                       } else {
+                               if (net_ratelimit())
+                                       dev_warn(&card->dev->dev, "Failed to allocate RX skb");
+
+                               /* We'll have to try again later */
+                               tasklet_schedule(&card->tlet);
+                       }
+               }
        }
        if (rx_done)
                iowrite32(rx_done, card->config_regs + FLAGS_ADDR);
@@ -768,8 +875,7 @@ static int popen(struct atm_vcc *vcc)
 
        fpga_queue(card, SOLOS_CHAN(vcc->dev), skb, NULL);
 
-//     dev_dbg(&card->dev->dev, "Open for vpi %d and vci %d on interface %d\n", vcc->vpi, vcc->vci, SOLOS_CHAN(vcc->dev));
-       set_bit(ATM_VF_ADDR, &vcc->flags); // accept the vpi / vci
+       set_bit(ATM_VF_ADDR, &vcc->flags);
        set_bit(ATM_VF_READY, &vcc->flags);
        list_vccs(0);
 
@@ -797,8 +903,6 @@ static void pclose(struct atm_vcc *vcc)
 
        fpga_queue(card, SOLOS_CHAN(vcc->dev), skb, NULL);
 
-//     dev_dbg(&card->dev->dev, "Close for vpi %d and vci %d on interface %d\n", vcc->vpi, vcc->vci, SOLOS_CHAN(vcc->dev));
-
        clear_bit(ATM_VF_ADDR, &vcc->flags);
        clear_bit(ATM_VF_READY, &vcc->flags);
 
@@ -838,22 +942,26 @@ static void fpga_queue(struct solos_card *card, int port, struct sk_buff *skb,
                       struct atm_vcc *vcc)
 {
        int old_len;
+       unsigned long flags;
 
-       *(void **)skb->cb = vcc;
+       SKB_CB(skb)->vcc = vcc;
 
-       spin_lock(&card->tx_queue_lock);
+       spin_lock_irqsave(&card->tx_queue_lock, flags);
        old_len = skb_queue_len(&card->tx_queue[port]);
        skb_queue_tail(&card->tx_queue[port], skb);
-       spin_unlock(&card->tx_queue_lock);
+       if (!old_len)
+               card->tx_mask |= (1 << port);
+       spin_unlock_irqrestore(&card->tx_queue_lock, flags);
 
-       /* If TX might need to be started, do so */
+       /* Theoretically we could just schedule the tasklet here, but
+          that introduces latency we don't want -- it's noticeable */
        if (!old_len)
                fpga_tx(card);
 }
 
-static int fpga_tx(struct solos_card *card)
+static uint32_t fpga_tx(struct solos_card *card)
 {
-       uint32_t tx_pending;
+       uint32_t tx_pending, card_flags;
        uint32_t tx_started = 0;
        struct sk_buff *skb;
        struct atm_vcc *vcc;
@@ -861,69 +969,75 @@ static int fpga_tx(struct solos_card *card)
        unsigned long flags;
 
        spin_lock_irqsave(&card->tx_lock, flags);
-
-       tx_pending = ioread32(card->config_regs + FLAGS_ADDR);
-
-       dev_vdbg(&card->dev->dev, "TX Flags are %X\n", tx_pending);
-
-       for (port = 0; port < card->nr_ports; port++) {
-               if (card->atmdev[port] && !(tx_pending & (1 << port))) {
+       
+       card_flags = ioread32(card->config_regs + FLAGS_ADDR);
+       /*
+        * The queue lock is required for _writing_ to tx_mask, but we're
+        * OK to read it here without locking. The only potential update
+        * that we could race with is in fpga_queue() where it sets a bit
+        * for a new port... but it's going to call this function again if
+        * it's doing that, anyway.
+        */
+       tx_pending = card->tx_mask & ~card_flags;
+
+       for (port = 0; tx_pending; tx_pending >>= 1, port++) {
+               if (tx_pending & 1) {
+                       struct sk_buff *oldskb = card->tx_skb[port];
+                       if (oldskb)
+                               pci_unmap_single(card->dev, SKB_CB(oldskb)->dma_addr,
+                                                oldskb->len, PCI_DMA_TODEVICE);
 
                        spin_lock(&card->tx_queue_lock);
                        skb = skb_dequeue(&card->tx_queue[port]);
+                       if (!skb)
+                               card->tx_mask &= ~(1 << port);
                        spin_unlock(&card->tx_queue_lock);
 
-                       if (!skb)
+                       if (skb && !card->using_dma) {
+                               memcpy_toio(TX_BUF(card, port), skb->data, skb->len);
+                               tx_started |= 1 << port;
+                               oldskb = skb; /* We're done with this skb already */
+                       } else if (skb && card->using_dma) {
+                               SKB_CB(skb)->dma_addr = pci_map_single(card->dev, skb->data,
+                                                                      skb->len, PCI_DMA_TODEVICE);
+                               iowrite32(SKB_CB(skb)->dma_addr,
+                                         card->config_regs + TX_DMA_ADDR(port));
+                       }
+
+                       if (!oldskb)
                                continue;
 
+                       /* Clean up and free oldskb now it's gone */
                        if (atmdebug) {
                                dev_info(&card->dev->dev, "Transmitted: port %d\n",
                                         port);
-                               print_buffer(skb);
+                               print_buffer(oldskb);
                        }
-                       memcpy_toio(TX_BUF(card, port), skb->data, skb->len);
 
-                       vcc = *(void **)skb->cb;
+                       vcc = SKB_CB(oldskb)->vcc;
 
                        if (vcc) {
                                atomic_inc(&vcc->stats->tx);
-                               solos_pop(vcc, skb);
+                               solos_pop(vcc, oldskb);
                        } else
-                               dev_kfree_skb_irq(skb);
+                               dev_kfree_skb_irq(oldskb);
 
-                       tx_started |= 1 << port; //Set TX full flag
                }
        }
+       /* For non-DMA TX, write the 'TX start' bit for all four ports simultaneously */
        if (tx_started)
                iowrite32(tx_started, card->config_regs + FLAGS_ADDR);
 
        spin_unlock_irqrestore(&card->tx_lock, flags);
-       return 0;
+       return card_flags;
 }
 
 static int psend(struct atm_vcc *vcc, struct sk_buff *skb)
 {
        struct solos_card *card = vcc->dev->dev_data;
-       struct sk_buff *skb2 = NULL;
        struct pkt_hdr *header;
        int pktlen;
 
-       //dev_dbg(&card->dev->dev, "psend called.\n");
-       //dev_dbg(&card->dev->dev, "dev,vpi,vci = %d,%d,%d\n",SOLOS_CHAN(vcc->dev),vcc->vpi,vcc->vci);
-
-       if (debug) {
-               skb2 = atm_alloc_charge(vcc, skb->len, GFP_ATOMIC);
-               if (skb2) {
-                       memcpy(skb2->data, skb->data, skb->len);
-                       skb_put(skb2, skb->len);
-                       vcc->push(vcc, skb2);
-                       atomic_inc(&vcc->stats->rx);
-               }
-               atomic_inc(&vcc->stats->tx);
-               solos_pop(vcc, skb);
-               return 0;
-       }
-
        pktlen = skb->len;
        if (pktlen > (BUF_SIZE - sizeof(*header))) {
                dev_warn(&card->dev->dev, "Length of PDU is too large. Dropping PDU.\n");
@@ -976,15 +1090,12 @@ static struct atmdev_ops fpga_ops = {
 
 static int fpga_probe(struct pci_dev *dev, const struct pci_device_id *id)
 {
-       int err, i;
+       int err;
        uint16_t fpga_ver;
        uint8_t major_ver, minor_ver;
        uint32_t data32;
        struct solos_card *card;
 
-       if (debug)
-               return 0;
-
        card = kzalloc(sizeof(*card), GFP_KERNEL);
        if (!card)
                return -ENOMEM;
@@ -999,6 +1110,12 @@ static int fpga_probe(struct pci_dev *dev, const struct pci_device_id *id)
                goto out;
        }
 
+       err = pci_set_dma_mask(dev, DMA_BIT_MASK(32));
+       if (err) {
+               dev_warn(&dev->dev, "Failed to set 32-bit DMA mask\n");
+               goto out;
+       }
+
        err = pci_request_regions(dev, "solos");
        if (err) {
                dev_warn(&dev->dev, "Failed to request regions\n");
@@ -1016,26 +1133,36 @@ static int fpga_probe(struct pci_dev *dev, const struct pci_device_id *id)
                goto out_unmap_config;
        }
 
-//     for(i=0;i<64 ;i+=4){
-//             data32=ioread32(card->buffers + i);
-//             dev_dbg(&card->dev->dev, "%08lX\n",(unsigned long)data32);
-//     }
+       if (reset) {
+               iowrite32(1, card->config_regs + FPGA_MODE);
+               data32 = ioread32(card->config_regs + FPGA_MODE); 
 
-       //Fill Config Mem with zeros
-       for(i = 0; i < 128; i += 4)
-               iowrite32(0, card->config_regs + i);
-
-       //Set RX empty flags
-       iowrite32(0xF0, card->config_regs + FLAGS_ADDR);
+               iowrite32(0, card->config_regs + FPGA_MODE);
+               data32 = ioread32(card->config_regs + FPGA_MODE); 
+       }
 
        data32 = ioread32(card->config_regs + FPGA_VER);
        fpga_ver = (data32 & 0x0000FFFF);
        major_ver = ((data32 & 0xFF000000) >> 24);
        minor_ver = ((data32 & 0x00FF0000) >> 16);
+       card->fpga_version = FPGA_VERSION(major_ver,minor_ver);
+       if (card->fpga_version > LEGACY_BUFFERS)
+               card->buffer_size = BUF_SIZE;
+       else
+               card->buffer_size = OLD_BUF_SIZE;
        dev_info(&dev->dev, "Solos FPGA Version %d.%02d svn-%d\n",
                 major_ver, minor_ver, fpga_ver);
 
-       card->nr_ports = 2; /* FIXME: Detect daughterboard */
+       if (card->fpga_version >= DMA_SUPPORTED){
+               card->using_dma = 1;
+       } else {
+               card->using_dma = 0;
+               /* Set RX empty flag for all ports */
+               iowrite32(0xF0, card->config_regs + FLAGS_ADDR);
+       }
+
+       data32 = ioread32(card->config_regs + PORTS);
+       card->nr_ports = (data32 & 0x000000FF);
 
        pci_set_drvdata(dev, card);
 
@@ -1046,41 +1173,13 @@ static int fpga_probe(struct pci_dev *dev, const struct pci_device_id *id)
        spin_lock_init(&card->param_queue_lock);
        INIT_LIST_HEAD(&card->param_queue);
 
-/*
-       // Set Loopback mode
-       data32 = 0x00010000;
-       iowrite32(data32,card->config_regs + FLAGS_ADDR);
-*/
-/*
-       // Fill Buffers with zeros
-       for (i = 0; i < BUF_SIZE * 8; i += 4)
-               iowrite32(0, card->buffers + i);
-*/
-/*
-       for(i = 0; i < (BUF_SIZE * 1); i += 4)
-               iowrite32(0x12345678, card->buffers + i + (0*BUF_SIZE));
-       for(i = 0; i < (BUF_SIZE * 1); i += 4)
-               iowrite32(0xabcdef98, card->buffers + i + (1*BUF_SIZE));
-
-       // Read Config Memory
-       printk(KERN_DEBUG "Reading Config MEM\n");
-       i = 0;
-       for(i = 0; i < 16; i++) {
-               data32=ioread32(card->buffers + i*(BUF_SIZE/2));
-               printk(KERN_ALERT "Addr: %lX Data: %08lX\n",
-                      (unsigned long)(addr_start + i*(BUF_SIZE/2)),
-                      (unsigned long)data32);
-       }
-*/
-       //dev_dbg(&card->dev->dev, "Requesting IRQ: %d\n",dev->irq);
-       err = request_irq(dev->irq, solos_irq, IRQF_DISABLED|IRQF_SHARED,
+       err = request_irq(dev->irq, solos_irq, IRQF_SHARED,
                          "solos-pci", card);
        if (err) {
                dev_dbg(&card->dev->dev, "Failed to request interrupt IRQ: %d\n", dev->irq);
                goto out_unmap_both;
        }
 
-       // Enable IRQs
        iowrite32(1, card->config_regs + IRQ_EN_ADDR);
 
        if (fpga_upgrade)
@@ -1089,6 +1188,12 @@ static int fpga_probe(struct pci_dev *dev, const struct pci_device_id *id)
        if (firmware_upgrade)
                flash_upgrade(card, 1);
 
+       if (db_fpga_upgrade)
+               flash_upgrade(card, 2);
+
+       if (db_firmware_upgrade)
+               flash_upgrade(card, 3);
+
        err = atm_init(card);
        if (err)
                goto out_free_irq;
@@ -1108,6 +1213,7 @@ static int fpga_probe(struct pci_dev *dev, const struct pci_device_id *id)
  out_release_regions:
        pci_release_regions(dev);
  out:
+       kfree(card);
        return err;
 }
 
@@ -1165,8 +1271,28 @@ static void atm_remove(struct solos_card *card)
 
        for (i = 0; i < card->nr_ports; i++) {
                if (card->atmdev[i]) {
+                       struct sk_buff *skb;
+
                        dev_info(&card->dev->dev, "Unregistering ATM device %d\n", card->atmdev[i]->number);
+
+                       sysfs_remove_group(&card->atmdev[i]->class_dev.kobj, &solos_attr_group);
                        atm_dev_deregister(card->atmdev[i]);
+
+                       skb = card->rx_skb[i];
+                       if (skb) {
+                               pci_unmap_single(card->dev, SKB_CB(skb)->dma_addr,
+                                                RX_DMA_SIZE, PCI_DMA_FROMDEVICE);
+                               dev_kfree_skb(skb);
+                       }
+                       skb = card->tx_skb[i];
+                       if (skb) {
+                               pci_unmap_single(card->dev, SKB_CB(skb)->dma_addr,
+                                                skb->len, PCI_DMA_TODEVICE);
+                               dev_kfree_skb(skb);
+                       }
+                       while ((skb = skb_dequeue(&card->tx_queue[i])))
+                               dev_kfree_skb(skb);
                }
        }
 }
@@ -1174,31 +1300,31 @@ static void atm_remove(struct solos_card *card)
 static void fpga_remove(struct pci_dev *dev)
 {
        struct solos_card *card = pci_get_drvdata(dev);
+       
+       /* Disable IRQs */
+       iowrite32(0, card->config_regs + IRQ_EN_ADDR);
 
-       if (debug)
-               return;
+       /* Reset FPGA */
+       iowrite32(1, card->config_regs + FPGA_MODE);
+       (void)ioread32(card->config_regs + FPGA_MODE); 
 
        atm_remove(card);
 
-       dev_vdbg(&dev->dev, "Freeing IRQ\n");
-       // Disable IRQs from FPGA
-       iowrite32(0, card->config_regs + IRQ_EN_ADDR);
        free_irq(dev->irq, card);
        tasklet_kill(&card->tlet);
 
-       //      iowrite32(0x01,pciregs);
-       dev_vdbg(&dev->dev, "Unmapping PCI resource\n");
+       /* Release device from reset */
+       iowrite32(0, card->config_regs + FPGA_MODE);
+       (void)ioread32(card->config_regs + FPGA_MODE); 
+
        pci_iounmap(dev, card->buffers);
        pci_iounmap(dev, card->config_regs);
 
-       dev_vdbg(&dev->dev, "Releasing PCI Region\n");
        pci_release_regions(dev);
        pci_disable_device(dev);
 
        pci_set_drvdata(dev, NULL);
        kfree(card);
-//     dev_dbg(&card->dev->dev, "fpga_remove\n");
-       return;
 }
 
 static struct pci_device_id fpga_pci_tbl[] __devinitdata = {