Lines Matching refs:wq_queue
346 assert(fifo_len(wq->wq_queue) == 0); in init_phase_two()
347 fifo_free(wq->wq_queue, NULL); in init_phase_two()
348 wq->wq_queue = wq->wq_donequeue; in init_phase_two()
399 while (fifo_empty(wq->wq_queue)) { in worker_runphase1()
413 pow = fifo_remove(wq->wq_queue); in worker_runphase1()
461 if (fifo_len(wq->wq_queue) < 2) { in worker_runphase2()
469 pow1 = fifo_remove(wq->wq_queue); in worker_runphase2()
470 pow2 = fifo_remove(wq->wq_queue); in worker_runphase2()
494 fifo_add(wq->wq_queue, pow2); in worker_runphase2()
496 pthread_self(), (void *)pow2, fifo_len(wq->wq_queue), in worker_runphase2()
523 wq->wq_ninqueue, fifo_len(wq->wq_queue)); in worker_thread()
547 while (fifo_len(wq->wq_queue) > wq->wq_ithrottle) { in merge_ctf_cb()
549 fifo_len(wq->wq_queue), wq->wq_ithrottle); in merge_ctf_cb()
553 fifo_add(wq->wq_queue, td); in merge_ctf_cb()
660 wq->wq_queue = fifo_new(); in wq_init()
922 assert(fifo_len(wq.wq_queue) == 1); in main()
923 mstrtd = fifo_remove(wq.wq_queue); in main()