| /kernel/linux/linux-5.10/net/core/ |
| H A D | sock_reuseport.c | 91 reuse->socks[0] = sk; in reuseport_alloc()
122 memcpy(more_reuse->socks, reuse->socks, in reuseport_grow()
127 rcu_assign_pointer(reuse->socks[i]->sk_reuseport_cb, in reuseport_grow()
185 reuse->socks[reuse->num_socks] = sk; in reuseport_add_sock()
221 if (reuse->socks[i] == sk) { in reuseport_detach_sock()
222 reuse->socks[i] = reuse->socks[reuse->num_socks - 1]; in reuseport_detach_sock()
233 static struct sock *run_bpf_filter(struct sock_reuseport *reuse, u16 socks, in run_bpf_filter() argument
257 if (index >= socks) in run_bpf_filter()
281 u16 socks; reuseport_select_sock() local
[all...] |
| /kernel/linux/linux-6.6/net/core/ |
| H A D | sock_reuseport.c | 119 if (reuse->socks[left] == sk) in reuseport_sock_index()
127 reuse->socks[reuse->num_socks] = sk; in __reuseport_add_sock()
142 reuse->socks[i] = reuse->socks[reuse->num_socks - 1]; in __reuseport_detach_sock()
152 reuse->socks[reuse->max_socks - reuse->num_closed_socks - 1] = sk; in __reuseport_add_closed_sock()
166 reuse->socks[i] = reuse->socks[reuse->max_socks - reuse->num_closed_socks]; in __reuseport_detach_closed_sock()
235 reuse->socks[0] = sk; in reuseport_alloc()
261 sk = reuse->socks[reuse->max_socks - reuse->num_closed_socks]; in reuseport_grow()
283 memcpy(more_reuse->socks, reus in reuseport_grow()
498 run_bpf_filter(struct sock_reuseport *reuse, u16 socks, struct bpf_prog *prog, struct sk_buff *skb, int hdr_len) run_bpf_filter() argument
577 u16 socks; reuseport_select_sock() local
629 u16 socks; reuseport_migrate_sock() local
[all...] |
| /kernel/linux/linux-5.10/drivers/block/ |
| H A D | nbd.c | 91 struct nbd_sock **socks; member
364 struct nbd_sock *nsock = config->socks[i]; in sock_shutdown()
422 if (config->socks) { in nbd_xmit_timeout()
425 config->socks[cmd->index]; in nbd_xmit_timeout()
449 struct nbd_sock *nsock = config->socks[cmd->index]; in nbd_xmit_timeout()
489 struct socket *sock = config->socks[index]->sock; in sock_xmit()
545 struct nbd_sock *nsock = config->socks[index]; in nbd_send_cmd()
852 nsock = config->socks[args->index]; in recv_work()
895 struct nbd_sock *nsock = config->socks[index]; in find_fallback()
908 !config->socks[fallbac in find_fallback()
1090 struct nbd_sock **socks; nbd_add_socket() local
2076 struct nlattr *socks[NBD_SOCK_MAX+1]; nbd_genl_connect() local
2263 struct nlattr *socks[NBD_SOCK_MAX+1]; nbd_genl_reconfigure() local
[all...] |
| /kernel/linux/linux-6.6/drivers/block/ |
| H A D | nbd.c | 96 struct nbd_sock **socks; member
375 struct nbd_sock *nsock = config->socks[i]; in sock_shutdown()
449 if (config->socks) { in nbd_xmit_timeout()
452 config->socks[cmd->index]; in nbd_xmit_timeout()
476 struct nbd_sock *nsock = config->socks[cmd->index]; in nbd_xmit_timeout()
558 struct socket *sock = config->socks[index]->sock; in sock_xmit()
577 struct nbd_sock *nsock = config->socks[index]; in nbd_send_cmd()
936 struct nbd_sock *nsock = config->socks[index]; in find_fallback()
949 !config->socks[fallback]->dead) in find_fallback()
954 config->socks[nsoc in find_fallback()
1131 struct nbd_sock **socks; nbd_add_socket() local
2084 struct nlattr *socks[NBD_SOCK_MAX+1]; nbd_genl_connect() local
2296 struct nlattr *socks[NBD_SOCK_MAX+1]; nbd_genl_reconfigure() local
[all...] |
| /kernel/linux/linux-5.10/tools/testing/selftests/bpf/progs/ |
| H A D | bpf_iter_sockmap.c | 33 __u32 socks = 0; variable
53 socks++; in copy()
|
| /kernel/linux/linux-6.6/tools/testing/selftests/bpf/progs/ |
| H A D | bpf_iter_sockmap.c | 33 __u32 socks = 0; variable
53 socks++; in copy()
|
| /kernel/linux/linux-6.6/kernel/bpf/ |
| H A D | reuseport_array.c | 24 struct sock __rcu **socks; in bpf_sk_reuseport_detach() local
27 socks = __locked_read_sk_user_data_with_flags(sk, SK_USER_DATA_BPF); in bpf_sk_reuseport_detach()
28 if (socks) { in bpf_sk_reuseport_detach()
36 RCU_INIT_POINTER(*socks, NULL); in bpf_sk_reuseport_detach()
|
| /kernel/linux/linux-5.10/kernel/bpf/ |
| H A D | reuseport_array.c | 28 struct sock __rcu **socks; in bpf_sk_reuseport_detach() local
30 socks = (void *)(sk_user_data & SK_USER_DATA_PTRMASK); in bpf_sk_reuseport_detach()
38 RCU_INIT_POINTER(*socks, NULL); in bpf_sk_reuseport_detach()
|
| /kernel/linux/linux-5.10/include/net/ |
| H A D | sock_reuseport.h | 16 u16 max_socks; /* length of socks */
17 u16 num_socks; /* elements in socks */
19 * reuse->socks[] group.
22 /* ID stays the same even after the size of socks[] grows. */
27 struct sock *socks[]; /* array of sock pointers */ member
|
| H A D | sock.h | 32 * use private slabcaches for its socks
1283 atomic_t socks; member
1295 atomic_inc(&sk->sk_prot->socks); in sk_refcnt_debug_inc()
1300 atomic_dec(&sk->sk_prot->socks); in sk_refcnt_debug_dec()
1302 sk->sk_prot->name, sk, atomic_read(&sk->sk_prot->socks)); in sk_refcnt_debug_dec()
|
| /kernel/linux/linux-6.6/include/net/ |
| H A D | sock_reuseport.h | 16 u16 max_socks; /* length of socks */
17 u16 num_socks; /* elements in socks */
18 u16 num_closed_socks; /* closed elements in socks */
21 * reuse->socks[] group.
24 /* ID stays the same even after the size of socks[] grows. */
29 struct sock *socks[]; /* array of sock pointers */ member
|
| /kernel/linux/linux-5.10/tools/testing/selftests/bpf/prog_tests/ |
| H A D | sockmap_basic.c | 265 if (CHECK(skel->bss->socks != num_sockets, "socks", "got %u expected %u\n", in test_sockmap_copy()
266 skel->bss->socks, num_sockets)) in test_sockmap_copy()
|
| /kernel/linux/linux-6.6/tools/testing/selftests/bpf/prog_tests/ |
| H A D | sockmap_basic.c | 256 if (!ASSERT_EQ(skel->bss->socks, num_sockets, "socks")) in test_sockmap_copy()
|