Searched refs:zstream_queue_t (Results 1 – 4 of 4) sorted by relevance
182 zstream_queue_t *tp_queues[ZQ_MAX_QUEUES];203 static inline void initialize_monitor_data(zstream_queue_t *);204 static inline void update_monitor_data(zstream_queue_t *);208 static void print_batch_size_histogram(zstream_queue_t *);304 zstream_queue_t *322 zstream_queue_t *queue = safe_malloc(sizeof (zstream_queue_t)); in zstream_queue_create()323 *queue = (zstream_queue_t) { in zstream_queue_create()387 advance_indexes(zstream_queue_t *queue) in advance_indexes()433 score_queue(zstream_queue_t *queue) in score_queue()498 claim_batch(zstream_queue_t *queue, queue_slot_t **batch) in claim_batch()[all …]
78 typedef struct zstream_queue zstream_queue_t; typedef110 zstream_queue_t *118 zstream_enqueue(zstream_queue_t *queue, queue_item_t *item);131 zstream_dequeue(zstream_queue_t *queue, queue_item_t *item);139 zstream_queue_fini(zstream_queue_t *queue);
55 zstream_queue_t *wc_in_queue;56 zstream_queue_t *wc_out_queue;208 zstream_queue_t *queue; in zstream_chain_exec()
108 zstream_queue_t *qr_queue;