Home
last modified time | relevance | path

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

/linux/net/core/
A Dskmsg.c496 if (likely(psock)) in sk_msg_is_readable()
718 psock = kzalloc_node(sizeof(*psock), GFP_ATOMIC | __GFP_NOWARN, node); in sk_psock_init()
719 if (!psock) { in sk_psock_init()
725 psock->sk = sk; in sk_psock_init()
752 return psock; in sk_psock_init()
828 if (psock->sk_redir) in sk_psock_destroy()
830 if (psock->sk_pair) in sk_psock_destroy()
832 sock_put(psock->sk); in sk_psock_destroy()
833 kfree(psock); in sk_psock_destroy()
843 else if (psock->progs.stream_verdict || psock->progs.skb_verdict) in sk_psock_drop()
[all …]
A Dsock_map.c173 psock->psock_update_sk_prot(sk, psock, false); in sock_map_del_link()
182 if (likely(psock)) { in sock_map_unref()
201 psock = sk_psock(sk); in sock_map_psock_get_checked()
202 if (psock) { in sock_map_psock_get_checked()
213 return psock; in sock_map_psock_get_checked()
261 if (IS_ERR(psock)) { in sock_map_link()
266 if (psock) { in sock_map_link()
279 if (IS_ERR(psock)) { in sock_map_link()
490 psock = sk_psock(sk); in sock_map_update_common()
491 WARN_ON_ONCE(!psock); in sock_map_update_common()
[all …]
/linux/include/linux/
A Dskmsg.h371 return psock ? list_empty(&psock->ingress_msg) : true; in sk_psock_queue_empty()
435 if (psock->cork) { in sk_psock_cork_free()
436 sk_msg_free(psock->sk, psock->cork); in sk_psock_cork_free()
437 kfree(psock->cork); in sk_psock_cork_free()
438 psock->cork = NULL; in sk_psock_cork_free()
446 psock->psock_update_sk_prot(sk, psock, true); in sk_psock_restore_proto()
454 psock = sk_psock(sk); in sk_psock_get()
455 if (psock && !refcount_inc_not_zero(&psock->refcnt)) in sk_psock_get()
456 psock = NULL; in sk_psock_get()
458 return psock; in sk_psock_get()
[all …]
/linux/net/ipv4/
A Dtcp_bpf.c167 if (unlikely(!psock)) in tcp_bpf_sendmsg_redir()
237 if (unlikely(!psock)) in tcp_bpf_recvmsg_parser()
399 psock->eval = sk_psock_msg_verdict(sk, psock, msg); in tcp_bpf_send_verdict()
406 if (!psock->cork) { in tcp_bpf_send_verdict()
407 psock->cork = kzalloc(sizeof(*psock->cork), in tcp_bpf_send_verdict()
409 if (!psock->cork) in tcp_bpf_send_verdict()
417 if (psock->apply_bytes && psock->apply_bytes < tosend) in tcp_bpf_send_verdict()
440 if (psock->cork) { in tcp_bpf_send_verdict()
526 if (psock->cork) { in tcp_bpf_sendmsg()
655 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/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()
592 if (unlikely(psock && psock->tx_stopped)) { in kcm_write_msgs()
701 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/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
82 psock = sk_psock_get(sk); in vsock_bpf_recvmsg()
83 if (unlikely(!psock)) in vsock_bpf_recvmsg()
87 if (vsock_has_data(sk, psock) && sk_psock_queue_empty(psock)) { in vsock_bpf_recvmsg()
89 sk_psock_put(sk, psock); in vsock_bpf_recvmsg()
102 if (sk_psock_queue_empty(psock)) { in vsock_bpf_recvmsg()
104 sk_psock_put(sk, psock); in vsock_bpf_recvmsg()
[all …]
/linux/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
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()
87 sk_psock_put(sk, psock); in unix_bpf_recvmsg()
93 sk_psock_put(sk, psock); in unix_bpf_recvmsg()
185 if (!psock->sk_pair) { in unix_stream_bpf_update_proto()
[all …]
/linux/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/tools/testing/selftests/bpf/prog_tests/
A Dlwt_redirect.c162 int psock = -1; in send_and_capture_test_packets() local
179 psock = new_packet_sock(target_dev); in send_and_capture_test_packets()
182 ret = wait_for_packet(psock, filter, &timeo); in send_and_capture_test_packets()
189 if (psock >= 0) in send_and_capture_test_packets()
190 close(psock); in send_and_capture_test_packets()
/linux/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()
886 switch (psock->eval) { in bpf_exec_tx_verdict()
1960 struct sk_psock *psock; in tls_sw_recvmsg() local
2012 if (psock) { in tls_sw_recvmsg()
2169 if (psock) in tls_sw_recvmsg()
2262 if (psock) { in tls_sw_read_sock()
2349 psock = sk_psock(sk); in tls_sw_sock_is_readable()
2350 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()
431 if (psock) in tls_sk_poll()
432 sk_psock_put(sk, psock); in tls_sk_poll()
/linux/include/net/
A Daf_unix.h121 int unix_dgram_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore);
122 int unix_stream_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore);
A Daf_vsock.h247 int vsock_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore);
A Dudp.h524 int udp_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore);
A Dsock.h1271 struct sk_psock *psock,
A Dtcp.h2596 int tcp_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore);
/linux/Documentation/bpf/
A Dmap_sockmap.rst311 retrieve the associated socket and its attached psock.

Completed in 71 milliseconds