Lines Matching refs:wqes
125 struct io_wqe *wqes[]; member
966 struct io_wqe *wqe = wq->wqes[numa_node_id()]; in io_wq_enqueue()
1086 struct io_wqe *wqe = wq->wqes[node]; in io_wq_cancel_cb()
1100 struct io_wqe *wqe = wq->wqes[node]; in io_wq_cancel_cb()
1143 wq = kzalloc(struct_size(wq, wqes, nr_node_ids), GFP_KERNEL); in io_wq_create()
1165 wq->wqes[node] = wqe; in io_wq_create()
1196 if (!wq->wqes[node]) in io_wq_create()
1198 free_cpumask_var(wq->wqes[node]->cpu_mask); in io_wq_create()
1199 kfree(wq->wqes[node]); in io_wq_create()
1250 struct io_wqe *wqe = wq->wqes[node]; in io_wq_exit_workers()
1260 list_del_init(&wq->wqes[node]->wait.entry); in io_wq_exit_workers()
1274 struct io_wqe *wqe = wq->wqes[node]; in io_wq_destroy()
1321 io_wq_for_each_worker(wq->wqes[i], io_wq_worker_affinity, &od); in __io_wq_cpu_online()
1346 struct io_wqe *wqe = wq->wqes[i]; in io_wq_cpu_affinity()
1381 struct io_wqe *wqe = wq->wqes[node]; in io_wq_max_workers()