Function worker_loopback

dpdk/drivers/event/sw/sw_evdev_selftest.c:3189–3303

}

static int
worker_loopback(struct test *t, uint8_t disable_implicit_release)
{
	/* use a single producer core, and a worker core to see what happens
	 * if the worker loops packets back multiple times
	 */
	struct test_event_dev_stats stats;
	uint64_t print_cycles = 0, cycles = 0;
	uint64_t tx_pkts = 0;
	int err;
	int w_lcore, p_lcore;

	static const struct rte_mbuf_dynfield counter_dynfield_desc = {
		.name = "rte_event_sw_dynfield_selftest_counter",
		.size = sizeof(counter_dynfield_t),
		.align = __alignof__(counter_dynfield_t),
	};
	counter_dynfield_offset =
		rte_mbuf_dynfield_register(&counter_dynfield_desc);
	if (counter_dynfield_offset < 0) {
		printf("Error registering mbuf field\n");
		return -rte_errno;
	}

	if (init(t, 8, 2) < 0 ||
			create_atomic_qids(t, 8) < 0) {
		printf("%d: Error initializing device\n", __LINE__);
		return -1;
	}

	/* RX with low max events */
	static struct rte_event_port_conf conf = {
			.dequeue_depth = 32,
			.enqueue_depth = 64,
	};
	/* beware: this cannot be initialized in the static above as it would
	 * only be initialized once - and this needs to be set for multiple runs
	 */
	conf.new_event_threshold = 512;
	conf.event_port_cfg = disable_implicit_release ?
		RTE_EVENT_PORT_CFG_DISABLE_IMPL_REL : 0;

	if (rte_event_port_setup(evdev, 0, &conf) < 0) {
		printf("Error setting up RX port\n");
		return -1;
	}
	t->port[0] = 0;
	/* TX with higher max events */
	conf.new_event_threshold = 4096;
	if (rte_event_port_setup(evdev, 1, &conf) < 0) {
		printf("Error setting up TX port\n");
		return -1;
	}
	t->port[1] = 1;

	/* CQ mapping to QID */
	err = rte_event_port_link(evdev, t->port[1], NULL, NULL, 0);
	if (err != 8) { /* should have mapped all queues*/