Searched refs:zstream_queue_t (Results 1 – 4 of 4) sorted by relevance
71 typedef struct zstream_queue zstream_queue_t; typedef105 zstream_queue_t *113 zstream_enqueue(zstream_queue_t *queue, queue_item_t *item);126 zstream_dequeue(zstream_queue_t *queue, queue_item_t *item);134 zstream_queue_fini(zstream_queue_t *queue);
163 zstream_queue_t *tp_queues[ZQ_MAX_QUEUES];184 static void print_batch_size_histogram(zstream_queue_t *);280 zstream_queue_t *300 zstream_queue_t *queue = safe_malloc(sizeof (zstream_queue_t)); in zstream_queue_create()301 *queue = (zstream_queue_t) { in zstream_queue_create()364 advance_indexes(zstream_queue_t *queue) in advance_indexes()411 score_queue(zstream_queue_t *queue) in score_queue()478 claim_batch(zstream_queue_t *queue, queue_slot_t **batch) in claim_batch()531 assign_queue_and_get_work(zstream_queue_t **queue, queue_slot_t **batch) in assign_queue_and_get_work()541 zstream_queue_t *to_score = pool.tp_queues[i]; in assign_queue_and_get_work()[all …]
55 zstream_queue_t *wc_in_queue;56 zstream_queue_t *wc_out_queue;208 zstream_queue_t *queue; in zstream_chain_exec()
100 zstream_queue_t *qr_queue;