Lines Matching refs:wq_queue
72 * 2. T1 reads an input file from the input queue (wq_queue). This is the
95 * When this is complete, wq_done_queue is moved to wq_queue, and Phase II
100 * The input queue (wq_queue) and the done queue (wq_done_queue) are
138 * The queue (wq_queue), ninqueue, and the master batch ID and last
348 assert(fifo_len(wq->wq_queue) == 0);
349 fifo_free(wq->wq_queue, NULL);
350 wq->wq_queue = wq->wq_donequeue;
401 while (fifo_empty(wq->wq_queue)) {
415 pow = fifo_remove(wq->wq_queue);
463 if (fifo_len(wq->wq_queue) < 2) {
471 pow1 = fifo_remove(wq->wq_queue);
472 pow2 = fifo_remove(wq->wq_queue);
496 fifo_add(wq->wq_queue, pow2);
498 pthread_self(), (void *)pow2, fifo_len(wq->wq_queue),
525 wq->wq_ninqueue, fifo_len(wq->wq_queue));
549 while (fifo_len(wq->wq_queue) > wq->wq_ithrottle) {
551 fifo_len(wq->wq_queue), wq->wq_ithrottle);
555 fifo_add(wq->wq_queue, td);
662 wq->wq_queue = fifo_new();
931 assert(fifo_len(wq.wq_queue) == 1);
932 mstrtd = fifo_remove(wq.wq_queue);