Function test20

dpdk/app/test/test_lpm.c:1360–1439

* rte_lpm_rcu_qsbr_add DQ mode functional test. * Reader and writer are in the same thread in this test. * - Create LPM which supports 1 tbl8 group at max * - Add RCU QSBR variable to LPM * - Add a rule with depth=28 (> 24) * - Register a reader thread (not a real thread) * - Reader lookup existing rule * - Writer delete the rule * - Reader lookup the rule * - Writer re-add the ru

 *  - Reader lookup the rule
 */
int32_t
test20(void)
{
	struct rte_lpm *lpm = NULL;
	struct rte_lpm_config config;
	size_t sz;
	struct rte_rcu_qsbr *qsv;
	int32_t status;
	uint32_t ip, next_hop, next_hop_return;
	uint8_t depth;
	struct rte_lpm_rcu_config rcu_cfg = {0};

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

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

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

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

	rcu_cfg.v = qsv;
	rcu_cfg.mode = RTE_LPM_QSBR_MODE_DQ;
	/* Attach RCU QSBR to LPM table */
	status = rte_lpm_rcu_qsbr_add(lpm, &rcu_cfg);
	TEST_LPM_ASSERT(status == 0);

	ip = RTE_IPV4(192, 0, 2, 100);
	depth = 28;
	next_hop = 1;
	status = rte_lpm_add(lpm, ip, depth, next_hop);
	TEST_LPM_ASSERT(status == 0);
	TEST_LPM_ASSERT(lpm->tbl24[ip>>8].valid_group);

	/* Register pseudo reader */
	status = rte_rcu_qsbr_thread_register(qsv, 0);
	TEST_LPM_ASSERT(status == 0);
	rte_rcu_qsbr_thread_online(qsv, 0);

	status = rte_lpm_lookup(lpm, ip, &next_hop_return);
	TEST_LPM_ASSERT(status == 0);
	TEST_LPM_ASSERT(next_hop_return == next_hop);

	/* Writer update */
	status = rte_lpm_delete(lpm, ip, depth);
	TEST_LPM_ASSERT(status == 0);
	TEST_LPM_ASSERT(!lpm->tbl24[ip>>8].valid);

	status = rte_lpm_lookup(lpm, ip, &next_hop_return);
	TEST_LPM_ASSERT(status != 0);