Received: by 2002:a05:7412:7c14:b0:fa:6e18:a558 with SMTP id ii20csp329877rdb; Mon, 22 Jan 2024 05:44:49 -0800 (PST) X-Google-Smtp-Source: AGHT+IEPjvaESAAxE3IJzDLD0Qg3dcFlBUQgpRKEASRh67Y2Z0CAD1XTPr4vwb9HsFx4Pz42Xo43 X-Received: by 2002:a17:902:b088:b0:1d0:c7f:8eed with SMTP id p8-20020a170902b08800b001d00c7f8eedmr4343950plr.58.1705931089483; Mon, 22 Jan 2024 05:44:49 -0800 (PST) ARC-Seal: i=2; a=rsa-sha256; t=1705931089; cv=pass; d=google.com; s=arc-20160816; b=CNVdfujJf9qCxvFsMl8CmcVsu+EOs66QKA+4BUf3X0eecrKdrHGXCg4RI5gpW/Syuv 0m3CPcTwPutfMljqJOC6MQjTiI456N7J1ayE3REwlVvlmdpdHyIaDjqvyD01EOjmFl7n c+Ffxw917LCEbbyVQjT90T9c+NoAExSjTOFeCJ00TwRZcJ4RvL4fJ1CdIftflCxp1mzs OcZ05yE8QceUbtF96wufvWhjk7EMys6IH5INd31uN1PyfOl94ROAgdrn19r9EnSj4j3P AVgEAG11TsW8OXtqL0cFRecj/pwYElcCwdXCjitTg04fqTCbljIbSl9aM+1VJai/3dbH jtCg== ARC-Message-Signature: i=2; a=rsa-sha256; c=relaxed/relaxed; d=google.com; s=arc-20160816; h=mime-version:list-unsubscribe:list-subscribe:list-id:precedence :user-agent:content-transfer-encoding:autocrypt:references :in-reply-to:date:cc:to:from:subject:message-id:dkim-signature; bh=izBh2/okfq6ZntMd+Zzi+QP9xp6OCWFdVrznui6Vfwc=; fh=ojetYXhyIrMepoz0XWb2AL/8eJLLEfz2GCtDXWJIAJI=; b=O1iH2oPdLDHxjLUwTzSkqt44ilJ0r5vmrf+p1vT3Wo3UL7SszumU6u0fJvcV8C1+ig jI3aPl9zVRDopldimcMjjbv3kM3/0W5vwo6dTpVZ13QS9AWqL4XtZNBb2Ei657aod8R1 4YvPFrmTpgM2URzBWEsxR1dxlMHRxlUAe7dN0YJp24b8ZA4YtkfCoSUKEfvRLpmWybP2 Cdds5/Sg326A9Gpk28xOxeTfr4T1EosA6Scy9RmX8YGnuGgpRgIqm8RFN5PfgZ0DiPzv 9dZkQTBhuWEYuAC+YMKtsaS31KD+RNUn5iLMAJqIrllBVkg0yEDDS7+5D4tgh1E7bPoA Ou4Q== ARC-Authentication-Results: i=2; mx.google.com; dkim=pass header.i=@kernel.org header.s=k20201202 header.b=kFHuDEX8; arc=pass (i=1 dkim=pass dkdomain=kernel.org); spf=pass (google.com: domain of linux-nfs+bounces-1237-linux.lists.archive=gmail.com@vger.kernel.org designates 2604:1380:45e3:2400::1 as permitted sender) smtp.mailfrom="linux-nfs+bounces-1237-linux.lists.archive=gmail.com@vger.kernel.org"; dmarc=pass (p=NONE sp=NONE dis=NONE) header.from=kernel.org Return-Path: Received: from sv.mirrors.kernel.org (sv.mirrors.kernel.org. [2604:1380:45e3:2400::1]) by mx.google.com with ESMTPS id u16-20020a170903125000b001d6fd932a81si8314401plh.275.2024.01.22.05.44.49 for (version=TLS1_3 cipher=TLS_AES_256_GCM_SHA384 bits=256/256); Mon, 22 Jan 2024 05:44:49 -0800 (PST) Received-SPF: pass (google.com: domain of linux-nfs+bounces-1237-linux.lists.archive=gmail.com@vger.kernel.org designates 2604:1380:45e3:2400::1 as permitted sender) client-ip=2604:1380:45e3:2400::1; Authentication-Results: mx.google.com; dkim=pass header.i=@kernel.org header.s=k20201202 header.b=kFHuDEX8; arc=pass (i=1 dkim=pass dkdomain=kernel.org); spf=pass (google.com: domain of linux-nfs+bounces-1237-linux.lists.archive=gmail.com@vger.kernel.org designates 2604:1380:45e3:2400::1 as permitted sender) smtp.mailfrom="linux-nfs+bounces-1237-linux.lists.archive=gmail.com@vger.kernel.org"; dmarc=pass (p=NONE sp=NONE dis=NONE) header.from=kernel.org 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 sv.mirrors.kernel.org (Postfix) with ESMTPS id 4A45828608D for ; Mon, 22 Jan 2024 13:42:18 +0000 (UTC) Received: from localhost.localdomain (localhost.localdomain [127.0.0.1]) by smtp.subspace.kernel.org (Postfix) with ESMTP id 751E33D0C0; Mon, 22 Jan 2024 13:41:52 +0000 (UTC) Authentication-Results: smtp.subspace.kernel.org; dkim=pass (2048-bit key) header.d=kernel.org header.i=@kernel.org header.b="kFHuDEX8" X-Original-To: linux-nfs@vger.kernel.org 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 4B5BB3D38D; Mon, 22 Jan 2024 13:41:51 +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=1705930912; cv=none; b=cWsofDbAIdvbQQhRqsLNTOHUpe38SvLc4DOFu5Fl1RGD83owzg0Hme4+0BLkKl6/sSYqdRD0iQfzemdxkdFQM7z5BVa4O8Nr+f/0JxVQozDqrmbkpbYYVBXhaRLEa+ctoTPFQ9E+/Ohik4FmchV/UN9tYX2o33qKCcsTzLPlj30= ARC-Message-Signature:i=1; a=rsa-sha256; d=subspace.kernel.org; s=arc-20240116; t=1705930912; c=relaxed/simple; bh=r7YVuqXisutoEcs9J46MNv4m/J3R2j9tu4bJWuMWmpo=; h=Message-ID:Subject:From:To:Cc:Date:In-Reply-To:References: Content-Type:MIME-Version; b=I4fHU3QFocEOhJ0d5VEH2gp3HgIoruLcq82LtTkGyVS62WziJC7zVyKIbH2SJInW/lOJErl9E4rK++I6v75dExdv6uGBuJJA9e4pbxCel1zM1g50CSPM9fLV7wc/VRksWKaeVP44tYl4MH9udn1WdeoWbC5m1SJ0dO7nqCpTgvg= ARC-Authentication-Results:i=1; smtp.subspace.kernel.org; dkim=pass (2048-bit key) header.d=kernel.org header.i=@kernel.org header.b=kFHuDEX8; arc=none smtp.client-ip=10.30.226.201 Received: by smtp.kernel.org (Postfix) with ESMTPSA id F3E1EC433F1; Mon, 22 Jan 2024 13:41:50 +0000 (UTC) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/simple; d=kernel.org; s=k20201202; t=1705930911; bh=r7YVuqXisutoEcs9J46MNv4m/J3R2j9tu4bJWuMWmpo=; h=Subject:From:To:Cc:Date:In-Reply-To:References:From; b=kFHuDEX8iFEK49RYyHI8bJ5a1vprCGKNK55IhcsWnC9GWjXsALBgFvCyU7+liKbFm nacx+5zTiX+u4BR5BX9UUXlSa1HmNUcLQMejnQeZuXAS6EHE6mbgSfweVoNWKhKjtx yZg+B9M5Uja6RtrZCvb9PT/e4WzgBhLui5ZcOc9jNXMi6yP6IM8Yqv/2tqGCXi9kKw t7RN6Q7REdLfQOhijBbpIdGtWl9FKzhMQPwyIJgd6PSs5aeX7WnGGy0756oGPu3Che LX+VyahqrHmlc9ypbM75x7tIthnZBvYz6SJ2PTy9JJVGOOxBV0gF8JADbArr83hIfW 4R3VvMODkgE4A== Message-ID: <9e3ae337dcf168c60c4cfd51aa0b2fc7b24bcbfb.camel@kernel.org> Subject: Re: [PATCH v6 3/3] NFSD: add write_ports to netlink command From: Jeff Layton To: Lorenzo Bianconi , linux-nfs@vger.kernel.org Cc: lorenzo.bianconi@redhat.com, neilb@suse.de, kuba@kernel.org, chuck.lever@oracle.com, horms@kernel.org, netdev@vger.kernel.org Date: Mon, 22 Jan 2024 08:41:49 -0500 In-Reply-To: References: Autocrypt: addr=jlayton@kernel.org; prefer-encrypt=mutual; keydata=mQINBE6V0TwBEADXhJg7s8wFDwBMEvn0qyhAnzFLTOCHooMZyx7XO7dAiIhDSi7G1NPxwn8jdFUQMCR/GlpozMFlSFiZXiObE7sef9rTtM68ukUyZM4pJ9l0KjQNgDJ6Fr342Htkjxu/kFV1WvegyjnSsFt7EGoDjdKqr1TS9syJYFjagYtvWk/UfHlW09X+jOh4vYtfX7iYSx/NfqV3W1D7EDi0PqVT2h6v8i8YqsATFPwO4nuiTmL6I40ZofxVd+9wdRI4Db8yUNA4ZSP2nqLcLtFjClYRBoJvRWvsv4lm0OX6MYPtv76hka8lW4mnRmZqqx3UtfHX/hF/zH24Gj7A6sYKYLCU3YrI2Ogiu7/ksKcl7goQjpvtVYrOOI5VGLHge0awt7bhMCTM9KAfPc+xL/ZxAMVWd3NCk5SamL2cE99UWgtvNOIYU8m6EjTLhsj8snVluJH0/RcxEeFbnSaswVChNSGa7mXJrTR22lRL6ZPjdMgS2Km90haWPRc8Wolcz07Y2se0xpGVLEQcDEsvv5IMmeMe1/qLZ6NaVkNuL3WOXvxaVT9USW1+/SGipO2IpKJjeDZfehlB/kpfF24+RrK+seQfCBYyUE8QJpvTZyfUHNYldXlrjO6n5MdOempLqWpfOmcGkwnyNRBR46g/jf8KnPRwXs509yAqDB6sELZH+yWr9LQZEwARAQABtCVKZWZmIExheXRvbiA8amxheXRvbkBwb29jaGllcmVkcy5uZXQ+iQI7BBMBAgAlAhsDBgsJCAcDAgYVCAIJCgsEFgIDAQIeAQIXgAUCTpXWPAIZAQAKCRAADmhBGVaCFc65D/4gBLNMHopQYgG/9RIM3kgFCCQV0pLv0hcg1cjr+bPI5f1PzJoOVi9s0wBDHwp8+vtHgYhM54yt43uI7Htij0RHFL5eFqoVT4TSfAg2qlvNemJEOY0e4daljjmZM7UtmpGs9NN0r9r50W82eb5Kw5bc/ r0kmR/arUS2st+ecRsCnwAOj6HiURwIgfDMHGPtSkoPpu3DDp/cjcYUg3HaOJuTjtGHFH963B+f+hyQ2BrQZBBE76ErgTDJ2Db9Ey0kw7VEZ4I2nnVUY9B5dE2pJFVO5HJBMp30fUGKvwaKqYCU2iAKxdmJXRIONb7dSde8LqZahuunPDMZyMA5+mkQl7kpIpR6kVDIiqmxzRuPeiMP7O2FCUlS2DnJnRVrHmCljLkZWf7ZUA22wJpepBligemtSRSbqCyZ3B48zJ8g5B8xLEntPo/NknSJaYRvfEQqGxgk5kkNWMIMDkfQOlDSXZvoxqU9wFH/9jTv1/6p8dHeGM0BsbBLMqQaqnWiVt5mG92E1zkOW69LnoozE6Le+12DsNW7RjiR5K+27MObjXEYIW7FIvNN/TQ6U1EOsdxwB8o//Yfc3p2QqPr5uS93SDDan5ehH59BnHpguTc27XiQQZ9EGiieCUx6Zh2ze3X2UW9YNzE15uKwkkuEIj60NvQRmEDfweYfOfPVOueC+iFifbQgSmVmZiBMYXl0b24gPGpsYXl0b25AcmVkaGF0LmNvbT6JAjgEEwECACIFAk6V0q0CGwMGCwkIBwMCBhUIAgkKCwQWAgMBAh4BAheAAAoJEAAOaEEZVoIViKUQALpvsacTMWWOd7SlPFzIYy2/fjvKlfB/Xs4YdNcf9qLqF+lk2RBUHdR/dGwZpvw/OLmnZ8TryDo2zXVJNWEEUFNc7wQpl3i78r6UU/GUY/RQmOgPhs3epQC3PMJj4xFx+VuVcf/MXgDDdBUHaCTT793hyBeDbQuciARDJAW24Q1RCmjcwWIV/pgrlFa4lAXsmhoac8UPc82Ijrs6ivlTweFf16VBc4nSLX5FB3ls7S5noRhm5/Zsd4PGPgIHgCZcPgkAnU1S/A/rSqf3FLpU+CbVBDvlVAnOq9gfNF+QiTlOHdZVIe4gEYAU3CUjbleywQqV02BKxPVM0C5/oVjMVx 3bri75n1TkBYGmqAXy9usCkHIsG5CBHmphv9MHmqMZQVsxvCzfnI5IO1+7MoloeeW/lxuyd0pU88dZsV/riHw87i2GJUJtVlMl5IGBNFpqoNUoqmvRfEMeXhy/kUX4Xc03I1coZIgmwLmCSXwx9MaCPFzV/dOOrju2xjO+2sYyB5BNtxRqUEyXglpujFZqJxxau7E0eXoYgoY9gtFGsspzFkVNntamVXEWVVgzJJr/EWW0y+jNd54MfPRqH+eCGuqlnNLktSAVz1MvVRY1dxUltSlDZT7P2bUoMorIPu8p7ZCg9dyX1+9T6Muc5dHxf/BBP/ir+3e8JTFQBFOiLNdFtB9KZWZmIExheXRvbiA8amxheXRvbkBzYW1iYS5vcmc+iQI4BBMBAgAiBQJOldK9AhsDBgsJCAcDAgYVCAIJCgsEFgIDAQIeAQIXgAAKCRAADmhBGVaCFWgWD/0ZRi4hN9FK2BdQs9RwNnFZUr7JidAWfCrs37XrA/56olQl3ojn0fQtrP4DbTmCuh0SfMijB24psy1GnkPepnaQ6VRf7Dxg/Y8muZELSOtsv2CKt3/02J1BBitrkkqmHyni5fLLYYg6fub0T/8Kwo1qGPdu1hx2BQRERYtQ/S5d/T0cACdlzi6w8rs5f09hU9Tu4qV1JLKmBTgUWKN969HPRkxiojLQziHVyM/weR5Reu6FZVNuVBGqBD+sfk/c98VJHjsQhYJijcsmgMb1NohAzwrBKcSGKOWJToGEO/1RkIN8tqGnYNp2G+aR685D0chgTl1WzPRM6mFG1+n2b2RR95DxumKVpwBwdLPoCkI24JkeDJ7lXSe3uFWISstFGt0HL8EewP8RuGC8s5h7Ct91HMNQTbjgA+Vi1foWUVXpEintAKgoywaIDlJfTZIl6Ew8ETN/7DLy8bXYgq0XzhaKg3CnOUuGQV5/nl4OAX/3jocT5Cz/OtAiNYj5mLPeL5z2ZszjoCAH6caqsF2oLyA nLqRgDgR+wTQT6gMhr2IRsl+cp8gPHBwQ4uZMb+X00c/Amm9VfviT+BI7B66cnC7Zv6Gvmtu2rEjWDGWPqUgccB7hdMKnKDthkA227/82tYoFiFMb/NwtgGrn5n2vwJyKN6SEoygGrNt0SI84y6hEVbQlSmVmZiBMYXl0b24gPGpsYXl0b25AcHJpbWFyeWRhdGEuY29tPokCOQQTAQIAIwUCU4xmKQIbAwcLCQgHAwIBBhUIAgkKCwQWAgMBAh4BAheAAAoJEAAOaEEZVoIV1H0P/j4OUTwFd7BBbpoSp695qb6HqCzWMuExsp8nZjruymMaeZbGr3OWMNEXRI1FWNHMtcMHWLP/RaDqCJil28proO+PQ/yPhsr2QqJcW4nr91tBrv/MqItuAXLYlsgXqp4BxLP67bzRJ1Bd2x0bWXurpEXY//VBOLnODqThGEcL7jouwjmnRh9FTKZfBDpFRaEfDFOXIfAkMKBa/c9TQwRpx2DPsl3eFWVCNuNGKeGsirLqCxUg5kWTxEorROppz9oU4HPicL6rRH22Ce6nOAON2vHvhkUuO3GbffhrcsPD4DaYup4ic+DxWm+DaSSRJ+e1yJvwi6NmQ9P9UAuLG93S2MdNNbosZ9P8k2mTOVKMc+GooI9Ve/vH8unwitwo7ORMVXhJeU6Q0X7zf3SjwDq2lBhn1DSuTsn2DbsNTiDvqrAaCvbsTsw+SZRwF85eG67eAwouYk+dnKmp1q57LDKMyzysij2oDKbcBlwB/TeX16p8+LxECv51asjS9TInnipssssUDrHIvoTTXWcz7Y5wIngxDFwT8rPY3EggzLGfK5Zx2Q5S/N0FfmADmKknG/D8qGIcJE574D956tiUDKN4I+/g125ORR1v7bP+OIaayAvq17RP+qcAqkxc0x8iCYVCYDouDyNvWPGRhbLUO7mlBpjW9jK9e2fvZY9iw3QzIPGKtClKZWZmIExheXRvbiA8amVmZi5sYXl0 b25AcHJpbWFyeWRhdGEuY29tPokCOQQTAQIAIwUCU4xmUAIbAwcLCQgHAwIBBhUIAgkKCwQWAgMBAh4BAheAAAoJEAAOaEEZVoIVzJoQALFCS6n/FHQS+hIzHIb56JbokhK0AFqoLVzLKzrnaeXhE5isWcVg0eoV2oTScIwUSUapy94if69tnUo4Q7YNt8/6yFM6hwZAxFjOXR0ciGE3Q+Z1zi49Ox51yjGMQGxlakV9ep4sV/d5a50M+LFTmYSAFp6HY23JN9PkjVJC4PUv5DYRbOZ6Y1+TfXKBAewMVqtwT1Y+LPlfmI8dbbbuUX/kKZ5ddhV2736fgyfpslvJKYl0YifUOVy4D1G/oSycyHkJG78OvX4JKcf2kKzVvg7/Rnv+AueCfFQ6nGwPn0P91I7TEOC4XfZ6a1K3uTp4fPPs1Wn75X7K8lzJP/p8lme40uqwAyBjk+IA5VGd+CVRiyJTpGZwA0jwSYLyXboX+Dqm9pSYzmC9+/AE7lIgpWj+3iNisp1SWtHc4pdtQ5EU2SEz8yKvDbD0lNDbv4ljI7eflPsvN6vOrxz24mCliEco5DwhpaaSnzWnbAPXhQDWb/lUgs/JNk8dtwmvWnqCwRqElMLVisAbJmC0BhZ/Ab4sph3EaiZfdXKhiQqSGdK4La3OTJOJYZphPdGgnkvDV9Pl1QZ0ijXQrVIy3zd6VCNaKYq7BAKidn5g/2Q8oio9Tf4XfdZ9dtwcB+bwDJFgvvDYaZ5bI3ln4V3EyW5i2NfXazz/GA/I/ZtbsigCFc8ftCBKZWZmIExheXRvbiA8amxheXRvbkBrZXJuZWwub3JnPokCOAQTAQIAIgUCWe8u6AIbAwYLCQgHAwIGFQgCCQoLBBYCAwECHgECF4AACgkQAA5oQRlWghUuCg/+Lb/xGxZD2Q1oJVAE37uW308UpVSD2tAMJUvFTdDbfe3zKlPDTuVsyNsALBGclPLagJ5ZTP+Vp2irAN9uwBuac BOTtmOdz4ZN2tdvNgozzuxp4CHBDVzAslUi2idy+xpsp47DWPxYFIRP3M8QG/aNW052LaPc0cedYxp8+9eiVUNpxF4SiU4i9JDfX/sn9XcfoVZIxMpCRE750zvJvcCUz9HojsrMQ1NFc7MFT1z3MOW2/RlzPcog7xvR5ENPH19ojRDCHqumUHRry+RF0lH00clzX/W8OrQJZtoBPXv9ahka/Vp7kEulcBJr1cH5Wz/WprhsIM7U9pse1f1gYy9YbXtWctUz8uvDR7shsQxAhX3qO7DilMtuGo1v97I/Kx4gXQ52syh/w6EBny71CZrOgD6kJwPVVAaM1LRC28muq91WCFhs/nzHozpbzcheyGtMUI2Ao4K6mnY+3zIuXPygZMFr9KXE6fF7HzKxKuZMJOaEZCiDOq0anx6FmOzs5E6Jqdpo/mtI8beK+BE7Va6ni7YrQlnT0i3vaTVMTiCThbqsB20VrbMjlhpf8lfK1XVNbRq/R7GZ9zHESlsa35ha60yd/j3pu5hT2xyy8krV8vGhHvnJ1XRMJBAB/UYb6FyC7S+mQZIQXVeAA+smfTT0tDrisj1U5x6ZB9b3nBg65ke5Ag0ETpXRPAEQAJkVmzCmF+IEenf9a2nZRXMluJohnfl2wCMmw5qNzyk0f+mYuTwTCpw7BE2H0yXk4ZfAuA+xdj14K0A1Dj52j/fKRuDqoNAhQe0b6ipo85Sz98G+XnmQOMeFVp5G1Z7r/QP/nus3mXvtFsu9lLSjMA0cam2NLDt7vx3l9kUYlQBhyIE7/DkKg+3fdqRg7qJoMHNcODtQY+n3hMyaVpplJ/l0DdQDbRSZi5AzDM3DWZEShhuP6/E2LN4O3xWnZukEiz688d1ppl7vBZO9wBql6Ft9Og74diZrTN6lXGGjEWRvO55h6ijMsLCLNDRAVehPhZvSlPldtUuvhZLAjdWpwmzbRIwgoQcO51aWeKthpcpj8feDdKdlVjvJO9fgFD5kqZ QiErRVPpB7VzA/pYV5Mdy7GMbPjmO0IpoL0tVZ8JvUzUZXB3ErS/dJflvboAAQeLpLCkQjqZiQ/DCmgJCrBJst9Xc7YsKKS379Tc3GU33HNSpaOxs2NwfzoesyjKU+P35czvXWTtj7KVVSj3SgzzFk+gLx8y2Nvt9iESdZ1Ustv8tipDsGcvIZ43MQwqU9YbLg8k4V9ch+Mo8SE+C0jyZYDCE2ZGf3OztvtSYMsTnF6/luzVyej1AFVYjKHORzNoTwdHUeC+9/07GO0bMYTPXYvJ/vxBFm3oniXyhgb5FtABEBAAGJAh8EGAECAAkFAk6V0TwCGwwACgkQAA5oQRlWghXhZRAAyycZ2DDyXh2bMYvI8uHgCbeXfL3QCvcw2XoZTH2l2umPiTzrCsDJhgwZfG9BDyOHaYhPasd5qgrUBtjjUiNKjVM+Cx1DnieR0dZWafnqGv682avPblfi70XXr2juRE/fSZoZkyZhm+nsLuIcXTnzY4D572JGrpRMTpNpGmitBdh1l/9O7Fb64uLOtA5Qj5jcHHOjL0DZpjmFWYKlSAHmURHrE8M0qRryQXvlhoQxlJR4nvQrjOPMsqWD5F9mcRyowOzr8amasLv43w92rD2nHoBK6rbFE/qC7AAjABEsZq8+TQmueN0maIXUQu7TBzejsEbV0i29z+kkrjU2NmK5pcxgAtehVxpZJ14LqmN6E0suTtzjNT1eMoqOPrMSx+6vOCIuvJ/MVYnQgHhjtPPnU86mebTY5Loy9YfJAC2EVpxtcCbx2KiwErTndEyWL+GL53LuScUD7tW8vYbGIp4RlnUgPLbqpgssq2gwYO9m75FGuKuB2+2bCGajqalid5nzeq9v7cYLLRgArJfOIBWZrHy2m0C+pFu9DSuV6SNr2dvMQUv1V58h0FaSOxHVQnJdnoHn13g/CKKvyg2EMrMt/EfcXgvDwQbnG9we4xJiWOIOcsvrWcB6C6lWBDA+In7w7SXnnok kZWuOsJdJQdmwlWC5L5ln9xgfr/4mOY38B0U= Content-Type: text/plain; charset="ISO-8859-15" Content-Transfer-Encoding: quoted-printable User-Agent: Evolution 3.50.3 (3.50.3-1.fc39) Precedence: bulk X-Mailing-List: linux-nfs@vger.kernel.org List-Id: List-Subscribe: List-Unsubscribe: MIME-Version: 1.0 On Sat, 2024-01-20 at 18:33 +0100, Lorenzo Bianconi wrote: > Introduce write_ports netlink command. For listener-set, userspace is > expected to provide a NFS listeners list it wants to enable (all the > other ports will be closed). >=20 Ditto here. This is a change to a declarative interface, which I think is a better way to handle this, but we should be aware of the change. > Signed-off-by: Lorenzo Bianconi > --- > Documentation/netlink/specs/nfsd.yaml | 37 +++++ > fs/nfsd/netlink.c | 23 +++ > fs/nfsd/netlink.h | 3 + > fs/nfsd/nfsctl.c | 196 ++++++++++++++++++++++++++ > include/uapi/linux/nfsd_netlink.h | 18 +++ > tools/net/ynl/generated/nfsd-user.c | 191 +++++++++++++++++++++++++ > tools/net/ynl/generated/nfsd-user.h | 55 ++++++++ > 7 files changed, 523 insertions(+) >=20 > diff --git a/Documentation/netlink/specs/nfsd.yaml b/Documentation/netlin= k/specs/nfsd.yaml > index 30f18798e84e..296ff24b23ac 100644 > --- a/Documentation/netlink/specs/nfsd.yaml > +++ b/Documentation/netlink/specs/nfsd.yaml > @@ -85,6 +85,26 @@ attribute-sets: > type: nest > nested-attributes: nfs-version > multi-attr: true > + - > + name: server-instance > + attributes: > + - > + name: transport-name > + type: string > + - > + name: port > + type: u32 > + - > + name: inet-proto > + type: u16 > + - > + name: server-listener > + attributes: > + - > + name: instance > + type: nest > + nested-attributes: server-instance > + multi-attr: true > =20 > operations: > list: > @@ -144,3 +164,20 @@ operations: > reply: > attributes: > - version > + - > + name: listener-set > + doc: set nfs running listeners > + attribute-set: server-listener > + flags: [ admin-perm ] > + do: > + request: > + attributes: > + - instance > + - > + name: listener-get > + doc: get nfs running listeners > + attribute-set: server-listener > + do: > + reply: > + attributes: > + - instance > diff --git a/fs/nfsd/netlink.c b/fs/nfsd/netlink.c > index 5cbbd3295543..c772f9e14761 100644 > --- a/fs/nfsd/netlink.c > +++ b/fs/nfsd/netlink.c > @@ -16,6 +16,12 @@ const struct nla_policy nfsd_nfs_version_nl_policy[NFS= D_A_NFS_VERSION_MINOR + 1] > [NFSD_A_NFS_VERSION_MINOR] =3D { .type =3D NLA_U32, }, > }; > =20 > +const struct nla_policy nfsd_server_instance_nl_policy[NFSD_A_SERVER_INS= TANCE_INET_PROTO + 1] =3D { > + [NFSD_A_SERVER_INSTANCE_TRANSPORT_NAME] =3D { .type =3D NLA_NUL_STRING,= }, > + [NFSD_A_SERVER_INSTANCE_PORT] =3D { .type =3D NLA_U32, }, > + [NFSD_A_SERVER_INSTANCE_INET_PROTO] =3D { .type =3D NLA_U16, }, > +}; > + > /* NFSD_CMD_THREADS_SET - do */ > static const struct nla_policy nfsd_threads_set_nl_policy[NFSD_A_SERVER_= WORKER_THREADS + 1] =3D { > [NFSD_A_SERVER_WORKER_THREADS] =3D { .type =3D NLA_U32, }, > @@ -26,6 +32,11 @@ static const struct nla_policy nfsd_version_set_nl_pol= icy[NFSD_A_SERVER_PROTO_VE > [NFSD_A_SERVER_PROTO_VERSION] =3D NLA_POLICY_NESTED(nfsd_nfs_version_nl= _policy), > }; > =20 > +/* NFSD_CMD_LISTENER_SET - do */ > +static const struct nla_policy nfsd_listener_set_nl_policy[NFSD_A_SERVER= _LISTENER_INSTANCE + 1] =3D { > + [NFSD_A_SERVER_LISTENER_INSTANCE] =3D NLA_POLICY_NESTED(nfsd_server_ins= tance_nl_policy), > +}; > + > /* Ops table for nfsd */ > static const struct genl_split_ops nfsd_nl_ops[] =3D { > { > @@ -59,6 +70,18 @@ static const struct genl_split_ops nfsd_nl_ops[] =3D { > .doit =3D nfsd_nl_version_get_doit, > .flags =3D GENL_CMD_CAP_DO, > }, > + { > + .cmd =3D NFSD_CMD_LISTENER_SET, > + .doit =3D nfsd_nl_listener_set_doit, > + .policy =3D nfsd_listener_set_nl_policy, > + .maxattr =3D NFSD_A_SERVER_LISTENER_INSTANCE, > + .flags =3D GENL_ADMIN_PERM | GENL_CMD_CAP_DO, > + }, > + { > + .cmd =3D NFSD_CMD_LISTENER_GET, > + .doit =3D nfsd_nl_listener_get_doit, > + .flags =3D GENL_CMD_CAP_DO, > + }, > }; > =20 > struct genl_family nfsd_nl_family __ro_after_init =3D { > diff --git a/fs/nfsd/netlink.h b/fs/nfsd/netlink.h > index c9a1be693fef..10a26ad32cd0 100644 > --- a/fs/nfsd/netlink.h > +++ b/fs/nfsd/netlink.h > @@ -13,6 +13,7 @@ > =20 > /* Common nested types */ > extern const struct nla_policy nfsd_nfs_version_nl_policy[NFSD_A_NFS_VER= SION_MINOR + 1]; > +extern const struct nla_policy nfsd_server_instance_nl_policy[NFSD_A_SER= VER_INSTANCE_INET_PROTO + 1]; > =20 > int nfsd_nl_rpc_status_get_start(struct netlink_callback *cb); > int nfsd_nl_rpc_status_get_done(struct netlink_callback *cb); > @@ -23,6 +24,8 @@ int nfsd_nl_threads_set_doit(struct sk_buff *skb, struc= t genl_info *info); > int nfsd_nl_threads_get_doit(struct sk_buff *skb, struct genl_info *info= ); > int nfsd_nl_version_set_doit(struct sk_buff *skb, struct genl_info *info= ); > int nfsd_nl_version_get_doit(struct sk_buff *skb, struct genl_info *info= ); > +int nfsd_nl_listener_set_doit(struct sk_buff *skb, struct genl_info *inf= o); > +int nfsd_nl_listener_get_doit(struct sk_buff *skb, struct genl_info *inf= o); > =20 > extern struct genl_family nfsd_nl_family; > =20 > diff --git a/fs/nfsd/nfsctl.c b/fs/nfsd/nfsctl.c > index 53af82303f93..562b209f2921 100644 > --- a/fs/nfsd/nfsctl.c > +++ b/fs/nfsd/nfsctl.c > @@ -1896,6 +1896,202 @@ int nfsd_nl_version_get_doit(struct sk_buff *skb,= struct genl_info *info) > return err; > } > =20 > +/** > + * nfsd_nl_listener_set_doit - set the nfs running listeners > + * @skb: reply buffer > + * @info: netlink metadata and command arguments > + * > + * Return 0 on success or a negative errno. > + */ > +int nfsd_nl_listener_set_doit(struct sk_buff *skb, struct genl_info *inf= o) > +{ > + struct nlattr *tb[ARRAY_SIZE(nfsd_server_instance_nl_policy)]; > + struct net *net =3D genl_info_net(info); > + struct svc_xprt *xprt, *tmp_xprt; > + const struct nlattr *attr; > + struct svc_serv *serv; > + const char *xcl_name; > + struct nfsd_net *nn; > + int port, err, rem; > + sa_family_t af; > + > + if (GENL_REQ_ATTR_CHECK(info, NFSD_A_SERVER_LISTENER_INSTANCE)) > + return -EINVAL; > + > + mutex_lock(&nfsd_mutex); > + > + err =3D nfsd_create_serv(net); > + if (err) { > + mutex_unlock(&nfsd_mutex); > + return err; > + } > + > + nn =3D net_generic(net, nfsd_net_id); > + serv =3D nn->nfsd_serv; > + > + /* 1- create brand new listeners */ > + nlmsg_for_each_attr(attr, info->nlhdr, GENL_HDRLEN, rem) { > + if (nla_type(attr) !=3D NFSD_A_SERVER_LISTENER_INSTANCE) > + continue; > + > + if (nla_parse_nested(tb, ARRAY_SIZE(tb), attr, > + nfsd_server_instance_nl_policy, > + info->extack) < 0) > + continue; > + > + if (!tb[NFSD_A_SERVER_INSTANCE_TRANSPORT_NAME] || > + !tb[NFSD_A_SERVER_INSTANCE_PORT]) > + continue; > + > + xcl_name =3D nla_data(tb[NFSD_A_SERVER_INSTANCE_TRANSPORT_NAME]); > + port =3D nla_get_u32(tb[NFSD_A_SERVER_INSTANCE_PORT]); > + if (port < 1 || port > USHRT_MAX) > + continue; > + > + af =3D nla_get_u32(tb[NFSD_A_SERVER_INSTANCE_INET_PROTO]); > + if (af !=3D PF_INET && af !=3D PF_INET6) > + continue; > + > + xprt =3D svc_find_xprt(serv, xcl_name, net, PF_INET, port); > + if (xprt) { > + svc_xprt_put(xprt); > + continue; > + } > + > + /* create new listerner */ > + if (svc_xprt_create(serv, xcl_name, net, af, port, > + SVC_SOCK_ANONYMOUS, get_current_cred())) > + continue; > + } > + > + /* 2- remove stale listeners */ The old portlist interface was weird, in that it was only additive. You couldn't use it to close a listening socket (AFAICT). We may be able to support that now with this interface, but we'll need to test that case carefully. > + spin_lock_bh(&serv->sv_lock); > + list_for_each_entry_safe(xprt, tmp_xprt, &serv->sv_permsocks, > + xpt_list) { > + struct svc_xprt *rqt_xprt =3D NULL; > + > + nlmsg_for_each_attr(attr, info->nlhdr, GENL_HDRLEN, rem) { > + if (nla_type(attr) !=3D NFSD_A_SERVER_LISTENER_INSTANCE) > + continue; > + > + if (nla_parse_nested(tb, ARRAY_SIZE(tb), attr, > + nfsd_server_instance_nl_policy, > + info->extack) < 0) > + continue; > + > + if (!tb[NFSD_A_SERVER_INSTANCE_TRANSPORT_NAME] || > + !tb[NFSD_A_SERVER_INSTANCE_PORT]) > + continue; > + > + xcl_name =3D nla_data( > + tb[NFSD_A_SERVER_INSTANCE_TRANSPORT_NAME]); > + port =3D nla_get_u32(tb[NFSD_A_SERVER_INSTANCE_PORT]); > + if (port < 1 || port > USHRT_MAX) > + continue; > + > + af =3D nla_get_u32(tb[NFSD_A_SERVER_INSTANCE_INET_PROTO]); > + if (af !=3D PF_INET && af !=3D PF_INET6) > + continue; > + > + if (!strcmp(xprt->xpt_class->xcl_name, xcl_name) && > + port =3D=3D svc_xprt_local_port(xprt) && > + af =3D=3D xprt->xpt_local.ss_family && > + xprt->xpt_net =3D=3D net) { > + rqt_xprt =3D xprt; > + break; > + } > + } > + > + /* remove stale listener */ > + if (!rqt_xprt) { > + spin_unlock_bh(&serv->sv_lock); > + svc_xprt_close(xprt); >=20 I'm not sure this is safe. Can anything else modify sv_permsocks while you're not holding the lock? Maybe not since you're holding the nfsd_mutex, but it's still probably best to restart the list walk if you have to drop the lock here. You're typically only going to have a few sockets here anyway -- usually just one each for TCP, UDP and maybe RDMA. > + spin_lock_bh(&serv->sv_lock); > + } > + } > + spin_unlock_bh(&serv->sv_lock); > + > + if (!serv->sv_nrthreads && list_empty(&nn->nfsd_serv->sv_permsocks)) > + nfsd_destroy_serv(net); > + > + mutex_unlock(&nfsd_mutex); > + > + return 0; > +} > + > +/** > + * nfsd_nl_listener_get_doit - get the nfs running listeners > + * @skb: reply buffer > + * @info: netlink metadata and command arguments > + * > + * Return 0 on success or a negative errno. > + */ > +int nfsd_nl_listener_get_doit(struct sk_buff *skb, struct genl_info *inf= o) > +{ > + struct svc_xprt *xprt; > + struct svc_serv *serv; > + struct nfsd_net *nn; > + void *hdr; > + int err; > + > + skb =3D genlmsg_new(GENLMSG_DEFAULT_SIZE, GFP_KERNEL); > + if (!skb) > + return -ENOMEM; > + > + hdr =3D genlmsg_iput(skb, info); > + if (!hdr) { > + err =3D -EMSGSIZE; > + goto err_free_msg; > + } > + > + mutex_lock(&nfsd_mutex); > + nn =3D net_generic(genl_info_net(info), nfsd_net_id); > + if (!nn->nfsd_serv) { > + err =3D -EINVAL; > + goto err_nfsd_unlock; > + } > + > + serv =3D nn->nfsd_serv; > + spin_lock_bh(&serv->sv_lock); > + list_for_each_entry(xprt, &serv->sv_permsocks, xpt_list) { > + struct nlattr *attr; > + > + attr =3D nla_nest_start_noflag(skb, > + NFSD_A_SERVER_LISTENER_INSTANCE); > + if (!attr) { > + err =3D -EINVAL; > + goto err_serv_unlock; > + } > + > + if (nla_put_string(skb, NFSD_A_SERVER_INSTANCE_TRANSPORT_NAME, > + xprt->xpt_class->xcl_name) || > + nla_put_u32(skb, NFSD_A_SERVER_INSTANCE_PORT, > + svc_xprt_local_port(xprt)) || > + nla_put_u16(skb, NFSD_A_SERVER_INSTANCE_INET_PROTO, > + xprt->xpt_local.ss_family)) { > + err =3D -EINVAL; > + goto err_serv_unlock; > + } > + > + nla_nest_end(skb, attr); > + } > + spin_unlock_bh(&serv->sv_lock); > + mutex_unlock(&nfsd_mutex); > + > + genlmsg_end(skb, hdr); > + > + return genlmsg_reply(skb, info); > + > +err_serv_unlock: > + spin_unlock_bh(&serv->sv_lock); > +err_nfsd_unlock: > + mutex_unlock(&nfsd_mutex); > +err_free_msg: > + nlmsg_free(skb); > + > + return err; > +} > + > /** > * nfsd_net_init - Prepare the nfsd_net portion of a new net namespace > * @net: a freshly-created network namespace > diff --git a/include/uapi/linux/nfsd_netlink.h b/include/uapi/linux/nfsd_= netlink.h > index 2a06f9fe6fe9..659ab76b8840 100644 > --- a/include/uapi/linux/nfsd_netlink.h > +++ b/include/uapi/linux/nfsd_netlink.h > @@ -51,12 +51,30 @@ enum { > NFSD_A_SERVER_PROTO_MAX =3D (__NFSD_A_SERVER_PROTO_MAX - 1) > }; > =20 > +enum { > + NFSD_A_SERVER_INSTANCE_TRANSPORT_NAME =3D 1, > + NFSD_A_SERVER_INSTANCE_PORT, > + NFSD_A_SERVER_INSTANCE_INET_PROTO, > + > + __NFSD_A_SERVER_INSTANCE_MAX, > + NFSD_A_SERVER_INSTANCE_MAX =3D (__NFSD_A_SERVER_INSTANCE_MAX - 1) > +}; > + > +enum { > + NFSD_A_SERVER_LISTENER_INSTANCE =3D 1, > + > + __NFSD_A_SERVER_LISTENER_MAX, > + NFSD_A_SERVER_LISTENER_MAX =3D (__NFSD_A_SERVER_LISTENER_MAX - 1) > +}; > + > enum { > NFSD_CMD_RPC_STATUS_GET =3D 1, > NFSD_CMD_THREADS_SET, > NFSD_CMD_THREADS_GET, > NFSD_CMD_VERSION_SET, > NFSD_CMD_VERSION_GET, > + NFSD_CMD_LISTENER_SET, > + NFSD_CMD_LISTENER_GET, > =20 > __NFSD_CMD_MAX, > NFSD_CMD_MAX =3D (__NFSD_CMD_MAX - 1) > diff --git a/tools/net/ynl/generated/nfsd-user.c b/tools/net/ynl/generate= d/nfsd-user.c > index ad498543f464..d52f392c7f59 100644 > --- a/tools/net/ynl/generated/nfsd-user.c > +++ b/tools/net/ynl/generated/nfsd-user.c > @@ -19,6 +19,8 @@ static const char * const nfsd_op_strmap[] =3D { > [NFSD_CMD_THREADS_GET] =3D "threads-get", > [NFSD_CMD_VERSION_SET] =3D "version-set", > [NFSD_CMD_VERSION_GET] =3D "version-get", > + [NFSD_CMD_LISTENER_SET] =3D "listener-set", > + [NFSD_CMD_LISTENER_GET] =3D "listener-get", > }; > =20 > const char *nfsd_op_str(int op) > @@ -39,6 +41,17 @@ struct ynl_policy_nest nfsd_nfs_version_nest =3D { > .table =3D nfsd_nfs_version_policy, > }; > =20 > +struct ynl_policy_attr nfsd_server_instance_policy[NFSD_A_SERVER_INSTANC= E_MAX + 1] =3D { > + [NFSD_A_SERVER_INSTANCE_TRANSPORT_NAME] =3D { .name =3D "transport-name= ", .type =3D YNL_PT_NUL_STR, }, > + [NFSD_A_SERVER_INSTANCE_PORT] =3D { .name =3D "port", .type =3D YNL_PT_= U32, }, > + [NFSD_A_SERVER_INSTANCE_INET_PROTO] =3D { .name =3D "inet-proto", .type= =3D YNL_PT_U16, }, > +}; > + > +struct ynl_policy_nest nfsd_server_instance_nest =3D { > + .max_attr =3D NFSD_A_SERVER_INSTANCE_MAX, > + .table =3D nfsd_server_instance_policy, > +}; > + > struct ynl_policy_attr nfsd_rpc_status_policy[NFSD_A_RPC_STATUS_MAX + 1]= =3D { > [NFSD_A_RPC_STATUS_XID] =3D { .name =3D "xid", .type =3D YNL_PT_U32, }, > [NFSD_A_RPC_STATUS_FLAGS] =3D { .name =3D "flags", .type =3D YNL_PT_U32= , }, > @@ -79,6 +92,15 @@ struct ynl_policy_nest nfsd_server_proto_nest =3D { > .table =3D nfsd_server_proto_policy, > }; > =20 > +struct ynl_policy_attr nfsd_server_listener_policy[NFSD_A_SERVER_LISTENE= R_MAX + 1] =3D { > + [NFSD_A_SERVER_LISTENER_INSTANCE] =3D { .name =3D "instance", .type =3D= YNL_PT_NEST, .nest =3D &nfsd_server_instance_nest, }, > +}; > + > +struct ynl_policy_nest nfsd_server_listener_nest =3D { > + .max_attr =3D NFSD_A_SERVER_LISTENER_MAX, > + .table =3D nfsd_server_listener_policy, > +}; > + > /* Common nested types */ > void nfsd_nfs_version_free(struct nfsd_nfs_version *obj) > { > @@ -124,6 +146,64 @@ int nfsd_nfs_version_parse(struct ynl_parse_arg *yar= g, > return 0; > } > =20 > +void nfsd_server_instance_free(struct nfsd_server_instance *obj) > +{ > + free(obj->transport_name); > +} > + > +int nfsd_server_instance_put(struct nlmsghdr *nlh, unsigned int attr_typ= e, > + struct nfsd_server_instance *obj) > +{ > + struct nlattr *nest; > + > + nest =3D mnl_attr_nest_start(nlh, attr_type); > + if (obj->_present.transport_name_len) > + mnl_attr_put_strz(nlh, NFSD_A_SERVER_INSTANCE_TRANSPORT_NAME, obj->tra= nsport_name); > + if (obj->_present.port) > + mnl_attr_put_u32(nlh, NFSD_A_SERVER_INSTANCE_PORT, obj->port); > + if (obj->_present.inet_proto) > + mnl_attr_put_u16(nlh, NFSD_A_SERVER_INSTANCE_INET_PROTO, obj->inet_pro= to); > + mnl_attr_nest_end(nlh, nest); > + > + return 0; > +} > + > +int nfsd_server_instance_parse(struct ynl_parse_arg *yarg, > + const struct nlattr *nested) > +{ > + struct nfsd_server_instance *dst =3D yarg->data; > + const struct nlattr *attr; > + > + mnl_attr_for_each_nested(attr, nested) { > + unsigned int type =3D mnl_attr_get_type(attr); > + > + if (type =3D=3D NFSD_A_SERVER_INSTANCE_TRANSPORT_NAME) { > + unsigned int len; > + > + if (ynl_attr_validate(yarg, attr)) > + return MNL_CB_ERROR; > + > + len =3D strnlen(mnl_attr_get_str(attr), mnl_attr_get_payload_len(attr= )); > + dst->_present.transport_name_len =3D len; > + dst->transport_name =3D malloc(len + 1); > + memcpy(dst->transport_name, mnl_attr_get_str(attr), len); > + dst->transport_name[len] =3D 0; > + } else if (type =3D=3D NFSD_A_SERVER_INSTANCE_PORT) { > + if (ynl_attr_validate(yarg, attr)) > + return MNL_CB_ERROR; > + dst->_present.port =3D 1; > + dst->port =3D mnl_attr_get_u32(attr); > + } else if (type =3D=3D NFSD_A_SERVER_INSTANCE_INET_PROTO) { > + if (ynl_attr_validate(yarg, attr)) > + return MNL_CB_ERROR; > + dst->_present.inet_proto =3D 1; > + dst->inet_proto =3D mnl_attr_get_u16(attr); > + } > + } > + > + return 0; > +} > + > /* =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D NFSD_CMD_RPC_STATUS_GET = =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D */ > /* NFSD_CMD_RPC_STATUS_GET - dump */ > int nfsd_rpc_status_get_rsp_dump_parse(const struct nlmsghdr *nlh, void = *data) > @@ -467,6 +547,117 @@ struct nfsd_version_get_rsp *nfsd_version_get(struc= t ynl_sock *ys) > return NULL; > } > =20 > +/* =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D NFSD_CMD_LISTENER_SET =3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D */ > +/* NFSD_CMD_LISTENER_SET - do */ > +void nfsd_listener_set_req_free(struct nfsd_listener_set_req *req) > +{ > + unsigned int i; > + > + for (i =3D 0; i < req->n_instance; i++) > + nfsd_server_instance_free(&req->instance[i]); > + free(req->instance); > + free(req); > +} > + > +int nfsd_listener_set(struct ynl_sock *ys, struct nfsd_listener_set_req = *req) > +{ > + struct ynl_req_state yrs =3D { .yarg =3D { .ys =3D ys, }, }; > + struct nlmsghdr *nlh; > + int err; > + > + nlh =3D ynl_gemsg_start_req(ys, ys->family_id, NFSD_CMD_LISTENER_SET, 1= ); > + ys->req_policy =3D &nfsd_server_listener_nest; > + > + for (unsigned int i =3D 0; i < req->n_instance; i++) > + nfsd_server_instance_put(nlh, NFSD_A_SERVER_LISTENER_INSTANCE, &req->i= nstance[i]); > + > + err =3D ynl_exec(ys, nlh, &yrs); > + if (err < 0) > + return -1; > + > + return 0; > +} > + > +/* =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D NFSD_CMD_LISTENER_GET =3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D */ > +/* NFSD_CMD_LISTENER_GET - do */ > +void nfsd_listener_get_rsp_free(struct nfsd_listener_get_rsp *rsp) > +{ > + unsigned int i; > + > + for (i =3D 0; i < rsp->n_instance; i++) > + nfsd_server_instance_free(&rsp->instance[i]); > + free(rsp->instance); > + free(rsp); > +} > + > +int nfsd_listener_get_rsp_parse(const struct nlmsghdr *nlh, void *data) > +{ > + struct nfsd_listener_get_rsp *dst; > + struct ynl_parse_arg *yarg =3D data; > + unsigned int n_instance =3D 0; > + const struct nlattr *attr; > + struct ynl_parse_arg parg; > + int i; > + > + dst =3D yarg->data; > + parg.ys =3D yarg->ys; > + > + if (dst->instance) > + return ynl_error_parse(yarg, "attribute already present (server-listen= er.instance)"); > + > + mnl_attr_for_each(attr, nlh, sizeof(struct genlmsghdr)) { > + unsigned int type =3D mnl_attr_get_type(attr); > + > + if (type =3D=3D NFSD_A_SERVER_LISTENER_INSTANCE) { > + n_instance++; > + } > + } > + > + if (n_instance) { > + dst->instance =3D calloc(n_instance, sizeof(*dst->instance)); > + dst->n_instance =3D n_instance; > + i =3D 0; > + parg.rsp_policy =3D &nfsd_server_instance_nest; > + mnl_attr_for_each(attr, nlh, sizeof(struct genlmsghdr)) { > + if (mnl_attr_get_type(attr) =3D=3D NFSD_A_SERVER_LISTENER_INSTANCE) { > + parg.data =3D &dst->instance[i]; > + if (nfsd_server_instance_parse(&parg, attr)) > + return MNL_CB_ERROR; > + i++; > + } > + } > + } > + > + return MNL_CB_OK; > +} > + > +struct nfsd_listener_get_rsp *nfsd_listener_get(struct ynl_sock *ys) > +{ > + struct ynl_req_state yrs =3D { .yarg =3D { .ys =3D ys, }, }; > + struct nfsd_listener_get_rsp *rsp; > + struct nlmsghdr *nlh; > + int err; > + > + nlh =3D ynl_gemsg_start_req(ys, ys->family_id, NFSD_CMD_LISTENER_GET, 1= ); > + ys->req_policy =3D &nfsd_server_listener_nest; > + yrs.yarg.rsp_policy =3D &nfsd_server_listener_nest; > + > + rsp =3D calloc(1, sizeof(*rsp)); > + yrs.yarg.data =3D rsp; > + yrs.cb =3D nfsd_listener_get_rsp_parse; > + yrs.rsp_cmd =3D NFSD_CMD_LISTENER_GET; > + > + err =3D ynl_exec(ys, nlh, &yrs); > + if (err < 0) > + goto err_free; > + > + return rsp; > + > +err_free: > + nfsd_listener_get_rsp_free(rsp); > + return NULL; > +} > + > const struct ynl_family ynl_nfsd_family =3D { > .name =3D "nfsd", > }; > diff --git a/tools/net/ynl/generated/nfsd-user.h b/tools/net/ynl/generate= d/nfsd-user.h > index d062ee8fa8b6..5765fb6f2ef5 100644 > --- a/tools/net/ynl/generated/nfsd-user.h > +++ b/tools/net/ynl/generated/nfsd-user.h > @@ -29,6 +29,18 @@ struct nfsd_nfs_version { > __u32 minor; > }; > =20 > +struct nfsd_server_instance { > + struct { > + __u32 transport_name_len; > + __u32 port:1; > + __u32 inet_proto:1; > + } _present; > + > + char *transport_name; > + __u32 port; > + __u16 inet_proto; > +}; > + > /* =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D NFSD_CMD_RPC_STATUS_GET = =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D */ > /* NFSD_CMD_RPC_STATUS_GET - dump */ > struct nfsd_rpc_status_get_rsp_dump { > @@ -164,4 +176,47 @@ void nfsd_version_get_rsp_free(struct nfsd_version_g= et_rsp *rsp); > */ > struct nfsd_version_get_rsp *nfsd_version_get(struct ynl_sock *ys); > =20 > +/* =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D NFSD_CMD_LISTENER_SET =3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D */ > +/* NFSD_CMD_LISTENER_SET - do */ > +struct nfsd_listener_set_req { > + unsigned int n_instance; > + struct nfsd_server_instance *instance; > +}; > + > +static inline struct nfsd_listener_set_req *nfsd_listener_set_req_alloc(= void) > +{ > + return calloc(1, sizeof(struct nfsd_listener_set_req)); > +} > +void nfsd_listener_set_req_free(struct nfsd_listener_set_req *req); > + > +static inline void > +__nfsd_listener_set_req_set_instance(struct nfsd_listener_set_req *req, > + struct nfsd_server_instance *instance, > + unsigned int n_instance) > +{ > + free(req->instance); > + req->instance =3D instance; > + req->n_instance =3D n_instance; > +} > + > +/* > + * set nfs running listeners > + */ > +int nfsd_listener_set(struct ynl_sock *ys, struct nfsd_listener_set_req = *req); > + > +/* =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D NFSD_CMD_LISTENER_GET =3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D */ > +/* NFSD_CMD_LISTENER_GET - do */ > + > +struct nfsd_listener_get_rsp { > + unsigned int n_instance; > + struct nfsd_server_instance *instance; > +}; > + > +void nfsd_listener_get_rsp_free(struct nfsd_listener_get_rsp *rsp); > + > +/* > + * get nfs running listeners > + */ > +struct nfsd_listener_get_rsp *nfsd_listener_get(struct ynl_sock *ys); > + > #endif /* _LINUX_NFSD_GEN_H */ --=20 Jeff Layton