net/mptcp/pm_netlink.c

402 	struct sock *sk = (struct sock *)msk, *ssk;
435 			ssk = mptcp_subflow_tcp_sock(subflow);
436 			remote_address((struct sock_common *)ssk, &addrs[i]);
464 	struct sock *ssk = mptcp_subflow_tcp_sock(subflow);
470 	slow = lock_sock_fast(ssk);
477 	__mptcp_subflow_send_ack(ssk);
478 	unlock_sock_fast(ssk, slow);
743 		struct sock *ssk = mptcp_subflow_tcp_sock(subflow);
746 		mptcp_local_address((struct sock_common *)ssk, &local);
751 			remote_address((struct sock_common *)ssk, &remote);
795 			struct sock *ssk = mptcp_subflow_tcp_sock(subflow);
809 			mptcp_subflow_shutdown(sk, ssk, how);
812 			mptcp_close_ssk(sk, ssk, subflow);
1001 	struct sock *newsk, *ssk;
1027 	ssk = __mptcp_nmpc_sk(mptcp_sk(newsk));
1029 	if (IS_ERR(ssk))
1030 		return PTR_ERR(ssk);
1037 	if (ssk->sk_family == AF_INET)
1038 		err = inet_bind_sk(ssk, (struct sockaddr *)&addr, addrlen);
1040 	else if (ssk->sk_family == AF_INET6)
1041 		err = inet6_bind_sk(ssk, (struct sockaddr *)&addr, addrlen);
1052 	lock_sock(ssk);
1053 	err = __inet_listen_sk(ssk, backlog);
1055 		mptcp_event_pm_listener(ssk, MPTCP_EVENT_LISTENER_CREATED);
1056 	release_sock(ssk);
1107 void mptcp_pm_nl_subflow_chk_stale(const struct mptcp_sock *msk, struct sock *ssk)
1109 	struct mptcp_subflow_context *iter, *subflow = mptcp_subflow_ctx(ssk);
1126 			slow = lock_sock_fast(ssk);
1127 			if (!tcp_rtx_and_write_queues_empty(ssk)) {
1132 			unlock_sock_fast(ssk, slow);
1959 static int mptcp_event_add_subflow(struct sk_buff *skb, const struct sock *ssk)
1961 	const struct inet_sock *issk = inet_sk(ssk);
1964 	if (nla_put_u16(skb, MPTCP_ATTR_FAMILY, ssk->sk_family))
1967 	switch (ssk->sk_family) {
1976 		const struct ipv6_pinfo *np = inet6_sk(ssk);
1980 		if (nla_put_in6_addr(skb, MPTCP_ATTR_DADDR6, &ssk->sk_v6_daddr))
1995 	sf = mptcp_subflow_ctx(ssk);
2010 					 const struct sock *ssk)
2019 	if (mptcp_event_add_subflow(skb, ssk))
2022 	sf = mptcp_subflow_ctx(ssk);
2029 	if (ssk->sk_bound_dev_if &&
2030 	    nla_put_s32(skb, MPTCP_ATTR_IF_IDX, ssk->sk_bound_dev_if))
2033 	sk_err = READ_ONCE(ssk->sk_err);
2043 				       const struct sock *ssk)
2045 	return mptcp_event_put_token_and_ssk(skb, msk, ssk);
2050 				  const struct sock *ssk)
2054 	if (mptcp_event_put_token_and_ssk(skb, msk, ssk))
2057 	sf = mptcp_subflow_ctx(ssk);
2072 			       const struct sock *ssk)
2082 	return mptcp_event_add_subflow(skb, ssk);
2116 void mptcp_event_addr_announced(const struct sock *ssk,
2119 	struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk);
2121 	struct net *net = sock_net(ssk);
2145 			 inet_sk(ssk)->inet_dport :
2173 void mptcp_event_pm_listener(const struct sock *ssk,
2176 	const struct inet_sock *issk = inet_sk(ssk);
2177 	struct net *net = sock_net(ssk);
2192 	if (nla_put_u16(skb, MPTCP_ATTR_FAMILY, ssk->sk_family))
2198 	switch (ssk->sk_family) {
2205 		const struct ipv6_pinfo *np = inet6_sk(ssk);
2226 		 const struct sock *ssk, gfp_t gfp)
2249 		if (mptcp_event_created(skb, msk, ssk) < 0)
2263 		if (mptcp_event_sub_established(skb, msk, ssk) < 0)
2267 		if (mptcp_event_sub_closed(skb, msk, ssk) < 0)