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()
143 void bt_sock_link(struct bt_sock_list *l, struct sock *sk)  in bt_sock_link()  argument
146 	sk_add_node(sk, &l->head);  in bt_sock_link()
151 void bt_sock_unlink(struct bt_sock_list *l, struct sock *sk)  in bt_sock_unlink()  argument
154 	sk_del_node_init(sk);  in bt_sock_unlink()
159 void bt_accept_enqueue(struct sock *parent, struct sock *sk, bool bh)  in bt_accept_enqueue()  argument
161 	BT_DBG("parent %p, sk %p", parent, sk);  in bt_accept_enqueue()
163 	sock_hold(sk);  in bt_accept_enqueue()
166 		bh_lock_sock_nested(sk);  in bt_accept_enqueue()
168 		lock_sock_nested(sk, SINGLE_DEPTH_NESTING);  in bt_accept_enqueue()
170 	list_add_tail(&bt_sk(sk)->accept_q, &bt_sk(parent)->accept_q);  in bt_accept_enqueue()
171 	bt_sk(sk)->parent = parent;  in bt_accept_enqueue()
174 		bh_unlock_sock(sk);  in bt_accept_enqueue()
176 		release_sock(sk);  in bt_accept_enqueue()
185 void bt_accept_unlink(struct sock *sk)  in bt_accept_unlink()  argument
187 	BT_DBG("sk %p state %d", sk, sk->sk_state);  in bt_accept_unlink()
189 	list_del_init(&bt_sk(sk)->accept_q);  in bt_accept_unlink()
190 	sk_acceptq_removed(bt_sk(sk)->parent);  in bt_accept_unlink()
191 	bt_sk(sk)->parent = NULL;  in bt_accept_unlink()
192 	sock_put(sk);  in bt_accept_unlink()
199 	struct sock *sk;  in bt_accept_dequeue()  local
205 		sk = (struct sock *)s;  in bt_accept_dequeue()
208 		sock_hold(sk);  in bt_accept_dequeue()
209 		lock_sock(sk);  in bt_accept_dequeue()
214 		if (!bt_sk(sk)->parent) {  in bt_accept_dequeue()
215 			BT_DBG("sk %p, already unlinked", sk);  in bt_accept_dequeue()
216 			release_sock(sk);  in bt_accept_dequeue()
217 			sock_put(sk);  in bt_accept_dequeue()
227 		sock_put(sk);  in bt_accept_dequeue()
230 		if (sk->sk_state == BT_CLOSED) {  in bt_accept_dequeue()
231 			bt_accept_unlink(sk);  in bt_accept_dequeue()
232 			release_sock(sk);  in bt_accept_dequeue()
236 		if (sk->sk_state == BT_CONNECTED || !newsock ||  in bt_accept_dequeue()
238 			bt_accept_unlink(sk);  in bt_accept_dequeue()
240 				sock_graft(sk, newsock);  in bt_accept_dequeue()
242 			release_sock(sk);  in bt_accept_dequeue()
243 			return sk;  in bt_accept_dequeue()
246 		release_sock(sk);  in bt_accept_dequeue()
256 	struct sock *sk = sock->sk;  in bt_sock_recvmsg()  local
262 	BT_DBG("sock %p sk %p len %zu", sock, sk, len);  in bt_sock_recvmsg()
267 	skb = skb_recv_datagram(sk, flags, &err);  in bt_sock_recvmsg()
269 		if (sk->sk_shutdown & RCV_SHUTDOWN)  in bt_sock_recvmsg()
285 		sock_recv_cmsgs(msg, sk, skb);  in bt_sock_recvmsg()
287 		if (msg->msg_name && bt_sk(sk)->skb_msg_name)  in bt_sock_recvmsg()
288 			bt_sk(sk)->skb_msg_name(skb, msg->msg_name,  in bt_sock_recvmsg()
291 		if (bt_sk(sk)->skb_put_cmsg)  in bt_sock_recvmsg()
292 			bt_sk(sk)->skb_put_cmsg(skb, msg, sk);  in bt_sock_recvmsg()
295 	skb_free_datagram(sk, skb);  in bt_sock_recvmsg()
304 static long bt_sock_data_wait(struct sock *sk, long timeo)  in bt_sock_data_wait()  argument
308 	add_wait_queue(sk_sleep(sk), &wait);  in bt_sock_data_wait()
312 		if (!skb_queue_empty(&sk->sk_receive_queue))  in bt_sock_data_wait()
315 		if (sk->sk_err || (sk->sk_shutdown & RCV_SHUTDOWN))  in bt_sock_data_wait()
321 		sk_set_bit(SOCKWQ_ASYNC_WAITDATA, sk);  in bt_sock_data_wait()
322 		release_sock(sk);  in bt_sock_data_wait()
324 		lock_sock(sk);  in bt_sock_data_wait()
325 		sk_clear_bit(SOCKWQ_ASYNC_WAITDATA, sk);  in bt_sock_data_wait()
329 	remove_wait_queue(sk_sleep(sk), &wait);  in bt_sock_data_wait()
336 	struct sock *sk = sock->sk;  in bt_sock_stream_recvmsg()  local
344 	BT_DBG("sk %p size %zu", sk, size);  in bt_sock_stream_recvmsg()
346 	lock_sock(sk);  in bt_sock_stream_recvmsg()
348 	target = sock_rcvlowat(sk, flags & MSG_WAITALL, size);  in bt_sock_stream_recvmsg()
349 	timeo  = sock_rcvtimeo(sk, flags & MSG_DONTWAIT);  in bt_sock_stream_recvmsg()
355 		skb = skb_dequeue(&sk->sk_receive_queue);  in bt_sock_stream_recvmsg()
360 			err = sock_error(sk);  in bt_sock_stream_recvmsg()
363 			if (sk->sk_shutdown & RCV_SHUTDOWN)  in bt_sock_stream_recvmsg()
370 			timeo = bt_sock_data_wait(sk, timeo);  in bt_sock_stream_recvmsg()
381 			skb_queue_head(&sk->sk_receive_queue, skb);  in bt_sock_stream_recvmsg()
389 		sock_recv_cmsgs(msg, sk, skb);  in bt_sock_stream_recvmsg()
420 				skb_queue_head(&sk->sk_receive_queue, skb);  in bt_sock_stream_recvmsg()
427 			skb_queue_head(&sk->sk_receive_queue, skb);  in bt_sock_stream_recvmsg()
433 	release_sock(sk);  in bt_sock_stream_recvmsg()
441 	struct sock *sk;  in bt_accept_poll()  local
444 		sk = (struct sock *)s;  in bt_accept_poll()
445 		if (sk->sk_state == BT_CONNECTED ||  in bt_accept_poll()
447 		     sk->sk_state == BT_CONNECT2))  in bt_accept_poll()
457 	struct sock *sk = sock->sk;  in bt_sock_poll()  local
460 	poll_wait(file, sk_sleep(sk), wait);  in bt_sock_poll()
462 	if (sk->sk_state == BT_LISTEN)  in bt_sock_poll()
463 		return bt_accept_poll(sk);  in bt_sock_poll()
465 	if (sk->sk_err || !skb_queue_empty_lockless(&sk->sk_error_queue))  in bt_sock_poll()
467 			(sock_flag(sk, SOCK_SELECT_ERR_QUEUE) ? EPOLLPRI : 0);  in bt_sock_poll()
469 	if (sk->sk_shutdown & RCV_SHUTDOWN)  in bt_sock_poll()
472 	if (sk->sk_shutdown == SHUTDOWN_MASK)  in bt_sock_poll()
475 	if (!skb_queue_empty_lockless(&sk->sk_receive_queue))  in bt_sock_poll()
478 	if (sk->sk_state == BT_CLOSED)  in bt_sock_poll()
481 	if (sk->sk_state == BT_CONNECT ||  in bt_sock_poll()
482 	    sk->sk_state == BT_CONNECT2 ||  in bt_sock_poll()
483 	    sk->sk_state == BT_CONFIG)  in bt_sock_poll()
486 	if (!test_bit(BT_SK_SUSPEND, &bt_sk(sk)->flags) && sock_writeable(sk))  in bt_sock_poll()
489 		sk_set_bit(SOCKWQ_ASYNC_NOSPACE, sk);  in bt_sock_poll()
497 	struct sock *sk = sock->sk;  in bt_sock_ioctl()  local
502 	BT_DBG("sk %p cmd %x arg %lx", sk, cmd, arg);  in bt_sock_ioctl()
506 		if (sk->sk_state == BT_LISTEN)  in bt_sock_ioctl()
509 		amount = sk->sk_sndbuf - sk_wmem_alloc_get(sk);  in bt_sock_ioctl()
516 		if (sk->sk_state == BT_LISTEN)  in bt_sock_ioctl()
519 		lock_sock(sk);  in bt_sock_ioctl()
520 		skb = skb_peek(&sk->sk_receive_queue);  in bt_sock_ioctl()
522 		release_sock(sk);  in bt_sock_ioctl()
536 int bt_sock_wait_state(struct sock *sk, int state, unsigned long timeo)  in bt_sock_wait_state()  argument
541 	BT_DBG("sk %p", sk);  in bt_sock_wait_state()
543 	add_wait_queue(sk_sleep(sk), &wait);  in bt_sock_wait_state()
545 	while (sk->sk_state != state) {  in bt_sock_wait_state()
556 		release_sock(sk);  in bt_sock_wait_state()
558 		lock_sock(sk);  in bt_sock_wait_state()
561 		err = sock_error(sk);  in bt_sock_wait_state()
566 	remove_wait_queue(sk_sleep(sk), &wait);  in bt_sock_wait_state()
572 int bt_sock_wait_ready(struct sock *sk, unsigned int msg_flags)  in bt_sock_wait_ready()  argument
578 	BT_DBG("sk %p", sk);  in bt_sock_wait_ready()
580 	timeo = sock_sndtimeo(sk, !!(msg_flags & MSG_DONTWAIT));  in bt_sock_wait_ready()
582 	add_wait_queue(sk_sleep(sk), &wait);  in bt_sock_wait_ready()
584 	while (test_bit(BT_SK_SUSPEND, &bt_sk(sk)->flags)) {  in bt_sock_wait_ready()
595 		release_sock(sk);  in bt_sock_wait_ready()
597 		lock_sock(sk);  in bt_sock_wait_ready()
600 		err = sock_error(sk);  in bt_sock_wait_ready()
605 	remove_wait_queue(sk_sleep(sk), &wait);  in bt_sock_wait_ready()
650 		struct sock *sk = sk_entry(v);  in bt_seq_show()  local
651 		struct bt_sock *bt = bt_sk(sk);  in bt_seq_show()
655 			   sk,  in bt_seq_show()
656 			   refcount_read(&sk->sk_refcnt),  in bt_seq_show()
657 			   sk_rmem_alloc_get(sk),  in bt_seq_show()
658 			   sk_wmem_alloc_get(sk),  in bt_seq_show()
659 			   from_kuid(seq_user_ns(seq), sock_i_uid(sk)),  in bt_seq_show()
660 			   sock_i_ino(sk),  in bt_seq_show()