block: add timer on blkdev_dequeue_request() not elv_next_request()
[linux-2.6/mini2440.git] / drivers / bluetooth / bpa10x.c
blobb936d8ce2728836c2ba3c214a2cf93960886187f
1 /*
3 * Digianswer Bluetooth USB driver
5 * Copyright (C) 2004-2007 Marcel Holtmann <marcel@holtmann.org>
8 * This program is free software; you can redistribute it and/or modify
9 * it under the terms of the GNU General Public License as published by
10 * the Free Software Foundation; either version 2 of the License, or
11 * (at your option) any later version.
13 * This program is distributed in the hope that it will be useful,
14 * but WITHOUT ANY WARRANTY; without even the implied warranty of
15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16 * GNU General Public License for more details.
18 * You should have received a copy of the GNU General Public License
19 * along with this program; if not, write to the Free Software
20 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
24 #include <linux/kernel.h>
25 #include <linux/module.h>
26 #include <linux/init.h>
27 #include <linux/slab.h>
28 #include <linux/types.h>
29 #include <linux/sched.h>
30 #include <linux/errno.h>
31 #include <linux/skbuff.h>
33 #include <linux/usb.h>
35 #include <net/bluetooth/bluetooth.h>
36 #include <net/bluetooth/hci_core.h>
38 #ifndef CONFIG_BT_HCIBPA10X_DEBUG
39 #undef BT_DBG
40 #define BT_DBG(D...)
41 #endif
43 #define VERSION "0.10"
45 static struct usb_device_id bpa10x_table[] = {
46 /* Tektronix BPA 100/105 (Digianswer) */
47 { USB_DEVICE(0x08fd, 0x0002) },
49 { } /* Terminating entry */
52 MODULE_DEVICE_TABLE(usb, bpa10x_table);
54 struct bpa10x_data {
55 struct hci_dev *hdev;
56 struct usb_device *udev;
58 struct usb_anchor tx_anchor;
59 struct usb_anchor rx_anchor;
61 struct sk_buff *rx_skb[2];
64 #define HCI_VENDOR_HDR_SIZE 5
66 struct hci_vendor_hdr {
67 __u8 type;
68 __le16 snum;
69 __le16 dlen;
70 } __attribute__ ((packed));
72 static int bpa10x_recv(struct hci_dev *hdev, int queue, void *buf, int count)
74 struct bpa10x_data *data = hdev->driver_data;
76 BT_DBG("%s queue %d buffer %p count %d", hdev->name,
77 queue, buf, count);
79 if (queue < 0 || queue > 1)
80 return -EILSEQ;
82 hdev->stat.byte_rx += count;
84 while (count) {
85 struct sk_buff *skb = data->rx_skb[queue];
86 struct { __u8 type; int expect; } *scb;
87 int type, len = 0;
89 if (!skb) {
90 /* Start of the frame */
92 type = *((__u8 *) buf);
93 count--; buf++;
95 switch (type) {
96 case HCI_EVENT_PKT:
97 if (count >= HCI_EVENT_HDR_SIZE) {
98 struct hci_event_hdr *h = buf;
99 len = HCI_EVENT_HDR_SIZE + h->plen;
100 } else
101 return -EILSEQ;
102 break;
104 case HCI_ACLDATA_PKT:
105 if (count >= HCI_ACL_HDR_SIZE) {
106 struct hci_acl_hdr *h = buf;
107 len = HCI_ACL_HDR_SIZE +
108 __le16_to_cpu(h->dlen);
109 } else
110 return -EILSEQ;
111 break;
113 case HCI_SCODATA_PKT:
114 if (count >= HCI_SCO_HDR_SIZE) {
115 struct hci_sco_hdr *h = buf;
116 len = HCI_SCO_HDR_SIZE + h->dlen;
117 } else
118 return -EILSEQ;
119 break;
121 case HCI_VENDOR_PKT:
122 if (count >= HCI_VENDOR_HDR_SIZE) {
123 struct hci_vendor_hdr *h = buf;
124 len = HCI_VENDOR_HDR_SIZE +
125 __le16_to_cpu(h->dlen);
126 } else
127 return -EILSEQ;
128 break;
131 skb = bt_skb_alloc(len, GFP_ATOMIC);
132 if (!skb) {
133 BT_ERR("%s no memory for packet", hdev->name);
134 return -ENOMEM;
137 skb->dev = (void *) hdev;
139 data->rx_skb[queue] = skb;
141 scb = (void *) skb->cb;
142 scb->type = type;
143 scb->expect = len;
144 } else {
145 /* Continuation */
147 scb = (void *) skb->cb;
148 len = scb->expect;
151 len = min(len, count);
153 memcpy(skb_put(skb, len), buf, len);
155 scb->expect -= len;
157 if (scb->expect == 0) {
158 /* Complete frame */
160 data->rx_skb[queue] = NULL;
162 bt_cb(skb)->pkt_type = scb->type;
163 hci_recv_frame(skb);
166 count -= len; buf += len;
169 return 0;
172 static void bpa10x_tx_complete(struct urb *urb)
174 struct sk_buff *skb = urb->context;
175 struct hci_dev *hdev = (struct hci_dev *) skb->dev;
177 BT_DBG("%s urb %p status %d count %d", hdev->name,
178 urb, urb->status, urb->actual_length);
180 if (!test_bit(HCI_RUNNING, &hdev->flags))
181 goto done;
183 if (!urb->status)
184 hdev->stat.byte_tx += urb->transfer_buffer_length;
185 else
186 hdev->stat.err_tx++;
188 done:
189 kfree(urb->setup_packet);
191 kfree_skb(skb);
194 static void bpa10x_rx_complete(struct urb *urb)
196 struct hci_dev *hdev = urb->context;
197 struct bpa10x_data *data = hdev->driver_data;
198 int err;
200 BT_DBG("%s urb %p status %d count %d", hdev->name,
201 urb, urb->status, urb->actual_length);
203 if (!test_bit(HCI_RUNNING, &hdev->flags))
204 return;
206 if (urb->status == 0) {
207 if (bpa10x_recv(hdev, usb_pipebulk(urb->pipe),
208 urb->transfer_buffer,
209 urb->actual_length) < 0) {
210 BT_ERR("%s corrupted event packet", hdev->name);
211 hdev->stat.err_rx++;
215 usb_anchor_urb(urb, &data->rx_anchor);
217 err = usb_submit_urb(urb, GFP_ATOMIC);
218 if (err < 0) {
219 BT_ERR("%s urb %p failed to resubmit (%d)",
220 hdev->name, urb, -err);
221 usb_unanchor_urb(urb);
225 static inline int bpa10x_submit_intr_urb(struct hci_dev *hdev)
227 struct bpa10x_data *data = hdev->driver_data;
228 struct urb *urb;
229 unsigned char *buf;
230 unsigned int pipe;
231 int err, size = 16;
233 BT_DBG("%s", hdev->name);
235 urb = usb_alloc_urb(0, GFP_KERNEL);
236 if (!urb)
237 return -ENOMEM;
239 buf = kmalloc(size, GFP_KERNEL);
240 if (!buf) {
241 usb_free_urb(urb);
242 return -ENOMEM;
245 pipe = usb_rcvintpipe(data->udev, 0x81);
247 usb_fill_int_urb(urb, data->udev, pipe, buf, size,
248 bpa10x_rx_complete, hdev, 1);
250 urb->transfer_flags |= URB_FREE_BUFFER;
252 usb_anchor_urb(urb, &data->rx_anchor);
254 err = usb_submit_urb(urb, GFP_KERNEL);
255 if (err < 0) {
256 BT_ERR("%s urb %p submission failed (%d)",
257 hdev->name, urb, -err);
258 usb_unanchor_urb(urb);
261 usb_free_urb(urb);
263 return err;
266 static inline int bpa10x_submit_bulk_urb(struct hci_dev *hdev)
268 struct bpa10x_data *data = hdev->driver_data;
269 struct urb *urb;
270 unsigned char *buf;
271 unsigned int pipe;
272 int err, size = 64;
274 BT_DBG("%s", hdev->name);
276 urb = usb_alloc_urb(0, GFP_KERNEL);
277 if (!urb)
278 return -ENOMEM;
280 buf = kmalloc(size, GFP_KERNEL);
281 if (!buf) {
282 usb_free_urb(urb);
283 return -ENOMEM;
286 pipe = usb_rcvbulkpipe(data->udev, 0x82);
288 usb_fill_bulk_urb(urb, data->udev, pipe,
289 buf, size, bpa10x_rx_complete, hdev);
291 urb->transfer_flags |= URB_FREE_BUFFER;
293 usb_anchor_urb(urb, &data->rx_anchor);
295 err = usb_submit_urb(urb, GFP_KERNEL);
296 if (err < 0) {
297 BT_ERR("%s urb %p submission failed (%d)",
298 hdev->name, urb, -err);
299 usb_unanchor_urb(urb);
302 usb_free_urb(urb);
304 return err;
307 static int bpa10x_open(struct hci_dev *hdev)
309 struct bpa10x_data *data = hdev->driver_data;
310 int err;
312 BT_DBG("%s", hdev->name);
314 if (test_and_set_bit(HCI_RUNNING, &hdev->flags))
315 return 0;
317 err = bpa10x_submit_intr_urb(hdev);
318 if (err < 0)
319 goto error;
321 err = bpa10x_submit_bulk_urb(hdev);
322 if (err < 0)
323 goto error;
325 return 0;
327 error:
328 usb_kill_anchored_urbs(&data->rx_anchor);
330 clear_bit(HCI_RUNNING, &hdev->flags);
332 return err;
335 static int bpa10x_close(struct hci_dev *hdev)
337 struct bpa10x_data *data = hdev->driver_data;
339 BT_DBG("%s", hdev->name);
341 if (!test_and_clear_bit(HCI_RUNNING, &hdev->flags))
342 return 0;
344 usb_kill_anchored_urbs(&data->rx_anchor);
346 return 0;
349 static int bpa10x_flush(struct hci_dev *hdev)
351 struct bpa10x_data *data = hdev->driver_data;
353 BT_DBG("%s", hdev->name);
355 usb_kill_anchored_urbs(&data->tx_anchor);
357 return 0;
360 static int bpa10x_send_frame(struct sk_buff *skb)
362 struct hci_dev *hdev = (struct hci_dev *) skb->dev;
363 struct bpa10x_data *data = hdev->driver_data;
364 struct usb_ctrlrequest *dr;
365 struct urb *urb;
366 unsigned int pipe;
367 int err;
369 BT_DBG("%s", hdev->name);
371 if (!test_bit(HCI_RUNNING, &hdev->flags))
372 return -EBUSY;
374 urb = usb_alloc_urb(0, GFP_ATOMIC);
375 if (!urb)
376 return -ENOMEM;
378 /* Prepend skb with frame type */
379 *skb_push(skb, 1) = bt_cb(skb)->pkt_type;
381 switch (bt_cb(skb)->pkt_type) {
382 case HCI_COMMAND_PKT:
383 dr = kmalloc(sizeof(*dr), GFP_ATOMIC);
384 if (!dr) {
385 usb_free_urb(urb);
386 return -ENOMEM;
389 dr->bRequestType = USB_TYPE_VENDOR;
390 dr->bRequest = 0;
391 dr->wIndex = 0;
392 dr->wValue = 0;
393 dr->wLength = __cpu_to_le16(skb->len);
395 pipe = usb_sndctrlpipe(data->udev, 0x00);
397 usb_fill_control_urb(urb, data->udev, pipe, (void *) dr,
398 skb->data, skb->len, bpa10x_tx_complete, skb);
400 hdev->stat.cmd_tx++;
401 break;
403 case HCI_ACLDATA_PKT:
404 pipe = usb_sndbulkpipe(data->udev, 0x02);
406 usb_fill_bulk_urb(urb, data->udev, pipe,
407 skb->data, skb->len, bpa10x_tx_complete, skb);
409 hdev->stat.acl_tx++;
410 break;
412 case HCI_SCODATA_PKT:
413 pipe = usb_sndbulkpipe(data->udev, 0x02);
415 usb_fill_bulk_urb(urb, data->udev, pipe,
416 skb->data, skb->len, bpa10x_tx_complete, skb);
418 hdev->stat.sco_tx++;
419 break;
421 default:
422 usb_free_urb(urb);
423 return -EILSEQ;
426 usb_anchor_urb(urb, &data->tx_anchor);
428 err = usb_submit_urb(urb, GFP_ATOMIC);
429 if (err < 0) {
430 BT_ERR("%s urb %p submission failed", hdev->name, urb);
431 kfree(urb->setup_packet);
432 usb_unanchor_urb(urb);
435 usb_free_urb(urb);
437 return 0;
440 static void bpa10x_destruct(struct hci_dev *hdev)
442 struct bpa10x_data *data = hdev->driver_data;
444 BT_DBG("%s", hdev->name);
446 kfree_skb(data->rx_skb[0]);
447 kfree_skb(data->rx_skb[1]);
448 kfree(data);
451 static int bpa10x_probe(struct usb_interface *intf, const struct usb_device_id *id)
453 struct bpa10x_data *data;
454 struct hci_dev *hdev;
455 int err;
457 BT_DBG("intf %p id %p", intf, id);
459 if (intf->cur_altsetting->desc.bInterfaceNumber != 0)
460 return -ENODEV;
462 data = kzalloc(sizeof(*data), GFP_KERNEL);
463 if (!data)
464 return -ENOMEM;
466 data->udev = interface_to_usbdev(intf);
468 init_usb_anchor(&data->tx_anchor);
469 init_usb_anchor(&data->rx_anchor);
471 hdev = hci_alloc_dev();
472 if (!hdev) {
473 kfree(data);
474 return -ENOMEM;
477 hdev->type = HCI_USB;
478 hdev->driver_data = data;
480 data->hdev = hdev;
482 SET_HCIDEV_DEV(hdev, &intf->dev);
484 hdev->open = bpa10x_open;
485 hdev->close = bpa10x_close;
486 hdev->flush = bpa10x_flush;
487 hdev->send = bpa10x_send_frame;
488 hdev->destruct = bpa10x_destruct;
490 hdev->owner = THIS_MODULE;
492 err = hci_register_dev(hdev);
493 if (err < 0) {
494 hci_free_dev(hdev);
495 kfree(data);
496 return err;
499 usb_set_intfdata(intf, data);
501 return 0;
504 static void bpa10x_disconnect(struct usb_interface *intf)
506 struct bpa10x_data *data = usb_get_intfdata(intf);
508 BT_DBG("intf %p", intf);
510 if (!data)
511 return;
513 usb_set_intfdata(intf, NULL);
515 hci_unregister_dev(data->hdev);
517 hci_free_dev(data->hdev);
520 static struct usb_driver bpa10x_driver = {
521 .name = "bpa10x",
522 .probe = bpa10x_probe,
523 .disconnect = bpa10x_disconnect,
524 .id_table = bpa10x_table,
527 static int __init bpa10x_init(void)
529 BT_INFO("Digianswer Bluetooth USB driver ver %s", VERSION);
531 return usb_register(&bpa10x_driver);
534 static void __exit bpa10x_exit(void)
536 usb_deregister(&bpa10x_driver);
539 module_init(bpa10x_init);
540 module_exit(bpa10x_exit);
542 MODULE_AUTHOR("Marcel Holtmann <marcel@holtmann.org>");
543 MODULE_DESCRIPTION("Digianswer Bluetooth USB driver ver " VERSION);
544 MODULE_VERSION(VERSION);
545 MODULE_LICENSE("GPL");