| /linux/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()
178 reuse = kzalloc_flex(*reuse, socks, max_socks, GFP_ATOMIC); in __reuseport_alloc()
234 reuse->socks[0] = sk; in reuseport_alloc()
260 sk = reuse->socks[reuse->max_socks - reuse->num_closed_socks]; in reuseport_grow()
282 memcpy(more_reuse->socks, reuse->socks, in reuseport_grow()
284 memcpy(more_reuse->socks + in reuseport_grow()
[all …]
|
| /linux/tools/testing/selftests/bpf/prog_tests/ |
| H A D | sock_iter_batch.c | 259 int *socks, int socks_len, int *established_socks, in remove_seen() argument
269 check_n_were_seen_once(socks, socks_len, socks_len - 1, counts, in remove_seen()
273 close_idx = get_seen_socket(socks, counts, counts_len); in remove_seen()
276 close(socks[close_idx]); in remove_seen()
277 socks[close_idx] = -1; in remove_seen()
285 check_n_were_seen_once(socks, socks_len, socks_len - 1, counts, in remove_seen()
327 __u16 port, int *socks, int socks_len, in remove_unseen() argument
338 check_n_were_seen_once(socks, socks_len, 1, counts, counts_len); in remove_unseen()
343 close_idx = get_nth_socket(socks, socks_len, link, 1); in remove_unseen()
346 close(socks[close_idx]); in remove_unseen()
[all …]
|
| H A D | sockmap_basic.c | 359 if (!ASSERT_EQ(skel->bss->socks, num_sockets, "socks")) in test_sockmap_copy()
|
| /linux/drivers/block/ |
| H A D | nbd.c | 97 struct nbd_sock **socks; member
409 struct nbd_sock *nsock = config->socks[i]; in sock_shutdown()
491 if (config->socks) { in nbd_xmit_timeout()
494 config->socks[cmd->index]; in nbd_xmit_timeout()
518 struct nbd_sock *nsock = config->socks[cmd->index]; in nbd_xmit_timeout()
603 struct socket *sock = config->socks[index]->sock; in sock_xmit()
650 struct nbd_sock *nsock = config->socks[index]; in nbd_send_cmd()
1062 struct nbd_sock *nsock = config->socks[index]; in find_fallback()
1075 !config->socks[fallback]->dead) in find_fallback()
1080 config->socks[nsock->fallback_index]->dead) { in find_fallback()
[all …]
|
| /linux/net/xfrm/ |
| H A D | xfrm_nat_keepalive.c | 215 static int nat_keepalive_sk_init(struct sock_bh_locked __percpu *socks, in nat_keepalive_sk_init()
227 per_cpu_ptr(socks, i)->sock = sk; in nat_keepalive_sk_fini() argument
233 inet_ctl_sock_destroy(per_cpu_ptr(socks, i)->sock); in nat_keepalive_sk_fini()
237 static void nat_keepalive_sk_fini(struct sock_bh_locked __percpu *socks) in xfrm_nat_keepalive_state_updated()
242 inet_ctl_sock_destroy(per_cpu_ptr(socks, i)->sock); in xfrm_nat_keepalive_state_updated()
205 nat_keepalive_sk_init(struct sock * __percpu * socks,unsigned short family) nat_keepalive_sk_init() argument
|
| /linux/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()
|
| /linux/include/net/ |
| H A D | sock_reuseport.h | 29 struct sock *socks[] __counted_by(max_socks);
|
| /linux/tools/testing/selftests/namespaces/ |
| H A D | siocgskns_test.c | 342 int socks[5]; in TEST() local
353 socks[i] = socket(AF_INET, SOCK_STREAM, 0); in TEST()
354 ASSERT_GE(socks[i], 0); in TEST()
359 netns_fds[i] = ioctl(socks[i], SIOCGSKNS); in TEST()
363 close(socks[j]); in TEST()
384 close(socks[i]); in TEST()
399 close(socks[i]); in TEST()
|
| /linux/net/mctp/test/ |
| H A D | route-test.c | 1503 struct socket *socks[ARRAY_SIZE(lookup_binds)];
1516 &rc, &socks[i]); in mctp_bind_lookup_desc()
1523 sock_expect = socks[i];
1542 skb_sock = skb_recv_datagram(socks[i]->sk, in mctp_test_bind_lookup()
1563 sock_release(socks[i]); in mctp_test_bind_lookup()
1530 struct socket *socks[ARRAY_SIZE(lookup_binds)]; mctp_test_bind_lookup() local
|