Searched refs:qr_queue (Results 1 – 1 of 1) sorted by relevance
100 zstream_queue_t *qr_queue; member223 zstream_enqueue(run->qr_queue, item); in qtest_producer()228 zstream_queue_fini(run->qr_queue); in qtest_producer()249 while (zstream_dequeue(run->qr_queue, item)) { in qtest_consumer()319 runs[i].qr_queue = zstream_queue_create(¶ms); in run_queue_workloads()