Function test_app_process_queue

dpdk/app/test/test_dispatcher.c:341–404

}

static void
test_app_process_queue(uint8_t p_event_dev_id, uint8_t p_event_port_id,
	struct rte_event *in_events, uint16_t num,
	void *cb_data)
{
	struct app_queue *app_queue = cb_data;
	struct test_app *app = container_of(app_queue, struct test_app,
					    queues[app_queue->queue_id]);
	unsigned int lcore_id = rte_lcore_id();
	bool intermediate_queue = app_queue->queue_id != LAST_QUEUE_ID;
	int event_port_id;
	uint16_t i;
	struct rte_event out_events[num];

	event_port_id = test_app_get_worker_port(app, lcore_id);

	if (event_port_id < 0 || p_event_dev_id != app->event_dev_id ||
	    p_event_port_id != event_port_id) {
		test_app_queue_note_error(app);
		return;
	}

	for (i = 0; i < num; i++) {
		const struct rte_event *in_event = &in_events[i];
		struct rte_event *out_event = &out_events[i];
		uint64_t sn = in_event->u64;
		uint64_t expected_sn;

		if (in_event->queue_id != app_queue->queue_id) {
			test_app_queue_note_error(app);
			return;
		}

		expected_sn = app_queue->sn[in_event->flow_id]++;

		if (expected_sn != sn) {
			test_app_queue_note_error(app);
			return;
		}

		if (intermediate_queue)
			*out_event = (struct rte_event) {
				.queue_id = in_event->queue_id + 1,
				.flow_id = in_event->flow_id,
				.sched_type = RTE_SCHED_TYPE_ATOMIC,
				.op = RTE_EVENT_OP_FORWARD,
				.priority = RTE_EVENT_DEV_PRIORITY_NORMAL,
				.u64 = sn
			};
	}

	if (intermediate_queue) {
		uint16_t n = 0;

		do {
			n += rte_event_enqueue_forward_burst(p_event_dev_id,
							     p_event_port_id,
							     out_events + n,