Searched refs:wq (Results 1 - 25 of 54) sorted by relevance

123

/openbsd-current/usr.sbin/smtpd/
H A Dwaitq.c57 struct waitq *wq, key; local
61 wq = SPLAY_FIND(waitqtree, &waitqs, &key);
62 if (wq == NULL) {
63 wq = xmalloc(sizeof *wq);
64 wq->tag = tag;
65 TAILQ_INIT(&wq->waiters);
66 SPLAY_INSERT(waitqtree, &waitqs, wq);
72 TAILQ_INSERT_TAIL(&wq->waiters, w, entry);
74 return (w == TAILQ_FIRST(&wq
80 struct waitq *wq, key; local
[all...]
/openbsd-current/sys/dev/pci/drm/i915/
H A Di915_sw_fence.c269 static int i915_sw_fence_wake(wait_queue_entry_t *wq, unsigned mode, int flags, void *key) argument
271 i915_sw_fence_set_error_once(wq->private, flags);
273 list_del(&wq->entry);
274 __i915_sw_fence_complete(wq->private, key);
276 if (wq->flags & I915_SW_FENCE_FLAG_ALLOC)
277 kfree(wq);
285 wait_queue_entry_t *wq; local
293 list_for_each_entry(wq, &fence->wait.head, entry) {
294 if (wq->func != i915_sw_fence_wake)
297 if (__i915_sw_fence_check_if_after(wq
306 wait_queue_entry_t *wq; local
340 __i915_sw_fence_await_sw_fence(struct i915_sw_fence *fence, struct i915_sw_fence *signaler, wait_queue_entry_t *wq, gfp_t gfp) argument
396 i915_sw_fence_await_sw_fence(struct i915_sw_fence *fence, struct i915_sw_fence *signaler, wait_queue_entry_t *wq) argument
[all...]
H A Di915_sw_fence.h74 wait_queue_entry_t *wq);
/openbsd-current/sys/dev/pci/drm/
H A Ddrm_suballoc.c75 init_waitqueue_head(&sa_manager->wq);
218 spin_lock(&sa_manager->wq.lock);
220 spin_unlock(&sa_manager->wq.lock);
338 spin_lock(&sa_manager->wq.lock);
348 spin_unlock(&sa_manager->wq.lock);
362 spin_unlock(&sa_manager->wq.lock);
370 spin_lock(&sa_manager->wq.lock);
374 (sa_manager->wq,
377 spin_unlock(&sa_manager->wq.lock);
378 wait_event(sa_manager->wq,
[all...]
H A Ddrm_flip_work.c94 * @wq: the work-queue to run the queued work on
102 struct workqueue_struct *wq)
110 queue_work(wq, &work->worker);
101 drm_flip_work_commit(struct drm_flip_work *work, struct workqueue_struct *wq) argument
H A Ddrm_debugfs_crc.c307 ret = wait_event_interruptible_lock_irq(crc->wq,
350 poll_wait(file, &crc->wq, wait);
434 wake_up_interruptible(&crc->wq);
/openbsd-current/sys/dev/pci/drm/include/linux/
H A Dworkqueue.h67 destroy_workqueue(struct workqueue_struct *wq) argument
69 taskq_destroy((struct taskq *)wq);
89 queue_work(struct workqueue_struct *wq, struct work_struct *work) argument
91 work->tq = (struct taskq *)wq;
169 queue_delayed_work(struct workqueue_struct *wq, argument
172 dwork->tq = (struct taskq *)wq;
177 mod_delayed_work(struct workqueue_struct *wq, argument
180 dwork->tq = (struct taskq *)wq;
223 drain_workqueue(struct workqueue_struct *wq) argument
225 flush_workqueue(wq);
252 queue_rcu_work(struct workqueue_struct *wq, struct rcu_work *work) argument
[all...]
/openbsd-current/sys/dev/pci/drm/include/drm/
H A Ddrm_debugfs_crc.h51 * @wq: workqueue used to synchronize reading and writing
60 wait_queue_head_t wq; member in struct:drm_crtc_crc
H A Ddrm_flip_work.h87 struct workqueue_struct *wq);
H A Ddrm_suballoc.h17 * @wq: Wait queue for sleeping allocations on contention.
25 wait_queue_head_t wq; member in struct:drm_suballoc_manager
/openbsd-current/sys/dev/pci/drm/amd/amdgpu/
H A Damdgpu_reset.c122 if (reset_domain->wq)
123 destroy_workqueue(reset_domain->wq);
142 reset_domain->wq = create_singlethread_workqueue(wq_name);
143 if (!reset_domain->wq) {
144 DRM_ERROR("Failed to allocate wq for amdgpu_reset_domain!");
H A Damdgpu_reset.h83 struct workqueue_struct *wq; member in struct:amdgpu_reset_domain
122 return queue_work(domain->wq, work);
/openbsd-current/sys/dev/pci/drm/amd/amdkfd/
H A Dkfd_events.h64 wait_queue_head_t wq; /* List of event waiters. */ member in struct:kfd_event
H A Dkfd_events.c267 list_for_each_entry(waiter, &ev->wq.head, wait.entry)
269 wake_up_all(&ev->wq);
411 init_waitqueue_head(&ev->wq);
487 init_waitqueue_head(&ev->wq);
632 ev->signaled = !ev->auto_reset || !waitqueue_active(&ev->wq);
639 list_for_each_entry(waiter, &ev->wq.head, wait.entry)
642 wake_up_all(&ev->wq);
821 add_wait_queue(&ev->wq, &waiter->wait);
923 remove_wait_queue(&waiters[i].event->wq,
/openbsd-current/sys/dev/pci/drm/i915/gt/uc/
H A Dintel_gsc_uc.c141 gsc->wq = alloc_ordered_workqueue("i915_gsc", 0);
142 if (!gsc->wq) {
261 if (gsc->wq) {
262 destroy_workqueue(gsc->wq);
263 gsc->wq = NULL;
317 queue_work(gsc->wq, &gsc->work);
H A Dintel_gsc_uc.h44 struct workqueue_struct *wq; member in struct:intel_gsc_uc
H A Dintel_guc_ct.h74 /** @wq: wait queue for g2h chanenl */
75 wait_queue_head_t wq; member in struct:intel_guc_ct
/openbsd-current/sys/dev/pci/
H A Dif_oce.c126 #define OCE_WQ_FOREACH(sc, wq, i) \
127 for (i = 0, wq = sc->sc_wq[0]; i < sc->sc_nwq; i++, wq = sc->sc_wq[i])
1045 struct oce_wq *wq; local
1097 OCE_WQ_FOREACH(sc, wq, i)
1098 oce_arm_cq(wq->cq, 0, TRUE);
1126 struct oce_wq *wq; local
1152 OCE_WQ_FOREACH(sc, wq, i)
1153 oce_drain_wq(wq);
1202 struct oce_wq *wq local
1427 struct oce_wq *wq = (struct oce_wq *)arg; local
1456 oce_txeof(struct oce_wq *wq) argument
1895 struct oce_wq *wq; local
1942 struct oce_wq *wq; local
1974 struct oce_wq *wq; local
2033 oce_drain_wq(struct oce_wq *wq) argument
2049 oce_destroy_wq(struct oce_wq *wq) argument
3287 oce_new_wq(struct oce_softc *sc, struct oce_wq *wq) argument
[all...]
/openbsd-current/sys/dev/pci/drm/i915/selftests/
H A Dmock_gem_device.c73 destroy_workqueue(i915->wq);
212 i915->wq = alloc_ordered_workqueue("mock", 0);
213 if (!i915->wq)
252 destroy_workqueue(i915->wq);
/openbsd-current/sys/dev/pci/drm/ttm/
H A Dttm_device.c203 bdev->wq = alloc_workqueue("ttm", WQ_MEM_RECLAIM | WQ_HIGHPRI, 16);
204 if (!bdev->wq) {
235 drain_workqueue(bdev->wq);
236 destroy_workqueue(bdev->wq);
/openbsd-current/sys/dev/pci/drm/i915/display/
H A Dintel_display_driver.c228 i915->display.wq.modeset = alloc_ordered_workqueue("i915_modeset", 0);
229 i915->display.wq.flip = alloc_workqueue("i915_flip", WQ_HIGHPRI |
417 flush_workqueue(i915->display.wq.flip);
418 flush_workqueue(i915->display.wq.modeset);
459 destroy_workqueue(i915->display.wq.flip);
460 destroy_workqueue(i915->display.wq.modeset);
/openbsd-current/sys/dev/pci/drm/include/drm/ttm/
H A Dttm_device.h270 * @wq: Work queue structure for the delayed delete workqueue.
272 struct workqueue_struct *wq; member in struct:ttm_device
/openbsd-current/sys/dev/acpi/
H A Dacpi.c1809 struct acpi_taskq *wq; local
1812 wq = pool_get(&acpiwqpool, PR_ZERO | PR_NOWAIT);
1813 if (wq == NULL) {
1817 wq->handler = handler;
1818 wq->arg0 = arg0;
1819 wq->arg1 = arg1;
1822 SIMPLEQ_INSERT_TAIL(&acpi_taskq, wq, next);
1829 struct acpi_taskq *wq; local
1839 wq = SIMPLEQ_FIRST(&acpi_taskq);
1843 wq
2343 struct acpi_wakeq *wq; local
[all...]
/openbsd-current/sys/dev/usb/dwc2/
H A Ddwc2.h279 queue_delayed_work(struct taskq *wq, struct delayed_work *dw, int j) argument
281 dw->dw_wq = wq;
/openbsd-current/sys/dev/pci/drm/ttm/tests/
H A Dttm_device_test.c32 KUNIT_ASSERT_NOT_NULL(test, ttm_dev->wq);
63 KUNIT_ASSERT_NOT_NULL(test, ttm_devs[i].wq);

Completed in 414 milliseconds

123