/drivers/staging/lustre/lustre/ptlrpc/ |
H A D | client.c | 2342 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 D | rtw_cmd.h | 46 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 D | f_mtp.c | 106 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 D | tcm_usb_gadget.c | 2322 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 D | omapfb-main.c | 1706 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 D | cm.c | 82 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 D | mlx4_ib.h | 356 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 D | qp.c | 1739 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 D | dm.c | 174 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 D | dm-cache-target.c | 251 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 D | dm-thin.c | 178 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 D | wil6210.h | 402 wait_queue_head_t wq; /* for all wait_event() use */ member in struct:wil6210_priv
|
/drivers/scsi/lpfc/ |
H A D | lpfc_bsg.c | 52 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 D | mpt3sas_base.c | 264 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 D | drbd_main.c | 2217 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 D | cxio_wr.h | 698 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 D | iw_cxgb4.h | 484 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 D | ipath_verbs.h | 303 * 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 D | qib_verbs.h | 364 * 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 D | cx231xx.h | 248 wait_queue_head_t wq; member in struct:cx231xx_dmaqueue
|
/drivers/media/usb/em28xx/ |
H A D | em28xx.h | 284 wait_queue_head_t wq; member in struct:em28xx_dmaqueue
|
/drivers/message/fusion/ |
H A D | mptbase.c | 2062 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 D | cxl.h | 398 wait_queue_head_t wq; member in struct:cxl_context
|
/drivers/net/ethernet/broadcom/genet/ |
H A D | bcmgenet.h | 546 wait_queue_head_t wq; member in struct:bcmgenet_priv
|
/drivers/nfc/ |
H A D | pn533.c | 357 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...] |