X-Git-Url: https://git.whamcloud.com/?p=fs%2Flustre-release.git;a=blobdiff_plain;f=lustre%2Fosp%2Fosp_trans.c;h=b6e5cf4ff1d9d29eafc2aacdd599d85984ab2044;hp=a3aa8d33562812551987a3679e92eb6f7da8fcd6;hb=4f53536d002c13886210b672b657795baa067144;hpb=b1f01a709ffe66d82f13ad421d319432d235c05b

diff --git a/lustre/osp/osp_trans.c b/lustre/osp/osp_trans.c
index a3aa8d3..b6e5cf4 100644
--- a/lustre/osp/osp_trans.c
+++ b/lustre/osp/osp_trans.c
@@ -791,7 +791,8 @@ static int osp_trans_trigger(const struct lu_env *env, struct osp_device *osp,
 	args = ptlrpc_req_async_args(req);
 	args->oaua_update = dt_update;
 
-	if (!th->th_wait_submit && is_only_remote_trans(th) && !th->th_sync) {
+	if (is_only_remote_trans(th) && !th->th_sync &&
+	    !th->th_wait_submit) {
 		args->oaua_flow_control = true;
 
 		if (!osp->opd_connect_mdt) {
@@ -959,7 +960,8 @@ int osp_trans_stop(const struct lu_env *env, struct dt_device *dt,
 	    dt_update->dur_buf.ub_req->ourq_count == 0)
 		GOTO(out, rc);
 
-	if (is_only_remote_trans(th) && !th->th_sync) {
+	if (is_only_remote_trans(th) && !th->th_sync &&
+	    !th->th_wait_submit) {
 		struct osp_device *osp = dt2osp_dev(th->th_dev);
 		struct client_obd *cli = &osp->opd_obd->u.cli;