2 BlueZ - Bluetooth protocol stack for Linux
3 Copyright (C) 2000-2001 Qualcomm Incorporated
4 Copyright (C) 2009-2010 Gustavo F. Padovan <gustavo@padovan.org>
5 Copyright (C) 2010 Google Inc.
6 Copyright (C) 2011 ProFUSION Embedded Systems
7 Copyright (c) 2012 Code Aurora Forum. All rights reserved.
9 Written 2000,2001 by Maxim Krasnyansky <maxk@qualcomm.com>
11 This program is free software; you can redistribute it and/or modify
12 it under the terms of the GNU General Public License version 2 as
13 published by the Free Software Foundation;
15 THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
16 OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
17 FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT OF THIRD PARTY RIGHTS.
18 IN NO EVENT SHALL THE COPYRIGHT HOLDER(S) AND AUTHOR(S) BE LIABLE FOR ANY
19 CLAIM, OR ANY SPECIAL INDIRECT OR CONSEQUENTIAL DAMAGES, OR ANY DAMAGES
20 WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
21 ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
22 OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
24 ALL LIABILITY, INCLUDING LIABILITY FOR INFRINGEMENT OF ANY PATENTS,
25 COPYRIGHTS, TRADEMARKS OR OTHER RIGHTS, RELATING TO USE OF THIS
26 SOFTWARE IS DISCLAIMED.
29 /* Bluetooth L2CAP core. */
31 #include <linux/module.h>
33 #include <linux/debugfs.h>
34 #include <linux/crc16.h>
35 #include <linux/filter.h>
37 #include <net/bluetooth/bluetooth.h>
38 #include <net/bluetooth/hci_core.h>
39 #include <net/bluetooth/l2cap.h>
45 #define LE_FLOWCTL_MAX_CREDITS 65535
48 bool enable_ecred = IS_ENABLED(CONFIG_BT_LE_L2CAP_ECRED);
50 static u32 l2cap_feat_mask = L2CAP_FEAT_FIXED_CHAN | L2CAP_FEAT_UCD;
52 static LIST_HEAD(chan_list);
53 static DEFINE_RWLOCK(chan_list_lock);
55 static struct sk_buff *l2cap_build_cmd(struct l2cap_conn *conn,
56 u8 code, u8 ident, u16 dlen, void *data);
57 static void l2cap_send_cmd(struct l2cap_conn *conn, u8 ident, u8 code, u16 len,
59 static int l2cap_build_conf_req(struct l2cap_chan *chan, void *data, size_t data_size);
60 static void l2cap_send_disconn_req(struct l2cap_chan *chan, int err);
62 static void l2cap_tx(struct l2cap_chan *chan, struct l2cap_ctrl *control,
63 struct sk_buff_head *skbs, u8 event);
64 static void l2cap_retrans_timeout(struct work_struct *work);
65 static void l2cap_monitor_timeout(struct work_struct *work);
66 static void l2cap_ack_timeout(struct work_struct *work);
68 static inline u8 bdaddr_type(u8 link_type, u8 bdaddr_type)
70 if (link_type == LE_LINK) {
71 if (bdaddr_type == ADDR_LE_DEV_PUBLIC)
72 return BDADDR_LE_PUBLIC;
74 return BDADDR_LE_RANDOM;
80 static inline u8 bdaddr_src_type(struct hci_conn *hcon)
82 return bdaddr_type(hcon->type, hcon->src_type);
85 static inline u8 bdaddr_dst_type(struct hci_conn *hcon)
87 return bdaddr_type(hcon->type, hcon->dst_type);
90 /* ---- L2CAP channels ---- */
92 static struct l2cap_chan *__l2cap_get_chan_by_dcid(struct l2cap_conn *conn,
97 list_for_each_entry(c, &conn->chan_l, list) {
104 static struct l2cap_chan *__l2cap_get_chan_by_scid(struct l2cap_conn *conn,
107 struct l2cap_chan *c;
109 list_for_each_entry(c, &conn->chan_l, list) {
116 /* Find channel with given SCID.
117 * Returns a reference locked channel.
119 static struct l2cap_chan *l2cap_get_chan_by_scid(struct l2cap_conn *conn,
122 struct l2cap_chan *c;
124 mutex_lock(&conn->chan_lock);
125 c = __l2cap_get_chan_by_scid(conn, cid);
127 /* Only lock if chan reference is not 0 */
128 c = l2cap_chan_hold_unless_zero(c);
132 mutex_unlock(&conn->chan_lock);
137 /* Find channel with given DCID.
138 * Returns a reference locked channel.
140 static struct l2cap_chan *l2cap_get_chan_by_dcid(struct l2cap_conn *conn,
143 struct l2cap_chan *c;
145 mutex_lock(&conn->chan_lock);
146 c = __l2cap_get_chan_by_dcid(conn, cid);
148 /* Only lock if chan reference is not 0 */
149 c = l2cap_chan_hold_unless_zero(c);
153 mutex_unlock(&conn->chan_lock);
158 static struct l2cap_chan *__l2cap_get_chan_by_ident(struct l2cap_conn *conn,
161 struct l2cap_chan *c;
163 list_for_each_entry(c, &conn->chan_l, list) {
164 if (c->ident == ident)
170 static struct l2cap_chan *l2cap_get_chan_by_ident(struct l2cap_conn *conn,
173 struct l2cap_chan *c;
175 mutex_lock(&conn->chan_lock);
176 c = __l2cap_get_chan_by_ident(conn, ident);
178 /* Only lock if chan reference is not 0 */
179 c = l2cap_chan_hold_unless_zero(c);
183 mutex_unlock(&conn->chan_lock);
188 static struct l2cap_chan *__l2cap_global_chan_by_addr(__le16 psm, bdaddr_t *src,
191 struct l2cap_chan *c;
193 list_for_each_entry(c, &chan_list, global_l) {
194 if (src_type == BDADDR_BREDR && c->src_type != BDADDR_BREDR)
197 if (src_type != BDADDR_BREDR && c->src_type == BDADDR_BREDR)
200 if (c->sport == psm && !bacmp(&c->src, src))
206 int l2cap_add_psm(struct l2cap_chan *chan, bdaddr_t *src, __le16 psm)
210 write_lock(&chan_list_lock);
212 if (psm && __l2cap_global_chan_by_addr(psm, src, chan->src_type)) {
222 u16 p, start, end, incr;
224 if (chan->src_type == BDADDR_BREDR) {
225 start = L2CAP_PSM_DYN_START;
226 end = L2CAP_PSM_AUTO_END;
229 start = L2CAP_PSM_LE_DYN_START;
230 end = L2CAP_PSM_LE_DYN_END;
235 for (p = start; p <= end; p += incr)
236 if (!__l2cap_global_chan_by_addr(cpu_to_le16(p), src,
238 chan->psm = cpu_to_le16(p);
239 chan->sport = cpu_to_le16(p);
246 write_unlock(&chan_list_lock);
249 EXPORT_SYMBOL_GPL(l2cap_add_psm);
251 int l2cap_add_scid(struct l2cap_chan *chan, __u16 scid)
253 write_lock(&chan_list_lock);
255 /* Override the defaults (which are for conn-oriented) */
256 chan->omtu = L2CAP_DEFAULT_MTU;
257 chan->chan_type = L2CAP_CHAN_FIXED;
261 write_unlock(&chan_list_lock);
266 static u16 l2cap_alloc_cid(struct l2cap_conn *conn)
270 if (conn->hcon->type == LE_LINK)
271 dyn_end = L2CAP_CID_LE_DYN_END;
273 dyn_end = L2CAP_CID_DYN_END;
275 for (cid = L2CAP_CID_DYN_START; cid <= dyn_end; cid++) {
276 if (!__l2cap_get_chan_by_scid(conn, cid))
283 static void l2cap_state_change(struct l2cap_chan *chan, int state)
285 BT_DBG("chan %p %s -> %s", chan, state_to_string(chan->state),
286 state_to_string(state));
289 chan->ops->state_change(chan, state, 0);
292 static inline void l2cap_state_change_and_error(struct l2cap_chan *chan,
296 chan->ops->state_change(chan, chan->state, err);
299 static inline void l2cap_chan_set_err(struct l2cap_chan *chan, int err)
301 chan->ops->state_change(chan, chan->state, err);
304 static void __set_retrans_timer(struct l2cap_chan *chan)
306 if (!delayed_work_pending(&chan->monitor_timer) &&
307 chan->retrans_timeout) {
308 l2cap_set_timer(chan, &chan->retrans_timer,
309 msecs_to_jiffies(chan->retrans_timeout));
313 static void __set_monitor_timer(struct l2cap_chan *chan)
315 __clear_retrans_timer(chan);
316 if (chan->monitor_timeout) {
317 l2cap_set_timer(chan, &chan->monitor_timer,
318 msecs_to_jiffies(chan->monitor_timeout));
322 static struct sk_buff *l2cap_ertm_seq_in_queue(struct sk_buff_head *head,
327 skb_queue_walk(head, skb) {
328 if (bt_cb(skb)->l2cap.txseq == seq)
335 /* ---- L2CAP sequence number lists ---- */
337 /* For ERTM, ordered lists of sequence numbers must be tracked for
338 * SREJ requests that are received and for frames that are to be
339 * retransmitted. These seq_list functions implement a singly-linked
340 * list in an array, where membership in the list can also be checked
341 * in constant time. Items can also be added to the tail of the list
342 * and removed from the head in constant time, without further memory
346 static int l2cap_seq_list_init(struct l2cap_seq_list *seq_list, u16 size)
348 size_t alloc_size, i;
350 /* Allocated size is a power of 2 to map sequence numbers
351 * (which may be up to 14 bits) in to a smaller array that is
352 * sized for the negotiated ERTM transmit windows.
354 alloc_size = roundup_pow_of_two(size);
356 seq_list->list = kmalloc_array(alloc_size, sizeof(u16), GFP_KERNEL);
360 seq_list->mask = alloc_size - 1;
361 seq_list->head = L2CAP_SEQ_LIST_CLEAR;
362 seq_list->tail = L2CAP_SEQ_LIST_CLEAR;
363 for (i = 0; i < alloc_size; i++)
364 seq_list->list[i] = L2CAP_SEQ_LIST_CLEAR;
369 static inline void l2cap_seq_list_free(struct l2cap_seq_list *seq_list)
371 kfree(seq_list->list);
374 static inline bool l2cap_seq_list_contains(struct l2cap_seq_list *seq_list,
377 /* Constant-time check for list membership */
378 return seq_list->list[seq & seq_list->mask] != L2CAP_SEQ_LIST_CLEAR;
381 static inline u16 l2cap_seq_list_pop(struct l2cap_seq_list *seq_list)
383 u16 seq = seq_list->head;
384 u16 mask = seq_list->mask;
386 seq_list->head = seq_list->list[seq & mask];
387 seq_list->list[seq & mask] = L2CAP_SEQ_LIST_CLEAR;
389 if (seq_list->head == L2CAP_SEQ_LIST_TAIL) {
390 seq_list->head = L2CAP_SEQ_LIST_CLEAR;
391 seq_list->tail = L2CAP_SEQ_LIST_CLEAR;
397 static void l2cap_seq_list_clear(struct l2cap_seq_list *seq_list)
401 if (seq_list->head == L2CAP_SEQ_LIST_CLEAR)
404 for (i = 0; i <= seq_list->mask; i++)
405 seq_list->list[i] = L2CAP_SEQ_LIST_CLEAR;
407 seq_list->head = L2CAP_SEQ_LIST_CLEAR;
408 seq_list->tail = L2CAP_SEQ_LIST_CLEAR;
411 static void l2cap_seq_list_append(struct l2cap_seq_list *seq_list, u16 seq)
413 u16 mask = seq_list->mask;
415 /* All appends happen in constant time */
417 if (seq_list->list[seq & mask] != L2CAP_SEQ_LIST_CLEAR)
420 if (seq_list->tail == L2CAP_SEQ_LIST_CLEAR)
421 seq_list->head = seq;
423 seq_list->list[seq_list->tail & mask] = seq;
425 seq_list->tail = seq;
426 seq_list->list[seq & mask] = L2CAP_SEQ_LIST_TAIL;
429 static void l2cap_chan_timeout(struct work_struct *work)
431 struct l2cap_chan *chan = container_of(work, struct l2cap_chan,
433 struct l2cap_conn *conn = chan->conn;
436 BT_DBG("chan %p state %s", chan, state_to_string(chan->state));
438 mutex_lock(&conn->chan_lock);
439 /* __set_chan_timer() calls l2cap_chan_hold(chan) while scheduling
440 * this work. No need to call l2cap_chan_hold(chan) here again.
442 l2cap_chan_lock(chan);
444 if (chan->state == BT_CONNECTED || chan->state == BT_CONFIG)
445 reason = ECONNREFUSED;
446 else if (chan->state == BT_CONNECT &&
447 chan->sec_level != BT_SECURITY_SDP)
448 reason = ECONNREFUSED;
452 l2cap_chan_close(chan, reason);
454 chan->ops->close(chan);
456 l2cap_chan_unlock(chan);
457 l2cap_chan_put(chan);
459 mutex_unlock(&conn->chan_lock);
462 struct l2cap_chan *l2cap_chan_create(void)
464 struct l2cap_chan *chan;
466 chan = kzalloc(sizeof(*chan), GFP_ATOMIC);
470 skb_queue_head_init(&chan->tx_q);
471 skb_queue_head_init(&chan->srej_q);
472 mutex_init(&chan->lock);
474 /* Set default lock nesting level */
475 atomic_set(&chan->nesting, L2CAP_NESTING_NORMAL);
477 write_lock(&chan_list_lock);
478 list_add(&chan->global_l, &chan_list);
479 write_unlock(&chan_list_lock);
481 INIT_DELAYED_WORK(&chan->chan_timer, l2cap_chan_timeout);
482 INIT_DELAYED_WORK(&chan->retrans_timer, l2cap_retrans_timeout);
483 INIT_DELAYED_WORK(&chan->monitor_timer, l2cap_monitor_timeout);
484 INIT_DELAYED_WORK(&chan->ack_timer, l2cap_ack_timeout);
486 chan->state = BT_OPEN;
488 kref_init(&chan->kref);
490 /* This flag is cleared in l2cap_chan_ready() */
491 set_bit(CONF_NOT_COMPLETE, &chan->conf_state);
493 BT_DBG("chan %p", chan);
497 EXPORT_SYMBOL_GPL(l2cap_chan_create);
499 static void l2cap_chan_destroy(struct kref *kref)
501 struct l2cap_chan *chan = container_of(kref, struct l2cap_chan, kref);
503 BT_DBG("chan %p", chan);
505 write_lock(&chan_list_lock);
506 list_del(&chan->global_l);
507 write_unlock(&chan_list_lock);
512 void l2cap_chan_hold(struct l2cap_chan *c)
514 BT_DBG("chan %p orig refcnt %u", c, kref_read(&c->kref));
519 struct l2cap_chan *l2cap_chan_hold_unless_zero(struct l2cap_chan *c)
521 BT_DBG("chan %p orig refcnt %u", c, kref_read(&c->kref));
523 if (!kref_get_unless_zero(&c->kref))
529 void l2cap_chan_put(struct l2cap_chan *c)
531 BT_DBG("chan %p orig refcnt %u", c, kref_read(&c->kref));
533 kref_put(&c->kref, l2cap_chan_destroy);
535 EXPORT_SYMBOL_GPL(l2cap_chan_put);
537 void l2cap_chan_set_defaults(struct l2cap_chan *chan)
539 chan->fcs = L2CAP_FCS_CRC16;
540 chan->max_tx = L2CAP_DEFAULT_MAX_TX;
541 chan->tx_win = L2CAP_DEFAULT_TX_WINDOW;
542 chan->tx_win_max = L2CAP_DEFAULT_TX_WINDOW;
543 chan->remote_max_tx = chan->max_tx;
544 chan->remote_tx_win = chan->tx_win;
545 chan->ack_win = L2CAP_DEFAULT_TX_WINDOW;
546 chan->sec_level = BT_SECURITY_LOW;
547 chan->flush_to = L2CAP_DEFAULT_FLUSH_TO;
548 chan->retrans_timeout = L2CAP_DEFAULT_RETRANS_TO;
549 chan->monitor_timeout = L2CAP_DEFAULT_MONITOR_TO;
551 chan->conf_state = 0;
552 set_bit(CONF_NOT_COMPLETE, &chan->conf_state);
554 set_bit(FLAG_FORCE_ACTIVE, &chan->flags);
556 EXPORT_SYMBOL_GPL(l2cap_chan_set_defaults);
558 static void l2cap_le_flowctl_init(struct l2cap_chan *chan, u16 tx_credits)
561 chan->sdu_last_frag = NULL;
563 chan->tx_credits = tx_credits;
564 /* Derive MPS from connection MTU to stop HCI fragmentation */
565 chan->mps = min_t(u16, chan->imtu, chan->conn->mtu - L2CAP_HDR_SIZE);
566 /* Give enough credits for a full packet */
567 chan->rx_credits = (chan->imtu / chan->mps) + 1;
569 skb_queue_head_init(&chan->tx_q);
572 static void l2cap_ecred_init(struct l2cap_chan *chan, u16 tx_credits)
574 l2cap_le_flowctl_init(chan, tx_credits);
576 /* L2CAP implementations shall support a minimum MPS of 64 octets */
577 if (chan->mps < L2CAP_ECRED_MIN_MPS) {
578 chan->mps = L2CAP_ECRED_MIN_MPS;
579 chan->rx_credits = (chan->imtu / chan->mps) + 1;
583 void __l2cap_chan_add(struct l2cap_conn *conn, struct l2cap_chan *chan)
585 BT_DBG("conn %p, psm 0x%2.2x, dcid 0x%4.4x", conn,
586 __le16_to_cpu(chan->psm), chan->dcid);
588 conn->disc_reason = HCI_ERROR_REMOTE_USER_TERM;
592 switch (chan->chan_type) {
593 case L2CAP_CHAN_CONN_ORIENTED:
594 /* Alloc CID for connection-oriented socket */
595 chan->scid = l2cap_alloc_cid(conn);
596 if (conn->hcon->type == ACL_LINK)
597 chan->omtu = L2CAP_DEFAULT_MTU;
600 case L2CAP_CHAN_CONN_LESS:
601 /* Connectionless socket */
602 chan->scid = L2CAP_CID_CONN_LESS;
603 chan->dcid = L2CAP_CID_CONN_LESS;
604 chan->omtu = L2CAP_DEFAULT_MTU;
607 case L2CAP_CHAN_FIXED:
608 /* Caller will set CID and CID specific MTU values */
612 /* Raw socket can send/recv signalling messages only */
613 chan->scid = L2CAP_CID_SIGNALING;
614 chan->dcid = L2CAP_CID_SIGNALING;
615 chan->omtu = L2CAP_DEFAULT_MTU;
618 chan->local_id = L2CAP_BESTEFFORT_ID;
619 chan->local_stype = L2CAP_SERV_BESTEFFORT;
620 chan->local_msdu = L2CAP_DEFAULT_MAX_SDU_SIZE;
621 chan->local_sdu_itime = L2CAP_DEFAULT_SDU_ITIME;
622 chan->local_acc_lat = L2CAP_DEFAULT_ACC_LAT;
623 chan->local_flush_to = L2CAP_EFS_DEFAULT_FLUSH_TO;
625 l2cap_chan_hold(chan);
627 /* Only keep a reference for fixed channels if they requested it */
628 if (chan->chan_type != L2CAP_CHAN_FIXED ||
629 test_bit(FLAG_HOLD_HCI_CONN, &chan->flags))
630 hci_conn_hold(conn->hcon);
632 list_add(&chan->list, &conn->chan_l);
635 void l2cap_chan_add(struct l2cap_conn *conn, struct l2cap_chan *chan)
637 mutex_lock(&conn->chan_lock);
638 __l2cap_chan_add(conn, chan);
639 mutex_unlock(&conn->chan_lock);
642 void l2cap_chan_del(struct l2cap_chan *chan, int err)
644 struct l2cap_conn *conn = chan->conn;
646 __clear_chan_timer(chan);
648 BT_DBG("chan %p, conn %p, err %d, state %s", chan, conn, err,
649 state_to_string(chan->state));
651 chan->ops->teardown(chan, err);
654 struct amp_mgr *mgr = conn->hcon->amp_mgr;
655 /* Delete from channel list */
656 list_del(&chan->list);
658 l2cap_chan_put(chan);
662 /* Reference was only held for non-fixed channels or
663 * fixed channels that explicitly requested it using the
664 * FLAG_HOLD_HCI_CONN flag.
666 if (chan->chan_type != L2CAP_CHAN_FIXED ||
667 test_bit(FLAG_HOLD_HCI_CONN, &chan->flags))
668 hci_conn_drop(conn->hcon);
670 if (mgr && mgr->bredr_chan == chan)
671 mgr->bredr_chan = NULL;
674 if (chan->hs_hchan) {
675 struct hci_chan *hs_hchan = chan->hs_hchan;
677 BT_DBG("chan %p disconnect hs_hchan %p", chan, hs_hchan);
678 amp_disconnect_logical_link(hs_hchan);
681 if (test_bit(CONF_NOT_COMPLETE, &chan->conf_state))
684 switch (chan->mode) {
685 case L2CAP_MODE_BASIC:
688 case L2CAP_MODE_LE_FLOWCTL:
689 case L2CAP_MODE_EXT_FLOWCTL:
690 skb_queue_purge(&chan->tx_q);
693 case L2CAP_MODE_ERTM:
694 __clear_retrans_timer(chan);
695 __clear_monitor_timer(chan);
696 __clear_ack_timer(chan);
698 skb_queue_purge(&chan->srej_q);
700 l2cap_seq_list_free(&chan->srej_list);
701 l2cap_seq_list_free(&chan->retrans_list);
704 case L2CAP_MODE_STREAMING:
705 skb_queue_purge(&chan->tx_q);
709 EXPORT_SYMBOL_GPL(l2cap_chan_del);
711 static void __l2cap_chan_list_id(struct l2cap_conn *conn, u16 id,
712 l2cap_chan_func_t func, void *data)
714 struct l2cap_chan *chan, *l;
716 list_for_each_entry_safe(chan, l, &conn->chan_l, list) {
717 if (chan->ident == id)
722 static void __l2cap_chan_list(struct l2cap_conn *conn, l2cap_chan_func_t func,
725 struct l2cap_chan *chan;
727 list_for_each_entry(chan, &conn->chan_l, list) {
732 void l2cap_chan_list(struct l2cap_conn *conn, l2cap_chan_func_t func,
738 mutex_lock(&conn->chan_lock);
739 __l2cap_chan_list(conn, func, data);
740 mutex_unlock(&conn->chan_lock);
743 EXPORT_SYMBOL_GPL(l2cap_chan_list);
745 static void l2cap_conn_update_id_addr(struct work_struct *work)
747 struct l2cap_conn *conn = container_of(work, struct l2cap_conn,
749 struct hci_conn *hcon = conn->hcon;
750 struct l2cap_chan *chan;
752 mutex_lock(&conn->chan_lock);
754 list_for_each_entry(chan, &conn->chan_l, list) {
755 l2cap_chan_lock(chan);
756 bacpy(&chan->dst, &hcon->dst);
757 chan->dst_type = bdaddr_dst_type(hcon);
758 l2cap_chan_unlock(chan);
761 mutex_unlock(&conn->chan_lock);
764 static void l2cap_chan_le_connect_reject(struct l2cap_chan *chan)
766 struct l2cap_conn *conn = chan->conn;
767 struct l2cap_le_conn_rsp rsp;
770 if (test_bit(FLAG_DEFER_SETUP, &chan->flags))
771 result = L2CAP_CR_LE_AUTHORIZATION;
773 result = L2CAP_CR_LE_BAD_PSM;
775 l2cap_state_change(chan, BT_DISCONN);
777 rsp.dcid = cpu_to_le16(chan->scid);
778 rsp.mtu = cpu_to_le16(chan->imtu);
779 rsp.mps = cpu_to_le16(chan->mps);
780 rsp.credits = cpu_to_le16(chan->rx_credits);
781 rsp.result = cpu_to_le16(result);
783 l2cap_send_cmd(conn, chan->ident, L2CAP_LE_CONN_RSP, sizeof(rsp),
787 static void l2cap_chan_ecred_connect_reject(struct l2cap_chan *chan)
789 l2cap_state_change(chan, BT_DISCONN);
791 __l2cap_ecred_conn_rsp_defer(chan);
794 static void l2cap_chan_connect_reject(struct l2cap_chan *chan)
796 struct l2cap_conn *conn = chan->conn;
797 struct l2cap_conn_rsp rsp;
800 if (test_bit(FLAG_DEFER_SETUP, &chan->flags))
801 result = L2CAP_CR_SEC_BLOCK;
803 result = L2CAP_CR_BAD_PSM;
805 l2cap_state_change(chan, BT_DISCONN);
807 rsp.scid = cpu_to_le16(chan->dcid);
808 rsp.dcid = cpu_to_le16(chan->scid);
809 rsp.result = cpu_to_le16(result);
810 rsp.status = cpu_to_le16(L2CAP_CS_NO_INFO);
812 l2cap_send_cmd(conn, chan->ident, L2CAP_CONN_RSP, sizeof(rsp), &rsp);
815 void l2cap_chan_close(struct l2cap_chan *chan, int reason)
817 struct l2cap_conn *conn = chan->conn;
819 BT_DBG("chan %p state %s", chan, state_to_string(chan->state));
821 switch (chan->state) {
823 chan->ops->teardown(chan, 0);
828 if (chan->chan_type == L2CAP_CHAN_CONN_ORIENTED) {
829 __set_chan_timer(chan, chan->ops->get_sndtimeo(chan));
830 l2cap_send_disconn_req(chan, reason);
832 l2cap_chan_del(chan, reason);
836 if (chan->chan_type == L2CAP_CHAN_CONN_ORIENTED) {
837 if (conn->hcon->type == ACL_LINK)
838 l2cap_chan_connect_reject(chan);
839 else if (conn->hcon->type == LE_LINK) {
840 switch (chan->mode) {
841 case L2CAP_MODE_LE_FLOWCTL:
842 l2cap_chan_le_connect_reject(chan);
844 case L2CAP_MODE_EXT_FLOWCTL:
845 l2cap_chan_ecred_connect_reject(chan);
851 l2cap_chan_del(chan, reason);
856 l2cap_chan_del(chan, reason);
860 chan->ops->teardown(chan, 0);
864 EXPORT_SYMBOL(l2cap_chan_close);
866 static inline u8 l2cap_get_auth_type(struct l2cap_chan *chan)
868 switch (chan->chan_type) {
870 switch (chan->sec_level) {
871 case BT_SECURITY_HIGH:
872 case BT_SECURITY_FIPS:
873 return HCI_AT_DEDICATED_BONDING_MITM;
874 case BT_SECURITY_MEDIUM:
875 return HCI_AT_DEDICATED_BONDING;
877 return HCI_AT_NO_BONDING;
880 case L2CAP_CHAN_CONN_LESS:
881 if (chan->psm == cpu_to_le16(L2CAP_PSM_3DSP)) {
882 if (chan->sec_level == BT_SECURITY_LOW)
883 chan->sec_level = BT_SECURITY_SDP;
885 if (chan->sec_level == BT_SECURITY_HIGH ||
886 chan->sec_level == BT_SECURITY_FIPS)
887 return HCI_AT_NO_BONDING_MITM;
889 return HCI_AT_NO_BONDING;
891 case L2CAP_CHAN_CONN_ORIENTED:
892 if (chan->psm == cpu_to_le16(L2CAP_PSM_SDP)) {
893 if (chan->sec_level == BT_SECURITY_LOW)
894 chan->sec_level = BT_SECURITY_SDP;
896 if (chan->sec_level == BT_SECURITY_HIGH ||
897 chan->sec_level == BT_SECURITY_FIPS)
898 return HCI_AT_NO_BONDING_MITM;
900 return HCI_AT_NO_BONDING;
905 switch (chan->sec_level) {
906 case BT_SECURITY_HIGH:
907 case BT_SECURITY_FIPS:
908 return HCI_AT_GENERAL_BONDING_MITM;
909 case BT_SECURITY_MEDIUM:
910 return HCI_AT_GENERAL_BONDING;
912 return HCI_AT_NO_BONDING;
918 /* Service level security */
919 int l2cap_chan_check_security(struct l2cap_chan *chan, bool initiator)
921 struct l2cap_conn *conn = chan->conn;
924 if (conn->hcon->type == LE_LINK)
925 return smp_conn_security(conn->hcon, chan->sec_level);
927 auth_type = l2cap_get_auth_type(chan);
929 return hci_conn_security(conn->hcon, chan->sec_level, auth_type,
933 static u8 l2cap_get_ident(struct l2cap_conn *conn)
937 /* Get next available identificator.
938 * 1 - 128 are used by kernel.
939 * 129 - 199 are reserved.
940 * 200 - 254 are used by utilities like l2ping, etc.
943 mutex_lock(&conn->ident_lock);
945 if (++conn->tx_ident > 128)
950 mutex_unlock(&conn->ident_lock);
955 static void l2cap_send_cmd(struct l2cap_conn *conn, u8 ident, u8 code, u16 len,
958 struct sk_buff *skb = l2cap_build_cmd(conn, code, ident, len, data);
961 BT_DBG("code 0x%2.2x", code);
966 /* Use NO_FLUSH if supported or we have an LE link (which does
967 * not support auto-flushing packets) */
968 if (lmp_no_flush_capable(conn->hcon->hdev) ||
969 conn->hcon->type == LE_LINK)
970 flags = ACL_START_NO_FLUSH;
974 bt_cb(skb)->force_active = BT_POWER_FORCE_ACTIVE_ON;
975 skb->priority = HCI_PRIO_MAX;
977 hci_send_acl(conn->hchan, skb, flags);
980 static bool __chan_is_moving(struct l2cap_chan *chan)
982 return chan->move_state != L2CAP_MOVE_STABLE &&
983 chan->move_state != L2CAP_MOVE_WAIT_PREPARE;
986 static void l2cap_do_send(struct l2cap_chan *chan, struct sk_buff *skb)
988 struct hci_conn *hcon = chan->conn->hcon;
991 BT_DBG("chan %p, skb %p len %d priority %u", chan, skb, skb->len,
994 if (chan->hs_hcon && !__chan_is_moving(chan)) {
996 hci_send_acl(chan->hs_hchan, skb, ACL_COMPLETE);
1003 /* Use NO_FLUSH for LE links (where this is the only option) or
1004 * if the BR/EDR link supports it and flushing has not been
1005 * explicitly requested (through FLAG_FLUSHABLE).
1007 if (hcon->type == LE_LINK ||
1008 (!test_bit(FLAG_FLUSHABLE, &chan->flags) &&
1009 lmp_no_flush_capable(hcon->hdev)))
1010 flags = ACL_START_NO_FLUSH;
1014 bt_cb(skb)->force_active = test_bit(FLAG_FORCE_ACTIVE, &chan->flags);
1015 hci_send_acl(chan->conn->hchan, skb, flags);
1018 static void __unpack_enhanced_control(u16 enh, struct l2cap_ctrl *control)
1020 control->reqseq = (enh & L2CAP_CTRL_REQSEQ) >> L2CAP_CTRL_REQSEQ_SHIFT;
1021 control->final = (enh & L2CAP_CTRL_FINAL) >> L2CAP_CTRL_FINAL_SHIFT;
1023 if (enh & L2CAP_CTRL_FRAME_TYPE) {
1025 control->sframe = 1;
1026 control->poll = (enh & L2CAP_CTRL_POLL) >> L2CAP_CTRL_POLL_SHIFT;
1027 control->super = (enh & L2CAP_CTRL_SUPERVISE) >> L2CAP_CTRL_SUPER_SHIFT;
1033 control->sframe = 0;
1034 control->sar = (enh & L2CAP_CTRL_SAR) >> L2CAP_CTRL_SAR_SHIFT;
1035 control->txseq = (enh & L2CAP_CTRL_TXSEQ) >> L2CAP_CTRL_TXSEQ_SHIFT;
1042 static void __unpack_extended_control(u32 ext, struct l2cap_ctrl *control)
1044 control->reqseq = (ext & L2CAP_EXT_CTRL_REQSEQ) >> L2CAP_EXT_CTRL_REQSEQ_SHIFT;
1045 control->final = (ext & L2CAP_EXT_CTRL_FINAL) >> L2CAP_EXT_CTRL_FINAL_SHIFT;
1047 if (ext & L2CAP_EXT_CTRL_FRAME_TYPE) {
1049 control->sframe = 1;
1050 control->poll = (ext & L2CAP_EXT_CTRL_POLL) >> L2CAP_EXT_CTRL_POLL_SHIFT;
1051 control->super = (ext & L2CAP_EXT_CTRL_SUPERVISE) >> L2CAP_EXT_CTRL_SUPER_SHIFT;
1057 control->sframe = 0;
1058 control->sar = (ext & L2CAP_EXT_CTRL_SAR) >> L2CAP_EXT_CTRL_SAR_SHIFT;
1059 control->txseq = (ext & L2CAP_EXT_CTRL_TXSEQ) >> L2CAP_EXT_CTRL_TXSEQ_SHIFT;
1066 static inline void __unpack_control(struct l2cap_chan *chan,
1067 struct sk_buff *skb)
1069 if (test_bit(FLAG_EXT_CTRL, &chan->flags)) {
1070 __unpack_extended_control(get_unaligned_le32(skb->data),
1071 &bt_cb(skb)->l2cap);
1072 skb_pull(skb, L2CAP_EXT_CTRL_SIZE);
1074 __unpack_enhanced_control(get_unaligned_le16(skb->data),
1075 &bt_cb(skb)->l2cap);
1076 skb_pull(skb, L2CAP_ENH_CTRL_SIZE);
1080 static u32 __pack_extended_control(struct l2cap_ctrl *control)
1084 packed = control->reqseq << L2CAP_EXT_CTRL_REQSEQ_SHIFT;
1085 packed |= control->final << L2CAP_EXT_CTRL_FINAL_SHIFT;
1087 if (control->sframe) {
1088 packed |= control->poll << L2CAP_EXT_CTRL_POLL_SHIFT;
1089 packed |= control->super << L2CAP_EXT_CTRL_SUPER_SHIFT;
1090 packed |= L2CAP_EXT_CTRL_FRAME_TYPE;
1092 packed |= control->sar << L2CAP_EXT_CTRL_SAR_SHIFT;
1093 packed |= control->txseq << L2CAP_EXT_CTRL_TXSEQ_SHIFT;
1099 static u16 __pack_enhanced_control(struct l2cap_ctrl *control)
1103 packed = control->reqseq << L2CAP_CTRL_REQSEQ_SHIFT;
1104 packed |= control->final << L2CAP_CTRL_FINAL_SHIFT;
1106 if (control->sframe) {
1107 packed |= control->poll << L2CAP_CTRL_POLL_SHIFT;
1108 packed |= control->super << L2CAP_CTRL_SUPER_SHIFT;
1109 packed |= L2CAP_CTRL_FRAME_TYPE;
1111 packed |= control->sar << L2CAP_CTRL_SAR_SHIFT;
1112 packed |= control->txseq << L2CAP_CTRL_TXSEQ_SHIFT;
1118 static inline void __pack_control(struct l2cap_chan *chan,
1119 struct l2cap_ctrl *control,
1120 struct sk_buff *skb)
1122 if (test_bit(FLAG_EXT_CTRL, &chan->flags)) {
1123 put_unaligned_le32(__pack_extended_control(control),
1124 skb->data + L2CAP_HDR_SIZE);
1126 put_unaligned_le16(__pack_enhanced_control(control),
1127 skb->data + L2CAP_HDR_SIZE);
1131 static inline unsigned int __ertm_hdr_size(struct l2cap_chan *chan)
1133 if (test_bit(FLAG_EXT_CTRL, &chan->flags))
1134 return L2CAP_EXT_HDR_SIZE;
1136 return L2CAP_ENH_HDR_SIZE;
1139 static struct sk_buff *l2cap_create_sframe_pdu(struct l2cap_chan *chan,
1142 struct sk_buff *skb;
1143 struct l2cap_hdr *lh;
1144 int hlen = __ertm_hdr_size(chan);
1146 if (chan->fcs == L2CAP_FCS_CRC16)
1147 hlen += L2CAP_FCS_SIZE;
1149 skb = bt_skb_alloc(hlen, GFP_KERNEL);
1152 return ERR_PTR(-ENOMEM);
1154 lh = skb_put(skb, L2CAP_HDR_SIZE);
1155 lh->len = cpu_to_le16(hlen - L2CAP_HDR_SIZE);
1156 lh->cid = cpu_to_le16(chan->dcid);
1158 if (test_bit(FLAG_EXT_CTRL, &chan->flags))
1159 put_unaligned_le32(control, skb_put(skb, L2CAP_EXT_CTRL_SIZE));
1161 put_unaligned_le16(control, skb_put(skb, L2CAP_ENH_CTRL_SIZE));
1163 if (chan->fcs == L2CAP_FCS_CRC16) {
1164 u16 fcs = crc16(0, (u8 *)skb->data, skb->len);
1165 put_unaligned_le16(fcs, skb_put(skb, L2CAP_FCS_SIZE));
1168 skb->priority = HCI_PRIO_MAX;
1172 static void l2cap_send_sframe(struct l2cap_chan *chan,
1173 struct l2cap_ctrl *control)
1175 struct sk_buff *skb;
1178 BT_DBG("chan %p, control %p", chan, control);
1180 if (!control->sframe)
1183 if (__chan_is_moving(chan))
1186 if (test_and_clear_bit(CONN_SEND_FBIT, &chan->conn_state) &&
1190 if (control->super == L2CAP_SUPER_RR)
1191 clear_bit(CONN_RNR_SENT, &chan->conn_state);
1192 else if (control->super == L2CAP_SUPER_RNR)
1193 set_bit(CONN_RNR_SENT, &chan->conn_state);
1195 if (control->super != L2CAP_SUPER_SREJ) {
1196 chan->last_acked_seq = control->reqseq;
1197 __clear_ack_timer(chan);
1200 BT_DBG("reqseq %d, final %d, poll %d, super %d", control->reqseq,
1201 control->final, control->poll, control->super);
1203 if (test_bit(FLAG_EXT_CTRL, &chan->flags))
1204 control_field = __pack_extended_control(control);
1206 control_field = __pack_enhanced_control(control);
1208 skb = l2cap_create_sframe_pdu(chan, control_field);
1210 l2cap_do_send(chan, skb);
1213 static void l2cap_send_rr_or_rnr(struct l2cap_chan *chan, bool poll)
1215 struct l2cap_ctrl control;
1217 BT_DBG("chan %p, poll %d", chan, poll);
1219 memset(&control, 0, sizeof(control));
1221 control.poll = poll;
1223 if (test_bit(CONN_LOCAL_BUSY, &chan->conn_state))
1224 control.super = L2CAP_SUPER_RNR;
1226 control.super = L2CAP_SUPER_RR;
1228 control.reqseq = chan->buffer_seq;
1229 l2cap_send_sframe(chan, &control);
1232 static inline int __l2cap_no_conn_pending(struct l2cap_chan *chan)
1234 if (chan->chan_type != L2CAP_CHAN_CONN_ORIENTED)
1237 return !test_bit(CONF_CONNECT_PEND, &chan->conf_state);
1240 static bool __amp_capable(struct l2cap_chan *chan)
1242 struct l2cap_conn *conn = chan->conn;
1243 struct hci_dev *hdev;
1244 bool amp_available = false;
1246 if (!(conn->local_fixed_chan & L2CAP_FC_A2MP))
1249 if (!(conn->remote_fixed_chan & L2CAP_FC_A2MP))
1252 read_lock(&hci_dev_list_lock);
1253 list_for_each_entry(hdev, &hci_dev_list, list) {
1254 if (hdev->amp_type != AMP_TYPE_BREDR &&
1255 test_bit(HCI_UP, &hdev->flags)) {
1256 amp_available = true;
1260 read_unlock(&hci_dev_list_lock);
1262 if (chan->chan_policy == BT_CHANNEL_POLICY_AMP_PREFERRED)
1263 return amp_available;
1268 static bool l2cap_check_efs(struct l2cap_chan *chan)
1270 /* Check EFS parameters */
1274 void l2cap_send_conn_req(struct l2cap_chan *chan)
1276 struct l2cap_conn *conn = chan->conn;
1277 struct l2cap_conn_req req;
1279 req.scid = cpu_to_le16(chan->scid);
1280 req.psm = chan->psm;
1282 chan->ident = l2cap_get_ident(conn);
1284 set_bit(CONF_CONNECT_PEND, &chan->conf_state);
1286 l2cap_send_cmd(conn, chan->ident, L2CAP_CONN_REQ, sizeof(req), &req);
1289 static void l2cap_send_create_chan_req(struct l2cap_chan *chan, u8 amp_id)
1291 struct l2cap_create_chan_req req;
1292 req.scid = cpu_to_le16(chan->scid);
1293 req.psm = chan->psm;
1294 req.amp_id = amp_id;
1296 chan->ident = l2cap_get_ident(chan->conn);
1298 l2cap_send_cmd(chan->conn, chan->ident, L2CAP_CREATE_CHAN_REQ,
1302 static void l2cap_move_setup(struct l2cap_chan *chan)
1304 struct sk_buff *skb;
1306 BT_DBG("chan %p", chan);
1308 if (chan->mode != L2CAP_MODE_ERTM)
1311 __clear_retrans_timer(chan);
1312 __clear_monitor_timer(chan);
1313 __clear_ack_timer(chan);
1315 chan->retry_count = 0;
1316 skb_queue_walk(&chan->tx_q, skb) {
1317 if (bt_cb(skb)->l2cap.retries)
1318 bt_cb(skb)->l2cap.retries = 1;
1323 chan->expected_tx_seq = chan->buffer_seq;
1325 clear_bit(CONN_REJ_ACT, &chan->conn_state);
1326 clear_bit(CONN_SREJ_ACT, &chan->conn_state);
1327 l2cap_seq_list_clear(&chan->retrans_list);
1328 l2cap_seq_list_clear(&chan->srej_list);
1329 skb_queue_purge(&chan->srej_q);
1331 chan->tx_state = L2CAP_TX_STATE_XMIT;
1332 chan->rx_state = L2CAP_RX_STATE_MOVE;
1334 set_bit(CONN_REMOTE_BUSY, &chan->conn_state);
1337 static void l2cap_move_done(struct l2cap_chan *chan)
1339 u8 move_role = chan->move_role;
1340 BT_DBG("chan %p", chan);
1342 chan->move_state = L2CAP_MOVE_STABLE;
1343 chan->move_role = L2CAP_MOVE_ROLE_NONE;
1345 if (chan->mode != L2CAP_MODE_ERTM)
1348 switch (move_role) {
1349 case L2CAP_MOVE_ROLE_INITIATOR:
1350 l2cap_tx(chan, NULL, NULL, L2CAP_EV_EXPLICIT_POLL);
1351 chan->rx_state = L2CAP_RX_STATE_WAIT_F;
1353 case L2CAP_MOVE_ROLE_RESPONDER:
1354 chan->rx_state = L2CAP_RX_STATE_WAIT_P;
1359 static void l2cap_chan_ready(struct l2cap_chan *chan)
1361 /* The channel may have already been flagged as connected in
1362 * case of receiving data before the L2CAP info req/rsp
1363 * procedure is complete.
1365 if (chan->state == BT_CONNECTED)
1368 /* This clears all conf flags, including CONF_NOT_COMPLETE */
1369 chan->conf_state = 0;
1370 __clear_chan_timer(chan);
1372 switch (chan->mode) {
1373 case L2CAP_MODE_LE_FLOWCTL:
1374 case L2CAP_MODE_EXT_FLOWCTL:
1375 if (!chan->tx_credits)
1376 chan->ops->suspend(chan);
1380 chan->state = BT_CONNECTED;
1382 chan->ops->ready(chan);
1385 static void l2cap_le_connect(struct l2cap_chan *chan)
1387 struct l2cap_conn *conn = chan->conn;
1388 struct l2cap_le_conn_req req;
1390 if (test_and_set_bit(FLAG_LE_CONN_REQ_SENT, &chan->flags))
1394 chan->imtu = chan->conn->mtu;
1396 l2cap_le_flowctl_init(chan, 0);
1398 memset(&req, 0, sizeof(req));
1399 req.psm = chan->psm;
1400 req.scid = cpu_to_le16(chan->scid);
1401 req.mtu = cpu_to_le16(chan->imtu);
1402 req.mps = cpu_to_le16(chan->mps);
1403 req.credits = cpu_to_le16(chan->rx_credits);
1405 chan->ident = l2cap_get_ident(conn);
1407 l2cap_send_cmd(conn, chan->ident, L2CAP_LE_CONN_REQ,
1411 struct l2cap_ecred_conn_data {
1413 struct l2cap_ecred_conn_req req;
1416 struct l2cap_chan *chan;
1421 static void l2cap_ecred_defer_connect(struct l2cap_chan *chan, void *data)
1423 struct l2cap_ecred_conn_data *conn = data;
1426 if (chan == conn->chan)
1429 if (!test_and_clear_bit(FLAG_DEFER_SETUP, &chan->flags))
1432 pid = chan->ops->get_peer_pid(chan);
1434 /* Only add deferred channels with the same PID/PSM */
1435 if (conn->pid != pid || chan->psm != conn->chan->psm || chan->ident ||
1436 chan->mode != L2CAP_MODE_EXT_FLOWCTL || chan->state != BT_CONNECT)
1439 if (test_and_set_bit(FLAG_ECRED_CONN_REQ_SENT, &chan->flags))
1442 l2cap_ecred_init(chan, 0);
1444 /* Set the same ident so we can match on the rsp */
1445 chan->ident = conn->chan->ident;
1447 /* Include all channels deferred */
1448 conn->pdu.scid[conn->count] = cpu_to_le16(chan->scid);
1453 static void l2cap_ecred_connect(struct l2cap_chan *chan)
1455 struct l2cap_conn *conn = chan->conn;
1456 struct l2cap_ecred_conn_data data;
1458 if (test_bit(FLAG_DEFER_SETUP, &chan->flags))
1461 if (test_and_set_bit(FLAG_ECRED_CONN_REQ_SENT, &chan->flags))
1464 l2cap_ecred_init(chan, 0);
1466 memset(&data, 0, sizeof(data));
1467 data.pdu.req.psm = chan->psm;
1468 data.pdu.req.mtu = cpu_to_le16(chan->imtu);
1469 data.pdu.req.mps = cpu_to_le16(chan->mps);
1470 data.pdu.req.credits = cpu_to_le16(chan->rx_credits);
1471 data.pdu.scid[0] = cpu_to_le16(chan->scid);
1473 chan->ident = l2cap_get_ident(conn);
1477 data.pid = chan->ops->get_peer_pid(chan);
1479 __l2cap_chan_list(conn, l2cap_ecred_defer_connect, &data);
1481 l2cap_send_cmd(conn, chan->ident, L2CAP_ECRED_CONN_REQ,
1482 sizeof(data.pdu.req) + data.count * sizeof(__le16),
1486 static void l2cap_le_start(struct l2cap_chan *chan)
1488 struct l2cap_conn *conn = chan->conn;
1490 if (!smp_conn_security(conn->hcon, chan->sec_level))
1494 l2cap_chan_ready(chan);
1498 if (chan->state == BT_CONNECT) {
1499 if (chan->mode == L2CAP_MODE_EXT_FLOWCTL)
1500 l2cap_ecred_connect(chan);
1502 l2cap_le_connect(chan);
1506 static void l2cap_start_connection(struct l2cap_chan *chan)
1508 if (__amp_capable(chan)) {
1509 BT_DBG("chan %p AMP capable: discover AMPs", chan);
1510 a2mp_discover_amp(chan);
1511 } else if (chan->conn->hcon->type == LE_LINK) {
1512 l2cap_le_start(chan);
1514 l2cap_send_conn_req(chan);
1518 static void l2cap_request_info(struct l2cap_conn *conn)
1520 struct l2cap_info_req req;
1522 if (conn->info_state & L2CAP_INFO_FEAT_MASK_REQ_SENT)
1525 req.type = cpu_to_le16(L2CAP_IT_FEAT_MASK);
1527 conn->info_state |= L2CAP_INFO_FEAT_MASK_REQ_SENT;
1528 conn->info_ident = l2cap_get_ident(conn);
1530 schedule_delayed_work(&conn->info_timer, L2CAP_INFO_TIMEOUT);
1532 l2cap_send_cmd(conn, conn->info_ident, L2CAP_INFO_REQ,
1536 static bool l2cap_check_enc_key_size(struct hci_conn *hcon)
1538 /* The minimum encryption key size needs to be enforced by the
1539 * host stack before establishing any L2CAP connections. The
1540 * specification in theory allows a minimum of 1, but to align
1541 * BR/EDR and LE transports, a minimum of 7 is chosen.
1543 * This check might also be called for unencrypted connections
1544 * that have no key size requirements. Ensure that the link is
1545 * actually encrypted before enforcing a key size.
1547 int min_key_size = hcon->hdev->min_enc_key_size;
1549 /* On FIPS security level, key size must be 16 bytes */
1550 if (hcon->sec_level == BT_SECURITY_FIPS)
1553 return (!test_bit(HCI_CONN_ENCRYPT, &hcon->flags) ||
1554 hcon->enc_key_size >= min_key_size);
1557 static void l2cap_do_start(struct l2cap_chan *chan)
1559 struct l2cap_conn *conn = chan->conn;
1561 if (conn->hcon->type == LE_LINK) {
1562 l2cap_le_start(chan);
1566 if (!(conn->info_state & L2CAP_INFO_FEAT_MASK_REQ_SENT)) {
1567 l2cap_request_info(conn);
1571 if (!(conn->info_state & L2CAP_INFO_FEAT_MASK_REQ_DONE))
1574 if (!l2cap_chan_check_security(chan, true) ||
1575 !__l2cap_no_conn_pending(chan))
1578 if (l2cap_check_enc_key_size(conn->hcon))
1579 l2cap_start_connection(chan);
1581 __set_chan_timer(chan, L2CAP_DISC_TIMEOUT);
1584 static inline int l2cap_mode_supported(__u8 mode, __u32 feat_mask)
1586 u32 local_feat_mask = l2cap_feat_mask;
1588 local_feat_mask |= L2CAP_FEAT_ERTM | L2CAP_FEAT_STREAMING;
1591 case L2CAP_MODE_ERTM:
1592 return L2CAP_FEAT_ERTM & feat_mask & local_feat_mask;
1593 case L2CAP_MODE_STREAMING:
1594 return L2CAP_FEAT_STREAMING & feat_mask & local_feat_mask;
1600 static void l2cap_send_disconn_req(struct l2cap_chan *chan, int err)
1602 struct l2cap_conn *conn = chan->conn;
1603 struct l2cap_disconn_req req;
1608 if (chan->mode == L2CAP_MODE_ERTM && chan->state == BT_CONNECTED) {
1609 __clear_retrans_timer(chan);
1610 __clear_monitor_timer(chan);
1611 __clear_ack_timer(chan);
1614 if (chan->scid == L2CAP_CID_A2MP) {
1615 l2cap_state_change(chan, BT_DISCONN);
1619 req.dcid = cpu_to_le16(chan->dcid);
1620 req.scid = cpu_to_le16(chan->scid);
1621 l2cap_send_cmd(conn, l2cap_get_ident(conn), L2CAP_DISCONN_REQ,
1624 l2cap_state_change_and_error(chan, BT_DISCONN, err);
1627 /* ---- L2CAP connections ---- */
1628 static void l2cap_conn_start(struct l2cap_conn *conn)
1630 struct l2cap_chan *chan, *tmp;
1632 BT_DBG("conn %p", conn);
1634 mutex_lock(&conn->chan_lock);
1636 list_for_each_entry_safe(chan, tmp, &conn->chan_l, list) {
1637 l2cap_chan_lock(chan);
1639 if (chan->chan_type != L2CAP_CHAN_CONN_ORIENTED) {
1640 l2cap_chan_ready(chan);
1641 l2cap_chan_unlock(chan);
1645 if (chan->state == BT_CONNECT) {
1646 if (!l2cap_chan_check_security(chan, true) ||
1647 !__l2cap_no_conn_pending(chan)) {
1648 l2cap_chan_unlock(chan);
1652 if (!l2cap_mode_supported(chan->mode, conn->feat_mask)
1653 && test_bit(CONF_STATE2_DEVICE,
1654 &chan->conf_state)) {
1655 l2cap_chan_close(chan, ECONNRESET);
1656 l2cap_chan_unlock(chan);
1660 if (l2cap_check_enc_key_size(conn->hcon))
1661 l2cap_start_connection(chan);
1663 l2cap_chan_close(chan, ECONNREFUSED);
1665 } else if (chan->state == BT_CONNECT2) {
1666 struct l2cap_conn_rsp rsp;
1668 rsp.scid = cpu_to_le16(chan->dcid);
1669 rsp.dcid = cpu_to_le16(chan->scid);
1671 if (l2cap_chan_check_security(chan, false)) {
1672 if (test_bit(FLAG_DEFER_SETUP, &chan->flags)) {
1673 rsp.result = cpu_to_le16(L2CAP_CR_PEND);
1674 rsp.status = cpu_to_le16(L2CAP_CS_AUTHOR_PEND);
1675 chan->ops->defer(chan);
1678 l2cap_state_change(chan, BT_CONFIG);
1679 rsp.result = cpu_to_le16(L2CAP_CR_SUCCESS);
1680 rsp.status = cpu_to_le16(L2CAP_CS_NO_INFO);
1683 rsp.result = cpu_to_le16(L2CAP_CR_PEND);
1684 rsp.status = cpu_to_le16(L2CAP_CS_AUTHEN_PEND);
1687 l2cap_send_cmd(conn, chan->ident, L2CAP_CONN_RSP,
1690 if (test_bit(CONF_REQ_SENT, &chan->conf_state) ||
1691 rsp.result != L2CAP_CR_SUCCESS) {
1692 l2cap_chan_unlock(chan);
1696 set_bit(CONF_REQ_SENT, &chan->conf_state);
1697 l2cap_send_cmd(conn, l2cap_get_ident(conn), L2CAP_CONF_REQ,
1698 l2cap_build_conf_req(chan, buf, sizeof(buf)), buf);
1699 chan->num_conf_req++;
1702 l2cap_chan_unlock(chan);
1705 mutex_unlock(&conn->chan_lock);
1708 static void l2cap_le_conn_ready(struct l2cap_conn *conn)
1710 struct hci_conn *hcon = conn->hcon;
1711 struct hci_dev *hdev = hcon->hdev;
1713 BT_DBG("%s conn %p", hdev->name, conn);
1715 /* For outgoing pairing which doesn't necessarily have an
1716 * associated socket (e.g. mgmt_pair_device).
1719 smp_conn_security(hcon, hcon->pending_sec_level);
1721 /* For LE peripheral connections, make sure the connection interval
1722 * is in the range of the minimum and maximum interval that has
1723 * been configured for this connection. If not, then trigger
1724 * the connection update procedure.
1726 if (hcon->role == HCI_ROLE_SLAVE &&
1727 (hcon->le_conn_interval < hcon->le_conn_min_interval ||
1728 hcon->le_conn_interval > hcon->le_conn_max_interval)) {
1729 struct l2cap_conn_param_update_req req;
1731 req.min = cpu_to_le16(hcon->le_conn_min_interval);
1732 req.max = cpu_to_le16(hcon->le_conn_max_interval);
1733 req.latency = cpu_to_le16(hcon->le_conn_latency);
1734 req.to_multiplier = cpu_to_le16(hcon->le_supv_timeout);
1736 l2cap_send_cmd(conn, l2cap_get_ident(conn),
1737 L2CAP_CONN_PARAM_UPDATE_REQ, sizeof(req), &req);
1741 static void l2cap_conn_ready(struct l2cap_conn *conn)
1743 struct l2cap_chan *chan;
1744 struct hci_conn *hcon = conn->hcon;
1746 BT_DBG("conn %p", conn);
1748 if (hcon->type == ACL_LINK)
1749 l2cap_request_info(conn);
1751 mutex_lock(&conn->chan_lock);
1753 list_for_each_entry(chan, &conn->chan_l, list) {
1755 l2cap_chan_lock(chan);
1757 if (chan->scid == L2CAP_CID_A2MP) {
1758 l2cap_chan_unlock(chan);
1762 if (hcon->type == LE_LINK) {
1763 l2cap_le_start(chan);
1764 } else if (chan->chan_type != L2CAP_CHAN_CONN_ORIENTED) {
1765 if (conn->info_state & L2CAP_INFO_FEAT_MASK_REQ_DONE)
1766 l2cap_chan_ready(chan);
1767 } else if (chan->state == BT_CONNECT) {
1768 l2cap_do_start(chan);
1771 l2cap_chan_unlock(chan);
1774 mutex_unlock(&conn->chan_lock);
1776 if (hcon->type == LE_LINK)
1777 l2cap_le_conn_ready(conn);
1779 queue_work(hcon->hdev->workqueue, &conn->pending_rx_work);
1782 /* Notify sockets that we cannot guaranty reliability anymore */
1783 static void l2cap_conn_unreliable(struct l2cap_conn *conn, int err)
1785 struct l2cap_chan *chan;
1787 BT_DBG("conn %p", conn);
1789 mutex_lock(&conn->chan_lock);
1791 list_for_each_entry(chan, &conn->chan_l, list) {
1792 if (test_bit(FLAG_FORCE_RELIABLE, &chan->flags))
1793 l2cap_chan_set_err(chan, err);
1796 mutex_unlock(&conn->chan_lock);
1799 static void l2cap_info_timeout(struct work_struct *work)
1801 struct l2cap_conn *conn = container_of(work, struct l2cap_conn,
1804 conn->info_state |= L2CAP_INFO_FEAT_MASK_REQ_DONE;
1805 conn->info_ident = 0;
1807 l2cap_conn_start(conn);
1812 * External modules can register l2cap_user objects on l2cap_conn. The ->probe
1813 * callback is called during registration. The ->remove callback is called
1814 * during unregistration.
1815 * An l2cap_user object can either be explicitly unregistered or when the
1816 * underlying l2cap_conn object is deleted. This guarantees that l2cap->hcon,
1817 * l2cap->hchan, .. are valid as long as the remove callback hasn't been called.
1818 * External modules must own a reference to the l2cap_conn object if they intend
1819 * to call l2cap_unregister_user(). The l2cap_conn object might get destroyed at
1820 * any time if they don't.
1823 int l2cap_register_user(struct l2cap_conn *conn, struct l2cap_user *user)
1825 struct hci_dev *hdev = conn->hcon->hdev;
1828 /* We need to check whether l2cap_conn is registered. If it is not, we
1829 * must not register the l2cap_user. l2cap_conn_del() is unregisters
1830 * l2cap_conn objects, but doesn't provide its own locking. Instead, it
1831 * relies on the parent hci_conn object to be locked. This itself relies
1832 * on the hci_dev object to be locked. So we must lock the hci device
1837 if (!list_empty(&user->list)) {
1842 /* conn->hchan is NULL after l2cap_conn_del() was called */
1848 ret = user->probe(conn, user);
1852 list_add(&user->list, &conn->users);
1856 hci_dev_unlock(hdev);
1859 EXPORT_SYMBOL(l2cap_register_user);
1861 void l2cap_unregister_user(struct l2cap_conn *conn, struct l2cap_user *user)
1863 struct hci_dev *hdev = conn->hcon->hdev;
1867 if (list_empty(&user->list))
1870 list_del_init(&user->list);
1871 user->remove(conn, user);
1874 hci_dev_unlock(hdev);
1876 EXPORT_SYMBOL(l2cap_unregister_user);
1878 static void l2cap_unregister_all_users(struct l2cap_conn *conn)
1880 struct l2cap_user *user;
1882 while (!list_empty(&conn->users)) {
1883 user = list_first_entry(&conn->users, struct l2cap_user, list);
1884 list_del_init(&user->list);
1885 user->remove(conn, user);
1889 static void l2cap_conn_del(struct hci_conn *hcon, int err)
1891 struct l2cap_conn *conn = hcon->l2cap_data;
1892 struct l2cap_chan *chan, *l;
1897 BT_DBG("hcon %p conn %p, err %d", hcon, conn, err);
1899 kfree_skb(conn->rx_skb);
1901 skb_queue_purge(&conn->pending_rx);
1903 /* We can not call flush_work(&conn->pending_rx_work) here since we
1904 * might block if we are running on a worker from the same workqueue
1905 * pending_rx_work is waiting on.
1907 if (work_pending(&conn->pending_rx_work))
1908 cancel_work_sync(&conn->pending_rx_work);
1910 cancel_delayed_work_sync(&conn->id_addr_timer);
1912 l2cap_unregister_all_users(conn);
1914 /* Force the connection to be immediately dropped */
1915 hcon->disc_timeout = 0;
1917 mutex_lock(&conn->chan_lock);
1920 list_for_each_entry_safe(chan, l, &conn->chan_l, list) {
1921 l2cap_chan_hold(chan);
1922 l2cap_chan_lock(chan);
1924 l2cap_chan_del(chan, err);
1926 chan->ops->close(chan);
1928 l2cap_chan_unlock(chan);
1929 l2cap_chan_put(chan);
1932 mutex_unlock(&conn->chan_lock);
1934 hci_chan_del(conn->hchan);
1936 if (conn->info_state & L2CAP_INFO_FEAT_MASK_REQ_SENT)
1937 cancel_delayed_work_sync(&conn->info_timer);
1939 hcon->l2cap_data = NULL;
1941 l2cap_conn_put(conn);
1944 static void l2cap_conn_free(struct kref *ref)
1946 struct l2cap_conn *conn = container_of(ref, struct l2cap_conn, ref);
1948 hci_conn_put(conn->hcon);
1952 struct l2cap_conn *l2cap_conn_get(struct l2cap_conn *conn)
1954 kref_get(&conn->ref);
1957 EXPORT_SYMBOL(l2cap_conn_get);
1959 void l2cap_conn_put(struct l2cap_conn *conn)
1961 kref_put(&conn->ref, l2cap_conn_free);
1963 EXPORT_SYMBOL(l2cap_conn_put);
1965 /* ---- Socket interface ---- */
1967 /* Find socket with psm and source / destination bdaddr.
1968 * Returns closest match.
1970 static struct l2cap_chan *l2cap_global_chan_by_psm(int state, __le16 psm,
1975 struct l2cap_chan *c, *tmp, *c1 = NULL;
1977 read_lock(&chan_list_lock);
1979 list_for_each_entry_safe(c, tmp, &chan_list, global_l) {
1980 if (state && c->state != state)
1983 if (link_type == ACL_LINK && c->src_type != BDADDR_BREDR)
1986 if (link_type == LE_LINK && c->src_type == BDADDR_BREDR)
1989 if (c->chan_type != L2CAP_CHAN_FIXED && c->psm == psm) {
1990 int src_match, dst_match;
1991 int src_any, dst_any;
1994 src_match = !bacmp(&c->src, src);
1995 dst_match = !bacmp(&c->dst, dst);
1996 if (src_match && dst_match) {
1997 if (!l2cap_chan_hold_unless_zero(c))
2000 read_unlock(&chan_list_lock);
2005 src_any = !bacmp(&c->src, BDADDR_ANY);
2006 dst_any = !bacmp(&c->dst, BDADDR_ANY);
2007 if ((src_match && dst_any) || (src_any && dst_match) ||
2008 (src_any && dst_any))
2014 c1 = l2cap_chan_hold_unless_zero(c1);
2016 read_unlock(&chan_list_lock);
2021 static void l2cap_monitor_timeout(struct work_struct *work)
2023 struct l2cap_chan *chan = container_of(work, struct l2cap_chan,
2024 monitor_timer.work);
2026 BT_DBG("chan %p", chan);
2028 l2cap_chan_lock(chan);
2031 l2cap_chan_unlock(chan);
2032 l2cap_chan_put(chan);
2036 l2cap_tx(chan, NULL, NULL, L2CAP_EV_MONITOR_TO);
2038 l2cap_chan_unlock(chan);
2039 l2cap_chan_put(chan);
2042 static void l2cap_retrans_timeout(struct work_struct *work)
2044 struct l2cap_chan *chan = container_of(work, struct l2cap_chan,
2045 retrans_timer.work);
2047 BT_DBG("chan %p", chan);
2049 l2cap_chan_lock(chan);
2052 l2cap_chan_unlock(chan);
2053 l2cap_chan_put(chan);
2057 l2cap_tx(chan, NULL, NULL, L2CAP_EV_RETRANS_TO);
2058 l2cap_chan_unlock(chan);
2059 l2cap_chan_put(chan);
2062 static void l2cap_streaming_send(struct l2cap_chan *chan,
2063 struct sk_buff_head *skbs)
2065 struct sk_buff *skb;
2066 struct l2cap_ctrl *control;
2068 BT_DBG("chan %p, skbs %p", chan, skbs);
2070 if (__chan_is_moving(chan))
2073 skb_queue_splice_tail_init(skbs, &chan->tx_q);
2075 while (!skb_queue_empty(&chan->tx_q)) {
2077 skb = skb_dequeue(&chan->tx_q);
2079 bt_cb(skb)->l2cap.retries = 1;
2080 control = &bt_cb(skb)->l2cap;
2082 control->reqseq = 0;
2083 control->txseq = chan->next_tx_seq;
2085 __pack_control(chan, control, skb);
2087 if (chan->fcs == L2CAP_FCS_CRC16) {
2088 u16 fcs = crc16(0, (u8 *) skb->data, skb->len);
2089 put_unaligned_le16(fcs, skb_put(skb, L2CAP_FCS_SIZE));
2092 l2cap_do_send(chan, skb);
2094 BT_DBG("Sent txseq %u", control->txseq);
2096 chan->next_tx_seq = __next_seq(chan, chan->next_tx_seq);
2097 chan->frames_sent++;
2101 static int l2cap_ertm_send(struct l2cap_chan *chan)
2103 struct sk_buff *skb, *tx_skb;
2104 struct l2cap_ctrl *control;
2107 BT_DBG("chan %p", chan);
2109 if (chan->state != BT_CONNECTED)
2112 if (test_bit(CONN_REMOTE_BUSY, &chan->conn_state))
2115 if (__chan_is_moving(chan))
2118 while (chan->tx_send_head &&
2119 chan->unacked_frames < chan->remote_tx_win &&
2120 chan->tx_state == L2CAP_TX_STATE_XMIT) {
2122 skb = chan->tx_send_head;
2124 bt_cb(skb)->l2cap.retries = 1;
2125 control = &bt_cb(skb)->l2cap;
2127 if (test_and_clear_bit(CONN_SEND_FBIT, &chan->conn_state))
2130 control->reqseq = chan->buffer_seq;
2131 chan->last_acked_seq = chan->buffer_seq;
2132 control->txseq = chan->next_tx_seq;
2134 __pack_control(chan, control, skb);
2136 if (chan->fcs == L2CAP_FCS_CRC16) {
2137 u16 fcs = crc16(0, (u8 *) skb->data, skb->len);
2138 put_unaligned_le16(fcs, skb_put(skb, L2CAP_FCS_SIZE));
2141 /* Clone after data has been modified. Data is assumed to be
2142 read-only (for locking purposes) on cloned sk_buffs.
2144 tx_skb = skb_clone(skb, GFP_KERNEL);
2149 __set_retrans_timer(chan);
2151 chan->next_tx_seq = __next_seq(chan, chan->next_tx_seq);
2152 chan->unacked_frames++;
2153 chan->frames_sent++;
2156 if (skb_queue_is_last(&chan->tx_q, skb))
2157 chan->tx_send_head = NULL;
2159 chan->tx_send_head = skb_queue_next(&chan->tx_q, skb);
2161 l2cap_do_send(chan, tx_skb);
2162 BT_DBG("Sent txseq %u", control->txseq);
2165 BT_DBG("Sent %d, %u unacked, %u in ERTM queue", sent,
2166 chan->unacked_frames, skb_queue_len(&chan->tx_q));
2171 static void l2cap_ertm_resend(struct l2cap_chan *chan)
2173 struct l2cap_ctrl control;
2174 struct sk_buff *skb;
2175 struct sk_buff *tx_skb;
2178 BT_DBG("chan %p", chan);
2180 if (test_bit(CONN_REMOTE_BUSY, &chan->conn_state))
2183 if (__chan_is_moving(chan))
2186 while (chan->retrans_list.head != L2CAP_SEQ_LIST_CLEAR) {
2187 seq = l2cap_seq_list_pop(&chan->retrans_list);
2189 skb = l2cap_ertm_seq_in_queue(&chan->tx_q, seq);
2191 BT_DBG("Error: Can't retransmit seq %d, frame missing",
2196 bt_cb(skb)->l2cap.retries++;
2197 control = bt_cb(skb)->l2cap;
2199 if (chan->max_tx != 0 &&
2200 bt_cb(skb)->l2cap.retries > chan->max_tx) {
2201 BT_DBG("Retry limit exceeded (%d)", chan->max_tx);
2202 l2cap_send_disconn_req(chan, ECONNRESET);
2203 l2cap_seq_list_clear(&chan->retrans_list);
2207 control.reqseq = chan->buffer_seq;
2208 if (test_and_clear_bit(CONN_SEND_FBIT, &chan->conn_state))
2213 if (skb_cloned(skb)) {
2214 /* Cloned sk_buffs are read-only, so we need a
2217 tx_skb = skb_copy(skb, GFP_KERNEL);
2219 tx_skb = skb_clone(skb, GFP_KERNEL);
2223 l2cap_seq_list_clear(&chan->retrans_list);
2227 /* Update skb contents */
2228 if (test_bit(FLAG_EXT_CTRL, &chan->flags)) {
2229 put_unaligned_le32(__pack_extended_control(&control),
2230 tx_skb->data + L2CAP_HDR_SIZE);
2232 put_unaligned_le16(__pack_enhanced_control(&control),
2233 tx_skb->data + L2CAP_HDR_SIZE);
2237 if (chan->fcs == L2CAP_FCS_CRC16) {
2238 u16 fcs = crc16(0, (u8 *) tx_skb->data,
2239 tx_skb->len - L2CAP_FCS_SIZE);
2240 put_unaligned_le16(fcs, skb_tail_pointer(tx_skb) -
2244 l2cap_do_send(chan, tx_skb);
2246 BT_DBG("Resent txseq %d", control.txseq);
2248 chan->last_acked_seq = chan->buffer_seq;
2252 static void l2cap_retransmit(struct l2cap_chan *chan,
2253 struct l2cap_ctrl *control)
2255 BT_DBG("chan %p, control %p", chan, control);
2257 l2cap_seq_list_append(&chan->retrans_list, control->reqseq);
2258 l2cap_ertm_resend(chan);
2261 static void l2cap_retransmit_all(struct l2cap_chan *chan,
2262 struct l2cap_ctrl *control)
2264 struct sk_buff *skb;
2266 BT_DBG("chan %p, control %p", chan, control);
2269 set_bit(CONN_SEND_FBIT, &chan->conn_state);
2271 l2cap_seq_list_clear(&chan->retrans_list);
2273 if (test_bit(CONN_REMOTE_BUSY, &chan->conn_state))
2276 if (chan->unacked_frames) {
2277 skb_queue_walk(&chan->tx_q, skb) {
2278 if (bt_cb(skb)->l2cap.txseq == control->reqseq ||
2279 skb == chan->tx_send_head)
2283 skb_queue_walk_from(&chan->tx_q, skb) {
2284 if (skb == chan->tx_send_head)
2287 l2cap_seq_list_append(&chan->retrans_list,
2288 bt_cb(skb)->l2cap.txseq);
2291 l2cap_ertm_resend(chan);
2295 static void l2cap_send_ack(struct l2cap_chan *chan)
2297 struct l2cap_ctrl control;
2298 u16 frames_to_ack = __seq_offset(chan, chan->buffer_seq,
2299 chan->last_acked_seq);
2302 BT_DBG("chan %p last_acked_seq %d buffer_seq %d",
2303 chan, chan->last_acked_seq, chan->buffer_seq);
2305 memset(&control, 0, sizeof(control));
2308 if (test_bit(CONN_LOCAL_BUSY, &chan->conn_state) &&
2309 chan->rx_state == L2CAP_RX_STATE_RECV) {
2310 __clear_ack_timer(chan);
2311 control.super = L2CAP_SUPER_RNR;
2312 control.reqseq = chan->buffer_seq;
2313 l2cap_send_sframe(chan, &control);
2315 if (!test_bit(CONN_REMOTE_BUSY, &chan->conn_state)) {
2316 l2cap_ertm_send(chan);
2317 /* If any i-frames were sent, they included an ack */
2318 if (chan->buffer_seq == chan->last_acked_seq)
2322 /* Ack now if the window is 3/4ths full.
2323 * Calculate without mul or div
2325 threshold = chan->ack_win;
2326 threshold += threshold << 1;
2329 BT_DBG("frames_to_ack %u, threshold %d", frames_to_ack,
2332 if (frames_to_ack >= threshold) {
2333 __clear_ack_timer(chan);
2334 control.super = L2CAP_SUPER_RR;
2335 control.reqseq = chan->buffer_seq;
2336 l2cap_send_sframe(chan, &control);
2341 __set_ack_timer(chan);
2345 static inline int l2cap_skbuff_fromiovec(struct l2cap_chan *chan,
2346 struct msghdr *msg, int len,
2347 int count, struct sk_buff *skb)
2349 struct l2cap_conn *conn = chan->conn;
2350 struct sk_buff **frag;
2353 if (!copy_from_iter_full(skb_put(skb, count), count, &msg->msg_iter))
2359 /* Continuation fragments (no L2CAP header) */
2360 frag = &skb_shinfo(skb)->frag_list;
2362 struct sk_buff *tmp;
2364 count = min_t(unsigned int, conn->mtu, len);
2366 tmp = chan->ops->alloc_skb(chan, 0, count,
2367 msg->msg_flags & MSG_DONTWAIT);
2369 return PTR_ERR(tmp);
2373 if (!copy_from_iter_full(skb_put(*frag, count), count,
2380 skb->len += (*frag)->len;
2381 skb->data_len += (*frag)->len;
2383 frag = &(*frag)->next;
2389 static struct sk_buff *l2cap_create_connless_pdu(struct l2cap_chan *chan,
2390 struct msghdr *msg, size_t len)
2392 struct l2cap_conn *conn = chan->conn;
2393 struct sk_buff *skb;
2394 int err, count, hlen = L2CAP_HDR_SIZE + L2CAP_PSMLEN_SIZE;
2395 struct l2cap_hdr *lh;
2397 BT_DBG("chan %p psm 0x%2.2x len %zu", chan,
2398 __le16_to_cpu(chan->psm), len);
2400 count = min_t(unsigned int, (conn->mtu - hlen), len);
2402 skb = chan->ops->alloc_skb(chan, hlen, count,
2403 msg->msg_flags & MSG_DONTWAIT);
2407 /* Create L2CAP header */
2408 lh = skb_put(skb, L2CAP_HDR_SIZE);
2409 lh->cid = cpu_to_le16(chan->dcid);
2410 lh->len = cpu_to_le16(len + L2CAP_PSMLEN_SIZE);
2411 put_unaligned(chan->psm, (__le16 *) skb_put(skb, L2CAP_PSMLEN_SIZE));
2413 err = l2cap_skbuff_fromiovec(chan, msg, len, count, skb);
2414 if (unlikely(err < 0)) {
2416 return ERR_PTR(err);
2421 static struct sk_buff *l2cap_create_basic_pdu(struct l2cap_chan *chan,
2422 struct msghdr *msg, size_t len)
2424 struct l2cap_conn *conn = chan->conn;
2425 struct sk_buff *skb;
2427 struct l2cap_hdr *lh;
2429 BT_DBG("chan %p len %zu", chan, len);
2431 count = min_t(unsigned int, (conn->mtu - L2CAP_HDR_SIZE), len);
2433 skb = chan->ops->alloc_skb(chan, L2CAP_HDR_SIZE, count,
2434 msg->msg_flags & MSG_DONTWAIT);
2438 /* Create L2CAP header */
2439 lh = skb_put(skb, L2CAP_HDR_SIZE);
2440 lh->cid = cpu_to_le16(chan->dcid);
2441 lh->len = cpu_to_le16(len);
2443 err = l2cap_skbuff_fromiovec(chan, msg, len, count, skb);
2444 if (unlikely(err < 0)) {
2446 return ERR_PTR(err);
2451 static struct sk_buff *l2cap_create_iframe_pdu(struct l2cap_chan *chan,
2452 struct msghdr *msg, size_t len,
2455 struct l2cap_conn *conn = chan->conn;
2456 struct sk_buff *skb;
2457 int err, count, hlen;
2458 struct l2cap_hdr *lh;
2460 BT_DBG("chan %p len %zu", chan, len);
2463 return ERR_PTR(-ENOTCONN);
2465 hlen = __ertm_hdr_size(chan);
2468 hlen += L2CAP_SDULEN_SIZE;
2470 if (chan->fcs == L2CAP_FCS_CRC16)
2471 hlen += L2CAP_FCS_SIZE;
2473 count = min_t(unsigned int, (conn->mtu - hlen), len);
2475 skb = chan->ops->alloc_skb(chan, hlen, count,
2476 msg->msg_flags & MSG_DONTWAIT);
2480 /* Create L2CAP header */
2481 lh = skb_put(skb, L2CAP_HDR_SIZE);
2482 lh->cid = cpu_to_le16(chan->dcid);
2483 lh->len = cpu_to_le16(len + (hlen - L2CAP_HDR_SIZE));
2485 /* Control header is populated later */
2486 if (test_bit(FLAG_EXT_CTRL, &chan->flags))
2487 put_unaligned_le32(0, skb_put(skb, L2CAP_EXT_CTRL_SIZE));
2489 put_unaligned_le16(0, skb_put(skb, L2CAP_ENH_CTRL_SIZE));
2492 put_unaligned_le16(sdulen, skb_put(skb, L2CAP_SDULEN_SIZE));
2494 err = l2cap_skbuff_fromiovec(chan, msg, len, count, skb);
2495 if (unlikely(err < 0)) {
2497 return ERR_PTR(err);
2500 bt_cb(skb)->l2cap.fcs = chan->fcs;
2501 bt_cb(skb)->l2cap.retries = 0;
2505 static int l2cap_segment_sdu(struct l2cap_chan *chan,
2506 struct sk_buff_head *seg_queue,
2507 struct msghdr *msg, size_t len)
2509 struct sk_buff *skb;
2514 BT_DBG("chan %p, msg %p, len %zu", chan, msg, len);
2516 /* It is critical that ERTM PDUs fit in a single HCI fragment,
2517 * so fragmented skbs are not used. The HCI layer's handling
2518 * of fragmented skbs is not compatible with ERTM's queueing.
2521 /* PDU size is derived from the HCI MTU */
2522 pdu_len = chan->conn->mtu;
2524 /* Constrain PDU size for BR/EDR connections */
2526 pdu_len = min_t(size_t, pdu_len, L2CAP_BREDR_MAX_PAYLOAD);
2528 /* Adjust for largest possible L2CAP overhead. */
2530 pdu_len -= L2CAP_FCS_SIZE;
2532 pdu_len -= __ertm_hdr_size(chan);
2534 /* Remote device may have requested smaller PDUs */
2535 pdu_len = min_t(size_t, pdu_len, chan->remote_mps);
2537 if (len <= pdu_len) {
2538 sar = L2CAP_SAR_UNSEGMENTED;
2542 sar = L2CAP_SAR_START;
2547 skb = l2cap_create_iframe_pdu(chan, msg, pdu_len, sdu_len);
2550 __skb_queue_purge(seg_queue);
2551 return PTR_ERR(skb);
2554 bt_cb(skb)->l2cap.sar = sar;
2555 __skb_queue_tail(seg_queue, skb);
2561 if (len <= pdu_len) {
2562 sar = L2CAP_SAR_END;
2565 sar = L2CAP_SAR_CONTINUE;
2572 static struct sk_buff *l2cap_create_le_flowctl_pdu(struct l2cap_chan *chan,
2574 size_t len, u16 sdulen)
2576 struct l2cap_conn *conn = chan->conn;
2577 struct sk_buff *skb;
2578 int err, count, hlen;
2579 struct l2cap_hdr *lh;
2581 BT_DBG("chan %p len %zu", chan, len);
2584 return ERR_PTR(-ENOTCONN);
2586 hlen = L2CAP_HDR_SIZE;
2589 hlen += L2CAP_SDULEN_SIZE;
2591 count = min_t(unsigned int, (conn->mtu - hlen), len);
2593 skb = chan->ops->alloc_skb(chan, hlen, count,
2594 msg->msg_flags & MSG_DONTWAIT);
2598 /* Create L2CAP header */
2599 lh = skb_put(skb, L2CAP_HDR_SIZE);
2600 lh->cid = cpu_to_le16(chan->dcid);
2601 lh->len = cpu_to_le16(len + (hlen - L2CAP_HDR_SIZE));
2604 put_unaligned_le16(sdulen, skb_put(skb, L2CAP_SDULEN_SIZE));
2606 err = l2cap_skbuff_fromiovec(chan, msg, len, count, skb);
2607 if (unlikely(err < 0)) {
2609 return ERR_PTR(err);
2615 static int l2cap_segment_le_sdu(struct l2cap_chan *chan,
2616 struct sk_buff_head *seg_queue,
2617 struct msghdr *msg, size_t len)
2619 struct sk_buff *skb;
2623 BT_DBG("chan %p, msg %p, len %zu", chan, msg, len);
2626 pdu_len = chan->remote_mps - L2CAP_SDULEN_SIZE;
2632 skb = l2cap_create_le_flowctl_pdu(chan, msg, pdu_len, sdu_len);
2634 __skb_queue_purge(seg_queue);
2635 return PTR_ERR(skb);
2638 __skb_queue_tail(seg_queue, skb);
2644 pdu_len += L2CAP_SDULEN_SIZE;
2651 static void l2cap_le_flowctl_send(struct l2cap_chan *chan)
2655 BT_DBG("chan %p", chan);
2657 while (chan->tx_credits && !skb_queue_empty(&chan->tx_q)) {
2658 l2cap_do_send(chan, skb_dequeue(&chan->tx_q));
2663 BT_DBG("Sent %d credits %u queued %u", sent, chan->tx_credits,
2664 skb_queue_len(&chan->tx_q));
2667 int l2cap_chan_send(struct l2cap_chan *chan, struct msghdr *msg, size_t len)
2669 struct sk_buff *skb;
2671 struct sk_buff_head seg_queue;
2676 /* Connectionless channel */
2677 if (chan->chan_type == L2CAP_CHAN_CONN_LESS) {
2678 skb = l2cap_create_connless_pdu(chan, msg, len);
2680 return PTR_ERR(skb);
2682 l2cap_do_send(chan, skb);
2686 switch (chan->mode) {
2687 case L2CAP_MODE_LE_FLOWCTL:
2688 case L2CAP_MODE_EXT_FLOWCTL:
2689 /* Check outgoing MTU */
2690 if (len > chan->omtu)
2693 __skb_queue_head_init(&seg_queue);
2695 err = l2cap_segment_le_sdu(chan, &seg_queue, msg, len);
2697 if (chan->state != BT_CONNECTED) {
2698 __skb_queue_purge(&seg_queue);
2705 skb_queue_splice_tail_init(&seg_queue, &chan->tx_q);
2707 l2cap_le_flowctl_send(chan);
2709 if (!chan->tx_credits)
2710 chan->ops->suspend(chan);
2716 case L2CAP_MODE_BASIC:
2717 /* Check outgoing MTU */
2718 if (len > chan->omtu)
2721 /* Create a basic PDU */
2722 skb = l2cap_create_basic_pdu(chan, msg, len);
2724 return PTR_ERR(skb);
2726 l2cap_do_send(chan, skb);
2730 case L2CAP_MODE_ERTM:
2731 case L2CAP_MODE_STREAMING:
2732 /* Check outgoing MTU */
2733 if (len > chan->omtu) {
2738 __skb_queue_head_init(&seg_queue);
2740 /* Do segmentation before calling in to the state machine,
2741 * since it's possible to block while waiting for memory
2744 err = l2cap_segment_sdu(chan, &seg_queue, msg, len);
2749 if (chan->mode == L2CAP_MODE_ERTM)
2750 l2cap_tx(chan, NULL, &seg_queue, L2CAP_EV_DATA_REQUEST);
2752 l2cap_streaming_send(chan, &seg_queue);
2756 /* If the skbs were not queued for sending, they'll still be in
2757 * seg_queue and need to be purged.
2759 __skb_queue_purge(&seg_queue);
2763 BT_DBG("bad state %1.1x", chan->mode);
2769 EXPORT_SYMBOL_GPL(l2cap_chan_send);
2771 static void l2cap_send_srej(struct l2cap_chan *chan, u16 txseq)
2773 struct l2cap_ctrl control;
2776 BT_DBG("chan %p, txseq %u", chan, txseq);
2778 memset(&control, 0, sizeof(control));
2780 control.super = L2CAP_SUPER_SREJ;
2782 for (seq = chan->expected_tx_seq; seq != txseq;
2783 seq = __next_seq(chan, seq)) {
2784 if (!l2cap_ertm_seq_in_queue(&chan->srej_q, seq)) {
2785 control.reqseq = seq;
2786 l2cap_send_sframe(chan, &control);
2787 l2cap_seq_list_append(&chan->srej_list, seq);
2791 chan->expected_tx_seq = __next_seq(chan, txseq);
2794 static void l2cap_send_srej_tail(struct l2cap_chan *chan)
2796 struct l2cap_ctrl control;
2798 BT_DBG("chan %p", chan);
2800 if (chan->srej_list.tail == L2CAP_SEQ_LIST_CLEAR)
2803 memset(&control, 0, sizeof(control));
2805 control.super = L2CAP_SUPER_SREJ;
2806 control.reqseq = chan->srej_list.tail;
2807 l2cap_send_sframe(chan, &control);
2810 static void l2cap_send_srej_list(struct l2cap_chan *chan, u16 txseq)
2812 struct l2cap_ctrl control;
2816 BT_DBG("chan %p, txseq %u", chan, txseq);
2818 memset(&control, 0, sizeof(control));
2820 control.super = L2CAP_SUPER_SREJ;
2822 /* Capture initial list head to allow only one pass through the list. */
2823 initial_head = chan->srej_list.head;
2826 seq = l2cap_seq_list_pop(&chan->srej_list);
2827 if (seq == txseq || seq == L2CAP_SEQ_LIST_CLEAR)
2830 control.reqseq = seq;
2831 l2cap_send_sframe(chan, &control);
2832 l2cap_seq_list_append(&chan->srej_list, seq);
2833 } while (chan->srej_list.head != initial_head);
2836 static void l2cap_process_reqseq(struct l2cap_chan *chan, u16 reqseq)
2838 struct sk_buff *acked_skb;
2841 BT_DBG("chan %p, reqseq %u", chan, reqseq);
2843 if (chan->unacked_frames == 0 || reqseq == chan->expected_ack_seq)
2846 BT_DBG("expected_ack_seq %u, unacked_frames %u",
2847 chan->expected_ack_seq, chan->unacked_frames);
2849 for (ackseq = chan->expected_ack_seq; ackseq != reqseq;
2850 ackseq = __next_seq(chan, ackseq)) {
2852 acked_skb = l2cap_ertm_seq_in_queue(&chan->tx_q, ackseq);
2854 skb_unlink(acked_skb, &chan->tx_q);
2855 kfree_skb(acked_skb);
2856 chan->unacked_frames--;
2860 chan->expected_ack_seq = reqseq;
2862 if (chan->unacked_frames == 0)
2863 __clear_retrans_timer(chan);
2865 BT_DBG("unacked_frames %u", chan->unacked_frames);
2868 static void l2cap_abort_rx_srej_sent(struct l2cap_chan *chan)
2870 BT_DBG("chan %p", chan);
2872 chan->expected_tx_seq = chan->buffer_seq;
2873 l2cap_seq_list_clear(&chan->srej_list);
2874 skb_queue_purge(&chan->srej_q);
2875 chan->rx_state = L2CAP_RX_STATE_RECV;
2878 static void l2cap_tx_state_xmit(struct l2cap_chan *chan,
2879 struct l2cap_ctrl *control,
2880 struct sk_buff_head *skbs, u8 event)
2882 BT_DBG("chan %p, control %p, skbs %p, event %d", chan, control, skbs,
2886 case L2CAP_EV_DATA_REQUEST:
2887 if (chan->tx_send_head == NULL)
2888 chan->tx_send_head = skb_peek(skbs);
2890 skb_queue_splice_tail_init(skbs, &chan->tx_q);
2891 l2cap_ertm_send(chan);
2893 case L2CAP_EV_LOCAL_BUSY_DETECTED:
2894 BT_DBG("Enter LOCAL_BUSY");
2895 set_bit(CONN_LOCAL_BUSY, &chan->conn_state);
2897 if (chan->rx_state == L2CAP_RX_STATE_SREJ_SENT) {
2898 /* The SREJ_SENT state must be aborted if we are to
2899 * enter the LOCAL_BUSY state.
2901 l2cap_abort_rx_srej_sent(chan);
2904 l2cap_send_ack(chan);
2907 case L2CAP_EV_LOCAL_BUSY_CLEAR:
2908 BT_DBG("Exit LOCAL_BUSY");
2909 clear_bit(CONN_LOCAL_BUSY, &chan->conn_state);
2911 if (test_bit(CONN_RNR_SENT, &chan->conn_state)) {
2912 struct l2cap_ctrl local_control;
2914 memset(&local_control, 0, sizeof(local_control));
2915 local_control.sframe = 1;
2916 local_control.super = L2CAP_SUPER_RR;
2917 local_control.poll = 1;
2918 local_control.reqseq = chan->buffer_seq;
2919 l2cap_send_sframe(chan, &local_control);
2921 chan->retry_count = 1;
2922 __set_monitor_timer(chan);
2923 chan->tx_state = L2CAP_TX_STATE_WAIT_F;
2926 case L2CAP_EV_RECV_REQSEQ_AND_FBIT:
2927 l2cap_process_reqseq(chan, control->reqseq);
2929 case L2CAP_EV_EXPLICIT_POLL:
2930 l2cap_send_rr_or_rnr(chan, 1);
2931 chan->retry_count = 1;
2932 __set_monitor_timer(chan);
2933 __clear_ack_timer(chan);
2934 chan->tx_state = L2CAP_TX_STATE_WAIT_F;
2936 case L2CAP_EV_RETRANS_TO:
2937 l2cap_send_rr_or_rnr(chan, 1);
2938 chan->retry_count = 1;
2939 __set_monitor_timer(chan);
2940 chan->tx_state = L2CAP_TX_STATE_WAIT_F;
2942 case L2CAP_EV_RECV_FBIT:
2943 /* Nothing to process */
2950 static void l2cap_tx_state_wait_f(struct l2cap_chan *chan,
2951 struct l2cap_ctrl *control,
2952 struct sk_buff_head *skbs, u8 event)
2954 BT_DBG("chan %p, control %p, skbs %p, event %d", chan, control, skbs,
2958 case L2CAP_EV_DATA_REQUEST:
2959 if (chan->tx_send_head == NULL)
2960 chan->tx_send_head = skb_peek(skbs);
2961 /* Queue data, but don't send. */
2962 skb_queue_splice_tail_init(skbs, &chan->tx_q);
2964 case L2CAP_EV_LOCAL_BUSY_DETECTED:
2965 BT_DBG("Enter LOCAL_BUSY");
2966 set_bit(CONN_LOCAL_BUSY, &chan->conn_state);
2968 if (chan->rx_state == L2CAP_RX_STATE_SREJ_SENT) {
2969 /* The SREJ_SENT state must be aborted if we are to
2970 * enter the LOCAL_BUSY state.
2972 l2cap_abort_rx_srej_sent(chan);
2975 l2cap_send_ack(chan);
2978 case L2CAP_EV_LOCAL_BUSY_CLEAR:
2979 BT_DBG("Exit LOCAL_BUSY");
2980 clear_bit(CONN_LOCAL_BUSY, &chan->conn_state);
2982 if (test_bit(CONN_RNR_SENT, &chan->conn_state)) {
2983 struct l2cap_ctrl local_control;
2984 memset(&local_control, 0, sizeof(local_control));
2985 local_control.sframe = 1;
2986 local_control.super = L2CAP_SUPER_RR;
2987 local_control.poll = 1;
2988 local_control.reqseq = chan->buffer_seq;
2989 l2cap_send_sframe(chan, &local_control);
2991 chan->retry_count = 1;
2992 __set_monitor_timer(chan);
2993 chan->tx_state = L2CAP_TX_STATE_WAIT_F;
2996 case L2CAP_EV_RECV_REQSEQ_AND_FBIT:
2997 l2cap_process_reqseq(chan, control->reqseq);
3000 case L2CAP_EV_RECV_FBIT:
3001 if (control && control->final) {
3002 __clear_monitor_timer(chan);
3003 if (chan->unacked_frames > 0)
3004 __set_retrans_timer(chan);
3005 chan->retry_count = 0;
3006 chan->tx_state = L2CAP_TX_STATE_XMIT;
3007 BT_DBG("recv fbit tx_state 0x2.2%x", chan->tx_state);
3010 case L2CAP_EV_EXPLICIT_POLL:
3013 case L2CAP_EV_MONITOR_TO:
3014 if (chan->max_tx == 0 || chan->retry_count < chan->max_tx) {
3015 l2cap_send_rr_or_rnr(chan, 1);
3016 __set_monitor_timer(chan);
3017 chan->retry_count++;
3019 l2cap_send_disconn_req(chan, ECONNABORTED);
3027 static void l2cap_tx(struct l2cap_chan *chan, struct l2cap_ctrl *control,
3028 struct sk_buff_head *skbs, u8 event)
3030 BT_DBG("chan %p, control %p, skbs %p, event %d, state %d",
3031 chan, control, skbs, event, chan->tx_state);
3033 switch (chan->tx_state) {
3034 case L2CAP_TX_STATE_XMIT:
3035 l2cap_tx_state_xmit(chan, control, skbs, event);
3037 case L2CAP_TX_STATE_WAIT_F:
3038 l2cap_tx_state_wait_f(chan, control, skbs, event);
3046 static void l2cap_pass_to_tx(struct l2cap_chan *chan,
3047 struct l2cap_ctrl *control)
3049 BT_DBG("chan %p, control %p", chan, control);
3050 l2cap_tx(chan, control, NULL, L2CAP_EV_RECV_REQSEQ_AND_FBIT);
3053 static void l2cap_pass_to_tx_fbit(struct l2cap_chan *chan,
3054 struct l2cap_ctrl *control)
3056 BT_DBG("chan %p, control %p", chan, control);
3057 l2cap_tx(chan, control, NULL, L2CAP_EV_RECV_FBIT);
3060 /* Copy frame to all raw sockets on that connection */
3061 static void l2cap_raw_recv(struct l2cap_conn *conn, struct sk_buff *skb)
3063 struct sk_buff *nskb;
3064 struct l2cap_chan *chan;
3066 BT_DBG("conn %p", conn);
3068 mutex_lock(&conn->chan_lock);
3070 list_for_each_entry(chan, &conn->chan_l, list) {
3071 if (chan->chan_type != L2CAP_CHAN_RAW)
3074 /* Don't send frame to the channel it came from */
3075 if (bt_cb(skb)->l2cap.chan == chan)
3078 nskb = skb_clone(skb, GFP_KERNEL);
3081 if (chan->ops->recv(chan, nskb))
3085 mutex_unlock(&conn->chan_lock);
3088 /* ---- L2CAP signalling commands ---- */
3089 static struct sk_buff *l2cap_build_cmd(struct l2cap_conn *conn, u8 code,
3090 u8 ident, u16 dlen, void *data)
3092 struct sk_buff *skb, **frag;
3093 struct l2cap_cmd_hdr *cmd;
3094 struct l2cap_hdr *lh;
3097 BT_DBG("conn %p, code 0x%2.2x, ident 0x%2.2x, len %u",
3098 conn, code, ident, dlen);
3100 if (conn->mtu < L2CAP_HDR_SIZE + L2CAP_CMD_HDR_SIZE)
3103 len = L2CAP_HDR_SIZE + L2CAP_CMD_HDR_SIZE + dlen;
3104 count = min_t(unsigned int, conn->mtu, len);
3106 skb = bt_skb_alloc(count, GFP_KERNEL);
3110 lh = skb_put(skb, L2CAP_HDR_SIZE);
3111 lh->len = cpu_to_le16(L2CAP_CMD_HDR_SIZE + dlen);
3113 if (conn->hcon->type == LE_LINK)
3114 lh->cid = cpu_to_le16(L2CAP_CID_LE_SIGNALING);
3116 lh->cid = cpu_to_le16(L2CAP_CID_SIGNALING);
3118 cmd = skb_put(skb, L2CAP_CMD_HDR_SIZE);
3121 cmd->len = cpu_to_le16(dlen);
3124 count -= L2CAP_HDR_SIZE + L2CAP_CMD_HDR_SIZE;
3125 skb_put_data(skb, data, count);
3131 /* Continuation fragments (no L2CAP header) */
3132 frag = &skb_shinfo(skb)->frag_list;
3134 count = min_t(unsigned int, conn->mtu, len);
3136 *frag = bt_skb_alloc(count, GFP_KERNEL);
3140 skb_put_data(*frag, data, count);
3145 frag = &(*frag)->next;
3155 static inline int l2cap_get_conf_opt(void **ptr, int *type, int *olen,
3158 struct l2cap_conf_opt *opt = *ptr;
3161 len = L2CAP_CONF_OPT_SIZE + opt->len;
3169 *val = *((u8 *) opt->val);
3173 *val = get_unaligned_le16(opt->val);
3177 *val = get_unaligned_le32(opt->val);
3181 *val = (unsigned long) opt->val;
3185 BT_DBG("type 0x%2.2x len %u val 0x%lx", *type, opt->len, *val);
3189 static void l2cap_add_conf_opt(void **ptr, u8 type, u8 len, unsigned long val, size_t size)
3191 struct l2cap_conf_opt *opt = *ptr;
3193 BT_DBG("type 0x%2.2x len %u val 0x%lx", type, len, val);
3195 if (size < L2CAP_CONF_OPT_SIZE + len)
3203 *((u8 *) opt->val) = val;
3207 put_unaligned_le16(val, opt->val);
3211 put_unaligned_le32(val, opt->val);
3215 memcpy(opt->val, (void *) val, len);
3219 *ptr += L2CAP_CONF_OPT_SIZE + len;
3222 static void l2cap_add_opt_efs(void **ptr, struct l2cap_chan *chan, size_t size)
3224 struct l2cap_conf_efs efs;
3226 switch (chan->mode) {
3227 case L2CAP_MODE_ERTM:
3228 efs.id = chan->local_id;
3229 efs.stype = chan->local_stype;
3230 efs.msdu = cpu_to_le16(chan->local_msdu);
3231 efs.sdu_itime = cpu_to_le32(chan->local_sdu_itime);
3232 efs.acc_lat = cpu_to_le32(L2CAP_DEFAULT_ACC_LAT);
3233 efs.flush_to = cpu_to_le32(L2CAP_EFS_DEFAULT_FLUSH_TO);
3236 case L2CAP_MODE_STREAMING:
3238 efs.stype = L2CAP_SERV_BESTEFFORT;
3239 efs.msdu = cpu_to_le16(chan->local_msdu);
3240 efs.sdu_itime = cpu_to_le32(chan->local_sdu_itime);
3249 l2cap_add_conf_opt(ptr, L2CAP_CONF_EFS, sizeof(efs),
3250 (unsigned long) &efs, size);
3253 static void l2cap_ack_timeout(struct work_struct *work)
3255 struct l2cap_chan *chan = container_of(work, struct l2cap_chan,
3259 BT_DBG("chan %p", chan);
3261 l2cap_chan_lock(chan);
3263 frames_to_ack = __seq_offset(chan, chan->buffer_seq,
3264 chan->last_acked_seq);
3267 l2cap_send_rr_or_rnr(chan, 0);
3269 l2cap_chan_unlock(chan);
3270 l2cap_chan_put(chan);
3273 int l2cap_ertm_init(struct l2cap_chan *chan)
3277 chan->next_tx_seq = 0;
3278 chan->expected_tx_seq = 0;
3279 chan->expected_ack_seq = 0;
3280 chan->unacked_frames = 0;
3281 chan->buffer_seq = 0;
3282 chan->frames_sent = 0;
3283 chan->last_acked_seq = 0;
3285 chan->sdu_last_frag = NULL;
3288 skb_queue_head_init(&chan->tx_q);
3290 chan->local_amp_id = AMP_ID_BREDR;
3291 chan->move_id = AMP_ID_BREDR;
3292 chan->move_state = L2CAP_MOVE_STABLE;
3293 chan->move_role = L2CAP_MOVE_ROLE_NONE;
3295 if (chan->mode != L2CAP_MODE_ERTM)
3298 chan->rx_state = L2CAP_RX_STATE_RECV;
3299 chan->tx_state = L2CAP_TX_STATE_XMIT;
3301 skb_queue_head_init(&chan->srej_q);
3303 err = l2cap_seq_list_init(&chan->srej_list, chan->tx_win);
3307 err = l2cap_seq_list_init(&chan->retrans_list, chan->remote_tx_win);
3309 l2cap_seq_list_free(&chan->srej_list);
3314 static inline __u8 l2cap_select_mode(__u8 mode, __u16 remote_feat_mask)
3317 case L2CAP_MODE_STREAMING:
3318 case L2CAP_MODE_ERTM:
3319 if (l2cap_mode_supported(mode, remote_feat_mask))
3323 return L2CAP_MODE_BASIC;
3327 static inline bool __l2cap_ews_supported(struct l2cap_conn *conn)
3329 return ((conn->local_fixed_chan & L2CAP_FC_A2MP) &&
3330 (conn->feat_mask & L2CAP_FEAT_EXT_WINDOW));
3333 static inline bool __l2cap_efs_supported(struct l2cap_conn *conn)
3335 return ((conn->local_fixed_chan & L2CAP_FC_A2MP) &&
3336 (conn->feat_mask & L2CAP_FEAT_EXT_FLOW));
3339 static void __l2cap_set_ertm_timeouts(struct l2cap_chan *chan,
3340 struct l2cap_conf_rfc *rfc)
3342 if (chan->local_amp_id != AMP_ID_BREDR && chan->hs_hcon) {
3343 u64 ertm_to = chan->hs_hcon->hdev->amp_be_flush_to;
3345 /* Class 1 devices have must have ERTM timeouts
3346 * exceeding the Link Supervision Timeout. The
3347 * default Link Supervision Timeout for AMP
3348 * controllers is 10 seconds.
3350 * Class 1 devices use 0xffffffff for their
3351 * best-effort flush timeout, so the clamping logic
3352 * will result in a timeout that meets the above
3353 * requirement. ERTM timeouts are 16-bit values, so
3354 * the maximum timeout is 65.535 seconds.
3357 /* Convert timeout to milliseconds and round */
3358 ertm_to = DIV_ROUND_UP_ULL(ertm_to, 1000);
3360 /* This is the recommended formula for class 2 devices
3361 * that start ERTM timers when packets are sent to the
3364 ertm_to = 3 * ertm_to + 500;
3366 if (ertm_to > 0xffff)
3369 rfc->retrans_timeout = cpu_to_le16((u16) ertm_to);
3370 rfc->monitor_timeout = rfc->retrans_timeout;
3372 rfc->retrans_timeout = cpu_to_le16(L2CAP_DEFAULT_RETRANS_TO);
3373 rfc->monitor_timeout = cpu_to_le16(L2CAP_DEFAULT_MONITOR_TO);
3377 static inline void l2cap_txwin_setup(struct l2cap_chan *chan)
3379 if (chan->tx_win > L2CAP_DEFAULT_TX_WINDOW &&
3380 __l2cap_ews_supported(chan->conn)) {
3381 /* use extended control field */
3382 set_bit(FLAG_EXT_CTRL, &chan->flags);
3383 chan->tx_win_max = L2CAP_DEFAULT_EXT_WINDOW;
3385 chan->tx_win = min_t(u16, chan->tx_win,
3386 L2CAP_DEFAULT_TX_WINDOW);
3387 chan->tx_win_max = L2CAP_DEFAULT_TX_WINDOW;
3389 chan->ack_win = chan->tx_win;
3392 static void l2cap_mtu_auto(struct l2cap_chan *chan)
3394 struct hci_conn *conn = chan->conn->hcon;
3396 chan->imtu = L2CAP_DEFAULT_MIN_MTU;
3398 /* The 2-DH1 packet has between 2 and 56 information bytes
3399 * (including the 2-byte payload header)
3401 if (!(conn->pkt_type & HCI_2DH1))
3404 /* The 3-DH1 packet has between 2 and 85 information bytes
3405 * (including the 2-byte payload header)
3407 if (!(conn->pkt_type & HCI_3DH1))
3410 /* The 2-DH3 packet has between 2 and 369 information bytes
3411 * (including the 2-byte payload header)
3413 if (!(conn->pkt_type & HCI_2DH3))
3416 /* The 3-DH3 packet has between 2 and 554 information bytes
3417 * (including the 2-byte payload header)
3419 if (!(conn->pkt_type & HCI_3DH3))
3422 /* The 2-DH5 packet has between 2 and 681 information bytes
3423 * (including the 2-byte payload header)
3425 if (!(conn->pkt_type & HCI_2DH5))
3428 /* The 3-DH5 packet has between 2 and 1023 information bytes
3429 * (including the 2-byte payload header)
3431 if (!(conn->pkt_type & HCI_3DH5))
3435 static int l2cap_build_conf_req(struct l2cap_chan *chan, void *data, size_t data_size)
3437 struct l2cap_conf_req *req = data;
3438 struct l2cap_conf_rfc rfc = { .mode = chan->mode };
3439 void *ptr = req->data;
3440 void *endptr = data + data_size;
3443 BT_DBG("chan %p", chan);
3445 if (chan->num_conf_req || chan->num_conf_rsp)
3448 switch (chan->mode) {
3449 case L2CAP_MODE_STREAMING:
3450 case L2CAP_MODE_ERTM:
3451 if (test_bit(CONF_STATE2_DEVICE, &chan->conf_state))
3454 if (__l2cap_efs_supported(chan->conn))
3455 set_bit(FLAG_EFS_ENABLE, &chan->flags);
3459 chan->mode = l2cap_select_mode(rfc.mode, chan->conn->feat_mask);
3464 if (chan->imtu != L2CAP_DEFAULT_MTU) {
3466 l2cap_mtu_auto(chan);
3467 l2cap_add_conf_opt(&ptr, L2CAP_CONF_MTU, 2, chan->imtu,
3471 switch (chan->mode) {
3472 case L2CAP_MODE_BASIC:
3476 if (!(chan->conn->feat_mask & L2CAP_FEAT_ERTM) &&
3477 !(chan->conn->feat_mask & L2CAP_FEAT_STREAMING))
3480 rfc.mode = L2CAP_MODE_BASIC;
3482 rfc.max_transmit = 0;
3483 rfc.retrans_timeout = 0;
3484 rfc.monitor_timeout = 0;
3485 rfc.max_pdu_size = 0;
3487 l2cap_add_conf_opt(&ptr, L2CAP_CONF_RFC, sizeof(rfc),
3488 (unsigned long) &rfc, endptr - ptr);
3491 case L2CAP_MODE_ERTM:
3492 rfc.mode = L2CAP_MODE_ERTM;
3493 rfc.max_transmit = chan->max_tx;
3495 __l2cap_set_ertm_timeouts(chan, &rfc);
3497 size = min_t(u16, L2CAP_DEFAULT_MAX_PDU_SIZE, chan->conn->mtu -
3498 L2CAP_EXT_HDR_SIZE - L2CAP_SDULEN_SIZE -
3500 rfc.max_pdu_size = cpu_to_le16(size);
3502 l2cap_txwin_setup(chan);
3504 rfc.txwin_size = min_t(u16, chan->tx_win,
3505 L2CAP_DEFAULT_TX_WINDOW);
3507 l2cap_add_conf_opt(&ptr, L2CAP_CONF_RFC, sizeof(rfc),
3508 (unsigned long) &rfc, endptr - ptr);
3510 if (test_bit(FLAG_EFS_ENABLE, &chan->flags))
3511 l2cap_add_opt_efs(&ptr, chan, endptr - ptr);
3513 if (test_bit(FLAG_EXT_CTRL, &chan->flags))
3514 l2cap_add_conf_opt(&ptr, L2CAP_CONF_EWS, 2,
3515 chan->tx_win, endptr - ptr);
3517 if (chan->conn->feat_mask & L2CAP_FEAT_FCS)
3518 if (chan->fcs == L2CAP_FCS_NONE ||
3519 test_bit(CONF_RECV_NO_FCS, &chan->conf_state)) {
3520 chan->fcs = L2CAP_FCS_NONE;
3521 l2cap_add_conf_opt(&ptr, L2CAP_CONF_FCS, 1,
3522 chan->fcs, endptr - ptr);
3526 case L2CAP_MODE_STREAMING:
3527 l2cap_txwin_setup(chan);
3528 rfc.mode = L2CAP_MODE_STREAMING;
3530 rfc.max_transmit = 0;
3531 rfc.retrans_timeout = 0;
3532 rfc.monitor_timeout = 0;
3534 size = min_t(u16, L2CAP_DEFAULT_MAX_PDU_SIZE, chan->conn->mtu -
3535 L2CAP_EXT_HDR_SIZE - L2CAP_SDULEN_SIZE -
3537 rfc.max_pdu_size = cpu_to_le16(size);
3539 l2cap_add_conf_opt(&ptr, L2CAP_CONF_RFC, sizeof(rfc),
3540 (unsigned long) &rfc, endptr - ptr);
3542 if (test_bit(FLAG_EFS_ENABLE, &chan->flags))
3543 l2cap_add_opt_efs(&ptr, chan, endptr - ptr);
3545 if (chan->conn->feat_mask & L2CAP_FEAT_FCS)
3546 if (chan->fcs == L2CAP_FCS_NONE ||
3547 test_bit(CONF_RECV_NO_FCS, &chan->conf_state)) {
3548 chan->fcs = L2CAP_FCS_NONE;
3549 l2cap_add_conf_opt(&ptr, L2CAP_CONF_FCS, 1,
3550 chan->fcs, endptr - ptr);
3555 req->dcid = cpu_to_le16(chan->dcid);
3556 req->flags = cpu_to_le16(0);
3561 static int l2cap_parse_conf_req(struct l2cap_chan *chan, void *data, size_t data_size)
3563 struct l2cap_conf_rsp *rsp = data;
3564 void *ptr = rsp->data;
3565 void *endptr = data + data_size;
3566 void *req = chan->conf_req;
3567 int len = chan->conf_len;
3568 int type, hint, olen;
3570 struct l2cap_conf_rfc rfc = { .mode = L2CAP_MODE_BASIC };
3571 struct l2cap_conf_efs efs;
3573 u16 mtu = L2CAP_DEFAULT_MTU;
3574 u16 result = L2CAP_CONF_SUCCESS;
3577 BT_DBG("chan %p", chan);
3579 while (len >= L2CAP_CONF_OPT_SIZE) {
3580 len -= l2cap_get_conf_opt(&req, &type, &olen, &val);
3584 hint = type & L2CAP_CONF_HINT;
3585 type &= L2CAP_CONF_MASK;
3588 case L2CAP_CONF_MTU:
3594 case L2CAP_CONF_FLUSH_TO:
3597 chan->flush_to = val;
3600 case L2CAP_CONF_QOS:
3603 case L2CAP_CONF_RFC:
3604 if (olen != sizeof(rfc))
3606 memcpy(&rfc, (void *) val, olen);
3609 case L2CAP_CONF_FCS:
3612 if (val == L2CAP_FCS_NONE)
3613 set_bit(CONF_RECV_NO_FCS, &chan->conf_state);
3616 case L2CAP_CONF_EFS:
3617 if (olen != sizeof(efs))
3620 memcpy(&efs, (void *) val, olen);
3623 case L2CAP_CONF_EWS:
3626 if (!(chan->conn->local_fixed_chan & L2CAP_FC_A2MP))
3627 return -ECONNREFUSED;
3628 set_bit(FLAG_EXT_CTRL, &chan->flags);
3629 set_bit(CONF_EWS_RECV, &chan->conf_state);
3630 chan->tx_win_max = L2CAP_DEFAULT_EXT_WINDOW;
3631 chan->remote_tx_win = val;
3637 result = L2CAP_CONF_UNKNOWN;
3638 l2cap_add_conf_opt(&ptr, (u8)type, sizeof(u8), type, endptr - ptr);
3643 if (chan->num_conf_rsp || chan->num_conf_req > 1)
3646 switch (chan->mode) {
3647 case L2CAP_MODE_STREAMING:
3648 case L2CAP_MODE_ERTM:
3649 if (!test_bit(CONF_STATE2_DEVICE, &chan->conf_state)) {
3650 chan->mode = l2cap_select_mode(rfc.mode,
3651 chan->conn->feat_mask);
3656 if (__l2cap_efs_supported(chan->conn))
3657 set_bit(FLAG_EFS_ENABLE, &chan->flags);
3659 return -ECONNREFUSED;
3662 if (chan->mode != rfc.mode)
3663 return -ECONNREFUSED;
3669 if (chan->mode != rfc.mode) {
3670 result = L2CAP_CONF_UNACCEPT;
3671 rfc.mode = chan->mode;
3673 if (chan->num_conf_rsp == 1)
3674 return -ECONNREFUSED;
3676 l2cap_add_conf_opt(&ptr, L2CAP_CONF_RFC, sizeof(rfc),
3677 (unsigned long) &rfc, endptr - ptr);
3680 if (result == L2CAP_CONF_SUCCESS) {
3681 /* Configure output options and let the other side know
3682 * which ones we don't like. */
3684 if (mtu < L2CAP_DEFAULT_MIN_MTU)
3685 result = L2CAP_CONF_UNACCEPT;
3688 set_bit(CONF_MTU_DONE, &chan->conf_state);
3690 l2cap_add_conf_opt(&ptr, L2CAP_CONF_MTU, 2, chan->omtu, endptr - ptr);
3693 if (chan->local_stype != L2CAP_SERV_NOTRAFIC &&
3694 efs.stype != L2CAP_SERV_NOTRAFIC &&
3695 efs.stype != chan->local_stype) {
3697 result = L2CAP_CONF_UNACCEPT;
3699 if (chan->num_conf_req >= 1)
3700 return -ECONNREFUSED;
3702 l2cap_add_conf_opt(&ptr, L2CAP_CONF_EFS,
3704 (unsigned long) &efs, endptr - ptr);
3706 /* Send PENDING Conf Rsp */
3707 result = L2CAP_CONF_PENDING;
3708 set_bit(CONF_LOC_CONF_PEND, &chan->conf_state);
3713 case L2CAP_MODE_BASIC:
3714 chan->fcs = L2CAP_FCS_NONE;
3715 set_bit(CONF_MODE_DONE, &chan->conf_state);
3718 case L2CAP_MODE_ERTM:
3719 if (!test_bit(CONF_EWS_RECV, &chan->conf_state))
3720 chan->remote_tx_win = rfc.txwin_size;
3722 rfc.txwin_size = L2CAP_DEFAULT_TX_WINDOW;
3724 chan->remote_max_tx = rfc.max_transmit;
3726 size = min_t(u16, le16_to_cpu(rfc.max_pdu_size),
3727 chan->conn->mtu - L2CAP_EXT_HDR_SIZE -
3728 L2CAP_SDULEN_SIZE - L2CAP_FCS_SIZE);
3729 rfc.max_pdu_size = cpu_to_le16(size);
3730 chan->remote_mps = size;
3732 __l2cap_set_ertm_timeouts(chan, &rfc);
3734 set_bit(CONF_MODE_DONE, &chan->conf_state);
3736 l2cap_add_conf_opt(&ptr, L2CAP_CONF_RFC,
3737 sizeof(rfc), (unsigned long) &rfc, endptr - ptr);
3740 test_bit(FLAG_EFS_ENABLE, &chan->flags)) {
3741 chan->remote_id = efs.id;
3742 chan->remote_stype = efs.stype;
3743 chan->remote_msdu = le16_to_cpu(efs.msdu);
3744 chan->remote_flush_to =
3745 le32_to_cpu(efs.flush_to);
3746 chan->remote_acc_lat =
3747 le32_to_cpu(efs.acc_lat);
3748 chan->remote_sdu_itime =
3749 le32_to_cpu(efs.sdu_itime);
3750 l2cap_add_conf_opt(&ptr, L2CAP_CONF_EFS,
3752 (unsigned long) &efs, endptr - ptr);
3756 case L2CAP_MODE_STREAMING:
3757 size = min_t(u16, le16_to_cpu(rfc.max_pdu_size),
3758 chan->conn->mtu - L2CAP_EXT_HDR_SIZE -
3759 L2CAP_SDULEN_SIZE - L2CAP_FCS_SIZE);
3760 rfc.max_pdu_size = cpu_to_le16(size);
3761 chan->remote_mps = size;
3763 set_bit(CONF_MODE_DONE, &chan->conf_state);
3765 l2cap_add_conf_opt(&ptr, L2CAP_CONF_RFC, sizeof(rfc),
3766 (unsigned long) &rfc, endptr - ptr);
3771 result = L2CAP_CONF_UNACCEPT;
3773 memset(&rfc, 0, sizeof(rfc));
3774 rfc.mode = chan->mode;
3777 if (result == L2CAP_CONF_SUCCESS)
3778 set_bit(CONF_OUTPUT_DONE, &chan->conf_state);
3780 rsp->scid = cpu_to_le16(chan->dcid);
3781 rsp->result = cpu_to_le16(result);
3782 rsp->flags = cpu_to_le16(0);
3787 static int l2cap_parse_conf_rsp(struct l2cap_chan *chan, void *rsp, int len,
3788 void *data, size_t size, u16 *result)
3790 struct l2cap_conf_req *req = data;
3791 void *ptr = req->data;
3792 void *endptr = data + size;
3795 struct l2cap_conf_rfc rfc = { .mode = L2CAP_MODE_BASIC };
3796 struct l2cap_conf_efs efs;
3798 BT_DBG("chan %p, rsp %p, len %d, req %p", chan, rsp, len, data);
3800 while (len >= L2CAP_CONF_OPT_SIZE) {
3801 len -= l2cap_get_conf_opt(&rsp, &type, &olen, &val);
3806 case L2CAP_CONF_MTU:
3809 if (val < L2CAP_DEFAULT_MIN_MTU) {
3810 *result = L2CAP_CONF_UNACCEPT;
3811 chan->imtu = L2CAP_DEFAULT_MIN_MTU;
3814 l2cap_add_conf_opt(&ptr, L2CAP_CONF_MTU, 2, chan->imtu,
3818 case L2CAP_CONF_FLUSH_TO:
3821 chan->flush_to = val;
3822 l2cap_add_conf_opt(&ptr, L2CAP_CONF_FLUSH_TO, 2,
3823 chan->flush_to, endptr - ptr);
3826 case L2CAP_CONF_RFC:
3827 if (olen != sizeof(rfc))
3829 memcpy(&rfc, (void *)val, olen);
3830 if (test_bit(CONF_STATE2_DEVICE, &chan->conf_state) &&
3831 rfc.mode != chan->mode)
3832 return -ECONNREFUSED;
3834 l2cap_add_conf_opt(&ptr, L2CAP_CONF_RFC, sizeof(rfc),
3835 (unsigned long) &rfc, endptr - ptr);
3838 case L2CAP_CONF_EWS:
3841 chan->ack_win = min_t(u16, val, chan->ack_win);
3842 l2cap_add_conf_opt(&ptr, L2CAP_CONF_EWS, 2,
3843 chan->tx_win, endptr - ptr);
3846 case L2CAP_CONF_EFS:
3847 if (olen != sizeof(efs))
3849 memcpy(&efs, (void *)val, olen);
3850 if (chan->local_stype != L2CAP_SERV_NOTRAFIC &&
3851 efs.stype != L2CAP_SERV_NOTRAFIC &&
3852 efs.stype != chan->local_stype)
3853 return -ECONNREFUSED;
3854 l2cap_add_conf_opt(&ptr, L2CAP_CONF_EFS, sizeof(efs),
3855 (unsigned long) &efs, endptr - ptr);
3858 case L2CAP_CONF_FCS:
3861 if (*result == L2CAP_CONF_PENDING)
3862 if (val == L2CAP_FCS_NONE)
3863 set_bit(CONF_RECV_NO_FCS,
3869 if (chan->mode == L2CAP_MODE_BASIC && chan->mode != rfc.mode)
3870 return -ECONNREFUSED;
3872 chan->mode = rfc.mode;
3874 if (*result == L2CAP_CONF_SUCCESS || *result == L2CAP_CONF_PENDING) {
3876 case L2CAP_MODE_ERTM:
3877 chan->retrans_timeout = le16_to_cpu(rfc.retrans_timeout);
3878 chan->monitor_timeout = le16_to_cpu(rfc.monitor_timeout);
3879 chan->mps = le16_to_cpu(rfc.max_pdu_size);
3880 if (!test_bit(FLAG_EXT_CTRL, &chan->flags))
3881 chan->ack_win = min_t(u16, chan->ack_win,
3884 if (test_bit(FLAG_EFS_ENABLE, &chan->flags)) {
3885 chan->local_msdu = le16_to_cpu(efs.msdu);
3886 chan->local_sdu_itime =
3887 le32_to_cpu(efs.sdu_itime);
3888 chan->local_acc_lat = le32_to_cpu(efs.acc_lat);
3889 chan->local_flush_to =
3890 le32_to_cpu(efs.flush_to);
3894 case L2CAP_MODE_STREAMING:
3895 chan->mps = le16_to_cpu(rfc.max_pdu_size);
3899 req->dcid = cpu_to_le16(chan->dcid);
3900 req->flags = cpu_to_le16(0);
3905 static int l2cap_build_conf_rsp(struct l2cap_chan *chan, void *data,
3906 u16 result, u16 flags)
3908 struct l2cap_conf_rsp *rsp = data;
3909 void *ptr = rsp->data;
3911 BT_DBG("chan %p", chan);
3913 rsp->scid = cpu_to_le16(chan->dcid);
3914 rsp->result = cpu_to_le16(result);
3915 rsp->flags = cpu_to_le16(flags);
3920 void __l2cap_le_connect_rsp_defer(struct l2cap_chan *chan)
3922 struct l2cap_le_conn_rsp rsp;
3923 struct l2cap_conn *conn = chan->conn;
3925 BT_DBG("chan %p", chan);
3927 rsp.dcid = cpu_to_le16(chan->scid);
3928 rsp.mtu = cpu_to_le16(chan->imtu);
3929 rsp.mps = cpu_to_le16(chan->mps);
3930 rsp.credits = cpu_to_le16(chan->rx_credits);
3931 rsp.result = cpu_to_le16(L2CAP_CR_LE_SUCCESS);
3933 l2cap_send_cmd(conn, chan->ident, L2CAP_LE_CONN_RSP, sizeof(rsp),
3937 static void l2cap_ecred_list_defer(struct l2cap_chan *chan, void *data)
3941 if (*result || test_bit(FLAG_ECRED_CONN_REQ_SENT, &chan->flags))
3944 switch (chan->state) {
3946 /* If channel still pending accept add to result */
3952 /* If not connected or pending accept it has been refused */
3953 *result = -ECONNREFUSED;
3958 struct l2cap_ecred_rsp_data {
3960 struct l2cap_ecred_conn_rsp rsp;
3961 __le16 scid[L2CAP_ECRED_MAX_CID];
3966 static void l2cap_ecred_rsp_defer(struct l2cap_chan *chan, void *data)
3968 struct l2cap_ecred_rsp_data *rsp = data;
3970 if (test_bit(FLAG_ECRED_CONN_REQ_SENT, &chan->flags))
3973 /* Reset ident so only one response is sent */
3976 /* Include all channels pending with the same ident */
3977 if (!rsp->pdu.rsp.result)
3978 rsp->pdu.rsp.dcid[rsp->count++] = cpu_to_le16(chan->scid);
3980 l2cap_chan_del(chan, ECONNRESET);
3983 void __l2cap_ecred_conn_rsp_defer(struct l2cap_chan *chan)
3985 struct l2cap_conn *conn = chan->conn;
3986 struct l2cap_ecred_rsp_data data;
3987 u16 id = chan->ident;
3993 BT_DBG("chan %p id %d", chan, id);
3995 memset(&data, 0, sizeof(data));
3997 data.pdu.rsp.mtu = cpu_to_le16(chan->imtu);
3998 data.pdu.rsp.mps = cpu_to_le16(chan->mps);
3999 data.pdu.rsp.credits = cpu_to_le16(chan->rx_credits);
4000 data.pdu.rsp.result = cpu_to_le16(L2CAP_CR_LE_SUCCESS);
4002 /* Verify that all channels are ready */
4003 __l2cap_chan_list_id(conn, id, l2cap_ecred_list_defer, &result);
4009 data.pdu.rsp.result = cpu_to_le16(L2CAP_CR_LE_AUTHORIZATION);
4011 /* Build response */
4012 __l2cap_chan_list_id(conn, id, l2cap_ecred_rsp_defer, &data);
4014 l2cap_send_cmd(conn, id, L2CAP_ECRED_CONN_RSP,
4015 sizeof(data.pdu.rsp) + (data.count * sizeof(__le16)),
4019 void __l2cap_connect_rsp_defer(struct l2cap_chan *chan)
4021 struct l2cap_conn_rsp rsp;
4022 struct l2cap_conn *conn = chan->conn;
4026 rsp.scid = cpu_to_le16(chan->dcid);
4027 rsp.dcid = cpu_to_le16(chan->scid);
4028 rsp.result = cpu_to_le16(L2CAP_CR_SUCCESS);
4029 rsp.status = cpu_to_le16(L2CAP_CS_NO_INFO);
4032 rsp_code = L2CAP_CREATE_CHAN_RSP;
4034 rsp_code = L2CAP_CONN_RSP;
4036 BT_DBG("chan %p rsp_code %u", chan, rsp_code);
4038 l2cap_send_cmd(conn, chan->ident, rsp_code, sizeof(rsp), &rsp);
4040 if (test_and_set_bit(CONF_REQ_SENT, &chan->conf_state))
4043 l2cap_send_cmd(conn, l2cap_get_ident(conn), L2CAP_CONF_REQ,
4044 l2cap_build_conf_req(chan, buf, sizeof(buf)), buf);
4045 chan->num_conf_req++;
4048 static void l2cap_conf_rfc_get(struct l2cap_chan *chan, void *rsp, int len)
4052 /* Use sane default values in case a misbehaving remote device
4053 * did not send an RFC or extended window size option.
4055 u16 txwin_ext = chan->ack_win;
4056 struct l2cap_conf_rfc rfc = {
4058 .retrans_timeout = cpu_to_le16(L2CAP_DEFAULT_RETRANS_TO),
4059 .monitor_timeout = cpu_to_le16(L2CAP_DEFAULT_MONITOR_TO),
4060 .max_pdu_size = cpu_to_le16(chan->imtu),
4061 .txwin_size = min_t(u16, chan->ack_win, L2CAP_DEFAULT_TX_WINDOW),
4064 BT_DBG("chan %p, rsp %p, len %d", chan, rsp, len);
4066 if ((chan->mode != L2CAP_MODE_ERTM) && (chan->mode != L2CAP_MODE_STREAMING))
4069 while (len >= L2CAP_CONF_OPT_SIZE) {
4070 len -= l2cap_get_conf_opt(&rsp, &type, &olen, &val);
4075 case L2CAP_CONF_RFC:
4076 if (olen != sizeof(rfc))
4078 memcpy(&rfc, (void *)val, olen);
4080 case L2CAP_CONF_EWS:
4089 case L2CAP_MODE_ERTM:
4090 chan->retrans_timeout = le16_to_cpu(rfc.retrans_timeout);
4091 chan->monitor_timeout = le16_to_cpu(rfc.monitor_timeout);
4092 chan->mps = le16_to_cpu(rfc.max_pdu_size);
4093 if (test_bit(FLAG_EXT_CTRL, &chan->flags))
4094 chan->ack_win = min_t(u16, chan->ack_win, txwin_ext);
4096 chan->ack_win = min_t(u16, chan->ack_win,
4099 case L2CAP_MODE_STREAMING:
4100 chan->mps = le16_to_cpu(rfc.max_pdu_size);
4104 static inline int l2cap_command_rej(struct l2cap_conn *conn,
4105 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
4108 struct l2cap_cmd_rej_unk *rej = (struct l2cap_cmd_rej_unk *) data;
4110 if (cmd_len < sizeof(*rej))
4113 if (rej->reason != L2CAP_REJ_NOT_UNDERSTOOD)
4116 if ((conn->info_state & L2CAP_INFO_FEAT_MASK_REQ_SENT) &&
4117 cmd->ident == conn->info_ident) {
4118 cancel_delayed_work(&conn->info_timer);
4120 conn->info_state |= L2CAP_INFO_FEAT_MASK_REQ_DONE;
4121 conn->info_ident = 0;
4123 l2cap_conn_start(conn);
4129 static struct l2cap_chan *l2cap_connect(struct l2cap_conn *conn,
4130 struct l2cap_cmd_hdr *cmd,
4131 u8 *data, u8 rsp_code, u8 amp_id)
4133 struct l2cap_conn_req *req = (struct l2cap_conn_req *) data;
4134 struct l2cap_conn_rsp rsp;
4135 struct l2cap_chan *chan = NULL, *pchan;
4136 int result, status = L2CAP_CS_NO_INFO;
4138 u16 dcid = 0, scid = __le16_to_cpu(req->scid);
4139 __le16 psm = req->psm;
4141 BT_DBG("psm 0x%2.2x scid 0x%4.4x", __le16_to_cpu(psm), scid);
4143 /* Check if we have socket listening on psm */
4144 pchan = l2cap_global_chan_by_psm(BT_LISTEN, psm, &conn->hcon->src,
4145 &conn->hcon->dst, ACL_LINK);
4147 result = L2CAP_CR_BAD_PSM;
4151 mutex_lock(&conn->chan_lock);
4152 l2cap_chan_lock(pchan);
4154 /* Check if the ACL is secure enough (if not SDP) */
4155 if (psm != cpu_to_le16(L2CAP_PSM_SDP) &&
4156 !hci_conn_check_link_mode(conn->hcon)) {
4157 conn->disc_reason = HCI_ERROR_AUTH_FAILURE;
4158 result = L2CAP_CR_SEC_BLOCK;
4162 result = L2CAP_CR_NO_MEM;
4164 /* Check for valid dynamic CID range (as per Erratum 3253) */
4165 if (scid < L2CAP_CID_DYN_START || scid > L2CAP_CID_DYN_END) {
4166 result = L2CAP_CR_INVALID_SCID;
4170 /* Check if we already have channel with that dcid */
4171 if (__l2cap_get_chan_by_dcid(conn, scid)) {
4172 result = L2CAP_CR_SCID_IN_USE;
4176 chan = pchan->ops->new_connection(pchan);
4180 /* For certain devices (ex: HID mouse), support for authentication,
4181 * pairing and bonding is optional. For such devices, inorder to avoid
4182 * the ACL alive for too long after L2CAP disconnection, reset the ACL
4183 * disc_timeout back to HCI_DISCONN_TIMEOUT during L2CAP connect.
4185 conn->hcon->disc_timeout = HCI_DISCONN_TIMEOUT;
4187 bacpy(&chan->src, &conn->hcon->src);
4188 bacpy(&chan->dst, &conn->hcon->dst);
4189 chan->src_type = bdaddr_src_type(conn->hcon);
4190 chan->dst_type = bdaddr_dst_type(conn->hcon);
4193 chan->local_amp_id = amp_id;
4195 __l2cap_chan_add(conn, chan);
4199 __set_chan_timer(chan, chan->ops->get_sndtimeo(chan));
4201 chan->ident = cmd->ident;
4203 if (conn->info_state & L2CAP_INFO_FEAT_MASK_REQ_DONE) {
4204 if (l2cap_chan_check_security(chan, false)) {
4205 if (test_bit(FLAG_DEFER_SETUP, &chan->flags)) {
4206 l2cap_state_change(chan, BT_CONNECT2);
4207 result = L2CAP_CR_PEND;
4208 status = L2CAP_CS_AUTHOR_PEND;
4209 chan->ops->defer(chan);
4211 /* Force pending result for AMP controllers.
4212 * The connection will succeed after the
4213 * physical link is up.
4215 if (amp_id == AMP_ID_BREDR) {
4216 l2cap_state_change(chan, BT_CONFIG);
4217 result = L2CAP_CR_SUCCESS;
4219 l2cap_state_change(chan, BT_CONNECT2);
4220 result = L2CAP_CR_PEND;
4222 status = L2CAP_CS_NO_INFO;
4225 l2cap_state_change(chan, BT_CONNECT2);
4226 result = L2CAP_CR_PEND;
4227 status = L2CAP_CS_AUTHEN_PEND;
4230 l2cap_state_change(chan, BT_CONNECT2);
4231 result = L2CAP_CR_PEND;
4232 status = L2CAP_CS_NO_INFO;
4236 l2cap_chan_unlock(pchan);
4237 mutex_unlock(&conn->chan_lock);
4238 l2cap_chan_put(pchan);
4241 rsp.scid = cpu_to_le16(scid);
4242 rsp.dcid = cpu_to_le16(dcid);
4243 rsp.result = cpu_to_le16(result);
4244 rsp.status = cpu_to_le16(status);
4245 l2cap_send_cmd(conn, cmd->ident, rsp_code, sizeof(rsp), &rsp);
4247 if (result == L2CAP_CR_PEND && status == L2CAP_CS_NO_INFO) {
4248 struct l2cap_info_req info;
4249 info.type = cpu_to_le16(L2CAP_IT_FEAT_MASK);
4251 conn->info_state |= L2CAP_INFO_FEAT_MASK_REQ_SENT;
4252 conn->info_ident = l2cap_get_ident(conn);
4254 schedule_delayed_work(&conn->info_timer, L2CAP_INFO_TIMEOUT);
4256 l2cap_send_cmd(conn, conn->info_ident, L2CAP_INFO_REQ,
4257 sizeof(info), &info);
4260 if (chan && !test_bit(CONF_REQ_SENT, &chan->conf_state) &&
4261 result == L2CAP_CR_SUCCESS) {
4263 set_bit(CONF_REQ_SENT, &chan->conf_state);
4264 l2cap_send_cmd(conn, l2cap_get_ident(conn), L2CAP_CONF_REQ,
4265 l2cap_build_conf_req(chan, buf, sizeof(buf)), buf);
4266 chan->num_conf_req++;
4272 static int l2cap_connect_req(struct l2cap_conn *conn,
4273 struct l2cap_cmd_hdr *cmd, u16 cmd_len, u8 *data)
4275 struct hci_dev *hdev = conn->hcon->hdev;
4276 struct hci_conn *hcon = conn->hcon;
4278 if (cmd_len < sizeof(struct l2cap_conn_req))
4282 if (hci_dev_test_flag(hdev, HCI_MGMT) &&
4283 !test_and_set_bit(HCI_CONN_MGMT_CONNECTED, &hcon->flags))
4284 mgmt_device_connected(hdev, hcon, NULL, 0);
4285 hci_dev_unlock(hdev);
4287 l2cap_connect(conn, cmd, data, L2CAP_CONN_RSP, 0);
4291 static int l2cap_connect_create_rsp(struct l2cap_conn *conn,
4292 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
4295 struct l2cap_conn_rsp *rsp = (struct l2cap_conn_rsp *) data;
4296 u16 scid, dcid, result, status;
4297 struct l2cap_chan *chan;
4301 if (cmd_len < sizeof(*rsp))
4304 scid = __le16_to_cpu(rsp->scid);
4305 dcid = __le16_to_cpu(rsp->dcid);
4306 result = __le16_to_cpu(rsp->result);
4307 status = __le16_to_cpu(rsp->status);
4309 if (result == L2CAP_CR_SUCCESS && (dcid < L2CAP_CID_DYN_START ||
4310 dcid > L2CAP_CID_DYN_END))
4313 BT_DBG("dcid 0x%4.4x scid 0x%4.4x result 0x%2.2x status 0x%2.2x",
4314 dcid, scid, result, status);
4316 mutex_lock(&conn->chan_lock);
4319 chan = __l2cap_get_chan_by_scid(conn, scid);
4325 chan = __l2cap_get_chan_by_ident(conn, cmd->ident);
4332 chan = l2cap_chan_hold_unless_zero(chan);
4340 l2cap_chan_lock(chan);
4343 case L2CAP_CR_SUCCESS:
4344 if (__l2cap_get_chan_by_dcid(conn, dcid)) {
4349 l2cap_state_change(chan, BT_CONFIG);
4352 clear_bit(CONF_CONNECT_PEND, &chan->conf_state);
4354 if (test_and_set_bit(CONF_REQ_SENT, &chan->conf_state))
4357 l2cap_send_cmd(conn, l2cap_get_ident(conn), L2CAP_CONF_REQ,
4358 l2cap_build_conf_req(chan, req, sizeof(req)), req);
4359 chan->num_conf_req++;
4363 set_bit(CONF_CONNECT_PEND, &chan->conf_state);
4367 l2cap_chan_del(chan, ECONNREFUSED);
4371 l2cap_chan_unlock(chan);
4372 l2cap_chan_put(chan);
4375 mutex_unlock(&conn->chan_lock);
4380 static inline void set_default_fcs(struct l2cap_chan *chan)
4382 /* FCS is enabled only in ERTM or streaming mode, if one or both
4385 if (chan->mode != L2CAP_MODE_ERTM && chan->mode != L2CAP_MODE_STREAMING)
4386 chan->fcs = L2CAP_FCS_NONE;
4387 else if (!test_bit(CONF_RECV_NO_FCS, &chan->conf_state))
4388 chan->fcs = L2CAP_FCS_CRC16;
4391 static void l2cap_send_efs_conf_rsp(struct l2cap_chan *chan, void *data,
4392 u8 ident, u16 flags)
4394 struct l2cap_conn *conn = chan->conn;
4396 BT_DBG("conn %p chan %p ident %d flags 0x%4.4x", conn, chan, ident,
4399 clear_bit(CONF_LOC_CONF_PEND, &chan->conf_state);
4400 set_bit(CONF_OUTPUT_DONE, &chan->conf_state);
4402 l2cap_send_cmd(conn, ident, L2CAP_CONF_RSP,
4403 l2cap_build_conf_rsp(chan, data,
4404 L2CAP_CONF_SUCCESS, flags), data);
4407 static void cmd_reject_invalid_cid(struct l2cap_conn *conn, u8 ident,
4410 struct l2cap_cmd_rej_cid rej;
4412 rej.reason = cpu_to_le16(L2CAP_REJ_INVALID_CID);
4413 rej.scid = __cpu_to_le16(scid);
4414 rej.dcid = __cpu_to_le16(dcid);
4416 l2cap_send_cmd(conn, ident, L2CAP_COMMAND_REJ, sizeof(rej), &rej);
4419 static inline int l2cap_config_req(struct l2cap_conn *conn,
4420 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
4423 struct l2cap_conf_req *req = (struct l2cap_conf_req *) data;
4426 struct l2cap_chan *chan;
4429 if (cmd_len < sizeof(*req))
4432 dcid = __le16_to_cpu(req->dcid);
4433 flags = __le16_to_cpu(req->flags);
4435 BT_DBG("dcid 0x%4.4x flags 0x%2.2x", dcid, flags);
4437 chan = l2cap_get_chan_by_scid(conn, dcid);
4439 cmd_reject_invalid_cid(conn, cmd->ident, dcid, 0);
4443 if (chan->state != BT_CONFIG && chan->state != BT_CONNECT2 &&
4444 chan->state != BT_CONNECTED) {
4445 cmd_reject_invalid_cid(conn, cmd->ident, chan->scid,
4450 /* Reject if config buffer is too small. */
4451 len = cmd_len - sizeof(*req);
4452 if (chan->conf_len + len > sizeof(chan->conf_req)) {
4453 l2cap_send_cmd(conn, cmd->ident, L2CAP_CONF_RSP,
4454 l2cap_build_conf_rsp(chan, rsp,
4455 L2CAP_CONF_REJECT, flags), rsp);
4460 memcpy(chan->conf_req + chan->conf_len, req->data, len);
4461 chan->conf_len += len;
4463 if (flags & L2CAP_CONF_FLAG_CONTINUATION) {
4464 /* Incomplete config. Send empty response. */
4465 l2cap_send_cmd(conn, cmd->ident, L2CAP_CONF_RSP,
4466 l2cap_build_conf_rsp(chan, rsp,
4467 L2CAP_CONF_SUCCESS, flags), rsp);
4471 /* Complete config. */
4472 len = l2cap_parse_conf_req(chan, rsp, sizeof(rsp));
4474 l2cap_send_disconn_req(chan, ECONNRESET);
4478 chan->ident = cmd->ident;
4479 l2cap_send_cmd(conn, cmd->ident, L2CAP_CONF_RSP, len, rsp);
4480 if (chan->num_conf_rsp < L2CAP_CONF_MAX_CONF_RSP)
4481 chan->num_conf_rsp++;
4483 /* Reset config buffer. */
4486 if (!test_bit(CONF_OUTPUT_DONE, &chan->conf_state))
4489 if (test_bit(CONF_INPUT_DONE, &chan->conf_state)) {
4490 set_default_fcs(chan);
4492 if (chan->mode == L2CAP_MODE_ERTM ||
4493 chan->mode == L2CAP_MODE_STREAMING)
4494 err = l2cap_ertm_init(chan);
4497 l2cap_send_disconn_req(chan, -err);
4499 l2cap_chan_ready(chan);
4504 if (!test_and_set_bit(CONF_REQ_SENT, &chan->conf_state)) {
4506 l2cap_send_cmd(conn, l2cap_get_ident(conn), L2CAP_CONF_REQ,
4507 l2cap_build_conf_req(chan, buf, sizeof(buf)), buf);
4508 chan->num_conf_req++;
4511 /* Got Conf Rsp PENDING from remote side and assume we sent
4512 Conf Rsp PENDING in the code above */
4513 if (test_bit(CONF_REM_CONF_PEND, &chan->conf_state) &&
4514 test_bit(CONF_LOC_CONF_PEND, &chan->conf_state)) {
4516 /* check compatibility */
4518 /* Send rsp for BR/EDR channel */
4520 l2cap_send_efs_conf_rsp(chan, rsp, cmd->ident, flags);
4522 chan->ident = cmd->ident;
4526 l2cap_chan_unlock(chan);
4527 l2cap_chan_put(chan);
4531 static inline int l2cap_config_rsp(struct l2cap_conn *conn,
4532 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
4535 struct l2cap_conf_rsp *rsp = (struct l2cap_conf_rsp *)data;
4536 u16 scid, flags, result;
4537 struct l2cap_chan *chan;
4538 int len = cmd_len - sizeof(*rsp);
4541 if (cmd_len < sizeof(*rsp))
4544 scid = __le16_to_cpu(rsp->scid);
4545 flags = __le16_to_cpu(rsp->flags);
4546 result = __le16_to_cpu(rsp->result);
4548 BT_DBG("scid 0x%4.4x flags 0x%2.2x result 0x%2.2x len %d", scid, flags,
4551 chan = l2cap_get_chan_by_scid(conn, scid);
4556 case L2CAP_CONF_SUCCESS:
4557 l2cap_conf_rfc_get(chan, rsp->data, len);
4558 clear_bit(CONF_REM_CONF_PEND, &chan->conf_state);
4561 case L2CAP_CONF_PENDING:
4562 set_bit(CONF_REM_CONF_PEND, &chan->conf_state);
4564 if (test_bit(CONF_LOC_CONF_PEND, &chan->conf_state)) {
4567 len = l2cap_parse_conf_rsp(chan, rsp->data, len,
4568 buf, sizeof(buf), &result);
4570 l2cap_send_disconn_req(chan, ECONNRESET);
4574 if (!chan->hs_hcon) {
4575 l2cap_send_efs_conf_rsp(chan, buf, cmd->ident,
4578 if (l2cap_check_efs(chan)) {
4579 amp_create_logical_link(chan);
4580 chan->ident = cmd->ident;
4586 case L2CAP_CONF_UNKNOWN:
4587 case L2CAP_CONF_UNACCEPT:
4588 if (chan->num_conf_rsp <= L2CAP_CONF_MAX_CONF_RSP) {
4591 if (len > sizeof(req) - sizeof(struct l2cap_conf_req)) {
4592 l2cap_send_disconn_req(chan, ECONNRESET);
4596 /* throw out any old stored conf requests */
4597 result = L2CAP_CONF_SUCCESS;
4598 len = l2cap_parse_conf_rsp(chan, rsp->data, len,
4599 req, sizeof(req), &result);
4601 l2cap_send_disconn_req(chan, ECONNRESET);
4605 l2cap_send_cmd(conn, l2cap_get_ident(conn),
4606 L2CAP_CONF_REQ, len, req);
4607 chan->num_conf_req++;
4608 if (result != L2CAP_CONF_SUCCESS)
4615 l2cap_chan_set_err(chan, ECONNRESET);
4617 __set_chan_timer(chan, L2CAP_DISC_REJ_TIMEOUT);
4618 l2cap_send_disconn_req(chan, ECONNRESET);
4622 if (flags & L2CAP_CONF_FLAG_CONTINUATION)
4625 set_bit(CONF_INPUT_DONE, &chan->conf_state);
4627 if (test_bit(CONF_OUTPUT_DONE, &chan->conf_state)) {
4628 set_default_fcs(chan);
4630 if (chan->mode == L2CAP_MODE_ERTM ||
4631 chan->mode == L2CAP_MODE_STREAMING)
4632 err = l2cap_ertm_init(chan);
4635 l2cap_send_disconn_req(chan, -err);
4637 l2cap_chan_ready(chan);
4641 l2cap_chan_unlock(chan);
4642 l2cap_chan_put(chan);
4646 static inline int l2cap_disconnect_req(struct l2cap_conn *conn,
4647 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
4650 struct l2cap_disconn_req *req = (struct l2cap_disconn_req *) data;
4651 struct l2cap_disconn_rsp rsp;
4653 struct l2cap_chan *chan;
4655 if (cmd_len != sizeof(*req))
4658 scid = __le16_to_cpu(req->scid);
4659 dcid = __le16_to_cpu(req->dcid);
4661 BT_DBG("scid 0x%4.4x dcid 0x%4.4x", scid, dcid);
4663 chan = l2cap_get_chan_by_scid(conn, dcid);
4665 cmd_reject_invalid_cid(conn, cmd->ident, dcid, scid);
4669 rsp.dcid = cpu_to_le16(chan->scid);
4670 rsp.scid = cpu_to_le16(chan->dcid);
4671 l2cap_send_cmd(conn, cmd->ident, L2CAP_DISCONN_RSP, sizeof(rsp), &rsp);
4673 chan->ops->set_shutdown(chan);
4675 l2cap_chan_unlock(chan);
4676 mutex_lock(&conn->chan_lock);
4677 l2cap_chan_lock(chan);
4678 l2cap_chan_del(chan, ECONNRESET);
4679 mutex_unlock(&conn->chan_lock);
4681 chan->ops->close(chan);
4683 l2cap_chan_unlock(chan);
4684 l2cap_chan_put(chan);
4689 static inline int l2cap_disconnect_rsp(struct l2cap_conn *conn,
4690 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
4693 struct l2cap_disconn_rsp *rsp = (struct l2cap_disconn_rsp *) data;
4695 struct l2cap_chan *chan;
4697 if (cmd_len != sizeof(*rsp))
4700 scid = __le16_to_cpu(rsp->scid);
4701 dcid = __le16_to_cpu(rsp->dcid);
4703 BT_DBG("dcid 0x%4.4x scid 0x%4.4x", dcid, scid);
4705 chan = l2cap_get_chan_by_scid(conn, scid);
4710 if (chan->state != BT_DISCONN) {
4711 l2cap_chan_unlock(chan);
4712 l2cap_chan_put(chan);
4716 l2cap_chan_unlock(chan);
4717 mutex_lock(&conn->chan_lock);
4718 l2cap_chan_lock(chan);
4719 l2cap_chan_del(chan, 0);
4720 mutex_unlock(&conn->chan_lock);
4722 chan->ops->close(chan);
4724 l2cap_chan_unlock(chan);
4725 l2cap_chan_put(chan);
4730 static inline int l2cap_information_req(struct l2cap_conn *conn,
4731 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
4734 struct l2cap_info_req *req = (struct l2cap_info_req *) data;
4737 if (cmd_len != sizeof(*req))
4740 type = __le16_to_cpu(req->type);
4742 BT_DBG("type 0x%4.4x", type);
4744 if (type == L2CAP_IT_FEAT_MASK) {
4746 u32 feat_mask = l2cap_feat_mask;
4747 struct l2cap_info_rsp *rsp = (struct l2cap_info_rsp *) buf;
4748 rsp->type = cpu_to_le16(L2CAP_IT_FEAT_MASK);
4749 rsp->result = cpu_to_le16(L2CAP_IR_SUCCESS);
4751 feat_mask |= L2CAP_FEAT_ERTM | L2CAP_FEAT_STREAMING
4753 if (conn->local_fixed_chan & L2CAP_FC_A2MP)
4754 feat_mask |= L2CAP_FEAT_EXT_FLOW
4755 | L2CAP_FEAT_EXT_WINDOW;
4757 put_unaligned_le32(feat_mask, rsp->data);
4758 l2cap_send_cmd(conn, cmd->ident, L2CAP_INFO_RSP, sizeof(buf),
4760 } else if (type == L2CAP_IT_FIXED_CHAN) {
4762 struct l2cap_info_rsp *rsp = (struct l2cap_info_rsp *) buf;
4764 rsp->type = cpu_to_le16(L2CAP_IT_FIXED_CHAN);
4765 rsp->result = cpu_to_le16(L2CAP_IR_SUCCESS);
4766 rsp->data[0] = conn->local_fixed_chan;
4767 memset(rsp->data + 1, 0, 7);
4768 l2cap_send_cmd(conn, cmd->ident, L2CAP_INFO_RSP, sizeof(buf),
4771 struct l2cap_info_rsp rsp;
4772 rsp.type = cpu_to_le16(type);
4773 rsp.result = cpu_to_le16(L2CAP_IR_NOTSUPP);
4774 l2cap_send_cmd(conn, cmd->ident, L2CAP_INFO_RSP, sizeof(rsp),
4781 static inline int l2cap_information_rsp(struct l2cap_conn *conn,
4782 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
4785 struct l2cap_info_rsp *rsp = (struct l2cap_info_rsp *) data;
4788 if (cmd_len < sizeof(*rsp))
4791 type = __le16_to_cpu(rsp->type);
4792 result = __le16_to_cpu(rsp->result);
4794 BT_DBG("type 0x%4.4x result 0x%2.2x", type, result);
4796 /* L2CAP Info req/rsp are unbound to channels, add extra checks */
4797 if (cmd->ident != conn->info_ident ||
4798 conn->info_state & L2CAP_INFO_FEAT_MASK_REQ_DONE)
4801 cancel_delayed_work(&conn->info_timer);
4803 if (result != L2CAP_IR_SUCCESS) {
4804 conn->info_state |= L2CAP_INFO_FEAT_MASK_REQ_DONE;
4805 conn->info_ident = 0;
4807 l2cap_conn_start(conn);
4813 case L2CAP_IT_FEAT_MASK:
4814 conn->feat_mask = get_unaligned_le32(rsp->data);
4816 if (conn->feat_mask & L2CAP_FEAT_FIXED_CHAN) {
4817 struct l2cap_info_req req;
4818 req.type = cpu_to_le16(L2CAP_IT_FIXED_CHAN);
4820 conn->info_ident = l2cap_get_ident(conn);
4822 l2cap_send_cmd(conn, conn->info_ident,
4823 L2CAP_INFO_REQ, sizeof(req), &req);
4825 conn->info_state |= L2CAP_INFO_FEAT_MASK_REQ_DONE;
4826 conn->info_ident = 0;
4828 l2cap_conn_start(conn);
4832 case L2CAP_IT_FIXED_CHAN:
4833 conn->remote_fixed_chan = rsp->data[0];
4834 conn->info_state |= L2CAP_INFO_FEAT_MASK_REQ_DONE;
4835 conn->info_ident = 0;
4837 l2cap_conn_start(conn);
4844 static int l2cap_create_channel_req(struct l2cap_conn *conn,
4845 struct l2cap_cmd_hdr *cmd,
4846 u16 cmd_len, void *data)
4848 struct l2cap_create_chan_req *req = data;
4849 struct l2cap_create_chan_rsp rsp;
4850 struct l2cap_chan *chan;
4851 struct hci_dev *hdev;
4854 if (cmd_len != sizeof(*req))
4857 if (!(conn->local_fixed_chan & L2CAP_FC_A2MP))
4860 psm = le16_to_cpu(req->psm);
4861 scid = le16_to_cpu(req->scid);
4863 BT_DBG("psm 0x%2.2x, scid 0x%4.4x, amp_id %d", psm, scid, req->amp_id);
4865 /* For controller id 0 make BR/EDR connection */
4866 if (req->amp_id == AMP_ID_BREDR) {
4867 l2cap_connect(conn, cmd, data, L2CAP_CREATE_CHAN_RSP,
4872 /* Validate AMP controller id */
4873 hdev = hci_dev_get(req->amp_id);
4877 if (hdev->dev_type != HCI_AMP || !test_bit(HCI_UP, &hdev->flags)) {
4882 chan = l2cap_connect(conn, cmd, data, L2CAP_CREATE_CHAN_RSP,
4885 struct amp_mgr *mgr = conn->hcon->amp_mgr;
4886 struct hci_conn *hs_hcon;
4888 hs_hcon = hci_conn_hash_lookup_ba(hdev, AMP_LINK,
4892 cmd_reject_invalid_cid(conn, cmd->ident, chan->scid,
4897 BT_DBG("mgr %p bredr_chan %p hs_hcon %p", mgr, chan, hs_hcon);
4899 mgr->bredr_chan = chan;
4900 chan->hs_hcon = hs_hcon;
4901 chan->fcs = L2CAP_FCS_NONE;
4902 conn->mtu = hdev->block_mtu;
4911 rsp.scid = cpu_to_le16(scid);
4912 rsp.result = cpu_to_le16(L2CAP_CR_BAD_AMP);
4913 rsp.status = cpu_to_le16(L2CAP_CS_NO_INFO);
4915 l2cap_send_cmd(conn, cmd->ident, L2CAP_CREATE_CHAN_RSP,
4921 static void l2cap_send_move_chan_req(struct l2cap_chan *chan, u8 dest_amp_id)
4923 struct l2cap_move_chan_req req;
4926 BT_DBG("chan %p, dest_amp_id %d", chan, dest_amp_id);
4928 ident = l2cap_get_ident(chan->conn);
4929 chan->ident = ident;
4931 req.icid = cpu_to_le16(chan->scid);
4932 req.dest_amp_id = dest_amp_id;
4934 l2cap_send_cmd(chan->conn, ident, L2CAP_MOVE_CHAN_REQ, sizeof(req),
4937 __set_chan_timer(chan, L2CAP_MOVE_TIMEOUT);
4940 static void l2cap_send_move_chan_rsp(struct l2cap_chan *chan, u16 result)
4942 struct l2cap_move_chan_rsp rsp;
4944 BT_DBG("chan %p, result 0x%4.4x", chan, result);
4946 rsp.icid = cpu_to_le16(chan->dcid);
4947 rsp.result = cpu_to_le16(result);
4949 l2cap_send_cmd(chan->conn, chan->ident, L2CAP_MOVE_CHAN_RSP,
4953 static void l2cap_send_move_chan_cfm(struct l2cap_chan *chan, u16 result)
4955 struct l2cap_move_chan_cfm cfm;
4957 BT_DBG("chan %p, result 0x%4.4x", chan, result);
4959 chan->ident = l2cap_get_ident(chan->conn);
4961 cfm.icid = cpu_to_le16(chan->scid);
4962 cfm.result = cpu_to_le16(result);
4964 l2cap_send_cmd(chan->conn, chan->ident, L2CAP_MOVE_CHAN_CFM,
4967 __set_chan_timer(chan, L2CAP_MOVE_TIMEOUT);
4970 static void l2cap_send_move_chan_cfm_icid(struct l2cap_conn *conn, u16 icid)
4972 struct l2cap_move_chan_cfm cfm;
4974 BT_DBG("conn %p, icid 0x%4.4x", conn, icid);
4976 cfm.icid = cpu_to_le16(icid);
4977 cfm.result = cpu_to_le16(L2CAP_MC_UNCONFIRMED);
4979 l2cap_send_cmd(conn, l2cap_get_ident(conn), L2CAP_MOVE_CHAN_CFM,
4983 static void l2cap_send_move_chan_cfm_rsp(struct l2cap_conn *conn, u8 ident,
4986 struct l2cap_move_chan_cfm_rsp rsp;
4988 BT_DBG("icid 0x%4.4x", icid);
4990 rsp.icid = cpu_to_le16(icid);
4991 l2cap_send_cmd(conn, ident, L2CAP_MOVE_CHAN_CFM_RSP, sizeof(rsp), &rsp);
4994 static void __release_logical_link(struct l2cap_chan *chan)
4996 chan->hs_hchan = NULL;
4997 chan->hs_hcon = NULL;
4999 /* Placeholder - release the logical link */
5002 static void l2cap_logical_fail(struct l2cap_chan *chan)
5004 /* Logical link setup failed */
5005 if (chan->state != BT_CONNECTED) {
5006 /* Create channel failure, disconnect */
5007 l2cap_send_disconn_req(chan, ECONNRESET);
5011 switch (chan->move_role) {
5012 case L2CAP_MOVE_ROLE_RESPONDER:
5013 l2cap_move_done(chan);
5014 l2cap_send_move_chan_rsp(chan, L2CAP_MR_NOT_SUPP);
5016 case L2CAP_MOVE_ROLE_INITIATOR:
5017 if (chan->move_state == L2CAP_MOVE_WAIT_LOGICAL_COMP ||
5018 chan->move_state == L2CAP_MOVE_WAIT_LOGICAL_CFM) {
5019 /* Remote has only sent pending or
5020 * success responses, clean up
5022 l2cap_move_done(chan);
5025 /* Other amp move states imply that the move
5026 * has already aborted
5028 l2cap_send_move_chan_cfm(chan, L2CAP_MC_UNCONFIRMED);
5033 static void l2cap_logical_finish_create(struct l2cap_chan *chan,
5034 struct hci_chan *hchan)
5036 struct l2cap_conf_rsp rsp;
5038 chan->hs_hchan = hchan;
5039 chan->hs_hcon->l2cap_data = chan->conn;
5041 l2cap_send_efs_conf_rsp(chan, &rsp, chan->ident, 0);
5043 if (test_bit(CONF_INPUT_DONE, &chan->conf_state)) {
5046 set_default_fcs(chan);
5048 err = l2cap_ertm_init(chan);
5050 l2cap_send_disconn_req(chan, -err);
5052 l2cap_chan_ready(chan);
5056 static void l2cap_logical_finish_move(struct l2cap_chan *chan,
5057 struct hci_chan *hchan)
5059 chan->hs_hcon = hchan->conn;
5060 chan->hs_hcon->l2cap_data = chan->conn;
5062 BT_DBG("move_state %d", chan->move_state);
5064 switch (chan->move_state) {
5065 case L2CAP_MOVE_WAIT_LOGICAL_COMP:
5066 /* Move confirm will be sent after a success
5067 * response is received
5069 chan->move_state = L2CAP_MOVE_WAIT_RSP_SUCCESS;
5071 case L2CAP_MOVE_WAIT_LOGICAL_CFM:
5072 if (test_bit(CONN_LOCAL_BUSY, &chan->conn_state)) {
5073 chan->move_state = L2CAP_MOVE_WAIT_LOCAL_BUSY;
5074 } else if (chan->move_role == L2CAP_MOVE_ROLE_INITIATOR) {
5075 chan->move_state = L2CAP_MOVE_WAIT_CONFIRM_RSP;
5076 l2cap_send_move_chan_cfm(chan, L2CAP_MC_CONFIRMED);
5077 } else if (chan->move_role == L2CAP_MOVE_ROLE_RESPONDER) {
5078 chan->move_state = L2CAP_MOVE_WAIT_CONFIRM;
5079 l2cap_send_move_chan_rsp(chan, L2CAP_MR_SUCCESS);
5083 /* Move was not in expected state, free the channel */
5084 __release_logical_link(chan);
5086 chan->move_state = L2CAP_MOVE_STABLE;
5090 /* Call with chan locked */
5091 void l2cap_logical_cfm(struct l2cap_chan *chan, struct hci_chan *hchan,
5094 BT_DBG("chan %p, hchan %p, status %d", chan, hchan, status);
5097 l2cap_logical_fail(chan);
5098 __release_logical_link(chan);
5102 if (chan->state != BT_CONNECTED) {
5103 /* Ignore logical link if channel is on BR/EDR */
5104 if (chan->local_amp_id != AMP_ID_BREDR)
5105 l2cap_logical_finish_create(chan, hchan);
5107 l2cap_logical_finish_move(chan, hchan);
5111 void l2cap_move_start(struct l2cap_chan *chan)
5113 BT_DBG("chan %p", chan);
5115 if (chan->local_amp_id == AMP_ID_BREDR) {
5116 if (chan->chan_policy != BT_CHANNEL_POLICY_AMP_PREFERRED)
5118 chan->move_role = L2CAP_MOVE_ROLE_INITIATOR;
5119 chan->move_state = L2CAP_MOVE_WAIT_PREPARE;
5120 /* Placeholder - start physical link setup */
5122 chan->move_role = L2CAP_MOVE_ROLE_INITIATOR;
5123 chan->move_state = L2CAP_MOVE_WAIT_RSP_SUCCESS;
5125 l2cap_move_setup(chan);
5126 l2cap_send_move_chan_req(chan, 0);
5130 static void l2cap_do_create(struct l2cap_chan *chan, int result,
5131 u8 local_amp_id, u8 remote_amp_id)
5133 BT_DBG("chan %p state %s %u -> %u", chan, state_to_string(chan->state),
5134 local_amp_id, remote_amp_id);
5136 chan->fcs = L2CAP_FCS_NONE;
5138 /* Outgoing channel on AMP */
5139 if (chan->state == BT_CONNECT) {
5140 if (result == L2CAP_CR_SUCCESS) {
5141 chan->local_amp_id = local_amp_id;
5142 l2cap_send_create_chan_req(chan, remote_amp_id);
5144 /* Revert to BR/EDR connect */
5145 l2cap_send_conn_req(chan);
5151 /* Incoming channel on AMP */
5152 if (__l2cap_no_conn_pending(chan)) {
5153 struct l2cap_conn_rsp rsp;
5155 rsp.scid = cpu_to_le16(chan->dcid);
5156 rsp.dcid = cpu_to_le16(chan->scid);
5158 if (result == L2CAP_CR_SUCCESS) {
5159 /* Send successful response */
5160 rsp.result = cpu_to_le16(L2CAP_CR_SUCCESS);
5161 rsp.status = cpu_to_le16(L2CAP_CS_NO_INFO);
5163 /* Send negative response */
5164 rsp.result = cpu_to_le16(L2CAP_CR_NO_MEM);
5165 rsp.status = cpu_to_le16(L2CAP_CS_NO_INFO);
5168 l2cap_send_cmd(chan->conn, chan->ident, L2CAP_CREATE_CHAN_RSP,
5171 if (result == L2CAP_CR_SUCCESS) {
5172 l2cap_state_change(chan, BT_CONFIG);
5173 set_bit(CONF_REQ_SENT, &chan->conf_state);
5174 l2cap_send_cmd(chan->conn, l2cap_get_ident(chan->conn),
5176 l2cap_build_conf_req(chan, buf, sizeof(buf)), buf);
5177 chan->num_conf_req++;
5182 static void l2cap_do_move_initiate(struct l2cap_chan *chan, u8 local_amp_id,
5185 l2cap_move_setup(chan);
5186 chan->move_id = local_amp_id;
5187 chan->move_state = L2CAP_MOVE_WAIT_RSP;
5189 l2cap_send_move_chan_req(chan, remote_amp_id);
5192 static void l2cap_do_move_respond(struct l2cap_chan *chan, int result)
5194 struct hci_chan *hchan = NULL;
5196 /* Placeholder - get hci_chan for logical link */
5199 if (hchan->state == BT_CONNECTED) {
5200 /* Logical link is ready to go */
5201 chan->hs_hcon = hchan->conn;
5202 chan->hs_hcon->l2cap_data = chan->conn;
5203 chan->move_state = L2CAP_MOVE_WAIT_CONFIRM;
5204 l2cap_send_move_chan_rsp(chan, L2CAP_MR_SUCCESS);
5206 l2cap_logical_cfm(chan, hchan, L2CAP_MR_SUCCESS);
5208 /* Wait for logical link to be ready */
5209 chan->move_state = L2CAP_MOVE_WAIT_LOGICAL_CFM;
5212 /* Logical link not available */
5213 l2cap_send_move_chan_rsp(chan, L2CAP_MR_NOT_ALLOWED);
5217 static void l2cap_do_move_cancel(struct l2cap_chan *chan, int result)
5219 if (chan->move_role == L2CAP_MOVE_ROLE_RESPONDER) {
5221 if (result == -EINVAL)
5222 rsp_result = L2CAP_MR_BAD_ID;
5224 rsp_result = L2CAP_MR_NOT_ALLOWED;
5226 l2cap_send_move_chan_rsp(chan, rsp_result);
5229 chan->move_role = L2CAP_MOVE_ROLE_NONE;
5230 chan->move_state = L2CAP_MOVE_STABLE;
5232 /* Restart data transmission */
5233 l2cap_ertm_send(chan);
5236 /* Invoke with locked chan */
5237 void __l2cap_physical_cfm(struct l2cap_chan *chan, int result)
5239 u8 local_amp_id = chan->local_amp_id;
5240 u8 remote_amp_id = chan->remote_amp_id;
5242 BT_DBG("chan %p, result %d, local_amp_id %d, remote_amp_id %d",
5243 chan, result, local_amp_id, remote_amp_id);
5245 if (chan->state == BT_DISCONN || chan->state == BT_CLOSED)
5248 if (chan->state != BT_CONNECTED) {
5249 l2cap_do_create(chan, result, local_amp_id, remote_amp_id);
5250 } else if (result != L2CAP_MR_SUCCESS) {
5251 l2cap_do_move_cancel(chan, result);
5253 switch (chan->move_role) {
5254 case L2CAP_MOVE_ROLE_INITIATOR:
5255 l2cap_do_move_initiate(chan, local_amp_id,
5258 case L2CAP_MOVE_ROLE_RESPONDER:
5259 l2cap_do_move_respond(chan, result);
5262 l2cap_do_move_cancel(chan, result);
5268 static inline int l2cap_move_channel_req(struct l2cap_conn *conn,
5269 struct l2cap_cmd_hdr *cmd,
5270 u16 cmd_len, void *data)
5272 struct l2cap_move_chan_req *req = data;
5273 struct l2cap_move_chan_rsp rsp;
5274 struct l2cap_chan *chan;
5276 u16 result = L2CAP_MR_NOT_ALLOWED;
5278 if (cmd_len != sizeof(*req))
5281 icid = le16_to_cpu(req->icid);
5283 BT_DBG("icid 0x%4.4x, dest_amp_id %d", icid, req->dest_amp_id);
5285 if (!(conn->local_fixed_chan & L2CAP_FC_A2MP))
5288 chan = l2cap_get_chan_by_dcid(conn, icid);
5290 rsp.icid = cpu_to_le16(icid);
5291 rsp.result = cpu_to_le16(L2CAP_MR_NOT_ALLOWED);
5292 l2cap_send_cmd(conn, cmd->ident, L2CAP_MOVE_CHAN_RSP,
5297 chan->ident = cmd->ident;
5299 if (chan->scid < L2CAP_CID_DYN_START ||
5300 chan->chan_policy == BT_CHANNEL_POLICY_BREDR_ONLY ||
5301 (chan->mode != L2CAP_MODE_ERTM &&
5302 chan->mode != L2CAP_MODE_STREAMING)) {
5303 result = L2CAP_MR_NOT_ALLOWED;
5304 goto send_move_response;
5307 if (chan->local_amp_id == req->dest_amp_id) {
5308 result = L2CAP_MR_SAME_ID;
5309 goto send_move_response;
5312 if (req->dest_amp_id != AMP_ID_BREDR) {
5313 struct hci_dev *hdev;
5314 hdev = hci_dev_get(req->dest_amp_id);
5315 if (!hdev || hdev->dev_type != HCI_AMP ||
5316 !test_bit(HCI_UP, &hdev->flags)) {
5320 result = L2CAP_MR_BAD_ID;
5321 goto send_move_response;
5326 /* Detect a move collision. Only send a collision response
5327 * if this side has "lost", otherwise proceed with the move.
5328 * The winner has the larger bd_addr.
5330 if ((__chan_is_moving(chan) ||
5331 chan->move_role != L2CAP_MOVE_ROLE_NONE) &&
5332 bacmp(&conn->hcon->src, &conn->hcon->dst) > 0) {
5333 result = L2CAP_MR_COLLISION;
5334 goto send_move_response;
5337 chan->move_role = L2CAP_MOVE_ROLE_RESPONDER;
5338 l2cap_move_setup(chan);
5339 chan->move_id = req->dest_amp_id;
5341 if (req->dest_amp_id == AMP_ID_BREDR) {
5342 /* Moving to BR/EDR */
5343 if (test_bit(CONN_LOCAL_BUSY, &chan->conn_state)) {
5344 chan->move_state = L2CAP_MOVE_WAIT_LOCAL_BUSY;
5345 result = L2CAP_MR_PEND;
5347 chan->move_state = L2CAP_MOVE_WAIT_CONFIRM;
5348 result = L2CAP_MR_SUCCESS;
5351 chan->move_state = L2CAP_MOVE_WAIT_PREPARE;
5352 /* Placeholder - uncomment when amp functions are available */
5353 /*amp_accept_physical(chan, req->dest_amp_id);*/
5354 result = L2CAP_MR_PEND;
5358 l2cap_send_move_chan_rsp(chan, result);
5360 l2cap_chan_unlock(chan);
5361 l2cap_chan_put(chan);
5366 static void l2cap_move_continue(struct l2cap_conn *conn, u16 icid, u16 result)
5368 struct l2cap_chan *chan;
5369 struct hci_chan *hchan = NULL;
5371 chan = l2cap_get_chan_by_scid(conn, icid);
5373 l2cap_send_move_chan_cfm_icid(conn, icid);
5377 __clear_chan_timer(chan);
5378 if (result == L2CAP_MR_PEND)
5379 __set_chan_timer(chan, L2CAP_MOVE_ERTX_TIMEOUT);
5381 switch (chan->move_state) {
5382 case L2CAP_MOVE_WAIT_LOGICAL_COMP:
5383 /* Move confirm will be sent when logical link
5386 chan->move_state = L2CAP_MOVE_WAIT_LOGICAL_CFM;
5388 case L2CAP_MOVE_WAIT_RSP_SUCCESS:
5389 if (result == L2CAP_MR_PEND) {
5391 } else if (test_bit(CONN_LOCAL_BUSY,
5392 &chan->conn_state)) {
5393 chan->move_state = L2CAP_MOVE_WAIT_LOCAL_BUSY;
5395 /* Logical link is up or moving to BR/EDR,
5398 chan->move_state = L2CAP_MOVE_WAIT_CONFIRM_RSP;
5399 l2cap_send_move_chan_cfm(chan, L2CAP_MC_CONFIRMED);
5402 case L2CAP_MOVE_WAIT_RSP:
5404 if (result == L2CAP_MR_SUCCESS) {
5405 /* Remote is ready, send confirm immediately
5406 * after logical link is ready
5408 chan->move_state = L2CAP_MOVE_WAIT_LOGICAL_CFM;
5410 /* Both logical link and move success
5411 * are required to confirm
5413 chan->move_state = L2CAP_MOVE_WAIT_LOGICAL_COMP;
5416 /* Placeholder - get hci_chan for logical link */
5418 /* Logical link not available */
5419 l2cap_send_move_chan_cfm(chan, L2CAP_MC_UNCONFIRMED);
5423 /* If the logical link is not yet connected, do not
5424 * send confirmation.
5426 if (hchan->state != BT_CONNECTED)
5429 /* Logical link is already ready to go */
5431 chan->hs_hcon = hchan->conn;
5432 chan->hs_hcon->l2cap_data = chan->conn;
5434 if (result == L2CAP_MR_SUCCESS) {
5435 /* Can confirm now */
5436 l2cap_send_move_chan_cfm(chan, L2CAP_MC_CONFIRMED);
5438 /* Now only need move success
5441 chan->move_state = L2CAP_MOVE_WAIT_RSP_SUCCESS;
5444 l2cap_logical_cfm(chan, hchan, L2CAP_MR_SUCCESS);
5447 /* Any other amp move state means the move failed. */
5448 chan->move_id = chan->local_amp_id;
5449 l2cap_move_done(chan);
5450 l2cap_send_move_chan_cfm(chan, L2CAP_MC_UNCONFIRMED);
5453 l2cap_chan_unlock(chan);
5454 l2cap_chan_put(chan);
5457 static void l2cap_move_fail(struct l2cap_conn *conn, u8 ident, u16 icid,
5460 struct l2cap_chan *chan;
5462 chan = l2cap_get_chan_by_ident(conn, ident);
5464 /* Could not locate channel, icid is best guess */
5465 l2cap_send_move_chan_cfm_icid(conn, icid);
5469 __clear_chan_timer(chan);
5471 if (chan->move_role == L2CAP_MOVE_ROLE_INITIATOR) {
5472 if (result == L2CAP_MR_COLLISION) {
5473 chan->move_role = L2CAP_MOVE_ROLE_RESPONDER;
5475 /* Cleanup - cancel move */
5476 chan->move_id = chan->local_amp_id;
5477 l2cap_move_done(chan);
5481 l2cap_send_move_chan_cfm(chan, L2CAP_MC_UNCONFIRMED);
5483 l2cap_chan_unlock(chan);
5484 l2cap_chan_put(chan);
5487 static int l2cap_move_channel_rsp(struct l2cap_conn *conn,
5488 struct l2cap_cmd_hdr *cmd,
5489 u16 cmd_len, void *data)
5491 struct l2cap_move_chan_rsp *rsp = data;
5494 if (cmd_len != sizeof(*rsp))
5497 icid = le16_to_cpu(rsp->icid);
5498 result = le16_to_cpu(rsp->result);
5500 BT_DBG("icid 0x%4.4x, result 0x%4.4x", icid, result);
5502 if (result == L2CAP_MR_SUCCESS || result == L2CAP_MR_PEND)
5503 l2cap_move_continue(conn, icid, result);
5505 l2cap_move_fail(conn, cmd->ident, icid, result);
5510 static int l2cap_move_channel_confirm(struct l2cap_conn *conn,
5511 struct l2cap_cmd_hdr *cmd,
5512 u16 cmd_len, void *data)
5514 struct l2cap_move_chan_cfm *cfm = data;
5515 struct l2cap_chan *chan;
5518 if (cmd_len != sizeof(*cfm))
5521 icid = le16_to_cpu(cfm->icid);
5522 result = le16_to_cpu(cfm->result);
5524 BT_DBG("icid 0x%4.4x, result 0x%4.4x", icid, result);
5526 chan = l2cap_get_chan_by_dcid(conn, icid);
5528 /* Spec requires a response even if the icid was not found */
5529 l2cap_send_move_chan_cfm_rsp(conn, cmd->ident, icid);
5533 if (chan->move_state == L2CAP_MOVE_WAIT_CONFIRM) {
5534 if (result == L2CAP_MC_CONFIRMED) {
5535 chan->local_amp_id = chan->move_id;
5536 if (chan->local_amp_id == AMP_ID_BREDR)
5537 __release_logical_link(chan);
5539 chan->move_id = chan->local_amp_id;
5542 l2cap_move_done(chan);
5545 l2cap_send_move_chan_cfm_rsp(conn, cmd->ident, icid);
5547 l2cap_chan_unlock(chan);
5548 l2cap_chan_put(chan);
5553 static inline int l2cap_move_channel_confirm_rsp(struct l2cap_conn *conn,
5554 struct l2cap_cmd_hdr *cmd,
5555 u16 cmd_len, void *data)
5557 struct l2cap_move_chan_cfm_rsp *rsp = data;
5558 struct l2cap_chan *chan;
5561 if (cmd_len != sizeof(*rsp))
5564 icid = le16_to_cpu(rsp->icid);
5566 BT_DBG("icid 0x%4.4x", icid);
5568 chan = l2cap_get_chan_by_scid(conn, icid);
5572 __clear_chan_timer(chan);
5574 if (chan->move_state == L2CAP_MOVE_WAIT_CONFIRM_RSP) {
5575 chan->local_amp_id = chan->move_id;
5577 if (chan->local_amp_id == AMP_ID_BREDR && chan->hs_hchan)
5578 __release_logical_link(chan);
5580 l2cap_move_done(chan);
5583 l2cap_chan_unlock(chan);
5584 l2cap_chan_put(chan);
5589 static inline int l2cap_conn_param_update_req(struct l2cap_conn *conn,
5590 struct l2cap_cmd_hdr *cmd,
5591 u16 cmd_len, u8 *data)
5593 struct hci_conn *hcon = conn->hcon;
5594 struct l2cap_conn_param_update_req *req;
5595 struct l2cap_conn_param_update_rsp rsp;
5596 u16 min, max, latency, to_multiplier;
5599 if (hcon->role != HCI_ROLE_MASTER)
5602 if (cmd_len != sizeof(struct l2cap_conn_param_update_req))
5605 req = (struct l2cap_conn_param_update_req *) data;
5606 min = __le16_to_cpu(req->min);
5607 max = __le16_to_cpu(req->max);
5608 latency = __le16_to_cpu(req->latency);
5609 to_multiplier = __le16_to_cpu(req->to_multiplier);
5611 BT_DBG("min 0x%4.4x max 0x%4.4x latency: 0x%4.4x Timeout: 0x%4.4x",
5612 min, max, latency, to_multiplier);
5614 memset(&rsp, 0, sizeof(rsp));
5616 err = hci_check_conn_params(min, max, latency, to_multiplier);
5618 rsp.result = cpu_to_le16(L2CAP_CONN_PARAM_REJECTED);
5620 rsp.result = cpu_to_le16(L2CAP_CONN_PARAM_ACCEPTED);
5622 l2cap_send_cmd(conn, cmd->ident, L2CAP_CONN_PARAM_UPDATE_RSP,
5628 store_hint = hci_le_conn_update(hcon, min, max, latency,
5630 mgmt_new_conn_param(hcon->hdev, &hcon->dst, hcon->dst_type,
5631 store_hint, min, max, latency,
5639 static int l2cap_le_connect_rsp(struct l2cap_conn *conn,
5640 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
5643 struct l2cap_le_conn_rsp *rsp = (struct l2cap_le_conn_rsp *) data;
5644 struct hci_conn *hcon = conn->hcon;
5645 u16 dcid, mtu, mps, credits, result;
5646 struct l2cap_chan *chan;
5649 if (cmd_len < sizeof(*rsp))
5652 dcid = __le16_to_cpu(rsp->dcid);
5653 mtu = __le16_to_cpu(rsp->mtu);
5654 mps = __le16_to_cpu(rsp->mps);
5655 credits = __le16_to_cpu(rsp->credits);
5656 result = __le16_to_cpu(rsp->result);
5658 if (result == L2CAP_CR_LE_SUCCESS && (mtu < 23 || mps < 23 ||
5659 dcid < L2CAP_CID_DYN_START ||
5660 dcid > L2CAP_CID_LE_DYN_END))
5663 BT_DBG("dcid 0x%4.4x mtu %u mps %u credits %u result 0x%2.2x",
5664 dcid, mtu, mps, credits, result);
5666 mutex_lock(&conn->chan_lock);
5668 chan = __l2cap_get_chan_by_ident(conn, cmd->ident);
5676 l2cap_chan_lock(chan);
5679 case L2CAP_CR_LE_SUCCESS:
5680 if (__l2cap_get_chan_by_dcid(conn, dcid)) {
5688 chan->remote_mps = mps;
5689 chan->tx_credits = credits;
5690 l2cap_chan_ready(chan);
5693 case L2CAP_CR_LE_AUTHENTICATION:
5694 case L2CAP_CR_LE_ENCRYPTION:
5695 /* If we already have MITM protection we can't do
5698 if (hcon->sec_level > BT_SECURITY_MEDIUM) {
5699 l2cap_chan_del(chan, ECONNREFUSED);
5703 sec_level = hcon->sec_level + 1;
5704 if (chan->sec_level < sec_level)
5705 chan->sec_level = sec_level;
5707 /* We'll need to send a new Connect Request */
5708 clear_bit(FLAG_LE_CONN_REQ_SENT, &chan->flags);
5710 smp_conn_security(hcon, chan->sec_level);
5714 l2cap_chan_del(chan, ECONNREFUSED);
5718 l2cap_chan_unlock(chan);
5721 mutex_unlock(&conn->chan_lock);
5726 static inline int l2cap_bredr_sig_cmd(struct l2cap_conn *conn,
5727 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
5732 switch (cmd->code) {
5733 case L2CAP_COMMAND_REJ:
5734 l2cap_command_rej(conn, cmd, cmd_len, data);
5737 case L2CAP_CONN_REQ:
5738 err = l2cap_connect_req(conn, cmd, cmd_len, data);
5741 case L2CAP_CONN_RSP:
5742 case L2CAP_CREATE_CHAN_RSP:
5743 l2cap_connect_create_rsp(conn, cmd, cmd_len, data);
5746 case L2CAP_CONF_REQ:
5747 err = l2cap_config_req(conn, cmd, cmd_len, data);
5750 case L2CAP_CONF_RSP:
5751 l2cap_config_rsp(conn, cmd, cmd_len, data);
5754 case L2CAP_DISCONN_REQ:
5755 err = l2cap_disconnect_req(conn, cmd, cmd_len, data);
5758 case L2CAP_DISCONN_RSP:
5759 l2cap_disconnect_rsp(conn, cmd, cmd_len, data);
5762 case L2CAP_ECHO_REQ:
5763 l2cap_send_cmd(conn, cmd->ident, L2CAP_ECHO_RSP, cmd_len, data);
5766 case L2CAP_ECHO_RSP:
5769 case L2CAP_INFO_REQ:
5770 err = l2cap_information_req(conn, cmd, cmd_len, data);
5773 case L2CAP_INFO_RSP:
5774 l2cap_information_rsp(conn, cmd, cmd_len, data);
5777 case L2CAP_CREATE_CHAN_REQ:
5778 err = l2cap_create_channel_req(conn, cmd, cmd_len, data);
5781 case L2CAP_MOVE_CHAN_REQ:
5782 err = l2cap_move_channel_req(conn, cmd, cmd_len, data);
5785 case L2CAP_MOVE_CHAN_RSP:
5786 l2cap_move_channel_rsp(conn, cmd, cmd_len, data);
5789 case L2CAP_MOVE_CHAN_CFM:
5790 err = l2cap_move_channel_confirm(conn, cmd, cmd_len, data);
5793 case L2CAP_MOVE_CHAN_CFM_RSP:
5794 l2cap_move_channel_confirm_rsp(conn, cmd, cmd_len, data);
5798 BT_ERR("Unknown BR/EDR signaling command 0x%2.2x", cmd->code);
5806 static int l2cap_le_connect_req(struct l2cap_conn *conn,
5807 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
5810 struct l2cap_le_conn_req *req = (struct l2cap_le_conn_req *) data;
5811 struct l2cap_le_conn_rsp rsp;
5812 struct l2cap_chan *chan, *pchan;
5813 u16 dcid, scid, credits, mtu, mps;
5817 if (cmd_len != sizeof(*req))
5820 scid = __le16_to_cpu(req->scid);
5821 mtu = __le16_to_cpu(req->mtu);
5822 mps = __le16_to_cpu(req->mps);
5827 if (mtu < 23 || mps < 23)
5830 BT_DBG("psm 0x%2.2x scid 0x%4.4x mtu %u mps %u", __le16_to_cpu(psm),
5833 /* BLUETOOTH CORE SPECIFICATION Version 5.3 | Vol 3, Part A
5836 * Valid range: 0x0001-0x00ff
5838 * Table 4.15: L2CAP_LE_CREDIT_BASED_CONNECTION_REQ SPSM ranges
5840 if (!psm || __le16_to_cpu(psm) > L2CAP_PSM_LE_DYN_END) {
5841 result = L2CAP_CR_LE_BAD_PSM;
5846 /* Check if we have socket listening on psm */
5847 pchan = l2cap_global_chan_by_psm(BT_LISTEN, psm, &conn->hcon->src,
5848 &conn->hcon->dst, LE_LINK);
5850 result = L2CAP_CR_LE_BAD_PSM;
5855 mutex_lock(&conn->chan_lock);
5856 l2cap_chan_lock(pchan);
5858 if (!smp_sufficient_security(conn->hcon, pchan->sec_level,
5860 result = L2CAP_CR_LE_AUTHENTICATION;
5862 goto response_unlock;
5865 /* Check for valid dynamic CID range */
5866 if (scid < L2CAP_CID_DYN_START || scid > L2CAP_CID_LE_DYN_END) {
5867 result = L2CAP_CR_LE_INVALID_SCID;
5869 goto response_unlock;
5872 /* Check if we already have channel with that dcid */
5873 if (__l2cap_get_chan_by_dcid(conn, scid)) {
5874 result = L2CAP_CR_LE_SCID_IN_USE;
5876 goto response_unlock;
5879 chan = pchan->ops->new_connection(pchan);
5881 result = L2CAP_CR_LE_NO_MEM;
5882 goto response_unlock;
5885 bacpy(&chan->src, &conn->hcon->src);
5886 bacpy(&chan->dst, &conn->hcon->dst);
5887 chan->src_type = bdaddr_src_type(conn->hcon);
5888 chan->dst_type = bdaddr_dst_type(conn->hcon);
5892 chan->remote_mps = mps;
5894 __l2cap_chan_add(conn, chan);
5896 l2cap_le_flowctl_init(chan, __le16_to_cpu(req->credits));
5899 credits = chan->rx_credits;
5901 __set_chan_timer(chan, chan->ops->get_sndtimeo(chan));
5903 chan->ident = cmd->ident;
5905 if (test_bit(FLAG_DEFER_SETUP, &chan->flags)) {
5906 l2cap_state_change(chan, BT_CONNECT2);
5907 /* The following result value is actually not defined
5908 * for LE CoC but we use it to let the function know
5909 * that it should bail out after doing its cleanup
5910 * instead of sending a response.
5912 result = L2CAP_CR_PEND;
5913 chan->ops->defer(chan);
5915 l2cap_chan_ready(chan);
5916 result = L2CAP_CR_LE_SUCCESS;
5920 l2cap_chan_unlock(pchan);
5921 mutex_unlock(&conn->chan_lock);
5922 l2cap_chan_put(pchan);
5924 if (result == L2CAP_CR_PEND)
5929 rsp.mtu = cpu_to_le16(chan->imtu);
5930 rsp.mps = cpu_to_le16(chan->mps);
5936 rsp.dcid = cpu_to_le16(dcid);
5937 rsp.credits = cpu_to_le16(credits);
5938 rsp.result = cpu_to_le16(result);
5940 l2cap_send_cmd(conn, cmd->ident, L2CAP_LE_CONN_RSP, sizeof(rsp), &rsp);
5945 static inline int l2cap_le_credits(struct l2cap_conn *conn,
5946 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
5949 struct l2cap_le_credits *pkt;
5950 struct l2cap_chan *chan;
5951 u16 cid, credits, max_credits;
5953 if (cmd_len != sizeof(*pkt))
5956 pkt = (struct l2cap_le_credits *) data;
5957 cid = __le16_to_cpu(pkt->cid);
5958 credits = __le16_to_cpu(pkt->credits);
5960 BT_DBG("cid 0x%4.4x credits 0x%4.4x", cid, credits);
5962 chan = l2cap_get_chan_by_dcid(conn, cid);
5966 max_credits = LE_FLOWCTL_MAX_CREDITS - chan->tx_credits;
5967 if (credits > max_credits) {
5968 BT_ERR("LE credits overflow");
5969 l2cap_send_disconn_req(chan, ECONNRESET);
5971 /* Return 0 so that we don't trigger an unnecessary
5972 * command reject packet.
5977 chan->tx_credits += credits;
5979 /* Resume sending */
5980 l2cap_le_flowctl_send(chan);
5982 if (chan->tx_credits)
5983 chan->ops->resume(chan);
5986 l2cap_chan_unlock(chan);
5987 l2cap_chan_put(chan);
5992 static inline int l2cap_ecred_conn_req(struct l2cap_conn *conn,
5993 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
5996 struct l2cap_ecred_conn_req *req = (void *) data;
5998 struct l2cap_ecred_conn_rsp rsp;
5999 __le16 dcid[L2CAP_ECRED_MAX_CID];
6001 struct l2cap_chan *chan, *pchan;
6011 if (cmd_len < sizeof(*req) || (cmd_len - sizeof(*req)) % sizeof(u16)) {
6012 result = L2CAP_CR_LE_INVALID_PARAMS;
6016 cmd_len -= sizeof(*req);
6017 num_scid = cmd_len / sizeof(u16);
6019 if (num_scid > ARRAY_SIZE(pdu.dcid)) {
6020 result = L2CAP_CR_LE_INVALID_PARAMS;
6024 mtu = __le16_to_cpu(req->mtu);
6025 mps = __le16_to_cpu(req->mps);
6027 if (mtu < L2CAP_ECRED_MIN_MTU || mps < L2CAP_ECRED_MIN_MPS) {
6028 result = L2CAP_CR_LE_UNACCEPT_PARAMS;
6034 /* BLUETOOTH CORE SPECIFICATION Version 5.3 | Vol 3, Part A
6037 * Valid range: 0x0001-0x00ff
6039 * Table 4.15: L2CAP_LE_CREDIT_BASED_CONNECTION_REQ SPSM ranges
6041 if (!psm || __le16_to_cpu(psm) > L2CAP_PSM_LE_DYN_END) {
6042 result = L2CAP_CR_LE_BAD_PSM;
6046 BT_DBG("psm 0x%2.2x mtu %u mps %u", __le16_to_cpu(psm), mtu, mps);
6048 memset(&pdu, 0, sizeof(pdu));
6050 /* Check if we have socket listening on psm */
6051 pchan = l2cap_global_chan_by_psm(BT_LISTEN, psm, &conn->hcon->src,
6052 &conn->hcon->dst, LE_LINK);
6054 result = L2CAP_CR_LE_BAD_PSM;
6058 mutex_lock(&conn->chan_lock);
6059 l2cap_chan_lock(pchan);
6061 if (!smp_sufficient_security(conn->hcon, pchan->sec_level,
6063 result = L2CAP_CR_LE_AUTHENTICATION;
6067 result = L2CAP_CR_LE_SUCCESS;
6069 for (i = 0; i < num_scid; i++) {
6070 u16 scid = __le16_to_cpu(req->scid[i]);
6072 BT_DBG("scid[%d] 0x%4.4x", i, scid);
6074 pdu.dcid[i] = 0x0000;
6075 len += sizeof(*pdu.dcid);
6077 /* Check for valid dynamic CID range */
6078 if (scid < L2CAP_CID_DYN_START || scid > L2CAP_CID_LE_DYN_END) {
6079 result = L2CAP_CR_LE_INVALID_SCID;
6083 /* Check if we already have channel with that dcid */
6084 if (__l2cap_get_chan_by_dcid(conn, scid)) {
6085 result = L2CAP_CR_LE_SCID_IN_USE;
6089 chan = pchan->ops->new_connection(pchan);
6091 result = L2CAP_CR_LE_NO_MEM;
6095 bacpy(&chan->src, &conn->hcon->src);
6096 bacpy(&chan->dst, &conn->hcon->dst);
6097 chan->src_type = bdaddr_src_type(conn->hcon);
6098 chan->dst_type = bdaddr_dst_type(conn->hcon);
6102 chan->remote_mps = mps;
6104 __l2cap_chan_add(conn, chan);
6106 l2cap_ecred_init(chan, __le16_to_cpu(req->credits));
6109 if (!pdu.rsp.credits) {
6110 pdu.rsp.mtu = cpu_to_le16(chan->imtu);
6111 pdu.rsp.mps = cpu_to_le16(chan->mps);
6112 pdu.rsp.credits = cpu_to_le16(chan->rx_credits);
6115 pdu.dcid[i] = cpu_to_le16(chan->scid);
6117 __set_chan_timer(chan, chan->ops->get_sndtimeo(chan));
6119 chan->ident = cmd->ident;
6120 chan->mode = L2CAP_MODE_EXT_FLOWCTL;
6122 if (test_bit(FLAG_DEFER_SETUP, &chan->flags)) {
6123 l2cap_state_change(chan, BT_CONNECT2);
6125 chan->ops->defer(chan);
6127 l2cap_chan_ready(chan);
6132 l2cap_chan_unlock(pchan);
6133 mutex_unlock(&conn->chan_lock);
6134 l2cap_chan_put(pchan);
6137 pdu.rsp.result = cpu_to_le16(result);
6142 l2cap_send_cmd(conn, cmd->ident, L2CAP_ECRED_CONN_RSP,
6143 sizeof(pdu.rsp) + len, &pdu);
6148 static inline int l2cap_ecred_conn_rsp(struct l2cap_conn *conn,
6149 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
6152 struct l2cap_ecred_conn_rsp *rsp = (void *) data;
6153 struct hci_conn *hcon = conn->hcon;
6154 u16 mtu, mps, credits, result;
6155 struct l2cap_chan *chan, *tmp;
6156 int err = 0, sec_level;
6159 if (cmd_len < sizeof(*rsp))
6162 mtu = __le16_to_cpu(rsp->mtu);
6163 mps = __le16_to_cpu(rsp->mps);
6164 credits = __le16_to_cpu(rsp->credits);
6165 result = __le16_to_cpu(rsp->result);
6167 BT_DBG("mtu %u mps %u credits %u result 0x%4.4x", mtu, mps, credits,
6170 mutex_lock(&conn->chan_lock);
6172 cmd_len -= sizeof(*rsp);
6174 list_for_each_entry_safe(chan, tmp, &conn->chan_l, list) {
6177 if (chan->ident != cmd->ident ||
6178 chan->mode != L2CAP_MODE_EXT_FLOWCTL ||
6179 chan->state == BT_CONNECTED)
6182 l2cap_chan_lock(chan);
6184 /* Check that there is a dcid for each pending channel */
6185 if (cmd_len < sizeof(dcid)) {
6186 l2cap_chan_del(chan, ECONNREFUSED);
6187 l2cap_chan_unlock(chan);
6191 dcid = __le16_to_cpu(rsp->dcid[i++]);
6192 cmd_len -= sizeof(u16);
6194 BT_DBG("dcid[%d] 0x%4.4x", i, dcid);
6196 /* Check if dcid is already in use */
6197 if (dcid && __l2cap_get_chan_by_dcid(conn, dcid)) {
6198 /* If a device receives a
6199 * L2CAP_CREDIT_BASED_CONNECTION_RSP packet with an
6200 * already-assigned Destination CID, then both the
6201 * original channel and the new channel shall be
6202 * immediately discarded and not used.
6204 l2cap_chan_del(chan, ECONNREFUSED);
6205 l2cap_chan_unlock(chan);
6206 chan = __l2cap_get_chan_by_dcid(conn, dcid);
6207 l2cap_chan_lock(chan);
6208 l2cap_chan_del(chan, ECONNRESET);
6209 l2cap_chan_unlock(chan);
6214 case L2CAP_CR_LE_AUTHENTICATION:
6215 case L2CAP_CR_LE_ENCRYPTION:
6216 /* If we already have MITM protection we can't do
6219 if (hcon->sec_level > BT_SECURITY_MEDIUM) {
6220 l2cap_chan_del(chan, ECONNREFUSED);
6224 sec_level = hcon->sec_level + 1;
6225 if (chan->sec_level < sec_level)
6226 chan->sec_level = sec_level;
6228 /* We'll need to send a new Connect Request */
6229 clear_bit(FLAG_ECRED_CONN_REQ_SENT, &chan->flags);
6231 smp_conn_security(hcon, chan->sec_level);
6234 case L2CAP_CR_LE_BAD_PSM:
6235 l2cap_chan_del(chan, ECONNREFUSED);
6239 /* If dcid was not set it means channels was refused */
6241 l2cap_chan_del(chan, ECONNREFUSED);
6248 chan->remote_mps = mps;
6249 chan->tx_credits = credits;
6250 l2cap_chan_ready(chan);
6254 l2cap_chan_unlock(chan);
6257 mutex_unlock(&conn->chan_lock);
6262 static inline int l2cap_ecred_reconf_req(struct l2cap_conn *conn,
6263 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
6266 struct l2cap_ecred_reconf_req *req = (void *) data;
6267 struct l2cap_ecred_reconf_rsp rsp;
6268 u16 mtu, mps, result;
6269 struct l2cap_chan *chan;
6275 if (cmd_len < sizeof(*req) || cmd_len - sizeof(*req) % sizeof(u16)) {
6276 result = L2CAP_CR_LE_INVALID_PARAMS;
6280 mtu = __le16_to_cpu(req->mtu);
6281 mps = __le16_to_cpu(req->mps);
6283 BT_DBG("mtu %u mps %u", mtu, mps);
6285 if (mtu < L2CAP_ECRED_MIN_MTU) {
6286 result = L2CAP_RECONF_INVALID_MTU;
6290 if (mps < L2CAP_ECRED_MIN_MPS) {
6291 result = L2CAP_RECONF_INVALID_MPS;
6295 cmd_len -= sizeof(*req);
6296 num_scid = cmd_len / sizeof(u16);
6297 result = L2CAP_RECONF_SUCCESS;
6299 for (i = 0; i < num_scid; i++) {
6302 scid = __le16_to_cpu(req->scid[i]);
6306 chan = __l2cap_get_chan_by_dcid(conn, scid);
6310 /* If the MTU value is decreased for any of the included
6311 * channels, then the receiver shall disconnect all
6312 * included channels.
6314 if (chan->omtu > mtu) {
6315 BT_ERR("chan %p decreased MTU %u -> %u", chan,
6317 result = L2CAP_RECONF_INVALID_MTU;
6321 chan->remote_mps = mps;
6325 rsp.result = cpu_to_le16(result);
6327 l2cap_send_cmd(conn, cmd->ident, L2CAP_ECRED_RECONF_RSP, sizeof(rsp),
6333 static inline int l2cap_ecred_reconf_rsp(struct l2cap_conn *conn,
6334 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
6337 struct l2cap_chan *chan, *tmp;
6338 struct l2cap_ecred_conn_rsp *rsp = (void *) data;
6341 if (cmd_len < sizeof(*rsp))
6344 result = __le16_to_cpu(rsp->result);
6346 BT_DBG("result 0x%4.4x", rsp->result);
6351 list_for_each_entry_safe(chan, tmp, &conn->chan_l, list) {
6352 if (chan->ident != cmd->ident)
6355 l2cap_chan_del(chan, ECONNRESET);
6361 static inline int l2cap_le_command_rej(struct l2cap_conn *conn,
6362 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
6365 struct l2cap_cmd_rej_unk *rej = (struct l2cap_cmd_rej_unk *) data;
6366 struct l2cap_chan *chan;
6368 if (cmd_len < sizeof(*rej))
6371 mutex_lock(&conn->chan_lock);
6373 chan = __l2cap_get_chan_by_ident(conn, cmd->ident);
6377 chan = l2cap_chan_hold_unless_zero(chan);
6381 l2cap_chan_lock(chan);
6382 l2cap_chan_del(chan, ECONNREFUSED);
6383 l2cap_chan_unlock(chan);
6384 l2cap_chan_put(chan);
6387 mutex_unlock(&conn->chan_lock);
6391 static inline int l2cap_le_sig_cmd(struct l2cap_conn *conn,
6392 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
6397 switch (cmd->code) {
6398 case L2CAP_COMMAND_REJ:
6399 l2cap_le_command_rej(conn, cmd, cmd_len, data);
6402 case L2CAP_CONN_PARAM_UPDATE_REQ:
6403 err = l2cap_conn_param_update_req(conn, cmd, cmd_len, data);
6406 case L2CAP_CONN_PARAM_UPDATE_RSP:
6409 case L2CAP_LE_CONN_RSP:
6410 l2cap_le_connect_rsp(conn, cmd, cmd_len, data);
6413 case L2CAP_LE_CONN_REQ:
6414 err = l2cap_le_connect_req(conn, cmd, cmd_len, data);
6417 case L2CAP_LE_CREDITS:
6418 err = l2cap_le_credits(conn, cmd, cmd_len, data);
6421 case L2CAP_ECRED_CONN_REQ:
6422 err = l2cap_ecred_conn_req(conn, cmd, cmd_len, data);
6425 case L2CAP_ECRED_CONN_RSP:
6426 err = l2cap_ecred_conn_rsp(conn, cmd, cmd_len, data);
6429 case L2CAP_ECRED_RECONF_REQ:
6430 err = l2cap_ecred_reconf_req(conn, cmd, cmd_len, data);
6433 case L2CAP_ECRED_RECONF_RSP:
6434 err = l2cap_ecred_reconf_rsp(conn, cmd, cmd_len, data);
6437 case L2CAP_DISCONN_REQ:
6438 err = l2cap_disconnect_req(conn, cmd, cmd_len, data);
6441 case L2CAP_DISCONN_RSP:
6442 l2cap_disconnect_rsp(conn, cmd, cmd_len, data);
6446 BT_ERR("Unknown LE signaling command 0x%2.2x", cmd->code);
6454 static inline void l2cap_le_sig_channel(struct l2cap_conn *conn,
6455 struct sk_buff *skb)
6457 struct hci_conn *hcon = conn->hcon;
6458 struct l2cap_cmd_hdr *cmd;
6462 if (hcon->type != LE_LINK)
6465 if (skb->len < L2CAP_CMD_HDR_SIZE)
6468 cmd = (void *) skb->data;
6469 skb_pull(skb, L2CAP_CMD_HDR_SIZE);
6471 len = le16_to_cpu(cmd->len);
6473 BT_DBG("code 0x%2.2x len %d id 0x%2.2x", cmd->code, len, cmd->ident);
6475 if (len != skb->len || !cmd->ident) {
6476 BT_DBG("corrupted command");
6480 err = l2cap_le_sig_cmd(conn, cmd, len, skb->data);
6482 struct l2cap_cmd_rej_unk rej;
6484 BT_ERR("Wrong link type (%d)", err);
6486 rej.reason = cpu_to_le16(L2CAP_REJ_NOT_UNDERSTOOD);
6487 l2cap_send_cmd(conn, cmd->ident, L2CAP_COMMAND_REJ,
6495 static inline void l2cap_sig_send_rej(struct l2cap_conn *conn, u16 ident)
6497 struct l2cap_cmd_rej_unk rej;
6499 rej.reason = cpu_to_le16(L2CAP_REJ_NOT_UNDERSTOOD);
6500 l2cap_send_cmd(conn, ident, L2CAP_COMMAND_REJ, sizeof(rej), &rej);
6503 static inline void l2cap_sig_channel(struct l2cap_conn *conn,
6504 struct sk_buff *skb)
6506 struct hci_conn *hcon = conn->hcon;
6507 struct l2cap_cmd_hdr *cmd;
6510 l2cap_raw_recv(conn, skb);
6512 if (hcon->type != ACL_LINK)
6515 while (skb->len >= L2CAP_CMD_HDR_SIZE) {
6518 cmd = (void *) skb->data;
6519 skb_pull(skb, L2CAP_CMD_HDR_SIZE);
6521 len = le16_to_cpu(cmd->len);
6523 BT_DBG("code 0x%2.2x len %d id 0x%2.2x", cmd->code, len,
6526 if (len > skb->len || !cmd->ident) {
6527 BT_DBG("corrupted command");
6528 l2cap_sig_send_rej(conn, cmd->ident);
6529 skb_pull(skb, len > skb->len ? skb->len : len);
6533 err = l2cap_bredr_sig_cmd(conn, cmd, len, skb->data);
6535 BT_ERR("Wrong link type (%d)", err);
6536 l2cap_sig_send_rej(conn, cmd->ident);
6543 BT_DBG("corrupted command");
6544 l2cap_sig_send_rej(conn, 0);
6551 static int l2cap_check_fcs(struct l2cap_chan *chan, struct sk_buff *skb)
6553 u16 our_fcs, rcv_fcs;
6556 if (test_bit(FLAG_EXT_CTRL, &chan->flags))
6557 hdr_size = L2CAP_EXT_HDR_SIZE;
6559 hdr_size = L2CAP_ENH_HDR_SIZE;
6561 if (chan->fcs == L2CAP_FCS_CRC16) {
6562 skb_trim(skb, skb->len - L2CAP_FCS_SIZE);
6563 rcv_fcs = get_unaligned_le16(skb->data + skb->len);
6564 our_fcs = crc16(0, skb->data - hdr_size, skb->len + hdr_size);
6566 if (our_fcs != rcv_fcs)
6572 static void l2cap_send_i_or_rr_or_rnr(struct l2cap_chan *chan)
6574 struct l2cap_ctrl control;
6576 BT_DBG("chan %p", chan);
6578 memset(&control, 0, sizeof(control));
6581 control.reqseq = chan->buffer_seq;
6582 set_bit(CONN_SEND_FBIT, &chan->conn_state);
6584 if (test_bit(CONN_LOCAL_BUSY, &chan->conn_state)) {
6585 control.super = L2CAP_SUPER_RNR;
6586 l2cap_send_sframe(chan, &control);
6589 if (test_and_clear_bit(CONN_REMOTE_BUSY, &chan->conn_state) &&
6590 chan->unacked_frames > 0)
6591 __set_retrans_timer(chan);
6593 /* Send pending iframes */
6594 l2cap_ertm_send(chan);
6596 if (!test_bit(CONN_LOCAL_BUSY, &chan->conn_state) &&
6597 test_bit(CONN_SEND_FBIT, &chan->conn_state)) {
6598 /* F-bit wasn't sent in an s-frame or i-frame yet, so
6601 control.super = L2CAP_SUPER_RR;
6602 l2cap_send_sframe(chan, &control);
6606 static void append_skb_frag(struct sk_buff *skb, struct sk_buff *new_frag,
6607 struct sk_buff **last_frag)
6609 /* skb->len reflects data in skb as well as all fragments
6610 * skb->data_len reflects only data in fragments
6612 if (!skb_has_frag_list(skb))
6613 skb_shinfo(skb)->frag_list = new_frag;
6615 new_frag->next = NULL;
6617 (*last_frag)->next = new_frag;
6618 *last_frag = new_frag;
6620 skb->len += new_frag->len;
6621 skb->data_len += new_frag->len;
6622 skb->truesize += new_frag->truesize;
6625 static int l2cap_reassemble_sdu(struct l2cap_chan *chan, struct sk_buff *skb,
6626 struct l2cap_ctrl *control)
6630 switch (control->sar) {
6631 case L2CAP_SAR_UNSEGMENTED:
6635 err = chan->ops->recv(chan, skb);
6638 case L2CAP_SAR_START:
6642 if (!pskb_may_pull(skb, L2CAP_SDULEN_SIZE))
6645 chan->sdu_len = get_unaligned_le16(skb->data);
6646 skb_pull(skb, L2CAP_SDULEN_SIZE);
6648 if (chan->sdu_len > chan->imtu) {
6653 if (skb->len >= chan->sdu_len)
6657 chan->sdu_last_frag = skb;
6663 case L2CAP_SAR_CONTINUE:
6667 append_skb_frag(chan->sdu, skb,
6668 &chan->sdu_last_frag);
6671 if (chan->sdu->len >= chan->sdu_len)
6681 append_skb_frag(chan->sdu, skb,
6682 &chan->sdu_last_frag);
6685 if (chan->sdu->len != chan->sdu_len)
6688 err = chan->ops->recv(chan, chan->sdu);
6691 /* Reassembly complete */
6693 chan->sdu_last_frag = NULL;
6701 kfree_skb(chan->sdu);
6703 chan->sdu_last_frag = NULL;
6710 static int l2cap_resegment(struct l2cap_chan *chan)
6716 void l2cap_chan_busy(struct l2cap_chan *chan, int busy)
6720 if (chan->mode != L2CAP_MODE_ERTM)
6723 event = busy ? L2CAP_EV_LOCAL_BUSY_DETECTED : L2CAP_EV_LOCAL_BUSY_CLEAR;
6724 l2cap_tx(chan, NULL, NULL, event);
6727 static int l2cap_rx_queued_iframes(struct l2cap_chan *chan)
6730 /* Pass sequential frames to l2cap_reassemble_sdu()
6731 * until a gap is encountered.
6734 BT_DBG("chan %p", chan);
6736 while (!test_bit(CONN_LOCAL_BUSY, &chan->conn_state)) {
6737 struct sk_buff *skb;
6738 BT_DBG("Searching for skb with txseq %d (queue len %d)",
6739 chan->buffer_seq, skb_queue_len(&chan->srej_q));
6741 skb = l2cap_ertm_seq_in_queue(&chan->srej_q, chan->buffer_seq);
6746 skb_unlink(skb, &chan->srej_q);
6747 chan->buffer_seq = __next_seq(chan, chan->buffer_seq);
6748 err = l2cap_reassemble_sdu(chan, skb, &bt_cb(skb)->l2cap);
6753 if (skb_queue_empty(&chan->srej_q)) {
6754 chan->rx_state = L2CAP_RX_STATE_RECV;
6755 l2cap_send_ack(chan);
6761 static void l2cap_handle_srej(struct l2cap_chan *chan,
6762 struct l2cap_ctrl *control)
6764 struct sk_buff *skb;
6766 BT_DBG("chan %p, control %p", chan, control);
6768 if (control->reqseq == chan->next_tx_seq) {
6769 BT_DBG("Invalid reqseq %d, disconnecting", control->reqseq);
6770 l2cap_send_disconn_req(chan, ECONNRESET);
6774 skb = l2cap_ertm_seq_in_queue(&chan->tx_q, control->reqseq);
6777 BT_DBG("Seq %d not available for retransmission",
6782 if (chan->max_tx != 0 && bt_cb(skb)->l2cap.retries >= chan->max_tx) {
6783 BT_DBG("Retry limit exceeded (%d)", chan->max_tx);
6784 l2cap_send_disconn_req(chan, ECONNRESET);
6788 clear_bit(CONN_REMOTE_BUSY, &chan->conn_state);
6790 if (control->poll) {
6791 l2cap_pass_to_tx(chan, control);
6793 set_bit(CONN_SEND_FBIT, &chan->conn_state);
6794 l2cap_retransmit(chan, control);
6795 l2cap_ertm_send(chan);
6797 if (chan->tx_state == L2CAP_TX_STATE_WAIT_F) {
6798 set_bit(CONN_SREJ_ACT, &chan->conn_state);
6799 chan->srej_save_reqseq = control->reqseq;
6802 l2cap_pass_to_tx_fbit(chan, control);
6804 if (control->final) {
6805 if (chan->srej_save_reqseq != control->reqseq ||
6806 !test_and_clear_bit(CONN_SREJ_ACT,
6808 l2cap_retransmit(chan, control);
6810 l2cap_retransmit(chan, control);
6811 if (chan->tx_state == L2CAP_TX_STATE_WAIT_F) {
6812 set_bit(CONN_SREJ_ACT, &chan->conn_state);
6813 chan->srej_save_reqseq = control->reqseq;
6819 static void l2cap_handle_rej(struct l2cap_chan *chan,
6820 struct l2cap_ctrl *control)
6822 struct sk_buff *skb;
6824 BT_DBG("chan %p, control %p", chan, control);
6826 if (control->reqseq == chan->next_tx_seq) {
6827 BT_DBG("Invalid reqseq %d, disconnecting", control->reqseq);
6828 l2cap_send_disconn_req(chan, ECONNRESET);
6832 skb = l2cap_ertm_seq_in_queue(&chan->tx_q, control->reqseq);
6834 if (chan->max_tx && skb &&
6835 bt_cb(skb)->l2cap.retries >= chan->max_tx) {
6836 BT_DBG("Retry limit exceeded (%d)", chan->max_tx);
6837 l2cap_send_disconn_req(chan, ECONNRESET);
6841 clear_bit(CONN_REMOTE_BUSY, &chan->conn_state);
6843 l2cap_pass_to_tx(chan, control);
6845 if (control->final) {
6846 if (!test_and_clear_bit(CONN_REJ_ACT, &chan->conn_state))
6847 l2cap_retransmit_all(chan, control);
6849 l2cap_retransmit_all(chan, control);
6850 l2cap_ertm_send(chan);
6851 if (chan->tx_state == L2CAP_TX_STATE_WAIT_F)
6852 set_bit(CONN_REJ_ACT, &chan->conn_state);
6856 static u8 l2cap_classify_txseq(struct l2cap_chan *chan, u16 txseq)
6858 BT_DBG("chan %p, txseq %d", chan, txseq);
6860 BT_DBG("last_acked_seq %d, expected_tx_seq %d", chan->last_acked_seq,
6861 chan->expected_tx_seq);
6863 if (chan->rx_state == L2CAP_RX_STATE_SREJ_SENT) {
6864 if (__seq_offset(chan, txseq, chan->last_acked_seq) >=
6866 /* See notes below regarding "double poll" and
6869 if (chan->tx_win <= ((chan->tx_win_max + 1) >> 1)) {
6870 BT_DBG("Invalid/Ignore - after SREJ");
6871 return L2CAP_TXSEQ_INVALID_IGNORE;
6873 BT_DBG("Invalid - in window after SREJ sent");
6874 return L2CAP_TXSEQ_INVALID;
6878 if (chan->srej_list.head == txseq) {
6879 BT_DBG("Expected SREJ");
6880 return L2CAP_TXSEQ_EXPECTED_SREJ;
6883 if (l2cap_ertm_seq_in_queue(&chan->srej_q, txseq)) {
6884 BT_DBG("Duplicate SREJ - txseq already stored");
6885 return L2CAP_TXSEQ_DUPLICATE_SREJ;
6888 if (l2cap_seq_list_contains(&chan->srej_list, txseq)) {
6889 BT_DBG("Unexpected SREJ - not requested");
6890 return L2CAP_TXSEQ_UNEXPECTED_SREJ;
6894 if (chan->expected_tx_seq == txseq) {
6895 if (__seq_offset(chan, txseq, chan->last_acked_seq) >=
6897 BT_DBG("Invalid - txseq outside tx window");
6898 return L2CAP_TXSEQ_INVALID;
6901 return L2CAP_TXSEQ_EXPECTED;
6905 if (__seq_offset(chan, txseq, chan->last_acked_seq) <
6906 __seq_offset(chan, chan->expected_tx_seq, chan->last_acked_seq)) {
6907 BT_DBG("Duplicate - expected_tx_seq later than txseq");
6908 return L2CAP_TXSEQ_DUPLICATE;
6911 if (__seq_offset(chan, txseq, chan->last_acked_seq) >= chan->tx_win) {
6912 /* A source of invalid packets is a "double poll" condition,
6913 * where delays cause us to send multiple poll packets. If
6914 * the remote stack receives and processes both polls,
6915 * sequence numbers can wrap around in such a way that a
6916 * resent frame has a sequence number that looks like new data
6917 * with a sequence gap. This would trigger an erroneous SREJ
6920 * Fortunately, this is impossible with a tx window that's
6921 * less than half of the maximum sequence number, which allows
6922 * invalid frames to be safely ignored.
6924 * With tx window sizes greater than half of the tx window
6925 * maximum, the frame is invalid and cannot be ignored. This
6926 * causes a disconnect.
6929 if (chan->tx_win <= ((chan->tx_win_max + 1) >> 1)) {
6930 BT_DBG("Invalid/Ignore - txseq outside tx window");
6931 return L2CAP_TXSEQ_INVALID_IGNORE;
6933 BT_DBG("Invalid - txseq outside tx window");
6934 return L2CAP_TXSEQ_INVALID;
6937 BT_DBG("Unexpected - txseq indicates missing frames");
6938 return L2CAP_TXSEQ_UNEXPECTED;
6942 static int l2cap_rx_state_recv(struct l2cap_chan *chan,
6943 struct l2cap_ctrl *control,
6944 struct sk_buff *skb, u8 event)
6946 struct l2cap_ctrl local_control;
6948 bool skb_in_use = false;
6950 BT_DBG("chan %p, control %p, skb %p, event %d", chan, control, skb,
6954 case L2CAP_EV_RECV_IFRAME:
6955 switch (l2cap_classify_txseq(chan, control->txseq)) {
6956 case L2CAP_TXSEQ_EXPECTED:
6957 l2cap_pass_to_tx(chan, control);
6959 if (test_bit(CONN_LOCAL_BUSY, &chan->conn_state)) {
6960 BT_DBG("Busy, discarding expected seq %d",
6965 chan->expected_tx_seq = __next_seq(chan,
6968 chan->buffer_seq = chan->expected_tx_seq;
6971 /* l2cap_reassemble_sdu may free skb, hence invalidate
6972 * control, so make a copy in advance to use it after
6973 * l2cap_reassemble_sdu returns and to avoid the race
6974 * condition, for example:
6976 * The current thread calls:
6977 * l2cap_reassemble_sdu
6978 * chan->ops->recv == l2cap_sock_recv_cb
6979 * __sock_queue_rcv_skb
6980 * Another thread calls:
6984 * Then the current thread tries to access control, but
6985 * it was freed by skb_free_datagram.
6987 local_control = *control;
6988 err = l2cap_reassemble_sdu(chan, skb, control);
6992 if (local_control.final) {
6993 if (!test_and_clear_bit(CONN_REJ_ACT,
6994 &chan->conn_state)) {
6995 local_control.final = 0;
6996 l2cap_retransmit_all(chan, &local_control);
6997 l2cap_ertm_send(chan);
7001 if (!test_bit(CONN_LOCAL_BUSY, &chan->conn_state))
7002 l2cap_send_ack(chan);
7004 case L2CAP_TXSEQ_UNEXPECTED:
7005 l2cap_pass_to_tx(chan, control);
7007 /* Can't issue SREJ frames in the local busy state.
7008 * Drop this frame, it will be seen as missing
7009 * when local busy is exited.
7011 if (test_bit(CONN_LOCAL_BUSY, &chan->conn_state)) {
7012 BT_DBG("Busy, discarding unexpected seq %d",
7017 /* There was a gap in the sequence, so an SREJ
7018 * must be sent for each missing frame. The
7019 * current frame is stored for later use.
7021 skb_queue_tail(&chan->srej_q, skb);
7023 BT_DBG("Queued %p (queue len %d)", skb,
7024 skb_queue_len(&chan->srej_q));
7026 clear_bit(CONN_SREJ_ACT, &chan->conn_state);
7027 l2cap_seq_list_clear(&chan->srej_list);
7028 l2cap_send_srej(chan, control->txseq);
7030 chan->rx_state = L2CAP_RX_STATE_SREJ_SENT;
7032 case L2CAP_TXSEQ_DUPLICATE:
7033 l2cap_pass_to_tx(chan, control);
7035 case L2CAP_TXSEQ_INVALID_IGNORE:
7037 case L2CAP_TXSEQ_INVALID:
7039 l2cap_send_disconn_req(chan, ECONNRESET);
7043 case L2CAP_EV_RECV_RR:
7044 l2cap_pass_to_tx(chan, control);
7045 if (control->final) {
7046 clear_bit(CONN_REMOTE_BUSY, &chan->conn_state);
7048 if (!test_and_clear_bit(CONN_REJ_ACT, &chan->conn_state) &&
7049 !__chan_is_moving(chan)) {
7051 l2cap_retransmit_all(chan, control);
7054 l2cap_ertm_send(chan);
7055 } else if (control->poll) {
7056 l2cap_send_i_or_rr_or_rnr(chan);
7058 if (test_and_clear_bit(CONN_REMOTE_BUSY,
7059 &chan->conn_state) &&
7060 chan->unacked_frames)
7061 __set_retrans_timer(chan);
7063 l2cap_ertm_send(chan);
7066 case L2CAP_EV_RECV_RNR:
7067 set_bit(CONN_REMOTE_BUSY, &chan->conn_state);
7068 l2cap_pass_to_tx(chan, control);
7069 if (control && control->poll) {
7070 set_bit(CONN_SEND_FBIT, &chan->conn_state);
7071 l2cap_send_rr_or_rnr(chan, 0);
7073 __clear_retrans_timer(chan);
7074 l2cap_seq_list_clear(&chan->retrans_list);
7076 case L2CAP_EV_RECV_REJ:
7077 l2cap_handle_rej(chan, control);
7079 case L2CAP_EV_RECV_SREJ:
7080 l2cap_handle_srej(chan, control);
7086 if (skb && !skb_in_use) {
7087 BT_DBG("Freeing %p", skb);
7094 static int l2cap_rx_state_srej_sent(struct l2cap_chan *chan,
7095 struct l2cap_ctrl *control,
7096 struct sk_buff *skb, u8 event)
7099 u16 txseq = control->txseq;
7100 bool skb_in_use = false;
7102 BT_DBG("chan %p, control %p, skb %p, event %d", chan, control, skb,
7106 case L2CAP_EV_RECV_IFRAME:
7107 switch (l2cap_classify_txseq(chan, txseq)) {
7108 case L2CAP_TXSEQ_EXPECTED:
7109 /* Keep frame for reassembly later */
7110 l2cap_pass_to_tx(chan, control);
7111 skb_queue_tail(&chan->srej_q, skb);
7113 BT_DBG("Queued %p (queue len %d)", skb,
7114 skb_queue_len(&chan->srej_q));
7116 chan->expected_tx_seq = __next_seq(chan, txseq);
7118 case L2CAP_TXSEQ_EXPECTED_SREJ:
7119 l2cap_seq_list_pop(&chan->srej_list);
7121 l2cap_pass_to_tx(chan, control);
7122 skb_queue_tail(&chan->srej_q, skb);
7124 BT_DBG("Queued %p (queue len %d)", skb,
7125 skb_queue_len(&chan->srej_q));
7127 err = l2cap_rx_queued_iframes(chan);
7132 case L2CAP_TXSEQ_UNEXPECTED:
7133 /* Got a frame that can't be reassembled yet.
7134 * Save it for later, and send SREJs to cover
7135 * the missing frames.
7137 skb_queue_tail(&chan->srej_q, skb);
7139 BT_DBG("Queued %p (queue len %d)", skb,
7140 skb_queue_len(&chan->srej_q));
7142 l2cap_pass_to_tx(chan, control);
7143 l2cap_send_srej(chan, control->txseq);
7145 case L2CAP_TXSEQ_UNEXPECTED_SREJ:
7146 /* This frame was requested with an SREJ, but
7147 * some expected retransmitted frames are
7148 * missing. Request retransmission of missing
7151 skb_queue_tail(&chan->srej_q, skb);
7153 BT_DBG("Queued %p (queue len %d)", skb,
7154 skb_queue_len(&chan->srej_q));
7156 l2cap_pass_to_tx(chan, control);
7157 l2cap_send_srej_list(chan, control->txseq);
7159 case L2CAP_TXSEQ_DUPLICATE_SREJ:
7160 /* We've already queued this frame. Drop this copy. */
7161 l2cap_pass_to_tx(chan, control);
7163 case L2CAP_TXSEQ_DUPLICATE:
7164 /* Expecting a later sequence number, so this frame
7165 * was already received. Ignore it completely.
7168 case L2CAP_TXSEQ_INVALID_IGNORE:
7170 case L2CAP_TXSEQ_INVALID:
7172 l2cap_send_disconn_req(chan, ECONNRESET);
7176 case L2CAP_EV_RECV_RR:
7177 l2cap_pass_to_tx(chan, control);
7178 if (control->final) {
7179 clear_bit(CONN_REMOTE_BUSY, &chan->conn_state);
7181 if (!test_and_clear_bit(CONN_REJ_ACT,
7182 &chan->conn_state)) {
7184 l2cap_retransmit_all(chan, control);
7187 l2cap_ertm_send(chan);
7188 } else if (control->poll) {
7189 if (test_and_clear_bit(CONN_REMOTE_BUSY,
7190 &chan->conn_state) &&
7191 chan->unacked_frames) {
7192 __set_retrans_timer(chan);
7195 set_bit(CONN_SEND_FBIT, &chan->conn_state);
7196 l2cap_send_srej_tail(chan);
7198 if (test_and_clear_bit(CONN_REMOTE_BUSY,
7199 &chan->conn_state) &&
7200 chan->unacked_frames)
7201 __set_retrans_timer(chan);
7203 l2cap_send_ack(chan);
7206 case L2CAP_EV_RECV_RNR:
7207 set_bit(CONN_REMOTE_BUSY, &chan->conn_state);
7208 l2cap_pass_to_tx(chan, control);
7209 if (control->poll) {
7210 l2cap_send_srej_tail(chan);
7212 struct l2cap_ctrl rr_control;
7213 memset(&rr_control, 0, sizeof(rr_control));
7214 rr_control.sframe = 1;
7215 rr_control.super = L2CAP_SUPER_RR;
7216 rr_control.reqseq = chan->buffer_seq;
7217 l2cap_send_sframe(chan, &rr_control);
7221 case L2CAP_EV_RECV_REJ:
7222 l2cap_handle_rej(chan, control);
7224 case L2CAP_EV_RECV_SREJ:
7225 l2cap_handle_srej(chan, control);
7229 if (skb && !skb_in_use) {
7230 BT_DBG("Freeing %p", skb);
7237 static int l2cap_finish_move(struct l2cap_chan *chan)
7239 BT_DBG("chan %p", chan);
7241 chan->rx_state = L2CAP_RX_STATE_RECV;
7244 chan->conn->mtu = chan->hs_hcon->hdev->block_mtu;
7246 chan->conn->mtu = chan->conn->hcon->hdev->acl_mtu;
7248 return l2cap_resegment(chan);
7251 static int l2cap_rx_state_wait_p(struct l2cap_chan *chan,
7252 struct l2cap_ctrl *control,
7253 struct sk_buff *skb, u8 event)
7257 BT_DBG("chan %p, control %p, skb %p, event %d", chan, control, skb,
7263 l2cap_process_reqseq(chan, control->reqseq);
7265 if (!skb_queue_empty(&chan->tx_q))
7266 chan->tx_send_head = skb_peek(&chan->tx_q);
7268 chan->tx_send_head = NULL;
7270 /* Rewind next_tx_seq to the point expected
7273 chan->next_tx_seq = control->reqseq;
7274 chan->unacked_frames = 0;
7276 err = l2cap_finish_move(chan);
7280 set_bit(CONN_SEND_FBIT, &chan->conn_state);
7281 l2cap_send_i_or_rr_or_rnr(chan);
7283 if (event == L2CAP_EV_RECV_IFRAME)
7286 return l2cap_rx_state_recv(chan, control, NULL, event);
7289 static int l2cap_rx_state_wait_f(struct l2cap_chan *chan,
7290 struct l2cap_ctrl *control,
7291 struct sk_buff *skb, u8 event)
7295 if (!control->final)
7298 clear_bit(CONN_REMOTE_BUSY, &chan->conn_state);
7300 chan->rx_state = L2CAP_RX_STATE_RECV;
7301 l2cap_process_reqseq(chan, control->reqseq);
7303 if (!skb_queue_empty(&chan->tx_q))
7304 chan->tx_send_head = skb_peek(&chan->tx_q);
7306 chan->tx_send_head = NULL;
7308 /* Rewind next_tx_seq to the point expected
7311 chan->next_tx_seq = control->reqseq;
7312 chan->unacked_frames = 0;
7315 chan->conn->mtu = chan->hs_hcon->hdev->block_mtu;
7317 chan->conn->mtu = chan->conn->hcon->hdev->acl_mtu;
7319 err = l2cap_resegment(chan);
7322 err = l2cap_rx_state_recv(chan, control, skb, event);
7327 static bool __valid_reqseq(struct l2cap_chan *chan, u16 reqseq)
7329 /* Make sure reqseq is for a packet that has been sent but not acked */
7332 unacked = __seq_offset(chan, chan->next_tx_seq, chan->expected_ack_seq);
7333 return __seq_offset(chan, chan->next_tx_seq, reqseq) <= unacked;
7336 static int l2cap_rx(struct l2cap_chan *chan, struct l2cap_ctrl *control,
7337 struct sk_buff *skb, u8 event)
7341 BT_DBG("chan %p, control %p, skb %p, event %d, state %d", chan,
7342 control, skb, event, chan->rx_state);
7344 if (__valid_reqseq(chan, control->reqseq)) {
7345 switch (chan->rx_state) {
7346 case L2CAP_RX_STATE_RECV:
7347 err = l2cap_rx_state_recv(chan, control, skb, event);
7349 case L2CAP_RX_STATE_SREJ_SENT:
7350 err = l2cap_rx_state_srej_sent(chan, control, skb,
7353 case L2CAP_RX_STATE_WAIT_P:
7354 err = l2cap_rx_state_wait_p(chan, control, skb, event);
7356 case L2CAP_RX_STATE_WAIT_F:
7357 err = l2cap_rx_state_wait_f(chan, control, skb, event);
7364 BT_DBG("Invalid reqseq %d (next_tx_seq %d, expected_ack_seq %d",
7365 control->reqseq, chan->next_tx_seq,
7366 chan->expected_ack_seq);
7367 l2cap_send_disconn_req(chan, ECONNRESET);
7373 static int l2cap_stream_rx(struct l2cap_chan *chan, struct l2cap_ctrl *control,
7374 struct sk_buff *skb)
7376 /* l2cap_reassemble_sdu may free skb, hence invalidate control, so store
7377 * the txseq field in advance to use it after l2cap_reassemble_sdu
7378 * returns and to avoid the race condition, for example:
7380 * The current thread calls:
7381 * l2cap_reassemble_sdu
7382 * chan->ops->recv == l2cap_sock_recv_cb
7383 * __sock_queue_rcv_skb
7384 * Another thread calls:
7388 * Then the current thread tries to access control, but it was freed by
7389 * skb_free_datagram.
7391 u16 txseq = control->txseq;
7393 BT_DBG("chan %p, control %p, skb %p, state %d", chan, control, skb,
7396 if (l2cap_classify_txseq(chan, txseq) == L2CAP_TXSEQ_EXPECTED) {
7397 l2cap_pass_to_tx(chan, control);
7399 BT_DBG("buffer_seq %u->%u", chan->buffer_seq,
7400 __next_seq(chan, chan->buffer_seq));
7402 chan->buffer_seq = __next_seq(chan, chan->buffer_seq);
7404 l2cap_reassemble_sdu(chan, skb, control);
7407 kfree_skb(chan->sdu);
7410 chan->sdu_last_frag = NULL;
7414 BT_DBG("Freeing %p", skb);
7419 chan->last_acked_seq = txseq;
7420 chan->expected_tx_seq = __next_seq(chan, txseq);
7425 static int l2cap_data_rcv(struct l2cap_chan *chan, struct sk_buff *skb)
7427 struct l2cap_ctrl *control = &bt_cb(skb)->l2cap;
7431 __unpack_control(chan, skb);
7436 * We can just drop the corrupted I-frame here.
7437 * Receiver will miss it and start proper recovery
7438 * procedures and ask for retransmission.
7440 if (l2cap_check_fcs(chan, skb))
7443 if (!control->sframe && control->sar == L2CAP_SAR_START)
7444 len -= L2CAP_SDULEN_SIZE;
7446 if (chan->fcs == L2CAP_FCS_CRC16)
7447 len -= L2CAP_FCS_SIZE;
7449 if (len > chan->mps) {
7450 l2cap_send_disconn_req(chan, ECONNRESET);
7454 if (chan->ops->filter) {
7455 if (chan->ops->filter(chan, skb))
7459 if (!control->sframe) {
7462 BT_DBG("iframe sar %d, reqseq %d, final %d, txseq %d",
7463 control->sar, control->reqseq, control->final,
7466 /* Validate F-bit - F=0 always valid, F=1 only
7467 * valid in TX WAIT_F
7469 if (control->final && chan->tx_state != L2CAP_TX_STATE_WAIT_F)
7472 if (chan->mode != L2CAP_MODE_STREAMING) {
7473 event = L2CAP_EV_RECV_IFRAME;
7474 err = l2cap_rx(chan, control, skb, event);
7476 err = l2cap_stream_rx(chan, control, skb);
7480 l2cap_send_disconn_req(chan, ECONNRESET);
7482 const u8 rx_func_to_event[4] = {
7483 L2CAP_EV_RECV_RR, L2CAP_EV_RECV_REJ,
7484 L2CAP_EV_RECV_RNR, L2CAP_EV_RECV_SREJ
7487 /* Only I-frames are expected in streaming mode */
7488 if (chan->mode == L2CAP_MODE_STREAMING)
7491 BT_DBG("sframe reqseq %d, final %d, poll %d, super %d",
7492 control->reqseq, control->final, control->poll,
7496 BT_ERR("Trailing bytes: %d in sframe", len);
7497 l2cap_send_disconn_req(chan, ECONNRESET);
7501 /* Validate F and P bits */
7502 if (control->final && (control->poll ||
7503 chan->tx_state != L2CAP_TX_STATE_WAIT_F))
7506 event = rx_func_to_event[control->super];
7507 if (l2cap_rx(chan, control, skb, event))
7508 l2cap_send_disconn_req(chan, ECONNRESET);
7518 static void l2cap_chan_le_send_credits(struct l2cap_chan *chan)
7520 struct l2cap_conn *conn = chan->conn;
7521 struct l2cap_le_credits pkt;
7524 return_credits = (chan->imtu / chan->mps) + 1;
7526 if (chan->rx_credits >= return_credits)
7529 return_credits -= chan->rx_credits;
7531 BT_DBG("chan %p returning %u credits to sender", chan, return_credits);
7533 chan->rx_credits += return_credits;
7535 pkt.cid = cpu_to_le16(chan->scid);
7536 pkt.credits = cpu_to_le16(return_credits);
7538 chan->ident = l2cap_get_ident(conn);
7540 l2cap_send_cmd(conn, chan->ident, L2CAP_LE_CREDITS, sizeof(pkt), &pkt);
7543 static int l2cap_ecred_recv(struct l2cap_chan *chan, struct sk_buff *skb)
7547 BT_DBG("SDU reassemble complete: chan %p skb->len %u", chan, skb->len);
7549 /* Wait recv to confirm reception before updating the credits */
7550 err = chan->ops->recv(chan, skb);
7552 /* Update credits whenever an SDU is received */
7553 l2cap_chan_le_send_credits(chan);
7558 static int l2cap_ecred_data_rcv(struct l2cap_chan *chan, struct sk_buff *skb)
7562 if (!chan->rx_credits) {
7563 BT_ERR("No credits to receive LE L2CAP data");
7564 l2cap_send_disconn_req(chan, ECONNRESET);
7568 if (chan->imtu < skb->len) {
7569 BT_ERR("Too big LE L2CAP PDU");
7574 BT_DBG("rx_credits %u -> %u", chan->rx_credits + 1, chan->rx_credits);
7576 /* Update if remote had run out of credits, this should only happens
7577 * if the remote is not using the entire MPS.
7579 if (!chan->rx_credits)
7580 l2cap_chan_le_send_credits(chan);
7587 sdu_len = get_unaligned_le16(skb->data);
7588 skb_pull(skb, L2CAP_SDULEN_SIZE);
7590 BT_DBG("Start of new SDU. sdu_len %u skb->len %u imtu %u",
7591 sdu_len, skb->len, chan->imtu);
7593 if (sdu_len > chan->imtu) {
7594 BT_ERR("Too big LE L2CAP SDU length received");
7599 if (skb->len > sdu_len) {
7600 BT_ERR("Too much LE L2CAP data received");
7605 if (skb->len == sdu_len)
7606 return l2cap_ecred_recv(chan, skb);
7609 chan->sdu_len = sdu_len;
7610 chan->sdu_last_frag = skb;
7612 /* Detect if remote is not able to use the selected MPS */
7613 if (skb->len + L2CAP_SDULEN_SIZE < chan->mps) {
7614 u16 mps_len = skb->len + L2CAP_SDULEN_SIZE;
7616 /* Adjust the number of credits */
7617 BT_DBG("chan->mps %u -> %u", chan->mps, mps_len);
7618 chan->mps = mps_len;
7619 l2cap_chan_le_send_credits(chan);
7625 BT_DBG("SDU fragment. chan->sdu->len %u skb->len %u chan->sdu_len %u",
7626 chan->sdu->len, skb->len, chan->sdu_len);
7628 if (chan->sdu->len + skb->len > chan->sdu_len) {
7629 BT_ERR("Too much LE L2CAP data received");
7634 append_skb_frag(chan->sdu, skb, &chan->sdu_last_frag);
7637 if (chan->sdu->len == chan->sdu_len) {
7638 err = l2cap_ecred_recv(chan, chan->sdu);
7641 chan->sdu_last_frag = NULL;
7649 kfree_skb(chan->sdu);
7651 chan->sdu_last_frag = NULL;
7655 /* We can't return an error here since we took care of the skb
7656 * freeing internally. An error return would cause the caller to
7657 * do a double-free of the skb.
7662 static void l2cap_data_channel(struct l2cap_conn *conn, u16 cid,
7663 struct sk_buff *skb)
7665 struct l2cap_chan *chan;
7667 chan = l2cap_get_chan_by_scid(conn, cid);
7669 if (cid == L2CAP_CID_A2MP) {
7670 chan = a2mp_channel_create(conn, skb);
7676 l2cap_chan_hold(chan);
7677 l2cap_chan_lock(chan);
7679 BT_DBG("unknown cid 0x%4.4x", cid);
7680 /* Drop packet and return */
7686 BT_DBG("chan %p, len %d", chan, skb->len);
7688 /* If we receive data on a fixed channel before the info req/rsp
7689 * procedure is done simply assume that the channel is supported
7690 * and mark it as ready.
7692 if (chan->chan_type == L2CAP_CHAN_FIXED)
7693 l2cap_chan_ready(chan);
7695 if (chan->state != BT_CONNECTED)
7698 switch (chan->mode) {
7699 case L2CAP_MODE_LE_FLOWCTL:
7700 case L2CAP_MODE_EXT_FLOWCTL:
7701 if (l2cap_ecred_data_rcv(chan, skb) < 0)
7706 case L2CAP_MODE_BASIC:
7707 /* If socket recv buffers overflows we drop data here
7708 * which is *bad* because L2CAP has to be reliable.
7709 * But we don't have any other choice. L2CAP doesn't
7710 * provide flow control mechanism. */
7712 if (chan->imtu < skb->len) {
7713 BT_ERR("Dropping L2CAP data: receive buffer overflow");
7717 if (!chan->ops->recv(chan, skb))
7721 case L2CAP_MODE_ERTM:
7722 case L2CAP_MODE_STREAMING:
7723 l2cap_data_rcv(chan, skb);
7727 BT_DBG("chan %p: bad mode 0x%2.2x", chan, chan->mode);
7735 l2cap_chan_unlock(chan);
7736 l2cap_chan_put(chan);
7739 static void l2cap_conless_channel(struct l2cap_conn *conn, __le16 psm,
7740 struct sk_buff *skb)
7742 struct hci_conn *hcon = conn->hcon;
7743 struct l2cap_chan *chan;
7745 if (hcon->type != ACL_LINK)
7748 chan = l2cap_global_chan_by_psm(0, psm, &hcon->src, &hcon->dst,
7753 BT_DBG("chan %p, len %d", chan, skb->len);
7755 if (chan->state != BT_BOUND && chan->state != BT_CONNECTED)
7758 if (chan->imtu < skb->len)
7761 /* Store remote BD_ADDR and PSM for msg_name */
7762 bacpy(&bt_cb(skb)->l2cap.bdaddr, &hcon->dst);
7763 bt_cb(skb)->l2cap.psm = psm;
7765 if (!chan->ops->recv(chan, skb)) {
7766 l2cap_chan_put(chan);
7771 l2cap_chan_put(chan);
7776 static void l2cap_recv_frame(struct l2cap_conn *conn, struct sk_buff *skb)
7778 struct l2cap_hdr *lh = (void *) skb->data;
7779 struct hci_conn *hcon = conn->hcon;
7783 if (hcon->state != BT_CONNECTED) {
7784 BT_DBG("queueing pending rx skb");
7785 skb_queue_tail(&conn->pending_rx, skb);
7789 skb_pull(skb, L2CAP_HDR_SIZE);
7790 cid = __le16_to_cpu(lh->cid);
7791 len = __le16_to_cpu(lh->len);
7793 if (len != skb->len) {
7798 /* Since we can't actively block incoming LE connections we must
7799 * at least ensure that we ignore incoming data from them.
7801 if (hcon->type == LE_LINK &&
7802 hci_bdaddr_list_lookup(&hcon->hdev->reject_list, &hcon->dst,
7803 bdaddr_dst_type(hcon))) {
7808 BT_DBG("len %d, cid 0x%4.4x", len, cid);
7811 case L2CAP_CID_SIGNALING:
7812 l2cap_sig_channel(conn, skb);
7815 case L2CAP_CID_CONN_LESS:
7816 psm = get_unaligned((__le16 *) skb->data);
7817 skb_pull(skb, L2CAP_PSMLEN_SIZE);
7818 l2cap_conless_channel(conn, psm, skb);
7821 case L2CAP_CID_LE_SIGNALING:
7822 l2cap_le_sig_channel(conn, skb);
7826 l2cap_data_channel(conn, cid, skb);
7831 static void process_pending_rx(struct work_struct *work)
7833 struct l2cap_conn *conn = container_of(work, struct l2cap_conn,
7835 struct sk_buff *skb;
7839 while ((skb = skb_dequeue(&conn->pending_rx)))
7840 l2cap_recv_frame(conn, skb);
7843 static struct l2cap_conn *l2cap_conn_add(struct hci_conn *hcon)
7845 struct l2cap_conn *conn = hcon->l2cap_data;
7846 struct hci_chan *hchan;
7851 hchan = hci_chan_create(hcon);
7855 conn = kzalloc(sizeof(*conn), GFP_KERNEL);
7857 hci_chan_del(hchan);
7861 kref_init(&conn->ref);
7862 hcon->l2cap_data = conn;
7863 conn->hcon = hci_conn_get(hcon);
7864 conn->hchan = hchan;
7866 BT_DBG("hcon %p conn %p hchan %p", hcon, conn, hchan);
7868 switch (hcon->type) {
7870 if (hcon->hdev->le_mtu) {
7871 conn->mtu = hcon->hdev->le_mtu;
7876 conn->mtu = hcon->hdev->acl_mtu;
7880 conn->feat_mask = 0;
7882 conn->local_fixed_chan = L2CAP_FC_SIG_BREDR | L2CAP_FC_CONNLESS;
7884 if (hcon->type == ACL_LINK &&
7885 hci_dev_test_flag(hcon->hdev, HCI_HS_ENABLED))
7886 conn->local_fixed_chan |= L2CAP_FC_A2MP;
7888 if (hci_dev_test_flag(hcon->hdev, HCI_LE_ENABLED) &&
7889 (bredr_sc_enabled(hcon->hdev) ||
7890 hci_dev_test_flag(hcon->hdev, HCI_FORCE_BREDR_SMP)))
7891 conn->local_fixed_chan |= L2CAP_FC_SMP_BREDR;
7893 mutex_init(&conn->ident_lock);
7894 mutex_init(&conn->chan_lock);
7896 INIT_LIST_HEAD(&conn->chan_l);
7897 INIT_LIST_HEAD(&conn->users);
7899 INIT_DELAYED_WORK(&conn->info_timer, l2cap_info_timeout);
7901 skb_queue_head_init(&conn->pending_rx);
7902 INIT_WORK(&conn->pending_rx_work, process_pending_rx);
7903 INIT_DELAYED_WORK(&conn->id_addr_timer, l2cap_conn_update_id_addr);
7905 conn->disc_reason = HCI_ERROR_REMOTE_USER_TERM;
7910 static bool is_valid_psm(u16 psm, u8 dst_type)
7915 if (bdaddr_type_is_le(dst_type))
7916 return (psm <= 0x00ff);
7918 /* PSM must be odd and lsb of upper byte must be 0 */
7919 return ((psm & 0x0101) == 0x0001);
7922 struct l2cap_chan_data {
7923 struct l2cap_chan *chan;
7928 static void l2cap_chan_by_pid(struct l2cap_chan *chan, void *data)
7930 struct l2cap_chan_data *d = data;
7933 if (chan == d->chan)
7936 if (!test_bit(FLAG_DEFER_SETUP, &chan->flags))
7939 pid = chan->ops->get_peer_pid(chan);
7941 /* Only count deferred channels with the same PID/PSM */
7942 if (d->pid != pid || chan->psm != d->chan->psm || chan->ident ||
7943 chan->mode != L2CAP_MODE_EXT_FLOWCTL || chan->state != BT_CONNECT)
7949 int l2cap_chan_connect(struct l2cap_chan *chan, __le16 psm, u16 cid,
7950 bdaddr_t *dst, u8 dst_type)
7952 struct l2cap_conn *conn;
7953 struct hci_conn *hcon;
7954 struct hci_dev *hdev;
7957 BT_DBG("%pMR -> %pMR (type %u) psm 0x%4.4x mode 0x%2.2x", &chan->src,
7958 dst, dst_type, __le16_to_cpu(psm), chan->mode);
7960 hdev = hci_get_route(dst, &chan->src, chan->src_type);
7962 return -EHOSTUNREACH;
7966 if (!is_valid_psm(__le16_to_cpu(psm), dst_type) && !cid &&
7967 chan->chan_type != L2CAP_CHAN_RAW) {
7972 if (chan->chan_type == L2CAP_CHAN_CONN_ORIENTED && !psm) {
7977 if (chan->chan_type == L2CAP_CHAN_FIXED && !cid) {
7982 switch (chan->mode) {
7983 case L2CAP_MODE_BASIC:
7985 case L2CAP_MODE_LE_FLOWCTL:
7987 case L2CAP_MODE_EXT_FLOWCTL:
7988 if (!enable_ecred) {
7993 case L2CAP_MODE_ERTM:
7994 case L2CAP_MODE_STREAMING:
8003 switch (chan->state) {
8007 /* Already connecting */
8012 /* Already connected */
8026 /* Set destination address and psm */
8027 bacpy(&chan->dst, dst);
8028 chan->dst_type = dst_type;
8033 if (bdaddr_type_is_le(dst_type)) {
8034 /* Convert from L2CAP channel address type to HCI address type
8036 if (dst_type == BDADDR_LE_PUBLIC)
8037 dst_type = ADDR_LE_DEV_PUBLIC;
8039 dst_type = ADDR_LE_DEV_RANDOM;
8041 if (hci_dev_test_flag(hdev, HCI_ADVERTISING))
8042 hcon = hci_connect_le(hdev, dst, dst_type, false,
8044 HCI_LE_CONN_TIMEOUT,
8047 hcon = hci_connect_le_scan(hdev, dst, dst_type,
8049 HCI_LE_CONN_TIMEOUT,
8050 CONN_REASON_L2CAP_CHAN);
8053 u8 auth_type = l2cap_get_auth_type(chan);
8054 hcon = hci_connect_acl(hdev, dst, chan->sec_level, auth_type,
8055 CONN_REASON_L2CAP_CHAN);
8059 err = PTR_ERR(hcon);
8063 conn = l2cap_conn_add(hcon);
8065 hci_conn_drop(hcon);
8070 if (chan->mode == L2CAP_MODE_EXT_FLOWCTL) {
8071 struct l2cap_chan_data data;
8074 data.pid = chan->ops->get_peer_pid(chan);
8077 l2cap_chan_list(conn, l2cap_chan_by_pid, &data);
8079 /* Check if there isn't too many channels being connected */
8080 if (data.count > L2CAP_ECRED_CONN_SCID_MAX) {
8081 hci_conn_drop(hcon);
8087 mutex_lock(&conn->chan_lock);
8088 l2cap_chan_lock(chan);
8090 if (cid && __l2cap_get_chan_by_dcid(conn, cid)) {
8091 hci_conn_drop(hcon);
8096 /* Update source addr of the socket */
8097 bacpy(&chan->src, &hcon->src);
8098 chan->src_type = bdaddr_src_type(hcon);
8100 __l2cap_chan_add(conn, chan);
8102 /* l2cap_chan_add takes its own ref so we can drop this one */
8103 hci_conn_drop(hcon);
8105 l2cap_state_change(chan, BT_CONNECT);
8106 __set_chan_timer(chan, chan->ops->get_sndtimeo(chan));
8108 /* Release chan->sport so that it can be reused by other
8109 * sockets (as it's only used for listening sockets).
8111 write_lock(&chan_list_lock);
8113 write_unlock(&chan_list_lock);
8115 if (hcon->state == BT_CONNECTED) {
8116 if (chan->chan_type != L2CAP_CHAN_CONN_ORIENTED) {
8117 __clear_chan_timer(chan);
8118 if (l2cap_chan_check_security(chan, true))
8119 l2cap_state_change(chan, BT_CONNECTED);
8121 l2cap_do_start(chan);
8127 l2cap_chan_unlock(chan);
8128 mutex_unlock(&conn->chan_lock);
8130 hci_dev_unlock(hdev);
8134 EXPORT_SYMBOL_GPL(l2cap_chan_connect);
8136 static void l2cap_ecred_reconfigure(struct l2cap_chan *chan)
8138 struct l2cap_conn *conn = chan->conn;
8140 struct l2cap_ecred_reconf_req req;
8144 pdu.req.mtu = cpu_to_le16(chan->imtu);
8145 pdu.req.mps = cpu_to_le16(chan->mps);
8146 pdu.scid = cpu_to_le16(chan->scid);
8148 chan->ident = l2cap_get_ident(conn);
8150 l2cap_send_cmd(conn, chan->ident, L2CAP_ECRED_RECONF_REQ,
8154 int l2cap_chan_reconfigure(struct l2cap_chan *chan, __u16 mtu)
8156 if (chan->imtu > mtu)
8159 BT_DBG("chan %p mtu 0x%4.4x", chan, mtu);
8163 l2cap_ecred_reconfigure(chan);
8168 /* ---- L2CAP interface with lower layer (HCI) ---- */
8170 int l2cap_connect_ind(struct hci_dev *hdev, bdaddr_t *bdaddr)
8172 int exact = 0, lm1 = 0, lm2 = 0;
8173 struct l2cap_chan *c;
8175 BT_DBG("hdev %s, bdaddr %pMR", hdev->name, bdaddr);
8177 /* Find listening sockets and check their link_mode */
8178 read_lock(&chan_list_lock);
8179 list_for_each_entry(c, &chan_list, global_l) {
8180 if (c->state != BT_LISTEN)
8183 if (!bacmp(&c->src, &hdev->bdaddr)) {
8184 lm1 |= HCI_LM_ACCEPT;
8185 if (test_bit(FLAG_ROLE_SWITCH, &c->flags))
8186 lm1 |= HCI_LM_MASTER;
8188 } else if (!bacmp(&c->src, BDADDR_ANY)) {
8189 lm2 |= HCI_LM_ACCEPT;
8190 if (test_bit(FLAG_ROLE_SWITCH, &c->flags))
8191 lm2 |= HCI_LM_MASTER;
8194 read_unlock(&chan_list_lock);
8196 return exact ? lm1 : lm2;
8199 /* Find the next fixed channel in BT_LISTEN state, continue iteration
8200 * from an existing channel in the list or from the beginning of the
8201 * global list (by passing NULL as first parameter).
8203 static struct l2cap_chan *l2cap_global_fixed_chan(struct l2cap_chan *c,
8204 struct hci_conn *hcon)
8206 u8 src_type = bdaddr_src_type(hcon);
8208 read_lock(&chan_list_lock);
8211 c = list_next_entry(c, global_l);
8213 c = list_entry(chan_list.next, typeof(*c), global_l);
8215 list_for_each_entry_from(c, &chan_list, global_l) {
8216 if (c->chan_type != L2CAP_CHAN_FIXED)
8218 if (c->state != BT_LISTEN)
8220 if (bacmp(&c->src, &hcon->src) && bacmp(&c->src, BDADDR_ANY))
8222 if (src_type != c->src_type)
8225 c = l2cap_chan_hold_unless_zero(c);
8226 read_unlock(&chan_list_lock);
8230 read_unlock(&chan_list_lock);
8235 static void l2cap_connect_cfm(struct hci_conn *hcon, u8 status)
8237 struct hci_dev *hdev = hcon->hdev;
8238 struct l2cap_conn *conn;
8239 struct l2cap_chan *pchan;
8242 if (hcon->type != ACL_LINK && hcon->type != LE_LINK)
8245 BT_DBG("hcon %p bdaddr %pMR status %d", hcon, &hcon->dst, status);
8248 l2cap_conn_del(hcon, bt_to_errno(status));
8252 conn = l2cap_conn_add(hcon);
8256 dst_type = bdaddr_dst_type(hcon);
8258 /* If device is blocked, do not create channels for it */
8259 if (hci_bdaddr_list_lookup(&hdev->reject_list, &hcon->dst, dst_type))
8262 /* Find fixed channels and notify them of the new connection. We
8263 * use multiple individual lookups, continuing each time where
8264 * we left off, because the list lock would prevent calling the
8265 * potentially sleeping l2cap_chan_lock() function.
8267 pchan = l2cap_global_fixed_chan(NULL, hcon);
8269 struct l2cap_chan *chan, *next;
8271 /* Client fixed channels should override server ones */
8272 if (__l2cap_get_chan_by_dcid(conn, pchan->scid))
8275 l2cap_chan_lock(pchan);
8276 chan = pchan->ops->new_connection(pchan);
8278 bacpy(&chan->src, &hcon->src);
8279 bacpy(&chan->dst, &hcon->dst);
8280 chan->src_type = bdaddr_src_type(hcon);
8281 chan->dst_type = dst_type;
8283 __l2cap_chan_add(conn, chan);
8286 l2cap_chan_unlock(pchan);
8288 next = l2cap_global_fixed_chan(pchan, hcon);
8289 l2cap_chan_put(pchan);
8293 l2cap_conn_ready(conn);
8296 int l2cap_disconn_ind(struct hci_conn *hcon)
8298 struct l2cap_conn *conn = hcon->l2cap_data;
8300 BT_DBG("hcon %p", hcon);
8303 return HCI_ERROR_REMOTE_USER_TERM;
8304 return conn->disc_reason;
8307 static void l2cap_disconn_cfm(struct hci_conn *hcon, u8 reason)
8309 if (hcon->type != ACL_LINK && hcon->type != LE_LINK)
8312 BT_DBG("hcon %p reason %d", hcon, reason);
8314 l2cap_conn_del(hcon, bt_to_errno(reason));
8317 static inline void l2cap_check_encryption(struct l2cap_chan *chan, u8 encrypt)
8319 if (chan->chan_type != L2CAP_CHAN_CONN_ORIENTED)
8322 if (encrypt == 0x00) {
8323 if (chan->sec_level == BT_SECURITY_MEDIUM) {
8324 __set_chan_timer(chan, L2CAP_ENC_TIMEOUT);
8325 } else if (chan->sec_level == BT_SECURITY_HIGH ||
8326 chan->sec_level == BT_SECURITY_FIPS)
8327 l2cap_chan_close(chan, ECONNREFUSED);
8329 if (chan->sec_level == BT_SECURITY_MEDIUM)
8330 __clear_chan_timer(chan);
8334 static void l2cap_security_cfm(struct hci_conn *hcon, u8 status, u8 encrypt)
8336 struct l2cap_conn *conn = hcon->l2cap_data;
8337 struct l2cap_chan *chan;
8342 BT_DBG("conn %p status 0x%2.2x encrypt %u", conn, status, encrypt);
8344 mutex_lock(&conn->chan_lock);
8346 list_for_each_entry(chan, &conn->chan_l, list) {
8347 l2cap_chan_lock(chan);
8349 BT_DBG("chan %p scid 0x%4.4x state %s", chan, chan->scid,
8350 state_to_string(chan->state));
8352 if (chan->scid == L2CAP_CID_A2MP) {
8353 l2cap_chan_unlock(chan);
8357 if (!status && encrypt)
8358 chan->sec_level = hcon->sec_level;
8360 if (!__l2cap_no_conn_pending(chan)) {
8361 l2cap_chan_unlock(chan);
8365 if (!status && (chan->state == BT_CONNECTED ||
8366 chan->state == BT_CONFIG)) {
8367 chan->ops->resume(chan);
8368 l2cap_check_encryption(chan, encrypt);
8369 l2cap_chan_unlock(chan);
8373 if (chan->state == BT_CONNECT) {
8374 if (!status && l2cap_check_enc_key_size(hcon))
8375 l2cap_start_connection(chan);
8377 __set_chan_timer(chan, L2CAP_DISC_TIMEOUT);
8378 } else if (chan->state == BT_CONNECT2 &&
8379 !(chan->mode == L2CAP_MODE_EXT_FLOWCTL ||
8380 chan->mode == L2CAP_MODE_LE_FLOWCTL)) {
8381 struct l2cap_conn_rsp rsp;
8384 if (!status && l2cap_check_enc_key_size(hcon)) {
8385 if (test_bit(FLAG_DEFER_SETUP, &chan->flags)) {
8386 res = L2CAP_CR_PEND;
8387 stat = L2CAP_CS_AUTHOR_PEND;
8388 chan->ops->defer(chan);
8390 l2cap_state_change(chan, BT_CONFIG);
8391 res = L2CAP_CR_SUCCESS;
8392 stat = L2CAP_CS_NO_INFO;
8395 l2cap_state_change(chan, BT_DISCONN);
8396 __set_chan_timer(chan, L2CAP_DISC_TIMEOUT);
8397 res = L2CAP_CR_SEC_BLOCK;
8398 stat = L2CAP_CS_NO_INFO;
8401 rsp.scid = cpu_to_le16(chan->dcid);
8402 rsp.dcid = cpu_to_le16(chan->scid);
8403 rsp.result = cpu_to_le16(res);
8404 rsp.status = cpu_to_le16(stat);
8405 l2cap_send_cmd(conn, chan->ident, L2CAP_CONN_RSP,
8408 if (!test_bit(CONF_REQ_SENT, &chan->conf_state) &&
8409 res == L2CAP_CR_SUCCESS) {
8411 set_bit(CONF_REQ_SENT, &chan->conf_state);
8412 l2cap_send_cmd(conn, l2cap_get_ident(conn),
8414 l2cap_build_conf_req(chan, buf, sizeof(buf)),
8416 chan->num_conf_req++;
8420 l2cap_chan_unlock(chan);
8423 mutex_unlock(&conn->chan_lock);
8426 /* Append fragment into frame respecting the maximum len of rx_skb */
8427 static int l2cap_recv_frag(struct l2cap_conn *conn, struct sk_buff *skb,
8430 if (!conn->rx_skb) {
8431 /* Allocate skb for the complete frame (with header) */
8432 conn->rx_skb = bt_skb_alloc(len, GFP_KERNEL);
8439 /* Copy as much as the rx_skb can hold */
8440 len = min_t(u16, len, skb->len);
8441 skb_copy_from_linear_data(skb, skb_put(conn->rx_skb, len), len);
8443 conn->rx_len -= len;
8448 static int l2cap_recv_len(struct l2cap_conn *conn, struct sk_buff *skb)
8450 struct sk_buff *rx_skb;
8453 /* Append just enough to complete the header */
8454 len = l2cap_recv_frag(conn, skb, L2CAP_LEN_SIZE - conn->rx_skb->len);
8456 /* If header could not be read just continue */
8457 if (len < 0 || conn->rx_skb->len < L2CAP_LEN_SIZE)
8460 rx_skb = conn->rx_skb;
8461 len = get_unaligned_le16(rx_skb->data);
8463 /* Check if rx_skb has enough space to received all fragments */
8464 if (len + (L2CAP_HDR_SIZE - L2CAP_LEN_SIZE) <= skb_tailroom(rx_skb)) {
8465 /* Update expected len */
8466 conn->rx_len = len + (L2CAP_HDR_SIZE - L2CAP_LEN_SIZE);
8467 return L2CAP_LEN_SIZE;
8470 /* Reset conn->rx_skb since it will need to be reallocated in order to
8471 * fit all fragments.
8473 conn->rx_skb = NULL;
8475 /* Reallocates rx_skb using the exact expected length */
8476 len = l2cap_recv_frag(conn, rx_skb,
8477 len + (L2CAP_HDR_SIZE - L2CAP_LEN_SIZE));
8483 static void l2cap_recv_reset(struct l2cap_conn *conn)
8485 kfree_skb(conn->rx_skb);
8486 conn->rx_skb = NULL;
8490 void l2cap_recv_acldata(struct hci_conn *hcon, struct sk_buff *skb, u16 flags)
8492 struct l2cap_conn *conn = hcon->l2cap_data;
8495 /* For AMP controller do not create l2cap conn */
8496 if (!conn && hcon->hdev->dev_type != HCI_PRIMARY)
8500 conn = l2cap_conn_add(hcon);
8505 BT_DBG("conn %p len %u flags 0x%x", conn, skb->len, flags);
8509 case ACL_START_NO_FLUSH:
8512 BT_ERR("Unexpected start frame (len %d)", skb->len);
8513 l2cap_recv_reset(conn);
8514 l2cap_conn_unreliable(conn, ECOMM);
8517 /* Start fragment may not contain the L2CAP length so just
8518 * copy the initial byte when that happens and use conn->mtu as
8521 if (skb->len < L2CAP_LEN_SIZE) {
8522 l2cap_recv_frag(conn, skb, conn->mtu);
8526 len = get_unaligned_le16(skb->data) + L2CAP_HDR_SIZE;
8528 if (len == skb->len) {
8529 /* Complete frame received */
8530 l2cap_recv_frame(conn, skb);
8534 BT_DBG("Start: total len %d, frag len %u", len, skb->len);
8536 if (skb->len > len) {
8537 BT_ERR("Frame is too long (len %u, expected len %d)",
8539 l2cap_conn_unreliable(conn, ECOMM);
8543 /* Append fragment into frame (with header) */
8544 if (l2cap_recv_frag(conn, skb, len) < 0)
8550 BT_DBG("Cont: frag len %u (expecting %u)", skb->len, conn->rx_len);
8552 if (!conn->rx_skb) {
8553 BT_ERR("Unexpected continuation frame (len %d)", skb->len);
8554 l2cap_conn_unreliable(conn, ECOMM);
8558 /* Complete the L2CAP length if it has not been read */
8559 if (conn->rx_skb->len < L2CAP_LEN_SIZE) {
8560 if (l2cap_recv_len(conn, skb) < 0) {
8561 l2cap_conn_unreliable(conn, ECOMM);
8565 /* Header still could not be read just continue */
8566 if (conn->rx_skb->len < L2CAP_LEN_SIZE)
8570 if (skb->len > conn->rx_len) {
8571 BT_ERR("Fragment is too long (len %u, expected %u)",
8572 skb->len, conn->rx_len);
8573 l2cap_recv_reset(conn);
8574 l2cap_conn_unreliable(conn, ECOMM);
8578 /* Append fragment into frame (with header) */
8579 l2cap_recv_frag(conn, skb, skb->len);
8581 if (!conn->rx_len) {
8582 /* Complete frame received. l2cap_recv_frame
8583 * takes ownership of the skb so set the global
8584 * rx_skb pointer to NULL first.
8586 struct sk_buff *rx_skb = conn->rx_skb;
8587 conn->rx_skb = NULL;
8588 l2cap_recv_frame(conn, rx_skb);
8597 static struct hci_cb l2cap_cb = {
8599 .connect_cfm = l2cap_connect_cfm,
8600 .disconn_cfm = l2cap_disconn_cfm,
8601 .security_cfm = l2cap_security_cfm,
8604 static int l2cap_debugfs_show(struct seq_file *f, void *p)
8606 struct l2cap_chan *c;
8608 read_lock(&chan_list_lock);
8610 list_for_each_entry(c, &chan_list, global_l) {
8611 seq_printf(f, "%pMR (%u) %pMR (%u) %d %d 0x%4.4x 0x%4.4x %d %d %d %d\n",
8612 &c->src, c->src_type, &c->dst, c->dst_type,
8613 c->state, __le16_to_cpu(c->psm),
8614 c->scid, c->dcid, c->imtu, c->omtu,
8615 c->sec_level, c->mode);
8618 read_unlock(&chan_list_lock);
8623 DEFINE_SHOW_ATTRIBUTE(l2cap_debugfs);
8625 static struct dentry *l2cap_debugfs;
8627 int __init l2cap_init(void)
8631 err = l2cap_init_sockets();
8635 hci_register_cb(&l2cap_cb);
8637 if (IS_ERR_OR_NULL(bt_debugfs))
8640 l2cap_debugfs = debugfs_create_file("l2cap", 0444, bt_debugfs,
8641 NULL, &l2cap_debugfs_fops);
8646 void l2cap_exit(void)
8648 debugfs_remove(l2cap_debugfs);
8649 hci_unregister_cb(&l2cap_cb);
8650 l2cap_cleanup_sockets();
8653 module_param(disable_ertm, bool, 0644);
8654 MODULE_PARM_DESC(disable_ertm, "Disable enhanced retransmission mode");
8656 module_param(enable_ecred, bool, 0644);
8657 MODULE_PARM_DESC(enable_ecred, "Enable enhanced credit flow control mode");