if (IS_ERR(th))
GOTO(out, rc = PTR_ERR(th));
+ th->th_wait_submit = 1;
rc = llog_declare_create(env, *res, th);
if (rc == 0) {
rc = dt_trans_start_local(env, d, th);
if (rc)
GOTO(out_trans, rc);
+ th->th_wait_submit = 1;
rc = dt_trans_start_local(env, dt, th);
if (rc)
GOTO(out_trans, rc);