Home
last modified time | relevance | path

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

/linux-6.3-rc2/net/core/
A Dskmsg.c496 psock = sk_psock(sk); in sk_msg_is_readable()
497 if (likely(psock)) in sk_msg_is_readable()
719 psock = kzalloc_node(sizeof(*psock), GFP_ATOMIC | __GFP_NOWARN, node); in sk_psock_init()
720 if (!psock) { in sk_psock_init()
726 psock->sk = sk; in sk_psock_init()
753 return psock; in sk_psock_init()
834 if (psock->sk_redir) in sk_psock_destroy()
836 sock_put(psock->sk); in sk_psock_destroy()
837 kfree(psock); in sk_psock_destroy()
847 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()
263 ret = PTR_ERR(psock); in sock_map_link()
267 if (psock) { in sock_map_link()
280 if (IS_ERR(psock)) { in sock_map_link()
491 psock = sk_psock(sk); in sock_map_update_common()
[all …]
/linux-6.3-rc2/net/ipv4/
A Dtcp_bpf.c144 if (unlikely(!psock)) in tcp_bpf_sendmsg_redir()
302 psock->eval = sk_psock_msg_verdict(sk, psock, msg); in tcp_bpf_send_verdict()
310 psock->cork = kzalloc(sizeof(*psock->cork), in tcp_bpf_send_verdict()
312 if (!psock->cork) in tcp_bpf_send_verdict()
320 if (psock->apply_bytes && psock->apply_bytes < tosend) in tcp_bpf_send_verdict()
343 if (psock->cork) { in tcp_bpf_send_verdict()
429 if (psock->cork) { in tcp_bpf_sendmsg()
500 if (psock->cork) { in tcp_bpf_sendpage()
501 msg = psock->cork; in tcp_bpf_sendpage()
608 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 …]
/linux-6.3-rc2/include/linux/
A Dskmsg.h361 return psock ? list_empty(&psock->ingress_msg) : true; in sk_psock_queue_empty()
422 if (psock->cork) { in sk_psock_cork_free()
423 sk_msg_free(psock->sk, psock->cork); in sk_psock_cork_free()
424 kfree(psock->cork); in sk_psock_cork_free()
425 psock->cork = NULL; in sk_psock_cork_free()
433 psock->psock_update_sk_prot(sk, psock, true); in sk_psock_restore_proto()
441 psock = sk_psock(sk); in sk_psock_get()
442 if (psock && !refcount_inc_not_zero(&psock->refcnt)) in sk_psock_get()
443 psock = NULL; in sk_psock_get()
445 return psock; in sk_psock_get()
[all …]
/linux-6.3-rc2/net/kcm/
A Dkcmsock.c101 psock->strp.stats.msgs - psock->saved_rx_msgs; in kcm_update_rx_mux_stats()
102 psock->saved_rx_msgs = psock->strp.stats.msgs; in kcm_update_rx_mux_stats()
103 psock->saved_rx_bytes = psock->strp.stats.bytes; in kcm_update_rx_mux_stats()
110 psock->stats.tx_bytes - psock->saved_tx_bytes); in kcm_update_tx_mux_stats()
112 psock->stats.tx_msgs - psock->saved_tx_msgs; in kcm_update_tx_mux_stats()
113 psock->saved_tx_msgs = psock->stats.tx_msgs; in kcm_update_tx_mux_stats()
114 psock->saved_tx_bytes = psock->stats.tx_bytes; in kcm_update_tx_mux_stats()
452 if (psock) { in reserve_psock()
594 if (unlikely(psock && psock->tx_stopped)) { in kcm_write_msgs()
628 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 …]
/linux-6.3-rc2/net/unix/
A Dunix_bpf.c30 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
60 psock = sk_psock_get(sk); in unix_bpf_recvmsg()
61 if (unlikely(!psock)) in unix_bpf_recvmsg()
66 sk_psock_queue_empty(psock)) { in unix_bpf_recvmsg()
68 sk_psock_put(sk, psock); in unix_bpf_recvmsg()
81 if (!sk_psock_queue_empty(psock)) in unix_bpf_recvmsg()
84 sk_psock_put(sk, psock); in unix_bpf_recvmsg()
90 sk_psock_put(sk, psock); in unix_bpf_recvmsg()
[all …]
/linux-6.3-rc2/drivers/pcmcia/
A Dtcic.c105 u_short psock; member
404 socket_table[sockets].psock = i; in init_tcic()
533 u_short psock; in tcic_interrupt() local
546 psock = socket_table[i].psock; in tcic_interrupt()
595 u_short psock = container_of(sock, struct tcic_socket, socket)->psock; in tcic_get_status() local
611 if (reg & (TCIC_PWR_VCC(psock)|TCIC_PWR_VPP(psock))) in tcic_get_status()
621 u_short psock = container_of(sock, struct tcic_socket, socket)->psock; in tcic_set_socket() local
631 reg &= ~(TCIC_PWR_VCC(psock) | TCIC_PWR_VPP(psock)); in tcic_set_socket()
635 case 0: reg |= TCIC_PWR_VCC(psock) | TCIC_PWR_VPP(psock); break; in tcic_set_socket()
696 u_short psock = container_of(sock, struct tcic_socket, socket)->psock; in tcic_set_io_map() local
[all …]
A Di82365.c149 u_short psock; member
224 reg = I365_REG(socket[sock].psock, reg); in i365_get()
237 u_char val = I365_REG(socket[sock].psock, reg); in i365_set()
579 socket[sockets].psock = sock; in identify()
662 static void __init add_socket(unsigned int port, int psock, int type) in add_socket() argument
665 socket[sockets].psock = psock; in add_socket()
683 t->ioaddr, t->psock*0x40); in add_pcic()
907 if (socket[sock].psock & 1) { in i365_get_status()
1120 pcic[s->type].name, s->psock);
/linux-6.3-rc2/net/tls/
A Dtls_sw.c807 struct sk_psock *psock; in bpf_exec_tx_verdict() local
816 if (!psock || !policy) { in bpf_exec_tx_verdict()
823 if (psock) in bpf_exec_tx_verdict()
831 psock->eval = sk_psock_msg_verdict(sk, psock, msg); in bpf_exec_tx_verdict()
844 switch (psock->eval) { in bpf_exec_tx_verdict()
1933 struct sk_psock *psock; in tls_sw_recvmsg() local
1983 if (psock) { in tls_sw_recvmsg()
2141 if (psock) in tls_sw_recvmsg()
2225 psock = sk_psock(sk); in tls_sw_sock_is_readable()
2226 if (psock) in tls_sw_sock_is_readable()
[all …]
/linux-6.3-rc2/include/net/
A Daf_unix.h102 int unix_dgram_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore);
103 int unix_stream_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore);
A Dudp.h531 struct proto *udp_bpf_get_proto(struct sock *sk, struct sk_psock *psock);
532 int udp_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore);
A Dtcp.h2321 struct proto *tcp_bpf_get_proto(struct sock *sk, struct sk_psock *psock);
2322 int tcp_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore);
A Dsock.h1290 struct sk_psock *psock,
/linux-6.3-rc2/Documentation/bpf/
A Dmap_sockmap.rst311 retrieve the associated socket and its attached psock.

Completed in 47 milliseconds