Skip to content

Commit

Permalink
NFSv4.1: Cleanup ugliness in pnfs_layoutgets_blocked()
Browse files Browse the repository at this point in the history
Split it into two functions, one which checks if layoutgets are blocked,
and one which checks if the layout stateid has expired.

Signed-off-by: Trond Myklebust <Trond.Myklebust@netapp.com>
  • Loading branch information
Trond Myklebust authored and Trond Myklebust committed Oct 5, 2012
1 parent 22aaf71 commit 19c54ab
Showing 1 changed file with 14 additions and 11 deletions.
25 changes: 14 additions & 11 deletions fs/nfs/pnfs.c
Original file line number Diff line number Diff line change
Expand Up @@ -583,17 +583,19 @@ pnfs_set_layout_stateid(struct pnfs_layout_hdr *lo, const nfs4_stateid *new,
}
}

/* lget is set to 1 if called from inside send_layoutget call chain */
static bool
pnfs_layoutgets_blocked(struct pnfs_layout_hdr *lo, nfs4_stateid *stateid,
int lget)
pnfs_layout_stateid_blocked(const struct pnfs_layout_hdr *lo,
const nfs4_stateid *stateid)
{
if (stateid != NULL) {
u32 seqid = be32_to_cpu(stateid->seqid);
u32 seqid = be32_to_cpu(stateid->seqid);

if (!pnfs_seqid_is_newer(seqid, lo->plh_barrier))
return true;
}
return !pnfs_seqid_is_newer(seqid, lo->plh_barrier);
}

/* lget is set to 1 if called from inside send_layoutget call chain */
static bool
pnfs_layoutgets_blocked(const struct pnfs_layout_hdr *lo, int lget)
{
return lo->plh_block_lgets ||
test_bit(NFS_LAYOUT_BULK_RECALL, &lo->plh_flags) ||
(list_empty(&lo->plh_segs) &&
Expand All @@ -608,7 +610,7 @@ pnfs_choose_layoutget_stateid(nfs4_stateid *dst, struct pnfs_layout_hdr *lo,

dprintk("--> %s\n", __func__);
spin_lock(&lo->plh_inode->i_lock);
if (pnfs_layoutgets_blocked(lo, NULL, 1)) {
if (pnfs_layoutgets_blocked(lo, 1)) {
status = -EAGAIN;
} else if (list_empty(&lo->plh_segs)) {
int seq;
Expand Down Expand Up @@ -1111,7 +1113,7 @@ pnfs_update_layout(struct inode *ino,
if (lseg)
goto out_unlock;

if (pnfs_layoutgets_blocked(lo, NULL, 0))
if (pnfs_layoutgets_blocked(lo, 0))
goto out_unlock;
atomic_inc(&lo->plh_outstanding);

Expand Down Expand Up @@ -1184,7 +1186,8 @@ pnfs_layout_process(struct nfs4_layoutget *lgp)
goto out_forget_reply;
}

if (pnfs_layoutgets_blocked(lo, &res->stateid, 1)) {
if (pnfs_layoutgets_blocked(lo, 1) ||
pnfs_layout_stateid_blocked(lo, &res->stateid)) {
dprintk("%s forget reply due to state\n", __func__);
goto out_forget_reply;
}
Expand Down

0 comments on commit 19c54ab

Please sign in to comment.