67 void bt_sock_reclassify_lock(struct sock *sk, int proto)  in bt_sock_reclassify_lock()  argument
69 	BUG_ON(!sk);  in bt_sock_reclassify_lock()
70 	BUG_ON(!sock_allow_reclassification(sk));  in bt_sock_reclassify_lock()
72 	sock_lock_init_class_and_name(sk,  in bt_sock_reclassify_lock()
159 			bt_sock_reclassify_lock(sock->sk, proto);  in bt_sock_create()
168 void bt_sock_link(struct bt_sock_list *l, struct sock *sk)  in bt_sock_link()  argument
171 	sk_add_node(sk, &l->head);  in bt_sock_link()
176 void bt_sock_unlink(struct bt_sock_list *l, struct sock *sk)  in bt_sock_unlink()  argument
179 	sk_del_node_init(sk);  in bt_sock_unlink()
184 void bt_accept_enqueue(struct sock *parent, struct sock *sk)  in bt_accept_enqueue()  argument
186 	BT_DBG("parent %p, sk %p", parent, sk);  in bt_accept_enqueue()
188 	sock_hold(sk);  in bt_accept_enqueue()
189 	list_add_tail(&bt_sk(sk)->accept_q, &bt_sk(parent)->accept_q);  in bt_accept_enqueue()
190 	bt_sk(sk)->parent = parent;  in bt_accept_enqueue()
198 void bt_accept_unlink(struct sock *sk)  in bt_accept_unlink()  argument
200 	BT_DBG("sk %p state %d", sk, sk->sk_state);  in bt_accept_unlink()
202 	list_del_init(&bt_sk(sk)->accept_q);  in bt_accept_unlink()
203 	bt_sk(sk)->parent->sk_ack_backlog--;  in bt_accept_unlink()
204 	bt_sk(sk)->parent = NULL;  in bt_accept_unlink()
205 	sock_put(sk);  in bt_accept_unlink()
212 	struct sock *sk;  in bt_accept_dequeue()  local
218 		sk = (struct sock *)s;  in bt_accept_dequeue()
221 		sock_hold(sk);  in bt_accept_dequeue()
222 		lock_sock(sk);  in bt_accept_dequeue()
227 		if (!bt_sk(sk)->parent) {  in bt_accept_dequeue()
228 			BT_DBG("sk %p, already unlinked", sk);  in bt_accept_dequeue()
229 			release_sock(sk);  in bt_accept_dequeue()
230 			sock_put(sk);  in bt_accept_dequeue()
240 		sock_put(sk);  in bt_accept_dequeue()
243 		if (sk->sk_state == BT_CLOSED) {  in bt_accept_dequeue()
244 			bt_accept_unlink(sk);  in bt_accept_dequeue()
245 			release_sock(sk);  in bt_accept_dequeue()
249 		if (sk->sk_state == BT_CONNECTED || !newsock ||  in bt_accept_dequeue()
251 			bt_accept_unlink(sk);  in bt_accept_dequeue()
253 				sock_graft(sk, newsock);  in bt_accept_dequeue()
255 			release_sock(sk);  in bt_accept_dequeue()
256 			return sk;  in bt_accept_dequeue()
259 		release_sock(sk);  in bt_accept_dequeue()
270 	struct sock *sk = sock->sk;  in bt_sock_recvmsg()  local
276 	BT_DBG("sock %p sk %p len %zu", sock, sk, len);  in bt_sock_recvmsg()
281 	skb = skb_recv_datagram(sk, flags, noblock, &err);  in bt_sock_recvmsg()
283 		if (sk->sk_shutdown & RCV_SHUTDOWN)  in bt_sock_recvmsg()
299 		sock_recv_ts_and_drops(msg, sk, skb);  in bt_sock_recvmsg()
301 		if (bt_sk(sk)->skb_msg_name)  in bt_sock_recvmsg()
302 			bt_sk(sk)->skb_msg_name(skb, msg->msg_name,  in bt_sock_recvmsg()
306 	skb_free_datagram(sk, skb);  in bt_sock_recvmsg()
315 static long bt_sock_data_wait(struct sock *sk, long timeo)  in bt_sock_data_wait()  argument
319 	add_wait_queue(sk_sleep(sk), &wait);  in bt_sock_data_wait()
323 		if (!skb_queue_empty(&sk->sk_receive_queue))  in bt_sock_data_wait()
326 		if (sk->sk_err || (sk->sk_shutdown & RCV_SHUTDOWN))  in bt_sock_data_wait()
332 		sk_set_bit(SOCKWQ_ASYNC_WAITDATA, sk);  in bt_sock_data_wait()
333 		release_sock(sk);  in bt_sock_data_wait()
335 		lock_sock(sk);  in bt_sock_data_wait()
336 		sk_clear_bit(SOCKWQ_ASYNC_WAITDATA, sk);  in bt_sock_data_wait()
340 	remove_wait_queue(sk_sleep(sk), &wait);  in bt_sock_data_wait()
347 	struct sock *sk = sock->sk;  in bt_sock_stream_recvmsg()  local
355 	BT_DBG("sk %p size %zu", sk, size);  in bt_sock_stream_recvmsg()
357 	lock_sock(sk);  in bt_sock_stream_recvmsg()
359 	target = sock_rcvlowat(sk, flags & MSG_WAITALL, size);  in bt_sock_stream_recvmsg()
360 	timeo  = sock_rcvtimeo(sk, flags & MSG_DONTWAIT);  in bt_sock_stream_recvmsg()
366 		skb = skb_dequeue(&sk->sk_receive_queue);  in bt_sock_stream_recvmsg()
371 			err = sock_error(sk);  in bt_sock_stream_recvmsg()
374 			if (sk->sk_shutdown & RCV_SHUTDOWN)  in bt_sock_stream_recvmsg()
381 			timeo = bt_sock_data_wait(sk, timeo);  in bt_sock_stream_recvmsg()
392 			skb_queue_head(&sk->sk_receive_queue, skb);  in bt_sock_stream_recvmsg()
400 		sock_recv_ts_and_drops(msg, sk, skb);  in bt_sock_stream_recvmsg()
431 				skb_queue_head(&sk->sk_receive_queue, skb);  in bt_sock_stream_recvmsg()
438 			skb_queue_head(&sk->sk_receive_queue, skb);  in bt_sock_stream_recvmsg()
444 	release_sock(sk);  in bt_sock_stream_recvmsg()
452 	struct sock *sk;  in bt_accept_poll()  local
455 		sk = (struct sock *)s;  in bt_accept_poll()
456 		if (sk->sk_state == BT_CONNECTED ||  in bt_accept_poll()
458 		     sk->sk_state == BT_CONNECT2))  in bt_accept_poll()
468 	struct sock *sk = sock->sk;  in bt_sock_poll()  local
471 	BT_DBG("sock %p, sk %p", sock, sk);  in bt_sock_poll()
473 	poll_wait(file, sk_sleep(sk), wait);  in bt_sock_poll()
475 	if (sk->sk_state == BT_LISTEN)  in bt_sock_poll()
476 		return bt_accept_poll(sk);  in bt_sock_poll()
478 	if (sk->sk_err || !skb_queue_empty(&sk->sk_error_queue))  in bt_sock_poll()
480 			(sock_flag(sk, SOCK_SELECT_ERR_QUEUE) ? POLLPRI : 0);  in bt_sock_poll()
482 	if (sk->sk_shutdown & RCV_SHUTDOWN)  in bt_sock_poll()
485 	if (sk->sk_shutdown == SHUTDOWN_MASK)  in bt_sock_poll()
488 	if (!skb_queue_empty(&sk->sk_receive_queue))  in bt_sock_poll()
491 	if (sk->sk_state == BT_CLOSED)  in bt_sock_poll()
494 	if (sk->sk_state == BT_CONNECT ||  in bt_sock_poll()
495 			sk->sk_state == BT_CONNECT2 ||  in bt_sock_poll()
496 			sk->sk_state == BT_CONFIG)  in bt_sock_poll()
499 	if (!test_bit(BT_SK_SUSPEND, &bt_sk(sk)->flags) && sock_writeable(sk))  in bt_sock_poll()
502 		sk_set_bit(SOCKWQ_ASYNC_NOSPACE, sk);  in bt_sock_poll()
510 	struct sock *sk = sock->sk;  in bt_sock_ioctl()  local
515 	BT_DBG("sk %p cmd %x arg %lx", sk, cmd, arg);  in bt_sock_ioctl()
519 		if (sk->sk_state == BT_LISTEN)  in bt_sock_ioctl()
522 		amount = sk->sk_sndbuf - sk_wmem_alloc_get(sk);  in bt_sock_ioctl()
529 		if (sk->sk_state == BT_LISTEN)  in bt_sock_ioctl()
532 		lock_sock(sk);  in bt_sock_ioctl()
533 		skb = skb_peek(&sk->sk_receive_queue);  in bt_sock_ioctl()
535 		release_sock(sk);  in bt_sock_ioctl()
540 		err = sock_get_timestamp(sk, (struct timeval __user *) arg);  in bt_sock_ioctl()
544 		err = sock_get_timestampns(sk, (struct timespec __user *) arg);  in bt_sock_ioctl()
557 int bt_sock_wait_state(struct sock *sk, int state, unsigned long timeo)  in bt_sock_wait_state()  argument
562 	BT_DBG("sk %p", sk);  in bt_sock_wait_state()
564 	add_wait_queue(sk_sleep(sk), &wait);  in bt_sock_wait_state()
566 	while (sk->sk_state != state) {  in bt_sock_wait_state()
577 		release_sock(sk);  in bt_sock_wait_state()
579 		lock_sock(sk);  in bt_sock_wait_state()
582 		err = sock_error(sk);  in bt_sock_wait_state()
587 	remove_wait_queue(sk_sleep(sk), &wait);  in bt_sock_wait_state()
593 int bt_sock_wait_ready(struct sock *sk, unsigned long flags)  in bt_sock_wait_ready()  argument
599 	BT_DBG("sk %p", sk);  in bt_sock_wait_ready()
601 	timeo = sock_sndtimeo(sk, flags & O_NONBLOCK);  in bt_sock_wait_ready()
603 	add_wait_queue(sk_sleep(sk), &wait);  in bt_sock_wait_ready()
605 	while (test_bit(BT_SK_SUSPEND, &bt_sk(sk)->flags)) {  in bt_sock_wait_ready()
616 		release_sock(sk);  in bt_sock_wait_ready()
618 		lock_sock(sk);  in bt_sock_wait_ready()
621 		err = sock_error(sk);  in bt_sock_wait_ready()
626 	remove_wait_queue(sk_sleep(sk), &wait);  in bt_sock_wait_ready()
679 		struct sock *sk = sk_entry(v);  in bt_seq_show()  local
680 		struct bt_sock *bt = bt_sk(sk);  in bt_seq_show()
684 			   sk,  in bt_seq_show()
685 			   atomic_read(&sk->sk_refcnt),  in bt_seq_show()
686 			   sk_rmem_alloc_get(sk),  in bt_seq_show()
687 			   sk_wmem_alloc_get(sk),  in bt_seq_show()
688 			   from_kuid(seq_user_ns(seq), sock_i_uid(sk)),  in bt_seq_show()
689 			   sock_i_ino(sk),  in bt_seq_show()