Commit 566052c5 authored by Fred Isaman's avatar Fred Isaman Committed by Trond Myklebust

pnfs: add prefix to struct pnfs_layout_segment fields

While we are renaming all the fields, change lo->state to lo->plh_flags.
Signed-off-by: default avatarFred Isaman <iisaman@netapp.com>
Signed-off-by: default avatarTrond Myklebust <Trond.Myklebust@netapp.com>
parent daaa82d1
...@@ -243,7 +243,7 @@ filelayout_alloc_lseg(struct pnfs_layout_hdr *layoutid, ...@@ -243,7 +243,7 @@ filelayout_alloc_lseg(struct pnfs_layout_hdr *layoutid,
static void static void
filelayout_free_lseg(struct pnfs_layout_segment *lseg) filelayout_free_lseg(struct pnfs_layout_segment *lseg)
{ {
struct nfs_server *nfss = NFS_SERVER(lseg->layout->inode); struct nfs_server *nfss = NFS_SERVER(lseg->pls_layout->inode);
struct nfs4_filelayout_segment *fl = FILELAYOUT_LSEG(lseg); struct nfs4_filelayout_segment *fl = FILELAYOUT_LSEG(lseg);
dprintk("--> %s\n", __func__); dprintk("--> %s\n", __func__);
......
...@@ -210,9 +210,9 @@ put_layout_hdr(struct inode *inode) ...@@ -210,9 +210,9 @@ put_layout_hdr(struct inode *inode)
static void static void
init_lseg(struct pnfs_layout_hdr *lo, struct pnfs_layout_segment *lseg) init_lseg(struct pnfs_layout_hdr *lo, struct pnfs_layout_segment *lseg)
{ {
INIT_LIST_HEAD(&lseg->fi_list); INIT_LIST_HEAD(&lseg->pls_list);
kref_init(&lseg->kref); kref_init(&lseg->pls_refcount);
lseg->layout = lo; lseg->pls_layout = lo;
} }
/* Called without i_lock held, as the free_lseg call may sleep */ /* Called without i_lock held, as the free_lseg call may sleep */
...@@ -220,8 +220,8 @@ static void ...@@ -220,8 +220,8 @@ static void
destroy_lseg(struct kref *kref) destroy_lseg(struct kref *kref)
{ {
struct pnfs_layout_segment *lseg = struct pnfs_layout_segment *lseg =
container_of(kref, struct pnfs_layout_segment, kref); container_of(kref, struct pnfs_layout_segment, pls_refcount);
struct inode *ino = lseg->layout->inode; struct inode *ino = lseg->pls_layout->inode;
dprintk("--> %s\n", __func__); dprintk("--> %s\n", __func__);
NFS_SERVER(ino)->pnfs_curr_ld->free_lseg(lseg); NFS_SERVER(ino)->pnfs_curr_ld->free_lseg(lseg);
...@@ -236,8 +236,8 @@ put_lseg(struct pnfs_layout_segment *lseg) ...@@ -236,8 +236,8 @@ put_lseg(struct pnfs_layout_segment *lseg)
return; return;
dprintk("%s: lseg %p ref %d\n", __func__, lseg, dprintk("%s: lseg %p ref %d\n", __func__, lseg,
atomic_read(&lseg->kref.refcount)); atomic_read(&lseg->pls_refcount.refcount));
kref_put(&lseg->kref, destroy_lseg); kref_put(&lseg->pls_refcount, destroy_lseg);
} }
static void static void
...@@ -249,9 +249,9 @@ pnfs_clear_lseg_list(struct pnfs_layout_hdr *lo, struct list_head *tmp_list) ...@@ -249,9 +249,9 @@ pnfs_clear_lseg_list(struct pnfs_layout_hdr *lo, struct list_head *tmp_list)
dprintk("%s:Begin lo %p\n", __func__, lo); dprintk("%s:Begin lo %p\n", __func__, lo);
assert_spin_locked(&lo->inode->i_lock); assert_spin_locked(&lo->inode->i_lock);
list_for_each_entry_safe(lseg, next, &lo->segs, fi_list) { list_for_each_entry_safe(lseg, next, &lo->segs, pls_list) {
dprintk("%s: freeing lseg %p\n", __func__, lseg); dprintk("%s: freeing lseg %p\n", __func__, lseg);
list_move(&lseg->fi_list, tmp_list); list_move(&lseg->pls_list, tmp_list);
} }
clp = NFS_SERVER(lo->inode)->nfs_client; clp = NFS_SERVER(lo->inode)->nfs_client;
spin_lock(&clp->cl_lock); spin_lock(&clp->cl_lock);
...@@ -259,7 +259,7 @@ pnfs_clear_lseg_list(struct pnfs_layout_hdr *lo, struct list_head *tmp_list) ...@@ -259,7 +259,7 @@ pnfs_clear_lseg_list(struct pnfs_layout_hdr *lo, struct list_head *tmp_list)
list_del_init(&lo->layouts); list_del_init(&lo->layouts);
spin_unlock(&clp->cl_lock); spin_unlock(&clp->cl_lock);
write_seqlock(&lo->seqlock); write_seqlock(&lo->seqlock);
clear_bit(NFS_LAYOUT_STATEID_SET, &lo->state); clear_bit(NFS_LAYOUT_STATEID_SET, &lo->plh_flags);
write_sequnlock(&lo->seqlock); write_sequnlock(&lo->seqlock);
dprintk("%s:Return\n", __func__); dprintk("%s:Return\n", __func__);
...@@ -272,9 +272,9 @@ pnfs_free_lseg_list(struct list_head *tmp_list) ...@@ -272,9 +272,9 @@ pnfs_free_lseg_list(struct list_head *tmp_list)
while (!list_empty(tmp_list)) { while (!list_empty(tmp_list)) {
lseg = list_entry(tmp_list->next, struct pnfs_layout_segment, lseg = list_entry(tmp_list->next, struct pnfs_layout_segment,
fi_list); pls_list);
dprintk("%s calling put_lseg on %p\n", __func__, lseg); dprintk("%s calling put_lseg on %p\n", __func__, lseg);
list_del(&lseg->fi_list); list_del(&lseg->pls_list);
put_lseg(lseg); put_lseg(lseg);
} }
} }
...@@ -331,7 +331,7 @@ pnfs_set_layout_stateid(struct pnfs_layout_hdr *lo, ...@@ -331,7 +331,7 @@ pnfs_set_layout_stateid(struct pnfs_layout_hdr *lo,
bool overwrite = false; bool overwrite = false;
write_seqlock(&lo->seqlock); write_seqlock(&lo->seqlock);
if (!test_bit(NFS_LAYOUT_STATEID_SET, &lo->state) || if (!test_bit(NFS_LAYOUT_STATEID_SET, &lo->plh_flags) ||
memcmp(old->stateid.other, new->stateid.other, sizeof(new->stateid.other))) memcmp(old->stateid.other, new->stateid.other, sizeof(new->stateid.other)))
overwrite = true; overwrite = true;
else { else {
...@@ -360,7 +360,7 @@ pnfs_layout_from_open_stateid(struct pnfs_layout_hdr *lo, ...@@ -360,7 +360,7 @@ pnfs_layout_from_open_stateid(struct pnfs_layout_hdr *lo,
memcpy(lo->stateid.data, state->stateid.data, memcpy(lo->stateid.data, state->stateid.data,
sizeof(state->stateid.data)); sizeof(state->stateid.data));
} while (read_seqretry(&state->seqlock, seq)); } while (read_seqretry(&state->seqlock, seq));
set_bit(NFS_LAYOUT_STATEID_SET, &lo->state); set_bit(NFS_LAYOUT_STATEID_SET, &lo->plh_flags);
write_sequnlock(&lo->seqlock); write_sequnlock(&lo->seqlock);
dprintk("<-- %s\n", __func__); dprintk("<-- %s\n", __func__);
} }
...@@ -374,7 +374,7 @@ pnfs_get_layout_stateid(nfs4_stateid *dst, struct pnfs_layout_hdr *lo, ...@@ -374,7 +374,7 @@ pnfs_get_layout_stateid(nfs4_stateid *dst, struct pnfs_layout_hdr *lo,
dprintk("--> %s\n", __func__); dprintk("--> %s\n", __func__);
do { do {
seq = read_seqbegin(&lo->seqlock); seq = read_seqbegin(&lo->seqlock);
if (!test_bit(NFS_LAYOUT_STATEID_SET, &lo->state)) { if (!test_bit(NFS_LAYOUT_STATEID_SET, &lo->plh_flags)) {
/* This will trigger retry of the read */ /* This will trigger retry of the read */
pnfs_layout_from_open_stateid(lo, open_state); pnfs_layout_from_open_stateid(lo, open_state);
} else } else
...@@ -424,7 +424,7 @@ send_layoutget(struct pnfs_layout_hdr *lo, ...@@ -424,7 +424,7 @@ send_layoutget(struct pnfs_layout_hdr *lo,
nfs4_proc_layoutget(lgp); nfs4_proc_layoutget(lgp);
if (!lseg) { if (!lseg) {
/* remember that LAYOUTGET failed and suspend trying */ /* remember that LAYOUTGET failed and suspend trying */
set_bit(lo_fail_bit(iomode), &lo->state); set_bit(lo_fail_bit(iomode), &lo->plh_flags);
} }
return lseg; return lseg;
} }
...@@ -459,26 +459,26 @@ pnfs_insert_layout(struct pnfs_layout_hdr *lo, ...@@ -459,26 +459,26 @@ pnfs_insert_layout(struct pnfs_layout_hdr *lo,
list_add_tail(&lo->layouts, &clp->cl_layouts); list_add_tail(&lo->layouts, &clp->cl_layouts);
spin_unlock(&clp->cl_lock); spin_unlock(&clp->cl_lock);
} }
list_for_each_entry(lp, &lo->segs, fi_list) { list_for_each_entry(lp, &lo->segs, pls_list) {
if (cmp_layout(lp->range.iomode, lseg->range.iomode) > 0) if (cmp_layout(lp->pls_range.iomode, lseg->pls_range.iomode) > 0)
continue; continue;
list_add_tail(&lseg->fi_list, &lp->fi_list); list_add_tail(&lseg->pls_list, &lp->pls_list);
dprintk("%s: inserted lseg %p " dprintk("%s: inserted lseg %p "
"iomode %d offset %llu length %llu before " "iomode %d offset %llu length %llu before "
"lp %p iomode %d offset %llu length %llu\n", "lp %p iomode %d offset %llu length %llu\n",
__func__, lseg, lseg->range.iomode, __func__, lseg, lseg->pls_range.iomode,
lseg->range.offset, lseg->range.length, lseg->pls_range.offset, lseg->pls_range.length,
lp, lp->range.iomode, lp->range.offset, lp, lp->pls_range.iomode, lp->pls_range.offset,
lp->range.length); lp->pls_range.length);
found = 1; found = 1;
break; break;
} }
if (!found) { if (!found) {
list_add_tail(&lseg->fi_list, &lo->segs); list_add_tail(&lseg->pls_list, &lo->segs);
dprintk("%s: inserted lseg %p " dprintk("%s: inserted lseg %p "
"iomode %d offset %llu length %llu at tail\n", "iomode %d offset %llu length %llu at tail\n",
__func__, lseg, lseg->range.iomode, __func__, lseg, lseg->pls_range.iomode,
lseg->range.offset, lseg->range.length); lseg->pls_range.offset, lseg->pls_range.length);
} }
get_layout_hdr_locked(lo); get_layout_hdr_locked(lo);
...@@ -538,7 +538,7 @@ pnfs_find_alloc_layout(struct inode *ino) ...@@ -538,7 +538,7 @@ pnfs_find_alloc_layout(struct inode *ino)
static int static int
is_matching_lseg(struct pnfs_layout_segment *lseg, u32 iomode) is_matching_lseg(struct pnfs_layout_segment *lseg, u32 iomode)
{ {
return (iomode != IOMODE_RW || lseg->range.iomode == IOMODE_RW); return (iomode != IOMODE_RW || lseg->pls_range.iomode == IOMODE_RW);
} }
/* /*
...@@ -552,17 +552,17 @@ pnfs_has_layout(struct pnfs_layout_hdr *lo, u32 iomode) ...@@ -552,17 +552,17 @@ pnfs_has_layout(struct pnfs_layout_hdr *lo, u32 iomode)
dprintk("%s:Begin\n", __func__); dprintk("%s:Begin\n", __func__);
assert_spin_locked(&lo->inode->i_lock); assert_spin_locked(&lo->inode->i_lock);
list_for_each_entry(lseg, &lo->segs, fi_list) { list_for_each_entry(lseg, &lo->segs, pls_list) {
if (is_matching_lseg(lseg, iomode)) { if (is_matching_lseg(lseg, iomode)) {
ret = lseg; ret = lseg;
break; break;
} }
if (cmp_layout(iomode, lseg->range.iomode) > 0) if (cmp_layout(iomode, lseg->pls_range.iomode) > 0)
break; break;
} }
dprintk("%s:Return lseg %p ref %d\n", dprintk("%s:Return lseg %p ref %d\n",
__func__, ret, ret ? atomic_read(&ret->kref.refcount) : 0); __func__, ret, ret ? atomic_read(&ret->pls_refcount.refcount) : 0);
return ret; return ret;
} }
...@@ -597,7 +597,7 @@ pnfs_update_layout(struct inode *ino, ...@@ -597,7 +597,7 @@ pnfs_update_layout(struct inode *ino,
} }
/* if LAYOUTGET already failed once we don't try again */ /* if LAYOUTGET already failed once we don't try again */
if (test_bit(lo_fail_bit(iomode), &nfsi->layout->state)) if (test_bit(lo_fail_bit(iomode), &nfsi->layout->plh_flags))
goto out_unlock; goto out_unlock;
get_layout_hdr_locked(lo); /* Matched in nfs4_layoutget_release */ get_layout_hdr_locked(lo); /* Matched in nfs4_layoutget_release */
...@@ -606,7 +606,7 @@ pnfs_update_layout(struct inode *ino, ...@@ -606,7 +606,7 @@ pnfs_update_layout(struct inode *ino,
lseg = send_layoutget(lo, ctx, iomode); lseg = send_layoutget(lo, ctx, iomode);
out: out:
dprintk("%s end, state 0x%lx lseg %p\n", __func__, dprintk("%s end, state 0x%lx lseg %p\n", __func__,
nfsi->layout->state, lseg); nfsi->layout->plh_flags, lseg);
return lseg; return lseg;
out_unlock: out_unlock:
spin_unlock(&ino->i_lock); spin_unlock(&ino->i_lock);
...@@ -636,7 +636,7 @@ pnfs_layout_process(struct nfs4_layoutget *lgp) ...@@ -636,7 +636,7 @@ pnfs_layout_process(struct nfs4_layoutget *lgp)
spin_lock(&ino->i_lock); spin_lock(&ino->i_lock);
init_lseg(lo, lseg); init_lseg(lo, lseg);
lseg->range = res->range; lseg->pls_range = res->range;
*lgp->lsegpp = lseg; *lgp->lsegpp = lseg;
pnfs_insert_layout(lo, lseg); pnfs_insert_layout(lo, lseg);
......
...@@ -31,10 +31,10 @@ ...@@ -31,10 +31,10 @@
#define FS_NFS_PNFS_H #define FS_NFS_PNFS_H
struct pnfs_layout_segment { struct pnfs_layout_segment {
struct list_head fi_list; struct list_head pls_list;
struct pnfs_layout_range range; struct pnfs_layout_range pls_range;
struct kref kref; struct kref pls_refcount;
struct pnfs_layout_hdr *layout; struct pnfs_layout_hdr *pls_layout;
}; };
#ifdef CONFIG_NFS_V4_1 #ifdef CONFIG_NFS_V4_1
...@@ -65,7 +65,7 @@ struct pnfs_layout_hdr { ...@@ -65,7 +65,7 @@ struct pnfs_layout_hdr {
struct list_head segs; /* layout segments list */ struct list_head segs; /* layout segments list */
seqlock_t seqlock; /* Protects the stateid */ seqlock_t seqlock; /* Protects the stateid */
nfs4_stateid stateid; nfs4_stateid stateid;
unsigned long state; unsigned long plh_flags;
struct inode *inode; struct inode *inode;
}; };
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment