pnfs/flexfiles: Fix misplaced barrier in nfs4_ff_layout_prepare_ds
[ Upstream commit a2915fa06227b056a8f9b0d79b61dca08ad5cfc6 ]
_nfs4_pnfs_v3/v4_ds_connect do
some work
smp_wmb
ds->ds_clp = clp;
And nfs4_ff_layout_prepare_ds currently does
smp_rmb
if(ds->ds_clp)
...
This patch places the smp_rmb after the if. This ensures that following
reads only happen once nfs4_ff_layout_prepare_ds has checked that data
has been properly initialized.
Fixes: d67ae825a5
("pnfs/flexfiles: Add the FlexFile Layout Driver")
Signed-off-by: Baptiste Lepers <baptiste.lepers@gmail.com>
Signed-off-by: Trond Myklebust <trond.myklebust@hammerspace.com>
Signed-off-by: Sasha Levin <sashal@kernel.org>
This commit is contained in:
parent
2b2fdb6f48
commit
4b48c6ede3
@ -378,10 +378,10 @@ nfs4_ff_layout_prepare_ds(struct pnfs_layout_segment *lseg,
|
|||||||
goto noconnect;
|
goto noconnect;
|
||||||
|
|
||||||
ds = mirror->mirror_ds->ds;
|
ds = mirror->mirror_ds->ds;
|
||||||
|
if (READ_ONCE(ds->ds_clp))
|
||||||
|
goto out;
|
||||||
/* matching smp_wmb() in _nfs4_pnfs_v3/4_ds_connect */
|
/* matching smp_wmb() in _nfs4_pnfs_v3/4_ds_connect */
|
||||||
smp_rmb();
|
smp_rmb();
|
||||||
if (ds->ds_clp)
|
|
||||||
goto out;
|
|
||||||
|
|
||||||
/* FIXME: For now we assume the server sent only one version of NFS
|
/* FIXME: For now we assume the server sent only one version of NFS
|
||||||
* to use for the DS.
|
* to use for the DS.
|
||||||
|
@ -641,7 +641,7 @@ static int _nfs4_pnfs_v3_ds_connect(struct nfs_server *mds_srv,
|
|||||||
}
|
}
|
||||||
|
|
||||||
smp_wmb();
|
smp_wmb();
|
||||||
ds->ds_clp = clp;
|
WRITE_ONCE(ds->ds_clp, clp);
|
||||||
dprintk("%s [new] addr: %s\n", __func__, ds->ds_remotestr);
|
dprintk("%s [new] addr: %s\n", __func__, ds->ds_remotestr);
|
||||||
out:
|
out:
|
||||||
return status;
|
return status;
|
||||||
@ -714,7 +714,7 @@ static int _nfs4_pnfs_v4_ds_connect(struct nfs_server *mds_srv,
|
|||||||
}
|
}
|
||||||
|
|
||||||
smp_wmb();
|
smp_wmb();
|
||||||
ds->ds_clp = clp;
|
WRITE_ONCE(ds->ds_clp, clp);
|
||||||
dprintk("%s [new] addr: %s\n", __func__, ds->ds_remotestr);
|
dprintk("%s [new] addr: %s\n", __func__, ds->ds_remotestr);
|
||||||
out:
|
out:
|
||||||
return status;
|
return status;
|
||||||
|
Loading…
Reference in New Issue
Block a user