15 static int unix_msg_wait_data(struct sock *sk, struct sk_psock *psock,  in unix_msg_wait_data()  argument
30 	if (!unix_sk_has_data(sk, psock)) {  in unix_msg_wait_data()
34 		ret = unix_sk_has_data(sk, psock);  in unix_msg_wait_data()
54 	struct sk_psock *psock;  in unix_bpf_recvmsg()  local
63 	psock = sk_psock_get(sk);  in unix_bpf_recvmsg()
64 	if (unlikely(!psock))  in unix_bpf_recvmsg()
69 	    sk_psock_queue_empty(psock)) {  in unix_bpf_recvmsg()
71 		sk_psock_put(sk, psock);  in unix_bpf_recvmsg()
76 	copied = sk_msg_recvmsg(sk, psock, msg, len, flags);  in unix_bpf_recvmsg()
82 		data = unix_msg_wait_data(sk, psock, timeo);  in unix_bpf_recvmsg()
84 			if (!sk_psock_queue_empty(psock))  in unix_bpf_recvmsg()
87 			sk_psock_put(sk, psock);  in unix_bpf_recvmsg()
93 	sk_psock_put(sk, psock);  in unix_bpf_recvmsg()
147 int unix_dgram_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore)  in unix_dgram_bpf_update_proto()  argument
153 		sk->sk_write_space = psock->saved_write_space;  in unix_dgram_bpf_update_proto()
154 		sock_replace_proto(sk, psock->sk_proto);  in unix_dgram_bpf_update_proto()
158 	unix_dgram_bpf_check_needs_rebuild(psock->sk_proto);  in unix_dgram_bpf_update_proto()
163 int unix_stream_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore)  in unix_stream_bpf_update_proto()  argument
172 		sk->sk_write_space = psock->saved_write_space;  in unix_stream_bpf_update_proto()
173 		sock_replace_proto(sk, psock->sk_proto);  in unix_stream_bpf_update_proto()
185 	if (!psock->sk_pair) {  in unix_stream_bpf_update_proto()
188 		psock->sk_pair = sk_pair;  in unix_stream_bpf_update_proto()
191 	unix_stream_bpf_check_needs_rebuild(psock->sk_proto);  in unix_stream_bpf_update_proto()