23 void rxrpc_remove_user_ID(struct rxrpc_sock *rx, struct rxrpc_call *call)  in rxrpc_remove_user_ID()  argument
28 		write_lock_bh(&rx->call_lock);  in rxrpc_remove_user_ID()
31 		write_unlock_bh(&rx->call_lock);  in rxrpc_remove_user_ID()
51 	struct rxrpc_sock *rx = rxrpc_sk(sock->sk);  in rxrpc_recvmsg()  local
66 	timeo = sock_rcvtimeo(&rx->sk, flags & MSG_DONTWAIT);  in rxrpc_recvmsg()
69 	lock_sock(&rx->sk);  in rxrpc_recvmsg()
74 		if (RB_EMPTY_ROOT(&rx->calls)) {  in rxrpc_recvmsg()
77 			if (rx->sk.sk_state != RXRPC_SERVER_LISTENING) {  in rxrpc_recvmsg()
78 				release_sock(&rx->sk);  in rxrpc_recvmsg()
86 		skb = skb_peek(&rx->sk.sk_receive_queue);  in rxrpc_recvmsg()
94 			release_sock(&rx->sk);  in rxrpc_recvmsg()
95 			prepare_to_wait_exclusive(sk_sleep(&rx->sk), &wait,  in rxrpc_recvmsg()
97 			ret = sock_error(&rx->sk);  in rxrpc_recvmsg()
101 			if (skb_queue_empty(&rx->sk.sk_receive_queue)) {  in rxrpc_recvmsg()
106 			finish_wait(sk_sleep(&rx->sk), &wait);  in rxrpc_recvmsg()
107 			lock_sock(&rx->sk);  in rxrpc_recvmsg()
124 			if (skb_dequeue(&rx->sk.sk_receive_queue) != skb)  in rxrpc_recvmsg()
135 				release_sock(&rx->sk);  in rxrpc_recvmsg()
150 			sock_recv_ts_and_drops(msg, &rx->sk, skb);  in rxrpc_recvmsg()
220 				if (skb_dequeue(&rx->sk.sk_receive_queue) !=  in rxrpc_recvmsg()
240 			if (skb == (struct sk_buff *) &rx->sk.sk_receive_queue)  in rxrpc_recvmsg()
246 		if (skb_dequeue(&rx->sk.sk_receive_queue) != skb)  in rxrpc_recvmsg()
254 	release_sock(&rx->sk);  in rxrpc_recvmsg()
273 			if (skb_dequeue(&rx->sk.sk_receive_queue) != skb)  in rxrpc_recvmsg()
325 		if (skb_dequeue(&rx->sk.sk_receive_queue) != skb)  in rxrpc_recvmsg()
328 		rxrpc_remove_user_ID(rx, call);  in rxrpc_recvmsg()
331 	release_sock(&rx->sk);  in rxrpc_recvmsg()
340 	release_sock(&rx->sk);  in rxrpc_recvmsg()
349 	release_sock(&rx->sk);  in rxrpc_recvmsg()
353 	skb_kill_datagram(&rx->sk, skb, flags);  in rxrpc_recvmsg()
360 	finish_wait(sk_sleep(&rx->sk), &wait);  in rxrpc_recvmsg()