Home
last modified time | relevance | path

Searched refs:psock (Results 1 – 11 of 11) sorted by relevance

/net/core/
A Dskmsg.c499 if (likely(psock)) in sk_msg_is_readable()
725 sk_psock_put(psock->sk, psock); in sk_psock_backlog()
745 psock = kzalloc_node(sizeof(*psock), GFP_ATOMIC | __GFP_NOWARN, node); in sk_psock_init()
746 if (!psock) { in sk_psock_init()
752 psock->sk = sk; in sk_psock_init()
779 return psock; in sk_psock_init()
857 if (psock->sk_redir) in sk_psock_destroy()
859 if (psock->sk_pair) in sk_psock_destroy()
862 kfree(psock); in sk_psock_destroy()
872 else if (psock->progs.stream_verdict || psock->progs.skb_verdict) in sk_psock_drop()
[all …]
A Dsock_map.c174 psock->psock_update_sk_prot(sk, psock, false); in sock_map_del_link()
183 if (likely(psock)) { in sock_map_unref()
202 psock = sk_psock(sk); in sock_map_psock_get_checked()
203 if (psock) { in sock_map_psock_get_checked()
214 return psock; in sock_map_psock_get_checked()
262 if (IS_ERR(psock)) { in sock_map_link()
267 if (psock) { in sock_map_link()
280 if (IS_ERR(psock)) { in sock_map_link()
493 psock = sk_psock(sk); in sock_map_update_common()
494 WARN_ON_ONCE(!psock); in sock_map_update_common()
[all …]
/net/ipv4/
A Dtcp_bpf.c169 if (unlikely(!psock)) in tcp_bpf_sendmsg_redir()
401 psock->eval = sk_psock_msg_verdict(sk, psock, msg); in tcp_bpf_send_verdict()
408 if (!psock->cork) { in tcp_bpf_send_verdict()
409 psock->cork = kzalloc(sizeof(*psock->cork), in tcp_bpf_send_verdict()
411 if (!psock->cork) in tcp_bpf_send_verdict()
419 if (psock->apply_bytes && psock->apply_bytes < tosend) in tcp_bpf_send_verdict()
442 if (psock->cork) { in tcp_bpf_send_verdict()
525 if (psock->cork) { in tcp_bpf_sendmsg()
676 tp->copied_seq = psock->copied_seq - psock->ingress_bytes; in tcp_bpf_strp_read_sock()
690 if (psock->progs.stream_verdict || psock->progs.skb_verdict) { in tcp_bpf_update_proto()
[all …]
A Dudp_bpf.c32 !sk_psock_queue_empty(psock); in psock_has_data()
52 ret = udp_msg_has_data(sk, psock); in udp_msg_wait_data()
55 ret = udp_msg_has_data(sk, psock); in udp_msg_wait_data()
65 struct sk_psock *psock; in udp_bpf_recvmsg() local
74 psock = sk_psock_get(sk); in udp_bpf_recvmsg()
75 if (unlikely(!psock)) in udp_bpf_recvmsg()
78 if (!psock_has_data(psock)) { in udp_bpf_recvmsg()
90 data = udp_msg_wait_data(sk, psock, timeo); in udp_bpf_recvmsg()
92 if (psock_has_data(psock)) in udp_bpf_recvmsg()
101 sk_psock_put(sk, psock); in udp_bpf_recvmsg()
[all …]
/net/kcm/
A Dkcmsock.c102 psock->strp.stats.msgs - psock->saved_rx_msgs; in kcm_update_rx_mux_stats()
103 psock->saved_rx_msgs = psock->strp.stats.msgs; in kcm_update_rx_mux_stats()
104 psock->saved_rx_bytes = psock->strp.stats.bytes; in kcm_update_rx_mux_stats()
111 psock->stats.tx_bytes - psock->saved_tx_bytes); in kcm_update_tx_mux_stats()
113 psock->stats.tx_msgs - psock->saved_tx_msgs; in kcm_update_tx_mux_stats()
114 psock->saved_tx_msgs = psock->stats.tx_msgs; in kcm_update_tx_mux_stats()
115 psock->saved_tx_bytes = psock->stats.tx_bytes; in kcm_update_tx_mux_stats()
453 if (psock) { in reserve_psock()
593 if (unlikely(psock && psock->tx_stopped)) { in kcm_write_msgs()
702 if (psock) in kcm_write_msgs()
[all …]
A Dkcmproc.c144 psock->index, in kcm_format_psock()
147 psock->stats.tx_msgs, in kcm_format_psock()
154 if (psock->done) in kcm_format_psock()
157 if (psock->tx_stopped) in kcm_format_psock()
160 if (psock->strp.stopped) in kcm_format_psock()
163 if (psock->tx_kcm) in kcm_format_psock()
166 if (!psock->strp.paused && !psock->ready_rx_msg) { in kcm_format_psock()
175 if (psock->strp.paused) in kcm_format_psock()
178 if (psock->ready_rx_msg) in kcm_format_psock()
190 struct kcm_psock *psock; in kcm_format_mux() local
[all …]
/net/unix/
A Dunix_bpf.c31 if (!unix_sk_has_data(sk, psock)) { in unix_msg_wait_data()
35 ret = unix_sk_has_data(sk, psock); in unix_msg_wait_data()
55 struct sk_psock *psock; in unix_bpf_recvmsg() local
64 psock = sk_psock_get(sk); in unix_bpf_recvmsg()
65 if (unlikely(!psock)) in unix_bpf_recvmsg()
70 sk_psock_queue_empty(psock)) { in unix_bpf_recvmsg()
72 sk_psock_put(sk, psock); in unix_bpf_recvmsg()
88 sk_psock_put(sk, psock); in unix_bpf_recvmsg()
94 sk_psock_put(sk, psock); in unix_bpf_recvmsg()
186 if (!psock->sk_pair) { in unix_stream_bpf_update_proto()
[all …]
A Daf_unix.h63 int unix_dgram_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore);
64 int unix_stream_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore);
/net/vmw_vsock/
A Dvsock_bpf.c34 return vsock_sk_has_data(sk, psock); in vsock_has_data()
51 ret = vsock_has_data(sk, psock); in vsock_msg_wait_data()
54 ret = vsock_has_data(sk, psock); in vsock_msg_wait_data()
79 struct sk_psock *psock; in vsock_bpf_recvmsg() local
83 psock = sk_psock_get(sk); in vsock_bpf_recvmsg()
84 if (unlikely(!psock)) in vsock_bpf_recvmsg()
95 if (vsock_has_data(sk, psock) && sk_psock_queue_empty(psock)) { in vsock_bpf_recvmsg()
97 sk_psock_put(sk, psock); in vsock_bpf_recvmsg()
110 if (sk_psock_queue_empty(psock)) { in vsock_bpf_recvmsg()
112 sk_psock_put(sk, psock); in vsock_bpf_recvmsg()
[all …]
/net/tls/
A Dtls_sw.c849 struct sk_psock *psock; in bpf_exec_tx_verdict() local
865 if (psock) in bpf_exec_tx_verdict()
873 psock->eval = sk_psock_msg_verdict(sk, psock, msg); in bpf_exec_tx_verdict()
899 switch (psock->eval) { in bpf_exec_tx_verdict()
2019 struct sk_psock *psock; in tls_sw_recvmsg() local
2071 if (psock) { in tls_sw_recvmsg()
2228 if (psock) in tls_sw_recvmsg()
2321 if (psock) { in tls_sw_read_sock()
2408 psock = sk_psock(sk); in tls_sw_sock_is_readable()
2409 if (psock) in tls_sw_sock_is_readable()
[all …]
A Dtls_main.c410 struct sk_psock *psock; in tls_sk_poll() local
424 psock = sk_psock_get(sk); in tls_sk_poll()
428 sk_psock_queue_empty(psock)) || in tls_sk_poll()
432 if (psock) in tls_sk_poll()
433 sk_psock_put(sk, psock); in tls_sk_poll()

Completed in 38 milliseconds