Function ordered_atomic_hist_completion

dpdk/drivers/event/sw/sw_evdev_selftest.c:2962–3086

}

static int
ordered_atomic_hist_completion(struct test *t)
{
	const int rx_enq = 0;
	int err;

	/* Create instance with 1 atomic QID going to 3 ports + 1 prod port */
	if (init(t, 2, 2) < 0 ||
			create_ports(t, 2) < 0 ||
			create_ordered_qids(t, 1) < 0 ||
			create_atomic_qids(t, 1) < 0)
		return -1;

	/* Helpers to identify queues */
	const uint8_t qid_ordered = t->qid[0];
	const uint8_t qid_atomic = t->qid[1];

	/* CQ mapping to QID */
	if (rte_event_port_link(evdev, t->port[1], &t->qid[0], NULL, 1) != 1) {
		printf("%d: error mapping port 1 qid\n", __LINE__);
		return -1;
	}
	if (rte_event_port_link(evdev, t->port[1], &t->qid[1], NULL, 1) != 1) {
		printf("%d: error mapping port 1 qid\n", __LINE__);
		return -1;
	}
	if (rte_event_dev_start(evdev) < 0) {
		printf("%d: Error with start call\n", __LINE__);
		return -1;
	}

	/* Enqueue 1x ordered event, to be RELEASE-ed by the worker
	 * CPU, which may cause hist-list corruption (by not comleting)
	 */
	struct rte_event ord_ev = {
		.op = RTE_EVENT_OP_NEW,
		.queue_id = qid_ordered,
		.event_type = RTE_EVENT_TYPE_CPU,
		.priority = RTE_EVENT_DEV_PRIORITY_NORMAL,
	};
	err = rte_event_enqueue_burst(evdev, t->port[rx_enq], &ord_ev, 1);
	if (err != 1) {
		printf("%d: Failed to enqueue\n", __LINE__);
		return -1;
	}

	/* call the scheduler. This schedules the above event as a single
	 * event in an ORDERED queue, to the worker.
	 */
	rte_service_run_iter_on_app_lcore(t->service_id, 1);

	/* Dequeue ORDERED event 0 from port 1, so that we can then drop */
	struct rte_event ev;
	if (!rte_event_dequeue_burst(evdev, t->port[1], &ev, 1, 0)) {
		printf("%d: failed to dequeue\n", __LINE__);
		return -1;
	}