From nobody Sat Oct 11 06:01:21 2025 Received: from smtp.kernel.org (aws-us-west-2-korg-mail-1.web.codeaurora.org [10.30.226.201]) (using TLSv1.2 with cipher ECDHE-RSA-AES256-GCM-SHA384 (256/256 bits)) (No client certificate requested) by smtp.subspace.kernel.org (Postfix) with ESMTPS id 86A6022ACEB for ; Tue, 23 Sep 2025 09:33:06 +0000 (UTC) Authentication-Results: smtp.subspace.kernel.org; arc=none smtp.client-ip=10.30.226.201 ARC-Seal: i=1; a=rsa-sha256; d=subspace.kernel.org; s=arc-20240116; t=1758619986; cv=none; b=C7xd0Z02ga/LmAH473vPG8hKytg+XkPHMnqmG041WzqeRokfjpI0bWijl2nUttoWaDdrhSJQfSbJYdkSGz/5U3jSG4W9IwfJtxxJyPSvzHur1SyUHU0TdZmnjuIM1NVeDRk/QnYzHUITLsMjElJdSgILCqGZwmvMqEo0ZjskY10= ARC-Message-Signature: i=1; a=rsa-sha256; d=subspace.kernel.org; s=arc-20240116; t=1758619986; c=relaxed/simple; bh=6yfPBzZSyhsri2II2OENRj+P9fe0Ytg3eeV3x75kBME=; h=From:Date:Subject:MIME-Version:Content-Type:Message-Id:References: In-Reply-To:To:Cc; b=onIDxsDVzlexV6lXrCzsCim5E0TjE9p39571cH6FkE2trogMd9rhBL6YD8tTcsBu3MMhX9xVL/T//LLUqaCvl20T0wbO2hE2Tu64jxPD9HOipEFu+4zuJgI356D0ooHbl1ajzE3qku1XBC0e8a164GDwNeXbE4ITmN4eFBQgn04= ARC-Authentication-Results: i=1; smtp.subspace.kernel.org; dkim=pass (2048-bit key) header.d=kernel.org header.i=@kernel.org header.b=U86hRRjn; arc=none smtp.client-ip=10.30.226.201 Authentication-Results: smtp.subspace.kernel.org; dkim=pass (2048-bit key) header.d=kernel.org header.i=@kernel.org header.b="U86hRRjn" Received: by smtp.kernel.org (Postfix) with ESMTPSA id 8A33CC116C6; Tue, 23 Sep 2025 09:33:05 +0000 (UTC) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/simple; d=kernel.org; s=k20201202; t=1758619986; bh=6yfPBzZSyhsri2II2OENRj+P9fe0Ytg3eeV3x75kBME=; h=From:Date:Subject:References:In-Reply-To:To:Cc:From; b=U86hRRjnwx5XhtUm0MtDA5R5APFu1r6zdN/si10d6eqs1XM4KboEdbTivU1BwJ0oZ LzAeYs6owAv1XIxfbmSYjnH4rBRilCxH2prAa/NIoIiFDMjw6TL2KAuP+kiybOpK47 G1e8PmhEHmoisPxIyQGGsPWuUqiHThDllFS26oLytj3Ri8f4goZvIOOphLPSy6I0BY p9Gg4SrRv9Y7bpT1I0dd5W0zDBPh08z5/hepkHFLgrMj33ZE9ezQ5dx/hORI/PtBPW fFKk2uXtgXh/AqhfHv3Ez4PFa+q8OeHdSeJ/e55RLYAl6fluPv+8wEp8+FQlnKw+ub 3Nb1w1oHSS2ww== From: "Matthieu Baerts (NGI0)" Date: Tue, 23 Sep 2025 11:32:47 +0200 Subject: [PATCH mptcp-next v2 1/6] mptcp: pm: in-kernel: remove stale_loss_cnt Precedence: bulk X-Mailing-List: mptcp@lists.linux.dev List-Id: List-Subscribe: List-Unsubscribe: MIME-Version: 1.0 Content-Type: text/plain; charset="utf-8" Content-Transfer-Encoding: quoted-printable Message-Id: <20250923-pm-kern-endp-add_addr-new-v2-1-ee5369dad569@kernel.org> References: <20250923-pm-kern-endp-add_addr-new-v2-0-ee5369dad569@kernel.org> In-Reply-To: <20250923-pm-kern-endp-add_addr-new-v2-0-ee5369dad569@kernel.org> To: MPTCP Upstream Cc: "Matthieu Baerts (NGI0)" X-Mailer: b4 0.14.2 X-Developer-Signature: v=1; a=openpgp-sha256; l=1297; i=matttbe@kernel.org; h=from:subject:message-id; bh=6yfPBzZSyhsri2II2OENRj+P9fe0Ytg3eeV3x75kBME=; b=owGbwMvMwCVWo/Th0Gd3rumMp9WSGDIuZXrmvE8Ot712VnvvjocJE/c3Fm64nsiywP+LpNVKL 4mSe9FrO0pZGMS4GGTFFFmk2yLzZz6v4i3x8rOAmcPKBDKEgYtTACZyJZKRYf9ce+OEE8sO2up9 +344rJ/78saqZ2wPzv+7GZF39zfT1r+MDAtLLlpoZIf8mdJ7d/ljt1Dz5vQ7kfN33u/84/As6X9 APj8A X-Developer-Key: i=matttbe@kernel.org; a=openpgp; fpr=E8CB85F76877057A6E27F77AF6B7824F4269A073 It is currently not used. It was in fact never used since its introduction in commit ff5a0b421cb2 ("mptcp: faster active backup recovery"). It was probably initially added to struct pm_nl_pernet during the development of this commit, before being added to struct mptcp_pernet in ctrl.c, but not removed from the first place. Signed-off-by: Matthieu Baerts (NGI0) Reviewed-by: Mat Martineau --- net/mptcp/pm_kernel.c | 2 -- 1 file changed, 2 deletions(-) diff --git a/net/mptcp/pm_kernel.c b/net/mptcp/pm_kernel.c index e84c381aa3a4e2ad8a05e4b0daa7a5e8daf2c35b..52ae6304b311189ab927857ab74= a9ee44ac6d76a 100644 --- a/net/mptcp/pm_kernel.c +++ b/net/mptcp/pm_kernel.c @@ -19,7 +19,6 @@ struct pm_nl_pernet { spinlock_t lock; struct list_head endp_list; unsigned int endpoints; - unsigned int stale_loss_cnt; unsigned int endp_signal_max; unsigned int endp_subflow_max; unsigned int limit_add_addr_accepted; @@ -1461,7 +1460,6 @@ static int __net_init pm_nl_init_net(struct net *net) /* Cit. 2 subflows ought to be enough for anybody. */ pernet->limit_extra_subflows =3D 2; pernet->next_id =3D 1; - pernet->stale_loss_cnt =3D 4; spin_lock_init(&pernet->lock); =20 /* No need to initialize other pernet fields, the struct is zeroed at --=20 2.51.0 From nobody Sat Oct 11 06:01:21 2025 Received: from smtp.kernel.org (aws-us-west-2-korg-mail-1.web.codeaurora.org [10.30.226.201]) (using TLSv1.2 with cipher ECDHE-RSA-AES256-GCM-SHA384 (256/256 bits)) (No client certificate requested) by smtp.subspace.kernel.org (Postfix) with ESMTPS id 48DD022ACEB for ; Tue, 23 Sep 2025 09:33:07 +0000 (UTC) Authentication-Results: smtp.subspace.kernel.org; arc=none smtp.client-ip=10.30.226.201 ARC-Seal: i=1; a=rsa-sha256; d=subspace.kernel.org; s=arc-20240116; t=1758619987; cv=none; b=NkZpZcKoQjVhcusNkchYqFsgoDJAwuifCLvLkXkOtRMvJvBvKGMjh81nzQDUAnxiRnnBEBH85D+E+M3jlWZn6HBp0dBMcpDfV/hNEY7K86Im/isbwTCbdXFQkfBgqxZdRAJYUUm1e2VDPm5PYjNtZU5hlQR0q1wLzCvWxK1mJ/g= ARC-Message-Signature: i=1; a=rsa-sha256; d=subspace.kernel.org; s=arc-20240116; t=1758619987; c=relaxed/simple; bh=ndfy6Mw2jvVkalIV+KJeSFelr6WEbJjZmLy0qzzfsaY=; h=From:Date:Subject:MIME-Version:Content-Type:Message-Id:References: In-Reply-To:To:Cc; b=AVb11E1njLPROJf/OdMELrUSgLnrpjN3tAePwbLKpOeGoJAMMCwjhQ1UgtlyruoBpqBnqxV470SJWpW+djTzSHF43AfDFkTUz48ih+BWhH+hfvTGZo2O3+Y3myPV0KMqjECz1PLD4RwmI7VjqIrDZp1Sa8ujsCS5WagDrPcVSJ4= ARC-Authentication-Results: i=1; smtp.subspace.kernel.org; dkim=pass (2048-bit key) header.d=kernel.org header.i=@kernel.org header.b=tdUt1rB6; arc=none smtp.client-ip=10.30.226.201 Authentication-Results: smtp.subspace.kernel.org; dkim=pass (2048-bit key) header.d=kernel.org header.i=@kernel.org header.b="tdUt1rB6" Received: by smtp.kernel.org (Postfix) with ESMTPSA id 6B058C116B1; Tue, 23 Sep 2025 09:33:06 +0000 (UTC) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/simple; d=kernel.org; s=k20201202; t=1758619986; bh=ndfy6Mw2jvVkalIV+KJeSFelr6WEbJjZmLy0qzzfsaY=; h=From:Date:Subject:References:In-Reply-To:To:Cc:From; b=tdUt1rB612/pOYtrC0+oPRbz47rTWS7gS8eJsx3iwUWfCwzQ/zSEWt6XDmrFTHKz6 ayLURqe39dR9HkUX0hWwGB49p4pAZ8ygb42EPrsE4lJev+FhGQOcmYTQmwDDUQYpVN uPHip+hghMmDY0uGKC93WJZhOP6aLyZYs3sUdtZ7eflw+PT0R2O3xXGGosDd27oLAH 1UUA1VxYEoOKfeYwARr7n1WM4ZiqY5bR6PaRbJNcvw7hCzJb1SSKuYJUlmE6EaABoN Qcf6fyLj2oOzqwr97JTJ11eBU8gd85MeYYYp4bKMUnuQjp6VG1hTA76Qk2ceU5Xc5n 9Q0+1ISJn3a/A== From: "Matthieu Baerts (NGI0)" Date: Tue, 23 Sep 2025 11:32:48 +0200 Subject: [PATCH mptcp-next v2 2/6] mptcp: pm: in-kernel: reduce pernet struct size Precedence: bulk X-Mailing-List: mptcp@lists.linux.dev List-Id: List-Subscribe: List-Unsubscribe: MIME-Version: 1.0 Content-Type: text/plain; charset="utf-8" Content-Transfer-Encoding: quoted-printable Message-Id: <20250923-pm-kern-endp-add_addr-new-v2-2-ee5369dad569@kernel.org> References: <20250923-pm-kern-endp-add_addr-new-v2-0-ee5369dad569@kernel.org> In-Reply-To: <20250923-pm-kern-endp-add_addr-new-v2-0-ee5369dad569@kernel.org> To: MPTCP Upstream Cc: "Matthieu Baerts (NGI0)" X-Mailer: b4 0.14.2 X-Developer-Signature: v=1; a=openpgp-sha256; l=9388; i=matttbe@kernel.org; h=from:subject:message-id; bh=ndfy6Mw2jvVkalIV+KJeSFelr6WEbJjZmLy0qzzfsaY=; b=owGbwMvMwCVWo/Th0Gd3rumMp9WSGDIuZXr1ljicXTX3TnMRl++KRZO8Doh9dL15++Xmmltqr wvFf8692VHKwiDGxSArpsgi3RaZP/N5FW+Jl58FzBxWJpAhDFycAjCR5imMDG8Ci9Y2S7CfrUxd y5N+JCqASb9RiFf+Se+ByaJmPTssKhkZ/nsYPslv592jbNtzeduyXHljoYkKb74sllJvPPlX2GM ZNwA= X-Developer-Key: i=matttbe@kernel.org; a=openpgp; fpr=E8CB85F76877057A6E27F77AF6B7824F4269A073 All the 'unsigned int' variables from the 'pm_nl_pernet' structure are bounded to MPTCP_PM_ADDR_MAX, currently set to 8. The endpoint ID is also bounded by the protocol to 8-bit. MPTCP_PM_ADDR_MAX, if extended later, will never over 8-bit. So no need to use 'unsigned int' variables, 'u8' is enough. Note that the exposed counters in MPTCP_INFO are already limited to 8-bit, same for pm->extra_subflows, and others. So it seems even better to limit them to 8-bit. Signed-off-by: Matthieu Baerts (NGI0) Reviewed-by: Mat Martineau --- net/mptcp/pm_kernel.c | 59 ++++++++++++++++++++---------------------------= ---- net/mptcp/protocol.h | 8 +++---- 2 files changed, 27 insertions(+), 40 deletions(-) diff --git a/net/mptcp/pm_kernel.c b/net/mptcp/pm_kernel.c index 52ae6304b311189ab927857ab74a9ee44ac6d76a..ae6ab3178c226fe3ec66d156bb0= dc919075043e5 100644 --- a/net/mptcp/pm_kernel.c +++ b/net/mptcp/pm_kernel.c @@ -18,12 +18,12 @@ struct pm_nl_pernet { /* protects pernet updates */ spinlock_t lock; struct list_head endp_list; - unsigned int endpoints; - unsigned int endp_signal_max; - unsigned int endp_subflow_max; - unsigned int limit_add_addr_accepted; - unsigned int limit_extra_subflows; - unsigned int next_id; + u8 endpoints; + u8 endp_signal_max; + u8 endp_subflow_max; + u8 limit_add_addr_accepted; + u8 limit_extra_subflows; + u8 next_id; DECLARE_BITMAP(id_bitmap, MPTCP_PM_MAX_ADDR_ID + 1); }; =20 @@ -45,7 +45,7 @@ static struct pm_nl_pernet *genl_info_pm_nl(struct genl_i= nfo *info) return pm_nl_get_pernet(genl_info_net(info)); } =20 -unsigned int mptcp_pm_get_endp_signal_max(const struct mptcp_sock *msk) +u8 mptcp_pm_get_endp_signal_max(const struct mptcp_sock *msk) { const struct pm_nl_pernet *pernet =3D pm_nl_get_pernet_from_msk(msk); =20 @@ -53,7 +53,7 @@ unsigned int mptcp_pm_get_endp_signal_max(const struct mp= tcp_sock *msk) } EXPORT_SYMBOL_GPL(mptcp_pm_get_endp_signal_max); =20 -unsigned int mptcp_pm_get_endp_subflow_max(const struct mptcp_sock *msk) +u8 mptcp_pm_get_endp_subflow_max(const struct mptcp_sock *msk) { struct pm_nl_pernet *pernet =3D pm_nl_get_pernet_from_msk(msk); =20 @@ -61,7 +61,7 @@ unsigned int mptcp_pm_get_endp_subflow_max(const struct m= ptcp_sock *msk) } EXPORT_SYMBOL_GPL(mptcp_pm_get_endp_subflow_max); =20 -unsigned int mptcp_pm_get_limit_add_addr_accepted(const struct mptcp_sock = *msk) +u8 mptcp_pm_get_limit_add_addr_accepted(const struct mptcp_sock *msk) { struct pm_nl_pernet *pernet =3D pm_nl_get_pernet_from_msk(msk); =20 @@ -69,7 +69,7 @@ unsigned int mptcp_pm_get_limit_add_addr_accepted(const s= truct mptcp_sock *msk) } EXPORT_SYMBOL_GPL(mptcp_pm_get_limit_add_addr_accepted); =20 -unsigned int mptcp_pm_get_limit_extra_subflows(const struct mptcp_sock *ms= k) +u8 mptcp_pm_get_limit_extra_subflows(const struct mptcp_sock *msk) { struct pm_nl_pernet *pernet =3D pm_nl_get_pernet_from_msk(msk); =20 @@ -185,15 +185,13 @@ fill_remote_addresses_fullmesh(struct mptcp_sock *msk, struct mptcp_addr_info *local, struct mptcp_addr_info *addrs) { + u8 limit_extra_subflows =3D mptcp_pm_get_limit_extra_subflows(msk); bool deny_id0 =3D READ_ONCE(msk->pm.remote_deny_join_id0); DECLARE_BITMAP(unavail_id, MPTCP_PM_MAX_ADDR_ID + 1); struct sock *sk =3D (struct sock *)msk, *ssk; struct mptcp_subflow_context *subflow; - unsigned int limit_extra_subflows; int i =3D 0; =20 - limit_extra_subflows =3D mptcp_pm_get_limit_extra_subflows(msk); - /* Forbid creation of new subflows matching existing ones, possibly * already created by incoming ADD_ADDR */ @@ -272,20 +270,14 @@ __lookup_addr(struct pm_nl_pernet *pernet, const stru= ct mptcp_addr_info *info) =20 static void mptcp_pm_create_subflow_or_signal_addr(struct mptcp_sock *msk) { + u8 limit_extra_subflows =3D mptcp_pm_get_limit_extra_subflows(msk); + struct pm_nl_pernet *pernet =3D pm_nl_get_pernet_from_msk(msk); + u8 endp_subflow_max =3D mptcp_pm_get_endp_subflow_max(msk); + u8 endp_signal_max =3D mptcp_pm_get_endp_signal_max(msk); struct sock *sk =3D (struct sock *)msk; - unsigned int limit_extra_subflows; bool signal_and_subflow =3D false; - unsigned int endp_subflow_max; - unsigned int endp_signal_max; - struct pm_nl_pernet *pernet; struct mptcp_pm_local local; =20 - pernet =3D pm_nl_get_pernet(sock_net(sk)); - - endp_signal_max =3D mptcp_pm_get_endp_signal_max(msk); - endp_subflow_max =3D mptcp_pm_get_endp_subflow_max(msk); - limit_extra_subflows =3D mptcp_pm_get_limit_extra_subflows(msk); - /* do lazy endpoint usage accounting for the MPC subflows */ if (unlikely(!(msk->pm.status & BIT(MPTCP_PM_MPC_ENDPOINT_ACCOUNTED))) &&= msk->first) { struct mptcp_subflow_context *subflow =3D mptcp_subflow_ctx(msk->first); @@ -400,16 +392,15 @@ fill_local_addresses_vec_fullmesh(struct mptcp_sock *= msk, struct mptcp_pm_local *locals, bool c_flag_case) { + u8 limit_extra_subflows =3D mptcp_pm_get_limit_extra_subflows(msk); struct pm_nl_pernet *pernet =3D pm_nl_get_pernet_from_msk(msk); struct sock *sk =3D (struct sock *)msk; struct mptcp_pm_addr_entry *entry; - unsigned int limit_extra_subflows; struct mptcp_addr_info mpc_addr; struct mptcp_pm_local *local; int i =3D 0; =20 mptcp_local_address((struct sock_common *)msk, &mpc_addr); - limit_extra_subflows =3D mptcp_pm_get_limit_extra_subflows(msk); =20 rcu_read_lock(); list_for_each_entry_rcu(entry, &pernet->endp_list, list) { @@ -448,16 +439,15 @@ fill_local_addresses_vec_c_flag(struct mptcp_sock *ms= k, struct mptcp_addr_info *remote, struct mptcp_pm_local *locals) { - unsigned int endp_subflow_max =3D mptcp_pm_get_endp_subflow_max(msk); + u8 limit_extra_subflows =3D mptcp_pm_get_limit_extra_subflows(msk); struct pm_nl_pernet *pernet =3D pm_nl_get_pernet_from_msk(msk); + u8 endp_subflow_max =3D mptcp_pm_get_endp_subflow_max(msk); struct sock *sk =3D (struct sock *)msk; - unsigned int limit_extra_subflows; struct mptcp_addr_info mpc_addr; struct mptcp_pm_local *local; int i =3D 0; =20 mptcp_local_address((struct sock_common *)msk, &mpc_addr); - limit_extra_subflows =3D mptcp_pm_get_limit_extra_subflows(msk); =20 while (msk->pm.local_addr_used < endp_subflow_max) { local =3D &locals[i]; @@ -534,17 +524,14 @@ fill_local_addresses_vec(struct mptcp_sock *msk, stru= ct mptcp_addr_info *remote, =20 static void mptcp_pm_nl_add_addr_received(struct mptcp_sock *msk) { + u8 limit_add_addr_accepted =3D mptcp_pm_get_limit_add_addr_accepted(msk); + u8 limit_extra_subflows =3D mptcp_pm_get_limit_extra_subflows(msk); struct mptcp_pm_local locals[MPTCP_PM_ADDR_MAX]; struct sock *sk =3D (struct sock *)msk; - unsigned int limit_extra_subflows; - unsigned int limit_add_addr_accepted; struct mptcp_addr_info remote; bool sf_created =3D false; int i, nr; =20 - limit_add_addr_accepted =3D mptcp_pm_get_limit_add_addr_accepted(msk); - limit_extra_subflows =3D mptcp_pm_get_limit_extra_subflows(msk); - pr_debug("accepted %d:%d remote family %d\n", msk->pm.add_addr_accepted, limit_add_addr_accepted, msk->pm.remote.family); @@ -586,7 +573,7 @@ static void mptcp_pm_nl_add_addr_received(struct mptcp_= sock *msk) void mptcp_pm_nl_rm_addr(struct mptcp_sock *msk, u8 rm_id) { if (rm_id && WARN_ON_ONCE(msk->pm.add_addr_accepted =3D=3D 0)) { - unsigned int limit_add_addr_accepted =3D + u8 limit_add_addr_accepted =3D mptcp_pm_get_limit_add_addr_accepted(msk); =20 /* Note: if the subflow has been closed before, this @@ -617,8 +604,8 @@ static int mptcp_pm_nl_append_new_local_addr(struct pm_= nl_pernet *pernet, bool needs_id, bool replace) { struct mptcp_pm_addr_entry *cur, *del_entry =3D NULL; - unsigned int addr_max; int ret =3D -EINVAL; + u8 addr_max; =20 spin_lock_bh(&pernet->lock); /* to keep the code simple, don't do IDR-like allocation for address ID, @@ -1064,8 +1051,8 @@ int mptcp_pm_nl_del_addr_doit(struct sk_buff *skb, st= ruct genl_info *info) { struct pm_nl_pernet *pernet =3D genl_info_pm_nl(info); struct mptcp_pm_addr_entry addr, *entry; - unsigned int addr_max; struct nlattr *attr; + u8 addr_max; int ret; =20 if (GENL_REQ_ATTR_CHECK(info, MPTCP_PM_ENDPOINT_ADDR)) diff --git a/net/mptcp/protocol.h b/net/mptcp/protocol.h index a65aedc84ef5db3d8fc489b39d85ca56eb50e30e..027d717ef7cffe150f8de7b3b40= 4916a1899537a 100644 --- a/net/mptcp/protocol.h +++ b/net/mptcp/protocol.h @@ -1177,10 +1177,10 @@ void __init mptcp_pm_userspace_register(void); void __init mptcp_pm_nl_init(void); void mptcp_pm_worker(struct mptcp_sock *msk); void __mptcp_pm_kernel_worker(struct mptcp_sock *msk); -unsigned int mptcp_pm_get_endp_signal_max(const struct mptcp_sock *msk); -unsigned int mptcp_pm_get_endp_subflow_max(const struct mptcp_sock *msk); -unsigned int mptcp_pm_get_limit_add_addr_accepted(const struct mptcp_sock = *msk); -unsigned int mptcp_pm_get_limit_extra_subflows(const struct mptcp_sock *ms= k); +u8 mptcp_pm_get_endp_signal_max(const struct mptcp_sock *msk); +u8 mptcp_pm_get_endp_subflow_max(const struct mptcp_sock *msk); +u8 mptcp_pm_get_limit_add_addr_accepted(const struct mptcp_sock *msk); +u8 mptcp_pm_get_limit_extra_subflows(const struct mptcp_sock *msk); =20 /* called under PM lock */ static inline void __mptcp_pm_close_subflow(struct mptcp_sock *msk) --=20 2.51.0 From nobody Sat Oct 11 06:01:21 2025 Received: from smtp.kernel.org (aws-us-west-2-korg-mail-1.web.codeaurora.org [10.30.226.201]) (using TLSv1.2 with cipher ECDHE-RSA-AES256-GCM-SHA384 (256/256 bits)) (No client certificate requested) by smtp.subspace.kernel.org (Postfix) with ESMTPS id 2EF8622ACEB for ; Tue, 23 Sep 2025 09:33:07 +0000 (UTC) Authentication-Results: smtp.subspace.kernel.org; arc=none smtp.client-ip=10.30.226.201 ARC-Seal: i=1; a=rsa-sha256; d=subspace.kernel.org; s=arc-20240116; t=1758619988; cv=none; b=GTye8GsfPAz6v5c/rt+ygzc9+UpraWd5XZzKs/byA6lpe3JAs0q4wkFZIMbb3s4OMUsqLVM4t4aBg1f+FGQKmKnaXiK7poe19cixqo+gNDMOM/vWqNmpLWvUQXj0jj25F8248mrNCEnvFRZ07XOoK+pKTFDP3BX+Ctwn5zeP81Q= ARC-Message-Signature: i=1; a=rsa-sha256; d=subspace.kernel.org; s=arc-20240116; t=1758619988; c=relaxed/simple; bh=f/LCEkBBEMOjCcqO3y70adeFU6ZBKgAHSJ2N31WHhrs=; h=From:Date:Subject:MIME-Version:Content-Type:Message-Id:References: In-Reply-To:To:Cc; b=TvBbD1EHZzYfXACkRe6scpOJjj4knsK+9ykXwLYRDbRYJ/vd6+Rp37vk2i4Fw+5FhziLUcv/2vhG+i3P6dY1wrxloh4fBv0F7fBQYUfgDrVSp4jetuxjCWt1bfe9YU0S8Af78gv2C2B5ISl+Ro0x6rk7nOdJk0C2eW2gfhYTH5Q= ARC-Authentication-Results: i=1; smtp.subspace.kernel.org; dkim=pass (2048-bit key) header.d=kernel.org header.i=@kernel.org header.b=L20rt+UH; arc=none smtp.client-ip=10.30.226.201 Authentication-Results: smtp.subspace.kernel.org; dkim=pass (2048-bit key) header.d=kernel.org header.i=@kernel.org header.b="L20rt+UH" Received: by smtp.kernel.org (Postfix) with ESMTPSA id 4B44CC4CEF5; Tue, 23 Sep 2025 09:33:07 +0000 (UTC) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/simple; d=kernel.org; s=k20201202; t=1758619987; bh=f/LCEkBBEMOjCcqO3y70adeFU6ZBKgAHSJ2N31WHhrs=; h=From:Date:Subject:References:In-Reply-To:To:Cc:From; b=L20rt+UH+PD3MJtWjQoA9YfzdaKfrTMOyyKj2b6YAciBlUhetKO8GFuuTWxa8dhBb So/5G16OM+xqjjyywsNfyxhpCDTS/Br9BHNsPmT7QrtOMdk0mghAeED2JYvOo6XRSD vrjwyncH+9UeQCufR0wGBQ4vPyzu1tCKdW9QYVH2tYpa9SHD18ch+IJ1QJzBpp2KPa u5Dci23TbHmiQ+gHBHOorUNizc+m/fd2gStAOF1Cym1+n+ATlh1wxbh8XkwUuQfJX4 o8yCqeVRpX7mB7bSr1pQFrl0mVtnkQFS4p/JUgb18M9NHQVT3/LnbHajlIxe9TVopV 66dR7iNIvq4Xg== From: "Matthieu Baerts (NGI0)" Date: Tue, 23 Sep 2025 11:32:49 +0200 Subject: [PATCH mptcp-next v2 3/6] mptcp: pm: in-kernel: compare IDs instead of addresses Precedence: bulk X-Mailing-List: mptcp@lists.linux.dev List-Id: List-Subscribe: List-Unsubscribe: MIME-Version: 1.0 Content-Type: text/plain; charset="utf-8" Content-Transfer-Encoding: quoted-printable Message-Id: <20250923-pm-kern-endp-add_addr-new-v2-3-ee5369dad569@kernel.org> References: <20250923-pm-kern-endp-add_addr-new-v2-0-ee5369dad569@kernel.org> In-Reply-To: <20250923-pm-kern-endp-add_addr-new-v2-0-ee5369dad569@kernel.org> To: MPTCP Upstream Cc: "Matthieu Baerts (NGI0)" X-Mailer: b4 0.14.2 X-Developer-Signature: v=1; a=openpgp-sha256; l=6882; i=matttbe@kernel.org; h=from:subject:message-id; bh=f/LCEkBBEMOjCcqO3y70adeFU6ZBKgAHSJ2N31WHhrs=; b=owGbwMvMwCVWo/Th0Gd3rumMp9WSGDIuZfo073nHdS+nqit726/QKuOQ0IJkHTcX8/vbi7Nau Ca67UntKGVhEONikBVTZJFui8yf+byKt8TLzwJmDisTyBAGLk4BmMisG4wMf+93btwYcGtXzoqZ 6010vr7eoPr26eKNyXm8Ji6/pyiwNDH8FfCQujRf5V9WbPO5zMfHm/cU7jSXfHdKoK6T8UzRkpX efAA= X-Developer-Key: i=matttbe@kernel.org; a=openpgp; fpr=E8CB85F76877057A6E27F77AF6B7824F4269A073 When receiving an ADD_ADDR right after the 3WHS, the connection will switch to 'fully established'. It means the MPTCP worker will be called to treat two events, in this order: ADD_ADDR_RECEIVED, PM_ESTABLISHED. The MPTCP endpoints cannot have the ID 0, because it is reserved to the address and port used by the initial subflow. To be able to deal with this case in different places, msk->mpc_endpoint_id contains the endpoint ID linked to the initial subflow. This variable was only set when treating the first PM_ESTABLISHED event, after ADD_ADDR_RECEIVED. That's why in fill_local_addresses_vec(), the endpoint addresses were compared with the one of the initial subflow, instead of only comparing the IDs. Instead, msk->mpc_endpoint_id is now set when treating ADD_ADDR_RECEIVED as well, if needed, then the IDs can be compared. To be able to do so, the code doing that is now in a dedicated helper, and called from the functions linked to the two actions. While at it, mptcp_endp_get_local_id() has also been moved up, next to this new helper, because they are linked, and to be able to use it in fill_local_addresses_vec() in the next commit. Signed-off-by: Matthieu Baerts (NGI0) Reviewed-by: Mat Martineau --- v2: - rename new helper to mptcp_mpc_endpoint_setup (Mat) - call it from mptcp_pm_nl_add_addr_received instead of fill_vec (Mat) - add comments mentioning the MP_PRIO operation. --- net/mptcp/pm_kernel.c | 82 +++++++++++++++++++++++++++--------------------= ---- 1 file changed, 44 insertions(+), 38 deletions(-) diff --git a/net/mptcp/pm_kernel.c b/net/mptcp/pm_kernel.c index ae6ab3178c226fe3ec66d156bb0dc919075043e5..aaaa684d86239fbfa4e237590fc= 274fa9b7b0347 100644 --- a/net/mptcp/pm_kernel.c +++ b/net/mptcp/pm_kernel.c @@ -268,6 +268,46 @@ __lookup_addr(struct pm_nl_pernet *pernet, const struc= t mptcp_addr_info *info) return NULL; } =20 +static u8 mptcp_endp_get_local_id(struct mptcp_sock *msk, + const struct mptcp_addr_info *addr) +{ + return msk->mpc_endpoint_id =3D=3D addr->id ? 0 : addr->id; +} + +/* Set mpc_endpoint_id, and send MP_PRIO for ID0 if needed */ +static void mptcp_mpc_endpoint_setup(struct mptcp_sock *msk) +{ + struct mptcp_subflow_context *subflow; + struct mptcp_pm_addr_entry *entry; + struct mptcp_addr_info mpc_addr; + struct pm_nl_pernet *pernet; + bool backup =3D false; + + /* do lazy endpoint usage accounting for the MPC subflows */ + if (likely(msk->pm.status & BIT(MPTCP_PM_MPC_ENDPOINT_ACCOUNTED)) || + !msk->first) + return; + + subflow =3D mptcp_subflow_ctx(msk->first); + pernet =3D pm_nl_get_pernet_from_msk(msk); + + mptcp_local_address((struct sock_common *)msk->first, &mpc_addr); + rcu_read_lock(); + entry =3D __lookup_addr(pernet, &mpc_addr); + if (entry) { + __clear_bit(entry->addr.id, msk->pm.id_avail_bitmap); + msk->mpc_endpoint_id =3D entry->addr.id; + backup =3D !!(entry->flags & MPTCP_PM_ADDR_FLAG_BACKUP); + } + rcu_read_unlock(); + + /* Send MP_PRIO */ + if (backup) + mptcp_pm_send_ack(msk, subflow, true, backup); + + msk->pm.status |=3D BIT(MPTCP_PM_MPC_ENDPOINT_ACCOUNTED); +} + static void mptcp_pm_create_subflow_or_signal_addr(struct mptcp_sock *msk) { u8 limit_extra_subflows =3D mptcp_pm_get_limit_extra_subflows(msk); @@ -278,28 +318,7 @@ static void mptcp_pm_create_subflow_or_signal_addr(str= uct mptcp_sock *msk) bool signal_and_subflow =3D false; struct mptcp_pm_local local; =20 - /* do lazy endpoint usage accounting for the MPC subflows */ - if (unlikely(!(msk->pm.status & BIT(MPTCP_PM_MPC_ENDPOINT_ACCOUNTED))) &&= msk->first) { - struct mptcp_subflow_context *subflow =3D mptcp_subflow_ctx(msk->first); - struct mptcp_pm_addr_entry *entry; - struct mptcp_addr_info mpc_addr; - bool backup =3D false; - - mptcp_local_address((struct sock_common *)msk->first, &mpc_addr); - rcu_read_lock(); - entry =3D __lookup_addr(pernet, &mpc_addr); - if (entry) { - __clear_bit(entry->addr.id, msk->pm.id_avail_bitmap); - msk->mpc_endpoint_id =3D entry->addr.id; - backup =3D !!(entry->flags & MPTCP_PM_ADDR_FLAG_BACKUP); - } - rcu_read_unlock(); - - if (backup) - mptcp_pm_send_ack(msk, subflow, true, backup); - - msk->pm.status |=3D BIT(MPTCP_PM_MPC_ENDPOINT_ACCOUNTED); - } + mptcp_mpc_endpoint_setup(msk); =20 pr_debug("local %d:%d signal %d:%d subflows %d:%d\n", msk->pm.local_addr_used, endp_subflow_max, @@ -396,12 +415,9 @@ fill_local_addresses_vec_fullmesh(struct mptcp_sock *m= sk, struct pm_nl_pernet *pernet =3D pm_nl_get_pernet_from_msk(msk); struct sock *sk =3D (struct sock *)msk; struct mptcp_pm_addr_entry *entry; - struct mptcp_addr_info mpc_addr; struct mptcp_pm_local *local; int i =3D 0; =20 - mptcp_local_address((struct sock_common *)msk, &mpc_addr); - rcu_read_lock(); list_for_each_entry_rcu(entry, &pernet->endp_list, list) { if (!(entry->flags & MPTCP_PM_ADDR_FLAG_FULLMESH)) @@ -419,8 +435,7 @@ fill_local_addresses_vec_fullmesh(struct mptcp_sock *ms= k, __clear_bit(local->addr.id, msk->pm.id_avail_bitmap); =20 /* Special case for ID0: set the correct ID */ - if (mptcp_addresses_equal(&local->addr, &mpc_addr, - local->addr.port)) + if (local->addr.id =3D=3D msk->mpc_endpoint_id) local->addr.id =3D 0; =20 msk->pm.extra_subflows++; @@ -443,12 +458,9 @@ fill_local_addresses_vec_c_flag(struct mptcp_sock *msk, struct pm_nl_pernet *pernet =3D pm_nl_get_pernet_from_msk(msk); u8 endp_subflow_max =3D mptcp_pm_get_endp_subflow_max(msk); struct sock *sk =3D (struct sock *)msk; - struct mptcp_addr_info mpc_addr; struct mptcp_pm_local *local; int i =3D 0; =20 - mptcp_local_address((struct sock_common *)msk, &mpc_addr); - while (msk->pm.local_addr_used < endp_subflow_max) { local =3D &locals[i]; =20 @@ -460,8 +472,7 @@ fill_local_addresses_vec_c_flag(struct mptcp_sock *msk, if (!mptcp_pm_addr_families_match(sk, &local->addr, remote)) continue; =20 - if (mptcp_addresses_equal(&local->addr, &mpc_addr, - local->addr.port)) + if (local->addr.id =3D=3D msk->mpc_endpoint_id) continue; =20 msk->pm.local_addr_used++; @@ -539,6 +550,7 @@ static void mptcp_pm_nl_add_addr_received(struct mptcp_= sock *msk) remote =3D msk->pm.remote; mptcp_pm_announce_addr(msk, &remote, true); mptcp_pm_addr_send_ack(msk); + mptcp_mpc_endpoint_setup(msk); =20 if (lookup_subflow_by_daddr(&msk->conn_list, &remote)) return; @@ -927,12 +939,6 @@ int mptcp_pm_nl_add_addr_doit(struct sk_buff *skb, str= uct genl_info *info) return ret; } =20 -static u8 mptcp_endp_get_local_id(struct mptcp_sock *msk, - const struct mptcp_addr_info *addr) -{ - return msk->mpc_endpoint_id =3D=3D addr->id ? 0 : addr->id; -} - static bool mptcp_pm_remove_anno_addr(struct mptcp_sock *msk, const struct mptcp_addr_info *addr, bool force) --=20 2.51.0 From nobody Sat Oct 11 06:01:21 2025 Received: from smtp.kernel.org (aws-us-west-2-korg-mail-1.web.codeaurora.org [10.30.226.201]) (using TLSv1.2 with cipher ECDHE-RSA-AES256-GCM-SHA384 (256/256 bits)) (No client certificate requested) by smtp.subspace.kernel.org (Postfix) with ESMTPS id 0DF8122ACEB for ; Tue, 23 Sep 2025 09:33:08 +0000 (UTC) Authentication-Results: smtp.subspace.kernel.org; arc=none smtp.client-ip=10.30.226.201 ARC-Seal: i=1; a=rsa-sha256; d=subspace.kernel.org; s=arc-20240116; t=1758619989; cv=none; b=PLzhUSFD6vC30ZE482pElDimA60tIDwxpEPRr8RWzeQl2AH6GR37hiYPcrfOOPw9JWV1eySiXde2X80AB3AMwV4FqvdUpLu4/rfT+rsCJTcAb1JAkJSN+7f9/LSyDnFXavRujTW0bdlFGx9G7s6iUBeFBOW24A9468fcm6kHV2s= ARC-Message-Signature: i=1; a=rsa-sha256; d=subspace.kernel.org; s=arc-20240116; t=1758619989; c=relaxed/simple; bh=2/0PjhEFbIJRwQxqp5w/H2uKVwclF8Nq+lpJHWw53ZE=; h=From:Date:Subject:MIME-Version:Content-Type:Message-Id:References: In-Reply-To:To:Cc; b=UVs33v/URgPr151c+N03rJMl2ZdkTViCudnPaUeac+pF6Dm3sd1s4QV2LNkU2x9CNapwsWKZCAwPVxjlD02hAJd6+POxz/7H0HW9yLaZqv1jtbuKbvTpRAeOvrJ2A2v+RsZFrUm8YIL2fB+6iiwtpdNCZJcL41j7728MHi4u2wE= ARC-Authentication-Results: i=1; smtp.subspace.kernel.org; dkim=pass (2048-bit key) header.d=kernel.org header.i=@kernel.org header.b=gd9hV/8X; arc=none smtp.client-ip=10.30.226.201 Authentication-Results: smtp.subspace.kernel.org; dkim=pass (2048-bit key) header.d=kernel.org header.i=@kernel.org header.b="gd9hV/8X" Received: by smtp.kernel.org (Postfix) with ESMTPSA id 2B5CBC116C6; Tue, 23 Sep 2025 09:33:08 +0000 (UTC) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/simple; d=kernel.org; s=k20201202; t=1758619988; bh=2/0PjhEFbIJRwQxqp5w/H2uKVwclF8Nq+lpJHWw53ZE=; h=From:Date:Subject:References:In-Reply-To:To:Cc:From; b=gd9hV/8Xn//5mmo/MVijjPnOXPPmIKwDem78wHRISJ+yvNmevCTSZatQRheIfoiLe 7gJIP9MefkMZhATlqhAuIvAGvtU4aZfqXOQv0V87FmFwS3VJZWiYxGmVWc+CBh5d7e d8M6uyU3TwX85922pet2pD9bB4haE99p0Vv/4sbJ8wchZy7jCRZ1dwY/jOOS7Dzbhx dR1p4VRVocKFbw5xHzQRMcN4oIZ/vPpHFg9ApRB3lrBu5oEH/BwRdm9+FXsYBNXfsO uQRIwvP8s5/jYXDZGhigyaXoVcDcL7F8+Sow9pIrmLn3pmLXZGrNjR1qTvosvxC63Y eStfbKDYrY6Zg== From: "Matthieu Baerts (NGI0)" Date: Tue, 23 Sep 2025 11:32:50 +0200 Subject: [PATCH mptcp-next v2 4/6] Squash to "mptcp: pm: in-kernel: usable client side with C-flag" Precedence: bulk X-Mailing-List: mptcp@lists.linux.dev List-Id: List-Subscribe: List-Unsubscribe: MIME-Version: 1.0 Content-Type: text/plain; charset="utf-8" Content-Transfer-Encoding: quoted-printable Message-Id: <20250923-pm-kern-endp-add_addr-new-v2-4-ee5369dad569@kernel.org> References: <20250923-pm-kern-endp-add_addr-new-v2-0-ee5369dad569@kernel.org> In-Reply-To: <20250923-pm-kern-endp-add_addr-new-v2-0-ee5369dad569@kernel.org> To: MPTCP Upstream Cc: "Matthieu Baerts (NGI0)" X-Mailer: b4 0.14.2 X-Developer-Signature: v=1; a=openpgp-sha256; l=1194; i=matttbe@kernel.org; h=from:subject:message-id; bh=2/0PjhEFbIJRwQxqp5w/H2uKVwclF8Nq+lpJHWw53ZE=; b=owGbwMvMwCVWo/Th0Gd3rumMp9WSGDIuZfrO9Nz7/f4m44v7n229nMLI+NpLp/jTkjTBxbcY9 t/edLpTqqOUhUGMi0FWTJFFui0yf+bzKt4SLz8LmDmsTCBDGLg4BWAiWzoY/grHPLy+Y2XMqf0a OTdji9/bhf/1M3vh+s3Z5OobuS1VVjcZ/mnKP8k1D7JdoOVo92iyxoVLl3aKz7yRbuF1aN3jw4I OcSwA X-Developer-Key: i=matttbe@kernel.org; a=openpgp; fpr=E8CB85F76877057A6E27F77AF6B7824F4269A073 In this special case (fullmesh + subflow + c-flag), local_addr_used should be incremented for new subflows not involving local ID0. Similar to what is done when receiving an ADD_ADR in the non-fullmesh case, or in the subflow only case. Signed-off-by: Matthieu Baerts (NGI0) Reviewed-by: Mat Martineau --- net/mptcp/pm_kernel.c | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/net/mptcp/pm_kernel.c b/net/mptcp/pm_kernel.c index aaaa684d86239fbfa4e237590fc274fa9b7b0347..116d62ed86f78b0242a33a67f77= ff875ba00ae30 100644 --- a/net/mptcp/pm_kernel.c +++ b/net/mptcp/pm_kernel.c @@ -431,9 +431,13 @@ fill_local_addresses_vec_fullmesh(struct mptcp_sock *m= sk, local->flags =3D entry->flags; local->ifindex =3D entry->ifindex; =20 - if (c_flag_case && (entry->flags & MPTCP_PM_ADDR_FLAG_SUBFLOW)) + if (c_flag_case && (entry->flags & MPTCP_PM_ADDR_FLAG_SUBFLOW)) { __clear_bit(local->addr.id, msk->pm.id_avail_bitmap); =20 + if (local->addr.id !=3D msk->mpc_endpoint_id) + msk->pm.local_addr_used++; + } + /* Special case for ID0: set the correct ID */ if (local->addr.id =3D=3D msk->mpc_endpoint_id) local->addr.id =3D 0; --=20 2.51.0 From nobody Sat Oct 11 06:01:21 2025 Received: from smtp.kernel.org (aws-us-west-2-korg-mail-1.web.codeaurora.org [10.30.226.201]) (using TLSv1.2 with cipher ECDHE-RSA-AES256-GCM-SHA384 (256/256 bits)) (No client certificate requested) by smtp.subspace.kernel.org (Postfix) with ESMTPS id F41A530E0D8 for ; Tue, 23 Sep 2025 09:33:09 +0000 (UTC) Authentication-Results: smtp.subspace.kernel.org; arc=none smtp.client-ip=10.30.226.201 ARC-Seal: i=1; a=rsa-sha256; d=subspace.kernel.org; s=arc-20240116; t=1758619990; cv=none; b=JM5cV9gvqv6nSGOr2WlnI00PL+2CDEWXOWt4XNxlWfxO7AlJDAdt9M2SQJsM6EZ4bEFqpjHDJNJAL6tn5KnFx38aQ1LkmtR5d/ikZCLUDsCzdFO5y7p/2CPmtzbFL+sqvqnYuz04LuX/M1QS3NGaSTvDeYT38hc1xie/uKrtoyE= ARC-Message-Signature: i=1; a=rsa-sha256; d=subspace.kernel.org; s=arc-20240116; t=1758619990; c=relaxed/simple; bh=IPTmBXy/Tar6Ks8W5hbH2qvDPsOxMd/ABnDHBa3sIWE=; h=From:Date:Subject:MIME-Version:Content-Type:Message-Id:References: In-Reply-To:To:Cc; b=k3iSJVOimYQIGGRUCT7Bwg84emtjxrptAWtNyq5RskbM1kRH461vz0c/gpzqv969QQtGjR91J6yYXhWxU668aT9r4g/TQxIPi43RwGEw0bYBWAeP8+na01+Qy9iySUWvHzetjnXSw4Y3KLMCSqmj7wAw/W4YPliC1JrXvqMKobg= ARC-Authentication-Results: i=1; smtp.subspace.kernel.org; dkim=pass (2048-bit key) header.d=kernel.org header.i=@kernel.org header.b=EZ2k0d3Q; arc=none smtp.client-ip=10.30.226.201 Authentication-Results: smtp.subspace.kernel.org; dkim=pass (2048-bit key) header.d=kernel.org header.i=@kernel.org header.b="EZ2k0d3Q" Received: by smtp.kernel.org (Postfix) with ESMTPSA id 0B696C4CEF5; Tue, 23 Sep 2025 09:33:08 +0000 (UTC) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/simple; d=kernel.org; s=k20201202; t=1758619989; bh=IPTmBXy/Tar6Ks8W5hbH2qvDPsOxMd/ABnDHBa3sIWE=; h=From:Date:Subject:References:In-Reply-To:To:Cc:From; b=EZ2k0d3QoevEIQRfkTxbXQiFfIMgGRj/TID8Pjhp4KnqDX1qwNnDK6jn53JsLYp4j 4uPOsoDDRmivQPqVSXLAbVSdAVue9WefnXkQSn1uCSoRASRFJVZaOSdxkoi11qLcMX Qjlp5WZhxIKWom6rA1lk3s93Hnz/OedlCU+6mEW16i2gnbvViZgZf/+glVMWAA3+cQ 7/14tY4UJMm9oY3/btUsi/tqvfXEeieZRbae+2j0HUlhJU0w6rKDvzUuQTxEMB2gIU Ivc9r329oxEs7E+9GnwG0WN0z3yYP8SkzQAm+UlY9/R5AoqudDtjthI6nXC5KWkXaJ TQG1JqyjB1cig== From: "Matthieu Baerts (NGI0)" Date: Tue, 23 Sep 2025 11:32:51 +0200 Subject: [PATCH mptcp-next v2 5/6] mptcp: pm: in-kernel: add 'address' endpoints Precedence: bulk X-Mailing-List: mptcp@lists.linux.dev List-Id: List-Subscribe: List-Unsubscribe: MIME-Version: 1.0 Content-Type: text/plain; charset="utf-8" Content-Transfer-Encoding: quoted-printable Message-Id: <20250923-pm-kern-endp-add_addr-new-v2-5-ee5369dad569@kernel.org> References: <20250923-pm-kern-endp-add_addr-new-v2-0-ee5369dad569@kernel.org> In-Reply-To: <20250923-pm-kern-endp-add_addr-new-v2-0-ee5369dad569@kernel.org> To: MPTCP Upstream Cc: "Matthieu Baerts (NGI0)" X-Mailer: b4 0.14.2 X-Developer-Signature: v=1; a=openpgp-sha256; l=9124; i=matttbe@kernel.org; h=from:subject:message-id; bh=IPTmBXy/Tar6Ks8W5hbH2qvDPsOxMd/ABnDHBa3sIWE=; b=owGbwMvMwCVWo/Th0Gd3rumMp9WSGDIuZfox93+YN8erX3XmOlmhA1fm8/v8u5/UtL1+wvPV9 eJPN2wx7ChlYRDjYpAVU2SRbovMn/m8irfEy88CZg4rE8gQBi5OAZgIEzsjw9Qou93vDYtOhoRs Wq/eKdp6fX0199+FnC6XZjPVMNdvi2Fk2OhZn3Hw4D+PtfJCPuv/CVz18A08nzbPU6E29PdBsTZ JfgA= X-Developer-Key: i=matttbe@kernel.org; a=openpgp; fpr=E8CB85F76877057A6E27F77AF6B7824F4269A073 Currently, upon the reception of an ADD_ADDR (and when the fullmesh flag is not used), the in-kernel PM will create new subflows using the local address the routing configuration will pick. It would be easier to pick local addresses from a selected list of endpoints, and use it only once, than relying on routing rules. Use case: both the client (C) and the server (S) have two addresses (a and b). The client establishes the connection between C(a) and S(a). Once established, the server announces its additional address S(b). Once received, the client connects to it using its second address C(b). Compared to a situation without the 'address' endpoint for C(b), the client didn't use this address C(b) to establish a subflow to the server's primary address S(a). So at the end, we have: C S C(a) --- S(a) C(b) --- S(b) In case of a 3rd address on each side (C(c) and S(c)), upon the reception of an ADD_ADDR with S(c), the client should not pick C(b) because it has already been used. C(c) should then be used. Note that this situation is currently possible if C doesn't add any endpoint, but configure the routing in order to pick C(b) for the route to S(b), and pick C(c) for the route to S(c). That doesn't sound very practical because it means knowing in advance the IP addresses that will be used and announced by the server. In the code, the new endpoint type is added. Similar to the other subflow types, an MPTCP_INFO counter is added. While at it, hole are now commented in struct mptcp_info, to remember next time that these holes can no longer be used. Closes: https://github.com/multipath-tcp/mptcp_net-next/issues/503 Signed-off-by: Matthieu Baerts (NGI0) Reviewed-by: Mat Martineau --- v2: - rename var and function names to state 1 address will be filled (Mat) --- include/uapi/linux/mptcp.h | 6 +++- net/mptcp/pm_kernel.c | 82 ++++++++++++++++++++++++++++++++++++++++++= ++++ net/mptcp/protocol.h | 1 + net/mptcp/sockopt.c | 2 ++ 4 files changed, 90 insertions(+), 1 deletion(-) diff --git a/include/uapi/linux/mptcp.h b/include/uapi/linux/mptcp.h index 5ec996977b3fa2351222e6d01b814770b34348e9..65dc069e9063325ad2e1ffb1da2= 1cc4a4b6efd32 100644 --- a/include/uapi/linux/mptcp.h +++ b/include/uapi/linux/mptcp.h @@ -39,6 +39,7 @@ #define MPTCP_PM_ADDR_FLAG_BACKUP _BITUL(2) #define MPTCP_PM_ADDR_FLAG_FULLMESH _BITUL(3) #define MPTCP_PM_ADDR_FLAG_IMPLICIT _BITUL(4) +#define MPTCP_PM_ADDR_FLAG_ADDRESS _BITUL(5) =20 struct mptcp_info { __u8 mptcpi_subflows; @@ -51,6 +52,7 @@ struct mptcp_info { #define mptcpi_endp_signal_max mptcpi_add_addr_signal_max __u8 mptcpi_add_addr_accepted_max; #define mptcpi_limit_add_addr_accepted mptcpi_add_addr_accepted_max + /* 16-bit hole that can no longer be filled */ __u32 mptcpi_flags; __u32 mptcpi_token; __u64 mptcpi_write_seq; @@ -60,13 +62,15 @@ struct mptcp_info { __u8 mptcpi_local_addr_max; #define mptcpi_endp_subflow_max mptcpi_local_addr_max __u8 mptcpi_csum_enabled; + /* 8-bit hole that can no longer be filled */ __u32 mptcpi_retransmits; __u64 mptcpi_bytes_retrans; __u64 mptcpi_bytes_sent; __u64 mptcpi_bytes_received; __u64 mptcpi_bytes_acked; __u8 mptcpi_subflows_total; - __u8 reserved[3]; + __u8 mptcpi_endp_address_max; + __u8 reserved[2]; __u32 mptcpi_last_data_sent; __u32 mptcpi_last_data_recv; __u32 mptcpi_last_ack_recv; diff --git a/net/mptcp/pm_kernel.c b/net/mptcp/pm_kernel.c index 116d62ed86f78b0242a33a67f77ff875ba00ae30..13c575e477833303c8f030e37a2= 809ece3c30ab4 100644 --- a/net/mptcp/pm_kernel.c +++ b/net/mptcp/pm_kernel.c @@ -21,6 +21,7 @@ struct pm_nl_pernet { u8 endpoints; u8 endp_signal_max; u8 endp_subflow_max; + u8 endp_address_max; u8 limit_add_addr_accepted; u8 limit_extra_subflows; u8 next_id; @@ -61,6 +62,14 @@ u8 mptcp_pm_get_endp_subflow_max(const struct mptcp_sock= *msk) } EXPORT_SYMBOL_GPL(mptcp_pm_get_endp_subflow_max); =20 +u8 mptcp_pm_get_endp_address_max(const struct mptcp_sock *msk) +{ + struct pm_nl_pernet *pernet =3D pm_nl_get_pernet_from_msk(msk); + + return READ_ONCE(pernet->endp_address_max); +} +EXPORT_SYMBOL_GPL(mptcp_pm_get_endp_address_max); + u8 mptcp_pm_get_limit_add_addr_accepted(const struct mptcp_sock *msk) { struct pm_nl_pernet *pernet =3D pm_nl_get_pernet_from_msk(msk); @@ -453,6 +462,66 @@ fill_local_addresses_vec_fullmesh(struct mptcp_sock *m= sk, return i; } =20 +static unsigned int +fill_local_address_endp(struct mptcp_sock *msk, struct mptcp_addr_info *re= mote, + struct mptcp_pm_local *locals) +{ + struct pm_nl_pernet *pernet =3D pm_nl_get_pernet_from_msk(msk); + DECLARE_BITMAP(unavail_id, MPTCP_PM_MAX_ADDR_ID + 1); + struct mptcp_subflow_context *subflow; + struct sock *sk =3D (struct sock *)msk; + struct mptcp_pm_addr_entry *entry; + struct mptcp_pm_local *local; + int found =3D 0; + + /* Forbid creation of new subflows matching existing ones, possibly + * already created by 'subflow' endpoints + */ + bitmap_zero(unavail_id, MPTCP_PM_MAX_ADDR_ID + 1); + mptcp_for_each_subflow(msk, subflow) { + struct sock *ssk =3D mptcp_subflow_tcp_sock(subflow); + + if ((1 << inet_sk_state_load(ssk)) & + (TCPF_FIN_WAIT1 | TCPF_FIN_WAIT2 | TCPF_CLOSING | + TCPF_CLOSE)) + continue; + + __set_bit(READ_ONCE(subflow->local_id), unavail_id); + } + + rcu_read_lock(); + list_for_each_entry_rcu(entry, &pernet->endp_list, list) { + if (!(entry->flags & MPTCP_PM_ADDR_FLAG_ADDRESS)) + continue; + + if (!mptcp_pm_addr_families_match(sk, &entry->addr, remote)) + continue; + + if (test_bit(mptcp_endp_get_local_id(msk, &entry->addr), + unavail_id)) + continue; + + local =3D &locals[0]; + local->addr =3D entry->addr; + local->flags =3D entry->flags; + local->ifindex =3D entry->ifindex; + + if (entry->flags & MPTCP_PM_ADDR_FLAG_SUBFLOW) { + __clear_bit(local->addr.id, msk->pm.id_avail_bitmap); + + if (local->addr.id !=3D msk->mpc_endpoint_id) + msk->pm.local_addr_used++; + } + + msk->pm.extra_subflows++; + found =3D 1; + break; + } + rcu_read_unlock(); + + return found; +} + static unsigned int fill_local_addresses_vec_c_flag(struct mptcp_sock *msk, struct mptcp_addr_info *remote, @@ -527,6 +596,10 @@ fill_local_addresses_vec(struct mptcp_sock *msk, struc= t mptcp_addr_info *remote, if (i) return i; =20 + /* If there is at least one MPTCP endpoint with an address flag */ + if (mptcp_pm_get_endp_address_max(msk)) + return fill_local_address_endp(msk, remote, locals); + /* Special case: peer sets the C flag, accept one ADD_ADDR if default * limits are used -- accepting no ADD_ADDR -- and use subflow endpoints */ @@ -702,6 +775,10 @@ static int mptcp_pm_nl_append_new_local_addr(struct pm= _nl_pernet *pernet, addr_max =3D pernet->endp_subflow_max; WRITE_ONCE(pernet->endp_subflow_max, addr_max + 1); } + if (entry->flags & MPTCP_PM_ADDR_FLAG_ADDRESS) { + addr_max =3D pernet->endp_address_max; + WRITE_ONCE(pernet->endp_address_max, addr_max + 1); + } =20 pernet->endpoints++; if (!entry->addr.port) @@ -1096,6 +1173,10 @@ int mptcp_pm_nl_del_addr_doit(struct sk_buff *skb, s= truct genl_info *info) addr_max =3D pernet->endp_subflow_max; WRITE_ONCE(pernet->endp_subflow_max, addr_max - 1); } + if (entry->flags & MPTCP_PM_ADDR_FLAG_ADDRESS) { + addr_max =3D pernet->endp_address_max; + WRITE_ONCE(pernet->endp_address_max, addr_max - 1); + } =20 pernet->endpoints--; list_del_rcu(&entry->list); @@ -1178,6 +1259,7 @@ static void __reset_counters(struct pm_nl_pernet *per= net) { WRITE_ONCE(pernet->endp_signal_max, 0); WRITE_ONCE(pernet->endp_subflow_max, 0); + WRITE_ONCE(pernet->endp_address_max, 0); pernet->endpoints =3D 0; } =20 diff --git a/net/mptcp/protocol.h b/net/mptcp/protocol.h index 027d717ef7cffe150f8de7b3b404916a1899537a..57e4db26e0ae1c5e82bc5a262cc= b9d5e36508543 100644 --- a/net/mptcp/protocol.h +++ b/net/mptcp/protocol.h @@ -1179,6 +1179,7 @@ void mptcp_pm_worker(struct mptcp_sock *msk); void __mptcp_pm_kernel_worker(struct mptcp_sock *msk); u8 mptcp_pm_get_endp_signal_max(const struct mptcp_sock *msk); u8 mptcp_pm_get_endp_subflow_max(const struct mptcp_sock *msk); +u8 mptcp_pm_get_endp_address_max(const struct mptcp_sock *msk); u8 mptcp_pm_get_limit_add_addr_accepted(const struct mptcp_sock *msk); u8 mptcp_pm_get_limit_extra_subflows(const struct mptcp_sock *msk); =20 diff --git a/net/mptcp/sockopt.c b/net/mptcp/sockopt.c index 92a2a274262732a345b9ab185efd7da1f0a5773a..3cdc35323cc18de3585169fe729= a51cab25a4cba 100644 --- a/net/mptcp/sockopt.c +++ b/net/mptcp/sockopt.c @@ -980,6 +980,8 @@ void mptcp_diag_fill_info(struct mptcp_sock *msk, struc= t mptcp_info *info) mptcp_pm_get_limit_add_addr_accepted(msk); info->mptcpi_endp_subflow_max =3D mptcp_pm_get_endp_subflow_max(msk); + info->mptcpi_endp_address_max =3D + mptcp_pm_get_endp_address_max(msk); } =20 if (__mptcp_check_fallback(msk)) --=20 2.51.0 From nobody Sat Oct 11 06:01:21 2025 Received: from smtp.kernel.org (aws-us-west-2-korg-mail-1.web.codeaurora.org [10.30.226.201]) (using TLSv1.2 with cipher ECDHE-RSA-AES256-GCM-SHA384 (256/256 bits)) (No client certificate requested) by smtp.subspace.kernel.org (Postfix) with ESMTPS id 7928E2F3C23 for ; Tue, 23 Sep 2025 09:33:10 +0000 (UTC) Authentication-Results: smtp.subspace.kernel.org; arc=none smtp.client-ip=10.30.226.201 ARC-Seal: i=1; a=rsa-sha256; d=subspace.kernel.org; s=arc-20240116; t=1758619990; cv=none; b=qJB6BRFgcB2GOsZPRZm9CamkvAJScOdVJKIycFjPmln4lisd1OGGgljW6U1dIcbQb0zG5wudb+HTgvUZH8gKpTATrlK6yXJxdut9/6Z30LnkmZzK2dNGBkmL/87/uEDcmprSDJr5Pyo4nTEIrH8WMY0QEHBq6m14G0+1khxz6Ao= ARC-Message-Signature: i=1; a=rsa-sha256; d=subspace.kernel.org; s=arc-20240116; t=1758619990; c=relaxed/simple; bh=BZGVScledBPyxgT9ajdqZAv+wSsrJH7qGc+H2E0ax8A=; h=From:Date:Subject:MIME-Version:Content-Type:Message-Id:References: In-Reply-To:To:Cc; b=Qn3n9vLTk7Go2rSXsW36+6w/w5rEizSBJQGbpC1692g+Kery2gNVogEdhSd/uUWZ3ZLq7dJsYYDK+xSNtxKJD6foT3i3r0dFQSvNN7ZvuDg0dOF2n6KZ61yQ0SxxJ1GLIrAO/fBfRjahJ9SvLZ6CM79XznieiQViLdl8s575XP8= ARC-Authentication-Results: i=1; smtp.subspace.kernel.org; dkim=pass (2048-bit key) header.d=kernel.org header.i=@kernel.org header.b=YIGNEAr7; arc=none smtp.client-ip=10.30.226.201 Authentication-Results: smtp.subspace.kernel.org; dkim=pass (2048-bit key) header.d=kernel.org header.i=@kernel.org header.b="YIGNEAr7" Received: by smtp.kernel.org (Postfix) with ESMTPSA id DF5F5C4CEF7; Tue, 23 Sep 2025 09:33:09 +0000 (UTC) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/simple; d=kernel.org; s=k20201202; t=1758619990; bh=BZGVScledBPyxgT9ajdqZAv+wSsrJH7qGc+H2E0ax8A=; h=From:Date:Subject:References:In-Reply-To:To:Cc:From; b=YIGNEAr71LuTuYlKuvHFjE67lD4BaOU2aT5LqHe6pVAuKpPOpwLZhOTfrkWHzoFx7 itHvZPQVFzBQmIKFxjX0YJLtjgJsnzTsRd4HzGh3oEO4Wk9gSGjgB1NxqLg0JznXt8 Kc0mA+HBDoDnw+yEAqJtEIqYdLA/E3g+yf83faExOZrhtA58VAd6M6L5+QgQtTuAsx rchuzvlQHj/LqLKzu2J2k2X1KlY+8lfRVNtnXUdmoSGHd0kkvFcENszc2H1+UbPJwE gP2gFrWrFpzz31VEza4YKVzDdhIDh5QWeN3Zc4P0fomxxLz1PDxbYENAceu3uncv5x cLg5L9qCiMpvg== From: "Matthieu Baerts (NGI0)" Date: Tue, 23 Sep 2025 11:32:52 +0200 Subject: [PATCH mptcp-next v2 6/6] selftests: mptcp: join: validate new 'address' endpoints Precedence: bulk X-Mailing-List: mptcp@lists.linux.dev List-Id: List-Subscribe: List-Unsubscribe: MIME-Version: 1.0 Content-Type: text/plain; charset="utf-8" Content-Transfer-Encoding: quoted-printable Message-Id: <20250923-pm-kern-endp-add_addr-new-v2-6-ee5369dad569@kernel.org> References: <20250923-pm-kern-endp-add_addr-new-v2-0-ee5369dad569@kernel.org> In-Reply-To: <20250923-pm-kern-endp-add_addr-new-v2-0-ee5369dad569@kernel.org> To: MPTCP Upstream Cc: "Matthieu Baerts (NGI0)" X-Mailer: b4 0.14.2 X-Developer-Signature: v=1; a=openpgp-sha256; l=4594; i=matttbe@kernel.org; h=from:subject:message-id; bh=BZGVScledBPyxgT9ajdqZAv+wSsrJH7qGc+H2E0ax8A=; b=owGbwMvMwCVWo/Th0Gd3rumMp9WSGDIuZfq36ctIiM7gOm87LcE+qORNB3PUmzedrEdKD3erX zOZumF9RykLgxgXg6yYIot0W2T+zOdVvCVefhYwc1iZQIYwcHEKwESygxkZ5j36aZDsVSbH9XzK yuWJRaWJ17aaJEfWbpL3jJc8rDjLmOGfoo+P/o4Ytq9X6z5UpgtE2UWd3mRT8dDePs/wo1zf3RI GAA== X-Developer-Key: i=matttbe@kernel.org; a=openpgp; fpr=E8CB85F76877057A6E27F77AF6B7824F4269A073 Here are a few sub-tests for mptcp_join.sh, validating the new 'address' endpoint type. In a setup where subflows created using the routing rules would be rejected by the listener, and where the latter announces one IP address, some cases are verified: - Without any 'address' endpoints: no new subflows are created. - With one 'address' endpoints: a second subflow is created. - With multiple 'address' endpoints: 2 IPv4 subflows are created. - With one 'address' endpoints, but the server announcing a second IP address, only one subflow is created. Signed-off-by: Matthieu Baerts (NGI0) Reviewed-by: Mat Martineau --- tools/testing/selftests/net/mptcp/mptcp_join.sh | 56 +++++++++++++++++++++= ++++ tools/testing/selftests/net/mptcp/pm_nl_ctl.c | 9 ++++ 2 files changed, 65 insertions(+) diff --git a/tools/testing/selftests/net/mptcp/mptcp_join.sh b/tools/testin= g/selftests/net/mptcp/mptcp_join.sh index a94b3960ad5e009dbead66b6ff2aa01f70aa3e1f..b0d935e3c8381ea34e74c3878e8= 69610b1a6fa41 100755 --- a/tools/testing/selftests/net/mptcp/mptcp_join.sh +++ b/tools/testing/selftests/net/mptcp/mptcp_join.sh @@ -2320,6 +2320,61 @@ signal_address_tests() fi } =20 +address_endp_tests() +{ + # no address endpoints: routing rules are used + if reset_with_tcp_filter "without address endpoint" ns1 10.0.2.2 REJECT && + mptcp_lib_kallsyms_has "mptcp_pm_get_endp_address_max$"; then + pm_nl_set_limits $ns1 0 2 + pm_nl_set_limits $ns2 2 2 + pm_nl_add_endpoint $ns1 10.0.2.1 flags signal + run_tests $ns1 $ns2 10.0.1.1 + join_syn_tx=3D1 \ + chk_join_nr 0 0 0 + chk_add_nr 1 1 + fi + + # address endpoints: this endpoint is used + if reset_with_tcp_filter "with address endpoint" ns1 10.0.2.2 REJECT && + mptcp_lib_kallsyms_has "mptcp_pm_get_endp_address_max$"; then + pm_nl_set_limits $ns1 0 2 + pm_nl_set_limits $ns2 2 2 + pm_nl_add_endpoint $ns1 10.0.2.1 flags signal + pm_nl_add_endpoint $ns2 10.0.3.2 flags address + run_tests $ns1 $ns2 10.0.1.1 + chk_join_nr 1 1 1 + chk_add_nr 1 1 + fi + + # address endpoints: these endpoints are used + if reset_with_tcp_filter "with multiple address endpoints" ns1 10.0.2.2 R= EJECT && + mptcp_lib_kallsyms_has "mptcp_pm_get_endp_address_max$"; then + pm_nl_set_limits $ns1 0 2 + pm_nl_set_limits $ns2 2 2 + pm_nl_add_endpoint $ns1 10.0.2.1 flags signal + pm_nl_add_endpoint $ns1 10.0.3.1 flags signal + pm_nl_add_endpoint $ns2 dead:beef:3::2 flags address + pm_nl_add_endpoint $ns2 10.0.3.2 flags address + pm_nl_add_endpoint $ns2 10.0.4.2 flags address + run_tests $ns1 $ns2 10.0.1.1 + chk_join_nr 2 2 2 + chk_add_nr 2 2 + fi + + # address endpoints: only one endpoint is used + if reset_with_tcp_filter "single address endpoints" ns1 10.0.2.2 REJECT && + mptcp_lib_kallsyms_has "mptcp_pm_get_endp_address_max$"; then + pm_nl_set_limits $ns1 0 2 + pm_nl_set_limits $ns2 2 2 + pm_nl_add_endpoint $ns1 10.0.2.1 flags signal + pm_nl_add_endpoint $ns1 10.0.3.1 flags signal + pm_nl_add_endpoint $ns2 10.0.3.2 flags address + run_tests $ns1 $ns2 10.0.1.1 + chk_join_nr 1 1 1 + chk_add_nr 2 2 + fi +} + link_failure_tests() { # accept and use add_addr with additional subflows and link loss @@ -4109,6 +4164,7 @@ all_tests_sorted=3D( f@subflows_tests e@subflows_error_tests s@signal_address_tests + A@address_endp_tests l@link_failure_tests t@add_addr_timeout_tests r@remove_tests diff --git a/tools/testing/selftests/net/mptcp/pm_nl_ctl.c b/tools/testing/= selftests/net/mptcp/pm_nl_ctl.c index d4981b76693bbddca74169437a540ad6294cf1d5..9164c2e797bd003d933d274a547= 91b23928748f6 100644 --- a/tools/testing/selftests/net/mptcp/pm_nl_ctl.c +++ b/tools/testing/selftests/net/mptcp/pm_nl_ctl.c @@ -830,6 +830,8 @@ int add_addr(int fd, int pm_family, int argc, char *arg= v[]) flags |=3D MPTCP_PM_ADDR_FLAG_SUBFLOW; else if (!strcmp(tok, "signal")) flags |=3D MPTCP_PM_ADDR_FLAG_SIGNAL; + else if (!strcmp(tok, "address")) + flags |=3D MPTCP_PM_ADDR_FLAG_ADDRESS; else if (!strcmp(tok, "backup")) flags |=3D MPTCP_PM_ADDR_FLAG_BACKUP; else if (!strcmp(tok, "fullmesh")) @@ -1018,6 +1020,13 @@ static void print_addr(struct rtattr *attrs, int len) printf(","); } =20 + if (flags & MPTCP_PM_ADDR_FLAG_ADDRESS) { + printf("address"); + flags &=3D ~MPTCP_PM_ADDR_FLAG_ADDRESS; + if (flags) + printf(","); + } + if (flags & MPTCP_PM_ADDR_FLAG_BACKUP) { printf("backup"); flags &=3D ~MPTCP_PM_ADDR_FLAG_BACKUP; --=20 2.51.0