Function test_refcnt_mbuf

dpdk/app/test/test_mbuf.c:1092–1160

#endif

static int
test_refcnt_mbuf(void)
{
#ifdef RTE_MBUF_REFCNT_ATOMIC
	unsigned int main_lcore, worker, tref;
	int ret = -1;
	struct rte_mempool *refcnt_pool = NULL;
	struct rte_ring *refcnt_mbuf_ring = NULL;

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

	printf("starting %s, at %u lcores\n", __func__, rte_lcore_count());

	/* create refcnt pool & ring if they don't exist */

	refcnt_pool = rte_pktmbuf_pool_create(MAKE_STRING(refcnt_pool),
					      REFCNT_MBUF_NUM, 0, 0, 0,
					      SOCKET_ID_ANY);
	if (refcnt_pool == NULL) {
		printf("%s: cannot allocate " MAKE_STRING(refcnt_pool) "\n",
		       __func__);
		return -1;
	}

	refcnt_mbuf_ring = rte_ring_create("refcnt_mbuf_ring",
					   rte_align32pow2(REFCNT_RING_SIZE), SOCKET_ID_ANY,
					   RING_F_SP_ENQ);
	if (refcnt_mbuf_ring == NULL) {
		printf("%s: cannot allocate " MAKE_STRING(refcnt_mbuf_ring)
		       "\n", __func__);
		goto err;
	}

	refcnt_stop_workers = 0;
	memset(refcnt_lcore, 0, sizeof (refcnt_lcore));

	rte_eal_mp_remote_launch(test_refcnt_worker, refcnt_mbuf_ring, SKIP_MAIN);

	test_refcnt_main(refcnt_pool, refcnt_mbuf_ring);

	rte_eal_mp_wait_lcore();

	/* check that we processed all references */
	tref = 0;
	main_lcore = rte_get_main_lcore();

	RTE_LCORE_FOREACH_WORKER(worker)
		tref += refcnt_lcore[worker];

	if (tref != refcnt_lcore[main_lcore])
		rte_panic("referenced mbufs: %u, freed mbufs: %u\n",
			  tref, refcnt_lcore[main_lcore]);

	rte_mempool_dump(stdout, refcnt_pool);
	rte_ring_dump(stdout, refcnt_mbuf_ring);