argv[0], argv[1], argv[2], argv[3], argv[4]);
}
#else
+ if (imp->imp_state == LUSTRE_IMP_CLOSED) {
+ EXIT;
+ return;
+ }
ptlrpc_recover_import(imp, NULL);
#endif
}
list_for_each_safe(tmp, pos, &imp->imp_delayed_list) {
req = list_entry(tmp, struct ptlrpc_request, rq_list);
- if (req->rq_set) {
- DEBUG_REQ(D_HA, req, "waking (set %p):", req->rq_set);
- wake_up(&req->rq_set->set_waitq);
- } else {
- DEBUG_REQ(D_HA, req, "waking:");
- wake_up(&req->rq_reply_waitq);
- }
+ DEBUG_REQ(D_HA, req, "waking (set %p):", req->rq_set);
+ ptlrpc_wake_client_req(req);
}
spin_unlock_irqrestore(&imp->imp_lock, flags);
}