/linux-master/drivers/iommu/ |
H A D | io-pgfault.c | 256 flush_workqueue(iopf_param->queue->wq); 460 queue->wq = alloc_workqueue("iopf_queue/%s", WQ_UNBOUND, 0, name); 461 if (!queue->wq) { 490 destroy_workqueue(queue->wq);
|
/linux-master/drivers/crypto/intel/iaa/ |
H A D | iaa_crypto.h | 46 struct idxd_wq *wq; member in struct:iaa_wq
|
/linux-master/drivers/net/ethernet/netronome/nfp/ |
H A D | ccm.c | 104 err = wait_event_interruptible_timeout(ccm->wq, 195 wake_up_interruptible_all(&ccm->wq); 210 init_waitqueue_head(&ccm->wq);
|
H A D | ccm_mbox.c | 417 wake_up_all(&nn->mbox_cmsg.wq); 443 wait_event(nn->mbox_cmsg.wq, nfp_ccm_mbox_done(skb)); 456 wake_up_all(&nn->mbox_cmsg.wq); 563 to = !wait_event_timeout(nn->mbox_cmsg.wq, 645 wake_up_all(&nn->mbox_cmsg.wq); 729 init_waitqueue_head(&nn->mbox_cmsg.wq);
|
/linux-master/drivers/net/ethernet/chelsio/inline_crypto/chtls/ |
H A D | chtls_cm.h | 145 struct socket_wq *wq; local 148 wq = rcu_dereference(sk->sk_wq); 149 if (skwq_has_sleeper(wq)) {
|
/linux-master/fs/jffs2/ |
H A D | os-linux.h | 41 #define sleep_on_spinunlock(wq, s) \ 44 add_wait_queue((wq), &__wait); \ 48 remove_wait_queue((wq), &__wait); \
|
/linux-master/drivers/md/bcache/ |
H A D | movinggc.c | 113 continue_at(cl, write_moving_finish, op->wq); 123 continue_at(cl, write_moving, io->op.wq); 158 io->op.wq = c->moving_gc_wq;
|
/linux-master/drivers/net/ethernet/mellanox/mlx5/core/en/ |
H A D | params.h | 17 struct mlx5_wq_param wq; member in struct:mlx5e_cq_param 25 struct mlx5_wq_param wq; member in struct:mlx5e_rq_param 33 struct mlx5_wq_param wq; member in struct:mlx5e_sq_param
|
/linux-master/drivers/target/tcm_fc/ |
H A D | tfc_conf.c | 222 struct workqueue_struct *wq; local 253 wq = alloc_workqueue("tcm_fc", 0, 1); 254 if (!wq) { 261 destroy_workqueue(wq); 265 tpg->workqueue = wq;
|
/linux-master/drivers/net/ethernet/mellanox/mlx5/core/ |
H A D | dpll.c | 14 struct workqueue_struct *wq; member in struct:mlx5_dpll 248 queue_delayed_work(mdpll->wq, &mdpll->work, 384 mdpll->wq = create_singlethread_workqueue("mlx5_dpll"); 385 if (!mdpll->wq) { 418 destroy_workqueue(mdpll->wq);
|
/linux-master/drivers/net/wireless/st/cw1200/ |
H A D | cw1200_spi.c | 40 wait_queue_head_t wq; member in struct:hwbus_priv 204 add_wait_queue(&self->wq, &wait); 217 remove_wait_queue(&self->wq, &wait); 229 wake_up(&self->wq); 415 init_waitqueue_head(&self->wq);
|
/linux-master/drivers/sbus/char/ |
H A D | bbc_i2c.c | 131 add_wait_queue(&bp->wq, &wait); 136 bp->wq, 145 remove_wait_queue(&bp->wq, &wait); 281 wake_up_interruptible(&bp->wq); 319 init_waitqueue_head(&bp->wq);
|
/linux-master/drivers/scsi/fnic/ |
H A D | vnic_dev.c | 23 struct vnic_wq wq; member in struct:devcmd2_controller 341 pr_err("%s: devcmd2 wq full while issuing cmd %d\n", 431 err = vnic_wq_devcmd2_alloc(vdev, &vdev->devcmd2->wq, 436 fetch_index = ioread32(&vdev->devcmd2->wq.ctrl->fetch_index); 448 vnic_wq_init_start(&vdev->devcmd2->wq, 0, fetch_index, 451 vnic_wq_enable(&vdev->devcmd2->wq); 461 (struct vnic_devcmd2 *) vdev->devcmd2->wq.ring.descs; 462 vdev->devcmd2->wq_ctrl = vdev->devcmd2->wq.ctrl; 478 vnic_wq_disable(&vdev->devcmd2->wq); 480 vnic_wq_free(&vdev->devcmd2->wq); [all...] |
/linux-master/drivers/media/platform/mediatek/vpu/ |
H A D | mtk_vpu.c | 126 * @wq: workqueue for VPU watchdog 131 struct workqueue_struct *wq; member in struct:vpu_wdt 143 * @wq: wait queue for VPU initialization status 150 wait_queue_head_t wq; member in struct:vpu_run 614 ret = wait_event_interruptible_timeout(run->wq, 647 wake_up_interruptible(&vpu->run.wq); 798 queue_work(vpu->wdt.wq, &vpu->wdt.ws); 849 vpu->wdt.wq = create_singlethread_workqueue("vpu_wdt"); 850 if (!vpu->wdt.wq) { 909 init_waitqueue_head(&vpu->run.wq); [all...] |
/linux-master/drivers/net/ethernet/mellanox/mlx5/core/en/rep/ |
H A D | bridge.c | 474 /* Mark for deletion to prevent the update wq task from 498 queue_work(br_offloads->wq, &work->work); 516 queue_delayed_work(br_offloads->wq, &br_offloads->update_work, 536 br_offloads->wq = alloc_ordered_workqueue("mlx5_bridge_wq", 0); 537 if (!br_offloads->wq) { 564 queue_delayed_work(br_offloads->wq, &br_offloads->update_work, 573 destroy_workqueue(br_offloads->wq); 595 destroy_workqueue(br_offloads->wq);
|
/linux-master/net/smc/ |
H A D | smc_tx.c | 45 struct socket_wq *wq; local 53 wq = rcu_dereference(sk->sk_wq); 54 if (skwq_has_sleeper(wq)) 55 wake_up_interruptible_poll(&wq->wait, 58 if (wq && wq->fasync_list && !(sk->sk_shutdown & SEND_SHUTDOWN)) 59 sock_wake_async(wq, SOCK_WAKE_SPACE, POLL_OUT);
|
/linux-master/drivers/infiniband/hw/mlx5/ |
H A D | devx.c | 719 void *rqc, *wq; local 722 wq = MLX5_ADDR_OF(rqc, rqc, wq); 723 MLX5_SET(wq, wq, dbr_umem_valid, 1); 724 MLX5_SET(wq, wq, wq_umem_valid, 1); 730 void *sqc, *wq; local 733 wq = MLX5_ADDR_OF(sqc, sqc, wq); 745 void *rmpc, *wq; local 756 void *xrqc, *wq; local [all...] |
/linux-master/drivers/accel/qaic/ |
H A D | qaic_drv.c | 49 struct workqueue_struct *wq = res; local 51 destroy_workqueue(wq); 56 struct workqueue_struct *wq; local 59 wq = alloc_workqueue(fmt, WQ_UNBOUND, 0); 60 if (!wq) 62 ret = drmm_add_action_or_reset(dev, qaicm_wq_release, wq); 66 return wq;
|
/linux-master/drivers/xen/ |
H A D | pvcalls-back.c | 51 struct workqueue_struct *wq; member in struct:pvcalls_ioworker 82 struct workqueue_struct *wq; member in struct:sockpass_mapping 313 queue_work(iow->wq, &iow->register_work); 366 map->ioworker.wq = alloc_ordered_workqueue("pvcalls_io", 0); 367 if (!map->ioworker.wq) 472 destroy_workqueue(mappass->wq); 571 queue_work(iow->wq, &iow->register_work); 617 queue_work(mappass->wq, &mappass->register_work); 639 map->wq = alloc_ordered_workqueue("pvcalls_wq", 0); 640 if (!map->wq) { [all...] |
/linux-master/drivers/scsi/bfa/ |
H A D | bfad_im.c | 151 wait_queue_head_t *wq; local 155 wq = bfad_priv(cmnd)->wq; 156 bfad_priv(cmnd)->wq = NULL; 158 if (wq) 159 wake_up(wq); 301 DECLARE_WAIT_QUEUE_HEAD_ONSTACK(wq); 329 bfad_priv(cmnd)->wq = &wq; 350 wait_event(wq, test_bi [all...] |
/linux-master/drivers/staging/fieldbus/anybuss/ |
H A D | host.c | 337 wait_queue_head_t *wq) 348 wake_up(wq); 354 wait_queue_head_t *wq) 358 ret = ab_task_enqueue(t, q, slock, wq); 377 wait_queue_head_t wq; member in struct:anybuss_host 475 wake_up(&cd->wq); 542 err = ab_task_enqueue_wait(t, cd->powerq, &cd->qlock, &cd->wq); 844 err = ab_task_enqueue_wait(t, cd->powerq, &cd->qlock, &cd->wq); 956 ret = ab_task_enqueue(t, cd->powerq, &cd->qlock, &cd->wq); 991 wait_event_timeout(cd->wq, 336 ab_task_enqueue(struct ab_task *t, struct kfifo *q, spinlock_t *slock, wait_queue_head_t *wq) argument 353 ab_task_enqueue_wait(struct ab_task *t, struct kfifo *q, spinlock_t *slock, wait_queue_head_t *wq) argument [all...] |
/linux-master/drivers/mtd/lpddr/ |
H A D | lpddr_cmds.c | 87 init_waitqueue_head(&chip->wq); 173 add_wait_queue(&chip->wq, &wait); 176 remove_wait_queue(&chip->wq, &wait); 272 add_wait_queue(&chip->wq, &wait); 275 remove_wait_queue(&chip->wq, &wait); 339 add_wait_queue(&chip->wq, &wait); 342 remove_wait_queue(&chip->wq, &wait); 365 wake_up(&chip->wq); 379 wake_up(&chip->wq); 400 wake_up(&chip->wq); [all...] |
/linux-master/tools/testing/selftests/x86/ |
H A D | lam.c | 1053 void *wq; local 1061 wq = mmap(NULL, 0x1000, PROT_WRITE, 1063 if (wq == MAP_FAILED) 1066 return wq; 1083 void *wq = NULL; local 1110 wq = allocate_dsa_pasid(); 1111 if (wq == MAP_FAILED) 1124 if (wq != MAP_FAILED && wq != NULL) 1125 if (munmap(wq, [all...] |
/linux-master/drivers/net/ethernet/mellanox/mlx5/core/fpga/ |
H A D | conn.c | 116 data = mlx5_wq_cyc_get_wqe(&conn->qp.wq.rq, ix); 126 *conn->qp.wq.rq.db = cpu_to_be32(conn->qp.rq.pc & 0xffff); 135 *conn->qp.wq.sq.db = cpu_to_be32(conn->qp.sq.pc); 151 ctrl = mlx5_wq_cyc_get_wqe(&conn->qp.wq.sq, ix); 362 conn->fdev->conn_res.uar->map, conn->cq.wq.cc); 371 cqe = mlx5_cqwq_get_cqe(&conn->cq.wq); 376 mlx5_cqwq_pop(&conn->cq.wq); 378 mlx5_cqwq_update_db_record(&conn->cq.wq); 385 mlx5_fpga_dbg(conn->fdev, "Re-arming CQ with cc# %u\n", conn->cq.wq.cc); 430 err = mlx5_cqwq_create(mdev, &wqp, temp_cqc, &conn->cq.wq, [all...] |
/linux-master/drivers/scsi/snic/ |
H A D | snic_io.c | 20 snic_wq_cmpl_frame_send(struct vnic_wq *wq, argument 25 struct snic *snic = svnic_dev_priv(wq->vdev); 55 svnic_wq_service(&snic->wq[q_num], 83 snic_free_wq_buf(struct vnic_wq *wq, struct vnic_wq_buf *buf) argument 87 struct snic *snic = svnic_dev_priv(wq->vdev); 185 snic_queue_wq_eth_desc(&snic->wq[q_num], os_buf, pa, len, 0, 0, 1);
|