Function timer_stress2_main_loop

dpdk/app/test/test_timer.c:271–396

#define NB_STRESS2_TIMERS 8192

static int
timer_stress2_main_loop(__rte_unused void *arg)
{
	static struct rte_timer *timers;
	int i, ret;
	uint64_t delay = rte_get_timer_hz() / 20;
	unsigned int lcore_id = rte_lcore_id();
	unsigned int main_lcore = rte_get_main_lcore();
	int32_t my_collisions = 0;
	static uint32_t collisions;

	if (lcore_id == main_lcore) {
		cb_count = 0;
		test_failed = 0;
		__atomic_store_n(&collisions, 0, __ATOMIC_RELAXED);
		timers = rte_malloc(NULL, sizeof(*timers) * NB_STRESS2_TIMERS, 0);
		if (timers == NULL) {
			printf("Test Failed\n");
			printf("- Cannot allocate memory for timers\n" );
			test_failed = 1;
			main_start_workers();
			goto cleanup;
		}
		for (i = 0; i < NB_STRESS2_TIMERS; i++)
			rte_timer_init(&timers[i]);
		main_start_workers();
	} else {
		worker_wait_to_start();
		if (test_failed)
			goto cleanup;
	}

	/* have all cores schedule all timers on main lcore */
	for (i = 0; i < NB_STRESS2_TIMERS; i++) {
		ret = rte_timer_reset(&timers[i], delay, SINGLE, main_lcore,
				timer_stress2_cb, NULL);
		/* there will be collisions when multiple cores simultaneously
		 * configure the same timers */
		if (ret != 0)
			my_collisions++;
	}
	if (my_collisions != 0)
		__atomic_fetch_add(&collisions, my_collisions, __ATOMIC_RELAXED);

	/* wait long enough for timers to expire */
	rte_delay_ms(100);

	/* all cores rendezvous */
	if (lcore_id == main_lcore) {
		main_wait_for_workers();
	} else {
		worker_finish();
	}

	/* now check that we get the right number of callbacks */
	if (lcore_id == main_lcore) {
		my_collisions = __atomic_load_n(&collisions, __ATOMIC_RELAXED);
		if (my_collisions != 0)