Lines Matching refs:nr_events

756 static void io_iopoll_complete(struct io_ring_ctx *ctx, unsigned int *nr_events,  in io_iopoll_complete()  argument
769 (*nr_events)++; in io_iopoll_complete()
792 static int io_do_iopoll(struct io_ring_ctx *ctx, unsigned int *nr_events, in io_do_iopoll() argument
804 spin = !ctx->poll_multi_file && *nr_events < min; in io_do_iopoll()
832 io_iopoll_complete(ctx, nr_events, &done); in io_do_iopoll()
842 static int io_iopoll_getevents(struct io_ring_ctx *ctx, unsigned int *nr_events, in io_iopoll_getevents() argument
848 ret = io_do_iopoll(ctx, nr_events, min); in io_iopoll_getevents()
851 if (!min || *nr_events >= min) in io_iopoll_getevents()
869 unsigned int nr_events = 0; in io_iopoll_reap_events() local
871 io_iopoll_getevents(ctx, &nr_events, 1); in io_iopoll_reap_events()
882 static int __io_iopoll_check(struct io_ring_ctx *ctx, unsigned *nr_events, in __io_iopoll_check() argument
913 if (*nr_events < min) in __io_iopoll_check()
914 tmin = min - *nr_events; in __io_iopoll_check()
916 ret = io_iopoll_getevents(ctx, nr_events, tmin); in __io_iopoll_check()
920 } while (min && !*nr_events && !need_resched()); in __io_iopoll_check()
925 static int io_iopoll_check(struct io_ring_ctx *ctx, unsigned *nr_events, in io_iopoll_check() argument
936 ret = __io_iopoll_check(ctx, nr_events, min); in io_iopoll_check()
2682 unsigned nr_events = 0; in io_sq_thread() local
2695 __io_iopoll_check(ctx, &nr_events, 0); in io_sq_thread()
2704 nr_events = inflight; in io_sq_thread()
2707 inflight -= nr_events; in io_sq_thread()
3694 unsigned nr_events = 0; in SYSCALL_DEFINE6() local
3699 ret = io_iopoll_check(ctx, &nr_events, min_complete); in SYSCALL_DEFINE6()