RT-AC56 3.0.0.4.374.37 core
[tomato.git] / release / src-rt-6.x.4708 / linux / linux-2.6.36 / net / bluetooth / sco.c
blobd0927d1fdadaba4887dbac40064c4328541b9b00
1 /*
2 BlueZ - Bluetooth protocol stack for Linux
3 Copyright (C) 2000-2001 Qualcomm Incorporated
5 Written 2000,2001 by Maxim Krasnyansky <maxk@qualcomm.com>
7 This program is free software; you can redistribute it and/or modify
8 it under the terms of the GNU General Public License version 2 as
9 published by the Free Software Foundation;
11 THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
12 OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
13 FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT OF THIRD PARTY RIGHTS.
14 IN NO EVENT SHALL THE COPYRIGHT HOLDER(S) AND AUTHOR(S) BE LIABLE FOR ANY
15 CLAIM, OR ANY SPECIAL INDIRECT OR CONSEQUENTIAL DAMAGES, OR ANY DAMAGES
16 WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
17 ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
18 OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
20 ALL LIABILITY, INCLUDING LIABILITY FOR INFRINGEMENT OF ANY PATENTS,
21 COPYRIGHTS, TRADEMARKS OR OTHER RIGHTS, RELATING TO USE OF THIS
22 SOFTWARE IS DISCLAIMED.
25 /* Bluetooth SCO sockets. */
27 #include <linux/module.h>
29 #include <linux/types.h>
30 #include <linux/errno.h>
31 #include <linux/kernel.h>
32 #include <linux/sched.h>
33 #include <linux/slab.h>
34 #include <linux/poll.h>
35 #include <linux/fcntl.h>
36 #include <linux/init.h>
37 #include <linux/interrupt.h>
38 #include <linux/socket.h>
39 #include <linux/skbuff.h>
40 #include <linux/device.h>
41 #include <linux/debugfs.h>
42 #include <linux/seq_file.h>
43 #include <linux/list.h>
44 #include <net/sock.h>
46 #include <asm/system.h>
47 #include <asm/uaccess.h>
49 #include <net/bluetooth/bluetooth.h>
50 #include <net/bluetooth/hci_core.h>
51 #include <net/bluetooth/sco.h>
53 #define VERSION "0.6"
55 static int disable_esco = 0;
57 static const struct proto_ops sco_sock_ops;
59 static struct bt_sock_list sco_sk_list = {
60 .lock = __RW_LOCK_UNLOCKED(sco_sk_list.lock)
63 static void __sco_chan_add(struct sco_conn *conn, struct sock *sk, struct sock *parent);
64 static void sco_chan_del(struct sock *sk, int err);
66 static int sco_conn_del(struct hci_conn *conn, int err);
68 static void sco_sock_close(struct sock *sk);
69 static void sco_sock_kill(struct sock *sk);
71 /* ---- SCO timers ---- */
72 static void sco_sock_timeout(unsigned long arg)
74 struct sock *sk = (struct sock *) arg;
76 BT_DBG("sock %p state %d", sk, sk->sk_state);
78 bh_lock_sock(sk);
79 sk->sk_err = ETIMEDOUT;
80 sk->sk_state_change(sk);
81 bh_unlock_sock(sk);
83 sco_sock_kill(sk);
84 sock_put(sk);
87 static void sco_sock_set_timer(struct sock *sk, long timeout)
89 BT_DBG("sock %p state %d timeout %ld", sk, sk->sk_state, timeout);
90 sk_reset_timer(sk, &sk->sk_timer, jiffies + timeout);
93 static void sco_sock_clear_timer(struct sock *sk)
95 BT_DBG("sock %p state %d", sk, sk->sk_state);
96 sk_stop_timer(sk, &sk->sk_timer);
99 /* ---- SCO connections ---- */
100 static struct sco_conn *sco_conn_add(struct hci_conn *hcon, __u8 status)
102 struct hci_dev *hdev = hcon->hdev;
103 struct sco_conn *conn = hcon->sco_data;
105 if (conn || status)
106 return conn;
108 conn = kzalloc(sizeof(struct sco_conn), GFP_ATOMIC);
109 if (!conn)
110 return NULL;
112 spin_lock_init(&conn->lock);
114 hcon->sco_data = conn;
115 conn->hcon = hcon;
117 conn->src = &hdev->bdaddr;
118 conn->dst = &hcon->dst;
120 if (hdev->sco_mtu > 0)
121 conn->mtu = hdev->sco_mtu;
122 else
123 conn->mtu = 60;
125 BT_DBG("hcon %p conn %p", hcon, conn);
127 return conn;
130 static inline struct sock *sco_chan_get(struct sco_conn *conn)
132 struct sock *sk = NULL;
133 sco_conn_lock(conn);
134 sk = conn->sk;
135 sco_conn_unlock(conn);
136 return sk;
139 static int sco_conn_del(struct hci_conn *hcon, int err)
141 struct sco_conn *conn;
142 struct sock *sk;
144 if (!(conn = hcon->sco_data))
145 return 0;
147 BT_DBG("hcon %p conn %p, err %d", hcon, conn, err);
149 /* Kill socket */
150 if ((sk = sco_chan_get(conn))) {
151 bh_lock_sock(sk);
152 sco_sock_clear_timer(sk);
153 sco_chan_del(sk, err);
154 bh_unlock_sock(sk);
155 sco_sock_kill(sk);
158 hcon->sco_data = NULL;
159 kfree(conn);
160 return 0;
163 static inline int sco_chan_add(struct sco_conn *conn, struct sock *sk, struct sock *parent)
165 int err = 0;
167 sco_conn_lock(conn);
168 if (conn->sk)
169 err = -EBUSY;
170 else
171 __sco_chan_add(conn, sk, parent);
173 sco_conn_unlock(conn);
174 return err;
177 static int sco_connect(struct sock *sk)
179 bdaddr_t *src = &bt_sk(sk)->src;
180 bdaddr_t *dst = &bt_sk(sk)->dst;
181 struct sco_conn *conn;
182 struct hci_conn *hcon;
183 struct hci_dev *hdev;
184 int err, type;
186 BT_DBG("%s -> %s", batostr(src), batostr(dst));
188 if (!(hdev = hci_get_route(dst, src)))
189 return -EHOSTUNREACH;
191 hci_dev_lock_bh(hdev);
193 err = -ENOMEM;
195 if (lmp_esco_capable(hdev) && !disable_esco)
196 type = ESCO_LINK;
197 else
198 type = SCO_LINK;
200 hcon = hci_connect(hdev, type, dst, BT_SECURITY_LOW, HCI_AT_NO_BONDING);
201 if (!hcon)
202 goto done;
204 conn = sco_conn_add(hcon, 0);
205 if (!conn) {
206 hci_conn_put(hcon);
207 goto done;
210 /* Update source addr of the socket */
211 bacpy(src, conn->src);
213 err = sco_chan_add(conn, sk, NULL);
214 if (err)
215 goto done;
217 if (hcon->state == BT_CONNECTED) {
218 sco_sock_clear_timer(sk);
219 sk->sk_state = BT_CONNECTED;
220 } else {
221 sk->sk_state = BT_CONNECT;
222 sco_sock_set_timer(sk, sk->sk_sndtimeo);
225 done:
226 hci_dev_unlock_bh(hdev);
227 hci_dev_put(hdev);
228 return err;
231 static inline int sco_send_frame(struct sock *sk, struct msghdr *msg, int len)
233 struct sco_conn *conn = sco_pi(sk)->conn;
234 struct sk_buff *skb;
235 int err, count;
237 /* Check outgoing MTU */
238 if (len > conn->mtu)
239 return -EINVAL;
241 BT_DBG("sk %p len %d", sk, len);
243 count = min_t(unsigned int, conn->mtu, len);
244 skb = bt_skb_send_alloc(sk, count,
245 msg->msg_flags & MSG_DONTWAIT, &err);
246 if (!skb)
247 return err;
249 if (memcpy_fromiovec(skb_put(skb, count), msg->msg_iov, count)) {
250 kfree_skb(skb);
251 return -EFAULT;
254 hci_send_sco(conn->hcon, skb);
256 return count;
259 static inline void sco_recv_frame(struct sco_conn *conn, struct sk_buff *skb)
261 struct sock *sk = sco_chan_get(conn);
263 if (!sk)
264 goto drop;
266 BT_DBG("sk %p len %d", sk, skb->len);
268 if (sk->sk_state != BT_CONNECTED)
269 goto drop;
271 if (!sock_queue_rcv_skb(sk, skb))
272 return;
274 drop:
275 kfree_skb(skb);
278 /* -------- Socket interface ---------- */
279 static struct sock *__sco_get_sock_by_addr(bdaddr_t *ba)
281 struct sock *sk;
282 struct hlist_node *node;
284 sk_for_each(sk, node, &sco_sk_list.head)
285 if (!bacmp(&bt_sk(sk)->src, ba))
286 goto found;
287 sk = NULL;
288 found:
289 return sk;
292 /* Find socket listening on source bdaddr.
293 * Returns closest match.
295 static struct sock *sco_get_sock_listen(bdaddr_t *src)
297 struct sock *sk = NULL, *sk1 = NULL;
298 struct hlist_node *node;
300 read_lock(&sco_sk_list.lock);
302 sk_for_each(sk, node, &sco_sk_list.head) {
303 if (sk->sk_state != BT_LISTEN)
304 continue;
306 /* Exact match. */
307 if (!bacmp(&bt_sk(sk)->src, src))
308 break;
310 /* Closest match */
311 if (!bacmp(&bt_sk(sk)->src, BDADDR_ANY))
312 sk1 = sk;
315 read_unlock(&sco_sk_list.lock);
317 return node ? sk : sk1;
320 static void sco_sock_destruct(struct sock *sk)
322 BT_DBG("sk %p", sk);
324 skb_queue_purge(&sk->sk_receive_queue);
325 skb_queue_purge(&sk->sk_write_queue);
328 static void sco_sock_cleanup_listen(struct sock *parent)
330 struct sock *sk;
332 BT_DBG("parent %p", parent);
334 /* Close not yet accepted channels */
335 while ((sk = bt_accept_dequeue(parent, NULL))) {
336 sco_sock_close(sk);
337 sco_sock_kill(sk);
340 parent->sk_state = BT_CLOSED;
341 sock_set_flag(parent, SOCK_ZAPPED);
344 /* Kill socket (only if zapped and orphan)
345 * Must be called on unlocked socket.
347 static void sco_sock_kill(struct sock *sk)
349 if (!sock_flag(sk, SOCK_ZAPPED) || sk->sk_socket)
350 return;
352 BT_DBG("sk %p state %d", sk, sk->sk_state);
354 /* Kill poor orphan */
355 bt_sock_unlink(&sco_sk_list, sk);
356 sock_set_flag(sk, SOCK_DEAD);
357 sock_put(sk);
360 static void __sco_sock_close(struct sock *sk)
362 BT_DBG("sk %p state %d socket %p", sk, sk->sk_state, sk->sk_socket);
364 switch (sk->sk_state) {
365 case BT_LISTEN:
366 sco_sock_cleanup_listen(sk);
367 break;
369 case BT_CONNECTED:
370 case BT_CONFIG:
371 case BT_CONNECT:
372 case BT_DISCONN:
373 sco_chan_del(sk, ECONNRESET);
374 break;
376 default:
377 sock_set_flag(sk, SOCK_ZAPPED);
378 break;
382 /* Must be called on unlocked socket. */
383 static void sco_sock_close(struct sock *sk)
385 sco_sock_clear_timer(sk);
386 lock_sock(sk);
387 __sco_sock_close(sk);
388 release_sock(sk);
389 sco_sock_kill(sk);
392 static void sco_sock_init(struct sock *sk, struct sock *parent)
394 BT_DBG("sk %p", sk);
396 if (parent)
397 sk->sk_type = parent->sk_type;
400 static struct proto sco_proto = {
401 .name = "SCO",
402 .owner = THIS_MODULE,
403 .obj_size = sizeof(struct sco_pinfo)
406 static struct sock *sco_sock_alloc(struct net *net, struct socket *sock, int proto, gfp_t prio)
408 struct sock *sk;
410 sk = sk_alloc(net, PF_BLUETOOTH, prio, &sco_proto);
411 if (!sk)
412 return NULL;
414 sock_init_data(sock, sk);
415 INIT_LIST_HEAD(&bt_sk(sk)->accept_q);
417 sk->sk_destruct = sco_sock_destruct;
418 sk->sk_sndtimeo = SCO_CONN_TIMEOUT;
420 sock_reset_flag(sk, SOCK_ZAPPED);
422 sk->sk_protocol = proto;
423 sk->sk_state = BT_OPEN;
425 setup_timer(&sk->sk_timer, sco_sock_timeout, (unsigned long)sk);
427 bt_sock_link(&sco_sk_list, sk);
428 return sk;
431 static int sco_sock_create(struct net *net, struct socket *sock, int protocol,
432 int kern)
434 struct sock *sk;
436 BT_DBG("sock %p", sock);
438 sock->state = SS_UNCONNECTED;
440 if (sock->type != SOCK_SEQPACKET)
441 return -ESOCKTNOSUPPORT;
443 sock->ops = &sco_sock_ops;
445 sk = sco_sock_alloc(net, sock, protocol, GFP_ATOMIC);
446 if (!sk)
447 return -ENOMEM;
449 sco_sock_init(sk, NULL);
450 return 0;
453 static int sco_sock_bind(struct socket *sock, struct sockaddr *addr, int addr_len)
455 struct sockaddr_sco *sa = (struct sockaddr_sco *) addr;
456 struct sock *sk = sock->sk;
457 bdaddr_t *src = &sa->sco_bdaddr;
458 int err = 0;
460 BT_DBG("sk %p %s", sk, batostr(&sa->sco_bdaddr));
462 if (!addr || addr->sa_family != AF_BLUETOOTH)
463 return -EINVAL;
465 lock_sock(sk);
467 if (sk->sk_state != BT_OPEN) {
468 err = -EBADFD;
469 goto done;
472 write_lock_bh(&sco_sk_list.lock);
474 if (bacmp(src, BDADDR_ANY) && __sco_get_sock_by_addr(src)) {
475 err = -EADDRINUSE;
476 } else {
477 /* Save source address */
478 bacpy(&bt_sk(sk)->src, &sa->sco_bdaddr);
479 sk->sk_state = BT_BOUND;
482 write_unlock_bh(&sco_sk_list.lock);
484 done:
485 release_sock(sk);
486 return err;
489 static int sco_sock_connect(struct socket *sock, struct sockaddr *addr, int alen, int flags)
491 struct sockaddr_sco *sa = (struct sockaddr_sco *) addr;
492 struct sock *sk = sock->sk;
493 int err = 0;
496 BT_DBG("sk %p", sk);
498 if (alen < sizeof(struct sockaddr_sco) ||
499 addr->sa_family != AF_BLUETOOTH)
500 return -EINVAL;
502 if (sk->sk_state != BT_OPEN && sk->sk_state != BT_BOUND)
503 return -EBADFD;
505 if (sk->sk_type != SOCK_SEQPACKET)
506 return -EINVAL;
508 lock_sock(sk);
510 /* Set destination address and psm */
511 bacpy(&bt_sk(sk)->dst, &sa->sco_bdaddr);
513 if ((err = sco_connect(sk)))
514 goto done;
516 err = bt_sock_wait_state(sk, BT_CONNECTED,
517 sock_sndtimeo(sk, flags & O_NONBLOCK));
519 done:
520 release_sock(sk);
521 return err;
524 static int sco_sock_listen(struct socket *sock, int backlog)
526 struct sock *sk = sock->sk;
527 int err = 0;
529 BT_DBG("sk %p backlog %d", sk, backlog);
531 lock_sock(sk);
533 if (sk->sk_state != BT_BOUND || sock->type != SOCK_SEQPACKET) {
534 err = -EBADFD;
535 goto done;
538 sk->sk_max_ack_backlog = backlog;
539 sk->sk_ack_backlog = 0;
540 sk->sk_state = BT_LISTEN;
542 done:
543 release_sock(sk);
544 return err;
547 static int sco_sock_accept(struct socket *sock, struct socket *newsock, int flags)
549 DECLARE_WAITQUEUE(wait, current);
550 struct sock *sk = sock->sk, *ch;
551 long timeo;
552 int err = 0;
554 lock_sock(sk);
556 if (sk->sk_state != BT_LISTEN) {
557 err = -EBADFD;
558 goto done;
561 timeo = sock_rcvtimeo(sk, flags & O_NONBLOCK);
563 BT_DBG("sk %p timeo %ld", sk, timeo);
565 /* Wait for an incoming connection. (wake-one). */
566 add_wait_queue_exclusive(sk_sleep(sk), &wait);
567 while (!(ch = bt_accept_dequeue(sk, newsock))) {
568 set_current_state(TASK_INTERRUPTIBLE);
569 if (!timeo) {
570 err = -EAGAIN;
571 break;
574 release_sock(sk);
575 timeo = schedule_timeout(timeo);
576 lock_sock(sk);
578 if (sk->sk_state != BT_LISTEN) {
579 err = -EBADFD;
580 break;
583 if (signal_pending(current)) {
584 err = sock_intr_errno(timeo);
585 break;
588 set_current_state(TASK_RUNNING);
589 remove_wait_queue(sk_sleep(sk), &wait);
591 if (err)
592 goto done;
594 newsock->state = SS_CONNECTED;
596 BT_DBG("new socket %p", ch);
598 done:
599 release_sock(sk);
600 return err;
603 static int sco_sock_getname(struct socket *sock, struct sockaddr *addr, int *len, int peer)
605 struct sockaddr_sco *sa = (struct sockaddr_sco *) addr;
606 struct sock *sk = sock->sk;
608 BT_DBG("sock %p, sk %p", sock, sk);
610 addr->sa_family = AF_BLUETOOTH;
611 *len = sizeof(struct sockaddr_sco);
613 if (peer)
614 bacpy(&sa->sco_bdaddr, &bt_sk(sk)->dst);
615 else
616 bacpy(&sa->sco_bdaddr, &bt_sk(sk)->src);
618 return 0;
621 static int sco_sock_sendmsg(struct kiocb *iocb, struct socket *sock,
622 struct msghdr *msg, size_t len)
624 struct sock *sk = sock->sk;
625 int err;
627 BT_DBG("sock %p, sk %p", sock, sk);
629 err = sock_error(sk);
630 if (err)
631 return err;
633 if (msg->msg_flags & MSG_OOB)
634 return -EOPNOTSUPP;
636 lock_sock(sk);
638 if (sk->sk_state == BT_CONNECTED)
639 err = sco_send_frame(sk, msg, len);
640 else
641 err = -ENOTCONN;
643 release_sock(sk);
644 return err;
647 static int sco_sock_setsockopt(struct socket *sock, int level, int optname, char __user *optval, unsigned int optlen)
649 struct sock *sk = sock->sk;
650 int err = 0;
652 BT_DBG("sk %p", sk);
654 lock_sock(sk);
656 switch (optname) {
657 default:
658 err = -ENOPROTOOPT;
659 break;
662 release_sock(sk);
663 return err;
666 static int sco_sock_getsockopt_old(struct socket *sock, int optname, char __user *optval, int __user *optlen)
668 struct sock *sk = sock->sk;
669 struct sco_options opts;
670 struct sco_conninfo cinfo;
671 int len, err = 0;
673 BT_DBG("sk %p", sk);
675 if (get_user(len, optlen))
676 return -EFAULT;
678 lock_sock(sk);
680 switch (optname) {
681 case SCO_OPTIONS:
682 if (sk->sk_state != BT_CONNECTED) {
683 err = -ENOTCONN;
684 break;
687 opts.mtu = sco_pi(sk)->conn->mtu;
689 BT_DBG("mtu %d", opts.mtu);
691 len = min_t(unsigned int, len, sizeof(opts));
692 if (copy_to_user(optval, (char *)&opts, len))
693 err = -EFAULT;
695 break;
697 case SCO_CONNINFO:
698 if (sk->sk_state != BT_CONNECTED) {
699 err = -ENOTCONN;
700 break;
703 cinfo.hci_handle = sco_pi(sk)->conn->hcon->handle;
704 memcpy(cinfo.dev_class, sco_pi(sk)->conn->hcon->dev_class, 3);
706 len = min_t(unsigned int, len, sizeof(cinfo));
707 if (copy_to_user(optval, (char *)&cinfo, len))
708 err = -EFAULT;
710 break;
712 default:
713 err = -ENOPROTOOPT;
714 break;
717 release_sock(sk);
718 return err;
721 static int sco_sock_getsockopt(struct socket *sock, int level, int optname, char __user *optval, int __user *optlen)
723 struct sock *sk = sock->sk;
724 int len, err = 0;
726 BT_DBG("sk %p", sk);
728 if (level == SOL_SCO)
729 return sco_sock_getsockopt_old(sock, optname, optval, optlen);
731 if (get_user(len, optlen))
732 return -EFAULT;
734 lock_sock(sk);
736 switch (optname) {
737 default:
738 err = -ENOPROTOOPT;
739 break;
742 release_sock(sk);
743 return err;
746 static int sco_sock_shutdown(struct socket *sock, int how)
748 struct sock *sk = sock->sk;
749 int err = 0;
751 BT_DBG("sock %p, sk %p", sock, sk);
753 if (!sk)
754 return 0;
756 lock_sock(sk);
757 if (!sk->sk_shutdown) {
758 sk->sk_shutdown = SHUTDOWN_MASK;
759 sco_sock_clear_timer(sk);
760 __sco_sock_close(sk);
762 if (sock_flag(sk, SOCK_LINGER) && sk->sk_lingertime)
763 err = bt_sock_wait_state(sk, BT_CLOSED,
764 sk->sk_lingertime);
766 release_sock(sk);
767 return err;
770 static int sco_sock_release(struct socket *sock)
772 struct sock *sk = sock->sk;
773 int err = 0;
775 BT_DBG("sock %p, sk %p", sock, sk);
777 if (!sk)
778 return 0;
780 sco_sock_close(sk);
782 if (sock_flag(sk, SOCK_LINGER) && sk->sk_lingertime) {
783 lock_sock(sk);
784 err = bt_sock_wait_state(sk, BT_CLOSED, sk->sk_lingertime);
785 release_sock(sk);
788 sock_orphan(sk);
789 sco_sock_kill(sk);
790 return err;
793 static void __sco_chan_add(struct sco_conn *conn, struct sock *sk, struct sock *parent)
795 BT_DBG("conn %p", conn);
797 sco_pi(sk)->conn = conn;
798 conn->sk = sk;
800 if (parent)
801 bt_accept_enqueue(parent, sk);
804 /* Delete channel.
805 * Must be called on the locked socket. */
806 static void sco_chan_del(struct sock *sk, int err)
808 struct sco_conn *conn;
810 conn = sco_pi(sk)->conn;
812 BT_DBG("sk %p, conn %p, err %d", sk, conn, err);
814 if (conn) {
815 sco_conn_lock(conn);
816 conn->sk = NULL;
817 sco_pi(sk)->conn = NULL;
818 sco_conn_unlock(conn);
819 hci_conn_put(conn->hcon);
822 sk->sk_state = BT_CLOSED;
823 sk->sk_err = err;
824 sk->sk_state_change(sk);
826 sock_set_flag(sk, SOCK_ZAPPED);
829 static void sco_conn_ready(struct sco_conn *conn)
831 struct sock *parent, *sk;
833 BT_DBG("conn %p", conn);
835 sco_conn_lock(conn);
837 if ((sk = conn->sk)) {
838 sco_sock_clear_timer(sk);
839 bh_lock_sock(sk);
840 sk->sk_state = BT_CONNECTED;
841 sk->sk_state_change(sk);
842 bh_unlock_sock(sk);
843 } else {
844 parent = sco_get_sock_listen(conn->src);
845 if (!parent)
846 goto done;
848 bh_lock_sock(parent);
850 sk = sco_sock_alloc(sock_net(parent), NULL,
851 BTPROTO_SCO, GFP_ATOMIC);
852 if (!sk) {
853 bh_unlock_sock(parent);
854 goto done;
857 sco_sock_init(sk, parent);
859 bacpy(&bt_sk(sk)->src, conn->src);
860 bacpy(&bt_sk(sk)->dst, conn->dst);
862 hci_conn_hold(conn->hcon);
863 __sco_chan_add(conn, sk, parent);
865 sk->sk_state = BT_CONNECTED;
867 /* Wake up parent */
868 parent->sk_data_ready(parent, 1);
870 bh_unlock_sock(parent);
873 done:
874 sco_conn_unlock(conn);
877 /* ----- SCO interface with lower layer (HCI) ----- */
878 static int sco_connect_ind(struct hci_dev *hdev, bdaddr_t *bdaddr, __u8 type)
880 register struct sock *sk;
881 struct hlist_node *node;
882 int lm = 0;
884 if (type != SCO_LINK && type != ESCO_LINK)
885 return 0;
887 BT_DBG("hdev %s, bdaddr %s", hdev->name, batostr(bdaddr));
889 /* Find listening sockets */
890 read_lock(&sco_sk_list.lock);
891 sk_for_each(sk, node, &sco_sk_list.head) {
892 if (sk->sk_state != BT_LISTEN)
893 continue;
895 if (!bacmp(&bt_sk(sk)->src, &hdev->bdaddr) ||
896 !bacmp(&bt_sk(sk)->src, BDADDR_ANY)) {
897 lm |= HCI_LM_ACCEPT;
898 break;
901 read_unlock(&sco_sk_list.lock);
903 return lm;
906 static int sco_connect_cfm(struct hci_conn *hcon, __u8 status)
908 BT_DBG("hcon %p bdaddr %s status %d", hcon, batostr(&hcon->dst), status);
910 if (hcon->type != SCO_LINK && hcon->type != ESCO_LINK)
911 return 0;
913 if (!status) {
914 struct sco_conn *conn;
916 conn = sco_conn_add(hcon, status);
917 if (conn)
918 sco_conn_ready(conn);
919 } else
920 sco_conn_del(hcon, bt_err(status));
922 return 0;
925 static int sco_disconn_cfm(struct hci_conn *hcon, __u8 reason)
927 BT_DBG("hcon %p reason %d", hcon, reason);
929 if (hcon->type != SCO_LINK && hcon->type != ESCO_LINK)
930 return 0;
932 sco_conn_del(hcon, bt_err(reason));
934 return 0;
937 static int sco_recv_scodata(struct hci_conn *hcon, struct sk_buff *skb)
939 struct sco_conn *conn = hcon->sco_data;
941 if (!conn)
942 goto drop;
944 BT_DBG("conn %p len %d", conn, skb->len);
946 if (skb->len) {
947 sco_recv_frame(conn, skb);
948 return 0;
951 drop:
952 kfree_skb(skb);
953 return 0;
956 static int sco_debugfs_show(struct seq_file *f, void *p)
958 struct sock *sk;
959 struct hlist_node *node;
961 read_lock_bh(&sco_sk_list.lock);
963 sk_for_each(sk, node, &sco_sk_list.head) {
964 seq_printf(f, "%s %s %d\n", batostr(&bt_sk(sk)->src),
965 batostr(&bt_sk(sk)->dst), sk->sk_state);
968 read_unlock_bh(&sco_sk_list.lock);
970 return 0;
973 static int sco_debugfs_open(struct inode *inode, struct file *file)
975 return single_open(file, sco_debugfs_show, inode->i_private);
978 static const struct file_operations sco_debugfs_fops = {
979 .open = sco_debugfs_open,
980 .read = seq_read,
981 .llseek = seq_lseek,
982 .release = single_release,
985 static struct dentry *sco_debugfs;
987 static const struct proto_ops sco_sock_ops = {
988 .family = PF_BLUETOOTH,
989 .owner = THIS_MODULE,
990 .release = sco_sock_release,
991 .bind = sco_sock_bind,
992 .connect = sco_sock_connect,
993 .listen = sco_sock_listen,
994 .accept = sco_sock_accept,
995 .getname = sco_sock_getname,
996 .sendmsg = sco_sock_sendmsg,
997 .recvmsg = bt_sock_recvmsg,
998 .poll = bt_sock_poll,
999 .ioctl = bt_sock_ioctl,
1000 .mmap = sock_no_mmap,
1001 .socketpair = sock_no_socketpair,
1002 .shutdown = sco_sock_shutdown,
1003 .setsockopt = sco_sock_setsockopt,
1004 .getsockopt = sco_sock_getsockopt
1007 static const struct net_proto_family sco_sock_family_ops = {
1008 .family = PF_BLUETOOTH,
1009 .owner = THIS_MODULE,
1010 .create = sco_sock_create,
1013 static struct hci_proto sco_hci_proto = {
1014 .name = "SCO",
1015 .id = HCI_PROTO_SCO,
1016 .connect_ind = sco_connect_ind,
1017 .connect_cfm = sco_connect_cfm,
1018 .disconn_cfm = sco_disconn_cfm,
1019 .recv_scodata = sco_recv_scodata
1022 static int __init sco_init(void)
1024 int err;
1026 err = proto_register(&sco_proto, 0);
1027 if (err < 0)
1028 return err;
1030 err = bt_sock_register(BTPROTO_SCO, &sco_sock_family_ops);
1031 if (err < 0) {
1032 BT_ERR("SCO socket registration failed");
1033 goto error;
1036 err = hci_register_proto(&sco_hci_proto);
1037 if (err < 0) {
1038 BT_ERR("SCO protocol registration failed");
1039 bt_sock_unregister(BTPROTO_SCO);
1040 goto error;
1043 if (bt_debugfs) {
1044 sco_debugfs = debugfs_create_file("sco", 0444,
1045 bt_debugfs, NULL, &sco_debugfs_fops);
1046 if (!sco_debugfs)
1047 BT_ERR("Failed to create SCO debug file");
1050 BT_INFO("SCO (Voice Link) ver %s", VERSION);
1051 BT_INFO("SCO socket layer initialized");
1053 return 0;
1055 error:
1056 proto_unregister(&sco_proto);
1057 return err;
1060 static void __exit sco_exit(void)
1062 debugfs_remove(sco_debugfs);
1064 if (bt_sock_unregister(BTPROTO_SCO) < 0)
1065 BT_ERR("SCO socket unregistration failed");
1067 if (hci_unregister_proto(&sco_hci_proto) < 0)
1068 BT_ERR("SCO protocol unregistration failed");
1070 proto_unregister(&sco_proto);
1073 module_init(sco_init);
1074 module_exit(sco_exit);
1076 module_param(disable_esco, bool, 0644);
1077 MODULE_PARM_DESC(disable_esco, "Disable eSCO connection creation");
1079 MODULE_AUTHOR("Marcel Holtmann <marcel@holtmann.org>");
1080 MODULE_DESCRIPTION("Bluetooth SCO ver " VERSION);
1081 MODULE_VERSION(VERSION);
1082 MODULE_LICENSE("GPL");
1083 MODULE_ALIAS("bt-proto-2");