1 // SPDX-License-Identifier: GPL-2.0 2 /* 3 * BlueZ - Bluetooth protocol stack for Linux 4 * 5 * Copyright (C) 2022 Intel Corporation 6 */ 7 8 #include <linux/module.h> 9 #include <linux/debugfs.h> 10 #include <linux/seq_file.h> 11 #include <linux/sched/signal.h> 12 13 #include <net/bluetooth/bluetooth.h> 14 #include <net/bluetooth/hci_core.h> 15 #include <net/bluetooth/iso.h> 16 17 static const struct proto_ops iso_sock_ops; 18 19 static struct bt_sock_list iso_sk_list = { 20 .lock = __RW_LOCK_UNLOCKED(iso_sk_list.lock) 21 }; 22 23 /* ---- ISO connections ---- */ 24 struct iso_conn { 25 struct hci_conn *hcon; 26 27 /* @lock: spinlock protecting changes to iso_conn fields */ 28 spinlock_t lock; 29 struct sock *sk; 30 31 struct delayed_work timeout_work; 32 33 struct sk_buff *rx_skb; 34 __u32 rx_len; 35 __u16 tx_sn; 36 }; 37 38 #define iso_conn_lock(c) spin_lock(&(c)->lock) 39 #define iso_conn_unlock(c) spin_unlock(&(c)->lock) 40 41 static void iso_sock_close(struct sock *sk); 42 static void iso_sock_kill(struct sock *sk); 43 44 /* ----- ISO socket info ----- */ 45 #define iso_pi(sk) ((struct iso_pinfo *)sk) 46 47 #define EIR_SERVICE_DATA_LENGTH 4 48 #define BASE_MAX_LENGTH (HCI_MAX_PER_AD_LENGTH - EIR_SERVICE_DATA_LENGTH) 49 50 struct iso_pinfo { 51 struct bt_sock bt; 52 bdaddr_t src; 53 __u8 src_type; 54 bdaddr_t dst; 55 __u8 dst_type; 56 __u8 bc_sid; 57 __u8 bc_num_bis; 58 __u8 bc_bis[ISO_MAX_NUM_BIS]; 59 __u16 sync_handle; 60 __u32 flags; 61 struct bt_iso_qos qos; 62 __u8 base_len; 63 __u8 base[BASE_MAX_LENGTH]; 64 struct iso_conn *conn; 65 }; 66 67 /* ---- ISO timers ---- */ 68 #define ISO_CONN_TIMEOUT (HZ * 40) 69 #define ISO_DISCONN_TIMEOUT (HZ * 2) 70 71 static void iso_sock_timeout(struct work_struct *work) 72 { 73 struct iso_conn *conn = container_of(work, struct iso_conn, 74 timeout_work.work); 75 struct sock *sk; 76 77 iso_conn_lock(conn); 78 sk = conn->sk; 79 if (sk) 80 sock_hold(sk); 81 iso_conn_unlock(conn); 82 83 if (!sk) 84 return; 85 86 BT_DBG("sock %p state %d", sk, sk->sk_state); 87 88 lock_sock(sk); 89 sk->sk_err = ETIMEDOUT; 90 sk->sk_state_change(sk); 91 release_sock(sk); 92 sock_put(sk); 93 } 94 95 static void iso_sock_set_timer(struct sock *sk, long timeout) 96 { 97 if (!iso_pi(sk)->conn) 98 return; 99 100 BT_DBG("sock %p state %d timeout %ld", sk, sk->sk_state, timeout); 101 cancel_delayed_work(&iso_pi(sk)->conn->timeout_work); 102 schedule_delayed_work(&iso_pi(sk)->conn->timeout_work, timeout); 103 } 104 105 static void iso_sock_clear_timer(struct sock *sk) 106 { 107 if (!iso_pi(sk)->conn) 108 return; 109 110 BT_DBG("sock %p state %d", sk, sk->sk_state); 111 cancel_delayed_work(&iso_pi(sk)->conn->timeout_work); 112 } 113 114 /* ---- ISO connections ---- */ 115 static struct iso_conn *iso_conn_add(struct hci_conn *hcon) 116 { 117 struct iso_conn *conn = hcon->iso_data; 118 119 if (conn) 120 return conn; 121 122 conn = kzalloc(sizeof(*conn), GFP_KERNEL); 123 if (!conn) 124 return NULL; 125 126 spin_lock_init(&conn->lock); 127 INIT_DELAYED_WORK(&conn->timeout_work, iso_sock_timeout); 128 129 hcon->iso_data = conn; 130 conn->hcon = hcon; 131 conn->tx_sn = 0; 132 133 BT_DBG("hcon %p conn %p", hcon, conn); 134 135 return conn; 136 } 137 138 /* Delete channel. Must be called on the locked socket. */ 139 static void iso_chan_del(struct sock *sk, int err) 140 { 141 struct iso_conn *conn; 142 struct sock *parent; 143 144 conn = iso_pi(sk)->conn; 145 146 BT_DBG("sk %p, conn %p, err %d", sk, conn, err); 147 148 if (conn) { 149 iso_conn_lock(conn); 150 conn->sk = NULL; 151 iso_pi(sk)->conn = NULL; 152 iso_conn_unlock(conn); 153 154 if (conn->hcon) 155 hci_conn_drop(conn->hcon); 156 } 157 158 sk->sk_state = BT_CLOSED; 159 sk->sk_err = err; 160 161 parent = bt_sk(sk)->parent; 162 if (parent) { 163 bt_accept_unlink(sk); 164 parent->sk_data_ready(parent); 165 } else { 166 sk->sk_state_change(sk); 167 } 168 169 sock_set_flag(sk, SOCK_ZAPPED); 170 } 171 172 static void iso_conn_del(struct hci_conn *hcon, int err) 173 { 174 struct iso_conn *conn = hcon->iso_data; 175 struct sock *sk; 176 177 if (!conn) 178 return; 179 180 BT_DBG("hcon %p conn %p, err %d", hcon, conn, err); 181 182 /* Kill socket */ 183 iso_conn_lock(conn); 184 sk = conn->sk; 185 if (sk) 186 sock_hold(sk); 187 iso_conn_unlock(conn); 188 189 if (sk) { 190 lock_sock(sk); 191 iso_sock_clear_timer(sk); 192 iso_chan_del(sk, err); 193 release_sock(sk); 194 sock_put(sk); 195 } 196 197 /* Ensure no more work items will run before freeing conn. */ 198 cancel_delayed_work_sync(&conn->timeout_work); 199 200 hcon->iso_data = NULL; 201 kfree(conn); 202 } 203 204 static int __iso_chan_add(struct iso_conn *conn, struct sock *sk, 205 struct sock *parent) 206 { 207 BT_DBG("conn %p", conn); 208 209 if (iso_pi(sk)->conn == conn && conn->sk == sk) 210 return 0; 211 212 if (conn->sk) { 213 BT_ERR("conn->sk already set"); 214 return -EBUSY; 215 } 216 217 iso_pi(sk)->conn = conn; 218 conn->sk = sk; 219 220 if (parent) 221 bt_accept_enqueue(parent, sk, true); 222 223 return 0; 224 } 225 226 static int iso_chan_add(struct iso_conn *conn, struct sock *sk, 227 struct sock *parent) 228 { 229 int err; 230 231 iso_conn_lock(conn); 232 err = __iso_chan_add(conn, sk, parent); 233 iso_conn_unlock(conn); 234 235 return err; 236 } 237 238 static inline u8 le_addr_type(u8 bdaddr_type) 239 { 240 if (bdaddr_type == BDADDR_LE_PUBLIC) 241 return ADDR_LE_DEV_PUBLIC; 242 else 243 return ADDR_LE_DEV_RANDOM; 244 } 245 246 static int iso_connect_bis(struct sock *sk) 247 { 248 struct iso_conn *conn; 249 struct hci_conn *hcon; 250 struct hci_dev *hdev; 251 int err; 252 253 BT_DBG("%pMR", &iso_pi(sk)->src); 254 255 hdev = hci_get_route(&iso_pi(sk)->dst, &iso_pi(sk)->src, 256 iso_pi(sk)->src_type); 257 if (!hdev) 258 return -EHOSTUNREACH; 259 260 hci_dev_lock(hdev); 261 262 if (!bis_capable(hdev)) { 263 err = -EOPNOTSUPP; 264 goto done; 265 } 266 267 /* Fail if out PHYs are marked as disabled */ 268 if (!iso_pi(sk)->qos.out.phy) { 269 err = -EINVAL; 270 goto done; 271 } 272 273 hcon = hci_connect_bis(hdev, &iso_pi(sk)->dst, iso_pi(sk)->dst_type, 274 &iso_pi(sk)->qos, iso_pi(sk)->base_len, 275 iso_pi(sk)->base); 276 if (IS_ERR(hcon)) { 277 err = PTR_ERR(hcon); 278 goto done; 279 } 280 281 conn = iso_conn_add(hcon); 282 if (!conn) { 283 hci_conn_drop(hcon); 284 err = -ENOMEM; 285 goto done; 286 } 287 288 /* Update source addr of the socket */ 289 bacpy(&iso_pi(sk)->src, &hcon->src); 290 291 err = iso_chan_add(conn, sk, NULL); 292 if (err) 293 goto done; 294 295 if (hcon->state == BT_CONNECTED) { 296 iso_sock_clear_timer(sk); 297 sk->sk_state = BT_CONNECTED; 298 } else { 299 sk->sk_state = BT_CONNECT; 300 iso_sock_set_timer(sk, sk->sk_sndtimeo); 301 } 302 303 done: 304 hci_dev_unlock(hdev); 305 hci_dev_put(hdev); 306 return err; 307 } 308 309 static int iso_connect_cis(struct sock *sk) 310 { 311 struct iso_conn *conn; 312 struct hci_conn *hcon; 313 struct hci_dev *hdev; 314 int err; 315 316 BT_DBG("%pMR -> %pMR", &iso_pi(sk)->src, &iso_pi(sk)->dst); 317 318 hdev = hci_get_route(&iso_pi(sk)->dst, &iso_pi(sk)->src, 319 iso_pi(sk)->src_type); 320 if (!hdev) 321 return -EHOSTUNREACH; 322 323 hci_dev_lock(hdev); 324 325 if (!cis_central_capable(hdev)) { 326 err = -EOPNOTSUPP; 327 goto done; 328 } 329 330 /* Fail if either PHYs are marked as disabled */ 331 if (!iso_pi(sk)->qos.in.phy && !iso_pi(sk)->qos.out.phy) { 332 err = -EINVAL; 333 goto done; 334 } 335 336 /* Just bind if DEFER_SETUP has been set */ 337 if (test_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags)) { 338 hcon = hci_bind_cis(hdev, &iso_pi(sk)->dst, 339 le_addr_type(iso_pi(sk)->dst_type), 340 &iso_pi(sk)->qos); 341 if (IS_ERR(hcon)) { 342 err = PTR_ERR(hcon); 343 goto done; 344 } 345 } else { 346 hcon = hci_connect_cis(hdev, &iso_pi(sk)->dst, 347 le_addr_type(iso_pi(sk)->dst_type), 348 &iso_pi(sk)->qos); 349 if (IS_ERR(hcon)) { 350 err = PTR_ERR(hcon); 351 goto done; 352 } 353 } 354 355 conn = iso_conn_add(hcon); 356 if (!conn) { 357 hci_conn_drop(hcon); 358 err = -ENOMEM; 359 goto done; 360 } 361 362 /* Update source addr of the socket */ 363 bacpy(&iso_pi(sk)->src, &hcon->src); 364 365 err = iso_chan_add(conn, sk, NULL); 366 if (err) 367 goto done; 368 369 if (hcon->state == BT_CONNECTED) { 370 iso_sock_clear_timer(sk); 371 sk->sk_state = BT_CONNECTED; 372 } else if (test_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags)) { 373 iso_sock_clear_timer(sk); 374 sk->sk_state = BT_CONNECT; 375 } else { 376 sk->sk_state = BT_CONNECT; 377 iso_sock_set_timer(sk, sk->sk_sndtimeo); 378 } 379 380 done: 381 hci_dev_unlock(hdev); 382 hci_dev_put(hdev); 383 return err; 384 } 385 386 static struct bt_iso_qos *iso_sock_get_qos(struct sock *sk) 387 { 388 if (sk->sk_state == BT_CONNECTED || sk->sk_state == BT_CONNECT2) 389 return &iso_pi(sk)->conn->hcon->iso_qos; 390 391 return &iso_pi(sk)->qos; 392 } 393 394 static int iso_send_frame(struct sock *sk, struct sk_buff *skb) 395 { 396 struct iso_conn *conn = iso_pi(sk)->conn; 397 struct bt_iso_qos *qos = iso_sock_get_qos(sk); 398 struct hci_iso_data_hdr *hdr; 399 int len = 0; 400 401 BT_DBG("sk %p len %d", sk, skb->len); 402 403 if (skb->len > qos->out.sdu) 404 return -EMSGSIZE; 405 406 len = skb->len; 407 408 /* Push ISO data header */ 409 hdr = skb_push(skb, HCI_ISO_DATA_HDR_SIZE); 410 hdr->sn = cpu_to_le16(conn->tx_sn++); 411 hdr->slen = cpu_to_le16(hci_iso_data_len_pack(len, 412 HCI_ISO_STATUS_VALID)); 413 414 if (sk->sk_state == BT_CONNECTED) 415 hci_send_iso(conn->hcon, skb); 416 else 417 len = -ENOTCONN; 418 419 return len; 420 } 421 422 static void iso_recv_frame(struct iso_conn *conn, struct sk_buff *skb) 423 { 424 struct sock *sk; 425 426 iso_conn_lock(conn); 427 sk = conn->sk; 428 iso_conn_unlock(conn); 429 430 if (!sk) 431 goto drop; 432 433 BT_DBG("sk %p len %d", sk, skb->len); 434 435 if (sk->sk_state != BT_CONNECTED) 436 goto drop; 437 438 if (!sock_queue_rcv_skb(sk, skb)) 439 return; 440 441 drop: 442 kfree_skb(skb); 443 } 444 445 /* -------- Socket interface ---------- */ 446 static struct sock *__iso_get_sock_listen_by_addr(bdaddr_t *ba) 447 { 448 struct sock *sk; 449 450 sk_for_each(sk, &iso_sk_list.head) { 451 if (sk->sk_state != BT_LISTEN) 452 continue; 453 454 if (!bacmp(&iso_pi(sk)->src, ba)) 455 return sk; 456 } 457 458 return NULL; 459 } 460 461 static struct sock *__iso_get_sock_listen_by_sid(bdaddr_t *ba, bdaddr_t *bc, 462 __u8 sid) 463 { 464 struct sock *sk; 465 466 sk_for_each(sk, &iso_sk_list.head) { 467 if (sk->sk_state != BT_LISTEN) 468 continue; 469 470 if (bacmp(&iso_pi(sk)->src, ba)) 471 continue; 472 473 if (bacmp(&iso_pi(sk)->dst, bc)) 474 continue; 475 476 if (iso_pi(sk)->bc_sid == sid) 477 return sk; 478 } 479 480 return NULL; 481 } 482 483 typedef bool (*iso_sock_match_t)(struct sock *sk, void *data); 484 485 /* Find socket listening: 486 * source bdaddr (Unicast) 487 * destination bdaddr (Broadcast only) 488 * match func - pass NULL to ignore 489 * match func data - pass -1 to ignore 490 * Returns closest match. 491 */ 492 static struct sock *iso_get_sock_listen(bdaddr_t *src, bdaddr_t *dst, 493 iso_sock_match_t match, void *data) 494 { 495 struct sock *sk = NULL, *sk1 = NULL; 496 497 read_lock(&iso_sk_list.lock); 498 499 sk_for_each(sk, &iso_sk_list.head) { 500 if (sk->sk_state != BT_LISTEN) 501 continue; 502 503 /* Match Broadcast destination */ 504 if (bacmp(dst, BDADDR_ANY) && bacmp(&iso_pi(sk)->dst, dst)) 505 continue; 506 507 /* Use Match function if provided */ 508 if (match && !match(sk, data)) 509 continue; 510 511 /* Exact match. */ 512 if (!bacmp(&iso_pi(sk)->src, src)) 513 break; 514 515 /* Closest match */ 516 if (!bacmp(&iso_pi(sk)->src, BDADDR_ANY)) 517 sk1 = sk; 518 } 519 520 read_unlock(&iso_sk_list.lock); 521 522 return sk ? sk : sk1; 523 } 524 525 static void iso_sock_destruct(struct sock *sk) 526 { 527 BT_DBG("sk %p", sk); 528 529 skb_queue_purge(&sk->sk_receive_queue); 530 skb_queue_purge(&sk->sk_write_queue); 531 } 532 533 static void iso_sock_cleanup_listen(struct sock *parent) 534 { 535 struct sock *sk; 536 537 BT_DBG("parent %p", parent); 538 539 /* Close not yet accepted channels */ 540 while ((sk = bt_accept_dequeue(parent, NULL))) { 541 iso_sock_close(sk); 542 iso_sock_kill(sk); 543 } 544 545 parent->sk_state = BT_CLOSED; 546 sock_set_flag(parent, SOCK_ZAPPED); 547 } 548 549 /* Kill socket (only if zapped and orphan) 550 * Must be called on unlocked socket. 551 */ 552 static void iso_sock_kill(struct sock *sk) 553 { 554 if (!sock_flag(sk, SOCK_ZAPPED) || sk->sk_socket || 555 sock_flag(sk, SOCK_DEAD)) 556 return; 557 558 BT_DBG("sk %p state %d", sk, sk->sk_state); 559 560 /* Kill poor orphan */ 561 bt_sock_unlink(&iso_sk_list, sk); 562 sock_set_flag(sk, SOCK_DEAD); 563 sock_put(sk); 564 } 565 566 static void iso_conn_defer_reject(struct hci_conn *conn) 567 { 568 struct hci_cp_le_reject_cis cp; 569 570 BT_DBG("conn %p", conn); 571 572 memset(&cp, 0, sizeof(cp)); 573 cp.handle = cpu_to_le16(conn->handle); 574 cp.reason = HCI_ERROR_REJ_BAD_ADDR; 575 hci_send_cmd(conn->hdev, HCI_OP_LE_REJECT_CIS, sizeof(cp), &cp); 576 } 577 578 static void __iso_sock_close(struct sock *sk) 579 { 580 BT_DBG("sk %p state %d socket %p", sk, sk->sk_state, sk->sk_socket); 581 582 switch (sk->sk_state) { 583 case BT_LISTEN: 584 iso_sock_cleanup_listen(sk); 585 break; 586 587 case BT_CONNECTED: 588 case BT_CONFIG: 589 if (iso_pi(sk)->conn->hcon) { 590 sk->sk_state = BT_DISCONN; 591 iso_sock_set_timer(sk, ISO_DISCONN_TIMEOUT); 592 iso_conn_lock(iso_pi(sk)->conn); 593 hci_conn_drop(iso_pi(sk)->conn->hcon); 594 iso_pi(sk)->conn->hcon = NULL; 595 iso_conn_unlock(iso_pi(sk)->conn); 596 } else { 597 iso_chan_del(sk, ECONNRESET); 598 } 599 break; 600 601 case BT_CONNECT2: 602 if (iso_pi(sk)->conn->hcon) 603 iso_conn_defer_reject(iso_pi(sk)->conn->hcon); 604 iso_chan_del(sk, ECONNRESET); 605 break; 606 case BT_CONNECT: 607 /* In case of DEFER_SETUP the hcon would be bound to CIG which 608 * needs to be removed so just call hci_conn_del so the cleanup 609 * callback do what is needed. 610 */ 611 if (test_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags) && 612 iso_pi(sk)->conn->hcon) { 613 hci_conn_del(iso_pi(sk)->conn->hcon); 614 iso_pi(sk)->conn->hcon = NULL; 615 } 616 617 iso_chan_del(sk, ECONNRESET); 618 break; 619 case BT_DISCONN: 620 iso_chan_del(sk, ECONNRESET); 621 break; 622 623 default: 624 sock_set_flag(sk, SOCK_ZAPPED); 625 break; 626 } 627 } 628 629 /* Must be called on unlocked socket. */ 630 static void iso_sock_close(struct sock *sk) 631 { 632 iso_sock_clear_timer(sk); 633 lock_sock(sk); 634 __iso_sock_close(sk); 635 release_sock(sk); 636 iso_sock_kill(sk); 637 } 638 639 static void iso_sock_init(struct sock *sk, struct sock *parent) 640 { 641 BT_DBG("sk %p", sk); 642 643 if (parent) { 644 sk->sk_type = parent->sk_type; 645 bt_sk(sk)->flags = bt_sk(parent)->flags; 646 security_sk_clone(parent, sk); 647 } 648 } 649 650 static struct proto iso_proto = { 651 .name = "ISO", 652 .owner = THIS_MODULE, 653 .obj_size = sizeof(struct iso_pinfo) 654 }; 655 656 #define DEFAULT_IO_QOS \ 657 { \ 658 .interval = 10000u, \ 659 .latency = 10u, \ 660 .sdu = 40u, \ 661 .phy = BT_ISO_PHY_2M, \ 662 .rtn = 2u, \ 663 } 664 665 static struct bt_iso_qos default_qos = { 666 .cig = BT_ISO_QOS_CIG_UNSET, 667 .cis = BT_ISO_QOS_CIS_UNSET, 668 .sca = 0x00, 669 .packing = 0x00, 670 .framing = 0x00, 671 .in = DEFAULT_IO_QOS, 672 .out = DEFAULT_IO_QOS, 673 }; 674 675 static struct sock *iso_sock_alloc(struct net *net, struct socket *sock, 676 int proto, gfp_t prio, int kern) 677 { 678 struct sock *sk; 679 680 sk = sk_alloc(net, PF_BLUETOOTH, prio, &iso_proto, kern); 681 if (!sk) 682 return NULL; 683 684 sock_init_data(sock, sk); 685 INIT_LIST_HEAD(&bt_sk(sk)->accept_q); 686 687 sk->sk_destruct = iso_sock_destruct; 688 sk->sk_sndtimeo = ISO_CONN_TIMEOUT; 689 690 sock_reset_flag(sk, SOCK_ZAPPED); 691 692 sk->sk_protocol = proto; 693 sk->sk_state = BT_OPEN; 694 695 /* Set address type as public as default src address is BDADDR_ANY */ 696 iso_pi(sk)->src_type = BDADDR_LE_PUBLIC; 697 698 iso_pi(sk)->qos = default_qos; 699 700 bt_sock_link(&iso_sk_list, sk); 701 return sk; 702 } 703 704 static int iso_sock_create(struct net *net, struct socket *sock, int protocol, 705 int kern) 706 { 707 struct sock *sk; 708 709 BT_DBG("sock %p", sock); 710 711 sock->state = SS_UNCONNECTED; 712 713 if (sock->type != SOCK_SEQPACKET) 714 return -ESOCKTNOSUPPORT; 715 716 sock->ops = &iso_sock_ops; 717 718 sk = iso_sock_alloc(net, sock, protocol, GFP_ATOMIC, kern); 719 if (!sk) 720 return -ENOMEM; 721 722 iso_sock_init(sk, NULL); 723 return 0; 724 } 725 726 static int iso_sock_bind_bc(struct socket *sock, struct sockaddr *addr, 727 int addr_len) 728 { 729 struct sockaddr_iso *sa = (struct sockaddr_iso *)addr; 730 struct sock *sk = sock->sk; 731 int i; 732 733 BT_DBG("sk %p bc_sid %u bc_num_bis %u", sk, sa->iso_bc->bc_sid, 734 sa->iso_bc->bc_num_bis); 735 736 if (addr_len > sizeof(*sa) + sizeof(*sa->iso_bc) || 737 sa->iso_bc->bc_num_bis < 0x01 || sa->iso_bc->bc_num_bis > 0x1f) 738 return -EINVAL; 739 740 bacpy(&iso_pi(sk)->dst, &sa->iso_bc->bc_bdaddr); 741 iso_pi(sk)->dst_type = sa->iso_bc->bc_bdaddr_type; 742 iso_pi(sk)->sync_handle = -1; 743 iso_pi(sk)->bc_sid = sa->iso_bc->bc_sid; 744 iso_pi(sk)->bc_num_bis = sa->iso_bc->bc_num_bis; 745 746 for (i = 0; i < iso_pi(sk)->bc_num_bis; i++) { 747 if (sa->iso_bc->bc_bis[i] < 0x01 || 748 sa->iso_bc->bc_bis[i] > 0x1f) 749 return -EINVAL; 750 751 memcpy(iso_pi(sk)->bc_bis, sa->iso_bc->bc_bis, 752 iso_pi(sk)->bc_num_bis); 753 } 754 755 return 0; 756 } 757 758 static int iso_sock_bind(struct socket *sock, struct sockaddr *addr, 759 int addr_len) 760 { 761 struct sockaddr_iso *sa = (struct sockaddr_iso *)addr; 762 struct sock *sk = sock->sk; 763 int err = 0; 764 765 BT_DBG("sk %p %pMR type %u", sk, &sa->iso_bdaddr, sa->iso_bdaddr_type); 766 767 if (!addr || addr_len < sizeof(struct sockaddr_iso) || 768 addr->sa_family != AF_BLUETOOTH) 769 return -EINVAL; 770 771 lock_sock(sk); 772 773 if (sk->sk_state != BT_OPEN) { 774 err = -EBADFD; 775 goto done; 776 } 777 778 if (sk->sk_type != SOCK_SEQPACKET) { 779 err = -EINVAL; 780 goto done; 781 } 782 783 /* Check if the address type is of LE type */ 784 if (!bdaddr_type_is_le(sa->iso_bdaddr_type)) { 785 err = -EINVAL; 786 goto done; 787 } 788 789 bacpy(&iso_pi(sk)->src, &sa->iso_bdaddr); 790 iso_pi(sk)->src_type = sa->iso_bdaddr_type; 791 792 /* Check for Broadcast address */ 793 if (addr_len > sizeof(*sa)) { 794 err = iso_sock_bind_bc(sock, addr, addr_len); 795 if (err) 796 goto done; 797 } 798 799 sk->sk_state = BT_BOUND; 800 801 done: 802 release_sock(sk); 803 return err; 804 } 805 806 static int iso_sock_connect(struct socket *sock, struct sockaddr *addr, 807 int alen, int flags) 808 { 809 struct sockaddr_iso *sa = (struct sockaddr_iso *)addr; 810 struct sock *sk = sock->sk; 811 int err; 812 813 BT_DBG("sk %p", sk); 814 815 if (alen < sizeof(struct sockaddr_iso) || 816 addr->sa_family != AF_BLUETOOTH) 817 return -EINVAL; 818 819 if (sk->sk_state != BT_OPEN && sk->sk_state != BT_BOUND) 820 return -EBADFD; 821 822 if (sk->sk_type != SOCK_SEQPACKET) 823 return -EINVAL; 824 825 /* Check if the address type is of LE type */ 826 if (!bdaddr_type_is_le(sa->iso_bdaddr_type)) 827 return -EINVAL; 828 829 lock_sock(sk); 830 831 bacpy(&iso_pi(sk)->dst, &sa->iso_bdaddr); 832 iso_pi(sk)->dst_type = sa->iso_bdaddr_type; 833 834 if (bacmp(&iso_pi(sk)->dst, BDADDR_ANY)) 835 err = iso_connect_cis(sk); 836 else 837 err = iso_connect_bis(sk); 838 839 if (err) 840 goto done; 841 842 if (!test_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags)) { 843 err = bt_sock_wait_state(sk, BT_CONNECTED, 844 sock_sndtimeo(sk, flags & O_NONBLOCK)); 845 } 846 847 done: 848 release_sock(sk); 849 return err; 850 } 851 852 static int iso_listen_bis(struct sock *sk) 853 { 854 struct hci_dev *hdev; 855 int err = 0; 856 857 BT_DBG("%pMR -> %pMR (SID 0x%2.2x)", &iso_pi(sk)->src, 858 &iso_pi(sk)->dst, iso_pi(sk)->bc_sid); 859 860 write_lock(&iso_sk_list.lock); 861 862 if (__iso_get_sock_listen_by_sid(&iso_pi(sk)->src, &iso_pi(sk)->dst, 863 iso_pi(sk)->bc_sid)) 864 err = -EADDRINUSE; 865 866 write_unlock(&iso_sk_list.lock); 867 868 if (err) 869 return err; 870 871 hdev = hci_get_route(&iso_pi(sk)->dst, &iso_pi(sk)->src, 872 iso_pi(sk)->src_type); 873 if (!hdev) 874 return -EHOSTUNREACH; 875 876 hci_dev_lock(hdev); 877 878 err = hci_pa_create_sync(hdev, &iso_pi(sk)->dst, iso_pi(sk)->dst_type, 879 iso_pi(sk)->bc_sid); 880 881 hci_dev_unlock(hdev); 882 hci_dev_put(hdev); 883 884 return err; 885 } 886 887 static int iso_listen_cis(struct sock *sk) 888 { 889 int err = 0; 890 891 BT_DBG("%pMR", &iso_pi(sk)->src); 892 893 write_lock(&iso_sk_list.lock); 894 895 if (__iso_get_sock_listen_by_addr(&iso_pi(sk)->src)) 896 err = -EADDRINUSE; 897 898 write_unlock(&iso_sk_list.lock); 899 900 return err; 901 } 902 903 static int iso_sock_listen(struct socket *sock, int backlog) 904 { 905 struct sock *sk = sock->sk; 906 int err = 0; 907 908 BT_DBG("sk %p backlog %d", sk, backlog); 909 910 lock_sock(sk); 911 912 if (sk->sk_state != BT_BOUND) { 913 err = -EBADFD; 914 goto done; 915 } 916 917 if (sk->sk_type != SOCK_SEQPACKET) { 918 err = -EINVAL; 919 goto done; 920 } 921 922 if (!bacmp(&iso_pi(sk)->dst, BDADDR_ANY)) 923 err = iso_listen_cis(sk); 924 else 925 err = iso_listen_bis(sk); 926 927 if (err) 928 goto done; 929 930 sk->sk_max_ack_backlog = backlog; 931 sk->sk_ack_backlog = 0; 932 933 sk->sk_state = BT_LISTEN; 934 935 done: 936 release_sock(sk); 937 return err; 938 } 939 940 static int iso_sock_accept(struct socket *sock, struct socket *newsock, 941 int flags, bool kern) 942 { 943 DEFINE_WAIT_FUNC(wait, woken_wake_function); 944 struct sock *sk = sock->sk, *ch; 945 long timeo; 946 int err = 0; 947 948 lock_sock(sk); 949 950 timeo = sock_rcvtimeo(sk, flags & O_NONBLOCK); 951 952 BT_DBG("sk %p timeo %ld", sk, timeo); 953 954 /* Wait for an incoming connection. (wake-one). */ 955 add_wait_queue_exclusive(sk_sleep(sk), &wait); 956 while (1) { 957 if (sk->sk_state != BT_LISTEN) { 958 err = -EBADFD; 959 break; 960 } 961 962 ch = bt_accept_dequeue(sk, newsock); 963 if (ch) 964 break; 965 966 if (!timeo) { 967 err = -EAGAIN; 968 break; 969 } 970 971 if (signal_pending(current)) { 972 err = sock_intr_errno(timeo); 973 break; 974 } 975 976 release_sock(sk); 977 978 timeo = wait_woken(&wait, TASK_INTERRUPTIBLE, timeo); 979 lock_sock(sk); 980 } 981 remove_wait_queue(sk_sleep(sk), &wait); 982 983 if (err) 984 goto done; 985 986 newsock->state = SS_CONNECTED; 987 988 BT_DBG("new socket %p", ch); 989 990 done: 991 release_sock(sk); 992 return err; 993 } 994 995 static int iso_sock_getname(struct socket *sock, struct sockaddr *addr, 996 int peer) 997 { 998 struct sockaddr_iso *sa = (struct sockaddr_iso *)addr; 999 struct sock *sk = sock->sk; 1000 1001 BT_DBG("sock %p, sk %p", sock, sk); 1002 1003 addr->sa_family = AF_BLUETOOTH; 1004 1005 if (peer) { 1006 bacpy(&sa->iso_bdaddr, &iso_pi(sk)->dst); 1007 sa->iso_bdaddr_type = iso_pi(sk)->dst_type; 1008 } else { 1009 bacpy(&sa->iso_bdaddr, &iso_pi(sk)->src); 1010 sa->iso_bdaddr_type = iso_pi(sk)->src_type; 1011 } 1012 1013 return sizeof(struct sockaddr_iso); 1014 } 1015 1016 static int iso_sock_sendmsg(struct socket *sock, struct msghdr *msg, 1017 size_t len) 1018 { 1019 struct sock *sk = sock->sk; 1020 struct iso_conn *conn = iso_pi(sk)->conn; 1021 struct sk_buff *skb, **frag; 1022 int err; 1023 1024 BT_DBG("sock %p, sk %p", sock, sk); 1025 1026 err = sock_error(sk); 1027 if (err) 1028 return err; 1029 1030 if (msg->msg_flags & MSG_OOB) 1031 return -EOPNOTSUPP; 1032 1033 if (sk->sk_state != BT_CONNECTED) 1034 return -ENOTCONN; 1035 1036 skb = bt_skb_sendmsg(sk, msg, len, conn->hcon->hdev->iso_mtu, 1037 HCI_ISO_DATA_HDR_SIZE, 0); 1038 if (IS_ERR(skb)) 1039 return PTR_ERR(skb); 1040 1041 len -= skb->len; 1042 1043 BT_DBG("skb %p len %d", sk, skb->len); 1044 1045 /* Continuation fragments */ 1046 frag = &skb_shinfo(skb)->frag_list; 1047 while (len) { 1048 struct sk_buff *tmp; 1049 1050 tmp = bt_skb_sendmsg(sk, msg, len, conn->hcon->hdev->iso_mtu, 1051 0, 0); 1052 if (IS_ERR(tmp)) { 1053 kfree_skb(skb); 1054 return PTR_ERR(tmp); 1055 } 1056 1057 *frag = tmp; 1058 1059 len -= tmp->len; 1060 1061 skb->len += tmp->len; 1062 skb->data_len += tmp->len; 1063 1064 BT_DBG("frag %p len %d", *frag, tmp->len); 1065 1066 frag = &(*frag)->next; 1067 } 1068 1069 lock_sock(sk); 1070 1071 if (sk->sk_state == BT_CONNECTED) 1072 err = iso_send_frame(sk, skb); 1073 else 1074 err = -ENOTCONN; 1075 1076 release_sock(sk); 1077 1078 if (err < 0) 1079 kfree_skb(skb); 1080 return err; 1081 } 1082 1083 static void iso_conn_defer_accept(struct hci_conn *conn) 1084 { 1085 struct hci_cp_le_accept_cis cp; 1086 struct hci_dev *hdev = conn->hdev; 1087 1088 BT_DBG("conn %p", conn); 1089 1090 conn->state = BT_CONFIG; 1091 1092 cp.handle = cpu_to_le16(conn->handle); 1093 1094 hci_send_cmd(hdev, HCI_OP_LE_ACCEPT_CIS, sizeof(cp), &cp); 1095 } 1096 1097 static int iso_sock_recvmsg(struct socket *sock, struct msghdr *msg, 1098 size_t len, int flags) 1099 { 1100 struct sock *sk = sock->sk; 1101 struct iso_pinfo *pi = iso_pi(sk); 1102 int err; 1103 1104 BT_DBG("sk %p", sk); 1105 1106 lock_sock(sk); 1107 1108 if (test_and_clear_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags)) { 1109 switch (sk->sk_state) { 1110 case BT_CONNECT2: 1111 iso_conn_defer_accept(pi->conn->hcon); 1112 sk->sk_state = BT_CONFIG; 1113 release_sock(sk); 1114 return 0; 1115 case BT_CONNECT: 1116 err = iso_connect_cis(sk); 1117 release_sock(sk); 1118 return err; 1119 } 1120 } 1121 1122 release_sock(sk); 1123 1124 return bt_sock_recvmsg(sock, msg, len, flags); 1125 } 1126 1127 static bool check_io_qos(struct bt_iso_io_qos *qos) 1128 { 1129 /* If no PHY is enable SDU must be 0 */ 1130 if (!qos->phy && qos->sdu) 1131 return false; 1132 1133 if (qos->interval && (qos->interval < 0xff || qos->interval > 0xfffff)) 1134 return false; 1135 1136 if (qos->latency && (qos->latency < 0x05 || qos->latency > 0xfa0)) 1137 return false; 1138 1139 if (qos->phy > BT_ISO_PHY_ANY) 1140 return false; 1141 1142 return true; 1143 } 1144 1145 static bool check_qos(struct bt_iso_qos *qos) 1146 { 1147 if (qos->sca > 0x07) 1148 return false; 1149 1150 if (qos->packing > 0x01) 1151 return false; 1152 1153 if (qos->framing > 0x01) 1154 return false; 1155 1156 if (!check_io_qos(&qos->in)) 1157 return false; 1158 1159 if (!check_io_qos(&qos->out)) 1160 return false; 1161 1162 return true; 1163 } 1164 1165 static int iso_sock_setsockopt(struct socket *sock, int level, int optname, 1166 sockptr_t optval, unsigned int optlen) 1167 { 1168 struct sock *sk = sock->sk; 1169 int len, err = 0; 1170 struct bt_iso_qos qos; 1171 u32 opt; 1172 1173 BT_DBG("sk %p", sk); 1174 1175 lock_sock(sk); 1176 1177 switch (optname) { 1178 case BT_DEFER_SETUP: 1179 if (sk->sk_state != BT_BOUND && sk->sk_state != BT_LISTEN) { 1180 err = -EINVAL; 1181 break; 1182 } 1183 1184 if (copy_from_sockptr(&opt, optval, sizeof(u32))) { 1185 err = -EFAULT; 1186 break; 1187 } 1188 1189 if (opt) 1190 set_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags); 1191 else 1192 clear_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags); 1193 break; 1194 1195 case BT_ISO_QOS: 1196 if (sk->sk_state != BT_OPEN && sk->sk_state != BT_BOUND && 1197 sk->sk_state != BT_CONNECT2) { 1198 err = -EINVAL; 1199 break; 1200 } 1201 1202 len = min_t(unsigned int, sizeof(qos), optlen); 1203 if (len != sizeof(qos)) { 1204 err = -EINVAL; 1205 break; 1206 } 1207 1208 memset(&qos, 0, sizeof(qos)); 1209 1210 if (copy_from_sockptr(&qos, optval, len)) { 1211 err = -EFAULT; 1212 break; 1213 } 1214 1215 if (!check_qos(&qos)) { 1216 err = -EINVAL; 1217 break; 1218 } 1219 1220 iso_pi(sk)->qos = qos; 1221 1222 break; 1223 1224 case BT_ISO_BASE: 1225 if (sk->sk_state != BT_OPEN && sk->sk_state != BT_BOUND && 1226 sk->sk_state != BT_CONNECT2) { 1227 err = -EINVAL; 1228 break; 1229 } 1230 1231 if (optlen > sizeof(iso_pi(sk)->base)) { 1232 err = -EOVERFLOW; 1233 break; 1234 } 1235 1236 len = min_t(unsigned int, sizeof(iso_pi(sk)->base), optlen); 1237 1238 if (copy_from_sockptr(iso_pi(sk)->base, optval, len)) { 1239 err = -EFAULT; 1240 break; 1241 } 1242 1243 iso_pi(sk)->base_len = len; 1244 1245 break; 1246 1247 default: 1248 err = -ENOPROTOOPT; 1249 break; 1250 } 1251 1252 release_sock(sk); 1253 return err; 1254 } 1255 1256 static int iso_sock_getsockopt(struct socket *sock, int level, int optname, 1257 char __user *optval, int __user *optlen) 1258 { 1259 struct sock *sk = sock->sk; 1260 int len, err = 0; 1261 struct bt_iso_qos *qos; 1262 u8 base_len; 1263 u8 *base; 1264 1265 BT_DBG("sk %p", sk); 1266 1267 if (get_user(len, optlen)) 1268 return -EFAULT; 1269 1270 lock_sock(sk); 1271 1272 switch (optname) { 1273 case BT_DEFER_SETUP: 1274 if (sk->sk_state == BT_CONNECTED) { 1275 err = -EINVAL; 1276 break; 1277 } 1278 1279 if (put_user(test_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags), 1280 (u32 __user *)optval)) 1281 err = -EFAULT; 1282 1283 break; 1284 1285 case BT_ISO_QOS: 1286 qos = iso_sock_get_qos(sk); 1287 1288 len = min_t(unsigned int, len, sizeof(*qos)); 1289 if (copy_to_user(optval, qos, len)) 1290 err = -EFAULT; 1291 1292 break; 1293 1294 case BT_ISO_BASE: 1295 if (sk->sk_state == BT_CONNECTED) { 1296 base_len = iso_pi(sk)->conn->hcon->le_per_adv_data_len; 1297 base = iso_pi(sk)->conn->hcon->le_per_adv_data; 1298 } else { 1299 base_len = iso_pi(sk)->base_len; 1300 base = iso_pi(sk)->base; 1301 } 1302 1303 len = min_t(unsigned int, len, base_len); 1304 if (copy_to_user(optval, base, len)) 1305 err = -EFAULT; 1306 1307 break; 1308 1309 default: 1310 err = -ENOPROTOOPT; 1311 break; 1312 } 1313 1314 release_sock(sk); 1315 return err; 1316 } 1317 1318 static int iso_sock_shutdown(struct socket *sock, int how) 1319 { 1320 struct sock *sk = sock->sk; 1321 int err = 0; 1322 1323 BT_DBG("sock %p, sk %p, how %d", sock, sk, how); 1324 1325 if (!sk) 1326 return 0; 1327 1328 sock_hold(sk); 1329 lock_sock(sk); 1330 1331 switch (how) { 1332 case SHUT_RD: 1333 if (sk->sk_shutdown & RCV_SHUTDOWN) 1334 goto unlock; 1335 sk->sk_shutdown |= RCV_SHUTDOWN; 1336 break; 1337 case SHUT_WR: 1338 if (sk->sk_shutdown & SEND_SHUTDOWN) 1339 goto unlock; 1340 sk->sk_shutdown |= SEND_SHUTDOWN; 1341 break; 1342 case SHUT_RDWR: 1343 if (sk->sk_shutdown & SHUTDOWN_MASK) 1344 goto unlock; 1345 sk->sk_shutdown |= SHUTDOWN_MASK; 1346 break; 1347 } 1348 1349 iso_sock_clear_timer(sk); 1350 __iso_sock_close(sk); 1351 1352 if (sock_flag(sk, SOCK_LINGER) && sk->sk_lingertime && 1353 !(current->flags & PF_EXITING)) 1354 err = bt_sock_wait_state(sk, BT_CLOSED, sk->sk_lingertime); 1355 1356 unlock: 1357 release_sock(sk); 1358 sock_put(sk); 1359 1360 return err; 1361 } 1362 1363 static int iso_sock_release(struct socket *sock) 1364 { 1365 struct sock *sk = sock->sk; 1366 int err = 0; 1367 1368 BT_DBG("sock %p, sk %p", sock, sk); 1369 1370 if (!sk) 1371 return 0; 1372 1373 iso_sock_close(sk); 1374 1375 if (sock_flag(sk, SOCK_LINGER) && sk->sk_lingertime && 1376 !(current->flags & PF_EXITING)) { 1377 lock_sock(sk); 1378 err = bt_sock_wait_state(sk, BT_CLOSED, sk->sk_lingertime); 1379 release_sock(sk); 1380 } 1381 1382 sock_orphan(sk); 1383 iso_sock_kill(sk); 1384 return err; 1385 } 1386 1387 static void iso_sock_ready(struct sock *sk) 1388 { 1389 BT_DBG("sk %p", sk); 1390 1391 if (!sk) 1392 return; 1393 1394 lock_sock(sk); 1395 iso_sock_clear_timer(sk); 1396 sk->sk_state = BT_CONNECTED; 1397 sk->sk_state_change(sk); 1398 release_sock(sk); 1399 } 1400 1401 struct iso_list_data { 1402 struct hci_conn *hcon; 1403 int count; 1404 }; 1405 1406 static bool iso_match_big(struct sock *sk, void *data) 1407 { 1408 struct hci_evt_le_big_sync_estabilished *ev = data; 1409 1410 return ev->handle == iso_pi(sk)->qos.big; 1411 } 1412 1413 static void iso_conn_ready(struct iso_conn *conn) 1414 { 1415 struct sock *parent; 1416 struct sock *sk = conn->sk; 1417 struct hci_ev_le_big_sync_estabilished *ev; 1418 1419 BT_DBG("conn %p", conn); 1420 1421 if (sk) { 1422 iso_sock_ready(conn->sk); 1423 } else { 1424 iso_conn_lock(conn); 1425 1426 if (!conn->hcon) { 1427 iso_conn_unlock(conn); 1428 return; 1429 } 1430 1431 ev = hci_recv_event_data(conn->hcon->hdev, 1432 HCI_EVT_LE_BIG_SYNC_ESTABILISHED); 1433 if (ev) 1434 parent = iso_get_sock_listen(&conn->hcon->src, 1435 &conn->hcon->dst, 1436 iso_match_big, ev); 1437 else 1438 parent = iso_get_sock_listen(&conn->hcon->src, 1439 BDADDR_ANY, NULL, NULL); 1440 1441 if (!parent) { 1442 iso_conn_unlock(conn); 1443 return; 1444 } 1445 1446 lock_sock(parent); 1447 1448 sk = iso_sock_alloc(sock_net(parent), NULL, 1449 BTPROTO_ISO, GFP_ATOMIC, 0); 1450 if (!sk) { 1451 release_sock(parent); 1452 iso_conn_unlock(conn); 1453 return; 1454 } 1455 1456 iso_sock_init(sk, parent); 1457 1458 bacpy(&iso_pi(sk)->src, &conn->hcon->src); 1459 iso_pi(sk)->src_type = conn->hcon->src_type; 1460 1461 /* If hcon has no destination address (BDADDR_ANY) it means it 1462 * was created by HCI_EV_LE_BIG_SYNC_ESTABILISHED so we need to 1463 * initialize using the parent socket destination address. 1464 */ 1465 if (!bacmp(&conn->hcon->dst, BDADDR_ANY)) { 1466 bacpy(&conn->hcon->dst, &iso_pi(parent)->dst); 1467 conn->hcon->dst_type = iso_pi(parent)->dst_type; 1468 conn->hcon->sync_handle = iso_pi(parent)->sync_handle; 1469 } 1470 1471 bacpy(&iso_pi(sk)->dst, &conn->hcon->dst); 1472 iso_pi(sk)->dst_type = conn->hcon->dst_type; 1473 1474 hci_conn_hold(conn->hcon); 1475 __iso_chan_add(conn, sk, parent); 1476 1477 if (test_bit(BT_SK_DEFER_SETUP, &bt_sk(parent)->flags)) 1478 sk->sk_state = BT_CONNECT2; 1479 else 1480 sk->sk_state = BT_CONNECTED; 1481 1482 /* Wake up parent */ 1483 parent->sk_data_ready(parent); 1484 1485 release_sock(parent); 1486 1487 iso_conn_unlock(conn); 1488 } 1489 } 1490 1491 static bool iso_match_sid(struct sock *sk, void *data) 1492 { 1493 struct hci_ev_le_pa_sync_established *ev = data; 1494 1495 return ev->sid == iso_pi(sk)->bc_sid; 1496 } 1497 1498 static bool iso_match_sync_handle(struct sock *sk, void *data) 1499 { 1500 struct hci_evt_le_big_info_adv_report *ev = data; 1501 1502 return le16_to_cpu(ev->sync_handle) == iso_pi(sk)->sync_handle; 1503 } 1504 1505 /* ----- ISO interface with lower layer (HCI) ----- */ 1506 1507 int iso_connect_ind(struct hci_dev *hdev, bdaddr_t *bdaddr, __u8 *flags) 1508 { 1509 struct hci_ev_le_pa_sync_established *ev1; 1510 struct hci_evt_le_big_info_adv_report *ev2; 1511 struct sock *sk; 1512 int lm = 0; 1513 1514 bt_dev_dbg(hdev, "bdaddr %pMR", bdaddr); 1515 1516 /* Broadcast receiver requires handling of some events before it can 1517 * proceed to establishing a BIG sync: 1518 * 1519 * 1. HCI_EV_LE_PA_SYNC_ESTABLISHED: The socket may specify a specific 1520 * SID to listen to and once sync is estabilished its handle needs to 1521 * be stored in iso_pi(sk)->sync_handle so it can be matched once 1522 * receiving the BIG Info. 1523 * 2. HCI_EVT_LE_BIG_INFO_ADV_REPORT: When connect_ind is triggered by a 1524 * a BIG Info it attempts to check if there any listening socket with 1525 * the same sync_handle and if it does then attempt to create a sync. 1526 */ 1527 ev1 = hci_recv_event_data(hdev, HCI_EV_LE_PA_SYNC_ESTABLISHED); 1528 if (ev1) { 1529 sk = iso_get_sock_listen(&hdev->bdaddr, bdaddr, iso_match_sid, 1530 ev1); 1531 if (sk) 1532 iso_pi(sk)->sync_handle = le16_to_cpu(ev1->handle); 1533 1534 goto done; 1535 } 1536 1537 ev2 = hci_recv_event_data(hdev, HCI_EVT_LE_BIG_INFO_ADV_REPORT); 1538 if (ev2) { 1539 sk = iso_get_sock_listen(&hdev->bdaddr, bdaddr, 1540 iso_match_sync_handle, ev2); 1541 if (sk) { 1542 int err; 1543 1544 if (ev2->num_bis < iso_pi(sk)->bc_num_bis) 1545 iso_pi(sk)->bc_num_bis = ev2->num_bis; 1546 1547 err = hci_le_big_create_sync(hdev, 1548 &iso_pi(sk)->qos, 1549 iso_pi(sk)->sync_handle, 1550 iso_pi(sk)->bc_num_bis, 1551 iso_pi(sk)->bc_bis); 1552 if (err) { 1553 bt_dev_err(hdev, "hci_le_big_create_sync: %d", 1554 err); 1555 sk = NULL; 1556 } 1557 } 1558 } else { 1559 sk = iso_get_sock_listen(&hdev->bdaddr, BDADDR_ANY, NULL, NULL); 1560 } 1561 1562 done: 1563 if (!sk) 1564 return lm; 1565 1566 lm |= HCI_LM_ACCEPT; 1567 1568 if (test_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags)) 1569 *flags |= HCI_PROTO_DEFER; 1570 1571 return lm; 1572 } 1573 1574 static void iso_connect_cfm(struct hci_conn *hcon, __u8 status) 1575 { 1576 if (hcon->type != ISO_LINK) { 1577 if (hcon->type != LE_LINK) 1578 return; 1579 1580 /* Check if LE link has failed */ 1581 if (status) { 1582 if (hcon->link) 1583 iso_conn_del(hcon->link, bt_to_errno(status)); 1584 return; 1585 } 1586 1587 /* Create CIS if pending */ 1588 hci_le_create_cis(hcon); 1589 return; 1590 } 1591 1592 BT_DBG("hcon %p bdaddr %pMR status %d", hcon, &hcon->dst, status); 1593 1594 if (!status) { 1595 struct iso_conn *conn; 1596 1597 conn = iso_conn_add(hcon); 1598 if (conn) 1599 iso_conn_ready(conn); 1600 } else { 1601 iso_conn_del(hcon, bt_to_errno(status)); 1602 } 1603 } 1604 1605 static void iso_disconn_cfm(struct hci_conn *hcon, __u8 reason) 1606 { 1607 if (hcon->type != ISO_LINK) 1608 return; 1609 1610 BT_DBG("hcon %p reason %d", hcon, reason); 1611 1612 iso_conn_del(hcon, bt_to_errno(reason)); 1613 } 1614 1615 void iso_recv(struct hci_conn *hcon, struct sk_buff *skb, u16 flags) 1616 { 1617 struct iso_conn *conn = hcon->iso_data; 1618 struct hci_iso_data_hdr *hdr; 1619 __u16 pb, ts, len; 1620 1621 if (!conn) 1622 goto drop; 1623 1624 pb = hci_iso_flags_pb(flags); 1625 ts = hci_iso_flags_ts(flags); 1626 1627 BT_DBG("conn %p len %d pb 0x%x ts 0x%x", conn, skb->len, pb, ts); 1628 1629 switch (pb) { 1630 case ISO_START: 1631 case ISO_SINGLE: 1632 if (conn->rx_len) { 1633 BT_ERR("Unexpected start frame (len %d)", skb->len); 1634 kfree_skb(conn->rx_skb); 1635 conn->rx_skb = NULL; 1636 conn->rx_len = 0; 1637 } 1638 1639 if (ts) { 1640 /* TODO: add timestamp to the packet? */ 1641 hdr = skb_pull_data(skb, HCI_ISO_TS_DATA_HDR_SIZE); 1642 if (!hdr) { 1643 BT_ERR("Frame is too short (len %d)", skb->len); 1644 goto drop; 1645 } 1646 1647 } else { 1648 hdr = skb_pull_data(skb, HCI_ISO_DATA_HDR_SIZE); 1649 if (!hdr) { 1650 BT_ERR("Frame is too short (len %d)", skb->len); 1651 goto drop; 1652 } 1653 } 1654 1655 len = __le16_to_cpu(hdr->slen); 1656 flags = hci_iso_data_flags(len); 1657 len = hci_iso_data_len(len); 1658 1659 BT_DBG("Start: total len %d, frag len %d flags 0x%4.4x", len, 1660 skb->len, flags); 1661 1662 if (len == skb->len) { 1663 /* Complete frame received */ 1664 iso_recv_frame(conn, skb); 1665 return; 1666 } 1667 1668 if (pb == ISO_SINGLE) { 1669 BT_ERR("Frame malformed (len %d, expected len %d)", 1670 skb->len, len); 1671 goto drop; 1672 } 1673 1674 if (skb->len > len) { 1675 BT_ERR("Frame is too long (len %d, expected len %d)", 1676 skb->len, len); 1677 goto drop; 1678 } 1679 1680 /* Allocate skb for the complete frame (with header) */ 1681 conn->rx_skb = bt_skb_alloc(len, GFP_KERNEL); 1682 if (!conn->rx_skb) 1683 goto drop; 1684 1685 skb_copy_from_linear_data(skb, skb_put(conn->rx_skb, skb->len), 1686 skb->len); 1687 conn->rx_len = len - skb->len; 1688 break; 1689 1690 case ISO_CONT: 1691 BT_DBG("Cont: frag len %d (expecting %d)", skb->len, 1692 conn->rx_len); 1693 1694 if (!conn->rx_len) { 1695 BT_ERR("Unexpected continuation frame (len %d)", 1696 skb->len); 1697 goto drop; 1698 } 1699 1700 if (skb->len > conn->rx_len) { 1701 BT_ERR("Fragment is too long (len %d, expected %d)", 1702 skb->len, conn->rx_len); 1703 kfree_skb(conn->rx_skb); 1704 conn->rx_skb = NULL; 1705 conn->rx_len = 0; 1706 goto drop; 1707 } 1708 1709 skb_copy_from_linear_data(skb, skb_put(conn->rx_skb, skb->len), 1710 skb->len); 1711 conn->rx_len -= skb->len; 1712 return; 1713 1714 case ISO_END: 1715 skb_copy_from_linear_data(skb, skb_put(conn->rx_skb, skb->len), 1716 skb->len); 1717 conn->rx_len -= skb->len; 1718 1719 if (!conn->rx_len) { 1720 struct sk_buff *rx_skb = conn->rx_skb; 1721 1722 /* Complete frame received. iso_recv_frame 1723 * takes ownership of the skb so set the global 1724 * rx_skb pointer to NULL first. 1725 */ 1726 conn->rx_skb = NULL; 1727 iso_recv_frame(conn, rx_skb); 1728 } 1729 break; 1730 } 1731 1732 drop: 1733 kfree_skb(skb); 1734 } 1735 1736 static struct hci_cb iso_cb = { 1737 .name = "ISO", 1738 .connect_cfm = iso_connect_cfm, 1739 .disconn_cfm = iso_disconn_cfm, 1740 }; 1741 1742 static int iso_debugfs_show(struct seq_file *f, void *p) 1743 { 1744 struct sock *sk; 1745 1746 read_lock(&iso_sk_list.lock); 1747 1748 sk_for_each(sk, &iso_sk_list.head) { 1749 seq_printf(f, "%pMR %pMR %d\n", &iso_pi(sk)->src, 1750 &iso_pi(sk)->dst, sk->sk_state); 1751 } 1752 1753 read_unlock(&iso_sk_list.lock); 1754 1755 return 0; 1756 } 1757 1758 DEFINE_SHOW_ATTRIBUTE(iso_debugfs); 1759 1760 static struct dentry *iso_debugfs; 1761 1762 static const struct proto_ops iso_sock_ops = { 1763 .family = PF_BLUETOOTH, 1764 .owner = THIS_MODULE, 1765 .release = iso_sock_release, 1766 .bind = iso_sock_bind, 1767 .connect = iso_sock_connect, 1768 .listen = iso_sock_listen, 1769 .accept = iso_sock_accept, 1770 .getname = iso_sock_getname, 1771 .sendmsg = iso_sock_sendmsg, 1772 .recvmsg = iso_sock_recvmsg, 1773 .poll = bt_sock_poll, 1774 .ioctl = bt_sock_ioctl, 1775 .mmap = sock_no_mmap, 1776 .socketpair = sock_no_socketpair, 1777 .shutdown = iso_sock_shutdown, 1778 .setsockopt = iso_sock_setsockopt, 1779 .getsockopt = iso_sock_getsockopt 1780 }; 1781 1782 static const struct net_proto_family iso_sock_family_ops = { 1783 .family = PF_BLUETOOTH, 1784 .owner = THIS_MODULE, 1785 .create = iso_sock_create, 1786 }; 1787 1788 static bool iso_inited; 1789 1790 bool iso_enabled(void) 1791 { 1792 return iso_inited; 1793 } 1794 1795 int iso_init(void) 1796 { 1797 int err; 1798 1799 BUILD_BUG_ON(sizeof(struct sockaddr_iso) > sizeof(struct sockaddr)); 1800 1801 if (iso_inited) 1802 return -EALREADY; 1803 1804 err = proto_register(&iso_proto, 0); 1805 if (err < 0) 1806 return err; 1807 1808 err = bt_sock_register(BTPROTO_ISO, &iso_sock_family_ops); 1809 if (err < 0) { 1810 BT_ERR("ISO socket registration failed"); 1811 goto error; 1812 } 1813 1814 err = bt_procfs_init(&init_net, "iso", &iso_sk_list, NULL); 1815 if (err < 0) { 1816 BT_ERR("Failed to create ISO proc file"); 1817 bt_sock_unregister(BTPROTO_ISO); 1818 goto error; 1819 } 1820 1821 BT_INFO("ISO socket layer initialized"); 1822 1823 hci_register_cb(&iso_cb); 1824 1825 if (IS_ERR_OR_NULL(bt_debugfs)) 1826 return 0; 1827 1828 if (!iso_debugfs) { 1829 iso_debugfs = debugfs_create_file("iso", 0444, bt_debugfs, 1830 NULL, &iso_debugfs_fops); 1831 } 1832 1833 iso_inited = true; 1834 1835 return 0; 1836 1837 error: 1838 proto_unregister(&iso_proto); 1839 return err; 1840 } 1841 1842 int iso_exit(void) 1843 { 1844 if (!iso_inited) 1845 return -EALREADY; 1846 1847 bt_procfs_cleanup(&init_net, "iso"); 1848 1849 debugfs_remove(iso_debugfs); 1850 iso_debugfs = NULL; 1851 1852 hci_unregister_cb(&iso_cb); 1853 1854 bt_sock_unregister(BTPROTO_ISO); 1855 1856 proto_unregister(&iso_proto); 1857 1858 iso_inited = false; 1859 1860 return 0; 1861 } 1862