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
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);
65 static inline u8 bdaddr_type(u8 link_type, u8 bdaddr_type)
67 if (link_type == LE_LINK) {
68 if (bdaddr_type == ADDR_LE_DEV_PUBLIC)
69 return BDADDR_LE_PUBLIC;
71 return BDADDR_LE_RANDOM;
77 static inline u8 bdaddr_src_type(struct hci_conn *hcon)
79 return bdaddr_type(hcon->type, hcon->src_type);
82 static inline u8 bdaddr_dst_type(struct hci_conn *hcon)
84 return bdaddr_type(hcon->type, hcon->dst_type);
87 /* ---- L2CAP channels ---- */
89 static struct l2cap_chan *__l2cap_get_chan_by_dcid(struct l2cap_conn *conn,
94 list_for_each_entry(c, &conn->chan_l, list) {
101 static struct l2cap_chan *__l2cap_get_chan_by_scid(struct l2cap_conn *conn,
104 struct l2cap_chan *c;
106 list_for_each_entry(c, &conn->chan_l, list) {
113 /* Find channel with given SCID.
114 * Returns locked channel. */
115 static struct l2cap_chan *l2cap_get_chan_by_scid(struct l2cap_conn *conn,
118 struct l2cap_chan *c;
120 mutex_lock(&conn->chan_lock);
121 c = __l2cap_get_chan_by_scid(conn, cid);
124 mutex_unlock(&conn->chan_lock);
129 /* Find channel with given DCID.
130 * Returns locked channel.
132 static struct l2cap_chan *l2cap_get_chan_by_dcid(struct l2cap_conn *conn,
135 struct l2cap_chan *c;
137 mutex_lock(&conn->chan_lock);
138 c = __l2cap_get_chan_by_dcid(conn, cid);
141 mutex_unlock(&conn->chan_lock);
146 static struct l2cap_chan *__l2cap_get_chan_by_ident(struct l2cap_conn *conn,
149 struct l2cap_chan *c;
151 list_for_each_entry(c, &conn->chan_l, list) {
152 if (c->ident == ident)
158 static struct l2cap_chan *l2cap_get_chan_by_ident(struct l2cap_conn *conn,
161 struct l2cap_chan *c;
163 mutex_lock(&conn->chan_lock);
164 c = __l2cap_get_chan_by_ident(conn, ident);
167 mutex_unlock(&conn->chan_lock);
172 static struct l2cap_chan *__l2cap_global_chan_by_addr(__le16 psm, bdaddr_t *src,
175 struct l2cap_chan *c;
177 list_for_each_entry(c, &chan_list, global_l) {
178 if (src_type == BDADDR_BREDR && c->src_type != BDADDR_BREDR)
181 if (src_type != BDADDR_BREDR && c->src_type == BDADDR_BREDR)
184 if (c->sport == psm && !bacmp(&c->src, src))
190 int l2cap_add_psm(struct l2cap_chan *chan, bdaddr_t *src, __le16 psm)
194 write_lock(&chan_list_lock);
196 if (psm && __l2cap_global_chan_by_addr(psm, src, chan->src_type)) {
206 u16 p, start, end, incr;
208 if (chan->src_type == BDADDR_BREDR) {
209 start = L2CAP_PSM_DYN_START;
210 end = L2CAP_PSM_AUTO_END;
213 start = L2CAP_PSM_LE_DYN_START;
214 end = L2CAP_PSM_LE_DYN_END;
219 for (p = start; p <= end; p += incr)
220 if (!__l2cap_global_chan_by_addr(cpu_to_le16(p), src,
222 chan->psm = cpu_to_le16(p);
223 chan->sport = cpu_to_le16(p);
230 write_unlock(&chan_list_lock);
233 EXPORT_SYMBOL_GPL(l2cap_add_psm);
235 int l2cap_add_scid(struct l2cap_chan *chan, __u16 scid)
237 write_lock(&chan_list_lock);
239 /* Override the defaults (which are for conn-oriented) */
240 chan->omtu = L2CAP_DEFAULT_MTU;
241 chan->chan_type = L2CAP_CHAN_FIXED;
245 write_unlock(&chan_list_lock);
250 static u16 l2cap_alloc_cid(struct l2cap_conn *conn)
254 if (conn->hcon->type == LE_LINK)
255 dyn_end = L2CAP_CID_LE_DYN_END;
257 dyn_end = L2CAP_CID_DYN_END;
259 for (cid = L2CAP_CID_DYN_START; cid <= dyn_end; cid++) {
260 if (!__l2cap_get_chan_by_scid(conn, cid))
267 static void l2cap_state_change(struct l2cap_chan *chan, int state)
269 BT_DBG("chan %p %s -> %s", chan, state_to_string(chan->state),
270 state_to_string(state));
273 chan->ops->state_change(chan, state, 0);
276 static inline void l2cap_state_change_and_error(struct l2cap_chan *chan,
280 chan->ops->state_change(chan, chan->state, err);
283 static inline void l2cap_chan_set_err(struct l2cap_chan *chan, int err)
285 chan->ops->state_change(chan, chan->state, err);
288 static void __set_retrans_timer(struct l2cap_chan *chan)
290 if (!delayed_work_pending(&chan->monitor_timer) &&
291 chan->retrans_timeout) {
292 l2cap_set_timer(chan, &chan->retrans_timer,
293 msecs_to_jiffies(chan->retrans_timeout));
297 static void __set_monitor_timer(struct l2cap_chan *chan)
299 __clear_retrans_timer(chan);
300 if (chan->monitor_timeout) {
301 l2cap_set_timer(chan, &chan->monitor_timer,
302 msecs_to_jiffies(chan->monitor_timeout));
306 static struct sk_buff *l2cap_ertm_seq_in_queue(struct sk_buff_head *head,
311 skb_queue_walk(head, skb) {
312 if (bt_cb(skb)->l2cap.txseq == seq)
319 /* ---- L2CAP sequence number lists ---- */
321 /* For ERTM, ordered lists of sequence numbers must be tracked for
322 * SREJ requests that are received and for frames that are to be
323 * retransmitted. These seq_list functions implement a singly-linked
324 * list in an array, where membership in the list can also be checked
325 * in constant time. Items can also be added to the tail of the list
326 * and removed from the head in constant time, without further memory
330 static int l2cap_seq_list_init(struct l2cap_seq_list *seq_list, u16 size)
332 size_t alloc_size, i;
334 /* Allocated size is a power of 2 to map sequence numbers
335 * (which may be up to 14 bits) in to a smaller array that is
336 * sized for the negotiated ERTM transmit windows.
338 alloc_size = roundup_pow_of_two(size);
340 seq_list->list = kmalloc_array(alloc_size, sizeof(u16), GFP_KERNEL);
344 seq_list->mask = alloc_size - 1;
345 seq_list->head = L2CAP_SEQ_LIST_CLEAR;
346 seq_list->tail = L2CAP_SEQ_LIST_CLEAR;
347 for (i = 0; i < alloc_size; i++)
348 seq_list->list[i] = L2CAP_SEQ_LIST_CLEAR;
353 static inline void l2cap_seq_list_free(struct l2cap_seq_list *seq_list)
355 kfree(seq_list->list);
358 static inline bool l2cap_seq_list_contains(struct l2cap_seq_list *seq_list,
361 /* Constant-time check for list membership */
362 return seq_list->list[seq & seq_list->mask] != L2CAP_SEQ_LIST_CLEAR;
365 static inline u16 l2cap_seq_list_pop(struct l2cap_seq_list *seq_list)
367 u16 seq = seq_list->head;
368 u16 mask = seq_list->mask;
370 seq_list->head = seq_list->list[seq & mask];
371 seq_list->list[seq & mask] = L2CAP_SEQ_LIST_CLEAR;
373 if (seq_list->head == L2CAP_SEQ_LIST_TAIL) {
374 seq_list->head = L2CAP_SEQ_LIST_CLEAR;
375 seq_list->tail = L2CAP_SEQ_LIST_CLEAR;
381 static void l2cap_seq_list_clear(struct l2cap_seq_list *seq_list)
385 if (seq_list->head == L2CAP_SEQ_LIST_CLEAR)
388 for (i = 0; i <= seq_list->mask; i++)
389 seq_list->list[i] = L2CAP_SEQ_LIST_CLEAR;
391 seq_list->head = L2CAP_SEQ_LIST_CLEAR;
392 seq_list->tail = L2CAP_SEQ_LIST_CLEAR;
395 static void l2cap_seq_list_append(struct l2cap_seq_list *seq_list, u16 seq)
397 u16 mask = seq_list->mask;
399 /* All appends happen in constant time */
401 if (seq_list->list[seq & mask] != L2CAP_SEQ_LIST_CLEAR)
404 if (seq_list->tail == L2CAP_SEQ_LIST_CLEAR)
405 seq_list->head = seq;
407 seq_list->list[seq_list->tail & mask] = seq;
409 seq_list->tail = seq;
410 seq_list->list[seq & mask] = L2CAP_SEQ_LIST_TAIL;
413 static void l2cap_chan_timeout(struct work_struct *work)
415 struct l2cap_chan *chan = container_of(work, struct l2cap_chan,
417 struct l2cap_conn *conn = chan->conn;
420 BT_DBG("chan %p state %s", chan, state_to_string(chan->state));
422 mutex_lock(&conn->chan_lock);
423 /* __set_chan_timer() calls l2cap_chan_hold(chan) while scheduling
424 * this work. No need to call l2cap_chan_hold(chan) here again.
426 l2cap_chan_lock(chan);
428 if (chan->state == BT_CONNECTED || chan->state == BT_CONFIG)
429 reason = ECONNREFUSED;
430 else if (chan->state == BT_CONNECT &&
431 chan->sec_level != BT_SECURITY_SDP)
432 reason = ECONNREFUSED;
436 l2cap_chan_close(chan, reason);
438 chan->ops->close(chan);
440 l2cap_chan_unlock(chan);
441 l2cap_chan_put(chan);
443 mutex_unlock(&conn->chan_lock);
446 struct l2cap_chan *l2cap_chan_create(void)
448 struct l2cap_chan *chan;
450 chan = kzalloc(sizeof(*chan), GFP_ATOMIC);
454 mutex_init(&chan->lock);
456 /* Set default lock nesting level */
457 atomic_set(&chan->nesting, L2CAP_NESTING_NORMAL);
459 write_lock(&chan_list_lock);
460 list_add(&chan->global_l, &chan_list);
461 write_unlock(&chan_list_lock);
463 INIT_DELAYED_WORK(&chan->chan_timer, l2cap_chan_timeout);
465 chan->state = BT_OPEN;
467 kref_init(&chan->kref);
469 /* This flag is cleared in l2cap_chan_ready() */
470 set_bit(CONF_NOT_COMPLETE, &chan->conf_state);
472 BT_DBG("chan %p", chan);
476 EXPORT_SYMBOL_GPL(l2cap_chan_create);
478 static void l2cap_chan_destroy(struct kref *kref)
480 struct l2cap_chan *chan = container_of(kref, struct l2cap_chan, kref);
482 BT_DBG("chan %p", chan);
484 write_lock(&chan_list_lock);
485 list_del(&chan->global_l);
486 write_unlock(&chan_list_lock);
491 void l2cap_chan_hold(struct l2cap_chan *c)
493 BT_DBG("chan %p orig refcnt %d", c, kref_read(&c->kref));
498 void l2cap_chan_put(struct l2cap_chan *c)
500 BT_DBG("chan %p orig refcnt %d", c, kref_read(&c->kref));
502 kref_put(&c->kref, l2cap_chan_destroy);
504 EXPORT_SYMBOL_GPL(l2cap_chan_put);
506 void l2cap_chan_set_defaults(struct l2cap_chan *chan)
508 chan->fcs = L2CAP_FCS_CRC16;
509 chan->max_tx = L2CAP_DEFAULT_MAX_TX;
510 chan->tx_win = L2CAP_DEFAULT_TX_WINDOW;
511 chan->tx_win_max = L2CAP_DEFAULT_TX_WINDOW;
512 chan->remote_max_tx = chan->max_tx;
513 chan->remote_tx_win = chan->tx_win;
514 chan->ack_win = L2CAP_DEFAULT_TX_WINDOW;
515 chan->sec_level = BT_SECURITY_LOW;
516 chan->flush_to = L2CAP_DEFAULT_FLUSH_TO;
517 chan->retrans_timeout = L2CAP_DEFAULT_RETRANS_TO;
518 chan->monitor_timeout = L2CAP_DEFAULT_MONITOR_TO;
519 chan->conf_state = 0;
521 set_bit(FLAG_FORCE_ACTIVE, &chan->flags);
523 EXPORT_SYMBOL_GPL(l2cap_chan_set_defaults);
525 static void l2cap_le_flowctl_init(struct l2cap_chan *chan, u16 tx_credits)
528 chan->sdu_last_frag = NULL;
530 chan->tx_credits = tx_credits;
531 /* Derive MPS from connection MTU to stop HCI fragmentation */
532 chan->mps = min_t(u16, chan->imtu, chan->conn->mtu - L2CAP_HDR_SIZE);
533 /* Give enough credits for a full packet */
534 chan->rx_credits = (chan->imtu / chan->mps) + 1;
536 skb_queue_head_init(&chan->tx_q);
539 static void l2cap_ecred_init(struct l2cap_chan *chan, u16 tx_credits)
541 l2cap_le_flowctl_init(chan, tx_credits);
543 /* L2CAP implementations shall support a minimum MPS of 64 octets */
544 if (chan->mps < L2CAP_ECRED_MIN_MPS) {
545 chan->mps = L2CAP_ECRED_MIN_MPS;
546 chan->rx_credits = (chan->imtu / chan->mps) + 1;
550 void __l2cap_chan_add(struct l2cap_conn *conn, struct l2cap_chan *chan)
552 BT_DBG("conn %p, psm 0x%2.2x, dcid 0x%4.4x", conn,
553 __le16_to_cpu(chan->psm), chan->dcid);
555 conn->disc_reason = HCI_ERROR_REMOTE_USER_TERM;
559 switch (chan->chan_type) {
560 case L2CAP_CHAN_CONN_ORIENTED:
561 /* Alloc CID for connection-oriented socket */
562 chan->scid = l2cap_alloc_cid(conn);
563 if (conn->hcon->type == ACL_LINK)
564 chan->omtu = L2CAP_DEFAULT_MTU;
567 case L2CAP_CHAN_CONN_LESS:
568 /* Connectionless socket */
569 chan->scid = L2CAP_CID_CONN_LESS;
570 chan->dcid = L2CAP_CID_CONN_LESS;
571 chan->omtu = L2CAP_DEFAULT_MTU;
574 case L2CAP_CHAN_FIXED:
575 /* Caller will set CID and CID specific MTU values */
579 /* Raw socket can send/recv signalling messages only */
580 chan->scid = L2CAP_CID_SIGNALING;
581 chan->dcid = L2CAP_CID_SIGNALING;
582 chan->omtu = L2CAP_DEFAULT_MTU;
585 chan->local_id = L2CAP_BESTEFFORT_ID;
586 chan->local_stype = L2CAP_SERV_BESTEFFORT;
587 chan->local_msdu = L2CAP_DEFAULT_MAX_SDU_SIZE;
588 chan->local_sdu_itime = L2CAP_DEFAULT_SDU_ITIME;
589 chan->local_acc_lat = L2CAP_DEFAULT_ACC_LAT;
590 chan->local_flush_to = L2CAP_EFS_DEFAULT_FLUSH_TO;
592 l2cap_chan_hold(chan);
594 /* Only keep a reference for fixed channels if they requested it */
595 if (chan->chan_type != L2CAP_CHAN_FIXED ||
596 test_bit(FLAG_HOLD_HCI_CONN, &chan->flags))
597 hci_conn_hold(conn->hcon);
599 list_add(&chan->list, &conn->chan_l);
602 void l2cap_chan_add(struct l2cap_conn *conn, struct l2cap_chan *chan)
604 mutex_lock(&conn->chan_lock);
605 __l2cap_chan_add(conn, chan);
606 mutex_unlock(&conn->chan_lock);
609 void l2cap_chan_del(struct l2cap_chan *chan, int err)
611 struct l2cap_conn *conn = chan->conn;
613 __clear_chan_timer(chan);
615 BT_DBG("chan %p, conn %p, err %d, state %s", chan, conn, err,
616 state_to_string(chan->state));
618 chan->ops->teardown(chan, err);
621 struct amp_mgr *mgr = conn->hcon->amp_mgr;
622 /* Delete from channel list */
623 list_del(&chan->list);
625 l2cap_chan_put(chan);
629 /* Reference was only held for non-fixed channels or
630 * fixed channels that explicitly requested it using the
631 * FLAG_HOLD_HCI_CONN flag.
633 if (chan->chan_type != L2CAP_CHAN_FIXED ||
634 test_bit(FLAG_HOLD_HCI_CONN, &chan->flags))
635 hci_conn_drop(conn->hcon);
637 if (mgr && mgr->bredr_chan == chan)
638 mgr->bredr_chan = NULL;
641 if (chan->hs_hchan) {
642 struct hci_chan *hs_hchan = chan->hs_hchan;
644 BT_DBG("chan %p disconnect hs_hchan %p", chan, hs_hchan);
645 amp_disconnect_logical_link(hs_hchan);
648 if (test_bit(CONF_NOT_COMPLETE, &chan->conf_state))
652 case L2CAP_MODE_BASIC:
655 case L2CAP_MODE_LE_FLOWCTL:
656 case L2CAP_MODE_EXT_FLOWCTL:
657 skb_queue_purge(&chan->tx_q);
660 case L2CAP_MODE_ERTM:
661 __clear_retrans_timer(chan);
662 __clear_monitor_timer(chan);
663 __clear_ack_timer(chan);
665 skb_queue_purge(&chan->srej_q);
667 l2cap_seq_list_free(&chan->srej_list);
668 l2cap_seq_list_free(&chan->retrans_list);
671 case L2CAP_MODE_STREAMING:
672 skb_queue_purge(&chan->tx_q);
678 EXPORT_SYMBOL_GPL(l2cap_chan_del);
680 static void __l2cap_chan_list(struct l2cap_conn *conn, l2cap_chan_func_t func,
683 struct l2cap_chan *chan;
685 list_for_each_entry(chan, &conn->chan_l, list) {
690 void l2cap_chan_list(struct l2cap_conn *conn, l2cap_chan_func_t func,
696 mutex_lock(&conn->chan_lock);
697 __l2cap_chan_list(conn, func, data);
698 mutex_unlock(&conn->chan_lock);
701 EXPORT_SYMBOL_GPL(l2cap_chan_list);
703 static void l2cap_conn_update_id_addr(struct work_struct *work)
705 struct l2cap_conn *conn = container_of(work, struct l2cap_conn,
706 id_addr_update_work);
707 struct hci_conn *hcon = conn->hcon;
708 struct l2cap_chan *chan;
710 mutex_lock(&conn->chan_lock);
712 list_for_each_entry(chan, &conn->chan_l, list) {
713 l2cap_chan_lock(chan);
714 bacpy(&chan->dst, &hcon->dst);
715 chan->dst_type = bdaddr_dst_type(hcon);
716 l2cap_chan_unlock(chan);
719 mutex_unlock(&conn->chan_lock);
722 static void l2cap_chan_le_connect_reject(struct l2cap_chan *chan)
724 struct l2cap_conn *conn = chan->conn;
725 struct l2cap_le_conn_rsp rsp;
728 if (test_bit(FLAG_DEFER_SETUP, &chan->flags))
729 result = L2CAP_CR_LE_AUTHORIZATION;
731 result = L2CAP_CR_LE_BAD_PSM;
733 l2cap_state_change(chan, BT_DISCONN);
735 rsp.dcid = cpu_to_le16(chan->scid);
736 rsp.mtu = cpu_to_le16(chan->imtu);
737 rsp.mps = cpu_to_le16(chan->mps);
738 rsp.credits = cpu_to_le16(chan->rx_credits);
739 rsp.result = cpu_to_le16(result);
741 l2cap_send_cmd(conn, chan->ident, L2CAP_LE_CONN_RSP, sizeof(rsp),
745 static void l2cap_chan_ecred_connect_reject(struct l2cap_chan *chan)
747 struct l2cap_conn *conn = chan->conn;
748 struct l2cap_ecred_conn_rsp rsp;
751 if (test_bit(FLAG_DEFER_SETUP, &chan->flags))
752 result = L2CAP_CR_LE_AUTHORIZATION;
754 result = L2CAP_CR_LE_BAD_PSM;
756 l2cap_state_change(chan, BT_DISCONN);
758 memset(&rsp, 0, sizeof(rsp));
760 rsp.result = cpu_to_le16(result);
762 l2cap_send_cmd(conn, chan->ident, L2CAP_LE_CONN_RSP, sizeof(rsp),
766 static void l2cap_chan_connect_reject(struct l2cap_chan *chan)
768 struct l2cap_conn *conn = chan->conn;
769 struct l2cap_conn_rsp rsp;
772 if (test_bit(FLAG_DEFER_SETUP, &chan->flags))
773 result = L2CAP_CR_SEC_BLOCK;
775 result = L2CAP_CR_BAD_PSM;
777 l2cap_state_change(chan, BT_DISCONN);
779 rsp.scid = cpu_to_le16(chan->dcid);
780 rsp.dcid = cpu_to_le16(chan->scid);
781 rsp.result = cpu_to_le16(result);
782 rsp.status = cpu_to_le16(L2CAP_CS_NO_INFO);
784 l2cap_send_cmd(conn, chan->ident, L2CAP_CONN_RSP, sizeof(rsp), &rsp);
787 void l2cap_chan_close(struct l2cap_chan *chan, int reason)
789 struct l2cap_conn *conn = chan->conn;
791 BT_DBG("chan %p state %s", chan, state_to_string(chan->state));
793 switch (chan->state) {
795 chan->ops->teardown(chan, 0);
800 if (chan->chan_type == L2CAP_CHAN_CONN_ORIENTED) {
801 __set_chan_timer(chan, chan->ops->get_sndtimeo(chan));
802 l2cap_send_disconn_req(chan, reason);
804 l2cap_chan_del(chan, reason);
808 if (chan->chan_type == L2CAP_CHAN_CONN_ORIENTED) {
809 if (conn->hcon->type == ACL_LINK)
810 l2cap_chan_connect_reject(chan);
811 else if (conn->hcon->type == LE_LINK) {
812 switch (chan->mode) {
813 case L2CAP_MODE_LE_FLOWCTL:
814 l2cap_chan_le_connect_reject(chan);
816 case L2CAP_MODE_EXT_FLOWCTL:
817 l2cap_chan_ecred_connect_reject(chan);
823 l2cap_chan_del(chan, reason);
828 l2cap_chan_del(chan, reason);
832 chan->ops->teardown(chan, 0);
836 EXPORT_SYMBOL(l2cap_chan_close);
838 static inline u8 l2cap_get_auth_type(struct l2cap_chan *chan)
840 switch (chan->chan_type) {
842 switch (chan->sec_level) {
843 case BT_SECURITY_HIGH:
844 case BT_SECURITY_FIPS:
845 return HCI_AT_DEDICATED_BONDING_MITM;
846 case BT_SECURITY_MEDIUM:
847 return HCI_AT_DEDICATED_BONDING;
849 return HCI_AT_NO_BONDING;
852 case L2CAP_CHAN_CONN_LESS:
853 if (chan->psm == cpu_to_le16(L2CAP_PSM_3DSP)) {
854 if (chan->sec_level == BT_SECURITY_LOW)
855 chan->sec_level = BT_SECURITY_SDP;
857 if (chan->sec_level == BT_SECURITY_HIGH ||
858 chan->sec_level == BT_SECURITY_FIPS)
859 return HCI_AT_NO_BONDING_MITM;
861 return HCI_AT_NO_BONDING;
863 case L2CAP_CHAN_CONN_ORIENTED:
864 if (chan->psm == cpu_to_le16(L2CAP_PSM_SDP)) {
865 if (chan->sec_level == BT_SECURITY_LOW)
866 chan->sec_level = BT_SECURITY_SDP;
868 if (chan->sec_level == BT_SECURITY_HIGH ||
869 chan->sec_level == BT_SECURITY_FIPS)
870 return HCI_AT_NO_BONDING_MITM;
872 return HCI_AT_NO_BONDING;
877 switch (chan->sec_level) {
878 case BT_SECURITY_HIGH:
879 case BT_SECURITY_FIPS:
880 return HCI_AT_GENERAL_BONDING_MITM;
881 case BT_SECURITY_MEDIUM:
882 return HCI_AT_GENERAL_BONDING;
884 return HCI_AT_NO_BONDING;
890 /* Service level security */
891 int l2cap_chan_check_security(struct l2cap_chan *chan, bool initiator)
893 struct l2cap_conn *conn = chan->conn;
896 if (conn->hcon->type == LE_LINK)
897 return smp_conn_security(conn->hcon, chan->sec_level);
899 auth_type = l2cap_get_auth_type(chan);
901 return hci_conn_security(conn->hcon, chan->sec_level, auth_type,
905 static u8 l2cap_get_ident(struct l2cap_conn *conn)
909 /* Get next available identificator.
910 * 1 - 128 are used by kernel.
911 * 129 - 199 are reserved.
912 * 200 - 254 are used by utilities like l2ping, etc.
915 mutex_lock(&conn->ident_lock);
917 if (++conn->tx_ident > 128)
922 mutex_unlock(&conn->ident_lock);
927 static void l2cap_send_cmd(struct l2cap_conn *conn, u8 ident, u8 code, u16 len,
930 struct sk_buff *skb = l2cap_build_cmd(conn, code, ident, len, data);
933 BT_DBG("code 0x%2.2x", code);
938 /* Use NO_FLUSH if supported or we have an LE link (which does
939 * not support auto-flushing packets) */
940 if (lmp_no_flush_capable(conn->hcon->hdev) ||
941 conn->hcon->type == LE_LINK)
942 flags = ACL_START_NO_FLUSH;
946 bt_cb(skb)->force_active = BT_POWER_FORCE_ACTIVE_ON;
947 skb->priority = HCI_PRIO_MAX;
949 hci_send_acl(conn->hchan, skb, flags);
952 static bool __chan_is_moving(struct l2cap_chan *chan)
954 return chan->move_state != L2CAP_MOVE_STABLE &&
955 chan->move_state != L2CAP_MOVE_WAIT_PREPARE;
958 static void l2cap_do_send(struct l2cap_chan *chan, struct sk_buff *skb)
960 struct hci_conn *hcon = chan->conn->hcon;
963 BT_DBG("chan %p, skb %p len %d priority %u", chan, skb, skb->len,
966 if (chan->hs_hcon && !__chan_is_moving(chan)) {
968 hci_send_acl(chan->hs_hchan, skb, ACL_COMPLETE);
975 /* Use NO_FLUSH for LE links (where this is the only option) or
976 * if the BR/EDR link supports it and flushing has not been
977 * explicitly requested (through FLAG_FLUSHABLE).
979 if (hcon->type == LE_LINK ||
980 (!test_bit(FLAG_FLUSHABLE, &chan->flags) &&
981 lmp_no_flush_capable(hcon->hdev)))
982 flags = ACL_START_NO_FLUSH;
986 bt_cb(skb)->force_active = test_bit(FLAG_FORCE_ACTIVE, &chan->flags);
987 hci_send_acl(chan->conn->hchan, skb, flags);
990 static void __unpack_enhanced_control(u16 enh, struct l2cap_ctrl *control)
992 control->reqseq = (enh & L2CAP_CTRL_REQSEQ) >> L2CAP_CTRL_REQSEQ_SHIFT;
993 control->final = (enh & L2CAP_CTRL_FINAL) >> L2CAP_CTRL_FINAL_SHIFT;
995 if (enh & L2CAP_CTRL_FRAME_TYPE) {
998 control->poll = (enh & L2CAP_CTRL_POLL) >> L2CAP_CTRL_POLL_SHIFT;
999 control->super = (enh & L2CAP_CTRL_SUPERVISE) >> L2CAP_CTRL_SUPER_SHIFT;
1005 control->sframe = 0;
1006 control->sar = (enh & L2CAP_CTRL_SAR) >> L2CAP_CTRL_SAR_SHIFT;
1007 control->txseq = (enh & L2CAP_CTRL_TXSEQ) >> L2CAP_CTRL_TXSEQ_SHIFT;
1014 static void __unpack_extended_control(u32 ext, struct l2cap_ctrl *control)
1016 control->reqseq = (ext & L2CAP_EXT_CTRL_REQSEQ) >> L2CAP_EXT_CTRL_REQSEQ_SHIFT;
1017 control->final = (ext & L2CAP_EXT_CTRL_FINAL) >> L2CAP_EXT_CTRL_FINAL_SHIFT;
1019 if (ext & L2CAP_EXT_CTRL_FRAME_TYPE) {
1021 control->sframe = 1;
1022 control->poll = (ext & L2CAP_EXT_CTRL_POLL) >> L2CAP_EXT_CTRL_POLL_SHIFT;
1023 control->super = (ext & L2CAP_EXT_CTRL_SUPERVISE) >> L2CAP_EXT_CTRL_SUPER_SHIFT;
1029 control->sframe = 0;
1030 control->sar = (ext & L2CAP_EXT_CTRL_SAR) >> L2CAP_EXT_CTRL_SAR_SHIFT;
1031 control->txseq = (ext & L2CAP_EXT_CTRL_TXSEQ) >> L2CAP_EXT_CTRL_TXSEQ_SHIFT;
1038 static inline void __unpack_control(struct l2cap_chan *chan,
1039 struct sk_buff *skb)
1041 if (test_bit(FLAG_EXT_CTRL, &chan->flags)) {
1042 __unpack_extended_control(get_unaligned_le32(skb->data),
1043 &bt_cb(skb)->l2cap);
1044 skb_pull(skb, L2CAP_EXT_CTRL_SIZE);
1046 __unpack_enhanced_control(get_unaligned_le16(skb->data),
1047 &bt_cb(skb)->l2cap);
1048 skb_pull(skb, L2CAP_ENH_CTRL_SIZE);
1052 static u32 __pack_extended_control(struct l2cap_ctrl *control)
1056 packed = control->reqseq << L2CAP_EXT_CTRL_REQSEQ_SHIFT;
1057 packed |= control->final << L2CAP_EXT_CTRL_FINAL_SHIFT;
1059 if (control->sframe) {
1060 packed |= control->poll << L2CAP_EXT_CTRL_POLL_SHIFT;
1061 packed |= control->super << L2CAP_EXT_CTRL_SUPER_SHIFT;
1062 packed |= L2CAP_EXT_CTRL_FRAME_TYPE;
1064 packed |= control->sar << L2CAP_EXT_CTRL_SAR_SHIFT;
1065 packed |= control->txseq << L2CAP_EXT_CTRL_TXSEQ_SHIFT;
1071 static u16 __pack_enhanced_control(struct l2cap_ctrl *control)
1075 packed = control->reqseq << L2CAP_CTRL_REQSEQ_SHIFT;
1076 packed |= control->final << L2CAP_CTRL_FINAL_SHIFT;
1078 if (control->sframe) {
1079 packed |= control->poll << L2CAP_CTRL_POLL_SHIFT;
1080 packed |= control->super << L2CAP_CTRL_SUPER_SHIFT;
1081 packed |= L2CAP_CTRL_FRAME_TYPE;
1083 packed |= control->sar << L2CAP_CTRL_SAR_SHIFT;
1084 packed |= control->txseq << L2CAP_CTRL_TXSEQ_SHIFT;
1090 static inline void __pack_control(struct l2cap_chan *chan,
1091 struct l2cap_ctrl *control,
1092 struct sk_buff *skb)
1094 if (test_bit(FLAG_EXT_CTRL, &chan->flags)) {
1095 put_unaligned_le32(__pack_extended_control(control),
1096 skb->data + L2CAP_HDR_SIZE);
1098 put_unaligned_le16(__pack_enhanced_control(control),
1099 skb->data + L2CAP_HDR_SIZE);
1103 static inline unsigned int __ertm_hdr_size(struct l2cap_chan *chan)
1105 if (test_bit(FLAG_EXT_CTRL, &chan->flags))
1106 return L2CAP_EXT_HDR_SIZE;
1108 return L2CAP_ENH_HDR_SIZE;
1111 static struct sk_buff *l2cap_create_sframe_pdu(struct l2cap_chan *chan,
1114 struct sk_buff *skb;
1115 struct l2cap_hdr *lh;
1116 int hlen = __ertm_hdr_size(chan);
1118 if (chan->fcs == L2CAP_FCS_CRC16)
1119 hlen += L2CAP_FCS_SIZE;
1121 skb = bt_skb_alloc(hlen, GFP_KERNEL);
1124 return ERR_PTR(-ENOMEM);
1126 lh = skb_put(skb, L2CAP_HDR_SIZE);
1127 lh->len = cpu_to_le16(hlen - L2CAP_HDR_SIZE);
1128 lh->cid = cpu_to_le16(chan->dcid);
1130 if (test_bit(FLAG_EXT_CTRL, &chan->flags))
1131 put_unaligned_le32(control, skb_put(skb, L2CAP_EXT_CTRL_SIZE));
1133 put_unaligned_le16(control, skb_put(skb, L2CAP_ENH_CTRL_SIZE));
1135 if (chan->fcs == L2CAP_FCS_CRC16) {
1136 u16 fcs = crc16(0, (u8 *)skb->data, skb->len);
1137 put_unaligned_le16(fcs, skb_put(skb, L2CAP_FCS_SIZE));
1140 skb->priority = HCI_PRIO_MAX;
1144 static void l2cap_send_sframe(struct l2cap_chan *chan,
1145 struct l2cap_ctrl *control)
1147 struct sk_buff *skb;
1150 BT_DBG("chan %p, control %p", chan, control);
1152 if (!control->sframe)
1155 if (__chan_is_moving(chan))
1158 if (test_and_clear_bit(CONN_SEND_FBIT, &chan->conn_state) &&
1162 if (control->super == L2CAP_SUPER_RR)
1163 clear_bit(CONN_RNR_SENT, &chan->conn_state);
1164 else if (control->super == L2CAP_SUPER_RNR)
1165 set_bit(CONN_RNR_SENT, &chan->conn_state);
1167 if (control->super != L2CAP_SUPER_SREJ) {
1168 chan->last_acked_seq = control->reqseq;
1169 __clear_ack_timer(chan);
1172 BT_DBG("reqseq %d, final %d, poll %d, super %d", control->reqseq,
1173 control->final, control->poll, control->super);
1175 if (test_bit(FLAG_EXT_CTRL, &chan->flags))
1176 control_field = __pack_extended_control(control);
1178 control_field = __pack_enhanced_control(control);
1180 skb = l2cap_create_sframe_pdu(chan, control_field);
1182 l2cap_do_send(chan, skb);
1185 static void l2cap_send_rr_or_rnr(struct l2cap_chan *chan, bool poll)
1187 struct l2cap_ctrl control;
1189 BT_DBG("chan %p, poll %d", chan, poll);
1191 memset(&control, 0, sizeof(control));
1193 control.poll = poll;
1195 if (test_bit(CONN_LOCAL_BUSY, &chan->conn_state))
1196 control.super = L2CAP_SUPER_RNR;
1198 control.super = L2CAP_SUPER_RR;
1200 control.reqseq = chan->buffer_seq;
1201 l2cap_send_sframe(chan, &control);
1204 static inline int __l2cap_no_conn_pending(struct l2cap_chan *chan)
1206 if (chan->chan_type != L2CAP_CHAN_CONN_ORIENTED)
1209 return !test_bit(CONF_CONNECT_PEND, &chan->conf_state);
1212 static bool __amp_capable(struct l2cap_chan *chan)
1214 struct l2cap_conn *conn = chan->conn;
1215 struct hci_dev *hdev;
1216 bool amp_available = false;
1218 if (!(conn->local_fixed_chan & L2CAP_FC_A2MP))
1221 if (!(conn->remote_fixed_chan & L2CAP_FC_A2MP))
1224 read_lock(&hci_dev_list_lock);
1225 list_for_each_entry(hdev, &hci_dev_list, list) {
1226 if (hdev->amp_type != AMP_TYPE_BREDR &&
1227 test_bit(HCI_UP, &hdev->flags)) {
1228 amp_available = true;
1232 read_unlock(&hci_dev_list_lock);
1234 if (chan->chan_policy == BT_CHANNEL_POLICY_AMP_PREFERRED)
1235 return amp_available;
1240 static bool l2cap_check_efs(struct l2cap_chan *chan)
1242 /* Check EFS parameters */
1246 void l2cap_send_conn_req(struct l2cap_chan *chan)
1248 struct l2cap_conn *conn = chan->conn;
1249 struct l2cap_conn_req req;
1251 req.scid = cpu_to_le16(chan->scid);
1252 req.psm = chan->psm;
1254 chan->ident = l2cap_get_ident(conn);
1256 set_bit(CONF_CONNECT_PEND, &chan->conf_state);
1258 l2cap_send_cmd(conn, chan->ident, L2CAP_CONN_REQ, sizeof(req), &req);
1261 static void l2cap_send_create_chan_req(struct l2cap_chan *chan, u8 amp_id)
1263 struct l2cap_create_chan_req req;
1264 req.scid = cpu_to_le16(chan->scid);
1265 req.psm = chan->psm;
1266 req.amp_id = amp_id;
1268 chan->ident = l2cap_get_ident(chan->conn);
1270 l2cap_send_cmd(chan->conn, chan->ident, L2CAP_CREATE_CHAN_REQ,
1274 static void l2cap_move_setup(struct l2cap_chan *chan)
1276 struct sk_buff *skb;
1278 BT_DBG("chan %p", chan);
1280 if (chan->mode != L2CAP_MODE_ERTM)
1283 __clear_retrans_timer(chan);
1284 __clear_monitor_timer(chan);
1285 __clear_ack_timer(chan);
1287 chan->retry_count = 0;
1288 skb_queue_walk(&chan->tx_q, skb) {
1289 if (bt_cb(skb)->l2cap.retries)
1290 bt_cb(skb)->l2cap.retries = 1;
1295 chan->expected_tx_seq = chan->buffer_seq;
1297 clear_bit(CONN_REJ_ACT, &chan->conn_state);
1298 clear_bit(CONN_SREJ_ACT, &chan->conn_state);
1299 l2cap_seq_list_clear(&chan->retrans_list);
1300 l2cap_seq_list_clear(&chan->srej_list);
1301 skb_queue_purge(&chan->srej_q);
1303 chan->tx_state = L2CAP_TX_STATE_XMIT;
1304 chan->rx_state = L2CAP_RX_STATE_MOVE;
1306 set_bit(CONN_REMOTE_BUSY, &chan->conn_state);
1309 static void l2cap_move_done(struct l2cap_chan *chan)
1311 u8 move_role = chan->move_role;
1312 BT_DBG("chan %p", chan);
1314 chan->move_state = L2CAP_MOVE_STABLE;
1315 chan->move_role = L2CAP_MOVE_ROLE_NONE;
1317 if (chan->mode != L2CAP_MODE_ERTM)
1320 switch (move_role) {
1321 case L2CAP_MOVE_ROLE_INITIATOR:
1322 l2cap_tx(chan, NULL, NULL, L2CAP_EV_EXPLICIT_POLL);
1323 chan->rx_state = L2CAP_RX_STATE_WAIT_F;
1325 case L2CAP_MOVE_ROLE_RESPONDER:
1326 chan->rx_state = L2CAP_RX_STATE_WAIT_P;
1331 static void l2cap_chan_ready(struct l2cap_chan *chan)
1333 /* The channel may have already been flagged as connected in
1334 * case of receiving data before the L2CAP info req/rsp
1335 * procedure is complete.
1337 if (chan->state == BT_CONNECTED)
1340 /* This clears all conf flags, including CONF_NOT_COMPLETE */
1341 chan->conf_state = 0;
1342 __clear_chan_timer(chan);
1344 switch (chan->mode) {
1345 case L2CAP_MODE_LE_FLOWCTL:
1346 case L2CAP_MODE_EXT_FLOWCTL:
1347 if (!chan->tx_credits)
1348 chan->ops->suspend(chan);
1352 chan->state = BT_CONNECTED;
1354 chan->ops->ready(chan);
1357 static void l2cap_le_connect(struct l2cap_chan *chan)
1359 struct l2cap_conn *conn = chan->conn;
1360 struct l2cap_le_conn_req req;
1362 if (test_and_set_bit(FLAG_LE_CONN_REQ_SENT, &chan->flags))
1366 chan->imtu = chan->conn->mtu;
1368 l2cap_le_flowctl_init(chan, 0);
1370 req.psm = chan->psm;
1371 req.scid = cpu_to_le16(chan->scid);
1372 req.mtu = cpu_to_le16(chan->imtu);
1373 req.mps = cpu_to_le16(chan->mps);
1374 req.credits = cpu_to_le16(chan->rx_credits);
1376 chan->ident = l2cap_get_ident(conn);
1378 l2cap_send_cmd(conn, chan->ident, L2CAP_LE_CONN_REQ,
1382 struct l2cap_ecred_conn_data {
1384 struct l2cap_ecred_conn_req req;
1387 struct l2cap_chan *chan;
1392 static void l2cap_ecred_defer_connect(struct l2cap_chan *chan, void *data)
1394 struct l2cap_ecred_conn_data *conn = data;
1397 if (chan == conn->chan)
1400 if (!test_and_clear_bit(FLAG_DEFER_SETUP, &chan->flags))
1403 pid = chan->ops->get_peer_pid(chan);
1405 /* Only add deferred channels with the same PID/PSM */
1406 if (conn->pid != pid || chan->psm != conn->chan->psm || chan->ident ||
1407 chan->mode != L2CAP_MODE_EXT_FLOWCTL || chan->state != BT_CONNECT)
1410 if (test_and_set_bit(FLAG_ECRED_CONN_REQ_SENT, &chan->flags))
1413 l2cap_ecred_init(chan, 0);
1415 /* Set the same ident so we can match on the rsp */
1416 chan->ident = conn->chan->ident;
1418 /* Include all channels deferred */
1419 conn->pdu.scid[conn->count] = cpu_to_le16(chan->scid);
1424 static void l2cap_ecred_connect(struct l2cap_chan *chan)
1426 struct l2cap_conn *conn = chan->conn;
1427 struct l2cap_ecred_conn_data data;
1429 if (test_bit(FLAG_DEFER_SETUP, &chan->flags))
1432 if (test_and_set_bit(FLAG_ECRED_CONN_REQ_SENT, &chan->flags))
1435 l2cap_ecred_init(chan, 0);
1437 data.pdu.req.psm = chan->psm;
1438 data.pdu.req.mtu = cpu_to_le16(chan->imtu);
1439 data.pdu.req.mps = cpu_to_le16(chan->mps);
1440 data.pdu.req.credits = cpu_to_le16(chan->rx_credits);
1441 data.pdu.scid[0] = cpu_to_le16(chan->scid);
1443 chan->ident = l2cap_get_ident(conn);
1444 data.pid = chan->ops->get_peer_pid(chan);
1448 data.pid = chan->ops->get_peer_pid(chan);
1450 __l2cap_chan_list(conn, l2cap_ecred_defer_connect, &data);
1452 l2cap_send_cmd(conn, chan->ident, L2CAP_ECRED_CONN_REQ,
1453 sizeof(data.pdu.req) + data.count * sizeof(__le16),
1457 static void l2cap_le_start(struct l2cap_chan *chan)
1459 struct l2cap_conn *conn = chan->conn;
1461 if (!smp_conn_security(conn->hcon, chan->sec_level))
1465 l2cap_chan_ready(chan);
1469 if (chan->state == BT_CONNECT) {
1470 if (chan->mode == L2CAP_MODE_EXT_FLOWCTL)
1471 l2cap_ecred_connect(chan);
1473 l2cap_le_connect(chan);
1477 static void l2cap_start_connection(struct l2cap_chan *chan)
1479 if (__amp_capable(chan)) {
1480 BT_DBG("chan %p AMP capable: discover AMPs", chan);
1481 a2mp_discover_amp(chan);
1482 } else if (chan->conn->hcon->type == LE_LINK) {
1483 l2cap_le_start(chan);
1485 l2cap_send_conn_req(chan);
1489 static void l2cap_request_info(struct l2cap_conn *conn)
1491 struct l2cap_info_req req;
1493 if (conn->info_state & L2CAP_INFO_FEAT_MASK_REQ_SENT)
1496 req.type = cpu_to_le16(L2CAP_IT_FEAT_MASK);
1498 conn->info_state |= L2CAP_INFO_FEAT_MASK_REQ_SENT;
1499 conn->info_ident = l2cap_get_ident(conn);
1501 schedule_delayed_work(&conn->info_timer, L2CAP_INFO_TIMEOUT);
1503 l2cap_send_cmd(conn, conn->info_ident, L2CAP_INFO_REQ,
1507 static bool l2cap_check_enc_key_size(struct hci_conn *hcon)
1509 /* The minimum encryption key size needs to be enforced by the
1510 * host stack before establishing any L2CAP connections. The
1511 * specification in theory allows a minimum of 1, but to align
1512 * BR/EDR and LE transports, a minimum of 7 is chosen.
1514 * This check might also be called for unencrypted connections
1515 * that have no key size requirements. Ensure that the link is
1516 * actually encrypted before enforcing a key size.
1518 int min_key_size = hcon->hdev->min_enc_key_size;
1520 /* On FIPS security level, key size must be 16 bytes */
1521 if (hcon->sec_level == BT_SECURITY_FIPS)
1524 return (!test_bit(HCI_CONN_ENCRYPT, &hcon->flags) ||
1525 hcon->enc_key_size >= min_key_size);
1528 static void l2cap_do_start(struct l2cap_chan *chan)
1530 struct l2cap_conn *conn = chan->conn;
1532 if (conn->hcon->type == LE_LINK) {
1533 l2cap_le_start(chan);
1537 if (!(conn->info_state & L2CAP_INFO_FEAT_MASK_REQ_SENT)) {
1538 l2cap_request_info(conn);
1542 if (!(conn->info_state & L2CAP_INFO_FEAT_MASK_REQ_DONE))
1545 if (!l2cap_chan_check_security(chan, true) ||
1546 !__l2cap_no_conn_pending(chan))
1549 if (l2cap_check_enc_key_size(conn->hcon))
1550 l2cap_start_connection(chan);
1552 __set_chan_timer(chan, L2CAP_DISC_TIMEOUT);
1555 static inline int l2cap_mode_supported(__u8 mode, __u32 feat_mask)
1557 u32 local_feat_mask = l2cap_feat_mask;
1559 local_feat_mask |= L2CAP_FEAT_ERTM | L2CAP_FEAT_STREAMING;
1562 case L2CAP_MODE_ERTM:
1563 return L2CAP_FEAT_ERTM & feat_mask & local_feat_mask;
1564 case L2CAP_MODE_STREAMING:
1565 return L2CAP_FEAT_STREAMING & feat_mask & local_feat_mask;
1571 static void l2cap_send_disconn_req(struct l2cap_chan *chan, int err)
1573 struct l2cap_conn *conn = chan->conn;
1574 struct l2cap_disconn_req req;
1579 if (chan->mode == L2CAP_MODE_ERTM && chan->state == BT_CONNECTED) {
1580 __clear_retrans_timer(chan);
1581 __clear_monitor_timer(chan);
1582 __clear_ack_timer(chan);
1585 if (chan->scid == L2CAP_CID_A2MP) {
1586 l2cap_state_change(chan, BT_DISCONN);
1590 req.dcid = cpu_to_le16(chan->dcid);
1591 req.scid = cpu_to_le16(chan->scid);
1592 l2cap_send_cmd(conn, l2cap_get_ident(conn), L2CAP_DISCONN_REQ,
1595 l2cap_state_change_and_error(chan, BT_DISCONN, err);
1598 /* ---- L2CAP connections ---- */
1599 static void l2cap_conn_start(struct l2cap_conn *conn)
1601 struct l2cap_chan *chan, *tmp;
1603 BT_DBG("conn %p", conn);
1605 mutex_lock(&conn->chan_lock);
1607 list_for_each_entry_safe(chan, tmp, &conn->chan_l, list) {
1608 l2cap_chan_lock(chan);
1610 if (chan->chan_type != L2CAP_CHAN_CONN_ORIENTED) {
1611 l2cap_chan_ready(chan);
1612 l2cap_chan_unlock(chan);
1616 if (chan->state == BT_CONNECT) {
1617 if (!l2cap_chan_check_security(chan, true) ||
1618 !__l2cap_no_conn_pending(chan)) {
1619 l2cap_chan_unlock(chan);
1623 if (!l2cap_mode_supported(chan->mode, conn->feat_mask)
1624 && test_bit(CONF_STATE2_DEVICE,
1625 &chan->conf_state)) {
1626 l2cap_chan_close(chan, ECONNRESET);
1627 l2cap_chan_unlock(chan);
1631 if (l2cap_check_enc_key_size(conn->hcon))
1632 l2cap_start_connection(chan);
1634 l2cap_chan_close(chan, ECONNREFUSED);
1636 } else if (chan->state == BT_CONNECT2) {
1637 struct l2cap_conn_rsp rsp;
1639 rsp.scid = cpu_to_le16(chan->dcid);
1640 rsp.dcid = cpu_to_le16(chan->scid);
1642 if (l2cap_chan_check_security(chan, false)) {
1643 if (test_bit(FLAG_DEFER_SETUP, &chan->flags)) {
1644 rsp.result = cpu_to_le16(L2CAP_CR_PEND);
1645 rsp.status = cpu_to_le16(L2CAP_CS_AUTHOR_PEND);
1646 chan->ops->defer(chan);
1649 l2cap_state_change(chan, BT_CONFIG);
1650 rsp.result = cpu_to_le16(L2CAP_CR_SUCCESS);
1651 rsp.status = cpu_to_le16(L2CAP_CS_NO_INFO);
1654 rsp.result = cpu_to_le16(L2CAP_CR_PEND);
1655 rsp.status = cpu_to_le16(L2CAP_CS_AUTHEN_PEND);
1658 l2cap_send_cmd(conn, chan->ident, L2CAP_CONN_RSP,
1661 if (test_bit(CONF_REQ_SENT, &chan->conf_state) ||
1662 rsp.result != L2CAP_CR_SUCCESS) {
1663 l2cap_chan_unlock(chan);
1667 set_bit(CONF_REQ_SENT, &chan->conf_state);
1668 l2cap_send_cmd(conn, l2cap_get_ident(conn), L2CAP_CONF_REQ,
1669 l2cap_build_conf_req(chan, buf, sizeof(buf)), buf);
1670 chan->num_conf_req++;
1673 l2cap_chan_unlock(chan);
1676 mutex_unlock(&conn->chan_lock);
1679 static void l2cap_le_conn_ready(struct l2cap_conn *conn)
1681 struct hci_conn *hcon = conn->hcon;
1682 struct hci_dev *hdev = hcon->hdev;
1684 BT_DBG("%s conn %p", hdev->name, conn);
1686 /* For outgoing pairing which doesn't necessarily have an
1687 * associated socket (e.g. mgmt_pair_device).
1690 smp_conn_security(hcon, hcon->pending_sec_level);
1692 /* For LE slave connections, make sure the connection interval
1693 * is in the range of the minium and maximum interval that has
1694 * been configured for this connection. If not, then trigger
1695 * the connection update procedure.
1697 if (hcon->role == HCI_ROLE_SLAVE &&
1698 (hcon->le_conn_interval < hcon->le_conn_min_interval ||
1699 hcon->le_conn_interval > hcon->le_conn_max_interval)) {
1700 struct l2cap_conn_param_update_req req;
1702 req.min = cpu_to_le16(hcon->le_conn_min_interval);
1703 req.max = cpu_to_le16(hcon->le_conn_max_interval);
1704 req.latency = cpu_to_le16(hcon->le_conn_latency);
1705 req.to_multiplier = cpu_to_le16(hcon->le_supv_timeout);
1707 l2cap_send_cmd(conn, l2cap_get_ident(conn),
1708 L2CAP_CONN_PARAM_UPDATE_REQ, sizeof(req), &req);
1712 static void l2cap_conn_ready(struct l2cap_conn *conn)
1714 struct l2cap_chan *chan;
1715 struct hci_conn *hcon = conn->hcon;
1717 BT_DBG("conn %p", conn);
1719 if (hcon->type == ACL_LINK)
1720 l2cap_request_info(conn);
1722 mutex_lock(&conn->chan_lock);
1724 list_for_each_entry(chan, &conn->chan_l, list) {
1726 l2cap_chan_lock(chan);
1728 if (chan->scid == L2CAP_CID_A2MP) {
1729 l2cap_chan_unlock(chan);
1733 if (hcon->type == LE_LINK) {
1734 l2cap_le_start(chan);
1735 } else if (chan->chan_type != L2CAP_CHAN_CONN_ORIENTED) {
1736 if (conn->info_state & L2CAP_INFO_FEAT_MASK_REQ_DONE)
1737 l2cap_chan_ready(chan);
1738 } else if (chan->state == BT_CONNECT) {
1739 l2cap_do_start(chan);
1742 l2cap_chan_unlock(chan);
1745 mutex_unlock(&conn->chan_lock);
1747 if (hcon->type == LE_LINK)
1748 l2cap_le_conn_ready(conn);
1750 queue_work(hcon->hdev->workqueue, &conn->pending_rx_work);
1753 /* Notify sockets that we cannot guaranty reliability anymore */
1754 static void l2cap_conn_unreliable(struct l2cap_conn *conn, int err)
1756 struct l2cap_chan *chan;
1758 BT_DBG("conn %p", conn);
1760 mutex_lock(&conn->chan_lock);
1762 list_for_each_entry(chan, &conn->chan_l, list) {
1763 if (test_bit(FLAG_FORCE_RELIABLE, &chan->flags))
1764 l2cap_chan_set_err(chan, err);
1767 mutex_unlock(&conn->chan_lock);
1770 static void l2cap_info_timeout(struct work_struct *work)
1772 struct l2cap_conn *conn = container_of(work, struct l2cap_conn,
1775 conn->info_state |= L2CAP_INFO_FEAT_MASK_REQ_DONE;
1776 conn->info_ident = 0;
1778 l2cap_conn_start(conn);
1783 * External modules can register l2cap_user objects on l2cap_conn. The ->probe
1784 * callback is called during registration. The ->remove callback is called
1785 * during unregistration.
1786 * An l2cap_user object can either be explicitly unregistered or when the
1787 * underlying l2cap_conn object is deleted. This guarantees that l2cap->hcon,
1788 * l2cap->hchan, .. are valid as long as the remove callback hasn't been called.
1789 * External modules must own a reference to the l2cap_conn object if they intend
1790 * to call l2cap_unregister_user(). The l2cap_conn object might get destroyed at
1791 * any time if they don't.
1794 int l2cap_register_user(struct l2cap_conn *conn, struct l2cap_user *user)
1796 struct hci_dev *hdev = conn->hcon->hdev;
1799 /* We need to check whether l2cap_conn is registered. If it is not, we
1800 * must not register the l2cap_user. l2cap_conn_del() is unregisters
1801 * l2cap_conn objects, but doesn't provide its own locking. Instead, it
1802 * relies on the parent hci_conn object to be locked. This itself relies
1803 * on the hci_dev object to be locked. So we must lock the hci device
1808 if (!list_empty(&user->list)) {
1813 /* conn->hchan is NULL after l2cap_conn_del() was called */
1819 ret = user->probe(conn, user);
1823 list_add(&user->list, &conn->users);
1827 hci_dev_unlock(hdev);
1830 EXPORT_SYMBOL(l2cap_register_user);
1832 void l2cap_unregister_user(struct l2cap_conn *conn, struct l2cap_user *user)
1834 struct hci_dev *hdev = conn->hcon->hdev;
1838 if (list_empty(&user->list))
1841 list_del_init(&user->list);
1842 user->remove(conn, user);
1845 hci_dev_unlock(hdev);
1847 EXPORT_SYMBOL(l2cap_unregister_user);
1849 static void l2cap_unregister_all_users(struct l2cap_conn *conn)
1851 struct l2cap_user *user;
1853 while (!list_empty(&conn->users)) {
1854 user = list_first_entry(&conn->users, struct l2cap_user, list);
1855 list_del_init(&user->list);
1856 user->remove(conn, user);
1860 static void l2cap_conn_del(struct hci_conn *hcon, int err)
1862 struct l2cap_conn *conn = hcon->l2cap_data;
1863 struct l2cap_chan *chan, *l;
1868 BT_DBG("hcon %p conn %p, err %d", hcon, conn, err);
1870 kfree_skb(conn->rx_skb);
1872 skb_queue_purge(&conn->pending_rx);
1874 /* We can not call flush_work(&conn->pending_rx_work) here since we
1875 * might block if we are running on a worker from the same workqueue
1876 * pending_rx_work is waiting on.
1878 if (work_pending(&conn->pending_rx_work))
1879 cancel_work_sync(&conn->pending_rx_work);
1881 if (work_pending(&conn->id_addr_update_work))
1882 cancel_work_sync(&conn->id_addr_update_work);
1884 l2cap_unregister_all_users(conn);
1886 /* Force the connection to be immediately dropped */
1887 hcon->disc_timeout = 0;
1889 mutex_lock(&conn->chan_lock);
1892 list_for_each_entry_safe(chan, l, &conn->chan_l, list) {
1893 l2cap_chan_hold(chan);
1894 l2cap_chan_lock(chan);
1896 l2cap_chan_del(chan, err);
1898 chan->ops->close(chan);
1900 l2cap_chan_unlock(chan);
1901 l2cap_chan_put(chan);
1904 mutex_unlock(&conn->chan_lock);
1906 hci_chan_del(conn->hchan);
1908 if (conn->info_state & L2CAP_INFO_FEAT_MASK_REQ_SENT)
1909 cancel_delayed_work_sync(&conn->info_timer);
1911 hcon->l2cap_data = NULL;
1913 l2cap_conn_put(conn);
1916 static void l2cap_conn_free(struct kref *ref)
1918 struct l2cap_conn *conn = container_of(ref, struct l2cap_conn, ref);
1920 hci_conn_put(conn->hcon);
1924 struct l2cap_conn *l2cap_conn_get(struct l2cap_conn *conn)
1926 kref_get(&conn->ref);
1929 EXPORT_SYMBOL(l2cap_conn_get);
1931 void l2cap_conn_put(struct l2cap_conn *conn)
1933 kref_put(&conn->ref, l2cap_conn_free);
1935 EXPORT_SYMBOL(l2cap_conn_put);
1937 /* ---- Socket interface ---- */
1939 /* Find socket with psm and source / destination bdaddr.
1940 * Returns closest match.
1942 static struct l2cap_chan *l2cap_global_chan_by_psm(int state, __le16 psm,
1947 struct l2cap_chan *c, *c1 = NULL;
1949 read_lock(&chan_list_lock);
1951 list_for_each_entry(c, &chan_list, global_l) {
1952 if (state && c->state != state)
1955 if (link_type == ACL_LINK && c->src_type != BDADDR_BREDR)
1958 if (link_type == LE_LINK && c->src_type == BDADDR_BREDR)
1961 if (c->psm == psm) {
1962 int src_match, dst_match;
1963 int src_any, dst_any;
1966 src_match = !bacmp(&c->src, src);
1967 dst_match = !bacmp(&c->dst, dst);
1968 if (src_match && dst_match) {
1970 read_unlock(&chan_list_lock);
1975 src_any = !bacmp(&c->src, BDADDR_ANY);
1976 dst_any = !bacmp(&c->dst, BDADDR_ANY);
1977 if ((src_match && dst_any) || (src_any && dst_match) ||
1978 (src_any && dst_any))
1984 l2cap_chan_hold(c1);
1986 read_unlock(&chan_list_lock);
1991 static void l2cap_monitor_timeout(struct work_struct *work)
1993 struct l2cap_chan *chan = container_of(work, struct l2cap_chan,
1994 monitor_timer.work);
1996 BT_DBG("chan %p", chan);
1998 l2cap_chan_lock(chan);
2001 l2cap_chan_unlock(chan);
2002 l2cap_chan_put(chan);
2006 l2cap_tx(chan, NULL, NULL, L2CAP_EV_MONITOR_TO);
2008 l2cap_chan_unlock(chan);
2009 l2cap_chan_put(chan);
2012 static void l2cap_retrans_timeout(struct work_struct *work)
2014 struct l2cap_chan *chan = container_of(work, struct l2cap_chan,
2015 retrans_timer.work);
2017 BT_DBG("chan %p", chan);
2019 l2cap_chan_lock(chan);
2022 l2cap_chan_unlock(chan);
2023 l2cap_chan_put(chan);
2027 l2cap_tx(chan, NULL, NULL, L2CAP_EV_RETRANS_TO);
2028 l2cap_chan_unlock(chan);
2029 l2cap_chan_put(chan);
2032 static void l2cap_streaming_send(struct l2cap_chan *chan,
2033 struct sk_buff_head *skbs)
2035 struct sk_buff *skb;
2036 struct l2cap_ctrl *control;
2038 BT_DBG("chan %p, skbs %p", chan, skbs);
2040 if (__chan_is_moving(chan))
2043 skb_queue_splice_tail_init(skbs, &chan->tx_q);
2045 while (!skb_queue_empty(&chan->tx_q)) {
2047 skb = skb_dequeue(&chan->tx_q);
2049 bt_cb(skb)->l2cap.retries = 1;
2050 control = &bt_cb(skb)->l2cap;
2052 control->reqseq = 0;
2053 control->txseq = chan->next_tx_seq;
2055 __pack_control(chan, control, skb);
2057 if (chan->fcs == L2CAP_FCS_CRC16) {
2058 u16 fcs = crc16(0, (u8 *) skb->data, skb->len);
2059 put_unaligned_le16(fcs, skb_put(skb, L2CAP_FCS_SIZE));
2062 l2cap_do_send(chan, skb);
2064 BT_DBG("Sent txseq %u", control->txseq);
2066 chan->next_tx_seq = __next_seq(chan, chan->next_tx_seq);
2067 chan->frames_sent++;
2071 static int l2cap_ertm_send(struct l2cap_chan *chan)
2073 struct sk_buff *skb, *tx_skb;
2074 struct l2cap_ctrl *control;
2077 BT_DBG("chan %p", chan);
2079 if (chan->state != BT_CONNECTED)
2082 if (test_bit(CONN_REMOTE_BUSY, &chan->conn_state))
2085 if (__chan_is_moving(chan))
2088 while (chan->tx_send_head &&
2089 chan->unacked_frames < chan->remote_tx_win &&
2090 chan->tx_state == L2CAP_TX_STATE_XMIT) {
2092 skb = chan->tx_send_head;
2094 bt_cb(skb)->l2cap.retries = 1;
2095 control = &bt_cb(skb)->l2cap;
2097 if (test_and_clear_bit(CONN_SEND_FBIT, &chan->conn_state))
2100 control->reqseq = chan->buffer_seq;
2101 chan->last_acked_seq = chan->buffer_seq;
2102 control->txseq = chan->next_tx_seq;
2104 __pack_control(chan, control, skb);
2106 if (chan->fcs == L2CAP_FCS_CRC16) {
2107 u16 fcs = crc16(0, (u8 *) skb->data, skb->len);
2108 put_unaligned_le16(fcs, skb_put(skb, L2CAP_FCS_SIZE));
2111 /* Clone after data has been modified. Data is assumed to be
2112 read-only (for locking purposes) on cloned sk_buffs.
2114 tx_skb = skb_clone(skb, GFP_KERNEL);
2119 __set_retrans_timer(chan);
2121 chan->next_tx_seq = __next_seq(chan, chan->next_tx_seq);
2122 chan->unacked_frames++;
2123 chan->frames_sent++;
2126 if (skb_queue_is_last(&chan->tx_q, skb))
2127 chan->tx_send_head = NULL;
2129 chan->tx_send_head = skb_queue_next(&chan->tx_q, skb);
2131 l2cap_do_send(chan, tx_skb);
2132 BT_DBG("Sent txseq %u", control->txseq);
2135 BT_DBG("Sent %d, %u unacked, %u in ERTM queue", sent,
2136 chan->unacked_frames, skb_queue_len(&chan->tx_q));
2141 static void l2cap_ertm_resend(struct l2cap_chan *chan)
2143 struct l2cap_ctrl control;
2144 struct sk_buff *skb;
2145 struct sk_buff *tx_skb;
2148 BT_DBG("chan %p", chan);
2150 if (test_bit(CONN_REMOTE_BUSY, &chan->conn_state))
2153 if (__chan_is_moving(chan))
2156 while (chan->retrans_list.head != L2CAP_SEQ_LIST_CLEAR) {
2157 seq = l2cap_seq_list_pop(&chan->retrans_list);
2159 skb = l2cap_ertm_seq_in_queue(&chan->tx_q, seq);
2161 BT_DBG("Error: Can't retransmit seq %d, frame missing",
2166 bt_cb(skb)->l2cap.retries++;
2167 control = bt_cb(skb)->l2cap;
2169 if (chan->max_tx != 0 &&
2170 bt_cb(skb)->l2cap.retries > chan->max_tx) {
2171 BT_DBG("Retry limit exceeded (%d)", chan->max_tx);
2172 l2cap_send_disconn_req(chan, ECONNRESET);
2173 l2cap_seq_list_clear(&chan->retrans_list);
2177 control.reqseq = chan->buffer_seq;
2178 if (test_and_clear_bit(CONN_SEND_FBIT, &chan->conn_state))
2183 if (skb_cloned(skb)) {
2184 /* Cloned sk_buffs are read-only, so we need a
2187 tx_skb = skb_copy(skb, GFP_KERNEL);
2189 tx_skb = skb_clone(skb, GFP_KERNEL);
2193 l2cap_seq_list_clear(&chan->retrans_list);
2197 /* Update skb contents */
2198 if (test_bit(FLAG_EXT_CTRL, &chan->flags)) {
2199 put_unaligned_le32(__pack_extended_control(&control),
2200 tx_skb->data + L2CAP_HDR_SIZE);
2202 put_unaligned_le16(__pack_enhanced_control(&control),
2203 tx_skb->data + L2CAP_HDR_SIZE);
2207 if (chan->fcs == L2CAP_FCS_CRC16) {
2208 u16 fcs = crc16(0, (u8 *) tx_skb->data,
2209 tx_skb->len - L2CAP_FCS_SIZE);
2210 put_unaligned_le16(fcs, skb_tail_pointer(tx_skb) -
2214 l2cap_do_send(chan, tx_skb);
2216 BT_DBG("Resent txseq %d", control.txseq);
2218 chan->last_acked_seq = chan->buffer_seq;
2222 static void l2cap_retransmit(struct l2cap_chan *chan,
2223 struct l2cap_ctrl *control)
2225 BT_DBG("chan %p, control %p", chan, control);
2227 l2cap_seq_list_append(&chan->retrans_list, control->reqseq);
2228 l2cap_ertm_resend(chan);
2231 static void l2cap_retransmit_all(struct l2cap_chan *chan,
2232 struct l2cap_ctrl *control)
2234 struct sk_buff *skb;
2236 BT_DBG("chan %p, control %p", chan, control);
2239 set_bit(CONN_SEND_FBIT, &chan->conn_state);
2241 l2cap_seq_list_clear(&chan->retrans_list);
2243 if (test_bit(CONN_REMOTE_BUSY, &chan->conn_state))
2246 if (chan->unacked_frames) {
2247 skb_queue_walk(&chan->tx_q, skb) {
2248 if (bt_cb(skb)->l2cap.txseq == control->reqseq ||
2249 skb == chan->tx_send_head)
2253 skb_queue_walk_from(&chan->tx_q, skb) {
2254 if (skb == chan->tx_send_head)
2257 l2cap_seq_list_append(&chan->retrans_list,
2258 bt_cb(skb)->l2cap.txseq);
2261 l2cap_ertm_resend(chan);
2265 static void l2cap_send_ack(struct l2cap_chan *chan)
2267 struct l2cap_ctrl control;
2268 u16 frames_to_ack = __seq_offset(chan, chan->buffer_seq,
2269 chan->last_acked_seq);
2272 BT_DBG("chan %p last_acked_seq %d buffer_seq %d",
2273 chan, chan->last_acked_seq, chan->buffer_seq);
2275 memset(&control, 0, sizeof(control));
2278 if (test_bit(CONN_LOCAL_BUSY, &chan->conn_state) &&
2279 chan->rx_state == L2CAP_RX_STATE_RECV) {
2280 __clear_ack_timer(chan);
2281 control.super = L2CAP_SUPER_RNR;
2282 control.reqseq = chan->buffer_seq;
2283 l2cap_send_sframe(chan, &control);
2285 if (!test_bit(CONN_REMOTE_BUSY, &chan->conn_state)) {
2286 l2cap_ertm_send(chan);
2287 /* If any i-frames were sent, they included an ack */
2288 if (chan->buffer_seq == chan->last_acked_seq)
2292 /* Ack now if the window is 3/4ths full.
2293 * Calculate without mul or div
2295 threshold = chan->ack_win;
2296 threshold += threshold << 1;
2299 BT_DBG("frames_to_ack %u, threshold %d", frames_to_ack,
2302 if (frames_to_ack >= threshold) {
2303 __clear_ack_timer(chan);
2304 control.super = L2CAP_SUPER_RR;
2305 control.reqseq = chan->buffer_seq;
2306 l2cap_send_sframe(chan, &control);
2311 __set_ack_timer(chan);
2315 static inline int l2cap_skbuff_fromiovec(struct l2cap_chan *chan,
2316 struct msghdr *msg, int len,
2317 int count, struct sk_buff *skb)
2319 struct l2cap_conn *conn = chan->conn;
2320 struct sk_buff **frag;
2323 if (!copy_from_iter_full(skb_put(skb, count), count, &msg->msg_iter))
2329 /* Continuation fragments (no L2CAP header) */
2330 frag = &skb_shinfo(skb)->frag_list;
2332 struct sk_buff *tmp;
2334 count = min_t(unsigned int, conn->mtu, len);
2336 tmp = chan->ops->alloc_skb(chan, 0, count,
2337 msg->msg_flags & MSG_DONTWAIT);
2339 return PTR_ERR(tmp);
2343 if (!copy_from_iter_full(skb_put(*frag, count), count,
2350 skb->len += (*frag)->len;
2351 skb->data_len += (*frag)->len;
2353 frag = &(*frag)->next;
2359 static struct sk_buff *l2cap_create_connless_pdu(struct l2cap_chan *chan,
2360 struct msghdr *msg, size_t len)
2362 struct l2cap_conn *conn = chan->conn;
2363 struct sk_buff *skb;
2364 int err, count, hlen = L2CAP_HDR_SIZE + L2CAP_PSMLEN_SIZE;
2365 struct l2cap_hdr *lh;
2367 BT_DBG("chan %p psm 0x%2.2x len %zu", chan,
2368 __le16_to_cpu(chan->psm), len);
2370 count = min_t(unsigned int, (conn->mtu - hlen), len);
2372 skb = chan->ops->alloc_skb(chan, hlen, count,
2373 msg->msg_flags & MSG_DONTWAIT);
2377 /* Create L2CAP header */
2378 lh = skb_put(skb, L2CAP_HDR_SIZE);
2379 lh->cid = cpu_to_le16(chan->dcid);
2380 lh->len = cpu_to_le16(len + L2CAP_PSMLEN_SIZE);
2381 put_unaligned(chan->psm, (__le16 *) skb_put(skb, L2CAP_PSMLEN_SIZE));
2383 err = l2cap_skbuff_fromiovec(chan, msg, len, count, skb);
2384 if (unlikely(err < 0)) {
2386 return ERR_PTR(err);
2391 static struct sk_buff *l2cap_create_basic_pdu(struct l2cap_chan *chan,
2392 struct msghdr *msg, size_t len)
2394 struct l2cap_conn *conn = chan->conn;
2395 struct sk_buff *skb;
2397 struct l2cap_hdr *lh;
2399 BT_DBG("chan %p len %zu", chan, len);
2401 count = min_t(unsigned int, (conn->mtu - L2CAP_HDR_SIZE), len);
2403 skb = chan->ops->alloc_skb(chan, L2CAP_HDR_SIZE, count,
2404 msg->msg_flags & MSG_DONTWAIT);
2408 /* Create L2CAP header */
2409 lh = skb_put(skb, L2CAP_HDR_SIZE);
2410 lh->cid = cpu_to_le16(chan->dcid);
2411 lh->len = cpu_to_le16(len);
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_iframe_pdu(struct l2cap_chan *chan,
2422 struct msghdr *msg, size_t len,
2425 struct l2cap_conn *conn = chan->conn;
2426 struct sk_buff *skb;
2427 int err, count, hlen;
2428 struct l2cap_hdr *lh;
2430 BT_DBG("chan %p len %zu", chan, len);
2433 return ERR_PTR(-ENOTCONN);
2435 hlen = __ertm_hdr_size(chan);
2438 hlen += L2CAP_SDULEN_SIZE;
2440 if (chan->fcs == L2CAP_FCS_CRC16)
2441 hlen += L2CAP_FCS_SIZE;
2443 count = min_t(unsigned int, (conn->mtu - hlen), len);
2445 skb = chan->ops->alloc_skb(chan, hlen, count,
2446 msg->msg_flags & MSG_DONTWAIT);
2450 /* Create L2CAP header */
2451 lh = skb_put(skb, L2CAP_HDR_SIZE);
2452 lh->cid = cpu_to_le16(chan->dcid);
2453 lh->len = cpu_to_le16(len + (hlen - L2CAP_HDR_SIZE));
2455 /* Control header is populated later */
2456 if (test_bit(FLAG_EXT_CTRL, &chan->flags))
2457 put_unaligned_le32(0, skb_put(skb, L2CAP_EXT_CTRL_SIZE));
2459 put_unaligned_le16(0, skb_put(skb, L2CAP_ENH_CTRL_SIZE));
2462 put_unaligned_le16(sdulen, skb_put(skb, L2CAP_SDULEN_SIZE));
2464 err = l2cap_skbuff_fromiovec(chan, msg, len, count, skb);
2465 if (unlikely(err < 0)) {
2467 return ERR_PTR(err);
2470 bt_cb(skb)->l2cap.fcs = chan->fcs;
2471 bt_cb(skb)->l2cap.retries = 0;
2475 static int l2cap_segment_sdu(struct l2cap_chan *chan,
2476 struct sk_buff_head *seg_queue,
2477 struct msghdr *msg, size_t len)
2479 struct sk_buff *skb;
2484 BT_DBG("chan %p, msg %p, len %zu", chan, msg, len);
2486 /* It is critical that ERTM PDUs fit in a single HCI fragment,
2487 * so fragmented skbs are not used. The HCI layer's handling
2488 * of fragmented skbs is not compatible with ERTM's queueing.
2491 /* PDU size is derived from the HCI MTU */
2492 pdu_len = chan->conn->mtu;
2494 /* Constrain PDU size for BR/EDR connections */
2496 pdu_len = min_t(size_t, pdu_len, L2CAP_BREDR_MAX_PAYLOAD);
2498 /* Adjust for largest possible L2CAP overhead. */
2500 pdu_len -= L2CAP_FCS_SIZE;
2502 pdu_len -= __ertm_hdr_size(chan);
2504 /* Remote device may have requested smaller PDUs */
2505 pdu_len = min_t(size_t, pdu_len, chan->remote_mps);
2507 if (len <= pdu_len) {
2508 sar = L2CAP_SAR_UNSEGMENTED;
2512 sar = L2CAP_SAR_START;
2517 skb = l2cap_create_iframe_pdu(chan, msg, pdu_len, sdu_len);
2520 __skb_queue_purge(seg_queue);
2521 return PTR_ERR(skb);
2524 bt_cb(skb)->l2cap.sar = sar;
2525 __skb_queue_tail(seg_queue, skb);
2531 if (len <= pdu_len) {
2532 sar = L2CAP_SAR_END;
2535 sar = L2CAP_SAR_CONTINUE;
2542 static struct sk_buff *l2cap_create_le_flowctl_pdu(struct l2cap_chan *chan,
2544 size_t len, u16 sdulen)
2546 struct l2cap_conn *conn = chan->conn;
2547 struct sk_buff *skb;
2548 int err, count, hlen;
2549 struct l2cap_hdr *lh;
2551 BT_DBG("chan %p len %zu", chan, len);
2554 return ERR_PTR(-ENOTCONN);
2556 hlen = L2CAP_HDR_SIZE;
2559 hlen += L2CAP_SDULEN_SIZE;
2561 count = min_t(unsigned int, (conn->mtu - hlen), len);
2563 skb = chan->ops->alloc_skb(chan, hlen, count,
2564 msg->msg_flags & MSG_DONTWAIT);
2568 /* Create L2CAP header */
2569 lh = skb_put(skb, L2CAP_HDR_SIZE);
2570 lh->cid = cpu_to_le16(chan->dcid);
2571 lh->len = cpu_to_le16(len + (hlen - L2CAP_HDR_SIZE));
2574 put_unaligned_le16(sdulen, skb_put(skb, L2CAP_SDULEN_SIZE));
2576 err = l2cap_skbuff_fromiovec(chan, msg, len, count, skb);
2577 if (unlikely(err < 0)) {
2579 return ERR_PTR(err);
2585 static int l2cap_segment_le_sdu(struct l2cap_chan *chan,
2586 struct sk_buff_head *seg_queue,
2587 struct msghdr *msg, size_t len)
2589 struct sk_buff *skb;
2593 BT_DBG("chan %p, msg %p, len %zu", chan, msg, len);
2596 pdu_len = chan->remote_mps - L2CAP_SDULEN_SIZE;
2602 skb = l2cap_create_le_flowctl_pdu(chan, msg, pdu_len, sdu_len);
2604 __skb_queue_purge(seg_queue);
2605 return PTR_ERR(skb);
2608 __skb_queue_tail(seg_queue, skb);
2614 pdu_len += L2CAP_SDULEN_SIZE;
2621 static void l2cap_le_flowctl_send(struct l2cap_chan *chan)
2625 BT_DBG("chan %p", chan);
2627 while (chan->tx_credits && !skb_queue_empty(&chan->tx_q)) {
2628 l2cap_do_send(chan, skb_dequeue(&chan->tx_q));
2633 BT_DBG("Sent %d credits %u queued %u", sent, chan->tx_credits,
2634 skb_queue_len(&chan->tx_q));
2637 int l2cap_chan_send(struct l2cap_chan *chan, struct msghdr *msg, size_t len)
2639 struct sk_buff *skb;
2641 struct sk_buff_head seg_queue;
2646 /* Connectionless channel */
2647 if (chan->chan_type == L2CAP_CHAN_CONN_LESS) {
2648 skb = l2cap_create_connless_pdu(chan, msg, len);
2650 return PTR_ERR(skb);
2652 /* Channel lock is released before requesting new skb and then
2653 * reacquired thus we need to recheck channel state.
2655 if (chan->state != BT_CONNECTED) {
2660 l2cap_do_send(chan, skb);
2664 switch (chan->mode) {
2665 case L2CAP_MODE_LE_FLOWCTL:
2666 case L2CAP_MODE_EXT_FLOWCTL:
2667 /* Check outgoing MTU */
2668 if (len > chan->omtu)
2671 __skb_queue_head_init(&seg_queue);
2673 err = l2cap_segment_le_sdu(chan, &seg_queue, msg, len);
2675 if (chan->state != BT_CONNECTED) {
2676 __skb_queue_purge(&seg_queue);
2683 skb_queue_splice_tail_init(&seg_queue, &chan->tx_q);
2685 l2cap_le_flowctl_send(chan);
2687 if (!chan->tx_credits)
2688 chan->ops->suspend(chan);
2694 case L2CAP_MODE_BASIC:
2695 /* Check outgoing MTU */
2696 if (len > chan->omtu)
2699 /* Create a basic PDU */
2700 skb = l2cap_create_basic_pdu(chan, msg, len);
2702 return PTR_ERR(skb);
2704 /* Channel lock is released before requesting new skb and then
2705 * reacquired thus we need to recheck channel state.
2707 if (chan->state != BT_CONNECTED) {
2712 l2cap_do_send(chan, skb);
2716 case L2CAP_MODE_ERTM:
2717 case L2CAP_MODE_STREAMING:
2718 /* Check outgoing MTU */
2719 if (len > chan->omtu) {
2724 __skb_queue_head_init(&seg_queue);
2726 /* Do segmentation before calling in to the state machine,
2727 * since it's possible to block while waiting for memory
2730 err = l2cap_segment_sdu(chan, &seg_queue, msg, len);
2732 /* The channel could have been closed while segmenting,
2733 * check that it is still connected.
2735 if (chan->state != BT_CONNECTED) {
2736 __skb_queue_purge(&seg_queue);
2743 if (chan->mode == L2CAP_MODE_ERTM)
2744 l2cap_tx(chan, NULL, &seg_queue, L2CAP_EV_DATA_REQUEST);
2746 l2cap_streaming_send(chan, &seg_queue);
2750 /* If the skbs were not queued for sending, they'll still be in
2751 * seg_queue and need to be purged.
2753 __skb_queue_purge(&seg_queue);
2757 BT_DBG("bad state %1.1x", chan->mode);
2763 EXPORT_SYMBOL_GPL(l2cap_chan_send);
2765 static void l2cap_send_srej(struct l2cap_chan *chan, u16 txseq)
2767 struct l2cap_ctrl control;
2770 BT_DBG("chan %p, txseq %u", chan, txseq);
2772 memset(&control, 0, sizeof(control));
2774 control.super = L2CAP_SUPER_SREJ;
2776 for (seq = chan->expected_tx_seq; seq != txseq;
2777 seq = __next_seq(chan, seq)) {
2778 if (!l2cap_ertm_seq_in_queue(&chan->srej_q, seq)) {
2779 control.reqseq = seq;
2780 l2cap_send_sframe(chan, &control);
2781 l2cap_seq_list_append(&chan->srej_list, seq);
2785 chan->expected_tx_seq = __next_seq(chan, txseq);
2788 static void l2cap_send_srej_tail(struct l2cap_chan *chan)
2790 struct l2cap_ctrl control;
2792 BT_DBG("chan %p", chan);
2794 if (chan->srej_list.tail == L2CAP_SEQ_LIST_CLEAR)
2797 memset(&control, 0, sizeof(control));
2799 control.super = L2CAP_SUPER_SREJ;
2800 control.reqseq = chan->srej_list.tail;
2801 l2cap_send_sframe(chan, &control);
2804 static void l2cap_send_srej_list(struct l2cap_chan *chan, u16 txseq)
2806 struct l2cap_ctrl control;
2810 BT_DBG("chan %p, txseq %u", chan, txseq);
2812 memset(&control, 0, sizeof(control));
2814 control.super = L2CAP_SUPER_SREJ;
2816 /* Capture initial list head to allow only one pass through the list. */
2817 initial_head = chan->srej_list.head;
2820 seq = l2cap_seq_list_pop(&chan->srej_list);
2821 if (seq == txseq || seq == L2CAP_SEQ_LIST_CLEAR)
2824 control.reqseq = seq;
2825 l2cap_send_sframe(chan, &control);
2826 l2cap_seq_list_append(&chan->srej_list, seq);
2827 } while (chan->srej_list.head != initial_head);
2830 static void l2cap_process_reqseq(struct l2cap_chan *chan, u16 reqseq)
2832 struct sk_buff *acked_skb;
2835 BT_DBG("chan %p, reqseq %u", chan, reqseq);
2837 if (chan->unacked_frames == 0 || reqseq == chan->expected_ack_seq)
2840 BT_DBG("expected_ack_seq %u, unacked_frames %u",
2841 chan->expected_ack_seq, chan->unacked_frames);
2843 for (ackseq = chan->expected_ack_seq; ackseq != reqseq;
2844 ackseq = __next_seq(chan, ackseq)) {
2846 acked_skb = l2cap_ertm_seq_in_queue(&chan->tx_q, ackseq);
2848 skb_unlink(acked_skb, &chan->tx_q);
2849 kfree_skb(acked_skb);
2850 chan->unacked_frames--;
2854 chan->expected_ack_seq = reqseq;
2856 if (chan->unacked_frames == 0)
2857 __clear_retrans_timer(chan);
2859 BT_DBG("unacked_frames %u", chan->unacked_frames);
2862 static void l2cap_abort_rx_srej_sent(struct l2cap_chan *chan)
2864 BT_DBG("chan %p", chan);
2866 chan->expected_tx_seq = chan->buffer_seq;
2867 l2cap_seq_list_clear(&chan->srej_list);
2868 skb_queue_purge(&chan->srej_q);
2869 chan->rx_state = L2CAP_RX_STATE_RECV;
2872 static void l2cap_tx_state_xmit(struct l2cap_chan *chan,
2873 struct l2cap_ctrl *control,
2874 struct sk_buff_head *skbs, u8 event)
2876 BT_DBG("chan %p, control %p, skbs %p, event %d", chan, control, skbs,
2880 case L2CAP_EV_DATA_REQUEST:
2881 if (chan->tx_send_head == NULL)
2882 chan->tx_send_head = skb_peek(skbs);
2884 skb_queue_splice_tail_init(skbs, &chan->tx_q);
2885 l2cap_ertm_send(chan);
2887 case L2CAP_EV_LOCAL_BUSY_DETECTED:
2888 BT_DBG("Enter LOCAL_BUSY");
2889 set_bit(CONN_LOCAL_BUSY, &chan->conn_state);
2891 if (chan->rx_state == L2CAP_RX_STATE_SREJ_SENT) {
2892 /* The SREJ_SENT state must be aborted if we are to
2893 * enter the LOCAL_BUSY state.
2895 l2cap_abort_rx_srej_sent(chan);
2898 l2cap_send_ack(chan);
2901 case L2CAP_EV_LOCAL_BUSY_CLEAR:
2902 BT_DBG("Exit LOCAL_BUSY");
2903 clear_bit(CONN_LOCAL_BUSY, &chan->conn_state);
2905 if (test_bit(CONN_RNR_SENT, &chan->conn_state)) {
2906 struct l2cap_ctrl local_control;
2908 memset(&local_control, 0, sizeof(local_control));
2909 local_control.sframe = 1;
2910 local_control.super = L2CAP_SUPER_RR;
2911 local_control.poll = 1;
2912 local_control.reqseq = chan->buffer_seq;
2913 l2cap_send_sframe(chan, &local_control);
2915 chan->retry_count = 1;
2916 __set_monitor_timer(chan);
2917 chan->tx_state = L2CAP_TX_STATE_WAIT_F;
2920 case L2CAP_EV_RECV_REQSEQ_AND_FBIT:
2921 l2cap_process_reqseq(chan, control->reqseq);
2923 case L2CAP_EV_EXPLICIT_POLL:
2924 l2cap_send_rr_or_rnr(chan, 1);
2925 chan->retry_count = 1;
2926 __set_monitor_timer(chan);
2927 __clear_ack_timer(chan);
2928 chan->tx_state = L2CAP_TX_STATE_WAIT_F;
2930 case L2CAP_EV_RETRANS_TO:
2931 l2cap_send_rr_or_rnr(chan, 1);
2932 chan->retry_count = 1;
2933 __set_monitor_timer(chan);
2934 chan->tx_state = L2CAP_TX_STATE_WAIT_F;
2936 case L2CAP_EV_RECV_FBIT:
2937 /* Nothing to process */
2944 static void l2cap_tx_state_wait_f(struct l2cap_chan *chan,
2945 struct l2cap_ctrl *control,
2946 struct sk_buff_head *skbs, u8 event)
2948 BT_DBG("chan %p, control %p, skbs %p, event %d", chan, control, skbs,
2952 case L2CAP_EV_DATA_REQUEST:
2953 if (chan->tx_send_head == NULL)
2954 chan->tx_send_head = skb_peek(skbs);
2955 /* Queue data, but don't send. */
2956 skb_queue_splice_tail_init(skbs, &chan->tx_q);
2958 case L2CAP_EV_LOCAL_BUSY_DETECTED:
2959 BT_DBG("Enter LOCAL_BUSY");
2960 set_bit(CONN_LOCAL_BUSY, &chan->conn_state);
2962 if (chan->rx_state == L2CAP_RX_STATE_SREJ_SENT) {
2963 /* The SREJ_SENT state must be aborted if we are to
2964 * enter the LOCAL_BUSY state.
2966 l2cap_abort_rx_srej_sent(chan);
2969 l2cap_send_ack(chan);
2972 case L2CAP_EV_LOCAL_BUSY_CLEAR:
2973 BT_DBG("Exit LOCAL_BUSY");
2974 clear_bit(CONN_LOCAL_BUSY, &chan->conn_state);
2976 if (test_bit(CONN_RNR_SENT, &chan->conn_state)) {
2977 struct l2cap_ctrl local_control;
2978 memset(&local_control, 0, sizeof(local_control));
2979 local_control.sframe = 1;
2980 local_control.super = L2CAP_SUPER_RR;
2981 local_control.poll = 1;
2982 local_control.reqseq = chan->buffer_seq;
2983 l2cap_send_sframe(chan, &local_control);
2985 chan->retry_count = 1;
2986 __set_monitor_timer(chan);
2987 chan->tx_state = L2CAP_TX_STATE_WAIT_F;
2990 case L2CAP_EV_RECV_REQSEQ_AND_FBIT:
2991 l2cap_process_reqseq(chan, control->reqseq);
2994 case L2CAP_EV_RECV_FBIT:
2995 if (control && control->final) {
2996 __clear_monitor_timer(chan);
2997 if (chan->unacked_frames > 0)
2998 __set_retrans_timer(chan);
2999 chan->retry_count = 0;
3000 chan->tx_state = L2CAP_TX_STATE_XMIT;
3001 BT_DBG("recv fbit tx_state 0x2.2%x", chan->tx_state);
3004 case L2CAP_EV_EXPLICIT_POLL:
3007 case L2CAP_EV_MONITOR_TO:
3008 if (chan->max_tx == 0 || chan->retry_count < chan->max_tx) {
3009 l2cap_send_rr_or_rnr(chan, 1);
3010 __set_monitor_timer(chan);
3011 chan->retry_count++;
3013 l2cap_send_disconn_req(chan, ECONNABORTED);
3021 static void l2cap_tx(struct l2cap_chan *chan, struct l2cap_ctrl *control,
3022 struct sk_buff_head *skbs, u8 event)
3024 BT_DBG("chan %p, control %p, skbs %p, event %d, state %d",
3025 chan, control, skbs, event, chan->tx_state);
3027 switch (chan->tx_state) {
3028 case L2CAP_TX_STATE_XMIT:
3029 l2cap_tx_state_xmit(chan, control, skbs, event);
3031 case L2CAP_TX_STATE_WAIT_F:
3032 l2cap_tx_state_wait_f(chan, control, skbs, event);
3040 static void l2cap_pass_to_tx(struct l2cap_chan *chan,
3041 struct l2cap_ctrl *control)
3043 BT_DBG("chan %p, control %p", chan, control);
3044 l2cap_tx(chan, control, NULL, L2CAP_EV_RECV_REQSEQ_AND_FBIT);
3047 static void l2cap_pass_to_tx_fbit(struct l2cap_chan *chan,
3048 struct l2cap_ctrl *control)
3050 BT_DBG("chan %p, control %p", chan, control);
3051 l2cap_tx(chan, control, NULL, L2CAP_EV_RECV_FBIT);
3054 /* Copy frame to all raw sockets on that connection */
3055 static void l2cap_raw_recv(struct l2cap_conn *conn, struct sk_buff *skb)
3057 struct sk_buff *nskb;
3058 struct l2cap_chan *chan;
3060 BT_DBG("conn %p", conn);
3062 mutex_lock(&conn->chan_lock);
3064 list_for_each_entry(chan, &conn->chan_l, list) {
3065 if (chan->chan_type != L2CAP_CHAN_RAW)
3068 /* Don't send frame to the channel it came from */
3069 if (bt_cb(skb)->l2cap.chan == chan)
3072 nskb = skb_clone(skb, GFP_KERNEL);
3075 if (chan->ops->recv(chan, nskb))
3079 mutex_unlock(&conn->chan_lock);
3082 /* ---- L2CAP signalling commands ---- */
3083 static struct sk_buff *l2cap_build_cmd(struct l2cap_conn *conn, u8 code,
3084 u8 ident, u16 dlen, void *data)
3086 struct sk_buff *skb, **frag;
3087 struct l2cap_cmd_hdr *cmd;
3088 struct l2cap_hdr *lh;
3091 BT_DBG("conn %p, code 0x%2.2x, ident 0x%2.2x, len %u",
3092 conn, code, ident, dlen);
3094 if (conn->mtu < L2CAP_HDR_SIZE + L2CAP_CMD_HDR_SIZE)
3097 len = L2CAP_HDR_SIZE + L2CAP_CMD_HDR_SIZE + dlen;
3098 count = min_t(unsigned int, conn->mtu, len);
3100 skb = bt_skb_alloc(count, GFP_KERNEL);
3104 lh = skb_put(skb, L2CAP_HDR_SIZE);
3105 lh->len = cpu_to_le16(L2CAP_CMD_HDR_SIZE + dlen);
3107 if (conn->hcon->type == LE_LINK)
3108 lh->cid = cpu_to_le16(L2CAP_CID_LE_SIGNALING);
3110 lh->cid = cpu_to_le16(L2CAP_CID_SIGNALING);
3112 cmd = skb_put(skb, L2CAP_CMD_HDR_SIZE);
3115 cmd->len = cpu_to_le16(dlen);
3118 count -= L2CAP_HDR_SIZE + L2CAP_CMD_HDR_SIZE;
3119 skb_put_data(skb, data, count);
3125 /* Continuation fragments (no L2CAP header) */
3126 frag = &skb_shinfo(skb)->frag_list;
3128 count = min_t(unsigned int, conn->mtu, len);
3130 *frag = bt_skb_alloc(count, GFP_KERNEL);
3134 skb_put_data(*frag, data, count);
3139 frag = &(*frag)->next;
3149 static inline int l2cap_get_conf_opt(void **ptr, int *type, int *olen,
3152 struct l2cap_conf_opt *opt = *ptr;
3155 len = L2CAP_CONF_OPT_SIZE + opt->len;
3163 *val = *((u8 *) opt->val);
3167 *val = get_unaligned_le16(opt->val);
3171 *val = get_unaligned_le32(opt->val);
3175 *val = (unsigned long) opt->val;
3179 BT_DBG("type 0x%2.2x len %u val 0x%lx", *type, opt->len, *val);
3183 static void l2cap_add_conf_opt(void **ptr, u8 type, u8 len, unsigned long val, size_t size)
3185 struct l2cap_conf_opt *opt = *ptr;
3187 BT_DBG("type 0x%2.2x len %u val 0x%lx", type, len, val);
3189 if (size < L2CAP_CONF_OPT_SIZE + len)
3197 *((u8 *) opt->val) = val;
3201 put_unaligned_le16(val, opt->val);
3205 put_unaligned_le32(val, opt->val);
3209 memcpy(opt->val, (void *) val, len);
3213 *ptr += L2CAP_CONF_OPT_SIZE + len;
3216 static void l2cap_add_opt_efs(void **ptr, struct l2cap_chan *chan, size_t size)
3218 struct l2cap_conf_efs efs;
3220 switch (chan->mode) {
3221 case L2CAP_MODE_ERTM:
3222 efs.id = chan->local_id;
3223 efs.stype = chan->local_stype;
3224 efs.msdu = cpu_to_le16(chan->local_msdu);
3225 efs.sdu_itime = cpu_to_le32(chan->local_sdu_itime);
3226 efs.acc_lat = cpu_to_le32(L2CAP_DEFAULT_ACC_LAT);
3227 efs.flush_to = cpu_to_le32(L2CAP_EFS_DEFAULT_FLUSH_TO);
3230 case L2CAP_MODE_STREAMING:
3232 efs.stype = L2CAP_SERV_BESTEFFORT;
3233 efs.msdu = cpu_to_le16(chan->local_msdu);
3234 efs.sdu_itime = cpu_to_le32(chan->local_sdu_itime);
3243 l2cap_add_conf_opt(ptr, L2CAP_CONF_EFS, sizeof(efs),
3244 (unsigned long) &efs, size);
3247 static void l2cap_ack_timeout(struct work_struct *work)
3249 struct l2cap_chan *chan = container_of(work, struct l2cap_chan,
3253 BT_DBG("chan %p", chan);
3255 l2cap_chan_lock(chan);
3257 frames_to_ack = __seq_offset(chan, chan->buffer_seq,
3258 chan->last_acked_seq);
3261 l2cap_send_rr_or_rnr(chan, 0);
3263 l2cap_chan_unlock(chan);
3264 l2cap_chan_put(chan);
3267 int l2cap_ertm_init(struct l2cap_chan *chan)
3271 chan->next_tx_seq = 0;
3272 chan->expected_tx_seq = 0;
3273 chan->expected_ack_seq = 0;
3274 chan->unacked_frames = 0;
3275 chan->buffer_seq = 0;
3276 chan->frames_sent = 0;
3277 chan->last_acked_seq = 0;
3279 chan->sdu_last_frag = NULL;
3282 skb_queue_head_init(&chan->tx_q);
3284 chan->local_amp_id = AMP_ID_BREDR;
3285 chan->move_id = AMP_ID_BREDR;
3286 chan->move_state = L2CAP_MOVE_STABLE;
3287 chan->move_role = L2CAP_MOVE_ROLE_NONE;
3289 if (chan->mode != L2CAP_MODE_ERTM)
3292 chan->rx_state = L2CAP_RX_STATE_RECV;
3293 chan->tx_state = L2CAP_TX_STATE_XMIT;
3295 INIT_DELAYED_WORK(&chan->retrans_timer, l2cap_retrans_timeout);
3296 INIT_DELAYED_WORK(&chan->monitor_timer, l2cap_monitor_timeout);
3297 INIT_DELAYED_WORK(&chan->ack_timer, l2cap_ack_timeout);
3299 skb_queue_head_init(&chan->srej_q);
3301 err = l2cap_seq_list_init(&chan->srej_list, chan->tx_win);
3305 err = l2cap_seq_list_init(&chan->retrans_list, chan->remote_tx_win);
3307 l2cap_seq_list_free(&chan->srej_list);
3312 static inline __u8 l2cap_select_mode(__u8 mode, __u16 remote_feat_mask)
3315 case L2CAP_MODE_STREAMING:
3316 case L2CAP_MODE_ERTM:
3317 if (l2cap_mode_supported(mode, remote_feat_mask))
3321 return L2CAP_MODE_BASIC;
3325 static inline bool __l2cap_ews_supported(struct l2cap_conn *conn)
3327 return ((conn->local_fixed_chan & L2CAP_FC_A2MP) &&
3328 (conn->feat_mask & L2CAP_FEAT_EXT_WINDOW));
3331 static inline bool __l2cap_efs_supported(struct l2cap_conn *conn)
3333 return ((conn->local_fixed_chan & L2CAP_FC_A2MP) &&
3334 (conn->feat_mask & L2CAP_FEAT_EXT_FLOW));
3337 static void __l2cap_set_ertm_timeouts(struct l2cap_chan *chan,
3338 struct l2cap_conf_rfc *rfc)
3340 if (chan->local_amp_id != AMP_ID_BREDR && chan->hs_hcon) {
3341 u64 ertm_to = chan->hs_hcon->hdev->amp_be_flush_to;
3343 /* Class 1 devices have must have ERTM timeouts
3344 * exceeding the Link Supervision Timeout. The
3345 * default Link Supervision Timeout for AMP
3346 * controllers is 10 seconds.
3348 * Class 1 devices use 0xffffffff for their
3349 * best-effort flush timeout, so the clamping logic
3350 * will result in a timeout that meets the above
3351 * requirement. ERTM timeouts are 16-bit values, so
3352 * the maximum timeout is 65.535 seconds.
3355 /* Convert timeout to milliseconds and round */
3356 ertm_to = DIV_ROUND_UP_ULL(ertm_to, 1000);
3358 /* This is the recommended formula for class 2 devices
3359 * that start ERTM timers when packets are sent to the
3362 ertm_to = 3 * ertm_to + 500;
3364 if (ertm_to > 0xffff)
3367 rfc->retrans_timeout = cpu_to_le16((u16) ertm_to);
3368 rfc->monitor_timeout = rfc->retrans_timeout;
3370 rfc->retrans_timeout = cpu_to_le16(L2CAP_DEFAULT_RETRANS_TO);
3371 rfc->monitor_timeout = cpu_to_le16(L2CAP_DEFAULT_MONITOR_TO);
3375 static inline void l2cap_txwin_setup(struct l2cap_chan *chan)
3377 if (chan->tx_win > L2CAP_DEFAULT_TX_WINDOW &&
3378 __l2cap_ews_supported(chan->conn)) {
3379 /* use extended control field */
3380 set_bit(FLAG_EXT_CTRL, &chan->flags);
3381 chan->tx_win_max = L2CAP_DEFAULT_EXT_WINDOW;
3383 chan->tx_win = min_t(u16, chan->tx_win,
3384 L2CAP_DEFAULT_TX_WINDOW);
3385 chan->tx_win_max = L2CAP_DEFAULT_TX_WINDOW;
3387 chan->ack_win = chan->tx_win;
3390 static void l2cap_mtu_auto(struct l2cap_chan *chan)
3392 struct hci_conn *conn = chan->conn->hcon;
3394 chan->imtu = L2CAP_DEFAULT_MIN_MTU;
3396 /* The 2-DH1 packet has between 2 and 56 information bytes
3397 * (including the 2-byte payload header)
3399 if (!(conn->pkt_type & HCI_2DH1))
3402 /* The 3-DH1 packet has between 2 and 85 information bytes
3403 * (including the 2-byte payload header)
3405 if (!(conn->pkt_type & HCI_3DH1))
3408 /* The 2-DH3 packet has between 2 and 369 information bytes
3409 * (including the 2-byte payload header)
3411 if (!(conn->pkt_type & HCI_2DH3))
3414 /* The 3-DH3 packet has between 2 and 554 information bytes
3415 * (including the 2-byte payload header)
3417 if (!(conn->pkt_type & HCI_3DH3))
3420 /* The 2-DH5 packet has between 2 and 681 information bytes
3421 * (including the 2-byte payload header)
3423 if (!(conn->pkt_type & HCI_2DH5))
3426 /* The 3-DH5 packet has between 2 and 1023 information bytes
3427 * (including the 2-byte payload header)
3429 if (!(conn->pkt_type & HCI_3DH5))
3433 static int l2cap_build_conf_req(struct l2cap_chan *chan, void *data, size_t data_size)
3435 struct l2cap_conf_req *req = data;
3436 struct l2cap_conf_rfc rfc = { .mode = chan->mode };
3437 void *ptr = req->data;
3438 void *endptr = data + data_size;
3441 BT_DBG("chan %p", chan);
3443 if (chan->num_conf_req || chan->num_conf_rsp)
3446 switch (chan->mode) {
3447 case L2CAP_MODE_STREAMING:
3448 case L2CAP_MODE_ERTM:
3449 if (test_bit(CONF_STATE2_DEVICE, &chan->conf_state))
3452 if (__l2cap_efs_supported(chan->conn))
3453 set_bit(FLAG_EFS_ENABLE, &chan->flags);
3457 chan->mode = l2cap_select_mode(rfc.mode, chan->conn->feat_mask);
3462 if (chan->imtu != L2CAP_DEFAULT_MTU) {
3464 l2cap_mtu_auto(chan);
3465 l2cap_add_conf_opt(&ptr, L2CAP_CONF_MTU, 2, chan->imtu,
3469 switch (chan->mode) {
3470 case L2CAP_MODE_BASIC:
3474 if (!(chan->conn->feat_mask & L2CAP_FEAT_ERTM) &&
3475 !(chan->conn->feat_mask & L2CAP_FEAT_STREAMING))
3478 rfc.mode = L2CAP_MODE_BASIC;
3480 rfc.max_transmit = 0;
3481 rfc.retrans_timeout = 0;
3482 rfc.monitor_timeout = 0;
3483 rfc.max_pdu_size = 0;
3485 l2cap_add_conf_opt(&ptr, L2CAP_CONF_RFC, sizeof(rfc),
3486 (unsigned long) &rfc, endptr - ptr);
3489 case L2CAP_MODE_ERTM:
3490 rfc.mode = L2CAP_MODE_ERTM;
3491 rfc.max_transmit = chan->max_tx;
3493 __l2cap_set_ertm_timeouts(chan, &rfc);
3495 size = min_t(u16, L2CAP_DEFAULT_MAX_PDU_SIZE, chan->conn->mtu -
3496 L2CAP_EXT_HDR_SIZE - L2CAP_SDULEN_SIZE -
3498 rfc.max_pdu_size = cpu_to_le16(size);
3500 l2cap_txwin_setup(chan);
3502 rfc.txwin_size = min_t(u16, chan->tx_win,
3503 L2CAP_DEFAULT_TX_WINDOW);
3505 l2cap_add_conf_opt(&ptr, L2CAP_CONF_RFC, sizeof(rfc),
3506 (unsigned long) &rfc, endptr - ptr);
3508 if (test_bit(FLAG_EFS_ENABLE, &chan->flags))
3509 l2cap_add_opt_efs(&ptr, chan, endptr - ptr);
3511 if (test_bit(FLAG_EXT_CTRL, &chan->flags))
3512 l2cap_add_conf_opt(&ptr, L2CAP_CONF_EWS, 2,
3513 chan->tx_win, endptr - ptr);
3515 if (chan->conn->feat_mask & L2CAP_FEAT_FCS)
3516 if (chan->fcs == L2CAP_FCS_NONE ||
3517 test_bit(CONF_RECV_NO_FCS, &chan->conf_state)) {
3518 chan->fcs = L2CAP_FCS_NONE;
3519 l2cap_add_conf_opt(&ptr, L2CAP_CONF_FCS, 1,
3520 chan->fcs, endptr - ptr);
3524 case L2CAP_MODE_STREAMING:
3525 l2cap_txwin_setup(chan);
3526 rfc.mode = L2CAP_MODE_STREAMING;
3528 rfc.max_transmit = 0;
3529 rfc.retrans_timeout = 0;
3530 rfc.monitor_timeout = 0;
3532 size = min_t(u16, L2CAP_DEFAULT_MAX_PDU_SIZE, chan->conn->mtu -
3533 L2CAP_EXT_HDR_SIZE - L2CAP_SDULEN_SIZE -
3535 rfc.max_pdu_size = cpu_to_le16(size);
3537 l2cap_add_conf_opt(&ptr, L2CAP_CONF_RFC, sizeof(rfc),
3538 (unsigned long) &rfc, endptr - ptr);
3540 if (test_bit(FLAG_EFS_ENABLE, &chan->flags))
3541 l2cap_add_opt_efs(&ptr, chan, endptr - ptr);
3543 if (chan->conn->feat_mask & L2CAP_FEAT_FCS)
3544 if (chan->fcs == L2CAP_FCS_NONE ||
3545 test_bit(CONF_RECV_NO_FCS, &chan->conf_state)) {
3546 chan->fcs = L2CAP_FCS_NONE;
3547 l2cap_add_conf_opt(&ptr, L2CAP_CONF_FCS, 1,
3548 chan->fcs, endptr - ptr);
3553 req->dcid = cpu_to_le16(chan->dcid);
3554 req->flags = cpu_to_le16(0);
3559 static int l2cap_parse_conf_req(struct l2cap_chan *chan, void *data, size_t data_size)
3561 struct l2cap_conf_rsp *rsp = data;
3562 void *ptr = rsp->data;
3563 void *endptr = data + data_size;
3564 void *req = chan->conf_req;
3565 int len = chan->conf_len;
3566 int type, hint, olen;
3568 struct l2cap_conf_rfc rfc = { .mode = L2CAP_MODE_BASIC };
3569 struct l2cap_conf_efs efs;
3571 u16 mtu = L2CAP_DEFAULT_MTU;
3572 u16 result = L2CAP_CONF_SUCCESS;
3575 BT_DBG("chan %p", chan);
3577 while (len >= L2CAP_CONF_OPT_SIZE) {
3578 len -= l2cap_get_conf_opt(&req, &type, &olen, &val);
3582 hint = type & L2CAP_CONF_HINT;
3583 type &= L2CAP_CONF_MASK;
3586 case L2CAP_CONF_MTU:
3592 case L2CAP_CONF_FLUSH_TO:
3595 chan->flush_to = val;
3598 case L2CAP_CONF_QOS:
3601 case L2CAP_CONF_RFC:
3602 if (olen != sizeof(rfc))
3604 memcpy(&rfc, (void *) val, olen);
3607 case L2CAP_CONF_FCS:
3610 if (val == L2CAP_FCS_NONE)
3611 set_bit(CONF_RECV_NO_FCS, &chan->conf_state);
3614 case L2CAP_CONF_EFS:
3615 if (olen != sizeof(efs))
3618 memcpy(&efs, (void *) val, olen);
3621 case L2CAP_CONF_EWS:
3624 if (!(chan->conn->local_fixed_chan & L2CAP_FC_A2MP))
3625 return -ECONNREFUSED;
3626 set_bit(FLAG_EXT_CTRL, &chan->flags);
3627 set_bit(CONF_EWS_RECV, &chan->conf_state);
3628 chan->tx_win_max = L2CAP_DEFAULT_EXT_WINDOW;
3629 chan->remote_tx_win = val;
3635 result = L2CAP_CONF_UNKNOWN;
3636 l2cap_add_conf_opt(&ptr, (u8)type, sizeof(u8), type, endptr - ptr);
3641 if (chan->num_conf_rsp || chan->num_conf_req > 1)
3644 switch (chan->mode) {
3645 case L2CAP_MODE_STREAMING:
3646 case L2CAP_MODE_ERTM:
3647 if (!test_bit(CONF_STATE2_DEVICE, &chan->conf_state)) {
3648 chan->mode = l2cap_select_mode(rfc.mode,
3649 chan->conn->feat_mask);
3654 if (__l2cap_efs_supported(chan->conn))
3655 set_bit(FLAG_EFS_ENABLE, &chan->flags);
3657 return -ECONNREFUSED;
3660 if (chan->mode != rfc.mode)
3661 return -ECONNREFUSED;
3667 if (chan->mode != rfc.mode) {
3668 result = L2CAP_CONF_UNACCEPT;
3669 rfc.mode = chan->mode;
3671 if (chan->num_conf_rsp == 1)
3672 return -ECONNREFUSED;
3674 l2cap_add_conf_opt(&ptr, L2CAP_CONF_RFC, sizeof(rfc),
3675 (unsigned long) &rfc, endptr - ptr);
3678 if (result == L2CAP_CONF_SUCCESS) {
3679 /* Configure output options and let the other side know
3680 * which ones we don't like. */
3682 if (mtu < L2CAP_DEFAULT_MIN_MTU)
3683 result = L2CAP_CONF_UNACCEPT;
3686 set_bit(CONF_MTU_DONE, &chan->conf_state);
3688 l2cap_add_conf_opt(&ptr, L2CAP_CONF_MTU, 2, chan->omtu, endptr - ptr);
3691 if (chan->local_stype != L2CAP_SERV_NOTRAFIC &&
3692 efs.stype != L2CAP_SERV_NOTRAFIC &&
3693 efs.stype != chan->local_stype) {
3695 result = L2CAP_CONF_UNACCEPT;
3697 if (chan->num_conf_req >= 1)
3698 return -ECONNREFUSED;
3700 l2cap_add_conf_opt(&ptr, L2CAP_CONF_EFS,
3702 (unsigned long) &efs, endptr - ptr);
3704 /* Send PENDING Conf Rsp */
3705 result = L2CAP_CONF_PENDING;
3706 set_bit(CONF_LOC_CONF_PEND, &chan->conf_state);
3711 case L2CAP_MODE_BASIC:
3712 chan->fcs = L2CAP_FCS_NONE;
3713 set_bit(CONF_MODE_DONE, &chan->conf_state);
3716 case L2CAP_MODE_ERTM:
3717 if (!test_bit(CONF_EWS_RECV, &chan->conf_state))
3718 chan->remote_tx_win = rfc.txwin_size;
3720 rfc.txwin_size = L2CAP_DEFAULT_TX_WINDOW;
3722 chan->remote_max_tx = rfc.max_transmit;
3724 size = min_t(u16, le16_to_cpu(rfc.max_pdu_size),
3725 chan->conn->mtu - L2CAP_EXT_HDR_SIZE -
3726 L2CAP_SDULEN_SIZE - L2CAP_FCS_SIZE);
3727 rfc.max_pdu_size = cpu_to_le16(size);
3728 chan->remote_mps = size;
3730 __l2cap_set_ertm_timeouts(chan, &rfc);
3732 set_bit(CONF_MODE_DONE, &chan->conf_state);
3734 l2cap_add_conf_opt(&ptr, L2CAP_CONF_RFC,
3735 sizeof(rfc), (unsigned long) &rfc, endptr - ptr);
3737 if (test_bit(FLAG_EFS_ENABLE, &chan->flags)) {
3738 chan->remote_id = efs.id;
3739 chan->remote_stype = efs.stype;
3740 chan->remote_msdu = le16_to_cpu(efs.msdu);
3741 chan->remote_flush_to =
3742 le32_to_cpu(efs.flush_to);
3743 chan->remote_acc_lat =
3744 le32_to_cpu(efs.acc_lat);
3745 chan->remote_sdu_itime =
3746 le32_to_cpu(efs.sdu_itime);
3747 l2cap_add_conf_opt(&ptr, L2CAP_CONF_EFS,
3749 (unsigned long) &efs, endptr - ptr);
3753 case L2CAP_MODE_STREAMING:
3754 size = min_t(u16, le16_to_cpu(rfc.max_pdu_size),
3755 chan->conn->mtu - L2CAP_EXT_HDR_SIZE -
3756 L2CAP_SDULEN_SIZE - L2CAP_FCS_SIZE);
3757 rfc.max_pdu_size = cpu_to_le16(size);
3758 chan->remote_mps = size;
3760 set_bit(CONF_MODE_DONE, &chan->conf_state);
3762 l2cap_add_conf_opt(&ptr, L2CAP_CONF_RFC, sizeof(rfc),
3763 (unsigned long) &rfc, endptr - ptr);
3768 result = L2CAP_CONF_UNACCEPT;
3770 memset(&rfc, 0, sizeof(rfc));
3771 rfc.mode = chan->mode;
3774 if (result == L2CAP_CONF_SUCCESS)
3775 set_bit(CONF_OUTPUT_DONE, &chan->conf_state);
3777 rsp->scid = cpu_to_le16(chan->dcid);
3778 rsp->result = cpu_to_le16(result);
3779 rsp->flags = cpu_to_le16(0);
3784 static int l2cap_parse_conf_rsp(struct l2cap_chan *chan, void *rsp, int len,
3785 void *data, size_t size, u16 *result)
3787 struct l2cap_conf_req *req = data;
3788 void *ptr = req->data;
3789 void *endptr = data + size;
3792 struct l2cap_conf_rfc rfc = { .mode = L2CAP_MODE_BASIC };
3793 struct l2cap_conf_efs efs;
3795 BT_DBG("chan %p, rsp %p, len %d, req %p", chan, rsp, len, data);
3797 while (len >= L2CAP_CONF_OPT_SIZE) {
3798 len -= l2cap_get_conf_opt(&rsp, &type, &olen, &val);
3803 case L2CAP_CONF_MTU:
3806 if (val < L2CAP_DEFAULT_MIN_MTU) {
3807 *result = L2CAP_CONF_UNACCEPT;
3808 chan->imtu = L2CAP_DEFAULT_MIN_MTU;
3811 l2cap_add_conf_opt(&ptr, L2CAP_CONF_MTU, 2, chan->imtu,
3815 case L2CAP_CONF_FLUSH_TO:
3818 chan->flush_to = val;
3819 l2cap_add_conf_opt(&ptr, L2CAP_CONF_FLUSH_TO, 2,
3820 chan->flush_to, endptr - ptr);
3823 case L2CAP_CONF_RFC:
3824 if (olen != sizeof(rfc))
3826 memcpy(&rfc, (void *)val, olen);
3827 if (test_bit(CONF_STATE2_DEVICE, &chan->conf_state) &&
3828 rfc.mode != chan->mode)
3829 return -ECONNREFUSED;
3831 l2cap_add_conf_opt(&ptr, L2CAP_CONF_RFC, sizeof(rfc),
3832 (unsigned long) &rfc, endptr - ptr);
3835 case L2CAP_CONF_EWS:
3838 chan->ack_win = min_t(u16, val, chan->ack_win);
3839 l2cap_add_conf_opt(&ptr, L2CAP_CONF_EWS, 2,
3840 chan->tx_win, endptr - ptr);
3843 case L2CAP_CONF_EFS:
3844 if (olen != sizeof(efs))
3846 memcpy(&efs, (void *)val, olen);
3847 if (chan->local_stype != L2CAP_SERV_NOTRAFIC &&
3848 efs.stype != L2CAP_SERV_NOTRAFIC &&
3849 efs.stype != chan->local_stype)
3850 return -ECONNREFUSED;
3851 l2cap_add_conf_opt(&ptr, L2CAP_CONF_EFS, sizeof(efs),
3852 (unsigned long) &efs, endptr - ptr);
3855 case L2CAP_CONF_FCS:
3858 if (*result == L2CAP_CONF_PENDING)
3859 if (val == L2CAP_FCS_NONE)
3860 set_bit(CONF_RECV_NO_FCS,
3866 if (chan->mode == L2CAP_MODE_BASIC && chan->mode != rfc.mode)
3867 return -ECONNREFUSED;
3869 chan->mode = rfc.mode;
3871 if (*result == L2CAP_CONF_SUCCESS || *result == L2CAP_CONF_PENDING) {
3873 case L2CAP_MODE_ERTM:
3874 chan->retrans_timeout = le16_to_cpu(rfc.retrans_timeout);
3875 chan->monitor_timeout = le16_to_cpu(rfc.monitor_timeout);
3876 chan->mps = le16_to_cpu(rfc.max_pdu_size);
3877 if (!test_bit(FLAG_EXT_CTRL, &chan->flags))
3878 chan->ack_win = min_t(u16, chan->ack_win,
3881 if (test_bit(FLAG_EFS_ENABLE, &chan->flags)) {
3882 chan->local_msdu = le16_to_cpu(efs.msdu);
3883 chan->local_sdu_itime =
3884 le32_to_cpu(efs.sdu_itime);
3885 chan->local_acc_lat = le32_to_cpu(efs.acc_lat);
3886 chan->local_flush_to =
3887 le32_to_cpu(efs.flush_to);
3891 case L2CAP_MODE_STREAMING:
3892 chan->mps = le16_to_cpu(rfc.max_pdu_size);
3896 req->dcid = cpu_to_le16(chan->dcid);
3897 req->flags = cpu_to_le16(0);
3902 static int l2cap_build_conf_rsp(struct l2cap_chan *chan, void *data,
3903 u16 result, u16 flags)
3905 struct l2cap_conf_rsp *rsp = data;
3906 void *ptr = rsp->data;
3908 BT_DBG("chan %p", chan);
3910 rsp->scid = cpu_to_le16(chan->dcid);
3911 rsp->result = cpu_to_le16(result);
3912 rsp->flags = cpu_to_le16(flags);
3917 void __l2cap_le_connect_rsp_defer(struct l2cap_chan *chan)
3919 struct l2cap_le_conn_rsp rsp;
3920 struct l2cap_conn *conn = chan->conn;
3922 BT_DBG("chan %p", chan);
3924 rsp.dcid = cpu_to_le16(chan->scid);
3925 rsp.mtu = cpu_to_le16(chan->imtu);
3926 rsp.mps = cpu_to_le16(chan->mps);
3927 rsp.credits = cpu_to_le16(chan->rx_credits);
3928 rsp.result = cpu_to_le16(L2CAP_CR_LE_SUCCESS);
3930 l2cap_send_cmd(conn, chan->ident, L2CAP_LE_CONN_RSP, sizeof(rsp),
3934 void __l2cap_ecred_conn_rsp_defer(struct l2cap_chan *chan)
3937 struct l2cap_ecred_conn_rsp rsp;
3940 struct l2cap_conn *conn = chan->conn;
3941 u16 ident = chan->ident;
3947 BT_DBG("chan %p ident %d", chan, ident);
3949 pdu.rsp.mtu = cpu_to_le16(chan->imtu);
3950 pdu.rsp.mps = cpu_to_le16(chan->mps);
3951 pdu.rsp.credits = cpu_to_le16(chan->rx_credits);
3952 pdu.rsp.result = cpu_to_le16(L2CAP_CR_LE_SUCCESS);
3954 mutex_lock(&conn->chan_lock);
3956 list_for_each_entry(chan, &conn->chan_l, list) {
3957 if (chan->ident != ident)
3960 /* Reset ident so only one response is sent */
3963 /* Include all channels pending with the same ident */
3964 pdu.dcid[i++] = cpu_to_le16(chan->scid);
3967 mutex_unlock(&conn->chan_lock);
3969 l2cap_send_cmd(conn, ident, L2CAP_ECRED_CONN_RSP,
3970 sizeof(pdu.rsp) + i * sizeof(__le16), &pdu);
3973 void __l2cap_connect_rsp_defer(struct l2cap_chan *chan)
3975 struct l2cap_conn_rsp rsp;
3976 struct l2cap_conn *conn = chan->conn;
3980 rsp.scid = cpu_to_le16(chan->dcid);
3981 rsp.dcid = cpu_to_le16(chan->scid);
3982 rsp.result = cpu_to_le16(L2CAP_CR_SUCCESS);
3983 rsp.status = cpu_to_le16(L2CAP_CS_NO_INFO);
3986 rsp_code = L2CAP_CREATE_CHAN_RSP;
3988 rsp_code = L2CAP_CONN_RSP;
3990 BT_DBG("chan %p rsp_code %u", chan, rsp_code);
3992 l2cap_send_cmd(conn, chan->ident, rsp_code, sizeof(rsp), &rsp);
3994 if (test_and_set_bit(CONF_REQ_SENT, &chan->conf_state))
3997 l2cap_send_cmd(conn, l2cap_get_ident(conn), L2CAP_CONF_REQ,
3998 l2cap_build_conf_req(chan, buf, sizeof(buf)), buf);
3999 chan->num_conf_req++;
4002 static void l2cap_conf_rfc_get(struct l2cap_chan *chan, void *rsp, int len)
4006 /* Use sane default values in case a misbehaving remote device
4007 * did not send an RFC or extended window size option.
4009 u16 txwin_ext = chan->ack_win;
4010 struct l2cap_conf_rfc rfc = {
4012 .retrans_timeout = cpu_to_le16(L2CAP_DEFAULT_RETRANS_TO),
4013 .monitor_timeout = cpu_to_le16(L2CAP_DEFAULT_MONITOR_TO),
4014 .max_pdu_size = cpu_to_le16(chan->imtu),
4015 .txwin_size = min_t(u16, chan->ack_win, L2CAP_DEFAULT_TX_WINDOW),
4018 BT_DBG("chan %p, rsp %p, len %d", chan, rsp, len);
4020 if ((chan->mode != L2CAP_MODE_ERTM) && (chan->mode != L2CAP_MODE_STREAMING))
4023 while (len >= L2CAP_CONF_OPT_SIZE) {
4024 len -= l2cap_get_conf_opt(&rsp, &type, &olen, &val);
4029 case L2CAP_CONF_RFC:
4030 if (olen != sizeof(rfc))
4032 memcpy(&rfc, (void *)val, olen);
4034 case L2CAP_CONF_EWS:
4043 case L2CAP_MODE_ERTM:
4044 chan->retrans_timeout = le16_to_cpu(rfc.retrans_timeout);
4045 chan->monitor_timeout = le16_to_cpu(rfc.monitor_timeout);
4046 chan->mps = le16_to_cpu(rfc.max_pdu_size);
4047 if (test_bit(FLAG_EXT_CTRL, &chan->flags))
4048 chan->ack_win = min_t(u16, chan->ack_win, txwin_ext);
4050 chan->ack_win = min_t(u16, chan->ack_win,
4053 case L2CAP_MODE_STREAMING:
4054 chan->mps = le16_to_cpu(rfc.max_pdu_size);
4058 static inline int l2cap_command_rej(struct l2cap_conn *conn,
4059 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
4062 struct l2cap_cmd_rej_unk *rej = (struct l2cap_cmd_rej_unk *) data;
4064 if (cmd_len < sizeof(*rej))
4067 if (rej->reason != L2CAP_REJ_NOT_UNDERSTOOD)
4070 if ((conn->info_state & L2CAP_INFO_FEAT_MASK_REQ_SENT) &&
4071 cmd->ident == conn->info_ident) {
4072 cancel_delayed_work(&conn->info_timer);
4074 conn->info_state |= L2CAP_INFO_FEAT_MASK_REQ_DONE;
4075 conn->info_ident = 0;
4077 l2cap_conn_start(conn);
4083 static struct l2cap_chan *l2cap_connect(struct l2cap_conn *conn,
4084 struct l2cap_cmd_hdr *cmd,
4085 u8 *data, u8 rsp_code, u8 amp_id)
4087 struct l2cap_conn_req *req = (struct l2cap_conn_req *) data;
4088 struct l2cap_conn_rsp rsp;
4089 struct l2cap_chan *chan = NULL, *pchan;
4090 int result, status = L2CAP_CS_NO_INFO;
4092 u16 dcid = 0, scid = __le16_to_cpu(req->scid);
4093 __le16 psm = req->psm;
4095 BT_DBG("psm 0x%2.2x scid 0x%4.4x", __le16_to_cpu(psm), scid);
4097 /* Check if we have socket listening on psm */
4098 pchan = l2cap_global_chan_by_psm(BT_LISTEN, psm, &conn->hcon->src,
4099 &conn->hcon->dst, ACL_LINK);
4101 result = L2CAP_CR_BAD_PSM;
4105 mutex_lock(&conn->chan_lock);
4106 l2cap_chan_lock(pchan);
4108 /* Check if the ACL is secure enough (if not SDP) */
4109 if (psm != cpu_to_le16(L2CAP_PSM_SDP) &&
4110 !hci_conn_check_link_mode(conn->hcon)) {
4111 conn->disc_reason = HCI_ERROR_AUTH_FAILURE;
4112 result = L2CAP_CR_SEC_BLOCK;
4116 result = L2CAP_CR_NO_MEM;
4118 /* Check for valid dynamic CID range (as per Erratum 3253) */
4119 if (scid < L2CAP_CID_DYN_START || scid > L2CAP_CID_DYN_END) {
4120 result = L2CAP_CR_INVALID_SCID;
4124 /* Check if we already have channel with that dcid */
4125 if (__l2cap_get_chan_by_dcid(conn, scid)) {
4126 result = L2CAP_CR_SCID_IN_USE;
4130 chan = pchan->ops->new_connection(pchan);
4134 /* For certain devices (ex: HID mouse), support for authentication,
4135 * pairing and bonding is optional. For such devices, inorder to avoid
4136 * the ACL alive for too long after L2CAP disconnection, reset the ACL
4137 * disc_timeout back to HCI_DISCONN_TIMEOUT during L2CAP connect.
4139 conn->hcon->disc_timeout = HCI_DISCONN_TIMEOUT;
4141 bacpy(&chan->src, &conn->hcon->src);
4142 bacpy(&chan->dst, &conn->hcon->dst);
4143 chan->src_type = bdaddr_src_type(conn->hcon);
4144 chan->dst_type = bdaddr_dst_type(conn->hcon);
4147 chan->local_amp_id = amp_id;
4149 __l2cap_chan_add(conn, chan);
4153 __set_chan_timer(chan, chan->ops->get_sndtimeo(chan));
4155 chan->ident = cmd->ident;
4157 if (conn->info_state & L2CAP_INFO_FEAT_MASK_REQ_DONE) {
4158 if (l2cap_chan_check_security(chan, false)) {
4159 if (test_bit(FLAG_DEFER_SETUP, &chan->flags)) {
4160 l2cap_state_change(chan, BT_CONNECT2);
4161 result = L2CAP_CR_PEND;
4162 status = L2CAP_CS_AUTHOR_PEND;
4163 chan->ops->defer(chan);
4165 /* Force pending result for AMP controllers.
4166 * The connection will succeed after the
4167 * physical link is up.
4169 if (amp_id == AMP_ID_BREDR) {
4170 l2cap_state_change(chan, BT_CONFIG);
4171 result = L2CAP_CR_SUCCESS;
4173 l2cap_state_change(chan, BT_CONNECT2);
4174 result = L2CAP_CR_PEND;
4176 status = L2CAP_CS_NO_INFO;
4179 l2cap_state_change(chan, BT_CONNECT2);
4180 result = L2CAP_CR_PEND;
4181 status = L2CAP_CS_AUTHEN_PEND;
4184 l2cap_state_change(chan, BT_CONNECT2);
4185 result = L2CAP_CR_PEND;
4186 status = L2CAP_CS_NO_INFO;
4190 l2cap_chan_unlock(pchan);
4191 mutex_unlock(&conn->chan_lock);
4192 l2cap_chan_put(pchan);
4195 rsp.scid = cpu_to_le16(scid);
4196 rsp.dcid = cpu_to_le16(dcid);
4197 rsp.result = cpu_to_le16(result);
4198 rsp.status = cpu_to_le16(status);
4199 l2cap_send_cmd(conn, cmd->ident, rsp_code, sizeof(rsp), &rsp);
4201 if (result == L2CAP_CR_PEND && status == L2CAP_CS_NO_INFO) {
4202 struct l2cap_info_req info;
4203 info.type = cpu_to_le16(L2CAP_IT_FEAT_MASK);
4205 conn->info_state |= L2CAP_INFO_FEAT_MASK_REQ_SENT;
4206 conn->info_ident = l2cap_get_ident(conn);
4208 schedule_delayed_work(&conn->info_timer, L2CAP_INFO_TIMEOUT);
4210 l2cap_send_cmd(conn, conn->info_ident, L2CAP_INFO_REQ,
4211 sizeof(info), &info);
4214 if (chan && !test_bit(CONF_REQ_SENT, &chan->conf_state) &&
4215 result == L2CAP_CR_SUCCESS) {
4217 set_bit(CONF_REQ_SENT, &chan->conf_state);
4218 l2cap_send_cmd(conn, l2cap_get_ident(conn), L2CAP_CONF_REQ,
4219 l2cap_build_conf_req(chan, buf, sizeof(buf)), buf);
4220 chan->num_conf_req++;
4226 static int l2cap_connect_req(struct l2cap_conn *conn,
4227 struct l2cap_cmd_hdr *cmd, u16 cmd_len, u8 *data)
4229 struct hci_dev *hdev = conn->hcon->hdev;
4230 struct hci_conn *hcon = conn->hcon;
4232 if (cmd_len < sizeof(struct l2cap_conn_req))
4236 if (hci_dev_test_flag(hdev, HCI_MGMT) &&
4237 !test_and_set_bit(HCI_CONN_MGMT_CONNECTED, &hcon->flags))
4238 mgmt_device_connected(hdev, hcon, 0, NULL, 0);
4239 hci_dev_unlock(hdev);
4241 l2cap_connect(conn, cmd, data, L2CAP_CONN_RSP, 0);
4245 static int l2cap_connect_create_rsp(struct l2cap_conn *conn,
4246 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
4249 struct l2cap_conn_rsp *rsp = (struct l2cap_conn_rsp *) data;
4250 u16 scid, dcid, result, status;
4251 struct l2cap_chan *chan;
4255 if (cmd_len < sizeof(*rsp))
4258 scid = __le16_to_cpu(rsp->scid);
4259 dcid = __le16_to_cpu(rsp->dcid);
4260 result = __le16_to_cpu(rsp->result);
4261 status = __le16_to_cpu(rsp->status);
4263 BT_DBG("dcid 0x%4.4x scid 0x%4.4x result 0x%2.2x status 0x%2.2x",
4264 dcid, scid, result, status);
4266 mutex_lock(&conn->chan_lock);
4269 chan = __l2cap_get_chan_by_scid(conn, scid);
4275 chan = __l2cap_get_chan_by_ident(conn, cmd->ident);
4284 l2cap_chan_lock(chan);
4287 case L2CAP_CR_SUCCESS:
4288 l2cap_state_change(chan, BT_CONFIG);
4291 clear_bit(CONF_CONNECT_PEND, &chan->conf_state);
4293 if (test_and_set_bit(CONF_REQ_SENT, &chan->conf_state))
4296 l2cap_send_cmd(conn, l2cap_get_ident(conn), L2CAP_CONF_REQ,
4297 l2cap_build_conf_req(chan, req, sizeof(req)), req);
4298 chan->num_conf_req++;
4302 set_bit(CONF_CONNECT_PEND, &chan->conf_state);
4306 l2cap_chan_del(chan, ECONNREFUSED);
4310 l2cap_chan_unlock(chan);
4313 mutex_unlock(&conn->chan_lock);
4318 static inline void set_default_fcs(struct l2cap_chan *chan)
4320 /* FCS is enabled only in ERTM or streaming mode, if one or both
4323 if (chan->mode != L2CAP_MODE_ERTM && chan->mode != L2CAP_MODE_STREAMING)
4324 chan->fcs = L2CAP_FCS_NONE;
4325 else if (!test_bit(CONF_RECV_NO_FCS, &chan->conf_state))
4326 chan->fcs = L2CAP_FCS_CRC16;
4329 static void l2cap_send_efs_conf_rsp(struct l2cap_chan *chan, void *data,
4330 u8 ident, u16 flags)
4332 struct l2cap_conn *conn = chan->conn;
4334 BT_DBG("conn %p chan %p ident %d flags 0x%4.4x", conn, chan, ident,
4337 clear_bit(CONF_LOC_CONF_PEND, &chan->conf_state);
4338 set_bit(CONF_OUTPUT_DONE, &chan->conf_state);
4340 l2cap_send_cmd(conn, ident, L2CAP_CONF_RSP,
4341 l2cap_build_conf_rsp(chan, data,
4342 L2CAP_CONF_SUCCESS, flags), data);
4345 static void cmd_reject_invalid_cid(struct l2cap_conn *conn, u8 ident,
4348 struct l2cap_cmd_rej_cid rej;
4350 rej.reason = cpu_to_le16(L2CAP_REJ_INVALID_CID);
4351 rej.scid = __cpu_to_le16(scid);
4352 rej.dcid = __cpu_to_le16(dcid);
4354 l2cap_send_cmd(conn, ident, L2CAP_COMMAND_REJ, sizeof(rej), &rej);
4357 static inline int l2cap_config_req(struct l2cap_conn *conn,
4358 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
4361 struct l2cap_conf_req *req = (struct l2cap_conf_req *) data;
4364 struct l2cap_chan *chan;
4367 if (cmd_len < sizeof(*req))
4370 dcid = __le16_to_cpu(req->dcid);
4371 flags = __le16_to_cpu(req->flags);
4373 BT_DBG("dcid 0x%4.4x flags 0x%2.2x", dcid, flags);
4375 chan = l2cap_get_chan_by_scid(conn, dcid);
4377 cmd_reject_invalid_cid(conn, cmd->ident, dcid, 0);
4381 if (chan->state != BT_CONFIG && chan->state != BT_CONNECT2 &&
4382 chan->state != BT_CONNECTED) {
4383 cmd_reject_invalid_cid(conn, cmd->ident, chan->scid,
4388 /* Reject if config buffer is too small. */
4389 len = cmd_len - sizeof(*req);
4390 if (chan->conf_len + len > sizeof(chan->conf_req)) {
4391 l2cap_send_cmd(conn, cmd->ident, L2CAP_CONF_RSP,
4392 l2cap_build_conf_rsp(chan, rsp,
4393 L2CAP_CONF_REJECT, flags), rsp);
4398 memcpy(chan->conf_req + chan->conf_len, req->data, len);
4399 chan->conf_len += len;
4401 if (flags & L2CAP_CONF_FLAG_CONTINUATION) {
4402 /* Incomplete config. Send empty response. */
4403 l2cap_send_cmd(conn, cmd->ident, L2CAP_CONF_RSP,
4404 l2cap_build_conf_rsp(chan, rsp,
4405 L2CAP_CONF_SUCCESS, flags), rsp);
4409 /* Complete config. */
4410 len = l2cap_parse_conf_req(chan, rsp, sizeof(rsp));
4412 l2cap_send_disconn_req(chan, ECONNRESET);
4416 chan->ident = cmd->ident;
4417 l2cap_send_cmd(conn, cmd->ident, L2CAP_CONF_RSP, len, rsp);
4418 chan->num_conf_rsp++;
4420 /* Reset config buffer. */
4423 if (!test_bit(CONF_OUTPUT_DONE, &chan->conf_state))
4426 if (test_bit(CONF_INPUT_DONE, &chan->conf_state)) {
4427 set_default_fcs(chan);
4429 if (chan->mode == L2CAP_MODE_ERTM ||
4430 chan->mode == L2CAP_MODE_STREAMING)
4431 err = l2cap_ertm_init(chan);
4434 l2cap_send_disconn_req(chan, -err);
4436 l2cap_chan_ready(chan);
4441 if (!test_and_set_bit(CONF_REQ_SENT, &chan->conf_state)) {
4443 l2cap_send_cmd(conn, l2cap_get_ident(conn), L2CAP_CONF_REQ,
4444 l2cap_build_conf_req(chan, buf, sizeof(buf)), buf);
4445 chan->num_conf_req++;
4448 /* Got Conf Rsp PENDING from remote side and assume we sent
4449 Conf Rsp PENDING in the code above */
4450 if (test_bit(CONF_REM_CONF_PEND, &chan->conf_state) &&
4451 test_bit(CONF_LOC_CONF_PEND, &chan->conf_state)) {
4453 /* check compatibility */
4455 /* Send rsp for BR/EDR channel */
4457 l2cap_send_efs_conf_rsp(chan, rsp, cmd->ident, flags);
4459 chan->ident = cmd->ident;
4463 l2cap_chan_unlock(chan);
4467 static inline int l2cap_config_rsp(struct l2cap_conn *conn,
4468 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
4471 struct l2cap_conf_rsp *rsp = (struct l2cap_conf_rsp *)data;
4472 u16 scid, flags, result;
4473 struct l2cap_chan *chan;
4474 int len = cmd_len - sizeof(*rsp);
4477 if (cmd_len < sizeof(*rsp))
4480 scid = __le16_to_cpu(rsp->scid);
4481 flags = __le16_to_cpu(rsp->flags);
4482 result = __le16_to_cpu(rsp->result);
4484 BT_DBG("scid 0x%4.4x flags 0x%2.2x result 0x%2.2x len %d", scid, flags,
4487 chan = l2cap_get_chan_by_scid(conn, scid);
4492 case L2CAP_CONF_SUCCESS:
4493 l2cap_conf_rfc_get(chan, rsp->data, len);
4494 clear_bit(CONF_REM_CONF_PEND, &chan->conf_state);
4497 case L2CAP_CONF_PENDING:
4498 set_bit(CONF_REM_CONF_PEND, &chan->conf_state);
4500 if (test_bit(CONF_LOC_CONF_PEND, &chan->conf_state)) {
4503 len = l2cap_parse_conf_rsp(chan, rsp->data, len,
4504 buf, sizeof(buf), &result);
4506 l2cap_send_disconn_req(chan, ECONNRESET);
4510 if (!chan->hs_hcon) {
4511 l2cap_send_efs_conf_rsp(chan, buf, cmd->ident,
4514 if (l2cap_check_efs(chan)) {
4515 amp_create_logical_link(chan);
4516 chan->ident = cmd->ident;
4522 case L2CAP_CONF_UNKNOWN:
4523 case L2CAP_CONF_UNACCEPT:
4524 if (chan->num_conf_rsp <= L2CAP_CONF_MAX_CONF_RSP) {
4527 if (len > sizeof(req) - sizeof(struct l2cap_conf_req)) {
4528 l2cap_send_disconn_req(chan, ECONNRESET);
4532 /* throw out any old stored conf requests */
4533 result = L2CAP_CONF_SUCCESS;
4534 len = l2cap_parse_conf_rsp(chan, rsp->data, len,
4535 req, sizeof(req), &result);
4537 l2cap_send_disconn_req(chan, ECONNRESET);
4541 l2cap_send_cmd(conn, l2cap_get_ident(conn),
4542 L2CAP_CONF_REQ, len, req);
4543 chan->num_conf_req++;
4544 if (result != L2CAP_CONF_SUCCESS)
4551 l2cap_chan_set_err(chan, ECONNRESET);
4553 __set_chan_timer(chan, L2CAP_DISC_REJ_TIMEOUT);
4554 l2cap_send_disconn_req(chan, ECONNRESET);
4558 if (flags & L2CAP_CONF_FLAG_CONTINUATION)
4561 set_bit(CONF_INPUT_DONE, &chan->conf_state);
4563 if (test_bit(CONF_OUTPUT_DONE, &chan->conf_state)) {
4564 set_default_fcs(chan);
4566 if (chan->mode == L2CAP_MODE_ERTM ||
4567 chan->mode == L2CAP_MODE_STREAMING)
4568 err = l2cap_ertm_init(chan);
4571 l2cap_send_disconn_req(chan, -err);
4573 l2cap_chan_ready(chan);
4577 l2cap_chan_unlock(chan);
4581 static inline int l2cap_disconnect_req(struct l2cap_conn *conn,
4582 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
4585 struct l2cap_disconn_req *req = (struct l2cap_disconn_req *) data;
4586 struct l2cap_disconn_rsp rsp;
4588 struct l2cap_chan *chan;
4590 if (cmd_len != sizeof(*req))
4593 scid = __le16_to_cpu(req->scid);
4594 dcid = __le16_to_cpu(req->dcid);
4596 BT_DBG("scid 0x%4.4x dcid 0x%4.4x", scid, dcid);
4598 mutex_lock(&conn->chan_lock);
4600 chan = __l2cap_get_chan_by_scid(conn, dcid);
4602 mutex_unlock(&conn->chan_lock);
4603 cmd_reject_invalid_cid(conn, cmd->ident, dcid, scid);
4607 l2cap_chan_hold(chan);
4608 l2cap_chan_lock(chan);
4610 rsp.dcid = cpu_to_le16(chan->scid);
4611 rsp.scid = cpu_to_le16(chan->dcid);
4612 l2cap_send_cmd(conn, cmd->ident, L2CAP_DISCONN_RSP, sizeof(rsp), &rsp);
4614 chan->ops->set_shutdown(chan);
4616 l2cap_chan_del(chan, ECONNRESET);
4618 chan->ops->close(chan);
4620 l2cap_chan_unlock(chan);
4621 l2cap_chan_put(chan);
4623 mutex_unlock(&conn->chan_lock);
4628 static inline int l2cap_disconnect_rsp(struct l2cap_conn *conn,
4629 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
4632 struct l2cap_disconn_rsp *rsp = (struct l2cap_disconn_rsp *) data;
4634 struct l2cap_chan *chan;
4636 if (cmd_len != sizeof(*rsp))
4639 scid = __le16_to_cpu(rsp->scid);
4640 dcid = __le16_to_cpu(rsp->dcid);
4642 BT_DBG("dcid 0x%4.4x scid 0x%4.4x", dcid, scid);
4644 mutex_lock(&conn->chan_lock);
4646 chan = __l2cap_get_chan_by_scid(conn, scid);
4648 mutex_unlock(&conn->chan_lock);
4652 l2cap_chan_hold(chan);
4653 l2cap_chan_lock(chan);
4655 if (chan->state != BT_DISCONN) {
4656 l2cap_chan_unlock(chan);
4657 l2cap_chan_put(chan);
4658 mutex_unlock(&conn->chan_lock);
4662 l2cap_chan_del(chan, 0);
4664 chan->ops->close(chan);
4666 l2cap_chan_unlock(chan);
4667 l2cap_chan_put(chan);
4669 mutex_unlock(&conn->chan_lock);
4674 static inline int l2cap_information_req(struct l2cap_conn *conn,
4675 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
4678 struct l2cap_info_req *req = (struct l2cap_info_req *) data;
4681 if (cmd_len != sizeof(*req))
4684 type = __le16_to_cpu(req->type);
4686 BT_DBG("type 0x%4.4x", type);
4688 if (type == L2CAP_IT_FEAT_MASK) {
4690 u32 feat_mask = l2cap_feat_mask;
4691 struct l2cap_info_rsp *rsp = (struct l2cap_info_rsp *) buf;
4692 rsp->type = cpu_to_le16(L2CAP_IT_FEAT_MASK);
4693 rsp->result = cpu_to_le16(L2CAP_IR_SUCCESS);
4695 feat_mask |= L2CAP_FEAT_ERTM | L2CAP_FEAT_STREAMING
4697 if (conn->local_fixed_chan & L2CAP_FC_A2MP)
4698 feat_mask |= L2CAP_FEAT_EXT_FLOW
4699 | L2CAP_FEAT_EXT_WINDOW;
4701 put_unaligned_le32(feat_mask, rsp->data);
4702 l2cap_send_cmd(conn, cmd->ident, L2CAP_INFO_RSP, sizeof(buf),
4704 } else if (type == L2CAP_IT_FIXED_CHAN) {
4706 struct l2cap_info_rsp *rsp = (struct l2cap_info_rsp *) buf;
4708 rsp->type = cpu_to_le16(L2CAP_IT_FIXED_CHAN);
4709 rsp->result = cpu_to_le16(L2CAP_IR_SUCCESS);
4710 rsp->data[0] = conn->local_fixed_chan;
4711 memset(rsp->data + 1, 0, 7);
4712 l2cap_send_cmd(conn, cmd->ident, L2CAP_INFO_RSP, sizeof(buf),
4715 struct l2cap_info_rsp rsp;
4716 rsp.type = cpu_to_le16(type);
4717 rsp.result = cpu_to_le16(L2CAP_IR_NOTSUPP);
4718 l2cap_send_cmd(conn, cmd->ident, L2CAP_INFO_RSP, sizeof(rsp),
4725 static inline int l2cap_information_rsp(struct l2cap_conn *conn,
4726 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
4729 struct l2cap_info_rsp *rsp = (struct l2cap_info_rsp *) data;
4732 if (cmd_len < sizeof(*rsp))
4735 type = __le16_to_cpu(rsp->type);
4736 result = __le16_to_cpu(rsp->result);
4738 BT_DBG("type 0x%4.4x result 0x%2.2x", type, result);
4740 /* L2CAP Info req/rsp are unbound to channels, add extra checks */
4741 if (cmd->ident != conn->info_ident ||
4742 conn->info_state & L2CAP_INFO_FEAT_MASK_REQ_DONE)
4745 cancel_delayed_work(&conn->info_timer);
4747 if (result != L2CAP_IR_SUCCESS) {
4748 conn->info_state |= L2CAP_INFO_FEAT_MASK_REQ_DONE;
4749 conn->info_ident = 0;
4751 l2cap_conn_start(conn);
4757 case L2CAP_IT_FEAT_MASK:
4758 conn->feat_mask = get_unaligned_le32(rsp->data);
4760 if (conn->feat_mask & L2CAP_FEAT_FIXED_CHAN) {
4761 struct l2cap_info_req req;
4762 req.type = cpu_to_le16(L2CAP_IT_FIXED_CHAN);
4764 conn->info_ident = l2cap_get_ident(conn);
4766 l2cap_send_cmd(conn, conn->info_ident,
4767 L2CAP_INFO_REQ, sizeof(req), &req);
4769 conn->info_state |= L2CAP_INFO_FEAT_MASK_REQ_DONE;
4770 conn->info_ident = 0;
4772 l2cap_conn_start(conn);
4776 case L2CAP_IT_FIXED_CHAN:
4777 conn->remote_fixed_chan = rsp->data[0];
4778 conn->info_state |= L2CAP_INFO_FEAT_MASK_REQ_DONE;
4779 conn->info_ident = 0;
4781 l2cap_conn_start(conn);
4788 static int l2cap_create_channel_req(struct l2cap_conn *conn,
4789 struct l2cap_cmd_hdr *cmd,
4790 u16 cmd_len, void *data)
4792 struct l2cap_create_chan_req *req = data;
4793 struct l2cap_create_chan_rsp rsp;
4794 struct l2cap_chan *chan;
4795 struct hci_dev *hdev;
4798 if (cmd_len != sizeof(*req))
4801 if (!(conn->local_fixed_chan & L2CAP_FC_A2MP))
4804 psm = le16_to_cpu(req->psm);
4805 scid = le16_to_cpu(req->scid);
4807 BT_DBG("psm 0x%2.2x, scid 0x%4.4x, amp_id %d", psm, scid, req->amp_id);
4809 /* For controller id 0 make BR/EDR connection */
4810 if (req->amp_id == AMP_ID_BREDR) {
4811 l2cap_connect(conn, cmd, data, L2CAP_CREATE_CHAN_RSP,
4816 /* Validate AMP controller id */
4817 hdev = hci_dev_get(req->amp_id);
4821 if (hdev->dev_type != HCI_AMP || !test_bit(HCI_UP, &hdev->flags)) {
4826 chan = l2cap_connect(conn, cmd, data, L2CAP_CREATE_CHAN_RSP,
4829 struct amp_mgr *mgr = conn->hcon->amp_mgr;
4830 struct hci_conn *hs_hcon;
4832 hs_hcon = hci_conn_hash_lookup_ba(hdev, AMP_LINK,
4836 cmd_reject_invalid_cid(conn, cmd->ident, chan->scid,
4841 BT_DBG("mgr %p bredr_chan %p hs_hcon %p", mgr, chan, hs_hcon);
4843 mgr->bredr_chan = chan;
4844 chan->hs_hcon = hs_hcon;
4845 chan->fcs = L2CAP_FCS_NONE;
4846 conn->mtu = hdev->block_mtu;
4855 rsp.scid = cpu_to_le16(scid);
4856 rsp.result = cpu_to_le16(L2CAP_CR_BAD_AMP);
4857 rsp.status = cpu_to_le16(L2CAP_CS_NO_INFO);
4859 l2cap_send_cmd(conn, cmd->ident, L2CAP_CREATE_CHAN_RSP,
4865 static void l2cap_send_move_chan_req(struct l2cap_chan *chan, u8 dest_amp_id)
4867 struct l2cap_move_chan_req req;
4870 BT_DBG("chan %p, dest_amp_id %d", chan, dest_amp_id);
4872 ident = l2cap_get_ident(chan->conn);
4873 chan->ident = ident;
4875 req.icid = cpu_to_le16(chan->scid);
4876 req.dest_amp_id = dest_amp_id;
4878 l2cap_send_cmd(chan->conn, ident, L2CAP_MOVE_CHAN_REQ, sizeof(req),
4881 __set_chan_timer(chan, L2CAP_MOVE_TIMEOUT);
4884 static void l2cap_send_move_chan_rsp(struct l2cap_chan *chan, u16 result)
4886 struct l2cap_move_chan_rsp rsp;
4888 BT_DBG("chan %p, result 0x%4.4x", chan, result);
4890 rsp.icid = cpu_to_le16(chan->dcid);
4891 rsp.result = cpu_to_le16(result);
4893 l2cap_send_cmd(chan->conn, chan->ident, L2CAP_MOVE_CHAN_RSP,
4897 static void l2cap_send_move_chan_cfm(struct l2cap_chan *chan, u16 result)
4899 struct l2cap_move_chan_cfm cfm;
4901 BT_DBG("chan %p, result 0x%4.4x", chan, result);
4903 chan->ident = l2cap_get_ident(chan->conn);
4905 cfm.icid = cpu_to_le16(chan->scid);
4906 cfm.result = cpu_to_le16(result);
4908 l2cap_send_cmd(chan->conn, chan->ident, L2CAP_MOVE_CHAN_CFM,
4911 __set_chan_timer(chan, L2CAP_MOVE_TIMEOUT);
4914 static void l2cap_send_move_chan_cfm_icid(struct l2cap_conn *conn, u16 icid)
4916 struct l2cap_move_chan_cfm cfm;
4918 BT_DBG("conn %p, icid 0x%4.4x", conn, icid);
4920 cfm.icid = cpu_to_le16(icid);
4921 cfm.result = cpu_to_le16(L2CAP_MC_UNCONFIRMED);
4923 l2cap_send_cmd(conn, l2cap_get_ident(conn), L2CAP_MOVE_CHAN_CFM,
4927 static void l2cap_send_move_chan_cfm_rsp(struct l2cap_conn *conn, u8 ident,
4930 struct l2cap_move_chan_cfm_rsp rsp;
4932 BT_DBG("icid 0x%4.4x", icid);
4934 rsp.icid = cpu_to_le16(icid);
4935 l2cap_send_cmd(conn, ident, L2CAP_MOVE_CHAN_CFM_RSP, sizeof(rsp), &rsp);
4938 static void __release_logical_link(struct l2cap_chan *chan)
4940 chan->hs_hchan = NULL;
4941 chan->hs_hcon = NULL;
4943 /* Placeholder - release the logical link */
4946 static void l2cap_logical_fail(struct l2cap_chan *chan)
4948 /* Logical link setup failed */
4949 if (chan->state != BT_CONNECTED) {
4950 /* Create channel failure, disconnect */
4951 l2cap_send_disconn_req(chan, ECONNRESET);
4955 switch (chan->move_role) {
4956 case L2CAP_MOVE_ROLE_RESPONDER:
4957 l2cap_move_done(chan);
4958 l2cap_send_move_chan_rsp(chan, L2CAP_MR_NOT_SUPP);
4960 case L2CAP_MOVE_ROLE_INITIATOR:
4961 if (chan->move_state == L2CAP_MOVE_WAIT_LOGICAL_COMP ||
4962 chan->move_state == L2CAP_MOVE_WAIT_LOGICAL_CFM) {
4963 /* Remote has only sent pending or
4964 * success responses, clean up
4966 l2cap_move_done(chan);
4969 /* Other amp move states imply that the move
4970 * has already aborted
4972 l2cap_send_move_chan_cfm(chan, L2CAP_MC_UNCONFIRMED);
4977 static void l2cap_logical_finish_create(struct l2cap_chan *chan,
4978 struct hci_chan *hchan)
4980 struct l2cap_conf_rsp rsp;
4982 chan->hs_hchan = hchan;
4983 chan->hs_hcon->l2cap_data = chan->conn;
4985 l2cap_send_efs_conf_rsp(chan, &rsp, chan->ident, 0);
4987 if (test_bit(CONF_INPUT_DONE, &chan->conf_state)) {
4990 set_default_fcs(chan);
4992 err = l2cap_ertm_init(chan);
4994 l2cap_send_disconn_req(chan, -err);
4996 l2cap_chan_ready(chan);
5000 static void l2cap_logical_finish_move(struct l2cap_chan *chan,
5001 struct hci_chan *hchan)
5003 chan->hs_hcon = hchan->conn;
5004 chan->hs_hcon->l2cap_data = chan->conn;
5006 BT_DBG("move_state %d", chan->move_state);
5008 switch (chan->move_state) {
5009 case L2CAP_MOVE_WAIT_LOGICAL_COMP:
5010 /* Move confirm will be sent after a success
5011 * response is received
5013 chan->move_state = L2CAP_MOVE_WAIT_RSP_SUCCESS;
5015 case L2CAP_MOVE_WAIT_LOGICAL_CFM:
5016 if (test_bit(CONN_LOCAL_BUSY, &chan->conn_state)) {
5017 chan->move_state = L2CAP_MOVE_WAIT_LOCAL_BUSY;
5018 } else if (chan->move_role == L2CAP_MOVE_ROLE_INITIATOR) {
5019 chan->move_state = L2CAP_MOVE_WAIT_CONFIRM_RSP;
5020 l2cap_send_move_chan_cfm(chan, L2CAP_MC_CONFIRMED);
5021 } else if (chan->move_role == L2CAP_MOVE_ROLE_RESPONDER) {
5022 chan->move_state = L2CAP_MOVE_WAIT_CONFIRM;
5023 l2cap_send_move_chan_rsp(chan, L2CAP_MR_SUCCESS);
5027 /* Move was not in expected state, free the channel */
5028 __release_logical_link(chan);
5030 chan->move_state = L2CAP_MOVE_STABLE;
5034 /* Call with chan locked */
5035 void l2cap_logical_cfm(struct l2cap_chan *chan, struct hci_chan *hchan,
5038 BT_DBG("chan %p, hchan %p, status %d", chan, hchan, status);
5041 l2cap_logical_fail(chan);
5042 __release_logical_link(chan);
5046 if (chan->state != BT_CONNECTED) {
5047 /* Ignore logical link if channel is on BR/EDR */
5048 if (chan->local_amp_id != AMP_ID_BREDR)
5049 l2cap_logical_finish_create(chan, hchan);
5051 l2cap_logical_finish_move(chan, hchan);
5055 void l2cap_move_start(struct l2cap_chan *chan)
5057 BT_DBG("chan %p", chan);
5059 if (chan->local_amp_id == AMP_ID_BREDR) {
5060 if (chan->chan_policy != BT_CHANNEL_POLICY_AMP_PREFERRED)
5062 chan->move_role = L2CAP_MOVE_ROLE_INITIATOR;
5063 chan->move_state = L2CAP_MOVE_WAIT_PREPARE;
5064 /* Placeholder - start physical link setup */
5066 chan->move_role = L2CAP_MOVE_ROLE_INITIATOR;
5067 chan->move_state = L2CAP_MOVE_WAIT_RSP_SUCCESS;
5069 l2cap_move_setup(chan);
5070 l2cap_send_move_chan_req(chan, 0);
5074 static void l2cap_do_create(struct l2cap_chan *chan, int result,
5075 u8 local_amp_id, u8 remote_amp_id)
5077 BT_DBG("chan %p state %s %u -> %u", chan, state_to_string(chan->state),
5078 local_amp_id, remote_amp_id);
5080 chan->fcs = L2CAP_FCS_NONE;
5082 /* Outgoing channel on AMP */
5083 if (chan->state == BT_CONNECT) {
5084 if (result == L2CAP_CR_SUCCESS) {
5085 chan->local_amp_id = local_amp_id;
5086 l2cap_send_create_chan_req(chan, remote_amp_id);
5088 /* Revert to BR/EDR connect */
5089 l2cap_send_conn_req(chan);
5095 /* Incoming channel on AMP */
5096 if (__l2cap_no_conn_pending(chan)) {
5097 struct l2cap_conn_rsp rsp;
5099 rsp.scid = cpu_to_le16(chan->dcid);
5100 rsp.dcid = cpu_to_le16(chan->scid);
5102 if (result == L2CAP_CR_SUCCESS) {
5103 /* Send successful response */
5104 rsp.result = cpu_to_le16(L2CAP_CR_SUCCESS);
5105 rsp.status = cpu_to_le16(L2CAP_CS_NO_INFO);
5107 /* Send negative response */
5108 rsp.result = cpu_to_le16(L2CAP_CR_NO_MEM);
5109 rsp.status = cpu_to_le16(L2CAP_CS_NO_INFO);
5112 l2cap_send_cmd(chan->conn, chan->ident, L2CAP_CREATE_CHAN_RSP,
5115 if (result == L2CAP_CR_SUCCESS) {
5116 l2cap_state_change(chan, BT_CONFIG);
5117 set_bit(CONF_REQ_SENT, &chan->conf_state);
5118 l2cap_send_cmd(chan->conn, l2cap_get_ident(chan->conn),
5120 l2cap_build_conf_req(chan, buf, sizeof(buf)), buf);
5121 chan->num_conf_req++;
5126 static void l2cap_do_move_initiate(struct l2cap_chan *chan, u8 local_amp_id,
5129 l2cap_move_setup(chan);
5130 chan->move_id = local_amp_id;
5131 chan->move_state = L2CAP_MOVE_WAIT_RSP;
5133 l2cap_send_move_chan_req(chan, remote_amp_id);
5136 static void l2cap_do_move_respond(struct l2cap_chan *chan, int result)
5138 struct hci_chan *hchan = NULL;
5140 /* Placeholder - get hci_chan for logical link */
5143 if (hchan->state == BT_CONNECTED) {
5144 /* Logical link is ready to go */
5145 chan->hs_hcon = hchan->conn;
5146 chan->hs_hcon->l2cap_data = chan->conn;
5147 chan->move_state = L2CAP_MOVE_WAIT_CONFIRM;
5148 l2cap_send_move_chan_rsp(chan, L2CAP_MR_SUCCESS);
5150 l2cap_logical_cfm(chan, hchan, L2CAP_MR_SUCCESS);
5152 /* Wait for logical link to be ready */
5153 chan->move_state = L2CAP_MOVE_WAIT_LOGICAL_CFM;
5156 /* Logical link not available */
5157 l2cap_send_move_chan_rsp(chan, L2CAP_MR_NOT_ALLOWED);
5161 static void l2cap_do_move_cancel(struct l2cap_chan *chan, int result)
5163 if (chan->move_role == L2CAP_MOVE_ROLE_RESPONDER) {
5165 if (result == -EINVAL)
5166 rsp_result = L2CAP_MR_BAD_ID;
5168 rsp_result = L2CAP_MR_NOT_ALLOWED;
5170 l2cap_send_move_chan_rsp(chan, rsp_result);
5173 chan->move_role = L2CAP_MOVE_ROLE_NONE;
5174 chan->move_state = L2CAP_MOVE_STABLE;
5176 /* Restart data transmission */
5177 l2cap_ertm_send(chan);
5180 /* Invoke with locked chan */
5181 void __l2cap_physical_cfm(struct l2cap_chan *chan, int result)
5183 u8 local_amp_id = chan->local_amp_id;
5184 u8 remote_amp_id = chan->remote_amp_id;
5186 BT_DBG("chan %p, result %d, local_amp_id %d, remote_amp_id %d",
5187 chan, result, local_amp_id, remote_amp_id);
5189 if (chan->state == BT_DISCONN || chan->state == BT_CLOSED)
5192 if (chan->state != BT_CONNECTED) {
5193 l2cap_do_create(chan, result, local_amp_id, remote_amp_id);
5194 } else if (result != L2CAP_MR_SUCCESS) {
5195 l2cap_do_move_cancel(chan, result);
5197 switch (chan->move_role) {
5198 case L2CAP_MOVE_ROLE_INITIATOR:
5199 l2cap_do_move_initiate(chan, local_amp_id,
5202 case L2CAP_MOVE_ROLE_RESPONDER:
5203 l2cap_do_move_respond(chan, result);
5206 l2cap_do_move_cancel(chan, result);
5212 static inline int l2cap_move_channel_req(struct l2cap_conn *conn,
5213 struct l2cap_cmd_hdr *cmd,
5214 u16 cmd_len, void *data)
5216 struct l2cap_move_chan_req *req = data;
5217 struct l2cap_move_chan_rsp rsp;
5218 struct l2cap_chan *chan;
5220 u16 result = L2CAP_MR_NOT_ALLOWED;
5222 if (cmd_len != sizeof(*req))
5225 icid = le16_to_cpu(req->icid);
5227 BT_DBG("icid 0x%4.4x, dest_amp_id %d", icid, req->dest_amp_id);
5229 if (!(conn->local_fixed_chan & L2CAP_FC_A2MP))
5232 chan = l2cap_get_chan_by_dcid(conn, icid);
5234 rsp.icid = cpu_to_le16(icid);
5235 rsp.result = cpu_to_le16(L2CAP_MR_NOT_ALLOWED);
5236 l2cap_send_cmd(conn, cmd->ident, L2CAP_MOVE_CHAN_RSP,
5241 chan->ident = cmd->ident;
5243 if (chan->scid < L2CAP_CID_DYN_START ||
5244 chan->chan_policy == BT_CHANNEL_POLICY_BREDR_ONLY ||
5245 (chan->mode != L2CAP_MODE_ERTM &&
5246 chan->mode != L2CAP_MODE_STREAMING)) {
5247 result = L2CAP_MR_NOT_ALLOWED;
5248 goto send_move_response;
5251 if (chan->local_amp_id == req->dest_amp_id) {
5252 result = L2CAP_MR_SAME_ID;
5253 goto send_move_response;
5256 if (req->dest_amp_id != AMP_ID_BREDR) {
5257 struct hci_dev *hdev;
5258 hdev = hci_dev_get(req->dest_amp_id);
5259 if (!hdev || hdev->dev_type != HCI_AMP ||
5260 !test_bit(HCI_UP, &hdev->flags)) {
5264 result = L2CAP_MR_BAD_ID;
5265 goto send_move_response;
5270 /* Detect a move collision. Only send a collision response
5271 * if this side has "lost", otherwise proceed with the move.
5272 * The winner has the larger bd_addr.
5274 if ((__chan_is_moving(chan) ||
5275 chan->move_role != L2CAP_MOVE_ROLE_NONE) &&
5276 bacmp(&conn->hcon->src, &conn->hcon->dst) > 0) {
5277 result = L2CAP_MR_COLLISION;
5278 goto send_move_response;
5281 chan->move_role = L2CAP_MOVE_ROLE_RESPONDER;
5282 l2cap_move_setup(chan);
5283 chan->move_id = req->dest_amp_id;
5285 if (req->dest_amp_id == AMP_ID_BREDR) {
5286 /* Moving to BR/EDR */
5287 if (test_bit(CONN_LOCAL_BUSY, &chan->conn_state)) {
5288 chan->move_state = L2CAP_MOVE_WAIT_LOCAL_BUSY;
5289 result = L2CAP_MR_PEND;
5291 chan->move_state = L2CAP_MOVE_WAIT_CONFIRM;
5292 result = L2CAP_MR_SUCCESS;
5295 chan->move_state = L2CAP_MOVE_WAIT_PREPARE;
5296 /* Placeholder - uncomment when amp functions are available */
5297 /*amp_accept_physical(chan, req->dest_amp_id);*/
5298 result = L2CAP_MR_PEND;
5302 l2cap_send_move_chan_rsp(chan, result);
5304 l2cap_chan_unlock(chan);
5309 static void l2cap_move_continue(struct l2cap_conn *conn, u16 icid, u16 result)
5311 struct l2cap_chan *chan;
5312 struct hci_chan *hchan = NULL;
5314 chan = l2cap_get_chan_by_scid(conn, icid);
5316 l2cap_send_move_chan_cfm_icid(conn, icid);
5320 __clear_chan_timer(chan);
5321 if (result == L2CAP_MR_PEND)
5322 __set_chan_timer(chan, L2CAP_MOVE_ERTX_TIMEOUT);
5324 switch (chan->move_state) {
5325 case L2CAP_MOVE_WAIT_LOGICAL_COMP:
5326 /* Move confirm will be sent when logical link
5329 chan->move_state = L2CAP_MOVE_WAIT_LOGICAL_CFM;
5331 case L2CAP_MOVE_WAIT_RSP_SUCCESS:
5332 if (result == L2CAP_MR_PEND) {
5334 } else if (test_bit(CONN_LOCAL_BUSY,
5335 &chan->conn_state)) {
5336 chan->move_state = L2CAP_MOVE_WAIT_LOCAL_BUSY;
5338 /* Logical link is up or moving to BR/EDR,
5341 chan->move_state = L2CAP_MOVE_WAIT_CONFIRM_RSP;
5342 l2cap_send_move_chan_cfm(chan, L2CAP_MC_CONFIRMED);
5345 case L2CAP_MOVE_WAIT_RSP:
5347 if (result == L2CAP_MR_SUCCESS) {
5348 /* Remote is ready, send confirm immediately
5349 * after logical link is ready
5351 chan->move_state = L2CAP_MOVE_WAIT_LOGICAL_CFM;
5353 /* Both logical link and move success
5354 * are required to confirm
5356 chan->move_state = L2CAP_MOVE_WAIT_LOGICAL_COMP;
5359 /* Placeholder - get hci_chan for logical link */
5361 /* Logical link not available */
5362 l2cap_send_move_chan_cfm(chan, L2CAP_MC_UNCONFIRMED);
5366 /* If the logical link is not yet connected, do not
5367 * send confirmation.
5369 if (hchan->state != BT_CONNECTED)
5372 /* Logical link is already ready to go */
5374 chan->hs_hcon = hchan->conn;
5375 chan->hs_hcon->l2cap_data = chan->conn;
5377 if (result == L2CAP_MR_SUCCESS) {
5378 /* Can confirm now */
5379 l2cap_send_move_chan_cfm(chan, L2CAP_MC_CONFIRMED);
5381 /* Now only need move success
5384 chan->move_state = L2CAP_MOVE_WAIT_RSP_SUCCESS;
5387 l2cap_logical_cfm(chan, hchan, L2CAP_MR_SUCCESS);
5390 /* Any other amp move state means the move failed. */
5391 chan->move_id = chan->local_amp_id;
5392 l2cap_move_done(chan);
5393 l2cap_send_move_chan_cfm(chan, L2CAP_MC_UNCONFIRMED);
5396 l2cap_chan_unlock(chan);
5399 static void l2cap_move_fail(struct l2cap_conn *conn, u8 ident, u16 icid,
5402 struct l2cap_chan *chan;
5404 chan = l2cap_get_chan_by_ident(conn, ident);
5406 /* Could not locate channel, icid is best guess */
5407 l2cap_send_move_chan_cfm_icid(conn, icid);
5411 __clear_chan_timer(chan);
5413 if (chan->move_role == L2CAP_MOVE_ROLE_INITIATOR) {
5414 if (result == L2CAP_MR_COLLISION) {
5415 chan->move_role = L2CAP_MOVE_ROLE_RESPONDER;
5417 /* Cleanup - cancel move */
5418 chan->move_id = chan->local_amp_id;
5419 l2cap_move_done(chan);
5423 l2cap_send_move_chan_cfm(chan, L2CAP_MC_UNCONFIRMED);
5425 l2cap_chan_unlock(chan);
5428 static int l2cap_move_channel_rsp(struct l2cap_conn *conn,
5429 struct l2cap_cmd_hdr *cmd,
5430 u16 cmd_len, void *data)
5432 struct l2cap_move_chan_rsp *rsp = data;
5435 if (cmd_len != sizeof(*rsp))
5438 icid = le16_to_cpu(rsp->icid);
5439 result = le16_to_cpu(rsp->result);
5441 BT_DBG("icid 0x%4.4x, result 0x%4.4x", icid, result);
5443 if (result == L2CAP_MR_SUCCESS || result == L2CAP_MR_PEND)
5444 l2cap_move_continue(conn, icid, result);
5446 l2cap_move_fail(conn, cmd->ident, icid, result);
5451 static int l2cap_move_channel_confirm(struct l2cap_conn *conn,
5452 struct l2cap_cmd_hdr *cmd,
5453 u16 cmd_len, void *data)
5455 struct l2cap_move_chan_cfm *cfm = data;
5456 struct l2cap_chan *chan;
5459 if (cmd_len != sizeof(*cfm))
5462 icid = le16_to_cpu(cfm->icid);
5463 result = le16_to_cpu(cfm->result);
5465 BT_DBG("icid 0x%4.4x, result 0x%4.4x", icid, result);
5467 chan = l2cap_get_chan_by_dcid(conn, icid);
5469 /* Spec requires a response even if the icid was not found */
5470 l2cap_send_move_chan_cfm_rsp(conn, cmd->ident, icid);
5474 if (chan->move_state == L2CAP_MOVE_WAIT_CONFIRM) {
5475 if (result == L2CAP_MC_CONFIRMED) {
5476 chan->local_amp_id = chan->move_id;
5477 if (chan->local_amp_id == AMP_ID_BREDR)
5478 __release_logical_link(chan);
5480 chan->move_id = chan->local_amp_id;
5483 l2cap_move_done(chan);
5486 l2cap_send_move_chan_cfm_rsp(conn, cmd->ident, icid);
5488 l2cap_chan_unlock(chan);
5493 static inline int l2cap_move_channel_confirm_rsp(struct l2cap_conn *conn,
5494 struct l2cap_cmd_hdr *cmd,
5495 u16 cmd_len, void *data)
5497 struct l2cap_move_chan_cfm_rsp *rsp = data;
5498 struct l2cap_chan *chan;
5501 if (cmd_len != sizeof(*rsp))
5504 icid = le16_to_cpu(rsp->icid);
5506 BT_DBG("icid 0x%4.4x", icid);
5508 chan = l2cap_get_chan_by_scid(conn, icid);
5512 __clear_chan_timer(chan);
5514 if (chan->move_state == L2CAP_MOVE_WAIT_CONFIRM_RSP) {
5515 chan->local_amp_id = chan->move_id;
5517 if (chan->local_amp_id == AMP_ID_BREDR && chan->hs_hchan)
5518 __release_logical_link(chan);
5520 l2cap_move_done(chan);
5523 l2cap_chan_unlock(chan);
5528 static inline int l2cap_conn_param_update_req(struct l2cap_conn *conn,
5529 struct l2cap_cmd_hdr *cmd,
5530 u16 cmd_len, u8 *data)
5532 struct hci_conn *hcon = conn->hcon;
5533 struct l2cap_conn_param_update_req *req;
5534 struct l2cap_conn_param_update_rsp rsp;
5535 u16 min, max, latency, to_multiplier;
5538 if (hcon->role != HCI_ROLE_MASTER)
5541 if (cmd_len != sizeof(struct l2cap_conn_param_update_req))
5544 req = (struct l2cap_conn_param_update_req *) data;
5545 min = __le16_to_cpu(req->min);
5546 max = __le16_to_cpu(req->max);
5547 latency = __le16_to_cpu(req->latency);
5548 to_multiplier = __le16_to_cpu(req->to_multiplier);
5550 BT_DBG("min 0x%4.4x max 0x%4.4x latency: 0x%4.4x Timeout: 0x%4.4x",
5551 min, max, latency, to_multiplier);
5553 memset(&rsp, 0, sizeof(rsp));
5555 err = hci_check_conn_params(min, max, latency, to_multiplier);
5557 rsp.result = cpu_to_le16(L2CAP_CONN_PARAM_REJECTED);
5559 rsp.result = cpu_to_le16(L2CAP_CONN_PARAM_ACCEPTED);
5561 l2cap_send_cmd(conn, cmd->ident, L2CAP_CONN_PARAM_UPDATE_RSP,
5567 store_hint = hci_le_conn_update(hcon, min, max, latency,
5569 mgmt_new_conn_param(hcon->hdev, &hcon->dst, hcon->dst_type,
5570 store_hint, min, max, latency,
5578 static int l2cap_le_connect_rsp(struct l2cap_conn *conn,
5579 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
5582 struct l2cap_le_conn_rsp *rsp = (struct l2cap_le_conn_rsp *) data;
5583 struct hci_conn *hcon = conn->hcon;
5584 u16 dcid, mtu, mps, credits, result;
5585 struct l2cap_chan *chan;
5588 if (cmd_len < sizeof(*rsp))
5591 dcid = __le16_to_cpu(rsp->dcid);
5592 mtu = __le16_to_cpu(rsp->mtu);
5593 mps = __le16_to_cpu(rsp->mps);
5594 credits = __le16_to_cpu(rsp->credits);
5595 result = __le16_to_cpu(rsp->result);
5597 if (result == L2CAP_CR_LE_SUCCESS && (mtu < 23 || mps < 23 ||
5598 dcid < L2CAP_CID_DYN_START ||
5599 dcid > L2CAP_CID_LE_DYN_END))
5602 BT_DBG("dcid 0x%4.4x mtu %u mps %u credits %u result 0x%2.2x",
5603 dcid, mtu, mps, credits, result);
5605 mutex_lock(&conn->chan_lock);
5607 chan = __l2cap_get_chan_by_ident(conn, cmd->ident);
5615 l2cap_chan_lock(chan);
5618 case L2CAP_CR_LE_SUCCESS:
5619 if (__l2cap_get_chan_by_dcid(conn, dcid)) {
5627 chan->remote_mps = mps;
5628 chan->tx_credits = credits;
5629 l2cap_chan_ready(chan);
5632 case L2CAP_CR_LE_AUTHENTICATION:
5633 case L2CAP_CR_LE_ENCRYPTION:
5634 /* If we already have MITM protection we can't do
5637 if (hcon->sec_level > BT_SECURITY_MEDIUM) {
5638 l2cap_chan_del(chan, ECONNREFUSED);
5642 sec_level = hcon->sec_level + 1;
5643 if (chan->sec_level < sec_level)
5644 chan->sec_level = sec_level;
5646 /* We'll need to send a new Connect Request */
5647 clear_bit(FLAG_LE_CONN_REQ_SENT, &chan->flags);
5649 smp_conn_security(hcon, chan->sec_level);
5653 l2cap_chan_del(chan, ECONNREFUSED);
5657 l2cap_chan_unlock(chan);
5660 mutex_unlock(&conn->chan_lock);
5665 static inline int l2cap_bredr_sig_cmd(struct l2cap_conn *conn,
5666 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
5671 switch (cmd->code) {
5672 case L2CAP_COMMAND_REJ:
5673 l2cap_command_rej(conn, cmd, cmd_len, data);
5676 case L2CAP_CONN_REQ:
5677 err = l2cap_connect_req(conn, cmd, cmd_len, data);
5680 case L2CAP_CONN_RSP:
5681 case L2CAP_CREATE_CHAN_RSP:
5682 l2cap_connect_create_rsp(conn, cmd, cmd_len, data);
5685 case L2CAP_CONF_REQ:
5686 err = l2cap_config_req(conn, cmd, cmd_len, data);
5689 case L2CAP_CONF_RSP:
5690 l2cap_config_rsp(conn, cmd, cmd_len, data);
5693 case L2CAP_DISCONN_REQ:
5694 err = l2cap_disconnect_req(conn, cmd, cmd_len, data);
5697 case L2CAP_DISCONN_RSP:
5698 l2cap_disconnect_rsp(conn, cmd, cmd_len, data);
5701 case L2CAP_ECHO_REQ:
5702 l2cap_send_cmd(conn, cmd->ident, L2CAP_ECHO_RSP, cmd_len, data);
5705 case L2CAP_ECHO_RSP:
5708 case L2CAP_INFO_REQ:
5709 err = l2cap_information_req(conn, cmd, cmd_len, data);
5712 case L2CAP_INFO_RSP:
5713 l2cap_information_rsp(conn, cmd, cmd_len, data);
5716 case L2CAP_CREATE_CHAN_REQ:
5717 err = l2cap_create_channel_req(conn, cmd, cmd_len, data);
5720 case L2CAP_MOVE_CHAN_REQ:
5721 err = l2cap_move_channel_req(conn, cmd, cmd_len, data);
5724 case L2CAP_MOVE_CHAN_RSP:
5725 l2cap_move_channel_rsp(conn, cmd, cmd_len, data);
5728 case L2CAP_MOVE_CHAN_CFM:
5729 err = l2cap_move_channel_confirm(conn, cmd, cmd_len, data);
5732 case L2CAP_MOVE_CHAN_CFM_RSP:
5733 l2cap_move_channel_confirm_rsp(conn, cmd, cmd_len, data);
5737 BT_ERR("Unknown BR/EDR signaling command 0x%2.2x", cmd->code);
5745 static int l2cap_le_connect_req(struct l2cap_conn *conn,
5746 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
5749 struct l2cap_le_conn_req *req = (struct l2cap_le_conn_req *) data;
5750 struct l2cap_le_conn_rsp rsp;
5751 struct l2cap_chan *chan, *pchan;
5752 u16 dcid, scid, credits, mtu, mps;
5756 if (cmd_len != sizeof(*req))
5759 scid = __le16_to_cpu(req->scid);
5760 mtu = __le16_to_cpu(req->mtu);
5761 mps = __le16_to_cpu(req->mps);
5766 if (mtu < 23 || mps < 23)
5769 BT_DBG("psm 0x%2.2x scid 0x%4.4x mtu %u mps %u", __le16_to_cpu(psm),
5772 /* Check if we have socket listening on psm */
5773 pchan = l2cap_global_chan_by_psm(BT_LISTEN, psm, &conn->hcon->src,
5774 &conn->hcon->dst, LE_LINK);
5776 result = L2CAP_CR_LE_BAD_PSM;
5781 mutex_lock(&conn->chan_lock);
5782 l2cap_chan_lock(pchan);
5784 if (!smp_sufficient_security(conn->hcon, pchan->sec_level,
5786 result = L2CAP_CR_LE_AUTHENTICATION;
5788 goto response_unlock;
5791 /* Check for valid dynamic CID range */
5792 if (scid < L2CAP_CID_DYN_START || scid > L2CAP_CID_LE_DYN_END) {
5793 result = L2CAP_CR_LE_INVALID_SCID;
5795 goto response_unlock;
5798 /* Check if we already have channel with that dcid */
5799 if (__l2cap_get_chan_by_dcid(conn, scid)) {
5800 result = L2CAP_CR_LE_SCID_IN_USE;
5802 goto response_unlock;
5805 chan = pchan->ops->new_connection(pchan);
5807 result = L2CAP_CR_LE_NO_MEM;
5808 goto response_unlock;
5811 bacpy(&chan->src, &conn->hcon->src);
5812 bacpy(&chan->dst, &conn->hcon->dst);
5813 chan->src_type = bdaddr_src_type(conn->hcon);
5814 chan->dst_type = bdaddr_dst_type(conn->hcon);
5818 chan->remote_mps = mps;
5820 __l2cap_chan_add(conn, chan);
5822 l2cap_le_flowctl_init(chan, __le16_to_cpu(req->credits));
5825 credits = chan->rx_credits;
5827 __set_chan_timer(chan, chan->ops->get_sndtimeo(chan));
5829 chan->ident = cmd->ident;
5831 if (test_bit(FLAG_DEFER_SETUP, &chan->flags)) {
5832 l2cap_state_change(chan, BT_CONNECT2);
5833 /* The following result value is actually not defined
5834 * for LE CoC but we use it to let the function know
5835 * that it should bail out after doing its cleanup
5836 * instead of sending a response.
5838 result = L2CAP_CR_PEND;
5839 chan->ops->defer(chan);
5841 l2cap_chan_ready(chan);
5842 result = L2CAP_CR_LE_SUCCESS;
5846 l2cap_chan_unlock(pchan);
5847 mutex_unlock(&conn->chan_lock);
5848 l2cap_chan_put(pchan);
5850 if (result == L2CAP_CR_PEND)
5855 rsp.mtu = cpu_to_le16(chan->imtu);
5856 rsp.mps = cpu_to_le16(chan->mps);
5862 rsp.dcid = cpu_to_le16(dcid);
5863 rsp.credits = cpu_to_le16(credits);
5864 rsp.result = cpu_to_le16(result);
5866 l2cap_send_cmd(conn, cmd->ident, L2CAP_LE_CONN_RSP, sizeof(rsp), &rsp);
5871 static inline int l2cap_le_credits(struct l2cap_conn *conn,
5872 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
5875 struct l2cap_le_credits *pkt;
5876 struct l2cap_chan *chan;
5877 u16 cid, credits, max_credits;
5879 if (cmd_len != sizeof(*pkt))
5882 pkt = (struct l2cap_le_credits *) data;
5883 cid = __le16_to_cpu(pkt->cid);
5884 credits = __le16_to_cpu(pkt->credits);
5886 BT_DBG("cid 0x%4.4x credits 0x%4.4x", cid, credits);
5888 chan = l2cap_get_chan_by_dcid(conn, cid);
5892 max_credits = LE_FLOWCTL_MAX_CREDITS - chan->tx_credits;
5893 if (credits > max_credits) {
5894 BT_ERR("LE credits overflow");
5895 l2cap_send_disconn_req(chan, ECONNRESET);
5896 l2cap_chan_unlock(chan);
5898 /* Return 0 so that we don't trigger an unnecessary
5899 * command reject packet.
5904 chan->tx_credits += credits;
5906 /* Resume sending */
5907 l2cap_le_flowctl_send(chan);
5909 if (chan->tx_credits)
5910 chan->ops->resume(chan);
5912 l2cap_chan_unlock(chan);
5917 static inline int l2cap_ecred_conn_req(struct l2cap_conn *conn,
5918 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
5921 struct l2cap_ecred_conn_req *req = (void *) data;
5923 struct l2cap_ecred_conn_rsp rsp;
5924 __le16 dcid[L2CAP_ECRED_MAX_CID];
5926 struct l2cap_chan *chan, *pchan;
5936 if (cmd_len < sizeof(*req) || (cmd_len - sizeof(*req)) % sizeof(u16)) {
5937 result = L2CAP_CR_LE_INVALID_PARAMS;
5941 cmd_len -= sizeof(*req);
5942 num_scid = cmd_len / sizeof(u16);
5944 if (num_scid > ARRAY_SIZE(pdu.dcid)) {
5945 result = L2CAP_CR_LE_INVALID_PARAMS;
5949 mtu = __le16_to_cpu(req->mtu);
5950 mps = __le16_to_cpu(req->mps);
5952 if (mtu < L2CAP_ECRED_MIN_MTU || mps < L2CAP_ECRED_MIN_MPS) {
5953 result = L2CAP_CR_LE_UNACCEPT_PARAMS;
5959 BT_DBG("psm 0x%2.2x mtu %u mps %u", __le16_to_cpu(psm), mtu, mps);
5961 memset(&pdu, 0, sizeof(pdu));
5963 /* Check if we have socket listening on psm */
5964 pchan = l2cap_global_chan_by_psm(BT_LISTEN, psm, &conn->hcon->src,
5965 &conn->hcon->dst, LE_LINK);
5967 result = L2CAP_CR_LE_BAD_PSM;
5971 mutex_lock(&conn->chan_lock);
5972 l2cap_chan_lock(pchan);
5974 if (!smp_sufficient_security(conn->hcon, pchan->sec_level,
5976 result = L2CAP_CR_LE_AUTHENTICATION;
5980 result = L2CAP_CR_LE_SUCCESS;
5982 for (i = 0; i < num_scid; i++) {
5983 u16 scid = __le16_to_cpu(req->scid[i]);
5985 BT_DBG("scid[%d] 0x%4.4x", i, scid);
5987 pdu.dcid[i] = 0x0000;
5988 len += sizeof(*pdu.dcid);
5990 /* Check for valid dynamic CID range */
5991 if (scid < L2CAP_CID_DYN_START || scid > L2CAP_CID_LE_DYN_END) {
5992 result = L2CAP_CR_LE_INVALID_SCID;
5996 /* Check if we already have channel with that dcid */
5997 if (__l2cap_get_chan_by_dcid(conn, scid)) {
5998 result = L2CAP_CR_LE_SCID_IN_USE;
6002 chan = pchan->ops->new_connection(pchan);
6004 result = L2CAP_CR_LE_NO_MEM;
6008 bacpy(&chan->src, &conn->hcon->src);
6009 bacpy(&chan->dst, &conn->hcon->dst);
6010 chan->src_type = bdaddr_src_type(conn->hcon);
6011 chan->dst_type = bdaddr_dst_type(conn->hcon);
6015 chan->remote_mps = mps;
6017 __l2cap_chan_add(conn, chan);
6019 l2cap_ecred_init(chan, __le16_to_cpu(req->credits));
6022 if (!pdu.rsp.credits) {
6023 pdu.rsp.mtu = cpu_to_le16(chan->imtu);
6024 pdu.rsp.mps = cpu_to_le16(chan->mps);
6025 pdu.rsp.credits = cpu_to_le16(chan->rx_credits);
6028 pdu.dcid[i] = cpu_to_le16(chan->scid);
6030 __set_chan_timer(chan, chan->ops->get_sndtimeo(chan));
6032 chan->ident = cmd->ident;
6034 if (test_bit(FLAG_DEFER_SETUP, &chan->flags)) {
6035 l2cap_state_change(chan, BT_CONNECT2);
6037 chan->ops->defer(chan);
6039 l2cap_chan_ready(chan);
6044 l2cap_chan_unlock(pchan);
6045 mutex_unlock(&conn->chan_lock);
6046 l2cap_chan_put(pchan);
6049 pdu.rsp.result = cpu_to_le16(result);
6054 l2cap_send_cmd(conn, cmd->ident, L2CAP_ECRED_CONN_RSP,
6055 sizeof(pdu.rsp) + len, &pdu);
6060 static inline int l2cap_ecred_conn_rsp(struct l2cap_conn *conn,
6061 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
6064 struct l2cap_ecred_conn_rsp *rsp = (void *) data;
6065 struct hci_conn *hcon = conn->hcon;
6066 u16 mtu, mps, credits, result;
6067 struct l2cap_chan *chan;
6068 int err = 0, sec_level;
6071 if (cmd_len < sizeof(*rsp))
6074 mtu = __le16_to_cpu(rsp->mtu);
6075 mps = __le16_to_cpu(rsp->mps);
6076 credits = __le16_to_cpu(rsp->credits);
6077 result = __le16_to_cpu(rsp->result);
6079 BT_DBG("mtu %u mps %u credits %u result 0x%4.4x", mtu, mps, credits,
6082 mutex_lock(&conn->chan_lock);
6084 cmd_len -= sizeof(*rsp);
6086 list_for_each_entry(chan, &conn->chan_l, list) {
6089 if (chan->ident != cmd->ident ||
6090 chan->mode != L2CAP_MODE_EXT_FLOWCTL ||
6091 chan->state == BT_CONNECTED)
6094 l2cap_chan_lock(chan);
6096 /* Check that there is a dcid for each pending channel */
6097 if (cmd_len < sizeof(dcid)) {
6098 l2cap_chan_del(chan, ECONNREFUSED);
6099 l2cap_chan_unlock(chan);
6103 dcid = __le16_to_cpu(rsp->dcid[i++]);
6104 cmd_len -= sizeof(u16);
6106 BT_DBG("dcid[%d] 0x%4.4x", i, dcid);
6108 /* Check if dcid is already in use */
6109 if (dcid && __l2cap_get_chan_by_dcid(conn, dcid)) {
6110 /* If a device receives a
6111 * L2CAP_CREDIT_BASED_CONNECTION_RSP packet with an
6112 * already-assigned Destination CID, then both the
6113 * original channel and the new channel shall be
6114 * immediately discarded and not used.
6116 l2cap_chan_del(chan, ECONNREFUSED);
6117 l2cap_chan_unlock(chan);
6118 chan = __l2cap_get_chan_by_dcid(conn, dcid);
6119 l2cap_chan_lock(chan);
6120 l2cap_chan_del(chan, ECONNRESET);
6121 l2cap_chan_unlock(chan);
6126 case L2CAP_CR_LE_AUTHENTICATION:
6127 case L2CAP_CR_LE_ENCRYPTION:
6128 /* If we already have MITM protection we can't do
6131 if (hcon->sec_level > BT_SECURITY_MEDIUM) {
6132 l2cap_chan_del(chan, ECONNREFUSED);
6136 sec_level = hcon->sec_level + 1;
6137 if (chan->sec_level < sec_level)
6138 chan->sec_level = sec_level;
6140 /* We'll need to send a new Connect Request */
6141 clear_bit(FLAG_ECRED_CONN_REQ_SENT, &chan->flags);
6143 smp_conn_security(hcon, chan->sec_level);
6146 case L2CAP_CR_LE_BAD_PSM:
6147 l2cap_chan_del(chan, ECONNREFUSED);
6151 /* If dcid was not set it means channels was refused */
6153 l2cap_chan_del(chan, ECONNREFUSED);
6160 chan->remote_mps = mps;
6161 chan->tx_credits = credits;
6162 l2cap_chan_ready(chan);
6166 l2cap_chan_unlock(chan);
6169 mutex_unlock(&conn->chan_lock);
6174 static inline int l2cap_ecred_reconf_req(struct l2cap_conn *conn,
6175 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
6178 struct l2cap_ecred_reconf_req *req = (void *) data;
6179 struct l2cap_ecred_reconf_rsp rsp;
6180 u16 mtu, mps, result;
6181 struct l2cap_chan *chan;
6187 if (cmd_len < sizeof(*req) || cmd_len - sizeof(*req) % sizeof(u16)) {
6188 result = L2CAP_CR_LE_INVALID_PARAMS;
6192 mtu = __le16_to_cpu(req->mtu);
6193 mps = __le16_to_cpu(req->mps);
6195 BT_DBG("mtu %u mps %u", mtu, mps);
6197 if (mtu < L2CAP_ECRED_MIN_MTU) {
6198 result = L2CAP_RECONF_INVALID_MTU;
6202 if (mps < L2CAP_ECRED_MIN_MPS) {
6203 result = L2CAP_RECONF_INVALID_MPS;
6207 cmd_len -= sizeof(*req);
6208 num_scid = cmd_len / sizeof(u16);
6209 result = L2CAP_RECONF_SUCCESS;
6211 for (i = 0; i < num_scid; i++) {
6214 scid = __le16_to_cpu(req->scid[i]);
6218 chan = __l2cap_get_chan_by_dcid(conn, scid);
6222 /* If the MTU value is decreased for any of the included
6223 * channels, then the receiver shall disconnect all
6224 * included channels.
6226 if (chan->omtu > mtu) {
6227 BT_ERR("chan %p decreased MTU %u -> %u", chan,
6229 result = L2CAP_RECONF_INVALID_MTU;
6233 chan->remote_mps = mps;
6237 rsp.result = cpu_to_le16(result);
6239 l2cap_send_cmd(conn, cmd->ident, L2CAP_ECRED_RECONF_RSP, sizeof(rsp),
6245 static inline int l2cap_ecred_reconf_rsp(struct l2cap_conn *conn,
6246 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
6249 struct l2cap_chan *chan;
6250 struct l2cap_ecred_conn_rsp *rsp = (void *) data;
6253 if (cmd_len < sizeof(*rsp))
6256 result = __le16_to_cpu(rsp->result);
6258 BT_DBG("result 0x%4.4x", rsp->result);
6263 list_for_each_entry(chan, &conn->chan_l, list) {
6264 if (chan->ident != cmd->ident)
6267 l2cap_chan_del(chan, ECONNRESET);
6273 static inline int l2cap_le_command_rej(struct l2cap_conn *conn,
6274 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
6277 struct l2cap_cmd_rej_unk *rej = (struct l2cap_cmd_rej_unk *) data;
6278 struct l2cap_chan *chan;
6280 if (cmd_len < sizeof(*rej))
6283 mutex_lock(&conn->chan_lock);
6285 chan = __l2cap_get_chan_by_ident(conn, cmd->ident);
6289 l2cap_chan_lock(chan);
6290 l2cap_chan_del(chan, ECONNREFUSED);
6291 l2cap_chan_unlock(chan);
6294 mutex_unlock(&conn->chan_lock);
6298 static inline int l2cap_le_sig_cmd(struct l2cap_conn *conn,
6299 struct l2cap_cmd_hdr *cmd, u16 cmd_len,
6304 switch (cmd->code) {
6305 case L2CAP_COMMAND_REJ:
6306 l2cap_le_command_rej(conn, cmd, cmd_len, data);
6309 case L2CAP_CONN_PARAM_UPDATE_REQ:
6310 err = l2cap_conn_param_update_req(conn, cmd, cmd_len, data);
6313 case L2CAP_CONN_PARAM_UPDATE_RSP:
6316 case L2CAP_LE_CONN_RSP:
6317 l2cap_le_connect_rsp(conn, cmd, cmd_len, data);
6320 case L2CAP_LE_CONN_REQ:
6321 err = l2cap_le_connect_req(conn, cmd, cmd_len, data);
6324 case L2CAP_LE_CREDITS:
6325 err = l2cap_le_credits(conn, cmd, cmd_len, data);
6328 case L2CAP_ECRED_CONN_REQ:
6329 err = l2cap_ecred_conn_req(conn, cmd, cmd_len, data);
6332 case L2CAP_ECRED_CONN_RSP:
6333 err = l2cap_ecred_conn_rsp(conn, cmd, cmd_len, data);
6336 case L2CAP_ECRED_RECONF_REQ:
6337 err = l2cap_ecred_reconf_req(conn, cmd, cmd_len, data);
6340 case L2CAP_ECRED_RECONF_RSP:
6341 err = l2cap_ecred_reconf_rsp(conn, cmd, cmd_len, data);
6344 case L2CAP_DISCONN_REQ:
6345 err = l2cap_disconnect_req(conn, cmd, cmd_len, data);
6348 case L2CAP_DISCONN_RSP:
6349 l2cap_disconnect_rsp(conn, cmd, cmd_len, data);
6353 BT_ERR("Unknown LE signaling command 0x%2.2x", cmd->code);
6361 static inline void l2cap_le_sig_channel(struct l2cap_conn *conn,
6362 struct sk_buff *skb)
6364 struct hci_conn *hcon = conn->hcon;
6365 struct l2cap_cmd_hdr *cmd;
6369 if (hcon->type != LE_LINK)
6372 if (skb->len < L2CAP_CMD_HDR_SIZE)
6375 cmd = (void *) skb->data;
6376 skb_pull(skb, L2CAP_CMD_HDR_SIZE);
6378 len = le16_to_cpu(cmd->len);
6380 BT_DBG("code 0x%2.2x len %d id 0x%2.2x", cmd->code, len, cmd->ident);
6382 if (len != skb->len || !cmd->ident) {
6383 BT_DBG("corrupted command");
6387 err = l2cap_le_sig_cmd(conn, cmd, len, skb->data);
6389 struct l2cap_cmd_rej_unk rej;
6391 BT_ERR("Wrong link type (%d)", err);
6393 rej.reason = cpu_to_le16(L2CAP_REJ_NOT_UNDERSTOOD);
6394 l2cap_send_cmd(conn, cmd->ident, L2CAP_COMMAND_REJ,
6402 static inline void l2cap_sig_channel(struct l2cap_conn *conn,
6403 struct sk_buff *skb)
6405 struct hci_conn *hcon = conn->hcon;
6406 struct l2cap_cmd_hdr *cmd;
6409 l2cap_raw_recv(conn, skb);
6411 if (hcon->type != ACL_LINK)
6414 while (skb->len >= L2CAP_CMD_HDR_SIZE) {
6417 cmd = (void *) skb->data;
6418 skb_pull(skb, L2CAP_CMD_HDR_SIZE);
6420 len = le16_to_cpu(cmd->len);
6422 BT_DBG("code 0x%2.2x len %d id 0x%2.2x", cmd->code, len,
6425 if (len > skb->len || !cmd->ident) {
6426 BT_DBG("corrupted command");
6430 err = l2cap_bredr_sig_cmd(conn, cmd, len, skb->data);
6432 struct l2cap_cmd_rej_unk rej;
6434 BT_ERR("Wrong link type (%d)", err);
6436 rej.reason = cpu_to_le16(L2CAP_REJ_NOT_UNDERSTOOD);
6437 l2cap_send_cmd(conn, cmd->ident, L2CAP_COMMAND_REJ,
6448 static int l2cap_check_fcs(struct l2cap_chan *chan, struct sk_buff *skb)
6450 u16 our_fcs, rcv_fcs;
6453 if (test_bit(FLAG_EXT_CTRL, &chan->flags))
6454 hdr_size = L2CAP_EXT_HDR_SIZE;
6456 hdr_size = L2CAP_ENH_HDR_SIZE;
6458 if (chan->fcs == L2CAP_FCS_CRC16) {
6459 skb_trim(skb, skb->len - L2CAP_FCS_SIZE);
6460 rcv_fcs = get_unaligned_le16(skb->data + skb->len);
6461 our_fcs = crc16(0, skb->data - hdr_size, skb->len + hdr_size);
6463 if (our_fcs != rcv_fcs)
6469 static void l2cap_send_i_or_rr_or_rnr(struct l2cap_chan *chan)
6471 struct l2cap_ctrl control;
6473 BT_DBG("chan %p", chan);
6475 memset(&control, 0, sizeof(control));
6478 control.reqseq = chan->buffer_seq;
6479 set_bit(CONN_SEND_FBIT, &chan->conn_state);
6481 if (test_bit(CONN_LOCAL_BUSY, &chan->conn_state)) {
6482 control.super = L2CAP_SUPER_RNR;
6483 l2cap_send_sframe(chan, &control);
6486 if (test_and_clear_bit(CONN_REMOTE_BUSY, &chan->conn_state) &&
6487 chan->unacked_frames > 0)
6488 __set_retrans_timer(chan);
6490 /* Send pending iframes */
6491 l2cap_ertm_send(chan);
6493 if (!test_bit(CONN_LOCAL_BUSY, &chan->conn_state) &&
6494 test_bit(CONN_SEND_FBIT, &chan->conn_state)) {
6495 /* F-bit wasn't sent in an s-frame or i-frame yet, so
6498 control.super = L2CAP_SUPER_RR;
6499 l2cap_send_sframe(chan, &control);
6503 static void append_skb_frag(struct sk_buff *skb, struct sk_buff *new_frag,
6504 struct sk_buff **last_frag)
6506 /* skb->len reflects data in skb as well as all fragments
6507 * skb->data_len reflects only data in fragments
6509 if (!skb_has_frag_list(skb))
6510 skb_shinfo(skb)->frag_list = new_frag;
6512 new_frag->next = NULL;
6514 (*last_frag)->next = new_frag;
6515 *last_frag = new_frag;
6517 skb->len += new_frag->len;
6518 skb->data_len += new_frag->len;
6519 skb->truesize += new_frag->truesize;
6522 static int l2cap_reassemble_sdu(struct l2cap_chan *chan, struct sk_buff *skb,
6523 struct l2cap_ctrl *control)
6527 switch (control->sar) {
6528 case L2CAP_SAR_UNSEGMENTED:
6532 err = chan->ops->recv(chan, skb);
6535 case L2CAP_SAR_START:
6539 if (!pskb_may_pull(skb, L2CAP_SDULEN_SIZE))
6542 chan->sdu_len = get_unaligned_le16(skb->data);
6543 skb_pull(skb, L2CAP_SDULEN_SIZE);
6545 if (chan->sdu_len > chan->imtu) {
6550 if (skb->len >= chan->sdu_len)
6554 chan->sdu_last_frag = skb;
6560 case L2CAP_SAR_CONTINUE:
6564 append_skb_frag(chan->sdu, skb,
6565 &chan->sdu_last_frag);
6568 if (chan->sdu->len >= chan->sdu_len)
6578 append_skb_frag(chan->sdu, skb,
6579 &chan->sdu_last_frag);
6582 if (chan->sdu->len != chan->sdu_len)
6585 err = chan->ops->recv(chan, chan->sdu);
6588 /* Reassembly complete */
6590 chan->sdu_last_frag = NULL;
6598 kfree_skb(chan->sdu);
6600 chan->sdu_last_frag = NULL;
6607 static int l2cap_resegment(struct l2cap_chan *chan)
6613 void l2cap_chan_busy(struct l2cap_chan *chan, int busy)
6617 if (chan->mode != L2CAP_MODE_ERTM)
6620 event = busy ? L2CAP_EV_LOCAL_BUSY_DETECTED : L2CAP_EV_LOCAL_BUSY_CLEAR;
6621 l2cap_tx(chan, NULL, NULL, event);
6624 static int l2cap_rx_queued_iframes(struct l2cap_chan *chan)
6627 /* Pass sequential frames to l2cap_reassemble_sdu()
6628 * until a gap is encountered.
6631 BT_DBG("chan %p", chan);
6633 while (!test_bit(CONN_LOCAL_BUSY, &chan->conn_state)) {
6634 struct sk_buff *skb;
6635 BT_DBG("Searching for skb with txseq %d (queue len %d)",
6636 chan->buffer_seq, skb_queue_len(&chan->srej_q));
6638 skb = l2cap_ertm_seq_in_queue(&chan->srej_q, chan->buffer_seq);
6643 skb_unlink(skb, &chan->srej_q);
6644 chan->buffer_seq = __next_seq(chan, chan->buffer_seq);
6645 err = l2cap_reassemble_sdu(chan, skb, &bt_cb(skb)->l2cap);
6650 if (skb_queue_empty(&chan->srej_q)) {
6651 chan->rx_state = L2CAP_RX_STATE_RECV;
6652 l2cap_send_ack(chan);
6658 static void l2cap_handle_srej(struct l2cap_chan *chan,
6659 struct l2cap_ctrl *control)
6661 struct sk_buff *skb;
6663 BT_DBG("chan %p, control %p", chan, control);
6665 if (control->reqseq == chan->next_tx_seq) {
6666 BT_DBG("Invalid reqseq %d, disconnecting", control->reqseq);
6667 l2cap_send_disconn_req(chan, ECONNRESET);
6671 skb = l2cap_ertm_seq_in_queue(&chan->tx_q, control->reqseq);
6674 BT_DBG("Seq %d not available for retransmission",
6679 if (chan->max_tx != 0 && bt_cb(skb)->l2cap.retries >= chan->max_tx) {
6680 BT_DBG("Retry limit exceeded (%d)", chan->max_tx);
6681 l2cap_send_disconn_req(chan, ECONNRESET);
6685 clear_bit(CONN_REMOTE_BUSY, &chan->conn_state);
6687 if (control->poll) {
6688 l2cap_pass_to_tx(chan, control);
6690 set_bit(CONN_SEND_FBIT, &chan->conn_state);
6691 l2cap_retransmit(chan, control);
6692 l2cap_ertm_send(chan);
6694 if (chan->tx_state == L2CAP_TX_STATE_WAIT_F) {
6695 set_bit(CONN_SREJ_ACT, &chan->conn_state);
6696 chan->srej_save_reqseq = control->reqseq;
6699 l2cap_pass_to_tx_fbit(chan, control);
6701 if (control->final) {
6702 if (chan->srej_save_reqseq != control->reqseq ||
6703 !test_and_clear_bit(CONN_SREJ_ACT,
6705 l2cap_retransmit(chan, control);
6707 l2cap_retransmit(chan, control);
6708 if (chan->tx_state == L2CAP_TX_STATE_WAIT_F) {
6709 set_bit(CONN_SREJ_ACT, &chan->conn_state);
6710 chan->srej_save_reqseq = control->reqseq;
6716 static void l2cap_handle_rej(struct l2cap_chan *chan,
6717 struct l2cap_ctrl *control)
6719 struct sk_buff *skb;
6721 BT_DBG("chan %p, control %p", chan, control);
6723 if (control->reqseq == chan->next_tx_seq) {
6724 BT_DBG("Invalid reqseq %d, disconnecting", control->reqseq);
6725 l2cap_send_disconn_req(chan, ECONNRESET);
6729 skb = l2cap_ertm_seq_in_queue(&chan->tx_q, control->reqseq);
6731 if (chan->max_tx && skb &&
6732 bt_cb(skb)->l2cap.retries >= chan->max_tx) {
6733 BT_DBG("Retry limit exceeded (%d)", chan->max_tx);
6734 l2cap_send_disconn_req(chan, ECONNRESET);
6738 clear_bit(CONN_REMOTE_BUSY, &chan->conn_state);
6740 l2cap_pass_to_tx(chan, control);
6742 if (control->final) {
6743 if (!test_and_clear_bit(CONN_REJ_ACT, &chan->conn_state))
6744 l2cap_retransmit_all(chan, control);
6746 l2cap_retransmit_all(chan, control);
6747 l2cap_ertm_send(chan);
6748 if (chan->tx_state == L2CAP_TX_STATE_WAIT_F)
6749 set_bit(CONN_REJ_ACT, &chan->conn_state);
6753 static u8 l2cap_classify_txseq(struct l2cap_chan *chan, u16 txseq)
6755 BT_DBG("chan %p, txseq %d", chan, txseq);
6757 BT_DBG("last_acked_seq %d, expected_tx_seq %d", chan->last_acked_seq,
6758 chan->expected_tx_seq);
6760 if (chan->rx_state == L2CAP_RX_STATE_SREJ_SENT) {
6761 if (__seq_offset(chan, txseq, chan->last_acked_seq) >=
6763 /* See notes below regarding "double poll" and
6766 if (chan->tx_win <= ((chan->tx_win_max + 1) >> 1)) {
6767 BT_DBG("Invalid/Ignore - after SREJ");
6768 return L2CAP_TXSEQ_INVALID_IGNORE;
6770 BT_DBG("Invalid - in window after SREJ sent");
6771 return L2CAP_TXSEQ_INVALID;
6775 if (chan->srej_list.head == txseq) {
6776 BT_DBG("Expected SREJ");
6777 return L2CAP_TXSEQ_EXPECTED_SREJ;
6780 if (l2cap_ertm_seq_in_queue(&chan->srej_q, txseq)) {
6781 BT_DBG("Duplicate SREJ - txseq already stored");
6782 return L2CAP_TXSEQ_DUPLICATE_SREJ;
6785 if (l2cap_seq_list_contains(&chan->srej_list, txseq)) {
6786 BT_DBG("Unexpected SREJ - not requested");
6787 return L2CAP_TXSEQ_UNEXPECTED_SREJ;
6791 if (chan->expected_tx_seq == txseq) {
6792 if (__seq_offset(chan, txseq, chan->last_acked_seq) >=
6794 BT_DBG("Invalid - txseq outside tx window");
6795 return L2CAP_TXSEQ_INVALID;
6798 return L2CAP_TXSEQ_EXPECTED;
6802 if (__seq_offset(chan, txseq, chan->last_acked_seq) <
6803 __seq_offset(chan, chan->expected_tx_seq, chan->last_acked_seq)) {
6804 BT_DBG("Duplicate - expected_tx_seq later than txseq");
6805 return L2CAP_TXSEQ_DUPLICATE;
6808 if (__seq_offset(chan, txseq, chan->last_acked_seq) >= chan->tx_win) {
6809 /* A source of invalid packets is a "double poll" condition,
6810 * where delays cause us to send multiple poll packets. If
6811 * the remote stack receives and processes both polls,
6812 * sequence numbers can wrap around in such a way that a
6813 * resent frame has a sequence number that looks like new data
6814 * with a sequence gap. This would trigger an erroneous SREJ
6817 * Fortunately, this is impossible with a tx window that's
6818 * less than half of the maximum sequence number, which allows
6819 * invalid frames to be safely ignored.
6821 * With tx window sizes greater than half of the tx window
6822 * maximum, the frame is invalid and cannot be ignored. This
6823 * causes a disconnect.
6826 if (chan->tx_win <= ((chan->tx_win_max + 1) >> 1)) {
6827 BT_DBG("Invalid/Ignore - txseq outside tx window");
6828 return L2CAP_TXSEQ_INVALID_IGNORE;
6830 BT_DBG("Invalid - txseq outside tx window");
6831 return L2CAP_TXSEQ_INVALID;
6834 BT_DBG("Unexpected - txseq indicates missing frames");
6835 return L2CAP_TXSEQ_UNEXPECTED;
6839 static int l2cap_rx_state_recv(struct l2cap_chan *chan,
6840 struct l2cap_ctrl *control,
6841 struct sk_buff *skb, u8 event)
6844 bool skb_in_use = false;
6846 BT_DBG("chan %p, control %p, skb %p, event %d", chan, control, skb,
6850 case L2CAP_EV_RECV_IFRAME:
6851 switch (l2cap_classify_txseq(chan, control->txseq)) {
6852 case L2CAP_TXSEQ_EXPECTED:
6853 l2cap_pass_to_tx(chan, control);
6855 if (test_bit(CONN_LOCAL_BUSY, &chan->conn_state)) {
6856 BT_DBG("Busy, discarding expected seq %d",
6861 chan->expected_tx_seq = __next_seq(chan,
6864 chan->buffer_seq = chan->expected_tx_seq;
6867 err = l2cap_reassemble_sdu(chan, skb, control);
6871 if (control->final) {
6872 if (!test_and_clear_bit(CONN_REJ_ACT,
6873 &chan->conn_state)) {
6875 l2cap_retransmit_all(chan, control);
6876 l2cap_ertm_send(chan);
6880 if (!test_bit(CONN_LOCAL_BUSY, &chan->conn_state))
6881 l2cap_send_ack(chan);
6883 case L2CAP_TXSEQ_UNEXPECTED:
6884 l2cap_pass_to_tx(chan, control);
6886 /* Can't issue SREJ frames in the local busy state.
6887 * Drop this frame, it will be seen as missing
6888 * when local busy is exited.
6890 if (test_bit(CONN_LOCAL_BUSY, &chan->conn_state)) {
6891 BT_DBG("Busy, discarding unexpected seq %d",
6896 /* There was a gap in the sequence, so an SREJ
6897 * must be sent for each missing frame. The
6898 * current frame is stored for later use.
6900 skb_queue_tail(&chan->srej_q, skb);
6902 BT_DBG("Queued %p (queue len %d)", skb,
6903 skb_queue_len(&chan->srej_q));
6905 clear_bit(CONN_SREJ_ACT, &chan->conn_state);
6906 l2cap_seq_list_clear(&chan->srej_list);
6907 l2cap_send_srej(chan, control->txseq);
6909 chan->rx_state = L2CAP_RX_STATE_SREJ_SENT;
6911 case L2CAP_TXSEQ_DUPLICATE:
6912 l2cap_pass_to_tx(chan, control);
6914 case L2CAP_TXSEQ_INVALID_IGNORE:
6916 case L2CAP_TXSEQ_INVALID:
6918 l2cap_send_disconn_req(chan, ECONNRESET);
6922 case L2CAP_EV_RECV_RR:
6923 l2cap_pass_to_tx(chan, control);
6924 if (control->final) {
6925 clear_bit(CONN_REMOTE_BUSY, &chan->conn_state);
6927 if (!test_and_clear_bit(CONN_REJ_ACT, &chan->conn_state) &&
6928 !__chan_is_moving(chan)) {
6930 l2cap_retransmit_all(chan, control);
6933 l2cap_ertm_send(chan);
6934 } else if (control->poll) {
6935 l2cap_send_i_or_rr_or_rnr(chan);
6937 if (test_and_clear_bit(CONN_REMOTE_BUSY,
6938 &chan->conn_state) &&
6939 chan->unacked_frames)
6940 __set_retrans_timer(chan);
6942 l2cap_ertm_send(chan);
6945 case L2CAP_EV_RECV_RNR:
6946 set_bit(CONN_REMOTE_BUSY, &chan->conn_state);
6947 l2cap_pass_to_tx(chan, control);
6948 if (control && control->poll) {
6949 set_bit(CONN_SEND_FBIT, &chan->conn_state);
6950 l2cap_send_rr_or_rnr(chan, 0);
6952 __clear_retrans_timer(chan);
6953 l2cap_seq_list_clear(&chan->retrans_list);
6955 case L2CAP_EV_RECV_REJ:
6956 l2cap_handle_rej(chan, control);
6958 case L2CAP_EV_RECV_SREJ:
6959 l2cap_handle_srej(chan, control);
6965 if (skb && !skb_in_use) {
6966 BT_DBG("Freeing %p", skb);
6973 static int l2cap_rx_state_srej_sent(struct l2cap_chan *chan,
6974 struct l2cap_ctrl *control,
6975 struct sk_buff *skb, u8 event)
6978 u16 txseq = control->txseq;
6979 bool skb_in_use = false;
6981 BT_DBG("chan %p, control %p, skb %p, event %d", chan, control, skb,
6985 case L2CAP_EV_RECV_IFRAME:
6986 switch (l2cap_classify_txseq(chan, txseq)) {
6987 case L2CAP_TXSEQ_EXPECTED:
6988 /* Keep frame for reassembly later */
6989 l2cap_pass_to_tx(chan, control);
6990 skb_queue_tail(&chan->srej_q, skb);
6992 BT_DBG("Queued %p (queue len %d)", skb,
6993 skb_queue_len(&chan->srej_q));
6995 chan->expected_tx_seq = __next_seq(chan, txseq);
6997 case L2CAP_TXSEQ_EXPECTED_SREJ:
6998 l2cap_seq_list_pop(&chan->srej_list);
7000 l2cap_pass_to_tx(chan, control);
7001 skb_queue_tail(&chan->srej_q, skb);
7003 BT_DBG("Queued %p (queue len %d)", skb,
7004 skb_queue_len(&chan->srej_q));
7006 err = l2cap_rx_queued_iframes(chan);
7011 case L2CAP_TXSEQ_UNEXPECTED:
7012 /* Got a frame that can't be reassembled yet.
7013 * Save it for later, and send SREJs to cover
7014 * the missing frames.
7016 skb_queue_tail(&chan->srej_q, skb);
7018 BT_DBG("Queued %p (queue len %d)", skb,
7019 skb_queue_len(&chan->srej_q));
7021 l2cap_pass_to_tx(chan, control);
7022 l2cap_send_srej(chan, control->txseq);
7024 case L2CAP_TXSEQ_UNEXPECTED_SREJ:
7025 /* This frame was requested with an SREJ, but
7026 * some expected retransmitted frames are
7027 * missing. Request retransmission of missing
7030 skb_queue_tail(&chan->srej_q, skb);
7032 BT_DBG("Queued %p (queue len %d)", skb,
7033 skb_queue_len(&chan->srej_q));
7035 l2cap_pass_to_tx(chan, control);
7036 l2cap_send_srej_list(chan, control->txseq);
7038 case L2CAP_TXSEQ_DUPLICATE_SREJ:
7039 /* We've already queued this frame. Drop this copy. */
7040 l2cap_pass_to_tx(chan, control);
7042 case L2CAP_TXSEQ_DUPLICATE:
7043 /* Expecting a later sequence number, so this frame
7044 * was already received. Ignore it completely.
7047 case L2CAP_TXSEQ_INVALID_IGNORE:
7049 case L2CAP_TXSEQ_INVALID:
7051 l2cap_send_disconn_req(chan, ECONNRESET);
7055 case L2CAP_EV_RECV_RR:
7056 l2cap_pass_to_tx(chan, control);
7057 if (control->final) {
7058 clear_bit(CONN_REMOTE_BUSY, &chan->conn_state);
7060 if (!test_and_clear_bit(CONN_REJ_ACT,
7061 &chan->conn_state)) {
7063 l2cap_retransmit_all(chan, control);
7066 l2cap_ertm_send(chan);
7067 } else if (control->poll) {
7068 if (test_and_clear_bit(CONN_REMOTE_BUSY,
7069 &chan->conn_state) &&
7070 chan->unacked_frames) {
7071 __set_retrans_timer(chan);
7074 set_bit(CONN_SEND_FBIT, &chan->conn_state);
7075 l2cap_send_srej_tail(chan);
7077 if (test_and_clear_bit(CONN_REMOTE_BUSY,
7078 &chan->conn_state) &&
7079 chan->unacked_frames)
7080 __set_retrans_timer(chan);
7082 l2cap_send_ack(chan);
7085 case L2CAP_EV_RECV_RNR:
7086 set_bit(CONN_REMOTE_BUSY, &chan->conn_state);
7087 l2cap_pass_to_tx(chan, control);
7088 if (control->poll) {
7089 l2cap_send_srej_tail(chan);
7091 struct l2cap_ctrl rr_control;
7092 memset(&rr_control, 0, sizeof(rr_control));
7093 rr_control.sframe = 1;
7094 rr_control.super = L2CAP_SUPER_RR;
7095 rr_control.reqseq = chan->buffer_seq;
7096 l2cap_send_sframe(chan, &rr_control);
7100 case L2CAP_EV_RECV_REJ:
7101 l2cap_handle_rej(chan, control);
7103 case L2CAP_EV_RECV_SREJ:
7104 l2cap_handle_srej(chan, control);
7108 if (skb && !skb_in_use) {
7109 BT_DBG("Freeing %p", skb);
7116 static int l2cap_finish_move(struct l2cap_chan *chan)
7118 BT_DBG("chan %p", chan);
7120 chan->rx_state = L2CAP_RX_STATE_RECV;
7123 chan->conn->mtu = chan->hs_hcon->hdev->block_mtu;
7125 chan->conn->mtu = chan->conn->hcon->hdev->acl_mtu;
7127 return l2cap_resegment(chan);
7130 static int l2cap_rx_state_wait_p(struct l2cap_chan *chan,
7131 struct l2cap_ctrl *control,
7132 struct sk_buff *skb, u8 event)
7136 BT_DBG("chan %p, control %p, skb %p, event %d", chan, control, skb,
7142 l2cap_process_reqseq(chan, control->reqseq);
7144 if (!skb_queue_empty(&chan->tx_q))
7145 chan->tx_send_head = skb_peek(&chan->tx_q);
7147 chan->tx_send_head = NULL;
7149 /* Rewind next_tx_seq to the point expected
7152 chan->next_tx_seq = control->reqseq;
7153 chan->unacked_frames = 0;
7155 err = l2cap_finish_move(chan);
7159 set_bit(CONN_SEND_FBIT, &chan->conn_state);
7160 l2cap_send_i_or_rr_or_rnr(chan);
7162 if (event == L2CAP_EV_RECV_IFRAME)
7165 return l2cap_rx_state_recv(chan, control, NULL, event);
7168 static int l2cap_rx_state_wait_f(struct l2cap_chan *chan,
7169 struct l2cap_ctrl *control,
7170 struct sk_buff *skb, u8 event)
7174 if (!control->final)
7177 clear_bit(CONN_REMOTE_BUSY, &chan->conn_state);
7179 chan->rx_state = L2CAP_RX_STATE_RECV;
7180 l2cap_process_reqseq(chan, control->reqseq);
7182 if (!skb_queue_empty(&chan->tx_q))
7183 chan->tx_send_head = skb_peek(&chan->tx_q);
7185 chan->tx_send_head = NULL;
7187 /* Rewind next_tx_seq to the point expected
7190 chan->next_tx_seq = control->reqseq;
7191 chan->unacked_frames = 0;
7194 chan->conn->mtu = chan->hs_hcon->hdev->block_mtu;
7196 chan->conn->mtu = chan->conn->hcon->hdev->acl_mtu;
7198 err = l2cap_resegment(chan);
7201 err = l2cap_rx_state_recv(chan, control, skb, event);
7206 static bool __valid_reqseq(struct l2cap_chan *chan, u16 reqseq)
7208 /* Make sure reqseq is for a packet that has been sent but not acked */
7211 unacked = __seq_offset(chan, chan->next_tx_seq, chan->expected_ack_seq);
7212 return __seq_offset(chan, chan->next_tx_seq, reqseq) <= unacked;
7215 static int l2cap_rx(struct l2cap_chan *chan, struct l2cap_ctrl *control,
7216 struct sk_buff *skb, u8 event)
7220 BT_DBG("chan %p, control %p, skb %p, event %d, state %d", chan,
7221 control, skb, event, chan->rx_state);
7223 if (__valid_reqseq(chan, control->reqseq)) {
7224 switch (chan->rx_state) {
7225 case L2CAP_RX_STATE_RECV:
7226 err = l2cap_rx_state_recv(chan, control, skb, event);
7228 case L2CAP_RX_STATE_SREJ_SENT:
7229 err = l2cap_rx_state_srej_sent(chan, control, skb,
7232 case L2CAP_RX_STATE_WAIT_P:
7233 err = l2cap_rx_state_wait_p(chan, control, skb, event);
7235 case L2CAP_RX_STATE_WAIT_F:
7236 err = l2cap_rx_state_wait_f(chan, control, skb, event);
7243 BT_DBG("Invalid reqseq %d (next_tx_seq %d, expected_ack_seq %d",
7244 control->reqseq, chan->next_tx_seq,
7245 chan->expected_ack_seq);
7246 l2cap_send_disconn_req(chan, ECONNRESET);
7252 static int l2cap_stream_rx(struct l2cap_chan *chan, struct l2cap_ctrl *control,
7253 struct sk_buff *skb)
7255 BT_DBG("chan %p, control %p, skb %p, state %d", chan, control, skb,
7258 if (l2cap_classify_txseq(chan, control->txseq) ==
7259 L2CAP_TXSEQ_EXPECTED) {
7260 l2cap_pass_to_tx(chan, control);
7262 BT_DBG("buffer_seq %d->%d", chan->buffer_seq,
7263 __next_seq(chan, chan->buffer_seq));
7265 chan->buffer_seq = __next_seq(chan, chan->buffer_seq);
7267 l2cap_reassemble_sdu(chan, skb, control);
7270 kfree_skb(chan->sdu);
7273 chan->sdu_last_frag = NULL;
7277 BT_DBG("Freeing %p", skb);
7282 chan->last_acked_seq = control->txseq;
7283 chan->expected_tx_seq = __next_seq(chan, control->txseq);
7288 static int l2cap_data_rcv(struct l2cap_chan *chan, struct sk_buff *skb)
7290 struct l2cap_ctrl *control = &bt_cb(skb)->l2cap;
7294 __unpack_control(chan, skb);
7299 * We can just drop the corrupted I-frame here.
7300 * Receiver will miss it and start proper recovery
7301 * procedures and ask for retransmission.
7303 if (l2cap_check_fcs(chan, skb))
7306 if (!control->sframe && control->sar == L2CAP_SAR_START)
7307 len -= L2CAP_SDULEN_SIZE;
7309 if (chan->fcs == L2CAP_FCS_CRC16)
7310 len -= L2CAP_FCS_SIZE;
7312 if (len > chan->mps) {
7313 l2cap_send_disconn_req(chan, ECONNRESET);
7317 if (chan->ops->filter) {
7318 if (chan->ops->filter(chan, skb))
7322 if (!control->sframe) {
7325 BT_DBG("iframe sar %d, reqseq %d, final %d, txseq %d",
7326 control->sar, control->reqseq, control->final,
7329 /* Validate F-bit - F=0 always valid, F=1 only
7330 * valid in TX WAIT_F
7332 if (control->final && chan->tx_state != L2CAP_TX_STATE_WAIT_F)
7335 if (chan->mode != L2CAP_MODE_STREAMING) {
7336 event = L2CAP_EV_RECV_IFRAME;
7337 err = l2cap_rx(chan, control, skb, event);
7339 err = l2cap_stream_rx(chan, control, skb);
7343 l2cap_send_disconn_req(chan, ECONNRESET);
7345 const u8 rx_func_to_event[4] = {
7346 L2CAP_EV_RECV_RR, L2CAP_EV_RECV_REJ,
7347 L2CAP_EV_RECV_RNR, L2CAP_EV_RECV_SREJ
7350 /* Only I-frames are expected in streaming mode */
7351 if (chan->mode == L2CAP_MODE_STREAMING)
7354 BT_DBG("sframe reqseq %d, final %d, poll %d, super %d",
7355 control->reqseq, control->final, control->poll,
7359 BT_ERR("Trailing bytes: %d in sframe", len);
7360 l2cap_send_disconn_req(chan, ECONNRESET);
7364 /* Validate F and P bits */
7365 if (control->final && (control->poll ||
7366 chan->tx_state != L2CAP_TX_STATE_WAIT_F))
7369 event = rx_func_to_event[control->super];
7370 if (l2cap_rx(chan, control, skb, event))
7371 l2cap_send_disconn_req(chan, ECONNRESET);
7381 static void l2cap_chan_le_send_credits(struct l2cap_chan *chan)
7383 struct l2cap_conn *conn = chan->conn;
7384 struct l2cap_le_credits pkt;
7387 return_credits = (chan->imtu / chan->mps) + 1;
7389 if (chan->rx_credits >= return_credits)
7392 return_credits -= chan->rx_credits;
7394 BT_DBG("chan %p returning %u credits to sender", chan, return_credits);
7396 chan->rx_credits += return_credits;
7398 pkt.cid = cpu_to_le16(chan->scid);
7399 pkt.credits = cpu_to_le16(return_credits);
7401 chan->ident = l2cap_get_ident(conn);
7403 l2cap_send_cmd(conn, chan->ident, L2CAP_LE_CREDITS, sizeof(pkt), &pkt);
7406 static int l2cap_ecred_recv(struct l2cap_chan *chan, struct sk_buff *skb)
7410 BT_DBG("SDU reassemble complete: chan %p skb->len %u", chan, skb->len);
7412 /* Wait recv to confirm reception before updating the credits */
7413 err = chan->ops->recv(chan, skb);
7415 /* Update credits whenever an SDU is received */
7416 l2cap_chan_le_send_credits(chan);
7421 static int l2cap_ecred_data_rcv(struct l2cap_chan *chan, struct sk_buff *skb)
7425 if (!chan->rx_credits) {
7426 BT_ERR("No credits to receive LE L2CAP data");
7427 l2cap_send_disconn_req(chan, ECONNRESET);
7431 if (chan->imtu < skb->len) {
7432 BT_ERR("Too big LE L2CAP PDU");
7437 BT_DBG("rx_credits %u -> %u", chan->rx_credits + 1, chan->rx_credits);
7439 /* Update if remote had run out of credits, this should only happens
7440 * if the remote is not using the entire MPS.
7442 if (!chan->rx_credits)
7443 l2cap_chan_le_send_credits(chan);
7450 sdu_len = get_unaligned_le16(skb->data);
7451 skb_pull(skb, L2CAP_SDULEN_SIZE);
7453 BT_DBG("Start of new SDU. sdu_len %u skb->len %u imtu %u",
7454 sdu_len, skb->len, chan->imtu);
7456 if (sdu_len > chan->imtu) {
7457 BT_ERR("Too big LE L2CAP SDU length received");
7462 if (skb->len > sdu_len) {
7463 BT_ERR("Too much LE L2CAP data received");
7468 if (skb->len == sdu_len)
7469 return l2cap_ecred_recv(chan, skb);
7472 chan->sdu_len = sdu_len;
7473 chan->sdu_last_frag = skb;
7475 /* Detect if remote is not able to use the selected MPS */
7476 if (skb->len + L2CAP_SDULEN_SIZE < chan->mps) {
7477 u16 mps_len = skb->len + L2CAP_SDULEN_SIZE;
7479 /* Adjust the number of credits */
7480 BT_DBG("chan->mps %u -> %u", chan->mps, mps_len);
7481 chan->mps = mps_len;
7482 l2cap_chan_le_send_credits(chan);
7488 BT_DBG("SDU fragment. chan->sdu->len %u skb->len %u chan->sdu_len %u",
7489 chan->sdu->len, skb->len, chan->sdu_len);
7491 if (chan->sdu->len + skb->len > chan->sdu_len) {
7492 BT_ERR("Too much LE L2CAP data received");
7497 append_skb_frag(chan->sdu, skb, &chan->sdu_last_frag);
7500 if (chan->sdu->len == chan->sdu_len) {
7501 err = l2cap_ecred_recv(chan, chan->sdu);
7504 chan->sdu_last_frag = NULL;
7512 kfree_skb(chan->sdu);
7514 chan->sdu_last_frag = NULL;
7518 /* We can't return an error here since we took care of the skb
7519 * freeing internally. An error return would cause the caller to
7520 * do a double-free of the skb.
7525 static void l2cap_data_channel(struct l2cap_conn *conn, u16 cid,
7526 struct sk_buff *skb)
7528 struct l2cap_chan *chan;
7530 chan = l2cap_get_chan_by_scid(conn, cid);
7532 if (cid == L2CAP_CID_A2MP) {
7533 chan = a2mp_channel_create(conn, skb);
7539 l2cap_chan_lock(chan);
7541 BT_DBG("unknown cid 0x%4.4x", cid);
7542 /* Drop packet and return */
7548 BT_DBG("chan %p, len %d", chan, skb->len);
7550 /* If we receive data on a fixed channel before the info req/rsp
7551 * procdure is done simply assume that the channel is supported
7552 * and mark it as ready.
7554 if (chan->chan_type == L2CAP_CHAN_FIXED)
7555 l2cap_chan_ready(chan);
7557 if (chan->state != BT_CONNECTED)
7560 switch (chan->mode) {
7561 case L2CAP_MODE_LE_FLOWCTL:
7562 case L2CAP_MODE_EXT_FLOWCTL:
7563 if (l2cap_ecred_data_rcv(chan, skb) < 0)
7568 case L2CAP_MODE_BASIC:
7569 /* If socket recv buffers overflows we drop data here
7570 * which is *bad* because L2CAP has to be reliable.
7571 * But we don't have any other choice. L2CAP doesn't
7572 * provide flow control mechanism. */
7574 if (chan->imtu < skb->len) {
7575 BT_ERR("Dropping L2CAP data: receive buffer overflow");
7579 if (!chan->ops->recv(chan, skb))
7583 case L2CAP_MODE_ERTM:
7584 case L2CAP_MODE_STREAMING:
7585 l2cap_data_rcv(chan, skb);
7589 BT_DBG("chan %p: bad mode 0x%2.2x", chan, chan->mode);
7597 l2cap_chan_unlock(chan);
7600 static void l2cap_conless_channel(struct l2cap_conn *conn, __le16 psm,
7601 struct sk_buff *skb)
7603 struct hci_conn *hcon = conn->hcon;
7604 struct l2cap_chan *chan;
7606 if (hcon->type != ACL_LINK)
7609 chan = l2cap_global_chan_by_psm(0, psm, &hcon->src, &hcon->dst,
7614 BT_DBG("chan %p, len %d", chan, skb->len);
7616 if (chan->state != BT_BOUND && chan->state != BT_CONNECTED)
7619 if (chan->imtu < skb->len)
7622 /* Store remote BD_ADDR and PSM for msg_name */
7623 bacpy(&bt_cb(skb)->l2cap.bdaddr, &hcon->dst);
7624 bt_cb(skb)->l2cap.psm = psm;
7626 if (!chan->ops->recv(chan, skb)) {
7627 l2cap_chan_put(chan);
7632 l2cap_chan_put(chan);
7637 static void l2cap_recv_frame(struct l2cap_conn *conn, struct sk_buff *skb)
7639 struct l2cap_hdr *lh = (void *) skb->data;
7640 struct hci_conn *hcon = conn->hcon;
7644 if (hcon->state != BT_CONNECTED) {
7645 BT_DBG("queueing pending rx skb");
7646 skb_queue_tail(&conn->pending_rx, skb);
7650 skb_pull(skb, L2CAP_HDR_SIZE);
7651 cid = __le16_to_cpu(lh->cid);
7652 len = __le16_to_cpu(lh->len);
7654 if (len != skb->len) {
7659 /* Since we can't actively block incoming LE connections we must
7660 * at least ensure that we ignore incoming data from them.
7662 if (hcon->type == LE_LINK &&
7663 hci_bdaddr_list_lookup(&hcon->hdev->blacklist, &hcon->dst,
7664 bdaddr_dst_type(hcon))) {
7669 BT_DBG("len %d, cid 0x%4.4x", len, cid);
7672 case L2CAP_CID_SIGNALING:
7673 l2cap_sig_channel(conn, skb);
7676 case L2CAP_CID_CONN_LESS:
7677 psm = get_unaligned((__le16 *) skb->data);
7678 skb_pull(skb, L2CAP_PSMLEN_SIZE);
7679 l2cap_conless_channel(conn, psm, skb);
7682 case L2CAP_CID_LE_SIGNALING:
7683 l2cap_le_sig_channel(conn, skb);
7687 l2cap_data_channel(conn, cid, skb);
7692 static void process_pending_rx(struct work_struct *work)
7694 struct l2cap_conn *conn = container_of(work, struct l2cap_conn,
7696 struct sk_buff *skb;
7700 while ((skb = skb_dequeue(&conn->pending_rx)))
7701 l2cap_recv_frame(conn, skb);
7704 static struct l2cap_conn *l2cap_conn_add(struct hci_conn *hcon)
7706 struct l2cap_conn *conn = hcon->l2cap_data;
7707 struct hci_chan *hchan;
7712 hchan = hci_chan_create(hcon);
7716 conn = kzalloc(sizeof(*conn), GFP_KERNEL);
7718 hci_chan_del(hchan);
7722 kref_init(&conn->ref);
7723 hcon->l2cap_data = conn;
7724 conn->hcon = hci_conn_get(hcon);
7725 conn->hchan = hchan;
7727 BT_DBG("hcon %p conn %p hchan %p", hcon, conn, hchan);
7729 switch (hcon->type) {
7731 if (hcon->hdev->le_mtu) {
7732 conn->mtu = hcon->hdev->le_mtu;
7737 conn->mtu = hcon->hdev->acl_mtu;
7741 conn->feat_mask = 0;
7743 conn->local_fixed_chan = L2CAP_FC_SIG_BREDR | L2CAP_FC_CONNLESS;
7745 if (hcon->type == ACL_LINK &&
7746 hci_dev_test_flag(hcon->hdev, HCI_HS_ENABLED))
7747 conn->local_fixed_chan |= L2CAP_FC_A2MP;
7749 if (hci_dev_test_flag(hcon->hdev, HCI_LE_ENABLED) &&
7750 (bredr_sc_enabled(hcon->hdev) ||
7751 hci_dev_test_flag(hcon->hdev, HCI_FORCE_BREDR_SMP)))
7752 conn->local_fixed_chan |= L2CAP_FC_SMP_BREDR;
7754 mutex_init(&conn->ident_lock);
7755 mutex_init(&conn->chan_lock);
7757 INIT_LIST_HEAD(&conn->chan_l);
7758 INIT_LIST_HEAD(&conn->users);
7760 INIT_DELAYED_WORK(&conn->info_timer, l2cap_info_timeout);
7762 skb_queue_head_init(&conn->pending_rx);
7763 INIT_WORK(&conn->pending_rx_work, process_pending_rx);
7764 INIT_WORK(&conn->id_addr_update_work, l2cap_conn_update_id_addr);
7766 conn->disc_reason = HCI_ERROR_REMOTE_USER_TERM;
7771 static bool is_valid_psm(u16 psm, u8 dst_type) {
7775 if (bdaddr_type_is_le(dst_type))
7776 return (psm <= 0x00ff);
7778 /* PSM must be odd and lsb of upper byte must be 0 */
7779 return ((psm & 0x0101) == 0x0001);
7782 struct l2cap_chan_data {
7783 struct l2cap_chan *chan;
7788 static void l2cap_chan_by_pid(struct l2cap_chan *chan, void *data)
7790 struct l2cap_chan_data *d = data;
7793 if (chan == d->chan)
7796 if (!test_bit(FLAG_DEFER_SETUP, &chan->flags))
7799 pid = chan->ops->get_peer_pid(chan);
7801 /* Only count deferred channels with the same PID/PSM */
7802 if (d->pid != pid || chan->psm != d->chan->psm || chan->ident ||
7803 chan->mode != L2CAP_MODE_EXT_FLOWCTL || chan->state != BT_CONNECT)
7809 int l2cap_chan_connect(struct l2cap_chan *chan, __le16 psm, u16 cid,
7810 bdaddr_t *dst, u8 dst_type)
7812 struct l2cap_conn *conn;
7813 struct hci_conn *hcon;
7814 struct hci_dev *hdev;
7817 BT_DBG("%pMR -> %pMR (type %u) psm 0x%4.4x mode 0x%2.2x", &chan->src,
7818 dst, dst_type, __le16_to_cpu(psm), chan->mode);
7820 hdev = hci_get_route(dst, &chan->src, chan->src_type);
7822 return -EHOSTUNREACH;
7826 if (!is_valid_psm(__le16_to_cpu(psm), dst_type) && !cid &&
7827 chan->chan_type != L2CAP_CHAN_RAW) {
7832 if (chan->chan_type == L2CAP_CHAN_CONN_ORIENTED && !psm) {
7837 if (chan->chan_type == L2CAP_CHAN_FIXED && !cid) {
7842 switch (chan->mode) {
7843 case L2CAP_MODE_BASIC:
7845 case L2CAP_MODE_LE_FLOWCTL:
7847 case L2CAP_MODE_EXT_FLOWCTL:
7848 if (!enable_ecred) {
7853 case L2CAP_MODE_ERTM:
7854 case L2CAP_MODE_STREAMING:
7863 switch (chan->state) {
7867 /* Already connecting */
7872 /* Already connected */
7886 /* Set destination address and psm */
7887 bacpy(&chan->dst, dst);
7888 chan->dst_type = dst_type;
7893 if (bdaddr_type_is_le(dst_type)) {
7894 /* Convert from L2CAP channel address type to HCI address type
7896 if (dst_type == BDADDR_LE_PUBLIC)
7897 dst_type = ADDR_LE_DEV_PUBLIC;
7899 dst_type = ADDR_LE_DEV_RANDOM;
7901 if (hci_dev_test_flag(hdev, HCI_ADVERTISING))
7902 hcon = hci_connect_le(hdev, dst, dst_type,
7904 HCI_LE_CONN_TIMEOUT,
7905 HCI_ROLE_SLAVE, NULL);
7907 hcon = hci_connect_le_scan(hdev, dst, dst_type,
7909 HCI_LE_CONN_TIMEOUT,
7910 CONN_REASON_L2CAP_CHAN);
7913 u8 auth_type = l2cap_get_auth_type(chan);
7914 hcon = hci_connect_acl(hdev, dst, chan->sec_level, auth_type,
7915 CONN_REASON_L2CAP_CHAN);
7919 err = PTR_ERR(hcon);
7923 conn = l2cap_conn_add(hcon);
7925 hci_conn_drop(hcon);
7930 if (chan->mode == L2CAP_MODE_EXT_FLOWCTL) {
7931 struct l2cap_chan_data data;
7934 data.pid = chan->ops->get_peer_pid(chan);
7937 l2cap_chan_list(conn, l2cap_chan_by_pid, &data);
7939 /* Check if there isn't too many channels being connected */
7940 if (data.count > L2CAP_ECRED_CONN_SCID_MAX) {
7941 hci_conn_drop(hcon);
7947 mutex_lock(&conn->chan_lock);
7948 l2cap_chan_lock(chan);
7950 if (cid && __l2cap_get_chan_by_dcid(conn, cid)) {
7951 hci_conn_drop(hcon);
7956 /* Update source addr of the socket */
7957 bacpy(&chan->src, &hcon->src);
7958 chan->src_type = bdaddr_src_type(hcon);
7960 __l2cap_chan_add(conn, chan);
7962 /* l2cap_chan_add takes its own ref so we can drop this one */
7963 hci_conn_drop(hcon);
7965 l2cap_state_change(chan, BT_CONNECT);
7966 __set_chan_timer(chan, chan->ops->get_sndtimeo(chan));
7968 /* Release chan->sport so that it can be reused by other
7969 * sockets (as it's only used for listening sockets).
7971 write_lock(&chan_list_lock);
7973 write_unlock(&chan_list_lock);
7975 if (hcon->state == BT_CONNECTED) {
7976 if (chan->chan_type != L2CAP_CHAN_CONN_ORIENTED) {
7977 __clear_chan_timer(chan);
7978 if (l2cap_chan_check_security(chan, true))
7979 l2cap_state_change(chan, BT_CONNECTED);
7981 l2cap_do_start(chan);
7987 l2cap_chan_unlock(chan);
7988 mutex_unlock(&conn->chan_lock);
7990 hci_dev_unlock(hdev);
7994 EXPORT_SYMBOL_GPL(l2cap_chan_connect);
7996 static void l2cap_ecred_reconfigure(struct l2cap_chan *chan)
7998 struct l2cap_conn *conn = chan->conn;
8000 struct l2cap_ecred_reconf_req req;
8004 pdu.req.mtu = cpu_to_le16(chan->imtu);
8005 pdu.req.mps = cpu_to_le16(chan->mps);
8006 pdu.scid = cpu_to_le16(chan->scid);
8008 chan->ident = l2cap_get_ident(conn);
8010 l2cap_send_cmd(conn, chan->ident, L2CAP_ECRED_RECONF_REQ,
8014 int l2cap_chan_reconfigure(struct l2cap_chan *chan, __u16 mtu)
8016 if (chan->imtu > mtu)
8019 BT_DBG("chan %p mtu 0x%4.4x", chan, mtu);
8023 l2cap_ecred_reconfigure(chan);
8028 /* ---- L2CAP interface with lower layer (HCI) ---- */
8030 int l2cap_connect_ind(struct hci_dev *hdev, bdaddr_t *bdaddr)
8032 int exact = 0, lm1 = 0, lm2 = 0;
8033 struct l2cap_chan *c;
8035 BT_DBG("hdev %s, bdaddr %pMR", hdev->name, bdaddr);
8037 /* Find listening sockets and check their link_mode */
8038 read_lock(&chan_list_lock);
8039 list_for_each_entry(c, &chan_list, global_l) {
8040 if (c->state != BT_LISTEN)
8043 if (!bacmp(&c->src, &hdev->bdaddr)) {
8044 lm1 |= HCI_LM_ACCEPT;
8045 if (test_bit(FLAG_ROLE_SWITCH, &c->flags))
8046 lm1 |= HCI_LM_MASTER;
8048 } else if (!bacmp(&c->src, BDADDR_ANY)) {
8049 lm2 |= HCI_LM_ACCEPT;
8050 if (test_bit(FLAG_ROLE_SWITCH, &c->flags))
8051 lm2 |= HCI_LM_MASTER;
8054 read_unlock(&chan_list_lock);
8056 return exact ? lm1 : lm2;
8059 /* Find the next fixed channel in BT_LISTEN state, continue iteration
8060 * from an existing channel in the list or from the beginning of the
8061 * global list (by passing NULL as first parameter).
8063 static struct l2cap_chan *l2cap_global_fixed_chan(struct l2cap_chan *c,
8064 struct hci_conn *hcon)
8066 u8 src_type = bdaddr_src_type(hcon);
8068 read_lock(&chan_list_lock);
8071 c = list_next_entry(c, global_l);
8073 c = list_entry(chan_list.next, typeof(*c), global_l);
8075 list_for_each_entry_from(c, &chan_list, global_l) {
8076 if (c->chan_type != L2CAP_CHAN_FIXED)
8078 if (c->state != BT_LISTEN)
8080 if (bacmp(&c->src, &hcon->src) && bacmp(&c->src, BDADDR_ANY))
8082 if (src_type != c->src_type)
8086 read_unlock(&chan_list_lock);
8090 read_unlock(&chan_list_lock);
8095 static void l2cap_connect_cfm(struct hci_conn *hcon, u8 status)
8097 struct hci_dev *hdev = hcon->hdev;
8098 struct l2cap_conn *conn;
8099 struct l2cap_chan *pchan;
8102 if (hcon->type != ACL_LINK && hcon->type != LE_LINK)
8105 BT_DBG("hcon %p bdaddr %pMR status %d", hcon, &hcon->dst, status);
8108 l2cap_conn_del(hcon, bt_to_errno(status));
8112 conn = l2cap_conn_add(hcon);
8116 dst_type = bdaddr_dst_type(hcon);
8118 /* If device is blocked, do not create channels for it */
8119 if (hci_bdaddr_list_lookup(&hdev->blacklist, &hcon->dst, dst_type))
8122 /* Find fixed channels and notify them of the new connection. We
8123 * use multiple individual lookups, continuing each time where
8124 * we left off, because the list lock would prevent calling the
8125 * potentially sleeping l2cap_chan_lock() function.
8127 pchan = l2cap_global_fixed_chan(NULL, hcon);
8129 struct l2cap_chan *chan, *next;
8131 /* Client fixed channels should override server ones */
8132 if (__l2cap_get_chan_by_dcid(conn, pchan->scid))
8135 l2cap_chan_lock(pchan);
8136 chan = pchan->ops->new_connection(pchan);
8138 bacpy(&chan->src, &hcon->src);
8139 bacpy(&chan->dst, &hcon->dst);
8140 chan->src_type = bdaddr_src_type(hcon);
8141 chan->dst_type = dst_type;
8143 __l2cap_chan_add(conn, chan);
8146 l2cap_chan_unlock(pchan);
8148 next = l2cap_global_fixed_chan(pchan, hcon);
8149 l2cap_chan_put(pchan);
8153 l2cap_conn_ready(conn);
8156 int l2cap_disconn_ind(struct hci_conn *hcon)
8158 struct l2cap_conn *conn = hcon->l2cap_data;
8160 BT_DBG("hcon %p", hcon);
8163 return HCI_ERROR_REMOTE_USER_TERM;
8164 return conn->disc_reason;
8167 static void l2cap_disconn_cfm(struct hci_conn *hcon, u8 reason)
8169 if (hcon->type != ACL_LINK && hcon->type != LE_LINK)
8172 BT_DBG("hcon %p reason %d", hcon, reason);
8174 l2cap_conn_del(hcon, bt_to_errno(reason));
8177 static inline void l2cap_check_encryption(struct l2cap_chan *chan, u8 encrypt)
8179 if (chan->chan_type != L2CAP_CHAN_CONN_ORIENTED)
8182 if (encrypt == 0x00) {
8183 if (chan->sec_level == BT_SECURITY_MEDIUM) {
8184 __set_chan_timer(chan, L2CAP_ENC_TIMEOUT);
8185 } else if (chan->sec_level == BT_SECURITY_HIGH ||
8186 chan->sec_level == BT_SECURITY_FIPS)
8187 l2cap_chan_close(chan, ECONNREFUSED);
8189 if (chan->sec_level == BT_SECURITY_MEDIUM)
8190 __clear_chan_timer(chan);
8194 static void l2cap_security_cfm(struct hci_conn *hcon, u8 status, u8 encrypt)
8196 struct l2cap_conn *conn = hcon->l2cap_data;
8197 struct l2cap_chan *chan;
8202 BT_DBG("conn %p status 0x%2.2x encrypt %u", conn, status, encrypt);
8204 mutex_lock(&conn->chan_lock);
8206 list_for_each_entry(chan, &conn->chan_l, list) {
8207 l2cap_chan_lock(chan);
8209 BT_DBG("chan %p scid 0x%4.4x state %s", chan, chan->scid,
8210 state_to_string(chan->state));
8212 if (chan->scid == L2CAP_CID_A2MP) {
8213 l2cap_chan_unlock(chan);
8217 if (!status && encrypt)
8218 chan->sec_level = hcon->sec_level;
8220 if (!__l2cap_no_conn_pending(chan)) {
8221 l2cap_chan_unlock(chan);
8225 if (!status && (chan->state == BT_CONNECTED ||
8226 chan->state == BT_CONFIG)) {
8227 chan->ops->resume(chan);
8228 l2cap_check_encryption(chan, encrypt);
8229 l2cap_chan_unlock(chan);
8233 if (chan->state == BT_CONNECT) {
8234 if (!status && l2cap_check_enc_key_size(hcon))
8235 l2cap_start_connection(chan);
8237 __set_chan_timer(chan, L2CAP_DISC_TIMEOUT);
8238 } else if (chan->state == BT_CONNECT2 &&
8239 !(chan->mode == L2CAP_MODE_EXT_FLOWCTL ||
8240 chan->mode == L2CAP_MODE_LE_FLOWCTL)) {
8241 struct l2cap_conn_rsp rsp;
8244 if (!status && l2cap_check_enc_key_size(hcon)) {
8245 if (test_bit(FLAG_DEFER_SETUP, &chan->flags)) {
8246 res = L2CAP_CR_PEND;
8247 stat = L2CAP_CS_AUTHOR_PEND;
8248 chan->ops->defer(chan);
8250 l2cap_state_change(chan, BT_CONFIG);
8251 res = L2CAP_CR_SUCCESS;
8252 stat = L2CAP_CS_NO_INFO;
8255 l2cap_state_change(chan, BT_DISCONN);
8256 __set_chan_timer(chan, L2CAP_DISC_TIMEOUT);
8257 res = L2CAP_CR_SEC_BLOCK;
8258 stat = L2CAP_CS_NO_INFO;
8261 rsp.scid = cpu_to_le16(chan->dcid);
8262 rsp.dcid = cpu_to_le16(chan->scid);
8263 rsp.result = cpu_to_le16(res);
8264 rsp.status = cpu_to_le16(stat);
8265 l2cap_send_cmd(conn, chan->ident, L2CAP_CONN_RSP,
8268 if (!test_bit(CONF_REQ_SENT, &chan->conf_state) &&
8269 res == L2CAP_CR_SUCCESS) {
8271 set_bit(CONF_REQ_SENT, &chan->conf_state);
8272 l2cap_send_cmd(conn, l2cap_get_ident(conn),
8274 l2cap_build_conf_req(chan, buf, sizeof(buf)),
8276 chan->num_conf_req++;
8280 l2cap_chan_unlock(chan);
8283 mutex_unlock(&conn->chan_lock);
8286 /* Append fragment into frame respecting the maximum len of rx_skb */
8287 static int l2cap_recv_frag(struct l2cap_conn *conn, struct sk_buff *skb,
8290 if (!conn->rx_skb) {
8291 /* Allocate skb for the complete frame (with header) */
8292 conn->rx_skb = bt_skb_alloc(len, GFP_KERNEL);
8299 /* Copy as much as the rx_skb can hold */
8300 len = min_t(u16, len, skb->len);
8301 skb_copy_from_linear_data(skb, skb_put(conn->rx_skb, len), len);
8303 conn->rx_len -= len;
8308 static int l2cap_recv_len(struct l2cap_conn *conn, struct sk_buff *skb)
8310 struct sk_buff *rx_skb;
8313 /* Append just enough to complete the header */
8314 len = l2cap_recv_frag(conn, skb, L2CAP_LEN_SIZE - conn->rx_skb->len);
8316 /* If header could not be read just continue */
8317 if (len < 0 || conn->rx_skb->len < L2CAP_LEN_SIZE)
8320 rx_skb = conn->rx_skb;
8321 len = get_unaligned_le16(rx_skb->data);
8323 /* Check if rx_skb has enough space to received all fragments */
8324 if (len + (L2CAP_HDR_SIZE - L2CAP_LEN_SIZE) <= skb_tailroom(rx_skb)) {
8325 /* Update expected len */
8326 conn->rx_len = len + (L2CAP_HDR_SIZE - L2CAP_LEN_SIZE);
8327 return L2CAP_LEN_SIZE;
8330 /* Reset conn->rx_skb since it will need to be reallocated in order to
8331 * fit all fragments.
8333 conn->rx_skb = NULL;
8335 /* Reallocates rx_skb using the exact expected length */
8336 len = l2cap_recv_frag(conn, rx_skb,
8337 len + (L2CAP_HDR_SIZE - L2CAP_LEN_SIZE));
8343 static void l2cap_recv_reset(struct l2cap_conn *conn)
8345 kfree_skb(conn->rx_skb);
8346 conn->rx_skb = NULL;
8350 void l2cap_recv_acldata(struct hci_conn *hcon, struct sk_buff *skb, u16 flags)
8352 struct l2cap_conn *conn = hcon->l2cap_data;
8355 /* For AMP controller do not create l2cap conn */
8356 if (!conn && hcon->hdev->dev_type != HCI_PRIMARY)
8360 conn = l2cap_conn_add(hcon);
8365 BT_DBG("conn %p len %d flags 0x%x", conn, skb->len, flags);
8369 case ACL_START_NO_FLUSH:
8372 BT_ERR("Unexpected start frame (len %d)", skb->len);
8373 l2cap_recv_reset(conn);
8374 l2cap_conn_unreliable(conn, ECOMM);
8377 /* Start fragment may not contain the L2CAP length so just
8378 * copy the initial byte when that happens and use conn->mtu as
8381 if (skb->len < L2CAP_LEN_SIZE) {
8382 if (l2cap_recv_frag(conn, skb, conn->mtu) < 0)
8387 len = get_unaligned_le16(skb->data) + L2CAP_HDR_SIZE;
8389 if (len == skb->len) {
8390 /* Complete frame received */
8391 l2cap_recv_frame(conn, skb);
8395 BT_DBG("Start: total len %d, frag len %d", len, skb->len);
8397 if (skb->len > len) {
8398 BT_ERR("Frame is too long (len %d, expected len %d)",
8400 l2cap_conn_unreliable(conn, ECOMM);
8404 /* Append fragment into frame (with header) */
8405 if (l2cap_recv_frag(conn, skb, len) < 0)
8411 BT_DBG("Cont: frag len %d (expecting %d)", skb->len, conn->rx_len);
8413 if (!conn->rx_skb) {
8414 BT_ERR("Unexpected continuation frame (len %d)", skb->len);
8415 l2cap_conn_unreliable(conn, ECOMM);
8419 /* Complete the L2CAP length if it has not been read */
8420 if (conn->rx_skb->len < L2CAP_LEN_SIZE) {
8421 if (l2cap_recv_len(conn, skb) < 0) {
8422 l2cap_conn_unreliable(conn, ECOMM);
8426 /* Header still could not be read just continue */
8427 if (conn->rx_skb->len < L2CAP_LEN_SIZE)
8431 if (skb->len > conn->rx_len) {
8432 BT_ERR("Fragment is too long (len %d, expected %d)",
8433 skb->len, conn->rx_len);
8434 l2cap_recv_reset(conn);
8435 l2cap_conn_unreliable(conn, ECOMM);
8439 /* Append fragment into frame (with header) */
8440 l2cap_recv_frag(conn, skb, skb->len);
8442 if (!conn->rx_len) {
8443 /* Complete frame received. l2cap_recv_frame
8444 * takes ownership of the skb so set the global
8445 * rx_skb pointer to NULL first.
8447 struct sk_buff *rx_skb = conn->rx_skb;
8448 conn->rx_skb = NULL;
8449 l2cap_recv_frame(conn, rx_skb);
8458 static struct hci_cb l2cap_cb = {
8460 .connect_cfm = l2cap_connect_cfm,
8461 .disconn_cfm = l2cap_disconn_cfm,
8462 .security_cfm = l2cap_security_cfm,
8465 static int l2cap_debugfs_show(struct seq_file *f, void *p)
8467 struct l2cap_chan *c;
8469 read_lock(&chan_list_lock);
8471 list_for_each_entry(c, &chan_list, global_l) {
8472 seq_printf(f, "%pMR (%u) %pMR (%u) %d %d 0x%4.4x 0x%4.4x %d %d %d %d\n",
8473 &c->src, c->src_type, &c->dst, c->dst_type,
8474 c->state, __le16_to_cpu(c->psm),
8475 c->scid, c->dcid, c->imtu, c->omtu,
8476 c->sec_level, c->mode);
8479 read_unlock(&chan_list_lock);
8484 DEFINE_SHOW_ATTRIBUTE(l2cap_debugfs);
8486 static struct dentry *l2cap_debugfs;
8488 int __init l2cap_init(void)
8492 err = l2cap_init_sockets();
8496 hci_register_cb(&l2cap_cb);
8498 if (IS_ERR_OR_NULL(bt_debugfs))
8501 l2cap_debugfs = debugfs_create_file("l2cap", 0444, bt_debugfs,
8502 NULL, &l2cap_debugfs_fops);
8507 void l2cap_exit(void)
8509 debugfs_remove(l2cap_debugfs);
8510 hci_unregister_cb(&l2cap_cb);
8511 l2cap_cleanup_sockets();
8514 module_param(disable_ertm, bool, 0644);
8515 MODULE_PARM_DESC(disable_ertm, "Disable enhanced retransmission mode");
8517 module_param(enable_ecred, bool, 0644);
8518 MODULE_PARM_DESC(enable_ecred, "Enable enhanced credit flow control mode");