Lines Matching refs:psock
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()
55 struct sk_psock *psock; in unix_bpf_recvmsg() local
58 psock = sk_psock_get(sk); in unix_bpf_recvmsg()
59 if (unlikely(!psock)) in unix_bpf_recvmsg()
64 sk_psock_queue_empty(psock)) { in unix_bpf_recvmsg()
66 sk_psock_put(sk, psock); in unix_bpf_recvmsg()
71 copied = sk_msg_recvmsg(sk, psock, msg, len, flags); in unix_bpf_recvmsg()
77 data = unix_msg_wait_data(sk, psock, timeo); in unix_bpf_recvmsg()
79 if (!sk_psock_queue_empty(psock)) in unix_bpf_recvmsg()
82 sk_psock_put(sk, psock); in unix_bpf_recvmsg()
88 sk_psock_put(sk, psock); in unix_bpf_recvmsg()
142 int unix_dgram_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore) in unix_dgram_bpf_update_proto() argument
148 sk->sk_write_space = psock->saved_write_space; in unix_dgram_bpf_update_proto()
149 WRITE_ONCE(sk->sk_prot, psock->sk_proto); in unix_dgram_bpf_update_proto()
153 unix_dgram_bpf_check_needs_rebuild(psock->sk_proto); in unix_dgram_bpf_update_proto()
158 int unix_stream_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore) in unix_stream_bpf_update_proto() argument
161 sk->sk_write_space = psock->saved_write_space; in unix_stream_bpf_update_proto()
162 WRITE_ONCE(sk->sk_prot, psock->sk_proto); in unix_stream_bpf_update_proto()
166 unix_stream_bpf_check_needs_rebuild(psock->sk_proto); in unix_stream_bpf_update_proto()