/net/dccp/ |
D | ipv6.c | 424 struct sock *newsk; in dccp_v6_request_recv_sock() local 430 newsk = dccp_v4_request_recv_sock(sk, skb, req, dst, in dccp_v6_request_recv_sock() 432 if (newsk == NULL) in dccp_v6_request_recv_sock() 435 newdp6 = (struct dccp6_sock *)newsk; in dccp_v6_request_recv_sock() 436 newinet = inet_sk(newsk); in dccp_v6_request_recv_sock() 438 newnp = inet6_sk(newsk); in dccp_v6_request_recv_sock() 442 newnp->saddr = newsk->sk_v6_rcv_saddr; in dccp_v6_request_recv_sock() 444 inet_csk(newsk)->icsk_af_ops = &dccp_ipv6_mapped; in dccp_v6_request_recv_sock() 445 newsk->sk_backlog_rcv = dccp_v4_do_rcv; in dccp_v6_request_recv_sock() 464 dccp_sync_mss(newsk, inet_csk(newsk)->icsk_pmtu_cookie); in dccp_v6_request_recv_sock() [all …]
|
D | minisocks.c | 87 struct sock *newsk = inet_csk_clone_lock(sk, req, GFP_ATOMIC); in dccp_create_openreq_child() local 89 if (newsk != NULL) { in dccp_create_openreq_child() 91 struct inet_connection_sock *newicsk = inet_csk(newsk); in dccp_create_openreq_child() 92 struct dccp_sock *newdp = dccp_sk(newsk); in dccp_create_openreq_child() 125 if (dccp_feat_activate_values(newsk, &dreq->dreq_featneg)) { in dccp_create_openreq_child() 126 sk_free_unlock_clone(newsk); in dccp_create_openreq_child() 129 dccp_init_xmit_timers(newsk); in dccp_create_openreq_child() 133 return newsk; in dccp_create_openreq_child()
|
D | ipv4.c | 411 struct sock *newsk; in dccp_v4_request_recv_sock() local 416 newsk = dccp_create_openreq_child(sk, req, skb); in dccp_v4_request_recv_sock() 417 if (newsk == NULL) in dccp_v4_request_recv_sock() 420 newinet = inet_sk(newsk); in dccp_v4_request_recv_sock() 422 sk_daddr_set(newsk, ireq->ir_rmt_addr); in dccp_v4_request_recv_sock() 423 sk_rcv_saddr_set(newsk, ireq->ir_loc_addr); in dccp_v4_request_recv_sock() 430 if (dst == NULL && (dst = inet_csk_route_child_sock(sk, newsk, req)) == NULL) in dccp_v4_request_recv_sock() 433 sk_setup_caps(newsk, dst); in dccp_v4_request_recv_sock() 435 dccp_sync_mss(newsk, dst_mtu(dst)); in dccp_v4_request_recv_sock() 437 if (__inet_inherit_port(sk, newsk) < 0) in dccp_v4_request_recv_sock() [all …]
|
/net/ipv4/ |
D | inet_connection_sock.c | 480 struct sock *newsk; in inet_csk_accept() local 506 newsk = req->sk; in inet_csk_accept() 526 if (newsk && mem_cgroup_sockets_enabled) { in inet_csk_accept() 532 lock_sock(newsk); in inet_csk_accept() 537 amt = sk_mem_pages(newsk->sk_forward_alloc + in inet_csk_accept() 538 atomic_read(&newsk->sk_rmem_alloc)); in inet_csk_accept() 539 mem_cgroup_sk_alloc(newsk); in inet_csk_accept() 540 if (newsk->sk_memcg && amt) in inet_csk_accept() 541 mem_cgroup_charge_skmem(newsk->sk_memcg, amt, in inet_csk_accept() 544 release_sock(newsk); in inet_csk_accept() [all …]
|
D | tcp_minisocks.c | 460 struct sock *newsk = inet_csk_clone_lock(sk, req, GFP_ATOMIC); in tcp_create_openreq_child() local 467 if (!newsk) in tcp_create_openreq_child() 470 newicsk = inet_csk(newsk); in tcp_create_openreq_child() 471 newtp = tcp_sk(newsk); in tcp_create_openreq_child() 499 newsk->sk_txhash = treq->txhash; in tcp_create_openreq_child() 502 tcp_init_xmit_timers(newsk); in tcp_create_openreq_child() 505 if (sock_flag(newsk, SOCK_KEEPOPEN)) in tcp_create_openreq_child() 506 inet_csk_reset_keepalive_timer(newsk, in tcp_create_openreq_child() 551 tcp_bpf_clone(sk, newsk); in tcp_create_openreq_child() 555 return newsk; in tcp_create_openreq_child()
|
D | tcp_ipv4.c | 1555 struct sock *newsk; in tcp_v4_syn_recv_sock() local 1566 newsk = tcp_create_openreq_child(sk, req, skb); in tcp_v4_syn_recv_sock() 1567 if (!newsk) in tcp_v4_syn_recv_sock() 1570 newsk->sk_gso_type = SKB_GSO_TCPV4; in tcp_v4_syn_recv_sock() 1571 inet_sk_rx_dst_set(newsk, skb); in tcp_v4_syn_recv_sock() 1573 newtp = tcp_sk(newsk); in tcp_v4_syn_recv_sock() 1574 newinet = inet_sk(newsk); in tcp_v4_syn_recv_sock() 1576 sk_daddr_set(newsk, ireq->ir_rmt_addr); in tcp_v4_syn_recv_sock() 1577 sk_rcv_saddr_set(newsk, ireq->ir_loc_addr); in tcp_v4_syn_recv_sock() 1578 newsk->sk_bound_dev_if = ireq->ir_iif; in tcp_v4_syn_recv_sock() [all …]
|
D | tcp_bpf.c | 646 void tcp_bpf_clone(const struct sock *sk, struct sock *newsk) in tcp_bpf_clone() argument 648 struct proto *prot = newsk->sk_prot; in tcp_bpf_clone() 651 newsk->sk_prot = sk->sk_prot_creator; in tcp_bpf_clone()
|
/net/ipv6/ |
D | tcp_ipv6.c | 1250 struct sock *newsk; in tcp_v6_syn_recv_sock() local 1262 newsk = tcp_v4_syn_recv_sock(sk, skb, req, dst, in tcp_v6_syn_recv_sock() 1265 if (!newsk) in tcp_v6_syn_recv_sock() 1268 inet_sk(newsk)->pinet6 = tcp_inet6_sk(newsk); in tcp_v6_syn_recv_sock() 1270 newinet = inet_sk(newsk); in tcp_v6_syn_recv_sock() 1271 newnp = tcp_inet6_sk(newsk); in tcp_v6_syn_recv_sock() 1272 newtp = tcp_sk(newsk); in tcp_v6_syn_recv_sock() 1276 newnp->saddr = newsk->sk_v6_rcv_saddr; in tcp_v6_syn_recv_sock() 1278 inet_csk(newsk)->icsk_af_ops = &ipv6_mapped; in tcp_v6_syn_recv_sock() 1279 if (sk_is_mptcp(newsk)) in tcp_v6_syn_recv_sock() [all …]
|
/net/core/ |
D | sock.c | 2054 struct sock *newsk; in sk_clone_lock() local 2056 newsk = sk_prot_alloc(prot, priority, sk->sk_family); in sk_clone_lock() 2057 if (!newsk) in sk_clone_lock() 2060 sock_copy(newsk, sk); in sk_clone_lock() 2062 newsk->sk_prot_creator = prot; in sk_clone_lock() 2065 if (likely(newsk->sk_net_refcnt)) { in sk_clone_lock() 2066 get_net(sock_net(newsk)); in sk_clone_lock() 2067 sock_inuse_add(sock_net(newsk), 1); in sk_clone_lock() 2069 sk_node_init(&newsk->sk_node); in sk_clone_lock() 2070 sock_lock_init(newsk); in sk_clone_lock() [all …]
|
D | bpf_sk_storage.c | 167 bpf_sk_storage_clone_elem(struct sock *newsk, in bpf_sk_storage_clone_elem() argument 173 copy_selem = bpf_selem_alloc(smap, newsk, NULL, true); in bpf_sk_storage_clone_elem() 187 int bpf_sk_storage_clone(const struct sock *sk, struct sock *newsk) in bpf_sk_storage_clone() argument 194 RCU_INIT_POINTER(newsk->sk_bpf_storage, NULL); in bpf_sk_storage_clone() 220 copy_selem = bpf_sk_storage_clone_elem(newsk, smap, selem); in bpf_sk_storage_clone() 231 ret = bpf_local_storage_alloc(newsk, smap, copy_selem); in bpf_sk_storage_clone() 235 &newsk->sk_omem_alloc); in bpf_sk_storage_clone()
|
/net/sctp/ |
D | ipv6.c | 490 static void sctp_v6_copy_ip_options(struct sock *sk, struct sock *newsk) in sctp_v6_copy_ip_options() argument 495 newnp = inet6_sk(newsk); in sctp_v6_copy_ip_options() 500 opt = ipv6_dup_options(newsk, opt); in sctp_v6_copy_ip_options() 768 struct sock *newsk; in sctp_v6_create_accept_sk() local 772 newsk = sk_alloc(sock_net(sk), PF_INET6, GFP_KERNEL, sk->sk_prot, kern); in sctp_v6_create_accept_sk() 773 if (!newsk) in sctp_v6_create_accept_sk() 776 sock_init_data(NULL, newsk); in sctp_v6_create_accept_sk() 778 sctp_copy_sock(newsk, sk, asoc); in sctp_v6_create_accept_sk() 781 newsctp6sk = (struct sctp6_sock *)newsk; in sctp_v6_create_accept_sk() 782 inet_sk(newsk)->pinet6 = &newsctp6sk->inet6; in sctp_v6_create_accept_sk() [all …]
|
D | protocol.c | 177 static void sctp_v4_copy_ip_options(struct sock *sk, struct sock *newsk) in sctp_v4_copy_ip_options() argument 182 newinet = inet_sk(newsk); in sctp_v4_copy_ip_options() 187 newopt = sock_kmalloc(newsk, sizeof(*inet_opt) + in sctp_v4_copy_ip_options() 579 struct sock *newsk = sk_alloc(sock_net(sk), PF_INET, GFP_KERNEL, in sctp_v4_create_accept_sk() local 583 if (!newsk) in sctp_v4_create_accept_sk() 586 sock_init_data(NULL, newsk); in sctp_v4_create_accept_sk() 588 sctp_copy_sock(newsk, sk, asoc); in sctp_v4_create_accept_sk() 589 sock_reset_flag(newsk, SOCK_ZAPPED); in sctp_v4_create_accept_sk() 591 sctp_v4_copy_ip_options(sk, newsk); in sctp_v4_create_accept_sk() 593 newinet = inet_sk(newsk); in sctp_v4_create_accept_sk() [all …]
|
D | socket.c | 90 static int sctp_sock_migrate(struct sock *oldsk, struct sock *newsk, 4853 struct sock *newsk = NULL; in sctp_accept() local 4884 newsk = sp->pf->create_accept_sk(sk, asoc, kern); in sctp_accept() 4885 if (!newsk) { in sctp_accept() 4893 error = sctp_sock_migrate(sk, newsk, asoc, SCTP_SOCKET_TCP); in sctp_accept() 4895 sk_common_release(newsk); in sctp_accept() 4896 newsk = NULL; in sctp_accept() 4902 return newsk; in sctp_accept() 9454 void sctp_copy_sock(struct sock *newsk, struct sock *sk, in sctp_copy_sock() argument 9462 newsk->sk_type = sk->sk_type; in sctp_copy_sock() [all …]
|
D | associola.c | 1073 void sctp_assoc_migrate(struct sctp_association *assoc, struct sock *newsk) in sctp_assoc_migrate() argument 1075 struct sctp_sock *newsp = sctp_sk(newsk); in sctp_assoc_migrate() 1096 assoc->base.sk = newsk; in sctp_assoc_migrate()
|
/net/phonet/ |
D | pep.c | 766 struct sock *newsk = NULL; in pep_sock_accept() local 828 newsk = pep_find_pipe(&pn->hlist, &dst, pipe_handle); in pep_sock_accept() 829 if (unlikely(newsk)) { in pep_sock_accept() 830 __sock_put(newsk); in pep_sock_accept() 831 newsk = NULL; in pep_sock_accept() 837 newsk = sk_alloc(sock_net(sk), PF_PHONET, GFP_KERNEL, sk->sk_prot, in pep_sock_accept() 839 if (!newsk) { in pep_sock_accept() 845 sock_init_data(NULL, newsk); in pep_sock_accept() 846 newsk->sk_state = TCP_SYN_RECV; in pep_sock_accept() 847 newsk->sk_backlog_rcv = pipe_do_rcv; in pep_sock_accept() [all …]
|
D | socket.c | 298 struct sock *newsk; in pn_socket_accept() local 304 newsk = sk->sk_prot->accept(sk, flags, &err, kern); in pn_socket_accept() 305 if (!newsk) in pn_socket_accept() 308 lock_sock(newsk); in pn_socket_accept() 309 sock_graft(newsk, newsock); in pn_socket_accept() 311 release_sock(newsk); in pn_socket_accept()
|
/net/tipc/ |
D | topsrv.c | 457 struct sock *newsk; in tipc_topsrv_accept() local 479 newsk = newsock->sk; in tipc_topsrv_accept() 480 write_lock_bh(&newsk->sk_callback_lock); in tipc_topsrv_accept() 481 newsk->sk_data_ready = tipc_conn_data_ready; in tipc_topsrv_accept() 482 newsk->sk_write_space = tipc_conn_write_space; in tipc_topsrv_accept() 483 newsk->sk_user_data = con; in tipc_topsrv_accept() 484 write_unlock_bh(&newsk->sk_callback_lock); in tipc_topsrv_accept() 487 newsk->sk_data_ready(newsk); in tipc_topsrv_accept()
|
/net/llc/ |
D | llc_conn.c | 752 struct sock *newsk = llc_sk_alloc(sock_net(sk), sk->sk_family, GFP_ATOMIC, in llc_create_incoming_sock() local 756 if (!newsk) in llc_create_incoming_sock() 758 newllc = llc_sk(newsk); in llc_create_incoming_sock() 763 llc_sap_add_socket(llc->sap, newsk); in llc_create_incoming_sock() 766 return newsk; in llc_create_incoming_sock() 793 struct sock *newsk = llc_create_incoming_sock(sk, skb->dev, in llc_conn_handler() local 795 if (!newsk) in llc_conn_handler() 797 skb_set_owner_r(skb, newsk); in llc_conn_handler()
|
D | af_llc.c | 698 struct sock *sk = sock->sk, *newsk; in llc_ui_accept() local 725 newsk = skb->sk; in llc_ui_accept() 727 llc_ui_sk_init(newsock, newsk); in llc_ui_accept() 728 sock_reset_flag(newsk, SOCK_ZAPPED); in llc_ui_accept() 729 newsk->sk_state = TCP_ESTABLISHED; in llc_ui_accept() 732 newllc = llc_sk(newsk); in llc_ui_accept()
|
/net/unix/ |
D | af_unix.c | 1326 struct sock *newsk = NULL; in unix_stream_connect() local 1351 newsk = unix_create1(sock_net(sk), NULL, 0, sock->type); in unix_stream_connect() 1352 if (IS_ERR(newsk)) { in unix_stream_connect() 1353 err = PTR_ERR(newsk); in unix_stream_connect() 1354 newsk = NULL; in unix_stream_connect() 1361 skb = sock_wmalloc(newsk, 1, 0, GFP_KERNEL); in unix_stream_connect() 1436 err = security_unix_stream_connect(sk, other, newsk); in unix_stream_connect() 1445 unix_peer(newsk) = sk; in unix_stream_connect() 1446 newsk->sk_state = TCP_ESTABLISHED; in unix_stream_connect() 1447 newsk->sk_type = sk->sk_type; in unix_stream_connect() [all …]
|
/net/mptcp/ |
D | protocol.c | 2890 struct sock *newsk; in mptcp_accept() local 2899 newsk = inet_csk_accept(listener->sk, flags, err, kern); in mptcp_accept() 2900 if (!newsk) in mptcp_accept() 2903 pr_debug("msk=%p, subflow is mptcp=%d", msk, sk_is_mptcp(newsk)); in mptcp_accept() 2904 if (sk_is_mptcp(newsk)) { in mptcp_accept() 2908 subflow = mptcp_subflow_ctx(newsk); in mptcp_accept() 2915 tcp_sk(newsk)->is_mptcp = 0; in mptcp_accept() 2921 newsk = new_mptcp_sock; in mptcp_accept() 2929 newsk->sk_kern_sock = kern; in mptcp_accept() 2930 return newsk; in mptcp_accept() [all …]
|
D | pm_netlink.c | 899 struct sock *newsk; in mptcp_pm_nl_create_listen_socket() local 908 newsk = entry->lsk->sk; in mptcp_pm_nl_create_listen_socket() 909 if (!newsk) { in mptcp_pm_nl_create_listen_socket() 920 sock_lock_init_class_and_name(newsk, in mptcp_pm_nl_create_listen_socket() 926 lock_sock(newsk); in mptcp_pm_nl_create_listen_socket() 927 ssock = __mptcp_nmpc_socket(mptcp_sk(newsk)); in mptcp_pm_nl_create_listen_socket() 928 release_sock(newsk); in mptcp_pm_nl_create_listen_socket()
|
D | subflow.c | 1752 struct sock *newsk, in subflow_ulp_clone() argument 1756 struct mptcp_subflow_context *old_ctx = mptcp_subflow_ctx(newsk); in subflow_ulp_clone() 1761 subflow_ulp_fallback(newsk, old_ctx); in subflow_ulp_clone() 1765 new_ctx = subflow_create_ctx(newsk, priority); in subflow_ulp_clone() 1767 subflow_ulp_fallback(newsk, old_ctx); in subflow_ulp_clone() 1778 new_ctx->tcp_sock = newsk; in subflow_ulp_clone()
|
/net/kcm/ |
D | kcmsock.c | 1625 struct sock *newsk; in kcm_clone() local 1636 newsk = sk_alloc(sock_net(osock->sk), PF_KCM, GFP_KERNEL, in kcm_clone() 1638 if (!newsk) { in kcm_clone() 1642 sock_init_data(newsock, newsk); in kcm_clone() 1643 init_kcm_sock(kcm_sk(newsk), kcm_sk(osock->sk)->mux); in kcm_clone()
|
/net/netrom/ |
D | af_netrom.c | 779 struct sock *newsk; in nr_accept() local 825 newsk = skb->sk; in nr_accept() 826 sock_graft(newsk, newsock); in nr_accept()
|