Function test21

dpdk/app/test/test_lpm.c:1487–1564

* rte_lpm_rcu_qsbr_add sync mode functional test. * 1 Reader and 1 writer. They cannot be in the same thread in this test. * - Create LPM which supports 1 tbl8 group at max * - Add RCU QSBR variable with sync mode to LPM * - Register a reader thread. Reader keeps looking up a specific rule. * - Writer keeps adding and deleting a specific rule with depth=28 (> 24) */

 *  - Writer keeps adding and deleting a specific rule with depth=28 (> 24)
 */
int32_t
test21(void)
{
	struct rte_lpm_config config;
	size_t sz;
	int32_t status;
	uint32_t i, next_hop;
	uint8_t depth;
	struct rte_lpm_rcu_config rcu_cfg = {0};

	if (rte_lcore_count() < 2) {
		printf("Not enough cores for %s, expecting at least 2\n",
			__func__);
		return TEST_SKIPPED;
	}

	config.max_rules = MAX_RULES;
	config.number_tbl8s = 1;
	config.flags = 0;

	g_lpm = rte_lpm_create(__func__, SOCKET_ID_ANY, &config);
	TEST_LPM_ASSERT(g_lpm != NULL);

	/* Create RCU QSBR variable */
	sz = rte_rcu_qsbr_get_memsize(1);
	g_v = (struct rte_rcu_qsbr *)rte_zmalloc_socket(NULL, sz,
				RTE_CACHE_LINE_SIZE, SOCKET_ID_ANY);
	TEST_LPM_ASSERT(g_v != NULL);

	status = rte_rcu_qsbr_init(g_v, 1);
	TEST_LPM_ASSERT(status == 0);

	rcu_cfg.v = g_v;
	rcu_cfg.mode = RTE_LPM_QSBR_MODE_SYNC;
	/* Attach RCU QSBR to LPM table */
	status = rte_lpm_rcu_qsbr_add(g_lpm, &rcu_cfg);
	TEST_LPM_ASSERT(status == 0);

	writer_done = 0;
	/* Launch reader thread */
	rte_eal_remote_launch(test_lpm_rcu_qsbr_reader, NULL,
				rte_get_next_lcore(-1, 1, 0));

	depth = 28;
	next_hop = 1;
	status = rte_lpm_add(g_lpm, g_ip, depth, next_hop);
	if (status != 0) {
		printf("%s: Failed to add rule\n", __func__);
		goto error;
	}

	/* Writer update */
	for (i = 0; i < WRITER_ITERATIONS; i++) {
		status = rte_lpm_delete(g_lpm, g_ip, depth);
		if (status != 0) {
			printf("%s: Failed to delete rule at iteration %d\n",
				__func__, i);
			goto error;