From nobody Mon Feb 9 09:32:36 2026 Delivered-To: wpasupplicant.patchew@gmail.com Received: by 2002:a05:6638:2248:0:0:0:0 with SMTP id m8csp375861jas; Thu, 27 Jan 2022 16:38:59 -0800 (PST) X-Google-Smtp-Source: ABdhPJwuRQCZ9qFYBCGusEAA1FT9jCaaqwJR31p5ih+rfhyZtPeQINDSi+aHEhTy+ex9OKusnkQ7 X-Received: by 2002:a63:82c1:: with SMTP id w184mr4651593pgd.272.1643330339010; Thu, 27 Jan 2022 16:38:59 -0800 (PST) ARC-Seal: i=1; a=rsa-sha256; t=1643330339; cv=none; d=google.com; s=arc-20160816; b=PRYKwmf4XZnPPnJWn3osNJFsfrV/eH0qmFWkXHUyz1uRKugb6ZT7pcj1ZVRug5BHRH ysNn8QSoZ5g5AtTw+axVUDPDm8K0ABe2tOyv/KlaRA/5Nj+RZFsRmhPX4QUQcCmEGsGE UCUiRp8o0H/5DkZQHaUt4IQy4Wc8MUADWCMoaUIZaG5eaUqvuHdebYkmEgN/XhpBmoma MBd15gjSPBqKdc33zy1VDBkX/jKs+dUFCbs8iVFSmkKSzdVn/CSKvhPwFFLldsgrXihg BaNO0L8cJo4pGIXXwcWbHrctzL56eEP7CgHwaMoZc771m0eei/4RZd99qk4O7TxJgbst vltA== ARC-Message-Signature: i=1; a=rsa-sha256; c=relaxed/relaxed; d=google.com; s=arc-20160816; h=content-transfer-encoding:mime-version:list-unsubscribe :list-subscribe:list-id:precedence:references:in-reply-to:message-id :date:subject:to:from:dkim-signature; bh=8oZgi0wLDlzZYWFYfUjNvwV+PMoN8/jQ92MFvmhz6g4=; b=UpzChk+4wgkV2l9eiZW7vblegiaQ3a0m7JOpdR2TrVkUP4CzXg1Ra3wi3jo+St4qfk Sh+1Abbt1u7Ong/z1JhT3d5Q5LipDNBqx67c4qHkDjCiX4m1DgqbXRXP88s708RNfuPK rD77F+xVFVp8LEkCfDtuIPLRFx2Ytqm5FlRhjhg6t65uLABA2cZJQWGmXhNH24W1eXnv 3g2gKMxKoCDLU8CUSmzICfn93TBhuzmpJ0IzubQX1RnULA4QnIKsOItsbRnRQhGiKOBP PvMhzxDtUKS4PTpXgN/7MIUer4Whgh1JX2dNeofwgEaGYVmopO2Dv5zX+H7i5YsF3pMH Mz3w== ARC-Authentication-Results: i=1; mx.google.com; dkim=pass header.i=@intel.com header.s=Intel header.b=FXXFlmuE; spf=pass (google.com: domain of mptcp+bounces-3347-wpasupplicant.patchew=gmail.com@lists.linux.dev designates 147.75.197.195 as permitted sender) smtp.mailfrom="mptcp+bounces-3347-wpasupplicant.patchew=gmail.com@lists.linux.dev"; dmarc=pass (p=NONE sp=NONE dis=NONE) header.from=intel.com Return-Path: Received: from ewr.edge.kernel.org (ewr.edge.kernel.org. [147.75.197.195]) by mx.google.com with ESMTPS id p13si3636741plo.272.2022.01.27.16.38.58 for (version=TLS1_2 cipher=ECDHE-ECDSA-AES128-GCM-SHA256 bits=128/128); Thu, 27 Jan 2022 16:38:58 -0800 (PST) Received-SPF: pass (google.com: domain of mptcp+bounces-3347-wpasupplicant.patchew=gmail.com@lists.linux.dev designates 147.75.197.195 as permitted sender) client-ip=147.75.197.195; Authentication-Results: mx.google.com; dkim=pass header.i=@intel.com header.s=Intel header.b=FXXFlmuE; spf=pass (google.com: domain of mptcp+bounces-3347-wpasupplicant.patchew=gmail.com@lists.linux.dev designates 147.75.197.195 as permitted sender) smtp.mailfrom="mptcp+bounces-3347-wpasupplicant.patchew=gmail.com@lists.linux.dev"; dmarc=pass (p=NONE sp=NONE dis=NONE) header.from=intel.com Received: from smtp.subspace.kernel.org (wormhole.subspace.kernel.org [52.25.139.140]) (using TLSv1.2 with cipher ECDHE-RSA-AES256-GCM-SHA384 (256/256 bits)) (No client certificate requested) by ewr.edge.kernel.org (Postfix) with ESMTPS id 348991C0F42 for ; Fri, 28 Jan 2022 00:38:57 +0000 (UTC) Received: from localhost.localdomain (localhost.localdomain [127.0.0.1]) by smtp.subspace.kernel.org (Postfix) with ESMTP id 475FD3FC7; Fri, 28 Jan 2022 00:38:48 +0000 (UTC) X-Original-To: mptcp@lists.linux.dev Received: from mga05.intel.com (mga05.intel.com [192.55.52.43]) (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 B24D72CAA for ; Fri, 28 Jan 2022 00:38:46 +0000 (UTC) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/simple; d=intel.com; i=@intel.com; q=dns/txt; s=Intel; t=1643330326; x=1674866326; h=from:to:subject:date:message-id:in-reply-to:references: mime-version:content-transfer-encoding; bh=sZGkn2tE9zaUpJvQ/5gUaYWEglRQGcKa2DMg+7i0Kis=; b=FXXFlmuENlAEoapoG5ImiEAXHSB6yFmivIGbKpTKZiMAUuqk9lqCH4+e xA1D7E+4stxoXdhK+66n4x/U+qFqKTQuodpcCNVHlblsBUSloYKXNmHZB 1UO/aNXrmGCU7yWV/RlLnYPZuuqFmaW2XYbHUbPt4YF+325SkgDCpy8yY 4LPr7iVUtaSgMTRZgSWzqZGNEtAkfWPiWn6xQhWLTsG/3pjfVCLeRrz0L WyHfQK3r2edsRVO90Iw1iz6/ttY+0or9DqcD3ZES4VXDXjHTqyMUQlebX 0DoCWrpMabh/MazU5wyH32k6lg8B8tkISLVIcNMb8CEltxYRKsZjsBZoU g==; X-IronPort-AV: E=McAfee;i="6200,9189,10239"; a="333358334" X-IronPort-AV: E=Sophos;i="5.88,322,1635231600"; d="scan'208";a="333358334" Received: from orsmga006.jf.intel.com ([10.7.209.51]) by fmsmga105.fm.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384; 27 Jan 2022 16:38:42 -0800 X-IronPort-AV: E=Sophos;i="5.88,322,1635231600"; d="scan'208";a="480527119" Received: from otc-tsn-4.jf.intel.com ([10.23.153.135]) by orsmga006-auth.jf.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384; 27 Jan 2022 16:38:41 -0800 From: Kishen Maloor To: kishen.maloor@intel.com, mptcp@lists.linux.dev Subject: [PATCH mptcp-next v3 06/14] mptcp: netlink: Add MPTCP_PM_CMD_ANNOUNCE Date: Thu, 27 Jan 2022 19:38:28 -0500 Message-Id: <20220128003836.2732694-7-kishen.maloor@intel.com> X-Mailer: git-send-email 2.31.1 In-Reply-To: <20220128003836.2732694-1-kishen.maloor@intel.com> References: <20220128003836.2732694-1-kishen.maloor@intel.com> Precedence: bulk X-Mailing-List: mptcp@lists.linux.dev List-Id: List-Subscribe: List-Unsubscribe: MIME-Version: 1.0 Content-Transfer-Encoding: quoted-printable Content-Type: text/plain; charset="utf-8" This change adds a MPTCP netlink interface for issuing ADD_ADDR advertisements over the chosen MPTCP connection from a userspace path manager. The command requires the following parameters: { token, { loc_id, family, daddr4 | daddr6 [, dport] } [, if_idx], flags[signal|skiplsk] }. Signed-off-by: Kishen Maloor --- v3: use MPTCP_PM_ADDR_FLAG_NO_LISTEN to skip creating a listening socket in the kernel for an announced address, use the new helper lsk_list_find_or_create() --- include/uapi/linux/mptcp.h | 2 + net/mptcp/pm_netlink.c | 101 +++++++++++++++++++++++++++++++++++++ 2 files changed, 103 insertions(+) diff --git a/include/uapi/linux/mptcp.h b/include/uapi/linux/mptcp.h index 0df44a116a31..088bdfbf442c 100644 --- a/include/uapi/linux/mptcp.h +++ b/include/uapi/linux/mptcp.h @@ -55,6 +55,7 @@ enum { MPTCP_PM_ATTR_ADDR, /* nested address */ MPTCP_PM_ATTR_RCV_ADD_ADDRS, /* u32 */ MPTCP_PM_ATTR_SUBFLOWS, /* u32 */ + MPTCP_PM_ATTR_TOKEN, /* u32 */ =20 __MPTCP_PM_ATTR_MAX }; @@ -93,6 +94,7 @@ enum { MPTCP_PM_CMD_SET_LIMITS, MPTCP_PM_CMD_GET_LIMITS, MPTCP_PM_CMD_SET_FLAGS, + MPTCP_PM_CMD_ANNOUNCE, =20 __MPTCP_PM_CMD_AFTER_LAST }; diff --git a/net/mptcp/pm_netlink.c b/net/mptcp/pm_netlink.c index 829e20a6d0dd..e880177742d3 100644 --- a/net/mptcp/pm_netlink.c +++ b/net/mptcp/pm_netlink.c @@ -1312,6 +1312,7 @@ static const struct nla_policy mptcp_pm_policy[MPTCP_= PM_ATTR_MAX + 1] =3D { NLA_POLICY_NESTED(mptcp_pm_addr_policy), [MPTCP_PM_ATTR_RCV_ADD_ADDRS] =3D { .type =3D NLA_U32, }, [MPTCP_PM_ATTR_SUBFLOWS] =3D { .type =3D NLA_U32, }, + [MPTCP_PM_ATTR_TOKEN] =3D { .type =3D NLA_U32, }, }; =20 void mptcp_pm_nl_subflow_chk_stale(const struct mptcp_sock *msk, struct so= ck *ssk) @@ -2072,6 +2073,101 @@ static int mptcp_nl_set_flags(struct net *net, return ret; } =20 +static int mptcp_nl_cmd_announce(struct sk_buff *skb, struct genl_info *in= fo) +{ + struct nlattr *token =3D info->attrs[MPTCP_PM_ATTR_TOKEN]; + struct nlattr *addr =3D info->attrs[MPTCP_PM_ATTR_ADDR]; + struct pm_nl_pernet *pernet =3D genl_info_pm_nl(info); + struct mptcp_local_lsk *lsk_ref =3D NULL; + struct mptcp_pm_addr_entry addr_val; + bool reuse_port =3D false; + struct mptcp_sock *msk; + u32 token_val; + int err; + + if (!addr || !token) { + GENL_SET_ERR_MSG(info, "missing required inputs"); + return -EINVAL; + } + + token_val =3D nla_get_u32(token); + + msk =3D mptcp_token_get_sock(sock_net(skb->sk), token_val); + if (!msk) { + NL_SET_ERR_MSG_ATTR(info->extack, token, "invalid token"); + return -EINVAL; + } + + if (READ_ONCE(msk->pm.pm_type) !=3D MPTCP_PM_TYPE_USERSPACE) { + GENL_SET_ERR_MSG(info, "invalid request; userspace PM not selected"); + return -EINVAL; + } + + err =3D mptcp_pm_parse_entry(addr, info, true, &addr_val); + if (err < 0) { + GENL_SET_ERR_MSG(info, "error parsing local address"); + return err; + } + + if (addr_val.addr.id =3D=3D 0 || !(addr_val.flags & MPTCP_PM_ADDR_FLAG_SI= GNAL)) { + GENL_SET_ERR_MSG(info, "invalid addr id or flags"); + return -EINVAL; + } + + if (!(addr_val.flags & MPTCP_PM_ADDR_FLAG_NO_LISTEN)) { + if (!addr_val.addr.port) { + addr_val.addr.port =3D + ((struct inet_sock *)inet_sk + ((struct sock *)msk))->inet_sport; + + reuse_port =3D true; + } + + lsk_ref =3D lsk_list_find_or_create(sock_net(skb->sk), pernet, &addr_val= , &err); + + if ((!lsk_ref && !reuse_port) || (!lsk_ref && (err !=3D -EADDRINUSE) && = reuse_port)) { + GENL_SET_ERR_MSG(info, "error creating listen socket"); + err =3D (err =3D=3D 0) ? -ENOMEM : err; + return err; + } + + if (!reuse_port) { + addr_val.lsk_ref =3D lsk_ref; + lsk_ref =3D NULL; + } else { + addr_val.addr.port =3D 0; + } + } + + err =3D mptcp_userspace_pm_append_new_local_addr(msk, &addr_val); + if (err < 0) { + if (addr_val.lsk_ref) + lsk_list_release(pernet, addr_val.lsk_ref); + else if (lsk_ref) + lsk_list_release(pernet, lsk_ref); + GENL_SET_ERR_MSG(info, "did not match address and id"); + return err; + } + + lock_sock((struct sock *)msk); + spin_lock_bh(&msk->pm.lock); + + if (mptcp_pm_alloc_anno_list(msk, &addr_val, lsk_ref)) { + mptcp_pm_announce_addr(msk, &addr_val.addr, false); + mptcp_pm_nl_addr_send_ack(msk); + } + + spin_unlock_bh(&msk->pm.lock); + release_sock((struct sock *)msk); + + if (addr_val.lsk_ref) + lsk_list_release(pernet, addr_val.lsk_ref); + else if (lsk_ref) + lsk_list_release(pernet, lsk_ref); + + return 0; +} + static int mptcp_nl_cmd_set_flags(struct sk_buff *skb, struct genl_info *i= nfo) { struct mptcp_pm_addr_entry addr =3D { .addr =3D { .family =3D AF_UNSPEC }= , }, *entry; @@ -2425,6 +2521,11 @@ static const struct genl_small_ops mptcp_pm_ops[] = =3D { .doit =3D mptcp_nl_cmd_set_flags, .flags =3D GENL_ADMIN_PERM, }, + { + .cmd =3D MPTCP_PM_CMD_ANNOUNCE, + .doit =3D mptcp_nl_cmd_announce, + .flags =3D GENL_ADMIN_PERM, + }, }; =20 static struct genl_family mptcp_genl_family __ro_after_init =3D { --=20 2.31.1