LU-6325 ptlrpc: make ptlrpcd threads cpt-aware

[fs/lustre-release.git] / lustre / ptlrpc / import.c

diff --git a/lustre/ptlrpc/import.c b/lustre/ptlrpc/import.c
index e682e7c..e8f595b 100644 (file)
--- a/lustre/ptlrpc/import.c
+++ b/lustre/ptlrpc/import.c
@@ -756,16 +756,15 @@ int ptlrpc_connect_import(struct obd_import *imp)
                 lustre_msg_add_op_flags(request->rq_reqmsg,
                                         MSG_CONNECT_TRANSNO);
 
-        DEBUG_REQ(D_RPCTRACE, request, "(re)connect request (timeout %d)",
-                  request->rq_timeout);
-        ptlrpcd_add_req(request, PDL_POLICY_ROUND, -1);
-        rc = 0;
+       DEBUG_REQ(D_RPCTRACE, request, "(re)connect request (timeout %d)",
+                 request->rq_timeout);
+       ptlrpcd_add_req(request);
+       rc = 0;
 out:
-        if (rc != 0) {
-                IMPORT_SET_STATE(imp, LUSTRE_IMP_DISCON);
-        }
+       if (rc != 0)
+               IMPORT_SET_STATE(imp, LUSTRE_IMP_DISCON);
 
-        RETURN(rc);
+       RETURN(rc);
 }
 EXPORT_SYMBOL(ptlrpc_connect_import);
 
@@ -1341,7 +1340,7 @@ static int signal_completed_replay(struct obd_import *imp)
                req->rq_timeout *= 3;
        req->rq_interpret_reply = completed_replay_interpret;
 
-       ptlrpcd_add_req(req, PDL_POLICY_ROUND, -1);
+       ptlrpcd_add_req(req);
        RETURN(0);
 }