2 BlueZ - Bluetooth protocol stack for Linux
3 Copyright (C) 2000-2001 Qualcomm Incorporated
5 Written 2000,2001 by Maxim Krasnyansky <maxk@qualcomm.com>
7 This program is free software; you can redistribute it and/or modify
8 it under the terms of the GNU General Public License version 2 as
9 published by the Free Software Foundation;
11 THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
12 OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
13 FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT OF THIRD PARTY RIGHTS.
14 IN NO EVENT SHALL THE COPYRIGHT HOLDER(S) AND AUTHOR(S) BE LIABLE FOR ANY
15 CLAIM, OR ANY SPECIAL INDIRECT OR CONSEQUENTIAL DAMAGES, OR ANY DAMAGES
16 WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
17 ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
18 OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
20 ALL LIABILITY, INCLUDING LIABILITY FOR INFRINGEMENT OF ANY PATENTS,
21 COPYRIGHTS, TRADEMARKS OR OTHER RIGHTS, RELATING TO USE OF THIS
22 SOFTWARE IS DISCLAIMED.
25 /* Bluetooth address family and sockets. */
27 #include <linux/module.h>
28 #include <linux/debugfs.h>
29 #include <asm/ioctls.h>
31 #include <net/bluetooth/bluetooth.h>
32 #include <linux/proc_fs.h>
36 #define VERSION "2.20"
38 /* Bluetooth sockets */
39 #define BT_MAX_PROTO 8
40 static const struct net_proto_family
*bt_proto
[BT_MAX_PROTO
];
41 static DEFINE_RWLOCK(bt_proto_lock
);
43 static struct lock_class_key bt_lock_key
[BT_MAX_PROTO
];
44 static const char *const bt_key_strings
[BT_MAX_PROTO
] = {
45 "sk_lock-AF_BLUETOOTH-BTPROTO_L2CAP",
46 "sk_lock-AF_BLUETOOTH-BTPROTO_HCI",
47 "sk_lock-AF_BLUETOOTH-BTPROTO_SCO",
48 "sk_lock-AF_BLUETOOTH-BTPROTO_RFCOMM",
49 "sk_lock-AF_BLUETOOTH-BTPROTO_BNEP",
50 "sk_lock-AF_BLUETOOTH-BTPROTO_CMTP",
51 "sk_lock-AF_BLUETOOTH-BTPROTO_HIDP",
52 "sk_lock-AF_BLUETOOTH-BTPROTO_AVDTP",
55 static struct lock_class_key bt_slock_key
[BT_MAX_PROTO
];
56 static const char *const bt_slock_key_strings
[BT_MAX_PROTO
] = {
57 "slock-AF_BLUETOOTH-BTPROTO_L2CAP",
58 "slock-AF_BLUETOOTH-BTPROTO_HCI",
59 "slock-AF_BLUETOOTH-BTPROTO_SCO",
60 "slock-AF_BLUETOOTH-BTPROTO_RFCOMM",
61 "slock-AF_BLUETOOTH-BTPROTO_BNEP",
62 "slock-AF_BLUETOOTH-BTPROTO_CMTP",
63 "slock-AF_BLUETOOTH-BTPROTO_HIDP",
64 "slock-AF_BLUETOOTH-BTPROTO_AVDTP",
67 void bt_sock_reclassify_lock(struct sock
*sk
, int proto
)
70 BUG_ON(sock_owned_by_user(sk
));
72 sock_lock_init_class_and_name(sk
,
73 bt_slock_key_strings
[proto
], &bt_slock_key
[proto
],
74 bt_key_strings
[proto
], &bt_lock_key
[proto
]);
76 EXPORT_SYMBOL(bt_sock_reclassify_lock
);
78 int bt_sock_register(int proto
, const struct net_proto_family
*ops
)
82 if (proto
< 0 || proto
>= BT_MAX_PROTO
)
85 write_lock(&bt_proto_lock
);
90 bt_proto
[proto
] = ops
;
92 write_unlock(&bt_proto_lock
);
96 EXPORT_SYMBOL(bt_sock_register
);
98 void bt_sock_unregister(int proto
)
100 if (proto
< 0 || proto
>= BT_MAX_PROTO
)
103 write_lock(&bt_proto_lock
);
104 bt_proto
[proto
] = NULL
;
105 write_unlock(&bt_proto_lock
);
107 EXPORT_SYMBOL(bt_sock_unregister
);
109 static int bt_sock_create(struct net
*net
, struct socket
*sock
, int proto
,
114 if (net
!= &init_net
)
115 return -EAFNOSUPPORT
;
117 if (proto
< 0 || proto
>= BT_MAX_PROTO
)
120 if (!bt_proto
[proto
])
121 request_module("bt-proto-%d", proto
);
123 err
= -EPROTONOSUPPORT
;
125 read_lock(&bt_proto_lock
);
127 if (bt_proto
[proto
] && try_module_get(bt_proto
[proto
]->owner
)) {
128 err
= bt_proto
[proto
]->create(net
, sock
, proto
, kern
);
130 bt_sock_reclassify_lock(sock
->sk
, proto
);
131 module_put(bt_proto
[proto
]->owner
);
134 read_unlock(&bt_proto_lock
);
139 void bt_sock_link(struct bt_sock_list
*l
, struct sock
*sk
)
141 write_lock(&l
->lock
);
142 sk_add_node(sk
, &l
->head
);
143 write_unlock(&l
->lock
);
145 EXPORT_SYMBOL(bt_sock_link
);
147 void bt_sock_unlink(struct bt_sock_list
*l
, struct sock
*sk
)
149 write_lock(&l
->lock
);
150 sk_del_node_init(sk
);
151 write_unlock(&l
->lock
);
153 EXPORT_SYMBOL(bt_sock_unlink
);
155 void bt_accept_enqueue(struct sock
*parent
, struct sock
*sk
)
157 BT_DBG("parent %p, sk %p", parent
, sk
);
160 list_add_tail(&bt_sk(sk
)->accept_q
, &bt_sk(parent
)->accept_q
);
161 bt_sk(sk
)->parent
= parent
;
162 parent
->sk_ack_backlog
++;
164 EXPORT_SYMBOL(bt_accept_enqueue
);
166 void bt_accept_unlink(struct sock
*sk
)
168 BT_DBG("sk %p state %d", sk
, sk
->sk_state
);
170 list_del_init(&bt_sk(sk
)->accept_q
);
171 bt_sk(sk
)->parent
->sk_ack_backlog
--;
172 bt_sk(sk
)->parent
= NULL
;
175 EXPORT_SYMBOL(bt_accept_unlink
);
177 struct sock
*bt_accept_dequeue(struct sock
*parent
, struct socket
*newsock
)
179 struct list_head
*p
, *n
;
182 BT_DBG("parent %p", parent
);
184 list_for_each_safe(p
, n
, &bt_sk(parent
)->accept_q
) {
185 sk
= (struct sock
*) list_entry(p
, struct bt_sock
, accept_q
);
189 /* FIXME: Is this check still needed */
190 if (sk
->sk_state
== BT_CLOSED
) {
192 bt_accept_unlink(sk
);
196 if (sk
->sk_state
== BT_CONNECTED
|| !newsock
||
197 test_bit(BT_SK_DEFER_SETUP
, &bt_sk(parent
)->flags
)) {
198 bt_accept_unlink(sk
);
200 sock_graft(sk
, newsock
);
211 EXPORT_SYMBOL(bt_accept_dequeue
);
213 int bt_sock_recvmsg(struct kiocb
*iocb
, struct socket
*sock
,
214 struct msghdr
*msg
, size_t len
, int flags
)
216 int noblock
= flags
& MSG_DONTWAIT
;
217 struct sock
*sk
= sock
->sk
;
222 BT_DBG("sock %p sk %p len %zu", sock
, sk
, len
);
224 if (flags
& (MSG_OOB
))
227 skb
= skb_recv_datagram(sk
, flags
, noblock
, &err
);
229 if (sk
->sk_shutdown
& RCV_SHUTDOWN
)
237 msg
->msg_flags
|= MSG_TRUNC
;
241 skb_reset_transport_header(skb
);
242 err
= skb_copy_datagram_msg(skb
, 0, msg
, copied
);
244 sock_recv_ts_and_drops(msg
, sk
, skb
);
246 if (bt_sk(sk
)->skb_msg_name
)
247 bt_sk(sk
)->skb_msg_name(skb
, msg
->msg_name
,
251 skb_free_datagram(sk
, skb
);
253 return err
? : copied
;
255 EXPORT_SYMBOL(bt_sock_recvmsg
);
257 static long bt_sock_data_wait(struct sock
*sk
, long timeo
)
259 DECLARE_WAITQUEUE(wait
, current
);
261 add_wait_queue(sk_sleep(sk
), &wait
);
263 set_current_state(TASK_INTERRUPTIBLE
);
265 if (!skb_queue_empty(&sk
->sk_receive_queue
))
268 if (sk
->sk_err
|| (sk
->sk_shutdown
& RCV_SHUTDOWN
))
271 if (signal_pending(current
) || !timeo
)
274 set_bit(SOCK_ASYNC_WAITDATA
, &sk
->sk_socket
->flags
);
276 timeo
= schedule_timeout(timeo
);
278 clear_bit(SOCK_ASYNC_WAITDATA
, &sk
->sk_socket
->flags
);
281 __set_current_state(TASK_RUNNING
);
282 remove_wait_queue(sk_sleep(sk
), &wait
);
286 int bt_sock_stream_recvmsg(struct kiocb
*iocb
, struct socket
*sock
,
287 struct msghdr
*msg
, size_t size
, int flags
)
289 struct sock
*sk
= sock
->sk
;
291 size_t target
, copied
= 0;
297 BT_DBG("sk %p size %zu", sk
, size
);
301 target
= sock_rcvlowat(sk
, flags
& MSG_WAITALL
, size
);
302 timeo
= sock_rcvtimeo(sk
, flags
& MSG_DONTWAIT
);
308 skb
= skb_dequeue(&sk
->sk_receive_queue
);
310 if (copied
>= target
)
313 err
= sock_error(sk
);
316 if (sk
->sk_shutdown
& RCV_SHUTDOWN
)
323 timeo
= bt_sock_data_wait(sk
, timeo
);
325 if (signal_pending(current
)) {
326 err
= sock_intr_errno(timeo
);
332 chunk
= min_t(unsigned int, skb
->len
, size
);
333 if (skb_copy_datagram_msg(skb
, 0, msg
, chunk
)) {
334 skb_queue_head(&sk
->sk_receive_queue
, skb
);
342 sock_recv_ts_and_drops(msg
, sk
, skb
);
344 if (!(flags
& MSG_PEEK
)) {
345 int skb_len
= skb_headlen(skb
);
347 if (chunk
<= skb_len
) {
348 __skb_pull(skb
, chunk
);
350 struct sk_buff
*frag
;
352 __skb_pull(skb
, skb_len
);
355 skb_walk_frags(skb
, frag
) {
356 if (chunk
<= frag
->len
) {
357 /* Pulling partial data */
359 skb
->data_len
-= chunk
;
360 __skb_pull(frag
, chunk
);
362 } else if (frag
->len
) {
363 /* Pulling all frag data */
365 skb
->len
-= frag
->len
;
366 skb
->data_len
-= frag
->len
;
367 __skb_pull(frag
, frag
->len
);
373 skb_queue_head(&sk
->sk_receive_queue
, skb
);
379 /* put message back and return */
380 skb_queue_head(&sk
->sk_receive_queue
, skb
);
387 return copied
? : err
;
389 EXPORT_SYMBOL(bt_sock_stream_recvmsg
);
391 static inline unsigned int bt_accept_poll(struct sock
*parent
)
393 struct list_head
*p
, *n
;
396 list_for_each_safe(p
, n
, &bt_sk(parent
)->accept_q
) {
397 sk
= (struct sock
*) list_entry(p
, struct bt_sock
, accept_q
);
398 if (sk
->sk_state
== BT_CONNECTED
||
399 (test_bit(BT_SK_DEFER_SETUP
, &bt_sk(parent
)->flags
) &&
400 sk
->sk_state
== BT_CONNECT2
))
401 return POLLIN
| POLLRDNORM
;
407 unsigned int bt_sock_poll(struct file
*file
, struct socket
*sock
,
410 struct sock
*sk
= sock
->sk
;
411 unsigned int mask
= 0;
413 BT_DBG("sock %p, sk %p", sock
, sk
);
415 poll_wait(file
, sk_sleep(sk
), wait
);
417 if (sk
->sk_state
== BT_LISTEN
)
418 return bt_accept_poll(sk
);
420 if (sk
->sk_err
|| !skb_queue_empty(&sk
->sk_error_queue
))
422 (sock_flag(sk
, SOCK_SELECT_ERR_QUEUE
) ? POLLPRI
: 0);
424 if (sk
->sk_shutdown
& RCV_SHUTDOWN
)
425 mask
|= POLLRDHUP
| POLLIN
| POLLRDNORM
;
427 if (sk
->sk_shutdown
== SHUTDOWN_MASK
)
430 if (!skb_queue_empty(&sk
->sk_receive_queue
))
431 mask
|= POLLIN
| POLLRDNORM
;
433 if (sk
->sk_state
== BT_CLOSED
)
436 if (sk
->sk_state
== BT_CONNECT
||
437 sk
->sk_state
== BT_CONNECT2
||
438 sk
->sk_state
== BT_CONFIG
)
441 if (!test_bit(BT_SK_SUSPEND
, &bt_sk(sk
)->flags
) && sock_writeable(sk
))
442 mask
|= POLLOUT
| POLLWRNORM
| POLLWRBAND
;
444 set_bit(SOCK_ASYNC_NOSPACE
, &sk
->sk_socket
->flags
);
448 EXPORT_SYMBOL(bt_sock_poll
);
450 int bt_sock_ioctl(struct socket
*sock
, unsigned int cmd
, unsigned long arg
)
452 struct sock
*sk
= sock
->sk
;
457 BT_DBG("sk %p cmd %x arg %lx", sk
, cmd
, arg
);
461 if (sk
->sk_state
== BT_LISTEN
)
464 amount
= sk
->sk_sndbuf
- sk_wmem_alloc_get(sk
);
467 err
= put_user(amount
, (int __user
*) arg
);
471 if (sk
->sk_state
== BT_LISTEN
)
475 skb
= skb_peek(&sk
->sk_receive_queue
);
476 amount
= skb
? skb
->len
: 0;
478 err
= put_user(amount
, (int __user
*) arg
);
482 err
= sock_get_timestamp(sk
, (struct timeval __user
*) arg
);
486 err
= sock_get_timestampns(sk
, (struct timespec __user
*) arg
);
496 EXPORT_SYMBOL(bt_sock_ioctl
);
498 /* This function expects the sk lock to be held when called */
499 int bt_sock_wait_state(struct sock
*sk
, int state
, unsigned long timeo
)
501 DECLARE_WAITQUEUE(wait
, current
);
506 add_wait_queue(sk_sleep(sk
), &wait
);
507 set_current_state(TASK_INTERRUPTIBLE
);
508 while (sk
->sk_state
!= state
) {
514 if (signal_pending(current
)) {
515 err
= sock_intr_errno(timeo
);
520 timeo
= schedule_timeout(timeo
);
522 set_current_state(TASK_INTERRUPTIBLE
);
524 err
= sock_error(sk
);
528 __set_current_state(TASK_RUNNING
);
529 remove_wait_queue(sk_sleep(sk
), &wait
);
532 EXPORT_SYMBOL(bt_sock_wait_state
);
534 /* This function expects the sk lock to be held when called */
535 int bt_sock_wait_ready(struct sock
*sk
, unsigned long flags
)
537 DECLARE_WAITQUEUE(wait
, current
);
543 timeo
= sock_sndtimeo(sk
, flags
& O_NONBLOCK
);
545 add_wait_queue(sk_sleep(sk
), &wait
);
546 set_current_state(TASK_INTERRUPTIBLE
);
547 while (test_bit(BT_SK_SUSPEND
, &bt_sk(sk
)->flags
)) {
553 if (signal_pending(current
)) {
554 err
= sock_intr_errno(timeo
);
559 timeo
= schedule_timeout(timeo
);
561 set_current_state(TASK_INTERRUPTIBLE
);
563 err
= sock_error(sk
);
567 __set_current_state(TASK_RUNNING
);
568 remove_wait_queue(sk_sleep(sk
), &wait
);
572 EXPORT_SYMBOL(bt_sock_wait_ready
);
574 #ifdef CONFIG_PROC_FS
575 struct bt_seq_state
{
576 struct bt_sock_list
*l
;
579 static void *bt_seq_start(struct seq_file
*seq
, loff_t
*pos
)
580 __acquires(seq
->private->l
->lock
)
582 struct bt_seq_state
*s
= seq
->private;
583 struct bt_sock_list
*l
= s
->l
;
586 return seq_hlist_start_head(&l
->head
, *pos
);
589 static void *bt_seq_next(struct seq_file
*seq
, void *v
, loff_t
*pos
)
591 struct bt_seq_state
*s
= seq
->private;
592 struct bt_sock_list
*l
= s
->l
;
594 return seq_hlist_next(v
, &l
->head
, pos
);
597 static void bt_seq_stop(struct seq_file
*seq
, void *v
)
598 __releases(seq
->private->l
->lock
)
600 struct bt_seq_state
*s
= seq
->private;
601 struct bt_sock_list
*l
= s
->l
;
603 read_unlock(&l
->lock
);
606 static int bt_seq_show(struct seq_file
*seq
, void *v
)
608 struct bt_seq_state
*s
= seq
->private;
609 struct bt_sock_list
*l
= s
->l
;
611 if (v
== SEQ_START_TOKEN
) {
612 seq_puts(seq
,"sk RefCnt Rmem Wmem User Inode Parent");
614 if (l
->custom_seq_show
) {
616 l
->custom_seq_show(seq
, v
);
621 struct sock
*sk
= sk_entry(v
);
622 struct bt_sock
*bt
= bt_sk(sk
);
625 "%pK %-6d %-6u %-6u %-6u %-6lu %-6lu",
627 atomic_read(&sk
->sk_refcnt
),
628 sk_rmem_alloc_get(sk
),
629 sk_wmem_alloc_get(sk
),
630 from_kuid(seq_user_ns(seq
), sock_i_uid(sk
)),
632 bt
->parent
? sock_i_ino(bt
->parent
): 0LU);
634 if (l
->custom_seq_show
) {
636 l
->custom_seq_show(seq
, v
);
644 static const struct seq_operations bt_seq_ops
= {
645 .start
= bt_seq_start
,
651 static int bt_seq_open(struct inode
*inode
, struct file
*file
)
653 struct bt_sock_list
*sk_list
;
654 struct bt_seq_state
*s
;
656 sk_list
= PDE_DATA(inode
);
657 s
= __seq_open_private(file
, &bt_seq_ops
,
658 sizeof(struct bt_seq_state
));
666 static const struct file_operations bt_fops
= {
670 .release
= seq_release_private
673 int bt_procfs_init(struct net
*net
, const char *name
,
674 struct bt_sock_list
* sk_list
,
675 int (* seq_show
)(struct seq_file
*, void *))
677 sk_list
->custom_seq_show
= seq_show
;
679 if (!proc_create_data(name
, 0, net
->proc_net
, &bt_fops
, sk_list
))
684 void bt_procfs_cleanup(struct net
*net
, const char *name
)
686 remove_proc_entry(name
, net
->proc_net
);
689 int bt_procfs_init(struct net
*net
, const char *name
,
690 struct bt_sock_list
* sk_list
,
691 int (* seq_show
)(struct seq_file
*, void *))
696 void bt_procfs_cleanup(struct net
*net
, const char *name
)
700 EXPORT_SYMBOL(bt_procfs_init
);
701 EXPORT_SYMBOL(bt_procfs_cleanup
);
703 static struct net_proto_family bt_sock_family_ops
= {
704 .owner
= THIS_MODULE
,
705 .family
= PF_BLUETOOTH
,
706 .create
= bt_sock_create
,
709 struct dentry
*bt_debugfs
;
710 EXPORT_SYMBOL_GPL(bt_debugfs
);
712 static int __init
bt_init(void)
717 BUILD_BUG_ON(sizeof(struct bt_skb_cb
) > sizeof(skb
->cb
));
719 BT_INFO("Core ver %s", VERSION
);
725 bt_debugfs
= debugfs_create_dir("bluetooth", NULL
);
727 err
= bt_sysfs_init();
731 err
= sock_register(&bt_sock_family_ops
);
737 BT_INFO("HCI device and connection manager initialized");
739 err
= hci_sock_init();
759 sock_unregister(PF_BLUETOOTH
);
765 static void __exit
bt_exit(void)
773 sock_unregister(PF_BLUETOOTH
);
777 debugfs_remove_recursive(bt_debugfs
);
780 subsys_initcall(bt_init
);
781 module_exit(bt_exit
);
783 MODULE_AUTHOR("Marcel Holtmann <marcel@holtmann.org>");
784 MODULE_DESCRIPTION("Bluetooth Core ver " VERSION
);
785 MODULE_VERSION(VERSION
);
786 MODULE_LICENSE("GPL");
787 MODULE_ALIAS_NETPROTO(PF_BLUETOOTH
);