Searched refs:psock (Results 1 - 19 of 19) sorted by relevance

/linux-master/net/core/
H A Dskmsg.c411 /* Receive sk_msg from psock->ingress_msg to @msg. */
412 int sk_msg_recvmsg(struct sock *sk, struct sk_psock *psock, struct msghdr *msg, argument
420 msg_rx = sk_psock_peek_msg(psock);
470 msg_rx = sk_psock_next_msg(psock, msg_rx);
478 msg_rx = sk_psock_dequeue_msg(psock);
481 msg_rx = sk_psock_peek_msg(psock);
490 struct sk_psock *psock; local
494 psock = sk_psock(sk);
495 if (likely(psock))
496 empty = list_empty(&psock
525 sk_psock_skb_ingress_enqueue(struct sk_buff *skb, u32 off, u32 len, struct sk_psock *psock, struct sock *sk, struct sk_msg *msg) argument
562 sk_psock_skb_ingress(struct sk_psock *psock, struct sk_buff *skb, u32 off, u32 len) argument
596 sk_psock_skb_ingress_self(struct sk_psock *psock, struct sk_buff *skb, u32 off, u32 len) argument
612 sk_psock_handle_skb(struct sk_psock *psock, struct sk_buff *skb, u32 off, u32 len, bool ingress) argument
629 sk_psock_skb_state(struct sk_psock *psock, struct sk_psock_work_state *state, int len, int off) argument
644 struct sk_psock *psock = container_of(dwork, struct sk_psock, work); local
702 struct sk_psock *psock; local
755 sk_psock_link_pop(struct sk_psock *psock) argument
768 __sk_psock_purge_ingress_msg(struct sk_psock *psock) argument
779 __sk_psock_zap_ingress(struct sk_psock *psock) argument
790 sk_psock_link_destroy(struct sk_psock *psock) argument
800 sk_psock_stop(struct sk_psock *psock) argument
812 struct sk_psock *psock = container_of(to_rcu_work(work), local
835 sk_psock_drop(struct sock *sk, struct sk_psock *psock) argument
866 sk_psock_msg_verdict(struct sock *sk, struct sk_psock *psock, struct sk_msg *msg) argument
955 sk_psock_tls_strp_read(struct sk_psock *psock, struct sk_buff *skb) argument
976 sk_psock_verdict_apply(struct sk_psock *psock, struct sk_buff *skb, int verdict) argument
1039 struct sk_psock *psock; local
1057 struct sk_psock *psock; local
1091 struct sk_psock *psock = container_of(strp, struct sk_psock, strp); local
1109 struct sk_psock *psock; local
1127 sk_psock_init_strp(struct sock *sk, struct sk_psock *psock) argument
1144 sk_psock_start_strp(struct sock *sk, struct sk_psock *psock) argument
1154 sk_psock_stop_strp(struct sock *sk, struct sk_psock *psock) argument
1166 sk_psock_done_strp(struct sk_psock *psock) argument
1173 sk_psock_done_strp(struct sk_psock *psock) argument
1180 struct sk_psock *psock; local
1225 struct sk_psock *psock; local
1235 sk_psock_start_verdict(struct sock *sk, struct sk_psock *psock) argument
1245 sk_psock_stop_verdict(struct sock *sk, struct sk_psock *psock) argument
[all...]
H A Dsock_map.c128 static void sock_map_add_link(struct sk_psock *psock, argument
134 spin_lock_bh(&psock->link_lock);
135 list_add_tail(&link->list, &psock->link);
136 spin_unlock_bh(&psock->link_lock);
140 struct sk_psock *psock, void *link_raw)
145 spin_lock_bh(&psock->link_lock);
146 list_for_each_entry_safe(link, tmp, &psock->link, list) {
151 if (psock->saved_data_ready && progs->stream_parser)
153 if (psock->saved_data_ready && progs->stream_verdict)
155 if (psock
139 sock_map_del_link(struct sock *sk, struct sk_psock *psock, void *link_raw) argument
177 struct sk_psock *psock = sk_psock(sk); local
185 sock_map_init_proto(struct sock *sk, struct sk_psock *psock) argument
195 struct sk_psock *psock; local
220 struct sk_psock *psock; local
472 struct sk_psock *psock; local
992 struct sk_psock *psock; local
1579 sock_map_remove_links(struct sock *sk, struct sk_psock *psock) argument
1592 struct sk_psock *psock; local
1614 struct sk_psock *psock; local
1638 struct sk_psock *psock; local
[all...]
/linux-master/net/ipv4/
H A Dtcp_bpf.c32 static int bpf_tcp_ingress(struct sock *sk, struct sk_psock *psock, argument
77 sk_psock_queue_msg(psock, tmp);
78 sk_psock_data_ready(sk, psock);
164 struct sk_psock *psock = sk_psock_get(sk); local
167 if (unlikely(!psock))
170 ret = ingress ? bpf_tcp_ingress(sk, psock, msg, bytes, flags) :
172 sk_psock_put(sk, psock);
178 static int tcp_msg_wait_data(struct sock *sk, struct sk_psock *psock, argument
193 !list_empty(&psock->ingress_msg) ||
200 static bool is_next_msg_fin(struct sk_psock *psock) argument
227 struct sk_psock *psock; local
334 struct sk_psock *psock; local
381 tcp_bpf_send_verdict(struct sock *sk, struct sk_psock *psock, struct sk_msg *msg, int *copied, int flags) argument
499 struct sk_psock *psock; local
649 tcp_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore) argument
[all...]
H A Dudp_bpf.c29 static bool psock_has_data(struct sk_psock *psock) argument
31 return !skb_queue_empty(&psock->ingress_skb) ||
32 !sk_psock_queue_empty(psock);
38 static int udp_msg_wait_data(struct sock *sk, struct sk_psock *psock, argument
52 ret = udp_msg_has_data(sk, psock);
55 ret = udp_msg_has_data(sk, psock);
65 struct sk_psock *psock; local
74 psock = sk_psock_get(sk);
75 if (unlikely(!psock))
78 if (!psock_has_data(psock)) {
141 udp_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore) argument
[all...]
/linux-master/net/vmw_vsock/
H A Dvsock_bpf.c25 static bool vsock_has_data(struct sock *sk, struct sk_psock *psock) argument
34 return vsock_sk_has_data(sk, psock);
37 static bool vsock_msg_wait_data(struct sock *sk, struct sk_psock *psock, long timeo) argument
51 ret = vsock_has_data(sk, psock);
54 ret = vsock_has_data(sk, psock);
79 struct sk_psock *psock; local
82 psock = sk_psock_get(sk);
83 if (unlikely(!psock))
87 if (vsock_has_data(sk, psock) && sk_psock_queue_empty(psock)) {
149 vsock_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore) argument
[all...]
/linux-master/include/linux/
H A Dskmsg.h105 * exactly once with restore=true when the psock is being destroyed
106 * and psock refcnt is zero, but before an RCU grace period.
108 int (*psock_update_sk_prot)(struct sock *sk, struct sk_psock *psock,
136 int sk_msg_recvmsg(struct sock *sk, struct sk_psock *psock, struct msghdr *msg,
145 static inline void sk_msg_apply_bytes(struct sk_psock *psock, u32 bytes) argument
147 if (psock->apply_bytes) {
148 if (psock->apply_bytes < bytes)
149 psock->apply_bytes = 0;
151 psock->apply_bytes -= bytes;
292 static inline void sk_psock_set_state(struct sk_psock *psock, argument
298 sk_psock_clear_state(struct sk_psock *psock, enum sk_psock_state_bits bit) argument
304 sk_psock_test_state(const struct sk_psock *psock, enum sk_psock_state_bits bit) argument
316 sk_psock_queue_msg(struct sk_psock *psock, struct sk_msg *msg) argument
329 sk_psock_dequeue_msg(struct sk_psock *psock) argument
341 sk_psock_peek_msg(struct sk_psock *psock) argument
351 sk_psock_next_msg(struct sk_psock *psock, struct sk_msg *msg) argument
365 sk_psock_queue_empty(const struct sk_psock *psock) argument
377 sk_psock_report_error(struct sk_psock *psock, int err) argument
393 sk_psock_init_strp(struct sock *sk, struct sk_psock *psock) argument
398 sk_psock_start_strp(struct sock *sk, struct sk_psock *psock) argument
402 sk_psock_stop_strp(struct sock *sk, struct sk_psock *psock) argument
426 sk_psock_cork_free(struct sk_psock *psock) argument
435 sk_psock_restore_proto(struct sock *sk, struct sk_psock *psock) argument
444 struct sk_psock *psock; local
456 sk_psock_put(struct sock *sk, struct sk_psock *psock) argument
462 sk_psock_data_ready(struct sock *sk, struct sk_psock *psock) argument
503 sk_psock_strp_enabled(struct sk_psock *psock) argument
[all...]
/linux-master/net/kcm/
H A Dkcmsock.c55 static void kcm_abort_tx_psock(struct kcm_psock *psock, int err, argument
58 struct sock *csk = psock->sk;
59 struct kcm_mux *mux = psock->mux;
65 if (psock->tx_stopped) {
70 psock->tx_stopped = 1;
71 KCM_STATS_INCR(psock->stats.tx_aborts);
73 if (!psock->tx_kcm) {
75 list_del(&psock->psock_avail_list);
77 /* In this case psock is being aborted while outside of
78 * write_msgs and psock i
94 kcm_update_rx_mux_stats(struct kcm_mux *mux, struct kcm_psock *psock) argument
106 kcm_update_tx_mux_stats(struct kcm_mux *mux, struct kcm_psock *psock) argument
126 struct kcm_psock *psock; local
254 reserve_rx_kcm(struct kcm_psock *psock, struct sk_buff *head) argument
306 unreserve_rx_kcm(struct kcm_psock *psock, bool rcv_ready) argument
351 struct kcm_psock *psock; local
367 struct kcm_psock *psock = container_of(strp, struct kcm_psock, strp); local
388 struct kcm_psock *psock = container_of(strp, struct kcm_psock, strp); local
398 struct kcm_psock *psock = container_of(strp, struct kcm_psock, strp); local
417 struct kcm_psock *psock; local
446 struct kcm_psock *psock; local
496 psock_now_avail(struct kcm_psock *psock) argument
526 struct kcm_psock *psock; local
586 struct kcm_psock *psock; local
1219 struct kcm_psock *psock = NULL, *tpsock; local
1346 kcm_unattach(struct kcm_psock *psock) argument
1446 struct kcm_psock *psock; local
1594 struct kcm_psock *psock, *tmp_psock; local
1677 struct kcm_psock *psock; local
[all...]
H A Dkcmproc.c139 static void kcm_format_psock(struct kcm_psock *psock, struct seq_file *seq, argument
143 " psock-%-5u %-10llu %-16llu %-10llu %-16llu %-8d %-8d %-8d %-8d ",
144 psock->index,
145 psock->strp.stats.msgs,
146 psock->strp.stats.bytes,
147 psock->stats.tx_msgs,
148 psock->stats.tx_bytes,
149 psock->sk->sk_receive_queue.qlen,
150 atomic_read(&psock->sk->sk_rmem_alloc),
151 psock
190 struct kcm_psock *psock; local
248 struct kcm_psock *psock; local
[all...]
/linux-master/net/unix/
H A Dunix_bpf.c15 static int unix_msg_wait_data(struct sock *sk, struct sk_psock *psock, argument
30 if (!unix_sk_has_data(sk, psock)) {
34 ret = unix_sk_has_data(sk, psock);
54 struct sk_psock *psock; local
60 psock = sk_psock_get(sk);
61 if (unlikely(!psock))
66 sk_psock_queue_empty(psock)) {
68 sk_psock_put(sk, psock);
73 copied = sk_msg_recvmsg(sk, psock, msg, len, flags);
79 data = unix_msg_wait_data(sk, psock, time
144 unix_dgram_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore) argument
160 unix_stream_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore) argument
[all...]
/linux-master/drivers/pcmcia/
H A Dtcic.c105 u_short psock; member in struct:tcic_socket
404 socket_table[sockets].psock = i;
482 tcic_setw(TCIC_ADDR+2, socket_table[i].psock << TCIC_SS_SHFT);
533 u_short psock; local
546 psock = socket_table[i].psock;
547 tcic_setl(TCIC_ADDR, (psock << TCIC_ADDR_SS_SHFT)
548 | TCIC_ADDR_INDREG | TCIC_SCF1(psock));
550 latch = sstat ^ socket_table[psock].last_sstat;
595 u_short psock local
621 u_short psock = container_of(sock, struct tcic_socket, socket)->psock; local
696 u_short psock = container_of(sock, struct tcic_socket, socket)->psock; local
733 u_short psock = container_of(sock, struct tcic_socket, socket)->psock; local
[all...]
H A Di82365.c149 u_short psock; member in struct:i82365_socket
224 reg = I365_REG(socket[sock].psock, reg);
237 u_char val = I365_REG(socket[sock].psock, reg);
579 socket[sockets].psock = sock;
662 static void __init add_socket(unsigned int port, int psock, int type) argument
665 socket[sockets].psock = psock;
683 t->ioaddr, t->psock*0x40);
907 if (socket[sock].psock & 1) {
1120 pcic[s->type].name, s->psock);
[all...]
/linux-master/tools/testing/selftests/bpf/prog_tests/
H A Dlwt_redirect.c163 int psock = -1; local
180 psock = new_packet_sock(target_dev);
183 ret = wait_for_packet(psock, filter, &timeo);
190 if (psock >= 0)
191 close(psock);
/linux-master/include/net/
H A Daf_unix.h120 int unix_dgram_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore);
121 int unix_stream_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore);
H A Daf_vsock.h240 int vsock_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore);
H A Dudp.h529 int udp_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore);
H A Dtcp.h2580 int tcp_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore);
H A Dsock.h565 * sk_user_data points to psock type. This bit should be set
566 * when sk_user_data is assigned to a psock object.
1255 struct sk_psock *psock,
/linux-master/net/tls/
H A Dtls_sw.c849 struct sk_psock *psock; local
857 psock = sk_psock_get(sk);
858 if (!psock || !policy) {
865 if (psock)
866 sk_psock_put(sk, psock);
871 if (psock->eval == __SK_NONE) {
873 psock->eval = sk_psock_msg_verdict(sk, psock, msg);
886 switch (psock->eval) {
897 redir_ingress = psock
1308 tls_rx_rec_wait(struct sock *sk, struct sk_psock *psock, bool nonblock, bool released) argument
1960 struct sk_psock *psock; local
2254 struct sk_psock *psock; local
2347 struct sk_psock *psock; local
2431 struct sk_psock *psock; local
[all...]
H A Dtls_main.c410 struct sk_psock *psock; local
424 psock = sk_psock_get(sk);
428 sk_psock_queue_empty(psock))
431 if (psock)
432 sk_psock_put(sk, psock);

Completed in 185 milliseconds