Home
last modified time | relevance | path

Searched refs:wq_queue (Results 1 – 3 of 3) sorted by relevance

/netbsd-src/external/cddl/osnet/dist/tools/ctf/cvt/
H A Dctfmerge.c368 assert(fifo_len(wq->wq_queue) == 0); in init_phase_two()
369 fifo_free(wq->wq_queue, NULL); in init_phase_two()
370 wq->wq_queue = wq->wq_donequeue; in init_phase_two()
433 while (fifo_empty(wq->wq_queue)) { in worker_runphase1()
453 pow = fifo_remove(wq->wq_queue); in worker_runphase1()
520 if (fifo_len(wq->wq_queue) < 2) { in worker_runphase2()
532 pow1 = fifo_remove(wq->wq_queue); in worker_runphase2()
533 pow2 = fifo_remove(wq->wq_queue); in worker_runphase2()
564 fifo_add(wq->wq_queue, pow2); in worker_runphase2()
567 fifo_len(wq->wq_queue), wq->wq_ninqueue); in worker_runphase2()
[all …]
H A Dctfmerge.h64 fifo_t *wq_queue; member
/netbsd-src/sys/external/bsd/common/linux/
H A Dlinux_work.c60 struct work_head wq_queue; /* work to run */ member
269 TAILQ_INIT(&wq->wq_queue); in alloc_workqueue()
287 KASSERT(TAILQ_EMPTY(&wq->wq_queue)); in alloc_workqueue()
379 KASSERT(TAILQ_EMPTY(&wq->wq_queue)); in destroy_workqueue()
404 struct work_head *const q[2] = { &wq->wq_queue, &wq->wq_dqueue }; in linux_workqueue_thread()
416 if (TAILQ_EMPTY(&wq->wq_queue) && in linux_workqueue_thread()
717 TAILQ_INSERT_TAIL(&wq->wq_queue, work, work_entry); in queue_work()
765 TAILQ_REMOVE(&wq->wq_queue, work, work_entry); in cancel_work()
814 TAILQ_REMOVE(&wq->wq_queue, work, work_entry); in cancel_work_sync()
1506 done &= TAILQ_EMPTY(&wq->wq_queue); in drain_workqueue()
[all …]