Function test_basic

dpdk/app/test/test_dispatcher.c:795–895

}

static int
test_basic(void)
{
	int rc;
	int i;

	rc = test_app_start(test_app);
	if (rc != TEST_SUCCESS)
		return rc;

	uint64_t sns[NUM_FLOWS] = { 0 };

	for (i = 0; i < NUM_EVENTS;) {
		struct rte_event events[ENQUEUE_BURST_SIZE];
		int left;
		int batch_size;
		int j;
		uint16_t n = 0;

		batch_size = 1 + rte_rand_max(ENQUEUE_BURST_SIZE);
		left = NUM_EVENTS - i;

		batch_size = RTE_MIN(left, batch_size);

		for (j = 0; j < batch_size; j++) {
			struct rte_event *event = &events[j];
			uint64_t sn;
			uint32_t flow_id;

			flow_id = rte_rand_max(NUM_FLOWS);

			sn = sns[flow_id]++;

			*event = (struct rte_event) {
				.queue_id = 0,
				.flow_id = flow_id,
				.sched_type = RTE_SCHED_TYPE_ATOMIC,
				.op = RTE_EVENT_OP_NEW,
				.priority = RTE_EVENT_DEV_PRIORITY_NORMAL,
				.u64 = sn
			};
		}

		while (n < batch_size)
			n += rte_event_enqueue_new_burst(test_app->event_dev_id,
							 DRIVER_PORT_ID,
							 events + n,
							 batch_size - n);

		i += batch_size;
	}

	while (test_app_get_completed_events(test_app) != NUM_EVENTS)
		rte_event_maintain(test_app->event_dev_id, DRIVER_PORT_ID, 0);

	rc = test_app_get_errors(test_app);
	TEST_ASSERT(rc == 0, "%d errors occurred", rc);