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 <linux/stringify.h>
30 #include <asm/ioctls.h>
32 #include <net/bluetooth/bluetooth.h>
33 #include <linux/proc_fs.h>
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_allow_reclassification(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 bt_sock
*s
, *n
;
182 BT_DBG("parent %p", parent
);
184 list_for_each_entry_safe(s
, n
, &bt_sk(parent
)->accept_q
, accept_q
) {
185 sk
= (struct sock
*)s
;
189 /* FIXME: Is this check still needed */
190 if (sk
->sk_state
== BT_CLOSED
) {
191 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 socket
*sock
, struct msghdr
*msg
, size_t len
,
216 int noblock
= flags
& MSG_DONTWAIT
;
217 struct sock
*sk
= sock
->sk
;
223 BT_DBG("sock %p sk %p len %zu", sock
, sk
, len
);
228 skb
= skb_recv_datagram(sk
, flags
, noblock
, &err
);
230 if (sk
->sk_shutdown
& RCV_SHUTDOWN
)
239 msg
->msg_flags
|= MSG_TRUNC
;
243 skb_reset_transport_header(skb
);
244 err
= skb_copy_datagram_msg(skb
, 0, msg
, copied
);
246 sock_recv_ts_and_drops(msg
, sk
, skb
);
248 if (bt_sk(sk
)->skb_msg_name
)
249 bt_sk(sk
)->skb_msg_name(skb
, msg
->msg_name
,
253 skb_free_datagram(sk
, skb
);
255 if (flags
& MSG_TRUNC
)
258 return err
? : copied
;
260 EXPORT_SYMBOL(bt_sock_recvmsg
);
262 static long bt_sock_data_wait(struct sock
*sk
, long timeo
)
264 DECLARE_WAITQUEUE(wait
, current
);
266 add_wait_queue(sk_sleep(sk
), &wait
);
268 set_current_state(TASK_INTERRUPTIBLE
);
270 if (!skb_queue_empty(&sk
->sk_receive_queue
))
273 if (sk
->sk_err
|| (sk
->sk_shutdown
& RCV_SHUTDOWN
))
276 if (signal_pending(current
) || !timeo
)
279 sk_set_bit(SOCKWQ_ASYNC_WAITDATA
, sk
);
281 timeo
= schedule_timeout(timeo
);
283 sk_clear_bit(SOCKWQ_ASYNC_WAITDATA
, sk
);
286 __set_current_state(TASK_RUNNING
);
287 remove_wait_queue(sk_sleep(sk
), &wait
);
291 int bt_sock_stream_recvmsg(struct socket
*sock
, struct msghdr
*msg
,
292 size_t size
, int flags
)
294 struct sock
*sk
= sock
->sk
;
296 size_t target
, copied
= 0;
302 BT_DBG("sk %p size %zu", sk
, size
);
306 target
= sock_rcvlowat(sk
, flags
& MSG_WAITALL
, size
);
307 timeo
= sock_rcvtimeo(sk
, flags
& MSG_DONTWAIT
);
313 skb
= skb_dequeue(&sk
->sk_receive_queue
);
315 if (copied
>= target
)
318 err
= sock_error(sk
);
321 if (sk
->sk_shutdown
& RCV_SHUTDOWN
)
328 timeo
= bt_sock_data_wait(sk
, timeo
);
330 if (signal_pending(current
)) {
331 err
= sock_intr_errno(timeo
);
337 chunk
= min_t(unsigned int, skb
->len
, size
);
338 if (skb_copy_datagram_msg(skb
, 0, msg
, chunk
)) {
339 skb_queue_head(&sk
->sk_receive_queue
, skb
);
347 sock_recv_ts_and_drops(msg
, sk
, skb
);
349 if (!(flags
& MSG_PEEK
)) {
350 int skb_len
= skb_headlen(skb
);
352 if (chunk
<= skb_len
) {
353 __skb_pull(skb
, chunk
);
355 struct sk_buff
*frag
;
357 __skb_pull(skb
, skb_len
);
360 skb_walk_frags(skb
, frag
) {
361 if (chunk
<= frag
->len
) {
362 /* Pulling partial data */
364 skb
->data_len
-= chunk
;
365 __skb_pull(frag
, chunk
);
367 } else if (frag
->len
) {
368 /* Pulling all frag data */
370 skb
->len
-= frag
->len
;
371 skb
->data_len
-= frag
->len
;
372 __skb_pull(frag
, frag
->len
);
378 skb_queue_head(&sk
->sk_receive_queue
, skb
);
384 /* put message back and return */
385 skb_queue_head(&sk
->sk_receive_queue
, skb
);
392 return copied
? : err
;
394 EXPORT_SYMBOL(bt_sock_stream_recvmsg
);
396 static inline unsigned int bt_accept_poll(struct sock
*parent
)
398 struct bt_sock
*s
, *n
;
401 list_for_each_entry_safe(s
, n
, &bt_sk(parent
)->accept_q
, accept_q
) {
402 sk
= (struct sock
*)s
;
403 if (sk
->sk_state
== BT_CONNECTED
||
404 (test_bit(BT_SK_DEFER_SETUP
, &bt_sk(parent
)->flags
) &&
405 sk
->sk_state
== BT_CONNECT2
))
406 return POLLIN
| POLLRDNORM
;
412 unsigned int bt_sock_poll(struct file
*file
, struct socket
*sock
,
415 struct sock
*sk
= sock
->sk
;
416 unsigned int mask
= 0;
418 BT_DBG("sock %p, sk %p", sock
, sk
);
420 poll_wait(file
, sk_sleep(sk
), wait
);
422 if (sk
->sk_state
== BT_LISTEN
)
423 return bt_accept_poll(sk
);
425 if (sk
->sk_err
|| !skb_queue_empty(&sk
->sk_error_queue
))
427 (sock_flag(sk
, SOCK_SELECT_ERR_QUEUE
) ? POLLPRI
: 0);
429 if (sk
->sk_shutdown
& RCV_SHUTDOWN
)
430 mask
|= POLLRDHUP
| POLLIN
| POLLRDNORM
;
432 if (sk
->sk_shutdown
== SHUTDOWN_MASK
)
435 if (!skb_queue_empty(&sk
->sk_receive_queue
))
436 mask
|= POLLIN
| POLLRDNORM
;
438 if (sk
->sk_state
== BT_CLOSED
)
441 if (sk
->sk_state
== BT_CONNECT
||
442 sk
->sk_state
== BT_CONNECT2
||
443 sk
->sk_state
== BT_CONFIG
)
446 if (!test_bit(BT_SK_SUSPEND
, &bt_sk(sk
)->flags
) && sock_writeable(sk
))
447 mask
|= POLLOUT
| POLLWRNORM
| POLLWRBAND
;
449 sk_set_bit(SOCKWQ_ASYNC_NOSPACE
, sk
);
453 EXPORT_SYMBOL(bt_sock_poll
);
455 int bt_sock_ioctl(struct socket
*sock
, unsigned int cmd
, unsigned long arg
)
457 struct sock
*sk
= sock
->sk
;
462 BT_DBG("sk %p cmd %x arg %lx", sk
, cmd
, arg
);
466 if (sk
->sk_state
== BT_LISTEN
)
469 amount
= sk
->sk_sndbuf
- sk_wmem_alloc_get(sk
);
472 err
= put_user(amount
, (int __user
*) arg
);
476 if (sk
->sk_state
== BT_LISTEN
)
480 skb
= skb_peek(&sk
->sk_receive_queue
);
481 amount
= skb
? skb
->len
: 0;
483 err
= put_user(amount
, (int __user
*) arg
);
487 err
= sock_get_timestamp(sk
, (struct timeval __user
*) arg
);
491 err
= sock_get_timestampns(sk
, (struct timespec __user
*) arg
);
501 EXPORT_SYMBOL(bt_sock_ioctl
);
503 /* This function expects the sk lock to be held when called */
504 int bt_sock_wait_state(struct sock
*sk
, int state
, unsigned long timeo
)
506 DECLARE_WAITQUEUE(wait
, current
);
511 add_wait_queue(sk_sleep(sk
), &wait
);
512 set_current_state(TASK_INTERRUPTIBLE
);
513 while (sk
->sk_state
!= state
) {
519 if (signal_pending(current
)) {
520 err
= sock_intr_errno(timeo
);
525 timeo
= schedule_timeout(timeo
);
527 set_current_state(TASK_INTERRUPTIBLE
);
529 err
= sock_error(sk
);
533 __set_current_state(TASK_RUNNING
);
534 remove_wait_queue(sk_sleep(sk
), &wait
);
537 EXPORT_SYMBOL(bt_sock_wait_state
);
539 /* This function expects the sk lock to be held when called */
540 int bt_sock_wait_ready(struct sock
*sk
, unsigned long flags
)
542 DECLARE_WAITQUEUE(wait
, current
);
548 timeo
= sock_sndtimeo(sk
, flags
& O_NONBLOCK
);
550 add_wait_queue(sk_sleep(sk
), &wait
);
551 set_current_state(TASK_INTERRUPTIBLE
);
552 while (test_bit(BT_SK_SUSPEND
, &bt_sk(sk
)->flags
)) {
558 if (signal_pending(current
)) {
559 err
= sock_intr_errno(timeo
);
564 timeo
= schedule_timeout(timeo
);
566 set_current_state(TASK_INTERRUPTIBLE
);
568 err
= sock_error(sk
);
572 __set_current_state(TASK_RUNNING
);
573 remove_wait_queue(sk_sleep(sk
), &wait
);
577 EXPORT_SYMBOL(bt_sock_wait_ready
);
579 #ifdef CONFIG_PROC_FS
580 struct bt_seq_state
{
581 struct bt_sock_list
*l
;
584 static void *bt_seq_start(struct seq_file
*seq
, loff_t
*pos
)
585 __acquires(seq
->private->l
->lock
)
587 struct bt_seq_state
*s
= seq
->private;
588 struct bt_sock_list
*l
= s
->l
;
591 return seq_hlist_start_head(&l
->head
, *pos
);
594 static void *bt_seq_next(struct seq_file
*seq
, void *v
, loff_t
*pos
)
596 struct bt_seq_state
*s
= seq
->private;
597 struct bt_sock_list
*l
= s
->l
;
599 return seq_hlist_next(v
, &l
->head
, pos
);
602 static void bt_seq_stop(struct seq_file
*seq
, void *v
)
603 __releases(seq
->private->l
->lock
)
605 struct bt_seq_state
*s
= seq
->private;
606 struct bt_sock_list
*l
= s
->l
;
608 read_unlock(&l
->lock
);
611 static int bt_seq_show(struct seq_file
*seq
, void *v
)
613 struct bt_seq_state
*s
= seq
->private;
614 struct bt_sock_list
*l
= s
->l
;
616 if (v
== SEQ_START_TOKEN
) {
617 seq_puts(seq
,"sk RefCnt Rmem Wmem User Inode Parent");
619 if (l
->custom_seq_show
) {
621 l
->custom_seq_show(seq
, v
);
626 struct sock
*sk
= sk_entry(v
);
627 struct bt_sock
*bt
= bt_sk(sk
);
630 "%pK %-6d %-6u %-6u %-6u %-6lu %-6lu",
632 atomic_read(&sk
->sk_refcnt
),
633 sk_rmem_alloc_get(sk
),
634 sk_wmem_alloc_get(sk
),
635 from_kuid(seq_user_ns(seq
), sock_i_uid(sk
)),
637 bt
->parent
? sock_i_ino(bt
->parent
): 0LU);
639 if (l
->custom_seq_show
) {
641 l
->custom_seq_show(seq
, v
);
649 static const struct seq_operations bt_seq_ops
= {
650 .start
= bt_seq_start
,
656 static int bt_seq_open(struct inode
*inode
, struct file
*file
)
658 struct bt_sock_list
*sk_list
;
659 struct bt_seq_state
*s
;
661 sk_list
= PDE_DATA(inode
);
662 s
= __seq_open_private(file
, &bt_seq_ops
,
663 sizeof(struct bt_seq_state
));
671 static const struct file_operations bt_fops
= {
675 .release
= seq_release_private
678 int bt_procfs_init(struct net
*net
, const char *name
,
679 struct bt_sock_list
*sk_list
,
680 int (* seq_show
)(struct seq_file
*, void *))
682 sk_list
->custom_seq_show
= seq_show
;
684 if (!proc_create_data(name
, 0, net
->proc_net
, &bt_fops
, sk_list
))
689 void bt_procfs_cleanup(struct net
*net
, const char *name
)
691 remove_proc_entry(name
, net
->proc_net
);
694 int bt_procfs_init(struct net
*net
, const char *name
,
695 struct bt_sock_list
*sk_list
,
696 int (* seq_show
)(struct seq_file
*, void *))
701 void bt_procfs_cleanup(struct net
*net
, const char *name
)
705 EXPORT_SYMBOL(bt_procfs_init
);
706 EXPORT_SYMBOL(bt_procfs_cleanup
);
708 static struct net_proto_family bt_sock_family_ops
= {
709 .owner
= THIS_MODULE
,
710 .family
= PF_BLUETOOTH
,
711 .create
= bt_sock_create
,
714 struct dentry
*bt_debugfs
;
715 EXPORT_SYMBOL_GPL(bt_debugfs
);
717 #define VERSION __stringify(BT_SUBSYS_VERSION) "." \
718 __stringify(BT_SUBSYS_REVISION)
720 static int __init
bt_init(void)
724 sock_skb_cb_check_size(sizeof(struct bt_skb_cb
));
726 BT_INFO("Core ver %s", VERSION
);
732 bt_debugfs
= debugfs_create_dir("bluetooth", NULL
);
736 err
= bt_sysfs_init();
740 err
= sock_register(&bt_sock_family_ops
);
746 BT_INFO("HCI device and connection manager initialized");
748 err
= hci_sock_init();
775 sock_unregister(PF_BLUETOOTH
);
781 static void __exit
bt_exit(void)
791 sock_unregister(PF_BLUETOOTH
);
797 debugfs_remove_recursive(bt_debugfs
);
800 subsys_initcall(bt_init
);
801 module_exit(bt_exit
);
803 MODULE_AUTHOR("Marcel Holtmann <marcel@holtmann.org>");
804 MODULE_DESCRIPTION("Bluetooth Core ver " VERSION
);
805 MODULE_VERSION(VERSION
);
806 MODULE_LICENSE("GPL");
807 MODULE_ALIAS_NETPROTO(PF_BLUETOOTH
);