Home
last modified time | relevance | path

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

/Linux-v5.15/fs/
Dio-wq.h6 struct io_wq;
123 struct io_wq *io_wq_create(unsigned bounded, struct io_wq_data *data);
124 void io_wq_exit_start(struct io_wq *wq);
125 void io_wq_put_and_exit(struct io_wq *wq);
127 void io_wq_enqueue(struct io_wq *wq, struct io_wq_work *work);
130 int io_wq_cpu_affinity(struct io_wq *wq, cpumask_var_t mask);
131 int io_wq_max_workers(struct io_wq *wq, int *new_count);
140 enum io_wq_cancel io_wq_cancel_cb(struct io_wq *wq, work_cancel_fn *cancel,
Dio-wq.c101 struct io_wq *wq;
110 struct io_wq { struct
138 static bool create_io_worker(struct io_wq *wq, struct io_wqe *wqe, int index); argument
171 static void io_worker_ref_put(struct io_wq *wq) in io_worker_ref_put()
277 struct io_wq *wq; in create_worker_cb()
307 struct io_wq *wq = wqe->wq; in io_queue_worker_create()
390 struct io_wq *wq = wqe->wq; in io_wait_on_hash()
483 struct io_wq *wq = wqe->wq; in io_worker_handle_work()
550 struct io_wq *wq = wqe->wq; in io_wqe_worker()
726 static bool create_io_worker(struct io_wq *wq, struct io_wqe *wqe, int index) in create_io_worker()
[all …]
Dio_uring.c470 struct io_wq *io_wq; member
1453 BUG_ON(!tctx->io_wq); in io_queue_async_work()
1470 io_wq_enqueue(tctx->io_wq, &req->work); in io_queue_async_work()
6236 if (!tctx || !tctx->io_wq) in io_async_cancel_one()
6239 cancel_ret = io_wq_cancel_cb(tctx->io_wq, io_cancel_cb, &data, false); in io_async_cancel_one()
8526 static struct io_wq *io_init_wq_offload(struct io_ring_ctx *ctx, in io_init_wq_offload()
8574 tctx->io_wq = io_init_wq_offload(ctx, task); in io_uring_alloc_task_context()
8575 if (IS_ERR(tctx->io_wq)) { in io_uring_alloc_task_context()
8576 ret = PTR_ERR(tctx->io_wq); in io_uring_alloc_task_context()
8598 WARN_ON_ONCE(tctx->io_wq); in __io_uring_free()
[all …]
/Linux-v5.15/drivers/scsi/lpfc/
Dlpfc_debugfs.h426 wq = phba->sli4_hba.hdwq[wqidx].io_wq; in lpfc_debug_dump_wq()
470 wq = phba->sli4_hba.hdwq[wqidx].io_wq; in lpfc_debug_dump_cq()
575 if (phba->sli4_hba.hdwq[wq_idx].io_wq->queue_id == qid) in lpfc_debug_dump_wq_by_id()
579 lpfc_debug_dump_q(phba->sli4_hba.hdwq[wq_idx].io_wq); in lpfc_debug_dump_wq_by_id()
Dlpfc_nvme.c2169 pring = qp->io_wq->pring; in lpfc_nvme_lport_unreg_wait()
2623 if (!phba->sli4_hba.hdwq[i].io_wq) in lpfc_nvme_wait_for_io_drain()
2625 pring = phba->sli4_hba.hdwq[i].io_wq->pring; in lpfc_nvme_wait_for_io_drain()
Dlpfc_sli4.h699 struct lpfc_queue *io_wq; /* Fast-path FCP & NVME work queue */ member
Dlpfc_nvmet.c1104 wq = ctxp->hdwq->io_wq; in lpfc_nvmet_xmt_fcp_op()
1179 wq = ctxp->hdwq->io_wq; in lpfc_nvmet_xmt_fcp_abort()
2111 wq = phba->sli4_hba.hdwq[qidx].io_wq; in lpfc_nvmet_destroy_targetport()
Dlpfc_sli.c4526 pring = phba->sli4_hba.hdwq[i].io_wq->pring; in lpfc_sli_abort_fcp_rings()
4568 pring = phba->sli4_hba.hdwq[i].io_wq->pring; in lpfc_sli_flush_io_rings()
11048 wq = phba->sli4_hba.hdwq[piocb->hba_wqidx].io_wq; in __lpfc_sli_issue_iocb_s4()
11216 return phba->sli4_hba.hdwq[piocb->hba_wqidx].io_wq->pring; in lpfc_sli4_calc_ring()
11698 pring = phba->sli4_hba.hdwq[i].io_wq->pring; in lpfc_sli4_queue_init()
12782 phba->sli4_hba.hdwq[iocbq->hba_wqidx].io_wq->pring; in lpfc_sli_abort_taskmgmt()
21045 wq = phba->sli4_hba.hdwq[0].io_wq; in lpfc_drain_txq()
21298 wq = qp->io_wq; in lpfc_sli4_issue_wqe()
21320 wq = qp->io_wq; in lpfc_sli4_issue_wqe()
21460 txcmplq_cnt = qp->io_wq->pring->txcmplq_cnt; in lpfc_snapshot_mxp()
[all …]
Dlpfc_debugfs.c532 txcmplq_cnt = qp->io_wq->pring->txcmplq_cnt; in lpfc_debugfs_multixripools_data()
3885 qp = phba->sli4_hba.hdwq[qidx].io_wq; in lpfc_idiag_wqs_for_cq()
4476 qp = phba->sli4_hba.hdwq[qidx].io_wq; in lpfc_idiag_queacc_write()
Dlpfc_init.c10197 phba->sli4_hba.hdwq[idx].io_wq = qdesc; in lpfc_alloc_io_wq_cq()
10622 lpfc_sli4_queue_free(hdwq[idx].io_wq); in lpfc_sli4_release_hdwq()
10625 hdwq[idx].io_wq = NULL; in lpfc_sli4_release_hdwq()
10962 qp[qidx].io_wq, in lpfc_sli4_queue_setup()
11269 lpfc_wq_destroy(phba, qp->io_wq); in lpfc_sli4_queue_unset()
Dlpfc_scsi.c5911 pring_s4 = phba->sli4_hba.hdwq[iocb->hba_wqidx].io_wq->pring; in lpfc_abort_handler()