| /linux/net/core/ |
| A D | skmsg.c | 483 psock = sk_psock(sk); in sk_msg_is_readable()
484 if (likely(psock)) in sk_msg_is_readable()
694 psock = kzalloc_node(sizeof(*psock), GFP_ATOMIC | __GFP_NOWARN, node); in sk_psock_init()
695 if (!psock) { in sk_psock_init()
701 psock->sk = sk; in sk_psock_init()
725 return psock; in sk_psock_init()
809 if (psock->sk_redir) in sk_psock_destroy()
811 sock_put(psock->sk); in sk_psock_destroy()
812 kfree(psock); in sk_psock_destroy()
822 else if (psock->progs.stream_verdict || psock->progs.skb_verdict) in sk_psock_drop()
[all …]
|
| A D | sock_map.c | 174 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()
484 psock = sk_psock(sk); in sock_map_update_common()
485 WARN_ON_ONCE(!psock); in sock_map_update_common()
[all …]
|
| /linux/net/ipv4/ |
| A D | tcp_bpf.c | 268 psock->eval = sk_psock_msg_verdict(sk, psock, msg); in tcp_bpf_send_verdict()
275 if (!psock->cork) { in tcp_bpf_send_verdict()
276 psock->cork = kzalloc(sizeof(*psock->cork), in tcp_bpf_send_verdict()
278 if (!psock->cork) in tcp_bpf_send_verdict()
286 if (psock->apply_bytes && psock->apply_bytes < tosend) in tcp_bpf_send_verdict()
307 if (psock->cork) { in tcp_bpf_send_verdict()
387 if (psock->cork) { in tcp_bpf_sendmsg()
458 if (psock->cork) { in tcp_bpf_sendpage()
459 msg = psock->cork; in tcp_bpf_sendpage()
565 if (psock->progs.stream_verdict || psock->progs.skb_verdict) { in tcp_bpf_update_proto()
[all …]
|
| A D | udp_bpf.c | 33 !sk_psock_queue_empty(psock); in psock_has_data()
53 ret = udp_msg_has_data(sk, psock); in udp_msg_wait_data()
56 ret = udp_msg_has_data(sk, psock); in udp_msg_wait_data()
66 struct sk_psock *psock; in udp_bpf_recvmsg() local
72 psock = sk_psock_get(sk); in udp_bpf_recvmsg()
73 if (unlikely(!psock)) in udp_bpf_recvmsg()
76 if (!psock_has_data(psock)) { in udp_bpf_recvmsg()
88 data = udp_msg_wait_data(sk, psock, timeo); in udp_bpf_recvmsg()
90 if (psock_has_data(psock)) in udp_bpf_recvmsg()
99 sk_psock_put(sk, psock); in udp_bpf_recvmsg()
[all …]
|
| /linux/include/linux/ |
| A D | skmsg.h | 369 return psock ? list_empty(&psock->ingress_msg) : true; in sk_psock_queue_empty()
430 if (psock->cork) { in sk_psock_cork_free()
431 sk_msg_free(psock->sk, psock->cork); in sk_psock_cork_free()
432 kfree(psock->cork); in sk_psock_cork_free()
433 psock->cork = NULL; in sk_psock_cork_free()
441 psock->psock_update_sk_prot(sk, psock, true); in sk_psock_restore_proto()
449 psock = sk_psock(sk); in sk_psock_get()
450 if (psock && !refcount_inc_not_zero(&psock->refcnt)) in sk_psock_get()
451 psock = NULL; in sk_psock_get()
453 return psock; in sk_psock_get()
[all …]
|
| /linux/net/kcm/ |
| A D | kcmsock.c | 99 psock->strp.stats.msgs - psock->saved_rx_msgs; in kcm_update_rx_mux_stats()
100 psock->saved_rx_msgs = psock->strp.stats.msgs; in kcm_update_rx_mux_stats()
101 psock->saved_rx_bytes = psock->strp.stats.bytes; in kcm_update_rx_mux_stats()
108 psock->stats.tx_bytes - psock->saved_tx_bytes); in kcm_update_tx_mux_stats()
110 psock->stats.tx_msgs - psock->saved_tx_msgs; in kcm_update_tx_mux_stats()
111 psock->saved_tx_msgs = psock->stats.tx_msgs; in kcm_update_tx_mux_stats()
112 psock->saved_tx_bytes = psock->stats.tx_bytes; in kcm_update_tx_mux_stats()
443 if (psock) { in reserve_psock()
585 if (unlikely(psock && psock->tx_stopped)) { in kcm_write_msgs()
619 if (!psock) in kcm_write_msgs()
[all …]
|
| A D | kcmproc.c | 144 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/net/unix/ |
| A D | unix_bpf.c | 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()
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()
[all …]
|
| /linux/drivers/pcmcia/ |
| A D | tcic.c | 105 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 D | i82365.c | 149 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/net/tls/ |
| A D | tls_sw.c | 807 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()
1761 struct sk_psock *psock; in tls_sw_recvmsg() local
1813 if (psock) { in tls_sw_recvmsg()
1993 if (psock) in tls_sw_recvmsg()
2072 psock = sk_psock(sk); in tls_sw_sock_is_readable()
2073 if (psock) in tls_sw_sock_is_readable()
[all …]
|
| /linux/include/net/ |
| A D | af_unix.h | 104 int unix_dgram_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore);
105 int unix_stream_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore);
|
| A D | udp.h | 546 struct proto *udp_bpf_get_proto(struct sock *sk, struct sk_psock *psock);
547 int udp_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore);
|
| A D | tcp.h | 2240 struct proto *tcp_bpf_get_proto(struct sock *sk, struct sk_psock *psock);
2241 int tcp_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore);
|
| A D | sock.h | 1204 struct sk_psock *psock,
|