|
@@ -798,29 +798,12 @@ static void aio_queue_work(struct kioctx * ctx)
|
|
|
queue_delayed_work(aio_wq, &ctx->wq, timeout);
|
|
|
}
|
|
|
|
|
|
-
|
|
|
-/*
|
|
|
- * aio_run_iocbs:
|
|
|
- * Process all pending retries queued on the ioctx
|
|
|
- * run list.
|
|
|
- * Assumes it is operating within the aio issuer's mm
|
|
|
- * context.
|
|
|
- */
|
|
|
-static inline void aio_run_iocbs(struct kioctx *ctx)
|
|
|
-{
|
|
|
- int requeue;
|
|
|
-
|
|
|
- spin_lock_irq(&ctx->ctx_lock);
|
|
|
-
|
|
|
- requeue = __aio_run_iocbs(ctx);
|
|
|
- spin_unlock_irq(&ctx->ctx_lock);
|
|
|
- if (requeue)
|
|
|
- aio_queue_work(ctx);
|
|
|
-}
|
|
|
-
|
|
|
/*
|
|
|
- * just like aio_run_iocbs, but keeps running them until
|
|
|
- * the list stays empty
|
|
|
+ * aio_run_all_iocbs:
|
|
|
+ * Process all pending retries queued on the ioctx
|
|
|
+ * run list, and keep running them until the list
|
|
|
+ * stays empty.
|
|
|
+ * Assumes it is operating within the aio issuer's mm context.
|
|
|
*/
|
|
|
static inline void aio_run_all_iocbs(struct kioctx *ctx)
|
|
|
{
|