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