diff --git a/lustre/ptlrpc/client.c b/lustre/ptlrpc/client.c index cbfcc5b11d3f7c6923ba0b08d47b9f0513938938..165dd29bcfed9cd4425cfa49b85b21d2a35d7b52 100644 --- a/lustre/ptlrpc/client.c +++ b/lustre/ptlrpc/client.c @@ -1521,8 +1521,7 @@ int ptlrpc_expired_set(void *data) list_entry(tmp, struct ptlrpc_request, rq_set_chain); /* Request in-flight? */ - if (!((req->rq_phase & - (RQ_PHASE_RPC | RQ_PHASE_UNREGISTERING) && + if (!((req->rq_phase == RQ_PHASE_RPC && !req->rq_waiting && !req->rq_resend) || (req->rq_phase == RQ_PHASE_BULK))) continue; @@ -1591,22 +1590,11 @@ int ptlrpc_set_next_timeout(struct ptlrpc_request_set *set) /* * Request in-flight? */ - if (!(((req->rq_phase & - (RQ_PHASE_RPC | RQ_PHASE_UNREGISTERING)) && - !req->rq_waiting) || + if (!(((req->rq_phase == RQ_PHASE_RPC) && !req->rq_waiting) || (req->rq_phase == RQ_PHASE_BULK) || (req->rq_phase == RQ_PHASE_NEW))) continue; - /* - * Check those waiting for long reply unlink every one - * second. - */ - if (req->rq_phase == RQ_PHASE_UNREGISTERING) { - timeout = 1; - break; - } - /* * Already timed out. */ diff --git a/lustre/ptlrpc/import.c b/lustre/ptlrpc/import.c index 4ffa92c963fa333d31695dea3fd9f8f7a5e788a6..80e0aafb44db3a5e714aee4aad1fb511fe488476 100644 --- a/lustre/ptlrpc/import.c +++ b/lustre/ptlrpc/import.c @@ -212,9 +212,8 @@ ptlrpc_inflight_deadline(struct ptlrpc_request *req, time_t now) { long dl; - if (!(((req->rq_phase & (RQ_PHASE_RPC | RQ_PHASE_UNREGISTERING)) && - !req->rq_waiting) || - (req->rq_phase == RQ_PHASE_BULK) || + if (!(((req->rq_phase == RQ_PHASE_RPC) && !req->rq_waiting) || + (req->rq_phase == RQ_PHASE_BULK) || (req->rq_phase == RQ_PHASE_NEW))) return 0;