Linux-2.6.12-rc2v2.6.12-rc2

Initial git repository build. I'm not bothering with the full history,
even though we have it. We can create a separate "historical" git
archive of that later if we want to, and in the meantime it's about
3.2GB when imported into git - space that would just make the early
git days unnecessarily complicated, when we don't have a lot of good
infrastructure for it.

Let it rip!

1 files changed, 877 insertions, 0 deletions

diff --git a/drivers/usb/media/dabusb.c b/drivers/usb/media/dabusb.c
new file mode 100644
index 000000000000..8823297d2191
--- /dev/null
+++ b/drivers/usb/media/dabusb.c
@@ -0,0 +1,877 @@
+/*****************************************************************************/
+
+/*
+ *      dabusb.c  --  dab usb driver.
+ *
+ *      Copyright (C) 1999  Deti Fliegl (deti@fliegl.de)
+ *
+ *      This program is free software; you can redistribute it and/or modify
+ *      it under the terms of the GNU General Public License as published by
+ *      the Free Software Foundation; either version 2 of the License, or
+ *      (at your option) any later version.
+ *
+ *      This program is distributed in the hope that it will be useful,
+ *      but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *      MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *      GNU General Public License for more details.
+ *
+ *      You should have received a copy of the GNU General Public License
+ *      along with this program; if not, write to the Free Software
+ *      Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
+ *
+ *
+ *
+ *  $Id: dabusb.c,v 1.54 2000/07/24 21:39:39 deti Exp $
+ *
+ */
+
+/*****************************************************************************/
+
+#include <linux/module.h>
+#include <linux/socket.h>
+#include <linux/list.h>
+#include <linux/vmalloc.h>
+#include <linux/slab.h>
+#include <linux/init.h>
+#include <asm/uaccess.h>
+#include <asm/atomic.h>
+#include <linux/delay.h>
+#include <linux/usb.h>
+#include <linux/smp_lock.h>
+
+#include "dabusb.h"
+#include "dabfirmware.h"
+
+/*
+ * Version Information
+ */
+#define DRIVER_VERSION "v1.54"
+#define DRIVER_AUTHOR "Deti Fliegl, deti@fliegl.de"
+#define DRIVER_DESC "DAB-USB Interface Driver for Linux (c)1999"
+
+/* --------------------------------------------------------------------- */
+
+#ifdef CONFIG_USB_DYNAMIC_MINORS
+#define NRDABUSB 256
+#else
+#define NRDABUSB 4
+#endif
+
+/*-------------------------------------------------------------------*/
+
+static dabusb_t dabusb[NRDABUSB];
+static int buffers = 256;
+static struct usb_driver dabusb_driver;
+
+/*-------------------------------------------------------------------*/
+
+static int dabusb_add_buf_tail (pdabusb_t s, struct list_head *dst, struct list_head *src)
+{
+        unsigned long flags;
+        struct list_head *tmp;
+        int ret = 0;
+
+        spin_lock_irqsave (&s->lock, flags);
+
+        if (list_empty (src)) {
+                // no elements in source buffer
+                ret = -1;
+                goto err;
+        }
+        tmp = src->next;
+        list_move_tail (tmp, dst);
+
+  err:  spin_unlock_irqrestore (&s->lock, flags);
+        return ret;
+}
+/*-------------------------------------------------------------------*/
+#ifdef DEBUG 
+static void dump_urb (struct urb *urb)
+{
+        dbg("urb                   :%p", urb);
+        dbg("dev                   :%p", urb->dev);
+        dbg("pipe                  :%08X", urb->pipe);
+        dbg("status                :%d", urb->status);
+        dbg("transfer_flags        :%08X", urb->transfer_flags);
+        dbg("transfer_buffer       :%p", urb->transfer_buffer);
+        dbg("transfer_buffer_length:%d", urb->transfer_buffer_length);
+        dbg("actual_length         :%d", urb->actual_length);
+        dbg("setup_packet          :%p", urb->setup_packet);
+        dbg("start_frame           :%d", urb->start_frame);
+        dbg("number_of_packets     :%d", urb->number_of_packets);
+        dbg("interval              :%d", urb->interval);
+        dbg("error_count           :%d", urb->error_count);
+        dbg("context               :%p", urb->context);
+        dbg("complete              :%p", urb->complete);
+}
+#endif
+/*-------------------------------------------------------------------*/
+static int dabusb_cancel_queue (pdabusb_t s, struct list_head *q)
+{
+        unsigned long flags;
+        pbuff_t b;
+
+        dbg("dabusb_cancel_queue");
+
+        spin_lock_irqsave (&s->lock, flags);
+
+        list_for_each_entry(b, q, buff_list) {
+#ifdef DEBUG
+                dump_urb(b->purb);
+#endif
+                usb_unlink_urb (b->purb);
+        }
+        spin_unlock_irqrestore (&s->lock, flags);
+        return 0;
+}
+/*-------------------------------------------------------------------*/
+static int dabusb_free_queue (struct list_head *q)
+{
+        struct list_head *tmp;
+        struct list_head *p;
+        pbuff_t b;
+
+        dbg("dabusb_free_queue");
+        for (p = q->next; p != q;) {
+                b = list_entry (p, buff_t, buff_list);
+
+#ifdef DEBUG 
+                dump_urb(b->purb);
+#endif
+                if (b->purb->transfer_buffer)
+                        kfree (b->purb->transfer_buffer);
+                usb_free_urb(b->purb);
+                tmp = p->next;
+                list_del (p);
+                kfree (b);
+                p = tmp;
+        }
+
+        return 0;
+}
+/*-------------------------------------------------------------------*/
+static int dabusb_free_buffers (pdabusb_t s)
+{
+        unsigned long flags;
+        dbg("dabusb_free_buffers");
+
+        spin_lock_irqsave(&s->lock, flags);
+
+        dabusb_free_queue (&s->free_buff_list);
+        dabusb_free_queue (&s->rec_buff_list);
+
+        spin_unlock_irqrestore(&s->lock, flags);
+
+        s->got_mem = 0;
+        return 0;
+}
+/*-------------------------------------------------------------------*/
+static void dabusb_iso_complete (struct urb *purb, struct pt_regs *regs)
+{
+        pbuff_t b = purb->context;
+        pdabusb_t s = b->s;
+        int i;
+        int len;
+        int dst = 0;
+        void *buf = purb->transfer_buffer;
+
+        dbg("dabusb_iso_complete");
+
+        // process if URB was not killed
+        if (purb->status != -ENOENT) {
+                unsigned int pipe = usb_rcvisocpipe (purb->dev, _DABUSB_ISOPIPE);
+                int pipesize = usb_maxpacket (purb->dev, pipe, usb_pipeout (pipe));
+                for (i = 0; i < purb->number_of_packets; i++)
+                        if (!purb->iso_frame_desc[i].status) {
+                                len = purb->iso_frame_desc[i].actual_length;
+                                if (len <= pipesize) {
+                                        memcpy (buf + dst, buf + purb->iso_frame_desc[i].offset, len);
+                                        dst += len;
+                                }
+                                else
+                                        err("dabusb_iso_complete: invalid len %d", len);
+                        }
+                        else
+                                warn("dabusb_iso_complete: corrupted packet status: %d", purb->iso_frame_desc[i].status);
+                if (dst != purb->actual_length)
+                        err("dst!=purb->actual_length:%d!=%d", dst, purb->actual_length);
+        }
+
+        if (atomic_dec_and_test (&s->pending_io) && !s->remove_pending && s->state != _stopped) {
+                s->overruns++;
+                err("overrun (%d)", s->overruns);
+        }
+        wake_up (&s->wait);
+}
+/*-------------------------------------------------------------------*/
+static int dabusb_alloc_buffers (pdabusb_t s)
+{
+        int buffers = 0;
+        pbuff_t b;
+        unsigned int pipe = usb_rcvisocpipe (s->usbdev, _DABUSB_ISOPIPE);
+        int pipesize = usb_maxpacket (s->usbdev, pipe, usb_pipeout (pipe));
+        int packets = _ISOPIPESIZE / pipesize;
+        int transfer_buffer_length = packets * pipesize;
+        int i;
+
+        dbg("dabusb_alloc_buffers pipesize:%d packets:%d transfer_buffer_len:%d",
+                 pipesize, packets, transfer_buffer_length);
+
+        while (buffers < (s->total_buffer_size << 10)) {
+                b = (pbuff_t) kmalloc (sizeof (buff_t), GFP_KERNEL);
+                if (!b) {
+                        err("kmalloc(sizeof(buff_t))==NULL");
+                        goto err;
+                }
+                memset (b, 0, sizeof (buff_t));
+                b->s = s;
+                b->purb = usb_alloc_urb(packets, GFP_KERNEL);
+                if (!b->purb) {
+                        err("usb_alloc_urb == NULL");
+                        kfree (b);
+                        goto err;
+                }
+
+                b->purb->transfer_buffer = kmalloc (transfer_buffer_length, GFP_KERNEL);
+                if (!b->purb->transfer_buffer) {
+                        kfree (b->purb);
+                        kfree (b);
+                        err("kmalloc(%d)==NULL", transfer_buffer_length);
+                        goto err;
+                }
+
+                b->purb->transfer_buffer_length = transfer_buffer_length;
+                b->purb->number_of_packets = packets;
+                b->purb->complete = dabusb_iso_complete;
+                b->purb->context = b;
+                b->purb->dev = s->usbdev;
+                b->purb->pipe = pipe;
+                b->purb->transfer_flags = URB_ISO_ASAP;
+
+                for (i = 0; i < packets; i++) {
+                        b->purb->iso_frame_desc[i].offset = i * pipesize;
+                        b->purb->iso_frame_desc[i].length = pipesize;
+                }
+
+                buffers += transfer_buffer_length;
+                list_add_tail (&b->buff_list, &s->free_buff_list);
+        }
+        s->got_mem = buffers;
+
+        return 0;
+
+        err:
+        dabusb_free_buffers (s);
+        return -ENOMEM;
+}
+/*-------------------------------------------------------------------*/
+static int dabusb_bulk (pdabusb_t s, pbulk_transfer_t pb)
+{
+        int ret;
+        unsigned int pipe;
+        int actual_length;
+
+        dbg("dabusb_bulk");
+
+        if (!pb->pipe)
+                pipe = usb_rcvbulkpipe (s->usbdev, 2);
+        else
+                pipe = usb_sndbulkpipe (s->usbdev, 2);
+
+        ret=usb_bulk_msg(s->usbdev, pipe, pb->data, pb->size, &actual_length, 100);
+        if(ret<0) {
+                err("dabusb: usb_bulk_msg failed(%d)",ret);
+
+                if (usb_set_interface (s->usbdev, _DABUSB_IF, 1) < 0) {
+                        err("set_interface failed");
+                        return -EINVAL;
+                }
+
+        }
+        
+        if( ret == -EPIPE ) {
+                warn("CLEAR_FEATURE request to remove STALL condition.");
+                if(usb_clear_halt(s->usbdev, usb_pipeendpoint(pipe)))
+                        err("request failed");
+        }
+
+        pb->size = actual_length;
+        return ret;
+}
+/* --------------------------------------------------------------------- */
+static int dabusb_writemem (pdabusb_t s, int pos, unsigned char *data, int len)
+{
+        int ret;
+        unsigned char *transfer_buffer =  kmalloc (len, GFP_KERNEL);
+
+        if (!transfer_buffer) {
+                err("dabusb_writemem: kmalloc(%d) failed.", len);
+                return -ENOMEM;
+        }
+
+        memcpy (transfer_buffer, data, len);
+
+        ret=usb_control_msg(s->usbdev, usb_sndctrlpipe( s->usbdev, 0 ), 0xa0, 0x40, pos, 0, transfer_buffer, len, 300);
+
+        kfree (transfer_buffer);
+        return ret;
+}
+/* --------------------------------------------------------------------- */
+static int dabusb_8051_reset (pdabusb_t s, unsigned char reset_bit)
+{
+        dbg("dabusb_8051_reset: %d",reset_bit);
+        return dabusb_writemem (s, CPUCS_REG, &reset_bit, 1);
+}
+/* --------------------------------------------------------------------- */
+static int dabusb_loadmem (pdabusb_t s, const char *fname)
+{
+        int ret;
+        PINTEL_HEX_RECORD ptr = firmware;
+
+        dbg("Enter dabusb_loadmem (internal)");
+        
+        ret = dabusb_8051_reset (s, 1);
+        while (ptr->Type == 0) {
+
+                dbg("dabusb_writemem: %04X %p %d)", ptr->Address, ptr->Data, ptr->Length);
+
+                ret = dabusb_writemem (s, ptr->Address, ptr->Data, ptr->Length);
+                if (ret < 0) {
+                        err("dabusb_writemem failed (%d %04X %p %d)", ret, ptr->Address, ptr->Data, ptr->Length);
+                        break;
+                }
+                ptr++;
+        }
+        ret = dabusb_8051_reset (s, 0);
+
+        dbg("dabusb_loadmem: exit");
+
+        return ret;
+}
+/* --------------------------------------------------------------------- */
+static int dabusb_fpga_clear (pdabusb_t s, pbulk_transfer_t b)
+{
+        b->size = 4;
+        b->data[0] = 0x2a;
+        b->data[1] = 0;
+        b->data[2] = 0;
+        b->data[3] = 0;
+
+        dbg("dabusb_fpga_clear");
+
+        return dabusb_bulk (s, b);
+}
+/* --------------------------------------------------------------------- */
+static int dabusb_fpga_init (pdabusb_t s, pbulk_transfer_t b)
+{
+        b->size = 4;
+        b->data[0] = 0x2c;
+        b->data[1] = 0;
+        b->data[2] = 0;
+        b->data[3] = 0;
+
+        dbg("dabusb_fpga_init");
+
+        return dabusb_bulk (s, b);
+}
+/* --------------------------------------------------------------------- */
+static int dabusb_fpga_download (pdabusb_t s, const char *fname)
+{
+        pbulk_transfer_t b = kmalloc (sizeof (bulk_transfer_t), GFP_KERNEL);
+        unsigned int blen, n;
+        int ret;
+        unsigned char *buf = bitstream;
+
+        dbg("Enter dabusb_fpga_download (internal)");
+
+        if (!b) {
+                err("kmalloc(sizeof(bulk_transfer_t))==NULL");
+                return -ENOMEM;
+        }
+
+        b->pipe = 1;
+        ret = dabusb_fpga_clear (s, b);
+        mdelay (10);
+        blen = buf[73] + (buf[72] << 8);
+
+        dbg("Bitstream len: %i", blen);
+
+        b->data[0] = 0x2b;
+        b->data[1] = 0;
+        b->data[2] = 0;
+        b->data[3] = 60;
+
+        for (n = 0; n <= blen + 60; n += 60) {
+                // some cclks for startup
+                b->size = 64;
+                memcpy (b->data + 4, buf + 74 + n, 60);
+                ret = dabusb_bulk (s, b);
+                if (ret < 0) {
+                        err("dabusb_bulk failed.");
+                        break;
+                }
+                mdelay (1);
+        }
+
+        ret = dabusb_fpga_init (s, b);
+        kfree (b);
+
+        dbg("exit dabusb_fpga_download");
+
+        return ret;
+}
+
+static int dabusb_stop (pdabusb_t s)
+{
+        dbg("dabusb_stop");
+
+        s->state = _stopped;
+        dabusb_cancel_queue (s, &s->rec_buff_list);
+
+        dbg("pending_io: %d", s->pending_io.counter);
+
+        s->pending_io.counter = 0;
+        return 0;
+}
+
+static int dabusb_startrek (pdabusb_t s)
+{
+        if (!s->got_mem && s->state != _started) {
+
+                dbg("dabusb_startrek");
+
+                if (dabusb_alloc_buffers (s) < 0)
+                        return -ENOMEM;
+                dabusb_stop (s);
+                s->state = _started;
+                s->readptr = 0;
+        }
+
+        if (!list_empty (&s->free_buff_list)) {
+                pbuff_t end;
+                int ret;
+                
+        while (!dabusb_add_buf_tail (s, &s->rec_buff_list, &s->free_buff_list)) {
+
+                        dbg("submitting: end:%p s->rec_buff_list:%p", s->rec_buff_list.prev, &s->rec_buff_list);
+
+                        end = list_entry (s->rec_buff_list.prev, buff_t, buff_list);
+
+                        ret = usb_submit_urb (end->purb, GFP_KERNEL);
+                        if (ret) {
+                                err("usb_submit_urb returned:%d", ret);
+                                if (dabusb_add_buf_tail (s, &s->free_buff_list, &s->rec_buff_list))
+                                        err("startrek: dabusb_add_buf_tail failed");
+                                break;
+                        }
+                        else
+                                atomic_inc (&s->pending_io);
+                }
+                dbg("pending_io: %d",s->pending_io.counter);
+        }
+
+        return 0;
+}
+
+static ssize_t dabusb_read (struct file *file, char __user *buf, size_t count, loff_t * ppos)
+{
+        pdabusb_t s = (pdabusb_t) file->private_data;
+        unsigned long flags;
+        unsigned ret = 0;
+        int rem;
+        int cnt;
+        pbuff_t b;
+        struct urb *purb = NULL;
+
+        dbg("dabusb_read");
+
+        if (*ppos)
+                return -ESPIPE;
+
+        if (s->remove_pending)
+                return -EIO;
+
+
+        if (!s->usbdev)
+                return -EIO;
+
+        while (count > 0) {
+                dabusb_startrek (s);
+
+                spin_lock_irqsave (&s->lock, flags);
+
+                if (list_empty (&s->rec_buff_list)) {
+
+                        spin_unlock_irqrestore(&s->lock, flags);
+
+                        err("error: rec_buf_list is empty");
+                        goto err;
+                }
+                
+                b = list_entry (s->rec_buff_list.next, buff_t, buff_list);
+                purb = b->purb;
+
+                spin_unlock_irqrestore(&s->lock, flags);
+
+                if (purb->status == -EINPROGRESS) {
+                        if (file->f_flags & O_NONBLOCK)         // return nonblocking
+                         {
+                                if (!ret)
+                                        ret = -EAGAIN;
+                                goto err;
+                        }
+
+                        interruptible_sleep_on (&s->wait);
+
+                        if (signal_pending (current)) {
+                                if (!ret)
+                                        ret = -ERESTARTSYS;
+                                goto err;
+                        }
+
+                        spin_lock_irqsave (&s->lock, flags);
+
+                        if (list_empty (&s->rec_buff_list)) {
+                                spin_unlock_irqrestore(&s->lock, flags);
+                                err("error: still no buffer available.");
+                                goto err;
+                        }
+                        spin_unlock_irqrestore(&s->lock, flags);
+                        s->readptr = 0;
+                }
+                if (s->remove_pending) {
+                        ret = -EIO;
+                        goto err;
+                }
+
+                rem = purb->actual_length - s->readptr;         // set remaining bytes to copy
+
+                if (count >= rem)
+                        cnt = rem;
+                else
+                        cnt = count;
+
+                dbg("copy_to_user:%p %p %d",buf, purb->transfer_buffer + s->readptr, cnt);
+
+                if (copy_to_user (buf, purb->transfer_buffer + s->readptr, cnt)) {
+                        err("read: copy_to_user failed");
+                        if (!ret)
+                                ret = -EFAULT;
+                        goto err;
+                }
+
+                s->readptr += cnt;
+                count -= cnt;
+                buf += cnt;
+                ret += cnt;
+
+                if (s->readptr == purb->actual_length) {
+                        // finished, take next buffer
+                        if (dabusb_add_buf_tail (s, &s->free_buff_list, &s->rec_buff_list))
+                                err("read: dabusb_add_buf_tail failed");
+                        s->readptr = 0;
+                }
+        }
+      err:                      //up(&s->mutex);
+        return ret;
+}
+
+static int dabusb_open (struct inode *inode, struct file *file)
+{
+        int devnum = iminor(inode);
+        pdabusb_t s;
+
+        if (devnum < DABUSB_MINOR || devnum >= (DABUSB_MINOR + NRDABUSB))
+                return -EIO;
+
+        s = &dabusb[devnum - DABUSB_MINOR];
+
+        dbg("dabusb_open");
+        down (&s->mutex);
+
+        while (!s->usbdev || s->opened) {
+                up (&s->mutex);
+
+                if (file->f_flags & O_NONBLOCK) {
+                        return -EBUSY;
+                }
+                msleep_interruptible(500);
+
+                if (signal_pending (current)) {
+                        return -EAGAIN;
+                }
+                down (&s->mutex);
+        }
+        if (usb_set_interface (s->usbdev, _DABUSB_IF, 1) < 0) {
+                up(&s->mutex);
+                err("set_interface failed");
+                return -EINVAL;
+        }
+        s->opened = 1;
+        up (&s->mutex);
+
+        file->f_pos = 0;
+        file->private_data = s;
+
+        return nonseekable_open(inode, file);
+}
+
+static int dabusb_release (struct inode *inode, struct file *file)
+{
+        pdabusb_t s = (pdabusb_t) file->private_data;
+
+        dbg("dabusb_release");
+
+        down (&s->mutex);
+        dabusb_stop (s);
+        dabusb_free_buffers (s);
+        up (&s->mutex);
+
+        if (!s->remove_pending) {
+                if (usb_set_interface (s->usbdev, _DABUSB_IF, 0) < 0)
+                        err("set_interface failed");
+        }
+        else
+                wake_up (&s->remove_ok);
+
+        s->opened = 0;
+        return 0;
+}
+
+static int dabusb_ioctl (struct inode *inode, struct file *file, unsigned int cmd, unsigned long arg)
+{
+        pdabusb_t s = (pdabusb_t) file->private_data;
+        pbulk_transfer_t pbulk;
+        int ret = 0;
+        int version = DABUSB_VERSION;
+
+        dbg("dabusb_ioctl");
+
+        if (s->remove_pending)
+                return -EIO;
+
+        down (&s->mutex);
+
+        if (!s->usbdev) {
+                up (&s->mutex);
+                return -EIO;
+        }
+
+        switch (cmd) {
+
+        case IOCTL_DAB_BULK:
+                pbulk = (pbulk_transfer_t) kmalloc (sizeof (bulk_transfer_t), GFP_KERNEL);
+
+                if (!pbulk) {
+                        ret = -ENOMEM;
+                        break;
+                }
+
+                if (copy_from_user (pbulk, (void __user *) arg, sizeof (bulk_transfer_t))) {
+                        ret = -EFAULT;
+                        kfree (pbulk);
+                        break;
+                }
+
+                ret=dabusb_bulk (s, pbulk);
+                if(ret==0)
+                        if (copy_to_user((void __user *)arg, pbulk,
+                                         sizeof(bulk_transfer_t)))
+                                ret = -EFAULT;
+                kfree (pbulk);
+                break;
+
+        case IOCTL_DAB_OVERRUNS:
+                ret = put_user (s->overruns, (unsigned int __user *) arg);
+                break;
+
+        case IOCTL_DAB_VERSION:
+                ret = put_user (version, (unsigned int __user *) arg);
+                break;
+
+        default:
+                ret = -ENOIOCTLCMD;
+                break;
+        }
+        up (&s->mutex);
+        return ret;
+}
+
+static struct file_operations dabusb_fops =
+{
+        .owner =        THIS_MODULE,
+        .llseek =       no_llseek,
+        .read =         dabusb_read,
+        .ioctl =        dabusb_ioctl,
+        .open =         dabusb_open,
+        .release =      dabusb_release,
+};
+
+static struct usb_class_driver dabusb_class = {
+        .name =         "usb/dabusb%d",
+        .fops =         &dabusb_fops,
+        .mode =         S_IFCHR | S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP,
+        .minor_base =   DABUSB_MINOR,
+};
+
+
+/* --------------------------------------------------------------------- */
+static int dabusb_probe (struct usb_interface *intf,
+                         const struct usb_device_id *id)
+{
+        struct usb_device *usbdev = interface_to_usbdev(intf);
+        int retval;
+        pdabusb_t s;
+
+        dbg("dabusb: probe: vendor id 0x%x, device id 0x%x ifnum:%d",
+            le16_to_cpu(usbdev->descriptor.idVendor),
+            le16_to_cpu(usbdev->descriptor.idProduct),
+            intf->altsetting->desc.bInterfaceNumber);
+
+        /* We don't handle multiple configurations */
+        if (usbdev->descriptor.bNumConfigurations != 1)
+                return -ENODEV;
+
+        if (intf->altsetting->desc.bInterfaceNumber != _DABUSB_IF &&
+            le16_to_cpu(usbdev->descriptor.idProduct) == 0x9999)
+                return -ENODEV;
+
+
+
+        s = &dabusb[intf->minor];
+
+        down (&s->mutex);
+        s->remove_pending = 0;
+        s->usbdev = usbdev;
+        s->devnum = intf->minor;
+
+        if (usb_reset_configuration (usbdev) < 0) {
+                err("reset_configuration failed");
+                goto reject;
+        }
+        if (le16_to_cpu(usbdev->descriptor.idProduct) == 0x2131) {
+                dabusb_loadmem (s, NULL);
+                goto reject;
+        }
+        else {
+                dabusb_fpga_download (s, NULL);
+
+                if (usb_set_interface (s->usbdev, _DABUSB_IF, 0) < 0) {
+                        err("set_interface failed");
+                        goto reject;
+                }
+        }
+        dbg("bound to interface: %d", intf->altsetting->desc.bInterfaceNumber);
+        usb_set_intfdata (intf, s);
+        up (&s->mutex);
+
+        retval = usb_register_dev(intf, &dabusb_class);
+        if (retval) {
+                usb_set_intfdata (intf, NULL);
+                return -ENOMEM;
+        }
+
+        return 0;
+
+      reject:
+        up (&s->mutex);
+        s->usbdev = NULL;
+        return -ENODEV;
+}
+
+static void dabusb_disconnect (struct usb_interface *intf)
+{
+        wait_queue_t __wait;
+        pdabusb_t s = usb_get_intfdata (intf);
+
+        dbg("dabusb_disconnect");
+        
+        init_waitqueue_entry(&__wait, current);
+        
+        usb_set_intfdata (intf, NULL);
+        if (s) {
+                usb_deregister_dev (intf, &dabusb_class);
+                s->remove_pending = 1;
+                wake_up (&s->wait);
+                add_wait_queue(&s->remove_ok, &__wait);
+                set_current_state(TASK_UNINTERRUPTIBLE);
+                if (s->state == _started)
+                        schedule();
+                current->state = TASK_RUNNING;
+                remove_wait_queue(&s->remove_ok, &__wait);
+                
+                s->usbdev = NULL;
+                s->overruns = 0;
+        }
+}
+
+static struct usb_device_id dabusb_ids [] = {
+        // { USB_DEVICE(0x0547, 0x2131) },      /* An2131 chip, no boot ROM */
+        { USB_DEVICE(0x0547, 0x9999) },
+        { }                                             /* Terminating entry */
+};
+
+MODULE_DEVICE_TABLE (usb, dabusb_ids);
+
+static struct usb_driver dabusb_driver = {
+        .owner =        THIS_MODULE,
+        .name =         "dabusb",
+        .probe =        dabusb_probe,
+        .disconnect =   dabusb_disconnect,
+        .id_table =     dabusb_ids,
+};
+
+/* --------------------------------------------------------------------- */
+
+static int __init dabusb_init (void)
+{
+        int retval;
+        unsigned u;
+
+        /* initialize struct */
+        for (u = 0; u < NRDABUSB; u++) {
+                pdabusb_t s = &dabusb[u];
+                memset (s, 0, sizeof (dabusb_t));
+                init_MUTEX (&s->mutex);
+                s->usbdev = NULL;
+                s->total_buffer_size = buffers;
+                init_waitqueue_head (&s->wait);
+                init_waitqueue_head (&s->remove_ok);
+                spin_lock_init (&s->lock);
+                INIT_LIST_HEAD (&s->free_buff_list);
+                INIT_LIST_HEAD (&s->rec_buff_list);
+        }
+
+        /* register misc device */
+        retval = usb_register(&dabusb_driver);
+        if (retval)
+                goto out;
+
+        dbg("dabusb_init: driver registered");
+
+        info(DRIVER_VERSION ":" DRIVER_DESC);
+
+out:
+        return retval;
+}
+
+static void __exit dabusb_cleanup (void)
+{
+        dbg("dabusb_cleanup");
+
+        usb_deregister (&dabusb_driver);
+}
+
+/* --------------------------------------------------------------------- */
+
+MODULE_AUTHOR( DRIVER_AUTHOR );
+MODULE_DESCRIPTION( DRIVER_DESC );
+MODULE_LICENSE("GPL");
+
+module_param(buffers, int, 0);
+MODULE_PARM_DESC (buffers, "Number of buffers (default=256)");
+
+module_init (dabusb_init);
+module_exit (dabusb_cleanup);
+
+/* --------------------------------------------------------------------- */