diff options
| author | Andy Adamson <andros@netapp.com> | 2009-12-04 16:02:14 -0500 |
|---|---|---|
| committer | Trond Myklebust <Trond.Myklebust@netapp.com> | 2009-12-04 16:02:14 -0500 |
| commit | 0b9e2d41f1f0360be08809d4e3bb56b67be6241a (patch) | |
| tree | 6628c9ef423cf09a76ec34b6f9db64c7ca704c38 /fs/nfs | |
| parent | 691daf3b0c410c8bcab6735796be03ea446e1924 (diff) | |
nfs41: only state manager sets NFS4CLNT_SESSION_SETUP
Replace sync and async handlers setting of the NFS4CLNT_SESSION_SETUP bit with
setting NFS4CLNT_CHECK_LEASE, and let the state manager decide to reset the session.
Signed-off-by: Andy Adamson <andros@netapp.com>
Signed-off-by: Trond Myklebust <Trond.Myklebust@netapp.com>
Diffstat (limited to 'fs/nfs')
| -rw-r--r-- | fs/nfs/nfs4proc.c | 6 | ||||
| -rw-r--r-- | fs/nfs/nfs4state.c | 4 |
2 files changed, 6 insertions, 4 deletions
diff --git a/fs/nfs/nfs4proc.c b/fs/nfs/nfs4proc.c index a0f73e99ff3d..637a6b476bd6 100644 --- a/fs/nfs/nfs4proc.c +++ b/fs/nfs/nfs4proc.c | |||
| @@ -270,7 +270,7 @@ static int nfs4_handle_exception(const struct nfs_server *server, int errorcode, | |||
| 270 | case -NFS4ERR_SEQ_MISORDERED: | 270 | case -NFS4ERR_SEQ_MISORDERED: |
| 271 | dprintk("%s ERROR: %d Reset session\n", __func__, | 271 | dprintk("%s ERROR: %d Reset session\n", __func__, |
| 272 | errorcode); | 272 | errorcode); |
| 273 | set_bit(NFS4CLNT_SESSION_RESET, &clp->cl_state); | 273 | nfs4_schedule_state_recovery(clp); |
| 274 | exception->retry = 1; | 274 | exception->retry = 1; |
| 275 | break; | 275 | break; |
| 276 | #endif /* !defined(CONFIG_NFS_V4_1) */ | 276 | #endif /* !defined(CONFIG_NFS_V4_1) */ |
| @@ -466,7 +466,7 @@ static int nfs41_setup_sequence(struct nfs4_session *session, | |||
| 466 | tbl = &session->fc_slot_table; | 466 | tbl = &session->fc_slot_table; |
| 467 | 467 | ||
| 468 | spin_lock(&tbl->slot_tbl_lock); | 468 | spin_lock(&tbl->slot_tbl_lock); |
| 469 | if (test_bit(NFS4CLNT_SESSION_RESET, &session->clp->cl_state)) { | 469 | if (test_bit(NFS4CLNT_SESSION_DRAINING, &session->clp->cl_state)) { |
| 470 | /* | 470 | /* |
| 471 | * The state manager will wait until the slot table is empty. | 471 | * The state manager will wait until the slot table is empty. |
| 472 | * Schedule the reset thread | 472 | * Schedule the reset thread |
| @@ -3368,7 +3368,7 @@ _nfs4_async_handle_error(struct rpc_task *task, const struct nfs_server *server, | |||
| 3368 | case -NFS4ERR_SEQ_MISORDERED: | 3368 | case -NFS4ERR_SEQ_MISORDERED: |
| 3369 | dprintk("%s ERROR %d, Reset session\n", __func__, | 3369 | dprintk("%s ERROR %d, Reset session\n", __func__, |
| 3370 | task->tk_status); | 3370 | task->tk_status); |
| 3371 | set_bit(NFS4CLNT_SESSION_RESET, &clp->cl_state); | 3371 | nfs4_schedule_state_recovery(clp); |
| 3372 | task->tk_status = 0; | 3372 | task->tk_status = 0; |
| 3373 | return -EAGAIN; | 3373 | return -EAGAIN; |
| 3374 | #endif /* CONFIG_NFS_V4_1 */ | 3374 | #endif /* CONFIG_NFS_V4_1 */ |
diff --git a/fs/nfs/nfs4state.c b/fs/nfs/nfs4state.c index 3c1433598b60..46c69e2248e3 100644 --- a/fs/nfs/nfs4state.c +++ b/fs/nfs/nfs4state.c | |||
| @@ -1094,6 +1094,8 @@ static int nfs4_recovery_handle_error(struct nfs_client *clp, int error) | |||
| 1094 | case -NFS4ERR_SEQ_FALSE_RETRY: | 1094 | case -NFS4ERR_SEQ_FALSE_RETRY: |
| 1095 | case -NFS4ERR_SEQ_MISORDERED: | 1095 | case -NFS4ERR_SEQ_MISORDERED: |
| 1096 | set_bit(NFS4CLNT_SESSION_RESET, &clp->cl_state); | 1096 | set_bit(NFS4CLNT_SESSION_RESET, &clp->cl_state); |
| 1097 | /* Zero session reset errors */ | ||
| 1098 | return 0; | ||
| 1097 | } | 1099 | } |
| 1098 | return error; | 1100 | return error; |
| 1099 | } | 1101 | } |
| @@ -1191,7 +1193,6 @@ static int nfs4_reset_session(struct nfs_client *clp) | |||
| 1191 | set_bit(NFS4CLNT_SESSION_DRAINING, &clp->cl_state); | 1193 | set_bit(NFS4CLNT_SESSION_DRAINING, &clp->cl_state); |
| 1192 | spin_unlock(&tbl->slot_tbl_lock); | 1194 | spin_unlock(&tbl->slot_tbl_lock); |
| 1193 | status = wait_for_completion_interruptible(&ses->complete); | 1195 | status = wait_for_completion_interruptible(&ses->complete); |
| 1194 | clear_bit(NFS4CLNT_SESSION_DRAINING, &clp->cl_state); | ||
| 1195 | if (status) /* -ERESTARTSYS */ | 1196 | if (status) /* -ERESTARTSYS */ |
| 1196 | goto out; | 1197 | goto out; |
| 1197 | } else { | 1198 | } else { |
| @@ -1212,6 +1213,7 @@ static int nfs4_reset_session(struct nfs_client *clp) | |||
| 1212 | /* fall through*/ | 1213 | /* fall through*/ |
| 1213 | out: | 1214 | out: |
| 1214 | /* Wake up the next rpc task even on error */ | 1215 | /* Wake up the next rpc task even on error */ |
| 1216 | clear_bit(NFS4CLNT_SESSION_DRAINING, &clp->cl_state); | ||
| 1215 | rpc_wake_up_next(&clp->cl_session->fc_slot_table.slot_tbl_waitq); | 1217 | rpc_wake_up_next(&clp->cl_session->fc_slot_table.slot_tbl_waitq); |
| 1216 | return status; | 1218 | return status; |
| 1217 | } | 1219 | } |
