Received-SPF: pass (google.com: domain of linux-nfs-owner@vger.kernel.org designates 23.128.96.18 as permitted sender) client-ip=23.128.96.18;
From:   Nagendra Tomar <Nagendra.Tomar@microsoft.com>
To:     "linux-nfs@vger.kernel.org" <linux-nfs@vger.kernel.org>
CC:     Trond Myklebust <trond.myklebust@hammerspace.com>,
        "anna.schumaker@netapp.com" <anna.schumaker@netapp.com>
Subject: [PATCH 4/5] nfs: Add mount option for forcing RPC requests to one
 file over one connection
Thread-Topic: [PATCH 4/5] nfs: Add mount option for forcing RPC requests to
 one file over one connection
Thread-Index: AdcfqE88Ub7NiS+HTXGHJpvme+wyQQ==
Date:   Tue, 23 Mar 2021 05:50:09 +0000
Message-ID: <SG2P153MB036175692E2D6C18D06C3A1B9E649@SG2P153MB0361.APCP153.PROD.OUTLOOK.COM>
Accept-Language: en-IN, en-US
Content-Language: en-US
Content-Type: text/plain; charset="us-ascii"
Content-Transfer-Encoding: quoted-printable
MIME-Version: 1.0
X-MS-Exchange-CrossTenant-Network-Message-Id: 5c9e8708-32de-4ce1-9d19-08d8edbf84cd
X-MS-Exchange-CrossTenant-originalarrivaltime: 23 Mar 2021 05:50:09.2562
 (UTC)
X-MS-Exchange-CrossTenant-fromentityheader: Hosted
X-MS-Exchange-CrossTenant-id: 72f988bf-86f1-41af-91ab-2d7cd011db47
X-MS-Exchange-CrossTenant-mailboxtype: HOSTED
X-MS-Exchange-CrossTenant-userprincipalname: vh2GNmSU71oXIV9A8qjqFENhmB/TYoPJ6W47WcC9qSKnbGvioSe9xtgAtsanTQ4BSQZz8y8W74hVakbhvDiQMg==
X-MS-Exchange-Transport-CrossTenantHeadersStamped: SG2P153MB0214
Precedence: bulk
List-ID: <linux-nfs.vger.kernel.org>
X-Mailing-List: linux-nfs@vger.kernel.org

From: Nagendra S Tomar <natomar@microsoft.com>

Functions for computing target filehandles' hash for NFSv3.

Signed-off-by: Nagendra S Tomar <natomar@microsoft.com>
---
 fs/nfs/nfs3xdr.c | 154 +++++++++++++++++++++++++++++++++++++++++++++++++++=
++++
 1 file changed, 154 insertions(+)

diff --git a/fs/nfs/nfs3xdr.c b/fs/nfs/nfs3xdr.c
index ed1c83738c30..3d90686cd77d 100644
--- a/fs/nfs/nfs3xdr.c
+++ b/fs/nfs/nfs3xdr.c
@@ -817,6 +817,13 @@ static void nfs3_xdr_enc_getattr3args(struct rpc_rqst =
*req,
 	encode_nfs_fh3(xdr, fh);
 }
=20
+static u32 nfs3_fh_hash_getattr(const void *data)
+{
+	const struct nfs_fh *fh =3D data;
+
+	return jhash(fh->data, fh->size, 0);
+}
+
 /*
  * 3.3.2  SETATTR3args
  *
@@ -858,6 +865,14 @@ static void nfs3_xdr_enc_setattr3args(struct rpc_rqst =
*req,
 	encode_sattrguard3(xdr, args);
 }
=20
+static u32 nfs3_fh_hash_setattr(const void *data)
+{
+	const struct nfs3_sattrargs *args =3D data;
+	const struct nfs_fh *fh =3D args->fh;
+
+	return jhash(fh->data, fh->size, 0);
+}
+
 /*
  * 3.3.3  LOOKUP3args
  *
@@ -874,6 +889,14 @@ static void nfs3_xdr_enc_lookup3args(struct rpc_rqst *=
req,
 	encode_diropargs3(xdr, args->fh, args->name, args->len);
 }
=20
+static u32 nfs3_fh_hash_lookup(const void *data)
+{
+	const struct nfs3_diropargs *args =3D data;
+	const struct nfs_fh *fh =3D args->fh;
+
+	return jhash(fh->data, fh->size, 0);
+}
+
 /*
  * 3.3.4  ACCESS3args
  *
@@ -898,6 +921,14 @@ static void nfs3_xdr_enc_access3args(struct rpc_rqst *=
req,
 	encode_access3args(xdr, args);
 }
=20
+static u32 nfs3_fh_hash_access(const void *data)
+{
+	const struct nfs3_accessargs *args =3D data;
+	const struct nfs_fh *fh =3D args->fh;
+
+	return jhash(fh->data, fh->size, 0);
+}
+
 /*
  * 3.3.5  READLINK3args
  *
@@ -916,6 +947,14 @@ static void nfs3_xdr_enc_readlink3args(struct rpc_rqst=
 *req,
 				NFS3_readlinkres_sz - NFS3_pagepad_sz);
 }
=20
+static u32 nfs3_fh_hash_readlink(const void *data)
+{
+	const struct nfs3_readlinkargs *args =3D data;
+	const struct nfs_fh *fh =3D args->fh;
+
+	return jhash(fh->data, fh->size, 0);
+}
+
 /*
  * 3.3.6  READ3args
  *
@@ -951,6 +990,14 @@ static void nfs3_xdr_enc_read3args(struct rpc_rqst *re=
q,
 	req->rq_rcv_buf.flags |=3D XDRBUF_READ;
 }
=20
+static u32 nfs3_fh_hash_read(const void *data)
+{
+	const struct nfs_pgio_args *args =3D data;
+	const struct nfs_fh *fh =3D args->fh;
+
+	return jhash(fh->data, fh->size, 0);
+}
+
 /*
  * 3.3.7  WRITE3args
  *
@@ -993,6 +1040,14 @@ static void nfs3_xdr_enc_write3args(struct rpc_rqst *=
req,
 	xdr->buf->flags |=3D XDRBUF_WRITE;
 }
=20
+static u32 nfs3_fh_hash_write(const void *data)
+{
+	const struct nfs_pgio_args *args =3D data;
+	const struct nfs_fh *fh =3D args->fh;
+
+	return jhash(fh->data, fh->size, 0);
+}
+
 /*
  * 3.3.8  CREATE3args
  *
@@ -1043,6 +1098,14 @@ static void nfs3_xdr_enc_create3args(struct rpc_rqst=
 *req,
 	encode_createhow3(xdr, args, rpc_rqst_userns(req));
 }
=20
+static u32 nfs3_fh_hash_create(const void *data)
+{
+	const struct nfs3_createargs *args =3D data;
+	const struct nfs_fh *fh =3D args->fh;
+
+	return jhash(fh->data, fh->size, 0);
+}
+
 /*
  * 3.3.9  MKDIR3args
  *
@@ -1061,6 +1124,14 @@ static void nfs3_xdr_enc_mkdir3args(struct rpc_rqst =
*req,
 	encode_sattr3(xdr, args->sattr, rpc_rqst_userns(req));
 }
=20
+static u32 nfs3_fh_hash_mkdir(const void *data)
+{
+	const struct nfs3_mkdirargs *args =3D data;
+	const struct nfs_fh *fh =3D args->fh;
+
+	return jhash(fh->data, fh->size, 0);
+}
+
 /*
  * 3.3.10  SYMLINK3args
  *
@@ -1095,6 +1166,14 @@ static void nfs3_xdr_enc_symlink3args(struct rpc_rqs=
t *req,
 	xdr->buf->flags |=3D XDRBUF_WRITE;
 }
=20
+static u32 nfs3_fh_hash_symlink(const void *data)
+{
+	const struct nfs3_symlinkargs *args =3D data;
+	const struct nfs_fh *fh =3D args->fromfh;
+
+	return jhash(fh->data, fh->size, 0);
+}
+
 /*
  * 3.3.11  MKNOD3args
  *
@@ -1159,6 +1238,14 @@ static void nfs3_xdr_enc_mknod3args(struct rpc_rqst =
*req,
 	encode_mknoddata3(xdr, args, rpc_rqst_userns(req));
 }
=20
+static u32 nfs3_fh_hash_mknod(const void *data)
+{
+	const struct nfs3_mknodargs *args =3D data;
+	const struct nfs_fh *fh =3D args->fh;
+
+	return jhash(fh->data, fh->size, 0);
+}
+
 /*
  * 3.3.12  REMOVE3args
  *
@@ -1175,6 +1262,14 @@ static void nfs3_xdr_enc_remove3args(struct rpc_rqst=
 *req,
 	encode_diropargs3(xdr, args->fh, args->name.name, args->name.len);
 }
=20
+static u32 nfs3_fh_hash_remove(const void *data)
+{
+	const struct nfs_removeargs *args =3D data;
+	const struct nfs_fh *fh =3D args->fh;
+
+	return jhash(fh->data, fh->size, 0);
+}
+
 /*
  * 3.3.14  RENAME3args
  *
@@ -1195,6 +1290,14 @@ static void nfs3_xdr_enc_rename3args(struct rpc_rqst=
 *req,
 	encode_diropargs3(xdr, args->new_dir, new->name, new->len);
 }
=20
+static u32 nfs3_fh_hash_rename(const void *data)
+{
+	const struct nfs_renameargs *args =3D data;
+	const struct nfs_fh *fh =3D args->old_dir;
+
+	return jhash(fh->data, fh->size, 0);
+}
+
 /*
  * 3.3.15  LINK3args
  *
@@ -1213,6 +1316,14 @@ static void nfs3_xdr_enc_link3args(struct rpc_rqst *=
req,
 	encode_diropargs3(xdr, args->tofh, args->toname, args->tolen);
 }
=20
+static u32 nfs3_fh_hash_link(const void *data)
+{
+	const struct nfs3_linkargs *args =3D data;
+	const struct nfs_fh *fh =3D args->tofh;
+
+	return jhash(fh->data, fh->size, 0);
+}
+
 /*
  * 3.3.16  READDIR3args
  *
@@ -1247,6 +1358,14 @@ static void nfs3_xdr_enc_readdir3args(struct rpc_rqs=
t *req,
 				NFS3_readdirres_sz - NFS3_pagepad_sz);
 }
=20
+static u32 nfs3_fh_hash_readdir(const void *data)
+{
+	const struct nfs3_readdirargs *args =3D data;
+	struct nfs_fh *fh =3D args->fh;
+
+	return jhash(fh->data, fh->size, 0);
+}
+
 /*
  * 3.3.17  READDIRPLUS3args
  *
@@ -1289,6 +1408,14 @@ static void nfs3_xdr_enc_readdirplus3args(struct rpc=
_rqst *req,
 				NFS3_readdirres_sz - NFS3_pagepad_sz);
 }
=20
+static u32 nfs3_fh_hash_readdirplus(const void *data)
+{
+	const struct nfs3_readdirargs *args =3D data;
+	const struct nfs_fh *fh =3D args->fh;
+
+	return jhash(fh->data, fh->size, 0);
+}
+
 /*
  * 3.3.21  COMMIT3args
  *
@@ -1319,6 +1446,14 @@ static void nfs3_xdr_enc_commit3args(struct rpc_rqst=
 *req,
 	encode_commit3args(xdr, args);
 }
=20
+static u32 nfs3_fh_hash_commit(const void *data)
+{
+	const struct nfs_commitargs *args =3D data;
+	const struct nfs_fh *fh =3D args->fh;
+
+	return jhash(fh->data, fh->size, 0);
+}
+
 #ifdef CONFIG_NFS_V3_ACL
=20
 static void nfs3_xdr_enc_getacl3args(struct rpc_rqst *req,
@@ -1337,6 +1472,14 @@ static void nfs3_xdr_enc_getacl3args(struct rpc_rqst=
 *req,
 	}
 }
=20
+static u32 nfs3_fh_hash_getacl(const void *data)
+{
+	const struct nfs3_getaclargs *args =3D data;
+	const struct nfs_fh *fh =3D args->fh;
+
+	return jhash(fh->data, fh->size, 0);
+}
+
 static void nfs3_xdr_enc_setacl3args(struct rpc_rqst *req,
 				     struct xdr_stream *xdr,
 				     const void *data)
@@ -1366,6 +1509,14 @@ static void nfs3_xdr_enc_setacl3args(struct rpc_rqst=
 *req,
 	BUG_ON(error < 0);
 }
=20
+static u32 nfs3_fh_hash_setacl(const void *data)
+{
+	const struct nfs3_setaclargs *args =3D data;
+	const struct nfs_fh *fh =3D NFS_FH(args->inode);
+
+	return jhash(fh->data, fh->size, 0);
+}
+
 #endif  /* CONFIG_NFS_V3_ACL */
=20
 /*
@@ -2517,6 +2668,7 @@ static int nfs3_stat_to_errno(enum nfs_stat status)
 	.p_proc      =3D NFS3PROC_##proc,					\
 	.p_encode    =3D nfs3_xdr_enc_##argtype##3args,			\
 	.p_decode    =3D nfs3_xdr_dec_##restype##3res,			\
+	.p_fhhash    =3D nfs3_fh_hash_##argtype,				\
 	.p_arglen    =3D NFS3_##argtype##args_sz,				\
 	.p_replen    =3D NFS3_##restype##res_sz,				\
 	.p_timer     =3D timer,						\
@@ -2562,6 +2714,7 @@ static const struct rpc_procinfo nfs3_acl_procedures[=
] =3D {
 		.p_proc =3D ACLPROC3_GETACL,
 		.p_encode =3D nfs3_xdr_enc_getacl3args,
 		.p_decode =3D nfs3_xdr_dec_getacl3res,
+		.p_fhhash =3D nfs3_fh_hash_getacl,
 		.p_arglen =3D ACL3_getaclargs_sz,
 		.p_replen =3D ACL3_getaclres_sz,
 		.p_timer =3D 1,
@@ -2571,6 +2724,7 @@ static const struct rpc_procinfo nfs3_acl_procedures[=
] =3D {
 		.p_proc =3D ACLPROC3_SETACL,
 		.p_encode =3D nfs3_xdr_enc_setacl3args,
 		.p_decode =3D nfs3_xdr_dec_setacl3res,
+		.p_fhhash =3D nfs3_fh_hash_setacl,
 		.p_arglen =3D ACL3_setaclargs_sz,
 		.p_replen =3D ACL3_setaclres_sz,
 		.p_timer =3D 0,