Searched refs:zq_params (Results 1 – 1 of 1) sorted by relevance
46 #define Q_MOD(queue, index) ((index) % (queue)->zq_params.qp_queue_length)50 (queue)->zq_params.qp_queue_length)147 zq_params_t zq_params; member303 .zq_params = *params, in zstream_queue_create()416 uint64_t open_slots = queue->zq_params.qp_queue_length - in_queue; in score_queue()489 more_budget = cost_claimed < queue->zq_params.qp_batch_budget; in claim_batch()490 first_and_only = queue->zq_params.qp_batch_budget == 0 && in claim_batch()591 queue->zq_params.qp_process; in queue_worker()592 void *context = queue->zq_params.qp_context; in queue_worker()692 queue->zq_params.qp_cost(item, queue->zq_params.qp_context); in zstream_enqueue()[all …]