Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history
yaml
---
r: 346594
b: refs/heads/master
c: 69d206b
h: refs/heads/master
v: v3
  • Loading branch information
Trond Myklebust authored and Trond Myklebust committed Dec 5, 2012
1 parent 1bec98b commit ff296c4
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 7 deletions.
2 changes: 1 addition & 1 deletion [refs]
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
---
refs/heads/master: ac0748359a55faf4618f5f0bd9f9bf967c41d218
refs/heads/master: 69d206b5b39e298755b60e8e7056cb240182eb95
17 changes: 11 additions & 6 deletions trunk/fs/nfs/nfs4proc.c
Original file line number Diff line number Diff line change
Expand Up @@ -662,7 +662,7 @@ static struct nfs4_slot *nfs4_find_or_create_slot(struct nfs4_slot_table *tbl,
return slot;
p = &slot->next;
}
return NULL;
return ERR_PTR(-ENOMEM);
}

/*
Expand All @@ -676,7 +676,7 @@ static struct nfs4_slot *nfs4_find_or_create_slot(struct nfs4_slot_table *tbl,
*/
static struct nfs4_slot *nfs4_alloc_slot(struct nfs4_slot_table *tbl)
{
struct nfs4_slot *ret = NULL;
struct nfs4_slot *ret = ERR_PTR(-EBUSY);
u32 slotid;

dprintk("--> %s used_slots=%04lx highest_used=%u max_slots=%u\n",
Expand All @@ -686,7 +686,7 @@ static struct nfs4_slot *nfs4_alloc_slot(struct nfs4_slot_table *tbl)
if (slotid > tbl->max_slotid)
goto out;
ret = nfs4_find_or_create_slot(tbl, slotid, 1, GFP_NOWAIT);
if (ret == NULL)
if (IS_ERR(ret))
goto out;
__set_bit(slotid, tbl->used_slots);
if (slotid > tbl->highest_used_slotid ||
Expand All @@ -698,7 +698,7 @@ static struct nfs4_slot *nfs4_alloc_slot(struct nfs4_slot_table *tbl)
out:
dprintk("<-- %s used_slots=%04lx highest_used=%d slotid=%d \n",
__func__, tbl->used_slots[0], tbl->highest_used_slotid,
ret ? ret->slot_nr : -1);
!IS_ERR(ret) ? ret->slot_nr : -1);
return ret;
}

Expand Down Expand Up @@ -727,6 +727,8 @@ int nfs41_setup_sequence(struct nfs4_session *session,

tbl = &session->fc_slot_table;

task->tk_timeout = 0;

spin_lock(&tbl->slot_tbl_lock);
if (test_bit(NFS4_SESSION_DRAINING, &session->session_state) &&
!rpc_task_has_priority(task, RPC_PRIORITY_PRIVILEGED)) {
Expand All @@ -746,7 +748,10 @@ int nfs41_setup_sequence(struct nfs4_session *session,
}

slot = nfs4_alloc_slot(tbl);
if (slot == NULL) {
if (IS_ERR(slot)) {
/* If out of memory, try again in 1/4 second */
if (slot == ERR_PTR(-ENOMEM))
task->tk_timeout = HZ >> 2;
rpc_sleep_on(&tbl->slot_tbl_waitq, task, NULL);
spin_unlock(&tbl->slot_tbl_lock);
dprintk("<-- %s: no free slots\n", __func__);
Expand Down Expand Up @@ -5778,7 +5783,7 @@ static int nfs4_grow_slot_table(struct nfs4_slot_table *tbl,
{
if (max_reqs <= tbl->max_slots)
return 0;
if (nfs4_find_or_create_slot(tbl, max_reqs - 1, ivalue, GFP_NOFS))
if (!IS_ERR(nfs4_find_or_create_slot(tbl, max_reqs - 1, ivalue, GFP_NOFS)))
return 0;
return -ENOMEM;
}
Expand Down

0 comments on commit ff296c4

Please sign in to comment.