Lines Matching refs:socks

55 		if (reuse->socks[left] == sk)  in reuseport_sock_index()
63 reuse->socks[reuse->num_socks] = sk; in __reuseport_add_sock()
77 reuse->socks[i] = reuse->socks[reuse->num_socks - 1]; in __reuseport_detach_sock()
86 reuse->socks[reuse->max_socks - reuse->num_closed_socks - 1] = sk; in __reuseport_add_closed_sock()
99 reuse->socks[i] = reuse->socks[reuse->max_socks - reuse->num_closed_socks]; in __reuseport_detach_closed_sock()
167 reuse->socks[0] = sk; in reuseport_alloc()
192 sk = reuse->socks[reuse->max_socks - reuse->num_closed_socks]; in reuseport_grow()
213 memcpy(more_reuse->socks, reuse->socks, in reuseport_grow()
215 memcpy(more_reuse->socks + in reuseport_grow()
217 reuse->socks + (reuse->max_socks - reuse->num_closed_socks), in reuseport_grow()
222 rcu_assign_pointer(reuse->socks[i]->sk_reuseport_cb, in reuseport_grow()
428 static struct sock *run_bpf_filter(struct sock_reuseport *reuse, u16 socks, in run_bpf_filter() argument
452 if (index >= socks) in run_bpf_filter()
455 return reuse->socks[index]; in run_bpf_filter()
464 while (reuse->socks[i]->sk_state == TCP_ESTABLISHED) { in reuseport_select_sock_by_hash()
472 return reuse->socks[i]; in reuseport_select_sock_by_hash()
493 u16 socks; in reuseport_select_sock() local
503 socks = READ_ONCE(reuse->num_socks); in reuseport_select_sock()
504 if (likely(socks)) { in reuseport_select_sock()
514 sk2 = run_bpf_filter(reuse, socks, prog, skb, hdr_len); in reuseport_select_sock()
519 sk2 = reuseport_select_sock_by_hash(reuse, hash, socks); in reuseport_select_sock()
545 u16 socks; in reuseport_migrate_sock() local
554 socks = READ_ONCE(reuse->num_socks); in reuseport_migrate_sock()
555 if (unlikely(!socks)) in reuseport_migrate_sock()
583 nsk = reuseport_select_sock_by_hash(reuse, hash, socks); in reuseport_migrate_sock()