/src/share/examples/puffs/pgfs/ |
pgfs_waitq.c | 50 waitq_init(struct waitq *wq) 53 TAILQ_INIT(wq); 57 waiton(struct waitq *wq, struct puffs_cc *cc) 66 TAILQ_INSERT_TAIL(wq, &w, list); 71 wakeup_one(struct waitq *wq) 76 w = TAILQ_FIRST(wq); 78 TAILQ_REMOVE(wq, w, list); 88 wakeup(struct waitq *wq) 93 TAILQ_FOREACH(w, wq, list) { 97 TAILQ_INIT(wq); [all...] |
/src/sys/external/bsd/common/linux/ |
linux_work.c | 90 "struct work_struct *"/*work*/, "struct workqueue_struct *"/*wq*/); 92 "struct work_struct *"/*work*/, "struct workqueue_struct *"/*wq*/); 94 "struct work_struct *"/*work*/, "struct workqueue_struct *"/*wq*/); 96 "struct rcu_work *"/*work*/, "struct workqueue_struct *"/*wq*/); 98 "struct work_struct *"/*work*/, "struct workqueue_struct *"/*wq*/); 100 "struct delayed_work *"/*dw*/, "struct workqueue_struct *"/*wq*/, 103 "struct delayed_work *"/*dw*/, "struct workqueue_struct *"/*wq*/); 105 "struct delayed_work *"/*dw*/, "struct workqueue_struct *"/*wq*/); 107 "struct delayed_work *"/*dw*/, "struct workqueue_struct *"/*wq*/); 109 "struct work_struct *"/*work*/, "struct workqueue_struct *"/*wq*/); 258 struct workqueue_struct *wq; local in function:alloc_workqueue 403 struct workqueue_struct *const wq = cookie; local in function:linux_workqueue_thread 490 struct workqueue_struct *const wq = work_queue(&dw->work); local in function:linux_workqueue_timeout 536 struct workqueue_struct *wq = lwp_getspecific(workqueue_key); local in function:current_work 743 struct workqueue_struct *wq; local in function:cancel_work 792 struct workqueue_struct *wq; local in function:cancel_work_sync 1239 struct workqueue_struct *wq; local in function:cancel_delayed_work 1329 struct workqueue_struct *wq; local in function:cancel_delayed_work_sync 1524 struct workqueue_struct *wq; local in function:flush_work 1544 struct workqueue_struct *wq; local in function:flush_delayed_work 1646 struct workqueue_struct *wq = work_queue(&rw->work); local in function:queue_rcu_work_cb [all...] |
/src/sys/kern/ |
subr_workqueue.c | 75 "struct workqueue *"/*wq*/, 83 "struct workqueue *"/*wq*/); 86 "struct workqueue *"/*wq*/, 90 "struct workqueue *"/*wq*/, 95 "struct workqueue *"/*wq*/, 100 "struct workqueue *"/*wq*/, 103 "struct workqueue *"/*wq*/, 106 "struct workqueue *"/*wq*/, 109 "struct workqueue *"/*wq*/, 113 "struct workqueue *"/*wq*/); 164 struct workqueue *wq = cookie; local in function:workqueue_worker 303 struct workqueue *wq; local in function:workqueue_create [all...] |
/src/tests/rump/kernspace/ |
workqueue.c | 48 struct workqueue *wq; member in struct:test_softc 79 rv = workqueue_create(&sc->wq, "rumpwq", 95 workqueue_destroy(sc->wq); 109 workqueue_enqueue(sc->wq, &sc->wk, NULL); 133 workqueue_enqueue(sc->wq, &sc->wk, NULL); 134 workqueue_wait(sc->wq, &sc->wk); 141 workqueue_wait(sc->wq, &dummy); 161 workqueue_enqueue(sc->wq, &wk, NULL); 162 workqueue_enqueue(sc->wq, &sc->wk, NULL); 164 workqueue_wait(sc->wq, &sc->wk) [all...] |
/src/sys/external/bsd/drm2/dist/drm/i915/ |
i915_sw_fence.c | 163 drm_waitqueue_t wq; member in struct:i915_sw_fence_wq 173 DRM_SPIN_WAKEUP_ALL(&sfw->wq, &sfw->fence->wait.lock); 190 DRM_INIT_WAITQUEUE(&sfw.wq, "i915swf"); 194 DRM_SPIN_WAIT_NOINTR_UNTIL(ret, &sfw.wq, &fence->wait.lock, 199 DRM_DESTROY_WAITQUEUE(&sfw.wq); 322 static int i915_sw_fence_wake(wait_queue_entry_t *wq, unsigned mode, int flags, void *key) 324 i915_sw_fence_set_error_once(wq->private, flags); 326 list_del(&wq->entry); 327 __i915_sw_fence_complete(wq->private, key); 329 if (wq->flags & I915_SW_FENCE_FLAG_ALLOC 337 wait_queue_entry_t *wq; local in function:__i915_sw_fence_check_if_after 358 wait_queue_entry_t *wq; local in function:__i915_sw_fence_clear_checked_bit [all...] |
intel_wakeref.c | 31 DRM_WAKEUP_ALL(&wf->wq, &wf->mutex); 115 DRM_INIT_WAITQUEUE(&wf->wq, "i915wake"); 125 DRM_DESTROY_WAITQUEUE(&wf->wq); 136 DRM_WAIT_UNTIL(err, &wf->wq, &wf->mutex, !intel_wakeref_is_active(wf));
|
i915_sw_fence.h | 82 wait_queue_entry_t *wq);
|
intel_wakeref.h | 44 drm_waitqueue_t wq; member in struct:intel_wakeref
|
/src/sys/external/bsd/drm2/dist/drm/radeon/ |
radeon_sa.c | 63 DRM_INIT_WAITQUEUE(&sa_manager->wq, "radsabom"); 65 init_waitqueue_head(&sa_manager->wq); 105 DRM_DESTROY_WAITQUEUE(&sa_manager->wq); 350 spin_lock(&sa_manager->wq.lock); 366 spin_unlock(&sa_manager->wq.lock); 385 DRM_SPIN_WAIT_UNTIL(r, &sa_manager->wq, 389 spin_unlock(&sa_manager->wq.lock); 393 spin_lock(&sa_manager->wq.lock); 397 sa_manager->wq, 408 spin_unlock(&sa_manager->wq.lock) [all...] |
/src/sys/external/bsd/drm2/dist/include/drm/ |
drm_debugfs_crc.h | 57 * @wq: workqueue used to synchronize reading and writing 67 wait_queue_head_t wq; member in struct:drm_crtc_crc
|
drm_flip_work.h | 91 struct workqueue_struct *wq);
|
/src/sys/external/bsd/drm2/dist/drm/amd/amdkfd/ |
kfd_events.h | 63 wait_queue_head_t wq; /* List of event waiters. */ member in struct:kfd_event
|
kfd_events.c | 248 list_for_each_entry(waiter, &ev->wq.head, wait.entry) 250 wake_up_all(&ev->wq); 342 init_waitqueue_head(&ev->wq); 402 ev->signaled = !ev->auto_reset || !waitqueue_active(&ev->wq); 404 list_for_each_entry(waiter, &ev->wq.head, wait.entry) 407 wake_up_all(&ev->wq); 572 add_wait_queue(&ev->wq, &waiter->wait); 663 remove_wait_queue(&waiters[i].event->wq,
|
/src/sys/external/bsd/drm2/dist/drm/i915/selftests/ |
mock_gem_device.c | 72 destroy_workqueue(i915->wq); 176 i915->wq = alloc_ordered_workqueue("mock", 0); 177 if (!i915->wq) 202 destroy_workqueue(i915->wq);
|
/src/sys/dev/sysmon/ |
swwdog.c | 69 static struct workqueue *wq; variable in typeref:struct:workqueue * 116 if (workqueue_create(&wq, "swwreboot", doreboot, NULL, 118 aprint_error("failed to create swwdog reboot wq"); 126 workqueue_destroy(wq); 142 workqueue_destroy(wq); 192 workqueue_destroy(wq); 268 workqueue_enqueue(wq, &wk, NULL);
|
/src/sys/external/bsd/drm2/dist/drm/amd/amdgpu/ |
amdgpu_sa.c | 62 DRM_INIT_WAITQUEUE(&sa_manager->wq, "amdsabom"); 106 DRM_DESTROY_WAITQUEUE(&sa_manager->wq); 340 DRM_SPIN_WAIT_UNTIL(r, &sa_manager->wq, 373 DRM_SPIN_WAKEUP_ALL(&sa_manager->wq, &sa_manager->wq_lock); 385 spin_lock(&sa_manager->wq.lock); 403 spin_unlock(&sa_manager->wq.lock);
|
/src/sys/external/bsd/drm2/dist/drm/ |
drm_flip_work.c | 99 * @wq: the work-queue to run the queued work on 107 struct workqueue_struct *wq) 115 queue_work(wq, &work->worker);
|
drm_debugfs_crc.c | 310 ret = wait_event_interruptible_lock_irq(crc->wq, 353 poll_wait(file, &crc->wq, wait); 437 wake_up_interruptible(&crc->wq);
|
/src/sys/external/bsd/drm2/dist/drm/i915/gem/ |
i915_gem_pm.c | 26 flush_workqueue(i915->wq);
|
/src/sys/external/bsd/drm2/linux/ |
linux_kthread.c | 133 drm_waitqueue_t *wq) 151 T->kt_wq = wq; 169 spinlock_t *interlock, drm_waitqueue_t *wq) 174 T = kthread_alloc(func, cookie, interlock, wq);
|
/src/sys/external/bsd/ena-com/ |
ena_plat.h | 228 #define ena_wait_event_t struct { kcondvar_t wq; kmutex_t mtx; } 231 cv_init(&((waitqueue).wq), "enacv"); \ 236 cv_destroy(&((waitqueue).wq)); \ 240 cv_init(&((waitqueue).wq), "enacv") 244 cv_timedwait(&((waitqueue).wq), &((waitqueue).mtx), \ 251 cv_broadcast(&((waitqueue).wq)); \
|
/src/sys/external/bsd/drm2/dist/drm/nouveau/nvkm/engine/disp/ |
nv50.h | 19 struct workqueue_struct *wq; member in struct:nv50_disp
|
/src/sys/external/bsd/drm2/dist/drm/via/ |
via_dmablit.h | 96 struct work_struct wq; member in struct:_drm_via_blitq
|
/src/sys/external/bsd/drm2/dist/drm/vmwgfx/ |
vmwgfx_fence.c | 164 drm_waitqueue_t wq; member in struct:vmwgfx_wait_cb 177 DRM_SPIN_WAKEUP_ALL(&wait->wq, fence->lock); 212 DRM_INIT_WAITQUEUE(&cb.wq, "vmwgfxwf"); 225 DRM_SPIN_TIMED_WAIT_UNTIL(ret, &cb.wq, f->lock, timeout, C); 227 DRM_SPIN_TIMED_WAIT_NOINTR_UNTIL(ret, &cb.wq, f->lock, timeout, 275 DRM_DESTROY_WAITQUEUE(&cb.wq);
|
/src/sys/dev/pci/cxgb/ |
cxgb_main.c | 287 workqueue_create(&w->wq, w->name, w->func, w->context, PRIBIO, IPL_NET, 0); 288 // printf("======>> create workqueue for %s %p\n", w->name, w->wq); 802 if (p->start_task.wq != NULL) { 803 workqueue_destroy(p->start_task.wq); 804 p->start_task.wq = NULL; 941 workqueue_enqueue(sc->ext_intr_task.wq, &sc->ext_intr_task.w, NULL); 1469 workqueue_enqueue(pi->timer_reclaim_task.wq, &pi->timer_reclaim_task.w, NULL); 1487 workqueue_enqueue(pi->timer_reclaim_task.wq, &pi->timer_reclaim_task.w, NULL); 1492 workqueue_enqueue(pi->start_task.wq, &pi->start_task.w, NULL); 1554 workqueue_enqueue(sc->slow_intr_task.wq, &sc->slow_intr_task.w, NULL) [all...] |