Searched refs:state (Results 1 – 2 of 2) sorted by relevance
| /io_uring/ |
| D | io_uring.c | 294 unsigned long state; member
1949 struct io_submit_state *state) in io_flush_cached_locked_reqs() argument
1952 list_splice_init(&ctx->locked_free_list, &state->free_list); in io_flush_cached_locked_reqs()
1960 struct io_submit_state *state = &ctx->submit_state; in io_flush_cached_reqs() local
1969 io_flush_cached_locked_reqs(ctx, state); in io_flush_cached_reqs()
1971 nr = state->free_reqs; in io_flush_cached_reqs()
1972 while (!list_empty(&state->free_list)) { in io_flush_cached_reqs()
1973 struct io_kiocb *req = list_first_entry(&state->free_list, 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()
[all …]
|
| D | io-wq.c | 111 unsigned long state; member
186 return test_bit(IO_WQ_BIT_EXIT, &worker->wqe->wq->state); in io_wq_worker_stopped()
357 if (test_bit(IO_WQ_BIT_EXIT, &wq->state)) in io_queue_worker_create()
381 if (test_bit(IO_WQ_BIT_EXIT, &wq->state)) in io_queue_worker_create()
555 bool do_kill = test_bit(IO_WQ_BIT_EXIT, &wq->state); in io_worker_handle_work()
633 while (!test_bit(IO_WQ_BIT_EXIT, &wq->state)) { in io_wqe_worker()
666 if (test_bit(IO_WQ_BIT_EXIT, &wq->state)) { in io_wqe_worker()
924 if (test_bit(IO_WQ_BIT_EXIT, &wqe->wq->state) || in io_wqe_enqueue()
1218 set_bit(IO_WQ_BIT_EXIT, &wq->state); in io_wq_exit_start()
1289 WARN_ON_ONCE(!test_bit(IO_WQ_BIT_EXIT, &wq->state)); in io_wq_put_and_exit()
|