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)  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()
162 	lock_sock_nested(sk, SINGLE_DEPTH_NESTING);  in bt_accept_enqueue()
163 	list_add_tail(&bt_sk(sk)->accept_q, &bt_sk(parent)->accept_q);  in bt_accept_enqueue()
164 	bt_sk(sk)->parent = parent;  in bt_accept_enqueue()
165 	release_sock(sk);  in bt_accept_enqueue()
173 void bt_accept_unlink(struct sock *sk)  in bt_accept_unlink()  argument
175 	BT_DBG("sk %p state %d", sk, sk->sk_state);  in bt_accept_unlink()
177 	list_del_init(&bt_sk(sk)->accept_q);  in bt_accept_unlink()
178 	bt_sk(sk)->parent->sk_ack_backlog--;  in bt_accept_unlink()
179 	bt_sk(sk)->parent = NULL;  in bt_accept_unlink()
180 	sock_put(sk);  in bt_accept_unlink()
187 	struct sock *sk;  in bt_accept_dequeue()  local
193 		sk = (struct sock *)s;  in bt_accept_dequeue()
196 		sock_hold(sk);  in bt_accept_dequeue()
197 		lock_sock(sk);  in bt_accept_dequeue()
202 		if (!bt_sk(sk)->parent) {  in bt_accept_dequeue()
203 			BT_DBG("sk %p, already unlinked", sk);  in bt_accept_dequeue()
204 			release_sock(sk);  in bt_accept_dequeue()
205 			sock_put(sk);  in bt_accept_dequeue()
215 		sock_put(sk);  in bt_accept_dequeue()
218 		if (sk->sk_state == BT_CLOSED) {  in bt_accept_dequeue()
219 			bt_accept_unlink(sk);  in bt_accept_dequeue()
220 			release_sock(sk);  in bt_accept_dequeue()
224 		if (sk->sk_state == BT_CONNECTED || !newsock ||  in bt_accept_dequeue()
226 			bt_accept_unlink(sk);  in bt_accept_dequeue()
228 				sock_graft(sk, newsock);  in bt_accept_dequeue()
230 			release_sock(sk);  in bt_accept_dequeue()
231 			return sk;  in bt_accept_dequeue()
234 		release_sock(sk);  in bt_accept_dequeue()
245 	struct sock *sk = sock->sk;  in bt_sock_recvmsg()  local
251 	BT_DBG("sock %p sk %p len %zu", sock, sk, len);  in bt_sock_recvmsg()
256 	skb = skb_recv_datagram(sk, flags, noblock, &err);  in bt_sock_recvmsg()
258 		if (sk->sk_shutdown & RCV_SHUTDOWN)  in bt_sock_recvmsg()
274 		sock_recv_ts_and_drops(msg, sk, skb);  in bt_sock_recvmsg()
276 		if (msg->msg_name && bt_sk(sk)->skb_msg_name)  in bt_sock_recvmsg()
277 			bt_sk(sk)->skb_msg_name(skb, msg->msg_name,  in bt_sock_recvmsg()
281 	skb_free_datagram(sk, skb);  in bt_sock_recvmsg()
290 static long bt_sock_data_wait(struct sock *sk, long timeo)  in bt_sock_data_wait()  argument
294 	add_wait_queue(sk_sleep(sk), &wait);  in bt_sock_data_wait()
298 		if (!skb_queue_empty(&sk->sk_receive_queue))  in bt_sock_data_wait()
301 		if (sk->sk_err || (sk->sk_shutdown & RCV_SHUTDOWN))  in bt_sock_data_wait()
307 		sk_set_bit(SOCKWQ_ASYNC_WAITDATA, sk);  in bt_sock_data_wait()
308 		release_sock(sk);  in bt_sock_data_wait()
310 		lock_sock(sk);  in bt_sock_data_wait()
311 		sk_clear_bit(SOCKWQ_ASYNC_WAITDATA, sk);  in bt_sock_data_wait()
315 	remove_wait_queue(sk_sleep(sk), &wait);  in bt_sock_data_wait()
322 	struct sock *sk = sock->sk;  in bt_sock_stream_recvmsg()  local
330 	BT_DBG("sk %p size %zu", sk, size);  in bt_sock_stream_recvmsg()
332 	lock_sock(sk);  in bt_sock_stream_recvmsg()
334 	target = sock_rcvlowat(sk, flags & MSG_WAITALL, size);  in bt_sock_stream_recvmsg()
335 	timeo  = sock_rcvtimeo(sk, flags & MSG_DONTWAIT);  in bt_sock_stream_recvmsg()
341 		skb = skb_dequeue(&sk->sk_receive_queue);  in bt_sock_stream_recvmsg()
346 			err = sock_error(sk);  in bt_sock_stream_recvmsg()
349 			if (sk->sk_shutdown & RCV_SHUTDOWN)  in bt_sock_stream_recvmsg()
356 			timeo = bt_sock_data_wait(sk, timeo);  in bt_sock_stream_recvmsg()
367 			skb_queue_head(&sk->sk_receive_queue, skb);  in bt_sock_stream_recvmsg()
375 		sock_recv_ts_and_drops(msg, sk, skb);  in bt_sock_stream_recvmsg()
406 				skb_queue_head(&sk->sk_receive_queue, skb);  in bt_sock_stream_recvmsg()
413 			skb_queue_head(&sk->sk_receive_queue, skb);  in bt_sock_stream_recvmsg()
419 	release_sock(sk);  in bt_sock_stream_recvmsg()
427 	struct sock *sk;  in bt_accept_poll()  local
430 		sk = (struct sock *)s;  in bt_accept_poll()
431 		if (sk->sk_state == BT_CONNECTED ||  in bt_accept_poll()
433 		     sk->sk_state == BT_CONNECT2))  in bt_accept_poll()
443 	struct sock *sk = sock->sk;  in bt_sock_poll()  local
446 	BT_DBG("sock %p, sk %p", sock, sk);  in bt_sock_poll()
448 	poll_wait(file, sk_sleep(sk), wait);  in bt_sock_poll()
450 	if (sk->sk_state == BT_LISTEN)  in bt_sock_poll()
451 		return bt_accept_poll(sk);  in bt_sock_poll()
453 	if (sk->sk_err || !skb_queue_empty(&sk->sk_error_queue))  in bt_sock_poll()
455 			(sock_flag(sk, SOCK_SELECT_ERR_QUEUE) ? EPOLLPRI : 0);  in bt_sock_poll()
457 	if (sk->sk_shutdown & RCV_SHUTDOWN)  in bt_sock_poll()
460 	if (sk->sk_shutdown == SHUTDOWN_MASK)  in bt_sock_poll()
463 	if (!skb_queue_empty(&sk->sk_receive_queue))  in bt_sock_poll()
466 	if (sk->sk_state == BT_CLOSED)  in bt_sock_poll()
469 	if (sk->sk_state == BT_CONNECT ||  in bt_sock_poll()
470 			sk->sk_state == BT_CONNECT2 ||  in bt_sock_poll()
471 			sk->sk_state == BT_CONFIG)  in bt_sock_poll()
474 	if (!test_bit(BT_SK_SUSPEND, &bt_sk(sk)->flags) && sock_writeable(sk))  in bt_sock_poll()
477 		sk_set_bit(SOCKWQ_ASYNC_NOSPACE, sk);  in bt_sock_poll()
485 	struct sock *sk = sock->sk;  in bt_sock_ioctl()  local
490 	BT_DBG("sk %p cmd %x arg %lx", sk, cmd, arg);  in bt_sock_ioctl()
494 		if (sk->sk_state == BT_LISTEN)  in bt_sock_ioctl()
497 		amount = sk->sk_sndbuf - sk_wmem_alloc_get(sk);  in bt_sock_ioctl()
504 		if (sk->sk_state == BT_LISTEN)  in bt_sock_ioctl()
507 		lock_sock(sk);  in bt_sock_ioctl()
508 		skb = skb_peek(&sk->sk_receive_queue);  in bt_sock_ioctl()
510 		release_sock(sk);  in bt_sock_ioctl()
515 		err = sock_get_timestamp(sk, (struct timeval __user *) arg);  in bt_sock_ioctl()
519 		err = sock_get_timestampns(sk, (struct timespec __user *) arg);  in bt_sock_ioctl()
532 int bt_sock_wait_state(struct sock *sk, int state, unsigned long timeo)  in bt_sock_wait_state()  argument
537 	BT_DBG("sk %p", sk);  in bt_sock_wait_state()
539 	add_wait_queue(sk_sleep(sk), &wait);  in bt_sock_wait_state()
541 	while (sk->sk_state != state) {  in bt_sock_wait_state()
552 		release_sock(sk);  in bt_sock_wait_state()
554 		lock_sock(sk);  in bt_sock_wait_state()
557 		err = sock_error(sk);  in bt_sock_wait_state()
562 	remove_wait_queue(sk_sleep(sk), &wait);  in bt_sock_wait_state()
568 int bt_sock_wait_ready(struct sock *sk, unsigned long flags)  in bt_sock_wait_ready()  argument
574 	BT_DBG("sk %p", sk);  in bt_sock_wait_ready()
576 	timeo = sock_sndtimeo(sk, flags & O_NONBLOCK);  in bt_sock_wait_ready()
578 	add_wait_queue(sk_sleep(sk), &wait);  in bt_sock_wait_ready()
580 	while (test_bit(BT_SK_SUSPEND, &bt_sk(sk)->flags)) {  in bt_sock_wait_ready()
591 		release_sock(sk);  in bt_sock_wait_ready()
593 		lock_sock(sk);  in bt_sock_wait_ready()
596 		err = sock_error(sk);  in bt_sock_wait_ready()
601 	remove_wait_queue(sk_sleep(sk), &wait);  in bt_sock_wait_ready()
646 		struct sock *sk = sk_entry(v);  in bt_seq_show()  local
647 		struct bt_sock *bt = bt_sk(sk);  in bt_seq_show()
651 			   sk,  in bt_seq_show()
652 			   refcount_read(&sk->sk_refcnt),  in bt_seq_show()
653 			   sk_rmem_alloc_get(sk),  in bt_seq_show()
654 			   sk_wmem_alloc_get(sk),  in bt_seq_show()
655 			   from_kuid(seq_user_ns(seq), sock_i_uid(sk)),  in bt_seq_show()
656 			   sock_i_ino(sk),  in bt_seq_show()