lustre_msg_add_op_flags(request->rq_reqmsg,
MSG_CONNECT_TRANSNO);
- DEBUG_REQ(D_RPCTRACE, request, "(re)connect request");
+ DEBUG_REQ(D_RPCTRACE, request, "(re)connect request (timeout %d)",
+ request->rq_timeout);
ptlrpcd_add_req(request, PSCOPE_OTHER);
rc = 0;
out:
rc = ptlrpc_set_add_new_req(pc, req);
/*
* XXX disable this for CLIO: environment is needed for interpreter.
+ * add debug temporary to check rc.
*/
+ LASSERTF(rc == 0, "ptlrpcd_add_req failed (rc = %d)\n", rc);
if (rc && 0) {
/*
* Thread is probably in stop now so we need to
ptlrpc_req_interpret(NULL, req, -EBADR);
req->rq_set = NULL;
ptlrpc_req_finished(req);
+ } else if (req->rq_send_state == LUSTRE_IMP_CONNECTING) {
+ /*
+ * The request is for recovery, should be sent ASAP.
+ */
+ cfs_waitq_signal(&pc->pc_set->set_waitq);
}
return rc;