Function main

dpdk/examples/distributor/main.c:769–1027

Main function, does initialization and calls the per-lcore functions */

/* Main function, does initialization and calls the per-lcore functions */
int
main(int argc, char *argv[])
{
	struct rte_mempool *mbuf_pool;
	struct rte_distributor *d;
	struct rte_ring *dist_tx_ring;
	struct rte_ring *rx_dist_ring;
	struct rte_power_core_capabilities lcore_cap;
	unsigned int lcore_id, worker_id = 0;
	int distr_core_id = -1, rx_core_id = -1, tx_core_id = -1;
	unsigned nb_ports;
	unsigned int min_cores;
	uint16_t portid;
	uint16_t nb_ports_available;
	uint64_t t, freq;

	/* catch ctrl-c so we can print on exit */
	signal(SIGINT, int_handler);

	/* init EAL */
	int ret = rte_eal_init(argc, argv);
	if (ret < 0)
		rte_exit(EXIT_FAILURE, "Error with EAL initialization\n");
	argc -= ret;
	argv += ret;

	/* parse application arguments (after the EAL ones) */
	ret = parse_args(argc, argv);
	if (ret < 0)
		rte_exit(EXIT_FAILURE, "Invalid distributor parameters\n");

	if (enable_lcore_rx_distributor) {
	/* RX and distributor combined, 3 fixed function cores (stat, TX, at least 1 worker) */
		min_cores = 4;
		num_workers = rte_lcore_count() - 3;
	} else {
	/* separate RX and distributor, 3 fixed function cores (stat, TX, at least 1 worker) */
		min_cores = 5;
		num_workers = rte_lcore_count() - 4;
	}

	if (rte_lcore_count() < min_cores)
		rte_exit(EXIT_FAILURE, "Error, This application needs at "
				"least 4 logical cores to run:\n"
				"1 lcore for stats (can be core 0)\n"
				"1 or 2 lcore for packet RX and distribution\n"
				"1 lcore for packet TX\n"
				"and at least 1 lcore for worker threads\n");

	if (init_power_library() == 0)
		power_lib_initialised = 1;

	nb_ports = rte_eth_dev_count_avail();
	if (nb_ports == 0)
		rte_exit(EXIT_FAILURE, "Error: no ethernet ports detected\n");
	if (nb_ports != 1 && (nb_ports & 1))
		rte_exit(EXIT_FAILURE, "Error: number of ports must be even, except "
				"when using a single port\n");