Searched defs:wq (Results 101 - 125 of 138) sorted by relevance

123456

/drivers/staging/lustre/lustre/ptlrpc/
H A Dclient.c2342 wait_queue_head_t *wq; local
2388 wq = &request->rq_set->set_waitq;
2390 wq = &request->rq_reply_waitq;
2397 rc = l_wait_event(*wq, !ptlrpc_client_recv_or_unlink(request),
/drivers/staging/rtl8723au/include/
H A Drtw_cmd.h46 struct workqueue_struct *wq; member in struct:cmd_priv
56 struct workqueue_struct *wq; member in struct:evt_priv
/drivers/usb/gadget/function/
H A Df_mtp.c106 struct workqueue_struct *wq; member in struct:mtp_dev
931 queue_work(dev->wq, work);
933 flush_workqueue(dev->wq);
1275 dev->wq = create_singlethread_workqueue("f_mtp");
1276 if (!dev->wq) {
1292 destroy_workqueue(dev->wq);
1319 destroy_workqueue(dev->wq);
/drivers/usb/gadget/legacy/
H A Dtcm_usb_gadget.c2322 static void usbg_delayed_set_alt(struct work_struct *wq) argument
2324 struct guas_setup_wq *work = container_of(wq, struct guas_setup_wq,
/drivers/video/fbdev/omap2/omapfb/
H A Domapfb-main.c1706 struct workqueue_struct *wq; local
1708 wq = create_singlethread_workqueue("omapfb_auto_update");
1710 if (wq == NULL) {
1716 fbdev->auto_update_wq = wq;
/drivers/infiniband/core/
H A Dcm.c82 struct workqueue_struct *wq; member in struct:ib_cm
820 queue_delayed_work(cm.wq, &cm_id_priv->timewait_info->work.work,
3345 queue_delayed_work(cm.wq, &work->work, 0);
3454 queue_delayed_work(cm.wq, &work->work, 0);
3859 flush_workqueue(cm.wq);
3889 cm.wq = create_workqueue("ib_cm");
3890 if (!cm.wq) {
3901 destroy_workqueue(cm.wq);
3919 destroy_workqueue(cm.wq);
/drivers/infiniband/hw/mlx4/
H A Dmlx4_ib.h356 struct workqueue_struct *wq; member in struct:mlx4_sriov_alias_guid_port_rec_det
410 struct workqueue_struct *wq; member in struct:mlx4_ib_demux_pv_ctx
417 struct workqueue_struct *wq; member in struct:mlx4_ib_demux_ctx
/drivers/infiniband/hw/mlx5/
H A Dqp.c1739 static int mlx5_wq_overflow(struct mlx5_ib_wq *wq, int nreq, struct ib_cq *ib_cq) argument
1744 cur = wq->head - wq->tail;
1745 if (likely(cur + nreq < wq->max_post))
1750 cur = wq->head - wq->tail;
1753 return cur + nreq >= wq->max_post;
/drivers/md/
H A Ddm.c174 struct workqueue_struct *wq; member in struct:mapped_device
640 queue_work(md->wq, &md->work);
2106 md->wq = alloc_workqueue("kdmflush", WQ_MEM_RECLAIM, 0);
2107 if (!md->wq)
2130 destroy_workqueue(md->wq);
2155 destroy_workqueue(md->wq);
2640 queue_work(md->wq, &md->work);
2782 * flush_workqueue(md->wq).
2788 * Stop md->queue before flushing md->wq in case request-based
2789 * dm defers requests to md->wq fro
[all...]
H A Ddm-cache-target.c251 struct workqueue_struct *wq; member in struct:cache
336 queue_work(cache->wq, &cache->worker);
1674 flush_workqueue(cache->wq);
1749 queue_delayed_work(cache->wq, &cache->waker, COMMIT_PERIOD);
1792 if (cache->wq)
1793 destroy_workqueue(cache->wq);
2321 cache->wq = alloc_ordered_workqueue("dm-" DM_MSG_PREFIX, WQ_MEM_RECLAIM);
2322 if (!cache->wq) {
H A Ddm-thin.c178 struct workqueue_struct *wq; member in struct:pool
257 queue_work(pool->wq, &pool->worker);
1669 queue_delayed_work(pool->wq, &pool->waker, COMMIT_PERIOD);
1708 queue_work(pool->wq, &pw->worker);
1830 queue_delayed_work(pool->wq, &pool->no_space_timeout, no_space_timeout);
2151 if (pool->wq)
2152 destroy_workqueue(pool->wq);
2215 pool->wq = alloc_ordered_workqueue("dm-" DM_MSG_PREFIX, WQ_MEM_RECLAIM);
2216 if (!pool->wq) {
2268 destroy_workqueue(pool->wq);
[all...]
/drivers/net/wireless/ath/wil6210/
H A Dwil6210.h402 wait_queue_head_t wq; /* for all wait_event() use */ member in struct:wil6210_priv
/drivers/scsi/lpfc/
H A Dlpfc_bsg.c52 wait_queue_head_t wq; member in struct:lpfc_bsg_event
855 init_waitqueue_head(&evt->wq);
1113 wake_up_interruptible(&evt->wq);
2636 evt->wq, !list_empty(&evt->events_to_see),
3215 evt->wq, !list_empty(&evt->events_to_see),
/drivers/scsi/mpt3sas/
H A Dmpt3sas_base.c264 struct workqueue_struct *wq; local
267 wq = ioc->fault_reset_work_q;
270 if (wq) {
272 flush_workqueue(wq);
273 destroy_workqueue(wq);
/drivers/block/drbd/
H A Ddrbd_main.c2217 struct workqueue_struct *wq; member in struct:retry_worker
2290 queue_work(retry.wq, &retry.worker);
2335 if (retry.wq)
2336 destroy_workqueue(retry.wq);
2414 static void drbd_init_workqueue(struct drbd_work_queue* wq) argument
2416 spin_lock_init(&wq->q_lock);
2417 INIT_LIST_HEAD(&wq->q);
2418 init_waitqueue_head(&wq->q_wait);
2710 device->submit.wq = alloc_workqueue("drbd%u_submit",
2712 if (!device->submit.wq)
[all...]
/drivers/infiniband/hw/cxgb3/
H A Dcxio_wr.h698 u32 size_log2; /* total wq size */
747 static inline void cxio_set_wq_in_error(struct t3_wq *wq) argument
749 wq->queue->wq_in_err.err |= 1;
752 static inline void cxio_disable_wq_db(struct t3_wq *wq) argument
754 wq->queue->wq_in_err.err |= 2;
757 static inline void cxio_enable_wq_db(struct t3_wq *wq) argument
759 wq->queue->wq_in_err.err &= ~2;
762 static inline int cxio_wq_db_enabled(struct t3_wq *wq) argument
764 return !(wq->queue->wq_in_err.err & 2);
/drivers/infiniband/hw/cxgb4/
H A Diw_cxgb4.h484 struct t4_wq wq; member in struct:c4iw_qp
1012 void c4iw_count_rcqes(struct t4_cq *cq, struct t4_wq *wq, int *count);
1014 int c4iw_flush_rq(struct t4_wq *wq, struct t4_cq *cq, int count);
1029 extern void c4iw_log_wr_stats(struct t4_wq *wq, struct t4_cqe *cqe);
/drivers/infiniband/hw/ipath/
H A Dipath_verbs.h303 * Note that the wq array elements are variable size so you can't
310 struct ipath_rwqe wq[0]; member in struct:ipath_rwq
314 struct ipath_rwq *wq; member in struct:ipath_rq
491 * struct ipath_rwq.wq. This function does the array index computation.
497 ((char *) rq->wq->wq +
/drivers/infiniband/hw/qib/
H A Dqib_verbs.h364 * Note that the wq array elements are variable size so you can't
371 struct qib_rwqe wq[0]; member in struct:qib_rwq
375 struct qib_rwq *wq; member in struct:qib_rq
620 * struct qib_rwq.wq. This function does the array index computation.
625 ((char *) rq->wq->wq +
/drivers/media/usb/cx231xx/
H A Dcx231xx.h248 wait_queue_head_t wq; member in struct:cx231xx_dmaqueue
/drivers/media/usb/em28xx/
H A Dem28xx.h284 wait_queue_head_t wq; member in struct:em28xx_dmaqueue
/drivers/message/fusion/
H A Dmptbase.c2062 struct workqueue_struct *wq; local
2068 wq = ioc->reset_work_q;
2072 destroy_workqueue(wq);
2075 wq = ioc->fw_event_q;
2078 destroy_workqueue(wq);
/drivers/misc/cxl/
H A Dcxl.h398 wait_queue_head_t wq; member in struct:cxl_context
/drivers/net/ethernet/broadcom/genet/
H A Dbcmgenet.h546 wait_queue_head_t wq; member in struct:bcmgenet_priv
/drivers/nfc/
H A Dpn533.c357 struct workqueue_struct *wq; member in struct:pn533
749 queue_work(dev->wq, &dev->cmd_complete_work);
803 queue_work(dev->wq, &dev->cmd_complete_work);
1066 queue_work(dev->wq, &dev->cmd_work);
1651 queue_work(dev->wq, &dev->mi_tm_rx_work);
1733 queue_work(dev->wq, &dev->cmd_work);
1794 queue_work(dev->wq, &dev->tg_work);
1809 queue_delayed_work(dev->wq, &dev->poll_work,
1828 queue_delayed_work(dev->wq, &dev->poll_work,
1876 queue_work(dev->wq,
[all...]

Completed in 597 milliseconds

123456