1 // SPDX-License-Identifier: GPL-2.0 2 /* 3 * BlueZ - Bluetooth protocol stack for Linux 4 * 5 * Copyright (C) 2022 Intel Corporation 6 * Copyright 2023-2024 NXP 7 */ 8 9 #include <linux/module.h> 10 #include <linux/debugfs.h> 11 #include <linux/seq_file.h> 12 #include <linux/sched/signal.h> 13 14 #include <net/bluetooth/bluetooth.h> 15 #include <net/bluetooth/hci_core.h> 16 #include <net/bluetooth/iso.h> 17 #include "eir.h" 18 19 static const struct proto_ops iso_sock_ops; 20 21 static struct bt_sock_list iso_sk_list = { 22 .lock = __RW_LOCK_UNLOCKED(iso_sk_list.lock) 23 }; 24 25 /* ---- ISO connections ---- */ 26 struct iso_conn { 27 struct hci_conn *hcon; 28 29 /* @lock: spinlock protecting changes to iso_conn fields */ 30 spinlock_t lock; 31 struct sock *sk; 32 33 struct delayed_work timeout_work; 34 35 struct sk_buff *rx_skb; 36 __u32 rx_len; 37 __u16 tx_sn; 38 struct kref ref; 39 }; 40 41 #define iso_conn_lock(c) spin_lock(&(c)->lock) 42 #define iso_conn_unlock(c) spin_unlock(&(c)->lock) 43 44 static void iso_sock_close(struct sock *sk); 45 static void iso_sock_kill(struct sock *sk); 46 47 /* ----- ISO socket info ----- */ 48 #define iso_pi(sk) ((struct iso_pinfo *)sk) 49 50 #define EIR_SERVICE_DATA_LENGTH 4 51 #define BASE_MAX_LENGTH (HCI_MAX_PER_AD_LENGTH - EIR_SERVICE_DATA_LENGTH) 52 #define EIR_BAA_SERVICE_UUID 0x1851 53 54 /* iso_pinfo flags values */ 55 enum { 56 BT_SK_BIG_SYNC, 57 BT_SK_PA_SYNC, 58 }; 59 60 struct iso_pinfo { 61 struct bt_sock bt; 62 bdaddr_t src; 63 __u8 src_type; 64 bdaddr_t dst; 65 __u8 dst_type; 66 __u8 bc_sid; 67 __u8 bc_num_bis; 68 __u8 bc_bis[ISO_MAX_NUM_BIS]; 69 __u16 sync_handle; 70 unsigned long flags; 71 struct bt_iso_qos qos; 72 bool qos_user_set; 73 __u8 base_len; 74 __u8 base[BASE_MAX_LENGTH]; 75 struct iso_conn *conn; 76 }; 77 78 static struct bt_iso_qos default_qos; 79 80 static bool check_ucast_qos(struct bt_iso_qos *qos); 81 static bool check_bcast_qos(struct bt_iso_qos *qos); 82 static bool iso_match_sid(struct sock *sk, void *data); 83 static bool iso_match_sid_past(struct sock *sk, void *data); 84 static bool iso_match_sync_handle(struct sock *sk, void *data); 85 static bool iso_match_sync_handle_pa_report(struct sock *sk, void *data); 86 static void iso_sock_disconn(struct sock *sk); 87 88 typedef bool (*iso_sock_match_t)(struct sock *sk, void *data); 89 90 static struct sock *iso_get_sock(struct hci_dev *hdev, bdaddr_t *src, 91 bdaddr_t *dst, enum bt_sock_state state, 92 iso_sock_match_t match, void *data); 93 94 /* ---- ISO timers ---- */ 95 #define ISO_CONN_TIMEOUT secs_to_jiffies(20) 96 #define ISO_DISCONN_TIMEOUT secs_to_jiffies(2) 97 98 static void iso_conn_free(struct kref *ref) 99 { 100 struct iso_conn *conn = container_of(ref, struct iso_conn, ref); 101 102 BT_DBG("conn %p", conn); 103 104 if (conn->sk) 105 iso_pi(conn->sk)->conn = NULL; 106 107 if (conn->hcon) { 108 conn->hcon->iso_data = NULL; 109 hci_conn_drop(conn->hcon); 110 } 111 112 /* Ensure no more work items will run since hci_conn has been dropped */ 113 disable_delayed_work_sync(&conn->timeout_work); 114 115 kfree_skb(conn->rx_skb); 116 117 kfree(conn); 118 } 119 120 static void iso_conn_put(struct iso_conn *conn) 121 { 122 if (!conn) 123 return; 124 125 BT_DBG("conn %p refcnt %d", conn, kref_read(&conn->ref)); 126 127 kref_put(&conn->ref, iso_conn_free); 128 } 129 130 static struct iso_conn *iso_conn_hold_unless_zero(struct iso_conn *conn) 131 { 132 if (!conn) 133 return NULL; 134 135 BT_DBG("conn %p refcnt %u", conn, kref_read(&conn->ref)); 136 137 if (!kref_get_unless_zero(&conn->ref)) 138 return NULL; 139 140 return conn; 141 } 142 143 static struct sock *iso_sock_hold(struct iso_conn *conn) 144 { 145 if (!conn || !bt_sock_linked(&iso_sk_list, conn->sk)) 146 return NULL; 147 148 sock_hold(conn->sk); 149 150 return conn->sk; 151 } 152 153 static void iso_sock_timeout(struct work_struct *work) 154 { 155 struct iso_conn *conn = container_of(work, struct iso_conn, 156 timeout_work.work); 157 struct sock *sk; 158 159 conn = iso_conn_hold_unless_zero(conn); 160 if (!conn) 161 return; 162 163 iso_conn_lock(conn); 164 sk = iso_sock_hold(conn); 165 iso_conn_unlock(conn); 166 iso_conn_put(conn); 167 168 if (!sk) 169 return; 170 171 BT_DBG("sock %p state %d", sk, sk->sk_state); 172 173 lock_sock(sk); 174 sk->sk_err = ETIMEDOUT; 175 sk->sk_state_change(sk); 176 release_sock(sk); 177 sock_put(sk); 178 } 179 180 static void iso_sock_set_timer(struct sock *sk, long timeout) 181 { 182 if (!iso_pi(sk)->conn) 183 return; 184 185 BT_DBG("sock %p state %d timeout %ld", sk, sk->sk_state, timeout); 186 cancel_delayed_work(&iso_pi(sk)->conn->timeout_work); 187 schedule_delayed_work(&iso_pi(sk)->conn->timeout_work, timeout); 188 } 189 190 static void iso_sock_clear_timer(struct sock *sk) 191 { 192 if (!iso_pi(sk)->conn) 193 return; 194 195 BT_DBG("sock %p state %d", sk, sk->sk_state); 196 cancel_delayed_work(&iso_pi(sk)->conn->timeout_work); 197 } 198 199 /* ---- ISO connections ---- */ 200 static struct iso_conn *iso_conn_add(struct hci_conn *hcon) 201 { 202 struct iso_conn *conn = hcon->iso_data; 203 204 conn = iso_conn_hold_unless_zero(conn); 205 if (conn) { 206 if (!conn->hcon) { 207 iso_conn_lock(conn); 208 conn->hcon = hcon; 209 iso_conn_unlock(conn); 210 } 211 iso_conn_put(conn); 212 return conn; 213 } 214 215 conn = kzalloc_obj(*conn); 216 if (!conn) 217 return NULL; 218 219 kref_init(&conn->ref); 220 spin_lock_init(&conn->lock); 221 INIT_DELAYED_WORK(&conn->timeout_work, iso_sock_timeout); 222 223 hcon->iso_data = conn; 224 conn->hcon = hcon; 225 conn->tx_sn = 0; 226 227 BT_DBG("hcon %p conn %p", hcon, conn); 228 229 return conn; 230 } 231 232 /* Delete channel. Must be called on the locked socket. */ 233 static void iso_chan_del(struct sock *sk, int err) 234 { 235 struct iso_conn *conn; 236 struct sock *parent; 237 238 conn = iso_pi(sk)->conn; 239 iso_pi(sk)->conn = NULL; 240 241 BT_DBG("sk %p, conn %p, err %d", sk, conn, err); 242 243 if (conn) { 244 iso_conn_lock(conn); 245 conn->sk = NULL; 246 iso_conn_unlock(conn); 247 iso_conn_put(conn); 248 } 249 250 sk->sk_state = BT_CLOSED; 251 sk->sk_err = err; 252 253 parent = bt_sk(sk)->parent; 254 if (parent) { 255 bt_accept_unlink(sk); 256 parent->sk_data_ready(parent); 257 } else { 258 sk->sk_state_change(sk); 259 } 260 261 sock_set_flag(sk, SOCK_ZAPPED); 262 } 263 264 static void iso_conn_del(struct hci_conn *hcon, int err) 265 { 266 struct iso_conn *conn = hcon->iso_data; 267 struct sock *sk; 268 269 conn = iso_conn_hold_unless_zero(conn); 270 if (!conn) 271 return; 272 273 BT_DBG("hcon %p conn %p, err %d", hcon, conn, err); 274 275 /* Kill socket */ 276 iso_conn_lock(conn); 277 sk = iso_sock_hold(conn); 278 iso_conn_unlock(conn); 279 iso_conn_put(conn); 280 281 if (!sk) { 282 iso_conn_put(conn); 283 return; 284 } 285 286 lock_sock(sk); 287 iso_sock_clear_timer(sk); 288 iso_chan_del(sk, err); 289 release_sock(sk); 290 sock_put(sk); 291 } 292 293 static int __iso_chan_add(struct iso_conn *conn, struct sock *sk, 294 struct sock *parent) 295 { 296 BT_DBG("conn %p", conn); 297 298 if (iso_pi(sk)->conn == conn && conn->sk == sk) 299 return 0; 300 301 if (conn->sk) { 302 BT_ERR("conn->sk already set"); 303 return -EBUSY; 304 } 305 306 iso_pi(sk)->conn = conn; 307 conn->sk = sk; 308 309 if (parent) 310 bt_accept_enqueue(parent, sk, true); 311 312 return 0; 313 } 314 315 static int iso_chan_add(struct iso_conn *conn, struct sock *sk, 316 struct sock *parent) 317 { 318 int err; 319 320 iso_conn_lock(conn); 321 err = __iso_chan_add(conn, sk, parent); 322 iso_conn_unlock(conn); 323 324 return err; 325 } 326 327 static inline u8 le_addr_type(u8 bdaddr_type) 328 { 329 if (bdaddr_type == BDADDR_LE_PUBLIC) 330 return ADDR_LE_DEV_PUBLIC; 331 else 332 return ADDR_LE_DEV_RANDOM; 333 } 334 335 static int iso_connect_bis(struct sock *sk) 336 { 337 struct iso_conn *conn; 338 struct hci_conn *hcon; 339 struct hci_dev *hdev; 340 int err; 341 342 BT_DBG("%pMR (SID 0x%2.2x)", &iso_pi(sk)->src, iso_pi(sk)->bc_sid); 343 344 hdev = hci_get_route(&iso_pi(sk)->dst, &iso_pi(sk)->src, 345 iso_pi(sk)->src_type); 346 if (!hdev) 347 return -EHOSTUNREACH; 348 349 hci_dev_lock(hdev); 350 lock_sock(sk); 351 352 if (!bis_capable(hdev)) { 353 err = -EOPNOTSUPP; 354 goto unlock; 355 } 356 357 /* Fail if user set invalid QoS */ 358 if (iso_pi(sk)->qos_user_set && !check_bcast_qos(&iso_pi(sk)->qos)) { 359 iso_pi(sk)->qos = default_qos; 360 err = -EINVAL; 361 goto unlock; 362 } 363 364 /* Fail if out PHYs are marked as disabled */ 365 if (!iso_pi(sk)->qos.bcast.out.phys) { 366 err = -EINVAL; 367 goto unlock; 368 } 369 370 /* Just bind if DEFER_SETUP has been set */ 371 if (test_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags)) { 372 hcon = hci_bind_bis(hdev, &iso_pi(sk)->dst, iso_pi(sk)->bc_sid, 373 &iso_pi(sk)->qos, iso_pi(sk)->base_len, 374 iso_pi(sk)->base, 375 READ_ONCE(sk->sk_sndtimeo)); 376 if (IS_ERR(hcon)) { 377 err = PTR_ERR(hcon); 378 goto unlock; 379 } 380 } else { 381 hcon = hci_connect_bis(hdev, &iso_pi(sk)->dst, 382 le_addr_type(iso_pi(sk)->dst_type), 383 iso_pi(sk)->bc_sid, &iso_pi(sk)->qos, 384 iso_pi(sk)->base_len, iso_pi(sk)->base, 385 READ_ONCE(sk->sk_sndtimeo)); 386 if (IS_ERR(hcon)) { 387 err = PTR_ERR(hcon); 388 goto unlock; 389 } 390 391 /* Update SID if it was not set */ 392 if (iso_pi(sk)->bc_sid == HCI_SID_INVALID) 393 iso_pi(sk)->bc_sid = hcon->sid; 394 } 395 396 conn = iso_conn_add(hcon); 397 if (!conn) { 398 hci_conn_drop(hcon); 399 err = -ENOMEM; 400 goto unlock; 401 } 402 403 err = iso_chan_add(conn, sk, NULL); 404 if (err) 405 goto unlock; 406 407 /* Update source addr of the socket */ 408 bacpy(&iso_pi(sk)->src, &hcon->src); 409 410 if (hcon->state == BT_CONNECTED) { 411 iso_sock_clear_timer(sk); 412 sk->sk_state = BT_CONNECTED; 413 } else if (test_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags)) { 414 iso_sock_clear_timer(sk); 415 sk->sk_state = BT_CONNECT; 416 } else { 417 sk->sk_state = BT_CONNECT; 418 iso_sock_set_timer(sk, READ_ONCE(sk->sk_sndtimeo)); 419 } 420 421 unlock: 422 release_sock(sk); 423 hci_dev_unlock(hdev); 424 hci_dev_put(hdev); 425 return err; 426 } 427 428 static int iso_connect_cis(struct sock *sk) 429 { 430 struct iso_conn *conn; 431 struct hci_conn *hcon; 432 struct hci_dev *hdev; 433 int err; 434 435 BT_DBG("%pMR -> %pMR", &iso_pi(sk)->src, &iso_pi(sk)->dst); 436 437 hdev = hci_get_route(&iso_pi(sk)->dst, &iso_pi(sk)->src, 438 iso_pi(sk)->src_type); 439 if (!hdev) 440 return -EHOSTUNREACH; 441 442 hci_dev_lock(hdev); 443 lock_sock(sk); 444 445 if (!cis_central_capable(hdev)) { 446 err = -EOPNOTSUPP; 447 goto unlock; 448 } 449 450 /* Fail if user set invalid QoS */ 451 if (iso_pi(sk)->qos_user_set && !check_ucast_qos(&iso_pi(sk)->qos)) { 452 iso_pi(sk)->qos = default_qos; 453 err = -EINVAL; 454 goto unlock; 455 } 456 457 /* Fail if either PHYs are marked as disabled */ 458 if (!iso_pi(sk)->qos.ucast.in.phys && !iso_pi(sk)->qos.ucast.out.phys) { 459 err = -EINVAL; 460 goto unlock; 461 } 462 463 /* Check if there are available buffers for output/TX. */ 464 if (iso_pi(sk)->qos.ucast.out.sdu && !hci_iso_count(hdev) && 465 (hdev->iso_pkts && !hdev->iso_cnt)) { 466 err = -ENOBUFS; 467 goto unlock; 468 } 469 470 /* Just bind if DEFER_SETUP has been set */ 471 if (test_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags)) { 472 hcon = hci_bind_cis(hdev, &iso_pi(sk)->dst, 473 le_addr_type(iso_pi(sk)->dst_type), 474 &iso_pi(sk)->qos, 475 READ_ONCE(sk->sk_sndtimeo)); 476 if (IS_ERR(hcon)) { 477 err = PTR_ERR(hcon); 478 goto unlock; 479 } 480 } else { 481 hcon = hci_connect_cis(hdev, &iso_pi(sk)->dst, 482 le_addr_type(iso_pi(sk)->dst_type), 483 &iso_pi(sk)->qos, 484 READ_ONCE(sk->sk_sndtimeo)); 485 if (IS_ERR(hcon)) { 486 err = PTR_ERR(hcon); 487 goto unlock; 488 } 489 } 490 491 conn = iso_conn_add(hcon); 492 if (!conn) { 493 hci_conn_drop(hcon); 494 err = -ENOMEM; 495 goto unlock; 496 } 497 498 err = iso_chan_add(conn, sk, NULL); 499 if (err) 500 goto unlock; 501 502 /* Update source addr of the socket */ 503 bacpy(&iso_pi(sk)->src, &hcon->src); 504 505 if (hcon->state == BT_CONNECTED) { 506 iso_sock_clear_timer(sk); 507 sk->sk_state = BT_CONNECTED; 508 } else if (test_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags)) { 509 iso_sock_clear_timer(sk); 510 sk->sk_state = BT_CONNECT; 511 } else { 512 sk->sk_state = BT_CONNECT; 513 iso_sock_set_timer(sk, READ_ONCE(sk->sk_sndtimeo)); 514 } 515 516 unlock: 517 release_sock(sk); 518 hci_dev_unlock(hdev); 519 hci_dev_put(hdev); 520 return err; 521 } 522 523 static struct bt_iso_qos *iso_sock_get_qos(struct sock *sk) 524 { 525 if (sk->sk_state == BT_CONNECTED || sk->sk_state == BT_CONNECT2) 526 return &iso_pi(sk)->conn->hcon->iso_qos; 527 528 return &iso_pi(sk)->qos; 529 } 530 531 static int iso_send_frame(struct sock *sk, struct sk_buff *skb, 532 const struct sockcm_cookie *sockc) 533 { 534 struct iso_conn *conn = iso_pi(sk)->conn; 535 struct bt_iso_qos *qos = iso_sock_get_qos(sk); 536 struct hci_iso_data_hdr *hdr; 537 int len = 0; 538 539 BT_DBG("sk %p len %d", sk, skb->len); 540 541 if (skb->len > qos->ucast.out.sdu) 542 return -EMSGSIZE; 543 544 len = skb->len; 545 546 /* Push ISO data header */ 547 hdr = skb_push(skb, HCI_ISO_DATA_HDR_SIZE); 548 hdr->sn = cpu_to_le16(conn->tx_sn++); 549 hdr->slen = cpu_to_le16(hci_iso_data_len_pack(len, 550 HCI_ISO_STATUS_VALID)); 551 552 if (sk->sk_state == BT_CONNECTED) { 553 hci_setup_tx_timestamp(skb, 1, sockc); 554 hci_send_iso(conn->hcon, skb); 555 } else { 556 len = -ENOTCONN; 557 } 558 559 return len; 560 } 561 562 static void iso_recv_frame(struct iso_conn *conn, struct sk_buff *skb) 563 { 564 struct sock *sk; 565 566 iso_conn_lock(conn); 567 sk = iso_sock_hold(conn); 568 iso_conn_unlock(conn); 569 570 if (!sk) 571 goto drop; 572 573 BT_DBG("sk %p len %d", sk, skb->len); 574 575 if (sk->sk_state != BT_CONNECTED) 576 goto drop_put; 577 578 if (!sock_queue_rcv_skb(sk, skb)) { 579 sock_put(sk); 580 return; 581 } 582 583 drop_put: 584 sock_put(sk); 585 drop: 586 kfree_skb(skb); 587 } 588 589 /* -------- Socket interface ---------- */ 590 static struct sock *__iso_get_sock_listen_by_addr(bdaddr_t *src, bdaddr_t *dst) 591 { 592 struct sock *sk; 593 594 sk_for_each(sk, &iso_sk_list.head) { 595 if (sk->sk_state != BT_LISTEN) 596 continue; 597 598 if (bacmp(&iso_pi(sk)->dst, dst)) 599 continue; 600 601 if (!bacmp(&iso_pi(sk)->src, src)) 602 return sk; 603 } 604 605 return NULL; 606 } 607 608 static struct sock *__iso_get_sock_listen_by_sid(bdaddr_t *ba, bdaddr_t *bc, 609 __u8 sid) 610 { 611 struct sock *sk; 612 613 sk_for_each(sk, &iso_sk_list.head) { 614 if (sk->sk_state != BT_LISTEN) 615 continue; 616 617 if (bacmp(&iso_pi(sk)->src, ba)) 618 continue; 619 620 if (bacmp(&iso_pi(sk)->dst, bc)) 621 continue; 622 623 if (iso_pi(sk)->bc_sid == sid) 624 return sk; 625 } 626 627 return NULL; 628 } 629 630 /* Find socket in given state: 631 * source bdaddr (Unicast) 632 * destination bdaddr (Broadcast only) 633 * match func - pass NULL to ignore 634 * match func data - pass -1 to ignore 635 * Returns closest match. 636 */ 637 static struct sock *iso_get_sock(struct hci_dev *hdev, bdaddr_t *src, 638 bdaddr_t *dst, enum bt_sock_state state, 639 iso_sock_match_t match, void *data) 640 { 641 struct sock *sk = NULL, *sk1 = NULL; 642 643 read_lock(&iso_sk_list.lock); 644 645 sk_for_each(sk, &iso_sk_list.head) { 646 if (sk->sk_state != state) 647 continue; 648 649 /* Match Broadcast destination */ 650 if (bacmp(dst, BDADDR_ANY) && bacmp(&iso_pi(sk)->dst, dst)) { 651 struct smp_irk *irk1, *irk2; 652 653 /* Check if destination is an RPA that we can resolve */ 654 irk1 = hci_find_irk_by_rpa(hdev, dst); 655 if (!irk1) 656 continue; 657 658 /* Match with identity address */ 659 if (bacmp(&iso_pi(sk)->dst, &irk1->bdaddr)) { 660 /* Check if socket destination address is also 661 * an RPA and if the IRK matches. 662 */ 663 irk2 = hci_find_irk_by_rpa(hdev, 664 &iso_pi(sk)->dst); 665 if (!irk2 || irk1 != irk2) 666 continue; 667 } 668 } 669 670 /* Use Match function if provided */ 671 if (match && !match(sk, data)) 672 continue; 673 674 /* Exact match. */ 675 if (!bacmp(&iso_pi(sk)->src, src)) { 676 sock_hold(sk); 677 break; 678 } 679 680 /* Closest match */ 681 if (!bacmp(&iso_pi(sk)->src, BDADDR_ANY)) { 682 if (sk1) 683 sock_put(sk1); 684 685 sk1 = sk; 686 sock_hold(sk1); 687 } 688 } 689 690 if (sk && sk1) 691 sock_put(sk1); 692 693 read_unlock(&iso_sk_list.lock); 694 695 return sk ? sk : sk1; 696 } 697 698 static struct sock *iso_get_sock_big(struct sock *match_sk, bdaddr_t *src, 699 bdaddr_t *dst, uint8_t big) 700 { 701 struct sock *sk = NULL; 702 703 read_lock(&iso_sk_list.lock); 704 705 sk_for_each(sk, &iso_sk_list.head) { 706 if (match_sk == sk) 707 continue; 708 709 /* Look for sockets that have already been 710 * connected to the BIG 711 */ 712 if (sk->sk_state != BT_CONNECTED && 713 sk->sk_state != BT_CONNECT) 714 continue; 715 716 /* Match Broadcast destination */ 717 if (bacmp(&iso_pi(sk)->dst, dst)) 718 continue; 719 720 /* Match BIG handle */ 721 if (iso_pi(sk)->qos.bcast.big != big) 722 continue; 723 724 /* Match source address */ 725 if (bacmp(&iso_pi(sk)->src, src)) 726 continue; 727 728 sock_hold(sk); 729 break; 730 } 731 732 read_unlock(&iso_sk_list.lock); 733 734 return sk; 735 } 736 737 static void iso_sock_destruct(struct sock *sk) 738 { 739 BT_DBG("sk %p", sk); 740 741 iso_conn_put(iso_pi(sk)->conn); 742 743 skb_queue_purge(&sk->sk_receive_queue); 744 skb_queue_purge(&sk->sk_write_queue); 745 skb_queue_purge(&sk->sk_error_queue); 746 } 747 748 static void iso_sock_cleanup_listen(struct sock *parent) 749 { 750 struct sock *sk; 751 752 BT_DBG("parent %p", parent); 753 754 /* Close not yet accepted channels */ 755 while ((sk = bt_accept_dequeue(parent, NULL))) { 756 iso_sock_close(sk); 757 iso_sock_kill(sk); 758 /* Drop the reference handed back by bt_accept_dequeue(). */ 759 sock_put(sk); 760 } 761 762 /* If listening socket has a hcon, properly disconnect it */ 763 if (iso_pi(parent)->conn && iso_pi(parent)->conn->hcon) { 764 iso_sock_disconn(parent); 765 return; 766 } 767 768 parent->sk_state = BT_CLOSED; 769 sock_set_flag(parent, SOCK_ZAPPED); 770 } 771 772 /* Kill socket (only if zapped and orphan) 773 * Must be called on unlocked socket. 774 */ 775 static void iso_sock_kill(struct sock *sk) 776 { 777 if (!sock_flag(sk, SOCK_ZAPPED) || sk->sk_socket || 778 sock_flag(sk, SOCK_DEAD)) 779 return; 780 781 BT_DBG("sk %p state %d", sk, sk->sk_state); 782 783 /* Sock is dead, so set conn->sk to NULL to avoid possible UAF */ 784 if (iso_pi(sk)->conn) { 785 iso_conn_lock(iso_pi(sk)->conn); 786 iso_pi(sk)->conn->sk = NULL; 787 iso_conn_unlock(iso_pi(sk)->conn); 788 } 789 790 /* Kill poor orphan */ 791 bt_sock_unlink(&iso_sk_list, sk); 792 sock_set_flag(sk, SOCK_DEAD); 793 sock_put(sk); 794 } 795 796 static void iso_sock_disconn(struct sock *sk) 797 { 798 struct sock *bis_sk; 799 struct hci_conn *hcon = iso_pi(sk)->conn->hcon; 800 801 if (test_bit(HCI_CONN_BIG_CREATED, &hcon->flags)) { 802 bis_sk = iso_get_sock_big(sk, &iso_pi(sk)->src, 803 &iso_pi(sk)->dst, 804 iso_pi(sk)->qos.bcast.big); 805 806 /* If there are any other connected sockets for the 807 * same BIG, just delete the sk and leave the bis 808 * hcon active, in case later rebinding is needed. 809 */ 810 if (bis_sk) { 811 hcon->state = BT_OPEN; 812 hcon->iso_data = NULL; 813 iso_pi(sk)->conn->hcon = NULL; 814 iso_sock_clear_timer(sk); 815 iso_chan_del(sk, bt_to_errno(hcon->abort_reason)); 816 sock_put(bis_sk); 817 return; 818 } 819 } 820 821 sk->sk_state = BT_DISCONN; 822 iso_conn_lock(iso_pi(sk)->conn); 823 hci_conn_drop(iso_pi(sk)->conn->hcon); 824 iso_pi(sk)->conn->hcon = NULL; 825 iso_conn_unlock(iso_pi(sk)->conn); 826 } 827 828 static void __iso_sock_close(struct sock *sk) 829 { 830 BT_DBG("sk %p state %d socket %p", sk, sk->sk_state, sk->sk_socket); 831 832 switch (sk->sk_state) { 833 case BT_LISTEN: 834 iso_sock_cleanup_listen(sk); 835 break; 836 837 case BT_CONNECT: 838 case BT_CONNECTED: 839 case BT_CONFIG: 840 if (iso_pi(sk)->conn->hcon) 841 iso_sock_disconn(sk); 842 else 843 iso_chan_del(sk, ECONNRESET); 844 break; 845 846 case BT_CONNECT2: 847 if (iso_pi(sk)->conn->hcon && 848 (test_bit(HCI_CONN_PA_SYNC, &iso_pi(sk)->conn->hcon->flags) || 849 test_bit(HCI_CONN_PA_SYNC_FAILED, &iso_pi(sk)->conn->hcon->flags))) 850 iso_sock_disconn(sk); 851 else 852 iso_chan_del(sk, ECONNRESET); 853 break; 854 case BT_DISCONN: 855 iso_chan_del(sk, ECONNRESET); 856 break; 857 858 default: 859 sock_set_flag(sk, SOCK_ZAPPED); 860 break; 861 } 862 } 863 864 /* Must be called on unlocked socket. */ 865 static void iso_sock_close(struct sock *sk) 866 { 867 lock_sock(sk); 868 iso_sock_clear_timer(sk); 869 __iso_sock_close(sk); 870 release_sock(sk); 871 iso_sock_kill(sk); 872 } 873 874 static void iso_sock_init(struct sock *sk, struct sock *parent) 875 { 876 BT_DBG("sk %p", sk); 877 878 if (parent) { 879 sk->sk_type = parent->sk_type; 880 bt_sk(sk)->flags = bt_sk(parent)->flags; 881 security_sk_clone(parent, sk); 882 } 883 } 884 885 static struct proto iso_proto = { 886 .name = "ISO", 887 .owner = THIS_MODULE, 888 .obj_size = sizeof(struct iso_pinfo) 889 }; 890 891 #define DEFAULT_IO_QOS \ 892 { \ 893 .interval = 10000u, \ 894 .latency = 10u, \ 895 .sdu = 40u, \ 896 .phys = BT_ISO_PHY_2M, \ 897 .rtn = 2u, \ 898 } 899 900 static struct bt_iso_qos default_qos = { 901 .bcast = { 902 .big = BT_ISO_QOS_BIG_UNSET, 903 .bis = BT_ISO_QOS_BIS_UNSET, 904 .sync_factor = 0x01, 905 .packing = 0x00, 906 .framing = 0x00, 907 .in = DEFAULT_IO_QOS, 908 .out = DEFAULT_IO_QOS, 909 .encryption = 0x00, 910 .bcode = {0x00}, 911 .options = 0x00, 912 .skip = 0x0000, 913 .sync_timeout = BT_ISO_SYNC_TIMEOUT, 914 .sync_cte_type = 0x00, 915 .mse = 0x00, 916 .timeout = BT_ISO_SYNC_TIMEOUT, 917 }, 918 }; 919 920 static struct sock *iso_sock_alloc(struct net *net, struct socket *sock, 921 int proto, gfp_t prio, int kern) 922 { 923 struct sock *sk; 924 925 sk = bt_sock_alloc(net, sock, &iso_proto, proto, prio, kern); 926 if (!sk) 927 return NULL; 928 929 sk->sk_destruct = iso_sock_destruct; 930 sk->sk_sndtimeo = ISO_CONN_TIMEOUT; 931 932 /* Set address type as public as default src address is BDADDR_ANY */ 933 iso_pi(sk)->src_type = BDADDR_LE_PUBLIC; 934 935 iso_pi(sk)->qos = default_qos; 936 iso_pi(sk)->sync_handle = -1; 937 938 bt_sock_link(&iso_sk_list, sk); 939 return sk; 940 } 941 942 static int iso_sock_create(struct net *net, struct socket *sock, int protocol, 943 int kern) 944 { 945 struct sock *sk; 946 947 BT_DBG("sock %p", sock); 948 949 sock->state = SS_UNCONNECTED; 950 951 if (sock->type != SOCK_SEQPACKET) 952 return -ESOCKTNOSUPPORT; 953 954 sock->ops = &iso_sock_ops; 955 956 sk = iso_sock_alloc(net, sock, protocol, GFP_ATOMIC, kern); 957 if (!sk) 958 return -ENOMEM; 959 960 iso_sock_init(sk, NULL); 961 return 0; 962 } 963 964 static int iso_sock_bind_bc(struct socket *sock, struct sockaddr_unsized *addr, 965 int addr_len) 966 { 967 struct sockaddr_iso *sa = (struct sockaddr_iso *)addr; 968 struct sock *sk = sock->sk; 969 int i; 970 971 BT_DBG("sk %p bc_sid %u bc_num_bis %u", sk, sa->iso_bc->bc_sid, 972 sa->iso_bc->bc_num_bis); 973 974 if (addr_len != sizeof(*sa) + sizeof(*sa->iso_bc)) 975 return -EINVAL; 976 977 bacpy(&iso_pi(sk)->dst, &sa->iso_bc->bc_bdaddr); 978 979 /* Check if the address type is of LE type */ 980 if (!bdaddr_type_is_le(sa->iso_bc->bc_bdaddr_type)) 981 return -EINVAL; 982 983 iso_pi(sk)->dst_type = sa->iso_bc->bc_bdaddr_type; 984 985 if (sa->iso_bc->bc_sid > 0x0f && sa->iso_bc->bc_sid != HCI_SID_INVALID) 986 return -EINVAL; 987 988 iso_pi(sk)->bc_sid = sa->iso_bc->bc_sid; 989 990 if (sa->iso_bc->bc_num_bis > ISO_MAX_NUM_BIS) 991 return -EINVAL; 992 993 iso_pi(sk)->bc_num_bis = sa->iso_bc->bc_num_bis; 994 995 for (i = 0; i < iso_pi(sk)->bc_num_bis; i++) 996 if (sa->iso_bc->bc_bis[i] < 0x01 || 997 sa->iso_bc->bc_bis[i] > 0x1f) 998 return -EINVAL; 999 1000 memcpy(iso_pi(sk)->bc_bis, sa->iso_bc->bc_bis, 1001 iso_pi(sk)->bc_num_bis); 1002 1003 return 0; 1004 } 1005 1006 /* Must be called on the locked socket. */ 1007 static int iso_sock_rebind_bis(struct sock *sk, struct sockaddr_iso *sa, 1008 int addr_len) 1009 { 1010 int err = 0; 1011 1012 if (!test_bit(BT_SK_PA_SYNC, &iso_pi(sk)->flags)) 1013 return -EBADFD; 1014 1015 if (sa->iso_bc->bc_num_bis > ISO_MAX_NUM_BIS) { 1016 err = -EINVAL; 1017 goto done; 1018 } 1019 1020 iso_pi(sk)->bc_num_bis = sa->iso_bc->bc_num_bis; 1021 1022 for (int i = 0; i < iso_pi(sk)->bc_num_bis; i++) 1023 if (sa->iso_bc->bc_bis[i] < 0x01 || 1024 sa->iso_bc->bc_bis[i] > 0x1f) { 1025 err = -EINVAL; 1026 goto done; 1027 } 1028 1029 memcpy(iso_pi(sk)->bc_bis, sa->iso_bc->bc_bis, 1030 iso_pi(sk)->bc_num_bis); 1031 1032 done: 1033 return err; 1034 } 1035 1036 static struct hci_dev *iso_conn_get_hdev(struct iso_conn *conn) 1037 { 1038 struct hci_dev *hdev = NULL; 1039 1040 iso_conn_lock(conn); 1041 if (conn->hcon) 1042 hdev = hci_dev_hold(conn->hcon->hdev); 1043 iso_conn_unlock(conn); 1044 1045 return hdev; 1046 } 1047 1048 /* Must be called on the locked socket. */ 1049 static int iso_sock_rebind_bc(struct sock *sk, struct sockaddr_iso *sa, 1050 int addr_len) 1051 { 1052 struct hci_dev *hdev; 1053 struct hci_conn *bis; 1054 int err; 1055 1056 if (sk->sk_type != SOCK_SEQPACKET || !iso_pi(sk)->conn) 1057 return -EINVAL; 1058 1059 /* Check if it is really a Broadcast address being requested */ 1060 if (addr_len != sizeof(*sa) + sizeof(*sa->iso_bc)) 1061 return -EINVAL; 1062 1063 /* Check if the address hasn't changed then perhaps only the number of 1064 * bis has changed. 1065 */ 1066 if (!bacmp(&iso_pi(sk)->dst, &sa->iso_bc->bc_bdaddr) || 1067 !bacmp(&sa->iso_bc->bc_bdaddr, BDADDR_ANY)) 1068 return iso_sock_rebind_bis(sk, sa, addr_len); 1069 1070 /* Check if the address type is of LE type */ 1071 if (!bdaddr_type_is_le(sa->iso_bc->bc_bdaddr_type)) 1072 return -EINVAL; 1073 1074 hdev = iso_conn_get_hdev(iso_pi(sk)->conn); 1075 if (!hdev) 1076 return -EINVAL; 1077 1078 bis = iso_pi(sk)->conn->hcon; 1079 1080 /* Release the socket before lookups since that requires hci_dev_lock 1081 * which shall not be acquired while holding sock_lock for proper 1082 * ordering. 1083 */ 1084 release_sock(sk); 1085 hci_dev_lock(bis->hdev); 1086 lock_sock(sk); 1087 1088 if (!iso_pi(sk)->conn || iso_pi(sk)->conn->hcon != bis) { 1089 /* raced with iso_conn_del() or iso_disconn_sock() */ 1090 err = -ENOTCONN; 1091 goto unlock; 1092 } 1093 1094 BT_DBG("sk %p %pMR type %u", sk, &sa->iso_bc->bc_bdaddr, 1095 sa->iso_bc->bc_bdaddr_type); 1096 1097 err = hci_past_bis(bis, &sa->iso_bc->bc_bdaddr, 1098 le_addr_type(sa->iso_bc->bc_bdaddr_type)); 1099 1100 unlock: 1101 hci_dev_unlock(hdev); 1102 hci_dev_put(hdev); 1103 1104 return err; 1105 } 1106 1107 static int iso_sock_bind(struct socket *sock, struct sockaddr_unsized *addr, 1108 int addr_len) 1109 { 1110 struct sockaddr_iso *sa = (struct sockaddr_iso *)addr; 1111 struct sock *sk = sock->sk; 1112 int err = 0; 1113 1114 BT_DBG("sk %p %pMR type %u", sk, &sa->iso_bdaddr, sa->iso_bdaddr_type); 1115 1116 if (!addr || addr_len < sizeof(struct sockaddr_iso) || 1117 addr->sa_family != AF_BLUETOOTH) 1118 return -EINVAL; 1119 1120 lock_sock(sk); 1121 1122 if ((sk->sk_state == BT_CONNECT2 || sk->sk_state == BT_CONNECTED) && 1123 addr_len > sizeof(*sa)) { 1124 /* Allow the user to rebind to a different address using 1125 * PAST procedures. 1126 */ 1127 err = iso_sock_rebind_bc(sk, sa, addr_len); 1128 goto done; 1129 } 1130 1131 if (sk->sk_state != BT_OPEN) { 1132 err = -EBADFD; 1133 goto done; 1134 } 1135 1136 if (sk->sk_type != SOCK_SEQPACKET) { 1137 err = -EINVAL; 1138 goto done; 1139 } 1140 1141 /* Check if the address type is of LE type */ 1142 if (!bdaddr_type_is_le(sa->iso_bdaddr_type)) { 1143 err = -EINVAL; 1144 goto done; 1145 } 1146 1147 bacpy(&iso_pi(sk)->src, &sa->iso_bdaddr); 1148 iso_pi(sk)->src_type = sa->iso_bdaddr_type; 1149 1150 /* Check for Broadcast address */ 1151 if (addr_len > sizeof(*sa)) { 1152 err = iso_sock_bind_bc(sock, addr, addr_len); 1153 if (err) 1154 goto done; 1155 } 1156 1157 sk->sk_state = BT_BOUND; 1158 1159 done: 1160 release_sock(sk); 1161 return err; 1162 } 1163 1164 static int iso_sock_connect(struct socket *sock, struct sockaddr_unsized *addr, 1165 int alen, int flags) 1166 { 1167 struct sockaddr_iso *sa = (struct sockaddr_iso *)addr; 1168 struct sock *sk = sock->sk; 1169 int err; 1170 1171 BT_DBG("sk %p", sk); 1172 1173 if (alen < sizeof(struct sockaddr_iso) || 1174 addr->sa_family != AF_BLUETOOTH) 1175 return -EINVAL; 1176 1177 if (sk->sk_state != BT_OPEN && sk->sk_state != BT_BOUND) 1178 return -EBADFD; 1179 1180 if (sk->sk_type != SOCK_SEQPACKET) 1181 return -EINVAL; 1182 1183 /* Check if the address type is of LE type */ 1184 if (!bdaddr_type_is_le(sa->iso_bdaddr_type)) 1185 return -EINVAL; 1186 1187 lock_sock(sk); 1188 1189 bacpy(&iso_pi(sk)->dst, &sa->iso_bdaddr); 1190 iso_pi(sk)->dst_type = sa->iso_bdaddr_type; 1191 1192 release_sock(sk); 1193 1194 if (bacmp(&sa->iso_bdaddr, BDADDR_ANY)) 1195 err = iso_connect_cis(sk); 1196 else 1197 err = iso_connect_bis(sk); 1198 1199 if (err) 1200 return err; 1201 1202 lock_sock(sk); 1203 1204 if (!test_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags)) { 1205 err = bt_sock_wait_state(sk, BT_CONNECTED, 1206 sock_sndtimeo(sk, flags & O_NONBLOCK)); 1207 } 1208 1209 release_sock(sk); 1210 return err; 1211 } 1212 1213 static int iso_listen_bis(struct sock *sk) 1214 { 1215 struct hci_dev *hdev; 1216 int err = 0; 1217 struct iso_conn *conn; 1218 struct hci_conn *hcon; 1219 1220 BT_DBG("%pMR -> %pMR (SID 0x%2.2x)", &iso_pi(sk)->src, 1221 &iso_pi(sk)->dst, iso_pi(sk)->bc_sid); 1222 1223 write_lock(&iso_sk_list.lock); 1224 1225 if (__iso_get_sock_listen_by_sid(&iso_pi(sk)->src, &iso_pi(sk)->dst, 1226 iso_pi(sk)->bc_sid)) 1227 err = -EADDRINUSE; 1228 1229 write_unlock(&iso_sk_list.lock); 1230 1231 if (err) 1232 return err; 1233 1234 hdev = hci_get_route(&iso_pi(sk)->dst, &iso_pi(sk)->src, 1235 iso_pi(sk)->src_type); 1236 if (!hdev) 1237 return -EHOSTUNREACH; 1238 1239 hci_dev_lock(hdev); 1240 lock_sock(sk); 1241 1242 /* Fail if user set invalid QoS */ 1243 if (iso_pi(sk)->qos_user_set && !check_bcast_qos(&iso_pi(sk)->qos)) { 1244 iso_pi(sk)->qos = default_qos; 1245 err = -EINVAL; 1246 goto unlock; 1247 } 1248 1249 hcon = hci_pa_create_sync(hdev, &iso_pi(sk)->dst, 1250 le_addr_type(iso_pi(sk)->dst_type), 1251 iso_pi(sk)->bc_sid, &iso_pi(sk)->qos); 1252 if (IS_ERR(hcon)) { 1253 err = PTR_ERR(hcon); 1254 goto unlock; 1255 } 1256 1257 conn = iso_conn_add(hcon); 1258 if (!conn) { 1259 hci_conn_drop(hcon); 1260 err = -ENOMEM; 1261 goto unlock; 1262 } 1263 1264 err = iso_chan_add(conn, sk, NULL); 1265 if (err) { 1266 hci_conn_drop(hcon); 1267 goto unlock; 1268 } 1269 1270 unlock: 1271 release_sock(sk); 1272 hci_dev_unlock(hdev); 1273 hci_dev_put(hdev); 1274 return err; 1275 } 1276 1277 static int iso_listen_cis(struct sock *sk) 1278 { 1279 int err = 0; 1280 1281 BT_DBG("%pMR", &iso_pi(sk)->src); 1282 1283 write_lock(&iso_sk_list.lock); 1284 1285 if (__iso_get_sock_listen_by_addr(&iso_pi(sk)->src, &iso_pi(sk)->dst)) 1286 err = -EADDRINUSE; 1287 1288 write_unlock(&iso_sk_list.lock); 1289 1290 return err; 1291 } 1292 1293 static int iso_sock_listen(struct socket *sock, int backlog) 1294 { 1295 struct sock *sk = sock->sk; 1296 int err = 0; 1297 1298 BT_DBG("sk %p backlog %d", sk, backlog); 1299 1300 sock_hold(sk); 1301 lock_sock(sk); 1302 1303 if (sk->sk_state != BT_BOUND) { 1304 err = -EBADFD; 1305 goto done; 1306 } 1307 1308 if (sk->sk_type != SOCK_SEQPACKET) { 1309 err = -EINVAL; 1310 goto done; 1311 } 1312 1313 if (!bacmp(&iso_pi(sk)->dst, BDADDR_ANY)) { 1314 err = iso_listen_cis(sk); 1315 } else { 1316 /* Drop sock lock to avoid potential 1317 * deadlock with the hdev lock. 1318 */ 1319 release_sock(sk); 1320 err = iso_listen_bis(sk); 1321 lock_sock(sk); 1322 } 1323 1324 if (err) 1325 goto done; 1326 1327 sk->sk_max_ack_backlog = backlog; 1328 sk->sk_ack_backlog = 0; 1329 1330 sk->sk_state = BT_LISTEN; 1331 1332 done: 1333 release_sock(sk); 1334 sock_put(sk); 1335 return err; 1336 } 1337 1338 static int iso_sock_accept(struct socket *sock, struct socket *newsock, 1339 struct proto_accept_arg *arg) 1340 { 1341 DEFINE_WAIT_FUNC(wait, woken_wake_function); 1342 struct sock *sk = sock->sk, *ch; 1343 long timeo; 1344 int err = 0; 1345 1346 /* Use explicit nested locking to avoid lockdep warnings generated 1347 * because the parent socket and the child socket are locked on the 1348 * same thread. 1349 */ 1350 lock_sock_nested(sk, SINGLE_DEPTH_NESTING); 1351 1352 timeo = sock_rcvtimeo(sk, arg->flags & O_NONBLOCK); 1353 1354 BT_DBG("sk %p timeo %ld", sk, timeo); 1355 1356 /* Wait for an incoming connection. (wake-one). */ 1357 add_wait_queue_exclusive(sk_sleep(sk), &wait); 1358 while (1) { 1359 if (sk->sk_state != BT_LISTEN) { 1360 err = -EBADFD; 1361 break; 1362 } 1363 1364 ch = bt_accept_dequeue(sk, newsock); 1365 if (ch) { 1366 /* Drop the bridging ref from bt_accept_dequeue(); 1367 * the grafted socket keeps ch alive from here. 1368 */ 1369 sock_put(ch); 1370 break; 1371 } 1372 1373 if (!timeo) { 1374 err = -EAGAIN; 1375 break; 1376 } 1377 1378 if (signal_pending(current)) { 1379 err = sock_intr_errno(timeo); 1380 break; 1381 } 1382 1383 release_sock(sk); 1384 1385 timeo = wait_woken(&wait, TASK_INTERRUPTIBLE, timeo); 1386 lock_sock_nested(sk, SINGLE_DEPTH_NESTING); 1387 } 1388 remove_wait_queue(sk_sleep(sk), &wait); 1389 1390 if (err) 1391 goto done; 1392 1393 newsock->state = SS_CONNECTED; 1394 1395 BT_DBG("new socket %p", ch); 1396 1397 /* A Broadcast Sink might require BIG sync to be terminated 1398 * and re-established multiple times, while keeping the same 1399 * PA sync handle active. To allow this, once all BIS 1400 * connections have been accepted on a PA sync parent socket, 1401 * "reset" socket state, to allow future BIG re-sync procedures. 1402 */ 1403 if (test_bit(BT_SK_PA_SYNC, &iso_pi(sk)->flags)) { 1404 /* Iterate through the list of bound BIS indices 1405 * and clear each BIS as they are accepted by the 1406 * user space, one by one. 1407 */ 1408 for (int i = 0; i < iso_pi(sk)->bc_num_bis; i++) { 1409 if (iso_pi(sk)->bc_bis[i] > 0) { 1410 iso_pi(sk)->bc_bis[i] = 0; 1411 iso_pi(sk)->bc_num_bis--; 1412 break; 1413 } 1414 } 1415 1416 if (iso_pi(sk)->bc_num_bis == 0) { 1417 /* Once the last BIS was accepted, reset parent 1418 * socket parameters to mark that the listening 1419 * process for BIS connections has been completed: 1420 * 1421 * 1. Reset the DEFER setup flag on the parent sk. 1422 * 2. Clear the flag marking that the BIG create 1423 * sync command is pending. 1424 * 3. Transition socket state from BT_LISTEN to 1425 * BT_CONNECTED. 1426 */ 1427 set_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags); 1428 clear_bit(BT_SK_BIG_SYNC, &iso_pi(sk)->flags); 1429 sk->sk_state = BT_CONNECTED; 1430 } 1431 } 1432 1433 done: 1434 release_sock(sk); 1435 return err; 1436 } 1437 1438 static int iso_sock_getname(struct socket *sock, struct sockaddr *addr, 1439 int peer) 1440 { 1441 struct sockaddr_iso *sa = (struct sockaddr_iso *)addr; 1442 struct sock *sk = sock->sk; 1443 int len = sizeof(struct sockaddr_iso); 1444 1445 BT_DBG("sock %p, sk %p", sock, sk); 1446 1447 addr->sa_family = AF_BLUETOOTH; 1448 1449 if (peer) { 1450 struct hci_conn *hcon = iso_pi(sk)->conn ? 1451 iso_pi(sk)->conn->hcon : NULL; 1452 1453 bacpy(&sa->iso_bdaddr, &iso_pi(sk)->dst); 1454 sa->iso_bdaddr_type = iso_pi(sk)->dst_type; 1455 1456 if (hcon && (hcon->type == BIS_LINK || hcon->type == PA_LINK)) { 1457 sa->iso_bc->bc_sid = iso_pi(sk)->bc_sid; 1458 sa->iso_bc->bc_num_bis = iso_pi(sk)->bc_num_bis; 1459 memcpy(sa->iso_bc->bc_bis, iso_pi(sk)->bc_bis, 1460 ISO_MAX_NUM_BIS); 1461 len += sizeof(struct sockaddr_iso_bc); 1462 } 1463 } else { 1464 bacpy(&sa->iso_bdaddr, &iso_pi(sk)->src); 1465 sa->iso_bdaddr_type = iso_pi(sk)->src_type; 1466 } 1467 1468 return len; 1469 } 1470 1471 static int iso_sock_sendmsg(struct socket *sock, struct msghdr *msg, 1472 size_t len) 1473 { 1474 struct sock *sk = sock->sk; 1475 struct sk_buff *skb, **frag; 1476 struct sockcm_cookie sockc; 1477 size_t mtu; 1478 int err; 1479 1480 BT_DBG("sock %p, sk %p", sock, sk); 1481 1482 err = sock_error(sk); 1483 if (err) 1484 return err; 1485 1486 if (msg->msg_flags & MSG_OOB) 1487 return -EOPNOTSUPP; 1488 1489 hci_sockcm_init(&sockc, sk); 1490 1491 if (msg->msg_controllen) { 1492 err = sock_cmsg_send(sk, msg, &sockc); 1493 if (err) 1494 return err; 1495 } 1496 1497 lock_sock(sk); 1498 1499 if (sk->sk_state != BT_CONNECTED) { 1500 release_sock(sk); 1501 return -ENOTCONN; 1502 } 1503 1504 mtu = iso_pi(sk)->conn->hcon->mtu; 1505 1506 release_sock(sk); 1507 1508 skb = bt_skb_sendmsg(sk, msg, len, mtu, HCI_ISO_DATA_HDR_SIZE, 0); 1509 if (IS_ERR(skb)) 1510 return PTR_ERR(skb); 1511 1512 len -= skb->len; 1513 1514 BT_DBG("skb %p len %d", sk, skb->len); 1515 1516 /* Continuation fragments */ 1517 frag = &skb_shinfo(skb)->frag_list; 1518 while (len) { 1519 struct sk_buff *tmp; 1520 1521 tmp = bt_skb_sendmsg(sk, msg, len, mtu, 0, 0); 1522 if (IS_ERR(tmp)) { 1523 kfree_skb(skb); 1524 return PTR_ERR(tmp); 1525 } 1526 1527 *frag = tmp; 1528 1529 len -= tmp->len; 1530 1531 skb->len += tmp->len; 1532 skb->data_len += tmp->len; 1533 1534 BT_DBG("frag %p len %d", *frag, tmp->len); 1535 1536 frag = &(*frag)->next; 1537 } 1538 1539 lock_sock(sk); 1540 1541 if (sk->sk_state == BT_CONNECTED) 1542 err = iso_send_frame(sk, skb, &sockc); 1543 else 1544 err = -ENOTCONN; 1545 1546 release_sock(sk); 1547 1548 if (err < 0) 1549 kfree_skb(skb); 1550 return err; 1551 } 1552 1553 static void iso_conn_defer_accept(struct hci_conn *conn) 1554 { 1555 struct hci_cp_le_accept_cis cp; 1556 struct hci_dev *hdev = conn->hdev; 1557 1558 BT_DBG("conn %p", conn); 1559 1560 conn->state = BT_CONFIG; 1561 1562 cp.handle = cpu_to_le16(conn->handle); 1563 1564 hci_send_cmd(hdev, HCI_OP_LE_ACCEPT_CIS, sizeof(cp), &cp); 1565 } 1566 1567 static void iso_conn_big_sync(struct sock *sk) 1568 { 1569 int err; 1570 struct hci_dev *hdev; 1571 1572 hdev = hci_get_route(&iso_pi(sk)->dst, &iso_pi(sk)->src, 1573 iso_pi(sk)->src_type); 1574 1575 if (!hdev) 1576 return; 1577 1578 /* hci_le_big_create_sync requires hdev lock to be held, since 1579 * it enqueues the HCI LE BIG Create Sync command via 1580 * hci_cmd_sync_queue_once, which checks hdev flags that might 1581 * change. 1582 */ 1583 hci_dev_lock(hdev); 1584 lock_sock(sk); 1585 1586 if (!test_and_set_bit(BT_SK_BIG_SYNC, &iso_pi(sk)->flags)) { 1587 err = hci_conn_big_create_sync(hdev, iso_pi(sk)->conn->hcon, 1588 &iso_pi(sk)->qos, 1589 iso_pi(sk)->sync_handle, 1590 iso_pi(sk)->bc_num_bis, 1591 iso_pi(sk)->bc_bis); 1592 if (err) 1593 bt_dev_err(hdev, "hci_big_create_sync: %d", err); 1594 } 1595 1596 release_sock(sk); 1597 hci_dev_unlock(hdev); 1598 } 1599 1600 static int iso_sock_recvmsg(struct socket *sock, struct msghdr *msg, 1601 size_t len, int flags) 1602 { 1603 struct sock *sk = sock->sk; 1604 struct iso_pinfo *pi = iso_pi(sk); 1605 bool early_ret = false; 1606 int err = 0; 1607 1608 BT_DBG("sk %p", sk); 1609 1610 if (unlikely(flags & MSG_ERRQUEUE)) 1611 return sock_recv_errqueue(sk, msg, len, SOL_BLUETOOTH, 1612 BT_SCM_ERROR); 1613 1614 if (test_and_clear_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags)) { 1615 sock_hold(sk); 1616 lock_sock(sk); 1617 1618 switch (sk->sk_state) { 1619 case BT_CONNECT2: 1620 if (test_bit(BT_SK_PA_SYNC, &pi->flags)) { 1621 release_sock(sk); 1622 iso_conn_big_sync(sk); 1623 lock_sock(sk); 1624 1625 sk->sk_state = BT_LISTEN; 1626 } else { 1627 iso_conn_defer_accept(pi->conn->hcon); 1628 sk->sk_state = BT_CONFIG; 1629 } 1630 1631 early_ret = true; 1632 break; 1633 case BT_CONNECTED: 1634 if (test_bit(BT_SK_PA_SYNC, &iso_pi(sk)->flags)) { 1635 release_sock(sk); 1636 iso_conn_big_sync(sk); 1637 lock_sock(sk); 1638 1639 sk->sk_state = BT_LISTEN; 1640 early_ret = true; 1641 } 1642 1643 break; 1644 case BT_CONNECT: 1645 release_sock(sk); 1646 err = iso_connect_cis(sk); 1647 lock_sock(sk); 1648 1649 early_ret = true; 1650 break; 1651 default: 1652 break; 1653 } 1654 1655 release_sock(sk); 1656 sock_put(sk); 1657 1658 if (early_ret) 1659 return err; 1660 } 1661 1662 return bt_sock_recvmsg(sock, msg, len, flags); 1663 } 1664 1665 static bool check_io_qos(struct bt_iso_io_qos *qos) 1666 { 1667 /* If no PHY is enable SDU must be 0 */ 1668 if (!qos->phys && qos->sdu) 1669 return false; 1670 1671 if (qos->interval && (qos->interval < 0xff || qos->interval > 0xfffff)) 1672 return false; 1673 1674 if (qos->latency && (qos->latency < 0x05 || qos->latency > 0xfa0)) 1675 return false; 1676 1677 if (qos->phys > BT_ISO_PHY_ANY) 1678 return false; 1679 1680 return true; 1681 } 1682 1683 static bool check_ucast_qos(struct bt_iso_qos *qos) 1684 { 1685 if (qos->ucast.cig > 0xef && qos->ucast.cig != BT_ISO_QOS_CIG_UNSET) 1686 return false; 1687 1688 if (qos->ucast.cis > 0xef && qos->ucast.cis != BT_ISO_QOS_CIS_UNSET) 1689 return false; 1690 1691 if (qos->ucast.sca > 0x07) 1692 return false; 1693 1694 if (qos->ucast.packing > 0x01) 1695 return false; 1696 1697 if (qos->ucast.framing > 0x01) 1698 return false; 1699 1700 if (!check_io_qos(&qos->ucast.in)) 1701 return false; 1702 1703 if (!check_io_qos(&qos->ucast.out)) 1704 return false; 1705 1706 return true; 1707 } 1708 1709 static bool check_bcast_qos(struct bt_iso_qos *qos) 1710 { 1711 if (!qos->bcast.sync_factor) 1712 qos->bcast.sync_factor = 0x01; 1713 1714 if (qos->bcast.packing > 0x01) 1715 return false; 1716 1717 if (qos->bcast.framing > 0x01) 1718 return false; 1719 1720 if (!check_io_qos(&qos->bcast.in)) 1721 return false; 1722 1723 if (!check_io_qos(&qos->bcast.out)) 1724 return false; 1725 1726 if (qos->bcast.encryption > 0x01) 1727 return false; 1728 1729 if (qos->bcast.options > 0x07) 1730 return false; 1731 1732 if (qos->bcast.skip > 0x01f3) 1733 return false; 1734 1735 if (!qos->bcast.sync_timeout) 1736 qos->bcast.sync_timeout = BT_ISO_SYNC_TIMEOUT; 1737 1738 if (qos->bcast.sync_timeout < 0x000a || qos->bcast.sync_timeout > 0x4000) 1739 return false; 1740 1741 if (qos->bcast.sync_cte_type > 0x1f) 1742 return false; 1743 1744 if (qos->bcast.mse > 0x1f) 1745 return false; 1746 1747 if (!qos->bcast.timeout) 1748 qos->bcast.sync_timeout = BT_ISO_SYNC_TIMEOUT; 1749 1750 if (qos->bcast.timeout < 0x000a || qos->bcast.timeout > 0x4000) 1751 return false; 1752 1753 return true; 1754 } 1755 1756 static int iso_sock_setsockopt(struct socket *sock, int level, int optname, 1757 sockptr_t optval, unsigned int optlen) 1758 { 1759 struct sock *sk = sock->sk; 1760 int err = 0; 1761 struct bt_iso_qos qos = default_qos; 1762 u32 opt; 1763 1764 BT_DBG("sk %p", sk); 1765 1766 lock_sock(sk); 1767 1768 switch (optname) { 1769 case BT_DEFER_SETUP: 1770 if (sk->sk_state != BT_BOUND && sk->sk_state != BT_LISTEN) { 1771 err = -EINVAL; 1772 break; 1773 } 1774 1775 err = copy_safe_from_sockptr(&opt, sizeof(opt), optval, optlen); 1776 if (err) 1777 break; 1778 1779 if (opt) 1780 set_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags); 1781 else 1782 clear_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags); 1783 break; 1784 1785 case BT_PKT_STATUS: 1786 err = copy_safe_from_sockptr(&opt, sizeof(opt), optval, optlen); 1787 if (err) 1788 break; 1789 1790 if (opt) 1791 set_bit(BT_SK_PKT_STATUS, &bt_sk(sk)->flags); 1792 else 1793 clear_bit(BT_SK_PKT_STATUS, &bt_sk(sk)->flags); 1794 break; 1795 1796 case BT_PKT_SEQNUM: 1797 err = copy_safe_from_sockptr(&opt, sizeof(opt), optval, optlen); 1798 if (err) 1799 break; 1800 1801 if (opt) 1802 set_bit(BT_SK_PKT_SEQNUM, &bt_sk(sk)->flags); 1803 else 1804 clear_bit(BT_SK_PKT_SEQNUM, &bt_sk(sk)->flags); 1805 break; 1806 1807 case BT_ISO_QOS: 1808 if (sk->sk_state != BT_OPEN && sk->sk_state != BT_BOUND && 1809 sk->sk_state != BT_CONNECT2 && 1810 (!test_bit(BT_SK_PA_SYNC, &iso_pi(sk)->flags) || 1811 sk->sk_state != BT_CONNECTED)) { 1812 err = -EINVAL; 1813 break; 1814 } 1815 1816 err = copy_safe_from_sockptr(&qos, sizeof(qos), optval, optlen); 1817 if (err) 1818 break; 1819 1820 iso_pi(sk)->qos = qos; 1821 iso_pi(sk)->qos_user_set = true; 1822 1823 break; 1824 1825 case BT_ISO_BASE: 1826 if (sk->sk_state != BT_OPEN && sk->sk_state != BT_BOUND && 1827 sk->sk_state != BT_CONNECT2) { 1828 err = -EINVAL; 1829 break; 1830 } 1831 1832 if (optlen > sizeof(iso_pi(sk)->base)) { 1833 err = -EINVAL; 1834 break; 1835 } 1836 1837 err = copy_safe_from_sockptr(iso_pi(sk)->base, optlen, optval, 1838 optlen); 1839 if (err) 1840 break; 1841 1842 iso_pi(sk)->base_len = optlen; 1843 1844 break; 1845 1846 default: 1847 err = -ENOPROTOOPT; 1848 break; 1849 } 1850 1851 release_sock(sk); 1852 return err; 1853 } 1854 1855 static int iso_sock_getsockopt(struct socket *sock, int level, int optname, 1856 char __user *optval, int __user *optlen) 1857 { 1858 struct sock *sk = sock->sk; 1859 int len, err = 0; 1860 struct bt_iso_qos *qos; 1861 u8 base_len; 1862 u8 *base; 1863 1864 BT_DBG("sk %p", sk); 1865 1866 if (get_user(len, optlen)) 1867 return -EFAULT; 1868 1869 lock_sock(sk); 1870 1871 switch (optname) { 1872 case BT_DEFER_SETUP: 1873 if (sk->sk_state == BT_CONNECTED) { 1874 err = -EINVAL; 1875 break; 1876 } 1877 1878 if (put_user(test_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags), 1879 (u32 __user *)optval)) 1880 err = -EFAULT; 1881 1882 break; 1883 1884 case BT_PKT_STATUS: 1885 if (put_user(test_bit(BT_SK_PKT_STATUS, &bt_sk(sk)->flags), 1886 (int __user *)optval)) 1887 err = -EFAULT; 1888 break; 1889 1890 case BT_ISO_QOS: 1891 qos = iso_sock_get_qos(sk); 1892 1893 len = min_t(unsigned int, len, sizeof(*qos)); 1894 if (copy_to_user(optval, qos, len)) 1895 err = -EFAULT; 1896 1897 break; 1898 1899 case BT_ISO_BASE: 1900 if (sk->sk_state == BT_CONNECTED && 1901 !bacmp(&iso_pi(sk)->dst, BDADDR_ANY)) { 1902 base_len = iso_pi(sk)->conn->hcon->le_per_adv_data_len; 1903 base = iso_pi(sk)->conn->hcon->le_per_adv_data; 1904 } else { 1905 base_len = iso_pi(sk)->base_len; 1906 base = iso_pi(sk)->base; 1907 } 1908 1909 len = min_t(unsigned int, len, base_len); 1910 if (copy_to_user(optval, base, len)) 1911 err = -EFAULT; 1912 if (put_user(len, optlen)) 1913 err = -EFAULT; 1914 1915 break; 1916 1917 default: 1918 err = -ENOPROTOOPT; 1919 break; 1920 } 1921 1922 release_sock(sk); 1923 return err; 1924 } 1925 1926 static int iso_sock_shutdown(struct socket *sock, int how) 1927 { 1928 struct sock *sk = sock->sk; 1929 int err = 0; 1930 1931 BT_DBG("sock %p, sk %p, how %d", sock, sk, how); 1932 1933 if (!sk) 1934 return 0; 1935 1936 sock_hold(sk); 1937 lock_sock(sk); 1938 1939 switch (how) { 1940 case SHUT_RD: 1941 if (sk->sk_shutdown & RCV_SHUTDOWN) 1942 goto unlock; 1943 sk->sk_shutdown |= RCV_SHUTDOWN; 1944 break; 1945 case SHUT_WR: 1946 if (sk->sk_shutdown & SEND_SHUTDOWN) 1947 goto unlock; 1948 sk->sk_shutdown |= SEND_SHUTDOWN; 1949 break; 1950 case SHUT_RDWR: 1951 if (sk->sk_shutdown & SHUTDOWN_MASK) 1952 goto unlock; 1953 sk->sk_shutdown |= SHUTDOWN_MASK; 1954 break; 1955 } 1956 1957 iso_sock_clear_timer(sk); 1958 __iso_sock_close(sk); 1959 1960 if (sock_flag(sk, SOCK_LINGER) && sk->sk_lingertime && 1961 !(current->flags & PF_EXITING)) 1962 err = bt_sock_wait_state(sk, BT_CLOSED, sk->sk_lingertime); 1963 1964 unlock: 1965 release_sock(sk); 1966 sock_put(sk); 1967 1968 return err; 1969 } 1970 1971 static int iso_sock_release(struct socket *sock) 1972 { 1973 struct sock *sk = sock->sk; 1974 int err = 0; 1975 1976 BT_DBG("sock %p, sk %p", sock, sk); 1977 1978 if (!sk) 1979 return 0; 1980 1981 iso_sock_close(sk); 1982 1983 if (sock_flag(sk, SOCK_LINGER) && READ_ONCE(sk->sk_lingertime) && 1984 !(current->flags & PF_EXITING)) { 1985 lock_sock(sk); 1986 err = bt_sock_wait_state(sk, BT_CLOSED, sk->sk_lingertime); 1987 release_sock(sk); 1988 } 1989 1990 sock_orphan(sk); 1991 iso_sock_kill(sk); 1992 return err; 1993 } 1994 1995 static void iso_sock_ready(struct sock *sk) 1996 { 1997 BT_DBG("sk %p", sk); 1998 1999 if (!sk) 2000 return; 2001 2002 lock_sock(sk); 2003 iso_sock_clear_timer(sk); 2004 sk->sk_state = BT_CONNECTED; 2005 sk->sk_state_change(sk); 2006 release_sock(sk); 2007 } 2008 2009 static bool iso_match_big(struct sock *sk, void *data) 2010 { 2011 struct hci_evt_le_big_sync_established *ev = data; 2012 2013 return ev->handle == iso_pi(sk)->qos.bcast.big; 2014 } 2015 2016 static bool iso_match_big_hcon(struct sock *sk, void *data) 2017 { 2018 struct hci_conn *hcon = data; 2019 2020 return hcon->iso_qos.bcast.big == iso_pi(sk)->qos.bcast.big; 2021 } 2022 2023 static bool iso_match_pa_sync_flag(struct sock *sk, void *data) 2024 { 2025 return test_bit(BT_SK_PA_SYNC, &iso_pi(sk)->flags); 2026 } 2027 2028 static bool iso_match_dst(struct sock *sk, void *data) 2029 { 2030 return !bacmp(&iso_pi(sk)->dst, (bdaddr_t *)data); 2031 } 2032 2033 static void iso_conn_ready(struct iso_conn *conn) 2034 { 2035 struct sock *parent = NULL; 2036 struct sock *sk = conn->sk; 2037 struct hci_ev_le_big_sync_established *ev = NULL; 2038 struct hci_ev_le_pa_sync_established *ev2 = NULL; 2039 struct hci_ev_le_per_adv_report *ev3 = NULL; 2040 struct hci_conn *hcon; 2041 struct hci_dev *hdev; 2042 2043 BT_DBG("conn %p", conn); 2044 2045 if (sk) { 2046 /* Attempt to update source address in case of BIS Sender if 2047 * the advertisement is using a random address. 2048 */ 2049 if (conn->hcon->type == BIS_LINK && 2050 conn->hcon->role == HCI_ROLE_MASTER && 2051 !bacmp(&conn->hcon->dst, BDADDR_ANY)) { 2052 struct hci_conn *bis = conn->hcon; 2053 struct adv_info *adv; 2054 2055 adv = hci_find_adv_instance(bis->hdev, 2056 bis->iso_qos.bcast.bis); 2057 if (adv && bacmp(&adv->random_addr, BDADDR_ANY)) { 2058 lock_sock(sk); 2059 iso_pi(sk)->src_type = BDADDR_LE_RANDOM; 2060 bacpy(&iso_pi(sk)->src, &adv->random_addr); 2061 release_sock(sk); 2062 } 2063 } 2064 2065 iso_sock_ready(conn->sk); 2066 } else { 2067 hcon = conn->hcon; 2068 if (!hcon) 2069 return; 2070 2071 hdev = hcon->hdev; 2072 2073 if (test_bit(HCI_CONN_BIG_SYNC, &hcon->flags)) { 2074 /* A BIS slave hcon is notified to the ISO layer 2075 * after the Command Complete for the LE Setup 2076 * ISO Data Path command is received. Get the 2077 * parent socket that matches the hcon BIG handle. 2078 */ 2079 parent = iso_get_sock(hdev, &hcon->src, &hcon->dst, 2080 BT_LISTEN, iso_match_big_hcon, 2081 hcon); 2082 } else if (test_bit(HCI_CONN_BIG_SYNC_FAILED, &hcon->flags)) { 2083 ev = hci_recv_event_data(hcon->hdev, 2084 HCI_EVT_LE_BIG_SYNC_ESTABLISHED); 2085 2086 /* Get reference to PA sync parent socket, if it exists */ 2087 parent = iso_get_sock(hdev, &hcon->src, &hcon->dst, 2088 BT_LISTEN, 2089 iso_match_pa_sync_flag, 2090 NULL); 2091 if (!parent && ev) 2092 parent = iso_get_sock(hdev, &hcon->src, 2093 &hcon->dst, 2094 BT_LISTEN, 2095 iso_match_big, ev); 2096 } else if (test_bit(HCI_CONN_PA_SYNC_FAILED, &hcon->flags)) { 2097 ev2 = hci_recv_event_data(hcon->hdev, 2098 HCI_EV_LE_PA_SYNC_ESTABLISHED); 2099 if (ev2) 2100 parent = iso_get_sock(hdev, &hcon->src, 2101 &hcon->dst, 2102 BT_LISTEN, 2103 iso_match_sid, ev2); 2104 } else if (test_bit(HCI_CONN_PA_SYNC, &hcon->flags)) { 2105 ev3 = hci_recv_event_data(hcon->hdev, 2106 HCI_EV_LE_PER_ADV_REPORT); 2107 if (ev3) 2108 parent = iso_get_sock(hdev, &hcon->src, 2109 &hcon->dst, 2110 BT_LISTEN, 2111 iso_match_sync_handle_pa_report, 2112 ev3); 2113 } 2114 2115 if (!parent) 2116 parent = iso_get_sock(hdev, &hcon->src, BDADDR_ANY, 2117 BT_LISTEN, iso_match_dst, BDADDR_ANY); 2118 2119 if (!parent) 2120 return; 2121 2122 lock_sock(parent); 2123 2124 sk = iso_sock_alloc(sock_net(parent), NULL, 2125 BTPROTO_ISO, GFP_ATOMIC, 0); 2126 if (!sk) { 2127 release_sock(parent); 2128 return; 2129 } 2130 2131 iso_sock_init(sk, parent); 2132 2133 bacpy(&iso_pi(sk)->src, &hcon->src); 2134 2135 /* Convert from HCI to three-value type */ 2136 if (hcon->src_type == ADDR_LE_DEV_PUBLIC) 2137 iso_pi(sk)->src_type = BDADDR_LE_PUBLIC; 2138 else 2139 iso_pi(sk)->src_type = BDADDR_LE_RANDOM; 2140 2141 /* If hcon has no destination address (BDADDR_ANY) it means it 2142 * was created by HCI_EV_LE_BIG_SYNC_ESTABILISHED or 2143 * HCI_EV_LE_PA_SYNC_ESTABLISHED so we need to initialize using 2144 * the parent socket destination address. 2145 */ 2146 if (!bacmp(&hcon->dst, BDADDR_ANY)) { 2147 bacpy(&hcon->dst, &iso_pi(parent)->dst); 2148 hcon->dst_type = le_addr_type(iso_pi(parent)->dst_type); 2149 } 2150 2151 if (test_bit(HCI_CONN_PA_SYNC, &hcon->flags)) { 2152 iso_pi(sk)->qos = iso_pi(parent)->qos; 2153 hcon->iso_qos = iso_pi(sk)->qos; 2154 iso_pi(sk)->bc_sid = iso_pi(parent)->bc_sid; 2155 iso_pi(sk)->bc_num_bis = iso_pi(parent)->bc_num_bis; 2156 memcpy(iso_pi(sk)->bc_bis, iso_pi(parent)->bc_bis, 2157 ISO_MAX_NUM_BIS); 2158 set_bit(BT_SK_PA_SYNC, &iso_pi(sk)->flags); 2159 } 2160 2161 bacpy(&iso_pi(sk)->dst, &hcon->dst); 2162 2163 /* Convert from HCI to three-value type */ 2164 if (hcon->dst_type == ADDR_LE_DEV_PUBLIC) 2165 iso_pi(sk)->dst_type = BDADDR_LE_PUBLIC; 2166 else 2167 iso_pi(sk)->dst_type = BDADDR_LE_RANDOM; 2168 2169 iso_pi(sk)->sync_handle = iso_pi(parent)->sync_handle; 2170 memcpy(iso_pi(sk)->base, iso_pi(parent)->base, iso_pi(parent)->base_len); 2171 iso_pi(sk)->base_len = iso_pi(parent)->base_len; 2172 2173 hci_conn_hold(hcon); 2174 iso_chan_add(conn, sk, parent); 2175 2176 if ((ev && ((struct hci_evt_le_big_sync_established *)ev)->status) || 2177 (ev2 && ev2->status)) { 2178 /* Trigger error signal on child socket */ 2179 sk->sk_err = ECONNREFUSED; 2180 sk->sk_error_report(sk); 2181 } 2182 2183 if (test_bit(BT_SK_DEFER_SETUP, &bt_sk(parent)->flags)) 2184 sk->sk_state = BT_CONNECT2; 2185 else 2186 sk->sk_state = BT_CONNECTED; 2187 2188 /* Wake up parent */ 2189 parent->sk_data_ready(parent); 2190 2191 release_sock(parent); 2192 sock_put(parent); 2193 } 2194 } 2195 2196 static bool iso_match_sid(struct sock *sk, void *data) 2197 { 2198 struct hci_ev_le_pa_sync_established *ev = data; 2199 2200 if (iso_pi(sk)->bc_sid == HCI_SID_INVALID) 2201 return true; 2202 2203 return ev->sid == iso_pi(sk)->bc_sid; 2204 } 2205 2206 static bool iso_match_sid_past(struct sock *sk, void *data) 2207 { 2208 struct hci_ev_le_past_received *ev = data; 2209 2210 if (iso_pi(sk)->bc_sid == HCI_SID_INVALID) 2211 return true; 2212 2213 return ev->sid == iso_pi(sk)->bc_sid; 2214 } 2215 2216 static bool iso_match_sync_handle(struct sock *sk, void *data) 2217 { 2218 struct hci_evt_le_big_info_adv_report *ev = data; 2219 2220 return le16_to_cpu(ev->sync_handle) == iso_pi(sk)->sync_handle; 2221 } 2222 2223 static bool iso_match_sync_handle_pa_report(struct sock *sk, void *data) 2224 { 2225 struct hci_ev_le_per_adv_report *ev = data; 2226 2227 return le16_to_cpu(ev->sync_handle) == iso_pi(sk)->sync_handle; 2228 } 2229 2230 /* ----- ISO interface with lower layer (HCI) ----- */ 2231 2232 int iso_connect_ind(struct hci_dev *hdev, bdaddr_t *bdaddr, __u8 *flags) 2233 { 2234 struct hci_ev_le_pa_sync_established *ev1; 2235 struct hci_ev_le_past_received *ev1a; 2236 struct hci_evt_le_big_info_adv_report *ev2; 2237 struct hci_ev_le_per_adv_report *ev3; 2238 struct sock *sk; 2239 2240 bt_dev_dbg(hdev, "bdaddr %pMR", bdaddr); 2241 2242 /* Broadcast receiver requires handling of some events before it can 2243 * proceed to establishing a BIG sync: 2244 * 2245 * 1. HCI_EV_LE_PA_SYNC_ESTABLISHED: The socket may specify a specific 2246 * SID to listen to and once sync is established its handle needs to 2247 * be stored in iso_pi(sk)->sync_handle so it can be matched once 2248 * receiving the BIG Info. 2249 * 1a. HCI_EV_LE_PAST_RECEIVED: alternative to 1. 2250 * 2. HCI_EVT_LE_BIG_INFO_ADV_REPORT: When connect_ind is triggered by a 2251 * a BIG Info it attempts to check if there any listening socket with 2252 * the same sync_handle and if it does then attempt to create a sync. 2253 * 3. HCI_EV_LE_PER_ADV_REPORT: When a PA report is received, it is stored 2254 * in iso_pi(sk)->base so it can be passed up to user, in the case of a 2255 * broadcast sink. 2256 */ 2257 ev1 = hci_recv_event_data(hdev, HCI_EV_LE_PA_SYNC_ESTABLISHED); 2258 if (ev1) { 2259 sk = iso_get_sock(hdev, &hdev->bdaddr, bdaddr, BT_LISTEN, 2260 iso_match_sid, ev1); 2261 if (sk && !ev1->status) { 2262 lock_sock(sk); 2263 iso_pi(sk)->sync_handle = le16_to_cpu(ev1->handle); 2264 iso_pi(sk)->bc_sid = ev1->sid; 2265 release_sock(sk); 2266 } 2267 2268 goto done; 2269 } 2270 2271 ev1a = hci_recv_event_data(hdev, HCI_EV_LE_PAST_RECEIVED); 2272 if (ev1a) { 2273 sk = iso_get_sock(hdev, &hdev->bdaddr, bdaddr, BT_LISTEN, 2274 iso_match_sid_past, ev1a); 2275 if (sk && !ev1a->status) { 2276 lock_sock(sk); 2277 iso_pi(sk)->sync_handle = le16_to_cpu(ev1a->sync_handle); 2278 iso_pi(sk)->bc_sid = ev1a->sid; 2279 release_sock(sk); 2280 } 2281 2282 goto done; 2283 } 2284 2285 ev2 = hci_recv_event_data(hdev, HCI_EVT_LE_BIG_INFO_ADV_REPORT); 2286 if (ev2) { 2287 /* Check if BIGInfo report has already been handled */ 2288 sk = iso_get_sock(hdev, &hdev->bdaddr, bdaddr, BT_CONNECTED, 2289 iso_match_sync_handle, ev2); 2290 if (sk) { 2291 sock_put(sk); 2292 sk = NULL; 2293 goto done; 2294 } 2295 2296 /* Try to get PA sync socket, if it exists */ 2297 sk = iso_get_sock(hdev, &hdev->bdaddr, bdaddr, BT_CONNECT2, 2298 iso_match_sync_handle, ev2); 2299 if (!sk) 2300 sk = iso_get_sock(hdev, &hdev->bdaddr, bdaddr, 2301 BT_LISTEN, 2302 iso_match_sync_handle, 2303 ev2); 2304 2305 if (sk) { 2306 int err = 0; 2307 bool big_sync; 2308 struct hci_conn *hcon; 2309 2310 lock_sock(sk); 2311 2312 hcon = iso_pi(sk)->conn->hcon; 2313 iso_pi(sk)->qos.bcast.encryption = ev2->encryption; 2314 2315 if (ev2->num_bis < iso_pi(sk)->bc_num_bis) 2316 iso_pi(sk)->bc_num_bis = ev2->num_bis; 2317 2318 big_sync = !test_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags) && 2319 !test_and_set_bit(BT_SK_BIG_SYNC, &iso_pi(sk)->flags); 2320 2321 if (big_sync) 2322 err = hci_conn_big_create_sync(hdev, hcon, 2323 &iso_pi(sk)->qos, 2324 iso_pi(sk)->sync_handle, 2325 iso_pi(sk)->bc_num_bis, 2326 iso_pi(sk)->bc_bis); 2327 2328 release_sock(sk); 2329 2330 if (big_sync && err) { 2331 bt_dev_err(hdev, "hci_le_big_create_sync: %d", 2332 err); 2333 sock_put(sk); 2334 sk = NULL; 2335 } 2336 } 2337 2338 goto done; 2339 } 2340 2341 ev3 = hci_recv_event_data(hdev, HCI_EV_LE_PER_ADV_REPORT); 2342 if (ev3) { 2343 size_t base_len = 0; 2344 u8 *base; 2345 struct hci_conn *hcon; 2346 2347 sk = iso_get_sock(hdev, &hdev->bdaddr, bdaddr, BT_LISTEN, 2348 iso_match_sync_handle_pa_report, ev3); 2349 if (!sk) 2350 goto done; 2351 2352 hcon = iso_pi(sk)->conn->hcon; 2353 if (!hcon) 2354 goto done; 2355 2356 if (ev3->data_status == LE_PA_DATA_TRUNCATED) { 2357 /* The controller was unable to retrieve PA data. */ 2358 memset(hcon->le_per_adv_data, 0, 2359 HCI_MAX_PER_AD_TOT_LEN); 2360 hcon->le_per_adv_data_len = 0; 2361 hcon->le_per_adv_data_offset = 0; 2362 goto done; 2363 } 2364 2365 if (hcon->le_per_adv_data_offset + ev3->length > 2366 HCI_MAX_PER_AD_TOT_LEN) 2367 goto done; 2368 2369 memcpy(hcon->le_per_adv_data + hcon->le_per_adv_data_offset, 2370 ev3->data, ev3->length); 2371 hcon->le_per_adv_data_offset += ev3->length; 2372 2373 if (ev3->data_status == LE_PA_DATA_COMPLETE) { 2374 /* All PA data has been received. */ 2375 hcon->le_per_adv_data_len = 2376 hcon->le_per_adv_data_offset; 2377 hcon->le_per_adv_data_offset = 0; 2378 2379 /* Extract BASE */ 2380 base = eir_get_service_data(hcon->le_per_adv_data, 2381 hcon->le_per_adv_data_len, 2382 EIR_BAA_SERVICE_UUID, 2383 &base_len); 2384 2385 if (!base || base_len > BASE_MAX_LENGTH) 2386 goto done; 2387 2388 lock_sock(sk); 2389 memcpy(iso_pi(sk)->base, base, base_len); 2390 iso_pi(sk)->base_len = base_len; 2391 release_sock(sk); 2392 } else { 2393 /* This is a PA data fragment. Keep pa_data_len set to 0 2394 * until all data has been reassembled. 2395 */ 2396 hcon->le_per_adv_data_len = 0; 2397 } 2398 } else { 2399 sk = iso_get_sock(hdev, &hdev->bdaddr, BDADDR_ANY, 2400 BT_LISTEN, iso_match_dst, BDADDR_ANY); 2401 } 2402 2403 done: 2404 if (!sk) 2405 return 0; 2406 2407 if (test_bit(BT_SK_DEFER_SETUP, &bt_sk(sk)->flags)) 2408 *flags |= HCI_PROTO_DEFER; 2409 2410 sock_put(sk); 2411 2412 return HCI_LM_ACCEPT; 2413 } 2414 2415 static void iso_connect_cfm(struct hci_conn *hcon, __u8 status) 2416 { 2417 if (hcon->type != CIS_LINK && hcon->type != BIS_LINK && 2418 hcon->type != PA_LINK) { 2419 if (hcon->type != LE_LINK) 2420 return; 2421 2422 /* Check if LE link has failed */ 2423 if (status) { 2424 struct hci_link *link, *t; 2425 2426 list_for_each_entry_safe(link, t, &hcon->link_list, 2427 list) 2428 iso_conn_del(link->conn, bt_to_errno(status)); 2429 2430 return; 2431 } 2432 2433 /* Create CIS if pending */ 2434 hci_le_create_cis_pending(hcon->hdev); 2435 return; 2436 } 2437 2438 BT_DBG("hcon %p bdaddr %pMR status %d", hcon, &hcon->dst, status); 2439 2440 /* Similar to the success case, if HCI_CONN_BIG_SYNC_FAILED or 2441 * HCI_CONN_PA_SYNC_FAILED is set, queue the failed connection 2442 * into the accept queue of the listening socket and wake up 2443 * userspace, to inform the user about the event. 2444 */ 2445 if (!status || test_bit(HCI_CONN_BIG_SYNC_FAILED, &hcon->flags) || 2446 test_bit(HCI_CONN_PA_SYNC_FAILED, &hcon->flags)) { 2447 struct iso_conn *conn; 2448 2449 conn = iso_conn_add(hcon); 2450 if (conn) 2451 iso_conn_ready(conn); 2452 } else { 2453 iso_conn_del(hcon, bt_to_errno(status)); 2454 } 2455 } 2456 2457 static void iso_disconn_cfm(struct hci_conn *hcon, __u8 reason) 2458 { 2459 if (hcon->type != CIS_LINK && hcon->type != BIS_LINK && 2460 hcon->type != PA_LINK) 2461 return; 2462 2463 BT_DBG("hcon %p reason %d", hcon, reason); 2464 2465 iso_conn_del(hcon, bt_to_errno(reason)); 2466 } 2467 2468 int iso_recv(struct hci_dev *hdev, u16 handle, struct sk_buff *skb, u16 flags) 2469 { 2470 struct hci_conn *hcon; 2471 struct iso_conn *conn; 2472 struct skb_shared_hwtstamps *hwts; 2473 __u16 pb, ts, len, sn; 2474 2475 hci_dev_lock(hdev); 2476 2477 hcon = hci_conn_hash_lookup_handle(hdev, handle); 2478 if (!hcon) { 2479 hci_dev_unlock(hdev); 2480 kfree_skb(skb); 2481 return -ENOENT; 2482 } 2483 2484 conn = iso_conn_hold_unless_zero(hcon->iso_data); 2485 hcon = NULL; 2486 2487 hci_dev_unlock(hdev); 2488 2489 if (!conn) { 2490 kfree_skb(skb); 2491 return -EINVAL; 2492 } 2493 2494 pb = hci_iso_flags_pb(flags); 2495 ts = hci_iso_flags_ts(flags); 2496 2497 BT_DBG("conn %p len %d pb 0x%x ts 0x%x", conn, skb->len, pb, ts); 2498 2499 switch (pb) { 2500 case ISO_START: 2501 case ISO_SINGLE: 2502 if (conn->rx_len) { 2503 BT_ERR("Unexpected start frame (len %d)", skb->len); 2504 kfree_skb(conn->rx_skb); 2505 conn->rx_skb = NULL; 2506 conn->rx_len = 0; 2507 } 2508 2509 if (ts) { 2510 struct hci_iso_ts_data_hdr *hdr; 2511 2512 hdr = skb_pull_data(skb, HCI_ISO_TS_DATA_HDR_SIZE); 2513 if (!hdr) { 2514 BT_ERR("Frame is too short (len %d)", skb->len); 2515 goto drop; 2516 } 2517 2518 /* Record the timestamp to skb */ 2519 hwts = skb_hwtstamps(skb); 2520 hwts->hwtstamp = us_to_ktime(le32_to_cpu(hdr->ts)); 2521 2522 sn = __le16_to_cpu(hdr->sn); 2523 len = __le16_to_cpu(hdr->slen); 2524 } else { 2525 struct hci_iso_data_hdr *hdr; 2526 2527 hdr = skb_pull_data(skb, HCI_ISO_DATA_HDR_SIZE); 2528 if (!hdr) { 2529 BT_ERR("Frame is too short (len %d)", skb->len); 2530 goto drop; 2531 } 2532 2533 sn = __le16_to_cpu(hdr->sn); 2534 len = __le16_to_cpu(hdr->slen); 2535 } 2536 2537 flags = hci_iso_data_flags(len); 2538 len = hci_iso_data_len(len); 2539 2540 BT_DBG("Start: total len %d, frag len %d flags 0x%4.4x sn %d", 2541 len, skb->len, flags, sn); 2542 2543 if (len == skb->len) { 2544 /* Complete frame received */ 2545 hci_skb_pkt_status(skb) = flags & 0x03; 2546 hci_skb_pkt_seqnum(skb) = sn; 2547 iso_recv_frame(conn, skb); 2548 goto done; 2549 } 2550 2551 if (pb == ISO_SINGLE) { 2552 BT_ERR("Frame malformed (len %d, expected len %d)", 2553 skb->len, len); 2554 goto drop; 2555 } 2556 2557 if (skb->len > len) { 2558 BT_ERR("Frame is too long (len %d, expected len %d)", 2559 skb->len, len); 2560 goto drop; 2561 } 2562 2563 /* Allocate skb for the complete frame (with header) */ 2564 conn->rx_skb = bt_skb_alloc(len, GFP_KERNEL); 2565 if (!conn->rx_skb) 2566 goto drop; 2567 2568 hci_skb_pkt_status(conn->rx_skb) = flags & 0x03; 2569 hci_skb_pkt_seqnum(conn->rx_skb) = sn; 2570 skb_copy_from_linear_data(skb, skb_put(conn->rx_skb, skb->len), 2571 skb->len); 2572 conn->rx_len = len - skb->len; 2573 2574 /* Copy hw timestamp from skb to rx_skb if present */ 2575 if (ts) { 2576 hwts = skb_hwtstamps(conn->rx_skb); 2577 hwts->hwtstamp = skb_hwtstamps(skb)->hwtstamp; 2578 } 2579 2580 break; 2581 2582 case ISO_CONT: 2583 BT_DBG("Cont: frag len %d (expecting %d)", skb->len, 2584 conn->rx_len); 2585 2586 if (!conn->rx_len) { 2587 BT_ERR("Unexpected continuation frame (len %d)", 2588 skb->len); 2589 goto drop; 2590 } 2591 2592 if (skb->len > conn->rx_len) { 2593 BT_ERR("Fragment is too long (len %d, expected %d)", 2594 skb->len, conn->rx_len); 2595 kfree_skb(conn->rx_skb); 2596 conn->rx_skb = NULL; 2597 conn->rx_len = 0; 2598 goto drop; 2599 } 2600 2601 skb_copy_from_linear_data(skb, skb_put(conn->rx_skb, skb->len), 2602 skb->len); 2603 conn->rx_len -= skb->len; 2604 break; 2605 2606 case ISO_END: 2607 if (!conn->rx_len) { 2608 BT_ERR("Unexpected end frame (len %d)", skb->len); 2609 goto drop; 2610 } 2611 2612 skb_copy_from_linear_data(skb, skb_put(conn->rx_skb, skb->len), 2613 skb->len); 2614 conn->rx_len -= skb->len; 2615 2616 if (!conn->rx_len) { 2617 struct sk_buff *rx_skb = conn->rx_skb; 2618 2619 /* Complete frame received. iso_recv_frame 2620 * takes ownership of the skb so set the global 2621 * rx_skb pointer to NULL first. 2622 */ 2623 conn->rx_skb = NULL; 2624 iso_recv_frame(conn, rx_skb); 2625 } 2626 break; 2627 } 2628 2629 drop: 2630 kfree_skb(skb); 2631 done: 2632 iso_conn_put(conn); 2633 return 0; 2634 } 2635 2636 static struct hci_cb iso_cb = { 2637 .name = "ISO", 2638 .connect_cfm = iso_connect_cfm, 2639 .disconn_cfm = iso_disconn_cfm, 2640 }; 2641 2642 static int iso_debugfs_show(struct seq_file *f, void *p) 2643 { 2644 struct sock *sk; 2645 2646 read_lock(&iso_sk_list.lock); 2647 2648 sk_for_each(sk, &iso_sk_list.head) { 2649 seq_printf(f, "%pMR %pMR %d\n", &iso_pi(sk)->src, 2650 &iso_pi(sk)->dst, sk->sk_state); 2651 } 2652 2653 read_unlock(&iso_sk_list.lock); 2654 2655 return 0; 2656 } 2657 2658 DEFINE_SHOW_ATTRIBUTE(iso_debugfs); 2659 2660 static struct dentry *iso_debugfs; 2661 2662 static const struct proto_ops iso_sock_ops = { 2663 .family = PF_BLUETOOTH, 2664 .owner = THIS_MODULE, 2665 .release = iso_sock_release, 2666 .bind = iso_sock_bind, 2667 .connect = iso_sock_connect, 2668 .listen = iso_sock_listen, 2669 .accept = iso_sock_accept, 2670 .getname = iso_sock_getname, 2671 .sendmsg = iso_sock_sendmsg, 2672 .recvmsg = iso_sock_recvmsg, 2673 .poll = bt_sock_poll, 2674 .ioctl = bt_sock_ioctl, 2675 .mmap = sock_no_mmap, 2676 .socketpair = sock_no_socketpair, 2677 .shutdown = iso_sock_shutdown, 2678 .setsockopt = iso_sock_setsockopt, 2679 .getsockopt = iso_sock_getsockopt 2680 }; 2681 2682 static const struct net_proto_family iso_sock_family_ops = { 2683 .family = PF_BLUETOOTH, 2684 .owner = THIS_MODULE, 2685 .create = iso_sock_create, 2686 }; 2687 2688 static bool inited; 2689 2690 bool iso_inited(void) 2691 { 2692 return inited; 2693 } 2694 2695 int iso_init(void) 2696 { 2697 int err; 2698 2699 BUILD_BUG_ON(sizeof(struct sockaddr_iso) > sizeof(struct sockaddr)); 2700 2701 if (inited) 2702 return -EALREADY; 2703 2704 err = proto_register(&iso_proto, 0); 2705 if (err < 0) 2706 return err; 2707 2708 err = bt_sock_register(BTPROTO_ISO, &iso_sock_family_ops); 2709 if (err < 0) { 2710 BT_ERR("ISO socket registration failed"); 2711 goto error; 2712 } 2713 2714 err = bt_procfs_init(&init_net, "iso", &iso_sk_list, NULL); 2715 if (err < 0) { 2716 BT_ERR("Failed to create ISO proc file"); 2717 bt_sock_unregister(BTPROTO_ISO); 2718 goto error; 2719 } 2720 2721 BT_INFO("ISO socket layer initialized"); 2722 2723 hci_register_cb(&iso_cb); 2724 2725 if (!IS_ERR_OR_NULL(bt_debugfs)) 2726 iso_debugfs = debugfs_create_file("iso", 0444, bt_debugfs, 2727 NULL, &iso_debugfs_fops); 2728 2729 inited = true; 2730 2731 return 0; 2732 2733 error: 2734 proto_unregister(&iso_proto); 2735 return err; 2736 } 2737 2738 int iso_exit(void) 2739 { 2740 if (!inited) 2741 return -EALREADY; 2742 2743 bt_procfs_cleanup(&init_net, "iso"); 2744 2745 debugfs_remove(iso_debugfs); 2746 iso_debugfs = NULL; 2747 2748 hci_unregister_cb(&iso_cb); 2749 2750 bt_sock_unregister(BTPROTO_ISO); 2751 2752 proto_unregister(&iso_proto); 2753 2754 inited = false; 2755 2756 return 0; 2757 } 2758