71 void bt_sock_reclassify_lock(struct sock *sk, int proto)  in bt_sock_reclassify_lock()  argument
73 	BUG_ON(!sk);  in bt_sock_reclassify_lock()
74 	BUG_ON(!sock_allow_reclassification(sk));  in bt_sock_reclassify_lock()
76 	sock_lock_init_class_and_name(sk,  in bt_sock_reclassify_lock()
134 			bt_sock_reclassify_lock(sock->sk, proto);  in bt_sock_create()
146 	struct sock *sk;  in bt_sock_alloc()  local
148 	sk = sk_alloc(net, PF_BLUETOOTH, prio, prot, kern);  in bt_sock_alloc()
149 	if (!sk)  in bt_sock_alloc()
152 	sock_init_data(sock, sk);  in bt_sock_alloc()
153 	INIT_LIST_HEAD(&bt_sk(sk)->accept_q);  in bt_sock_alloc()
155 	sock_reset_flag(sk, SOCK_ZAPPED);  in bt_sock_alloc()
157 	sk->sk_protocol = proto;  in bt_sock_alloc()
158 	sk->sk_state    = BT_OPEN;  in bt_sock_alloc()
162 		spin_lock(&sk->sk_peer_lock);  in bt_sock_alloc()
163 		sk->sk_peer_pid  = get_pid(task_tgid(current));  in bt_sock_alloc()
164 		sk->sk_peer_cred = get_current_cred();  in bt_sock_alloc()
165 		spin_unlock(&sk->sk_peer_lock);  in bt_sock_alloc()
168 	return sk;  in bt_sock_alloc()
172 void bt_sock_link(struct bt_sock_list *l, struct sock *sk)  in bt_sock_link()  argument
175 	sk_add_node(sk, &l->head);  in bt_sock_link()
180 void bt_sock_unlink(struct bt_sock_list *l, struct sock *sk)  in bt_sock_unlink()  argument
183 	sk_del_node_init(sk);  in bt_sock_unlink()
188 void bt_accept_enqueue(struct sock *parent, struct sock *sk, bool bh)  in bt_accept_enqueue()  argument
193 	BT_DBG("parent %p, sk %p", parent, sk);  in bt_accept_enqueue()
195 	sock_hold(sk);  in bt_accept_enqueue()
198 		bh_lock_sock_nested(sk);  in bt_accept_enqueue()
200 		lock_sock_nested(sk, SINGLE_DEPTH_NESTING);  in bt_accept_enqueue()
202 	list_add_tail(&bt_sk(sk)->accept_q, &bt_sk(parent)->accept_q);  in bt_accept_enqueue()
203 	bt_sk(sk)->parent = parent;  in bt_accept_enqueue()
208 	spin_lock(&sk->sk_peer_lock);  in bt_accept_enqueue()
209 	old_pid = sk->sk_peer_pid;  in bt_accept_enqueue()
210 	old_cred = sk->sk_peer_cred;  in bt_accept_enqueue()
211 	sk->sk_peer_pid = get_pid(parent->sk_peer_pid);  in bt_accept_enqueue()
212 	sk->sk_peer_cred = get_cred(parent->sk_peer_cred);  in bt_accept_enqueue()
213 	spin_unlock(&sk->sk_peer_lock);  in bt_accept_enqueue()
219 		bh_unlock_sock(sk);  in bt_accept_enqueue()
221 		release_sock(sk);  in bt_accept_enqueue()
230 void bt_accept_unlink(struct sock *sk)  in bt_accept_unlink()  argument
232 	BT_DBG("sk %p state %d", sk, sk->sk_state);  in bt_accept_unlink()
234 	list_del_init(&bt_sk(sk)->accept_q);  in bt_accept_unlink()
235 	sk_acceptq_removed(bt_sk(sk)->parent);  in bt_accept_unlink()
236 	bt_sk(sk)->parent = NULL;  in bt_accept_unlink()
237 	sock_put(sk);  in bt_accept_unlink()
244 	struct sock *sk;  in bt_accept_dequeue()  local
250 		sk = (struct sock *)s;  in bt_accept_dequeue()
253 		sock_hold(sk);  in bt_accept_dequeue()
254 		lock_sock(sk);  in bt_accept_dequeue()
259 		if (!bt_sk(sk)->parent) {  in bt_accept_dequeue()
260 			BT_DBG("sk %p, already unlinked", sk);  in bt_accept_dequeue()
261 			release_sock(sk);  in bt_accept_dequeue()
262 			sock_put(sk);  in bt_accept_dequeue()
272 		sock_put(sk);  in bt_accept_dequeue()
275 		if (sk->sk_state == BT_CLOSED) {  in bt_accept_dequeue()
276 			bt_accept_unlink(sk);  in bt_accept_dequeue()
277 			release_sock(sk);  in bt_accept_dequeue()
281 		if (sk->sk_state == BT_CONNECTED || !newsock ||  in bt_accept_dequeue()
283 			bt_accept_unlink(sk);  in bt_accept_dequeue()
285 				sock_graft(sk, newsock);  in bt_accept_dequeue()
287 			release_sock(sk);  in bt_accept_dequeue()
288 			return sk;  in bt_accept_dequeue()
291 		release_sock(sk);  in bt_accept_dequeue()
301 	struct sock *sk = sock->sk;  in bt_sock_recvmsg()  local
307 	BT_DBG("sock %p sk %p len %zu", sock, sk, len);  in bt_sock_recvmsg()
312 	skb = skb_recv_datagram(sk, flags, &err);  in bt_sock_recvmsg()
314 		if (sk->sk_shutdown & RCV_SHUTDOWN)  in bt_sock_recvmsg()
330 		sock_recv_cmsgs(msg, sk, skb);  in bt_sock_recvmsg()
332 		if (msg->msg_name && bt_sk(sk)->skb_msg_name)  in bt_sock_recvmsg()
333 			bt_sk(sk)->skb_msg_name(skb, msg->msg_name,  in bt_sock_recvmsg()
336 		if (test_bit(BT_SK_PKT_STATUS, &bt_sk(sk)->flags)) {  in bt_sock_recvmsg()
344 	skb_free_datagram(sk, skb);  in bt_sock_recvmsg()
353 static long bt_sock_data_wait(struct sock *sk, long timeo)  in bt_sock_data_wait()  argument
357 	add_wait_queue(sk_sleep(sk), &wait);  in bt_sock_data_wait()
361 		if (!skb_queue_empty(&sk->sk_receive_queue))  in bt_sock_data_wait()
364 		if (sk->sk_err || (sk->sk_shutdown & RCV_SHUTDOWN))  in bt_sock_data_wait()
370 		sk_set_bit(SOCKWQ_ASYNC_WAITDATA, sk);  in bt_sock_data_wait()
371 		release_sock(sk);  in bt_sock_data_wait()
373 		lock_sock(sk);  in bt_sock_data_wait()
374 		sk_clear_bit(SOCKWQ_ASYNC_WAITDATA, sk);  in bt_sock_data_wait()
378 	remove_wait_queue(sk_sleep(sk), &wait);  in bt_sock_data_wait()
385 	struct sock *sk = sock->sk;  in bt_sock_stream_recvmsg()  local
393 	BT_DBG("sk %p size %zu", sk, size);  in bt_sock_stream_recvmsg()
395 	lock_sock(sk);  in bt_sock_stream_recvmsg()
397 	target = sock_rcvlowat(sk, flags & MSG_WAITALL, size);  in bt_sock_stream_recvmsg()
398 	timeo  = sock_rcvtimeo(sk, flags & MSG_DONTWAIT);  in bt_sock_stream_recvmsg()
404 		skb = skb_dequeue(&sk->sk_receive_queue);  in bt_sock_stream_recvmsg()
409 			err = sock_error(sk);  in bt_sock_stream_recvmsg()
412 			if (sk->sk_shutdown & RCV_SHUTDOWN)  in bt_sock_stream_recvmsg()
419 			timeo = bt_sock_data_wait(sk, timeo);  in bt_sock_stream_recvmsg()
430 			skb_queue_head(&sk->sk_receive_queue, skb);  in bt_sock_stream_recvmsg()
438 		sock_recv_cmsgs(msg, sk, skb);  in bt_sock_stream_recvmsg()
469 				skb_queue_head(&sk->sk_receive_queue, skb);  in bt_sock_stream_recvmsg()
476 			skb_queue_head(&sk->sk_receive_queue, skb);  in bt_sock_stream_recvmsg()
482 	release_sock(sk);  in bt_sock_stream_recvmsg()
490 	struct sock *sk;  in bt_accept_poll()  local
493 		sk = (struct sock *)s;  in bt_accept_poll()
494 		if (sk->sk_state == BT_CONNECTED ||  in bt_accept_poll()
496 		     sk->sk_state == BT_CONNECT2))  in bt_accept_poll()
506 	struct sock *sk = sock->sk;  in bt_sock_poll()  local
509 	poll_wait(file, sk_sleep(sk), wait);  in bt_sock_poll()
511 	if (sk->sk_state == BT_LISTEN)  in bt_sock_poll()
512 		return bt_accept_poll(sk);  in bt_sock_poll()
514 	if (sk->sk_err || !skb_queue_empty_lockless(&sk->sk_error_queue))  in bt_sock_poll()
516 			(sock_flag(sk, SOCK_SELECT_ERR_QUEUE) ? EPOLLPRI : 0);  in bt_sock_poll()
518 	if (sk->sk_shutdown & RCV_SHUTDOWN)  in bt_sock_poll()
521 	if (sk->sk_shutdown == SHUTDOWN_MASK)  in bt_sock_poll()
524 	if (!skb_queue_empty_lockless(&sk->sk_receive_queue))  in bt_sock_poll()
527 	if (sk->sk_state == BT_CLOSED)  in bt_sock_poll()
530 	if (sk->sk_state == BT_CONNECT ||  in bt_sock_poll()
531 	    sk->sk_state == BT_CONNECT2 ||  in bt_sock_poll()
532 	    sk->sk_state == BT_CONFIG)  in bt_sock_poll()
535 	if (!test_bit(BT_SK_SUSPEND, &bt_sk(sk)->flags) && sock_writeable(sk))  in bt_sock_poll()
538 		sk_set_bit(SOCKWQ_ASYNC_NOSPACE, sk);  in bt_sock_poll()
546 	struct sock *sk = sock->sk;  in bt_sock_ioctl()  local
551 	BT_DBG("sk %p cmd %x arg %lx", sk, cmd, arg);  in bt_sock_ioctl()
555 		if (sk->sk_state == BT_LISTEN)  in bt_sock_ioctl()
558 		amount = sk->sk_sndbuf - sk_wmem_alloc_get(sk);  in bt_sock_ioctl()
565 		if (sk->sk_state == BT_LISTEN)  in bt_sock_ioctl()
568 		lock_sock(sk);  in bt_sock_ioctl()
569 		skb = skb_peek(&sk->sk_receive_queue);  in bt_sock_ioctl()
571 		release_sock(sk);  in bt_sock_ioctl()
585 int bt_sock_wait_state(struct sock *sk, int state, unsigned long timeo)  in bt_sock_wait_state()  argument
590 	BT_DBG("sk %p", sk);  in bt_sock_wait_state()
592 	add_wait_queue(sk_sleep(sk), &wait);  in bt_sock_wait_state()
594 	while (sk->sk_state != state) {  in bt_sock_wait_state()
605 		release_sock(sk);  in bt_sock_wait_state()
607 		lock_sock(sk);  in bt_sock_wait_state()
610 		err = sock_error(sk);  in bt_sock_wait_state()
615 	remove_wait_queue(sk_sleep(sk), &wait);  in bt_sock_wait_state()
621 int bt_sock_wait_ready(struct sock *sk, unsigned int msg_flags)  in bt_sock_wait_ready()  argument
627 	BT_DBG("sk %p", sk);  in bt_sock_wait_ready()
629 	timeo = sock_sndtimeo(sk, !!(msg_flags & MSG_DONTWAIT));  in bt_sock_wait_ready()
631 	add_wait_queue(sk_sleep(sk), &wait);  in bt_sock_wait_ready()
633 	while (test_bit(BT_SK_SUSPEND, &bt_sk(sk)->flags)) {  in bt_sock_wait_ready()
644 		release_sock(sk);  in bt_sock_wait_ready()
646 		lock_sock(sk);  in bt_sock_wait_ready()
649 		err = sock_error(sk);  in bt_sock_wait_ready()
654 	remove_wait_queue(sk_sleep(sk), &wait);  in bt_sock_wait_ready()
699 		struct sock *sk = sk_entry(v);  in bt_seq_show()  local
700 		struct bt_sock *bt = bt_sk(sk);  in bt_seq_show()
704 			   sk,  in bt_seq_show()
705 			   refcount_read(&sk->sk_refcnt),  in bt_seq_show()
706 			   sk_rmem_alloc_get(sk),  in bt_seq_show()
707 			   sk_wmem_alloc_get(sk),  in bt_seq_show()
708 			   from_kuid(seq_user_ns(seq), sock_i_uid(sk)),  in bt_seq_show()
709 			   sock_i_ino(sk),  in bt_seq_show()