main.c

/* SPDX-License-Identifier: Apache-2.0
 * Copyright(c) 2017 Intel Corporation
 */

#include <unistd.h>
#include <locale.h>
#include <signal.h>

#include <rte_ip.h>
#include <rte_udp.h>
#include <rte_common.h>
#include <rte_ether.h>
#include <rte_mbuf.h>
#include <rte_branch_prediction.h>

#include "main.h"
#include "interface.h"
#include "cdr.h"
#include "session_cdr.h"
#include "master_cdr.h"

/**
 * Main function.
 */
int main(int argc, char **argv)
{
	int ret;

	/* Initialize the Environment Abstraction Layer */
	ret = rte_eal_init(argc, argv);
	if (ret < 0)
		rte_exit(EXIT_FAILURE, "Error with EAL initialization\n");

	if (signal(SIGINT, sig_handler) == SIG_ERR)
		rte_exit(EXIT_FAILURE, "Error:can't catch SIGINT\n");
	if (signal(SIGSEGV, sig_handler) == SIG_ERR)
		rte_exit(EXIT_FAILURE, "Error:can't catch SIGSEGV\n");
	argc -= ret;
	argv += ret;

	/* DP Init */
	dp_init(argc, argv);

#ifndef PERF_TEST
	/* Add support for dpdk-18.02 */
	/* enable DP log level */
	if (app.log_level == DEBUG) {
		/*Enable DEBUG log level*/
		rte_log_set_level(RTE_LOGTYPE_DP, RTE_LOG_DEBUG);
		rte_log_set_level(RTE_LOGTYPE_KNI, RTE_LOG_DEBUG);
		rte_log_set_level(RTE_LOGTYPE_API, RTE_LOG_DEBUG);
		rte_log_set_level(RTE_LOGTYPE_EPC, RTE_LOG_DEBUG);
		RTE_LOG_DP(DEBUG, DP, "LOG_LEVEL=LOG_DEBUG::"
				"\n\trte_log_get_global_level()= %u\n\n",
				rte_log_get_global_level());
	} else if (app.log_level == NOTICE) {
		/*Enable NOTICE log level*/
		rte_log_set_global_level(RTE_LOG_NOTICE);
		printf("LOG_LEVEL=LOG_NOTICE::"
				"\n\trte_log_get_global_level()= %u\n\n",
				rte_log_get_global_level());
	} else {
		/*Enable INFO log level*/
		rte_log_set_global_level(RTE_LOG_INFO);
		printf("LOG_LEVEL=LOG_INFO::"
				"\n\trte_log_get_global_level()= %u\n\n",
				rte_log_get_global_level());
	}
#endif

	/* Initialize DP PORTS and membufs */
	dp_port_init();

#ifdef DP_DDN
	/* Init Downlink data notification ring, container and mempool  */
	dp_ddn_init();
#endif

	switch (app.spgw_cfg) {
		case SGWU:
			/**
			 *UE <--S1U-->[SGW]<--S5/8-->[PGW]<--SGi-->
			 */
			RTE_LOG_DP(INFO, DP, "SPGW_CFG=SGWU::"
					"\n\tWEST_PORT=S1U <> EAST_PORT=S5/S8\n");
			/* Pipeline Init */
			epc_init_packet_framework(app.s5s8_sgwu_port,
					app.s1u_port);
#ifdef NGCORE_SHRINK
			/*S1U port handler*/
			register_ul_worker(s1u_pkt_handler, app.s1u_port);
			/*S5/8 port handler*/
			register_dl_worker(sgw_s5_s8_pkt_handler, app.s5s8_sgwu_port);
#else
			/*S1U port handler*/
			register_worker(s1u_pkt_handler, app.s1u_port);

			/*S5/8 port handler*/
			register_worker(sgw_s5_s8_pkt_handler, app.s5s8_sgwu_port);
#endif	/* NGCORE_SHRINK */
			break;

		case PGWU:
			/**
			 *UE <--S1U-->[SGW]<--S5/8-->[PGW]<--SGi-->
			 */
			RTE_LOG_DP(INFO, DP, "SPGW_CFG=PGWU::"
					"\n\tWEST_PORT=S5/S8 <> EAST_PORT=SGi\n");
			/* Pipeline Init */
			epc_init_packet_framework(app.sgi_port, app.s5s8_pgwu_port);
#ifdef NGCORE_SHRINK
			/*S5/8 port handler*/
			register_ul_worker(pgw_s5_s8_pkt_handler, app.s5s8_pgwu_port);
			/*SGi port handler*/
			register_dl_worker(sgi_pkt_handler, app.sgi_port);
#else
			/*S5/8 port handler*/
			register_worker(pgw_s5_s8_pkt_handler, app.s5s8_pgwu_port);

			/*SGi port handler*/
			register_worker(sgi_pkt_handler, app.sgi_port);
			break;
#endif	/* NGCORE_SHRINK */

		case SPGWU:
			/**
			 * UE <--S1U--> [SPGW] <--SGi-->
			 */
			RTE_LOG_DP(INFO, DP, "SPGW_CFG=SPGWU::"
					"\n\tWEST_PORT=S1U <> EAST_PORT=SGi\n");
			/* Pipeline Init */
			epc_init_packet_framework(app.sgi_port, app.s1u_port);
#ifdef NGCORE_SHRINK
			/*S1U port handler*/
			register_ul_worker(s1u_pkt_handler, app.s1u_port);
			/*SGi port handler*/
			register_dl_worker(sgi_pkt_handler, app.sgi_port);
#else
			/*S1U port handler*/
			register_worker(s1u_pkt_handler, app.s1u_port);

			/*SGi port handler*/
			register_worker(sgi_pkt_handler, app.sgi_port);
#endif	/* NGCORE_SHRINK */
			break;

		default:
			rte_exit(EXIT_FAILURE, "Invalid DP type(SPGW_CFG).\n");
	}

#ifndef SGX_CDR
	finalize_cur_cdrs(cdr_path);
#endif /* SGX_CDR */

	sess_cdr_init();

#ifdef EXTENDED_CDR
	extended_cdr_init();
#endif /* EXTENDED_CDR */

	iface_module_constructor();
	dp_table_init();

	packet_framework_launch();

	rte_eal_mp_wait_lcore();

	//free_kni_ports();

	return 0;
}