Lines Matching refs:wqes
125 struct io_wqe *wqes[]; member
956 struct io_wqe *wqe = wq->wqes[numa_node_id()]; in io_wq_enqueue()
1076 struct io_wqe *wqe = wq->wqes[node]; in io_wq_cancel_cb()
1090 struct io_wqe *wqe = wq->wqes[node]; in io_wq_cancel_cb()
1133 wq = kzalloc(struct_size(wq, wqes, nr_node_ids), GFP_KERNEL); in io_wq_create()
1155 wq->wqes[node] = wqe; in io_wq_create()
1186 if (!wq->wqes[node]) in io_wq_create()
1188 free_cpumask_var(wq->wqes[node]->cpu_mask); in io_wq_create()
1189 kfree(wq->wqes[node]); in io_wq_create()
1234 struct io_wqe *wqe = wq->wqes[node]; in io_wq_exit_workers()
1244 list_del_init(&wq->wqes[node]->wait.entry); in io_wq_exit_workers()
1258 struct io_wqe *wqe = wq->wqes[node]; in io_wq_destroy()
1305 io_wq_for_each_worker(wq->wqes[i], io_wq_worker_affinity, &od); in __io_wq_cpu_online()
1330 struct io_wqe *wqe = wq->wqes[i]; in io_wq_cpu_affinity()
1365 struct io_wqe *wqe = wq->wqes[node]; in io_wq_max_workers()