Home
last modified time | relevance | path

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

/Linux-v5.10/fs/
Dio-wq.h6 struct io_wq;
119 struct io_wq *io_wq_create(unsigned bounded, struct io_wq_data *data);
120 bool io_wq_get(struct io_wq *wq, struct io_wq_data *data);
121 void io_wq_destroy(struct io_wq *wq);
123 void io_wq_enqueue(struct io_wq *wq, struct io_wq_work *work);
131 void io_wq_cancel_all(struct io_wq *wq);
132 enum io_wq_cancel io_wq_cancel_work(struct io_wq *wq, struct io_wq_work *cwork);
136 enum io_wq_cancel io_wq_cancel_cb(struct io_wq *wq, work_cancel_fn *cancel,
139 struct task_struct *io_wq_get_task(struct io_wq *wq);
Dio-wq.c109 struct io_wq *wq;
116 struct io_wq { struct
534 struct io_wq *wq = wqe->wq; in io_worker_handle_work()
604 struct io_wq *wq = wqe->wq; in io_wqe_worker()
683 static bool create_io_worker(struct io_wq *wq, struct io_wqe *wqe, int index) in create_io_worker()
777 struct io_wq *wq = data; in io_wq_manager()
863 struct io_wq *wq = wqe->wq; in io_run_cancel()
922 void io_wq_enqueue(struct io_wq *wq, struct io_wq_work *work) in io_wq_enqueue()
941 void io_wq_cancel_all(struct io_wq *wq) in io_wq_cancel_all()
1037 enum io_wq_cancel io_wq_cancel_cb(struct io_wq *wq, work_cancel_fn *cancel, in io_wq_cancel_cb()
[all …]
Dio_uring.c295 struct io_wq *io_wq; member
1432 io_wq_enqueue(ctx->io_wq, &req->work); in __io_queue_async_work()
2083 tsk = io_wq_get_task(req->ctx->io_wq); in io_req_task_queue()
2204 tsk = io_wq_get_task(req->ctx->io_wq); in io_free_req_deferred()
3314 tsk = io_wq_get_task(req->ctx->io_wq); in io_async_buf_func()
4896 tsk = io_wq_get_task(req->ctx->io_wq); in __io_async_wake()
5603 cancel_ret = io_wq_cancel_cb(ctx->io_wq, io_cancel_cb, sqe_addr, false); in io_async_cancel_one()
7117 if (ctx->io_wq) { in io_finish_async()
7118 io_wq_destroy(ctx->io_wq); in io_finish_async()
7119 ctx->io_wq = NULL; in io_finish_async()
[all …]
/Linux-v5.10/drivers/scsi/lpfc/
Dlpfc_debugfs.h417 wq = phba->sli4_hba.hdwq[wqidx].io_wq; in lpfc_debug_dump_wq()
461 wq = phba->sli4_hba.hdwq[wqidx].io_wq; in lpfc_debug_dump_cq()
566 if (phba->sli4_hba.hdwq[wq_idx].io_wq->queue_id == qid) in lpfc_debug_dump_wq_by_id()
570 lpfc_debug_dump_q(phba->sli4_hba.hdwq[wq_idx].io_wq); in lpfc_debug_dump_wq_by_id()
Dlpfc_nvme.c2294 pring = phba->sli4_hba.hdwq[i].io_wq->pring; in lpfc_nvme_lport_unreg_wait()
2731 if (!phba->sli4_hba.hdwq[i].io_wq) in lpfc_nvme_wait_for_io_drain()
2733 pring = phba->sli4_hba.hdwq[i].io_wq->pring; in lpfc_nvme_wait_for_io_drain()
Dlpfc_sli4.h690 struct lpfc_queue *io_wq; /* Fast-path FCP & NVME work queue */ member
Dlpfc_nvmet.c1105 wq = ctxp->hdwq->io_wq; in lpfc_nvmet_xmt_fcp_op()
1180 wq = ctxp->hdwq->io_wq; in lpfc_nvmet_xmt_fcp_abort()
2108 wq = phba->sli4_hba.hdwq[qidx].io_wq; in lpfc_nvmet_destroy_targetport()
Dlpfc_sli.c4117 pring = phba->sli4_hba.hdwq[i].io_wq->pring; in lpfc_sli_abort_fcp_rings()
4159 pring = phba->sli4_hba.hdwq[i].io_wq->pring; in lpfc_sli_flush_io_rings()
10122 wq = phba->sli4_hba.hdwq[piocb->hba_wqidx].io_wq; in __lpfc_sli_issue_iocb_s4()
10269 return phba->sli4_hba.hdwq[piocb->hba_wqidx].io_wq->pring; in lpfc_sli4_calc_ring()
10727 pring = phba->sli4_hba.hdwq[i].io_wq->pring; in lpfc_sli4_queue_init()
11839 phba->sli4_hba.hdwq[iocbq->hba_wqidx].io_wq->pring; in lpfc_sli_abort_taskmgmt()
19965 wq = phba->sli4_hba.hdwq[0].io_wq; in lpfc_drain_txq()
20218 wq = qp->io_wq; in lpfc_sli4_issue_wqe()
20240 wq = qp->io_wq; in lpfc_sli4_issue_wqe()
20300 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()
3888 qp = phba->sli4_hba.hdwq[qidx].io_wq; in lpfc_idiag_wqs_for_cq()
4478 qp = phba->sli4_hba.hdwq[qidx].io_wq; in lpfc_idiag_queacc_write()
Dlpfc_init.c8944 phba->sli4_hba.hdwq[idx].io_wq = qdesc; in lpfc_alloc_io_wq_cq()
9369 lpfc_sli4_queue_free(hdwq[idx].io_wq); in lpfc_sli4_release_hdwq()
9372 hdwq[idx].io_wq = NULL; in lpfc_sli4_release_hdwq()
9711 qp[qidx].io_wq, in lpfc_sli4_queue_setup()
10018 lpfc_wq_destroy(phba, qp->io_wq); in lpfc_sli4_queue_unset()
Dlpfc_scsi.c4772 pring_s4 = phba->sli4_hba.hdwq[iocb->hba_wqidx].io_wq->pring; in lpfc_abort_handler()