diff options
author | Andy Adamson <andros@netapp.com> | 2012-04-27 17:53:49 -0400 |
---|---|---|
committer | Trond Myklebust <Trond.Myklebust@netapp.com> | 2012-05-19 17:55:31 -0400 |
commit | 671fb89695fee0c70a969371efd38ed30be76a8a (patch) | |
tree | 9feb369b1063a0fa038d21d5022384243f8f5edb /fs/nfs/nfs4filelayout.c | |
parent | 0ad2f378e1af7996d6f8355c02181ff3cc7ab260 (diff) |
NFSv4.1 wake up all tasks on un-connected DS slot table waitq
The DS has a connection error (invalid deviceid). Drain the fore channel
slot table waitq.
Signed-off-by: Andy Adamson <andros@netapp.com>
Signed-off-by: Trond Myklebust <Trond.Myklebust@netapp.com>
Diffstat (limited to 'fs/nfs/nfs4filelayout.c')
-rw-r--r-- | fs/nfs/nfs4filelayout.c | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/fs/nfs/nfs4filelayout.c b/fs/nfs/nfs4filelayout.c index 1b9bedb89620..a63062d3882f 100644 --- a/fs/nfs/nfs4filelayout.c +++ b/fs/nfs/nfs4filelayout.c | |||
@@ -133,6 +133,7 @@ static int filelayout_async_handle_error(struct rpc_task *task, | |||
133 | struct nfs_server *mds_server = NFS_SERVER(inode); | 133 | struct nfs_server *mds_server = NFS_SERVER(inode); |
134 | struct nfs4_deviceid_node *devid = FILELAYOUT_DEVID_NODE(lseg); | 134 | struct nfs4_deviceid_node *devid = FILELAYOUT_DEVID_NODE(lseg); |
135 | struct nfs_client *mds_client = mds_server->nfs_client; | 135 | struct nfs_client *mds_client = mds_server->nfs_client; |
136 | struct nfs4_slot_table *tbl = &clp->cl_session->fc_slot_table; | ||
136 | 137 | ||
137 | if (task->tk_status >= 0) | 138 | if (task->tk_status >= 0) |
138 | return 0; | 139 | return 0; |
@@ -186,6 +187,7 @@ static int filelayout_async_handle_error(struct rpc_task *task, | |||
186 | dprintk("%s DS connection error %d\n", __func__, | 187 | dprintk("%s DS connection error %d\n", __func__, |
187 | task->tk_status); | 188 | task->tk_status); |
188 | filelayout_mark_devid_invalid(devid); | 189 | filelayout_mark_devid_invalid(devid); |
190 | rpc_wake_up(&tbl->slot_tbl_waitq); | ||
189 | /* fall through */ | 191 | /* fall through */ |
190 | default: | 192 | default: |
191 | dprintk("%s Retry through MDS. Error %d\n", __func__, | 193 | dprintk("%s Retry through MDS. Error %d\n", __func__, |