Searched refs:wq_queue (Results 1 – 2 of 2) sorted by relevance
356 assert(fifo_len(wq->wq_queue) == 0); in init_phase_two()357 fifo_free(wq->wq_queue, NULL); in init_phase_two()358 wq->wq_queue = wq->wq_donequeue; in init_phase_two()409 while (fifo_empty(wq->wq_queue)) { in worker_runphase1()423 pow = fifo_remove(wq->wq_queue); in worker_runphase1()471 if (fifo_len(wq->wq_queue) < 2) { in worker_runphase2()479 pow1 = fifo_remove(wq->wq_queue); in worker_runphase2()480 pow2 = fifo_remove(wq->wq_queue); in worker_runphase2()504 fifo_add(wq->wq_queue, pow2); in worker_runphase2()506 pthread_self(), (void *)pow2, fifo_len(wq->wq_queue), in worker_runphase2()[all …]
64 fifo_t *wq_queue; member