| /linux-6.15/net/ipv4/ |
| H A D | inet_connection_sock.c | 667 struct sock *newsk; in inet_csk_accept() local 694 newsk = req->sk; in inet_csk_accept() 721 lock_sock(newsk); in inet_csk_accept() 724 if (newsk->sk_memcg) { in inet_csk_accept() 736 release_sock(newsk); in inet_csk_accept() 741 if (newsk) in inet_csk_accept() 744 return newsk; in inet_csk_accept() 746 newsk = NULL; in inet_csk_accept() 1242 if (!newsk) in inet_csk_clone_lock() 1246 newinet = inet_sk(newsk); in inet_csk_clone_lock() [all …]
|
| H A D | tcp_minisocks.c | 523 struct sock *newsk = inet_csk_clone_lock(sk, req, GFP_ATOMIC); in tcp_create_openreq_child() local 531 if (!newsk) in tcp_create_openreq_child() 534 newicsk = inet_csk(newsk); in tcp_create_openreq_child() 535 newtp = tcp_sk(newsk); in tcp_create_openreq_child() 563 newsk->sk_txhash = READ_ONCE(treq->txhash); in tcp_create_openreq_child() 566 tcp_init_xmit_timers(newsk); in tcp_create_openreq_child() 569 if (sock_flag(newsk, SOCK_KEEPOPEN)) in tcp_create_openreq_child() 570 tcp_reset_keepalive_timer(newsk, keepalive_time_when(newtp)); in tcp_create_openreq_child() 636 tcp_bpf_clone(sk, newsk); in tcp_create_openreq_child() 640 xa_init_flags(&newsk->sk_user_frags, XA_FLAGS_ALLOC1); in tcp_create_openreq_child() [all …]
|
| H A D | tcp_ipv4.c | 1763 struct sock *newsk; local 1775 if (!newsk) 1781 newtp = tcp_sk(newsk); 1807 sk_setup_caps(newsk, dst); 1814 tcp_initialize_rcv_mss(newsk); 1824 sk_gso_disable(newsk); 1846 bh_unlock_sock(newsk); 1847 sock_put(newsk); 1848 newsk = NULL; 1851 return newsk; [all …]
|
| /linux-6.15/net/dccp/ |
| H A D | ipv6.c | 433 struct sock *newsk; in dccp_v6_request_recv_sock() local 441 if (newsk == NULL) in dccp_v6_request_recv_sock() 445 newinet = inet_sk(newsk); in dccp_v6_request_recv_sock() 447 newnp = inet6_sk(newsk); in dccp_v6_request_recv_sock() 473 dccp_sync_mss(newsk, inet_csk(newsk)->icsk_pmtu_cookie); in dccp_v6_request_recv_sock() 475 return newsk; in dccp_v6_request_recv_sock() 491 if (newsk == NULL) in dccp_v6_request_recv_sock() 504 newinet = inet_sk(newsk); in dccp_v6_request_recv_sock() 506 newnp = inet6_sk(newsk); in dccp_v6_request_recv_sock() 551 dccp_done(newsk); in dccp_v6_request_recv_sock() [all …]
|
| H A D | minisocks.c | 82 struct sock *newsk = inet_csk_clone_lock(sk, req, GFP_ATOMIC); in dccp_create_openreq_child() local 84 if (newsk != NULL) { in dccp_create_openreq_child() 86 struct inet_connection_sock *newicsk = inet_csk(newsk); in dccp_create_openreq_child() 87 struct dccp_sock *newdp = dccp_sk(newsk); in dccp_create_openreq_child() 120 if (dccp_feat_activate_values(newsk, &dreq->dreq_featneg)) { in dccp_create_openreq_child() 121 sk_free_unlock_clone(newsk); in dccp_create_openreq_child() 124 dccp_init_xmit_timers(newsk); in dccp_create_openreq_child() 128 return newsk; in dccp_create_openreq_child()
|
| H A D | ipv4.c | 418 struct sock *newsk; in dccp_v4_request_recv_sock() local 423 newsk = dccp_create_openreq_child(sk, req, skb); in dccp_v4_request_recv_sock() 424 if (newsk == NULL) in dccp_v4_request_recv_sock() 427 newinet = inet_sk(newsk); in dccp_v4_request_recv_sock() 437 sk_setup_caps(newsk, dst); in dccp_v4_request_recv_sock() 439 dccp_sync_mss(newsk, dst_mtu(dst)); in dccp_v4_request_recv_sock() 441 if (__inet_inherit_port(sk, newsk) < 0) in dccp_v4_request_recv_sock() 443 *own_req = inet_ehash_nolisten(newsk, req_to_sk(req_unhash), NULL); in dccp_v4_request_recv_sock() 448 return newsk; in dccp_v4_request_recv_sock() 459 inet_csk_prepare_forced_close(newsk); in dccp_v4_request_recv_sock() [all …]
|
| /linux-6.15/net/ipv6/ |
| H A D | tcp_ipv6.c | 1368 struct sock *newsk; local 1383 if (!newsk) 1386 inet_sk(newsk)->pinet6 = tcp_inet6_sk(newsk); 1424 tcp_sync_mss(newsk, inet_csk(newsk)->icsk_pmtu_cookie); 1426 return newsk; 1441 if (!newsk) 1453 inet_sk(newsk)->pinet6 = tcp_inet6_sk(newsk); 1542 tcp_done(newsk); 1564 sock_put(newsk); 1565 newsk = NULL; [all …]
|
| /linux-6.15/tools/testing/selftests/bpf/progs/ |
| H A D | lsm_cgroup.c | 167 int BPF_PROG(socket_clone, struct sock *newsk, const struct request_sock *req) in BPF_PROG() argument 171 if (!newsk) in BPF_PROG() 175 if (bpf_setsockopt(newsk, SOL_SOCKET, SO_PRIORITY, &prio, sizeof(prio))) in BPF_PROG() 180 if (bpf_getsockopt(newsk, SOL_SOCKET, SO_PRIORITY, &prio, sizeof(prio))) in BPF_PROG()
|
| H A D | lsm_cgroup_nonvoid.c | 10 int BPF_PROG(nonvoid_socket_clone, struct sock *newsk, const struct request_sock *req) in BPF_PROG() argument
|
| /linux-6.15/drivers/net/ethernet/chelsio/inline_crypto/chtls/ |
| H A D | chtls_cm.c | 1123 struct sock *newsk; in chtls_recv_sock() local 1131 if (!newsk) in chtls_recv_sock() 1186 tp = tcp_sk(newsk); in chtls_recv_sock() 1219 csk->sk = newsk; in chtls_recv_sock() 1246 return newsk; in chtls_recv_sock() 1255 tcp_done(newsk); in chtls_recv_sock() 1300 struct sock *newsk; in chtls_pass_accept_request() local 1317 if (newsk) { in chtls_pass_accept_request() 1400 if (!newsk) in chtls_pass_accept_request() 1406 reply_skb->sk = newsk; in chtls_pass_accept_request() [all …]
|
| /linux-6.15/net/core/ |
| H A D | sock.c | 2424 struct sock *newsk; in sk_clone_lock() local 2427 if (!newsk) in sk_clone_lock() 2430 sock_copy(newsk, sk); in sk_clone_lock() 2436 get_net_track(sock_net(newsk), &newsk->ns_tracker, priority); in sk_clone_lock() 2445 __netns_tracker_alloc(sock_net(newsk), &newsk->ns_tracker, in sk_clone_lock() 2450 bh_lock_sock(newsk); in sk_clone_lock() 2451 newsk->sk_backlog.head = newsk->sk_backlog.tail = NULL; in sk_clone_lock() 2498 newsk = NULL; in sk_clone_lock() 2505 newsk = NULL; in sk_clone_lock() 2515 newsk->sk_err = 0; in sk_clone_lock() [all …]
|
| H A D | bpf_sk_storage.c | 135 bpf_sk_storage_clone_elem(struct sock *newsk, in bpf_sk_storage_clone_elem() argument 141 copy_selem = bpf_selem_alloc(smap, newsk, NULL, true, false, GFP_ATOMIC); in bpf_sk_storage_clone_elem() 155 int bpf_sk_storage_clone(const struct sock *sk, struct sock *newsk) in bpf_sk_storage_clone() argument 162 RCU_INIT_POINTER(newsk->sk_bpf_storage, NULL); in bpf_sk_storage_clone() 189 copy_selem = bpf_sk_storage_clone_elem(newsk, smap, selem); in bpf_sk_storage_clone() 200 ret = bpf_local_storage_alloc(newsk, smap, copy_selem, GFP_ATOMIC); in bpf_sk_storage_clone() 204 &newsk->sk_omem_alloc); in bpf_sk_storage_clone()
|
| /linux-6.15/net/sctp/ |
| H A D | ipv6.c | 494 newnp = inet6_sk(newsk); in sctp_v6_copy_ip_options() 782 struct sock *newsk; in sctp_v6_create_accept_sk() local 787 if (!newsk) in sctp_v6_create_accept_sk() 790 sock_init_data(NULL, newsk); in sctp_v6_create_accept_sk() 792 sctp_copy_sock(newsk, sk, asoc); in sctp_v6_create_accept_sk() 800 newnp = inet6_sk(newsk); in sctp_v6_create_accept_sk() 807 sctp_v6_copy_ip_options(sk, newsk); in sctp_v6_create_accept_sk() 816 if (newsk->sk_prot->init(newsk)) { in sctp_v6_create_accept_sk() 817 sk_common_release(newsk); in sctp_v6_create_accept_sk() 818 newsk = NULL; in sctp_v6_create_accept_sk() [all …]
|
| H A D | protocol.c | 183 newinet = inet_sk(newsk); in sctp_v4_copy_ip_options() 591 if (!newsk) in sctp_v4_create_accept_sk() 594 sock_init_data(NULL, newsk); in sctp_v4_create_accept_sk() 596 sctp_copy_sock(newsk, sk, asoc); in sctp_v4_create_accept_sk() 597 sock_reset_flag(newsk, SOCK_ZAPPED); in sctp_v4_create_accept_sk() 599 sctp_v4_copy_ip_options(sk, newsk); in sctp_v4_create_accept_sk() 601 newinet = inet_sk(newsk); in sctp_v4_create_accept_sk() 605 if (newsk->sk_prot->init(newsk)) { in sctp_v4_create_accept_sk() 606 sk_common_release(newsk); in sctp_v4_create_accept_sk() 607 newsk = NULL; in sctp_v4_create_accept_sk() [all …]
|
| H A D | socket.c | 4859 struct sock *newsk = NULL; in sctp_accept() local 4892 if (!newsk) { in sctp_accept() 4902 sk_common_release(newsk); in sctp_accept() 4903 newsk = NULL; in sctp_accept() 4909 return newsk; in sctp_accept() 9477 newsk->sk_type = sk->sk_type; in sctp_copy_sock() 9479 newsk->sk_flags = sk->sk_flags; in sctp_copy_sock() 9483 newsk->sk_reuse = sk->sk_reuse; in sctp_copy_sock() 9498 newinet = inet_sk(newsk); in sctp_copy_sock() 9511 inet_set_bit(MC_LOOP, newsk); in sctp_copy_sock() [all …]
|
| /linux-6.15/net/phonet/ |
| H A D | pep.c | 766 struct sock *newsk = NULL; in pep_sock_accept() local 830 if (unlikely(newsk)) { in pep_sock_accept() 831 __sock_put(newsk); in pep_sock_accept() 832 newsk = NULL; in pep_sock_accept() 840 if (!newsk) { in pep_sock_accept() 846 sock_init_data(NULL, newsk); in pep_sock_accept() 847 newsk->sk_state = TCP_SYN_RECV; in pep_sock_accept() 852 newpn = pep_sk(newsk); in pep_sock_accept() 873 sock_put(newsk); in pep_sock_accept() 874 newsk = NULL; in pep_sock_accept() [all …]
|
| H A D | socket.c | 298 struct sock *newsk; in pn_socket_accept() local 303 newsk = sk->sk_prot->accept(sk, arg); in pn_socket_accept() 304 if (!newsk) in pn_socket_accept() 307 lock_sock(newsk); in pn_socket_accept() 308 sock_graft(newsk, newsock); in pn_socket_accept() 310 release_sock(newsk); in pn_socket_accept()
|
| /linux-6.15/net/tipc/ |
| H A D | topsrv.c | 460 struct sock *newsk; in tipc_topsrv_accept() local 482 newsk = newsock->sk; in tipc_topsrv_accept() 483 write_lock_bh(&newsk->sk_callback_lock); in tipc_topsrv_accept() 484 newsk->sk_data_ready = tipc_conn_data_ready; in tipc_topsrv_accept() 485 newsk->sk_write_space = tipc_conn_write_space; in tipc_topsrv_accept() 486 newsk->sk_user_data = con; in tipc_topsrv_accept() 487 write_unlock_bh(&newsk->sk_callback_lock); in tipc_topsrv_accept() 490 newsk->sk_data_ready(newsk); in tipc_topsrv_accept()
|
| /linux-6.15/include/net/ |
| H A D | bpf_sk_storage.h | 32 int bpf_sk_storage_clone(const struct sock *sk, struct sock *newsk); 42 struct sock *newsk) in bpf_sk_storage_clone() argument
|
| /linux-6.15/security/selinux/include/ |
| H A D | netlabel.h | 42 void selinux_netlbl_sctp_sk_clone(struct sock *sk, struct sock *newsk); 106 struct sock *newsk) in selinux_netlbl_sctp_sk_clone() argument
|
| /linux-6.15/net/llc/ |
| H A D | llc_conn.c | 764 struct sock *newsk = llc_sk_alloc(sock_net(sk), sk->sk_family, GFP_ATOMIC, in llc_create_incoming_sock() local 768 if (!newsk) in llc_create_incoming_sock() 770 newllc = llc_sk(newsk); in llc_create_incoming_sock() 775 llc_sap_add_socket(llc->sap, newsk); in llc_create_incoming_sock() 778 return newsk; in llc_create_incoming_sock() 805 struct sock *newsk = llc_create_incoming_sock(sk, skb->dev, in llc_conn_handler() local 807 if (!newsk) in llc_conn_handler() 809 skb_set_owner_r(skb, newsk); in llc_conn_handler()
|
| H A D | af_llc.c | 699 struct sock *sk = sock->sk, *newsk; in llc_ui_accept() local 726 newsk = skb->sk; in llc_ui_accept() 728 llc_ui_sk_init(newsock, newsk); in llc_ui_accept() 729 sock_reset_flag(newsk, SOCK_ZAPPED); in llc_ui_accept() 730 newsk->sk_state = TCP_ESTABLISHED; in llc_ui_accept() 733 newllc = llc_sk(newsk); in llc_ui_accept()
|
| /linux-6.15/net/mptcp/ |
| H A D | protocol.c | 3156 newnp = inet6_sk(newsk); in mptcp_copy_ip6_options() 3176 newinet = inet_sk(newsk); in mptcp_copy_ip_options() 3811 struct sock *ssk, *newsk; in mptcp_stream_accept() local 3824 if (!newsk) in mptcp_stream_accept() 3827 pr_debug("newsk=%p, subflow is mptcp=%d\n", newsk, sk_is_mptcp(newsk)); in mptcp_stream_accept() 3828 if (sk_is_mptcp(newsk)) { in mptcp_stream_accept() 3843 newsk = new_mptcp_sock; in mptcp_stream_accept() 3847 lock_sock(newsk); in mptcp_stream_accept() 3851 msk = mptcp_sk(newsk); in mptcp_stream_accept() 3876 lock_sock(newsk); in mptcp_stream_accept() [all …]
|
| H A D | pm_kernel.c | 636 struct sock *newsk, *ssk; in mptcp_pm_nl_create_listen_socket() local 645 newsk = entry->lsk->sk; in mptcp_pm_nl_create_listen_socket() 646 if (!newsk) in mptcp_pm_nl_create_listen_socket() 655 sock_lock_init_class_and_name(newsk, in mptcp_pm_nl_create_listen_socket() 661 lock_sock(newsk); in mptcp_pm_nl_create_listen_socket() 662 ssk = __mptcp_nmpc_sk(mptcp_sk(newsk)); in mptcp_pm_nl_create_listen_socket() 663 release_sock(newsk); in mptcp_pm_nl_create_listen_socket() 686 inet_sk_state_store(newsk, TCP_LISTEN); in mptcp_pm_nl_create_listen_socket()
|
| /linux-6.15/include/linux/ |
| H A D | skbuff.h | 2273 static inline void __skb_insert(struct sk_buff *newsk, in __skb_insert() argument 2280 WRITE_ONCE(newsk->next, next); in __skb_insert() 2281 WRITE_ONCE(newsk->prev, prev); in __skb_insert() 2282 WRITE_ONCE(((struct sk_buff_list *)next)->prev, newsk); in __skb_insert() 2283 WRITE_ONCE(((struct sk_buff_list *)prev)->next, newsk); in __skb_insert() 2377 struct sk_buff *newsk) in __skb_queue_after() argument 2387 struct sk_buff *newsk) in __skb_queue_before() argument 2403 struct sk_buff *newsk) in __skb_queue_head() argument 2405 __skb_queue_after(list, (struct sk_buff *)list, newsk); in __skb_queue_head() 2420 struct sk_buff *newsk) in __skb_queue_tail() argument [all …]
|