| /linux/kernel/bpf/ |
| H A D | reuseport_array.c | 189 const struct sock *nsk, in reuseport_array_update_check() argument
200 if (nsk->sk_protocol != IPPROTO_UDP && nsk->sk_protocol != IPPROTO_TCP) in reuseport_array_update_check()
203 if (nsk->sk_family != AF_INET && nsk->sk_family != AF_INET6) in reuseport_array_update_check()
206 if (nsk->sk_type != SOCK_STREAM && nsk->sk_type != SOCK_DGRAM) in reuseport_array_update_check()
217 if (!sock_flag(nsk, SOCK_RCU_FREE) || !sk_hashed(nsk) || !nsk_reuse) in reuseport_array_update_check()
221 if (READ_ONCE(nsk->sk_user_data)) in reuseport_array_update_check()
236 struct sock *free_osk = NULL, *osk, *nsk; in bpf_fd_reuseport_array_update_elem() local
263 nsk = socket->sk; in bpf_fd_reuseport_array_update_elem()
264 if (!nsk) { in bpf_fd_reuseport_array_update_elem()
270 err = reuseport_array_update_check(array, nsk, in bpf_fd_reuseport_array_update_elem()
[all …]
|
| /linux/net/core/ |
| H A D | sock_reuseport.c | 625 struct sock *nsk = NULL; in reuseport_migrate_sock() local
659 nsk = bpf_run_sk_reuseport(reuse, sk, prog, skb, migrating_sk, hash); in reuseport_migrate_sock()
665 if (!nsk) in reuseport_migrate_sock()
666 nsk = reuseport_select_sock_by_hash(reuse, hash, socks); in reuseport_migrate_sock()
668 if (IS_ERR_OR_NULL(nsk) || unlikely(!refcount_inc_not_zero(&nsk->sk_refcnt))) { in reuseport_migrate_sock()
669 nsk = NULL; in reuseport_migrate_sock()
675 return nsk; in reuseport_migrate_sock()
|
| H A D | sock.c | 2206 * Copy all fields from osk to nsk but nsk->sk_refcnt must not change yet, in sock_copy()
2210 static void sock_copy(struct sock *nsk, const struct sock *osk) in sock_copy()
2214 void *sptr = nsk->sk_security; in sock_copy()
2226 memcpy(nsk, osk, offsetof(struct sock, sk_dontcopy_begin)); in sock_copy()
2228 unsafe_memcpy(&nsk->sk_dontcopy_end, &osk->sk_dontcopy_end, in sock_copy()
2233 nsk->sk_security = sptr; in sk_prot_alloc()
2234 security_sk_clone(osk, nsk); in sk_prot_alloc()
2205 sock_copy(struct sock * nsk,const struct sock * osk) sock_copy() argument
|
| /linux/net/iucv/ |
| H A D | af_iucv.c | 805 struct sock *sk = sock->sk, *nsk; in iucv_sock_accept()
820 while (!(nsk = iucv_accept_dequeue(sk, newsock))) { in iucv_sock_accept()
1599 struct sock *sk, *nsk; in iucv_callback_connreq()
1644 nsk = iucv_sock_alloc(NULL, sk->sk_protocol, GFP_ATOMIC, 0); in iucv_callback_connreq()
1645 if (!nsk) { in iucv_callback_connreq()
1651 niucv = iucv_sk(nsk); in iucv_callback_connreq()
1652 iucv_sock_init(nsk, sk); in iucv_callback_connreq()
1654 nsk->sk_allocation |= GFP_DMA; in iucv_callback_connreq()
1672 err = pr_iucv->path_accept(path, &af_iucv_handler, nuser_data, nsk); in iucv_callback_connreq()
1674 iucv_sever_path(nsk, in iucv_callback_connreq()
804 struct sock *sk = sock->sk, *nsk; iucv_sock_accept() local
1601 struct sock *sk, *nsk; iucv_callback_connreq() local
1855 struct sock *nsk; afiucv_hs_callback_syn() local
[all...] |
| /linux/net/ipv4/ |
| H A D | inet_connection_sock.c | 1032 struct sock *nsk; in reqsk_timer_handler()
1034 nsk = reuseport_migrate_sock(sk_listener, req_to_sk(req), NULL); in reqsk_timer_handler()
1035 if (!nsk) in reqsk_timer_handler() local
1038 nreq = inet_reqsk_clone(req, nsk); in reqsk_timer_handler()
1049 reqsk_queue_migrated(&inet_csk(nsk)->icsk_accept_queue, req); in reqsk_timer_handler()
1052 sk_listener = nsk; in reqsk_timer_handler()
1469 struct sock *child = req->sk, *nsk; in inet_csk_listen_stop()
1477 nsk = reuseport_migrate_sock(sk, child, NULL); in inet_csk_listen_stop()
1478 if (nsk) { in inet_csk_listen_stop()
1479 nreq = inet_reqsk_clone(req, nsk); in inet_csk_listen_stop()
1474 struct sock *child = req->sk, *nsk; inet_csk_listen_stop() local
1493 READ_ONCE(nsk->sk_data_ready)(nsk); inet_csk_listen_stop() local
[all...] |
| H A D | tcp_ipv4.c | 1859 struct sock *nsk = tcp_v4_cookie_check(sk, skb); local
1861 if (!nsk)
1863 if (nsk != sk) {
1864 reason = tcp_child_process(sk, nsk, skb);
1865 sock_put(nsk);
2122 struct sock *nsk;
2141 nsk = reuseport_migrate_sock(sk, req_to_sk(req), skb);
2142 if (!nsk) {
2146 sk = nsk;
2157 nsk
2123 struct sock *nsk; global() local
[all...] |
| /linux/net/smc/ |
| H A D | af_smc.c | 501 static void smc_adjust_sock_bufsizes(struct sock *nsk, struct sock *osk, in smc_adjust_sock_bufsizes() argument
504 nsk->sk_userlocks = osk->sk_userlocks; in smc_adjust_sock_bufsizes()
506 nsk->sk_sndbuf = osk->sk_sndbuf; in smc_adjust_sock_bufsizes()
508 nsk->sk_rcvbuf = osk->sk_rcvbuf; in smc_adjust_sock_bufsizes()
511 static void smc_copy_sock_settings(struct sock *nsk, struct sock *osk, in smc_copy_sock_settings() argument
515 nsk->sk_type = osk->sk_type; in smc_copy_sock_settings()
516 nsk->sk_sndtimeo = READ_ONCE(osk->sk_sndtimeo); in smc_copy_sock_settings()
517 nsk->sk_rcvtimeo = READ_ONCE(osk->sk_rcvtimeo); in smc_copy_sock_settings()
518 nsk->sk_mark = READ_ONCE(osk->sk_mark); in smc_copy_sock_settings()
519 nsk->sk_priority = READ_ONCE(osk->sk_priority); in smc_copy_sock_settings()
[all …]
|
| /linux/net/ipv6/ |
| H A D | tcp_ipv6.c | 1635 struct sock *nsk = tcp_v6_cookie_check(sk, skb);
1637 if (!nsk)
1639 if (nsk != sk) {
1640 reason = tcp_child_process(sk, nsk, skb);
1641 sock_put(nsk);
1782 struct sock *nsk;
1801 nsk = reuseport_migrate_sock(sk, req_to_sk(req), skb);
1802 if (!nsk) {
1806 sk = nsk;
1814 nsk
1620 struct sock *nsk = tcp_v6_cookie_check(sk, skb); global() local
1767 struct sock *nsk; global() local
[all...] |
| /linux/net/dccp/ |
| H A D | ipv4.c | |
| H A D | ipv6.c | |
| /linux/net/bluetooth/rfcomm/ |
| H A D | sock.c | 486 struct sock *sk = sock->sk, *nsk; in rfcomm_sock_accept()
509 nsk = bt_accept_dequeue(sk, newsock); in rfcomm_sock_accept()
510 if (nsk) { in rfcomm_sock_accept()
512 * the grafted socket keeps nsk alive from here. in rfcomm_sock_accept()
514 sock_put(nsk); in rfcomm_sock_accept()
541 BT_DBG("new socket %p", nsk); in rfcomm_sock_accept()
488 struct sock *sk = sock->sk, *nsk; rfcomm_sock_accept() local
|
| /linux/net/mptcp/ |
| H A D | protocol.c | 3559 struct sock *nsk = sk_clone_lock(sk, GFP_ATOMIC); in mptcp_sk_clone_init() local
3563 if (!nsk) in mptcp_sk_clone_init()
3567 if (nsk->sk_family == AF_INET6) in mptcp_sk_clone_init()
3568 inet_sk(nsk)->pinet6 = mptcp_inet6_sk(nsk); in mptcp_sk_clone_init()
3571 __mptcp_init_sock(nsk); in mptcp_sk_clone_init()
3574 if (nsk->sk_family == AF_INET6) in mptcp_sk_clone_init()
3575 mptcp_copy_ip6_options(nsk, sk); in mptcp_sk_clone_init()
3578 mptcp_copy_ip_options(nsk, sk); in mptcp_sk_clone_init()
3580 msk = mptcp_sk(nsk); in mptcp_sk_clone_init()
3598 sock_reset_flag(nsk, SOCK_RCU_FREE); in mptcp_sk_clone_init()
[all …]
|
| /linux/net/bluetooth/ |
| H A D | l2cap_sock.c | 331 struct sock *sk = sock->sk, *nsk; in l2cap_sock_accept()
349 nsk = bt_accept_dequeue(sk, newsock); in l2cap_sock_accept()
350 if (nsk) { in l2cap_sock_accept()
352 * the grafted socket keeps nsk alive from here. in l2cap_sock_accept()
354 sock_put(nsk); in l2cap_sock_accept()
381 BT_DBG("new socket %p", nsk); in l2cap_sock_accept()
333 struct sock *sk = sock->sk, *nsk; l2cap_sock_accept() local
|
| /linux/arch/arm64/kvm/ |
| H A D | pmu-emul.c | 635 bool nsk = evtreg & ARMV8_PMU_EXCLUDE_NS_EL1;
638 return p == nsk; in kvm_pmc_counts_at_el0()
648 bool nsk = evtreg & ARMV8_PMU_EXCLUDE_NS_EL1; kvm_pmc_counts_at_el1() local
|
| /linux/include/net/ |
| H A D | sock.h | 1035 static inline void sock_copy_flags(struct sock *nsk, const struct sock *osk) in sock_copy_flags() argument
1037 nsk->sk_flags = osk->sk_flags; in sock_copy_flags()
|