Lines Matching refs:nr
251 unsigned int nr; member
1179 static inline void __io_req_set_refcount(struct io_kiocb *req, int nr) in __io_req_set_refcount() argument
1183 atomic_set(&req->refs, nr); in __io_req_set_refcount()
1746 static inline void io_put_task(struct task_struct *task, int nr) in io_put_task() argument
1751 tctx->cached_refs += nr; in io_put_task()
1753 percpu_counter_sub(&tctx->inflight, nr); in io_put_task()
1756 put_task_struct_many(task, nr); in io_put_task()
1769 static inline void io_get_task_refs(int nr) in io_get_task_refs() argument
1773 tctx->cached_refs -= nr; in io_get_task_refs()
1961 int nr; in io_flush_cached_reqs() local
1971 nr = state->free_reqs; in io_flush_cached_reqs()
1977 state->reqs[nr++] = req; in io_flush_cached_reqs()
1978 if (nr == ARRAY_SIZE(state->reqs)) in io_flush_cached_reqs()
1982 state->free_reqs = nr; in io_flush_cached_reqs()
1983 return nr != 0; in io_flush_cached_reqs()
2397 int i, nr = state->compl_nr; in io_submit_flush_completions() local
2401 for (i = 0; i < nr; i++) { in io_submit_flush_completions()
2412 for (i = 0; i < nr; i++) { in io_submit_flush_completions()
3398 ssize_t nr; in loop_rw_iter() local
3408 nr = file->f_op->read(file, iovec.iov_base, in loop_rw_iter()
3411 nr = file->f_op->write(file, iovec.iov_base, in loop_rw_iter()
3415 if (nr < 0) { in loop_rw_iter()
3417 ret = nr; in loop_rw_iter()
3420 ret += nr; in loop_rw_iter()
3422 iov_iter_advance(iter, nr); in loop_rw_iter()
3424 req->rw.addr += nr; in loop_rw_iter()
3425 req->rw.len -= nr; in loop_rw_iter()
3429 if (nr != iovec.iov_len) in loop_rw_iter()
6484 up.nr = 0; in io_files_update()
7389 static int io_submit_sqes(struct io_ring_ctx *ctx, unsigned int nr) in io_submit_sqes() argument
7395 nr = min3(nr, ctx->sq_entries, io_sqring_entries(ctx)); in io_submit_sqes()
7396 if (!percpu_ref_tryget_many(&ctx->refs, nr)) in io_submit_sqes()
7398 io_get_task_refs(nr); in io_submit_sqes()
7400 io_submit_state_start(&ctx->submit_state, nr); in io_submit_sqes()
7401 while (submitted < nr) { in io_submit_sqes()
7422 if (unlikely(submitted != nr)) { in io_submit_sqes()
7424 int unused = nr - ref_used; in io_submit_sqes()
7940 size_t size = data->nr * sizeof(data->tags[0][0]); in io_rsrc_data_free()
7948 u64 __user *utags, unsigned nr, in io_rsrc_data_alloc() argument
7958 data->tags = (u64 **)io_alloc_page_table(nr * sizeof(data->tags[0][0])); in io_rsrc_data_alloc()
7964 data->nr = nr; in io_rsrc_data_alloc()
7969 for (i = 0; i < nr; i++) { in io_rsrc_data_alloc()
8029 unsigned nr = ctx->nr_user_files; in io_sqe_files_unregister() local
8041 ctx->nr_user_files = nr; in io_sqe_files_unregister()
8178 static int __io_sqe_files_scm(struct io_ring_ctx *ctx, int nr, int offset) in __io_sqe_files_scm() argument
8200 for (i = 0; i < nr; i++) { in __io_sqe_files_scm()
8218 for (i = 0; i < nr; i++) { in __io_sqe_files_scm()
8946 unsigned nr = ctx->nr_user_bufs; in io_sqe_buffers_unregister() local
8958 ctx->nr_user_bufs = nr; in io_sqe_buffers_unregister()
10723 if (!up.nr || up.resv || up.resv2) in io_register_rsrc_update()
10725 return __io_register_rsrc_update(ctx, type, &up, up.nr); in io_register_rsrc_update()
10740 if (!rr.nr || rr.resv || rr.resv2) in io_register_rsrc()
10746 rr.nr, u64_to_user_ptr(rr.tags)); in io_register_rsrc()
10749 rr.nr, u64_to_user_ptr(rr.tags)); in io_register_rsrc()