net/bluetooth/sco.c

   1 /*
   2    BlueZ - Bluetooth protocol stack for Linux
   3    Copyright (C) 2000-2001 Qualcomm Incorporated
   4
   5    Written 2000,2001 by Maxim Krasnyansky <maxk@qualcomm.com>
   6
   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;
  10
  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.
  19
  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.
  23 */
  24
  25 /* Bluetooth SCO sockets. */
  26
  27 #include <linux/module.h>
  28 #include <linux/debugfs.h>
  29 #include <linux/seq_file.h>
  30
  31 #include <net/bluetooth/bluetooth.h>
  32 #include <net/bluetooth/hci_core.h>
  33 #include <net/bluetooth/sco.h>
  34
  35 static bool disable_esco;
  36
  37 static const struct proto_ops sco_sock_ops;
  38
  39 static struct bt_sock_list sco_sk_list = {
  40         .lock = __RW_LOCK_UNLOCKED(sco_sk_list.lock)
  41 };
  42
  43 /* ---- SCO connections ---- */
  44 struct sco_conn {
  45         struct hci_conn *hcon;
  46
  47         spinlock_t      lock;
  48         struct sock     *sk;
  49
  50         unsigned int    mtu;
  51 };
  52
  53 #define sco_conn_lock(c)        spin_lock(&c->lock);
  54 #define sco_conn_unlock(c)      spin_unlock(&c->lock);
  55
  56 static void sco_sock_close(struct sock *sk);
  57 static void sco_sock_kill(struct sock *sk);
  58
  59 /* ----- SCO socket info ----- */
  60 #define sco_pi(sk) ((struct sco_pinfo *) sk)
  61
  62 struct sco_pinfo {
  63         struct bt_sock  bt;
  64         bdaddr_t        src;
  65         bdaddr_t        dst;
  66         __u32           flags;
  67         __u16           setting;
  68         struct sco_conn *conn;
  69 };
  70
  71 /* ---- SCO timers ---- */
  72 #define SCO_CONN_TIMEOUT        (HZ * 40)
  73 #define SCO_DISCONN_TIMEOUT     (HZ * 2)
  74
  75 static void sco_sock_timeout(unsigned long arg)
  76 {
  77         struct sock *sk = (struct sock *) arg;
  78
  79         BT_DBG("sock %p state %d", sk, sk->sk_state);
  80
  81         bh_lock_sock(sk);
  82         sk->sk_err = ETIMEDOUT;
  83         sk->sk_state_change(sk);
  84         bh_unlock_sock(sk);
  85
  86         sco_sock_kill(sk);
  87         sock_put(sk);
  88 }
  89
  90 static void sco_sock_set_timer(struct sock *sk, long timeout)
  91 {
  92         BT_DBG("sock %p state %d timeout %ld", sk, sk->sk_state, timeout);
  93         sk_reset_timer(sk, &sk->sk_timer, jiffies + timeout);
  94 }
  95
  96 static void sco_sock_clear_timer(struct sock *sk)
  97 {
  98         BT_DBG("sock %p state %d", sk, sk->sk_state);
  99         sk_stop_timer(sk, &sk->sk_timer);
 100 }
 101
 102 /* ---- SCO connections ---- */
 103 static struct sco_conn *sco_conn_add(struct hci_conn *hcon)
 104 {
 105         struct hci_dev *hdev = hcon->hdev;
 106         struct sco_conn *conn = hcon->sco_data;
 107
 108         if (conn)
 109                 return conn;
 110
 111         conn = kzalloc(sizeof(struct sco_conn), GFP_KERNEL);
 112         if (!conn)
 113                 return NULL;
 114
 115         spin_lock_init(&conn->lock);
 116
 117         hcon->sco_data = conn;
 118         conn->hcon = hcon;
 119
 120         if (hdev->sco_mtu > 0)
 121                 conn->mtu = hdev->sco_mtu;
 122         else
 123                 conn->mtu = 60;
 124
 125         BT_DBG("hcon %p conn %p", hcon, conn);
 126
 127         return conn;
 128 }
 129
 130 /* Delete channel.
 131  * Must be called on the locked socket. */
 132 static void sco_chan_del(struct sock *sk, int err)
 133 {
 134         struct sco_conn *conn;
 135
 136         conn = sco_pi(sk)->conn;
 137
 138         BT_DBG("sk %p, conn %p, err %d", sk, conn, err);
 139
 140         if (conn) {
 141                 sco_conn_lock(conn);
 142                 conn->sk = NULL;
 143                 sco_pi(sk)->conn = NULL;
 144                 sco_conn_unlock(conn);
 145
 146                 if (conn->hcon)
 147                         hci_conn_drop(conn->hcon);
 148         }
 149
 150         sk->sk_state = BT_CLOSED;
 151         sk->sk_err   = err;
 152         sk->sk_state_change(sk);
 153
 154         sock_set_flag(sk, SOCK_ZAPPED);
 155 }
 156
 157 static int sco_conn_del(struct hci_conn *hcon, int err)
 158 {
 159         struct sco_conn *conn = hcon->sco_data;
 160         struct sock *sk;
 161
 162         if (!conn)
 163                 return 0;
 164
 165         BT_DBG("hcon %p conn %p, err %d", hcon, conn, err);
 166
 167         /* Kill socket */
 168         sco_conn_lock(conn);
 169         sk = conn->sk;
 170         sco_conn_unlock(conn);
 171
 172         if (sk) {
 173                 bh_lock_sock(sk);
 174                 sco_sock_clear_timer(sk);
 175                 sco_chan_del(sk, err);
 176                 bh_unlock_sock(sk);
 177                 sco_sock_kill(sk);
 178         }
 179
 180         hcon->sco_data = NULL;
 181         kfree(conn);
 182         return 0;
 183 }
 184
 185 static void __sco_chan_add(struct sco_conn *conn, struct sock *sk, struct sock *parent)
 186 {
 187         BT_DBG("conn %p", conn);
 188
 189         sco_pi(sk)->conn = conn;
 190         conn->sk = sk;
 191
 192         if (parent)
 193                 bt_accept_enqueue(parent, sk);
 194 }
 195
 196 static int sco_chan_add(struct sco_conn *conn, struct sock *sk,
 197                         struct sock *parent)
 198 {
 199         int err = 0;
 200
 201         sco_conn_lock(conn);
 202         if (conn->sk)
 203                 err = -EBUSY;
 204         else
 205                 __sco_chan_add(conn, sk, parent);
 206
 207         sco_conn_unlock(conn);
 208         return err;
 209 }
 210
 211 static int sco_connect(struct sock *sk)
 212 {
 213         struct sco_conn *conn;
 214         struct hci_conn *hcon;
 215         struct hci_dev  *hdev;
 216         int err, type;
 217
 218         BT_DBG("%pMR -> %pMR", &sco_pi(sk)->src, &sco_pi(sk)->dst);
 219
 220         hdev = hci_get_route(&sco_pi(sk)->dst, &sco_pi(sk)->src);
 221         if (!hdev)
 222                 return -EHOSTUNREACH;
 223
 224         hci_dev_lock(hdev);
 225
 226         if (lmp_esco_capable(hdev) && !disable_esco)
 227                 type = ESCO_LINK;
 228         else
 229                 type = SCO_LINK;
 230
 231         if (sco_pi(sk)->setting == BT_VOICE_TRANSPARENT &&
 232             (!lmp_transp_capable(hdev) || !lmp_esco_capable(hdev))) {
 233                 err = -EOPNOTSUPP;
 234                 goto done;
 235         }
 236
 237         hcon = hci_connect_sco(hdev, type, &sco_pi(sk)->dst,
 238                                sco_pi(sk)->setting);
 239         if (IS_ERR(hcon)) {
 240                 err = PTR_ERR(hcon);
 241                 goto done;
 242         }
 243
 244         conn = sco_conn_add(hcon);
 245         if (!conn) {
 246                 hci_conn_drop(hcon);
 247                 err = -ENOMEM;
 248                 goto done;
 249         }
 250
 251         /* Update source addr of the socket */
 252         bacpy(&sco_pi(sk)->src, &hcon->src);
 253
 254         err = sco_chan_add(conn, sk, NULL);
 255         if (err)
 256                 goto done;
 257
 258         if (hcon->state == BT_CONNECTED) {
 259                 sco_sock_clear_timer(sk);
 260                 sk->sk_state = BT_CONNECTED;
 261         } else {
 262                 sk->sk_state = BT_CONNECT;
 263                 sco_sock_set_timer(sk, sk->sk_sndtimeo);
 264         }
 265
 266 done:
 267         hci_dev_unlock(hdev);
 268         hci_dev_put(hdev);
 269         return err;
 270 }
 271
 272 static int sco_send_frame(struct sock *sk, struct msghdr *msg, int len)
 273 {
 274         struct sco_conn *conn = sco_pi(sk)->conn;
 275         struct sk_buff *skb;
 276         int err;
 277
 278         /* Check outgoing MTU */
 279         if (len > conn->mtu)
 280                 return -EINVAL;
 281
 282         BT_DBG("sk %p len %d", sk, len);
 283
 284         skb = bt_skb_send_alloc(sk, len, msg->msg_flags & MSG_DONTWAIT, &err);
 285         if (!skb)
 286                 return err;
 287
 288         if (memcpy_fromiovec(skb_put(skb, len), msg->msg_iov, len)) {
 289                 kfree_skb(skb);
 290                 return -EFAULT;
 291         }
 292
 293         hci_send_sco(conn->hcon, skb);
 294
 295         return len;
 296 }
 297
 298 static void sco_recv_frame(struct sco_conn *conn, struct sk_buff *skb)
 299 {
 300         struct sock *sk;
 301
 302         sco_conn_lock(conn);
 303         sk = conn->sk;
 304         sco_conn_unlock(conn);
 305
 306         if (!sk)
 307                 goto drop;
 308
 309         BT_DBG("sk %p len %d", sk, skb->len);
 310
 311         if (sk->sk_state != BT_CONNECTED)
 312                 goto drop;
 313
 314         if (!sock_queue_rcv_skb(sk, skb))
 315                 return;
 316
 317 drop:
 318         kfree_skb(skb);
 319 }
 320
 321 /* -------- Socket interface ---------- */
 322 static struct sock *__sco_get_sock_listen_by_addr(bdaddr_t *ba)
 323 {
 324         struct sock *sk;
 325
 326         sk_for_each(sk, &sco_sk_list.head) {
 327                 if (sk->sk_state != BT_LISTEN)
 328                         continue;
 329
 330                 if (!bacmp(&sco_pi(sk)->src, ba))
 331                         return sk;
 332         }
 333
 334         return NULL;
 335 }
 336
 337 /* Find socket listening on source bdaddr.
 338  * Returns closest match.
 339  */
 340 static struct sock *sco_get_sock_listen(bdaddr_t *src)
 341 {
 342         struct sock *sk = NULL, *sk1 = NULL;
 343
 344         read_lock(&sco_sk_list.lock);
 345
 346         sk_for_each(sk, &sco_sk_list.head) {
 347                 if (sk->sk_state != BT_LISTEN)
 348                         continue;
 349
 350                 /* Exact match. */
 351                 if (!bacmp(&sco_pi(sk)->src, src))
 352                         break;
 353
 354                 /* Closest match */
 355                 if (!bacmp(&sco_pi(sk)->src, BDADDR_ANY))
 356                         sk1 = sk;
 357         }
 358
 359         read_unlock(&sco_sk_list.lock);
 360
 361         return sk ? sk : sk1;
 362 }
 363
 364 static void sco_sock_destruct(struct sock *sk)
 365 {
 366         BT_DBG("sk %p", sk);
 367
 368         skb_queue_purge(&sk->sk_receive_queue);
 369         skb_queue_purge(&sk->sk_write_queue);
 370 }
 371
 372 static void sco_sock_cleanup_listen(struct sock *parent)
 373 {
 374         struct sock *sk;
 375
 376         BT_DBG("parent %p", parent);
 377
 378         /* Close not yet accepted channels */
 379         while ((sk = bt_accept_dequeue(parent, NULL))) {
 380                 sco_sock_close(sk);
 381                 sco_sock_kill(sk);
 382         }
 383
 384         parent->sk_state  = BT_CLOSED;
 385         sock_set_flag(parent, SOCK_ZAPPED);
 386 }
 387
 388 /* Kill socket (only if zapped and orphan)
 389  * Must be called on unlocked socket.
 390  */
 391 static void sco_sock_kill(struct sock *sk)
 392 {
 393         if (!sock_flag(sk, SOCK_ZAPPED) || sk->sk_socket)
 394                 return;
 395
 396         BT_DBG("sk %p state %d", sk, sk->sk_state);
 397
 398         /* Kill poor orphan */
 399         bt_sock_unlink(&sco_sk_list, sk);
 400         sock_set_flag(sk, SOCK_DEAD);
 401         sock_put(sk);
 402 }
 403
 404 static void __sco_sock_close(struct sock *sk)
 405 {
 406         BT_DBG("sk %p state %d socket %p", sk, sk->sk_state, sk->sk_socket);
 407
 408         switch (sk->sk_state) {
 409         case BT_LISTEN:
 410                 sco_sock_cleanup_listen(sk);
 411                 break;
 412
 413         case BT_CONNECTED:
 414         case BT_CONFIG:
 415                 if (sco_pi(sk)->conn->hcon) {
 416                         sk->sk_state = BT_DISCONN;
 417                         sco_sock_set_timer(sk, SCO_DISCONN_TIMEOUT);
 418                         hci_conn_drop(sco_pi(sk)->conn->hcon);
 419                         sco_pi(sk)->conn->hcon = NULL;
 420                 } else
 421                         sco_chan_del(sk, ECONNRESET);
 422                 break;
 423
 424         case BT_CONNECT2:
 425         case BT_CONNECT:
 426         case BT_DISCONN:
 427                 sco_chan_del(sk, ECONNRESET);
 428                 break;
 429
 430         default:
 431                 sock_set_flag(sk, SOCK_ZAPPED);
 432                 break;
 433         }
 434 }
 435
 436 /* Must be called on unlocked socket. */
 437 static void sco_sock_close(struct sock *sk)
 438 {
 439         sco_sock_clear_timer(sk);
 440         lock_sock(sk);
 441         __sco_sock_close(sk);
 442         release_sock(sk);
 443         sco_sock_kill(sk);
 444 }
 445
 446 static void sco_sock_init(struct sock *sk, struct sock *parent)
 447 {
 448         BT_DBG("sk %p", sk);
 449
 450         if (parent) {
 451                 sk->sk_type = parent->sk_type;
 452                 bt_sk(sk)->flags = bt_sk(parent)->flags;
 453                 security_sk_clone(parent, sk);
 454         }
 455 }
 456
 457 static struct proto sco_proto = {
 458         .name           = "SCO",
 459         .owner          = THIS_MODULE,
 460         .obj_size       = sizeof(struct sco_pinfo)
 461 };
 462
 463 static struct sock *sco_sock_alloc(struct net *net, struct socket *sock, int proto, gfp_t prio)
 464 {
 465         struct sock *sk;
 466
 467         sk = sk_alloc(net, PF_BLUETOOTH, prio, &sco_proto);
 468         if (!sk)
 469                 return NULL;
 470
 471         sock_init_data(sock, sk);
 472         INIT_LIST_HEAD(&bt_sk(sk)->accept_q);
 473
 474         sk->sk_destruct = sco_sock_destruct;
 475         sk->sk_sndtimeo = SCO_CONN_TIMEOUT;
 476
 477         sock_reset_flag(sk, SOCK_ZAPPED);
 478
 479         sk->sk_protocol = proto;
 480         sk->sk_state    = BT_OPEN;
 481
 482         sco_pi(sk)->setting = BT_VOICE_CVSD_16BIT;
 483
 484         setup_timer(&sk->sk_timer, sco_sock_timeout, (unsigned long)sk);
 485
 486         bt_sock_link(&sco_sk_list, sk);
 487         return sk;
 488 }
 489
 490 static int sco_sock_create(struct net *net, struct socket *sock, int protocol,
 491                            int kern)
 492 {
 493         struct sock *sk;
 494
 495         BT_DBG("sock %p", sock);
 496
 497         sock->state = SS_UNCONNECTED;
 498
 499         if (sock->type != SOCK_SEQPACKET)
 500                 return -ESOCKTNOSUPPORT;
 501
 502         sock->ops = &sco_sock_ops;
 503
 504         sk = sco_sock_alloc(net, sock, protocol, GFP_ATOMIC);
 505         if (!sk)
 506                 return -ENOMEM;
 507
 508         sco_sock_init(sk, NULL);
 509         return 0;
 510 }
 511
 512 static int sco_sock_bind(struct socket *sock, struct sockaddr *addr, int addr_len)
 513 {
 514         struct sockaddr_sco *sa = (struct sockaddr_sco *) addr;
 515         struct sock *sk = sock->sk;
 516         int err = 0;
 517
 518         BT_DBG("sk %p %pMR", sk, &sa->sco_bdaddr);
 519
 520         if (!addr || addr->sa_family != AF_BLUETOOTH)
 521                 return -EINVAL;
 522
 523         lock_sock(sk);
 524
 525         if (sk->sk_state != BT_OPEN) {
 526                 err = -EBADFD;
 527                 goto done;
 528         }
 529
 530         if (sk->sk_type != SOCK_SEQPACKET) {
 531                 err = -EINVAL;
 532                 goto done;
 533         }
 534
 535         bacpy(&sco_pi(sk)->src, &sa->sco_bdaddr);
 536
 537         sk->sk_state = BT_BOUND;
 538
 539 done:
 540         release_sock(sk);
 541         return err;
 542 }
 543
 544 static int sco_sock_connect(struct socket *sock, struct sockaddr *addr, int alen, int flags)
 545 {
 546         struct sockaddr_sco *sa = (struct sockaddr_sco *) addr;
 547         struct sock *sk = sock->sk;
 548         int err;
 549
 550         BT_DBG("sk %p", sk);
 551
 552         if (alen < sizeof(struct sockaddr_sco) ||
 553             addr->sa_family != AF_BLUETOOTH)
 554                 return -EINVAL;
 555
 556         if (sk->sk_state != BT_OPEN && sk->sk_state != BT_BOUND)
 557                 return -EBADFD;
 558
 559         if (sk->sk_type != SOCK_SEQPACKET)
 560                 return -EINVAL;
 561
 562         lock_sock(sk);
 563
 564         /* Set destination address and psm */
 565         bacpy(&sco_pi(sk)->dst, &sa->sco_bdaddr);
 566
 567         err = sco_connect(sk);
 568         if (err)
 569                 goto done;
 570
 571         err = bt_sock_wait_state(sk, BT_CONNECTED,
 572                                  sock_sndtimeo(sk, flags & O_NONBLOCK));
 573
 574 done:
 575         release_sock(sk);
 576         return err;
 577 }
 578
 579 static int sco_sock_listen(struct socket *sock, int backlog)
 580 {
 581         struct sock *sk = sock->sk;
 582         bdaddr_t *src = &sco_pi(sk)->src;
 583         int err = 0;
 584
 585         BT_DBG("sk %p backlog %d", sk, backlog);
 586
 587         lock_sock(sk);
 588
 589         if (sk->sk_state != BT_BOUND) {
 590                 err = -EBADFD;
 591                 goto done;
 592         }
 593
 594         if (sk->sk_type != SOCK_SEQPACKET) {
 595                 err = -EINVAL;
 596                 goto done;
 597         }
 598
 599         write_lock(&sco_sk_list.lock);
 600
 601         if (__sco_get_sock_listen_by_addr(src)) {
 602                 err = -EADDRINUSE;
 603                 goto unlock;
 604         }
 605
 606         sk->sk_max_ack_backlog = backlog;
 607         sk->sk_ack_backlog = 0;
 608
 609         sk->sk_state = BT_LISTEN;
 610
 611 unlock:
 612         write_unlock(&sco_sk_list.lock);
 613
 614 done:
 615         release_sock(sk);
 616         return err;
 617 }
 618
 619 static int sco_sock_accept(struct socket *sock, struct socket *newsock, int flags)
 620 {
 621         DECLARE_WAITQUEUE(wait, current);
 622         struct sock *sk = sock->sk, *ch;
 623         long timeo;
 624         int err = 0;
 625
 626         lock_sock(sk);
 627
 628         timeo = sock_rcvtimeo(sk, flags & O_NONBLOCK);
 629
 630         BT_DBG("sk %p timeo %ld", sk, timeo);
 631
 632         /* Wait for an incoming connection. (wake-one). */
 633         add_wait_queue_exclusive(sk_sleep(sk), &wait);
 634         while (1) {
 635                 set_current_state(TASK_INTERRUPTIBLE);
 636
 637                 if (sk->sk_state != BT_LISTEN) {
 638                         err = -EBADFD;
 639                         break;
 640                 }
 641
 642                 ch = bt_accept_dequeue(sk, newsock);
 643                 if (ch)
 644                         break;
 645
 646                 if (!timeo) {
 647                         err = -EAGAIN;
 648                         break;
 649                 }
 650
 651                 if (signal_pending(current)) {
 652                         err = sock_intr_errno(timeo);
 653                         break;
 654                 }
 655
 656                 release_sock(sk);
 657                 timeo = schedule_timeout(timeo);
 658                 lock_sock(sk);
 659         }
 660         __set_current_state(TASK_RUNNING);
 661         remove_wait_queue(sk_sleep(sk), &wait);
 662
 663         if (err)
 664                 goto done;
 665
 666         newsock->state = SS_CONNECTED;
 667
 668         BT_DBG("new socket %p", ch);
 669
 670 done:
 671         release_sock(sk);
 672         return err;
 673 }
 674
 675 static int sco_sock_getname(struct socket *sock, struct sockaddr *addr, int *len, int peer)
 676 {
 677         struct sockaddr_sco *sa = (struct sockaddr_sco *) addr;
 678         struct sock *sk = sock->sk;
 679
 680         BT_DBG("sock %p, sk %p", sock, sk);
 681
 682         addr->sa_family = AF_BLUETOOTH;
 683         *len = sizeof(struct sockaddr_sco);
 684
 685         if (peer)
 686                 bacpy(&sa->sco_bdaddr, &sco_pi(sk)->dst);
 687         else
 688                 bacpy(&sa->sco_bdaddr, &sco_pi(sk)->src);
 689
 690         return 0;
 691 }
 692
 693 static int sco_sock_sendmsg(struct kiocb *iocb, struct socket *sock,
 694                             struct msghdr *msg, size_t len)
 695 {
 696         struct sock *sk = sock->sk;
 697         int err;
 698
 699         BT_DBG("sock %p, sk %p", sock, sk);
 700
 701         err = sock_error(sk);
 702         if (err)
 703                 return err;
 704
 705         if (msg->msg_flags & MSG_OOB)
 706                 return -EOPNOTSUPP;
 707
 708         lock_sock(sk);
 709
 710         if (sk->sk_state == BT_CONNECTED)
 711                 err = sco_send_frame(sk, msg, len);
 712         else
 713                 err = -ENOTCONN;
 714
 715         release_sock(sk);
 716         return err;
 717 }
 718
 719 static void sco_conn_defer_accept(struct hci_conn *conn, u16 setting)
 720 {
 721         struct hci_dev *hdev = conn->hdev;
 722
 723         BT_DBG("conn %p", conn);
 724
 725         conn->state = BT_CONFIG;
 726
 727         if (!lmp_esco_capable(hdev)) {
 728                 struct hci_cp_accept_conn_req cp;
 729
 730                 bacpy(&cp.bdaddr, &conn->dst);
 731                 cp.role = 0x00; /* Ignored */
 732
 733                 hci_send_cmd(hdev, HCI_OP_ACCEPT_CONN_REQ, sizeof(cp), &cp);
 734         } else {
 735                 struct hci_cp_accept_sync_conn_req cp;
 736
 737                 bacpy(&cp.bdaddr, &conn->dst);
 738                 cp.pkt_type = cpu_to_le16(conn->pkt_type);
 739
 740                 cp.tx_bandwidth   = cpu_to_le32(0x00001f40);
 741                 cp.rx_bandwidth   = cpu_to_le32(0x00001f40);
 742                 cp.content_format = cpu_to_le16(setting);
 743
 744                 switch (setting & SCO_AIRMODE_MASK) {
 745                 case SCO_AIRMODE_TRANSP:
 746                         if (conn->pkt_type & ESCO_2EV3)
 747                                 cp.max_latency = cpu_to_le16(0x0008);
 748                         else
 749                                 cp.max_latency = cpu_to_le16(0x000D);
 750                         cp.retrans_effort = 0x02;
 751                         break;
 752                 case SCO_AIRMODE_CVSD:
 753                         cp.max_latency = cpu_to_le16(0xffff);
 754                         cp.retrans_effort = 0xff;
 755                         break;
 756                 }
 757
 758                 hci_send_cmd(hdev, HCI_OP_ACCEPT_SYNC_CONN_REQ,
 759                              sizeof(cp), &cp);
 760         }
 761 }
 762
 763 static int sco_sock_recvmsg(struct kiocb *iocb, struct socket *sock,
 764                             struct msghdr *msg, size_t len, int flags)
 765 {
 766         struct sock *sk = sock->sk;
 767         struct sco_pinfo *pi = sco_pi(sk);
 768
 769         lock_sock(sk);
 770
 771         if (sk->sk_state == BT_CONNECT2 &&
 772             test_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags)) {
 773                 sco_conn_defer_accept(pi->conn->hcon, pi->setting);
 774                 sk->sk_state = BT_CONFIG;
 775
 776                 release_sock(sk);
 777                 return 0;
 778         }
 779
 780         release_sock(sk);
 781
 782         return bt_sock_recvmsg(iocb, sock, msg, len, flags);
 783 }
 784
 785 static int sco_sock_setsockopt(struct socket *sock, int level, int optname, char __user *optval, unsigned int optlen)
 786 {
 787         struct sock *sk = sock->sk;
 788         int len, err = 0;
 789         struct bt_voice voice;
 790         u32 opt;
 791
 792         BT_DBG("sk %p", sk);
 793
 794         lock_sock(sk);
 795
 796         switch (optname) {
 797
 798         case BT_DEFER_SETUP:
 799                 if (sk->sk_state != BT_BOUND && sk->sk_state != BT_LISTEN) {
 800                         err = -EINVAL;
 801                         break;
 802                 }
 803
 804                 if (get_user(opt, (u32 __user *) optval)) {
 805                         err = -EFAULT;
 806                         break;
 807                 }
 808
 809                 if (opt)
 810                         set_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags);
 811                 else
 812                         clear_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags);
 813                 break;
 814
 815         case BT_VOICE:
 816                 if (sk->sk_state != BT_OPEN && sk->sk_state != BT_BOUND &&
 817                     sk->sk_state != BT_CONNECT2) {
 818                         err = -EINVAL;
 819                         break;
 820                 }
 821
 822                 voice.setting = sco_pi(sk)->setting;
 823
 824                 len = min_t(unsigned int, sizeof(voice), optlen);
 825                 if (copy_from_user((char *) &voice, optval, len)) {
 826                         err = -EFAULT;
 827                         break;
 828                 }
 829
 830                 /* Explicitly check for these values */
 831                 if (voice.setting != BT_VOICE_TRANSPARENT &&
 832                     voice.setting != BT_VOICE_CVSD_16BIT) {
 833                         err = -EINVAL;
 834                         break;
 835                 }
 836
 837                 sco_pi(sk)->setting = voice.setting;
 838                 break;
 839
 840         default:
 841                 err = -ENOPROTOOPT;
 842                 break;
 843         }
 844
 845         release_sock(sk);
 846         return err;
 847 }
 848
 849 static int sco_sock_getsockopt_old(struct socket *sock, int optname, char __user *optval, int __user *optlen)
 850 {
 851         struct sock *sk = sock->sk;
 852         struct sco_options opts;
 853         struct sco_conninfo cinfo;
 854         int len, err = 0;
 855
 856         BT_DBG("sk %p", sk);
 857
 858         if (get_user(len, optlen))
 859                 return -EFAULT;
 860
 861         lock_sock(sk);
 862
 863         switch (optname) {
 864         case SCO_OPTIONS:
 865                 if (sk->sk_state != BT_CONNECTED &&
 866                     !(sk->sk_state == BT_CONNECT2 &&
 867                       test_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags))) {
 868                         err = -ENOTCONN;
 869                         break;
 870                 }
 871
 872                 opts.mtu = sco_pi(sk)->conn->mtu;
 873
 874                 BT_DBG("mtu %d", opts.mtu);
 875
 876                 len = min_t(unsigned int, len, sizeof(opts));
 877                 if (copy_to_user(optval, (char *)&opts, len))
 878                         err = -EFAULT;
 879
 880                 break;
 881
 882         case SCO_CONNINFO:
 883                 if (sk->sk_state != BT_CONNECTED &&
 884                     !(sk->sk_state == BT_CONNECT2 &&
 885                       test_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags))) {
 886                         err = -ENOTCONN;
 887                         break;
 888                 }
 889
 890                 memset(&cinfo, 0, sizeof(cinfo));
 891                 cinfo.hci_handle = sco_pi(sk)->conn->hcon->handle;
 892                 memcpy(cinfo.dev_class, sco_pi(sk)->conn->hcon->dev_class, 3);
 893
 894                 len = min_t(unsigned int, len, sizeof(cinfo));
 895                 if (copy_to_user(optval, (char *)&cinfo, len))
 896                         err = -EFAULT;
 897
 898                 break;
 899
 900         default:
 901                 err = -ENOPROTOOPT;
 902                 break;
 903         }
 904
 905         release_sock(sk);
 906         return err;
 907 }
 908
 909 static int sco_sock_getsockopt(struct socket *sock, int level, int optname, char __user *optval, int __user *optlen)
 910 {
 911         struct sock *sk = sock->sk;
 912         int len, err = 0;
 913         struct bt_voice voice;
 914
 915         BT_DBG("sk %p", sk);
 916
 917         if (level == SOL_SCO)
 918                 return sco_sock_getsockopt_old(sock, optname, optval, optlen);
 919
 920         if (get_user(len, optlen))
 921                 return -EFAULT;
 922
 923         lock_sock(sk);
 924
 925         switch (optname) {
 926
 927         case BT_DEFER_SETUP:
 928                 if (sk->sk_state != BT_BOUND && sk->sk_state != BT_LISTEN) {
 929                         err = -EINVAL;
 930                         break;
 931                 }
 932
 933                 if (put_user(test_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags),
 934                              (u32 __user *) optval))
 935                         err = -EFAULT;
 936
 937                 break;
 938
 939         case BT_VOICE:
 940                 voice.setting = sco_pi(sk)->setting;
 941
 942                 len = min_t(unsigned int, len, sizeof(voice));
 943                 if (copy_to_user(optval, (char *)&voice, len))
 944                         err = -EFAULT;
 945
 946                 break;
 947
 948         default:
 949                 err = -ENOPROTOOPT;
 950                 break;
 951         }
 952
 953         release_sock(sk);
 954         return err;
 955 }
 956
 957 static int sco_sock_shutdown(struct socket *sock, int how)
 958 {
 959         struct sock *sk = sock->sk;
 960         int err = 0;
 961
 962         BT_DBG("sock %p, sk %p", sock, sk);
 963
 964         if (!sk)
 965                 return 0;
 966
 967         lock_sock(sk);
 968         if (!sk->sk_shutdown) {
 969                 sk->sk_shutdown = SHUTDOWN_MASK;
 970                 sco_sock_clear_timer(sk);
 971                 __sco_sock_close(sk);
 972
 973                 if (sock_flag(sk, SOCK_LINGER) && sk->sk_lingertime)
 974                         err = bt_sock_wait_state(sk, BT_CLOSED,
 975                                                  sk->sk_lingertime);
 976         }
 977         release_sock(sk);
 978         return err;
 979 }
 980
 981 static int sco_sock_release(struct socket *sock)
 982 {
 983         struct sock *sk = sock->sk;
 984         int err = 0;
 985
 986         BT_DBG("sock %p, sk %p", sock, sk);
 987
 988         if (!sk)
 989                 return 0;
 990
 991         sco_sock_close(sk);
 992
 993         if (sock_flag(sk, SOCK_LINGER) && sk->sk_lingertime) {
 994                 lock_sock(sk);
 995                 err = bt_sock_wait_state(sk, BT_CLOSED, sk->sk_lingertime);
 996                 release_sock(sk);
 997         }
 998
 999         sock_orphan(sk);
1000         sco_sock_kill(sk);
1001         return err;
1002 }
1003
1004 static void sco_conn_ready(struct sco_conn *conn)
1005 {
1006         struct sock *parent;
1007         struct sock *sk = conn->sk;
1008
1009         BT_DBG("conn %p", conn);
1010
1011         if (sk) {
1012                 sco_sock_clear_timer(sk);
1013                 bh_lock_sock(sk);
1014                 sk->sk_state = BT_CONNECTED;
1015                 sk->sk_state_change(sk);
1016                 bh_unlock_sock(sk);
1017         } else {
1018                 sco_conn_lock(conn);
1019
1020                 parent = sco_get_sock_listen(&conn->hcon->src);
1021                 if (!parent) {
1022                         sco_conn_unlock(conn);
1023                         return;
1024                 }
1025
1026                 bh_lock_sock(parent);
1027
1028                 sk = sco_sock_alloc(sock_net(parent), NULL,
1029                                     BTPROTO_SCO, GFP_ATOMIC);
1030                 if (!sk) {
1031                         bh_unlock_sock(parent);
1032                         sco_conn_unlock(conn);
1033                         return;
1034                 }
1035
1036                 sco_sock_init(sk, parent);
1037
1038                 bacpy(&sco_pi(sk)->src, &conn->hcon->src);
1039                 bacpy(&sco_pi(sk)->dst, &conn->hcon->dst);
1040
1041                 hci_conn_hold(conn->hcon);
1042                 __sco_chan_add(conn, sk, parent);
1043
1044                 if (test_bit(BT_SK_DEFER_SETUP, &bt_sk(parent)->flags))
1045                         sk->sk_state = BT_CONNECT2;
1046                 else
1047                         sk->sk_state = BT_CONNECTED;
1048
1049                 /* Wake up parent */
1050                 parent->sk_data_ready(parent);
1051
1052                 bh_unlock_sock(parent);
1053
1054                 sco_conn_unlock(conn);
1055         }
1056 }
1057
1058 /* ----- SCO interface with lower layer (HCI) ----- */
1059 int sco_connect_ind(struct hci_dev *hdev, bdaddr_t *bdaddr, __u8 *flags)
1060 {
1061         struct sock *sk;
1062         int lm = 0;
1063
1064         BT_DBG("hdev %s, bdaddr %pMR", hdev->name, bdaddr);
1065
1066         /* Find listening sockets */
1067         read_lock(&sco_sk_list.lock);
1068         sk_for_each(sk, &sco_sk_list.head) {
1069                 if (sk->sk_state != BT_LISTEN)
1070                         continue;
1071
1072                 if (!bacmp(&sco_pi(sk)->src, &hdev->bdaddr) ||
1073                     !bacmp(&sco_pi(sk)->src, BDADDR_ANY)) {
1074                         lm |= HCI_LM_ACCEPT;
1075
1076                         if (test_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags))
1077                                 *flags |= HCI_PROTO_DEFER;
1078                         break;
1079                 }
1080         }
1081         read_unlock(&sco_sk_list.lock);
1082
1083         return lm;
1084 }
1085
1086 void sco_connect_cfm(struct hci_conn *hcon, __u8 status)
1087 {
1088         BT_DBG("hcon %p bdaddr %pMR status %d", hcon, &hcon->dst, status);
1089         if (!status) {
1090                 struct sco_conn *conn;
1091
1092                 conn = sco_conn_add(hcon);
1093                 if (conn)
1094                         sco_conn_ready(conn);
1095         } else
1096                 sco_conn_del(hcon, bt_to_errno(status));
1097 }
1098
1099 void sco_disconn_cfm(struct hci_conn *hcon, __u8 reason)
1100 {
1101         BT_DBG("hcon %p reason %d", hcon, reason);
1102
1103         sco_conn_del(hcon, bt_to_errno(reason));
1104 }
1105
1106 int sco_recv_scodata(struct hci_conn *hcon, struct sk_buff *skb)
1107 {
1108         struct sco_conn *conn = hcon->sco_data;
1109
1110         if (!conn)
1111                 goto drop;
1112
1113         BT_DBG("conn %p len %d", conn, skb->len);
1114
1115         if (skb->len) {
1116                 sco_recv_frame(conn, skb);
1117                 return 0;
1118         }
1119
1120 drop:
1121         kfree_skb(skb);
1122         return 0;
1123 }
1124
1125 static int sco_debugfs_show(struct seq_file *f, void *p)
1126 {
1127         struct sock *sk;
1128
1129         read_lock(&sco_sk_list.lock);
1130
1131         sk_for_each(sk, &sco_sk_list.head) {
1132                 seq_printf(f, "%pMR %pMR %d\n", &sco_pi(sk)->src,
1133                            &sco_pi(sk)->dst, sk->sk_state);
1134         }
1135
1136         read_unlock(&sco_sk_list.lock);
1137
1138         return 0;
1139 }
1140
1141 static int sco_debugfs_open(struct inode *inode, struct file *file)
1142 {
1143         return single_open(file, sco_debugfs_show, inode->i_private);
1144 }
1145
1146 static const struct file_operations sco_debugfs_fops = {
1147         .open           = sco_debugfs_open,
1148         .read           = seq_read,
1149         .llseek         = seq_lseek,
1150         .release        = single_release,
1151 };
1152
1153 static struct dentry *sco_debugfs;
1154
1155 static const struct proto_ops sco_sock_ops = {
1156         .family         = PF_BLUETOOTH,
1157         .owner          = THIS_MODULE,
1158         .release        = sco_sock_release,
1159         .bind           = sco_sock_bind,
1160         .connect        = sco_sock_connect,
1161         .listen         = sco_sock_listen,
1162         .accept         = sco_sock_accept,
1163         .getname        = sco_sock_getname,
1164         .sendmsg        = sco_sock_sendmsg,
1165         .recvmsg        = sco_sock_recvmsg,
1166         .poll           = bt_sock_poll,
1167         .ioctl          = bt_sock_ioctl,
1168         .mmap           = sock_no_mmap,
1169         .socketpair     = sock_no_socketpair,
1170         .shutdown       = sco_sock_shutdown,
1171         .setsockopt     = sco_sock_setsockopt,
1172         .getsockopt     = sco_sock_getsockopt
1173 };
1174
1175 static const struct net_proto_family sco_sock_family_ops = {
1176         .family = PF_BLUETOOTH,
1177         .owner  = THIS_MODULE,
1178         .create = sco_sock_create,
1179 };
1180
1181 int __init sco_init(void)
1182 {
1183         int err;
1184
1185         err = proto_register(&sco_proto, 0);
1186         if (err < 0)
1187                 return err;
1188
1189         err = bt_sock_register(BTPROTO_SCO, &sco_sock_family_ops);
1190         if (err < 0) {
1191                 BT_ERR("SCO socket registration failed");
1192                 goto error;
1193         }
1194
1195         err = bt_procfs_init(&init_net, "sco", &sco_sk_list, NULL);
1196         if (err < 0) {
1197                 BT_ERR("Failed to create SCO proc file");
1198                 bt_sock_unregister(BTPROTO_SCO);
1199                 goto error;
1200         }
1201
1202         BT_INFO("SCO socket layer initialized");
1203
1204         if (IS_ERR_OR_NULL(bt_debugfs))
1205                 return 0;
1206
1207         sco_debugfs = debugfs_create_file("sco", 0444, bt_debugfs,
1208                                           NULL, &sco_debugfs_fops);
1209
1210         return 0;
1211
1212 error:
1213         proto_unregister(&sco_proto);
1214         return err;
1215 }
1216
1217 void __exit sco_exit(void)
1218 {
1219         bt_procfs_cleanup(&init_net, "sco");
1220
1221         debugfs_remove(sco_debugfs);
1222
1223         bt_sock_unregister(BTPROTO_SCO);
1224
1225         proto_unregister(&sco_proto);
1226 }
1227
1228 module_param(disable_esco, bool, 0644);
1229 MODULE_PARM_DESC(disable_esco, "Disable eSCO connection creation");