Whamcloud - gitweb
LU-10419 lfsck: no delay for notify RPC 68/30768/1
authorFan Yong <fan.yong@intel.com>
Mon, 8 Jan 2018 07:56:43 +0000 (15:56 +0800)
committerFan Yong <fan.yong@intel.com>
Mon, 8 Jan 2018 08:12:56 +0000 (16:12 +0800)
It is impossible that current MDT has trouble on the connection
with some other MDT(s) or OST(s). Under such case, the LFSCK on
current MDT should skip related MDT(s) or OST(s) to avoid whole
LFSCK process being blocked by the trouble connection or remote
targets via setting the LFSCK notify RPC as rq_no_delay.

Signed-off-by: Fan Yong <fan.yong@intel.com>
Change-Id: Ib35080cedcbe49f4ae8c4b3690a4743d5afe41b1

lustre/lfsck/lfsck_layout.c
lustre/lfsck/lfsck_lib.c

index 5f6d008..e4bf746 100644 (file)
@@ -4524,6 +4524,7 @@ static int lfsck_layout_async_query(const struct lu_env *env,
        llsaa->llsaa_llst = llst;
        req->rq_interpret_reply = lfsck_layout_slave_async_interpret;
        req->rq_allow_intr = 1;
+       req->rq_no_delay = 1;
        ptlrpc_set_add_req(set, req);
 
        RETURN(0);
@@ -4553,6 +4554,7 @@ static int lfsck_layout_async_notify(const struct lu_env *env,
        *tmp = *lr;
        ptlrpc_request_set_replen(req);
        req->rq_allow_intr = 1;
+       req->rq_no_delay = 1;
        ptlrpc_set_add_req(set, req);
 
        RETURN(0);
index 9b4e021..b9d7e84 100644 (file)
@@ -2419,6 +2419,7 @@ int lfsck_async_request(const struct lu_env *env, struct obd_export *exp,
                lfsck_component_get(laia->laia_com);
        req->rq_interpret_reply = interpreter;
        req->rq_allow_intr = 1;
+       req->rq_no_delay = 1;
        ptlrpc_set_add_req(set, req);
 
        return 0;