/linux-master/net/core/ |
H A D | skmsg.c | 411 /* 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 D | sock_map.c | 128 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 D | tcp_bpf.c | 32 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 D | udp_bpf.c | 29 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 D | vsock_bpf.c | 25 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 D | skmsg.h | 105 * 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 D | kcmsock.c | 55 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 D | kcmproc.c | 139 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 D | unix_bpf.c | 15 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 D | tcic.c | 105 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 D | i82365.c | 149 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 D | lwt_redirect.c | 163 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 D | af_unix.h | 120 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 D | af_vsock.h | 240 int vsock_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore);
|
H A D | udp.h | 529 int udp_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore);
|
H A D | tcp.h | 2580 int tcp_bpf_update_proto(struct sock *sk, struct sk_psock *psock, bool restore);
|
H A D | sock.h | 565 * 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 D | tls_sw.c | 849 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 D | tls_main.c | 410 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);
|