Home
last modified time | relevance | path

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

/linux/fs/
A Dio-wq.h6 struct io_wq;
168 struct io_wq *io_wq_create(unsigned bounded, struct io_wq_data *data);
169 void io_wq_exit_start(struct io_wq *wq);
170 void io_wq_put_and_exit(struct io_wq *wq);
172 void io_wq_enqueue(struct io_wq *wq, struct io_wq_work *work);
175 int io_wq_cpu_affinity(struct io_wq *wq, cpumask_var_t mask);
176 int io_wq_max_workers(struct io_wq *wq, int *new_count);
185 enum io_wq_cancel io_wq_cancel_cb(struct io_wq *wq, work_cancel_fn *cancel,
A Dio-wq.c102 struct io_wq *wq;
111 struct io_wq { struct
184 struct io_wq *wq = wqe->wq; in io_worker_cancel_cb()
208 struct io_wq *wq = wqe->wq; in io_worker_exit()
314 struct io_wq *wq; in create_worker_cb()
344 struct io_wq *wq = wqe->wq; in io_queue_worker_create()
441 struct io_wq *wq = wqe->wq; in io_wait_on_hash()
544 struct io_wq *wq = wqe->wq; in io_worker_handle_work()
1129 struct io_wq *wq; in io_wq_create()
1315 struct io_wq *wq = hlist_entry_safe(node, struct io_wq, cpuhp_node); in io_wq_cpu_online()
[all …]
A Dio_uring.c467 struct io_wq *io_wq; member
1568 BUG_ON(!tctx->io_wq); in io_queue_async_work()
6292 if (!tctx || !tctx->io_wq) in io_async_cancel_one()
8665 if (IS_ERR(tctx->io_wq)) { in io_uring_alloc_task_context()
8688 WARN_ON_ONCE(tctx->io_wq); in __io_uring_free()
9792 struct io_wq *wq = tctx->io_wq; in io_uring_clean_tctx()
9806 tctx->io_wq = NULL; in io_uring_clean_tctx()
9845 if (tctx->io_wq) in io_uring_cancel_generic()
10764 if (!tctx || !tctx->io_wq) in io_register_iowq_aff()
10788 if (!tctx || !tctx->io_wq) in io_unregister_iowq_aff()
[all …]
A D.io-wq.o.cmd1 …t=1152 -DKBUILD_MODFILE='"fs/io-wq"' -DKBUILD_BASENAME='"io_wq"' -DKBUILD_MODNAME='"io_wq"' -D_…
/linux/drivers/scsi/lpfc/
A 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()
A Dlpfc_nvme.c2173 !qp || !qp->io_wq) in lpfc_nvme_lport_unreg_wait()
2176 pring = qp->io_wq->pring; in lpfc_nvme_lport_unreg_wait()
2673 if (!phba->sli4_hba.hdwq[i].io_wq) in lpfc_nvme_wait_for_io_drain()
2675 pring = phba->sli4_hba.hdwq[i].io_wq->pring; in lpfc_nvme_wait_for_io_drain()
A Dlpfc_sli4.h699 struct lpfc_queue *io_wq; /* Fast-path FCP & NVME work queue */ member
A 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()
A Dlpfc_sli.c4527 pring = phba->sli4_hba.hdwq[i].io_wq->pring; in lpfc_sli_abort_fcp_rings()
4569 pring = phba->sli4_hba.hdwq[i].io_wq->pring; in lpfc_sli_flush_io_rings()
11697 pring = phba->sli4_hba.hdwq[i].io_wq->pring; in lpfc_sli4_queue_init()
21099 wq = phba->sli4_hba.hdwq[0].io_wq; in lpfc_drain_txq()
21353 wq = qp->io_wq; in lpfc_sli4_issue_wqe()
21375 wq = qp->io_wq; in lpfc_sli4_issue_wqe()
21515 txcmplq_cnt = qp->io_wq->pring->txcmplq_cnt; in lpfc_snapshot_mxp()
21585 txcmplq_cnt = qp->io_wq->pring->txcmplq_cnt; in lpfc_adjust_high_watermark()
21870 txcmplq_cnt = qp->io_wq->pring->txcmplq_cnt; in lpfc_release_io_buf()
22300 cpu_to_node(hdwq->io_wq->chann)); in lpfc_get_sgl_per_hdwq()
[all …]
A 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()
A Dlpfc_init.c10286 phba->sli4_hba.hdwq[idx].io_wq = qdesc; in lpfc_alloc_io_wq_cq()
10711 lpfc_sli4_queue_free(hdwq[idx].io_wq); in lpfc_sli4_release_hdwq()
10714 hdwq[idx].io_wq = NULL; in lpfc_sli4_release_hdwq()
11051 qp[qidx].io_wq, in lpfc_sli4_queue_setup()
11358 lpfc_wq_destroy(phba, qp->io_wq); in lpfc_sli4_queue_unset()
A Dlpfc_scsi.c5931 pring_s4 = phba->sli4_hba.hdwq[iocb->hba_wqidx].io_wq->pring; in lpfc_abort_handler()

Completed in 115 milliseconds