69 void bt_sock_reclassify_lock(struct sock *sk, int proto)  in bt_sock_reclassify_lock()  argument
71 	BUG_ON(!sk);  in bt_sock_reclassify_lock()
72 	BUG_ON(!sock_allow_reclassification(sk));  in bt_sock_reclassify_lock()
74 	sock_lock_init_class_and_name(sk,  in bt_sock_reclassify_lock()
132 			bt_sock_reclassify_lock(sock->sk, proto);  in bt_sock_create()
141 void bt_sock_link(struct bt_sock_list *l, struct sock *sk)  in bt_sock_link()  argument
144 	sk_add_node(sk, &l->head);  in bt_sock_link()
149 void bt_sock_unlink(struct bt_sock_list *l, struct sock *sk)  in bt_sock_unlink()  argument
152 	sk_del_node_init(sk);  in bt_sock_unlink()
157 void bt_accept_enqueue(struct sock *parent, struct sock *sk, bool bh)  in bt_accept_enqueue()  argument
159 	BT_DBG("parent %p, sk %p", parent, sk);  in bt_accept_enqueue()
161 	sock_hold(sk);  in bt_accept_enqueue()
164 		bh_lock_sock_nested(sk);  in bt_accept_enqueue()
166 		lock_sock_nested(sk, SINGLE_DEPTH_NESTING);  in bt_accept_enqueue()
168 	list_add_tail(&bt_sk(sk)->accept_q, &bt_sk(parent)->accept_q);  in bt_accept_enqueue()
169 	bt_sk(sk)->parent = parent;  in bt_accept_enqueue()
172 		bh_unlock_sock(sk);  in bt_accept_enqueue()
174 		release_sock(sk);  in bt_accept_enqueue()
183 void bt_accept_unlink(struct sock *sk)  in bt_accept_unlink()  argument
185 	BT_DBG("sk %p state %d", sk, sk->sk_state);  in bt_accept_unlink()
187 	list_del_init(&bt_sk(sk)->accept_q);  in bt_accept_unlink()
188 	bt_sk(sk)->parent->sk_ack_backlog--;  in bt_accept_unlink()
189 	bt_sk(sk)->parent = NULL;  in bt_accept_unlink()
190 	sock_put(sk);  in bt_accept_unlink()
197 	struct sock *sk;  in bt_accept_dequeue()  local
203 		sk = (struct sock *)s;  in bt_accept_dequeue()
206 		sock_hold(sk);  in bt_accept_dequeue()
207 		lock_sock(sk);  in bt_accept_dequeue()
212 		if (!bt_sk(sk)->parent) {  in bt_accept_dequeue()
213 			BT_DBG("sk %p, already unlinked", sk);  in bt_accept_dequeue()
214 			release_sock(sk);  in bt_accept_dequeue()
215 			sock_put(sk);  in bt_accept_dequeue()
225 		sock_put(sk);  in bt_accept_dequeue()
228 		if (sk->sk_state == BT_CLOSED) {  in bt_accept_dequeue()
229 			bt_accept_unlink(sk);  in bt_accept_dequeue()
230 			release_sock(sk);  in bt_accept_dequeue()
234 		if (sk->sk_state == BT_CONNECTED || !newsock ||  in bt_accept_dequeue()
236 			bt_accept_unlink(sk);  in bt_accept_dequeue()
238 				sock_graft(sk, newsock);  in bt_accept_dequeue()
240 			release_sock(sk);  in bt_accept_dequeue()
241 			return sk;  in bt_accept_dequeue()
244 		release_sock(sk);  in bt_accept_dequeue()
255 	struct sock *sk = sock->sk;  in bt_sock_recvmsg()  local
261 	BT_DBG("sock %p sk %p len %zu", sock, sk, len);  in bt_sock_recvmsg()
266 	skb = skb_recv_datagram(sk, flags, noblock, &err);  in bt_sock_recvmsg()
268 		if (sk->sk_shutdown & RCV_SHUTDOWN)  in bt_sock_recvmsg()
284 		sock_recv_ts_and_drops(msg, sk, skb);  in bt_sock_recvmsg()
286 		if (msg->msg_name && bt_sk(sk)->skb_msg_name)  in bt_sock_recvmsg()
287 			bt_sk(sk)->skb_msg_name(skb, msg->msg_name,  in bt_sock_recvmsg()
291 	skb_free_datagram(sk, skb);  in bt_sock_recvmsg()
300 static long bt_sock_data_wait(struct sock *sk, long timeo)  in bt_sock_data_wait()  argument
304 	add_wait_queue(sk_sleep(sk), &wait);  in bt_sock_data_wait()
308 		if (!skb_queue_empty(&sk->sk_receive_queue))  in bt_sock_data_wait()
311 		if (sk->sk_err || (sk->sk_shutdown & RCV_SHUTDOWN))  in bt_sock_data_wait()
317 		sk_set_bit(SOCKWQ_ASYNC_WAITDATA, sk);  in bt_sock_data_wait()
318 		release_sock(sk);  in bt_sock_data_wait()
320 		lock_sock(sk);  in bt_sock_data_wait()
321 		sk_clear_bit(SOCKWQ_ASYNC_WAITDATA, sk);  in bt_sock_data_wait()
325 	remove_wait_queue(sk_sleep(sk), &wait);  in bt_sock_data_wait()
332 	struct sock *sk = sock->sk;  in bt_sock_stream_recvmsg()  local
340 	BT_DBG("sk %p size %zu", sk, size);  in bt_sock_stream_recvmsg()
342 	lock_sock(sk);  in bt_sock_stream_recvmsg()
344 	target = sock_rcvlowat(sk, flags & MSG_WAITALL, size);  in bt_sock_stream_recvmsg()
345 	timeo  = sock_rcvtimeo(sk, flags & MSG_DONTWAIT);  in bt_sock_stream_recvmsg()
351 		skb = skb_dequeue(&sk->sk_receive_queue);  in bt_sock_stream_recvmsg()
356 			err = sock_error(sk);  in bt_sock_stream_recvmsg()
359 			if (sk->sk_shutdown & RCV_SHUTDOWN)  in bt_sock_stream_recvmsg()
366 			timeo = bt_sock_data_wait(sk, timeo);  in bt_sock_stream_recvmsg()
377 			skb_queue_head(&sk->sk_receive_queue, skb);  in bt_sock_stream_recvmsg()
385 		sock_recv_ts_and_drops(msg, sk, skb);  in bt_sock_stream_recvmsg()
416 				skb_queue_head(&sk->sk_receive_queue, skb);  in bt_sock_stream_recvmsg()
423 			skb_queue_head(&sk->sk_receive_queue, skb);  in bt_sock_stream_recvmsg()
429 	release_sock(sk);  in bt_sock_stream_recvmsg()
437 	struct sock *sk;  in bt_accept_poll()  local
440 		sk = (struct sock *)s;  in bt_accept_poll()
441 		if (sk->sk_state == BT_CONNECTED ||  in bt_accept_poll()
443 		     sk->sk_state == BT_CONNECT2))  in bt_accept_poll()
453 	struct sock *sk = sock->sk;  in bt_sock_poll()  local
456 	BT_DBG("sock %p, sk %p", sock, sk);  in bt_sock_poll()
458 	poll_wait(file, sk_sleep(sk), wait);  in bt_sock_poll()
460 	if (sk->sk_state == BT_LISTEN)  in bt_sock_poll()
461 		return bt_accept_poll(sk);  in bt_sock_poll()
463 	if (sk->sk_err || !skb_queue_empty_lockless(&sk->sk_error_queue))  in bt_sock_poll()
465 			(sock_flag(sk, SOCK_SELECT_ERR_QUEUE) ? EPOLLPRI : 0);  in bt_sock_poll()
467 	if (sk->sk_shutdown & RCV_SHUTDOWN)  in bt_sock_poll()
470 	if (sk->sk_shutdown == SHUTDOWN_MASK)  in bt_sock_poll()
473 	if (!skb_queue_empty_lockless(&sk->sk_receive_queue))  in bt_sock_poll()
476 	if (sk->sk_state == BT_CLOSED)  in bt_sock_poll()
479 	if (sk->sk_state == BT_CONNECT ||  in bt_sock_poll()
480 			sk->sk_state == BT_CONNECT2 ||  in bt_sock_poll()
481 			sk->sk_state == BT_CONFIG)  in bt_sock_poll()
484 	if (!test_bit(BT_SK_SUSPEND, &bt_sk(sk)->flags) && sock_writeable(sk))  in bt_sock_poll()
487 		sk_set_bit(SOCKWQ_ASYNC_NOSPACE, sk);  in bt_sock_poll()
495 	struct sock *sk = sock->sk;  in bt_sock_ioctl()  local
500 	BT_DBG("sk %p cmd %x arg %lx", sk, cmd, arg);  in bt_sock_ioctl()
504 		if (sk->sk_state == BT_LISTEN)  in bt_sock_ioctl()
507 		amount = sk->sk_sndbuf - sk_wmem_alloc_get(sk);  in bt_sock_ioctl()
514 		if (sk->sk_state == BT_LISTEN)  in bt_sock_ioctl()
517 		lock_sock(sk);  in bt_sock_ioctl()
518 		skb = skb_peek(&sk->sk_receive_queue);  in bt_sock_ioctl()
520 		release_sock(sk);  in bt_sock_ioctl()
534 int bt_sock_wait_state(struct sock *sk, int state, unsigned long timeo)  in bt_sock_wait_state()  argument
539 	BT_DBG("sk %p", sk);  in bt_sock_wait_state()
541 	add_wait_queue(sk_sleep(sk), &wait);  in bt_sock_wait_state()
543 	while (sk->sk_state != state) {  in bt_sock_wait_state()
554 		release_sock(sk);  in bt_sock_wait_state()
556 		lock_sock(sk);  in bt_sock_wait_state()
559 		err = sock_error(sk);  in bt_sock_wait_state()
564 	remove_wait_queue(sk_sleep(sk), &wait);  in bt_sock_wait_state()
570 int bt_sock_wait_ready(struct sock *sk, unsigned long flags)  in bt_sock_wait_ready()  argument
576 	BT_DBG("sk %p", sk);  in bt_sock_wait_ready()
578 	timeo = sock_sndtimeo(sk, flags & O_NONBLOCK);  in bt_sock_wait_ready()
580 	add_wait_queue(sk_sleep(sk), &wait);  in bt_sock_wait_ready()
582 	while (test_bit(BT_SK_SUSPEND, &bt_sk(sk)->flags)) {  in bt_sock_wait_ready()
593 		release_sock(sk);  in bt_sock_wait_ready()
595 		lock_sock(sk);  in bt_sock_wait_ready()
598 		err = sock_error(sk);  in bt_sock_wait_ready()
603 	remove_wait_queue(sk_sleep(sk), &wait);  in bt_sock_wait_ready()
648 		struct sock *sk = sk_entry(v);  in bt_seq_show()  local
649 		struct bt_sock *bt = bt_sk(sk);  in bt_seq_show()
653 			   sk,  in bt_seq_show()
654 			   refcount_read(&sk->sk_refcnt),  in bt_seq_show()
655 			   sk_rmem_alloc_get(sk),  in bt_seq_show()
656 			   sk_wmem_alloc_get(sk),  in bt_seq_show()
657 			   from_kuid(seq_user_ns(seq), sock_i_uid(sk)),  in bt_seq_show()
658 			   sock_i_ino(sk),  in bt_seq_show()