Home
last modified time | relevance | path

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

/titanic_50/usr/src/tools/ctf/cvt/
H A Dctfmerge.c346 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()
[all …]
H A Dctfmerge.h64 fifo_t *wq_queue; member
/titanic_50/usr/src/uts/common/io/ib/clients/rdsv3/
H A Drdsv3_impl.c528 work = list_remove_head(&wq->wq_queue); in rdsv3_worker_thread()
536 work = list_remove_head(&wq->wq_queue); in rdsv3_worker_thread()
558 ASSERT(list_is_empty(&wq->wq_queue)); in rdsv3_flush_workqueue()
598 list_insert_tail(&wq->wq_queue, wp); in rdsv3_queue_work()
610 list_insert_tail(&wq->wq_queue, wp); in rdsv3_queue_work()
617 list_insert_tail(&wq->wq_queue, wp); in rdsv3_queue_work()
746 list_destroy(&wq->wq_queue); in rdsv3_destroy_task_workqueue()
790 list_create(&wq->wq_queue, sizeof (struct rdsv3_work_s), in rdsv3_create_task_workqueue()
/titanic_50/usr/src/uts/common/sys/ib/clients/rdsv3/
H A Drdsv3_impl.h252 list_t wq_queue; member