Because Light Weight connection might be evicted after
restart, then cause inflight RPC fails, to avoid this,
we need resend seq lookup RPC.
remove "-f" from "stop mdt" in sanity 17m, so umount can
keep the the connection, and otherwise the OSP might be
evicted.
Signed-off-by: wang di <di.wang@intel.com>
Change-Id: I032dfb95e65da56b198129c6d6d6039bad08ab9c
Reviewed-on: http://review.whamcloud.com/9106
Tested-by: Jenkins
Tested-by: Maloo <hpdd-maloo@intel.com>
Reviewed-by: Andreas Dilger <andreas.dilger@intel.com>
Reviewed-by: Jinshan Xiong <jinshan.xiong@intel.com>
Reviewed-by: Niu Yawei <yawei.niu@intel.com>
imp = class_exp2cliimp(exp);
switch (fld_op) {
case FLD_QUERY:
imp = class_exp2cliimp(exp);
switch (fld_op) {
case FLD_QUERY:
op = req_capsule_client_get(&req->rq_pill, &RMF_FLD_OPC);
*op = FLD_LOOKUP;
op = req_capsule_client_get(&req->rq_pill, &RMF_FLD_OPC);
*op = FLD_LOOKUP;
- if (imp->imp_connect_flags_orig & OBD_CONNECT_MDS_MDS)
+ /* For MDS_MDS seq lookup, it will always use LWP connection,
+ * but LWP will be evicted after restart, so cause the error.
+ * so we will set no_delay for seq lookup request, once the
+ * request fails because of the eviction. always retry here */
+ if (imp->imp_connect_flags_orig & OBD_CONNECT_MDS_MDS) {
req->rq_allow_replay = 1;
req->rq_allow_replay = 1;
+ req->rq_no_delay = 1;
+ }
break;
case FLD_READ:
req = ptlrpc_request_alloc_pack(imp, &RQF_FLD_READ,
break;
case FLD_READ:
req = ptlrpc_request_alloc_pack(imp, &RQF_FLD_READ,
fld_enter_request(&exp->exp_obd->u.cli);
rc = ptlrpc_queue_wait(req);
fld_exit_request(&exp->exp_obd->u.cli);
fld_enter_request(&exp->exp_obd->u.cli);
rc = ptlrpc_queue_wait(req);
fld_exit_request(&exp->exp_obd->u.cli);
+ if (rc != 0) {
+ if (rc == -EWOULDBLOCK) {
+ /* For no_delay req(see above), EWOULDBLOCK means the
+ * connection is being evicted, but this seq lookup
+ * should not return error, since it would cause
+ * unecessary failure of the application, instead
+ * it should retry here */
+ ptlrpc_req_finished(req);
+ goto again;
+ }
if (fld_op == FLD_QUERY) {
prange = req_capsule_server_get(&req->rq_pill,
if (fld_op == FLD_QUERY) {
prange = req_capsule_server_get(&req->rq_pill,
echo "stop and checking mds${mds_index}: $cmd"
# e2fsck should not return error
echo "stop and checking mds${mds_index}: $cmd"
# e2fsck should not return error
- stop mds${mds_index} -f
do_facet mds${mds_index} $cmd || rc=$?
start mds${mds_index} $devname $MDS_MOUNT_OPTS
do_facet mds${mds_index} $cmd || rc=$?
start mds${mds_index} $devname $MDS_MOUNT_OPTS