13 order_queue_process_stage_0(struct rte_event *const ev)  in order_queue_process_stage_0()  argument
15 	ev->queue_id = 1; /* q1 atomic queue */  in order_queue_process_stage_0()
16 	ev->op = RTE_EVENT_OP_FORWARD;  in order_queue_process_stage_0()
17 	ev->sched_type = RTE_SCHED_TYPE_ATOMIC;  in order_queue_process_stage_0()
18 	ev->event_type = RTE_EVENT_TYPE_CPU;  in order_queue_process_stage_0()
25 	struct rte_event ev;  in order_queue_worker()  local
29 					&ev, 1, 0);  in order_queue_worker()
38 			order_flow_id_copy_from_mbuf(t, &ev);  in order_queue_worker()
40 		if (ev.queue_id == 0) { /* from ordered queue */  in order_queue_worker()
41 			order_queue_process_stage_0(&ev);  in order_queue_worker()
42 			while (rte_event_enqueue_burst(dev_id, port, &ev, 1)  in order_queue_worker()
45 		} else if (ev.queue_id == 1) { /* from atomic queue */  in order_queue_worker()
46 			order_process_stage_1(t, &ev, nb_flows,  in order_queue_worker()
49 			order_process_stage_invalid(t, &ev);  in order_queue_worker()
59 	struct rte_event ev[BURST_SIZE];  in order_queue_worker_burst()  local
63 		uint16_t const nb_rx = rte_event_dequeue_burst(dev_id, port, ev,  in order_queue_worker_burst()
76 				order_flow_id_copy_from_mbuf(t, &ev[i]);  in order_queue_worker_burst()
78 			if (ev[i].queue_id == 0) { /* from ordered queue */  in order_queue_worker_burst()
79 				order_queue_process_stage_0(&ev[i]);  in order_queue_worker_burst()
80 			} else if (ev[i].queue_id == 1) {/* from atomic queue */  in order_queue_worker_burst()
81 				order_process_stage_1(t, &ev[i], nb_flows,  in order_queue_worker_burst()
83 				ev[i].op = RTE_EVENT_OP_RELEASE;  in order_queue_worker_burst()
85 				order_process_stage_invalid(t, &ev[i]);  in order_queue_worker_burst()
91 		enq = rte_event_enqueue_burst(dev_id, port, ev, nb_rx);  in order_queue_worker_burst()
94 							ev + enq, nb_rx - enq);  in order_queue_worker_burst()