Lines Matching refs:queue_id
35 ev.queue_id++; in pipeline_queue_worker_single_stage_tx()
58 ev.queue_id = tx_queue[ev.mbuf->port]; in pipeline_queue_worker_single_stage_fwd()
89 ev[i].queue_id++; in pipeline_queue_worker_single_stage_burst_tx()
118 ev[i].queue_id = tx_queue[ev[i].mbuf->port]; in pipeline_queue_worker_single_stage_burst_fwd()
145 cq_id = ev.queue_id % nb_stages; in pipeline_queue_worker_multi_stage_tx()
147 if (ev.queue_id == tx_queue[ev.mbuf->port]) { in pipeline_queue_worker_multi_stage_tx()
153 ev.queue_id++; in pipeline_queue_worker_multi_stage_tx()
177 cq_id = ev.queue_id % nb_stages; in pipeline_queue_worker_multi_stage_fwd()
180 ev.queue_id = tx_queue[ev.mbuf->port]; in pipeline_queue_worker_multi_stage_fwd()
185 ev.queue_id++; in pipeline_queue_worker_multi_stage_fwd()
212 cq_id = ev[i].queue_id % nb_stages; in pipeline_queue_worker_multi_stage_burst_tx()
214 if (ev[i].queue_id == tx_queue[ev[i].mbuf->port]) { in pipeline_queue_worker_multi_stage_burst_tx()
221 ev[i].queue_id++; in pipeline_queue_worker_multi_stage_burst_tx()
250 cq_id = ev[i].queue_id % nb_stages; in pipeline_queue_worker_multi_stage_burst_fwd()
253 ev[i].queue_id = tx_queue[ev[i].mbuf->port]; in pipeline_queue_worker_multi_stage_burst_fwd()
259 ev[i].queue_id++; in pipeline_queue_worker_multi_stage_burst_fwd()