Home
last modified time | relevance | path

Searched refs:io_wq (Results 1 – 9 of 9) sorted by relevance

/linux/io_uring/
H A Dio-wq.c55 struct io_wq *wq;
117 struct io_wq { struct
148 static bool create_io_worker(struct io_wq *wq, struct io_wq_acct *acct); argument
150 static bool io_acct_cancel_pending_work(struct io_wq *wq,
154 static void io_wq_cancel_tw_create(struct io_wq *wq);
177 static inline struct io_wq_acct *io_get_acct(struct io_wq *wq, bool bound) in io_get_acct()
182 static inline struct io_wq_acct *io_work_get_acct(struct io_wq *wq, in io_work_get_acct()
193 static void io_worker_ref_put(struct io_wq *wq) in io_worker_ref_put()
212 struct io_wq *wq = worker->wq; in io_worker_cancel_cb()
238 struct io_wq *wq = worker->wq; in io_worker_exit()
[all …]
H A Dtctx.c16 static struct io_wq *io_init_wq_offload(struct io_ring_ctx *ctx, in io_init_wq_offload()
63 WARN_ON_ONCE(tctx->io_wq); in io_uring_free_tctx()
98 tctx->io_wq = io_init_wq_offload(ctx, task); in io_uring_alloc_task_context()
99 if (IS_ERR(tctx->io_wq)) { in io_uring_alloc_task_context()
100 ret = PTR_ERR(tctx->io_wq); in io_uring_alloc_task_context()
165 ret = io_wq_max_workers(tctx->io_wq, limits); in __io_uring_add_tctx_node()
176 if (tctx->io_wq) in __io_uring_add_tctx_node()
177 io_wq_set_exit_on_idle(tctx->io_wq, false); in __io_uring_add_tctx_node()
188 if (tctx->io_wq) { in __io_uring_add_tctx_node()
189 io_wq_exit_start(tctx->io_wq); in __io_uring_add_tctx_node()
[all …]
H A Dcancel.c85 if (!tctx || !tctx->io_wq) in io_async_cancel_one()
89 cancel_ret = io_wq_cancel_cb(tctx->io_wq, io_cancel_cb, cd, all); in io_async_cancel_one()
504 if (!tctx || !tctx->io_wq) in io_uring_try_cancel_iowq()
506 cret = io_wq_cancel_cb(tctx->io_wq, io_cancel_ctx_cb, ctx, true); in io_uring_try_cancel_iowq()
535 } else if (tctx->io_wq) { in io_uring_try_cancel_requests()
540 cret = io_wq_cancel_cb(tctx->io_wq, io_cancel_task_cb, in io_uring_try_cancel_requests()
595 if (tctx->io_wq) in io_uring_cancel_generic()
596 io_wq_exit_start(tctx->io_wq); in io_uring_cancel_generic()
H A Dregister.c397 if (tctx && tctx->io_wq) { in io_register_iowq_max_workers()
398 ret = io_wq_max_workers(tctx->io_wq, new_count); in io_register_iowq_max_workers()
423 if (WARN_ON_ONCE(!tctx->io_wq)) in io_register_iowq_max_workers()
429 (void)io_wq_max_workers(tctx->io_wq, new_count); in io_register_iowq_max_workers()
H A Dio_uring.c416 if ((current->flags & PF_KTHREAD) || !tctx->io_wq) { in io_queue_iowq()
435 io_wq_enqueue(tctx->io_wq, &req->work); in io_queue_iowq()
2348 if (tsk && tsk->io_uring && tsk->io_uring->io_wq) in io_ring_exit_work()
2349 io_wq_cancel_cb(tsk->io_uring->io_wq, in io_ring_exit_work()
/linux/drivers/scsi/lpfc/
H A Dlpfc_sli.c4628 pring = phba->sli4_hba.hdwq[i].io_wq->pring; in lpfc_sli_abort_fcp_rings()
4664 !phba->sli4_hba.hdwq[i].io_wq) { in lpfc_sli_flush_io_rings()
4674 pring = phba->sli4_hba.hdwq[i].io_wq->pring; in lpfc_sli_flush_io_rings()
10704 wq = phba->sli4_hba.hdwq[piocb->hba_wqidx].io_wq; in __lpfc_sli_issue_iocb_s4()
11293 return phba->sli4_hba.hdwq[piocb->hba_wqidx].io_wq->pring; in lpfc_sli4_calc_ring()
11806 pring = phba->sli4_hba.hdwq[i].io_wq->pring; in lpfc_sli4_queue_init()
12919 phba->sli4_hba.hdwq[iocbq->hba_wqidx].io_wq->pring; in lpfc_sli_abort_taskmgmt()
21209 wq = phba->sli4_hba.hdwq[0].io_wq; in lpfc_drain_txq()
21452 wq = qp->io_wq; in lpfc_sli4_issue_wqe()
21474 wq = qp->io_wq; in lpfc_sli4_issue_wqe()
[all …]
H A Dlpfc_scsi.c5550 if (!phba->sli4_hba.hdwq[iocb->hba_wqidx].io_wq || in lpfc_abort_handler()
5551 !phba->sli4_hba.hdwq[iocb->hba_wqidx].io_wq->pring) { in lpfc_abort_handler()
5562 pring_s4 = phba->sli4_hba.hdwq[iocb->hba_wqidx].io_wq->pring; in lpfc_abort_handler()
H A Dlpfc_debugfs.c527 txcmplq_cnt = qp->io_wq->pring->txcmplq_cnt; in lpfc_debugfs_multixripools_data()
3893 qp = phba->sli4_hba.hdwq[qidx].io_wq; in lpfc_idiag_wqs_for_cq()
4484 qp = phba->sli4_hba.hdwq[qidx].io_wq; in lpfc_idiag_queacc_write()
H A Dlpfc_init.c10400 phba->sli4_hba.hdwq[idx].io_wq = qdesc; in lpfc_alloc_io_wq_cq()
10825 lpfc_sli4_queue_free(hdwq[idx].io_wq); in lpfc_sli4_release_hdwq()
10828 hdwq[idx].io_wq = NULL; in lpfc_sli4_release_hdwq()
11162 qp[qidx].io_wq, in lpfc_sli4_queue_setup()
11469 lpfc_wq_destroy(phba, qp->io_wq); in lpfc_sli4_queue_unset()