Function test_drop

dpdk/app/test/test_dispatcher.c:897–944

}

static int
test_drop(void)
{
	int rc;
	uint8_t unhandled_queue;
	struct rte_dispatcher_stats stats;

	unhandled_queue = (uint8_t)rte_rand_max(NUM_QUEUES);

	rc = test_app_start(test_app);
	if (rc != TEST_SUCCESS)
		return rc;

	rc = test_app_unregister_callback(test_app, unhandled_queue);
	if (rc != TEST_SUCCESS)
		return rc;

	struct rte_event event = {
	    .queue_id = unhandled_queue,
	    .flow_id = 0,
	    .sched_type = RTE_SCHED_TYPE_ATOMIC,
	    .op = RTE_EVENT_OP_NEW,
	    .priority = RTE_EVENT_DEV_PRIORITY_NORMAL,
	    .u64 = 0
	};

	do {
		rc = rte_event_enqueue_burst(test_app->event_dev_id,
					     DRIVER_PORT_ID, &event, 1);
	} while (rc == 0);

	do {
		rte_dispatcher_stats_get(test_app->dispatcher, &stats);

		rte_event_maintain(test_app->event_dev_id, DRIVER_PORT_ID, 0);
	} while (stats.ev_drop_count == 0 && stats.ev_dispatch_count == 0);

	rc = test_app_stop(test_app);
	if (rc != TEST_SUCCESS)
		return rc;

	TEST_ASSERT_EQUAL(stats.ev_drop_count, 1, "Drop count is not one");
	TEST_ASSERT_EQUAL(stats.ev_dispatch_count, 0,
			  "Dispatch count is not zero");
	TEST_ASSERT(stats.poll_count > 0, "Poll count is zero");

	return TEST_SUCCESS;
}

#define MORE_THAN_MAX_HANDLERS 1000
#define MIN_HANDLERS 32