@@ -1135,8 +1135,7 @@ static void cl_aio_end(const struct lu_env *env, struct cl_sync_io *anchor)
cl_page_put(env, page);
}
- if (!is_sync_kiocb(aio->cda_iocb) && !aio->cda_no_aio_complete &&
- aio->cda_iocb->ki_complete)
+ if (!aio->cda_no_aio_complete)
aio->cda_iocb->ki_complete(aio->cda_iocb,
ret ?: aio->cda_bytes, 0);
}
@@ -1156,7 +1155,10 @@ struct cl_dio_aio *cl_aio_alloc(struct kiocb *iocb, struct cl_object *obj)
cl_aio_end);
cl_page_list_init(&aio->cda_pages);
aio->cda_iocb = iocb;
- aio->cda_no_aio_complete = 0;
+ if (is_sync_kiocb(iocb))
+ aio->cda_no_aio_complete = 1;
+ else
+ aio->cda_no_aio_complete = 0;
cl_object_get(obj);
aio->cda_obj = obj;
}