/openbsd-current/usr.sbin/smtpd/ |
H A D | waitq.c | 57 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 D | i915_sw_fence.c | 269 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 D | i915_sw_fence.h | 74 wait_queue_entry_t *wq);
|
/openbsd-current/sys/dev/pci/drm/ |
H A D | drm_suballoc.c | 75 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 D | drm_flip_work.c | 94 * @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 D | drm_debugfs_crc.c | 307 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 D | workqueue.h | 67 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 D | drm_debugfs_crc.h | 51 * @wq: workqueue used to synchronize reading and writing 60 wait_queue_head_t wq; member in struct:drm_crtc_crc
|
H A D | drm_flip_work.h | 87 struct workqueue_struct *wq);
|
H A D | drm_suballoc.h | 17 * @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 D | amdgpu_reset.c | 122 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 D | amdgpu_reset.h | 83 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 D | kfd_events.h | 64 wait_queue_head_t wq; /* List of event waiters. */ member in struct:kfd_event
|
H A D | kfd_events.c | 267 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 D | intel_gsc_uc.c | 141 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 D | intel_gsc_uc.h | 44 struct workqueue_struct *wq; member in struct:intel_gsc_uc
|
H A D | intel_guc_ct.h | 74 /** @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 D | if_oce.c | 126 #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 D | mock_gem_device.c | 73 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 D | ttm_device.c | 203 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 D | intel_display_driver.c | 228 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 D | ttm_device.h | 270 * @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 D | acpi.c | 1809 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 D | dwc2.h | 279 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 D | ttm_device_test.c | 32 KUNIT_ASSERT_NOT_NULL(test, ttm_dev->wq); 63 KUNIT_ASSERT_NOT_NULL(test, ttm_devs[i].wq);
|