2 RFCOMM implementation for Linux Bluetooth stack (BlueZ).
3 Copyright (C) 2002 Maxim Krasnyansky <maxk@qualcomm.com>
4 Copyright (C) 2002 Marcel Holtmann <marcel@holtmann.org>
6 This program is free software; you can redistribute it and/or modify
7 it under the terms of the GNU General Public License version 2 as
8 published by the Free Software Foundation;
10 THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
11 OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
12 FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT OF THIRD PARTY RIGHTS.
13 IN NO EVENT SHALL THE COPYRIGHT HOLDER(S) AND AUTHOR(S) BE LIABLE FOR ANY
14 CLAIM, OR ANY SPECIAL INDIRECT OR CONSEQUENTIAL DAMAGES, OR ANY DAMAGES
15 WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
16 ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
17 OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
19 ALL LIABILITY, INCLUDING LIABILITY FOR INFRINGEMENT OF ANY PATENTS,
20 COPYRIGHTS, TRADEMARKS OR OTHER RIGHTS, RELATING TO USE OF THIS
21 SOFTWARE IS DISCLAIMED.
28 #include <linux/export.h>
29 #include <linux/debugfs.h>
31 #include <net/bluetooth/bluetooth.h>
32 #include <net/bluetooth/hci_core.h>
33 #include <net/bluetooth/l2cap.h>
34 #include <net/bluetooth/rfcomm.h>
36 static const struct proto_ops rfcomm_sock_ops
;
38 static struct bt_sock_list rfcomm_sk_list
= {
39 .lock
= __RW_LOCK_UNLOCKED(rfcomm_sk_list
.lock
)
42 static void rfcomm_sock_close(struct sock
*sk
);
43 static void rfcomm_sock_kill(struct sock
*sk
);
45 /* ---- DLC callbacks ----
47 * called under rfcomm_dlc_lock()
49 static void rfcomm_sk_data_ready(struct rfcomm_dlc
*d
, struct sk_buff
*skb
)
51 struct sock
*sk
= d
->owner
;
55 atomic_add(skb
->len
, &sk
->sk_rmem_alloc
);
56 skb_queue_tail(&sk
->sk_receive_queue
, skb
);
57 sk
->sk_data_ready(sk
);
59 if (atomic_read(&sk
->sk_rmem_alloc
) >= sk
->sk_rcvbuf
)
60 rfcomm_dlc_throttle(d
);
63 static void rfcomm_sk_state_change(struct rfcomm_dlc
*d
, int err
)
65 struct sock
*sk
= d
->owner
, *parent
;
71 BT_DBG("dlc %p state %ld err %d", d
, d
->state
, err
);
73 local_irq_save(flags
);
79 sk
->sk_state
= d
->state
;
81 parent
= bt_sk(sk
)->parent
;
83 if (d
->state
== BT_CLOSED
) {
84 sock_set_flag(sk
, SOCK_ZAPPED
);
87 parent
->sk_data_ready(parent
);
89 if (d
->state
== BT_CONNECTED
)
90 rfcomm_session_getaddr(d
->session
,
91 &rfcomm_pi(sk
)->src
, NULL
);
92 sk
->sk_state_change(sk
);
96 local_irq_restore(flags
);
98 if (parent
&& sock_flag(sk
, SOCK_ZAPPED
)) {
99 /* We have to drop DLC lock here, otherwise
100 * rfcomm_sock_destruct() will dead lock. */
101 rfcomm_dlc_unlock(d
);
102 rfcomm_sock_kill(sk
);
107 /* ---- Socket functions ---- */
108 static struct sock
*__rfcomm_get_listen_sock_by_addr(u8 channel
, bdaddr_t
*src
)
110 struct sock
*sk
= NULL
;
112 sk_for_each(sk
, &rfcomm_sk_list
.head
) {
113 if (rfcomm_pi(sk
)->channel
!= channel
)
116 if (bacmp(&rfcomm_pi(sk
)->src
, src
))
119 if (sk
->sk_state
== BT_BOUND
|| sk
->sk_state
== BT_LISTEN
)
123 return sk
? sk
: NULL
;
126 /* Find socket with channel and source bdaddr.
127 * Returns closest match.
129 static struct sock
*rfcomm_get_sock_by_channel(int state
, u8 channel
, bdaddr_t
*src
)
131 struct sock
*sk
= NULL
, *sk1
= NULL
;
133 read_lock(&rfcomm_sk_list
.lock
);
135 sk_for_each(sk
, &rfcomm_sk_list
.head
) {
136 if (state
&& sk
->sk_state
!= state
)
139 if (rfcomm_pi(sk
)->channel
== channel
) {
141 if (!bacmp(&rfcomm_pi(sk
)->src
, src
))
145 if (!bacmp(&rfcomm_pi(sk
)->src
, BDADDR_ANY
))
150 read_unlock(&rfcomm_sk_list
.lock
);
152 return sk
? sk
: sk1
;
155 static void rfcomm_sock_destruct(struct sock
*sk
)
157 struct rfcomm_dlc
*d
= rfcomm_pi(sk
)->dlc
;
159 BT_DBG("sk %p dlc %p", sk
, d
);
161 skb_queue_purge(&sk
->sk_receive_queue
);
162 skb_queue_purge(&sk
->sk_write_queue
);
165 rfcomm_pi(sk
)->dlc
= NULL
;
167 /* Detach DLC if it's owned by this socket */
170 rfcomm_dlc_unlock(d
);
175 static void rfcomm_sock_cleanup_listen(struct sock
*parent
)
179 BT_DBG("parent %p", parent
);
181 /* Close not yet accepted dlcs */
182 while ((sk
= bt_accept_dequeue(parent
, NULL
))) {
183 rfcomm_sock_close(sk
);
184 rfcomm_sock_kill(sk
);
187 parent
->sk_state
= BT_CLOSED
;
188 sock_set_flag(parent
, SOCK_ZAPPED
);
191 /* Kill socket (only if zapped and orphan)
192 * Must be called on unlocked socket.
194 static void rfcomm_sock_kill(struct sock
*sk
)
196 if (!sock_flag(sk
, SOCK_ZAPPED
) || sk
->sk_socket
)
199 BT_DBG("sk %p state %d refcnt %d", sk
, sk
->sk_state
, atomic_read(&sk
->sk_refcnt
));
201 /* Kill poor orphan */
202 bt_sock_unlink(&rfcomm_sk_list
, sk
);
203 sock_set_flag(sk
, SOCK_DEAD
);
207 static void __rfcomm_sock_close(struct sock
*sk
)
209 struct rfcomm_dlc
*d
= rfcomm_pi(sk
)->dlc
;
211 BT_DBG("sk %p state %d socket %p", sk
, sk
->sk_state
, sk
->sk_socket
);
213 switch (sk
->sk_state
) {
215 rfcomm_sock_cleanup_listen(sk
);
222 rfcomm_dlc_close(d
, 0);
225 sock_set_flag(sk
, SOCK_ZAPPED
);
231 * Must be called on unlocked socket.
233 static void rfcomm_sock_close(struct sock
*sk
)
236 __rfcomm_sock_close(sk
);
240 static void rfcomm_sock_init(struct sock
*sk
, struct sock
*parent
)
242 struct rfcomm_pinfo
*pi
= rfcomm_pi(sk
);
247 sk
->sk_type
= parent
->sk_type
;
248 pi
->dlc
->defer_setup
= test_bit(BT_SK_DEFER_SETUP
,
249 &bt_sk(parent
)->flags
);
251 pi
->sec_level
= rfcomm_pi(parent
)->sec_level
;
252 pi
->role_switch
= rfcomm_pi(parent
)->role_switch
;
254 security_sk_clone(parent
, sk
);
256 pi
->dlc
->defer_setup
= 0;
258 pi
->sec_level
= BT_SECURITY_LOW
;
262 pi
->dlc
->sec_level
= pi
->sec_level
;
263 pi
->dlc
->role_switch
= pi
->role_switch
;
266 static struct proto rfcomm_proto
= {
268 .owner
= THIS_MODULE
,
269 .obj_size
= sizeof(struct rfcomm_pinfo
)
272 static struct sock
*rfcomm_sock_alloc(struct net
*net
, struct socket
*sock
, int proto
, gfp_t prio
)
274 struct rfcomm_dlc
*d
;
277 sk
= sk_alloc(net
, PF_BLUETOOTH
, prio
, &rfcomm_proto
);
281 sock_init_data(sock
, sk
);
282 INIT_LIST_HEAD(&bt_sk(sk
)->accept_q
);
284 d
= rfcomm_dlc_alloc(prio
);
290 d
->data_ready
= rfcomm_sk_data_ready
;
291 d
->state_change
= rfcomm_sk_state_change
;
293 rfcomm_pi(sk
)->dlc
= d
;
296 sk
->sk_destruct
= rfcomm_sock_destruct
;
297 sk
->sk_sndtimeo
= RFCOMM_CONN_TIMEOUT
;
299 sk
->sk_sndbuf
= RFCOMM_MAX_CREDITS
* RFCOMM_DEFAULT_MTU
* 10;
300 sk
->sk_rcvbuf
= RFCOMM_MAX_CREDITS
* RFCOMM_DEFAULT_MTU
* 10;
302 sock_reset_flag(sk
, SOCK_ZAPPED
);
304 sk
->sk_protocol
= proto
;
305 sk
->sk_state
= BT_OPEN
;
307 bt_sock_link(&rfcomm_sk_list
, sk
);
313 static int rfcomm_sock_create(struct net
*net
, struct socket
*sock
,
314 int protocol
, int kern
)
318 BT_DBG("sock %p", sock
);
320 sock
->state
= SS_UNCONNECTED
;
322 if (sock
->type
!= SOCK_STREAM
&& sock
->type
!= SOCK_RAW
)
323 return -ESOCKTNOSUPPORT
;
325 sock
->ops
= &rfcomm_sock_ops
;
327 sk
= rfcomm_sock_alloc(net
, sock
, protocol
, GFP_ATOMIC
);
331 rfcomm_sock_init(sk
, NULL
);
335 static int rfcomm_sock_bind(struct socket
*sock
, struct sockaddr
*addr
, int addr_len
)
337 struct sockaddr_rc
*sa
= (struct sockaddr_rc
*) addr
;
338 struct sock
*sk
= sock
->sk
;
339 int chan
= sa
->rc_channel
;
342 BT_DBG("sk %p %pMR", sk
, &sa
->rc_bdaddr
);
344 if (!addr
|| addr
->sa_family
!= AF_BLUETOOTH
)
349 if (sk
->sk_state
!= BT_OPEN
) {
354 if (sk
->sk_type
!= SOCK_STREAM
) {
359 write_lock(&rfcomm_sk_list
.lock
);
361 if (chan
&& __rfcomm_get_listen_sock_by_addr(chan
, &sa
->rc_bdaddr
)) {
364 /* Save source address */
365 bacpy(&rfcomm_pi(sk
)->src
, &sa
->rc_bdaddr
);
366 rfcomm_pi(sk
)->channel
= chan
;
367 sk
->sk_state
= BT_BOUND
;
370 write_unlock(&rfcomm_sk_list
.lock
);
377 static int rfcomm_sock_connect(struct socket
*sock
, struct sockaddr
*addr
, int alen
, int flags
)
379 struct sockaddr_rc
*sa
= (struct sockaddr_rc
*) addr
;
380 struct sock
*sk
= sock
->sk
;
381 struct rfcomm_dlc
*d
= rfcomm_pi(sk
)->dlc
;
386 if (alen
< sizeof(struct sockaddr_rc
) ||
387 addr
->sa_family
!= AF_BLUETOOTH
)
392 if (sk
->sk_state
!= BT_OPEN
&& sk
->sk_state
!= BT_BOUND
) {
397 if (sk
->sk_type
!= SOCK_STREAM
) {
402 sk
->sk_state
= BT_CONNECT
;
403 bacpy(&rfcomm_pi(sk
)->dst
, &sa
->rc_bdaddr
);
404 rfcomm_pi(sk
)->channel
= sa
->rc_channel
;
406 d
->sec_level
= rfcomm_pi(sk
)->sec_level
;
407 d
->role_switch
= rfcomm_pi(sk
)->role_switch
;
409 err
= rfcomm_dlc_open(d
, &rfcomm_pi(sk
)->src
, &sa
->rc_bdaddr
,
412 err
= bt_sock_wait_state(sk
, BT_CONNECTED
,
413 sock_sndtimeo(sk
, flags
& O_NONBLOCK
));
420 static int rfcomm_sock_listen(struct socket
*sock
, int backlog
)
422 struct sock
*sk
= sock
->sk
;
425 BT_DBG("sk %p backlog %d", sk
, backlog
);
429 if (sk
->sk_state
!= BT_BOUND
) {
434 if (sk
->sk_type
!= SOCK_STREAM
) {
439 if (!rfcomm_pi(sk
)->channel
) {
440 bdaddr_t
*src
= &rfcomm_pi(sk
)->src
;
445 write_lock(&rfcomm_sk_list
.lock
);
447 for (channel
= 1; channel
< 31; channel
++)
448 if (!__rfcomm_get_listen_sock_by_addr(channel
, src
)) {
449 rfcomm_pi(sk
)->channel
= channel
;
454 write_unlock(&rfcomm_sk_list
.lock
);
460 sk
->sk_max_ack_backlog
= backlog
;
461 sk
->sk_ack_backlog
= 0;
462 sk
->sk_state
= BT_LISTEN
;
469 static int rfcomm_sock_accept(struct socket
*sock
, struct socket
*newsock
, int flags
)
471 DECLARE_WAITQUEUE(wait
, current
);
472 struct sock
*sk
= sock
->sk
, *nsk
;
476 lock_sock_nested(sk
, SINGLE_DEPTH_NESTING
);
478 if (sk
->sk_type
!= SOCK_STREAM
) {
483 timeo
= sock_rcvtimeo(sk
, flags
& O_NONBLOCK
);
485 BT_DBG("sk %p timeo %ld", sk
, timeo
);
487 /* Wait for an incoming connection. (wake-one). */
488 add_wait_queue_exclusive(sk_sleep(sk
), &wait
);
490 set_current_state(TASK_INTERRUPTIBLE
);
492 if (sk
->sk_state
!= BT_LISTEN
) {
497 nsk
= bt_accept_dequeue(sk
, newsock
);
506 if (signal_pending(current
)) {
507 err
= sock_intr_errno(timeo
);
512 timeo
= schedule_timeout(timeo
);
513 lock_sock_nested(sk
, SINGLE_DEPTH_NESTING
);
515 __set_current_state(TASK_RUNNING
);
516 remove_wait_queue(sk_sleep(sk
), &wait
);
521 newsock
->state
= SS_CONNECTED
;
523 BT_DBG("new socket %p", nsk
);
530 static int rfcomm_sock_getname(struct socket
*sock
, struct sockaddr
*addr
, int *len
, int peer
)
532 struct sockaddr_rc
*sa
= (struct sockaddr_rc
*) addr
;
533 struct sock
*sk
= sock
->sk
;
535 BT_DBG("sock %p, sk %p", sock
, sk
);
537 if (peer
&& sk
->sk_state
!= BT_CONNECTED
&&
538 sk
->sk_state
!= BT_CONNECT
&& sk
->sk_state
!= BT_CONNECT2
)
541 memset(sa
, 0, sizeof(*sa
));
542 sa
->rc_family
= AF_BLUETOOTH
;
543 sa
->rc_channel
= rfcomm_pi(sk
)->channel
;
545 bacpy(&sa
->rc_bdaddr
, &rfcomm_pi(sk
)->dst
);
547 bacpy(&sa
->rc_bdaddr
, &rfcomm_pi(sk
)->src
);
549 *len
= sizeof(struct sockaddr_rc
);
553 static int rfcomm_sock_sendmsg(struct kiocb
*iocb
, struct socket
*sock
,
554 struct msghdr
*msg
, size_t len
)
556 struct sock
*sk
= sock
->sk
;
557 struct rfcomm_dlc
*d
= rfcomm_pi(sk
)->dlc
;
561 if (test_bit(RFCOMM_DEFER_SETUP
, &d
->flags
))
564 if (msg
->msg_flags
& MSG_OOB
)
567 if (sk
->sk_shutdown
& SEND_SHUTDOWN
)
570 BT_DBG("sock %p, sk %p", sock
, sk
);
574 sent
= bt_sock_wait_ready(sk
, msg
->msg_flags
);
579 size_t size
= min_t(size_t, len
, d
->mtu
);
582 skb
= sock_alloc_send_skb(sk
, size
+ RFCOMM_SKB_RESERVE
,
583 msg
->msg_flags
& MSG_DONTWAIT
, &err
);
589 skb_reserve(skb
, RFCOMM_SKB_HEAD_RESERVE
);
591 err
= memcpy_fromiovec(skb_put(skb
, size
), msg
->msg_iov
, size
);
599 skb
->priority
= sk
->sk_priority
;
601 err
= rfcomm_dlc_send(d
, skb
);
619 static int rfcomm_sock_recvmsg(struct kiocb
*iocb
, struct socket
*sock
,
620 struct msghdr
*msg
, size_t size
, int flags
)
622 struct sock
*sk
= sock
->sk
;
623 struct rfcomm_dlc
*d
= rfcomm_pi(sk
)->dlc
;
626 if (test_and_clear_bit(RFCOMM_DEFER_SETUP
, &d
->flags
)) {
627 rfcomm_dlc_accept(d
);
631 len
= bt_sock_stream_recvmsg(iocb
, sock
, msg
, size
, flags
);
634 if (!(flags
& MSG_PEEK
) && len
> 0)
635 atomic_sub(len
, &sk
->sk_rmem_alloc
);
637 if (atomic_read(&sk
->sk_rmem_alloc
) <= (sk
->sk_rcvbuf
>> 2))
638 rfcomm_dlc_unthrottle(rfcomm_pi(sk
)->dlc
);
644 static int rfcomm_sock_setsockopt_old(struct socket
*sock
, int optname
, char __user
*optval
, unsigned int optlen
)
646 struct sock
*sk
= sock
->sk
;
656 if (get_user(opt
, (u32 __user
*) optval
)) {
661 if (opt
& RFCOMM_LM_FIPS
) {
666 if (opt
& RFCOMM_LM_AUTH
)
667 rfcomm_pi(sk
)->sec_level
= BT_SECURITY_LOW
;
668 if (opt
& RFCOMM_LM_ENCRYPT
)
669 rfcomm_pi(sk
)->sec_level
= BT_SECURITY_MEDIUM
;
670 if (opt
& RFCOMM_LM_SECURE
)
671 rfcomm_pi(sk
)->sec_level
= BT_SECURITY_HIGH
;
673 rfcomm_pi(sk
)->role_switch
= (opt
& RFCOMM_LM_MASTER
);
685 static int rfcomm_sock_setsockopt(struct socket
*sock
, int level
, int optname
, char __user
*optval
, unsigned int optlen
)
687 struct sock
*sk
= sock
->sk
;
688 struct bt_security sec
;
695 if (level
== SOL_RFCOMM
)
696 return rfcomm_sock_setsockopt_old(sock
, optname
, optval
, optlen
);
698 if (level
!= SOL_BLUETOOTH
)
705 if (sk
->sk_type
!= SOCK_STREAM
) {
710 sec
.level
= BT_SECURITY_LOW
;
712 len
= min_t(unsigned int, sizeof(sec
), optlen
);
713 if (copy_from_user((char *) &sec
, optval
, len
)) {
718 if (sec
.level
> BT_SECURITY_HIGH
) {
723 rfcomm_pi(sk
)->sec_level
= sec
.level
;
727 if (sk
->sk_state
!= BT_BOUND
&& sk
->sk_state
!= BT_LISTEN
) {
732 if (get_user(opt
, (u32 __user
*) optval
)) {
738 set_bit(BT_SK_DEFER_SETUP
, &bt_sk(sk
)->flags
);
740 clear_bit(BT_SK_DEFER_SETUP
, &bt_sk(sk
)->flags
);
753 static int rfcomm_sock_getsockopt_old(struct socket
*sock
, int optname
, char __user
*optval
, int __user
*optlen
)
755 struct sock
*sk
= sock
->sk
;
756 struct sock
*l2cap_sk
;
757 struct l2cap_conn
*conn
;
758 struct rfcomm_conninfo cinfo
;
764 if (get_user(len
, optlen
))
771 switch (rfcomm_pi(sk
)->sec_level
) {
772 case BT_SECURITY_LOW
:
773 opt
= RFCOMM_LM_AUTH
;
775 case BT_SECURITY_MEDIUM
:
776 opt
= RFCOMM_LM_AUTH
| RFCOMM_LM_ENCRYPT
;
778 case BT_SECURITY_HIGH
:
779 opt
= RFCOMM_LM_AUTH
| RFCOMM_LM_ENCRYPT
|
782 case BT_SECURITY_FIPS
:
783 opt
= RFCOMM_LM_AUTH
| RFCOMM_LM_ENCRYPT
|
784 RFCOMM_LM_SECURE
| RFCOMM_LM_FIPS
;
791 if (rfcomm_pi(sk
)->role_switch
)
792 opt
|= RFCOMM_LM_MASTER
;
794 if (put_user(opt
, (u32 __user
*) optval
))
799 case RFCOMM_CONNINFO
:
800 if (sk
->sk_state
!= BT_CONNECTED
&&
801 !rfcomm_pi(sk
)->dlc
->defer_setup
) {
806 l2cap_sk
= rfcomm_pi(sk
)->dlc
->session
->sock
->sk
;
807 conn
= l2cap_pi(l2cap_sk
)->chan
->conn
;
809 memset(&cinfo
, 0, sizeof(cinfo
));
810 cinfo
.hci_handle
= conn
->hcon
->handle
;
811 memcpy(cinfo
.dev_class
, conn
->hcon
->dev_class
, 3);
813 len
= min_t(unsigned int, len
, sizeof(cinfo
));
814 if (copy_to_user(optval
, (char *) &cinfo
, len
))
828 static int rfcomm_sock_getsockopt(struct socket
*sock
, int level
, int optname
, char __user
*optval
, int __user
*optlen
)
830 struct sock
*sk
= sock
->sk
;
831 struct bt_security sec
;
836 if (level
== SOL_RFCOMM
)
837 return rfcomm_sock_getsockopt_old(sock
, optname
, optval
, optlen
);
839 if (level
!= SOL_BLUETOOTH
)
842 if (get_user(len
, optlen
))
849 if (sk
->sk_type
!= SOCK_STREAM
) {
854 sec
.level
= rfcomm_pi(sk
)->sec_level
;
857 len
= min_t(unsigned int, len
, sizeof(sec
));
858 if (copy_to_user(optval
, (char *) &sec
, len
))
864 if (sk
->sk_state
!= BT_BOUND
&& sk
->sk_state
!= BT_LISTEN
) {
869 if (put_user(test_bit(BT_SK_DEFER_SETUP
, &bt_sk(sk
)->flags
),
870 (u32 __user
*) optval
))
884 static int rfcomm_sock_ioctl(struct socket
*sock
, unsigned int cmd
, unsigned long arg
)
886 struct sock
*sk __maybe_unused
= sock
->sk
;
889 BT_DBG("sk %p cmd %x arg %lx", sk
, cmd
, arg
);
891 err
= bt_sock_ioctl(sock
, cmd
, arg
);
893 if (err
== -ENOIOCTLCMD
) {
894 #ifdef CONFIG_BT_RFCOMM_TTY
896 err
= rfcomm_dev_ioctl(sk
, cmd
, (void __user
*) arg
);
906 static int rfcomm_sock_shutdown(struct socket
*sock
, int how
)
908 struct sock
*sk
= sock
->sk
;
911 BT_DBG("sock %p, sk %p", sock
, sk
);
917 if (!sk
->sk_shutdown
) {
918 sk
->sk_shutdown
= SHUTDOWN_MASK
;
919 __rfcomm_sock_close(sk
);
921 if (sock_flag(sk
, SOCK_LINGER
) && sk
->sk_lingertime
)
922 err
= bt_sock_wait_state(sk
, BT_CLOSED
, sk
->sk_lingertime
);
928 static int rfcomm_sock_release(struct socket
*sock
)
930 struct sock
*sk
= sock
->sk
;
933 BT_DBG("sock %p, sk %p", sock
, sk
);
938 err
= rfcomm_sock_shutdown(sock
, 2);
941 rfcomm_sock_kill(sk
);
945 /* ---- RFCOMM core layer callbacks ----
947 * called under rfcomm_lock()
949 int rfcomm_connect_ind(struct rfcomm_session
*s
, u8 channel
, struct rfcomm_dlc
**d
)
951 struct sock
*sk
, *parent
;
955 BT_DBG("session %p channel %d", s
, channel
);
957 rfcomm_session_getaddr(s
, &src
, &dst
);
959 /* Check if we have socket listening on channel */
960 parent
= rfcomm_get_sock_by_channel(BT_LISTEN
, channel
, &src
);
964 bh_lock_sock(parent
);
966 /* Check for backlog size */
967 if (sk_acceptq_is_full(parent
)) {
968 BT_DBG("backlog full %d", parent
->sk_ack_backlog
);
972 sk
= rfcomm_sock_alloc(sock_net(parent
), NULL
, BTPROTO_RFCOMM
, GFP_ATOMIC
);
976 bt_sock_reclassify_lock(sk
, BTPROTO_RFCOMM
);
978 rfcomm_sock_init(sk
, parent
);
979 bacpy(&rfcomm_pi(sk
)->src
, &src
);
980 bacpy(&rfcomm_pi(sk
)->dst
, &dst
);
981 rfcomm_pi(sk
)->channel
= channel
;
983 sk
->sk_state
= BT_CONFIG
;
984 bt_accept_enqueue(parent
, sk
);
986 /* Accept connection and return socket DLC */
987 *d
= rfcomm_pi(sk
)->dlc
;
991 bh_unlock_sock(parent
);
993 if (test_bit(BT_SK_DEFER_SETUP
, &bt_sk(parent
)->flags
))
994 parent
->sk_state_change(parent
);
999 static int rfcomm_sock_debugfs_show(struct seq_file
*f
, void *p
)
1003 read_lock(&rfcomm_sk_list
.lock
);
1005 sk_for_each(sk
, &rfcomm_sk_list
.head
) {
1006 seq_printf(f
, "%pMR %pMR %d %d\n",
1007 &rfcomm_pi(sk
)->src
, &rfcomm_pi(sk
)->dst
,
1008 sk
->sk_state
, rfcomm_pi(sk
)->channel
);
1011 read_unlock(&rfcomm_sk_list
.lock
);
1016 static int rfcomm_sock_debugfs_open(struct inode
*inode
, struct file
*file
)
1018 return single_open(file
, rfcomm_sock_debugfs_show
, inode
->i_private
);
1021 static const struct file_operations rfcomm_sock_debugfs_fops
= {
1022 .open
= rfcomm_sock_debugfs_open
,
1024 .llseek
= seq_lseek
,
1025 .release
= single_release
,
1028 static struct dentry
*rfcomm_sock_debugfs
;
1030 static const struct proto_ops rfcomm_sock_ops
= {
1031 .family
= PF_BLUETOOTH
,
1032 .owner
= THIS_MODULE
,
1033 .release
= rfcomm_sock_release
,
1034 .bind
= rfcomm_sock_bind
,
1035 .connect
= rfcomm_sock_connect
,
1036 .listen
= rfcomm_sock_listen
,
1037 .accept
= rfcomm_sock_accept
,
1038 .getname
= rfcomm_sock_getname
,
1039 .sendmsg
= rfcomm_sock_sendmsg
,
1040 .recvmsg
= rfcomm_sock_recvmsg
,
1041 .shutdown
= rfcomm_sock_shutdown
,
1042 .setsockopt
= rfcomm_sock_setsockopt
,
1043 .getsockopt
= rfcomm_sock_getsockopt
,
1044 .ioctl
= rfcomm_sock_ioctl
,
1045 .poll
= bt_sock_poll
,
1046 .socketpair
= sock_no_socketpair
,
1047 .mmap
= sock_no_mmap
1050 static const struct net_proto_family rfcomm_sock_family_ops
= {
1051 .family
= PF_BLUETOOTH
,
1052 .owner
= THIS_MODULE
,
1053 .create
= rfcomm_sock_create
1056 int __init
rfcomm_init_sockets(void)
1060 err
= proto_register(&rfcomm_proto
, 0);
1064 err
= bt_sock_register(BTPROTO_RFCOMM
, &rfcomm_sock_family_ops
);
1066 BT_ERR("RFCOMM socket layer registration failed");
1070 err
= bt_procfs_init(&init_net
, "rfcomm", &rfcomm_sk_list
, NULL
);
1072 BT_ERR("Failed to create RFCOMM proc file");
1073 bt_sock_unregister(BTPROTO_RFCOMM
);
1077 BT_INFO("RFCOMM socket layer initialized");
1079 if (IS_ERR_OR_NULL(bt_debugfs
))
1082 rfcomm_sock_debugfs
= debugfs_create_file("rfcomm", 0444,
1084 &rfcomm_sock_debugfs_fops
);
1089 proto_unregister(&rfcomm_proto
);
1093 void __exit
rfcomm_cleanup_sockets(void)
1095 bt_procfs_cleanup(&init_net
, "rfcomm");
1097 debugfs_remove(rfcomm_sock_debugfs
);
1099 bt_sock_unregister(BTPROTO_RFCOMM
);
1101 proto_unregister(&rfcomm_proto
);