Lines Matching refs:min_events

1257 				       int min_events)  in io_run_local_work_continue()  argument
1261 if (events < min_events) in io_run_local_work_continue()
1290 int min_events, int max_events) in __io_run_local_work() argument
1301 min_events -= ret; in __io_run_local_work()
1315 if (io_run_local_work_continue(ctx, ret, min_events)) in __io_run_local_work()
1319 if (io_run_local_work_continue(ctx, ret, min_events)) in __io_run_local_work()
1327 int min_events) in io_run_local_work_locked() argument
1333 return __io_run_local_work(ctx, ts, min_events, in io_run_local_work_locked()
1334 max(IO_LOCAL_TW_DEFAULT_MAX, min_events)); in io_run_local_work_locked()
1337 static int io_run_local_work(struct io_ring_ctx *ctx, int min_events, in io_run_local_work() argument
1344 ret = __io_run_local_work(ctx, ts, min_events, max_events); in io_run_local_work()
1500 static int io_iopoll_check(struct io_ring_ctx *ctx, unsigned int min_events) in io_iopoll_check() argument
1505 min_events = min(min_events, ctx->cq_entries); in io_iopoll_check()
1548 (void) io_run_local_work_locked(ctx, min_events); in io_iopoll_check()
1561 ret = io_do_iopoll(ctx, !min_events); in io_iopoll_check()
1571 } while (nr_events < min_events); in io_iopoll_check()
2532 static int io_cqring_wait(struct io_ring_ctx *ctx, int min_events, u32 flags, in io_cqring_wait() argument
2540 min_events = min_t(int, min_events, ctx->cq_entries); in io_cqring_wait()
2545 io_run_local_work(ctx, min_events, in io_cqring_wait()
2546 max(IO_LOCAL_TW_DEFAULT_MAX, min_events)); in io_cqring_wait()
2551 if (__io_cqring_events_user(ctx) >= min_events) in io_cqring_wait()
2558 iowq.cq_tail = READ_ONCE(ctx->rings->cq.head) + min_events; in io_cqring_wait()
2587 trace_io_uring_cqring_wait(ctx, min_events); in io_cqring_wait()