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
8 Written 2000,2001 by Maxim Krasnyansky <maxk@qualcomm.com>
10 This program is free software; you can redistribute it and/or modify
11 it under the terms of the GNU General Public License version 2 as
12 published by the Free Software Foundation;
14 THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
15 OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
16 FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT OF THIRD PARTY RIGHTS.
17 IN NO EVENT SHALL THE COPYRIGHT HOLDER(S) AND AUTHOR(S) BE LIABLE FOR ANY
18 CLAIM, OR ANY SPECIAL INDIRECT OR CONSEQUENTIAL DAMAGES, OR ANY DAMAGES
19 WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
20 ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
21 OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
23 ALL LIABILITY, INCLUDING LIABILITY FOR INFRINGEMENT OF ANY PATENTS,
24 COPYRIGHTS, TRADEMARKS OR OTHER RIGHTS, RELATING TO USE OF THIS
25 SOFTWARE IS DISCLAIMED.
28 /* Bluetooth L2CAP sockets. */
30 #include <linux/module.h>
31 #include <linux/export.h>
33 #include <net/bluetooth/bluetooth.h>
34 #include <net/bluetooth/hci_core.h>
35 #include <net/bluetooth/l2cap.h>
39 static struct bt_sock_list l2cap_sk_list
= {
40 .lock
= __RW_LOCK_UNLOCKED(l2cap_sk_list
.lock
)
43 static const struct proto_ops l2cap_sock_ops
;
44 static void l2cap_sock_init(struct sock
*sk
, struct sock
*parent
);
45 static struct sock
*l2cap_sock_alloc(struct net
*net
, struct socket
*sock
,
46 int proto
, gfp_t prio
);
48 bool l2cap_is_socket(struct socket
*sock
)
50 return sock
&& sock
->ops
== &l2cap_sock_ops
;
52 EXPORT_SYMBOL(l2cap_is_socket
);
54 static int l2cap_validate_bredr_psm(u16 psm
)
56 /* PSM must be odd and lsb of upper byte must be 0 */
57 if ((psm
& 0x0101) != 0x0001)
60 /* Restrict usage of well-known PSMs */
61 if (psm
< 0x1001 && !capable(CAP_NET_BIND_SERVICE
))
67 static int l2cap_validate_le_psm(u16 psm
)
69 /* Valid LE_PSM ranges are defined only until 0x00ff */
73 /* Restrict fixed, SIG assigned PSM values to CAP_NET_BIND_SERVICE */
74 if (psm
<= 0x007f && !capable(CAP_NET_BIND_SERVICE
))
80 static int l2cap_sock_bind(struct socket
*sock
, struct sockaddr
*addr
, int alen
)
82 struct sock
*sk
= sock
->sk
;
83 struct l2cap_chan
*chan
= l2cap_pi(sk
)->chan
;
84 struct sockaddr_l2 la
;
89 if (!addr
|| addr
->sa_family
!= AF_BLUETOOTH
)
92 memset(&la
, 0, sizeof(la
));
93 len
= min_t(unsigned int, sizeof(la
), alen
);
94 memcpy(&la
, addr
, len
);
96 if (la
.l2_cid
&& la
.l2_psm
)
99 if (!bdaddr_type_is_valid(la
.l2_bdaddr_type
))
103 /* When the socket gets created it defaults to
104 * CHAN_CONN_ORIENTED, so we need to overwrite the
107 chan
->chan_type
= L2CAP_CHAN_FIXED
;
108 chan
->omtu
= L2CAP_DEFAULT_MTU
;
111 if (bdaddr_type_is_le(la
.l2_bdaddr_type
)) {
112 /* We only allow ATT user space socket */
114 la
.l2_cid
!= cpu_to_le16(L2CAP_CID_ATT
))
120 if (sk
->sk_state
!= BT_OPEN
) {
126 __u16 psm
= __le16_to_cpu(la
.l2_psm
);
128 if (la
.l2_bdaddr_type
== BDADDR_BREDR
)
129 err
= l2cap_validate_bredr_psm(psm
);
131 err
= l2cap_validate_le_psm(psm
);
138 err
= l2cap_add_scid(chan
, __le16_to_cpu(la
.l2_cid
));
140 err
= l2cap_add_psm(chan
, &la
.l2_bdaddr
, la
.l2_psm
);
145 switch (chan
->chan_type
) {
146 case L2CAP_CHAN_CONN_LESS
:
147 if (__le16_to_cpu(la
.l2_psm
) == L2CAP_PSM_3DSP
)
148 chan
->sec_level
= BT_SECURITY_SDP
;
150 case L2CAP_CHAN_CONN_ORIENTED
:
151 if (__le16_to_cpu(la
.l2_psm
) == L2CAP_PSM_SDP
||
152 __le16_to_cpu(la
.l2_psm
) == L2CAP_PSM_RFCOMM
)
153 chan
->sec_level
= BT_SECURITY_SDP
;
156 chan
->sec_level
= BT_SECURITY_SDP
;
160 bacpy(&chan
->src
, &la
.l2_bdaddr
);
161 chan
->src_type
= la
.l2_bdaddr_type
;
163 if (chan
->psm
&& bdaddr_type_is_le(chan
->src_type
))
164 chan
->mode
= L2CAP_MODE_LE_FLOWCTL
;
166 chan
->state
= BT_BOUND
;
167 sk
->sk_state
= BT_BOUND
;
174 static int l2cap_sock_connect(struct socket
*sock
, struct sockaddr
*addr
,
177 struct sock
*sk
= sock
->sk
;
178 struct l2cap_chan
*chan
= l2cap_pi(sk
)->chan
;
179 struct sockaddr_l2 la
;
184 if (!addr
|| alen
< sizeof(addr
->sa_family
) ||
185 addr
->sa_family
!= AF_BLUETOOTH
)
188 memset(&la
, 0, sizeof(la
));
189 len
= min_t(unsigned int, sizeof(la
), alen
);
190 memcpy(&la
, addr
, len
);
192 if (la
.l2_cid
&& la
.l2_psm
)
195 if (!bdaddr_type_is_valid(la
.l2_bdaddr_type
))
198 /* Check that the socket wasn't bound to something that
199 * conflicts with the address given to connect(). If chan->src
200 * is BDADDR_ANY it means bind() was never used, in which case
201 * chan->src_type and la.l2_bdaddr_type do not need to match.
203 if (chan
->src_type
== BDADDR_BREDR
&& bacmp(&chan
->src
, BDADDR_ANY
) &&
204 bdaddr_type_is_le(la
.l2_bdaddr_type
)) {
205 /* Old user space versions will try to incorrectly bind
206 * the ATT socket using BDADDR_BREDR. We need to accept
207 * this and fix up the source address type only when
208 * both the source CID and destination CID indicate
209 * ATT. Anything else is an invalid combination.
211 if (chan
->scid
!= L2CAP_CID_ATT
||
212 la
.l2_cid
!= cpu_to_le16(L2CAP_CID_ATT
))
215 /* We don't have the hdev available here to make a
216 * better decision on random vs public, but since all
217 * user space versions that exhibit this issue anyway do
218 * not support random local addresses assuming public
219 * here is good enough.
221 chan
->src_type
= BDADDR_LE_PUBLIC
;
224 if (chan
->src_type
!= BDADDR_BREDR
&& la
.l2_bdaddr_type
== BDADDR_BREDR
)
227 if (bdaddr_type_is_le(la
.l2_bdaddr_type
)) {
228 /* We only allow ATT user space socket */
230 la
.l2_cid
!= cpu_to_le16(L2CAP_CID_ATT
))
234 if (chan
->psm
&& bdaddr_type_is_le(chan
->src_type
))
235 chan
->mode
= L2CAP_MODE_LE_FLOWCTL
;
237 err
= l2cap_chan_connect(chan
, la
.l2_psm
, __le16_to_cpu(la
.l2_cid
),
238 &la
.l2_bdaddr
, la
.l2_bdaddr_type
);
244 err
= bt_sock_wait_state(sk
, BT_CONNECTED
,
245 sock_sndtimeo(sk
, flags
& O_NONBLOCK
));
252 static int l2cap_sock_listen(struct socket
*sock
, int backlog
)
254 struct sock
*sk
= sock
->sk
;
255 struct l2cap_chan
*chan
= l2cap_pi(sk
)->chan
;
258 BT_DBG("sk %p backlog %d", sk
, backlog
);
262 if (sk
->sk_state
!= BT_BOUND
) {
267 if (sk
->sk_type
!= SOCK_SEQPACKET
&& sk
->sk_type
!= SOCK_STREAM
) {
272 switch (chan
->mode
) {
273 case L2CAP_MODE_BASIC
:
274 case L2CAP_MODE_LE_FLOWCTL
:
276 case L2CAP_MODE_ERTM
:
277 case L2CAP_MODE_STREAMING
:
286 sk
->sk_max_ack_backlog
= backlog
;
287 sk
->sk_ack_backlog
= 0;
289 chan
->state
= BT_LISTEN
;
290 sk
->sk_state
= BT_LISTEN
;
297 static int l2cap_sock_accept(struct socket
*sock
, struct socket
*newsock
,
300 DECLARE_WAITQUEUE(wait
, current
);
301 struct sock
*sk
= sock
->sk
, *nsk
;
305 lock_sock_nested(sk
, SINGLE_DEPTH_NESTING
);
307 timeo
= sock_rcvtimeo(sk
, flags
& O_NONBLOCK
);
309 BT_DBG("sk %p timeo %ld", sk
, timeo
);
311 /* Wait for an incoming connection. (wake-one). */
312 add_wait_queue_exclusive(sk_sleep(sk
), &wait
);
314 set_current_state(TASK_INTERRUPTIBLE
);
316 if (sk
->sk_state
!= BT_LISTEN
) {
321 nsk
= bt_accept_dequeue(sk
, newsock
);
330 if (signal_pending(current
)) {
331 err
= sock_intr_errno(timeo
);
336 timeo
= schedule_timeout(timeo
);
337 lock_sock_nested(sk
, SINGLE_DEPTH_NESTING
);
339 __set_current_state(TASK_RUNNING
);
340 remove_wait_queue(sk_sleep(sk
), &wait
);
345 newsock
->state
= SS_CONNECTED
;
347 BT_DBG("new socket %p", nsk
);
354 static int l2cap_sock_getname(struct socket
*sock
, struct sockaddr
*addr
,
357 struct sockaddr_l2
*la
= (struct sockaddr_l2
*) addr
;
358 struct sock
*sk
= sock
->sk
;
359 struct l2cap_chan
*chan
= l2cap_pi(sk
)->chan
;
361 BT_DBG("sock %p, sk %p", sock
, sk
);
363 if (peer
&& sk
->sk_state
!= BT_CONNECTED
&&
364 sk
->sk_state
!= BT_CONNECT
&& sk
->sk_state
!= BT_CONNECT2
&&
365 sk
->sk_state
!= BT_CONFIG
)
368 memset(la
, 0, sizeof(struct sockaddr_l2
));
369 addr
->sa_family
= AF_BLUETOOTH
;
370 *len
= sizeof(struct sockaddr_l2
);
372 la
->l2_psm
= chan
->psm
;
375 bacpy(&la
->l2_bdaddr
, &chan
->dst
);
376 la
->l2_cid
= cpu_to_le16(chan
->dcid
);
377 la
->l2_bdaddr_type
= chan
->dst_type
;
379 bacpy(&la
->l2_bdaddr
, &chan
->src
);
380 la
->l2_cid
= cpu_to_le16(chan
->scid
);
381 la
->l2_bdaddr_type
= chan
->src_type
;
387 static int l2cap_sock_getsockopt_old(struct socket
*sock
, int optname
,
388 char __user
*optval
, int __user
*optlen
)
390 struct sock
*sk
= sock
->sk
;
391 struct l2cap_chan
*chan
= l2cap_pi(sk
)->chan
;
392 struct l2cap_options opts
;
393 struct l2cap_conninfo cinfo
;
399 if (get_user(len
, optlen
))
406 /* LE sockets should use BT_SNDMTU/BT_RCVMTU, but since
407 * legacy ATT code depends on getsockopt for
408 * L2CAP_OPTIONS we need to let this pass.
410 if (bdaddr_type_is_le(chan
->src_type
) &&
411 chan
->scid
!= L2CAP_CID_ATT
) {
416 memset(&opts
, 0, sizeof(opts
));
417 opts
.imtu
= chan
->imtu
;
418 opts
.omtu
= chan
->omtu
;
419 opts
.flush_to
= chan
->flush_to
;
420 opts
.mode
= chan
->mode
;
421 opts
.fcs
= chan
->fcs
;
422 opts
.max_tx
= chan
->max_tx
;
423 opts
.txwin_size
= chan
->tx_win
;
425 len
= min_t(unsigned int, len
, sizeof(opts
));
426 if (copy_to_user(optval
, (char *) &opts
, len
))
432 switch (chan
->sec_level
) {
433 case BT_SECURITY_LOW
:
436 case BT_SECURITY_MEDIUM
:
437 opt
= L2CAP_LM_AUTH
| L2CAP_LM_ENCRYPT
;
439 case BT_SECURITY_HIGH
:
440 opt
= L2CAP_LM_AUTH
| L2CAP_LM_ENCRYPT
|
443 case BT_SECURITY_FIPS
:
444 opt
= L2CAP_LM_AUTH
| L2CAP_LM_ENCRYPT
|
445 L2CAP_LM_SECURE
| L2CAP_LM_FIPS
;
452 if (test_bit(FLAG_ROLE_SWITCH
, &chan
->flags
))
453 opt
|= L2CAP_LM_MASTER
;
455 if (test_bit(FLAG_FORCE_RELIABLE
, &chan
->flags
))
456 opt
|= L2CAP_LM_RELIABLE
;
458 if (put_user(opt
, (u32 __user
*) optval
))
464 if (sk
->sk_state
!= BT_CONNECTED
&&
465 !(sk
->sk_state
== BT_CONNECT2
&&
466 test_bit(BT_SK_DEFER_SETUP
, &bt_sk(sk
)->flags
))) {
471 memset(&cinfo
, 0, sizeof(cinfo
));
472 cinfo
.hci_handle
= chan
->conn
->hcon
->handle
;
473 memcpy(cinfo
.dev_class
, chan
->conn
->hcon
->dev_class
, 3);
475 len
= min_t(unsigned int, len
, sizeof(cinfo
));
476 if (copy_to_user(optval
, (char *) &cinfo
, len
))
490 static int l2cap_sock_getsockopt(struct socket
*sock
, int level
, int optname
,
491 char __user
*optval
, int __user
*optlen
)
493 struct sock
*sk
= sock
->sk
;
494 struct l2cap_chan
*chan
= l2cap_pi(sk
)->chan
;
495 struct bt_security sec
;
501 if (level
== SOL_L2CAP
)
502 return l2cap_sock_getsockopt_old(sock
, optname
, optval
, optlen
);
504 if (level
!= SOL_BLUETOOTH
)
507 if (get_user(len
, optlen
))
514 if (chan
->chan_type
!= L2CAP_CHAN_CONN_ORIENTED
&&
515 chan
->chan_type
!= L2CAP_CHAN_FIXED
&&
516 chan
->chan_type
!= L2CAP_CHAN_RAW
) {
521 memset(&sec
, 0, sizeof(sec
));
523 sec
.level
= chan
->conn
->hcon
->sec_level
;
525 if (sk
->sk_state
== BT_CONNECTED
)
526 sec
.key_size
= chan
->conn
->hcon
->enc_key_size
;
528 sec
.level
= chan
->sec_level
;
531 len
= min_t(unsigned int, len
, sizeof(sec
));
532 if (copy_to_user(optval
, (char *) &sec
, len
))
538 if (sk
->sk_state
!= BT_BOUND
&& sk
->sk_state
!= BT_LISTEN
) {
543 if (put_user(test_bit(BT_SK_DEFER_SETUP
, &bt_sk(sk
)->flags
),
544 (u32 __user
*) optval
))
550 if (put_user(test_bit(FLAG_FLUSHABLE
, &chan
->flags
),
551 (u32 __user
*) optval
))
557 if (sk
->sk_type
!= SOCK_SEQPACKET
&& sk
->sk_type
!= SOCK_STREAM
558 && sk
->sk_type
!= SOCK_RAW
) {
563 pwr
.force_active
= test_bit(FLAG_FORCE_ACTIVE
, &chan
->flags
);
565 len
= min_t(unsigned int, len
, sizeof(pwr
));
566 if (copy_to_user(optval
, (char *) &pwr
, len
))
571 case BT_CHANNEL_POLICY
:
572 if (put_user(chan
->chan_policy
, (u32 __user
*) optval
))
577 if (!bdaddr_type_is_le(chan
->src_type
)) {
582 if (sk
->sk_state
!= BT_CONNECTED
) {
587 if (put_user(chan
->omtu
, (u16 __user
*) optval
))
592 if (!bdaddr_type_is_le(chan
->src_type
)) {
597 if (put_user(chan
->imtu
, (u16 __user
*) optval
))
610 static bool l2cap_valid_mtu(struct l2cap_chan
*chan
, u16 mtu
)
612 switch (chan
->scid
) {
614 if (mtu
< L2CAP_LE_MIN_MTU
)
619 if (mtu
< L2CAP_DEFAULT_MIN_MTU
)
626 static int l2cap_sock_setsockopt_old(struct socket
*sock
, int optname
,
627 char __user
*optval
, unsigned int optlen
)
629 struct sock
*sk
= sock
->sk
;
630 struct l2cap_chan
*chan
= l2cap_pi(sk
)->chan
;
631 struct l2cap_options opts
;
641 if (bdaddr_type_is_le(chan
->src_type
)) {
646 if (sk
->sk_state
== BT_CONNECTED
) {
651 opts
.imtu
= chan
->imtu
;
652 opts
.omtu
= chan
->omtu
;
653 opts
.flush_to
= chan
->flush_to
;
654 opts
.mode
= chan
->mode
;
655 opts
.fcs
= chan
->fcs
;
656 opts
.max_tx
= chan
->max_tx
;
657 opts
.txwin_size
= chan
->tx_win
;
659 len
= min_t(unsigned int, sizeof(opts
), optlen
);
660 if (copy_from_user((char *) &opts
, optval
, len
)) {
665 if (opts
.txwin_size
> L2CAP_DEFAULT_EXT_WINDOW
) {
670 if (!l2cap_valid_mtu(chan
, opts
.imtu
)) {
675 chan
->mode
= opts
.mode
;
676 switch (chan
->mode
) {
677 case L2CAP_MODE_LE_FLOWCTL
:
679 case L2CAP_MODE_BASIC
:
680 clear_bit(CONF_STATE2_DEVICE
, &chan
->conf_state
);
682 case L2CAP_MODE_ERTM
:
683 case L2CAP_MODE_STREAMING
:
692 chan
->imtu
= opts
.imtu
;
693 chan
->omtu
= opts
.omtu
;
694 chan
->fcs
= opts
.fcs
;
695 chan
->max_tx
= opts
.max_tx
;
696 chan
->tx_win
= opts
.txwin_size
;
697 chan
->flush_to
= opts
.flush_to
;
701 if (get_user(opt
, (u32 __user
*) optval
)) {
706 if (opt
& L2CAP_LM_FIPS
) {
711 if (opt
& L2CAP_LM_AUTH
)
712 chan
->sec_level
= BT_SECURITY_LOW
;
713 if (opt
& L2CAP_LM_ENCRYPT
)
714 chan
->sec_level
= BT_SECURITY_MEDIUM
;
715 if (opt
& L2CAP_LM_SECURE
)
716 chan
->sec_level
= BT_SECURITY_HIGH
;
718 if (opt
& L2CAP_LM_MASTER
)
719 set_bit(FLAG_ROLE_SWITCH
, &chan
->flags
);
721 clear_bit(FLAG_ROLE_SWITCH
, &chan
->flags
);
723 if (opt
& L2CAP_LM_RELIABLE
)
724 set_bit(FLAG_FORCE_RELIABLE
, &chan
->flags
);
726 clear_bit(FLAG_FORCE_RELIABLE
, &chan
->flags
);
738 static int l2cap_sock_setsockopt(struct socket
*sock
, int level
, int optname
,
739 char __user
*optval
, unsigned int optlen
)
741 struct sock
*sk
= sock
->sk
;
742 struct l2cap_chan
*chan
= l2cap_pi(sk
)->chan
;
743 struct bt_security sec
;
745 struct l2cap_conn
*conn
;
751 if (level
== SOL_L2CAP
)
752 return l2cap_sock_setsockopt_old(sock
, optname
, optval
, optlen
);
754 if (level
!= SOL_BLUETOOTH
)
761 if (chan
->chan_type
!= L2CAP_CHAN_CONN_ORIENTED
&&
762 chan
->chan_type
!= L2CAP_CHAN_FIXED
&&
763 chan
->chan_type
!= L2CAP_CHAN_RAW
) {
768 sec
.level
= BT_SECURITY_LOW
;
770 len
= min_t(unsigned int, sizeof(sec
), optlen
);
771 if (copy_from_user((char *) &sec
, optval
, len
)) {
776 if (sec
.level
< BT_SECURITY_LOW
||
777 sec
.level
> BT_SECURITY_HIGH
) {
782 chan
->sec_level
= sec
.level
;
789 /*change security for LE channels */
790 if (chan
->scid
== L2CAP_CID_ATT
) {
791 if (smp_conn_security(conn
->hcon
, sec
.level
))
793 sk
->sk_state
= BT_CONFIG
;
794 chan
->state
= BT_CONFIG
;
796 /* or for ACL link */
797 } else if ((sk
->sk_state
== BT_CONNECT2
&&
798 test_bit(BT_SK_DEFER_SETUP
, &bt_sk(sk
)->flags
)) ||
799 sk
->sk_state
== BT_CONNECTED
) {
800 if (!l2cap_chan_check_security(chan
, true))
801 set_bit(BT_SK_SUSPEND
, &bt_sk(sk
)->flags
);
803 sk
->sk_state_change(sk
);
810 if (sk
->sk_state
!= BT_BOUND
&& sk
->sk_state
!= BT_LISTEN
) {
815 if (get_user(opt
, (u32 __user
*) optval
)) {
821 set_bit(BT_SK_DEFER_SETUP
, &bt_sk(sk
)->flags
);
822 set_bit(FLAG_DEFER_SETUP
, &chan
->flags
);
824 clear_bit(BT_SK_DEFER_SETUP
, &bt_sk(sk
)->flags
);
825 clear_bit(FLAG_DEFER_SETUP
, &chan
->flags
);
830 if (get_user(opt
, (u32 __user
*) optval
)) {
835 if (opt
> BT_FLUSHABLE_ON
) {
840 if (opt
== BT_FLUSHABLE_OFF
) {
842 /* proceed further only when we have l2cap_conn and
843 No Flush support in the LM */
844 if (!conn
|| !lmp_no_flush_capable(conn
->hcon
->hdev
)) {
851 set_bit(FLAG_FLUSHABLE
, &chan
->flags
);
853 clear_bit(FLAG_FLUSHABLE
, &chan
->flags
);
857 if (chan
->chan_type
!= L2CAP_CHAN_CONN_ORIENTED
&&
858 chan
->chan_type
!= L2CAP_CHAN_RAW
) {
863 pwr
.force_active
= BT_POWER_FORCE_ACTIVE_ON
;
865 len
= min_t(unsigned int, sizeof(pwr
), optlen
);
866 if (copy_from_user((char *) &pwr
, optval
, len
)) {
871 if (pwr
.force_active
)
872 set_bit(FLAG_FORCE_ACTIVE
, &chan
->flags
);
874 clear_bit(FLAG_FORCE_ACTIVE
, &chan
->flags
);
877 case BT_CHANNEL_POLICY
:
878 if (get_user(opt
, (u32 __user
*) optval
)) {
883 if (opt
> BT_CHANNEL_POLICY_AMP_PREFERRED
) {
888 if (chan
->mode
!= L2CAP_MODE_ERTM
&&
889 chan
->mode
!= L2CAP_MODE_STREAMING
) {
894 chan
->chan_policy
= (u8
) opt
;
896 if (sk
->sk_state
== BT_CONNECTED
&&
897 chan
->move_role
== L2CAP_MOVE_ROLE_NONE
)
898 l2cap_move_start(chan
);
903 if (!bdaddr_type_is_le(chan
->src_type
)) {
908 /* Setting is not supported as it's the remote side that
915 if (!bdaddr_type_is_le(chan
->src_type
)) {
920 if (sk
->sk_state
== BT_CONNECTED
) {
925 if (get_user(opt
, (u32 __user
*) optval
)) {
942 static int l2cap_sock_sendmsg(struct kiocb
*iocb
, struct socket
*sock
,
943 struct msghdr
*msg
, size_t len
)
945 struct sock
*sk
= sock
->sk
;
946 struct l2cap_chan
*chan
= l2cap_pi(sk
)->chan
;
949 BT_DBG("sock %p, sk %p", sock
, sk
);
951 err
= sock_error(sk
);
955 if (msg
->msg_flags
& MSG_OOB
)
958 if (sk
->sk_state
!= BT_CONNECTED
)
962 err
= bt_sock_wait_ready(sk
, msg
->msg_flags
);
967 l2cap_chan_lock(chan
);
968 err
= l2cap_chan_send(chan
, msg
, len
);
969 l2cap_chan_unlock(chan
);
974 static int l2cap_sock_recvmsg(struct kiocb
*iocb
, struct socket
*sock
,
975 struct msghdr
*msg
, size_t len
, int flags
)
977 struct sock
*sk
= sock
->sk
;
978 struct l2cap_pinfo
*pi
= l2cap_pi(sk
);
983 if (sk
->sk_state
== BT_CONNECT2
&& test_bit(BT_SK_DEFER_SETUP
,
984 &bt_sk(sk
)->flags
)) {
985 if (bdaddr_type_is_le(pi
->chan
->src_type
)) {
986 sk
->sk_state
= BT_CONNECTED
;
987 pi
->chan
->state
= BT_CONNECTED
;
988 __l2cap_le_connect_rsp_defer(pi
->chan
);
990 sk
->sk_state
= BT_CONFIG
;
991 pi
->chan
->state
= BT_CONFIG
;
992 __l2cap_connect_rsp_defer(pi
->chan
);
1001 if (sock
->type
== SOCK_STREAM
)
1002 err
= bt_sock_stream_recvmsg(iocb
, sock
, msg
, len
, flags
);
1004 err
= bt_sock_recvmsg(iocb
, sock
, msg
, len
, flags
);
1006 if (pi
->chan
->mode
!= L2CAP_MODE_ERTM
)
1009 /* Attempt to put pending rx data in the socket buffer */
1013 if (!test_bit(CONN_LOCAL_BUSY
, &pi
->chan
->conn_state
))
1016 if (pi
->rx_busy_skb
) {
1017 if (!sock_queue_rcv_skb(sk
, pi
->rx_busy_skb
))
1018 pi
->rx_busy_skb
= NULL
;
1023 /* Restore data flow when half of the receive buffer is
1024 * available. This avoids resending large numbers of
1027 if (atomic_read(&sk
->sk_rmem_alloc
) <= sk
->sk_rcvbuf
>> 1)
1028 l2cap_chan_busy(pi
->chan
, 0);
1035 /* Kill socket (only if zapped and orphan)
1036 * Must be called on unlocked socket.
1038 static void l2cap_sock_kill(struct sock
*sk
)
1040 if (!sock_flag(sk
, SOCK_ZAPPED
) || sk
->sk_socket
)
1043 BT_DBG("sk %p state %s", sk
, state_to_string(sk
->sk_state
));
1045 /* Kill poor orphan */
1047 l2cap_chan_put(l2cap_pi(sk
)->chan
);
1048 sock_set_flag(sk
, SOCK_DEAD
);
1052 static int __l2cap_wait_ack(struct sock
*sk
)
1054 struct l2cap_chan
*chan
= l2cap_pi(sk
)->chan
;
1055 DECLARE_WAITQUEUE(wait
, current
);
1059 add_wait_queue(sk_sleep(sk
), &wait
);
1060 set_current_state(TASK_INTERRUPTIBLE
);
1061 while (chan
->unacked_frames
> 0 && chan
->conn
) {
1065 if (signal_pending(current
)) {
1066 err
= sock_intr_errno(timeo
);
1071 timeo
= schedule_timeout(timeo
);
1073 set_current_state(TASK_INTERRUPTIBLE
);
1075 err
= sock_error(sk
);
1079 set_current_state(TASK_RUNNING
);
1080 remove_wait_queue(sk_sleep(sk
), &wait
);
1084 static int l2cap_sock_shutdown(struct socket
*sock
, int how
)
1086 struct sock
*sk
= sock
->sk
;
1087 struct l2cap_chan
*chan
;
1088 struct l2cap_conn
*conn
;
1091 BT_DBG("sock %p, sk %p", sock
, sk
);
1096 chan
= l2cap_pi(sk
)->chan
;
1100 mutex_lock(&conn
->chan_lock
);
1102 l2cap_chan_lock(chan
);
1105 if (!sk
->sk_shutdown
) {
1106 if (chan
->mode
== L2CAP_MODE_ERTM
)
1107 err
= __l2cap_wait_ack(sk
);
1109 sk
->sk_shutdown
= SHUTDOWN_MASK
;
1112 l2cap_chan_close(chan
, 0);
1115 if (sock_flag(sk
, SOCK_LINGER
) && sk
->sk_lingertime
&&
1116 !(current
->flags
& PF_EXITING
))
1117 err
= bt_sock_wait_state(sk
, BT_CLOSED
,
1121 if (!err
&& sk
->sk_err
)
1125 l2cap_chan_unlock(chan
);
1128 mutex_unlock(&conn
->chan_lock
);
1133 static int l2cap_sock_release(struct socket
*sock
)
1135 struct sock
*sk
= sock
->sk
;
1138 BT_DBG("sock %p, sk %p", sock
, sk
);
1143 bt_sock_unlink(&l2cap_sk_list
, sk
);
1145 err
= l2cap_sock_shutdown(sock
, 2);
1148 l2cap_sock_kill(sk
);
1152 static void l2cap_sock_cleanup_listen(struct sock
*parent
)
1156 BT_DBG("parent %p", parent
);
1158 /* Close not yet accepted channels */
1159 while ((sk
= bt_accept_dequeue(parent
, NULL
))) {
1160 struct l2cap_chan
*chan
= l2cap_pi(sk
)->chan
;
1162 l2cap_chan_lock(chan
);
1163 __clear_chan_timer(chan
);
1164 l2cap_chan_close(chan
, ECONNRESET
);
1165 l2cap_chan_unlock(chan
);
1167 l2cap_sock_kill(sk
);
1171 static struct l2cap_chan
*l2cap_sock_new_connection_cb(struct l2cap_chan
*chan
)
1173 struct sock
*sk
, *parent
= chan
->data
;
1177 /* Check for backlog size */
1178 if (sk_acceptq_is_full(parent
)) {
1179 BT_DBG("backlog full %d", parent
->sk_ack_backlog
);
1180 release_sock(parent
);
1184 sk
= l2cap_sock_alloc(sock_net(parent
), NULL
, BTPROTO_L2CAP
,
1187 release_sock(parent
);
1191 bt_sock_reclassify_lock(sk
, BTPROTO_L2CAP
);
1193 l2cap_sock_init(sk
, parent
);
1195 bt_accept_enqueue(parent
, sk
);
1197 release_sock(parent
);
1199 return l2cap_pi(sk
)->chan
;
1202 static int l2cap_sock_recv_cb(struct l2cap_chan
*chan
, struct sk_buff
*skb
)
1204 struct sock
*sk
= chan
->data
;
1209 if (l2cap_pi(sk
)->rx_busy_skb
) {
1214 err
= sock_queue_rcv_skb(sk
, skb
);
1216 /* For ERTM, handle one skb that doesn't fit into the recv
1217 * buffer. This is important to do because the data frames
1218 * have already been acked, so the skb cannot be discarded.
1220 * Notify the l2cap core that the buffer is full, so the
1221 * LOCAL_BUSY state is entered and no more frames are
1222 * acked and reassembled until there is buffer space
1225 if (err
< 0 && chan
->mode
== L2CAP_MODE_ERTM
) {
1226 l2cap_pi(sk
)->rx_busy_skb
= skb
;
1227 l2cap_chan_busy(chan
, 1);
1237 static void l2cap_sock_close_cb(struct l2cap_chan
*chan
)
1239 struct sock
*sk
= chan
->data
;
1241 l2cap_sock_kill(sk
);
1244 static void l2cap_sock_teardown_cb(struct l2cap_chan
*chan
, int err
)
1246 struct sock
*sk
= chan
->data
;
1247 struct sock
*parent
;
1251 parent
= bt_sk(sk
)->parent
;
1253 sock_set_flag(sk
, SOCK_ZAPPED
);
1255 switch (chan
->state
) {
1261 l2cap_sock_cleanup_listen(sk
);
1262 sk
->sk_state
= BT_CLOSED
;
1263 chan
->state
= BT_CLOSED
;
1267 sk
->sk_state
= BT_CLOSED
;
1268 chan
->state
= BT_CLOSED
;
1273 bt_accept_unlink(sk
);
1274 parent
->sk_data_ready(parent
);
1276 sk
->sk_state_change(sk
);
1285 static void l2cap_sock_state_change_cb(struct l2cap_chan
*chan
, int state
,
1288 struct sock
*sk
= chan
->data
;
1290 sk
->sk_state
= state
;
1296 static struct sk_buff
*l2cap_sock_alloc_skb_cb(struct l2cap_chan
*chan
,
1297 unsigned long hdr_len
,
1298 unsigned long len
, int nb
)
1300 struct sock
*sk
= chan
->data
;
1301 struct sk_buff
*skb
;
1304 l2cap_chan_unlock(chan
);
1305 skb
= bt_skb_send_alloc(sk
, hdr_len
+ len
, nb
, &err
);
1306 l2cap_chan_lock(chan
);
1309 return ERR_PTR(err
);
1311 skb
->priority
= sk
->sk_priority
;
1313 bt_cb(skb
)->chan
= chan
;
1318 static int l2cap_sock_memcpy_fromiovec_cb(struct l2cap_chan
*chan
,
1319 unsigned char *kdata
,
1320 struct iovec
*iov
, int len
)
1322 return memcpy_fromiovec(kdata
, iov
, len
);
1325 static void l2cap_sock_ready_cb(struct l2cap_chan
*chan
)
1327 struct sock
*sk
= chan
->data
;
1328 struct sock
*parent
;
1332 parent
= bt_sk(sk
)->parent
;
1334 BT_DBG("sk %p, parent %p", sk
, parent
);
1336 sk
->sk_state
= BT_CONNECTED
;
1337 sk
->sk_state_change(sk
);
1340 parent
->sk_data_ready(parent
);
1345 static void l2cap_sock_defer_cb(struct l2cap_chan
*chan
)
1347 struct sock
*parent
, *sk
= chan
->data
;
1351 parent
= bt_sk(sk
)->parent
;
1353 parent
->sk_data_ready(parent
);
1358 static void l2cap_sock_resume_cb(struct l2cap_chan
*chan
)
1360 struct sock
*sk
= chan
->data
;
1362 clear_bit(BT_SK_SUSPEND
, &bt_sk(sk
)->flags
);
1363 sk
->sk_state_change(sk
);
1366 static void l2cap_sock_set_shutdown_cb(struct l2cap_chan
*chan
)
1368 struct sock
*sk
= chan
->data
;
1371 sk
->sk_shutdown
= SHUTDOWN_MASK
;
1375 static long l2cap_sock_get_sndtimeo_cb(struct l2cap_chan
*chan
)
1377 struct sock
*sk
= chan
->data
;
1379 return sk
->sk_sndtimeo
;
1382 static void l2cap_sock_suspend_cb(struct l2cap_chan
*chan
)
1384 struct sock
*sk
= chan
->data
;
1386 set_bit(BT_SK_SUSPEND
, &bt_sk(sk
)->flags
);
1387 sk
->sk_state_change(sk
);
1390 static const struct l2cap_ops l2cap_chan_ops
= {
1391 .name
= "L2CAP Socket Interface",
1392 .new_connection
= l2cap_sock_new_connection_cb
,
1393 .recv
= l2cap_sock_recv_cb
,
1394 .close
= l2cap_sock_close_cb
,
1395 .teardown
= l2cap_sock_teardown_cb
,
1396 .state_change
= l2cap_sock_state_change_cb
,
1397 .ready
= l2cap_sock_ready_cb
,
1398 .defer
= l2cap_sock_defer_cb
,
1399 .resume
= l2cap_sock_resume_cb
,
1400 .suspend
= l2cap_sock_suspend_cb
,
1401 .set_shutdown
= l2cap_sock_set_shutdown_cb
,
1402 .get_sndtimeo
= l2cap_sock_get_sndtimeo_cb
,
1403 .alloc_skb
= l2cap_sock_alloc_skb_cb
,
1404 .memcpy_fromiovec
= l2cap_sock_memcpy_fromiovec_cb
,
1407 static void l2cap_sock_destruct(struct sock
*sk
)
1409 BT_DBG("sk %p", sk
);
1411 if (l2cap_pi(sk
)->chan
)
1412 l2cap_chan_put(l2cap_pi(sk
)->chan
);
1414 if (l2cap_pi(sk
)->rx_busy_skb
) {
1415 kfree_skb(l2cap_pi(sk
)->rx_busy_skb
);
1416 l2cap_pi(sk
)->rx_busy_skb
= NULL
;
1419 skb_queue_purge(&sk
->sk_receive_queue
);
1420 skb_queue_purge(&sk
->sk_write_queue
);
1423 static void l2cap_skb_msg_name(struct sk_buff
*skb
, void *msg_name
,
1426 DECLARE_SOCKADDR(struct sockaddr_l2
*, la
, msg_name
);
1428 memset(la
, 0, sizeof(struct sockaddr_l2
));
1429 la
->l2_family
= AF_BLUETOOTH
;
1430 la
->l2_psm
= bt_cb(skb
)->psm
;
1431 bacpy(&la
->l2_bdaddr
, &bt_cb(skb
)->bdaddr
);
1433 *msg_namelen
= sizeof(struct sockaddr_l2
);
1436 static void l2cap_sock_init(struct sock
*sk
, struct sock
*parent
)
1438 struct l2cap_chan
*chan
= l2cap_pi(sk
)->chan
;
1440 BT_DBG("sk %p", sk
);
1443 struct l2cap_chan
*pchan
= l2cap_pi(parent
)->chan
;
1445 sk
->sk_type
= parent
->sk_type
;
1446 bt_sk(sk
)->flags
= bt_sk(parent
)->flags
;
1448 chan
->chan_type
= pchan
->chan_type
;
1449 chan
->imtu
= pchan
->imtu
;
1450 chan
->omtu
= pchan
->omtu
;
1451 chan
->conf_state
= pchan
->conf_state
;
1452 chan
->mode
= pchan
->mode
;
1453 chan
->fcs
= pchan
->fcs
;
1454 chan
->max_tx
= pchan
->max_tx
;
1455 chan
->tx_win
= pchan
->tx_win
;
1456 chan
->tx_win_max
= pchan
->tx_win_max
;
1457 chan
->sec_level
= pchan
->sec_level
;
1458 chan
->flags
= pchan
->flags
;
1459 chan
->tx_credits
= pchan
->tx_credits
;
1460 chan
->rx_credits
= pchan
->rx_credits
;
1462 if (chan
->chan_type
== L2CAP_CHAN_FIXED
) {
1463 chan
->scid
= pchan
->scid
;
1464 chan
->dcid
= pchan
->scid
;
1467 security_sk_clone(parent
, sk
);
1469 switch (sk
->sk_type
) {
1471 chan
->chan_type
= L2CAP_CHAN_RAW
;
1474 chan
->chan_type
= L2CAP_CHAN_CONN_LESS
;
1475 bt_sk(sk
)->skb_msg_name
= l2cap_skb_msg_name
;
1477 case SOCK_SEQPACKET
:
1479 chan
->chan_type
= L2CAP_CHAN_CONN_ORIENTED
;
1483 chan
->imtu
= L2CAP_DEFAULT_MTU
;
1485 if (!disable_ertm
&& sk
->sk_type
== SOCK_STREAM
) {
1486 chan
->mode
= L2CAP_MODE_ERTM
;
1487 set_bit(CONF_STATE2_DEVICE
, &chan
->conf_state
);
1489 chan
->mode
= L2CAP_MODE_BASIC
;
1492 l2cap_chan_set_defaults(chan
);
1495 /* Default config options */
1496 chan
->flush_to
= L2CAP_DEFAULT_FLUSH_TO
;
1499 chan
->ops
= &l2cap_chan_ops
;
1502 static struct proto l2cap_proto
= {
1504 .owner
= THIS_MODULE
,
1505 .obj_size
= sizeof(struct l2cap_pinfo
)
1508 static struct sock
*l2cap_sock_alloc(struct net
*net
, struct socket
*sock
,
1509 int proto
, gfp_t prio
)
1512 struct l2cap_chan
*chan
;
1514 sk
= sk_alloc(net
, PF_BLUETOOTH
, prio
, &l2cap_proto
);
1518 sock_init_data(sock
, sk
);
1519 INIT_LIST_HEAD(&bt_sk(sk
)->accept_q
);
1521 sk
->sk_destruct
= l2cap_sock_destruct
;
1522 sk
->sk_sndtimeo
= L2CAP_CONN_TIMEOUT
;
1524 sock_reset_flag(sk
, SOCK_ZAPPED
);
1526 sk
->sk_protocol
= proto
;
1527 sk
->sk_state
= BT_OPEN
;
1529 chan
= l2cap_chan_create();
1535 l2cap_chan_hold(chan
);
1537 l2cap_pi(sk
)->chan
= chan
;
1542 static int l2cap_sock_create(struct net
*net
, struct socket
*sock
, int protocol
,
1547 BT_DBG("sock %p", sock
);
1549 sock
->state
= SS_UNCONNECTED
;
1551 if (sock
->type
!= SOCK_SEQPACKET
&& sock
->type
!= SOCK_STREAM
&&
1552 sock
->type
!= SOCK_DGRAM
&& sock
->type
!= SOCK_RAW
)
1553 return -ESOCKTNOSUPPORT
;
1555 if (sock
->type
== SOCK_RAW
&& !kern
&& !capable(CAP_NET_RAW
))
1558 sock
->ops
= &l2cap_sock_ops
;
1560 sk
= l2cap_sock_alloc(net
, sock
, protocol
, GFP_ATOMIC
);
1564 l2cap_sock_init(sk
, NULL
);
1565 bt_sock_link(&l2cap_sk_list
, sk
);
1569 static const struct proto_ops l2cap_sock_ops
= {
1570 .family
= PF_BLUETOOTH
,
1571 .owner
= THIS_MODULE
,
1572 .release
= l2cap_sock_release
,
1573 .bind
= l2cap_sock_bind
,
1574 .connect
= l2cap_sock_connect
,
1575 .listen
= l2cap_sock_listen
,
1576 .accept
= l2cap_sock_accept
,
1577 .getname
= l2cap_sock_getname
,
1578 .sendmsg
= l2cap_sock_sendmsg
,
1579 .recvmsg
= l2cap_sock_recvmsg
,
1580 .poll
= bt_sock_poll
,
1581 .ioctl
= bt_sock_ioctl
,
1582 .mmap
= sock_no_mmap
,
1583 .socketpair
= sock_no_socketpair
,
1584 .shutdown
= l2cap_sock_shutdown
,
1585 .setsockopt
= l2cap_sock_setsockopt
,
1586 .getsockopt
= l2cap_sock_getsockopt
1589 static const struct net_proto_family l2cap_sock_family_ops
= {
1590 .family
= PF_BLUETOOTH
,
1591 .owner
= THIS_MODULE
,
1592 .create
= l2cap_sock_create
,
1595 int __init
l2cap_init_sockets(void)
1599 err
= proto_register(&l2cap_proto
, 0);
1603 err
= bt_sock_register(BTPROTO_L2CAP
, &l2cap_sock_family_ops
);
1605 BT_ERR("L2CAP socket registration failed");
1609 err
= bt_procfs_init(&init_net
, "l2cap", &l2cap_sk_list
,
1612 BT_ERR("Failed to create L2CAP proc file");
1613 bt_sock_unregister(BTPROTO_L2CAP
);
1617 BT_INFO("L2CAP socket layer initialized");
1622 proto_unregister(&l2cap_proto
);
1626 void l2cap_cleanup_sockets(void)
1628 bt_procfs_cleanup(&init_net
, "l2cap");
1629 bt_sock_unregister(BTPROTO_L2CAP
);
1630 proto_unregister(&l2cap_proto
);