Lines Matching refs:wq_queue
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()
533 wq->wq_ninqueue, fifo_len(wq->wq_queue)); in worker_thread()
557 while (fifo_len(wq->wq_queue) > wq->wq_ithrottle) { in merge_ctf_cb()
559 fifo_len(wq->wq_queue), wq->wq_ithrottle); in merge_ctf_cb()
563 fifo_add(wq->wq_queue, td); in merge_ctf_cb()
673 wq->wq_queue = fifo_new(); in wq_init()
942 assert(fifo_len(wq.wq_queue) == 1); in main()
943 mstrtd = fifo_remove(wq.wq_queue); in main()